From e2085d8b212ca294432efef27fd1324217d01968 Mon Sep 17 00:00:00 2001
From: Peter Zhang <peter@0g.ai>
Date: Mon, 28 Oct 2024 23:27:04 +0800
Subject: [PATCH] add detailed metrics for storage layer

---
 node/storage/src/log_store/log_manager.rs | 2 ++
 node/storage/src/log_store/metrics.rs     | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/node/storage/src/log_store/log_manager.rs b/node/storage/src/log_store/log_manager.rs
index c8abea5..0546e14 100644
--- a/node/storage/src/log_store/log_manager.rs
+++ b/node/storage/src/log_store/log_manager.rs
@@ -192,6 +192,7 @@ impl LogStoreChunkWrite for LogManager {
         chunks: ChunkArray,
         maybe_file_proof: Option<FlowProof>,
     ) -> Result<bool> {
+        let start_time = Instant::now();
         let mut merkle = self.merkle.write();
         let tx = self
             .tx_store
@@ -224,6 +225,7 @@ impl LogStoreChunkWrite for LogManager {
             )?;
             self.flow_store.put_mpt_node_list(updated_node_list)?;
         }
+        metrics::PUT_CHUNKS.update_since(start_time);
         Ok(true)
     }
 
diff --git a/node/storage/src/log_store/metrics.rs b/node/storage/src/log_store/metrics.rs
index deaa4d1..ca05772 100644
--- a/node/storage/src/log_store/metrics.rs
+++ b/node/storage/src/log_store/metrics.rs
@@ -5,6 +5,8 @@ use metrics::{register_timer, Timer};
 lazy_static::lazy_static! {
     pub static ref PUT_TX: Arc<dyn Timer> = register_timer("log_store_put_tx");
 
+    pub static ref PUT_CHUNKS: Arc<dyn Timer> = register_timer("log_store_put_chunks");
+
     pub static ref TX_STORE_PUT: Arc<dyn Timer> = register_timer("log_store_tx_store_put_tx");
 
     pub static ref CHECK_TX_COMPLETED: Arc<dyn Timer> =