unify request_sync logic

1 files changed, 1 insertions, 4 deletions

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 {