one phase commit

2 files changed, 8 insertions, 3 deletions

diff --git a/sources/protocols/implementations/VSBerkelyTimeProtocol.java b/sources/protocols/implementations/VSBerkelyTimeProtocol.java
index 576c0d0..f432a1f 100644
--- a/sources/protocols/implementations/VSBerkelyTimeProtocol.java
+++ b/sources/protocols/implementations/VSBerkelyTimeProtocol.java
@@ -71,7 +71,7 @@ public class VSBerkelyTimeProtocol extends VSAbstractProtocol {
      */
     public void onServerInit() {
         Vector<Integer> vec = new Vector<Integer>();
-        vec.add(2);
+        vec.add(1);
         vec.add(3);
         initVector("pids", vec, "PIDs beteiliger Prozesse");
     }
diff --git a/sources/protocols/implementations/VSOnePhaseCommitProtocol.java b/sources/protocols/implementations/VSOnePhaseCommitProtocol.java
index 18c20a5..653a098 100644
--- a/sources/protocols/implementations/VSOnePhaseCommitProtocol.java
+++ b/sources/protocols/implementations/VSOnePhaseCommitProtocol.java
@@ -56,7 +56,7 @@ public class VSOnePhaseCommitProtocol extends VSAbstractProtocol {
     public void onServerInit() {
         /* Can be changed via GUI variables editor of each process */
         Vector<Integer> vec = new Vector<Integer>();
-        vec.add(2);
+        vec.add(1);
         vec.add(3);
 
         initVector("pids", vec, "PIDs beteilitger Prozesse");
@@ -109,9 +109,14 @@ public class VSOnePhaseCommitProtocol extends VSAbstractProtocol {
 
             logg("ACK von Prozess " + pid + " erhalten!");
 
-            if (pids.size() == 0)
+            if (pids.size() == 0) {
                 logg("ACKs von allen beteiligten Prozessen erhalten! " +
                      "Festgeschrieben!");
+
+                /* Remove the active schedule which has been created in the
+                   onServerStart method */
+                removeSchedules();
+			}
         }
     }