aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-07 02:04:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

sync bootstrapped files in the end

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-08-08 16:40:29 +04:00
parent 2ccdafd2a5
commit d2a8162e10
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
packages/turso-sync-engine/src/database_sync_operations.rs
View File

@@ -69,6 +69,18 @@ pub async fn db_bootstrap<C: ProtocolIO>(
coro.yield_(ProtocolCommand::IO).await?;
}
// sync files in the end
let mut completions = Vec::with_capacity(dbs.len());
for db in dbs {
let c = Completion::new_sync(move |_| {
// todo(sivukhin): we need to error out in case of failed sync
});
completions.push(db.sync(c)?);
}
while !completions.iter().all(|x| x.is_completed()) {
coro.yield_(ProtocolCommand::IO).await?;
}
let elapsed = std::time::Instant::now().duration_since(start_time);
tracing::debug!("db_bootstrap: finished: bytes={pos}, elapsed={:?}", elapsed);