dope-core 0.26.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
41
42
43
44
45
46
47

use std::mem;

use dope_sys::thread::{Thread, timer};
use o3::base::{marker::ThreadBound, time::Positive};

use crate::{
    Backend, driver,
    driver::{
        life::{finish, recovery},
        schedule::clock,
    },
};

/// Worker-local kernel deadline branded by its owning driver generation.
#[repr(transparent)]
pub struct Timer<'d>(clock::Bound<'d, <Backend as Thread>::Timer>);

impl<'d, T: dope_sys::Timer> Timer<'d>
where
    Backend: Thread<Timer = T>,
{
    pub fn try_new(deadline: Positive, owner: driver::Reference<'d>) -> Result<Self, timer::Error> {
        let raw = T::try_new(deadline)?;
        Ok(Self(clock::Bound::new(
            raw,
            (owner.brand, ThreadBound::NEW),
        )))
    }

    pub fn refresh(&self, context: driver::Context<'_, 'd>) {
        if let Err(cause) = self.0.inner.try_refresh() {
            recovery::Recovery::new(context, recovery::Cause::TimerRefresh(cause)).terminate();
        }
    }

    /// Disarms the timer after driver quiescence and returns the exact native error.
    /// Failure retains this timer; it may remain armed until dropped.
    pub fn try_disarm(&mut self, proof: &mut finish::Finish<'_, 'd>) -> Result<(), crate::Errno> {
        self.0.driver.0 = proof.brand();
        self.0.inner.try_disarm()
    }
}

const _: () = {
    assert!(mem::size_of::<Timer<'static>>() == mem::size_of::<<Backend as Thread>::Timer>());
    assert!(mem::align_of::<Timer<'static>>() == mem::align_of::<<Backend as Thread>::Timer>());
};