|
@@ -212,7 +212,8 @@ QDict *coroutine_mixed_fn qmp_dispatch(const QmpCommandList *cmds, QObject *requ
|
|
* executing the command handler so that it can make progress if it
|
|
* executing the command handler so that it can make progress if it
|
|
* involves an AIO_WAIT_WHILE().
|
|
* involves an AIO_WAIT_WHILE().
|
|
*/
|
|
*/
|
|
- aio_co_reschedule_self(qemu_get_aio_context());
|
|
|
|
|
|
+ aio_co_schedule(qemu_get_aio_context(), qemu_coroutine_self());
|
|
|
|
+ qemu_coroutine_yield();
|
|
}
|
|
}
|
|
|
|
|
|
monitor_set_cur(qemu_coroutine_self(), cur_mon);
|
|
monitor_set_cur(qemu_coroutine_self(), cur_mon);
|
|
@@ -226,7 +227,9 @@ QDict *coroutine_mixed_fn qmp_dispatch(const QmpCommandList *cmds, QObject *requ
|
|
* Move back to iohandler_ctx so that nested event loops for
|
|
* Move back to iohandler_ctx so that nested event loops for
|
|
* qemu_aio_context don't start new monitor commands.
|
|
* qemu_aio_context don't start new monitor commands.
|
|
*/
|
|
*/
|
|
- aio_co_reschedule_self(iohandler_get_aio_context());
|
|
|
|
|
|
+ aio_co_schedule(iohandler_get_aio_context(),
|
|
|
|
+ qemu_coroutine_self());
|
|
|
|
+ qemu_coroutine_yield();
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
/*
|
|
/*
|