diff --git a/script/src/verify.rs b/script/src/verify.rs index caad36b4bd4..880a40b53ac 100644 --- a/script/src/verify.rs +++ b/script/src/verify.rs @@ -1400,7 +1400,6 @@ async fn run_vms_with_signal( let (finished_send, mut finished_recv) = mpsc::unbounded_channel::<(Result, u64)>(); let (child_sender, child_recv) = watch::channel(ChunkCommand::Resume); - eprintln!("begin to run vms with signal: vms len {}", machines.len()); let jh = tokio::spawn( async move { run_vms_child(machines, child_recv, finished_send, context).await }, diff --git a/tx-pool/src/verify_mgr.rs b/tx-pool/src/verify_mgr.rs index b9ef1bcae31..d46d17e8f06 100644 --- a/tx-pool/src/verify_mgr.rs +++ b/tx-pool/src/verify_mgr.rs @@ -78,6 +78,10 @@ impl Worker { } async fn process_inner(&mut self) { + if self.command_rx.borrow().to_owned() == ChunkCommand::Suspend { + return; + } + if self.tasks.read().await.get_first().is_none() { return; }