diff options
| author | Paul Buetow <paul@buetow.org> | 2008-08-13 16:07:15 +0000 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2008-08-13 16:07:15 +0000 |
| commit | efff967bb744b0697592e6108cb227baa58e9885 (patch) | |
| tree | 9677c0ab8d95babc561068f42a73589273f01ff9 /sources/protocols/implementations | |
| parent | 5bf750ce5d254cc85790adefccbff78277019353 (diff) | |
all line lengths <= 80
Diffstat (limited to 'sources/protocols/implementations')
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); |
