From 8fd9c3e2980eb5720033584ac3cd2d156b5c9d63 Mon Sep 17 00:00:00 2001
From: Paul Buetow <paul@buetow.org>
Date: Mon, 26 May 2008 19:44:51 +0000
Subject: new onClientSchedule and onServerSchedule abstract methods

---
 sources/protocols/implementations/BerkelyTimeProtocol.java   | 12 ++++++++++++
 .../protocols/implementations/BroadcastSturmProtocol.java    | 12 ++++++++++++
 sources/protocols/implementations/DummyProtocol.java         | 12 ++++++++++++
 .../protocols/implementations/ExternalTimeSyncProtocol.java  | 12 ++++++++++++
 .../protocols/implementations/InternalTimeSyncProtocol.java  | 12 ++++++++++++
 .../protocols/implementations/OnePhaseCommitProtocol.java    | 12 ++++++++++++
 sources/protocols/implementations/PingPongProtocol.java      | 12 ++++++++++++
 .../protocols/implementations/TwoPhaseCommitProtocol.java    | 12 ++++++++++++
 8 files changed, 96 insertions(+)

(limited to 'sources/protocols/implementations')

diff --git a/sources/protocols/implementations/BerkelyTimeProtocol.java b/sources/protocols/implementations/BerkelyTimeProtocol.java
index 9a52c4c..635b1cd 100644
--- a/sources/protocols/implementations/BerkelyTimeProtocol.java
+++ b/sources/protocols/implementations/BerkelyTimeProtocol.java
@@ -107,6 +107,12 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol {
         }
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /**
      * Calculate the new average time.
      *
@@ -175,6 +181,12 @@ public class BerkelyTimeProtocol extends VSAbstractProtocol {
         }
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#toString()
      */
diff --git a/sources/protocols/implementations/BroadcastSturmProtocol.java b/sources/protocols/implementations/BroadcastSturmProtocol.java
index 49e183d..cfd258c 100644
--- a/sources/protocols/implementations/BroadcastSturmProtocol.java
+++ b/sources/protocols/implementations/BroadcastSturmProtocol.java
@@ -58,6 +58,12 @@ public class BroadcastSturmProtocol extends VSAbstractProtocol {
     protected void onClientRecv(VSMessage recvMessage) {
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerReset()
      */
@@ -65,6 +71,12 @@ public class BroadcastSturmProtocol extends VSAbstractProtocol {
         sentMessages.clear();
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerRecv(core.VSMessage)
      */
diff --git a/sources/protocols/implementations/DummyProtocol.java b/sources/protocols/implementations/DummyProtocol.java
index 929ace4..684de87 100644
--- a/sources/protocols/implementations/DummyProtocol.java
+++ b/sources/protocols/implementations/DummyProtocol.java
@@ -60,6 +60,12 @@ public class DummyProtocol extends VSAbstractProtocol {
         float f = recvMessage.getFloat("A float");
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerReset()
      */
@@ -74,6 +80,12 @@ public class DummyProtocol extends VSAbstractProtocol {
         logg("onServerRecv("+recvMessage+")");
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#toString()
      */
diff --git a/sources/protocols/implementations/ExternalTimeSyncProtocol.java b/sources/protocols/implementations/ExternalTimeSyncProtocol.java
index 3430f98..243418a 100644
--- a/sources/protocols/implementations/ExternalTimeSyncProtocol.java
+++ b/sources/protocols/implementations/ExternalTimeSyncProtocol.java
@@ -73,6 +73,12 @@ public class ExternalTimeSyncProtocol extends VSAbstractProtocol {
         process.setTime(newTime);
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerReset()
      */
@@ -93,6 +99,12 @@ public class ExternalTimeSyncProtocol extends VSAbstractProtocol {
         sendMessage(message);
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#toString()
      */
diff --git a/sources/protocols/implementations/InternalTimeSyncProtocol.java b/sources/protocols/implementations/InternalTimeSyncProtocol.java
index 5676d58..5b18740 100644
--- a/sources/protocols/implementations/InternalTimeSyncProtocol.java
+++ b/sources/protocols/implementations/InternalTimeSyncProtocol.java
@@ -77,6 +77,12 @@ public class InternalTimeSyncProtocol extends VSAbstractProtocol {
         process.setTime(newTime);
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerReset()
      */
@@ -98,6 +104,12 @@ public class InternalTimeSyncProtocol extends VSAbstractProtocol {
         sendMessage(message);
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#toString()
      */
diff --git a/sources/protocols/implementations/OnePhaseCommitProtocol.java b/sources/protocols/implementations/OnePhaseCommitProtocol.java
index 9c40493..c8dd7f2 100644
--- a/sources/protocols/implementations/OnePhaseCommitProtocol.java
+++ b/sources/protocols/implementations/OnePhaseCommitProtocol.java
@@ -64,6 +64,12 @@ public class OnePhaseCommitProtocol extends VSAbstractProtocol {
 
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerReset()
      */
@@ -77,6 +83,12 @@ public class OnePhaseCommitProtocol extends VSAbstractProtocol {
     protected void onServerRecv(VSMessage recvMessage) {
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#toString()
      */
diff --git a/sources/protocols/implementations/PingPongProtocol.java b/sources/protocols/implementations/PingPongProtocol.java
index 167feb6..4082dd3 100644
--- a/sources/protocols/implementations/PingPongProtocol.java
+++ b/sources/protocols/implementations/PingPongProtocol.java
@@ -65,6 +65,12 @@ public class PingPongProtocol extends VSAbstractProtocol {
         sendMessage(message);
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerReset()
      */
@@ -87,6 +93,12 @@ public class PingPongProtocol extends VSAbstractProtocol {
         sendMessage(message);
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#toString()
      */
diff --git a/sources/protocols/implementations/TwoPhaseCommitProtocol.java b/sources/protocols/implementations/TwoPhaseCommitProtocol.java
index db0277c..770c9cd 100644
--- a/sources/protocols/implementations/TwoPhaseCommitProtocol.java
+++ b/sources/protocols/implementations/TwoPhaseCommitProtocol.java
@@ -44,6 +44,12 @@ public class TwoPhaseCommitProtocol extends VSAbstractProtocol {
     protected void onClientRecv(VSMessage recvMessage) {
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onClientSchedule()
+     */
+    protected void onClientSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#onServerReset()
      */
@@ -56,6 +62,12 @@ public class TwoPhaseCommitProtocol extends VSAbstractProtocol {
     protected void onServerRecv(VSMessage recvMessage) {
     }
 
+    /* (non-Javadoc)
+     * @see protocols.VSAbstractProtocol#onServerSchedule()
+     */
+    protected void onServerSchedule() {
+    }
+
     /* (non-Javadoc)
      * @see protocols.VSAbstractProtocol#toString()
      */
-- 
cgit v1.2.3