summaryrefslogtreecommitdiff
path: root/sources/protocols
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2008-08-13 16:07:15 +0000
committerPaul Buetow <paul@buetow.org>2008-08-13 16:07:15 +0000
commitefff967bb744b0697592e6108cb227baa58e9885 (patch)
tree9677c0ab8d95babc561068f42a73589273f01ff9 /sources/protocols
parent5bf750ce5d254cc85790adefccbff78277019353 (diff)
all line lengths <= 80
Diffstat (limited to 'sources/protocols')
-rw-r--r--sources/protocols/implementations/VSExternalTimeSyncProtocol.java4
-rw-r--r--sources/protocols/implementations/VSInternalTimeSyncProtocol.java6
-rw-r--r--sources/protocols/implementations/VSOnePhaseCommitProtocol.java2
-rw-r--r--sources/protocols/implementations/VSReliableMulticastProtocol.java2
-rw-r--r--sources/protocols/implementations/VSTwoPhaseCommitProtocol.java6
5 files changed, 10 insertions, 10 deletions
diff --git a/sources/protocols/implementations/VSExternalTimeSyncProtocol.java b/sources/protocols/implementations/VSExternalTimeSyncProtocol.java
index 0e73ac3..3bb5eb9 100644
--- a/sources/protocols/implementations/VSExternalTimeSyncProtocol.java
+++ b/sources/protocols/implementations/VSExternalTimeSyncProtocol.java
@@ -93,8 +93,8 @@ public class VSExternalTimeSyncProtocol extends VSAbstractProtocol {
long newTime = serverTime + (long) (roundTripTime / 2);
log("Server Zeit: " + serverTime + "; RTT: " + roundTripTime +
- "; Alte Zeit: " + recvTime + "; Neue Zeit: " + newTime +
- "; Offset: " + (newTime - recvTime));
+ "; Alte Zeit: " + recvTime + "; Neue Zeit: " + newTime +
+ "; Offset: " + (newTime - recvTime));
process.setTime(newTime);
}
diff --git a/sources/protocols/implementations/VSInternalTimeSyncProtocol.java b/sources/protocols/implementations/VSInternalTimeSyncProtocol.java
index 6f82203..c52b0ed 100644
--- a/sources/protocols/implementations/VSInternalTimeSyncProtocol.java
+++ b/sources/protocols/implementations/VSInternalTimeSyncProtocol.java
@@ -93,9 +93,9 @@ public class VSInternalTimeSyncProtocol extends VSAbstractProtocol {
long newTime = serverTime + (long) ((tMax + tMin) / 2 );
log("Server Zeit: " + serverTime + "; (t_min,t_max): (" + tMin +
- "," + tMax + "); Alte Zeit: " + process.getTime() +
- "; Neue Zeit: " + newTime + "; Offset: " +
- (process.getTime() - newTime));
+ "," + tMax + "); Alte Zeit: " + process.getTime() +
+ "; Neue Zeit: " + newTime + "; Offset: " +
+ (process.getTime() - newTime));
process.setTime(newTime);
}
diff --git a/sources/protocols/implementations/VSOnePhaseCommitProtocol.java b/sources/protocols/implementations/VSOnePhaseCommitProtocol.java
index aa1f6ed..feb4dd5 100644
--- a/sources/protocols/implementations/VSOnePhaseCommitProtocol.java
+++ b/sources/protocols/implementations/VSOnePhaseCommitProtocol.java
@@ -111,7 +111,7 @@ public class VSOnePhaseCommitProtocol extends VSAbstractProtocol {
if (pids.size() == 0) {
log("ACKs von allen beteiligten Prozessen erhalten! " +
- "Festgeschrieben!");
+ "Festgeschrieben!");
/* Remove the active schedule which has been created in the
onServerStart method */
diff --git a/sources/protocols/implementations/VSReliableMulticastProtocol.java b/sources/protocols/implementations/VSReliableMulticastProtocol.java
index 9cfb04c..23f5857 100644
--- a/sources/protocols/implementations/VSReliableMulticastProtocol.java
+++ b/sources/protocols/implementations/VSReliableMulticastProtocol.java
@@ -108,7 +108,7 @@ public class VSReliableMulticastProtocol extends VSAbstractProtocol {
if (pids.size() == 0) {
log("ACKs von allen beteiligten Prozessen " +
- "erhalten!");
+ "erhalten!");
/* Remove the active schedule which has been created in the
onClientStart method */
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);