mirror of
https://github.com/Motorhead1991/qemu.git
synced 2025-08-02 23:33:54 -06:00
coroutine: add co_sleep_ns() coroutine sleep function
Signed-off-by: Stefan Hajnoczi <stefanha@linux.vnet.ibm.com> Signed-off-by: Kevin Wolf <kwolf@redhat.com>
This commit is contained in:
parent
031380d877
commit
7e6246670a
3 changed files with 48 additions and 0 deletions
38
qemu-coroutine-sleep.c
Normal file
38
qemu-coroutine-sleep.c
Normal file
|
@ -0,0 +1,38 @@
|
|||
/*
|
||||
* QEMU coroutine sleep
|
||||
*
|
||||
* Copyright IBM, Corp. 2011
|
||||
*
|
||||
* Authors:
|
||||
* Stefan Hajnoczi <stefanha@linux.vnet.ibm.com>
|
||||
*
|
||||
* This work is licensed under the terms of the GNU LGPL, version 2 or later.
|
||||
* See the COPYING.LIB file in the top-level directory.
|
||||
*
|
||||
*/
|
||||
|
||||
#include "qemu-coroutine.h"
|
||||
#include "qemu-timer.h"
|
||||
|
||||
typedef struct CoSleepCB {
|
||||
QEMUTimer *ts;
|
||||
Coroutine *co;
|
||||
} CoSleepCB;
|
||||
|
||||
static void co_sleep_cb(void *opaque)
|
||||
{
|
||||
CoSleepCB *sleep_cb = opaque;
|
||||
|
||||
qemu_free_timer(sleep_cb->ts);
|
||||
qemu_coroutine_enter(sleep_cb->co, NULL);
|
||||
}
|
||||
|
||||
void coroutine_fn co_sleep_ns(QEMUClock *clock, int64_t ns)
|
||||
{
|
||||
CoSleepCB sleep_cb = {
|
||||
.co = qemu_coroutine_self(),
|
||||
};
|
||||
sleep_cb.ts = qemu_new_timer(clock, SCALE_NS, co_sleep_cb, &sleep_cb);
|
||||
qemu_mod_timer(sleep_cb.ts, qemu_get_clock_ns(clock) + ns);
|
||||
qemu_coroutine_yield();
|
||||
}
|
Loading…
Add table
Add a link
Reference in a new issue