From 30ac208bac5acb677b2359a3f21f028b5b10a2b3 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Sat, 17 May 2008 15:55:43 +0000 Subject: renamed the package. --- sources/protocols/ExternalTimeSyncProtocol.java | 62 ------------------------- 1 file changed, 62 deletions(-) delete mode 100644 sources/protocols/ExternalTimeSyncProtocol.java (limited to 'sources/protocols/ExternalTimeSyncProtocol.java') diff --git a/sources/protocols/ExternalTimeSyncProtocol.java b/sources/protocols/ExternalTimeSyncProtocol.java deleted file mode 100644 index b6ee73f..0000000 --- a/sources/protocols/ExternalTimeSyncProtocol.java +++ /dev/null @@ -1,62 +0,0 @@ -package protocols; - -import prefs.VSPrefs; -import core.VSMessage; - -public class ExternalTimeSyncProtocol extends VSProtocol { - private long requestTime; - private boolean waitingForResponse; - - protected void onInit() { - setProtocolClassname(getClass().toString()); - } - - protected void onClientReset() { - } - - protected void onClientStart() { - requestTime = process.getTime(); - waitingForResponse = true; - - /* Multicast message to all processes */ - VSMessage message = new VSMessage(getProtocolClassname()); - message.setBoolean("isClientRequest", true); - sendMessage(message); - } - - protected void onClientRecv(VSMessage recvMessage) { - if (!recvMessage.getBoolean("isServerResponse")) - return; - - if (waitingForResponse) - waitingForResponse = false; - else - return; - - long recvTime = process.getTime(); - long roundTripTime = recvTime - requestTime; - long serverTime = recvMessage.getLong("time"); - long newTime = serverTime + (long) (roundTripTime / 2); - - logg("Server Zeit: " + serverTime + "; RTT: " + roundTripTime + "; Alte Zeit: " + recvTime + "; Neue Zeit: " + newTime + "; Offset: " + (newTime - recvTime)); - process.setTime(newTime); - } - - protected void onServerReset() { - } - - protected void onServerRecv(VSMessage recvMessage) { - if (!recvMessage.getBoolean("isClientRequest")) - return; - - /* Multicast message to all processes */ - VSMessage message = new VSMessage(getProtocolClassname()); - message.setLong("time", process.getTime()); - message.setBoolean("isServerResponse", true); - sendMessage(message); - } - - public String toString() { - return super.toString(); //+ "; " + prefs.getString("lang.requesttime") + ": " + requestTime; - } -} -- cgit v1.2.3