From 1316be5b09ed3ab30d4193c12847c855a654b830 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cl=C3=A9ment=20Renault?= Date: Wed, 16 Jan 2019 11:45:33 +0100 Subject: [PATCH] chore: Display timings of indexation operations --- src/database/mod.rs | 21 +++++++++++++-------- 1 file changed, 13 insertions(+), 8 deletions(-) diff --git a/src/database/mod.rs b/src/database/mod.rs index db6413fb1..32ca4ca14 100644 --- a/src/database/mod.rs +++ b/src/database/mod.rs @@ -7,7 +7,7 @@ use rocksdb::rocksdb_options::{DBOptions, IngestExternalFileOptions, ColumnFamil use rocksdb::rocksdb::{Writable, Snapshot}; use rocksdb::{DB, DBVector, MergeOperands}; use crossbeam::atomic::ArcCell; -use log::debug; +use log::info; pub use self::document_key::{DocumentKey, DocumentKeyAttr}; pub use self::view::{DatabaseView, DocumentIter}; @@ -148,14 +148,19 @@ impl Database { let options = IngestExternalFileOptions::new(); // options.move_files(move_update); - debug!("ingest update file"); - let cf_handle = db.cf_handle("default").expect("\"default\" column family not found"); - db.ingest_external_file_optimized(&cf_handle, &options, &[&path])?; + let (elapsed, result) = elapsed::measure_time(|| { + let cf_handle = db.cf_handle("default").expect("\"default\" column family not found"); + db.ingest_external_file_optimized(&cf_handle, &options, &[&path]) + }); + let _ = result?; + info!("ingesting update file took {}", elapsed); - debug!("compacting index range"); - // Compacting to trigger the merge operator only one time - // while ingesting the update and not each time searching - db.compact_range(Some(DATA_INDEX), Some(DATA_INDEX)); + let (elapsed, _) = elapsed::measure_time(|| { + // Compacting to trigger the merge operator only one time + // while ingesting the update and not each time searching + db.compact_range(Some(DATA_INDEX), Some(DATA_INDEX)); + }); + info!("compacting index range took {}", elapsed); Snapshot::new(db.clone()) };