chore: code fixing, remove redundant and add missing

crates/curp/src/lib.rs

@@ -247,6 +247,7 @@ mod test {
             (3, 2, 4),
             (4, 3, 5),
             (4, 3, 6),
+            (6, 4, 8),
         ];
 
         for (node_cnt, expected) in nodes.into_iter().zip(expected_res.into_iter()) {

crates/curp/src/server/mod.rs

@@ -188,7 +188,6 @@ impl<C: Command, CE: CommandExecutor<C>, RC: RoleChange> crate::rpc::Protocol fo
     }
 
     #[instrument(skip_all, name = "lease_keep_alive")]
-    #[allow(clippy::unimplemented)]
     async fn lease_keep_alive(
         &self,
         request: tonic::Request<tonic::Streaming<LeaseKeepAliveMsg>>,

crates/curp/src/server/raw_curp/log.rs

@@ -168,7 +168,7 @@ impl<C: Command> Log<C> {
             }
             let end = self.li_to_pi(self.batch_end[self.first_idx_in_cur_batch - 1]);
             match end.cmp(&last_index) {
-                // All the `batch_end[i]` lager than `len - 1` should be reset to zero
+                // All the `batch_end[i]` larger than `len - 1` should be reset to zero
                 Ordering::Greater => {
                     self.batch_end[self.first_idx_in_cur_batch - 1] = 0;
                     self.first_idx_in_cur_batch -= 1;
@@ -197,10 +197,12 @@ impl<C: Command> Log<C> {
         }
 
         // recalculate the `cur_batch_size`
-        self.cur_batch_size = 0;
-        for entry in self.entries.iter().skip(self.first_idx_in_cur_batch) {
-            self.cur_batch_size += entry.size;
-        }
+        self.cur_batch_size = self
+            .entries
+            .iter()
+            .skip(self.first_idx_in_cur_batch)
+            .map(|entry| entry.size)
+            .sum();
     }
 
     /// push a log entry into the back of queue

crates/xline-client/src/clients/kv.rs

@@ -31,7 +31,6 @@ impl Debug for KvClient {
     #[inline]
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         f.debug_struct("KvClient")
-            .field("kv_client", &self.kv_client)
             .field("kv_client", &self.kv_client)
             .field("token", &self.token)
             .finish()

crates/xline-client/src/clients/lease.rs

@@ -35,7 +35,6 @@ impl Debug for LeaseClient {
     #[inline]
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         f.debug_struct("LeaseClient")
-            .field("lease_client", &self.lease_client)
             .field("lease_client", &self.lease_client)
             .field("token", &self.token)
             .field("id_gen", &self.id_gen)

crates/xline/src/storage/compact/periodic_compactor.rs

@@ -1,5 +1,4 @@
 use std::{
-    cmp::Ordering,
     sync::{
         atomic::{AtomicBool, Ordering::Relaxed},
         Arc,
@@ -133,10 +132,7 @@ impl<C: Compactable> PeriodicCompactor<C> {
 fn sample_config(period: Duration) -> (Duration, usize) {
     /// one hour duration
     const ONEHOUR: Duration = Duration::from_secs(3600);
-    let base_interval = match period.cmp(&ONEHOUR) {
-        Ordering::Less => period,
-        Ordering::Equal | Ordering::Greater => ONEHOUR,
-    };
+    let base_interval = period.min(ONEHOUR);
     let divisor = 10;
     let check_interval = base_interval
         .checked_div(divisor)