package protocols; import java.util.ArrayList; import prefs.VSPrefs; import core.VSMessage; public class BroadcastSturmProtocol extends VSProtocol { private ArrayList sentMessages; private static int broadcastCount; public BroadcastSturmProtocol() { 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(); } }