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

checkpoint inflight

Browse Source
This commit is contained in:
Pere Diaz Bou
2024-11-13 12:04:54 +00:00
parent cbfb45e55b
commit 94a45eab9e
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/storage/pager.rs
View File

@@ -336,6 +336,7 @@ pub struct Pager {
flush_info: RefCell<FlushInfo>,
checkpoint_state: RefCell<CheckpointState>,
checkpoint_inflight: Rc<RefCell<usize>>,
syncing: Rc<RefCell<bool>>,
}
@@ -370,6 +371,7 @@ impl Pager {
}),
syncing: Rc::new(RefCell::new(false)),
checkpoint_state: RefCell::new(CheckpointState::Checkpoint),
checkpoint_inflight: Rc::new(RefCell::new(0)),
})
}
@@ -556,7 +558,7 @@ impl Pager {
log::trace!("checkpoint(state={:?})", state);
match state {
CheckpointState::Checkpoint => {
let in_flight = self.flush_info.borrow().in_flight_writes.clone();
let in_flight = self.checkpoint_inflight.clone();
match self.wal.borrow_mut().checkpoint(self, in_flight)? {
CheckpointStatus::IO => return Ok(CheckpointStatus::IO),
CheckpointStatus::Done => {
@@ -566,7 +568,7 @@ impl Pager {
};
}
CheckpointState::CheckpointDone => {
let in_flight = self.flush_info.borrow().in_flight_writes.clone();
let in_flight = self.checkpoint_inflight.clone();
if *in_flight.borrow() > 0 {
return Ok(CheckpointStatus::IO);
} else {

2
core/storage/sqlite3_ondisk.rs
View File

@@ -550,8 +550,8 @@ pub fn begin_write_btree_page(
*write_counter.borrow_mut() += 1;
let write_complete = {
let buf_copy = buffer.clone();
log::trace!("finish_write_btree_page");
Box::new(move |bytes_written: i32| {
log::trace!("finish_write_btree_page");
let buf_copy = buf_copy.clone();
let buf_len = buf_copy.borrow().len();
*write_counter.borrow_mut() -= 1;