summaryrefslogtreecommitdiff
path: root/sources/protocols/implementations
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2008-07-24 15:51:46 +0000
committerPaul Buetow <paul@buetow.org>2008-07-24 15:51:46 +0000
commit9c0dca93eb39b728cdea40b561fced48a8ee8eed (patch)
tree993627f74a0a91cd6484d0ee8b6cc6d285a6ed1d /sources/protocols/implementations
parent5b9d64399b6102d6c7a305c0b19565b71aeff319 (diff)
ok
Diffstat (limited to 'sources/protocols/implementations')
-rw-r--r--sources/protocols/implementations/VSBroadcastSturmProtocol.java10
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);
}
}