From 9855b1d537c2a348f4db7b3dff40fafe31f843e7 Mon Sep 17 00:00:00 2001 From: Ziyang Hu Date: Sun, 1 May 2022 22:21:07 +0800 Subject: [PATCH] timing --- src/db/mutation.rs | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/db/mutation.rs b/src/db/mutation.rs index f209e81f..b8971361 100644 --- a/src/db/mutation.rs +++ b/src/db/mutation.rs @@ -226,6 +226,7 @@ impl<'a, 'b, 't> MutationManager<'a, 'b, 't> { #[cfg(test)] mod tests { use std::fs; + use std::time::Instant; use pest::Parser as PestParser; use crate::db::engine::Engine; use crate::db::eval::Environment; @@ -302,6 +303,8 @@ mod tests { { let mut sess = engine.session().unwrap(); let s = fs::read_to_string("test_data/hr.cozo").unwrap(); + let start = Instant::now(); + for p in Parser::parse(Rule::file, &s).unwrap() { if p.as_rule() == Rule::EOI { break; @@ -309,6 +312,9 @@ mod tests { sess.run_definition(p).unwrap(); } sess.commit().unwrap(); + let duration = start.elapsed(); + println!("Time elapsed {:?}", duration); + } { @@ -316,15 +322,22 @@ mod tests { let data = fs::read_to_string("test_data/hr.json").unwrap(); let s = format!("insert {};", data); let p = Parser::parse(Rule::file, &s).unwrap().next().unwrap(); + + let start = Instant::now(); + assert!(sess.run_mutation(p.clone()).is_ok()); sess.commit().unwrap(); assert!(sess.run_mutation(p.clone()).is_err()); sess.rollback().unwrap(); + let duration = start.elapsed(); + let it = sess.txn.iterator(true, &sess.perm_cf); it.to_first(); for (k, v) in it.iter() { println!("K: {:?}, V: {:?}", Tuple::new(k), Tuple::new(v)); } + println!("Time elapsed {:?}", duration); + } drop(engine);