diff options
| author | tv <tv@krebsco.de> | 2026-11-03 03:26:15 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-03 03:26:15 +0100 |
| commit | 5b3d9cbd1bba986b06978bef0100d349b33e74c7 (patch) | |
| tree | bb441a8636a3a01da6319b9f6c64e0695d0729b1 /src/swarm/relay.rs | |
| parent | 2b4359f23d20b14bae1896512f678d02b7f3c34c (diff) | |
add eager link counters
Diffstat (limited to 'src/swarm/relay.rs')
| -rw-r--r-- | src/swarm/relay.rs | 3 |
1 files changed, 3 insertions, 0 deletions
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"); |
