summaryrefslogtreecommitdiff
path: root/sources/protocols
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2025-04-15 02:53:19 +0300
committerPaul Buetow <paul@buetow.org>2025-04-15 02:53:19 +0300
commit822c7de49419775fe20c982a302b95987bbac2cf (patch)
tree25f84e977d206fe2d3fddae4238f56b49999ddc1 /sources/protocols
parent53b373ad26ff3f3c1900b9baa0d5366113884ef6 (diff)
more translation into english
Diffstat (limited to 'sources/protocols')
-rw-r--r--sources/protocols/implementations/VSBasicMulticastProtocol.java2
-rw-r--r--sources/protocols/implementations/VSExternalTimeSyncProtocol.java5
-rw-r--r--sources/protocols/implementations/VSReliableMulticastProtocol.java11
-rw-r--r--sources/protocols/implementations/VSTwoPhaseCommitProtocol.java14
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);