Class Actor

application/src/actor.rs:34–56

#[cfg(feature = "prom")]
use metrics::{counter, histogram};
use summit_syncer::ingress::mailbox::Mailbox as SyncerMailbox;
use summit_types::{Block, BlockAuxData, Digest, EngineClient};

/// How long to wait before retrying check_payload when Reth returns SYNCING during certify.
const CERTIFY_SYNCING_RETRY: Duration = Duration::from_millis(100);

fn proposal_timestamp_wait(
    now_millis: u64,
    min_child_timestamp: u64,
    allowed_timestamp_future_ms: u64,
) -> Duration {
    // Verifiers accept timestamps up to `now + allowed_timestamp_future_ms`.
    // If the minimum monotonic child timestamp is beyond that bound, wait just
    // long enough for it to enter the verifier's future window.
    let max_allowed_timestamp = now_millis.saturating_add(allowed_timestamp_future_ms);
    Duration::from_millis(min_child_timestamp.saturating_sub(max_allowed_timestamp))
}

fn select_proposal_timestamp(now_millis: u64, min_child_timestamp: u64) -> u64 {
    // Once `min_child_timestamp` is inside the verifier future window, choose
    // the later of local time and `parent.timestamp + 1` to preserve monotonicity.
    now_millis.max(min_child_timestamp)
}

/// Whether the wait required to bring the monotonic child timestamp into the
/// verifier future window exceeds the leader window. When true the block could