summaryrefslogtreecommitdiff
path: root/sources/protocols/implementations/OnePhaseCommitProtocol.java
diff options
context:
space:
mode:
Diffstat (limited to 'sources/protocols/implementations/OnePhaseCommitProtocol.java')
-rw-r--r--sources/protocols/implementations/OnePhaseCommitProtocol.java12
1 files changed, 9 insertions, 3 deletions
diff --git a/sources/protocols/implementations/OnePhaseCommitProtocol.java b/sources/protocols/implementations/OnePhaseCommitProtocol.java
index cb720f3..cb984d3 100644
--- a/sources/protocols/implementations/OnePhaseCommitProtocol.java
+++ b/sources/protocols/implementations/OnePhaseCommitProtocol.java
@@ -4,7 +4,7 @@
*/
package protocols.implementations;
-import java.util.ArrayList;
+import java.util.Vector;
import protocols.VSProtocol;
import core.VSMessage;
@@ -16,7 +16,6 @@ public class OnePhaseCommitProtocol extends VSProtocol {
private static final long serialVersionUID = 1L;
/* Client variables, coordinator */
- private ArrayList<Integer> peerPids;
/* Server variables, peers */
private boolean ackSent;
@@ -26,7 +25,14 @@ public class OnePhaseCommitProtocol extends VSProtocol {
*/
public OnePhaseCommitProtocol() {
setClassname(getClass().toString());
- initInteger("numProcesses", 0, "Anzahl beteilitger Prozesse");
+
+ /* Can be changed via GUI variables editor of each process */
+ Vector<Integer> vec = new Vector<Integer>();
+ vec.add(2);
+ vec.add(3);
+ vec.add(4);
+
+ initVector("pids", vec, "PIDs beteilitger Prozesse");
}
/* (non-Javadoc)