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

pager: call rollback() after ending txn so that read lock info is not lost when ending txn

Browse Source
This commit is contained in:
Jussi Saurio
2025-07-30 17:21:19 +03:00
parent 7b1f04dc5e
commit 66c4b44c55
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
core/storage/pager.rs
View File

@@ -818,11 +818,11 @@ impl Pager {
) -> Result<IOResult<PagerCommitResult>> {
tracing::trace!("end_tx(rollback={})", rollback);
if rollback {
self.rollback(schema_did_change, connection)?;
if matches!(connection.transaction_state.get(), TransactionState::Write { .. }) {
self.wal.borrow().end_write_tx();
}
self.wal.borrow().end_read_tx();
self.rollback(schema_did_change, connection)?;
return Ok(IOResult::Done(PagerCommitResult::Rollback));
}
let commit_status = self.commit_dirty_pages(wal_checkpoint_disabled)?;