aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/sync.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-05 00:57:05 +0100
committertv <tv@krebsco.de>2026-11-05 00:57:05 +0100
commit0d16147e95211b0829fddaefb0d014fe0c48dbc8 (patch)
treee6b456a23ec9533010189279e4e9655978f481e1 /src/swarm/sync.rs
parent63871240278181f14af9d561f30b428d5db5e34a (diff)
new changes per message
Diffstat (limited to 'src/swarm/sync.rs')
-rw-r--r--src/swarm/sync.rs3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs
index 2a08aae..9a63c8b 100644
--- a/src/swarm/sync.rs
+++ b/src/swarm/sync.rs
@@ -506,7 +506,8 @@ pub(crate) async fn handle_sync(
let changed = heads_after != heads_before;
if changed {
// They came from it: none goes back (`SyncSession::came_from_peer`).
- peer_state.sync.came_from_peer(&replica.doc, &heads_before);
+ let new = peer_state.sync.came_from_peer(&replica.doc, &heads_before);
+ stats.new_changes(new);
}
if carried && !changed {
stats.nothing_new(payload_len, writer.is_some(), delivered, sizes);