Skip to content

Commit

Permalink
Merge pull request #4612 from chenyukang/yukang-fix-verify-queue-exit
Browse files Browse the repository at this point in the history
Fix: verify worker exit when signal_exit is_cancelled
  • Loading branch information
chenyukang authored Aug 25, 2024
2 parents 76ebab4 + ce41807 commit 8744829
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion tx-pool/src/verify_mgr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Expand Down Expand Up @@ -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);
Expand Down

0 comments on commit 8744829

Please sign in to comment.