From a008493f73cb5ee990ba349f3aa60ac5cefbfd66 Mon Sep 17 00:00:00 2001
From: yukang <moorekang@gmail.com>
Date: Tue, 16 Jan 2024 12:46:23 +0800
Subject: [PATCH] verify mgr will not pick entry when suspend

---
 script/src/verify.rs      | 1 -
 tx-pool/src/verify_mgr.rs | 4 ++++
 2 files changed, 4 insertions(+), 1 deletion(-)

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<i8, ckb_vm::Error>, 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;
         }