From d8a70796945ef3ece866ad16a95aab1e79f01b89 Mon Sep 17 00:00:00 2001 From: Yann Herklotz Date: Tue, 31 Jan 2017 18:21:27 +0000 Subject: Giving real time feedback --- rmi/RMIClient.java | 1 + 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)); -- cgit