diff options
| author | tv <tv@krebsco.de> | 2026-11-06 04:57:09 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-06 04:57:09 +0100 |
| commit | 9cf079423c60c15f660a14f07eb9fdcde6c9cb40 (patch) | |
| tree | 7dc00fd77c184c48db59e7a11ed9c5dcdfcdfab6 /src/swarm/peer/inbound.rs | |
| parent | 109a77cdd0f2fd479b5b6faf78c288a41d9ae6c7 (diff) | |
heads heard forget sent
Diffstat (limited to 'src/swarm/peer/inbound.rs')
| -rw-r--r-- | src/swarm/peer/inbound.rs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/swarm/peer/inbound.rs b/src/swarm/peer/inbound.rs index 1542d4f..8a424b8 100644 --- a/src/swarm/peer/inbound.rs +++ b/src/swarm/peer/inbound.rs @@ -12,7 +12,8 @@ use super::handshake::{ discover_peers, ensure_handshake, establish_peer, peer_swarm, remember_peer, send_hello_reply, }; use super::keepalive::{ - heal_if_diverged, heard_from, local_status, note_alive, note_status, status_received, + heal_if_diverged, heard_from, heard_heads, local_status, note_alive, note_status, + status_received, }; use super::lanes::SyncLanes; use crate::locks::MutexExt; @@ -199,6 +200,7 @@ pub(crate) async fn handle_message( // no reason, as changes on their way to us make them differ while writes go on. if !remote.announcing { status_received(state, &peer).await; + heard_heads(state, &peer, &remote); } let local = on_status(state, &peer, &remote, reactivated).await; if remote.announcing { |
