diff --git a/src/peer.rs b/src/peer.rs index 34b7467..33cf6e6 100644 --- a/src/peer.rs +++ b/src/peer.rs @@ -32,18 +32,6 @@ impl PeerProcessor { sender.clone(), )); - let processing_for_logging = processing.clone(); - tokio::spawn(async move { - loop { - sleep(std::time::Duration::from_secs(10)).await; - let processing_len = processing_for_logging.len(); - - if processing_len > 0 { - info!("Pending peers: {}", processing_len); - } - } - }); - Self { sender, processing } } @@ -181,14 +169,13 @@ pub async fn start_peer_rechecker( .await; let reachable_peer_count = authority.get_reachable_peer_count(); + let processing_len = processor.processing.len(); info!( - "Starting periodic peer recheck, {} reachable peers", - reachable_peer_count, + "Starting periodic peer recheck, {} reachable peers, {} pending peers", + reachable_peer_count, processing_len ); - let processing_len = processor.processing.len(); - if processing_len < PEER_RECHECK_BATCH_SIZE { for peer in expired_peers { processor.process(peer).await;