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

clear locked on pages when completion errors

Browse Source
This commit is contained in:
pedrocarlo
2025-08-19 10:56:46 -03:00
parent 1614b0e0fa
commit 46c756b130
2 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
core/storage/sqlite3_ondisk.rs
View File

@@ -876,6 +876,7 @@ pub fn begin_read_page(
let buf = Arc::new(buf);
let complete = Box::new(move |res: Result<(Arc<Buffer>, i32), CompletionError>| {
let Ok((mut buf, bytes_read)) = res else {
page.clear_locked();
return;
};
let buf_len = buf.len();

1
core/storage/wal.rs
View File

@@ -915,6 +915,7 @@ impl Wal for WalFile {
let frame = page.clone();
let complete = Box::new(move |res: Result<(Arc<Buffer>, i32), CompletionError>| {
let Ok((buf, bytes_read)) = res else {
page.clear_locked();
return;
};
let buf_len = buf.len();