diff options
| author | Paul Buetow <paul@buetow.org> | 2008-07-24 15:51:46 +0000 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2008-07-24 15:51:46 +0000 |
| commit | 9c0dca93eb39b728cdea40b561fced48a8ee8eed (patch) | |
| tree | 993627f74a0a91cd6484d0ee8b6cc6d285a6ed1d /sources | |
| parent | 5b9d64399b6102d6c7a305c0b19565b71aeff319 (diff) | |
ok
Diffstat (limited to 'sources')
| -rw-r--r-- | sources/protocols/implementations/VSBroadcastSturmProtocol.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/sources/protocols/implementations/VSBroadcastSturmProtocol.java b/sources/protocols/implementations/VSBroadcastSturmProtocol.java index fda052d..4166416 100644 --- a/sources/protocols/implementations/VSBroadcastSturmProtocol.java +++ b/sources/protocols/implementations/VSBroadcastSturmProtocol.java @@ -39,7 +39,7 @@ public class VSBroadcastSturmProtocol extends VSAbstractProtocol { private static final long serialVersionUID = 1L; /** The sent messages. */ - private ArrayList<VSMessage> sentMessages; + private ArrayList<Integer> sentMessages; /** The broadcast count. */ private static int broadcastCount; @@ -50,7 +50,7 @@ public class VSBroadcastSturmProtocol extends VSAbstractProtocol { public VSBroadcastSturmProtocol() { super(VSAbstractProtocol.HAS_ON_CLIENT_START); setClassname(getClass().toString()); - sentMessages = new ArrayList<VSMessage>(); + sentMessages = new ArrayList<Integer>(); } /* (non-Javadoc) @@ -71,7 +71,7 @@ public class VSBroadcastSturmProtocol extends VSAbstractProtocol { public void onClientStart() { VSMessage message = new VSMessage(); message.setInteger("Broadcast", broadcastCount++); - sentMessages.add(message); + sentMessages.add(message.getIntegerObj("Broadcast")); sendMessage(message); } @@ -111,11 +111,11 @@ public class VSBroadcastSturmProtocol extends VSAbstractProtocol { * @see protocols.VSAbstractProtocol#onServerRecv(core.VSMessage) */ public void onServerRecv(VSMessage recvMessage) { - if (!sentMessages.contains(recvMessage)) { + if (!sentMessages.contains(recvMessage.getIntegerObj("Broadcast"))) { VSMessage message = new VSMessage(); message.setInteger("Broadcast", recvMessage.getInteger("Broadcast")); - sentMessages.add(message); + sentMessages.add(message.getIntegerObj("Broadcast")); sendMessage(message); } } |
