fix ut

interactive_engine/executor/engine/pegasus/common/src/buffer.rs

@@ -383,7 +383,7 @@ impl<D, F: BufferFactory<D>> Drop for BufferPool<D, F> {
 }
 
 impl<D, F: BufferFactory<D>> BufferFactory<D> for BufferPool<D, F> {
-    fn create(&mut self, batch_size: usize) -> Option<Buffer<D>> {
+    fn create(&mut self, _batch_size: usize) -> Option<Buffer<D>> {
         // This method is only called by BufferPool, batch_size and self.batch_size are always same
         // assert_eq!(batch_size, self.batch_size);
         if let Some(inner) = self.fetch() {

interactive_engine/executor/store/groot/src/bin/write_bench.rs

@@ -38,6 +38,7 @@ fn main() {
     builder.add_storage_option("store.rocksdb.max.write.buffer.num", max_write_buffer_num);
     builder.add_storage_option("store.rocksdb.level0.compaction.trigger", level_zero_compaction_trigger);
     builder.add_storage_option("store.rocksdb.max.level.base.mb", max_level_base_mb);
+    builder.add_storage_option("store.data.path", path);
     let config = builder.build();
     let store = Arc::new(GraphStore::open(&config).unwrap());
     println!("store opened.");

interactive_engine/executor/store/groot/src/db/graph/meta.rs

@@ -832,7 +832,9 @@ mod tests {
         let path = "test_meta_normal";
         fs::rmr(path).unwrap();
         {
-            let db = RocksDB::open(&HashMap::new()).unwrap();
+            let mut config = HashMap::new();
+            config.insert("store.data.path".to_owned(), path.to_owned());
+            let db = RocksDB::open(&config).unwrap();
             let store = Arc::new(db);
             let meta = Meta::new(store.clone());
             let mut schema_version = 1;

interactive_engine/executor/store/groot/src/db/graph/store.rs

@@ -1139,6 +1139,7 @@ mod tests {
     pub fn create_empty_graph(path: &str) -> GraphStore {
         let mut builder = GraphConfigBuilder::new();
         builder.set_storage_engine("rocksdb");
+        builder.add_storage_option("store.data.path", path);
         let config = builder.build();
         GraphStore::open(&config).unwrap()
     }
@@ -1175,6 +1176,7 @@ mod bench {
     pub fn create_empty_graph(path: &str) -> GraphStore {
         let mut builder = GraphConfigBuilder::new();
         builder.set_storage_engine("rocksdb");
+        builder.add_storage_option("store.data.path", path);
         let config = builder.build();
         GraphStore::open(&config).unwrap()
     }

interactive_engine/executor/store/groot/src/db/graph/tests/backup.rs

@@ -85,6 +85,7 @@ pub fn test_backup_engine<G: MultiVersionGraph>(graph: G, test_dir: &str) {
 fn open_graph(path: &str) -> GraphStore {
     let mut builder = GraphConfigBuilder::new();
     builder.set_storage_engine("rocksdb");
+    builder.add_storage_option("store.data.path", path);
     let config = builder.build();
     GraphStore::open(&config).unwrap()
 }

interactive_engine/executor/store/groot/src/db/storage/mod.rs

@@ -1,5 +1,3 @@
-use crate::db::api::{BackupId, GraphResult};
-
 pub mod rocksdb;
 use std::ptr::null;
 

interactive_engine/executor/store/groot/src/db/storage/rocksdb.rs

@@ -7,14 +7,11 @@ use std::time::Duration;
 use ::rocksdb::backup::{BackupEngine, BackupEngineOptions, RestoreOptions};
 use ::rocksdb::{DBRawIterator, Env, IngestExternalFileOptions, Options, ReadOptions, DB};
 use crossbeam_epoch::{self as epoch, Atomic, Guard, Owned, Shared};
-use grpcio_sys::grpc_serving_status_update;
-use libc::option;
-use rocksdb::{CompactOptions, DBCompactionStyle, DBCompressionType, WriteBatch};
+use rocksdb::{CompactOptions, WriteBatch};
 
 use super::{StorageIter, StorageRes};
 use crate::db::api::*;
 use crate::db::storage::{KvPair, RawBytes};
-use crate::db::util::fs;
 
 pub struct RocksDB {
     db: Atomic<Arc<DB>>,
@@ -226,7 +223,6 @@ impl RocksDB {
         let db_shared = self.get_db(&guard);
 
         if let Some(db) = unsafe { db_shared.as_ref() } {
-            let mut opts = CompactOptions::default();
             db.compact_range(None::<&[u8]>, None::<&[u8]>);
             info!("compacted rocksdb");
             Ok(())
@@ -593,7 +589,9 @@ mod tests {
     fn test_rocksdb_iter() {
         let path = "test_rocksdb_iter";
         {
-            let db = RocksDB::open(&HashMap::new()).unwrap();
+            let mut config = HashMap::new();
+            config.insert("store.data.path".to_owned(), path.to_owned());
+            let db = RocksDB::open(&config).unwrap();
             let mut ans = Vec::new();
             for i in 1..=10 {
                 let key = format!("aaa#{:010}", i);
@@ -626,7 +624,9 @@ mod tests {
         let path = "test_rocksdb_scan_from";
         fs::rmr(path).unwrap();
         {
-            let db = RocksDB::open(&HashMap::new()).unwrap();
+            let mut config = HashMap::new();
+            config.insert("store.data.path".to_owned(), path.to_owned());
+            let db = RocksDB::open(&config).unwrap();
             for i in 1..=20 {
                 if i % 2 == 0 {
                     let key = format!("aaa#{:010}", i);