Struct OpaqueCommitAgreement 

pub struct OpaqueCommitAgreement;

Barrier commit agreement requiring no tensor communication capabilities.

Trait Implementations

impl Clone for OpaqueCommitAgreement

fn clone(&self) -> OpaqueCommitAgreement

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for OpaqueCommitAgreement

impl Debug for OpaqueCommitAgreement

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

Formats the value using the given formatter.

impl Default for OpaqueCommitAgreement

fn default() -> OpaqueCommitAgreement

Returns the “default value” for a type.

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

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

const ENABLED: bool = true

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.