Squashed 'third_party/rawrtc/re/' content from commit f3163ce8b
Change-Id: I6a235e6ac0f03269d951026f9d195da05c40fdab
git-subtree-dir: third_party/rawrtc/re
git-subtree-split: f3163ce8b526a13b35ef71ce4dd6f43585064d8a
diff --git a/src/tmr/tmr.c b/src/tmr/tmr.c
new file mode 100644
index 0000000..73083f1
--- /dev/null
+++ b/src/tmr/tmr.c
@@ -0,0 +1,305 @@
+/**
+ * @file tmr.c Timer implementation
+ *
+ * Copyright (C) 2010 Creytiv.com
+ */
+#include <string.h>
+#ifdef HAVE_SYS_TIME_H
+#include <sys/time.h>
+#endif
+#ifdef WIN32
+#include <windows.h>
+#else
+#include <time.h>
+#endif
+#ifdef HAVE_PTHREAD
+#include <stdlib.h>
+#include <pthread.h>
+#endif
+#include <re_types.h>
+#include <re_list.h>
+#include <re_fmt.h>
+#include <re_mem.h>
+#include <re_tmr.h>
+
+
+#define DEBUG_MODULE "tmr"
+#define DEBUG_LEVEL 5
+#include <re_dbg.h>
+
+
+#if !defined (RELEASE) && !defined (TMR_DEBUG)
+#define TMR_DEBUG 1 /**< Timer debugging (0 or 1) */
+#endif
+
+/** Timer values */
+enum {
+ MAX_BLOCKING = 100 /**< Maximum time spent in handler [ms] */
+};
+
+extern struct list *tmrl_get(void);
+
+
+static bool inspos_handler(struct le *le, void *arg)
+{
+ struct tmr *tmr = le->data;
+ const uint64_t now = *(uint64_t *)arg;
+
+ return tmr->jfs <= now;
+}
+
+
+static bool inspos_handler_0(struct le *le, void *arg)
+{
+ struct tmr *tmr = le->data;
+ const uint64_t now = *(uint64_t *)arg;
+
+ return tmr->jfs > now;
+}
+
+
+#if TMR_DEBUG
+static void call_handler(tmr_h *th, void *arg)
+{
+ const uint64_t tick = tmr_jiffies();
+ uint32_t diff;
+
+ /* Call handler */
+ th(arg);
+
+ diff = (uint32_t)(tmr_jiffies() - tick);
+
+ if (diff > MAX_BLOCKING) {
+ DEBUG_WARNING("long async blocking: %u>%u ms (h=%p arg=%p)\n",
+ diff, MAX_BLOCKING, th, arg);
+ }
+}
+#endif
+
+
+/**
+ * Poll all timers in the current thread
+ *
+ * @param tmrl Timer list
+ */
+void tmr_poll(struct list *tmrl)
+{
+ const uint64_t jfs = tmr_jiffies();
+
+ for (;;) {
+ struct tmr *tmr;
+ tmr_h *th;
+ void *th_arg;
+
+ tmr = list_ledata(tmrl->head);
+
+ if (!tmr || (tmr->jfs > jfs)) {
+ break;
+ }
+
+ th = tmr->th;
+ th_arg = tmr->arg;
+
+ tmr->th = NULL;
+
+ list_unlink(&tmr->le);
+
+ if (!th)
+ continue;
+
+#if TMR_DEBUG
+ call_handler(th, th_arg);
+#else
+ th(th_arg);
+#endif
+ }
+}
+
+
+/**
+ * Get the timer jiffies in milliseconds
+ *
+ * @return Jiffies in [ms]
+ */
+uint64_t tmr_jiffies(void)
+{
+ uint64_t jfs;
+
+#if defined(WIN32)
+ FILETIME ft;
+ ULARGE_INTEGER li;
+ GetSystemTimeAsFileTime(&ft);
+ li.LowPart = ft.dwLowDateTime;
+ li.HighPart = ft.dwHighDateTime;
+ jfs = li.QuadPart/10/1000;
+#else
+ struct timeval now;
+
+ if (0 != gettimeofday(&now, NULL)) {
+ DEBUG_WARNING("jiffies: gettimeofday() failed (%m)\n", errno);
+ return 0;
+ }
+
+ jfs = (long)now.tv_sec * (uint64_t)1000;
+ jfs += now.tv_usec / 1000;
+#endif
+
+ return jfs;
+}
+
+
+/**
+ * Get number of milliseconds until the next timer expires
+ *
+ * @param tmrl Timer-list
+ *
+ * @return Number of [ms], or 0 if no active timers
+ */
+uint64_t tmr_next_timeout(struct list *tmrl)
+{
+ const uint64_t jif = tmr_jiffies();
+ const struct tmr *tmr;
+
+ tmr = list_ledata(tmrl->head);
+ if (!tmr)
+ return 0;
+
+ if (tmr->jfs <= jif)
+ return 1;
+ else
+ return tmr->jfs - jif;
+}
+
+
+int tmr_status(struct re_printf *pf, void *unused)
+{
+ struct list *tmrl = tmrl_get();
+ struct le *le;
+ uint32_t n;
+ int err;
+
+ (void)unused;
+
+ n = list_count(tmrl);
+ if (!n)
+ return 0;
+
+ err = re_hprintf(pf, "Timers (%u):\n", n);
+
+ for (le = tmrl->head; le; le = le->next) {
+ const struct tmr *tmr = le->data;
+
+ err |= re_hprintf(pf, " %p: th=%p expire=%llums\n",
+ tmr, tmr->th,
+ (unsigned long long)tmr_get_expire(tmr));
+ }
+
+ if (n > 100)
+ err |= re_hprintf(pf, " (Dumped Timers: %u)\n", n);
+
+ return err;
+}
+
+
+/**
+ * Print timer debug info to stderr
+ */
+void tmr_debug(void)
+{
+ if (!list_isempty(tmrl_get()))
+ (void)re_fprintf(stderr, "%H", tmr_status, NULL);
+}
+
+
+/**
+ * Initialise a timer object
+ *
+ * @param tmr Timer to initialise
+ */
+void tmr_init(struct tmr *tmr)
+{
+ if (!tmr)
+ return;
+
+ memset(tmr, 0, sizeof(*tmr));
+}
+
+
+/**
+ * Start a timer
+ *
+ * @param tmr Timer to start
+ * @param delay Timer delay in [ms]
+ * @param th Timeout handler
+ * @param arg Handler argument
+ */
+void tmr_start(struct tmr *tmr, uint64_t delay, tmr_h *th, void *arg)
+{
+ struct list *tmrl = tmrl_get();
+ struct le *le;
+
+ if (!tmr)
+ return;
+
+ if (tmr->th) {
+ list_unlink(&tmr->le);
+ }
+
+ tmr->th = th;
+ tmr->arg = arg;
+
+ if (!th)
+ return;
+
+ tmr->jfs = delay + tmr_jiffies();
+
+ if (delay == 0) {
+ le = list_apply(tmrl, true, inspos_handler_0, &tmr->jfs);
+ if (le) {
+ list_insert_before(tmrl, le, &tmr->le, tmr);
+ }
+ else {
+ list_append(tmrl, &tmr->le, tmr);
+ }
+ }
+ else {
+ le = list_apply(tmrl, false, inspos_handler, &tmr->jfs);
+ if (le) {
+ list_insert_after(tmrl, le, &tmr->le, tmr);
+ }
+ else {
+ list_prepend(tmrl, &tmr->le, tmr);
+ }
+ }
+}
+
+
+/**
+ * Cancel an active timer
+ *
+ * @param tmr Timer to cancel
+ */
+void tmr_cancel(struct tmr *tmr)
+{
+ tmr_start(tmr, 0, NULL, NULL);
+}
+
+
+/**
+ * Get the time left until timer expires
+ *
+ * @param tmr Timer object
+ *
+ * @return Time in [ms] until expiration
+ */
+uint64_t tmr_get_expire(const struct tmr *tmr)
+{
+ uint64_t jfs;
+
+ if (!tmr || !tmr->th)
+ return 0;
+
+ jfs = tmr_jiffies();
+
+ return (tmr->jfs > jfs) ? (tmr->jfs - jfs) : 0;
+}