add log

nervosnetwork · Aug 23, 2024 · b14eccc · b14eccc
1 parent 4167beb
commit b14eccc
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 4 deletions.
diff --git a/.github/workflows/ci_integration_tests_macos.yaml b/.github/workflows/ci_integration_tests_macos.yaml
@@ -54,6 +54,8 @@ jobs:
     runs-on: macos-12
     steps:
     - uses: actions/checkout@v3
+    - run: |
+        make build
     - name: Setup upterm session
       uses: lhotari/action-upterm@v1
     - run: |

diff --git 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
@@ -597,7 +597,7 @@ fn all_specs() -> Vec<Box<dyn Spec>> {
         Box::new(RandomlyKill),
         Box::new(SyncChurn),
     ];
-    let mut specs: Vec<Box<dyn Spec>> = vec![Box::new(SendLargeCyclesTxToRelay::new())];
+    let mut specs: Vec<Box<dyn Spec>> = 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
@@ -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
@@ -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;
             }