use core::ops::{Add, AddAssign, Sub, SubAssign};
use super::Duration;
#[repr(transparent)]
#[derive(Copy, Clone, Default, Debug, Hash, PartialEq, Eq, PartialOrd, Ord)]
pub struct UnixInstant {
pub(crate) ns: u64,
}
impl UnixInstant {
pub const EPOCH: UnixInstant = UnixInstant { ns: 0 };
pub const fn from_nanos(ns: u64) -> Self {
Self { ns }
}
pub const fn as_nanos(&self) -> u64 {
self.ns
}
pub fn now() -> Self {
crate::sys::realtime::precise()
}
pub fn elapsed(&self) -> Duration {
Self::now() - *self
}
pub fn duration_since(&self, earlier: Self) -> Duration {
*self - earlier
}
pub fn checked_duration_since(&self, earlier: Self) -> Option<Duration> {
self.ns.checked_sub(earlier.ns).map(|ns| Duration { ns })
}
pub fn checked_sub(&self, duration: Duration) -> Option<Self> {
self.ns.checked_sub(duration.ns).map(|ns| Self { ns })
}
pub const fn as_secs(&self) -> u64 {
self.ns / 1_000_000_000
}
pub fn checked_add(&self, duration: Duration) -> Option<Self> {
self.ns
.checked_add(duration.as_nanos())
.map(|ns| Self { ns })
}
}
impl Add<Duration> for UnixInstant {
type Output = UnixInstant;
fn add(self, rhs: Duration) -> Self::Output {
UnixInstant {
ns: self.ns + rhs.ns,
}
}
}
impl Add<core::time::Duration> for UnixInstant {
type Output = UnixInstant;
fn add(self, rhs: core::time::Duration) -> Self::Output {
UnixInstant {
ns: self.ns + rhs.as_nanos() as u64,
}
}
}
impl Sub<UnixInstant> for UnixInstant {
type Output = Duration;
fn sub(self, rhs: UnixInstant) -> Self::Output {
Duration {
ns: self.ns - rhs.ns,
}
}
}
impl AddAssign<Duration> for UnixInstant {
fn add_assign(&mut self, rhs: Duration) {
self.ns += rhs.ns;
}
}
impl Sub<Duration> for UnixInstant {
type Output = UnixInstant;
fn sub(self, rhs: Duration) -> Self::Output {
UnixInstant {
ns: self.ns - rhs.ns,
}
}
}
impl SubAssign<Duration> for UnixInstant {
fn sub_assign(&mut self, rhs: Duration) {
self.ns -= rhs.ns;
}
}
impl AddAssign<core::time::Duration> for UnixInstant {
fn add_assign(&mut self, rhs: core::time::Duration) {
self.ns += rhs.as_nanos() as u64;
}
}
impl Sub<core::time::Duration> for UnixInstant {
type Output = UnixInstant;
fn sub(self, rhs: core::time::Duration) -> Self::Output {
UnixInstant {
ns: self.ns - rhs.as_nanos() as u64,
}
}
}
impl SubAssign<core::time::Duration> for UnixInstant {
fn sub_assign(&mut self, rhs: core::time::Duration) {
self.ns -= rhs.as_nanos() as u64;
}
}
impl From<crate::coarse::UnixInstant> for UnixInstant {
fn from(other: crate::coarse::UnixInstant) -> Self {
Self {
ns: other.secs as u64 * super::Duration::SECOND.as_nanos(),
}
}
}
#[derive(Debug)]
pub struct TryFromError {
kind: TryFromErrorKind,
}
#[derive(Debug)]
enum TryFromErrorKind {
Overflow,
BeforeEpoch,
}
impl TryFromError {
const fn description(&self) -> &'static str {
match self.kind {
TryFromErrorKind::Overflow => "can not convert to UnixInstant: value is too big",
TryFromErrorKind::BeforeEpoch => {
"can not convert to UnixInstant: value is before unix epoch"
}
}
}
}
impl core::fmt::Display for TryFromError {
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
self.description().fmt(f)
}
}
impl std::error::Error for TryFromError {}
impl TryFrom<std::time::SystemTime> for UnixInstant {
type Error = TryFromError;
fn try_from(other: std::time::SystemTime) -> Result<Self, Self::Error> {
let other = other
.duration_since(std::time::SystemTime::UNIX_EPOCH)
.map_err(|_| TryFromError {
kind: TryFromErrorKind::BeforeEpoch,
})?
.as_nanos();
if other > u64::MAX as u128 {
Err(TryFromError {
kind: TryFromErrorKind::Overflow,
})
} else {
Ok(Self { ns: other as u64 })
}
}
}
#[cfg(test)]
mod tests {
#[test]
fn from_coarse_unix_instant() {
let coarse = crate::coarse::UnixInstant::from_secs(5);
let precise = super::UnixInstant::from(coarse);
assert_eq!(precise.as_nanos(), 5_000_000_000);
}
}