dope-uring 0.39.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

use std::os::fd;

use dope_sys::io::{
    file,
    reactor::complete::{Decode, Outcome as _},
};

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) => {
                // 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),
        }
    }
}