Enum MerkleStage

pub enum MerkleStage {
    Execution {
        clean_threshold: u64,
    },
    Unwind,
    Both {
        clean_threshold: u64,
    },
}

The merkle hashing stage uses input from AccountHashingStage and StorageHashingStage to calculate intermediate hashes and state roots.

This stage should be run with the above two stages, otherwise it is a no-op.

This stage is split in two: one for calculating hashes and one for unwinding.

When run in execution, it’s going to be executed AFTER the hashing stages, to generate the state root. When run in unwind mode, it’s going to be executed BEFORE the hashing stages, so that it unwinds the intermediate hashes based on the unwound hashed state from the hashing stages. The order of these two variants is important. The unwind variant should be added to the pipeline before the execution variant.

An example pipeline to only hash state would be:

• MerkleStage::Unwind
• AccountHashingStage
• StorageHashingStage
• MerkleStage::Execution

Variants

Execution

The execution portion of the merkle stage.

Fields

clean_threshold: u64

The threshold (in number of blocks) for switching from incremental trie building of changes to whole rebuild.

Unwind

The unwind portion of the merkle stage.

Both

Available on crate feature test-utils only.

Able to execute and unwind. Used for tests

Fields

clean_threshold: u64

The threshold (in number of blocks) for switching from incremental trie building of changes to whole rebuild.

Implementations

impl MerkleStage

pub const fn default_execution() -> Self

Stage default for the MerkleStage::Execution.

pub const fn default_unwind() -> Self

Stage default for the MerkleStage::Unwind.

pub const fn new_execution(clean_threshold: u64) -> Self

Create new instance of MerkleStage::Execution.

pub fn get_execution_checkpoint( &self, provider: &impl StageCheckpointReader, ) -> Result<Option<MerkleCheckpoint>, StageError>

Gets the hashing progress

pub fn save_execution_checkpoint( &self, provider: &impl StageCheckpointWriter, checkpoint: Option<MerkleCheckpoint>, ) -> Result<(), StageError>

Saves the hashing progress

Trait Implementations

impl Clone for MerkleStage

fn clone(&self) -> MerkleStage

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MerkleStage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Provider> Stage<Provider> for MerkleStage

where Provider: DBProvider<Tx: DbTxMut> + TrieWriter + StatsReader + HeaderProvider + StageCheckpointReader + StageCheckpointWriter,

fn id(&self) -> StageId

Return the id of the stage

fn execute( &mut self, provider: &Provider, input: ExecInput, ) -> Result<ExecOutput, StageError>

Execute the stage.

fn unwind( &mut self, provider: &Provider, input: UnwindInput, ) -> Result<UnwindOutput, StageError>

Unwind the stage.

fn poll_execute_ready( &mut self, _cx: &mut Context<'_>, _input: ExecInput, ) -> Poll<Result<(), StageError>>

Returns Poll::Ready(Ok(())) when the stage is ready to execute the given range.

fn post_execute_commit(&mut self) -> Result<(), StageError>

Post execution commit hook.

fn post_unwind_commit(&mut self) -> Result<(), StageError>

Post unwind commit hook.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 16 bytes

Size for each variant:

• Execution: 8 bytes
• Unwind: 0 bytes
• Both: 8 bytes