remove pending gossip and control messages on RemovePeer

2018-02-20 18:23:28 +02:00 · 2018-02-20 18:23:28 +02:00 · 64cdbbabbc
parent bd29e81e3a
commit 64cdbbabbc
1 changed files with 2 additions and 0 deletions
--- a/gossipsub.go
+++ b/gossipsub.go
@ -68,6 +68,8 @@ func (gs *GossipSubRouter) RemovePeer(p peer.ID) {
 	for _, peers := range gs.fanout {
 		delete(peers, p)
 	}
+	delete(gs.gossip, p)
+	delete(gs.control, p)
 }

 func (gs *GossipSubRouter) HandleRPC(rpc *RPC) {