unreachability doesn't expire

1 files changed, 2 insertions, 5 deletions

diff --git a/src/swarm/topology.rs b/src/swarm/topology.rs
index e396a9d..84ae1cd 100644
--- a/src/swarm/topology.rs
+++ b/src/swarm/topology.rs
@@ -20,7 +20,6 @@
 use std::collections::{BTreeMap, BTreeSet};
 
 use sha2::{Digest, Sha256};
-use tokio::time::Instant;
 use tracing::info;
 
 use crate::locks::RwLockExt;
@@ -111,8 +110,7 @@ pub(crate) struct NeighbourChange {
 /// Recomputes the neighbours whenever something they depend on may have changed
 /// (`AppState::topology_changed`): the member list (`swarm::sync::run_change_publisher`),
 /// a peer becoming unreachable or reachable again (`swarm::peer`), and every 5 s as a
-/// fallback, which also covers unreachability expiring after `dormant_probe`. A burst of
-/// notifications coalesces into one recomputation.
+/// fallback. A burst of notifications coalesces into one recomputation.
 pub(crate) async fn run_worker(state: AppState) {
     loop {
         state.topology_changed.notified().await;
@@ -145,11 +143,10 @@ pub(crate) async fn refresh(state: &AppState) -> Option<NeighbourChange> {
         (current, stable)
     };
     let k = state.neighbours_k;
-    let now = Instant::now();
     let mut unreachable = BTreeSet::new();
     for member in &current {
         if let Some(peer_state) = state.get_peer_state(member).await {
-            if peer_state.lock().await.is_unreachable(&state.timing, now) {
+            if peer_state.lock().await.is_unreachable() {
                 unreachable.insert(member.clone());
             }
         }