pub struct PreparedStepSubmissionWave<R>where
R: DeviceRuntime,{ /* private fields */ }Expand description
Exact canonical command wave for one Step. Product waves cover the complete plan; determinism probes carry a sealed purpose for a plan-ordered subset. Node projections and shared Step backing remain owned until the one device fence reaches a terminal state; dropping a prepared wave rolls back.
Implementations§
Source§impl<R> PreparedStepSubmissionWave<R>where
R: DeviceRuntime,
impl<R> PreparedStepSubmissionWave<R>where
R: DeviceRuntime,
pub fn batch_step_id(&self) -> BatchStepId
pub const fn batch_invocation_id(&self) -> BatchInvocationId
pub const fn execution_lane_id(&self) -> ExecutionLaneId
pub fn fingerprint(&self) -> &str
pub fn nodes(&self) -> &[PreparedStepSubmissionNode<R>]
pub fn claimed_backing(&self) -> &ClaimedSubmissionWaveBacking
pub fn node_count(&self) -> usize
pub fn prepared_participant_flight_count(&self) -> usize
pub fn node_participant_projection_count(&self) -> usize
pub fn physical_invocation_ledger_entry_count(&self) -> usize
pub fn step_resources(&self) -> &Arc<StepResourceLease<R>> ⓘ
Auto Trait Implementations§
impl<R> !RefUnwindSafe for PreparedStepSubmissionWave<R>
impl<R> !UnwindSafe for PreparedStepSubmissionWave<R>
impl<R> Freeze for PreparedStepSubmissionWave<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Freeze,
Vec<PreparedStepSubmissionNode<R>>: Freeze,
Arc<StepResourceLease<R>>: Freeze,
impl<R> Send for PreparedStepSubmissionWave<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Send,
Vec<PreparedStepSubmissionNode<R>>: Send,
Arc<StepResourceLease<R>>: Send,
impl<R> Sync for PreparedStepSubmissionWave<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Sync,
Vec<PreparedStepSubmissionNode<R>>: Sync,
Arc<StepResourceLease<R>>: Sync,
impl<R> Unpin for PreparedStepSubmissionWave<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: Unpin,
Vec<PreparedStepSubmissionNode<R>>: Unpin,
Arc<StepResourceLease<R>>: Unpin,
impl<R> UnsafeUnpin for PreparedStepSubmissionWave<R>where
Option<RequestStateHazardPermit<Arc<AdmittedRequestResources<R>>>>: UnsafeUnpin,
Vec<PreparedStepSubmissionNode<R>>: UnsafeUnpin,
Arc<StepResourceLease<R>>: UnsafeUnpin,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more