From 243f70403e70b65146c23402164ca6d6391dd1b4 Mon Sep 17 00:00:00 2001 From: bsbds <69835502+bsbds@users.noreply.github.com> Date: Mon, 19 Aug 2024 17:46:59 +0800 Subject: [PATCH] refactor: disable dedup Signed-off-by: bsbds <69835502+bsbds@users.noreply.github.com> --- crates/curp/src/server/raw_curp/mod.rs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/crates/curp/src/server/raw_curp/mod.rs b/crates/curp/src/server/raw_curp/mod.rs index c3e18c895..a7c631411 100644 --- a/crates/curp/src/server/raw_curp/mod.rs +++ b/crates/curp/src/server/raw_curp/mod.rs @@ -1,3 +1,4 @@ +#![allow(unused)] //! READ THIS BEFORE YOU START WRITING CODE FOR THIS MODULE //! To avoid deadlock, let's make some rules: //! 1. To group similar functions, I divide Curp impl into three scope: one for utils(don't grab lock here), one for tick, one for handlers @@ -639,7 +640,6 @@ impl RawCurp { if self.lst.get_transferee().is_some() { return Err(CurpError::LeaderTransfer("leader transferring".to_owned())); } - self.deduplicate(propose_id, None)?; let mut log_w = self.log.write(); let entry = log_w.push(st_r.term, propose_id, EntryData::Shutdown); debug!("{} gets new log[{}]", self.id(), entry.index); @@ -673,7 +673,6 @@ impl RawCurp { } self.check_new_config(&conf_changes)?; - self.deduplicate(propose_id, None)?; let mut log_w = self.log.write(); let entry = log_w.push(st_r.term, propose_id, conf_changes.clone()); debug!("{} gets new log[{}]", self.id(), entry.index);