diff options
| author | Paul Buetow <paul@buetow.org> | 2008-05-27 20:13:54 +0000 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2008-05-27 20:13:54 +0000 |
| commit | 23055ca47090021dbf84d05d5e14c8990479bfe1 (patch) | |
| tree | 36edcf38df1569abb3f81f92cf6b6acc1689b714 /sources/protocols/implementations/BerkelyTimeProtocol.java | |
| parent | fae58d2173039e70ad94075d49c0c500e935e454 (diff) | |
onServerStart vs onClientStart works.
Diffstat (limited to 'sources/protocols/implementations/BerkelyTimeProtocol.java')
| -rw-r--r-- | sources/protocols/implementations/BerkelyTimeProtocol.java | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/sources/protocols/implementations/BerkelyTimeProtocol.java b/sources/protocols/implementations/BerkelyTimeProtocol.java index d680f41..ab4c96e 100644 --- a/sources/protocols/implementations/BerkelyTimeProtocol.java +++ b/sources/protocols/implementations/BerkelyTimeProtocol.java @@ -21,6 +21,7 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { * Instantiates a new berkely time protocol. */ public BerkelyTimeProtocol() { + super(VSAbstractProtocol.HAS_ON_SERVER_START); setClassname(getClass().toString()); } @@ -39,11 +40,10 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { /** Time the request/response has started */ private long requestTime; - /* (non-Javadoc) - * @see events.VSAbstractProtocol#onClientInit() + * @see events.VSAbstractProtocol#onServerInit() */ - public void onClientInit() { + public void onServerInit() { /* Those prefs are editable through the VSAbstractProtocol VSAbstractEditor GUI. */ Vector<Integer> vec = new Vector<Integer>(); vec.add(2); @@ -52,9 +52,9 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { } /* (non-Javadoc) - * @see protocols.VSAbstractProtocol#onClientReset() + * @see protocols.VSAbstractProtocol#onServerReset() */ - public void onClientReset() { + public void onServerReset() { processTimes.clear(); recvTimes.clear(); realTimesRTT.clear(); @@ -63,9 +63,9 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { } /* (non-Javadoc) - * @see protocols.VSAbstractProtocol#onClientStart() + * @see protocols.VSAbstractProtocol#onServerStart() */ - public void onClientStart() { + public void onServerStart() { peers.addAll(getVector("pids")); requestTime = process.getTime(); VSMessage message = new VSMessage(); @@ -74,9 +74,9 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { } /* (non-Javadoc) - * @see protocols.VSAbstractProtocol#onClientRecv(core.VSMessage) + * @see protocols.VSAbstractProtocol#onServerRecv(core.VSMessage) */ - public void onClientRecv(VSMessage recvMessage) { + public void onServerRecv(VSMessage recvMessage) { /* Ignore all protocol messages which are not a response message, e.g. itself */ if (!recvMessage.getBoolean("isResponse")) return; @@ -101,14 +101,14 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { /* Tell all other processes what to do in order to justify their times */ sendJustifyRequests(avgTime); /* Start "clean" next time */ - onClientReset(); + onServerReset(); } } /* (non-Javadoc) - * @see protocols.VSAbstractProtocol#onClientSchedule() + * @see protocols.VSAbstractProtocol#onServerSchedule() */ - public void onClientSchedule() { + public void onServerSchedule() { } /** @@ -149,21 +149,21 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { } /* (non-Javadoc) - * @see events.VSAbstractProtocol#onServerInit() + * @see events.VSAbstractProtocol#onClientInit() */ - public void onServerInit() { + public void onClientInit() { } /* (non-Javadoc) - * @see protocols.VSAbstractProtocol#onServerReset() + * @see protocols.VSAbstractProtocol#onClientReset() */ - public void onServerReset() { + public void onClientReset() { } /* (non-Javadoc) - * @see protocols.VSAbstractProtocol#onServerRecv(core.VSMessage) + * @see protocols.VSAbstractProtocol#onClientRecv(core.VSMessage) */ - public void onServerRecv(VSMessage recvMessage) { + public void onClientRecv(VSMessage recvMessage) { if (recvMessage.getBoolean("isRequest")) { VSMessage message = new VSMessage(); message.setInteger("processID", process.getProcessID()); @@ -186,9 +186,9 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { } /* (non-Javadoc) - * @see protocols.VSAbstractProtocol#onServerSchedule() + * @see protocols.VSAbstractProtocol#onClientSchedule() */ - public void onServerSchedule() { + public void onClientSchedule() { } /* (non-Javadoc) |
