Struct DirectReplicatedTextExecution 

pub struct DirectReplicatedTextExecution;

Ordinary unit execution for replicated text architectures.

Trait Implementations

impl Clone for DirectReplicatedTextExecution

fn clone(&self) -> DirectReplicatedTextExecution

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for DirectReplicatedTextExecution

impl Debug for DirectReplicatedTextExecution

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

Formats the value using the given formatter.

impl Default for DirectReplicatedTextExecution

fn default() -> DirectReplicatedTextExecution

Returns the “default value” for a type.

impl<A, B, S, R, P> ReplicatedRuntimeExecutionStrategy<A, B, S, R, P> for DirectReplicatedTextExecution

where B: SubmissionBackend<Executor = <<B as NeuralBackend>::Tensor as Tensor>::Context>, S: RuntimeState<B>, A: LayeredArchitecture<B, S>, R: LayerwisePolicy<B, A::Unit>, P: LayerwisePolicy<B, A::Unit, Error = R::Error>, A::Error: Display, P::Error: Display,

impl<A, B, S, R, P> ReplicatedTextExecutionStrategy<A, B, S, R, P> for DirectReplicatedTextExecution

where B: SubmissionBackend<Executor = <<B as NeuralBackend>::Tensor as Tensor>::Context>, S: RuntimeState<B>, A: LayeredArchitecture<B, S>, R: LayerwisePolicy<B, A::Unit>, P: LayerwisePolicy<B, A::Unit, Error = R::Error>, A::Error: Display, P::Error: Display,

type Runtime = ReplicatedTextRuntime<A, B, S, R, P>

Concrete execution runtime paired before the shared session lifecycle begins.

fn bounded_policy(runtime: &Self::Runtime) -> Option<&P>

Returns bounded residency state for the shared session report.

fn execution_residency( _runtime: &Self::Runtime, selected: &SelectedReplicatedTextRealization, ) -> ExecutionResidency

Returns the execution residency actually installed on this rank.

fn forward_with_observer<'a, O>( &mut self, runtime: &mut Self::Runtime, input: A::Input<'a>, state: &mut S, _pass: ExpertPass, context: &<<B as NeuralBackend>::Tensor as Tensor>::Context, observer: &mut O, ) -> Result<(B::Tensor, A::ForwardContext), ReplicatedTextSessionError<A::Error, R::Error, Infallible>>

where O: ActivationObserver<B::Tensor, A::Error> + ?Sized,

Executes one complete layered pass through the selected unit strategy.

fn prediction_target_capture( runtime: &mut Self::Runtime, forward: &A::ForwardContext, context: &<B::Tensor as Tensor>::Context, ) -> Result<Option<B::Tensor>, ReplicatedTextSessionError<A::Error, R::Error, Infallible>>

Resolves the rank-local tensor used by an additive prediction extension.

fn apply_prediction_target_operation<O>( runtime: &mut Self::Runtime, state: &mut S, operation: O, context: &<B::Tensor as Tensor>::Context, ) -> Result<Option<O::Output>, ReplicatedTextSessionError<A::Error, R::Error, Infallible>>

where O: PredictionTargetOperation<A, B, S>,

Runs one typed prediction-only operation against session-owned target modules and state.

const PARTITIONED_SESSION: bool = false

Whether this strategy executes one rank of a partitioned session.

const DISTRIBUTED_PHASE_AGREEMENT: bool = false

Whether control phases use a selected bounded all-rank agreement.

fn observe_output<O>( _runtime: &mut Self::Runtime, output: &B::Tensor, observer: &mut O, _context: &<B::Tensor as Tensor>::Context, ) -> Result<B::Tensor, ReplicatedTextSessionError<A::Error, R::Error, Infallible>>

where O: ActivationObserver<B::Tensor, A::Error> + ?Sized,

Applies the architecture’s final-logits observation on the rank that owns the authoritative output. Ordinary replicated strategies observe locally; partitioned strategies may suppress the seam on destinations.

fn publish_observed_output( _runtime: &mut Self::Runtime, output: B::Tensor, _context: &<B::Tensor as Tensor>::Context, ) -> Result<B::Tensor, ReplicatedTextSessionError<A::Error, R::Error, Infallible>>

Publishes an already-observed authoritative output after every rank has agreed that final observation succeeded.

fn publish_prediction_target_capture( _runtime: &mut Self::Runtime, capture: B::Tensor, _context: &<B::Tensor as Tensor>::Context, ) -> Result<B::Tensor, ReplicatedTextSessionError<A::Error, R::Error, Infallible>>

Publishes the output-owner capture to every prediction participant.

fn commit_after_completion( _runtime: &mut Self::Runtime, epoch: DistributedCommitEpoch, _context: &<<B as NeuralBackend>::Tensor as Tensor>::Context, ) -> DistributedCommitOutcome

Performs strategy-specific distributed commit only after output intervention and exact mechanism completion have succeeded.

fn agree_distributed_phase( _runtime: &mut Self::Runtime, _phase: DistributedExecutionPhase, local_success: bool, _context: &<<B as NeuralBackend>::Tensor as Tensor>::Context, ) -> Result<bool, ReplicatedTextSessionError<A::Error, R::Error, Infallible>>

Propagates one local shared-session phase result before the lifecycle can advance. Direct and unsupported strategies retain the local result.