aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2025-12-30 06:24:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Pass checkpoint mode from sqlite3 c api argument

Browse Source
This commit is contained in:
PThorpe92
2025-07-19 14:21:04 -04:00
committed by Jussi Saurio
parent f4becd1296
commit 7643ef97a6
2 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
sqlite3/src/lib.rs
View File

@@ -3,7 +3,7 @@
use std::ffi::{self, CStr, CString};
use tracing::trace;
use turso_core::{LimboError, Value};
use turso_core::{CheckpointMode, LimboError, Value};
use std::sync::{Arc, Mutex};
@@ -1108,7 +1108,7 @@ pub unsafe extern "C" fn sqlite3_wal_checkpoint(
pub unsafe extern "C" fn sqlite3_wal_checkpoint_v2(
db: *mut sqlite3,
_db_name: *const ffi::c_char,
_mode: ffi::c_int,
mode: ffi::c_int,
_log_size: *mut ffi::c_int,
_checkpoint_count: *mut ffi::c_int,
) -> ffi::c_int {
@@ -1118,7 +1118,14 @@ pub unsafe extern "C" fn sqlite3_wal_checkpoint_v2(
let db: &mut sqlite3 = &mut *db;
let db = db.inner.lock().unwrap();
// TODO: Checkpointing modes and reporting back log size and checkpoint count to caller.
if db.conn.checkpoint().is_err() {
let chkptmode = match mode {
SQLITE_CHECKPOINT_PASSIVE => CheckpointMode::Passive,
SQLITE_CHECKPOINT_RESTART => CheckpointMode::Restart,
SQLITE_CHECKPOINT_TRUNCATE => CheckpointMode::Truncate,
SQLITE_CHECKPOINT_FULL => CheckpointMode::Full,
_ => return SQLITE_MISUSE, // Unsupported mode
};
if db.conn.checkpoint(chkptmode).is_err() {
return SQLITE_ERROR;
}
SQLITE_OK