diff --git a/node/storage/src/log_store/log_manager.rs b/node/storage/src/log_store/log_manager.rs index 8de28ea..65bfdf3 100644 --- a/node/storage/src/log_store/log_manager.rs +++ b/node/storage/src/log_store/log_manager.rs @@ -191,6 +191,7 @@ impl LogStoreChunkWrite for LogManager { chunks: ChunkArray, maybe_file_proof: Option, ) -> Result { + let start_time = Instant::now(); let mut merkle = self.merkle.write(); let tx = self .tx_store @@ -222,6 +223,7 @@ impl LogStoreChunkWrite for LogManager { tx.start_entry_index, )?; } + 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 = register_timer("log_store_put_tx"); + pub static ref PUT_CHUNKS: Arc = register_timer("log_store_put_chunks"); + pub static ref TX_STORE_PUT: Arc = register_timer("log_store_tx_store_put_tx"); pub static ref CHECK_TX_COMPLETED: Arc =