dope-uring 0.24.0

Owned io_uring backend for dope
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
35
36
37
38
39
40
41

use std::os::fd;

use dope_sys::{
    Errno,
    io::{
        fd::Fd,
        file,
        reactor::complete::{Decode, Outcome as _},
    },
};
use o3::base::num::bounded;

use crate::{
    Uring,
    reactor::cq::{Invalid, Outcome},
};

// SAFETY: nonnegative native open results uniquely transfer their descriptor;
// the returned OwnedFd delivers or closes it exactly once.
unsafe impl file::raw::Completion for Uring {
    type Outcome = Outcome;
    type Invalid = Invalid;

    unsafe fn open(raw: Self::Outcome) -> Result<file::Opened, Self::Invalid> {
        match raw.decode() {
            Decode::Value(value) => {
                let value: bounded::U32<0, { i32::MAX as u32 }> = value.into();
                // SAFETY: the caller owns this successful open completion exactly once.
                let owned =
                    unsafe { <fd::OwnedFd as fd::FromRawFd>::from_raw_fd(value.get() as i32) };
                Ok(Ok(owned))
            }
            Decode::Error(code) => Ok(Err(code)),
            Decode::Invalid(invalid) => Err(invalid),
        }
    }

    fn close(file: fd::OwnedFd) -> Result<(), Errno> {
        <Uring as Fd>::close(file)
    }
}