From 923b0503c91aa4a9c0bc94489caddf9ac94c5ad8 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Mon, 26 May 2008 22:14:52 +0000 Subject: Two phase commit protocol works. --- sources/protocols/implementations/BerkelyTimeProtocol.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'sources/protocols/implementations/BerkelyTimeProtocol.java') 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 vec = new Vector(); 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); } /** -- cgit v1.2.3