ctdo
/
crashtest-r0ket
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

remote: bridge: reject duplicates

This commit is contained in:
schneider 2011-12-15 19:54:56 +01:00
parent e994e7fb24
commit 0a1c959bf9
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tools/game/r0ketrem0te/bridge.py
View File

@ -70,6 +70,7 @@ class Bridge:
self.crc = crcmod.predefined.mkCrcFun('crc-ccitt-false') self.crc = crcmod.predefined.mkCrcFun('crc-ccitt-false')
self.queues = {} self.queues = {}
self.callbacks = [] self.callbacks = []
self.ctrs = {}
self.reader = threading.Thread(target = self.readerThread) self.reader = threading.Thread(target = self.readerThread)
self.reader.daemon = True self.reader.daemon = True
@ -91,6 +92,7 @@ class Bridge:
self.setChannel(channel) self.setChannel(channel)
self.ctr = 0 self.ctr = 0
def registerCallback(self, callback): def registerCallback(self, callback):
if callback not in self.callbacks: if callback not in self.callbacks:
self.callbacks.append(callback) self.callbacks.append(callback)
@ -177,6 +179,8 @@ class Bridge:
if data[-2:] == chr(crc>>8) + chr(crc&0xFF): if data[-2:] == chr(crc>>8) + chr(crc&0xFF):
packet = packets.fromMessage(data) packet = packets.fromMessage(data)
print "received:", packet print "received:", packet
if packet.id in self.ctrs and self.ctrs[packet.id] == packet.ctr:
return
if isinstance(packet,packets.Ack): if isinstance(packet,packets.Ack):
self.ProcessAck(packet) self.ProcessAck(packet)
else: else: