dope-runtime 0.37.0

Thread-per-core execution and process lifecycle for dope
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

use std::mem;

use dope_core::io::Event;

mod idle;
pub(super) mod modes;
mod parked;
pub(crate) mod ready;
pub(crate) mod routes;
pub(crate) mod scope;

pub(crate) use idle::Idle;
pub(crate) use parked::{Parked, Status};

const _: () = {
    assert!(mem::size_of::<Option<Event<'static>>>() == mem::size_of::<Event<'static>>());
    assert!(mem::align_of::<Option<Event<'static>>>() == mem::align_of::<Event<'static>>());
};

pub(crate) fn shutdown(source: &impl crate::executor::Startup) -> impl FnMut() -> Status {
    move || {
        source.observed(crate::shutdown::Requested::new());
        Status::Shutdown
    }
}