Struct Worker

pub struct Worker { /* private fields */ }

An object representing the communication context.

Implementations

impl Worker

pub async fn tag_recv( &self, tag: u64, buf: &mut [MaybeUninit<u8>], ) -> Result<usize, Error>

Receives a message with tag.

pub async fn tag_recv_mask( &self, tag: u64, tag_mask: u64, buf: &mut [MaybeUninit<u8>], ) -> Result<(u64, usize), Error>

Receives a message with tag and tag_mask.

pub async fn tag_recv_vectored( &self, tag: u64, iov: &mut [IoSliceMut<'_>], ) -> Result<usize, Error>

Like tag_recv, except that it reads into a slice of buffers.

impl Worker

pub async fn polling(self: Rc<Self>)

Make progress on the worker.

pub fn print_to_stderr(&self)

Prints information about the worker.

Including protocols being used, thresholds, UCT transport methods, and other useful information associated with the worker.

pub fn thread_mode(&self) -> ucs_thread_mode_t

Thread safe level of the context.

pub fn address(&self) -> Result<WorkerAddress<'_>, Error>

Get the address of the worker object.

This address can be passed to remote instances of the UCP library in order to connect to this worker.

pub fn create_listener( self: &Rc<Self>, addr: SocketAddr, ) -> Result<Listener, Error>

Create a new Listener.

pub fn connect_addr( self: &Rc<Self>, addr: &WorkerAddress<'_>, ) -> Result<Endpoint, Error>

Connect to a remote worker by address.

pub async fn connect_socket( self: &Rc<Self>, addr: SocketAddr, ) -> Result<Endpoint, Error>

Connect to a remote listener.

pub async fn accept( self: &Rc<Self>, connection: ConnectionRequest, ) -> Result<Endpoint, Error>

Accept a connection request.

pub fn wait(&self) -> Result<(), Error>

Waits (blocking) until an event has happened.

pub fn arm(&self) -> Result<bool, Error>

This needs to be called before waiting on each notification on this worker.

Returns ‘true’ if one can wait for events (sleep mode).

pub fn progress(&self) -> u32

Explicitly progresses all communication operations on a worker.

pub fn event_fd(&self) -> Result<i32, Error>

Returns a valid file descriptor for polling functions.

pub fn flush(&self)

This routine flushes all outstanding AMO and RMA communications on the worker.

Trait Implementations

impl AsRawFd for Worker

fn as_raw_fd(&self) -> i32

Extracts the raw file descriptor.

impl Debug for Worker

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

Formats the value using the given formatter.

impl Drop for Worker

fn drop(&mut self)

Executes the destructor for this type.