diff options
| author | tv <tv@krebsco.de> | 2026-10-31 04:48:00 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-31 04:48:00 +0100 |
| commit | 6e0a3fc86fcd3df3d0b26469f132602c7dce9c24 (patch) | |
| tree | c335376b8ce31fe4431ca8b24e35bda827079316 /src/swarm/relay.rs | |
| parent | 89f41e04976a076e40183956db718d558998c0dc (diff) | |
unify request_sync logic
Diffstat (limited to 'src/swarm/relay.rs')
| -rw-r--r-- | src/swarm/relay.rs | 5 |
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 } |
