/*
 * Author: Wenbing Zhao
 * Last Modified: 11/6/2006
 * For EEC484/584 Project 2
 */

import java.io.*; 
  
public class Bob {
    public static final int RECEIVER_PORT = 9887;
    public static final int SENDER_PORT = 9888;

    public static void main(String args[]) throws Exception { 
	TransportLayer tl = 
	    new TransportLayer(SENDER_PORT, RECEIVER_PORT);
	// Start the transport layer protocol thread
	tl.start();

	int counter = 0;
	byte[] receiveBuffer = new byte[Packet.MAX_PACKET_PAYLOAD]; 
	// exercise the send and recv functionality
	while(true) {
	    String msgToSend = "[Bob]-("+counter+"): It is a nice day indeed.";
	    System.out.println(">>>App:"+msgToSend);
	    while(true) {
		int status = tl.send(msgToSend);
		if(status > 0)
		    break;
	    }

	    for(int i=0; i<2; i++) {
		int len = tl.recv(receiveBuffer);
		byte[] payload = new byte[len];
		for(int j=0; j<len; j++)
		    payload[j] = receiveBuffer[j];
		String msgRecvd = new String(payload);
		System.out.println("<<<App: "+new String(msgRecvd));
	    }
	    counter++;
	} 
    }
}