From 73af710419e86e35231c6d7d5a3406e989a43a19 Mon Sep 17 00:00:00 2001 From: vyzo Date: Thu, 21 Nov 2019 23:13:20 +0200 Subject: [PATCH] protocol ID for gossipsub v1.1 --- gossipsub.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/gossipsub.go b/gossipsub.go index feb5f6c..d747029 100644 --- a/gossipsub.go +++ b/gossipsub.go @@ -98,6 +98,7 @@ type connectInfo struct { func (gs *GossipSubRouter) Protocols() []protocol.ID { return []protocol.ID{GossipSubID_v11, GossipSubID_v10, FloodSubID} + return []protocol.ID{GossipSubID_v11, GossipSubID, FloodSubID} } func (gs *GossipSubRouter) Attach(p *PubSub) { @@ -863,6 +864,7 @@ func (gs *GossipSubRouter) getPeers(topic string, count int, filter func(peer.ID peers := make([]peer.ID, 0, len(tmap)) for p := range tmap { if (gs.peers[p] == GossipSubID_v10 || gs.peers[p] == GossipSubID_v11) && filter(p) { + if (gs.peers[p] == GossipSubID || gs.peers[p] == GossipSubID_v11) && filter(p) { peers = append(peers, p) } }