diff options
Diffstat (limited to 'src/swarm')
| -rw-r--r-- | src/swarm/peer/worker.rs | 6 | ||||
| -rw-r--r-- | src/swarm/reach.rs | 2 |
2 files changed, 4 insertions, 4 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) }; diff --git a/src/swarm/reach.rs b/src/swarm/reach.rs index 5c89d04..8c22ef6 100644 --- a/src/swarm/reach.rs +++ b/src/swarm/reach.rs @@ -50,7 +50,7 @@ async fn measure(state: &AppState) -> Vec<u64> { if peer_state.hello_state == HelloState::Established && !peer_state.liveness.is_dormant() && !peer_state.is_unreachable() - && !peer_state.answer_overdue(&state.timing, now) + && !peer_state.answer_overdue(now) && matches!(peer_state.standing, Standing::Member { .. }) { reached.push(topology::pair_key(&peer)); |