Struct Endpoint

pub struct Endpoint { /* private fields */ }

Communication endpoint.

Implementations

impl Endpoint

pub async fn put( &self, buf: &[u8], remote_addr: u64, rkey: &RKey, ) -> Result<(), Error>

Stores a contiguous block of data into remote memory.

pub async fn get( &self, buf: &mut [u8], remote_addr: u64, rkey: &RKey, ) -> Result<(), Error>

Loads a contiguous block of data from remote memory.

impl Endpoint

pub async fn stream_send(&self, buf: &[u8]) -> Result<usize, Error>

Sends data through stream.

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

Receives data from stream.

impl Endpoint

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

Sends a messages with tag.

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

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

impl Endpoint

pub fn is_closed(&self) -> bool

Whether the endpoint is closed.

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

Get the endpoint status.

pub fn print_to_stderr(&self)

Print endpoint information to stderr.

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

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

pub async fn close(&self, force: bool) -> Result<(), Error>

This routine close connection.

pub fn worker(&self) -> &Rc<Worker>

Get the worker of the endpoint.

Trait Implementations

impl Clone for Endpoint

fn clone(&self) -> Endpoint

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Endpoint

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

Formats the value using the given formatter.

impl Drop for Endpoint

fn drop(&mut self)

Executes the destructor for this type.