dope-core 0.23.0

Owned native I/O and completion driver 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
32
33
34
35
36
37
38
39
40

use o3::mem::quota;

use crate::driver::{
    self,
    schedule::{
        app,
        ready::{
            self,
            wake::{Drain, fanout::storage::Step},
        },
    },
};

pub(in crate::driver::schedule::ready::wake) fn one<'d>(
    driver: driver::Reference<'d>,
    work: app::Work<'_, 'd>,
    mut pending: impl FnMut() -> bool,
    mut next: impl FnMut() -> Option<Step<ready::Retained<'d>>>,
) -> Drain {
    loop {
        if !pending() {
            return match next() {
                None | Some(Step::Idle) => Drain::Empty,
                Some(Step::Item(target)) => {
                    target.wake(driver);
                    Drain::Woke
                }
            };
        }
        match work.run(&mut next) {
            quota::Admission::Item(Step::Idle) => {}
            quota::Admission::Item(Step::Item(target)) => {
                target.wake(driver);
                return Drain::Woke;
            }
            quota::Admission::Empty => return Drain::Empty,
            quota::Admission::Exhausted => return Drain::Exhausted,
        }
    }
}