chore: apply same member order (#12253)

This commit is contained in:
Matthias Seitz
2024-11-01 12:11:54 +01:00
committed by GitHub
parent 2758a560c0
commit c6b740801f
13 changed files with 98 additions and 98 deletions

View File

@ -60,6 +60,12 @@ impl BlockchainTreeEngine for NoopBlockchainTree {
Ok(()) Ok(())
} }
fn update_block_hashes_and_clear_buffered(
&self,
) -> Result<BTreeMap<BlockNumber, BlockHash>, CanonicalError> {
Ok(BTreeMap::new())
}
fn connect_buffered_blocks_to_canonical_hashes(&self) -> Result<(), CanonicalError> { fn connect_buffered_blocks_to_canonical_hashes(&self) -> Result<(), CanonicalError> {
Ok(()) Ok(())
} }
@ -67,12 +73,6 @@ impl BlockchainTreeEngine for NoopBlockchainTree {
fn make_canonical(&self, block_hash: BlockHash) -> Result<CanonicalOutcome, CanonicalError> { fn make_canonical(&self, block_hash: BlockHash) -> Result<CanonicalOutcome, CanonicalError> {
Err(BlockchainTreeError::BlockHashNotFoundInChain { block_hash }.into()) Err(BlockchainTreeError::BlockHashNotFoundInChain { block_hash }.into())
} }
fn update_block_hashes_and_clear_buffered(
&self,
) -> Result<BTreeMap<BlockNumber, BlockHash>, CanonicalError> {
Ok(BTreeMap::new())
}
} }
impl BlockchainTreeViewer for NoopBlockchainTree { impl BlockchainTreeViewer for NoopBlockchainTree {

View File

@ -108,11 +108,6 @@ where
}); });
} }
fn without_head(mut self) -> Self {
self.set_without_head();
self
}
fn set_with_head(&mut self, exex_head: ExExHead) { fn set_with_head(&mut self, exex_head: ExExHead) {
let current = std::mem::replace(&mut self.inner, ExExNotificationsInner::Invalid); let current = std::mem::replace(&mut self.inner, ExExNotificationsInner::Invalid);
self.inner = ExExNotificationsInner::WithHead(match current { self.inner = ExExNotificationsInner::WithHead(match current {
@ -131,6 +126,11 @@ where
}); });
} }
fn without_head(mut self) -> Self {
self.set_without_head();
self
}
fn with_head(mut self, exex_head: ExExHead) -> Self { fn with_head(mut self, exex_head: ExExHead) -> Self {
self.set_with_head(exex_head); self.set_with_head(exex_head);
self self

View File

@ -95,8 +95,8 @@ impl<T: FullNodeTypes, C: NodeComponents<T>> FullNodeComponents for NodeAdapter<
type Pool = C::Pool; type Pool = C::Pool;
type Evm = C::Evm; type Evm = C::Evm;
type Executor = C::Executor; type Executor = C::Executor;
type Network = C::Network;
type Consensus = C::Consensus; type Consensus = C::Consensus;
type Network = C::Network;
fn pool(&self) -> &Self::Pool { fn pool(&self) -> &Self::Pool {
self.components.pool() self.components.pool()
@ -110,8 +110,8 @@ impl<T: FullNodeTypes, C: NodeComponents<T>> FullNodeComponents for NodeAdapter<
self.components.block_executor() self.components.block_executor()
} }
fn provider(&self) -> &Self::Provider { fn consensus(&self) -> &Self::Consensus {
&self.provider self.components.consensus()
} }
fn network(&self) -> &Self::Network { fn network(&self) -> &Self::Network {
@ -122,12 +122,12 @@ impl<T: FullNodeTypes, C: NodeComponents<T>> FullNodeComponents for NodeAdapter<
self.components.payload_builder() self.components.payload_builder()
} }
fn task_executor(&self) -> &TaskExecutor { fn provider(&self) -> &Self::Provider {
&self.task_executor &self.provider
} }
fn consensus(&self) -> &Self::Consensus { fn task_executor(&self) -> &TaskExecutor {
self.components.consensus() &self.task_executor
} }
} }

View File

@ -119,8 +119,8 @@ where
{ {
type Provider = N::Provider; type Provider = N::Provider;
type Pool = N::Pool; type Pool = N::Pool;
type Network = <N as RpcNodeCore>::Network;
type Evm = <N as RpcNodeCore>::Evm; type Evm = <N as RpcNodeCore>::Evm;
type Network = <N as RpcNodeCore>::Network;
#[inline] #[inline]
fn pool(&self) -> &Self::Pool { fn pool(&self) -> &Self::Pool {

View File

@ -150,27 +150,27 @@ mod block_rlp {
} }
impl Encodable for Block { impl Encodable for Block {
fn length(&self) -> usize {
let helper: HelperRef<'_, _> = self.into();
helper.length()
}
fn encode(&self, out: &mut dyn bytes::BufMut) { fn encode(&self, out: &mut dyn bytes::BufMut) {
let helper: HelperRef<'_, _> = self.into(); let helper: HelperRef<'_, _> = self.into();
helper.encode(out) helper.encode(out)
} }
fn length(&self) -> usize {
let helper: HelperRef<'_, _> = self.into();
helper.length()
}
} }
impl Encodable for SealedBlock { impl Encodable for SealedBlock {
fn length(&self) -> usize {
let helper: HelperRef<'_, _> = self.into();
helper.length()
}
fn encode(&self, out: &mut dyn bytes::BufMut) { fn encode(&self, out: &mut dyn bytes::BufMut) {
let helper: HelperRef<'_, _> = self.into(); let helper: HelperRef<'_, _> = self.into();
helper.encode(out) helper.encode(out)
} }
fn length(&self) -> usize {
let helper: HelperRef<'_, _> = self.into();
helper.length()
}
} }
} }

View File

@ -38,8 +38,8 @@ where
{ {
type Provider = T::Provider; type Provider = T::Provider;
type Pool = T::Pool; type Pool = T::Pool;
type Network = <T as FullNodeComponents>::Network;
type Evm = <T as FullNodeComponents>::Evm; type Evm = <T as FullNodeComponents>::Evm;
type Network = <T as FullNodeComponents>::Network;
#[inline] #[inline]
fn pool(&self) -> &Self::Pool { fn pool(&self) -> &Self::Pool {

View File

@ -150,8 +150,8 @@ where
{ {
type Provider = Provider; type Provider = Provider;
type Pool = Pool; type Pool = Pool;
type Network = Network;
type Evm = EvmConfig; type Evm = EvmConfig;
type Network = Network;
fn pool(&self) -> &Self::Pool { fn pool(&self) -> &Self::Pool {
self.inner.pool() self.inner.pool()

View File

@ -2055,6 +2055,11 @@ impl<TX: DbTx, N: NodeTypes> StageCheckpointReader for DatabaseProvider<TX, N> {
Ok(self.tx.get::<tables::StageCheckpoints>(id.to_string())?) Ok(self.tx.get::<tables::StageCheckpoints>(id.to_string())?)
} }
/// Get stage checkpoint progress.
fn get_stage_checkpoint_progress(&self, id: StageId) -> ProviderResult<Option<Vec<u8>>> {
Ok(self.tx.get::<tables::StageCheckpointProgresses>(id.to_string())?)
}
fn get_all_checkpoints(&self) -> ProviderResult<Vec<(String, StageCheckpoint)>> { fn get_all_checkpoints(&self) -> ProviderResult<Vec<(String, StageCheckpoint)>> {
self.tx self.tx
.cursor_read::<tables::StageCheckpoints>()? .cursor_read::<tables::StageCheckpoints>()?
@ -2062,11 +2067,6 @@ impl<TX: DbTx, N: NodeTypes> StageCheckpointReader for DatabaseProvider<TX, N> {
.collect::<Result<Vec<(String, StageCheckpoint)>, _>>() .collect::<Result<Vec<(String, StageCheckpoint)>, _>>()
.map_err(ProviderError::Database) .map_err(ProviderError::Database)
} }
/// Get stage checkpoint progress.
fn get_stage_checkpoint_progress(&self, id: StageId) -> ProviderResult<Option<Vec<u8>>> {
Ok(self.tx.get::<tables::StageCheckpointProgresses>(id.to_string())?)
}
} }
impl<TX: DbTxMut, N: NodeTypes> StageCheckpointWriter for DatabaseProvider<TX, N> { impl<TX: DbTxMut, N: NodeTypes> StageCheckpointWriter for DatabaseProvider<TX, N> {

View File

@ -601,35 +601,6 @@ impl<N: ProviderNodeTypes> StateProviderFactory for BlockchainProvider<N> {
self.database.latest() self.database.latest()
} }
fn history_by_block_number(
&self,
block_number: BlockNumber,
) -> ProviderResult<StateProviderBox> {
trace!(target: "providers::blockchain", ?block_number, "Getting history by block number");
self.ensure_canonical_block(block_number)?;
self.database.history_by_block_number(block_number)
}
fn history_by_block_hash(&self, block_hash: BlockHash) -> ProviderResult<StateProviderBox> {
trace!(target: "providers::blockchain", ?block_hash, "Getting history by block hash");
self.database.history_by_block_hash(block_hash)
}
fn state_by_block_hash(&self, block: BlockHash) -> ProviderResult<StateProviderBox> {
trace!(target: "providers::blockchain", ?block, "Getting state by block hash");
let mut state = self.history_by_block_hash(block);
// we failed to get the state by hash, from disk, hash block be the pending block
if state.is_err() {
if let Ok(Some(pending)) = self.pending_state_by_hash(block) {
// we found pending block by hash
state = Ok(pending)
}
}
state
}
/// Returns a [`StateProviderBox`] indexed by the given block number or tag. /// Returns a [`StateProviderBox`] indexed by the given block number or tag.
/// ///
/// Note: if a number is provided this will only look at historical(canonical) state. /// Note: if a number is provided this will only look at historical(canonical) state.
@ -662,6 +633,35 @@ impl<N: ProviderNodeTypes> StateProviderFactory for BlockchainProvider<N> {
} }
} }
fn history_by_block_number(
&self,
block_number: BlockNumber,
) -> ProviderResult<StateProviderBox> {
trace!(target: "providers::blockchain", ?block_number, "Getting history by block number");
self.ensure_canonical_block(block_number)?;
self.database.history_by_block_number(block_number)
}
fn history_by_block_hash(&self, block_hash: BlockHash) -> ProviderResult<StateProviderBox> {
trace!(target: "providers::blockchain", ?block_hash, "Getting history by block hash");
self.database.history_by_block_hash(block_hash)
}
fn state_by_block_hash(&self, block: BlockHash) -> ProviderResult<StateProviderBox> {
trace!(target: "providers::blockchain", ?block, "Getting state by block hash");
let mut state = self.history_by_block_hash(block);
// we failed to get the state by hash, from disk, hash block be the pending block
if state.is_err() {
if let Ok(Some(pending)) = self.pending_state_by_hash(block) {
// we found pending block by hash
state = Ok(pending)
}
}
state
}
/// Returns the state provider for pending state. /// Returns the state provider for pending state.
/// ///
/// If there's no pending block available then the latest state provider is returned: /// If there's no pending block available then the latest state provider is returned:

View File

@ -760,18 +760,6 @@ impl StateProviderFactory for MockEthProvider {
Ok(Box::new(self.clone())) Ok(Box::new(self.clone()))
} }
fn history_by_block_number(&self, _block: BlockNumber) -> ProviderResult<StateProviderBox> {
Ok(Box::new(self.clone()))
}
fn history_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(self.clone()))
}
fn state_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(self.clone()))
}
fn state_by_block_number_or_tag( fn state_by_block_number_or_tag(
&self, &self,
number_or_tag: BlockNumberOrTag, number_or_tag: BlockNumberOrTag,
@ -798,6 +786,18 @@ impl StateProviderFactory for MockEthProvider {
} }
} }
fn history_by_block_number(&self, _block: BlockNumber) -> ProviderResult<StateProviderBox> {
Ok(Box::new(self.clone()))
}
fn history_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(self.clone()))
}
fn state_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(self.clone()))
}
fn pending(&self) -> ProviderResult<StateProviderBox> { fn pending(&self) -> ProviderResult<StateProviderBox> {
Ok(Box::new(self.clone())) Ok(Box::new(self.clone()))
} }

View File

@ -465,22 +465,6 @@ impl StateProviderFactory for NoopProvider {
Ok(Box::new(*self)) Ok(Box::new(*self))
} }
fn history_by_block_number(&self, _block: BlockNumber) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn history_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn state_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn pending(&self) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn state_by_block_number_or_tag( fn state_by_block_number_or_tag(
&self, &self,
number_or_tag: BlockNumberOrTag, number_or_tag: BlockNumberOrTag,
@ -507,6 +491,22 @@ impl StateProviderFactory for NoopProvider {
} }
} }
fn history_by_block_number(&self, _block: BlockNumber) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn history_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn state_by_block_hash(&self, _block: BlockHash) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn pending(&self) -> ProviderResult<StateProviderBox> {
Ok(Box::new(*self))
}
fn pending_state_by_hash(&self, _block_hash: B256) -> ProviderResult<Option<StateProviderBox>> { fn pending_state_by_hash(&self, _block_hash: B256) -> ProviderResult<Option<StateProviderBox>> {
Ok(Some(Box::new(*self))) Ok(Some(Box::new(*self)))
} }

View File

@ -32,11 +32,11 @@ pub struct NoopHashedAccountCursor;
impl HashedCursor for NoopHashedAccountCursor { impl HashedCursor for NoopHashedAccountCursor {
type Value = Account; type Value = Account;
fn next(&mut self) -> Result<Option<(B256, Self::Value)>, DatabaseError> { fn seek(&mut self, _key: B256) -> Result<Option<(B256, Self::Value)>, DatabaseError> {
Ok(None) Ok(None)
} }
fn seek(&mut self, _key: B256) -> Result<Option<(B256, Self::Value)>, DatabaseError> { fn next(&mut self) -> Result<Option<(B256, Self::Value)>, DatabaseError> {
Ok(None) Ok(None)
} }
} }
@ -49,11 +49,11 @@ pub struct NoopHashedStorageCursor;
impl HashedCursor for NoopHashedStorageCursor { impl HashedCursor for NoopHashedStorageCursor {
type Value = U256; type Value = U256;
fn next(&mut self) -> Result<Option<(B256, Self::Value)>, DatabaseError> { fn seek(&mut self, _key: B256) -> Result<Option<(B256, Self::Value)>, DatabaseError> {
Ok(None) Ok(None)
} }
fn seek(&mut self, _key: B256) -> Result<Option<(B256, Self::Value)>, DatabaseError> { fn next(&mut self) -> Result<Option<(B256, Self::Value)>, DatabaseError> {
Ok(None) Ok(None)
} }
} }

View File

@ -211,8 +211,8 @@ impl PrefixSet {
} }
impl<'a> IntoIterator for &'a PrefixSet { impl<'a> IntoIterator for &'a PrefixSet {
type IntoIter = std::slice::Iter<'a, reth_trie_common::Nibbles>;
type Item = &'a reth_trie_common::Nibbles; type Item = &'a reth_trie_common::Nibbles;
type IntoIter = std::slice::Iter<'a, reth_trie_common::Nibbles>;
fn into_iter(self) -> Self::IntoIter { fn into_iter(self) -> Self::IntoIter {
self.iter() self.iter()
} }