diff options
| -rwxr-xr-x | rmi/RMIClient.java | 1 | ||||
| -rwxr-xr-x | rmi/RMIServer.java | 6 |
2 files changed, 5 insertions, 2 deletions
diff --git a/rmi/RMIClient.java b/rmi/RMIClient.java index 3312879..7fcd822 100755 --- a/rmi/RMIClient.java +++ b/rmi/RMIClient.java @@ -41,6 +41,7 @@ public class RMIClient { MessageInfo msg = new MessageInfo(numMessages, i);
try {
iRMIServer.receiveMessage(msg);
+ System.out.println("Sent Message: " + Integer.toString(i + 1) + " out of " + Integer.toString(numMessages));
} catch(Exception e) {
System.err.println("RMIClient exception:");
e.printStackTrace();
diff --git a/rmi/RMIServer.java b/rmi/RMIServer.java index ba2cebd..55b5c80 100755 --- a/rmi/RMIServer.java +++ b/rmi/RMIServer.java @@ -33,13 +33,15 @@ public class RMIServer extends UnicastRemoteObject implements RMIServerI { // increment the total messages when a new call is made
totalMessages++;
+ System.out.println("Receieved Message: " + Integer.toString(msg.messageNum + 1) + " out of " + Integer.toString(msg.totalMessages));
+
// buffer the incomming messages
receivedMessages[totalMessages - 1] = msg.messageNum;
// when last expected message was sent, see which ones were lost
if(msg.messageNum == msg.totalMessages - 1) {
- for(int i = 0; i < totalMessages; ++i)
- System.out.println("Receieved Message: " + Integer.toString(receivedMessages[i] + 1) + " out of " + Integer.toString(msg.totalMessages));
+ // for(int i = 0; i < totalMessages; ++i)
+ // System.out.println("Receieved Message: " + Integer.toString(receivedMessages[i] + 1) + " out of " + Integer.toString(msg.totalMessages));
System.out.println("#######################################");
System.out.println("Messages received: " + Integer.toString(totalMessages));
System.out.println("Total messages sent: " + Integer.toString(msg.totalMessages));
|