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
60
61
62

// Copyright 2022 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

/// This module exists to abstract away the differences between the dev host and target versions
/// of `fuchsia_async::Duration`.
///
/// In particular, on development hosts `fuchsia_async::{Duration, Time}` are actually
/// `std::time::{Duration, Instant}`.
pub use self::platform::{deadline_after, Duration};

#[cfg(not(target_os = "fuchsia"))]
mod platform {
    use std::time::{Duration as OsDuration, Instant as OsTime};

    #[derive(Debug)]
    pub struct Duration {
        base: OsDuration,
    }

    impl Duration {
        pub const fn from_nanos(nanos: i64) -> Self {
            Self { base: OsDuration::from_nanos(nanos as u64) }
        }

        pub const fn from_micros(micros: i64) -> Self {
            Self { base: OsDuration::from_micros(micros as u64) }
        }

        pub const fn from_millis(millis: i64) -> Self {
            Self { base: OsDuration::from_millis(millis as u64) }
        }

        pub const fn from_seconds(seconds: i64) -> Self {
            Self { base: OsDuration::from_secs(seconds as u64) }
        }

        pub const fn into_nanos(self) -> i64 {
            self.base.as_nanos() as i64
        }

        pub const fn into_seconds(self) -> i64 {
            self.base.as_secs() as i64
        }
    }

    /// Provides a deadline after `timeout` nanoseconds that a `fuchsia_async::Timer` can wait until.
    pub fn deadline_after(timeout: Option<i64>) -> Option<fuchsia_async::Time> {
        timeout.and_then(|nanos| OsTime::now().checked_add(OsDuration::from_nanos(nanos as u64)))
    }
}

#[cfg(target_os = "fuchsia")]
mod platform {
    pub use fuchsia_async::Duration;
    use fuchsia_async::DurationExt;

    /// Provides a deadline after `timeout` nanoseconds that a `fuchsia_async::Timer` can wait until.
    pub fn deadline_after(timeout: Option<i64>) -> Option<fuchsia_async::Time> {
        timeout.map(|nanos| Duration::from_nanos(nanos).after_now())
    }
}