aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-31 03:49:56 +0100
committertv <tv@krebsco.de>2026-10-31 03:49:56 +0100
commit43230f03f7b7bd3ed3b4d45c04529ab3527a5ceb (patch)
tree974aeda7a385c551ac7f8d4e620d4ca1bce03a36 /src/swarm
parent67638bbf82a6fd565d65f2e0bcce556bfa8e7875 (diff)
unify sync_on predicate
Diffstat (limited to 'src/swarm')
-rw-r--r--src/swarm/peer/keepalive.rs9
1 files changed, 2 insertions, 7 deletions
diff --git a/src/swarm/peer/keepalive.rs b/src/swarm/peer/keepalive.rs
index 367b1d9..4b529f5 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, Standing};
+use crate::state::AppState;
use crate::swarm::sync::SyncEvent;
use crate::swarm::topology;
use crate::transport::{self, ParsedMessage};
@@ -138,12 +138,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.is_dormant()
- && matches!(peer_state.standing, Standing::Member { .. })
- && peer_state.epoch == Some(epoch)
- }
+ Some(peer_state) => peer_state.lock().await.syncs_on(epoch),
None => false,
};
transport::Status {