summaryrefslogtreecommitdiffstats
path: root/src/swarm
diff options
context:
space:
mode:
Diffstat (limited to 'src/swarm')
-rw-r--r--src/swarm/topology.rs8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/swarm/topology.rs b/src/swarm/topology.rs
index bdfeb53..5150e38 100644
--- a/src/swarm/topology.rs
+++ b/src/swarm/topology.rs
@@ -144,9 +144,15 @@ pub(crate) async fn refresh(state: &AppState) -> Option<NeighbourChange> {
(current, stable)
};
let k = state.neighbours_k;
+ // Those that don't answer, and those on none of our transports.
let mut unreachable = BTreeSet::new();
for member in &current {
- if let Some(peer_state) = state.get_peer_state(member).await
+ if member == state.local_id() {
+ continue;
+ }
+ if !state.transport.can_reach(member) {
+ unreachable.insert(member.clone());
+ } else if let Some(peer_state) = state.get_peer_state(member).await
&& peer_state.lock().await.is_unreachable()
{
unreachable.insert(member.clone());