From a5ddc888d5765a5bd242a854c5b59dc3351cfa58 Mon Sep 17 00:00:00 2001 From: Jayanring <81245047+Jayanring@users.noreply.github.com> Date: Tue, 29 Aug 2023 10:16:49 +0800 Subject: [PATCH] fix: EntryConfChangeV2 persist snapshot (#89) * fix: EntryConfChangeV2 persist snapshot * update dep --------- Co-authored-by: Jayanring <956165026@qq.com> --- Cargo.toml | 2 +- src/peer.rs | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/Cargo.toml b/Cargo.toml index 7144854..81af5d9 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -20,7 +20,7 @@ tokio = { version = "1.29", features = ["fs", "io-util", "rt", "macros"] } serde = "1.0" bytes = "1.4" tower = "0.4" -flume = "0.10" +flume = "0.11" cloud-util = { package = "cloud-util", git = "https://github.com/cita-cloud/cloud-common-rs.git" } cita_cloud_proto = { package = "cita_cloud_proto", git = "https://github.com/cita-cloud/cloud-common-rs.git" } diff --git a/src/peer.rs b/src/peer.rs index a709439..07d5eee 100644 --- a/src/peer.rs +++ b/src/peer.rs @@ -775,6 +775,7 @@ impl Peer { self.core.mut_store().update_conf_state(cs); self.pending_conf_change_proposed = false; self.core.mut_store().advance_applied_index(entry.index); + self.core.mut_store().persist_snapshot().await; } } }