diff --git a/tx-pool/src/verify_mgr.rs b/tx-pool/src/verify_mgr.rs index 1e0a9b5a70..0734ee8ab5 100644 --- a/tx-pool/src/verify_mgr.rs +++ b/tx-pool/src/verify_mgr.rs @@ -76,6 +76,10 @@ impl Worker { async fn process_inner(&mut self) { loop { + if self.exit_signal.is_cancelled() { + info!("Verify worker::process_inner exit_signal is cancelled"); + return; + } if self.status != ChunkCommand::Resume { return; } @@ -170,7 +174,6 @@ impl VerifyMgr { } fn send_child_command(&self, command: ChunkCommand) { - //info!("[verify-test] verify-mgr send child command: {:?}", command); for w in &self.workers { if let Err(err) = w.0.send(command.clone()) { info!("send worker command failed, error: {}", err);