1 | use core::time::Duration as UnsignedDuration; |
2 | |
3 | use crate::{ |
4 | error::{err, ErrorContext}, |
5 | Error, SignedDuration, Span, |
6 | }; |
7 | |
8 | /// An internal type for abstracting over different duration types. |
9 | #[derive (Clone, Copy, Debug)] |
10 | pub(crate) enum Duration { |
11 | Span(Span), |
12 | Signed(SignedDuration), |
13 | Unsigned(UnsignedDuration), |
14 | } |
15 | |
16 | impl Duration { |
17 | /// Convert this to a signed duration. |
18 | /// |
19 | /// This returns an error only in the case where this is an unsigned |
20 | /// duration with a number of whole seconds that exceeds `|i64::MIN|`. |
21 | #[cfg_attr (feature = "perf-inline" , inline(always))] |
22 | pub(crate) fn to_signed(self) -> Result<SDuration, Error> { |
23 | match self { |
24 | Duration::Span(span) => Ok(SDuration::Span(span)), |
25 | Duration::Signed(sdur) => Ok(SDuration::Absolute(sdur)), |
26 | Duration::Unsigned(udur) => { |
27 | let sdur = |
28 | SignedDuration::try_from(udur).with_context(|| { |
29 | err!( |
30 | "unsigned duration {udur:?} exceeds Jiff's limits" |
31 | ) |
32 | })?; |
33 | Ok(SDuration::Absolute(sdur)) |
34 | } |
35 | } |
36 | } |
37 | |
38 | /// Negates this duration. |
39 | /// |
40 | /// When the duration is a span, this can never fail because a span defines |
41 | /// its min and max values such that negation is always possible. |
42 | /// |
43 | /// When the duration is signed, then this attempts to return a signed |
44 | /// duration and only falling back to an unsigned duration when the number |
45 | /// of seconds corresponds to `i64::MIN`. |
46 | /// |
47 | /// When the duration is unsigned, then this fails when the whole seconds |
48 | /// exceed the absolute value of `i64::MIN`. Otherwise, a signed duration |
49 | /// is returned. |
50 | /// |
51 | /// The failures for large unsigned durations here are okay because the |
52 | /// point at which absolute durations overflow on negation, they would also |
53 | /// cause overflow when adding or subtracting to *any* valid datetime value |
54 | /// for *any* datetime type in this crate. So while the error message may |
55 | /// be different, the actual end result is the same (failure). |
56 | /// |
57 | /// TODO: Write unit tests for this. |
58 | #[cfg_attr (feature = "perf-inline" , inline(always))] |
59 | pub(crate) fn checked_neg(self) -> Result<Duration, Error> { |
60 | match self { |
61 | Duration::Span(span) => Ok(Duration::Span(span.negate())), |
62 | Duration::Signed(sdur) => { |
63 | // We try to stick with signed durations, but in the case |
64 | // where negation fails, we can represent its negation using |
65 | // an unsigned duration. |
66 | if let Some(sdur) = sdur.checked_neg() { |
67 | Ok(Duration::Signed(sdur)) |
68 | } else { |
69 | let udur = UnsignedDuration::new( |
70 | i64::MIN.unsigned_abs(), |
71 | sdur.subsec_nanos().unsigned_abs(), |
72 | ); |
73 | Ok(Duration::Unsigned(udur)) |
74 | } |
75 | } |
76 | Duration::Unsigned(udur) => { |
77 | // We can permit negating i64::MIN.unsigned_abs() to |
78 | // i64::MIN, but we need to handle it specially since |
79 | // i64::MIN.unsigned_abs() exceeds i64::MAX. |
80 | let sdur = if udur.as_secs() == i64::MIN.unsigned_abs() { |
81 | SignedDuration::new_without_nano_overflow( |
82 | i64::MIN, |
83 | // OK because `udur.subsec_nanos()` < 999_999_999. |
84 | -i32::try_from(udur.subsec_nanos()).unwrap(), |
85 | ) |
86 | } else { |
87 | // The negation here is always correct because it can only |
88 | // panic with `sdur.as_secs() == i64::MIN`, which is |
89 | // impossible because it must be positive. |
90 | // |
91 | // Otherwise, this is the only failure point in this entire |
92 | // routine. And specifically, we fail here in precisely |
93 | // the cases where `udur.as_secs() > |i64::MIN|`. |
94 | -SignedDuration::try_from(udur).with_context(|| { |
95 | err!("failed to negate unsigned duration {udur:?}" ) |
96 | })? |
97 | }; |
98 | Ok(Duration::Signed(sdur)) |
99 | } |
100 | } |
101 | } |
102 | |
103 | /// Returns true if and only if this duration is negative. |
104 | #[cfg_attr (feature = "perf-inline" , inline(always))] |
105 | pub(crate) fn is_negative(&self) -> bool { |
106 | match *self { |
107 | Duration::Span(ref span) => span.is_negative(), |
108 | Duration::Signed(ref sdur) => sdur.is_negative(), |
109 | Duration::Unsigned(_) => false, |
110 | } |
111 | } |
112 | } |
113 | |
114 | impl From<Span> for Duration { |
115 | #[inline ] |
116 | fn from(span: Span) -> Duration { |
117 | Duration::Span(span) |
118 | } |
119 | } |
120 | |
121 | impl From<SignedDuration> for Duration { |
122 | #[inline ] |
123 | fn from(sdur: SignedDuration) -> Duration { |
124 | Duration::Signed(sdur) |
125 | } |
126 | } |
127 | |
128 | impl From<UnsignedDuration> for Duration { |
129 | #[inline ] |
130 | fn from(udur: UnsignedDuration) -> Duration { |
131 | Duration::Unsigned(udur) |
132 | } |
133 | } |
134 | |
135 | /// An internal type for abstracting over signed durations. |
136 | /// |
137 | /// This is typically converted to from a `Duration`. It enables callers |
138 | /// downstream to implement datetime arithmetic on only two duration types |
139 | /// instead of doing it for three duration types (including |
140 | /// `std::time::Duration`). |
141 | /// |
142 | /// The main thing making this idea work is that if an unsigned duration cannot |
143 | /// fit into a signed duration, then it would overflow any calculation on any |
144 | /// datetime type in Jiff anyway. If this weren't true, then we'd need to |
145 | /// support doing actual arithmetic with unsigned durations separately from |
146 | /// signed durations. |
147 | #[derive (Clone, Copy, Debug)] |
148 | pub(crate) enum SDuration { |
149 | Span(Span), |
150 | Absolute(SignedDuration), |
151 | } |
152 | |