pub struct RdmaConnectionManager { /* private fields */ }Expand description
RDMA connection manager
Implementations§
Source§impl RdmaConnectionManager
impl RdmaConnectionManager
Sourcepub fn new(config: RdmaConfig) -> RdmaResult<Self>
pub fn new(config: RdmaConfig) -> RdmaResult<Self>
Create a new RDMA connection manager
Sourcepub async fn connect(&self, remote_endpoint: RdmaEndpoint) -> RdmaResult<usize>
pub async fn connect(&self, remote_endpoint: RdmaEndpoint) -> RdmaResult<usize>
Establish RDMA connection to a remote node
Sourcepub async fn rdma_read(
&self,
_connection_id: usize,
local_addr: u64,
remote_addr: u64,
length: usize,
lkey: u32,
rkey: u32,
) -> RdmaResult<WorkCompletion>
pub async fn rdma_read( &self, _connection_id: usize, local_addr: u64, remote_addr: u64, length: usize, lkey: u32, rkey: u32, ) -> RdmaResult<WorkCompletion>
Perform RDMA read operation
Sourcepub async fn rdma_write(
&self,
_connection_id: usize,
local_addr: u64,
remote_addr: u64,
length: usize,
lkey: u32,
rkey: u32,
) -> RdmaResult<WorkCompletion>
pub async fn rdma_write( &self, _connection_id: usize, local_addr: u64, remote_addr: u64, length: usize, lkey: u32, rkey: u32, ) -> RdmaResult<WorkCompletion>
Perform RDMA write operation
Sourcepub async fn atomic_compare_swap(
&self,
_connection_id: usize,
remote_addr: u64,
compare: u64,
_swap: u64,
rkey: u32,
) -> RdmaResult<u64>
pub async fn atomic_compare_swap( &self, _connection_id: usize, remote_addr: u64, compare: u64, _swap: u64, rkey: u32, ) -> RdmaResult<u64>
Perform atomic compare and swap
Sourcepub fn statistics(&self) -> RdmaStatistics
pub fn statistics(&self) -> RdmaStatistics
Get connection statistics
Sourcepub fn memory_pool_statistics(&self) -> MemoryPoolStats
pub fn memory_pool_statistics(&self) -> MemoryPoolStats
Get memory pool statistics
Auto Trait Implementations§
impl !Freeze for RdmaConnectionManager
impl RefUnwindSafe for RdmaConnectionManager
impl Send for RdmaConnectionManager
impl Sync for RdmaConnectionManager
impl Unpin for RdmaConnectionManager
impl UnsafeUnpin for RdmaConnectionManager
impl UnwindSafe for RdmaConnectionManager
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more