From 18bc1b2e36bacae45ee3a0f485a117f3756152d7 Mon Sep 17 00:00:00 2001 From: tv Date: Thu, 5 Nov 2026 05:20:00 +0100 Subject: push by default --- src/swarm/sync.rs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) (limited to 'src/swarm') diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs index aea6a0b..e551cb8 100644 --- a/src/swarm/sync.rs +++ b/src/swarm/sync.rs @@ -138,7 +138,6 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> { .map(|estimate| estimate.bytes_per_sec); let failed = peer_state_mutex.lock().await.failed_whole(Instant::now()); let delta_threshold = state.blobs.delta_threshold_for(rate, failed); - let push_changes = state.push_changes; let stats = Arc::clone(&state.stats); let clock = Arc::clone(&state.clock); @@ -168,10 +167,10 @@ async fn deliver_sync_to_peer(state: &AppState, peer: &str) -> Result<()> { delta_threshold, Instant::now(), ); - // Along a tree, taken as delivered: the changes as they are, if pushing - // (`AppState::push_changes`). Only those too small to deflate: larger - // ones go as a message, deflated (`compress`). - let pushed = (push_changes && level && writer.is_some() && again.is_none()) + // Along a tree, taken as delivered: the changes as they are + // (`SyncSession::push`). Only those too small to deflate: larger ones go + // as a message, deflated (`compress`). + let pushed = (level && writer.is_some() && again.is_none()) .then(|| { peer_state.sync.push( &replica.doc, -- cgit v1.3.1