From 853250918c64a379112fbb20cd9ac4ddf0afcc30 Mon Sep 17 00:00:00 2001 From: Giovanni Petrantoni Date: Wed, 8 Jul 2020 15:45:11 +0900 Subject: [PATCH] wip --- libp2p/protocols/pubsub/gossipsub.nim | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/libp2p/protocols/pubsub/gossipsub.nim b/libp2p/protocols/pubsub/gossipsub.nim index b0806abdf..d743b65de 100644 --- a/libp2p/protocols/pubsub/gossipsub.nim +++ b/libp2p/protocols/pubsub/gossipsub.nim @@ -287,16 +287,15 @@ method handleDisconnect*(g: GossipSub, peer: PubSubPeer) = .set(g.gossipsub.getOrDefault(t).len.int64, labelValues = [t]) for t in toSeq(g.mesh.keys): - if t in g.mesh: - g.mesh[t].excl(peer.id) + g.mesh[t].excl(peer.id) - libp2p_gossipsub_peers_per_topic_mesh + libp2p_gossipsub_peers_per_topic_mesh .set(g.mesh[t].len.int64, labelValues = [t]) - for t in toSeq(g.fanout.keys): - g.fanout[t].excl(peer.id) + for t in toSeq(g.fanout.keys): + g.fanout[t].excl(peer.id) - libp2p_gossipsub_peers_per_topic_fanout + libp2p_gossipsub_peers_per_topic_fanout .set(g.fanout[t].len.int64, labelValues = [t]) method subscribePeer*(p: GossipSub,