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

use dope_sys::{
    engine::admit::{self, Context},
    io::{reactor::submit, request},
    table::token::Codec,
};

use crate::{Uring, driver::Key, reactor::sq};

impl<C, T> admit::raw::Retain<C> for sq::raw::Vacancy<'_, T>
where
    C: Context<Native = Uring, Key = Key<T>>,
    T: Codec,
{
    unsafe fn retain(self, request: request::Borrowed<'_, sq::Fixed>, key: Key<T>) {
        // SAFETY: the host retains every encoded pointee through this flight's completion.
        unsafe { self.push_retained(request, T::flight(key)) };
    }

    unsafe fn file(self, request: sq::Borrowed<'_>, key: Key<T>) {
        // SAFETY: the host retains every encoded file borrow through this flight's completion.
        unsafe { submit::raw::Vacancy::push(self, request, T::flight(key)) };
    }
}