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 | 3a4f0c0413f7e4eef5313882a7bcc43193166bbb (patch) | |
| tree | 898e7d2d958d46b4b918b1d8a84a2210ec8c15bb /src/swarm/peer/keepalive.rs | |
| parent | 602dcc39ba2f7cd8a3ef1cd9abbaa204d8b13643 (diff) | |
unify request_sync logic
Diffstat (limited to 'src/swarm/peer/keepalive.rs')
| -rw-r--r-- | src/swarm/peer/keepalive.rs | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/swarm/peer/keepalive.rs b/src/swarm/peer/keepalive.rs index 0e80980..40b8ed3 100644 --- a/src/swarm/peer/keepalive.rs +++ b/src/swarm/peer/keepalive.rs @@ -17,7 +17,6 @@ use tracing::{debug, info, warn}; use super::handshake::ensure_handshake; use crate::state::{AppState, PeerState}; -use crate::swarm::sync::SyncEvent; use crate::swarm::topology; use crate::transport::{self, ParsedMessage}; @@ -214,9 +213,7 @@ pub(super) async fn note_status(state: &AppState, peer: &str, remote: &transport if became_ready { // We may have left the opening to it while it wasn't ready, and nothing else // would make us look again. - let _ = state - .sync_events - .send(SyncEvent::PeerNeedsSync(peer.to_owned())); + state.request_sync(peer); } } crate::swarm::source::reported(state, peer, remote.ready, Some(remote.syncs_with_you)); |
