dope-uring 0.33.1

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

use dope_sys::{io::Close as _, kernel, ring::register};

use crate::{Ring, error, reactor::register::Cleanup};

#[derive(Debug)]
pub struct Attempt<T> {
    ring: Ring<T>,
    error: kernel::Errno<error::Register<20>>,
}
impl<T> Attempt<T> {
    pub(crate) const fn new(ring: Ring<T>, error: kernel::Errno<error::Register<20>>) -> Self {
        Self { ring, error }
    }
}
impl<T> register::Registration for Attempt<T> {
    type Error = kernel::Errno<error::Register<20>>;
    type Unmap = kernel::Errno<error::Unmap>;
    type Cleanup = Cleanup<T>;

    fn try_close(self) -> Result<Self::Error, Self::Cleanup> {
        let Self { ring, error } = self;
        match ring.try_close() {
            Ok(()) => Ok(error),
            Err(ring) => Err(Cleanup::new(ring, error)),
        }
    }
}