Struct UringEngine 

pub struct UringEngine { /* private fields */ }

io_uring-backed Engine.

Implementations

impl UringEngine

pub fn new( entries: u32, pool: Option<&BufferPool>, sqpoll: bool, ) -> Result<Self>

Builds the ring and registers the buffer pool as kernel fixed buffers.

Errors

Ring creation or registration failure (e.g., SQPOLL denied for the current user — the runtime falls back per IO-05).

Trait Implementations

impl Engine for UringEngine

fn kind(&self) -> &'static str

Backend name for diagnostics (io_uring / mio).

fn add_listener(&mut self, fd: RawFd, token: Token) -> Result<()>

Registers a nonblocking listening socket for accept readiness.

fn add_stream(&mut self, _fd: RawFd, _token: Token) -> Result<()>

Registers a connected socket for read/write readiness.

fn read(&mut self, token: Token, fd: RawFd, slot: u32) -> Result<Poll>

Queues one read into pool slot. The completion yields bytes read; 0 means EOF.

fn write( &mut self, token: Token, fd: RawFd, slot: u32, len: usize, offset: usize, ) -> Result<Poll>

Queues a write of slot[0..len], resuming from a prior partial write when the backend tracks one for this token.

fn connect(&mut self, token: Token, addr: SocketAddr) -> Result<(RawFd, Poll)>

Starts a nonblocking connect(2); completion is a CQE where result == Ok(0) means established.

fn connect_unix(&mut self, token: Token, path: &Path) -> Result<(RawFd, Poll)>

Starts a nonblocking UDS connect(2) to path.

fn accept( &mut self, _lfd: RawFd, ltoken: Token, ) -> Result<Option<(RawFd, SocketAddr)>>

Attempts an accept on a registered listener; Ok(Some(..)) completes inline, Ok(None) waits for a CQE on the listener token.

fn splice_pump(&mut self, a: Token, afd: i32, b: Token, bfd: i32) -> Result<()>

Starts a bidirectional zero-copy splice pump between two registered streams (IO-04). Completions on either token report bytes moved; Ok(0) signals EOF for that direction.

fn remove(&mut self, fd: RawFd)

Removes a descriptor (before the worker closes it).

fn poll(&mut self, timeout: Option<Duration>, out: &mut Vec<Cqe>) -> Result<()>

Drives the backend, filling out with completions. Blocks up to timeout (or indefinitely when None).

fn take_accepted(&mut self, fd: RawFd) -> Option<SocketAddr>

Pops addresses of accepted connections reported by accept CQEs.

impl Send for UringEngine