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

Add assertion for expected write amount in writev callback

Browse Source
This commit is contained in:
PThorpe92
2025-08-14 10:53:16 -04:00
parent f9bd047e4d
commit 5a7c9325e2
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/storage/sqlite3_ondisk.rs
View File

@@ -1017,7 +1017,11 @@ pub fn write_pages_vectored(
let runs_left_cl = runs_left.clone();
let done_cl = done.clone();
let c = Completion::new_write(move |_| {
let total_sz = (page_sz * run_bufs.len()) as i32;
let c = Completion::new_write(move |res| {
// writev calls can sometimes return partial writes, but our `pwritev`
// implementation aggregates any partial writes and calls completion with total
turso_assert!(total_sz == res, "failed to write expected size");
if runs_left_cl.fetch_sub(1, Ordering::AcqRel) == 1 {
done_cl.store(true, Ordering::Release);
}