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

Remove fanout topic after joining the topic

Browse Source
This commit is contained in:
NIC619 2019-07-22 19:28:07 +08:00
parent 4ab99485a6
commit 67f9edb77d
No known key found for this signature in database
GPG Key ID: 570C35F5C2D51B17
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/gossipsub.py
View File

@ -207,7 +207,8 @@ class GossipSub(IPubsubRouter):
self.mesh[topic].append(peer) self.mesh[topic].append(peer)
await self.emit_graft(topic, peer) await self.emit_graft(topic, peer)
# TODO: Do we remove all peers from fanout[topic]? if topic_in_fanout:
del self.fanout[topic]
async def leave(self, topic): async def leave(self, topic):
# Note: the comments here are the near-exact algorithm description from the spec # Note: the comments here are the near-exact algorithm description from the spec
@ -303,7 +304,7 @@ class GossipSub(IPubsubRouter):
# TODO: there's no way time_since_last_publish gets set anywhere yet # TODO: there's no way time_since_last_publish gets set anywhere yet
if self.time_since_last_publish[topic] > self.time_to_live: if self.time_since_last_publish[topic] > self.time_to_live:
# Remove topic from fanout # Remove topic from fanout
self.fanout.remove(topic) del self.fanout[topic]
self.time_since_last_publish.remove(topic) self.time_since_last_publish.remove(topic)
else: else:
num_fanout_peers_in_topic = len(self.fanout[topic]) num_fanout_peers_in_topic = len(self.fanout[topic])