aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-01 23:08:21 +0100
committertv <tv@krebsco.de>2026-11-01 23:08:21 +0100
commitbc8e3afcd3eeb567661aa39d9d4cd6da1c57b29c (patch)
tree37d4277a21249889e99a0b0368435f8f7bb3b4cf /src
parent7b80ee727153798898f4432a6dbd678ff74df4ca (diff)
probe wakes peer worker
Diffstat (limited to 'src')
-rw-r--r--src/swarm/peer/handshake.rs5
1 files changed, 3 insertions, 2 deletions
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,