aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/relay.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-31 04:48:00 +0100
committertv <tv@krebsco.de>2026-10-31 04:48:00 +0100
commit6a8ea0aacd0012f9c1712c05dfa9cf14793eb1c7 (patch)
tree9e0efa915d24cf617c653c5b2e8a7de526b9f562 /src/swarm/relay.rs
parent7705c7faf5c637b95c68c60d782dc564357eccb0 (diff)
unify request_sync logic
Diffstat (limited to 'src/swarm/relay.rs')
-rw-r--r--src/swarm/relay.rs5
1 files changed, 1 insertions, 4 deletions
diff --git a/src/swarm/relay.rs b/src/swarm/relay.rs
index 6172f67..00043f2 100644
--- a/src/swarm/relay.rs
+++ b/src/swarm/relay.rs
@@ -28,7 +28,6 @@ use tracing::debug;
use crate::locks::MutexExt;
use crate::state::{AppState, Standing};
use crate::swarm::peer::send_status;
-use crate::swarm::sync::SyncEvent;
use crate::swarm::topology;
use crate::transport::{self, HeadsSummary};
@@ -183,9 +182,7 @@ pub(crate) async fn pull_if_behind(
peer_state.lock().await.sync.pull_from(theirs);
state.stats.pull_started();
debug!(peer = %peer, "Neighbour has changes we lack; pulling");
- let _ = state
- .sync_events
- .send(SyncEvent::PeerNeedsSync(peer.to_owned()));
+ state.request_sync(peer);
true
}