aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-04 05:34:55 +0100
committertv <tv@krebsco.de>2026-11-04 05:34:55 +0100
commit0c0066780fefb96b49c1b51efb63b6cfa37aee12 (patch)
treeaeb96341357bb0604489afdb318168859ef9db42 /src/swarm/peer
parentce6d4f9a56fbf8d162d10c415d5589062e9fbf1f (diff)
overdue sync asked after from then
Diffstat (limited to 'src/swarm/peer')
-rw-r--r--src/swarm/peer/worker.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/swarm/peer/worker.rs b/src/swarm/peer/worker.rs
index dad0870..67213e7 100644
--- a/src/swarm/peer/worker.rs
+++ b/src/swarm/peer/worker.rs
@@ -104,9 +104,9 @@ pub(crate) async fn run_peer_worker(state: AppState) {
if !neighbour {
peer_state.stop_hello_retries(topology::is_listed(&state, peer));
}
- let unanswered = peer_state.take_overdue_sync_reply(now);
- let ask_again = peer_state.take_ask_again_due(&state.timing, now);
- reach_changed |= peer_state.answer_overdue(&state.timing, now)
+ let unanswered = peer_state.take_overdue_sync_reply(&state.timing, now);
+ let ask_again = peer_state.take_ask_again_due(now);
+ reach_changed |= peer_state.answer_overdue(now)
&& crate::swarm::reach::reached_stops_answering(&state, peer);
(became_dormant, keepalive, unanswered, ask_again)
};