Struct HipServer 

pub struct HipServer { /* private fields */ }

Trait Implementations

impl ComputeServer for HipServer

type Kernel = Box<dyn CubeTask<CppCompiler<HipDialect<WmmaIntrinsicCompiler>>>>

The kernel type defines the computation algorithms.

type Storage = GpuStorage

The storage type defines how data is stored and accessed.

type Info = ()

Information that can be retrieved for the runtime.

fn logger(&self) -> Arc<ServerLogger>

Retrieve the server logger.

fn utilities(&self) -> Arc<ServerUtilities<Self>>

Retrieve the server utilities.

fn staging( &mut self, sizes: &[usize], stream_id: StreamId, ) -> Result<Vec<Bytes>, IoError>

Reserves N Bytes of the provided sizes to be used as staging to load data.

fn create( &mut self, descriptors: Vec<AllocationDescriptor<'_>>, stream_id: StreamId, ) -> Result<Vec<Allocation>, IoError>

Reserves size bytes in the storage, and returns a handle over them.

fn read( &mut self, descriptors: Vec<CopyDescriptor<'_>>, stream_id: StreamId, ) -> DynFut<Result<Vec<Bytes>, IoError>>

Given bindings, returns the owned resources as bytes.

fn write( &mut self, descriptors: Vec<(CopyDescriptor<'_>, Bytes)>, stream_id: StreamId, ) -> Result<(), IoError>

Writes the specified bytes into the buffers given

fn memory_usage(&mut self, stream_id: StreamId) -> MemoryUsage

The current memory usage of the server.

fn memory_cleanup(&mut self, stream_id: StreamId)

Ask the server to release memory that it can release.

unsafe fn launch( &mut self, kernel: Self::Kernel, count: CubeCount, bindings: Bindings, mode: ExecutionMode, stream_id: StreamId, ) -> Result<(), LaunchError>

Executes the kernel over the given memory handles.

fn flush(&mut self, _stream_id: StreamId)

Flush all outstanding tasks in the server.

fn sync(&mut self, stream_id: StreamId) -> DynFut<Result<(), ExecutionError>>

Wait for the completion of every task in the server.

fn start_profile(&mut self, stream_id: StreamId) -> ProfilingToken

Enable collecting timestamps.

fn end_profile( &mut self, stream_id: StreamId, token: ProfilingToken, ) -> Result<ProfileDuration, ProfileError>

Disable collecting timestamps.

fn get_resource( &mut self, binding: Binding, stream_id: StreamId, ) -> BindingResource<GpuResource>

Given a resource handle, returns the storage resource.

fn allocation_mode(&mut self, mode: MemoryAllocationMode, stream_id: StreamId)

Update the memory mode of allocation in the server.

fn create_with_data( &mut self, data: &[u8], stream_id: StreamId, ) -> Result<Handle, IoError>

Utility to create a new buffer and immediately copy contiguous data into it

fn create_with_bytes( &mut self, data: Bytes, stream_id: StreamId, ) -> Result<Handle, IoError>

Utility to create a new buffer and immediately copy contiguous data into it

impl Debug for HipServer

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

Formats the value using the given formatter.

impl DeviceState for HipServer

fn init(device_id: DeviceId) -> Self

Initialize a new state on the given device.

impl ServerCommunication for HipServer

const SERVER_COMM_ENABLED: bool = true

Indicates whether server-to-server communication is enabled for this implementation.

fn copy( server_src: &mut Self, server_dst: &mut Self, src: CopyDescriptor<'_>, stream_id_src: StreamId, stream_id_dst: StreamId, ) -> Result<Allocation, IoError>

Copies data from a source server to a destination server.

impl Send for HipServer