Merge pull request #1754 from tursodatabase/libsql-wal-fixes

libsql wal fixes

libsql-server/src/connection/legacy.rs

@@ -380,7 +380,10 @@ where
         ctx: RequestContext,
         builder: B,
     ) -> Result<B> {
-        let config = self.inner.lock().config();
+        let inner = self.inner.clone();
+        let config = tokio::task::spawn_blocking(move || inner.lock().config())
+            .await
+            .unwrap();
         check_program_auth(&ctx, &pgm, &config).await?;
         let conn = self.inner.clone();
         CoreConnection::run_async(conn, pgm, builder).await

libsql-server/src/connection/libsql.rs

@@ -93,7 +93,10 @@ impl LibsqlConnection {
         ctx: RequestContext,
         builder: B,
     ) -> Result<B> {
-        let config = self.inner.lock().config();
+        let inner = self.inner.clone();
+        let config = tokio::task::spawn_blocking(move || inner.lock().config())
+            .await
+            .unwrap();
         check_program_auth(&ctx, &pgm, &config).await?;
         let conn = self.inner.clone();
         CoreConnection::run_async(conn, pgm, builder).await

libsql-server/src/lib.rs

@@ -147,8 +147,8 @@ type MakeReplicationSvc = Box<
 // static GLOBAL: mimalloc::MiMalloc = mimalloc::MiMalloc;
 
 #[global_allocator]
-static GLOBAL: rheaper::Allocator<mimalloc::MiMalloc> =
-    rheaper::Allocator::from_allocator(mimalloc::MiMalloc);
+static GLOBAL: rheaper::Allocator<std::alloc::System> =
+    rheaper::Allocator::from_allocator(std::alloc::System);
 
 #[derive(clap::ValueEnum, PartialEq, Clone, Copy, Debug)]
 pub enum CustomWAL {

libsql-wal/src/segment/current.rs

@@ -654,7 +654,7 @@ impl SegmentIndex {
         offsets
             .iter()
             .rev()
-            .find(|fno| **fno as u64 <= max_offset)
+            .find(|fno| (**fno as u64) < max_offset)
             .copied()
     }