4 * Copyright (c) 2003-2008 Fabrice Bellard
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:
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
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
32 #include "qemu-timer.h"
38 /***********************************************************/
41 #define QEMU_CLOCK_REALTIME 0
42 #define QEMU_CLOCK_VIRTUAL 1
43 #define QEMU_CLOCK_HOST 2
46 QEMUTimer
*active_timers
;
48 NotifierList reset_notifiers
;
56 int64_t expire_time
; /* in nanoseconds */
64 struct qemu_alarm_timer
{
66 int (*start
)(struct qemu_alarm_timer
*t
);
67 void (*stop
)(struct qemu_alarm_timer
*t
);
68 void (*rearm
)(struct qemu_alarm_timer
*t
, int64_t nearest_delta_ns
);
69 #if defined(__linux__)
79 static struct qemu_alarm_timer
*alarm_timer
;
81 static bool qemu_timer_expired_ns(QEMUTimer
*timer_head
, int64_t current_time
)
83 return timer_head
&& (timer_head
->expire_time
<= current_time
);
86 static int64_t qemu_next_alarm_deadline(void)
88 int64_t delta
= INT64_MAX
;
91 if (!use_icount
&& vm_clock
->enabled
&& vm_clock
->active_timers
) {
92 delta
= vm_clock
->active_timers
->expire_time
-
93 qemu_get_clock_ns(vm_clock
);
95 if (host_clock
->enabled
&& host_clock
->active_timers
) {
96 int64_t hdelta
= host_clock
->active_timers
->expire_time
-
97 qemu_get_clock_ns(host_clock
);
102 if (rt_clock
->enabled
&& rt_clock
->active_timers
) {
103 rtdelta
= (rt_clock
->active_timers
->expire_time
-
104 qemu_get_clock_ns(rt_clock
));
105 if (rtdelta
< delta
) {
113 static void qemu_rearm_alarm_timer(struct qemu_alarm_timer
*t
)
115 int64_t nearest_delta_ns
= qemu_next_alarm_deadline();
116 if (nearest_delta_ns
< INT64_MAX
) {
117 t
->rearm(t
, nearest_delta_ns
);
121 /* TODO: MIN_TIMER_REARM_NS should be optimized */
122 #define MIN_TIMER_REARM_NS 250000
126 static int mm_start_timer(struct qemu_alarm_timer
*t
);
127 static void mm_stop_timer(struct qemu_alarm_timer
*t
);
128 static void mm_rearm_timer(struct qemu_alarm_timer
*t
, int64_t delta
);
130 static int win32_start_timer(struct qemu_alarm_timer
*t
);
131 static void win32_stop_timer(struct qemu_alarm_timer
*t
);
132 static void win32_rearm_timer(struct qemu_alarm_timer
*t
, int64_t delta
);
136 static int unix_start_timer(struct qemu_alarm_timer
*t
);
137 static void unix_stop_timer(struct qemu_alarm_timer
*t
);
138 static void unix_rearm_timer(struct qemu_alarm_timer
*t
, int64_t delta
);
142 static int dynticks_start_timer(struct qemu_alarm_timer
*t
);
143 static void dynticks_stop_timer(struct qemu_alarm_timer
*t
);
144 static void dynticks_rearm_timer(struct qemu_alarm_timer
*t
, int64_t delta
);
146 #endif /* __linux__ */
150 static struct qemu_alarm_timer alarm_timers
[] = {
153 {"dynticks", dynticks_start_timer
,
154 dynticks_stop_timer
, dynticks_rearm_timer
},
156 {"unix", unix_start_timer
, unix_stop_timer
, unix_rearm_timer
},
158 {"mmtimer", mm_start_timer
, mm_stop_timer
, mm_rearm_timer
},
159 {"dynticks", win32_start_timer
, win32_stop_timer
, win32_rearm_timer
},
164 static void show_available_alarms(void)
168 printf("Available alarm timers, in order of precedence:\n");
169 for (i
= 0; alarm_timers
[i
].name
; i
++)
170 printf("%s\n", alarm_timers
[i
].name
);
173 void configure_alarms(char const *opt
)
177 int count
= ARRAY_SIZE(alarm_timers
) - 1;
180 struct qemu_alarm_timer tmp
;
182 if (is_help_option(opt
)) {
183 show_available_alarms();
189 /* Reorder the array */
190 name
= strtok(arg
, ",");
192 for (i
= 0; i
< count
&& alarm_timers
[i
].name
; i
++) {
193 if (!strcmp(alarm_timers
[i
].name
, name
))
198 fprintf(stderr
, "Unknown clock %s\n", name
);
207 tmp
= alarm_timers
[i
];
208 alarm_timers
[i
] = alarm_timers
[cur
];
209 alarm_timers
[cur
] = tmp
;
213 name
= strtok(NULL
, ",");
219 /* Disable remaining timers */
220 for (i
= cur
; i
< count
; i
++)
221 alarm_timers
[i
].name
= NULL
;
223 show_available_alarms();
230 QEMUClock
*host_clock
;
232 static QEMUClock
*qemu_new_clock(int type
)
236 clock
= g_malloc0(sizeof(QEMUClock
));
238 clock
->enabled
= true;
239 clock
->last
= INT64_MIN
;
240 notifier_list_init(&clock
->reset_notifiers
);
244 void qemu_clock_enable(QEMUClock
*clock
, bool enabled
)
246 bool old
= clock
->enabled
;
247 clock
->enabled
= enabled
;
248 if (enabled
&& !old
) {
249 qemu_rearm_alarm_timer(alarm_timer
);
253 int64_t qemu_clock_has_timers(QEMUClock
*clock
)
255 return !!clock
->active_timers
;
258 int64_t qemu_clock_expired(QEMUClock
*clock
)
260 return (clock
->active_timers
&&
261 clock
->active_timers
->expire_time
< qemu_get_clock_ns(clock
));
264 int64_t qemu_clock_deadline(QEMUClock
*clock
)
266 /* To avoid problems with overflow limit this to 2^32. */
267 int64_t delta
= INT32_MAX
;
269 if (clock
->active_timers
) {
270 delta
= clock
->active_timers
->expire_time
- qemu_get_clock_ns(clock
);
278 QEMUTimer
*qemu_new_timer(QEMUClock
*clock
, int scale
,
279 QEMUTimerCB
*cb
, void *opaque
)
283 ts
= g_malloc0(sizeof(QEMUTimer
));
291 void qemu_free_timer(QEMUTimer
*ts
)
296 /* stop a timer, but do not dealloc it */
297 void qemu_del_timer(QEMUTimer
*ts
)
301 /* NOTE: this code must be signal safe because
302 qemu_timer_expired() can be called from a signal. */
303 pt
= &ts
->clock
->active_timers
;
316 /* modify the current timer so that it will be fired when current_time
317 >= expire_time. The corresponding callback will be called. */
318 void qemu_mod_timer_ns(QEMUTimer
*ts
, int64_t expire_time
)
324 /* add the timer in the sorted list */
325 /* NOTE: this code must be signal safe because
326 qemu_timer_expired() can be called from a signal. */
327 pt
= &ts
->clock
->active_timers
;
330 if (!qemu_timer_expired_ns(t
, expire_time
)) {
335 ts
->expire_time
= expire_time
;
339 /* Rearm if necessary */
340 if (pt
== &ts
->clock
->active_timers
) {
341 if (!alarm_timer
->pending
) {
342 qemu_rearm_alarm_timer(alarm_timer
);
344 /* Interrupt execution to force deadline recalculation. */
345 qemu_clock_warp(ts
->clock
);
352 void qemu_mod_timer(QEMUTimer
*ts
, int64_t expire_time
)
354 qemu_mod_timer_ns(ts
, expire_time
* ts
->scale
);
357 bool qemu_timer_pending(QEMUTimer
*ts
)
360 for (t
= ts
->clock
->active_timers
; t
!= NULL
; t
= t
->next
) {
368 bool qemu_timer_expired(QEMUTimer
*timer_head
, int64_t current_time
)
370 return qemu_timer_expired_ns(timer_head
, current_time
* timer_head
->scale
);
373 void qemu_run_timers(QEMUClock
*clock
)
376 int64_t current_time
;
381 current_time
= qemu_get_clock_ns(clock
);
383 ts
= clock
->active_timers
;
384 if (!qemu_timer_expired_ns(ts
, current_time
)) {
387 /* remove timer from the list before calling the callback */
388 clock
->active_timers
= ts
->next
;
391 /* run the callback (the timer list can be modified) */
396 int64_t qemu_get_clock_ns(QEMUClock
*clock
)
400 switch(clock
->type
) {
401 case QEMU_CLOCK_REALTIME
:
404 case QEMU_CLOCK_VIRTUAL
:
406 return cpu_get_icount();
408 return cpu_get_clock();
410 case QEMU_CLOCK_HOST
:
411 now
= get_clock_realtime();
415 notifier_list_notify(&clock
->reset_notifiers
, &now
);
421 void qemu_register_clock_reset_notifier(QEMUClock
*clock
, Notifier
*notifier
)
423 notifier_list_add(&clock
->reset_notifiers
, notifier
);
426 void qemu_unregister_clock_reset_notifier(QEMUClock
*clock
, Notifier
*notifier
)
428 notifier_remove(notifier
);
431 void init_clocks(void)
433 rt_clock
= qemu_new_clock(QEMU_CLOCK_REALTIME
);
434 vm_clock
= qemu_new_clock(QEMU_CLOCK_VIRTUAL
);
435 host_clock
= qemu_new_clock(QEMU_CLOCK_HOST
);
438 uint64_t qemu_timer_expire_time_ns(QEMUTimer
*ts
)
440 return qemu_timer_pending(ts
) ? ts
->expire_time
: -1;
443 void qemu_run_all_timers(void)
445 alarm_timer
->pending
= false;
448 qemu_run_timers(vm_clock
);
449 qemu_run_timers(rt_clock
);
450 qemu_run_timers(host_clock
);
452 /* rearm timer, if not periodic */
453 if (alarm_timer
->expired
) {
454 alarm_timer
->expired
= false;
455 qemu_rearm_alarm_timer(alarm_timer
);
460 static void CALLBACK
host_alarm_handler(PVOID lpParam
, BOOLEAN unused
)
462 static void host_alarm_handler(int host_signum
)
465 struct qemu_alarm_timer
*t
= alarm_timer
;
474 #if defined(__linux__)
476 #include "compatfd.h"
478 static int dynticks_start_timer(struct qemu_alarm_timer
*t
)
482 struct sigaction act
;
484 sigfillset(&act
.sa_mask
);
486 act
.sa_handler
= host_alarm_handler
;
488 sigaction(SIGALRM
, &act
, NULL
);
491 * Initialize ev struct to 0 to avoid valgrind complaining
492 * about uninitialized data in timer_create call
494 memset(&ev
, 0, sizeof(ev
));
495 ev
.sigev_value
.sival_int
= 0;
496 ev
.sigev_notify
= SIGEV_SIGNAL
;
497 #ifdef CONFIG_SIGEV_THREAD_ID
498 if (qemu_signalfd_available()) {
499 ev
.sigev_notify
= SIGEV_THREAD_ID
;
500 ev
._sigev_un
._tid
= qemu_get_thread_id();
502 #endif /* CONFIG_SIGEV_THREAD_ID */
503 ev
.sigev_signo
= SIGALRM
;
505 if (timer_create(CLOCK_REALTIME
, &ev
, &host_timer
)) {
506 perror("timer_create");
510 t
->timer
= host_timer
;
515 static void dynticks_stop_timer(struct qemu_alarm_timer
*t
)
517 timer_t host_timer
= t
->timer
;
519 timer_delete(host_timer
);
522 static void dynticks_rearm_timer(struct qemu_alarm_timer
*t
,
523 int64_t nearest_delta_ns
)
525 timer_t host_timer
= t
->timer
;
526 struct itimerspec timeout
;
529 if (nearest_delta_ns
< MIN_TIMER_REARM_NS
)
530 nearest_delta_ns
= MIN_TIMER_REARM_NS
;
532 /* check whether a timer is already running */
533 if (timer_gettime(host_timer
, &timeout
)) {
535 fprintf(stderr
, "Internal timer error: aborting\n");
538 current_ns
= timeout
.it_value
.tv_sec
* 1000000000LL + timeout
.it_value
.tv_nsec
;
539 if (current_ns
&& current_ns
<= nearest_delta_ns
)
542 timeout
.it_interval
.tv_sec
= 0;
543 timeout
.it_interval
.tv_nsec
= 0; /* 0 for one-shot timer */
544 timeout
.it_value
.tv_sec
= nearest_delta_ns
/ 1000000000;
545 timeout
.it_value
.tv_nsec
= nearest_delta_ns
% 1000000000;
546 if (timer_settime(host_timer
, 0 /* RELATIVE */, &timeout
, NULL
)) {
548 fprintf(stderr
, "Internal timer error: aborting\n");
553 #endif /* defined(__linux__) */
557 static int unix_start_timer(struct qemu_alarm_timer
*t
)
559 struct sigaction act
;
562 sigfillset(&act
.sa_mask
);
564 act
.sa_handler
= host_alarm_handler
;
566 sigaction(SIGALRM
, &act
, NULL
);
570 static void unix_rearm_timer(struct qemu_alarm_timer
*t
,
571 int64_t nearest_delta_ns
)
573 struct itimerval itv
;
576 if (nearest_delta_ns
< MIN_TIMER_REARM_NS
)
577 nearest_delta_ns
= MIN_TIMER_REARM_NS
;
579 itv
.it_interval
.tv_sec
= 0;
580 itv
.it_interval
.tv_usec
= 0; /* 0 for one-shot timer */
581 itv
.it_value
.tv_sec
= nearest_delta_ns
/ 1000000000;
582 itv
.it_value
.tv_usec
= (nearest_delta_ns
% 1000000000) / 1000;
583 err
= setitimer(ITIMER_REAL
, &itv
, NULL
);
586 fprintf(stderr
, "Internal timer error: aborting\n");
591 static void unix_stop_timer(struct qemu_alarm_timer
*t
)
593 struct itimerval itv
;
595 memset(&itv
, 0, sizeof(itv
));
596 setitimer(ITIMER_REAL
, &itv
, NULL
);
599 #endif /* !defined(_WIN32) */
604 static MMRESULT mm_timer
;
605 static TIMECAPS mm_tc
;
607 static void CALLBACK
mm_alarm_handler(UINT uTimerID
, UINT uMsg
,
608 DWORD_PTR dwUser
, DWORD_PTR dw1
,
611 struct qemu_alarm_timer
*t
= alarm_timer
;
620 static int mm_start_timer(struct qemu_alarm_timer
*t
)
622 timeGetDevCaps(&mm_tc
, sizeof(mm_tc
));
624 timeBeginPeriod(mm_tc
.wPeriodMin
);
626 mm_timer
= timeSetEvent(mm_tc
.wPeriodMin
, /* interval (ms) */
627 mm_tc
.wPeriodMin
, /* resolution */
628 mm_alarm_handler
, /* function */
629 (DWORD_PTR
)t
, /* parameter */
630 TIME_ONESHOT
| TIME_CALLBACK_FUNCTION
);
633 fprintf(stderr
, "Failed to initialize win32 alarm timer\n");
634 timeEndPeriod(mm_tc
.wPeriodMin
);
641 static void mm_stop_timer(struct qemu_alarm_timer
*t
)
643 timeKillEvent(mm_timer
);
644 timeEndPeriod(mm_tc
.wPeriodMin
);
647 static void mm_rearm_timer(struct qemu_alarm_timer
*t
, int64_t delta
)
649 int64_t nearest_delta_ms
= delta
/ 1000000;
650 if (nearest_delta_ms
< mm_tc
.wPeriodMin
) {
651 nearest_delta_ms
= mm_tc
.wPeriodMin
;
652 } else if (nearest_delta_ms
> mm_tc
.wPeriodMax
) {
653 nearest_delta_ms
= mm_tc
.wPeriodMax
;
656 timeKillEvent(mm_timer
);
657 mm_timer
= timeSetEvent((UINT
)nearest_delta_ms
,
661 TIME_ONESHOT
| TIME_CALLBACK_FUNCTION
);
664 fprintf(stderr
, "Failed to re-arm win32 alarm timer\n");
665 timeEndPeriod(mm_tc
.wPeriodMin
);
670 static int win32_start_timer(struct qemu_alarm_timer
*t
)
675 /* If you call ChangeTimerQueueTimer on a one-shot timer (its period
676 is zero) that has already expired, the timer is not updated. Since
677 creating a new timer is relatively expensive, set a bogus one-hour
678 interval in the dynticks case. */
679 success
= CreateTimerQueueTimer(&hTimer
,
685 WT_EXECUTEINTIMERTHREAD
);
688 fprintf(stderr
, "Failed to initialize win32 alarm timer: %ld\n",
697 static void win32_stop_timer(struct qemu_alarm_timer
*t
)
699 HANDLE hTimer
= t
->timer
;
702 DeleteTimerQueueTimer(NULL
, hTimer
, NULL
);
706 static void win32_rearm_timer(struct qemu_alarm_timer
*t
,
707 int64_t nearest_delta_ns
)
709 HANDLE hTimer
= t
->timer
;
710 int64_t nearest_delta_ms
;
713 nearest_delta_ms
= nearest_delta_ns
/ 1000000;
714 if (nearest_delta_ms
< 1) {
715 nearest_delta_ms
= 1;
717 /* ULONG_MAX can be 32 bit */
718 if (nearest_delta_ms
> ULONG_MAX
) {
719 nearest_delta_ms
= ULONG_MAX
;
721 success
= ChangeTimerQueueTimer(NULL
,
723 (unsigned long) nearest_delta_ms
,
727 fprintf(stderr
, "Failed to rearm win32 alarm timer: %ld\n",
736 static void quit_timers(void)
738 struct qemu_alarm_timer
*t
= alarm_timer
;
743 int init_timer_alarm(void)
745 struct qemu_alarm_timer
*t
= NULL
;
748 for (i
= 0; alarm_timers
[i
].name
; i
++) {
749 t
= &alarm_timers
[i
];