diff options
| author | Paul Buetow <paul@buetow.org> | 2008-05-26 22:14:52 +0000 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2008-05-26 22:14:52 +0000 |
| commit | 923b0503c91aa4a9c0bc94489caddf9ac94c5ad8 (patch) | |
| tree | 74bf4a51494085c9ecb107d3facc31bb585669b4 /sources/protocols/implementations/BerkelyTimeProtocol.java | |
| parent | faee8241ff7972ceeb622e0793c655f301ef0bd0 (diff) | |
Two phase commit protocol works.
Diffstat (limited to 'sources/protocols/implementations/BerkelyTimeProtocol.java')
| -rw-r--r-- | sources/protocols/implementations/BerkelyTimeProtocol.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/sources/protocols/implementations/BerkelyTimeProtocol.java b/sources/protocols/implementations/BerkelyTimeProtocol.java index 411a9e8..890221a 100644 --- a/sources/protocols/implementations/BerkelyTimeProtocol.java +++ b/sources/protocols/implementations/BerkelyTimeProtocol.java @@ -44,7 +44,7 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { Vector<Integer> vec = new Vector<Integer>(); vec.add(2); vec.add(3); - initVector("processPIDs", vec, "PIDs beteiliger Prozesse"); + initVector("pids", vec, "PIDs beteiliger Prozesse"); } /* (non-Javadoc) @@ -61,14 +61,14 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { recvTimes.clear(); realTimesRTT.clear(); peers.clear(); - peers.addAll(getVector("processPIDs")); + peers.addAll(getVector("pids")); } /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onClientStart() */ protected void onClientStart() { - peers.addAll(getVector("processPIDs")); + peers.addAll(getVector("pids")); requestTime = process.getTime(); VSMessage message = new VSMessage(); message.setBoolean("isRequest", true); @@ -130,7 +130,7 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { } /* Include the time of the local process */ sum += process.getTime(); - return (long) sum / (getVector("processPIDs").size() + 1); + return (long) sum / (getVector("pids").size() + 1); } /** |
