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

Update changes on delete

Browse Source 
Remove unwrap
This commit is contained in:
ben594
2025-01-19 20:04:25 -05:00
parent a54222d12b
commit 6c4ee1e905
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/vdbe/mod.rs
View File

@@ -896,10 +896,9 @@ impl Program {
Ok(crate::storage::wal::CheckpointStatus::IO) => Ok(StepResult::IO),
Ok(crate::storage::wal::CheckpointStatus::Done) => {
if self.change_cnt_on {
self.connection
.upgrade()
.unwrap()
.set_changes(self.n_change.get());
if let Some(conn) = self.connection.upgrade() {
conn.set_changes(self.n_change.get());
}
}
Ok(StepResult::Done)
}
@@ -2106,6 +2105,8 @@ impl Program {
Insn::DeleteAwait { cursor_id } => {
let cursor = btree_table_cursors.get_mut(cursor_id).unwrap();
cursor.wait_for_completion()?;
let prev_changes = self.n_change.get();
self.n_change.set(prev_changes + 1);
state.pc += 1;
}
Insn::NewRowid {