From a1fd8370f48956dc6084fb9c1e13e5b79ffd5fa9 Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 21 Oct 2026 14:12:01 +0200 Subject: resend sync messages that haven't been replied --- src/swarm/peer.rs | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'src/swarm/peer.rs') diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs index b092b03..6184427 100644 --- a/src/swarm/peer.rs +++ b/src/swarm/peer.rs @@ -387,13 +387,21 @@ pub(crate) async fn run_peer_worker(state: AppState) { for (peer, peer_state_mutex) in &peers { let now = Instant::now(); - let (became_dormant, ping_due) = { + let (became_dormant, ping_due, unanswered) = { let mut peer_state = peer_state_mutex.lock().await; let became_dormant = ready && peer_state.check_dormancy(&state.timing, now); let ping_due = peer_state.take_keepalive_due(&state.timing, now); - (became_dormant, ping_due) + let unanswered = peer_state.take_overdue_sync_reply(now); + (became_dormant, ping_due, unanswered) }; + if let Some(changes) = unanswered { + debug!(peer = %peer, changes, "No answer to our sync message; sending again"); + let _ = state + .sync_events + .send(SyncEvent::PeerNeedsSync(peer.clone())); + } + if became_dormant { warn!( peer = %peer, -- cgit v1.3.1