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

feat: integrate event handling (#9666)

Browse Source
This commit is contained in:
Matthias Seitz
2024-07-20 15:29:20 +02:00
committed by GitHub
parent 146bca3e6f
commit b3c8280321
2 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/ethereum/engine/src/service.rs
View File

@@ -5,12 +5,15 @@ use reth_chainspec::ChainSpec;
use reth_db_api::database::Database;
use reth_engine_tree::{
backfill::PipelineSync,
chain::{ChainEvent, ChainOrchestrator},
download::BasicBlockDownloader,
engine::{EngineApiRequestHandler, EngineHandler},
persistence::PersistenceHandle,
tree::EngineApiTreeHandlerImpl,
};
pub use reth_engine_tree::{
chain::{ChainEvent, ChainOrchestrator},
engine::EngineApiEvent,
};
use reth_ethereum_engine_primitives::EthEngineTypes;
use reth_evm_ethereum::execute::EthExecutorProvider;
use reth_network_p2p::{bodies::client::BodiesClient, headers::client::HeadersClient};

14
crates/ethereum/node/src/launch.rs
View File

@@ -5,7 +5,7 @@ use reth_beacon_consensus::{
hooks::{EngineHooks, StaticFileHook},
BeaconConsensusEngineHandle,
};
use reth_ethereum_engine::service::EthService;
use reth_ethereum_engine::service::{ChainEvent, EthService};
use reth_ethereum_engine_primitives::EthEngineTypes;
use reth_exex::ExExManagerHandle;
use reth_network::NetworkEvents;
@@ -174,7 +174,7 @@ where
let event_sender = EventSender::default();
let beacon_engine_handle =
BeaconConsensusEngineHandle::new(consensus_engine_tx, event_sender);
BeaconConsensusEngineHandle::new(consensus_engine_tx, event_sender.clone());
info!(target: "reth::cli", "Consensus engine initialized");
@@ -237,8 +237,16 @@ where
let (tx, rx) = oneshot::channel();
info!(target: "reth::cli", "Starting consensus engine");
ctx.task_executor().spawn_critical_blocking("consensus engine", async move {
// advance the chain and handle events
while let Some(event) = eth_service.next().await {
info!(target: "reth::cli", "Event: {event:?}");
debug!(target: "reth::cli", "Event: {event:?}");
match event {
ChainEvent::BackfillSyncFinished | ChainEvent::BackfillSyncStarted => {}
ChainEvent::FatalError => break,
ChainEvent::Handler(ev) => {
event_sender.notify(ev);
}
}
}
let _ = tx.send(());
});