Set receive exit signal log from debug to info

block-filter/src/filter.rs

@@ -1,5 +1,5 @@
 use ckb_async_runtime::tokio::{self, task::block_in_place};
-use ckb_logger::{debug, warn};
+use ckb_logger::{debug, info, warn};
 use ckb_shared::Shared;
 use ckb_stop_handler::{new_tokio_exit_rx, CancellationToken};
 use ckb_store::{ChainDB, ChainStore};
@@ -63,7 +63,7 @@ impl BlockFilter {
                         new_block_watcher.borrow_and_update();
                     }
                     _ = stop_rx.cancelled() => {
-                        debug!("BlockFilter received exit signal, exit now");
+                        info!("BlockFilter received exit signal, exit now");
                         break
                     },
                     else => break,

chain/src/chain.rs

@@ -411,7 +411,7 @@ impl ChainService {
                         },
                     },
                     recv(signal_receiver) -> _ => {
-                        debug!("ChainService received exit signal, exit now");
+                        info!("ChainService received exit signal, exit now");
                         unverified_queue_stop_tx.send(());
                         search_orphan_pool_stop_tx.send(());
 

ckb-bin/src/helper.rs

@@ -36,7 +36,7 @@ pub fn deadlock_detection() {
 
                 },
                 recv(stop_rx) -> _ =>{
-                    debug!("deadlock_detection received exit signal, stopped");
+                    info!("deadlock_detection received exit signal, stopped");
                     return;
                 }
             }

miner/src/client.rs

@@ -4,7 +4,7 @@ use ckb_app_config::MinerClientConfig;
 use ckb_async_runtime::Handle;
 use ckb_channel::Sender;
 use ckb_jsonrpc_types::{Block as JsonBlock, BlockTemplate};
-use ckb_logger::{debug, error};
+use ckb_logger::{debug, error, info};
 use ckb_stop_handler::{new_tokio_exit_rx, CancellationToken};
 use ckb_types::{
     packed::{Block, Byte32},
@@ -87,7 +87,7 @@ impl Rpc {
                         });
                     },
                     _ = stop_rx.cancelled() => {
-                        debug!("Rpc server received exit signal, exit now");
+                        info!("Rpc server received exit signal, exit now");
                         break
                     },
                     else => break
@@ -235,7 +235,7 @@ Otherwise ckb-miner does not work properly and will behave as it stopped committ
         let stop_rx: CancellationToken = new_tokio_exit_rx();
         let graceful = server.with_graceful_shutdown(async move {
             stop_rx.cancelled().await;
-            debug!("Miner client received exit signal, exit now");
+            info!("Miner client received exit signal, exit now");
         });
 
         if let Err(e) = graceful.await {
@@ -255,7 +255,7 @@ Otherwise ckb-miner does not work properly and will behave as it stopped committ
                     self.fetch_block_template().await;
                 }
                 _ = stop_rx.cancelled() => {
-                    debug!("Miner client pool_block_template received exit signal, exit now");
+                    info!("Miner client pool_block_template received exit signal, exit now");
                     break
                 },
                 else => break,

miner/src/miner.rs

@@ -105,7 +105,7 @@ impl Miner {
                     },
                 },
                 recv(stop_rx) -> _msg => {
-                    debug!("miner received exit signal, stopped");
+                    info!("miner received exit signal, stopped");
                     break;
                 }
             };

notify/src/lib.rs

@@ -1,7 +1,7 @@
 //! TODO(doc): @quake
 use ckb_app_config::NotifyConfig;
 use ckb_async_runtime::Handle;
-use ckb_logger::{debug, error, trace};
+use ckb_logger::{debug, error, info, trace};
 use ckb_stop_handler::{new_tokio_exit_rx, CancellationToken};
 use ckb_types::packed::Byte32;
 use ckb_types::{
@@ -178,7 +178,7 @@ impl NotifyService {
                     Some(msg) = network_alert_register_receiver.recv() => { self.handle_register_network_alert(msg) },
                     Some(msg) = network_alert_receiver.recv() => { self.handle_notify_network_alert(msg) },
                     _ = signal_receiver.cancelled() => {
-                        debug!("NotifyService received exit signal, exit now");
+                        info!("NotifyService received exit signal, exit now");
                         break;
                     }
                     else => break,

shared/src/types/header_map/mod.rs

@@ -1,5 +1,5 @@
 use ckb_async_runtime::Handle;
-use ckb_logger::debug;
+use ckb_logger::{debug, info};
 use ckb_stop_handler::{new_tokio_exit_rx, CancellationToken};
 use ckb_types::packed::Byte32;
 use std::sync::Arc;
@@ -58,7 +58,7 @@ impl HeaderMap {
                         debug!("HeaderMap limit_memory cost: {:?}", now.elapsed());
                     }
                     _ = stop_rx.cancelled() => {
-                        debug!("HeaderMap limit_memory received exit signal, exit now");
+                        info!("HeaderMap limit_memory received exit signal, exit now");
                         break
                     },
                 }

sync/src/synchronizer/mod.rs

@@ -147,7 +147,7 @@ impl BlockFetchCMD {
                     }
                 }
                 recv(stop_signal) -> _ => {
-                    debug!("thread BlockDownload received exit signal, exit now");
+                    info!("thread BlockDownload received exit signal, exit now");
                     return;
                 }
             }

tx-pool/src/chunk_process.rs

@@ -4,7 +4,7 @@ use crate::try_or_return_with_snapshot;
 use crate::{error::Reject, service::TxPoolService};
 use ckb_chain_spec::consensus::Consensus;
 use ckb_error::Error;
-use ckb_logger::debug;
+use ckb_logger::{debug, info};
 use ckb_snapshot::Snapshot;
 use ckb_store::data_loader_wrapper::AsDataLoader;
 use ckb_traits::{CellDataProvider, ExtensionProvider, HeaderProvider};
@@ -85,7 +85,7 @@ impl ChunkProcess {
                     }
                 },
                 _ = self.signal.cancelled() => {
-                    debug!("TxPool received exit signal, exit now");
+                    info!("TxPool received exit signal, exit now");
                     break
                 },
                 else => break,

tx-pool/src/service.rs

@@ -539,7 +539,7 @@ impl TxPoolServiceBuilder {
                                 block_assembler::process(service_clone, &message).await;
                             },
                             _ = signal_receiver.cancelled() => {
-                                debug!("TxPool received exit signal, exit now");
+                                info!("TxPool received exit signal, exit now");
                                 break
                             },
                             else => break,
@@ -574,7 +574,7 @@ impl TxPoolServiceBuilder {
                                 queue.clear();
                             }
                             _ = signal_receiver.cancelled() => {
-                                debug!("TxPool received exit signal, exit now");
+                                info!("TxPool received exit signal, exit now");
                                 break
                             },
                             else => break,
@@ -612,7 +612,7 @@ impl TxPoolServiceBuilder {
                         service.update_block_assembler_after_tx_pool_reorg().await;
                     },
                     _ = signal_receiver.cancelled() => {
-                        debug!("TxPool received exit signal, exit now");
+                        info!("TxPool received exit signal, exit now");
                         break
                     },
                     else => break,

util/indexer/src/service.rs

@@ -118,7 +118,7 @@ impl IndexerService {
                         }
                     }
                     _ = stop.cancelled() => {
-                        debug!("Indexer received exit signal, exit now");
+                        info!("Indexer received exit signal, exit now");
                         break
                     },
                     else => break,
@@ -204,7 +204,7 @@ impl IndexerService {
                         }
                     }
                     _ = stop.cancelled() => {
-                        debug!("Indexer received exit signal, exit now");
+                        info!("Indexer received exit signal, exit now");
                         break
                     },
                 }

util/metrics-service/src/lib.rs

@@ -10,7 +10,7 @@ use hyper::{
 use prometheus::Encoder as _;
 
 use ckb_async_runtime::Handle;
-use ckb_logger::debug;
+use ckb_logger::info;
 use ckb_metrics_config::{Config, Exporter, Target};
 use ckb_stop_handler::{new_tokio_exit_rx, CancellationToken};
 use ckb_util::strings;
@@ -66,7 +66,7 @@ fn run_exporter(exporter: Exporter, handle: &Handle) -> Result<(), String> {
                     .with_graceful_shutdown(async {
                         let exit_rx: CancellationToken = new_tokio_exit_rx();
                         exit_rx.cancelled().await;
-                        debug!("prometheus server received exit signal, exit now");
+                        info!("prometheus server received exit signal, exit now");
                     });
                 if let Err(err) = server.await {
                     ckb_logger::error!("prometheus server error: {}", err);

util/stop-handler/src/stop_register.rs

@@ -24,7 +24,7 @@ pub fn wait_all_ckb_services_exit() {
             }
         }
     }
-    debug!("all ckb threads have been stopped");
+    info!("all ckb threads have been stopped");
 }
 
 static CKB_HANDLES: once_cell::sync::Lazy<Mutex<CkbServiceHandles>> =