VerifyQueue: re_notify other Worker when OnlySmallCycleTx received a large cycle tx

tx-pool/src/component/verify_queue.rs

@@ -186,6 +186,11 @@ impl VerifyQueue {
  Ok(true)
  }
 
+ /// When OnlySmallCycleTx Worker is wakeup, but found the tx is large cycle tx, notify other workers.
+ pub fn re_notify(&self) {
+ self.ready_rx.notify_one();
+ }
+
  /// Clears the map, removing all elements.
  pub fn clear(&mut self) {
  self.inner.clear();

tx-pool/src/verify_mgr.rs

@@ -1,7 +1,7 @@
 extern crate num_cpus;
 use crate::component::verify_queue::VerifyQueue;
 use crate::service::TxPoolService;
-use ckb_logger::info;
+use ckb_logger::{debug, info};
 use ckb_script::ChunkCommand;
 use ckb_stop_handler::CancellationToken;
 use std::sync::Arc;
@@ -83,15 +83,23 @@ impl Worker {
  if self.tasks.read().await.is_empty() {
  return;
  }
+
  // pick a entry to run verify
- let entry = match self
- .tasks
- .write()
- .await
- .pop_front(self.role == WorkerRole::OnlySmallCycleTx)
- {
- Some(entry) => entry,
- None => return,
+ let entry = {
+ let mut tasks = self.tasks.write().await;
+ match tasks.pop_front(self.role == WorkerRole::OnlySmallCycleTx) {
+ Some(entry) => entry,
+ None => {
+ if !tasks.is_empty() {
+ tasks.re_notify();
+ debug!(
+ "Worker (role: {:?}) didn't got tx after pop_front, but tasks is not empty, notify other Workers now",
+ self.role
+ );
+ }
+ return;
+ }
+ }
  };
 
  if let Some((res, snapshot)) = self