PipedInputStream win = null;
PipedOutputStream wout = null;
PipedInputStream bin = null;
PipedOutputStream bout = null;
System.out.println("Building piped streams...");
try {
win = new PipedInputStream();
bin = new PipedInputStream();
wout = new PipedOutputStream(bin);
bout = new PipedOutputStream(win);
}
catch (IOException e) {
System.out.println("Failed to create streams.");
System.exit(1);
}
System.out.println("Building chess servers...");
ChessServer white = new ChessServer(win, wout);
ChessServer black = new ChessServer(bin, bout);
Thread whiteThr = new Thread(white);
Thread blackThr = new Thread(black);
String from = "x";
String to = "x";
int checkFlag = ChessPlayer.NO_CHECK;
if (white.getPlayer().nextMove(from, to, checkFlag)) {
try {
System.out.println("Sending first message...");
white.sendMsg(new MoveMessage(from, to, checkFlag));
}
catch (IOException e) {
System.out.println("Failed sending first message.");
}
try {
if (black.readMsg() != null)
System.out.println("Black got it...");
else
System.out.println("Black didn't get it...");
}
catch (IOException e) {
System.out.println("Failed reading message...");
}
}
else {
System.out.println("White didn't come up with a starting move.");
System.exit(1);
}
System.out.println("Starting threads...");
whiteThr.start();
blackThr.start();
System.out.println("Waiting for threads to die...");
while (whiteThr.isAlive() && blackThr.isAlive()) {}
