fix gossip tests

This commit is contained in:
Giovanni Petrantoni 2020-07-09 12:34:36 +09:00
parent 4698f41a91
commit 4bcb567d47
1 changed files with 2 additions and 1 deletions

View File

@ -168,6 +168,7 @@ proc rebalanceMesh(g: GossipSub, topic: string) {.async.} =
# send a graft message to the peer # send a graft message to the peer
await p.sendPrune(@[topic]) await p.sendPrune(@[topic])
g.mesh[topic].excl(id) g.mesh[topic].excl(id)
if topic in g.gossipsub:
g.gossipsub[topic].incl(id) g.gossipsub[topic].incl(id)
libp2p_gossipsub_peers_per_topic_gossipsub libp2p_gossipsub_peers_per_topic_gossipsub