From 06179a9df971636dd6c5e9f438baa9f133854830 Mon Sep 17 00:00:00 2001 From: tv Date: Tue, 27 Oct 2026 02:02:15 +0100 Subject: add support for several transports --- src/swarm/topology.rs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'src/swarm') 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 { (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 ¤t { - 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()); -- cgit v1.3.1