github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-26 15:48:13 -05:00
Code Issues Packages Projects Releases Wiki Activity

perf: add more granular newPayload metrics (#14134)

Browse Source
This commit is contained in:
Dan Cline
2025-02-02 15:04:07 -05:00
committed by GitHub
parent 4167610fab
commit b06682e9af
2 changed files with 33 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/engine/tree/src/tree/metrics.rs
View File

@@ -67,6 +67,16 @@ pub(crate) struct BlockValidationMetrics {
pub(crate) state_root_histogram: Histogram,
/// Latest state root duration
pub(crate) state_root_duration: Gauge,
/// Trie input computation duration
pub(crate) trie_input_duration: Gauge,
/// Prewarm spawn duration
#[allow(dead_code)]
pub(crate) prewarm_spawn_duration: Gauge,
/// Cache saving duration
#[allow(dead_code)]
pub(crate) cache_saving_duration: Gauge,
/// State root config creation duration
pub(crate) state_root_config_duration: Gauge,
}
impl BlockValidationMetrics {

28
crates/engine/tree/src/tree/mod.rs
View File

@@ -2375,11 +2375,29 @@ where
let (state_root_handle, state_root_task_config, state_hook) =
if is_descendant_of_persisting_blocks && self.config.use_state_root_task() {
let consistent_view = ConsistentDbView::new_with_latest_tip(self.provider.clone())?;
let state_root_config = StateRootConfig::new_from_input(
consistent_view.clone(),
self.compute_trie_input(consistent_view, block.header().parent_hash())
.map_err(|e| InsertBlockErrorKind::Other(Box::new(e)))?,
);
// Compute trie input
let trie_input_start = Instant::now();
let trie_input = self
.compute_trie_input(consistent_view.clone(), block.header().parent_hash())
.map_err(|e| InsertBlockErrorKind::Other(Box::new(e)))?;
// Create state root config
let config_start = Instant::now();
let state_root_config =
StateRootConfig::new_from_input(consistent_view, trie_input);
let trie_input_elapsed = config_start - trie_input_start;
self.metrics
.block_validation
.trie_input_duration
.set(trie_input_elapsed.as_secs_f64());
let config_elapsed = config_start.elapsed();
self.metrics
.block_validation
.state_root_config_duration
.set(config_elapsed.as_secs_f64());
let state_root_task = StateRootTask::new(
state_root_config.clone(),