diff --git a/Cargo.lock b/Cargo.lock index 4713319..3982812 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -246,6 +246,7 @@ version = "0.2.0" dependencies = [ "base64 0.13.0", "bytes", + "chrono", "crossbeam", "directories", "heed", @@ -276,6 +277,7 @@ dependencies = [ "thiserror", "thread_local", "threadpool", + "timer", "tokio", "tracing", "tracing-flame", @@ -2870,6 +2872,15 @@ dependencies = [ "syn", ] +[[package]] +name = "timer" +version = "0.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "31d42176308937165701f50638db1c31586f183f1aab416268216577aec7306b" +dependencies = [ + "chrono", +] + [[package]] name = "tinyvec" version = "1.3.1" diff --git a/src/database/abstraction/persy.rs b/src/database/abstraction/persy.rs index 5a7c181..ba1a1ab 100644 --- a/src/database/abstraction/persy.rs +++ b/src/database/abstraction/persy.rs @@ -17,6 +17,8 @@ use std::{ time::{Duration, Instant}, }; +use tracing::warn; + pub struct PersyEngine { persy: Persy, write_cache: Arc>, @@ -415,7 +417,7 @@ impl Tree for PersyTree { self.write_cache.read().unwrap().iter(&self.name, result) } Err(e) => { - log::warn!("error iterating {:?}", e); + warn!("error iterating {:?}", e); Box::new(std::iter::empty()) } } @@ -453,7 +455,7 @@ impl Tree for PersyTree { .iter_from(&self.name, from, backwards, result) } Err(e) => { - log::warn!("error iterating with prefix {:?}", e); + warn!("error iterating with prefix {:?}", e); Box::new(std::iter::empty()) } } @@ -493,7 +495,7 @@ impl Tree for PersyTree { .scan_prefix(&self.name, prefix, result) } Err(e) => { - log::warn!("error scanning prefix {:?}", e); + warn!("error scanning prefix {:?}", e); Box::new(std::iter::empty()) } }