From d2b408184987bcc20982241001cd1b9edbf55808 Mon Sep 17 00:00:00 2001 From: rakita Date: Mon, 26 Dec 2022 23:09:04 +0100 Subject: [PATCH] feat: Enable ExecutionStage (#622) --- bin/reth/src/node/mod.rs | 9 +++++++-- crates/stages/src/stages/execution.rs | 3 ++- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/bin/reth/src/node/mod.rs b/bin/reth/src/node/mod.rs index a49147dc5..1962888f5 100644 --- a/bin/reth/src/node/mod.rs +++ b/bin/reth/src/node/mod.rs @@ -17,6 +17,7 @@ use reth_db::{ transaction::{DbTx, DbTxMut}, }; use reth_downloaders::{bodies, headers}; +use reth_executor::Config as ExecutorConfig; use reth_interfaces::consensus::ForkchoiceState; use reth_network::{ config::{mainnet_nodes, rng_secret_key}, @@ -26,7 +27,10 @@ use reth_network::{ use reth_primitives::{Account, Header, H256}; use reth_provider::{db_provider::ProviderImpl, BlockProvider, HeaderProvider}; use reth_stages::{ - stages::{bodies::BodyStage, headers::HeaderStage, sender_recovery::SenderRecoveryStage}, + stages::{ + bodies::BodyStage, execution::ExecutionStage, headers::HeaderStage, + sender_recovery::SenderRecoveryStage, + }, stages_metrics::HeaderMetrics, stages_metrics_describer, }; @@ -136,7 +140,8 @@ impl Command { .push(SenderRecoveryStage { batch_size: config.stages.sender_recovery.batch_size, commit_threshold: config.stages.sender_recovery.commit_threshold, - }); + }) + .push(ExecutionStage { config: ExecutorConfig::new_ethereum() }); if let Some(tip) = self.tip { debug!("Tip manually set: {}", tip); diff --git a/crates/stages/src/stages/execution.rs b/crates/stages/src/stages/execution.rs index 61d129559..00afa864c 100644 --- a/crates/stages/src/stages/execution.rs +++ b/crates/stages/src/stages/execution.rs @@ -51,7 +51,8 @@ const EXECUTION: StageId = StageId("Execution"); /// to [tables::PlainStorageState] #[derive(Debug)] pub struct ExecutionStage { - config: Config, + /// Executor configuration. + pub config: Config, } impl Default for ExecutionStage {