logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-02-01 03:03:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

reduce gossip amplification; don't send to mesh peers

Browse Source
This commit is contained in:
vyzo 2018-02-20 15:10:16 +02:00 committed by Steven Allen
parent 0e288dc741
commit c5fe290389
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gossipsub.go
View File

@ -373,7 +373,11 @@ func (gs *GossipSubRouter) heartbeat() {
gpeers := gs.getPeers(topic, func(peer.ID) bool { return true })
for _, p := range gpeers[:GossipSubD] {
gs.pushGossip(p, &pb.ControlIHave{TopicID: &topic, MessageIDs: mids})
// skip mesh peers
_, ok := peers[p]
if !ok {
gs.pushGossip(p, &pb.ControlIHave{TopicID: &topic, MessageIDs: mids})
}
}
}