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

Keep should_checkpoint logic for now until greater checkpointing is fixed

Browse Source
This commit is contained in:
PThorpe92
2025-07-26 14:39:23 -04:00
parent 6644036be4
commit 7c027fed8c
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
core/storage/wal.rs
View File

@@ -802,11 +802,7 @@ impl Wal for WalFile {
fn should_checkpoint(&self) -> bool {
let shared = self.get_shared();
let frame_id = shared.max_frame.load(Ordering::SeqCst) as usize;
let nbackfilled = shared.nbackfills.load(Ordering::SeqCst) as usize;
if frame_id < self.checkpoint_threshold {
return false;
}
frame_id >= nbackfilled + self.checkpoint_threshold
frame_id > self.checkpoint_threshold
}
#[instrument(skip_all, level = Level::DEBUG)]
@@ -826,7 +822,6 @@ impl Wal for WalFile {
match state {
CheckpointState::Start => {
// TODO(pere): check what frames are safe to checkpoint between many readers!
self.ongoing_checkpoint.min_frame = self.min_frame;
let (shared_max, nbackfills) = {
let shared = self.get_shared();
(
@@ -838,6 +833,7 @@ impl Wal for WalFile {
// nothing to checkpoint, everything is already backfilled
return Ok(IOResult::Done(CheckpointResult::default()));
}
self.ongoing_checkpoint.min_frame = nbackfills + 1;
let shared = self.get_shared();
let busy = !shared.checkpoint_lock.write();
if busy {