dope-runtime 0.2.0

Thin io_uring adaptor with "Manifolds"
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

use dope_core::driver::{
    Completion, CompletionBackend, CompletionRouter, DriverOps, ExternalDispatch, PoolDriver,
};

pub fn install_external<B: CompletionBackend>(
    aux: Option<ExternalDispatch<B>>,
) -> Option<ExternalDispatch<B>> {
    B::install_external(aux)
}

#[inline(always)]
pub(super) fn current_external<B: CompletionBackend>() -> Option<ExternalDispatch<B>> {
    B::current_external()
}

pub(super) struct ExternalRouter<B: CompletionBackend> {
    pub(super) aux: Option<ExternalDispatch<B>>,
}

impl<B: PoolDriver> CompletionRouter<B> for ExternalRouter<B> {
    #[inline(always)]
    fn on_complete(&mut self, driver: &mut B::Driver, ev: Completion<B>) {
        if let Some(a) = self.aux {
            unsafe { (a.route)(a.state, driver, ev) };
        } else if let Some(b) = ev.buffer_select() {
            use dope_core::driver::ProvidedRingOps;
            driver.provided_ring().defer(b);
        }
    }
}