2022-01-04 10:21:08 +01:00
|
|
|
// Copyright (c) 2019-2022 Alexander Medvednikov. All rights reserved.
|
2020-01-01 12:01:03 +01:00
|
|
|
// Use of this source code is governed by an MIT license
|
|
|
|
// that can be found in the LICENSE file.
|
|
|
|
module time
|
|
|
|
|
2020-06-07 15:19:09 +02:00
|
|
|
#include <time.h>
|
2021-03-20 15:16:11 +01:00
|
|
|
#include <errno.h>
|
2021-02-01 14:50:41 +01:00
|
|
|
|
2020-01-01 12:01:03 +01:00
|
|
|
struct C.tm {
|
2020-12-06 15:19:39 +01:00
|
|
|
tm_sec int
|
|
|
|
tm_min int
|
|
|
|
tm_hour int
|
|
|
|
tm_mday int
|
|
|
|
tm_mon int
|
|
|
|
tm_year int
|
|
|
|
tm_wday int
|
|
|
|
tm_yday int
|
2020-06-10 11:14:55 +02:00
|
|
|
tm_isdst int
|
2020-01-01 12:01:03 +01:00
|
|
|
}
|
|
|
|
|
2021-05-27 21:40:32 +02:00
|
|
|
fn C.timegm(&C.tm) C.time_t
|
2020-12-06 15:19:39 +01:00
|
|
|
|
2020-12-26 02:10:47 +01:00
|
|
|
// fn C.gmtime_r(&tm, &gbuf)
|
2021-08-18 16:05:43 +02:00
|
|
|
fn C.localtime_r(t &C.time_t, tm &C.tm)
|
2020-01-01 12:01:03 +01:00
|
|
|
|
2021-08-04 12:12:02 +02:00
|
|
|
fn make_unix_time(t C.tm) i64 {
|
|
|
|
return i64(C.timegm(&t))
|
2020-02-04 12:17:04 +01:00
|
|
|
}
|
2020-04-24 07:33:25 +02:00
|
|
|
|
2020-12-26 02:10:47 +01:00
|
|
|
// local returns t with the location set to local time.
|
|
|
|
pub fn (t Time) local() Time {
|
2020-06-10 11:14:55 +02:00
|
|
|
loc_tm := C.tm{}
|
2021-04-05 21:32:33 +02:00
|
|
|
C.localtime_r(voidptr(&t.unix), &loc_tm)
|
2020-06-10 11:14:55 +02:00
|
|
|
return convert_ctime(loc_tm, t.microsecond)
|
|
|
|
}
|
|
|
|
|
2020-04-24 07:33:25 +02:00
|
|
|
// in most systems, these are __quad_t, which is an i64
|
|
|
|
struct C.timespec {
|
2020-07-15 10:22:33 +02:00
|
|
|
mut:
|
2020-04-24 07:33:25 +02:00
|
|
|
tv_sec i64
|
|
|
|
tv_nsec i64
|
|
|
|
}
|
|
|
|
|
|
|
|
// the first arg is defined in include/bits/types.h as `__S32_TYPE`, which is `int`
|
|
|
|
fn C.clock_gettime(int, &C.timespec)
|
|
|
|
|
2021-02-21 16:05:03 +01:00
|
|
|
fn C.nanosleep(req &C.timespec, rem &C.timespec) int
|
|
|
|
|
2021-01-13 15:30:54 +01:00
|
|
|
// sys_mono_now returns a *monotonically increasing time*, NOT a time adjusted for daylight savings, location etc.
|
2020-05-18 22:54:08 +02:00
|
|
|
pub fn sys_mono_now() u64 {
|
2020-04-24 07:33:25 +02:00
|
|
|
$if macos {
|
|
|
|
return sys_mono_now_darwin()
|
|
|
|
} $else {
|
|
|
|
ts := C.timespec{}
|
|
|
|
C.clock_gettime(C.CLOCK_MONOTONIC, &ts)
|
2020-12-06 15:19:39 +01:00
|
|
|
return u64(ts.tv_sec) * 1000000000 + u64(ts.tv_nsec)
|
2020-04-24 07:33:25 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-04-26 19:36:38 +02:00
|
|
|
// NB: vpc_now is used by `v -profile` .
|
|
|
|
// It should NOT call *any other v function*, just C functions and casts.
|
|
|
|
[inline]
|
|
|
|
fn vpc_now() u64 {
|
2020-05-05 16:19:25 +02:00
|
|
|
ts := C.timespec{}
|
|
|
|
C.clock_gettime(C.CLOCK_MONOTONIC, &ts)
|
2020-12-06 15:19:39 +01:00
|
|
|
return u64(ts.tv_sec) * 1000000000 + u64(ts.tv_nsec)
|
2020-04-26 19:36:38 +02:00
|
|
|
}
|
2020-06-07 15:19:09 +02:00
|
|
|
|
2020-09-25 17:02:02 +02:00
|
|
|
// The linux_* functions are placed here, since they're used on Android as well
|
|
|
|
// TODO: should `$if linux {}` be parsed on Android as well? (Android runs under the Linux kernel)
|
|
|
|
// linux_now returns the local time with high precision for most os:es
|
|
|
|
// this should be implemented properly with support for leap seconds.
|
|
|
|
// It uses the realtime clock to get and converts it to local time
|
|
|
|
fn linux_now() Time {
|
|
|
|
// get the high precision time as UTC realtime clock
|
|
|
|
// and use the nanoseconds part
|
|
|
|
mut ts := C.timespec{}
|
|
|
|
C.clock_gettime(C.CLOCK_REALTIME, &ts)
|
|
|
|
loc_tm := C.tm{}
|
2021-04-05 21:32:33 +02:00
|
|
|
C.localtime_r(voidptr(&ts.tv_sec), &loc_tm)
|
2020-12-06 15:19:39 +01:00
|
|
|
return convert_ctime(loc_tm, int(ts.tv_nsec / 1000))
|
2020-09-25 17:02:02 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
fn linux_utc() Time {
|
|
|
|
// get the high precision time as UTC realtime clock
|
|
|
|
// and use the nanoseconds part
|
|
|
|
mut ts := C.timespec{}
|
|
|
|
C.clock_gettime(C.CLOCK_REALTIME, &ts)
|
2021-07-06 17:51:47 +02:00
|
|
|
return unix2(i64(ts.tv_sec), int(ts.tv_nsec / 1000))
|
2020-09-25 17:02:02 +02:00
|
|
|
}
|
2020-06-10 11:14:55 +02:00
|
|
|
|
2020-06-07 15:19:09 +02:00
|
|
|
// dummy to compile with all compilers
|
|
|
|
pub fn win_now() Time {
|
|
|
|
return Time{}
|
|
|
|
}
|
|
|
|
|
2020-06-10 11:14:55 +02:00
|
|
|
// dummy to compile with all compilers
|
|
|
|
pub fn win_utc() Time {
|
|
|
|
return Time{}
|
|
|
|
}
|
2020-06-07 15:19:09 +02:00
|
|
|
|
|
|
|
// dummy to compile with all compilers
|
|
|
|
pub struct C.timeval {
|
|
|
|
tv_sec u64
|
|
|
|
tv_usec u64
|
2020-06-10 11:14:55 +02:00
|
|
|
}
|
2020-07-15 10:22:33 +02:00
|
|
|
|
|
|
|
// return absolute timespec for now()+d
|
|
|
|
pub fn (d Duration) timespec() C.timespec {
|
|
|
|
mut ts := C.timespec{}
|
|
|
|
C.clock_gettime(C.CLOCK_REALTIME, &ts)
|
|
|
|
d_sec := d / second
|
|
|
|
d_nsec := d % second
|
|
|
|
ts.tv_sec += d_sec
|
|
|
|
ts.tv_nsec += d_nsec
|
2020-12-21 09:27:06 +01:00
|
|
|
if ts.tv_nsec > i64(second) {
|
|
|
|
ts.tv_nsec -= i64(second)
|
2020-07-15 10:22:33 +02:00
|
|
|
ts.tv_sec++
|
|
|
|
}
|
|
|
|
return ts
|
|
|
|
}
|
|
|
|
|
|
|
|
// return timespec of 1970/1/1
|
|
|
|
pub fn zero_timespec() C.timespec {
|
|
|
|
ts := C.timespec{
|
2020-12-06 15:19:39 +01:00
|
|
|
tv_sec: 0
|
2020-07-15 10:22:33 +02:00
|
|
|
tv_nsec: 0
|
|
|
|
}
|
|
|
|
return ts
|
|
|
|
}
|
2021-02-21 16:05:03 +01:00
|
|
|
|
2021-02-27 18:41:06 +01:00
|
|
|
// sleep makes the calling thread sleep for a given duration (in nanoseconds).
|
|
|
|
pub fn sleep(duration Duration) {
|
2021-03-20 15:16:11 +01:00
|
|
|
mut req := C.timespec{duration / second, duration % second}
|
|
|
|
rem := C.timespec{}
|
|
|
|
for C.nanosleep(&req, &rem) < 0 {
|
|
|
|
if C.errno == C.EINTR {
|
|
|
|
// Interrupted by a signal handler
|
|
|
|
req = rem
|
|
|
|
} else {
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
2021-02-27 18:41:06 +01:00
|
|
|
}
|
2021-06-22 11:17:44 +02:00
|
|
|
|
|
|
|
// some *nix system functions (e.g. `C.poll()`, C.epoll_wait()) accept an `int`
|
|
|
|
// value as *timeout in milliseconds* with the special value `-1` meaning "infinite"
|
|
|
|
pub fn (d Duration) sys_milliseconds() int {
|
|
|
|
if d > C.INT32_MAX * millisecond { // treat 2147483647000001 .. C.INT64_MAX as "infinite"
|
|
|
|
return -1
|
|
|
|
} else if d <= 0 {
|
|
|
|
return 0 // treat negative timeouts as 0 - consistent with Unix behaviour
|
|
|
|
} else {
|
|
|
|
return int(d / millisecond)
|
|
|
|
}
|
|
|
|
}
|