diff options
| author | tv <tv@krebsco.de> | 2026-10-28 11:57:54 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-28 11:57:54 +0100 |
| commit | e13d027567f781c9729a518913b21ec4ee273039 (patch) | |
| tree | ada25e93f6164e0ce80282616937f19fc8f1aec0 /src/swarm/peer/handshake.rs | |
| parent | 8a4e5bab13069a298fa1d8c756e1a6c0bd719dfb (diff) | |
peers from member list start as unknown
Diffstat (limited to 'src/swarm/peer/handshake.rs')
| -rw-r--r-- | src/swarm/peer/handshake.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/swarm/peer/handshake.rs b/src/swarm/peer/handshake.rs index 1183db1..fbebfc6 100644 --- a/src/swarm/peer/handshake.rs +++ b/src/swarm/peer/handshake.rs @@ -9,7 +9,7 @@ use tokio::sync::Mutex; use tokio::time::Instant; use tracing::{debug, info, instrument, trace, warn}; -use crate::state::{AppState, HelloState, Liveness, PeerState, Standing}; +use crate::state::{AppState, HelloState, PeerState, Standing}; use crate::swarm::sync::SyncEvent; use crate::swarm::topology; use crate::transport::{self, ParsedMessage}; @@ -199,7 +199,7 @@ pub(super) async fn send_hello_reply( let mut peers = Vec::new(); for (known, peer_state_mutex) in candidates { let peer_state = peer_state_mutex.lock().await; - if peer_state.liveness == Liveness::Active + if !peer_state.liveness.is_dormant() && peer_state.hello_state == HelloState::Established && topology::is_neighbour(state, &known) { |
