diff --git a/src/protocols/mod.rs b/src/protocols/mod.rs index a0d861e8..ff7f88f1 100644 --- a/src/protocols/mod.rs +++ b/src/protocols/mod.rs @@ -30,10 +30,6 @@ mod rs_paxos; use rs_paxos::{RSPaxosReplica, RSPaxosClient}; pub use rs_paxos::{ReplicaConfigRSPaxos, ClientConfigRSPaxos}; -mod crossword; -use crossword::{CrosswordReplica, CrosswordClient}; -pub use crossword::{ReplicaConfigCrossword, ClientConfigCrossword}; - /// Enum of supported replication protocol types. #[derive(Debug, PartialEq, Eq, Clone, Copy, Serialize, Deserialize)] pub enum SmrProtocol { @@ -42,7 +38,6 @@ pub enum SmrProtocol { MultiPaxos, Raft, RSPaxos, - Crossword, } /// Helper macro for saving boilder-plate `Box` mapping in @@ -63,7 +58,6 @@ impl SmrProtocol { "MultiPaxos" => Some(Self::MultiPaxos), "Raft" => Some(Self::Raft), "RSPaxos" => Some(Self::RSPaxos), - "Crossword" => Some(Self::Crossword), _ => None, } } @@ -128,14 +122,6 @@ impl SmrProtocol { .await ) } - Self::Crossword => { - box_if_ok!( - CrosswordReplica::new_and_setup( - api_addr, p2p_addr, manager, config_str - ) - .await - ) - } } } @@ -199,7 +185,6 @@ mod protocols_name_tests { valid_name_test!(MultiPaxos); valid_name_test!(Raft); valid_name_test!(RSPaxos); - valid_name_test!(Crossword); } #[test] diff --git a/src/protocols/multipaxos.rs b/src/protocols/multipaxos.rs index dfad698a..f52ca472 100644 --- a/src/protocols/multipaxos.rs +++ b/src/protocols/multipaxos.rs @@ -277,9 +277,6 @@ pub struct MultiPaxosReplica { /// StorageHub module for the snapshot file. snapshot_hub: StorageHub, - /// StorageHub module for the snapshot file. - snapshot_hub: StorageHub, - /// TransportHub module. transport_hub: TransportHub, diff --git a/src/protocols/rs_paxos.rs b/src/protocols/rs_paxos.rs index 98ef6af2..1509fe0e 100644 --- a/src/protocols/rs_paxos.rs +++ b/src/protocols/rs_paxos.rs @@ -292,9 +292,6 @@ pub struct RSPaxosReplica { /// StorageHub module for the snapshot file. snapshot_hub: StorageHub, - /// StorageHub module for the snapshot file. - snapshot_hub: StorageHub, - /// TransportHub module. transport_hub: TransportHub, @@ -355,9 +352,6 @@ pub struct RSPaxosReplica { /// Current durable snapshot file offset. snap_offset: usize, - /// Current durable snapshot file offset. - snap_offset: usize, - /// Fixed Reed-Solomon coder. rs_coder: ReedSolomon, } @@ -1540,11 +1534,8 @@ impl RSPaxosReplica { /// Chooses a random hb_hear_timeout from the min-max range and kicks off /// the hb_hear_timer. fn kickoff_hb_hear_timer(&mut self) -> Result<(), SummersetError> { -<<<<<<< HEAD -======= self.hb_hear_timer.cancel()?; ->>>>>>> cb7f7384ce0f94e2d3bc15a486d794092f95f47d let timeout_ms = thread_rng().gen_range( self.config.hb_hear_timeout_min..=self.config.hb_hear_timeout_max, );