measure 2-hop neighbourhood

1 files changed, 3 insertions, 3 deletions

diff --git a/src/swarm/relay.rs b/src/swarm/relay.rs
index e11bd69..69d73d3 100644
--- a/src/swarm/relay.rs
+++ b/src/swarm/relay.rs
@@ -122,7 +122,7 @@ async fn announce_now(state: &AppState, senders: &HashSet<String>) {
     }
     state.stats.announce_round();
     for peer in neighbours {
-        if let Err(error) = announce_heads(state, &peer).await {
+        if let Err(error) = announce_heads(state, &peer, false).await {
             debug!(peer = %peer, error = %format!("{error:#}"), "Announcing our heads failed");
         }
     }
@@ -268,7 +268,7 @@ async fn graft(state: &AppState, peer: &str) {
     }
     state.stats.link_grafted();
     debug!(peer = %peer, "Link eager: we want its changes as it applies them");
-    if let Err(error) = announce_heads(state, peer).await {
+    if let Err(error) = announce_heads(state, peer, false).await {
         debug!(peer = %peer, error = %format!("{error:#}"), "Telling a neighbour the link is eager failed");
     }
 }
@@ -281,7 +281,7 @@ pub(crate) async fn prune(state: &AppState, peer: &str) {
     }
     state.stats.link_pruned();
     debug!(peer = %peer, "Link lazy: its changes reach us first another way");
-    if let Err(error) = announce_heads(state, peer).await {
+    if let Err(error) = announce_heads(state, peer, false).await {
         debug!(peer = %peer, error = %format!("{error:#}"), "Telling a neighbour the link is lazy failed");
     }
 }