cerc-io/lighthouse
10
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Move BlockStore test across to MemoryDB

Browse Source
This commit is contained in:
Paul Hauner 2018-09-21 15:02:28 +10:00
parent e6a693b89c
commit 8cbd4f47a0
No known key found for this signature in database
GPG Key ID: 303E4494BB28068C
1 changed files with 4 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
lighthouse/db/stores/block_store.rs
View File

@ -40,30 +40,15 @@ impl<T: ClientDB> BlockStore<T> {
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use super::*; use super::*;
use super::super::ClientDB; use super::super::super::MemoryDB;
use super::super::super::DiskDB; use std::thread;
use std::{ env, fs, thread };
use std::sync::Arc; use std::sync::Arc;
#[test] #[test]
fn test_block_store_on_disk_db() { fn test_block_store_on_disk_db() {
let pwd = env::current_dir().unwrap(); let column_families = vec![DB_COLUMN];
let path = pwd.join("block_store_testdb_please_remove");
let _ = fs::remove_dir_all(&path);
fs::create_dir_all(&path).unwrap();
let column_families = vec![
DB_COLUMN
];
let mut db = DiskDB::open(&path, None);
for cf in column_families {
db.create_col(&cf).unwrap();
}
let db = Arc::new(db);
let db = Arc::new(MemoryDB::open(Some(&column_families)));
let bs = Arc::new(BlockStore::new(db.clone())); let bs = Arc::new(BlockStore::new(db.clone()));
let thread_count = 10; let thread_count = 10;
@ -98,6 +83,5 @@ mod tests {
assert_eq!(vec![42], val); assert_eq!(vec![42], val);
} }
} }
fs::remove_dir_all(&path).unwrap();
} }
} }