From 97a3a4f07cdc8437f73f4270b237e85c7739a6be Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Tue, 27 May 2008 17:23:45 +0000 Subject: client and server variables are now separate in the editor. --- .../implementations/BerkelyTimeProtocol.java | 42 ++++++++++++---------- 1 file changed, 23 insertions(+), 19 deletions(-) (limited to 'sources/protocols/implementations/BerkelyTimeProtocol.java') diff --git a/sources/protocols/implementations/BerkelyTimeProtocol.java b/sources/protocols/implementations/BerkelyTimeProtocol.java index 890221a..d680f41 100644 --- a/sources/protocols/implementations/BerkelyTimeProtocol.java +++ b/sources/protocols/implementations/BerkelyTimeProtocol.java @@ -17,7 +17,12 @@ import java.util.Vector; public class BerkelyTimeProtocol extends VSAbstractProtocol { private static final long serialVersionUID = 1L; - /* Berkely Server variables */ + /** + * Instantiates a new berkely time protocol. + */ + public BerkelyTimeProtocol() { + setClassname(getClass().toString()); + } /** Integer: Process ID, Long: Local time of the process */ private HashMap processTimes = new HashMap(); @@ -34,12 +39,11 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { /** Time the request/response has started */ private long requestTime; - /** - * Instantiates a new berkely time protocol. - */ - public BerkelyTimeProtocol() { - setClassname(getClass().toString()); + /* (non-Javadoc) + * @see events.VSAbstractProtocol#onClientInit() + */ + public void onClientInit() { /* Those prefs are editable through the VSAbstractProtocol VSAbstractEditor GUI. */ Vector vec = new Vector(); vec.add(2); @@ -47,16 +51,10 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { initVector("pids", vec, "PIDs beteiliger Prozesse"); } - /* (non-Javadoc) - * @see events.VSAbstractEvent#onInit() - */ - protected void onInit() { - } - /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onClientReset() */ - protected void onClientReset() { + public void onClientReset() { processTimes.clear(); recvTimes.clear(); realTimesRTT.clear(); @@ -67,7 +65,7 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onClientStart() */ - protected void onClientStart() { + public void onClientStart() { peers.addAll(getVector("pids")); requestTime = process.getTime(); VSMessage message = new VSMessage(); @@ -78,7 +76,7 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onClientRecv(core.VSMessage) */ - protected void onClientRecv(VSMessage recvMessage) { + public void onClientRecv(VSMessage recvMessage) { /* Ignore all protocol messages which are not a response message, e.g. itself */ if (!recvMessage.getBoolean("isResponse")) return; @@ -110,7 +108,7 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onClientSchedule() */ - protected void onClientSchedule() { + public void onClientSchedule() { } /** @@ -150,16 +148,22 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { } } + /* (non-Javadoc) + * @see events.VSAbstractProtocol#onServerInit() + */ + public void onServerInit() { + } + /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onServerReset() */ - protected void onServerReset() { + public void onServerReset() { } /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onServerRecv(core.VSMessage) */ - protected void onServerRecv(VSMessage recvMessage) { + public void onServerRecv(VSMessage recvMessage) { if (recvMessage.getBoolean("isRequest")) { VSMessage message = new VSMessage(); message.setInteger("processID", process.getProcessID()); @@ -184,7 +188,7 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol { /* (non-Javadoc) * @see protocols.VSAbstractProtocol#onServerSchedule() */ - protected void onServerSchedule() { + public void onServerSchedule() { } /* (non-Javadoc) -- cgit v1.2.3