Struct SynchronizeTask

pub struct SynchronizeTask {
    pub client: Arc<EngineClient>,
    pub rollup: Arc<RollupConfig>,
    pub state_update: EngineSyncStateUpdate,
}

Internal task for execution layer forkchoice synchronization.

The SynchronizeTask performs engine_forkchoiceUpdated calls to synchronize the execution layer’s forkchoice state with the rollup node’s view. This task operates without payload attributes and is primarily used internally by other engine tasks rather than being directly enqueued by users.

Usage Patterns

• Internal Synchronization: Called by InsertTask, ConsolidateTask, and FinalizeTask
• Engine Reset: Used during engine resets to establish initial forkchoice state
• Safe Head Updates: Synchronizes safe and finalized head changes

Automatic Integration

Unlike the legacy ForkchoiceTask, forkchoice updates during block building are now handled automatically within BuildTask, eliminating the need for explicit forkchoice management in most user scenarios.

Fields

client: Arc<EngineClient>

The engine client.

rollup: Arc<RollupConfig>

The rollup config.

state_update: EngineSyncStateUpdate

The sync state update to apply to the engine state.

Implementations

impl SynchronizeTask

pub const fn new( client: Arc<EngineClient>, rollup: Arc<RollupConfig>, state_update: EngineSyncStateUpdate, ) -> Self

Creates a new SynchronizeTask.

Trait Implementations

impl Clone for SynchronizeTask

fn clone(&self) -> SynchronizeTask

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SynchronizeTask

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

Formats the value using the given formatter.

impl EngineTaskExt for SynchronizeTask

type Output = ()

The output type of the task.

type Error = SynchronizeTaskError

The error type of the task.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 mut EngineState, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, SynchronizeTaskError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes the task, taking a shared lock on the engine state and self.