Struct NoCommitAgreement 

pub struct NoCommitAgreement;

Proof that this execution path selects no distributed commit barrier.

Trait Implementations

impl Clone for NoCommitAgreement

fn clone(&self) -> NoCommitAgreement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for NoCommitAgreement

impl Debug for NoCommitAgreement

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

Formats the value using the given formatter.

impl Default for NoCommitAgreement

fn default() -> NoCommitAgreement

Returns the “default value” for a type.

impl<B, G, R, I> PartitionCommitAgreement<B, G, R, I> for NoCommitAgreement

where B: CommunicationBackend, G: Borrow<B::CommunicationGroup>, R: Borrow<B::CommunicationRoute>, I: CommunicationTensorMetadata<B>,

const ENABLED: bool = false

Whether this policy admits distributed commit agreement.

fn commit( &mut self, _communication: &PartitionCommunication<B, G, R, I>, _group: CollectiveGroupId, epoch: DistributedCommitEpoch, _executor: &B::Executor, ) -> DistributedCommitOutcome

Returns this rank’s honest observation of the globally identified final decision.

const PHASE_FAILURE_AGREEMENT: bool = false

Whether this policy propagates an explicit success status at every canonical shared-session phase.

fn agree_phase( &mut self, _communication: &PartitionCommunication<B, G, R, I>, _group: CollectiveGroupId, _phase: DistributedExecutionPhase, local_success: bool, _executor: &B::Executor, ) -> Result<bool, PartitionExecutionError>

Returns the conjunction of every member’s local phase status.

fn agree_phase_after_prior_failure( &mut self, communication: &PartitionCommunication<B, G, R, I>, group: CollectiveGroupId, phase: DistributedExecutionPhase, local_success: bool, executor: &B::Executor, ) -> Result<bool, PartitionExecutionError>

Performs the canonical all-rank agreement after an earlier subgroup communication failure poisoned the local session authority.