From c5fe29038957c3b83cc619e98b37d37c7a325ae9 Mon Sep 17 00:00:00 2001 From: vyzo Date: Tue, 20 Feb 2018 15:10:16 +0200 Subject: [PATCH] reduce gossip amplification; don't send to mesh peers --- gossipsub.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/gossipsub.go b/gossipsub.go index 63dfef3..7efc160 100644 --- a/gossipsub.go +++ b/gossipsub.go @@ -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}) + } } }