Add get_engine_path interface for RaftEngine trait

cmd/tikv-ctl/Cargo.toml

@@ -70,7 +70,7 @@ pd_client = { workspace = true }
 prometheus = { version = "0.13", features = ["nightly"] }
 protobuf = { version = "2.8", features = ["bytes"] }
 raft = { version = "0.7.0", default-features = false, features = ["protobuf-codec"] }
-raft-engine-ctl = { git = "https://github.com/tikv/raft-engine.git" }
+raft-engine-ctl = { git = "https://github.com/jiayang-zheng/raft-engine.git", rev = "9200bdae002a2fa09a56e0753eae211477f03f48" }
 raft_log_engine = { workspace = true }
 raftstore = { workspace = true }
 rand = "0.8"

components/engine_panic/src/raft_engine.rs

@@ -144,6 +144,10 @@ impl RaftEngine for PanicEngine {
         panic!()
     }
 
+    fn get_engine_path(&self) -> &str {
+        panic!()
+    }
+
     fn put_store_ident(&self, ident: &StoreIdent) -> Result<()> {
         panic!()
     }

components/engine_rocks/src/raft_engine.rs

@@ -339,6 +339,10 @@ impl RaftEngine for RocksEngine {
         Ok(used_size)
     }
 
+    fn get_engine_path(&self) -> &str {
+        self.as_inner().path()
+    }
+
     fn put_store_ident(&self, ident: &StoreIdent) -> Result<()> {
         self.put_msg(keys::STORE_IDENT_KEY, ident)
     }

components/engine_traits/src/raft_engine.rs

@@ -140,6 +140,9 @@ pub trait RaftEngine: RaftEngineReadOnly + PerfContextExt + Clone + Sync + Send
 
     fn get_engine_size(&self) -> Result<u64>;
 
+    /// The path to the directory on the filesystem where the raft log is stored
+    fn get_engine_path(&self) -> &str;
+
     /// Visit all available raft groups.
     ///
     /// If any error is returned, the iteration will stop.

components/raft_log_engine/Cargo.toml

@@ -14,7 +14,7 @@ num_cpus = "1"
 online_config = { workspace = true }
 protobuf = "2"
 raft = { version = "0.7.0", default-features = false, features = ["protobuf-codec"] }
-raft-engine = { git = "https://github.com/tikv/raft-engine.git", features = ["swap"] }
+raft-engine = { git = "https://github.com/jiayang-zheng/raft-engine.git", rev = "9200bdae002a2fa09a56e0753eae211477f03f48", features = ["swap"] }
 serde = "1.0"
 serde_derive = "1.0"
 slog = { version = "2.3", features = ["max_level_trace", "release_max_level_debug"] }

components/raft_log_engine/src/engine.rs

@@ -305,6 +305,10 @@ impl RaftLogEngine {
         )))
     }
 
+    pub fn path(&self) -> &str {
+        self.0.path()
+    }
+
     /// If path is not an empty directory, we say db exists.
     pub fn exists(path: &str) -> bool {
         let path = Path::new(path);
@@ -615,6 +619,10 @@ impl RaftEngine for RaftLogEngine {
         Ok(self.0.get_used_size() as u64)
     }
 
+    fn get_engine_path(&self) -> &str {
+        self.path()
+    }
+
     fn for_each_raft_group<E, F>(&self, f: &mut F) -> std::result::Result<(), E>
     where
         F: FnMut(u64) -> std::result::Result<(), E>,