diff options
| author | tv <tv@krebsco.de> | 2026-10-28 03:07:30 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-28 03:07:30 +0100 |
| commit | becffeb2c78b0e2e17eabf5060de2f2056710ff1 (patch) | |
| tree | a391ef741a382dbebc02156b3a89e29818ef7544 /src/swarm/peer/inbound.rs | |
| parent | b88be3ea1b475b1a656298b98708026388eaf2af (diff) | |
keepalive takes turns
Diffstat (limited to 'src/swarm/peer/inbound.rs')
| -rw-r--r-- | src/swarm/peer/inbound.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/swarm/peer/inbound.rs b/src/swarm/peer/inbound.rs index 0eaefb9..2e89739 100644 --- a/src/swarm/peer/inbound.rs +++ b/src/swarm/peer/inbound.rs @@ -11,7 +11,7 @@ use super::epoch::observe_peer_epoch; use super::handshake::{ discover_peers, ensure_handshake, establish_peer, peer_swarm, remember_peer, send_hello_reply, }; -use super::keepalive::{heal_if_diverged, local_status, note_alive, note_status}; +use super::keepalive::{heal_if_diverged, local_status, note_alive, note_status, status_received}; use super::lanes::SyncLanes; use crate::state::AppState; use crate::swarm::sync::SyncEvent; @@ -149,6 +149,7 @@ pub(crate) async fn handle_message( crate::swarm::blob::handle(state, &peer, blob).await; } transport::ParsedMessage::Status(remote) => { + status_received(state, &peer).await; let local = on_status(state, &peer, &remote, reactivated).await; if let Err(error) = state .transport |
