Struct RefCellComputeChannel

pub struct RefCellComputeChannel<Server> { /* private fields */ }

A channel using a ref cell to access the server with mutability.

Important

Only use this channel if you don’t use any threading in your application, otherwise it will panic or cause undefined behaviors.

This is mosly useful for no-std environments where threads aren’t supported, otherwise prefer the mutex or the mpsc channels.

Implementations

impl<Server> RefCellComputeChannel<Server>

where Server: ComputeServer,

pub fn new(server: Server) -> RefCellComputeChannel<Server>

Create a new cell compute channel.

Trait Implementations

impl<S> Clone for RefCellComputeChannel<S>

fn clone(&self) -> RefCellComputeChannel<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Server> ComputeChannel<Server> for RefCellComputeChannel<Server>

where Server: ComputeServer + Send,

fn read( &self, bindings: Vec<Binding>, ) -> Pin<Box<dyn Future<Output = Vec<Vec<u8>>> + Send>>

Given bindings, returns owned resources as bytes

fn read_tensor( &self, bindings: Vec<BindingWithMeta>, ) -> Pin<Box<dyn Future<Output = Vec<Vec<u8>>> + Send>>

Given bindings, returns owned resources as bytes

fn sync(&self) -> Pin<Box<dyn Future<Output = ()> + Send>>

Wait for the completion of every task in the server.

fn get_resource( &self, binding: Binding, ) -> BindingResource<<<Server as ComputeServer>::Storage as ComputeStorage>::Resource>

Given a resource handle, return the storage resource.

fn create(&self, resource: &[u8]) -> Handle

Given a resource as bytes, stores it and returns the resource handle

fn create_tensors( &self, data: Vec<&[u8]>, shape: Vec<&[usize]>, elem_size: Vec<usize>, ) -> Vec<(Handle, Vec<usize>)>

Given a resource as bytes and a shape, stores it and returns the tensor handle

fn empty(&self, size: usize) -> Handle

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

fn empty_tensors( &self, shape: Vec<&[usize]>, elem_size: Vec<usize>, ) -> Vec<(Handle, Vec<usize>)>

Reserves a tensor with shape in the storage, and returns a handle to it

unsafe fn execute( &self, kernel_description: <Server as ComputeServer>::Kernel, count: CubeCount, bindings: Bindings, kind: ExecutionMode, logger: Arc<ServerLogger>, )

Executes the kernel over the given bindings.

fn flush(&self)

Flush outstanding work of the server.

fn memory_usage(&self) -> MemoryUsage

Get the current memory usage of the server.

fn memory_cleanup(&self)

Ask the server to release memory that it can release.

fn start_profile(&self) -> ProfilingToken

Start a profile on the server. This allows you to profile kernels.

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

End the profile and return a ProfileDuration.

impl<Server> Debug for RefCellComputeChannel<Server>

where Server: Debug,

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

Formats the value using the given formatter.

impl<Server> Send for RefCellComputeChannel<Server>

where Server: ComputeServer,

This is unsafe, since no concurrency is supported by the RefCell channel. However using this channel should only be done in single threaded environments such as no-std.

impl<Server> Sync for RefCellComputeChannel<Server>

where Server: ComputeServer,