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

chore(root): cleanup some debt (#13427)

Browse Source
This commit is contained in:
Roman Krasiuk
2024-12-17 16:14:50 +01:00
committed by GitHub
parent abc4ff9779
commit e663f959b8
3 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
Cargo.lock generated
View File

@ -7391,6 +7391,7 @@ dependencies = [
"assert_matches", "assert_matches",
"criterion", "criterion",
"crossbeam-channel", "crossbeam-channel",
"derive_more",
"futures", "futures",
"metrics", "metrics",
"rand 0.8.5", "rand 0.8.5",

1
crates/engine/tree/Cargo.toml
View File

@ -58,6 +58,7 @@ reth-metrics = { workspace = true, features = ["common"] }
# misc # misc
rayon.workspace = true rayon.workspace = true
tracing.workspace = true tracing.workspace = true
derive_more.workspace = true
# optional deps for test-utils # optional deps for test-utils
reth-prune-types = { workspace = true, optional = true } reth-prune-types = { workspace = true, optional = true }

12
crates/engine/tree/src/tree/root.rs
View File

@ -1,6 +1,7 @@
//! State root task related functionality. //! State root task related functionality.
use alloy_primitives::map::HashSet; use alloy_primitives::map::HashSet;
use derive_more::derive::Deref;
use rayon::iter::{ParallelBridge, ParallelIterator}; use rayon::iter::{ParallelBridge, ParallelIterator};
use reth_errors::ProviderError; use reth_errors::ProviderError;
use reth_evm::system_calls::OnStateHook; use reth_evm::system_calls::OnStateHook;
@ -22,7 +23,6 @@ use reth_trie_sparse::{
use revm_primitives::{keccak256, EvmState, B256}; use revm_primitives::{keccak256, EvmState, B256};
use std::{ use std::{
collections::BTreeMap, collections::BTreeMap,
ops::Deref,
sync::{ sync::{
mpsc::{self, channel, Receiver, Sender}, mpsc::{self, channel, Receiver, Sender},
Arc, Arc,
@ -185,6 +185,7 @@ impl ProofSequencer {
/// A wrapper for the sender that signals completion when dropped /// A wrapper for the sender that signals completion when dropped
#[allow(dead_code)] #[allow(dead_code)]
#[derive(Deref)]
pub(crate) struct StateHookSender<BPF: BlindedProviderFactory>(Sender<StateRootMessage<BPF>>); pub(crate) struct StateHookSender<BPF: BlindedProviderFactory>(Sender<StateRootMessage<BPF>>);
#[allow(dead_code)] #[allow(dead_code)]
@ -194,14 +195,6 @@ impl<BPF: BlindedProviderFactory> StateHookSender<BPF> {
} }
} }
impl<BPF: BlindedProviderFactory> Deref for StateHookSender<BPF> {
type Target = Sender<StateRootMessage<BPF>>;
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl<BPF: BlindedProviderFactory> Drop for StateHookSender<BPF> { impl<BPF: BlindedProviderFactory> Drop for StateHookSender<BPF> {
fn drop(&mut self) { fn drop(&mut self) {
// Send completion signal when the sender is dropped // Send completion signal when the sender is dropped
@ -355,7 +348,6 @@ where
// TODO: replace with parallel proof // TODO: replace with parallel proof
let result = Proof::overlay_multiproof( let result = Proof::overlay_multiproof(
provider.tx_ref(), provider.tx_ref(),
// TODO(alexey): this clone can be expensive, we should avoid it
input.as_ref().clone(), input.as_ref().clone(),
proof_targets.clone(), proof_targets.clone(),
); );