varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-10 23:20:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'main' into enhancement/yamuxstream-lock

Browse Source
This commit is contained in:
Manu Sheel Gupta
2025-09-22 02:03:11 +05:30
committed by GitHub
parent 1326592fe2 a01811a435
commit 321bb86ea4
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
libp2p/pubsub/gossipsub.py
View File

@ -308,7 +308,8 @@ class GossipSub(IPubsubRouter, Service):
floodsub_peers: set[ID] = { floodsub_peers: set[ID] = {
peer_id peer_id
for peer_id in self.pubsub.peer_topics[topic] for peer_id in self.pubsub.peer_topics[topic]
if self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID if peer_id in self.peer_protocol
and self.peer_protocol[peer_id] == floodsub.PROTOCOL_ID
} }
send_to.update(floodsub_peers) send_to.update(floodsub_peers)