Add lonely_block channel and unverified_block channel length

chain/src/chain_service.rs

@@ -242,6 +242,12 @@ impl ChainService {
             }
         }
 
+        ckb_metrics::handle().map(|metrics| {
+            metrics
+                .ckb_chain_lonely_block_ch_len
+                .set(self.lonely_block_tx.len() as i64)
+        });
+
         match self.lonely_block_tx.send(lonely_block) {
             Ok(_) => {}
             Err(SendError(lonely_block)) => {

chain/src/consume_orphan.rs

@@ -96,6 +96,11 @@ impl ConsumeDescendantProcessor {
     fn send_unverified_block(&self, lonely_block: LonelyBlockHash, total_difficulty: U256) {
         let block_number = lonely_block.block_number_and_hash.number();
         let block_hash = lonely_block.block_number_and_hash.hash();
+        ckb_metrics::handle().map(|metrics| {
+            metrics
+                .ckb_chain_unverified_block_ch_len
+                .set(self.unverified_blocks_tx.len() as i64)
+        });
 
         match self.unverified_blocks_tx.send(lonely_block) {
             Ok(_) => {

util/metrics/src/lib.rs

@@ -74,6 +74,8 @@ pub struct Metrics {
     pub ckb_chain_execute_callback_duration: Histogram,
     /// ckb_chain orphan blocks count
     pub ckb_chain_orphan_count: IntGauge,
+    pub ckb_chain_lonely_block_ch_len: IntGauge,
+    pub ckb_chain_unverified_block_ch_len: IntGauge,
     /// ckb_sync_msg_process duration (seconds)
     pub ckb_sync_msg_process_duration: HistogramVec,
     /// ckb_sync_block_fetch duraiton (seconds)
@@ -157,6 +159,14 @@ static METRICS: once_cell::sync::Lazy<Metrics> = once_cell::sync::Lazy::new(|| {
             "ckb_chain_orphan_count",
             "The CKB chain orphan blocks count",
         ).unwrap(),
+        ckb_chain_lonely_block_ch_len: register_int_gauge!(
+            "ckb_chain_lonely_block_ch_len",
+            "The CKB chain lonely block channel length",
+        ).unwrap(),
+        ckb_chain_unverified_block_ch_len: register_int_gauge!(
+            "ckb_chain_unverified_block_ch_len",
+            "The CKB chain unverified block channel length",
+        ).unwrap(),
         ckb_sync_msg_process_duration: register_histogram_vec!(
             "ckb_sync_msg_process_duration",
             "The CKB sync message process duration (seconds)",