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

wal_insert_end: call pager.rollback() after tx ends so that lock index is preserved when ending tx

Browse Source
This commit is contained in:
Jussi Saurio
2025-07-30 18:22:40 +03:00
parent 7240d7903c
commit ff1c1b6b8c
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/lib.rs
View File

@@ -1170,12 +1170,13 @@ impl Connection {
{
let pager = self.pager.borrow();
{
let wal = pager.wal.borrow_mut();
wal.end_write_tx();
wal.end_read_tx();
}
// remove all non-commited changes in case if WAL session left some suffix without commit frame
pager.rollback(false, self)?;
let wal = pager.wal.borrow_mut();
wal.end_write_tx();
wal.end_read_tx();
}
// let's re-parse schema from scratch if schema cookie changed compared to the our in-memory view of schema