mytime.c

Go to the documentation of this file.

//
//
//  Author:     Lasse Collin
//
//  This file has been put into the public domain.
//  You can do whatever you want with this file.
//
 
#include "private.h"
 
#if !(defined(HAVE_CLOCK_GETTIME) && HAVE_DECL_CLOCK_MONOTONIC)
#   include <sys/time.h>
#endif
 
uint64_t opt_flush_timeout = 0;
 
static uint64_t start_time;
static uint64_t next_flush;
 
 
static uint64_t
mytime_now(void)
{
    // NOTE: HAVE_DECL_CLOCK_MONOTONIC is always defined to 0 or 1.
#if defined(HAVE_CLOCK_GETTIME) && HAVE_DECL_CLOCK_MONOTONIC
    // If CLOCK_MONOTONIC was available at compile time but for some
    // reason isn't at runtime, fallback to CLOCK_REALTIME which
    // according to POSIX is mandatory for all implementations.
    static clockid_t clk_id = CLOCK_MONOTONIC;
    struct timespec tv;
    while (clock_gettime(clk_id, &tv))
        clk_id = CLOCK_REALTIME;
 
    return (uint64_t)tv.tv_sec * 1000 + (uint64_t)(tv.tv_nsec / 1000000);
#else
    struct timeval tv;
    gettimeofday(&tv, NULL);
    return (uint64_t)tv.tv_sec * 1000 + (uint64_t)(tv.tv_usec / 1000);
#endif
}
 
 
extern void
mytime_set_start_time(void)
{
    start_time = mytime_now();
    return;
}
 
 
extern uint64_t
mytime_get_elapsed(void)
{
    return mytime_now() - start_time;
}
 
 
extern void
mytime_set_flush_time(void)
{
    next_flush = mytime_now() + opt_flush_timeout;
    return;
}
 
 
extern int
mytime_get_flush_timeout(void)
{
    if (opt_flush_timeout == 0 || opt_mode != MODE_COMPRESS)
        return -1;
 
    const uint64_t now = mytime_now();
    if (now >= next_flush)
        return 0;
 
    const uint64_t remaining = next_flush - now;
    return remaining > INT_MAX ? INT_MAX : (int)remaining;
}