aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer/keepalive.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
commit3a4f0c0413f7e4eef5313882a7bcc43193166bbb (patch)
tree898e7d2d958d46b4b918b1d8a84a2210ec8c15bb /src/swarm/peer/keepalive.rs
parent602dcc39ba2f7cd8a3ef1cd9abbaa204d8b13643 (diff)
unify request_sync logic
Diffstat (limited to 'src/swarm/peer/keepalive.rs')
-rw-r--r--src/swarm/peer/keepalive.rs5
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));