summaryrefslogtreecommitdiff
path: root/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java
diff options
context:
space:
mode:
Diffstat (limited to 'sources/protocols/implementations/VSTwoPhaseCommitProtocol.java')
-rw-r--r--sources/protocols/implementations/VSTwoPhaseCommitProtocol.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java b/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java
index b783b53..2a0a4f2 100644
--- a/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java
+++ b/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java
@@ -129,14 +129,14 @@ public class VSTwoPhaseCommitProtocol extends VSAbstractProtocol {
boolean vote = recvMessage.getBoolean("vote");
log("Abstimmung von Prozess " + pid +
- " erhalten! Ergebnis: " + vote);
+ " erhalten! Ergebnis: " + vote);
if (!vote)
voteResult = false;
if (votePids.size() == 0) {
log("Abstimmungen von allen beteiligten Prozessen " +
- "erhalten! Globales Ergebnis: " + voteResult);
+ "erhalten! Globales Ergebnis: " + voteResult);
/* Remove the active schedule which has been created in the
onServerStart method */
@@ -207,7 +207,7 @@ public class VSTwoPhaseCommitProtocol extends VSAbstractProtocol {
} else if (recvMessage.getBoolean("isVoteResult")) {
boolean voteResult = recvMessage.getBoolean("voteResult");
log("Globales Abstimmungsergebnis erhalten. Ergebnis: " +
- voteResult);
+ voteResult);
VSMessage message = new VSMessage();
message.setBoolean("isAck", true);