use std::ops::{Add, AddAssign, Sub, SubAssign};
use std::time::Duration;
use super::js::PERFORMANCE;
#[cfg(target_feature = "atomics")]
thread_local! {
static ORIGIN: f64 = PERFORMANCE.with(super::js::Performance::time_origin);
}
#[derive(Clone, Copy, Debug, Eq, Hash, Ord, PartialEq, PartialOrd)]
pub struct Instant(Duration);
impl Instant {
#[must_use]
pub fn now() -> Self {
let now = PERFORMANCE.with(|performance| {
#[cfg(target_feature = "atomics")]
return ORIGIN.with(|origin| performance.now() + origin);
#[cfg(not(target_feature = "atomics"))]
performance.now()
});
Self(time_stamp_to_duration(now))
}
#[must_use]
pub fn duration_since(&self, earlier: Self) -> Duration {
self.checked_duration_since(earlier).unwrap_or_default()
}
#[must_use]
#[allow(clippy::missing_const_for_fn)]
pub fn checked_duration_since(&self, earlier: Self) -> Option<Duration> {
self.0.checked_sub(earlier.0)
}
#[must_use]
pub fn saturating_duration_since(&self, earlier: Self) -> Duration {
self.checked_duration_since(earlier).unwrap_or_default()
}
#[must_use]
pub fn elapsed(&self) -> Duration {
Self::now() - *self
}
pub fn checked_add(&self, duration: Duration) -> Option<Self> {
self.0.checked_add(duration).map(Instant)
}
pub fn checked_sub(&self, duration: Duration) -> Option<Self> {
self.0.checked_sub(duration).map(Instant)
}
}
impl Add<Duration> for Instant {
type Output = Self;
fn add(self, other: Duration) -> Self {
self.checked_add(other)
.expect("overflow when adding duration to instant")
}
}
impl AddAssign<Duration> for Instant {
fn add_assign(&mut self, other: Duration) {
*self = *self + other;
}
}
impl Sub<Duration> for Instant {
type Output = Self;
fn sub(self, other: Duration) -> Self {
self.checked_sub(other)
.expect("overflow when subtracting duration from instant")
}
}
impl Sub<Self> for Instant {
type Output = Duration;
fn sub(self, other: Self) -> Duration {
self.duration_since(other)
}
}
impl SubAssign<Duration> for Instant {
fn sub_assign(&mut self, other: Duration) {
*self = *self - other;
}
}
#[allow(
clippy::as_conversions,
clippy::cast_possible_truncation,
clippy::cast_sign_loss
)]
fn time_stamp_to_duration(time_stamp: f64) -> Duration {
Duration::from_millis(time_stamp.trunc() as u64)
+ Duration::from_nanos((time_stamp.fract() * 1.0e6).round() as u64)
}
#[cfg(test)]
mod test {
use std::time::Duration;
use rand::distributions::Uniform;
use rand::Rng;
use wasm_bindgen_test::wasm_bindgen_test;
wasm_bindgen_test::wasm_bindgen_test_configure!(run_in_browser);
const MAXIMUM_ACCURATE_SECS: u64 = 285_616 * 365 * 24 * 60 * 60;
#[allow(clippy::as_conversions, clippy::cast_precision_loss)]
const MAXIMUM_ACCURATE_MILLIS: f64 = MAXIMUM_ACCURATE_SECS as f64 * 1_000.;
#[derive(Debug)]
struct ControlDuration(Duration);
impl ControlDuration {
fn new(time_stamp: f64) -> Self {
let time_stamp = Duration::from_secs_f64(time_stamp);
let secs = time_stamp.as_secs() / 1000;
let carry = time_stamp.as_secs() - secs * 1000;
#[allow(clippy::as_conversions, clippy::cast_possible_truncation)]
let extra_nanos = (carry * 1_000_000_000 / 1000) as u32;
let nanos = time_stamp.subsec_micros()
+ u32::from(time_stamp.subsec_nanos() % 1000 > 499)
+ extra_nanos;
Self(Duration::new(secs, nanos))
}
}
impl PartialEq<Duration> for ControlDuration {
fn eq(&self, duration: &Duration) -> bool {
if self.0 == *duration {
true
} else if let Some(diff) = self.0.checked_sub(*duration) {
diff == Duration::from_nanos(1)
} else {
false
}
}
}
#[wasm_bindgen_test]
fn sanity() {
#[track_caller]
fn assert(time_stamp: f64, result: Duration) {
let control = ControlDuration::new(time_stamp);
let duration = super::time_stamp_to_duration(time_stamp);
assert_eq!(control, result, "control and expected result are different");
assert_eq!(control, duration);
}
assert(0.000_000, Duration::ZERO);
assert(0.000_000_4, Duration::ZERO);
assert(0.000_000_5, Duration::from_nanos(1));
assert(0.000_001, Duration::from_nanos(1));
assert(0.000_001_4, Duration::from_nanos(1));
assert(0.000_001_5, Duration::from_nanos(2));
assert(0.999_999, Duration::from_nanos(999_999));
assert(0.999_999_4, Duration::from_nanos(999_999));
assert(0.999_999_5, Duration::from_millis(1));
assert(1., Duration::from_millis(1));
assert(1.000_000_4, Duration::from_millis(1));
assert(1.000_000_5, Duration::from_nanos(1_000_001));
assert(1.000_001, Duration::from_nanos(1_000_001));
assert(1.000_001_4, Duration::from_nanos(1_000_001));
assert(1.000_001_5, Duration::from_nanos(1_000_002));
assert(999.999_999, Duration::from_nanos(999_999_999));
assert(999.999_999_4, Duration::from_nanos(999_999_999));
assert(999.999_999_5, Duration::from_secs(1));
assert(1000., Duration::from_secs(1));
assert(1_000.000_000_4, Duration::from_secs(1));
assert(1_000.000_000_5, Duration::from_nanos(1_000_000_001));
assert(1_000.000_001, Duration::from_nanos(1_000_000_001));
assert(1_000.000_001_4, Duration::from_nanos(1_000_000_001));
assert(1_000.000_001_5, Duration::from_nanos(1_000_000_002));
assert(
MAXIMUM_ACCURATE_MILLIS,
Duration::from_secs(MAXIMUM_ACCURATE_SECS),
);
}
#[wasm_bindgen_test]
fn fuzzing() {
let mut random =
rand::thread_rng().sample_iter(Uniform::new_inclusive(0., MAXIMUM_ACCURATE_MILLIS));
for _ in 0..10_000_000 {
let time_stamp = random.next().unwrap();
let control = ControlDuration::new(time_stamp);
let duration = super::time_stamp_to_duration(time_stamp);
assert_eq!(control, duration);
}
}
}