Struct IoUring

pub struct IoUring<S = Entry, C = Entry>
where
    S: EntryMarker,
    C: EntryMarker,
{ /* private fields */ }

IoUring instance

• S: The ring’s submission queue entry (SQE) type, either squeue::Entry or squeue::Entry128;
• C: The ring’s completion queue entry (CQE) type, either cqueue::Entry or cqueue::Entry32.

Implementations

impl IoUring<Entry, Entry>

pub fn new(entries: u32) -> Result<Self>

Create a new IoUring instance with default configuration parameters. See Builder to customize it further.

The entries sets the size of queue, and its value should be the power of two.

impl<S: EntryMarker, C: EntryMarker> IoUring<S, C>

pub fn builder() -> Builder<S, C>

Create a Builder for an IoUring instance.

This allows for further customization than new.

Unlike IoUring::new, this function is available for any combination of submission queue entry (SQE) and completion queue entry (CQE) types.

pub fn submitter(&self) -> Submitter<'_>

Get the submitter of this io_uring instance, which can be used to submit submission queue events to the kernel for execution and to register files or buffers with it.

pub fn params(&self) -> &Parameters

Get the parameters that were used to construct this instance.

pub fn submit(&self) -> Result<usize>

Initiate asynchronous I/O. See Submitter::submit for more details.

pub fn submit_and_wait(&self, want: usize) -> Result<usize>

Initiate and/or complete asynchronous I/O. See Submitter::submit_and_wait for more details.

pub fn split( &mut self, ) -> (Submitter<'_>, SubmissionQueue<'_, S>, CompletionQueue<'_, C>)

Get the submitter, submission queue and completion queue of the io_uring instance. This can be used to operate on the different parts of the io_uring instance independently.

If you use this method to obtain sq and cq, please note that you need to drop or sync the queue before and after submit, otherwise the queue will not be updated.

pub fn submission(&mut self) -> SubmissionQueue<'_, S>

Get the submission queue of the io_uring instance. This is used to send I/O requests to the kernel.

pub unsafe fn submission_shared(&self) -> SubmissionQueue<'_, S>

Get the submission queue of the io_uring instance from a shared reference.

Safety

No other SubmissionQueues may exist when calling this function.

pub fn completion(&mut self) -> CompletionQueue<'_, C>

Get completion queue of the io_uring instance. This is used to receive I/O completion events from the kernel.

pub unsafe fn completion_shared(&self) -> CompletionQueue<'_, C>

Get the completion queue of the io_uring instance from a shared reference.

Safety

No other CompletionQueues may exist when calling this function.

Trait Implementations

impl AsFd for IoUring

fn as_fd(&self) -> BorrowedFd<'_>

Borrows the file descriptor.

impl<S: EntryMarker, C: EntryMarker> AsRawFd for IoUring<S, C>

fn as_raw_fd(&self) -> RawFd

Extracts the raw file descriptor.

impl<S: EntryMarker, C: EntryMarker> Drop for IoUring<S, C>

fn drop(&mut self)

Executes the destructor for this type.

impl<S: EntryMarker, C: EntryMarker> Send for IoUring<S, C>

impl<S: EntryMarker, C: EntryMarker> Sync for IoUring<S, C>