diff options
| author | tv <tv@krebsco.de> | 2026-10-31 03:49:56 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 03:49:56 +0100 |
| commit | 43230f03f7b7bd3ed3b4d45c04529ab3527a5ceb (patch) | |
| tree | 974aeda7a385c551ac7f8d4e620d4ca1bce03a36 /src/swarm/peer/keepalive.rs | |
| parent | 67638bbf82a6fd565d65f2e0bcce556bfa8e7875 (diff) | |
unify sync_on predicate
Diffstat (limited to 'src/swarm/peer/keepalive.rs')
| -rw-r--r-- | src/swarm/peer/keepalive.rs | 9 |
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 { |
