fips-core 0.3.11

Reusable FIPS mesh, endpoint, transport, and protocol library
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
48
49
50
51
52
53
54
55
56
57
58
59

//! Time helpers used by protocol state machines.
//!
//! Normal builds use wall-clock Unix time. The in-process sim transport uses a
//! Tokio-clock anchor so paused-time simulations can advance discovery,
//! retransmit, and timeout state without waiting on wall time.

use std::time::{Duration, SystemTime, UNIX_EPOCH};

#[cfg(feature = "sim-transport")]
use std::sync::OnceLock;

#[cfg(not(feature = "sim-transport"))]
pub(crate) type Instant = std::time::Instant;

#[cfg(feature = "sim-transport")]
pub(crate) type Instant = tokio::time::Instant;

#[cfg(feature = "sim-transport")]
struct ClockAnchor {
    started_at: Instant,
    started_unix_ms: u64,
}

pub(crate) fn instant_now() -> Instant {
    Instant::now()
}

pub(crate) fn now_ms() -> u64 {
    #[cfg(feature = "sim-transport")]
    {
        static ANCHOR: OnceLock<ClockAnchor> = OnceLock::new();
        let anchor = ANCHOR.get_or_init(|| ClockAnchor {
            started_at: instant_now(),
            started_unix_ms: wall_now_ms(),
        });
        let elapsed_ms = instant_now()
            .duration_since(anchor.started_at)
            .as_millis()
            .min(u128::from(u64::MAX)) as u64;
        anchor.started_unix_ms.saturating_add(elapsed_ms)
    }

    #[cfg(not(feature = "sim-transport"))]
    {
        wall_now_ms()
    }
}

pub(crate) fn now_secs() -> u64 {
    now_ms() / 1_000
}

fn wall_now_ms() -> u64 {
    SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .unwrap_or(Duration::ZERO)
        .as_millis()
        .min(u128::from(u64::MAX)) as u64
}