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. --- .../implementations/BroadcastSturmProtocol.java | 48 ++++++++++++++++++++++ 1 file changed, 48 insertions(+) create mode 100644 sources/protocols/implementations/BroadcastSturmProtocol.java (limited to 'sources/protocols/implementations/BroadcastSturmProtocol.java') diff --git a/sources/protocols/implementations/BroadcastSturmProtocol.java b/sources/protocols/implementations/BroadcastSturmProtocol.java new file mode 100644 index 0000000..c68b548 --- /dev/null +++ b/sources/protocols/implementations/BroadcastSturmProtocol.java @@ -0,0 +1,48 @@ +package protocols.implementations; + +import java.util.ArrayList; + +import core.VSMessage; +import prefs.VSPrefs; +import protocols.VSProtocol; + +public class BroadcastSturmProtocol extends VSProtocol { + private ArrayList sentMessages; + private static int broadcastCount; + + protected void onInit() { + setProtocolClassname(getClass().toString()); + sentMessages = new ArrayList(); + } + + protected void onClientReset() { + } + + protected void onClientStart() { + VSMessage message = new VSMessage(getProtocolClassname()); + message.setInteger("Broadcast", broadcastCount++); + sentMessages.add(message); + sendMessage(message); + } + + protected void onClientRecv(VSMessage recvMessage) { + } + + protected void onServerReset() { + sentMessages.clear(); + } + + protected void onServerRecv(VSMessage recvMessage) { + if (!sentMessages.contains(recvMessage)) { + VSMessage message = new VSMessage(getProtocolClassname()); + message.setInteger("Broadcast", recvMessage.getInteger("Broadcast")); + + sentMessages.add(message); + sendMessage(message); + } + } + + public String toString() { + return super.toString(); + } +} -- cgit v1.2.3