Skip to main content

execute_parallel_proposal

traverse_runtime::parallel_proposal

Function execute_parallel_proposal 

Source 
pub fn execute_parallel_proposal<E: LocalExecutor>(
    runtime: &Runtime<E>,
    canonical: &CanonicalProposal,
    schedule: &ParallelSchedule,
    authorization: AuthorizationSummary,
    proposal_digest: &str,
    snapshot_digest: &str,
    limits: &ParallelExecutionLimits,
) -> ProposalTrace
where
    Runtime<E>: Sync,
Expand description

Executes an authorized ParallelSchedule wave by wave, dispatching each wave’s nodes concurrently (bounded to limits.max_concurrent_nodes batches) when the wave has more than one member, and folding results back in lexicographic order regardless of real completion order (spec 110 FR-002).

Stops advancing to further waves — but never interrupts an already-dispatched one — at the first node failure, exhausted wall-time budget, or exceeded wave payload budget (spec 110 FR-005, FR-008 carried over from P1).