Use latest YAKV version

Cargo.lock

@@ -2572,7 +2572,7 @@ checksum = "b07db065a5cf61a7e4ba64f29e67db906fb1787316516c4e6e5ff0fea1efcd8a"
 
 [[package]]
 name = "yakv"
-version = "0.2.4"
+version = "0.2.5"
 dependencies = [
  "anyhow",
  "fs2",

pageserver/Cargo.toml

@@ -37,8 +37,8 @@ async-trait = "0.1"
 const_format = "0.2.21"
 tracing = "0.1.27"
 signal-hook = {version = "0.3.10", features = ["extended-siginfo"] }
-yakv = { path  = "../../yakv" }
-#yakv = "0.2.4"
+#yakv = { path  = "../../yakv" }
+yakv = "0.2.6"
 lz4_flex = "0.9.0"
 
 postgres_ffi = { path = "../postgres_ffi" }

pageserver/src/bin/pageserver.rs

@@ -323,8 +323,8 @@ fn main() -> Result<()> {
                 .help("Interval between checkpoint iterations"),
         )
         .arg(
-            Arg::with_name("checkpoint_distance")
-                .long("checkpoint_distance")
+            Arg::with_name("upload_distance")
+                .long("upload_distance")
                 .takes_value(true)
                 .help("Distance from current LSN to perform checkpoint of in-memory layers"),
         )

pageserver/src/toast_store.rs

@@ -5,7 +5,7 @@ use std::ops::{Bound, RangeBounds};
 use std::path::Path;
 
 use yakv::storage::{
-    Key, ReadOnlyTransaction, Storage, StorageConfig, StorageIterator, Transaction, Value,
+    Key, ReadOnlyTransaction, Select, Storage, StorageConfig, StorageIterator, Transaction, Value,
 };
 
 const TOAST_SEGMENT_SIZE: usize = 2 * 1024;
@@ -169,7 +169,6 @@ impl ToastStore {
                 StorageConfig {
                     cache_size: CACHE_SIZE,
                     nosync: false,
-                    mursiw: true,
                 },
             )?,
         })
@@ -206,7 +205,7 @@ impl ToastStore {
             key.extend_from_slice(&[0u8; 4]);
             tx.put(&key, &value)?;
         }
-        tx.delay()?;
+        tx.delay();
         Ok(())
     }
 
@@ -225,7 +224,8 @@ impl ToastStore {
     pub fn remove(&self, key: Key) -> Result<()> {
         let mut tx = self.db.start_transaction();
         self.tx_remove(&mut tx, &key)?;
-        tx.delay()
+        tx.delay();
+        Ok(())
     }
 
     pub fn tx_remove(&self, tx: &mut Transaction, key: &Key) -> Result<()> {