aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer/inbound.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-06 04:57:09 +0100
committertv <tv@krebsco.de>2026-11-06 04:57:09 +0100
commit9cf079423c60c15f660a14f07eb9fdcde6c9cb40 (patch)
tree7dc00fd77c184c48db59e7a11ed9c5dcdfcdfab6 /src/swarm/peer/inbound.rs
parent109a77cdd0f2fd479b5b6faf78c288a41d9ae6c7 (diff)
heads heard forget sent
Diffstat (limited to 'src/swarm/peer/inbound.rs')
-rw-r--r--src/swarm/peer/inbound.rs4
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 {