BlockQueue: emit peers that are behind/ahead only once, #1388

nimiq · May 22, 2023 · 33e47f9 · 33e47f9
1 parent 88da409
commit 33e47f9
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/consensus/src/sync/live/block_queue/mod.rs b/consensus/src/sync/live/block_queue/mod.rs
@@ -188,8 +188,7 @@ impl<N: Network> BlockQueue<N> {
             );
             self.report_validation_result(pubsub_id, MsgAcceptance::Ignore);
 
-            if self.network.has_peer(peer_id) {
-                self.request_component.take_peer(&peer_id);
+            if self.request_component.take_peer(&peer_id).is_some() {
                 return Some(QueuedBlock::TooFarBehind(block, peer_id));
             }
         } else if parent_known {
@@ -206,8 +205,7 @@ impl<N: Network> BlockQueue<N> {
             );
             self.report_validation_result(pubsub_id, MsgAcceptance::Ignore);
 
-            if self.network.has_peer(peer_id) {
-                self.request_component.take_peer(&peer_id);
+            if self.request_component.take_peer(&peer_id).is_some() {
                 return Some(QueuedBlock::TooFarAhead(block, peer_id));
             }
         } else if self.buffer.len() >= self.config.buffer_max {