From 2e0b05c39138e79c49e17a52a01db82237d2a9e2 Mon Sep 17 00:00:00 2001 From: tv Date: Fri, 23 Oct 2026 20:12:25 +0200 Subject: merge sync_reset_at and epoch_unannounced into opening --- src/swarm/sync.rs | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) (limited to 'src/swarm/sync.rs') diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index 91c6eee..1335361 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -63,8 +63,7 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str, retry_delivery: bool }; if !retry_delivery { - let we_open = crate::swarm::pair::leads(state.local_id(), peer); - if let Some(wait) = peer_state.opening_wait(we_open, Instant::now()) { + if let Some(wait) = peer_state.sync.opening_wait(Instant::now()) { trace!( wait_ms = wait.as_millis(), "Leaving the opening sync message to the peer" @@ -149,10 +148,6 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str, retry_delivery: bool .collect(); peer_state.sync.expect_reply(sent, Instant::now()); } - if message.is_some() { - // It carries our epoch. - peer_state.epoch_unannounced = false; - } (epoch, message) }; let Some(message) = message else { -- cgit v1.3.1