diff options
| author | tv <tv@krebsco.de> | 2026-11-05 01:47:45 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-05 01:47:45 +0100 |
| commit | cc1565d38dbdd104d1732e4e528c291c7edeb87c (patch) | |
| tree | 5c06f2da98391dd8fbcd8dd5ad00fe59df47c4d5 /src/swarm/sync.rs | |
| parent | b67ee4d3d59434f5a911b4eb0ee815ac9bcad3fe (diff) | |
asked known elsewhere
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index c76c16b..6c67e57 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -497,7 +497,10 @@ pub(crate) async fn handle_sync( } peer_state.sync.reply_settled(); - peer_state.sync.resend_if_needed(&replica.doc, &peer); + let asked = peer_state + .sync + .resend_if_needed(&replica.doc, &peer, Instant::now()); + stats.asked_known_elsewhere(asked); replica.refresh_heads(); let heads_after = replica.heads().to_vec(); if delivered { |