checkpoint metastore after every operation (tursodatabase#1393)

MarinPostma · web-flow · commit a494735e560c · 2024-05-15T13:59:42.000Z
diff --git a/libsql-server/src/namespace/meta_store.rs b/libsql-server/src/namespace/meta_store.rs
@@ -369,6 +369,15 @@ fn try_process(
         )?;
     }
 
+    if let Err(e) = checkpoint(&inner.conn) {
+        tracing::warn!("failed to checkpoint metastore: {e}");
+    }
+
+    Ok(())
+}
+
+fn checkpoint(conn: &rusqlite::Connection) -> Result<()> {
+    conn.execute("PRAGMA wal_checkpoint(TRUNCATE)", ())?;
     Ok(())
 }
 

Original file line number	Diff line number	Diff line change
`@@ -369,6 +369,15 @@ fn try_process(`
`369`	`369`	`)?;`
`370`	`370`	`}`
`371`	`371`
	`372`	`+ if let Err(e) = checkpoint(&inner.conn) {`
	`373`	`+ tracing::warn!("failed to checkpoint metastore: {e}");`
	`374`	`+ }`
	`375`	`+`
	`376`	`+ Ok(())`
	`377`	`+}`
	`378`	`+`
	`379`	`+fn checkpoint(conn: &rusqlite::Connection) -> Result<()> {`
	`380`	`+ conn.execute("PRAGMA wal_checkpoint(TRUNCATE)", ())?;`
`372`	`381`	`Ok(())`
`373`	`382`	`}`
`374`	`383`