diff options
| author | Paul Buetow <paul@buetow.org> | 2025-04-15 02:53:19 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2025-04-15 02:53:19 +0300 |
| commit | 822c7de49419775fe20c982a302b95987bbac2cf (patch) | |
| tree | 25f84e977d206fe2d3fddae4238f56b49999ddc1 /sources/protocols/implementations | |
| parent | 53b373ad26ff3f3c1900b9baa0d5366113884ef6 (diff) | |
more translation into english
Diffstat (limited to 'sources/protocols/implementations')
4 files changed, 15 insertions, 17 deletions
diff --git a/sources/protocols/implementations/VSBasicMulticastProtocol.java b/sources/protocols/implementations/VSBasicMulticastProtocol.java index 3172b8f..cfd5399 100644 --- a/sources/protocols/implementations/VSBasicMulticastProtocol.java +++ b/sources/protocols/implementations/VSBasicMulticastProtocol.java @@ -68,7 +68,7 @@ public class VSBasicMulticastProtocol extends VSAbstractProtocol { */ public void onServerRecv(VSMessage recvMessage) { if (recvMessage.getBoolean("isMulticast")) - log("Multicast erhalten"); + log("Multicast received"); } /* (non-Javadoc) diff --git a/sources/protocols/implementations/VSExternalTimeSyncProtocol.java b/sources/protocols/implementations/VSExternalTimeSyncProtocol.java index 24128f6..f044861 100644 --- a/sources/protocols/implementations/VSExternalTimeSyncProtocol.java +++ b/sources/protocols/implementations/VSExternalTimeSyncProtocol.java @@ -66,9 +66,8 @@ public class VSExternalTimeSyncProtocol extends VSAbstractProtocol { long serverTime = recvMessage.getLong("time"); long newTime = serverTime + (long) (roundTripTime / 2); - log("Server Zeit: " + serverTime + "; RTT: " + roundTripTime + - "; Alte Zeit: " + recvTime + "; Neue Zeit: " + newTime + - "; Offset: " + (newTime - recvTime)); + log("Server time: " + serverTime + "; RTT: " + roundTripTime + "; Old time: " + recvTime + "; New time: " + newTime + "; Offset: " + (newTime - recvTime)); + process.setTime(newTime); } diff --git a/sources/protocols/implementations/VSReliableMulticastProtocol.java b/sources/protocols/implementations/VSReliableMulticastProtocol.java index e4601ab..170533a 100644 --- a/sources/protocols/implementations/VSReliableMulticastProtocol.java +++ b/sources/protocols/implementations/VSReliableMulticastProtocol.java @@ -78,11 +78,11 @@ public class VSReliableMulticastProtocol extends VSAbstractProtocol { else return; - log("ACK von Prozess " + pid + " erhalten!"); + log("ACK from process " + pid + " received!"); + if (pids.size() == 0) { - log("ACKs von allen beteiligten Prozessen " + - "erhalten!"); + log("ACKs from all involved processes received!"); /* Remove the active schedule which has been created in the onClientStart method */ @@ -125,10 +125,11 @@ public class VSReliableMulticastProtocol extends VSAbstractProtocol { sendMessage(message); if (ackSent) { - log("ACK erneut versendet"); + log("ACK sent again"); } else { - log("ACK versendet"); + log("ACK sent"); + ackSent = true; } } diff --git a/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java b/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java index a98fcf6..8f9e4a3 100644 --- a/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java +++ b/sources/protocols/implementations/VSTwoPhaseCommitProtocol.java @@ -102,15 +102,13 @@ public class VSTwoPhaseCommitProtocol extends VSAbstractProtocol { return; boolean vote = recvMessage.getBoolean("vote"); - log("Abstimmung von Prozess " + pid + - " erhalten! Ergebnis: " + vote); + log("Vote from process " + pid + " received! Result: " + vote); if (!vote) voteResult = false; if (votePids.size() == 0) { - log("Abstimmungen von allen beteiligten Prozessen " + - "erhalten! Globales Ergebnis: " + voteResult); + log("Votes from all involved processes received! Global result: " + voteResult); /* Remove the active schedule which has been created in the onServerStart method */ @@ -130,7 +128,7 @@ public class VSTwoPhaseCommitProtocol extends VSAbstractProtocol { /* Remove the active schedule which has been created in the onServerStart method */ removeSchedules(); - log("Alle Teilnehmer haben die Abstimmung erhalten"); + log("All participants have received the vote"); } } } @@ -176,12 +174,12 @@ public class VSTwoPhaseCommitProtocol extends VSAbstractProtocol { message.setInteger("pid", process.getProcessID()); sendMessage(message); - log("Abstimmung " + myVote + " versendet"); + log("Vote " + myVote + " sent"); + } else if (recvMessage.getBoolean("isVoteResult")) { boolean voteResult = recvMessage.getBoolean("voteResult"); - log("Globales Abstimmungsergebnis erhalten. Ergebnis: " + - voteResult); + log("Global voting result received. Result: " + voteResult); VSMessage message = new VSMessage(); message.setBoolean("isAck", true); |
