From 1066d90e2d48cb9d0d69cb2122b4fa2e15869a97 Mon Sep 17 00:00:00 2001 From: Haydn Vestal Date: Tue, 11 Aug 2026 10:00:26 +0530 Subject: [PATCH] update to the latest freqfs API --- examples/example.rs | 3 ++- src/file.rs | 8 ++++++-- src/lib.rs | 2 +- 3 files changed, 9 insertions(+), 4 deletions(-) diff --git a/examples/example.rs b/examples/example.rs index df1b201..e314388 100644 --- a/examples/example.rs +++ b/examples/example.rs @@ -2,6 +2,7 @@ use std::cmp::Ordering; use std::fmt; use std::io; use std::path::PathBuf; +use std::time::Duration; use destream::en; use freqfs::{Cache, DirLock}; @@ -154,7 +155,7 @@ async fn main() -> Result<(), txfs::Error> { let path = setup_tmp_dir().await?; // initialize the cache - let cache = Cache::new(40, None); + let cache = Cache::new(40, None, 0, Duration::from_secs(3)); // load the directory and file paths into memory (not file contents, yet) let root = cache.load(path.clone())?; diff --git a/src/file.rs b/src/file.rs index 6940724..069b6cf 100644 --- a/src/file.rs +++ b/src/file.rs @@ -91,7 +91,9 @@ where { let size = version.get_size(); let mut versions = versions.write().await; - versions.create_file(txn_id.to_string(), version, size)?; + versions + .create_file(txn_id.to_string(), version, size) + .await?; } Ok(Self { @@ -202,7 +204,9 @@ where let version = F::clone(&*canon); let size = version.get_size(); - versions.create_file(txn_id.to_string(), version, size)? + versions + .create_file(txn_id.to_string(), version, size) + .await? } else if last_modified == txn_id { versions.get_file(&*last_modified).expect("version").clone() } else { diff --git a/src/lib.rs b/src/lib.rs index 880ddcf..5b25702 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -175,7 +175,7 @@ mod tests { path.push(format!("txfs_test_{}_{}", std::process::id(), unique)); fs::create_dir(&path).await?; - let cache = Cache::::new(40, None); + let cache = Cache::::new(1024, None, 0, std::time::Duration::from_secs(3)); let root = cache.load(path.clone())?; let dir = super::Dir::load(Txn(1), root).await?;