fix: Broken snapshot creation logic

lablup · Oct 2, 2024 · 18d73ec · 18d73ec
1 parent ccfb723
commit 18d73ec
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 7 deletions.
diff --git a/examples/src/config.rs b/examples/src/config.rs
@@ -15,6 +15,7 @@ pub fn build_config(node_id: u64) -> Config {
     ensure_directory_exist(&storage_pth).expect("Failed to create storage directory");
 
     Config {
+        bootstrap_from_snapshot: false,
         tick_interval: 0.2,
         log_dir: storage_pth.clone(),
         save_compacted_logs: true,

diff --git a/raftify/src/raft_node/mod.rs b/raftify/src/raft_node/mod.rs
@@ -1115,9 +1115,6 @@ impl<
                         storage: self.raw_node.store().clone(),
                     })
                     .unwrap();
-
-                // #[cfg(feature = "inmemory_storage")]
-                // todo!("Implement LocalRequestMsg::GetStorage request handler for inmemory storage");
             }
             LocalRequestMsg::DebugNode { tx_msg } => {
                 tx_msg

diff --git a/raftify/src/storage/heed_storage/mod.rs b/raftify/src/storage/heed_storage/mod.rs
@@ -496,10 +496,7 @@ impl HeedStorageCore {
     fn save_compacted_entries(&self, entries: &[Entry]) -> Result<()> {
         let compacted_log_dir_path = Path::new(&self.config.compacted_log_dir);
         let compacted_log_dir_path = compacted_log_dir_path.to_str().unwrap();
-        let dest_path = format!(
-            "{}/node-{}/compacted.json",
-            compacted_log_dir_path, self.config.raft_config.id
-        );
+        let dest_path = format!("{}/compacted_logs.json", compacted_log_dir_path);
 
         match fs::metadata(&dest_path) {
             Ok(metadata) if metadata.len() > self.config.compacted_log_size_threshold => {