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/source.rs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'src/swarm/source.rs') diff --git a/src/swarm/source.rs b/src/swarm/source.rs index 5e428f2..e098dc1 100644 --- a/src/swarm/source.rs +++ b/src/swarm/source.rs @@ -37,7 +37,6 @@ use tracing::{debug, info, warn}; use crate::locks::MutexExt; use crate::state::{AppState, CatchUpSource, PeerState}; -use crate::swarm::sync::SyncEvent; /// How long a clearly closer peer (by round-trip time) gets to claim the source role /// before whoever asks next takes it. @@ -303,7 +302,7 @@ pub(crate) fn finished(state: &AppState, from: &str) { tokio::spawn(async move { let peers: Vec = state.peer_states.read().await.keys().cloned().collect(); for other in peers.into_iter().filter(|other| *other != from) { - let _ = state.sync_events.send(SyncEvent::PeerNeedsSync(other)); + state.request_sync(&other); } }); } @@ -314,7 +313,7 @@ pub(crate) fn resync_everyone(state: &AppState) { tokio::spawn(async move { let peers: Vec = state.peer_states.read().await.keys().cloned().collect(); for other in peers { - let _ = state.sync_events.send(SyncEvent::PeerNeedsSync(other)); + state.request_sync(&other); } }); } -- cgit v1.3.1