From da1e3f2b0cd5a45f7ecc7e49873fd1f10cbb43c1 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Sat, 17 May 2008 15:45:11 +0000 Subject: sim.message.own.recv option added. --- sources/protocols/BerkelyTimeProtocol.java | 12 ++++++------ sources/protocols/VSRegisteredProtocols.java | 2 +- 2 files changed, 7 insertions(+), 7 deletions(-) (limited to 'sources/protocols') diff --git a/sources/protocols/BerkelyTimeProtocol.java b/sources/protocols/BerkelyTimeProtocol.java index ea81cba..2e1166e 100644 --- a/sources/protocols/BerkelyTimeProtocol.java +++ b/sources/protocols/BerkelyTimeProtocol.java @@ -57,8 +57,8 @@ public class BerkelyTimeProtocol extends VSProtocol { process.setTime(avgTime); /* Tell all other processes what to do in order to justify their times */ sendJustifyRequests(avgTime); - /* Start "clean" next time */ - onClientReset(); + /* Start "clean" next time */ + onClientReset(); } } @@ -91,7 +91,7 @@ public class BerkelyTimeProtocol extends VSProtocol { message.setBoolean("isJustify", true); message.setLong("timeDiff", diff); message.setInteger("receiverProcessID", processID); - sendMessage(message); + sendMessage(message); } } @@ -104,17 +104,17 @@ public class BerkelyTimeProtocol extends VSProtocol { message.setInteger("processID", process.getProcessID()); message.setLong("time", process.getTime()); message.setBoolean("isResponse", true); - sendMessage(message); + sendMessage(message); } else if (recvMessage.getBoolean("isJustify")) { /* Check if it's "my" justify message */ - if (recvMessage.getInteger("receiverProcessID") != process.getProcessID()) + if (recvMessage.getInteger("receiverProcessID") != process.getProcessID()) return; long timeDiff = recvMessage.getLong("timeDiff"); long recvTime = process.getTime(); long newTime = process.getTime() + timeDiff; - logg("Neue Zeit: " + newTime); + logg("Neue Zeit: " + newTime); process.setTime(newTime); } diff --git a/sources/protocols/VSRegisteredProtocols.java b/sources/protocols/VSRegisteredProtocols.java index 5153a07..c152a59 100644 --- a/sources/protocols/VSRegisteredProtocols.java +++ b/sources/protocols/VSRegisteredProtocols.java @@ -51,7 +51,7 @@ public final class VSRegisteredProtocols { if (protocolObj instanceof VSProtocol) { VSProtocol protocol = (VSProtocol) protocolObj; protocol.init(process); - return protocol; + return protocol; } return null; -- cgit v1.2.3