Struct NativeCheckpointTransfer 

pub struct NativeCheckpointTransfer<R: DeviceRuntime> { /* private fields */ }

One native reaper slot. Polling errors are not proof of quiescence. Keep the handle for blocking recovery or lane drain. Dropping it never releases an unknown write: it marks the exact result abandoned for the existing reaper’s sweep/recovery path, which continues owning all native resources meanwhile.

Implementations

impl<R: DeviceRuntime> NativeCheckpointTransfer<R>

pub fn slot_id(&self) -> CompletionSlotId

pub fn poll(&self) -> Result<NativeCheckpointObservation, VNextError>

pub fn wait_for_recovery( &self, ) -> Result<NativeCheckpointObservation, VNextError>

Blocking recovery; callers should use their existing completion worker.

pub fn recover_by_draining_lane( &self, ) -> Result<NativeCheckpointObservation, VNextError>

pub fn take_result( &mut self, ) -> Result<Option<NativeCheckpointResult<R>>, VNextError>

Takes a terminal result exactly once. A successful restore installs the core frontier for the target/input bound at submission, but keeps its gate closed while the caller publishes executor/scheduler progress.

Trait Implementations

impl<R: DeviceRuntime> Drop for NativeCheckpointTransfer<R>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.