aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/relay.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/swarm/relay.rs')
-rw-r--r--src/swarm/relay.rs3
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");