Archipelago » qemu

static void timespec_add_ms(struct timespec *ts, uint64_t msecs)

{

    ts->tv_sec = ts->tv_sec + (long)(msecs / 1000);

    ts->tv_nsec = (ts->tv_nsec + ((long)msecs % 1000) * 1000000);

    if (ts->tv_nsec >= 1000000000) {

        ts->tv_nsec -= 1000000000;

        ts->tv_sec++;

    }

}

int qemu_mutex_timedlock(QemuMutex *mutex, uint64_t msecs)

{

    int err;

    struct timespec ts;

    clock_gettime(CLOCK_REALTIME, &ts);

    timespec_add_ms(&ts, msecs);

    err = pthread_mutex_timedlock(&mutex->lock, &ts);

    if (err && err != ETIMEDOUT)

        error_exit(err, __func__);

    return err;

}

int qemu_cond_timedwait(QemuCond *cond, QemuMutex *mutex, uint64_t msecs)

{

    struct timespec ts;

    int err;

    clock_gettime(CLOCK_REALTIME, &ts);

    timespec_add_ms(&ts, msecs);

    err = pthread_cond_timedwait(&cond->cond, &mutex->lock, &ts);

    if (err && err != ETIMEDOUT)

        error_exit(err, __func__);

    return err;

}