diff options
Diffstat (limited to 'src/swarm/relay.rs')
| -rw-r--r-- | src/swarm/relay.rs | 6 |
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"); } } |