summaryrefslogtreecommitdiffstats
path: root/src/swarm/peer/keepalive.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/keepalive.rs
parent8a4e5bab13069a298fa1d8c756e1a6c0bd719dfb (diff)
peers from member list start as unknown
Diffstat (limited to 'src/swarm/peer/keepalive.rs')
-rw-r--r--src/swarm/peer/keepalive.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/swarm/peer/keepalive.rs b/src/swarm/peer/keepalive.rs
index c8a93eb..ea7ade2 100644
--- a/src/swarm/peer/keepalive.rs
+++ b/src/swarm/peer/keepalive.rs
@@ -16,7 +16,7 @@ use tokio::time::Instant;
use tracing::{debug, info, warn};
use super::handshake::ensure_handshake;
-use crate::state::{AppState, Liveness, Standing};
+use crate::state::{AppState, Standing};
use crate::swarm::sync::SyncEvent;
use crate::swarm::topology;
use crate::transport::{self, ParsedMessage};
@@ -139,7 +139,7 @@ pub(crate) async fn local_status(state: &AppState, peer: &str) -> transport::Sta
let syncs_with_you = match state.get_peer_state(peer).await {
Some(peer_state) => {
let peer_state = peer_state.lock().await;
- peer_state.liveness == Liveness::Active
+ !peer_state.liveness.is_dormant()
&& matches!(peer_state.standing, Standing::Member { .. })
&& peer_state.epoch == Some(epoch)
}