diff --git a/node/storage/src/log_store/flow_store.rs b/node/storage/src/log_store/flow_store.rs index 01e1b75..d630e2c 100644 --- a/node/storage/src/log_store/flow_store.rs +++ b/node/storage/src/log_store/flow_store.rs @@ -2,7 +2,8 @@ use crate::config::ShardConfig; use crate::error::Error; use crate::log_store::load_chunk::EntryBatch; use crate::log_store::log_manager::{ - bytes_to_entries, COL_ENTRY_BATCH, COL_FLOW_MPT_NODES, PORA_CHUNK_SIZE, COL_PAD_DATA_LIST, COL_PAD_DATA_SYNC_HEIGH + bytes_to_entries, COL_ENTRY_BATCH, COL_FLOW_MPT_NODES, COL_PAD_DATA_LIST, + COL_PAD_DATA_SYNC_HEIGH, PORA_CHUNK_SIZE, }; use crate::log_store::seal_task_manager::SealTaskManager; use crate::log_store::{ diff --git a/node/storage/src/log_store/log_manager.rs b/node/storage/src/log_store/log_manager.rs index 526b3c3..8a9d161 100644 --- a/node/storage/src/log_store/log_manager.rs +++ b/node/storage/src/log_store/log_manager.rs @@ -1289,6 +1289,7 @@ pub fn data_to_merkle_leaves(leaf_data: &[u8]) -> Result> { .collect() }; + metrics::DATA_TO_MERKLE_LEAVES_SIZE.update(leaf_data.len()); metrics::DATA_TO_MERKLE_LEAVES.update_since(start_time); Ok(r) } diff --git a/node/storage/src/log_store/metrics.rs b/node/storage/src/log_store/metrics.rs index 55706a3..70ddfda 100644 --- a/node/storage/src/log_store/metrics.rs +++ b/node/storage/src/log_store/metrics.rs @@ -1,6 +1,6 @@ use std::sync::Arc; -use metrics::{register_timer, Timer}; +use metrics::{register_timer, Gauge, GaugeUsize, Timer}; lazy_static::lazy_static! { pub static ref PUT_TX: Arc = register_timer("log_store_put_tx"); @@ -36,4 +36,6 @@ lazy_static::lazy_static! { pub static ref APPEND_ENTRIES: Arc = register_timer("log_store_flow_store_append_entries"); pub static ref FINALIZE_TX_WITH_HASH: Arc = register_timer("log_store_log_manager_finalize_tx_with_hash"); + + pub static ref DATA_TO_MERKLE_LEAVES_SIZE: Arc> = GaugeUsize::register("log_store_data_to_merkle_leaves_size"); }