From 5b3d9cbd1bba986b06978bef0100d349b33e74c7 Mon Sep 17 00:00:00 2001 From: tv Date: Tue, 3 Nov 2026 03:26:15 +0100 Subject: add eager link counters --- src/swarm/relay.rs | 3 +++ 1 file changed, 3 insertions(+) (limited to 'src/swarm/relay.rs') diff --git a/src/swarm/relay.rs b/src/swarm/relay.rs index fcca9c7..e11bd69 100644 --- a/src/swarm/relay.rs +++ b/src/swarm/relay.rs @@ -106,6 +106,7 @@ async fn forward_eagerly(state: &AppState, from: &str) { continue; } if peer_state.lock().await.eager_to { + state.stats.eager_forward(); state.request_sync(&peer); } } @@ -265,6 +266,7 @@ async fn graft(state: &AppState, peer: &str) { if !set_eager_from(state, peer, true).await { return; } + 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 { debug!(peer = %peer, error = %format!("{error:#}"), "Telling a neighbour the link is eager failed"); @@ -277,6 +279,7 @@ pub(crate) async fn prune(state: &AppState, peer: &str) { if !set_eager_from(state, peer, false).await { return; } + 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 { debug!(peer = %peer, error = %format!("{error:#}"), "Telling a neighbour the link is lazy failed"); -- cgit v1.3.1