diff options
| author | tv <tv@krebsco.de> | 2026-11-03 02:00:58 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-03 02:00:58 +0100 |
| commit | adecfcff1a818cb6d80fd8e24412830ef0988e65 (patch) | |
| tree | eca30977e4308db344eeb4231efa8959e3199355 /src/swarm/topology | |
| parent | 02989b6a22a7bbd2151d6a4ea4fe6dddc9f2995b (diff) | |
probe list members
Diffstat (limited to 'src/swarm/topology')
| -rw-r--r-- | src/swarm/topology/mod.rs | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/swarm/topology/mod.rs b/src/swarm/topology/mod.rs index 992c448..e5dacdd 100644 --- a/src/swarm/topology/mod.rs +++ b/src/swarm/topology/mod.rs @@ -113,6 +113,16 @@ pub(crate) fn summary(state: &AppState) -> Option<Summary> { }) } +/// Whether `peer` is in the member list the neighbours were computed from (false until +/// the view is known). +pub(crate) fn is_listed(state: &AppState, peer: &str) -> bool { + state + .neighbours + .read_or_recover() + .as_ref() + .is_some_and(|view| view.members.iter().any(|member| member == peer)) +} + /// Whether we initiate contact with `peer`: HELLOs, keepalives, dormancy checks, sync /// openings. Everyone is a neighbour until the view is known (while joining, or before /// any member registered), so joining works as in a full mesh. We always *answer* |
