qemu-coroutine-sleep.c 1.28 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13
/*
 * 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.
 *
 */

14
#include "block/coroutine.h"
15
#include "qemu/timer.h"
16
#include "block/aio.h"
17 18 19 20 21 22 23 24 25 26 27 28 29

typedef struct CoSleepCB {
    QEMUTimer *ts;
    Coroutine *co;
} CoSleepCB;

static void co_sleep_cb(void *opaque)
{
    CoSleepCB *sleep_cb = opaque;

    qemu_coroutine_enter(sleep_cb->co, NULL);
}

30
void coroutine_fn co_sleep_ns(QEMUClockType type, int64_t ns)
31 32 33 34
{
    CoSleepCB sleep_cb = {
        .co = qemu_coroutine_self(),
    };
35 36
    sleep_cb.ts = timer_new(type, SCALE_NS, co_sleep_cb, &sleep_cb);
    timer_mod(sleep_cb.ts, qemu_clock_get_ns(type) + ns);
37
    qemu_coroutine_yield();
38 39
    timer_del(sleep_cb.ts);
    timer_free(sleep_cb.ts);
40
}
41 42 43 44 45 46 47 48 49 50 51 52 53

void coroutine_fn co_aio_sleep_ns(AioContext *ctx, QEMUClockType type,
                                  int64_t ns)
{
    CoSleepCB sleep_cb = {
        .co = qemu_coroutine_self(),
    };
    sleep_cb.ts = aio_timer_new(ctx, type, SCALE_NS, co_sleep_cb, &sleep_cb);
    timer_mod(sleep_cb.ts, qemu_clock_get_ns(type) + ns);
    qemu_coroutine_yield();
    timer_del(sleep_cb.ts);
    timer_free(sleep_cb.ts);
}