diff --git a/Makefile b/Makefile index 91ef1c2a5d..fc77bea738 100644 --- a/Makefile +++ b/Makefile @@ -10,7 +10,7 @@ CKB_FEATURES ?= deadlock_detection,with_sentry ALL_FEATURES := deadlock_detection,with_sentry,with_dns_seeding,profiling,march-native CKB_BENCH_FEATURES ?= ci CKB_BUILD_TARGET ?= -INTEGRATION_RUST_LOG := info,ckb_test=debug,ckb_sync=debug,ckb_relay=debug,ckb_network=debug +INTEGRATION_RUST_LOG := debug,ckb_test=debug,ckb_sync=debug,ckb_relay=debug,ckb_network=debug CARGO_TARGET_DIR ?= $(shell pwd)/target BINARY_NAME ?= "ckb" COV_PROFRAW_DIR = ${CARGO_TARGET_DIR}/cov diff --git a/test/src/main.rs b/test/src/main.rs index 702fea3eca..3c76e18a92 100644 --- a/test/src/main.rs +++ b/test/src/main.rs @@ -597,7 +597,7 @@ fn all_specs() -> Vec> { Box::new(RandomlyKill), Box::new(SyncChurn), ]; - let mut specs: Vec> = vec![Box::new(SendLargeCyclesTxToRelay::new())]; + let mut specs: Vec> = vec![Box::new(DAOWithSatoshiCellOccupied)]; specs.shuffle(&mut thread_rng()); specs } diff --git a/test/src/specs/tx_pool/send_large_cycles_tx.rs b/test/src/specs/tx_pool/send_large_cycles_tx.rs index 3ae8eada43..d08c357196 100644 --- a/test/src/specs/tx_pool/send_large_cycles_tx.rs +++ b/test/src/specs/tx_pool/send_large_cycles_tx.rs @@ -106,7 +106,7 @@ impl Spec for SendLargeCyclesTxToRelay { info!("Generate large cycles tx"); let tx = build_tx(node1, &self.random_key.privkey, self.random_key.lock_arg()); - // send tx + // send tx to node1 let ret = node1.rpc_client().send_transaction_result(tx.data().into()); assert!(ret.is_ok()); diff --git a/tx-pool/src/verify_mgr.rs b/tx-pool/src/verify_mgr.rs index 2255e894b8..376bf8c486 100644 --- a/tx-pool/src/verify_mgr.rs +++ b/tx-pool/src/verify_mgr.rs @@ -76,8 +76,9 @@ impl Worker { async fn process_inner(&mut self) { loop { + eprintln!("Worker process_inner begin ...."); if self.status != ChunkCommand::Resume { - info!( + eprintln!( "Worker is not in resume status, current status: {:?}", self.status ); @@ -88,6 +89,7 @@ impl Worker { } // cheap query to check queue is not empty if self.tasks.read().await.is_empty() { + eprintln!("Worker queue is empty"); return; }