diff options
| author | tv <tv@krebsco.de> | 2026-10-26 17:50:58 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 17:50:58 +0100 |
| commit | e13cbc232b2438caac834f3573a42349517ff0c0 (patch) | |
| tree | 82267fbb1456834273ed2f15240bdbfc5c997b56 /src/swarm/peer | |
| parent | 71fa578f7853e92817ca75f2763f22bbb5de9df1 (diff) | |
unreachability doesn't expire
Diffstat (limited to 'src/swarm/peer')
| -rw-r--r-- | src/swarm/peer/handshake.rs | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/swarm/peer/handshake.rs b/src/swarm/peer/handshake.rs index f89e371..f08929a 100644 --- a/src/swarm/peer/handshake.rs +++ b/src/swarm/peer/handshake.rs @@ -150,10 +150,7 @@ async fn transmit_hello(state: &AppState, peer: &str) -> Result<()> { if !was_unreachable && peer_state.unreachable_since.is_some() { state.topology_changed.notify_one(); } - let wait = match peer_state.liveness { - Liveness::Dormant { .. } => state.timing.dormant_probe, - Liveness::Active => peer_state.hello_backoff.next(), - }; + let wait = peer_state.next_hello_wait(); peer_state.hello_state = HelloState::AwaitingReply { next_attempt: Instant::now() + wait, }; |
