From e6fbcdd9f8a5814eb6e82ed493c886c8aac6c545 Mon Sep 17 00:00:00 2001 From: Yann Herklotz Date: Tue, 31 Jan 2017 02:50:42 +0000 Subject: Good transmission on localhost --- rmi/RMIClient.java | 1 - rmi/RMIServer.java | 16 ++++++++++++++-- 2 files changed, 14 insertions(+), 3 deletions(-) diff --git a/rmi/RMIClient.java b/rmi/RMIClient.java index dc086ea..8b9561a 100755 --- a/rmi/RMIClient.java +++ b/rmi/RMIClient.java @@ -43,7 +43,6 @@ public class RMIClient { MessageInfo msg = new MessageInfo(numMessages, i); try { iRMIServer.receiveMessage(msg); - System.out.println("Successfully sent msg: " + Integer.toString(i)); } catch(Exception e) { System.err.println("RMIClient exception:"); e.printStackTrace(); diff --git a/rmi/RMIServer.java b/rmi/RMIServer.java index 458f745..2bbe247 100755 --- a/rmi/RMIServer.java +++ b/rmi/RMIServer.java @@ -28,15 +28,27 @@ public class RMIServer extends UnicastRemoteObject implements RMIServerI { if(msg.messageNum == 1) receivedMessages = new int[msg.totalMessages]; + totalMessages++; + // this may be a better implementations ???? // if(receivedMessages == null) // receivedMessages = new int[msg.totalMessages]; - // TODO: Log receipt of the message - System.out.println("Receieved Message: " + Integer.toString(msg.messageNum) + " out of " + Integer.toString(msg.totalMessages)); + // TODO: Log receipt of the messages + receivedMessages[totalMessages] = msg.messageNum; // TODO: If this is the last expected message, then identify // any missing messages + + if(msg.messageNum == msg.totalMessages) { + for(int i = 0; i < totalMessages + 1; ++i) + System.out.println("Receieved Message: " + Integer.toString(receivedMessages[i]) + " out of " + Integer.toString(msg.totalMessages)); + System.out.println("#######################################"); + System.out.println("Messages received: " + Integer.toString(totalMessages + 1)); + System.out.println("Total messages sent: " + Integer.toString(msg.totalMessages)); + System.out.println("Success rate: " + Double.toString((double)(totalMessages + 1) / (double)(msg.totalMessages) * 100.0) + "%"); + totalMessages = -1; + } } -- cgit