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

end read tx in op_transaction when write transaction return io

Browse Source
This commit is contained in:
meteorgan
2025-07-21 23:31:32 +08:00
parent 7ef50e0690
commit 08f1803a6b
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
core/vdbe/execute.rs
View File

@@ -1967,10 +1967,17 @@ pub fn op_transaction(
}
if updated && matches!(new_transaction_state, TransactionState::Write { .. }) {
if let LimboResult::Busy = return_if_io!(pager.begin_write_tx()) {
pager.end_read_tx()?;
tracing::trace!("begin_write_tx busy");
return Ok(InsnFunctionStepResult::Busy);
match pager.begin_write_tx()? {
IOResult::Done(r) => {
if let LimboResult::Busy = r {
pager.end_read_tx()?;
return Ok(InsnFunctionStepResult::Busy);
}
}
IOResult::IO => {
pager.end_read_tx()?;
return Ok(InsnFunctionStepResult::IO);
}
}
}
if updated {