Cleanup filtered messages (#4082)

arkpar · gavofyork · commit 223960f1f136 · 2019-11-11T11:34:23.000+01:00
diff --git a/core/network/src/protocol/consensus_gossip.rs b/core/network/src/protocol/consensus_gossip.rs
@@ -448,6 +448,7 @@ impl<B: BlockT> ConsensusGossip<B> {
 
 		for (_, ref mut peer) in self.peers.iter_mut() {
 			peer.known_messages.retain(|h| known_messages.contains_key(h));
+			peer.filtered_messages.retain(|h, _| known_messages.contains_key(h));
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -448,6 +448,7 @@ impl<B: BlockT> ConsensusGossip<B> {`
`448`	`448`
`449`	`449`	`for (_, ref mut peer) in self.peers.iter_mut() {`
`450`	`450`	`peer.known_messages.retain(\|h\| known_messages.contains_key(h));`
	`451`	`+ peer.filtered_messages.retain(\|h, _\| known_messages.contains_key(h));`
`451`	`452`	`}`
`452`	`453`	`}`
`453`	`454`