summaryrefslogtreecommitdiff
path: root/sources/protocols/implementations/BerkelyTimeProtocol.java
diff options
context:
space:
mode:
Diffstat (limited to 'sources/protocols/implementations/BerkelyTimeProtocol.java')
-rw-r--r--sources/protocols/implementations/BerkelyTimeProtocol.java42
1 files changed, 23 insertions, 19 deletions
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<Integer,Long> processTimes = new HashMap<Integer,Long>();
@@ -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<Integer> vec = new Vector<Integer>();
vec.add(2);
@@ -48,15 +52,9 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol {
}
/* (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() {
}
/**
@@ -151,15 +149,21 @@ 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)