github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-04-08 03:01:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore: fix formatting in launch_node (#20582)

Browse Source
This commit is contained in:
DaniPopes
2025-12-23 05:18:40 -03:00
committed by GitHub
parent 353c2a7f70
commit 8374646e49
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
crates/node/builder/src/launch/engine.rs
View File

@@ -290,7 +290,7 @@ impl EngineNodeLauncher {
let startup_sync_state_idle = ctx.node_config().debug.startup_sync_state_idle;
info!(target: "reth::cli", "Starting consensus engine");
ctx.task_executor().spawn_critical("consensus engine", Box::pin(async move {
let consensus_engine = async move {
if let Some(initial_target) = initial_target {
debug!(target: "reth::cli", %initial_target, "start backfill sync");
// network_handle's sync state is already initialized at Syncing
@@ -302,7 +302,9 @@ impl EngineNodeLauncher {
let mut res = Ok(());
let mut shutdown_rx = shutdown_rx.fuse();
// advance the chain and await payloads built locally to add into the engine api tree handler to prevent re-execution if that block is received as payload from the CL
// advance the chain and await payloads built locally to add into the engine api
// tree handler to prevent re-execution if that block is received as payload from
// the CL
loop {
tokio::select! {
shutdown_req = &mut shutdown_rx => {
@@ -344,19 +346,21 @@ impl EngineNodeLauncher {
if let Some(head) = ev.canonical_header() {
// Once we're progressing via live sync, we can consider the node is not syncing anymore
network_handle.update_sync_state(SyncState::Idle);
let head_block = Head {
let head_block = Head {
number: head.number(),
hash: head.hash(),
difficulty: head.difficulty(),
timestamp: head.timestamp(),
total_difficulty: chainspec.final_paris_total_difficulty().filter(|_| chainspec.is_paris_active_at_block(head.number())).unwrap_or_default(),
total_difficulty: chainspec.final_paris_total_difficulty()
.filter(|_| chainspec.is_paris_active_at_block(head.number()))
.unwrap_or_default(),
};
network_handle.update_status(head_block);
let updated = BlockRangeUpdate {
earliest: provider.earliest_block_number().unwrap_or_default(),
latest:head.number(),
latest_hash:head.hash()
latest: head.number(),
latest_hash: head.hash(),
};
network_handle.update_block_range(updated);
}
@@ -368,7 +372,8 @@ impl EngineNodeLauncher {
}
let _ = exit.send(res);
}));
};
ctx.task_executor().spawn_critical("consensus engine", Box::pin(consensus_engine));
let full_node = FullNode {
evm_config: ctx.components().evm_config().clone(),