summaryrefslogtreecommitdiff
path: root/sources/protocols
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2008-05-17 15:45:11 +0000
committerPaul Buetow <paul@buetow.org>2008-05-17 15:45:11 +0000
commitda1e3f2b0cd5a45f7ecc7e49873fd1f10cbb43c1 (patch)
treea2f3e5371670c70281658f3dabf58602f19954d0 /sources/protocols
parent56e2329351a73e35b36b46190660133368c593fc (diff)
sim.message.own.recv option added.
Diffstat (limited to 'sources/protocols')
-rw-r--r--sources/protocols/BerkelyTimeProtocol.java12
-rw-r--r--sources/protocols/VSRegisteredProtocols.java2
2 files changed, 7 insertions, 7 deletions
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;