package fdl.test.transfer.three;

import static org.junit.Assert.*;
import org.junit.Test;


public class TestTransfer {
	Server[] servers;
	ProtocolEngine[] engines;
	final int serverCount = 3;
	final int startPort = 10011;
	@Test
	public void testTransfer() {
		int port = startPort;
		servers = new Server[serverCount];
		engines = new ProtocolEngine[serverCount];
		
		for (int i = 0; i < serverCount; i++) {
			servers[i] = new Server("Server"+(i+1),port+i);
			servers[i].start();
		}
		
		TestSend send = new TestSend(startPort);
		send.start();
		try{
			send.join();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		
		for (int i = 0; i < serverCount; i++) {
			engines[i] = new ProtocolEngine("ProtocolEngine "+(i+1) +":port " +(port+i) +":port "+(netporot(port+i)),port+i,netporot(port+i));
			engines[i].start();
		}
		try {
			for (ProtocolEngine e: engines){
				e.join();
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		assertEquals(1,1);
	}
	private int netporot(int i) {
		i++;
		if(i >= startPort+serverCount) {
			return startPort;
		}
		return i;
	}
}