rings-core 0.20.0

Chord DHT implementation with ICE
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

//! Epoch clock boundary for periodic reassembly cleanup.

#[cfg(all(test, feature = "dummy", not(target_family = "wasm")))]
use std::sync::Arc;
#[cfg(all(test, feature = "dummy", not(target_family = "wasm")))]
use std::sync::Mutex;

pub(in crate::swarm::callback) enum ReassemblyCleanupClock {
    /// Read the current Unix epoch timestamp in milliseconds.
    System,
    #[cfg(all(test, feature = "dummy", not(target_family = "wasm")))]
    /// Read a test-controlled Unix epoch timestamp in milliseconds.
    Controlled(Arc<Mutex<u128>>),
}

impl ReassemblyCleanupClock {
    pub(in crate::swarm::callback) const fn system() -> Self {
        Self::System
    }

    #[cfg(all(test, feature = "dummy", not(target_family = "wasm")))]
    pub(in crate::swarm::callback) fn controlled(now_ms: Arc<Mutex<u128>>) -> Self {
        Self::Controlled(now_ms)
    }

    pub(super) fn now_ms(&self) -> u128 {
        match self {
            Self::System => crate::utils::get_epoch_ms(),
            #[cfg(all(test, feature = "dummy", not(target_family = "wasm")))]
            Self::Controlled(now_ms) => *now_ms
                .lock()
                .unwrap_or_else(std::sync::PoisonError::into_inner),
        }
    }
}