summaryrefslogtreecommitdiffstats
path: root/src/swarm/peer/handshake.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-28 11:57:54 +0100
committertv <tv@krebsco.de>2026-10-28 11:57:54 +0100
commite13d027567f781c9729a518913b21ec4ee273039 (patch)
treeada25e93f6164e0ce80282616937f19fc8f1aec0 /src/swarm/peer/handshake.rs
parent8a4e5bab13069a298fa1d8c756e1a6c0bd719dfb (diff)
peers from member list start as unknown
Diffstat (limited to 'src/swarm/peer/handshake.rs')
-rw-r--r--src/swarm/peer/handshake.rs4
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)
{