Fix ChainService error handle

nervosnetwork · Oct 13, 2023 · 245a11d · 245a11d
1 parent 3b74292
commit 245a11d
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/chain/src/chain.rs b/chain/src/chain.rs
@@ -516,7 +516,9 @@ impl ChainService {
 
                             match unverified_block_tx.send(unverified_block) {
                                 Ok(_) => {}
-                                Err(err) => error!("send unverified_block_tx failed: {}", err),
+                                Err(err) => {
+                                    error!("send unverified_block_tx failed: {}", err)
+                                }
                             };
 
                             if total_difficulty
@@ -687,11 +689,9 @@ impl ChainService {
             Err(SendError(lonely_block)) => {
                 error!("notify new block to orphan pool err: {}", err);
                 if let Some(verify_callback) = lonely_block.verify_callback {
-                    verify_callback(
-                        InternalErrorKind::System
-                            .other("OrphanBlock broker disconnected")
-                            .into(),
-                    );
+                    verify_callback(Err(InternalErrorKind::System
+                        .other("OrphanBlock broker disconnected")
+                        .into()));
                 }
             }
         }