timeout-trait 0.8.1

Traits used to wait and timeout.
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

use crate::{TickDuration, TickInstant};
use core::sync::atomic::{AtomicU64, Ordering};
use fugit::{KilohertzU32, NanosDurationU32, RateExtU32};

static TICK_SOURCE: AtomicU64 = AtomicU64::new(0);

#[derive(Clone, Copy)]
pub struct MockInstant {
    pub(crate) tick: u64,
}

impl MockInstant {
    pub fn add_time(t: NanosDurationU32) {
        let tick = t.to_nanos() as u64;
        TICK_SOURCE.fetch_add(tick, Ordering::Relaxed);
    }
}

impl TickInstant for MockInstant {
    fn frequency() -> KilohertzU32 {
        1000.MHz()
    }

    fn now() -> Self {
        Self {
            tick: TICK_SOURCE.load(Ordering::Relaxed),
        }
    }

    fn elapsed(&mut self) -> TickDuration<Self> {
        TickDuration::from_ticks(Self::now().tick.wrapping_sub(self.tick))
    }

    fn move_forward(&mut self, dur: &TickDuration<Self>) {
        self.tick += dur.as_ticks();
    }
}