kevy-uring 1.39.0

Pure-Rust io_uring bindings — no liburing, no libc crate.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! A reaped completion event.

use crate::ffi::{IORING_CQE_BUFFER_SHIFT, IORING_CQE_F_BUFFER, IORING_CQE_F_MORE};

/// One reaped completion (`struct io_uring_cqe`): the `user_data` you tagged
/// the submission with, and `res` (bytes transferred / accepted fd when ≥ 0,
/// else `-errno`).
#[repr(C)]
#[derive(Clone, Copy, Debug)]
pub struct Completion {
    /// The `user_data` tag the submission carried.
    pub user_data: u64,
    /// Result of the op: bytes transferred or accepted fd (≥ 0) or `-errno`.
    pub res: i32,
    /// io_uring `flags` (provided-buffer id + multishot armed bit).
    pub flags: u32,
}

impl Completion {
    /// The provided-buffer id the kernel filled, if this completion consumed
    /// one (multishot/`recv` with buffer select). Recycle it via
    /// [`ProvidedBufRing::recycle`](crate::ProvidedBufRing::recycle) once the
    /// bytes are copied out.
    pub fn buffer_id(&self) -> Option<u16> {
        (self.flags & IORING_CQE_F_BUFFER != 0)
            .then_some((self.flags >> IORING_CQE_BUFFER_SHIFT) as u16)
    }

    /// Whether the originating multishot SQE remains armed (more completions
    /// to come). When `false`, the op terminated and must be re-submitted.
    pub fn has_more(&self) -> bool {
        self.flags & IORING_CQE_F_MORE != 0
    }
}