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

Merge 'mvcc: Complete commit state machine early if write set is empty' from Jussi Saurio

Browse Source 
Closes #3104
This commit is contained in:
Pekka Enberg
2025-09-15 07:38:28 +03:00
committed by GitHub
parent 8510721c5e 2ea1798d6e
commit 27d4572c2e
1 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
core/mvcc/database/mod.rs
View File

@@ -482,6 +482,20 @@ impl<Clock: LogicalClock> StateTransition for CommitStateMachine<Clock> {
.extend(tx.write_set.iter().map(|v| *v.value()));
self.write_set
.sort_by(|a, b| a.table_id.cmp(&b.table_id).then(a.row_id.cmp(&b.row_id)));
if self.write_set.is_empty() {
if mvcc_store.is_exclusive_tx(&self.tx_id) {
mvcc_store.release_exclusive_tx(&self.tx_id);
self.commit_coordinator.pager_commit_lock.unlock();
// FIXME: this function isnt re-entrant
self.pager
.io
.block(|| self.pager.end_tx(false, &self.connection))?;
} else {
self.pager.end_read_tx()?;
}
self.finalize(mvcc_store)?;
return Ok(TransitionResult::Done(()));
}
self.state = CommitState::BeginPagerTxn { end_ts };
Ok(TransitionResult::Continue)
}