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/tree.rs | |
| parent | b67ee4d3d59434f5a911b4eb0ee815ac9bcad3fe (diff) | |
asked known elsewhere
Diffstat (limited to 'src/swarm/tree.rs')
| -rw-r--r-- | src/swarm/tree.rs | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/swarm/tree.rs b/src/swarm/tree.rs index ffdf80e..d6d4a35 100644 --- a/src/swarm/tree.rs +++ b/src/swarm/tree.rs @@ -394,7 +394,11 @@ pub(crate) async fn forward( let mut peer_state = peer_state.lock().await; peer_state.tree_writer = Some(writer); if let Some(replica) = &replica { - peer_state.sync.with_predecessors(&replica.doc, changes); + peer_state.sync.with_predecessors( + &replica.doc, + changes, + tokio::time::Instant::now(), + ); } } state.stats.tree_forward(); |
