summaryrefslogtreecommitdiff
path: root/sources/protocols/implementations/BerkelyTimeProtocol.java
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2008-05-26 18:53:39 +0000
committerPaul Buetow <paul@buetow.org>2008-05-26 18:53:39 +0000
commit96001873c9ffb6b3ff8866937eb39b8085032705 (patch)
tree2324a48e8087e481c48a566e5613a1b22e1227f1 /sources/protocols/implementations/BerkelyTimeProtocol.java
parent5b50abee94e410586ae92f81e41e4afd5a6fc71c (diff)
VSMessage constructor does not requier the protocol's classname anymore.
Diffstat (limited to 'sources/protocols/implementations/BerkelyTimeProtocol.java')
-rw-r--r--sources/protocols/implementations/BerkelyTimeProtocol.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/sources/protocols/implementations/BerkelyTimeProtocol.java b/sources/protocols/implementations/BerkelyTimeProtocol.java
index 176b2d7..d1a403f 100644
--- a/sources/protocols/implementations/BerkelyTimeProtocol.java
+++ b/sources/protocols/implementations/BerkelyTimeProtocol.java
@@ -70,7 +70,7 @@ public class BerkelyTimeProtocol extends VSProtocol {
peers = new ArrayList<Integer>();
peers.addAll(getVector("processPIDs"));
requestTime = process.getTime();
- VSMessage message = new VSMessage(getClassname());
+ VSMessage message = new VSMessage();
message.setBoolean("isRequest", true);
sendMessage(message);
}
@@ -136,7 +136,7 @@ public class BerkelyTimeProtocol extends VSProtocol {
for (Integer processID : processTimes.keySet()) {
long realProcessTime = realTimesRTT.get(processID).longValue();
long diff = avgTime - realProcessTime;
- VSMessage message = new VSMessage(getClassname());
+ VSMessage message = new VSMessage();
message.setBoolean("isJustify", true);
message.setLong("timeDiff", diff);
message.setInteger("receiverProcessID", processID);
@@ -155,7 +155,7 @@ public class BerkelyTimeProtocol extends VSProtocol {
*/
protected void onServerRecv(VSMessage recvMessage) {
if (recvMessage.getBoolean("isRequest")) {
- VSMessage message = new VSMessage(getClassname());
+ VSMessage message = new VSMessage();
message.setInteger("processID", process.getProcessID());
message.setLong("time", process.getTime());
message.setBoolean("isResponse", true);