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

Use new wait_for_completion for sync IO

Browse Source
This commit is contained in:
PThorpe92
2025-07-18 15:01:46 -04:00
committed by Jussi Saurio
parent 9c75872827
commit ad286bb873
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/storage/wal.rs
View File

@@ -1262,9 +1262,13 @@ impl WalFileShared {
wal_header.checksum_1 = checksums.0;
wal_header.checksum_2 = checksums.1;
let c = sqlite3_ondisk::begin_write_wal_header(&file, &wal_header)?;
// TODO: for now wait for completion
let header = Arc::new(SpinLock::new(wal_header));
let checksum = {
let checksum = header.lock();
(checksum.checksum_1, checksum.checksum_2)
};
io.wait_for_completion(c)?;
tracing::debug!("new_shared(header={:?})", wal_header);
tracing::debug!("new_shared(header={:?})", header);
let shared = WalFileShared {
wal_header: Arc::new(SpinLock::new(wal_header)),
min_frame: AtomicU64::new(0),
@@ -1326,7 +1330,6 @@ impl WalFileShared {
// rewrite header on disk
let c = sqlite3_ondisk::begin_write_wal_header(&self.file, &hdr)?;
// TODO: for now wait for completion
io.wait_for_completion(c)?;
self.frame_cache.lock().clear();