diff options
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index 567b1ea..22d6600 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -12,7 +12,7 @@ use tokio::sync::mpsc; use tokio::time::Instant; use tracing::{debug, info, trace, warn}; -use crate::state::{AppState, Liveness, PeerMembership, PeerState, PendingOutbound}; +use crate::state::{AppState, Liveness, PeerState, PendingOutbound, Standing}; use crate::swarm::peer::{peer_swarm, send_hello_once}; use crate::transport::{self, ParsedMessage}; @@ -58,7 +58,7 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str, retry_delivery: bool return Ok(()); } - let PeerMembership::Member { swarm_id } = &peer_state.membership else { + let Standing::Member { swarm_id } = &peer_state.standing else { return Ok(()); }; @@ -249,8 +249,8 @@ pub(crate) async fn handle_sync( let needs_hello = { let mut peer_state = peer_state_mutex.lock().await; - match &peer_state.membership { - PeerMembership::Unknown => { + match &peer_state.standing { + Standing::Stranger | Standing::Admitted => { let duplicate = peer_state.pending_inbound_sync.iter().any(|pending| { pending.message == envelope.message && pending.swarm_id == envelope.swarm_id @@ -268,13 +268,13 @@ pub(crate) async fn handle_sync( } true } - PeerMembership::Member { swarm_id } if swarm_id != &envelope.swarm_id => { + Standing::Member { swarm_id } if swarm_id != &envelope.swarm_id => { bail!( "Sync swarm mismatch for peer {peer}: validated_swarm={swarm_id}, envelope_swarm={}", envelope.swarm_id ); } - PeerMembership::Member { .. } => false, + Standing::Member { .. } => false, } }; |
