Austin Schuh | 36244a1 | 2019-09-21 17:52:38 -0700 | [diff] [blame] | 1 | // Copyright 2017 The Abseil Authors. |
| 2 | // |
| 3 | // Licensed under the Apache License, Version 2.0 (the "License"); |
| 4 | // you may not use this file except in compliance with the License. |
| 5 | // You may obtain a copy of the License at |
| 6 | // |
| 7 | // https://www.apache.org/licenses/LICENSE-2.0 |
| 8 | // |
| 9 | // Unless required by applicable law or agreed to in writing, software |
| 10 | // distributed under the License is distributed on an "AS IS" BASIS, |
| 11 | // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 12 | // See the License for the specific language governing permissions and |
| 13 | // limitations under the License. |
| 14 | |
| 15 | // The implementation of the absl::Time class, which is declared in |
| 16 | // //absl/time.h. |
| 17 | // |
| 18 | // The representation for an absl::Time is an absl::Duration offset from the |
| 19 | // epoch. We use the traditional Unix epoch (1970-01-01 00:00:00 +0000) |
| 20 | // for convenience, but this is not exposed in the API and could be changed. |
| 21 | // |
| 22 | // NOTE: To keep type verbosity to a minimum, the following variable naming |
| 23 | // conventions are used throughout this file. |
| 24 | // |
| 25 | // tz: An absl::TimeZone |
| 26 | // ci: An absl::TimeZone::CivilInfo |
| 27 | // ti: An absl::TimeZone::TimeInfo |
| 28 | // cd: An absl::CivilDay or a cctz::civil_day |
| 29 | // cs: An absl::CivilSecond or a cctz::civil_second |
| 30 | // bd: An absl::Time::Breakdown |
| 31 | // cl: A cctz::time_zone::civil_lookup |
| 32 | // al: A cctz::time_zone::absolute_lookup |
| 33 | |
| 34 | #include "absl/time/time.h" |
| 35 | |
| 36 | #if defined(_MSC_VER) |
| 37 | #include <winsock2.h> // for timeval |
| 38 | #endif |
| 39 | |
| 40 | #include <cstring> |
| 41 | #include <ctime> |
| 42 | #include <limits> |
| 43 | |
| 44 | #include "absl/time/internal/cctz/include/cctz/civil_time.h" |
| 45 | #include "absl/time/internal/cctz/include/cctz/time_zone.h" |
| 46 | |
| 47 | namespace cctz = absl::time_internal::cctz; |
| 48 | |
| 49 | namespace absl { |
| 50 | |
| 51 | namespace { |
| 52 | |
| 53 | inline cctz::time_point<cctz::seconds> unix_epoch() { |
| 54 | return std::chrono::time_point_cast<cctz::seconds>( |
| 55 | std::chrono::system_clock::from_time_t(0)); |
| 56 | } |
| 57 | |
| 58 | // Floors d to the next unit boundary closer to negative infinity. |
| 59 | inline int64_t FloorToUnit(absl::Duration d, absl::Duration unit) { |
| 60 | absl::Duration rem; |
| 61 | int64_t q = absl::IDivDuration(d, unit, &rem); |
| 62 | return (q > 0 || |
| 63 | rem >= ZeroDuration() || |
| 64 | q == std::numeric_limits<int64_t>::min()) ? q : q - 1; |
| 65 | } |
| 66 | |
| 67 | inline absl::Time::Breakdown InfiniteFutureBreakdown() { |
| 68 | absl::Time::Breakdown bd; |
| 69 | bd.year = std::numeric_limits<int64_t>::max(); |
| 70 | bd.month = 12; |
| 71 | bd.day = 31; |
| 72 | bd.hour = 23; |
| 73 | bd.minute = 59; |
| 74 | bd.second = 59; |
| 75 | bd.subsecond = absl::InfiniteDuration(); |
| 76 | bd.weekday = 4; |
| 77 | bd.yearday = 365; |
| 78 | bd.offset = 0; |
| 79 | bd.is_dst = false; |
| 80 | bd.zone_abbr = "-00"; |
| 81 | return bd; |
| 82 | } |
| 83 | |
| 84 | inline absl::Time::Breakdown InfinitePastBreakdown() { |
| 85 | Time::Breakdown bd; |
| 86 | bd.year = std::numeric_limits<int64_t>::min(); |
| 87 | bd.month = 1; |
| 88 | bd.day = 1; |
| 89 | bd.hour = 0; |
| 90 | bd.minute = 0; |
| 91 | bd.second = 0; |
| 92 | bd.subsecond = -absl::InfiniteDuration(); |
| 93 | bd.weekday = 7; |
| 94 | bd.yearday = 1; |
| 95 | bd.offset = 0; |
| 96 | bd.is_dst = false; |
| 97 | bd.zone_abbr = "-00"; |
| 98 | return bd; |
| 99 | } |
| 100 | |
| 101 | inline absl::TimeZone::CivilInfo InfiniteFutureCivilInfo() { |
| 102 | TimeZone::CivilInfo ci; |
| 103 | ci.cs = CivilSecond::max(); |
| 104 | ci.subsecond = InfiniteDuration(); |
| 105 | ci.offset = 0; |
| 106 | ci.is_dst = false; |
| 107 | ci.zone_abbr = "-00"; |
| 108 | return ci; |
| 109 | } |
| 110 | |
| 111 | inline absl::TimeZone::CivilInfo InfinitePastCivilInfo() { |
| 112 | TimeZone::CivilInfo ci; |
| 113 | ci.cs = CivilSecond::min(); |
| 114 | ci.subsecond = -InfiniteDuration(); |
| 115 | ci.offset = 0; |
| 116 | ci.is_dst = false; |
| 117 | ci.zone_abbr = "-00"; |
| 118 | return ci; |
| 119 | } |
| 120 | |
| 121 | inline absl::TimeConversion InfiniteFutureTimeConversion() { |
| 122 | absl::TimeConversion tc; |
| 123 | tc.pre = tc.trans = tc.post = absl::InfiniteFuture(); |
| 124 | tc.kind = absl::TimeConversion::UNIQUE; |
| 125 | tc.normalized = true; |
| 126 | return tc; |
| 127 | } |
| 128 | |
| 129 | inline TimeConversion InfinitePastTimeConversion() { |
| 130 | absl::TimeConversion tc; |
| 131 | tc.pre = tc.trans = tc.post = absl::InfinitePast(); |
| 132 | tc.kind = absl::TimeConversion::UNIQUE; |
| 133 | tc.normalized = true; |
| 134 | return tc; |
| 135 | } |
| 136 | |
| 137 | // Makes a Time from sec, overflowing to InfiniteFuture/InfinitePast as |
| 138 | // necessary. If sec is min/max, then consult cs+tz to check for overlow. |
| 139 | Time MakeTimeWithOverflow(const cctz::time_point<cctz::seconds>& sec, |
| 140 | const cctz::civil_second& cs, |
| 141 | const cctz::time_zone& tz, |
| 142 | bool* normalized = nullptr) { |
| 143 | const auto max = cctz::time_point<cctz::seconds>::max(); |
| 144 | const auto min = cctz::time_point<cctz::seconds>::min(); |
| 145 | if (sec == max) { |
| 146 | const auto al = tz.lookup(max); |
| 147 | if (cs > al.cs) { |
| 148 | if (normalized) *normalized = true; |
| 149 | return absl::InfiniteFuture(); |
| 150 | } |
| 151 | } |
| 152 | if (sec == min) { |
| 153 | const auto al = tz.lookup(min); |
| 154 | if (cs < al.cs) { |
| 155 | if (normalized) *normalized = true; |
| 156 | return absl::InfinitePast(); |
| 157 | } |
| 158 | } |
| 159 | const auto hi = (sec - unix_epoch()).count(); |
| 160 | return time_internal::FromUnixDuration(time_internal::MakeDuration(hi)); |
| 161 | } |
| 162 | |
| 163 | // Returns Mon=1..Sun=7. |
| 164 | inline int MapWeekday(const cctz::weekday& wd) { |
| 165 | switch (wd) { |
| 166 | case cctz::weekday::monday: |
| 167 | return 1; |
| 168 | case cctz::weekday::tuesday: |
| 169 | return 2; |
| 170 | case cctz::weekday::wednesday: |
| 171 | return 3; |
| 172 | case cctz::weekday::thursday: |
| 173 | return 4; |
| 174 | case cctz::weekday::friday: |
| 175 | return 5; |
| 176 | case cctz::weekday::saturday: |
| 177 | return 6; |
| 178 | case cctz::weekday::sunday: |
| 179 | return 7; |
| 180 | } |
| 181 | return 1; |
| 182 | } |
| 183 | |
| 184 | bool FindTransition(const cctz::time_zone& tz, |
| 185 | bool (cctz::time_zone::*find_transition)( |
| 186 | const cctz::time_point<cctz::seconds>& tp, |
| 187 | cctz::time_zone::civil_transition* trans) const, |
| 188 | Time t, TimeZone::CivilTransition* trans) { |
| 189 | // Transitions are second-aligned, so we can discard any fractional part. |
| 190 | const auto tp = unix_epoch() + cctz::seconds(ToUnixSeconds(t)); |
| 191 | cctz::time_zone::civil_transition tr; |
| 192 | if (!(tz.*find_transition)(tp, &tr)) return false; |
| 193 | trans->from = CivilSecond(tr.from); |
| 194 | trans->to = CivilSecond(tr.to); |
| 195 | return true; |
| 196 | } |
| 197 | |
| 198 | } // namespace |
| 199 | |
| 200 | // |
| 201 | // Time |
| 202 | // |
| 203 | |
| 204 | absl::Time::Breakdown Time::In(absl::TimeZone tz) const { |
| 205 | if (*this == absl::InfiniteFuture()) return InfiniteFutureBreakdown(); |
| 206 | if (*this == absl::InfinitePast()) return InfinitePastBreakdown(); |
| 207 | |
| 208 | const auto tp = unix_epoch() + cctz::seconds(time_internal::GetRepHi(rep_)); |
| 209 | const auto al = cctz::time_zone(tz).lookup(tp); |
| 210 | const auto cs = al.cs; |
| 211 | const auto cd = cctz::civil_day(cs); |
| 212 | |
| 213 | absl::Time::Breakdown bd; |
| 214 | bd.year = cs.year(); |
| 215 | bd.month = cs.month(); |
| 216 | bd.day = cs.day(); |
| 217 | bd.hour = cs.hour(); |
| 218 | bd.minute = cs.minute(); |
| 219 | bd.second = cs.second(); |
| 220 | bd.subsecond = time_internal::MakeDuration(0, time_internal::GetRepLo(rep_)); |
| 221 | bd.weekday = MapWeekday(cctz::get_weekday(cd)); |
| 222 | bd.yearday = cctz::get_yearday(cd); |
| 223 | bd.offset = al.offset; |
| 224 | bd.is_dst = al.is_dst; |
| 225 | bd.zone_abbr = al.abbr; |
| 226 | return bd; |
| 227 | } |
| 228 | |
| 229 | // |
| 230 | // Conversions from/to other time types. |
| 231 | // |
| 232 | |
| 233 | absl::Time FromUDate(double udate) { |
| 234 | return time_internal::FromUnixDuration(absl::Milliseconds(udate)); |
| 235 | } |
| 236 | |
| 237 | absl::Time FromUniversal(int64_t universal) { |
| 238 | return absl::UniversalEpoch() + 100 * absl::Nanoseconds(universal); |
| 239 | } |
| 240 | |
| 241 | int64_t ToUnixNanos(Time t) { |
| 242 | if (time_internal::GetRepHi(time_internal::ToUnixDuration(t)) >= 0 && |
| 243 | time_internal::GetRepHi(time_internal::ToUnixDuration(t)) >> 33 == 0) { |
| 244 | return (time_internal::GetRepHi(time_internal::ToUnixDuration(t)) * |
| 245 | 1000 * 1000 * 1000) + |
| 246 | (time_internal::GetRepLo(time_internal::ToUnixDuration(t)) / 4); |
| 247 | } |
| 248 | return FloorToUnit(time_internal::ToUnixDuration(t), absl::Nanoseconds(1)); |
| 249 | } |
| 250 | |
| 251 | int64_t ToUnixMicros(Time t) { |
| 252 | if (time_internal::GetRepHi(time_internal::ToUnixDuration(t)) >= 0 && |
| 253 | time_internal::GetRepHi(time_internal::ToUnixDuration(t)) >> 43 == 0) { |
| 254 | return (time_internal::GetRepHi(time_internal::ToUnixDuration(t)) * |
| 255 | 1000 * 1000) + |
| 256 | (time_internal::GetRepLo(time_internal::ToUnixDuration(t)) / 4000); |
| 257 | } |
| 258 | return FloorToUnit(time_internal::ToUnixDuration(t), absl::Microseconds(1)); |
| 259 | } |
| 260 | |
| 261 | int64_t ToUnixMillis(Time t) { |
| 262 | if (time_internal::GetRepHi(time_internal::ToUnixDuration(t)) >= 0 && |
| 263 | time_internal::GetRepHi(time_internal::ToUnixDuration(t)) >> 53 == 0) { |
| 264 | return (time_internal::GetRepHi(time_internal::ToUnixDuration(t)) * 1000) + |
| 265 | (time_internal::GetRepLo(time_internal::ToUnixDuration(t)) / |
| 266 | (4000 * 1000)); |
| 267 | } |
| 268 | return FloorToUnit(time_internal::ToUnixDuration(t), absl::Milliseconds(1)); |
| 269 | } |
| 270 | |
| 271 | int64_t ToUnixSeconds(Time t) { |
| 272 | return time_internal::GetRepHi(time_internal::ToUnixDuration(t)); |
| 273 | } |
| 274 | |
| 275 | time_t ToTimeT(Time t) { return absl::ToTimespec(t).tv_sec; } |
| 276 | |
| 277 | double ToUDate(Time t) { |
| 278 | return absl::FDivDuration(time_internal::ToUnixDuration(t), |
| 279 | absl::Milliseconds(1)); |
| 280 | } |
| 281 | |
| 282 | int64_t ToUniversal(absl::Time t) { |
| 283 | return absl::FloorToUnit(t - absl::UniversalEpoch(), absl::Nanoseconds(100)); |
| 284 | } |
| 285 | |
| 286 | absl::Time TimeFromTimespec(timespec ts) { |
| 287 | return time_internal::FromUnixDuration(absl::DurationFromTimespec(ts)); |
| 288 | } |
| 289 | |
| 290 | absl::Time TimeFromTimeval(timeval tv) { |
| 291 | return time_internal::FromUnixDuration(absl::DurationFromTimeval(tv)); |
| 292 | } |
| 293 | |
| 294 | timespec ToTimespec(Time t) { |
| 295 | timespec ts; |
| 296 | absl::Duration d = time_internal::ToUnixDuration(t); |
| 297 | if (!time_internal::IsInfiniteDuration(d)) { |
| 298 | ts.tv_sec = time_internal::GetRepHi(d); |
| 299 | if (ts.tv_sec == time_internal::GetRepHi(d)) { // no time_t narrowing |
| 300 | ts.tv_nsec = time_internal::GetRepLo(d) / 4; // floor |
| 301 | return ts; |
| 302 | } |
| 303 | } |
| 304 | if (d >= absl::ZeroDuration()) { |
| 305 | ts.tv_sec = std::numeric_limits<time_t>::max(); |
| 306 | ts.tv_nsec = 1000 * 1000 * 1000 - 1; |
| 307 | } else { |
| 308 | ts.tv_sec = std::numeric_limits<time_t>::min(); |
| 309 | ts.tv_nsec = 0; |
| 310 | } |
| 311 | return ts; |
| 312 | } |
| 313 | |
| 314 | timeval ToTimeval(Time t) { |
| 315 | timeval tv; |
| 316 | timespec ts = absl::ToTimespec(t); |
| 317 | tv.tv_sec = ts.tv_sec; |
| 318 | if (tv.tv_sec != ts.tv_sec) { // narrowing |
| 319 | if (ts.tv_sec < 0) { |
| 320 | tv.tv_sec = std::numeric_limits<decltype(tv.tv_sec)>::min(); |
| 321 | tv.tv_usec = 0; |
| 322 | } else { |
| 323 | tv.tv_sec = std::numeric_limits<decltype(tv.tv_sec)>::max(); |
| 324 | tv.tv_usec = 1000 * 1000 - 1; |
| 325 | } |
| 326 | return tv; |
| 327 | } |
| 328 | tv.tv_usec = static_cast<int>(ts.tv_nsec / 1000); // suseconds_t |
| 329 | return tv; |
| 330 | } |
| 331 | |
| 332 | Time FromChrono(const std::chrono::system_clock::time_point& tp) { |
| 333 | return time_internal::FromUnixDuration(time_internal::FromChrono( |
| 334 | tp - std::chrono::system_clock::from_time_t(0))); |
| 335 | } |
| 336 | |
| 337 | std::chrono::system_clock::time_point ToChronoTime(absl::Time t) { |
| 338 | using D = std::chrono::system_clock::duration; |
| 339 | auto d = time_internal::ToUnixDuration(t); |
| 340 | if (d < ZeroDuration()) d = Floor(d, FromChrono(D{1})); |
| 341 | return std::chrono::system_clock::from_time_t(0) + |
| 342 | time_internal::ToChronoDuration<D>(d); |
| 343 | } |
| 344 | |
| 345 | // |
| 346 | // TimeZone |
| 347 | // |
| 348 | |
| 349 | absl::TimeZone::CivilInfo TimeZone::At(Time t) const { |
| 350 | if (t == absl::InfiniteFuture()) return InfiniteFutureCivilInfo(); |
| 351 | if (t == absl::InfinitePast()) return InfinitePastCivilInfo(); |
| 352 | |
| 353 | const auto ud = time_internal::ToUnixDuration(t); |
| 354 | const auto tp = unix_epoch() + cctz::seconds(time_internal::GetRepHi(ud)); |
| 355 | const auto al = cz_.lookup(tp); |
| 356 | |
| 357 | TimeZone::CivilInfo ci; |
| 358 | ci.cs = CivilSecond(al.cs); |
| 359 | ci.subsecond = time_internal::MakeDuration(0, time_internal::GetRepLo(ud)); |
| 360 | ci.offset = al.offset; |
| 361 | ci.is_dst = al.is_dst; |
| 362 | ci.zone_abbr = al.abbr; |
| 363 | return ci; |
| 364 | } |
| 365 | |
| 366 | absl::TimeZone::TimeInfo TimeZone::At(CivilSecond ct) const { |
| 367 | const cctz::civil_second cs(ct); |
| 368 | const auto cl = cz_.lookup(cs); |
| 369 | |
| 370 | TimeZone::TimeInfo ti; |
| 371 | switch (cl.kind) { |
| 372 | case cctz::time_zone::civil_lookup::UNIQUE: |
| 373 | ti.kind = TimeZone::TimeInfo::UNIQUE; |
| 374 | break; |
| 375 | case cctz::time_zone::civil_lookup::SKIPPED: |
| 376 | ti.kind = TimeZone::TimeInfo::SKIPPED; |
| 377 | break; |
| 378 | case cctz::time_zone::civil_lookup::REPEATED: |
| 379 | ti.kind = TimeZone::TimeInfo::REPEATED; |
| 380 | break; |
| 381 | } |
| 382 | ti.pre = MakeTimeWithOverflow(cl.pre, cs, cz_); |
| 383 | ti.trans = MakeTimeWithOverflow(cl.trans, cs, cz_); |
| 384 | ti.post = MakeTimeWithOverflow(cl.post, cs, cz_); |
| 385 | return ti; |
| 386 | } |
| 387 | |
| 388 | bool TimeZone::NextTransition(Time t, CivilTransition* trans) const { |
| 389 | return FindTransition(cz_, &cctz::time_zone::next_transition, t, trans); |
| 390 | } |
| 391 | |
| 392 | bool TimeZone::PrevTransition(Time t, CivilTransition* trans) const { |
| 393 | return FindTransition(cz_, &cctz::time_zone::prev_transition, t, trans); |
| 394 | } |
| 395 | |
| 396 | // |
| 397 | // Conversions involving time zones. |
| 398 | // |
| 399 | |
| 400 | absl::TimeConversion ConvertDateTime(int64_t year, int mon, int day, int hour, |
| 401 | int min, int sec, TimeZone tz) { |
| 402 | // Avoids years that are too extreme for CivilSecond to normalize. |
| 403 | if (year > 300000000000) return InfiniteFutureTimeConversion(); |
| 404 | if (year < -300000000000) return InfinitePastTimeConversion(); |
| 405 | |
| 406 | const CivilSecond cs(year, mon, day, hour, min, sec); |
| 407 | const auto ti = tz.At(cs); |
| 408 | |
| 409 | TimeConversion tc; |
| 410 | tc.pre = ti.pre; |
| 411 | tc.trans = ti.trans; |
| 412 | tc.post = ti.post; |
| 413 | switch (ti.kind) { |
| 414 | case TimeZone::TimeInfo::UNIQUE: |
| 415 | tc.kind = TimeConversion::UNIQUE; |
| 416 | break; |
| 417 | case TimeZone::TimeInfo::SKIPPED: |
| 418 | tc.kind = TimeConversion::SKIPPED; |
| 419 | break; |
| 420 | case TimeZone::TimeInfo::REPEATED: |
| 421 | tc.kind = TimeConversion::REPEATED; |
| 422 | break; |
| 423 | } |
| 424 | tc.normalized = false; |
| 425 | if (year != cs.year() || mon != cs.month() || day != cs.day() || |
| 426 | hour != cs.hour() || min != cs.minute() || sec != cs.second()) { |
| 427 | tc.normalized = true; |
| 428 | } |
| 429 | return tc; |
| 430 | } |
| 431 | |
| 432 | absl::Time FromTM(const struct tm& tm, absl::TimeZone tz) { |
| 433 | const CivilSecond cs(tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, |
| 434 | tm.tm_hour, tm.tm_min, tm.tm_sec); |
| 435 | const auto ti = tz.At(cs); |
| 436 | return tm.tm_isdst == 0 ? ti.post : ti.pre; |
| 437 | } |
| 438 | |
| 439 | struct tm ToTM(absl::Time t, absl::TimeZone tz) { |
| 440 | struct tm tm = {}; |
| 441 | |
| 442 | const auto ci = tz.At(t); |
| 443 | const auto& cs = ci.cs; |
| 444 | tm.tm_sec = cs.second(); |
| 445 | tm.tm_min = cs.minute(); |
| 446 | tm.tm_hour = cs.hour(); |
| 447 | tm.tm_mday = cs.day(); |
| 448 | tm.tm_mon = cs.month() - 1; |
| 449 | |
| 450 | // Saturates tm.tm_year in cases of over/underflow, accounting for the fact |
| 451 | // that tm.tm_year is years since 1900. |
| 452 | if (cs.year() < std::numeric_limits<int>::min() + 1900) { |
| 453 | tm.tm_year = std::numeric_limits<int>::min(); |
| 454 | } else if (cs.year() > std::numeric_limits<int>::max()) { |
| 455 | tm.tm_year = std::numeric_limits<int>::max() - 1900; |
| 456 | } else { |
| 457 | tm.tm_year = static_cast<int>(cs.year() - 1900); |
| 458 | } |
| 459 | |
| 460 | switch (GetWeekday(cs)) { |
| 461 | case Weekday::sunday: |
| 462 | tm.tm_wday = 0; |
| 463 | break; |
| 464 | case Weekday::monday: |
| 465 | tm.tm_wday = 1; |
| 466 | break; |
| 467 | case Weekday::tuesday: |
| 468 | tm.tm_wday = 2; |
| 469 | break; |
| 470 | case Weekday::wednesday: |
| 471 | tm.tm_wday = 3; |
| 472 | break; |
| 473 | case Weekday::thursday: |
| 474 | tm.tm_wday = 4; |
| 475 | break; |
| 476 | case Weekday::friday: |
| 477 | tm.tm_wday = 5; |
| 478 | break; |
| 479 | case Weekday::saturday: |
| 480 | tm.tm_wday = 6; |
| 481 | break; |
| 482 | } |
| 483 | tm.tm_yday = GetYearDay(cs) - 1; |
| 484 | tm.tm_isdst = ci.is_dst ? 1 : 0; |
| 485 | |
| 486 | return tm; |
| 487 | } |
| 488 | |
| 489 | } // namespace absl |