Struct UringStorageIo 

pub struct UringStorageIo { /* private fields */ }

io_uring storage I/O backend.

One instance per core. Uses SQPOLL for zero-syscall submission and registered buffers for zero-copy writes.

Implementations

impl UringStorageIo

pub fn new(core_id: usize, config: &IoUringConfig) -> Result<Self, IoUringError>

Create a new io_uring backend for a specific core.

Errors

Returns an error if ring creation fails (insufficient privileges for SQPOLL, unsupported kernel version, etc.).

pub fn uses_sqpoll(&self) -> bool

Returns true if the underlying ring uses SQPOLL.

Trait Implementations

impl Debug for UringStorageIo

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

Formats the value using the given formatter.

impl Drop for UringStorageIo

fn drop(&mut self)

Executes the destructor for this type.

impl StorageIo for UringStorageIo

fn register_fd(&mut self, file: File) -> Result<IoFd, StorageIoError>

Register an already-opened file with this backend.

fn deregister_fd(&mut self, fd: IoFd) -> Result<(), StorageIoError>

Deregister and close a previously registered file.

fn submit_write( &mut self, fd: IoFd, data: &[u8], offset: u64, ) -> Result<u64, StorageIoError>

Submit a write at the given file offset. Non-blocking.

fn submit_append( &mut self, fd: IoFd, data: &[u8], ) -> Result<u64, StorageIoError>

Submit an append (write at current end-of-file). Non-blocking.

fn submit_datasync(&mut self, fd: IoFd) -> Result<u64, StorageIoError>

Submit an fdatasync (data-only sync, no metadata). Non-blocking.

fn flush(&mut self) -> Result<usize, StorageIoError>

Flush pending submissions to the kernel.

fn poll_completions(&mut self, out: &mut Vec<IoCompletion>)

Poll for completed operations. Non-blocking.

fn pending_count(&self) -> usize

Returns the number of operations submitted but not yet completed.