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

use dope_sys::{
    engine::{self, register, ring},
    io::reactor::submit::{Control, Poll as _, Queue as _},
    ring::ready::Ready as _,
    table::token::Codec as _,
};

use crate::{Engine, Uring};

impl<C: ring::Context> engine::raw::Register for Engine<C> {
    unsafe fn register(&mut self, source: register::Source<'_>) -> Result<(), register::Error> {
        let entry = <Uring as Control>::Poll::new(source, C::Token::shutdown());
        let vacancy = self
            .ring
            .submission()
            .try_one()
            .map_err(register::Error::Full)?;
        // SAFETY: the caller retains this exact descriptor through quiescence.
        unsafe { Self::arm(vacancy, &entry) };
        Ok(())
    }
}