From 6e0a3fc86fcd3df3d0b26469f132602c7dce9c24 Mon Sep 17 00:00:00 2001 From: tv Date: Sat, 31 Oct 2026 04:48:00 +0100 Subject: unify request_sync logic --- src/swarm/peer/worker.rs | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) (limited to 'src/swarm/peer/worker.rs') diff --git a/src/swarm/peer/worker.rs b/src/swarm/peer/worker.rs index f3d0e84..87d2b3c 100644 --- a/src/swarm/peer/worker.rs +++ b/src/swarm/peer/worker.rs @@ -13,7 +13,6 @@ use super::handshake::retry_hello_if_due; use super::keepalive::{send_ping, send_status}; use crate::locks::MutexExt; use crate::state::{AppState, Keepalive}; -use crate::swarm::sync::SyncEvent; use crate::swarm::topology; const PEER_TICK: Duration = Duration::from_millis(500); @@ -69,9 +68,7 @@ pub(crate) async fn run_peer_worker(state: AppState) { if let Some(changes) = unanswered { debug!(peer = %peer, changes, "No answer to our sync message; sending again"); crate::swarm::source::reply_timed_out(&state, peer); - let _ = state - .sync_events - .send(SyncEvent::PeerNeedsSync(peer.clone())); + state.request_sync(peer); } if became_dormant { -- cgit v1.3.1