[qemu.git] / qemu-timer.c

/*
 * QEMU System Emulator
 *
 * Copyright (c) 2003-2008 Fabrice Bellard
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

#include "sysemu.h"
#include "net.h"
#include "monitor.h"
#include "console.h"

#include "hw/hw.h"

#include "qemu-timer.h"
#ifdef CONFIG_POSIX
#include <pthread.h>
#endif

#ifdef _WIN32
#include <mmsystem.h>
#endif

/***********************************************************/
/* timers */

#define QEMU_CLOCK_REALTIME 0
#define QEMU_CLOCK_VIRTUAL  1
#define QEMU_CLOCK_HOST     2

struct QEMUClock {
    QEMUTimer *active_timers;

    NotifierList reset_notifiers;
    int64_t last;

    int type;
    bool enabled;
};

struct QEMUTimer {
    int64_t expire_time;	/* in nanoseconds */
    QEMUClock *clock;
    QEMUTimerCB *cb;
    void *opaque;
    QEMUTimer *next;
    int scale;
};

struct qemu_alarm_timer {
    char const *name;
    int (*start)(struct qemu_alarm_timer *t);
    void (*stop)(struct qemu_alarm_timer *t);
    void (*rearm)(struct qemu_alarm_timer *t, int64_t nearest_delta_ns);
#if defined(__linux__)
    timer_t timer;
    int fd;
#elif defined(_WIN32)
    HANDLE timer;
#endif
    bool expired;
    bool pending;
};

static struct qemu_alarm_timer *alarm_timer;

static bool qemu_timer_expired_ns(QEMUTimer *timer_head, int64_t current_time)
{
    return timer_head && (timer_head->expire_time <= current_time);
}

static int64_t qemu_next_alarm_deadline(void)
{
    int64_t delta = INT64_MAX;
    int64_t rtdelta;

    if (!use_icount && vm_clock->enabled && vm_clock->active_timers) {
        delta = vm_clock->active_timers->expire_time -
                     qemu_get_clock_ns(vm_clock);
    }
    if (host_clock->enabled && host_clock->active_timers) {
        int64_t hdelta = host_clock->active_timers->expire_time -
                 qemu_get_clock_ns(host_clock);
        if (hdelta < delta) {
            delta = hdelta;
        }
    }
    if (rt_clock->enabled && rt_clock->active_timers) {
        rtdelta = (rt_clock->active_timers->expire_time -
                 qemu_get_clock_ns(rt_clock));
        if (rtdelta < delta) {
            delta = rtdelta;
        }
    }

    return delta;
}

static void qemu_rearm_alarm_timer(struct qemu_alarm_timer *t)
{
    int64_t nearest_delta_ns = qemu_next_alarm_deadline();
    if (nearest_delta_ns < INT64_MAX) {
        t->rearm(t, nearest_delta_ns);
    }
}

/* TODO: MIN_TIMER_REARM_NS should be optimized */
#define MIN_TIMER_REARM_NS 250000

#ifdef _WIN32

static int mm_start_timer(struct qemu_alarm_timer *t);
static void mm_stop_timer(struct qemu_alarm_timer *t);
static void mm_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);

static int win32_start_timer(struct qemu_alarm_timer *t);
static void win32_stop_timer(struct qemu_alarm_timer *t);
static void win32_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);

#else

static int unix_start_timer(struct qemu_alarm_timer *t);
static void unix_stop_timer(struct qemu_alarm_timer *t);
static void unix_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);

#ifdef __linux__

static int dynticks_start_timer(struct qemu_alarm_timer *t);
static void dynticks_stop_timer(struct qemu_alarm_timer *t);
static void dynticks_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);

#endif /* __linux__ */

#endif /* _WIN32 */

static struct qemu_alarm_timer alarm_timers[] = {
#ifndef _WIN32
#ifdef __linux__
    {"dynticks", dynticks_start_timer,
     dynticks_stop_timer, dynticks_rearm_timer},
#endif
    {"unix", unix_start_timer, unix_stop_timer, unix_rearm_timer},
#else
    {"mmtimer", mm_start_timer, mm_stop_timer, mm_rearm_timer},
    {"dynticks", win32_start_timer, win32_stop_timer, win32_rearm_timer},
#endif
    {NULL, }
};

static void show_available_alarms(void)
{
    int i;

    printf("Available alarm timers, in order of precedence:\n");
    for (i = 0; alarm_timers[i].name; i++)
        printf("%s\n", alarm_timers[i].name);
}

void configure_alarms(char const *opt)
{
    int i;
    int cur = 0;
    int count = ARRAY_SIZE(alarm_timers) - 1;
    char *arg;
    char *name;
    struct qemu_alarm_timer tmp;

    if (is_help_option(opt)) {
        show_available_alarms();
        exit(0);
    }

    arg = g_strdup(opt);

    /* Reorder the array */
    name = strtok(arg, ",");
    while (name) {
        for (i = 0; i < count && alarm_timers[i].name; i++) {
            if (!strcmp(alarm_timers[i].name, name))
                break;
        }

        if (i == count) {
            fprintf(stderr, "Unknown clock %s\n", name);
            goto next;
        }

        if (i < cur)
            /* Ignore */
            goto next;

	/* Swap */
        tmp = alarm_timers[i];
        alarm_timers[i] = alarm_timers[cur];
        alarm_timers[cur] = tmp;

        cur++;
next:
        name = strtok(NULL, ",");
    }

    g_free(arg);

    if (cur) {
        /* Disable remaining timers */
        for (i = cur; i < count; i++)
            alarm_timers[i].name = NULL;
    } else {
        show_available_alarms();
        exit(1);
    }
}

QEMUClock *rt_clock;
QEMUClock *vm_clock;
QEMUClock *host_clock;

static QEMUClock *qemu_new_clock(int type)
{
    QEMUClock *clock;

    clock = g_malloc0(sizeof(QEMUClock));
    clock->type = type;
    clock->enabled = true;
    clock->last = INT64_MIN;
    notifier_list_init(&clock->reset_notifiers);
    return clock;
}

void qemu_clock_enable(QEMUClock *clock, bool enabled)
{
    bool old = clock->enabled;
    clock->enabled = enabled;
    if (enabled && !old) {
        qemu_rearm_alarm_timer(alarm_timer);
    }
}

int64_t qemu_clock_has_timers(QEMUClock *clock)
{
    return !!clock->active_timers;
}

int64_t qemu_clock_expired(QEMUClock *clock)
{
    return (clock->active_timers &&
            clock->active_timers->expire_time < qemu_get_clock_ns(clock));
}

int64_t qemu_clock_deadline(QEMUClock *clock)
{
    /* To avoid problems with overflow limit this to 2^32.  */
    int64_t delta = INT32_MAX;

    if (clock->active_timers) {
        delta = clock->active_timers->expire_time - qemu_get_clock_ns(clock);
    }
    if (delta < 0) {
        delta = 0;
    }
    return delta;
}

QEMUTimer *qemu_new_timer(QEMUClock *clock, int scale,
                          QEMUTimerCB *cb, void *opaque)
{
    QEMUTimer *ts;

    ts = g_malloc0(sizeof(QEMUTimer));
    ts->clock = clock;
    ts->cb = cb;
    ts->opaque = opaque;
    ts->scale = scale;
    return ts;
}

void qemu_free_timer(QEMUTimer *ts)
{
    g_free(ts);
}

/* stop a timer, but do not dealloc it */
void qemu_del_timer(QEMUTimer *ts)
{
    QEMUTimer **pt, *t;

    /* NOTE: this code must be signal safe because
       qemu_timer_expired() can be called from a signal. */
    pt = &ts->clock->active_timers;
    for(;;) {
        t = *pt;
        if (!t)
            break;
        if (t == ts) {
            *pt = t->next;
            break;
        }
        pt = &t->next;
    }
}

/* modify the current timer so that it will be fired when current_time
   >= expire_time. The corresponding callback will be called. */
void qemu_mod_timer_ns(QEMUTimer *ts, int64_t expire_time)
{
    QEMUTimer **pt, *t;

    qemu_del_timer(ts);

    /* add the timer in the sorted list */
    /* NOTE: this code must be signal safe because
       qemu_timer_expired() can be called from a signal. */
    pt = &ts->clock->active_timers;
    for(;;) {
        t = *pt;
        if (!qemu_timer_expired_ns(t, expire_time)) {
            break;
        }
        pt = &t->next;
    }
    ts->expire_time = expire_time;
    ts->next = *pt;
    *pt = ts;

    /* Rearm if necessary  */
    if (pt == &ts->clock->active_timers) {
        if (!alarm_timer->pending) {
            qemu_rearm_alarm_timer(alarm_timer);
        }
        /* Interrupt execution to force deadline recalculation.  */
        qemu_clock_warp(ts->clock);
        if (use_icount) {
            qemu_notify_event();
        }
    }
}

void qemu_mod_timer(QEMUTimer *ts, int64_t expire_time)
{
    qemu_mod_timer_ns(ts, expire_time * ts->scale);
}

bool qemu_timer_pending(QEMUTimer *ts)
{
    QEMUTimer *t;
    for (t = ts->clock->active_timers; t != NULL; t = t->next) {
        if (t == ts) {
            return true;
        }
    }
    return false;
}

bool qemu_timer_expired(QEMUTimer *timer_head, int64_t current_time)
{
    return qemu_timer_expired_ns(timer_head, current_time * timer_head->scale);
}

void qemu_run_timers(QEMUClock *clock)
{
    QEMUTimer *ts;
    int64_t current_time;
   
    if (!clock->enabled)
        return;

    current_time = qemu_get_clock_ns(clock);
    for(;;) {
        ts = clock->active_timers;
        if (!qemu_timer_expired_ns(ts, current_time)) {
            break;
        }
        /* remove timer from the list before calling the callback */
        clock->active_timers = ts->next;
        ts->next = NULL;

        /* run the callback (the timer list can be modified) */
        ts->cb(ts->opaque);
    }
}

int64_t qemu_get_clock_ns(QEMUClock *clock)
{
    int64_t now, last;

    switch(clock->type) {
    case QEMU_CLOCK_REALTIME:
        return get_clock();
    default:
    case QEMU_CLOCK_VIRTUAL:
        if (use_icount) {
            return cpu_get_icount();
        } else {
            return cpu_get_clock();
        }
    case QEMU_CLOCK_HOST:
        now = get_clock_realtime();
        last = clock->last;
        clock->last = now;
        if (now < last) {
            notifier_list_notify(&clock->reset_notifiers, &now);
        }
        return now;
    }
}

void qemu_register_clock_reset_notifier(QEMUClock *clock, Notifier *notifier)
{
    notifier_list_add(&clock->reset_notifiers, notifier);
}

void qemu_unregister_clock_reset_notifier(QEMUClock *clock, Notifier *notifier)
{
    notifier_remove(notifier);
}

void init_clocks(void)
{
    if (!rt_clock) {
        rt_clock = qemu_new_clock(QEMU_CLOCK_REALTIME);
        vm_clock = qemu_new_clock(QEMU_CLOCK_VIRTUAL);
        host_clock = qemu_new_clock(QEMU_CLOCK_HOST);
    }
}

uint64_t qemu_timer_expire_time_ns(QEMUTimer *ts)
{
    return qemu_timer_pending(ts) ? ts->expire_time : -1;
}

void qemu_run_all_timers(void)
{
    alarm_timer->pending = false;

    /* vm time timers */
    qemu_run_timers(vm_clock);
    qemu_run_timers(rt_clock);
    qemu_run_timers(host_clock);

    /* rearm timer, if not periodic */
    if (alarm_timer->expired) {
        alarm_timer->expired = false;
        qemu_rearm_alarm_timer(alarm_timer);
    }
}

#ifdef _WIN32
static void CALLBACK host_alarm_handler(PVOID lpParam, BOOLEAN unused)
#else
static void host_alarm_handler(int host_signum)
#endif
{
    struct qemu_alarm_timer *t = alarm_timer;
    if (!t)
	return;

    t->expired = true;
    t->pending = true;
    qemu_notify_event();
}

#if defined(__linux__)

#include "compatfd.h"

static int dynticks_start_timer(struct qemu_alarm_timer *t)
{
    struct sigevent ev;
    timer_t host_timer;
    struct sigaction act;

    sigfillset(&act.sa_mask);
    act.sa_flags = 0;
    act.sa_handler = host_alarm_handler;

    sigaction(SIGALRM, &act, NULL);

    /* 
     * Initialize ev struct to 0 to avoid valgrind complaining
     * about uninitialized data in timer_create call
     */
    memset(&ev, 0, sizeof(ev));
    ev.sigev_value.sival_int = 0;
    ev.sigev_notify = SIGEV_SIGNAL;
#ifdef CONFIG_SIGEV_THREAD_ID
    if (qemu_signalfd_available()) {
        ev.sigev_notify = SIGEV_THREAD_ID;
        ev._sigev_un._tid = qemu_get_thread_id();
    }
#endif /* CONFIG_SIGEV_THREAD_ID */
    ev.sigev_signo = SIGALRM;

    if (timer_create(CLOCK_REALTIME, &ev, &host_timer)) {
        perror("timer_create");
        return -1;
    }

    t->timer = host_timer;

    return 0;
}

static void dynticks_stop_timer(struct qemu_alarm_timer *t)
{
    timer_t host_timer = t->timer;

    timer_delete(host_timer);
}

static void dynticks_rearm_timer(struct qemu_alarm_timer *t,
                                 int64_t nearest_delta_ns)
{
    timer_t host_timer = t->timer;
    struct itimerspec timeout;
    int64_t current_ns;

    if (nearest_delta_ns < MIN_TIMER_REARM_NS)
        nearest_delta_ns = MIN_TIMER_REARM_NS;

    /* check whether a timer is already running */
    if (timer_gettime(host_timer, &timeout)) {
        perror("gettime");
        fprintf(stderr, "Internal timer error: aborting\n");
        exit(1);
    }
    current_ns = timeout.it_value.tv_sec * 1000000000LL + timeout.it_value.tv_nsec;
    if (current_ns && current_ns <= nearest_delta_ns)
        return;

    timeout.it_interval.tv_sec = 0;
    timeout.it_interval.tv_nsec = 0; /* 0 for one-shot timer */
    timeout.it_value.tv_sec =  nearest_delta_ns / 1000000000;
    timeout.it_value.tv_nsec = nearest_delta_ns % 1000000000;
    if (timer_settime(host_timer, 0 /* RELATIVE */, &timeout, NULL)) {
        perror("settime");
        fprintf(stderr, "Internal timer error: aborting\n");
        exit(1);
    }
}

#endif /* defined(__linux__) */

#if !defined(_WIN32)

static int unix_start_timer(struct qemu_alarm_timer *t)
{
    struct sigaction act;

    /* timer signal */
    sigfillset(&act.sa_mask);
    act.sa_flags = 0;
    act.sa_handler = host_alarm_handler;

    sigaction(SIGALRM, &act, NULL);
    return 0;
}

static void unix_rearm_timer(struct qemu_alarm_timer *t,
                             int64_t nearest_delta_ns)
{
    struct itimerval itv;
    int err;

    if (nearest_delta_ns < MIN_TIMER_REARM_NS)
        nearest_delta_ns = MIN_TIMER_REARM_NS;

    itv.it_interval.tv_sec = 0;
    itv.it_interval.tv_usec = 0; /* 0 for one-shot timer */
    itv.it_value.tv_sec =  nearest_delta_ns / 1000000000;
    itv.it_value.tv_usec = (nearest_delta_ns % 1000000000) / 1000;
    err = setitimer(ITIMER_REAL, &itv, NULL);
    if (err) {
        perror("setitimer");
        fprintf(stderr, "Internal timer error: aborting\n");
        exit(1);
    }
}

static void unix_stop_timer(struct qemu_alarm_timer *t)
{
    struct itimerval itv;

    memset(&itv, 0, sizeof(itv));
    setitimer(ITIMER_REAL, &itv, NULL);
}

#endif /* !defined(_WIN32) */


#ifdef _WIN32

static MMRESULT mm_timer;
static TIMECAPS mm_tc;

static void CALLBACK mm_alarm_handler(UINT uTimerID, UINT uMsg,
                                      DWORD_PTR dwUser, DWORD_PTR dw1,
                                      DWORD_PTR dw2)
{
    struct qemu_alarm_timer *t = alarm_timer;
    if (!t) {
        return;
    }
    t->expired = true;
    t->pending = true;
    qemu_notify_event();
}

static int mm_start_timer(struct qemu_alarm_timer *t)
{
    timeGetDevCaps(&mm_tc, sizeof(mm_tc));

    timeBeginPeriod(mm_tc.wPeriodMin);

    mm_timer = timeSetEvent(mm_tc.wPeriodMin,   /* interval (ms) */
                            mm_tc.wPeriodMin,   /* resolution */
                            mm_alarm_handler,   /* function */
                            (DWORD_PTR)t,       /* parameter */
                            TIME_ONESHOT | TIME_CALLBACK_FUNCTION);

    if (!mm_timer) {
        fprintf(stderr, "Failed to initialize win32 alarm timer\n");
        timeEndPeriod(mm_tc.wPeriodMin);
        return -1;
    }

    return 0;
}

static void mm_stop_timer(struct qemu_alarm_timer *t)
{
    timeKillEvent(mm_timer);
    timeEndPeriod(mm_tc.wPeriodMin);
}

static void mm_rearm_timer(struct qemu_alarm_timer *t, int64_t delta)
{
    int64_t nearest_delta_ms = delta / 1000000;
    if (nearest_delta_ms < mm_tc.wPeriodMin) {
        nearest_delta_ms = mm_tc.wPeriodMin;
    } else if (nearest_delta_ms > mm_tc.wPeriodMax) {
        nearest_delta_ms = mm_tc.wPeriodMax;
    }

    timeKillEvent(mm_timer);
    mm_timer = timeSetEvent((UINT)nearest_delta_ms,
                            mm_tc.wPeriodMin,
                            mm_alarm_handler,
                            (DWORD_PTR)t,
                            TIME_ONESHOT | TIME_CALLBACK_FUNCTION);

    if (!mm_timer) {
        fprintf(stderr, "Failed to re-arm win32 alarm timer\n");
        timeEndPeriod(mm_tc.wPeriodMin);
        exit(1);
    }
}

static int win32_start_timer(struct qemu_alarm_timer *t)
{
    HANDLE hTimer;
    BOOLEAN success;

    /* If you call ChangeTimerQueueTimer on a one-shot timer (its period
       is zero) that has already expired, the timer is not updated.  Since
       creating a new timer is relatively expensive, set a bogus one-hour
       interval in the dynticks case.  */
    success = CreateTimerQueueTimer(&hTimer,
                          NULL,
                          host_alarm_handler,
                          t,
                          1,
                          3600000,
                          WT_EXECUTEINTIMERTHREAD);

    if (!success) {
        fprintf(stderr, "Failed to initialize win32 alarm timer: %ld\n",
                GetLastError());
        return -1;
    }

    t->timer = hTimer;
    return 0;
}

static void win32_stop_timer(struct qemu_alarm_timer *t)
{
    HANDLE hTimer = t->timer;

    if (hTimer) {
        DeleteTimerQueueTimer(NULL, hTimer, NULL);
    }
}

static void win32_rearm_timer(struct qemu_alarm_timer *t,
                              int64_t nearest_delta_ns)
{
    HANDLE hTimer = t->timer;
    int64_t nearest_delta_ms;
    BOOLEAN success;

    nearest_delta_ms = nearest_delta_ns / 1000000;
    if (nearest_delta_ms < 1) {
        nearest_delta_ms = 1;
    }
    /* ULONG_MAX can be 32 bit */
    if (nearest_delta_ms > ULONG_MAX) {
        nearest_delta_ms = ULONG_MAX;
    }
    success = ChangeTimerQueueTimer(NULL,
                                    hTimer,
                                    (unsigned long) nearest_delta_ms,
                                    3600000);

    if (!success) {
        fprintf(stderr, "Failed to rearm win32 alarm timer: %ld\n",
                GetLastError());
        exit(-1);
    }

}

#endif /* _WIN32 */

static void quit_timers(void)
{
    struct qemu_alarm_timer *t = alarm_timer;
    alarm_timer = NULL;
    t->stop(t);
}

#ifdef CONFIG_POSIX
static void reinit_timers(void)
{
    struct qemu_alarm_timer *t = alarm_timer;
    t->stop(t);
    if (t->start(t)) {
        fprintf(stderr, "Internal timer error: aborting\n");
        exit(1);
    }
    qemu_rearm_alarm_timer(t);
}
#endif /* CONFIG_POSIX */

int init_timer_alarm(void)
{
    struct qemu_alarm_timer *t = NULL;
    int i, err = -1;

    if (alarm_timer) {
        return 0;
    }

    for (i = 0; alarm_timers[i].name; i++) {
        t = &alarm_timers[i];

        err = t->start(t);
        if (!err)
            break;
    }

    if (err) {
        err = -ENOENT;
        goto fail;
    }

    atexit(quit_timers);
#ifdef CONFIG_POSIX
    pthread_atfork(NULL, NULL, reinit_timers);
#endif
    alarm_timer = t;
    return 0;

fail:
    return err;
}
Commit	Line	Data
	1	/*
	2	* QEMU System Emulator
	3	*
	4	* Copyright (c) 2003-2008 Fabrice Bellard
	5	*
	6	* Permission is hereby granted, free of charge, to any person obtaining a copy
	7	* of this software and associated documentation files (the "Software"), to deal
	8	* in the Software without restriction, including without limitation the rights
	9	* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	10	* copies of the Software, and to permit persons to whom the Software is
	11	* furnished to do so, subject to the following conditions:
	12	*
	13	* The above copyright notice and this permission notice shall be included in
	14	* all copies or substantial portions of the Software.
	15	*
	16	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
	17	* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
	18	* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
	19	* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
	20	* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
	21	* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
	22	* THE SOFTWARE.
	23	*/
	24
	25	#include "sysemu.h"
	26	#include "net.h"
	27	#include "monitor.h"
	28	#include "console.h"
	29
	30	#include "hw/hw.h"
	31
	32	#include "qemu-timer.h"
	33	#ifdef CONFIG_POSIX
	34	#include <pthread.h>
	35	#endif
	36
	37	#ifdef _WIN32
	38	#include <mmsystem.h>
	39	#endif
	40
	41	/***********************************************************/
	42	/* timers */
	43
	44	#define QEMU_CLOCK_REALTIME 0
	45	#define QEMU_CLOCK_VIRTUAL 1
	46	#define QEMU_CLOCK_HOST 2
	47
	48	struct QEMUClock {
	49	QEMUTimer *active_timers;
	50
	51	NotifierList reset_notifiers;
	52	int64_t last;
	53
	54	int type;
	55	bool enabled;
	56	};
	57
	58	struct QEMUTimer {
	59	int64_t expire_time; /* in nanoseconds */
	60	QEMUClock *clock;
	61	QEMUTimerCB *cb;
	62	void *opaque;
	63	QEMUTimer *next;
	64	int scale;
	65	};
	66
	67	struct qemu_alarm_timer {
	68	char const *name;
	69	int (start)(struct qemu_alarm_timer t);
	70	void (stop)(struct qemu_alarm_timer t);
	71	void (rearm)(struct qemu_alarm_timer t, int64_t nearest_delta_ns);
	72	#if defined(__linux__)
	73	timer_t timer;
	74	int fd;
	75	#elif defined(_WIN32)
	76	HANDLE timer;
	77	#endif
	78	bool expired;
	79	bool pending;
	80	};
	81
	82	static struct qemu_alarm_timer *alarm_timer;
	83
	84	static bool qemu_timer_expired_ns(QEMUTimer *timer_head, int64_t current_time)
	85	{
	86	return timer_head && (timer_head->expire_time <= current_time);
	87	}
	88
	89	static int64_t qemu_next_alarm_deadline(void)
	90	{
	91	int64_t delta = INT64_MAX;
	92	int64_t rtdelta;
	93
	94	if (!use_icount && vm_clock->enabled && vm_clock->active_timers) {
	95	delta = vm_clock->active_timers->expire_time -
	96	qemu_get_clock_ns(vm_clock);
	97	}
	98	if (host_clock->enabled && host_clock->active_timers) {
	99	int64_t hdelta = host_clock->active_timers->expire_time -
	100	qemu_get_clock_ns(host_clock);
	101	if (hdelta < delta) {
	102	delta = hdelta;
	103	}
	104	}
	105	if (rt_clock->enabled && rt_clock->active_timers) {
	106	rtdelta = (rt_clock->active_timers->expire_time -
	107	qemu_get_clock_ns(rt_clock));
	108	if (rtdelta < delta) {
	109	delta = rtdelta;
	110	}
	111	}
	112
	113	return delta;
	114	}
	115
	116	static void qemu_rearm_alarm_timer(struct qemu_alarm_timer *t)
	117	{
	118	int64_t nearest_delta_ns = qemu_next_alarm_deadline();
	119	if (nearest_delta_ns < INT64_MAX) {
	120	t->rearm(t, nearest_delta_ns);
	121	}
	122	}
	123
	124	/* TODO: MIN_TIMER_REARM_NS should be optimized */
	125	#define MIN_TIMER_REARM_NS 250000
	126
	127	#ifdef _WIN32
	128
	129	static int mm_start_timer(struct qemu_alarm_timer *t);
	130	static void mm_stop_timer(struct qemu_alarm_timer *t);
	131	static void mm_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);
	132
	133	static int win32_start_timer(struct qemu_alarm_timer *t);
	134	static void win32_stop_timer(struct qemu_alarm_timer *t);
	135	static void win32_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);
	136
	137	#else
	138
	139	static int unix_start_timer(struct qemu_alarm_timer *t);
	140	static void unix_stop_timer(struct qemu_alarm_timer *t);
	141	static void unix_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);
	142
	143	#ifdef __linux__
	144
	145	static int dynticks_start_timer(struct qemu_alarm_timer *t);
	146	static void dynticks_stop_timer(struct qemu_alarm_timer *t);
	147	static void dynticks_rearm_timer(struct qemu_alarm_timer *t, int64_t delta);
	148
	149	#endif /* __linux__ */
	150
	151	#endif /* _WIN32 */
	152
	153	static struct qemu_alarm_timer alarm_timers[] = {
	154	#ifndef _WIN32
	155	#ifdef __linux__
	156	{"dynticks", dynticks_start_timer,
	157	dynticks_stop_timer, dynticks_rearm_timer},
	158	#endif
	159	{"unix", unix_start_timer, unix_stop_timer, unix_rearm_timer},
	160	#else
	161	{"mmtimer", mm_start_timer, mm_stop_timer, mm_rearm_timer},
	162	{"dynticks", win32_start_timer, win32_stop_timer, win32_rearm_timer},
	163	#endif
	164	{NULL, }
	165	};
	166
	167	static void show_available_alarms(void)
	168	{
	169	int i;
	170
	171	printf("Available alarm timers, in order of precedence:\n");
	172	for (i = 0; alarm_timers[i].name; i++)
	173	printf("%s\n", alarm_timers[i].name);
	174	}
	175
	176	void configure_alarms(char const *opt)
	177	{
	178	int i;
	179	int cur = 0;
	180	int count = ARRAY_SIZE(alarm_timers) - 1;
	181	char *arg;
	182	char *name;
	183	struct qemu_alarm_timer tmp;
	184
	185	if (is_help_option(opt)) {
	186	show_available_alarms();
	187	exit(0);
	188	}
	189
	190	arg = g_strdup(opt);
	191
	192	/* Reorder the array */
	193	name = strtok(arg, ",");
	194	while (name) {
	195	for (i = 0; i < count && alarm_timers[i].name; i++) {
	196	if (!strcmp(alarm_timers[i].name, name))
	197	break;
	198	}
	199
	200	if (i == count) {
	201	fprintf(stderr, "Unknown clock %s\n", name);
	202	goto next;
	203	}
	204
	205	if (i < cur)
	206	/* Ignore */
	207	goto next;
	208
	209	/* Swap */
	210	tmp = alarm_timers[i];
	211	alarm_timers[i] = alarm_timers[cur];
	212	alarm_timers[cur] = tmp;
	213
	214	cur++;
	215	next:
	216	name = strtok(NULL, ",");
	217	}
	218
	219	g_free(arg);
	220
	221	if (cur) {
	222	/* Disable remaining timers */
	223	for (i = cur; i < count; i++)
	224	alarm_timers[i].name = NULL;
	225	} else {
	226	show_available_alarms();
	227	exit(1);
	228	}
	229	}
	230
	231	QEMUClock *rt_clock;
	232	QEMUClock *vm_clock;
	233	QEMUClock *host_clock;
	234
	235	static QEMUClock *qemu_new_clock(int type)
	236	{
	237	QEMUClock *clock;
	238
	239	clock = g_malloc0(sizeof(QEMUClock));
	240	clock->type = type;
	241	clock->enabled = true;
	242	clock->last = INT64_MIN;
	243	notifier_list_init(&clock->reset_notifiers);
	244	return clock;
	245	}
	246
	247	void qemu_clock_enable(QEMUClock *clock, bool enabled)
	248	{
	249	bool old = clock->enabled;
	250	clock->enabled = enabled;
	251	if (enabled && !old) {
	252	qemu_rearm_alarm_timer(alarm_timer);
	253	}
	254	}
	255
	256	int64_t qemu_clock_has_timers(QEMUClock *clock)
	257	{
	258	return !!clock->active_timers;
	259	}
	260
	261	int64_t qemu_clock_expired(QEMUClock *clock)
	262	{
	263	return (clock->active_timers &&
	264	clock->active_timers->expire_time < qemu_get_clock_ns(clock));
	265	}
	266
	267	int64_t qemu_clock_deadline(QEMUClock *clock)
	268	{
	269	/* To avoid problems with overflow limit this to 2^32. */
	270	int64_t delta = INT32_MAX;
	271
	272	if (clock->active_timers) {
	273	delta = clock->active_timers->expire_time - qemu_get_clock_ns(clock);
	274	}
	275	if (delta < 0) {
	276	delta = 0;
	277	}
	278	return delta;
	279	}
	280
	281	QEMUTimer qemu_new_timer(QEMUClock clock, int scale,
	282	QEMUTimerCB cb, void opaque)
	283	{
	284	QEMUTimer *ts;
	285
	286	ts = g_malloc0(sizeof(QEMUTimer));
	287	ts->clock = clock;
	288	ts->cb = cb;
	289	ts->opaque = opaque;
	290	ts->scale = scale;
	291	return ts;
	292	}
	293
	294	void qemu_free_timer(QEMUTimer *ts)
	295	{
	296	g_free(ts);
	297	}
	298
	299	/* stop a timer, but do not dealloc it */
	300	void qemu_del_timer(QEMUTimer *ts)
	301	{
	302	QEMUTimer *pt, t;
	303
	304	/* NOTE: this code must be signal safe because
	305	qemu_timer_expired() can be called from a signal. */
	306	pt = &ts->clock->active_timers;
	307	for(;;) {
	308	t = *pt;
	309	if (!t)
	310	break;
	311	if (t == ts) {
	312	*pt = t->next;
	313	break;
	314	}
	315	pt = &t->next;
	316	}
	317	}
	318
	319	/* modify the current timer so that it will be fired when current_time
	320	>= expire_time. The corresponding callback will be called. */
	321	void qemu_mod_timer_ns(QEMUTimer *ts, int64_t expire_time)
	322	{
	323	QEMUTimer *pt, t;
	324
	325	qemu_del_timer(ts);
	326
	327	/* add the timer in the sorted list */
	328	/* NOTE: this code must be signal safe because
	329	qemu_timer_expired() can be called from a signal. */
	330	pt = &ts->clock->active_timers;
	331	for(;;) {
	332	t = *pt;
	333	if (!qemu_timer_expired_ns(t, expire_time)) {
	334	break;
	335	}
	336	pt = &t->next;
	337	}
	338	ts->expire_time = expire_time;
	339	ts->next = *pt;
	340	*pt = ts;
	341
	342	/* Rearm if necessary */
	343	if (pt == &ts->clock->active_timers) {
	344	if (!alarm_timer->pending) {
	345	qemu_rearm_alarm_timer(alarm_timer);
	346	}
	347	/* Interrupt execution to force deadline recalculation. */
	348	qemu_clock_warp(ts->clock);
	349	if (use_icount) {
	350	qemu_notify_event();
	351	}
	352	}
	353	}
	354
	355	void qemu_mod_timer(QEMUTimer *ts, int64_t expire_time)
	356	{
	357	qemu_mod_timer_ns(ts, expire_time * ts->scale);
	358	}
	359
	360	bool qemu_timer_pending(QEMUTimer *ts)
	361	{
	362	QEMUTimer *t;
	363	for (t = ts->clock->active_timers; t != NULL; t = t->next) {
	364	if (t == ts) {
	365	return true;
	366	}
	367	}
	368	return false;
	369	}
	370
	371	bool qemu_timer_expired(QEMUTimer *timer_head, int64_t current_time)
	372	{
	373	return qemu_timer_expired_ns(timer_head, current_time * timer_head->scale);
	374	}
	375
	376	void qemu_run_timers(QEMUClock *clock)
	377	{
	378	QEMUTimer *ts;
	379	int64_t current_time;
	380
	381	if (!clock->enabled)
	382	return;
	383
	384	current_time = qemu_get_clock_ns(clock);
	385	for(;;) {
	386	ts = clock->active_timers;
	387	if (!qemu_timer_expired_ns(ts, current_time)) {
	388	break;
	389	}
	390	/* remove timer from the list before calling the callback */
	391	clock->active_timers = ts->next;
	392	ts->next = NULL;
	393
	394	/* run the callback (the timer list can be modified) */
	395	ts->cb(ts->opaque);
	396	}
	397	}
	398
	399	int64_t qemu_get_clock_ns(QEMUClock *clock)
	400	{
	401	int64_t now, last;
	402
	403	switch(clock->type) {
	404	case QEMU_CLOCK_REALTIME:
	405	return get_clock();
	406	default:
	407	case QEMU_CLOCK_VIRTUAL:
	408	if (use_icount) {
	409	return cpu_get_icount();
	410	} else {
	411	return cpu_get_clock();
	412	}
	413	case QEMU_CLOCK_HOST:
	414	now = get_clock_realtime();
	415	last = clock->last;
	416	clock->last = now;
	417	if (now < last) {
	418	notifier_list_notify(&clock->reset_notifiers, &now);
	419	}
	420	return now;
	421	}
	422	}
	423
	424	void qemu_register_clock_reset_notifier(QEMUClock clock, Notifier notifier)
	425	{
	426	notifier_list_add(&clock->reset_notifiers, notifier);
	427	}
	428
	429	void qemu_unregister_clock_reset_notifier(QEMUClock clock, Notifier notifier)
	430	{
	431	notifier_remove(notifier);
	432	}
	433
	434	void init_clocks(void)
	435	{
	436	if (!rt_clock) {
	437	rt_clock = qemu_new_clock(QEMU_CLOCK_REALTIME);
	438	vm_clock = qemu_new_clock(QEMU_CLOCK_VIRTUAL);
	439	host_clock = qemu_new_clock(QEMU_CLOCK_HOST);
	440	}
	441	}
	442
	443	uint64_t qemu_timer_expire_time_ns(QEMUTimer *ts)
	444	{
	445	return qemu_timer_pending(ts) ? ts->expire_time : -1;
	446	}
	447
	448	void qemu_run_all_timers(void)
	449	{
	450	alarm_timer->pending = false;
	451
	452	/* vm time timers */
	453	qemu_run_timers(vm_clock);
	454	qemu_run_timers(rt_clock);
	455	qemu_run_timers(host_clock);
	456
	457	/* rearm timer, if not periodic */
	458	if (alarm_timer->expired) {
	459	alarm_timer->expired = false;
	460	qemu_rearm_alarm_timer(alarm_timer);
	461	}
	462	}
	463
	464	#ifdef _WIN32
	465	static void CALLBACK host_alarm_handler(PVOID lpParam, BOOLEAN unused)
	466	#else
	467	static void host_alarm_handler(int host_signum)
	468	#endif
	469	{
	470	struct qemu_alarm_timer *t = alarm_timer;
	471	if (!t)
	472	return;
	473
	474	t->expired = true;
	475	t->pending = true;
	476	qemu_notify_event();
	477	}
	478
	479	#if defined(__linux__)
	480
	481	#include "compatfd.h"
	482
	483	static int dynticks_start_timer(struct qemu_alarm_timer *t)
	484	{
	485	struct sigevent ev;
	486	timer_t host_timer;
	487	struct sigaction act;
	488
	489	sigfillset(&act.sa_mask);
	490	act.sa_flags = 0;
	491	act.sa_handler = host_alarm_handler;
	492
	493	sigaction(SIGALRM, &act, NULL);
	494
	495	/*
	496	* Initialize ev struct to 0 to avoid valgrind complaining
	497	* about uninitialized data in timer_create call
	498	*/
	499	memset(&ev, 0, sizeof(ev));
	500	ev.sigev_value.sival_int = 0;
	501	ev.sigev_notify = SIGEV_SIGNAL;
	502	#ifdef CONFIG_SIGEV_THREAD_ID
	503	if (qemu_signalfd_available()) {
	504	ev.sigev_notify = SIGEV_THREAD_ID;
	505	ev._sigev_un._tid = qemu_get_thread_id();
	506	}
	507	#endif /* CONFIG_SIGEV_THREAD_ID */
	508	ev.sigev_signo = SIGALRM;
	509
	510	if (timer_create(CLOCK_REALTIME, &ev, &host_timer)) {
	511	perror("timer_create");
	512	return -1;
	513	}
	514
	515	t->timer = host_timer;
	516
	517	return 0;
	518	}
	519
	520	static void dynticks_stop_timer(struct qemu_alarm_timer *t)
	521	{
	522	timer_t host_timer = t->timer;
	523
	524	timer_delete(host_timer);
	525	}
	526
	527	static void dynticks_rearm_timer(struct qemu_alarm_timer *t,
	528	int64_t nearest_delta_ns)
	529	{
	530	timer_t host_timer = t->timer;
	531	struct itimerspec timeout;
	532	int64_t current_ns;
	533
	534	if (nearest_delta_ns < MIN_TIMER_REARM_NS)
	535	nearest_delta_ns = MIN_TIMER_REARM_NS;
	536
	537	/* check whether a timer is already running */
	538	if (timer_gettime(host_timer, &timeout)) {
	539	perror("gettime");
	540	fprintf(stderr, "Internal timer error: aborting\n");
	541	exit(1);
	542	}
	543	current_ns = timeout.it_value.tv_sec * 1000000000LL + timeout.it_value.tv_nsec;
	544	if (current_ns && current_ns <= nearest_delta_ns)
	545	return;
	546
	547	timeout.it_interval.tv_sec = 0;
	548	timeout.it_interval.tv_nsec = 0; /* 0 for one-shot timer */
	549	timeout.it_value.tv_sec = nearest_delta_ns / 1000000000;
	550	timeout.it_value.tv_nsec = nearest_delta_ns % 1000000000;
	551	if (timer_settime(host_timer, 0 /* RELATIVE */, &timeout, NULL)) {
	552	perror("settime");
	553	fprintf(stderr, "Internal timer error: aborting\n");
	554	exit(1);
	555	}
	556	}
	557
	558	#endif /* defined(__linux__) */
	559
	560	#if !defined(_WIN32)
	561
	562	static int unix_start_timer(struct qemu_alarm_timer *t)
	563	{
	564	struct sigaction act;
	565
	566	/* timer signal */
	567	sigfillset(&act.sa_mask);
	568	act.sa_flags = 0;
	569	act.sa_handler = host_alarm_handler;
	570
	571	sigaction(SIGALRM, &act, NULL);
	572	return 0;
	573	}
	574
	575	static void unix_rearm_timer(struct qemu_alarm_timer *t,
	576	int64_t nearest_delta_ns)
	577	{
	578	struct itimerval itv;
	579	int err;
	580
	581	if (nearest_delta_ns < MIN_TIMER_REARM_NS)
	582	nearest_delta_ns = MIN_TIMER_REARM_NS;
	583
	584	itv.it_interval.tv_sec = 0;
	585	itv.it_interval.tv_usec = 0; /* 0 for one-shot timer */
	586	itv.it_value.tv_sec = nearest_delta_ns / 1000000000;
	587	itv.it_value.tv_usec = (nearest_delta_ns % 1000000000) / 1000;
	588	err = setitimer(ITIMER_REAL, &itv, NULL);
	589	if (err) {
	590	perror("setitimer");
	591	fprintf(stderr, "Internal timer error: aborting\n");
	592	exit(1);
	593	}
	594	}
	595
	596	static void unix_stop_timer(struct qemu_alarm_timer *t)
	597	{
	598	struct itimerval itv;
	599
	600	memset(&itv, 0, sizeof(itv));
	601	setitimer(ITIMER_REAL, &itv, NULL);
	602	}
	603
	604	#endif /* !defined(_WIN32) */
	605
	606
	607	#ifdef _WIN32
	608
	609	static MMRESULT mm_timer;
	610	static TIMECAPS mm_tc;
	611
	612	static void CALLBACK mm_alarm_handler(UINT uTimerID, UINT uMsg,
	613	DWORD_PTR dwUser, DWORD_PTR dw1,
	614	DWORD_PTR dw2)
	615	{
	616	struct qemu_alarm_timer *t = alarm_timer;
	617	if (!t) {
	618	return;
	619	}
	620	t->expired = true;
	621	t->pending = true;
	622	qemu_notify_event();
	623	}
	624
	625	static int mm_start_timer(struct qemu_alarm_timer *t)
	626	{
	627	timeGetDevCaps(&mm_tc, sizeof(mm_tc));
	628
	629	timeBeginPeriod(mm_tc.wPeriodMin);
	630
	631	mm_timer = timeSetEvent(mm_tc.wPeriodMin, /* interval (ms) */
	632	mm_tc.wPeriodMin, /* resolution */
	633	mm_alarm_handler, /* function */
	634	(DWORD_PTR)t, /* parameter */
	635	TIME_ONESHOT \| TIME_CALLBACK_FUNCTION);
	636
	637	if (!mm_timer) {
	638	fprintf(stderr, "Failed to initialize win32 alarm timer\n");
	639	timeEndPeriod(mm_tc.wPeriodMin);
	640	return -1;
	641	}
	642
	643	return 0;
	644	}
	645
	646	static void mm_stop_timer(struct qemu_alarm_timer *t)
	647	{
	648	timeKillEvent(mm_timer);
	649	timeEndPeriod(mm_tc.wPeriodMin);
	650	}
	651
	652	static void mm_rearm_timer(struct qemu_alarm_timer *t, int64_t delta)
	653	{
	654	int64_t nearest_delta_ms = delta / 1000000;
	655	if (nearest_delta_ms < mm_tc.wPeriodMin) {
	656	nearest_delta_ms = mm_tc.wPeriodMin;
	657	} else if (nearest_delta_ms > mm_tc.wPeriodMax) {
	658	nearest_delta_ms = mm_tc.wPeriodMax;
	659	}
	660
	661	timeKillEvent(mm_timer);
	662	mm_timer = timeSetEvent((UINT)nearest_delta_ms,
	663	mm_tc.wPeriodMin,
	664	mm_alarm_handler,
	665	(DWORD_PTR)t,
	666	TIME_ONESHOT \| TIME_CALLBACK_FUNCTION);
	667
	668	if (!mm_timer) {
	669	fprintf(stderr, "Failed to re-arm win32 alarm timer\n");
	670	timeEndPeriod(mm_tc.wPeriodMin);
	671	exit(1);
	672	}
	673	}
	674
	675	static int win32_start_timer(struct qemu_alarm_timer *t)
	676	{
	677	HANDLE hTimer;
	678	BOOLEAN success;
	679
	680	/* If you call ChangeTimerQueueTimer on a one-shot timer (its period
	681	is zero) that has already expired, the timer is not updated. Since
	682	creating a new timer is relatively expensive, set a bogus one-hour
	683	interval in the dynticks case. */
	684	success = CreateTimerQueueTimer(&hTimer,
	685	NULL,
	686	host_alarm_handler,
	687	t,
	688	1,
	689	3600000,
	690	WT_EXECUTEINTIMERTHREAD);
	691
	692	if (!success) {
	693	fprintf(stderr, "Failed to initialize win32 alarm timer: %ld\n",
	694	GetLastError());
	695	return -1;
	696	}
	697
	698	t->timer = hTimer;
	699	return 0;
	700	}
	701
	702	static void win32_stop_timer(struct qemu_alarm_timer *t)
	703	{
	704	HANDLE hTimer = t->timer;
	705
	706	if (hTimer) {
	707	DeleteTimerQueueTimer(NULL, hTimer, NULL);
	708	}
	709	}
	710
	711	static void win32_rearm_timer(struct qemu_alarm_timer *t,
	712	int64_t nearest_delta_ns)
	713	{
	714	HANDLE hTimer = t->timer;
	715	int64_t nearest_delta_ms;
	716	BOOLEAN success;
	717
	718	nearest_delta_ms = nearest_delta_ns / 1000000;
	719	if (nearest_delta_ms < 1) {
	720	nearest_delta_ms = 1;
	721	}
	722	/* ULONG_MAX can be 32 bit */
	723	if (nearest_delta_ms > ULONG_MAX) {
	724	nearest_delta_ms = ULONG_MAX;
	725	}
	726	success = ChangeTimerQueueTimer(NULL,
	727	hTimer,
	728	(unsigned long) nearest_delta_ms,
	729	3600000);
	730
	731	if (!success) {
	732	fprintf(stderr, "Failed to rearm win32 alarm timer: %ld\n",
	733	GetLastError());
	734	exit(-1);
	735	}
	736
	737	}
	738
	739	#endif /* _WIN32 */
	740
	741	static void quit_timers(void)
	742	{
	743	struct qemu_alarm_timer *t = alarm_timer;
	744	alarm_timer = NULL;
	745	t->stop(t);
	746	}
	747
	748	#ifdef CONFIG_POSIX
	749	static void reinit_timers(void)
	750	{
	751	struct qemu_alarm_timer *t = alarm_timer;
	752	t->stop(t);
	753	if (t->start(t)) {
	754	fprintf(stderr, "Internal timer error: aborting\n");
	755	exit(1);
	756	}
	757	qemu_rearm_alarm_timer(t);
	758	}
	759	#endif /* CONFIG_POSIX */
	760
	761	int init_timer_alarm(void)
	762	{
	763	struct qemu_alarm_timer *t = NULL;
	764	int i, err = -1;
	765
	766	if (alarm_timer) {
	767	return 0;
	768	}
	769
	770	for (i = 0; alarm_timers[i].name; i++) {
	771	t = &alarm_timers[i];
	772
	773	err = t->start(t);
	774	if (!err)
	775	break;
	776	}
	777
	778	if (err) {
	779	err = -ENOENT;
	780	goto fail;
	781	}
	782
	783	atexit(quit_timers);
	784	#ifdef CONFIG_POSIX
	785	pthread_atfork(NULL, NULL, reinit_timers);
	786	#endif
	787	alarm_timer = t;
	788	return 0;
	789
	790	fail:
	791	return err;
	792	}
	793