From aa71451e91afab78c199435b649b6679350605d0 Mon Sep 17 00:00:00 2001
From: Eval EXEC <execvy@gmail.com>
Date: Fri, 2 Feb 2024 16:26:45 +0800
Subject: [PATCH] Fix rebase conflicts with develop:
 https://github.com/nervosnetwork/ckb/tree/dfa4f3753862261818eb93c540e7a3679ef4acc9

---
 sync/src/relayer/block_transactions_process.rs | 5 ++---
 sync/src/relayer/compact_block_process.rs      | 5 ++---
 sync/src/relayer/mod.rs                        | 8 +++-----
 3 files changed, 7 insertions(+), 11 deletions(-)

diff --git a/sync/src/relayer/block_transactions_process.rs b/sync/src/relayer/block_transactions_process.rs
index 6b1161b36e..7c8487c94c 100644
--- a/sync/src/relayer/block_transactions_process.rs
+++ b/sync/src/relayer/block_transactions_process.rs
@@ -116,10 +116,9 @@ impl<'a> BlockTransactionsProcess<'a> {
                 match ret {
                     ReconstructionResult::Block(block) => {
                         pending.remove();
-                        let status = self
-                            .relayer
+                        self.relayer
                             .accept_block(self.nc.as_ref(), self.peer, block);
-                        return status;
+                        return Status::ok();
                     }
                     ReconstructionResult::Missing(transactions, uncles) => {
                         // We need to get all transactions and uncles that do not exist locally
diff --git a/sync/src/relayer/compact_block_process.rs b/sync/src/relayer/compact_block_process.rs
index 426b38da42..30b255c658 100644
--- a/sync/src/relayer/compact_block_process.rs
+++ b/sync/src/relayer/compact_block_process.rs
@@ -117,8 +117,7 @@ impl<'a> CompactBlockProcess<'a> {
                         >= block.epoch().number()
                 });
                 shrink_to_fit!(pending_compact_blocks, 20);
-                let status = self
-                    .relayer
+                self.relayer
                     .accept_block(self.nc.as_ref(), self.peer, block);
 
                 if let Some(metrics) = ckb_metrics::handle() {
@@ -126,7 +125,7 @@ impl<'a> CompactBlockProcess<'a> {
                         .ckb_relay_cb_verify_duration
                         .observe(instant.elapsed().as_secs_f64());
                 }
-                status
+                Status::ok()
             }
             ReconstructionResult::Missing(transactions, uncles) => {
                 let missing_transactions: Vec<u32> =
diff --git a/sync/src/relayer/mod.rs b/sync/src/relayer/mod.rs
index a66d575cef..dd9644fbd2 100644
--- a/sync/src/relayer/mod.rs
+++ b/sync/src/relayer/mod.rs
@@ -21,9 +21,7 @@ use self::get_transactions_process::GetTransactionsProcess;
 use self::transaction_hashes_process::TransactionHashesProcess;
 use self::transactions_process::TransactionsProcess;
 use crate::types::{ActiveChain, SyncShared};
-use crate::utils::{
-    is_internal_db_error, metric_ckb_message_bytes, send_message_to, MetricDirection,
-};
+use crate::utils::{metric_ckb_message_bytes, send_message_to, MetricDirection};
 use crate::{Status, StatusCode};
 use ckb_chain::VerifyResult;
 use ckb_chain::{ChainController, RemoteBlock};
@@ -303,13 +301,13 @@ impl Relayer {
         _nc: &dyn CKBProtocolContext,
         peer_id: PeerIndex,
         block: core::BlockView,
-    ) -> Status {
+    ) {
         if self
             .shared()
             .active_chain()
             .contains_block_status(&block.hash(), BlockStatus::BLOCK_STORED)
         {
-            return Status::ok();
+            return;
         }
 
         let block = Arc::new(block);