compat_time.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791
  1. /* Copyright (c) 2003-2004, Roger Dingledine
  2. * Copyright (c) 2004-2006, Roger Dingledine, Nick Mathewson.
  3. * Copyright (c) 2007-2017, The Tor Project, Inc. */
  4. /* See LICENSE for licensing information */
  5. /**
  6. * \file compat_time.c
  7. * \brief Portable wrappers for finding out the current time, running
  8. * timers, etc.
  9. **/
  10. #define COMPAT_TIME_PRIVATE
  11. #include "compat.h"
  12. #ifdef _WIN32
  13. #include <winsock2.h>
  14. #include <windows.h>
  15. #endif
  16. #ifdef HAVE_SYS_TYPES_H
  17. #include <sys/types.h>
  18. #endif
  19. #ifdef HAVE_UNISTD_H
  20. #include <unistd.h>
  21. #endif
  22. #ifdef TOR_UNIT_TESTS
  23. #if !defined(HAVE_USLEEP) && defined(HAVE_SYS_SELECT_H)
  24. /* as fallback implementation for tor_sleep_msec */
  25. #include <sys/select.h>
  26. #endif
  27. #endif /* defined(TOR_UNIT_TESTS) */
  28. #ifdef __APPLE__
  29. #include <mach/mach_time.h>
  30. #endif
  31. #include "torlog.h"
  32. #include "util.h"
  33. #include "container.h"
  34. #ifndef HAVE_GETTIMEOFDAY
  35. #ifdef HAVE_FTIME
  36. #include <sys/timeb.h>
  37. #endif
  38. #endif
  39. #ifdef _WIN32
  40. #undef HAVE_CLOCK_GETTIME
  41. #endif
  42. #ifdef TOR_UNIT_TESTS
  43. /** Delay for <b>msec</b> milliseconds. Only used in tests. */
  44. void
  45. tor_sleep_msec(int msec)
  46. {
  47. #ifdef _WIN32
  48. Sleep(msec);
  49. #elif defined(HAVE_USLEEP)
  50. sleep(msec / 1000);
  51. /* Some usleep()s hate sleeping more than 1 sec */
  52. usleep((msec % 1000) * 1000);
  53. #elif defined(HAVE_SYS_SELECT_H)
  54. struct timeval tv = { msec / 1000, (msec % 1000) * 1000};
  55. select(0, NULL, NULL, NULL, &tv);
  56. #else
  57. sleep(CEIL_DIV(msec, 1000));
  58. #endif /* defined(_WIN32) || ... */
  59. }
  60. #endif /* defined(TOR_UNIT_TESTS) */
  61. /** Set *timeval to the current time of day. On error, log and terminate.
  62. * (Same as gettimeofday(timeval,NULL), but never returns -1.)
  63. */
  64. void
  65. tor_gettimeofday(struct timeval *timeval)
  66. {
  67. #ifdef _WIN32
  68. /* Epoch bias copied from perl: number of units between windows epoch and
  69. * Unix epoch. */
  70. #define EPOCH_BIAS U64_LITERAL(116444736000000000)
  71. #define UNITS_PER_SEC U64_LITERAL(10000000)
  72. #define USEC_PER_SEC U64_LITERAL(1000000)
  73. #define UNITS_PER_USEC U64_LITERAL(10)
  74. union {
  75. uint64_t ft_64;
  76. FILETIME ft_ft;
  77. } ft;
  78. /* number of 100-nsec units since Jan 1, 1601 */
  79. GetSystemTimeAsFileTime(&ft.ft_ft);
  80. if (ft.ft_64 < EPOCH_BIAS) {
  81. /* LCOV_EXCL_START */
  82. log_err(LD_GENERAL,"System time is before 1970; failing.");
  83. exit(1); // exit ok: system clock is broken.
  84. /* LCOV_EXCL_STOP */
  85. }
  86. ft.ft_64 -= EPOCH_BIAS;
  87. timeval->tv_sec = (unsigned) (ft.ft_64 / UNITS_PER_SEC);
  88. timeval->tv_usec = (unsigned) ((ft.ft_64 / UNITS_PER_USEC) % USEC_PER_SEC);
  89. #elif defined(HAVE_GETTIMEOFDAY)
  90. if (gettimeofday(timeval, NULL)) {
  91. /* LCOV_EXCL_START */
  92. log_err(LD_GENERAL,"gettimeofday failed.");
  93. /* If gettimeofday dies, we have either given a bad timezone (we didn't),
  94. or segfaulted.*/
  95. exit(1); // exit ok: gettimeofday failed.
  96. /* LCOV_EXCL_STOP */
  97. }
  98. #elif defined(HAVE_FTIME)
  99. struct timeb tb;
  100. ftime(&tb);
  101. timeval->tv_sec = tb.time;
  102. timeval->tv_usec = tb.millitm * 1000;
  103. #else
  104. #error "No way to get time."
  105. #endif /* defined(_WIN32) || ... */
  106. return;
  107. }
  108. #define ONE_MILLION ((int64_t) (1000 * 1000))
  109. #define ONE_BILLION ((int64_t) (1000 * 1000 * 1000))
  110. /** True iff monotime_init has been called. */
  111. static int monotime_initialized = 0;
  112. static monotime_t initialized_at;
  113. #ifdef MONOTIME_COARSE_FN_IS_DIFFERENT
  114. static monotime_coarse_t initialized_at_coarse;
  115. #endif
  116. #ifdef TOR_UNIT_TESTS
  117. /** True if we are running unit tests and overriding the current monotonic
  118. * time. Note that mocked monotonic time might not be monotonic.
  119. */
  120. static int monotime_mocking_enabled = 0;
  121. static monotime_t initialized_at_saved;
  122. static int64_t mock_time_nsec = 0;
  123. #ifdef MONOTIME_COARSE_FN_IS_DIFFERENT
  124. static int64_t mock_time_nsec_coarse = 0;
  125. static monotime_coarse_t initialized_at_coarse_saved;
  126. #endif
  127. void
  128. monotime_enable_test_mocking(void)
  129. {
  130. if (BUG(monotime_initialized == 0)) {
  131. monotime_init();
  132. }
  133. tor_assert_nonfatal(monotime_mocking_enabled == 0);
  134. monotime_mocking_enabled = 1;
  135. memcpy(&initialized_at_saved,
  136. &initialized_at, sizeof(monotime_t));
  137. memset(&initialized_at, 0, sizeof(monotime_t));
  138. #ifdef MONOTIME_COARSE_FN_IS_DIFFERENT
  139. memcpy(&initialized_at_coarse_saved,
  140. &initialized_at_coarse, sizeof(monotime_coarse_t));
  141. memset(&initialized_at_coarse, 0, sizeof(monotime_coarse_t));
  142. #endif
  143. }
  144. void
  145. monotime_disable_test_mocking(void)
  146. {
  147. tor_assert_nonfatal(monotime_mocking_enabled == 1);
  148. monotime_mocking_enabled = 0;
  149. memcpy(&initialized_at,
  150. &initialized_at_saved, sizeof(monotime_t));
  151. #ifdef MONOTIME_COARSE_FN_IS_DIFFERENT
  152. memcpy(&initialized_at_coarse,
  153. &initialized_at_coarse_saved, sizeof(monotime_coarse_t));
  154. #endif
  155. }
  156. void
  157. monotime_set_mock_time_nsec(int64_t nsec)
  158. {
  159. tor_assert_nonfatal(monotime_mocking_enabled == 1);
  160. mock_time_nsec = nsec;
  161. }
  162. #ifdef MONOTIME_COARSE_FN_IS_DIFFERENT
  163. void
  164. monotime_coarse_set_mock_time_nsec(int64_t nsec)
  165. {
  166. tor_assert_nonfatal(monotime_mocking_enabled == 1);
  167. mock_time_nsec_coarse = nsec;
  168. }
  169. #endif /* defined(MONOTIME_COARSE_FN_IS_DIFFERENT) */
  170. #endif /* defined(TOR_UNIT_TESTS) */
  171. /* "ratchet" functions for monotonic time. */
  172. #if defined(_WIN32) || defined(TOR_UNIT_TESTS)
  173. /** Protected by lock: last value returned by monotime_get(). */
  174. static int64_t last_pctr = 0;
  175. /** Protected by lock: offset we must add to monotonic time values. */
  176. static int64_t pctr_offset = 0;
  177. /* If we are using GetTickCount(), how many times has it rolled over? */
  178. static uint32_t rollover_count = 0;
  179. /* If we are using GetTickCount(), what's the last value it returned? */
  180. static int64_t last_tick_count = 0;
  181. /** Helper for windows: Called with a sequence of times that are supposed
  182. * to be monotonic; increments them as appropriate so that they actually
  183. * _are_ monotonic.
  184. *
  185. * Caller must hold lock. */
  186. STATIC int64_t
  187. ratchet_performance_counter(int64_t count_raw)
  188. {
  189. /* must hold lock */
  190. const int64_t count_adjusted = count_raw + pctr_offset;
  191. if (PREDICT_UNLIKELY(count_adjusted < last_pctr)) {
  192. /* Monotonicity failed! Pretend no time elapsed. */
  193. pctr_offset = last_pctr - count_raw;
  194. return last_pctr;
  195. } else {
  196. last_pctr = count_adjusted;
  197. return count_adjusted;
  198. }
  199. }
  200. STATIC int64_t
  201. ratchet_coarse_performance_counter(const int64_t count_raw)
  202. {
  203. int64_t count = count_raw + (((int64_t)rollover_count) << 32);
  204. while (PREDICT_UNLIKELY(count < last_tick_count)) {
  205. ++rollover_count;
  206. count = count_raw + (((int64_t)rollover_count) << 32);
  207. }
  208. last_tick_count = count;
  209. return count;
  210. }
  211. #endif /* defined(_WIN32) || defined(TOR_UNIT_TESTS) */
  212. #if defined(MONOTIME_USING_GETTIMEOFDAY) || defined(TOR_UNIT_TESTS)
  213. static struct timeval last_timeofday = { 0, 0 };
  214. static struct timeval timeofday_offset = { 0, 0 };
  215. /** Helper for gettimeofday(): Called with a sequence of times that are
  216. * supposed to be monotonic; increments them as appropriate so that they
  217. * actually _are_ monotonic.
  218. *
  219. * Caller must hold lock. */
  220. STATIC void
  221. ratchet_timeval(const struct timeval *timeval_raw, struct timeval *out)
  222. {
  223. /* must hold lock */
  224. timeradd(timeval_raw, &timeofday_offset, out);
  225. if (PREDICT_UNLIKELY(timercmp(out, &last_timeofday, OP_LT))) {
  226. /* time ran backwards. Instead, declare that no time occurred. */
  227. timersub(&last_timeofday, timeval_raw, &timeofday_offset);
  228. memcpy(out, &last_timeofday, sizeof(struct timeval));
  229. } else {
  230. memcpy(&last_timeofday, out, sizeof(struct timeval));
  231. }
  232. }
  233. #endif /* defined(MONOTIME_USING_GETTIMEOFDAY) || defined(TOR_UNIT_TESTS) */
  234. #ifdef TOR_UNIT_TESTS
  235. /** For testing: reset all the ratchets */
  236. void
  237. monotime_reset_ratchets_for_testing(void)
  238. {
  239. last_pctr = pctr_offset = last_tick_count = 0;
  240. rollover_count = 0;
  241. memset(&last_timeofday, 0, sizeof(struct timeval));
  242. memset(&timeofday_offset, 0, sizeof(struct timeval));
  243. }
  244. #endif /* defined(TOR_UNIT_TESTS) */
  245. #ifdef __APPLE__
  246. /** Initialized on startup: tells is how to convert from ticks to
  247. * nanoseconds.
  248. */
  249. static struct mach_timebase_info mach_time_info;
  250. static int monotime_shift = 0;
  251. static void
  252. monotime_init_internal(void)
  253. {
  254. tor_assert(!monotime_initialized);
  255. int r = mach_timebase_info(&mach_time_info);
  256. tor_assert(r == 0);
  257. tor_assert(mach_time_info.denom != 0);
  258. {
  259. // approximate only.
  260. uint64_t ns_per_tick = mach_time_info.numer / mach_time_info.denom;
  261. uint64_t ms_per_tick = ns_per_tick * ONE_MILLION;
  262. // requires that tor_log2(0) == 0.
  263. monotime_shift = tor_log2(ms_per_tick);
  264. }
  265. }
  266. /**
  267. * Set "out" to the most recent monotonic time value
  268. */
  269. void
  270. monotime_get(monotime_t *out)
  271. {
  272. #ifdef TOR_UNIT_TESTS
  273. if (monotime_mocking_enabled) {
  274. out->abstime_ = (mock_time_nsec * mach_time_info.denom)
  275. / mach_time_info.numer;
  276. return;
  277. }
  278. #endif /* defined(TOR_UNIT_TESTS) */
  279. out->abstime_ = mach_absolute_time();
  280. }
  281. #if defined(HAVE_MACH_APPROXIMATE_TIME)
  282. void
  283. monotime_coarse_get(monotime_coarse_t *out)
  284. {
  285. #ifdef TOR_UNIT_TESTS
  286. if (monotime_mocking_enabled) {
  287. out->abstime_ = (mock_time_nsec_coarse * mach_time_info.denom)
  288. / mach_time_info.numer;
  289. return;
  290. }
  291. #endif /* defined(TOR_UNIT_TESTS) */
  292. out->abstime_ = mach_approximate_time();
  293. }
  294. #endif
  295. /**
  296. * Return the number of nanoseconds between <b>start</b> and <b>end</b>.
  297. */
  298. int64_t
  299. monotime_diff_nsec(const monotime_t *start,
  300. const monotime_t *end)
  301. {
  302. if (BUG(mach_time_info.denom == 0)) {
  303. monotime_init();
  304. }
  305. const int64_t diff_ticks = end->abstime_ - start->abstime_;
  306. const int64_t diff_nsec =
  307. (diff_ticks * mach_time_info.numer) / mach_time_info.denom;
  308. return diff_nsec;
  309. }
  310. uint32_t
  311. monotime_coarse_to_stamp(const monotime_coarse_t *t)
  312. {
  313. return (uint32_t)(t->abstime_ >> monotime_shift);
  314. }
  315. int
  316. monotime_is_zero(const monotime_t *val)
  317. {
  318. return val->abstime_ == 0;
  319. }
  320. /* end of "__APPLE__" */
  321. #elif defined(HAVE_CLOCK_GETTIME)
  322. #ifdef CLOCK_MONOTONIC_COARSE
  323. /**
  324. * Which clock should we use for coarse-grained monotonic time? By default
  325. * this is CLOCK_MONOTONIC_COARSE, but it might not work -- for example,
  326. * if we're compiled with newer Linux headers and then we try to run on
  327. * an old Linux kernel. In that case, we will fall back to CLOCK_MONOTONIC.
  328. */
  329. static int clock_monotonic_coarse = CLOCK_MONOTONIC_COARSE;
  330. #endif /* defined(CLOCK_MONOTONIC_COARSE) */
  331. static void
  332. monotime_init_internal(void)
  333. {
  334. #ifdef CLOCK_MONOTONIC_COARSE
  335. struct timespec ts;
  336. if (clock_gettime(CLOCK_MONOTONIC_COARSE, &ts) < 0) {
  337. log_info(LD_GENERAL, "CLOCK_MONOTONIC_COARSE isn't working (%s); "
  338. "falling back to CLOCK_MONOTONIC.", strerror(errno));
  339. clock_monotonic_coarse = CLOCK_MONOTONIC;
  340. }
  341. #endif /* defined(CLOCK_MONOTONIC_COARSE) */
  342. }
  343. void
  344. monotime_get(monotime_t *out)
  345. {
  346. #ifdef TOR_UNIT_TESTS
  347. if (monotime_mocking_enabled) {
  348. out->ts_.tv_sec = (time_t) (mock_time_nsec / ONE_BILLION);
  349. out->ts_.tv_nsec = (int) (mock_time_nsec % ONE_BILLION);
  350. return;
  351. }
  352. #endif /* defined(TOR_UNIT_TESTS) */
  353. int r = clock_gettime(CLOCK_MONOTONIC, &out->ts_);
  354. tor_assert(r == 0);
  355. }
  356. #ifdef CLOCK_MONOTONIC_COARSE
  357. void
  358. monotime_coarse_get(monotime_coarse_t *out)
  359. {
  360. #ifdef TOR_UNIT_TESTS
  361. if (monotime_mocking_enabled) {
  362. out->ts_.tv_sec = (time_t) (mock_time_nsec_coarse / ONE_BILLION);
  363. out->ts_.tv_nsec = (int) (mock_time_nsec_coarse % ONE_BILLION);
  364. return;
  365. }
  366. #endif /* defined(TOR_UNIT_TESTS) */
  367. int r = clock_gettime(clock_monotonic_coarse, &out->ts_);
  368. if (PREDICT_UNLIKELY(r < 0) &&
  369. errno == EINVAL &&
  370. clock_monotonic_coarse == CLOCK_MONOTONIC_COARSE) {
  371. /* We should have caught this at startup in monotime_init_internal!
  372. */
  373. log_warn(LD_BUG, "Falling back to non-coarse monotonic time %s initial "
  374. "system start?", monotime_initialized?"after":"without");
  375. clock_monotonic_coarse = CLOCK_MONOTONIC;
  376. r = clock_gettime(clock_monotonic_coarse, &out->ts_);
  377. }
  378. tor_assert(r == 0);
  379. }
  380. #endif /* defined(CLOCK_MONOTONIC_COARSE) */
  381. int64_t
  382. monotime_diff_nsec(const monotime_t *start,
  383. const monotime_t *end)
  384. {
  385. const int64_t diff_sec = end->ts_.tv_sec - start->ts_.tv_sec;
  386. const int64_t diff_nsec = diff_sec * ONE_BILLION +
  387. (end->ts_.tv_nsec - start->ts_.tv_nsec);
  388. return diff_nsec;
  389. }
  390. /* This value is ONE_BILLION >> 20. */
  391. static const uint32_t STAMP_TICKS_PER_SECOND = 953;
  392. uint32_t
  393. monotime_coarse_to_stamp(const monotime_coarse_t *t)
  394. {
  395. uint32_t nsec = (uint32_t)t->ts_.tv_nsec;
  396. uint32_t sec = (uint32_t)t->ts_.tv_sec;
  397. return (sec * STAMP_TICKS_PER_SECOND) + (nsec >> 20);
  398. }
  399. int
  400. monotime_is_zero(const monotime_t *val)
  401. {
  402. return val->ts_.tv_sec == 0 && val->ts_.tv_nsec == 0;
  403. }
  404. /* end of "HAVE_CLOCK_GETTIME" */
  405. #elif defined (_WIN32)
  406. /** Result of QueryPerformanceFrequency, in terms needed to
  407. * convert ticks to nanoseconds. */
  408. static int64_t nsec_per_tick_numer = 1;
  409. static int64_t nsec_per_tick_denom = 1;
  410. /** Lock to protect last_pctr and pctr_offset */
  411. static CRITICAL_SECTION monotime_lock;
  412. /** Lock to protect rollover_count and last_tick_count */
  413. static CRITICAL_SECTION monotime_coarse_lock;
  414. typedef ULONGLONG (WINAPI *GetTickCount64_fn_t)(void);
  415. static GetTickCount64_fn_t GetTickCount64_fn = NULL;
  416. static void
  417. monotime_init_internal(void)
  418. {
  419. tor_assert(!monotime_initialized);
  420. BOOL ok = InitializeCriticalSectionAndSpinCount(&monotime_lock, 200);
  421. tor_assert(ok);
  422. ok = InitializeCriticalSectionAndSpinCount(&monotime_coarse_lock, 200);
  423. tor_assert(ok);
  424. LARGE_INTEGER li;
  425. ok = QueryPerformanceFrequency(&li);
  426. tor_assert(ok);
  427. tor_assert(li.QuadPart);
  428. uint64_t n = ONE_BILLION;
  429. uint64_t d = li.QuadPart;
  430. /* We need to simplify this or we'll probably overflow the int64. */
  431. simplify_fraction64(&n, &d);
  432. tor_assert(n <= INT64_MAX);
  433. tor_assert(d <= INT64_MAX);
  434. nsec_per_tick_numer = (int64_t) n;
  435. nsec_per_tick_denom = (int64_t) d;
  436. last_pctr = 0;
  437. pctr_offset = 0;
  438. HANDLE h = load_windows_system_library(TEXT("kernel32.dll"));
  439. if (h) {
  440. GetTickCount64_fn = (GetTickCount64_fn_t)
  441. GetProcAddress(h, "GetTickCount64");
  442. }
  443. // FreeLibrary(h) ?
  444. }
  445. void
  446. monotime_get(monotime_t *out)
  447. {
  448. if (BUG(monotime_initialized == 0)) {
  449. monotime_init();
  450. }
  451. #ifdef TOR_UNIT_TESTS
  452. if (monotime_mocking_enabled) {
  453. out->pcount_ = (mock_time_nsec * nsec_per_tick_denom)
  454. / nsec_per_tick_numer;
  455. return;
  456. }
  457. #endif /* defined(TOR_UNIT_TESTS) */
  458. /* Alas, QueryPerformanceCounter is not always monotonic: see bug list at
  459. https://www.python.org/dev/peps/pep-0418/#windows-queryperformancecounter
  460. */
  461. EnterCriticalSection(&monotime_lock);
  462. LARGE_INTEGER res;
  463. BOOL ok = QueryPerformanceCounter(&res);
  464. tor_assert(ok);
  465. const int64_t count_raw = res.QuadPart;
  466. out->pcount_ = ratchet_performance_counter(count_raw);
  467. LeaveCriticalSection(&monotime_lock);
  468. }
  469. void
  470. monotime_coarse_get(monotime_coarse_t *out)
  471. {
  472. #ifdef TOR_UNIT_TESTS
  473. if (monotime_mocking_enabled) {
  474. out->tick_count_ = mock_time_nsec_coarse / ONE_MILLION;
  475. return;
  476. }
  477. #endif /* defined(TOR_UNIT_TESTS) */
  478. if (GetTickCount64_fn) {
  479. out->tick_count_ = (int64_t)GetTickCount64_fn();
  480. } else {
  481. EnterCriticalSection(&monotime_coarse_lock);
  482. DWORD tick = GetTickCount();
  483. out->tick_count_ = ratchet_coarse_performance_counter(tick);
  484. LeaveCriticalSection(&monotime_coarse_lock);
  485. }
  486. }
  487. int64_t
  488. monotime_diff_nsec(const monotime_t *start,
  489. const monotime_t *end)
  490. {
  491. if (BUG(monotime_initialized == 0)) {
  492. monotime_init();
  493. }
  494. const int64_t diff_ticks = end->pcount_ - start->pcount_;
  495. return (diff_ticks * nsec_per_tick_numer) / nsec_per_tick_denom;
  496. }
  497. int64_t
  498. monotime_coarse_diff_msec(const monotime_coarse_t *start,
  499. const monotime_coarse_t *end)
  500. {
  501. const int64_t diff_ticks = end->tick_count_ - start->tick_count_;
  502. return diff_ticks;
  503. }
  504. int64_t
  505. monotime_coarse_diff_usec(const monotime_coarse_t *start,
  506. const monotime_coarse_t *end)
  507. {
  508. return monotime_coarse_diff_msec(start, end) * 1000;
  509. }
  510. int64_t
  511. monotime_coarse_diff_nsec(const monotime_coarse_t *start,
  512. const monotime_coarse_t *end)
  513. {
  514. return monotime_coarse_diff_msec(start, end) * ONE_MILLION;
  515. }
  516. static const uint32_t STAMP_TICKS_PER_SECOND = 1000;
  517. uint32_t
  518. monotime_coarse_to_stamp(const monotime_coarse_t *t)
  519. {
  520. return (uint32_t) t->tick_count_;
  521. }
  522. int
  523. monotime_is_zero(const monotime_t *val)
  524. {
  525. return val->pcount_ == 0;
  526. }
  527. int
  528. monotime_coarse_is_zero(const monotime_coarse_t *val)
  529. {
  530. return val->tick_count_ == 0;
  531. }
  532. /* end of "_WIN32" */
  533. #elif defined(MONOTIME_USING_GETTIMEOFDAY)
  534. static tor_mutex_t monotime_lock;
  535. /** Initialize the monotonic timer subsystem. */
  536. static void
  537. monotime_init_internal(void)
  538. {
  539. tor_assert(!monotime_initialized);
  540. tor_mutex_init(&monotime_lock);
  541. }
  542. void
  543. monotime_get(monotime_t *out)
  544. {
  545. if (BUG(monotime_initialized == 0)) {
  546. monotime_init();
  547. }
  548. tor_mutex_acquire(&monotime_lock);
  549. struct timeval timeval_raw;
  550. tor_gettimeofday(&timeval_raw);
  551. ratchet_timeval(&timeval_raw, &out->tv_);
  552. tor_mutex_release(&monotime_lock);
  553. }
  554. int64_t
  555. monotime_diff_nsec(const monotime_t *start,
  556. const monotime_t *end)
  557. {
  558. struct timeval diff;
  559. timersub(&end->tv_, &start->tv_, &diff);
  560. return (diff.tv_sec * ONE_BILLION + diff.tv_usec * 1000);
  561. }
  562. /* This value is ONE_MILLION >> 10. */
  563. static const uint32_t STAMP_TICKS_PER_SECOND = 976;
  564. uint32_t
  565. monotime_coarse_to_stamp(const monotime_coarse_t *t)
  566. {
  567. const uint32_t usec = (uint32_t)t->tv_.tv_usec;
  568. const uint32_t sec = (uint32_t)t->tv_.tv_sec;
  569. return (sec * STAMP_TICKS_PER_SECOND) | (nsec >> 10);
  570. }
  571. int
  572. monotime_is_zero(const monotime_t *val)
  573. {
  574. return val->tv_.tv_sec == 0 && val->tv_.tv_usec == 0;
  575. }
  576. /* end of "MONOTIME_USING_GETTIMEOFDAY" */
  577. #else
  578. #error "No way to implement monotonic timers."
  579. #endif /* defined(__APPLE__) || ... */
  580. /**
  581. * Initialize the monotonic timer subsystem. Must be called before any
  582. * monotonic timer functions. This function is idempotent.
  583. */
  584. void
  585. monotime_init(void)
  586. {
  587. if (!monotime_initialized) {
  588. monotime_init_internal();
  589. monotime_initialized = 1;
  590. monotime_get(&initialized_at);
  591. #ifdef MONOTIME_COARSE_FN_IS_DIFFERENT
  592. monotime_coarse_get(&initialized_at_coarse);
  593. #endif
  594. }
  595. }
  596. void
  597. monotime_zero(monotime_t *out)
  598. {
  599. memset(out, 0, sizeof(*out));
  600. }
  601. #ifdef MONOTIME_COARSE_TYPE_IS_DIFFERENT
  602. void
  603. monotime_coarse_zero(monotime_coarse_t *out)
  604. {
  605. memset(out, 0, sizeof(*out));
  606. }
  607. #endif
  608. int64_t
  609. monotime_diff_usec(const monotime_t *start,
  610. const monotime_t *end)
  611. {
  612. const int64_t nsec = monotime_diff_nsec(start, end);
  613. return CEIL_DIV(nsec, 1000);
  614. }
  615. int64_t
  616. monotime_diff_msec(const monotime_t *start,
  617. const monotime_t *end)
  618. {
  619. const int64_t nsec = monotime_diff_nsec(start, end);
  620. return CEIL_DIV(nsec, ONE_MILLION);
  621. }
  622. uint64_t
  623. monotime_absolute_nsec(void)
  624. {
  625. monotime_t now;
  626. if (BUG(monotime_initialized == 0)) {
  627. monotime_init();
  628. }
  629. monotime_get(&now);
  630. return monotime_diff_nsec(&initialized_at, &now);
  631. }
  632. uint64_t
  633. monotime_absolute_usec(void)
  634. {
  635. return monotime_absolute_nsec() / 1000;
  636. }
  637. uint64_t
  638. monotime_absolute_msec(void)
  639. {
  640. return monotime_absolute_nsec() / ONE_MILLION;
  641. }
  642. #ifdef MONOTIME_COARSE_FN_IS_DIFFERENT
  643. uint64_t
  644. monotime_coarse_absolute_nsec(void)
  645. {
  646. if (BUG(monotime_initialized == 0)) {
  647. monotime_init();
  648. }
  649. monotime_coarse_t now;
  650. monotime_coarse_get(&now);
  651. return monotime_coarse_diff_nsec(&initialized_at_coarse, &now);
  652. }
  653. uint64_t
  654. monotime_coarse_absolute_usec(void)
  655. {
  656. return monotime_coarse_absolute_nsec() / 1000;
  657. }
  658. uint64_t
  659. monotime_coarse_absolute_msec(void)
  660. {
  661. return monotime_coarse_absolute_nsec() / ONE_MILLION;
  662. }
  663. #else
  664. #define initalized_at_coarse initialized_at
  665. #endif /* defined(MONOTIME_COARSE_FN_IS_DIFFERENT) */
  666. /**
  667. * Return the current time "stamp" as described by monotime_coarse_to_stamp.
  668. */
  669. uint32_t
  670. monotime_coarse_get_stamp(void)
  671. {
  672. monotime_coarse_t now;
  673. monotime_coarse_get(&now);
  674. return monotime_coarse_to_stamp(&now);
  675. }
  676. #ifdef __APPLE__
  677. uint64_t
  678. monotime_coarse_stamp_units_to_approx_msec(uint64_t units)
  679. {
  680. /* Recover as much precision as we can. */
  681. uint64_t abstime_diff = (units << monotime_shift);
  682. return (abstime_diff * mach_time_info.numer) /
  683. (mach_time_info.denom * ONE_MILLION);
  684. }
  685. #else
  686. uint64_t
  687. monotime_coarse_stamp_units_to_approx_msec(uint64_t units)
  688. {
  689. return (units * 1000) / STAMP_TICKS_PER_SECOND;
  690. }
  691. #endif