Skip to content

Commit

Permalink
raftstore: Convert to engine_test
Browse files Browse the repository at this point in the history
Signed-off-by: Brian Anderson <andersrb@gmail.com>
  • Loading branch information
brson committed Oct 8, 2020
1 parent 1d1ef37 commit dfae5e4
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions components/raftstore/src/store/worker/raftlog_gc.rs
Expand Up @@ -180,8 +180,7 @@ where
#[cfg(test)]
mod tests {
use super::*;
use engine_rocks::util::new_engine;
use engine_traits::{Engines, KvEngine, Mutable, WriteBatchExt, ALL_CFS, CF_DEFAULT};
use engine_traits::{KvEngine, Mutable, WriteBatchExt, ALL_CFS, CF_DEFAULT};
use std::sync::mpsc;
use std::time::Duration;
use tempfile::Builder;
Expand All @@ -191,8 +190,8 @@ mod tests {
let dir = Builder::new().prefix("gc-raft-log-test").tempdir().unwrap();
let path_raft = dir.path().join("raft");
let path_kv = dir.path().join("kv");
let raft_db = new_engine(path_kv.to_str().unwrap(), None, &[CF_DEFAULT], None).unwrap();
let kv_db = new_engine(path_raft.to_str().unwrap(), None, ALL_CFS, None).unwrap();
let raft_db = engine_test::raft::new_engine(path_kv.to_str().unwrap(), None, &[CF_DEFAULT], None).unwrap();
let kv_db = engine_test::kv::new_engine(path_raft.to_str().unwrap(), None, ALL_CFS, None).unwrap();
let engines = Engines::new(kv_db, raft_db.clone());

let (tx, rx) = mpsc::channel();
Expand Down

0 comments on commit dfae5e4

Please sign in to comment.