jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 19:09:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: disable eta for headers & bodies (#4065)

Browse Source
This commit is contained in:
Roman Krasiuk
2023-08-09 15:17:19 +03:00
committed by GitHub
parent 517f86aa2f
commit 6581961d3f
1 changed files with 17 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
bin/reth/src/node/events.rs
View File

@ -66,7 +66,7 @@ impl NodeState {
stage = %stage_id,
from = self.current_checkpoint.block_number,
checkpoint = %self.current_checkpoint,
eta = %self.eta,
eta = %self.eta.fmt_for_stage(stage_id),
"Executing stage",
);
}
@ -85,7 +85,7 @@ impl NodeState {
stage = %stage_id,
block = checkpoint.block_number,
%checkpoint,
eta = %self.eta,
eta = %self.eta.fmt_for_stage(stage_id),
"{}",
if done {
"Stage finished executing"
@ -226,13 +226,13 @@ where
let mut this = self.project();
while this.info_interval.poll_tick(cx).is_ready() {
if let Some(stage) = this.state.current_stage.map(|id| id.to_string()) {
if let Some(stage_id) = this.state.current_stage {
info!(
target: "reth::cli",
connected_peers = this.state.num_connected_peers(),
%stage,
stage = %stage_id.to_string(),
checkpoint = %this.state.current_checkpoint,
eta = %this.state.eta,
eta = %this.state.eta.fmt_for_stage(stage_id),
"Status"
);
} else {
@ -299,6 +299,18 @@ impl Eta {
self.last_checkpoint = current;
self.last_checkpoint_time = Some(Instant::now());
}
/// Format ETA for a given stage.
///
/// NOTE: Currently ETA is disabled for Headers and Bodies stages until we find better
/// heuristics for calculation.
fn fmt_for_stage(&self, stage: StageId) -> String {
if matches!(stage, StageId::Headers | StageId::Bodies) {
String::from("unknown")
} else {
format!("{}", self)
}
}
}
impl std::fmt::Display for Eta {