Struct GenericAioContextHandle

pub struct GenericAioContextHandle<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default>
where
    A::LinkOps: LinkedListOps + Default,
{ /* private fields */ }

Cloneable handle to AIO context. Required for any AIO operations

Implementations

impl<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default> GenericAioContextHandle<M, A, L>

where A::LinkOps: LinkedListOps + Default,

pub fn available_slots(&self) -> Option<usize>

Number of available AIO slots left in the context

Return None if AIO context stopped, or if use_semaphore was set to false

pub async fn submit_request( &self, fd: &impl AsRawFd, command: RawCommand<'_>, ) -> Result<u64, AioCommandError>

Submit command to the AIO context

If use_semaphore set to false, this function will return CapacityExceeded error if the user’s code tries to exceed the allowed number of in-flight requests

Trait Implementations

impl<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default> Clone for GenericAioContextHandle<M, A, L>

where A::LinkOps: LinkedListOps + Default,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<M: RawMutex, A: IntrusiveAdapter<M, L>, L: DefaultLinkOps<Ops = A::LinkOps> + Default> Debug for GenericAioContextHandle<M, A, L>

where A::LinkOps: LinkedListOps + Default,

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

Formats the value using the given formatter.