Method bitemporal_now_ms

nodedb/src/data/executor/core_loop/bitemporal_time.rs:43–56

(&self)

    /// watermark. Guarantees: strictly increasing on this core.
    #[inline]
    pub(in crate::data::executor) fn bitemporal_now_ms(&self) -> i64 {
        let prev = self.last_stamp_ms.load(Ordering::Relaxed);
        let anchor = if let Some(epoch_ms) = self.epoch_system_ms {
            epoch_ms
        } else {
            SystemTime::now()
                .duration_since(UNIX_EPOCH)
                .map(|d| i64::try_from(d.as_millis()).unwrap_or(i64::MAX))
                .unwrap_or(prev)
        };
        let next = anchor.max(prev.saturating_add(1));
        self.last_stamp_ms.store(next, Ordering::Relaxed);
        next
    }
}

#[cfg(test)]