openai/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-11-05 20:10:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

codex: address PR review feedback (#16989)

Browse Source
This commit is contained in:
Eric Traut
2026-04-08 22:25:35 -07:00
parent 4891934519
commit b7669fc7e9
1 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
codex-rs/state/src/runtime.rs
+17 -6
View File
@@ -142,16 +142,27 @@ impl StateRuntime {
/// Checkpoint both runtime SQLite databases so WAL contents are persisted to the main files.
pub async fn checkpoint_wal(&self) -> anyhow::Result<()> {
sqlx::query("PRAGMA wal_checkpoint(TRUNCATE)")
.execute(self.pool.as_ref())
.await?;
sqlx::query("PRAGMA wal_checkpoint(TRUNCATE)")
.execute(self.logs_pool.as_ref())
.await?;
checkpoint_wal_pool(self.pool.as_ref(), "state").await?;
checkpoint_wal_pool(self.logs_pool.as_ref(), "logs").await?;
Ok(())
}
}
async fn checkpoint_wal_pool(pool: &SqlitePool, name: &str) -> anyhow::Result<()> {
let row = sqlx::query("PRAGMA wal_checkpoint(TRUNCATE)")
.fetch_one(pool)
.await?;
let busy: i64 = row.try_get(0)?;
let log_pages: i64 = row.try_get(1)?;
let checkpointed_pages: i64 = row.try_get(2)?;
if busy != 0 {
anyhow::bail!(
"{name} WAL checkpoint was busy: {checkpointed_pages}/{log_pages} pages checkpointed"
);
}
Ok(())
}
fn base_sqlite_options(path: &Path) -> SqliteConnectOptions {
SqliteConnectOptions::new()
.filename(path)