StarMirror/py-libp2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix seen messages bug

Browse Source
This commit is contained in:
Stuckinaboot 2019-04-03 00:34:39 -04:00 committed by zixuanzh
parent 9d16aa834d
commit feaa393c5f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
libp2p/pubsub/pubsub.py
View File

@ -86,9 +86,10 @@ class Pubsub():
if rpc_incoming.publish:
# deal with RPC.publish
for message in rpc_incoming.publish:
if message.seqno not in self.seen_messages:
id_in_seen_msgs = (message.seqno, message.from_id)
if id_in_seen_msgs not in self.seen_messages:
should_publish = True
self.seen_messages.append((message.seqno, message.from_id))
self.seen_messages.append(id_in_seen_msgs)
await self.handle_talk(message)
if rpc_incoming.subscriptions: