diff --git a/sync/src/chain.rs b/sync/src/chain.rs index 2f810e754..65fca4069 100644 --- a/sync/src/chain.rs +++ b/sync/src/chain.rs @@ -1850,7 +1850,7 @@ impl ChainSync { /// propagates new transactions to all peers pub fn propagate_new_transactions(&mut self, io: &mut SyncIo) -> usize { - // Early out of nobody to send to. + // Early out if nobody to send to. if self.peers.is_empty() { return 0; } @@ -1948,9 +1948,6 @@ impl ChainSync { trace!(target: "sync", "Bad blocks in the queue, restarting"); self.restart(io); } - for peer_info in self.peers.values_mut() { - peer_info.last_sent_transactions.clear(); - } } }