Struct AsyncTransferPipeline 

pub struct AsyncTransferPipeline<T> { /* private fields */ }

Pipeline that manages a bounded queue of in-flight async transfers.

In CPU simulation mode every submitted transfer completes synchronously (the completion flag is set to true before submit returns). This means the pipeline compiles and passes tests on machines without real GPU hardware.

Type parameters

• T – The element type of the transfer buffers. Must be Clone + Send + 'static.

Implementations

impl<T: Clone + Send + 'static> AsyncTransferPipeline<T>

pub fn new(max_pending: usize) -> Self

Create a new pipeline that allows up to max_pending in-flight transfers before returning AsyncTransferError::PipelineFull.

A max_pending of 0 is valid and will cause every submit to fail immediately.

pub fn submit( &self, data: Vec<T>, direction: TransferDirection, ) -> Result<TransferHandle, AsyncTransferError>

Submit a transfer request for data in the given direction.

In CPU simulation mode the transfer completes immediately: the returned TransferHandle will already report is_complete() == true.

Errors

Returns AsyncTransferError::PipelineFull when the number of currently pending (incomplete) transfers equals max_pending.

pub fn is_complete(&self, handle: &TransferHandle) -> bool

Returns true if the transfer identified by handle has completed.

This is a convenience wrapper around TransferHandle::is_complete.

pub fn flush(&self) -> Result<(), AsyncTransferError>

Block until all pending transfers have completed, then drain the queue.

In CPU simulation mode this returns immediately because all transfers are marked complete on submission.

Errors

Returns AsyncTransferError::LockError if the internal mutex cannot be acquired.

pub fn pending_count(&self) -> usize

Return the number of transfers currently tracked in the pipeline (including already-completed ones that have not yet been flushed).

pub fn in_flight_count(&self) -> usize

Return the number of transfers that have NOT yet completed.