From 9cf079423c60c15f660a14f07eb9fdcde6c9cb40 Mon Sep 17 00:00:00 2001 From: tv Date: Fri, 6 Nov 2026 04:57:09 +0100 Subject: heads heard forget sent --- src/swarm/peer/inbound.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'src/swarm/peer/inbound.rs') 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 { -- cgit v1.3.1