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

fix(node): Graceful engine shutdown on node drop (#22698)

Browse Source
This commit is contained in:
Julio
2026-03-06 12:32:36 +08:00
committed by GitHub
parent 6149ac6c0e
commit cda19b07d6
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -293,7 +293,7 @@ impl EngineNodeLauncher {
let startup_sync_state_idle = ctx.node_config().debug.startup_sync_state_idle;
info!(target: "reth::cli", "Starting consensus engine");
let consensus_engine = async move {
let consensus_engine = move |mut on_graceful_shutdown| 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
@@ -371,12 +371,25 @@ impl EngineNodeLauncher {
);
}
}
_ = &mut on_graceful_shutdown => {
// Shutdown signal received.
// Send Terminate so the engine OS thread can exit cleanly before we
// drop the orchestrator.
debug!(target: "reth::cli", "shutdown signal received, terminating engine");
let (done_tx, done_rx) = oneshot::channel();
orchestrator.handler_mut().handler_mut().on_event(
FromOrchestrator::Terminate { tx: done_tx }.into()
);
let _ = done_rx.await;
break;
}
}
}
let _ = exit.send(res);
};
ctx.task_executor().spawn_critical_task("consensus engine", consensus_engine);
ctx.task_executor()
.spawn_critical_with_shutdown_signal("consensus engine", consensus_engine);
let engine_events_for_ethstats = engine_events.new_listener();