Struct HipStreamManager 

pub struct HipStreamManager { /* private fields */ }

HIP stream manager

Implementations

impl HipStreamManager

pub fn new(config: HipStreamConfig) -> Self

pub fn create_stream(&mut self, priority: Option<i32>) -> Result<u32, RocmError>

Create new stream Create new stream

Reuses a previously Self::destroy_streamd stream from stream_pool when one is available (its operation queue is cleared and it is given a fresh ID) instead of always allocating a new one.

pub fn destroy_stream(&mut self, stream_id: u32) -> Result<(), RocmError>

Destroy stream

Returns the stream to stream_pool for Self::create_stream to reuse instead of dropping it outright.

pub fn add_operation( &mut self, stream_id: u32, operation: HipOperation, ) -> Result<(), RocmError>

Add operation to stream

pub fn synchronize_stream(&mut self, stream_id: u32) -> Result<(), RocmError>

Synchronize stream