From 7c58f3d8bfa87cfbc6c89ae34780e81b5ff47e0d Mon Sep 17 00:00:00 2001 From: tv Date: Sun, 1 Nov 2026 23:08:21 +0100 Subject: probe wakes peer worker --- src/swarm/peer/handshake.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'src/swarm') diff --git a/src/swarm/peer/handshake.rs b/src/swarm/peer/handshake.rs index 896ffdf..6bd4784 100644 --- a/src/swarm/peer/handshake.rs +++ b/src/swarm/peer/handshake.rs @@ -305,8 +305,8 @@ pub(super) async fn discover_peers( } /// Brings `peer`'s next probe forward to now, if it is a member we can't reach (dormant, -/// or unanswered HELLOs) whose probe is pending: the peer worker sends it (its next -/// tick). Whether it was. +/// or unanswered HELLOs) whose probe is pending: the peer worker sends it (woken for +/// it). Whether it was. async fn probe_now(state: &AppState, peer: &str) -> bool { let Some(peer_state) = state.get_peer_state(peer).await else { return false; @@ -320,6 +320,7 @@ async fn probe_now(state: &AppState, peer: &str) -> bool { match &mut peer_state.hello_state { HelloState::AwaitingReply { next_attempt } => { *next_attempt = Instant::now(); + state.peers_due.now(); true } _ => false, -- cgit v1.3.1