summaryrefslogtreecommitdiff
path: root/sources/protocols/implementations/OnePhaseCommitProtocol.java
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2008-05-26 20:38:01 +0000
committerPaul Buetow <paul@buetow.org>2008-05-26 20:38:01 +0000
commitfaee8241ff7972ceeb622e0793c655f301ef0bd0 (patch)
tree8f8c045a73dd61e3d2ced3ad9882f49f07395a7f /sources/protocols/implementations/OnePhaseCommitProtocol.java
parent230ddbf8753db60f1baa517e4d9a4d08885fac04 (diff)
run astyle
Diffstat (limited to 'sources/protocols/implementations/OnePhaseCommitProtocol.java')
-rw-r--r--sources/protocols/implementations/OnePhaseCommitProtocol.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/sources/protocols/implementations/OnePhaseCommitProtocol.java b/sources/protocols/implementations/OnePhaseCommitProtocol.java
index 3e4ae52..a8d8d75 100644
--- a/sources/protocols/implementations/OnePhaseCommitProtocol.java
+++ b/sources/protocols/implementations/OnePhaseCommitProtocol.java
@@ -86,7 +86,7 @@ public class OnePhaseCommitProtocol extends VSAbstractProtocol {
logg("ACK von Prozess " + pid + " erhalten!");
if (pids.size() == 0)
- logg("ACKs von allen beteiligten Prozessen erhalten!");
+ logg("ACKs von allen beteiligten Prozessen erhalten! Festgeschrieben!");
}
}
@@ -116,6 +116,7 @@ public class OnePhaseCommitProtocol extends VSAbstractProtocol {
message.setInteger("pid", process.getProcessID());
sendMessage(message);
ackSent = true;
+ logg("Festgeschrieben");
}
/* (non-Javadoc)