diff options
| author | tv <tv@krebsco.de> | 2026-11-06 06:58:48 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-06 06:58:48 +0100 |
| commit | 19461552f88e8b82a24c63c00a6591996ae8f45d (patch) | |
| tree | 14b095388f5751cde36e452bc502262f223cd3df /src/swarm/sync.rs | |
| parent | b4948712867819c20efcf2d4eb06ee9272196695 (diff) | |
trees at runtime
Diffstat (limited to 'src/swarm/sync.rs')
| -rw-r--r-- | src/swarm/sync.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index a4ad30c..66fa4a5 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -686,6 +686,9 @@ pub(crate) async fn handle_sync( state.notify_store_changed(); crate::swarm::relay::pulled(state, peer); + if state.initial_sync_done.load(Ordering::Acquire) && !just_caught_up { + crate::swarm::tree::note_arrival(state, peer, writer, carried, &authors).await; + } // Caught up: our other neighbours may lack what the source had. if changed || just_caught_up { let writers: Vec<(u64, Vec<crate::document::ChangeHash>)> = authors |
