OpenE2K/qemu-e2k
13
4
Fork 0
Code Issues 4 Pull Requests Projects 2 Releases Activity

monitor: cleanup fetching of QMP requests

Browse Source 
Use a continue statement so that "after going to sleep" is treated the same
way as "after processing a request".  Pull the monitor_lock critical
section out of monitor_qmp_requests_pop_any_with_lock() and protect
qmp_dispatcher_co_shutdown with the monitor_lock.

The two changes are complex to separate because monitor_qmp_dispatcher_co()
previously had a complicated logic to check for shutdown both before
and after going to sleep.

Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
This commit is contained in:
Paolo Bonzini 2023-03-03 12:51:33 +01:00
parent 3e6bed619a
commit 0ff2553701
2 changed files with 22 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
monitor/monitor.c
View File

@ -56,7 +56,10 @@ IOThread *mon_iothread;
/* Coroutine to dispatch the requests received from I/O thread */ /* Coroutine to dispatch the requests received from I/O thread */
Coroutine *qmp_dispatcher_co; Coroutine *qmp_dispatcher_co;
/* Set to true when the dispatcher coroutine should terminate */ /*
* Set to true when the dispatcher coroutine should terminate. Protected
* by monitor_lock.
*/
bool qmp_dispatcher_co_shutdown; bool qmp_dispatcher_co_shutdown;
/* /*
@ -679,7 +682,9 @@ void monitor_cleanup(void)
* we'll just leave them in the queue without sending a response * we'll just leave them in the queue without sending a response
* and monitor_data_destroy() will free them. * and monitor_data_destroy() will free them.
*/ */
WITH_QEMU_LOCK_GUARD(&monitor_lock) {
qmp_dispatcher_co_shutdown = true; qmp_dispatcher_co_shutdown = true;
}
if (!qatomic_xchg(&qmp_dispatcher_co_busy, true)) { if (!qatomic_xchg(&qmp_dispatcher_co_busy, true)) {
aio_co_wake(qmp_dispatcher_co); aio_co_wake(qmp_dispatcher_co);
} }

34
monitor/qmp.c
View File

@ -178,8 +178,6 @@ static QMPRequest *monitor_qmp_requests_pop_any_with_lock(void)
Monitor *mon; Monitor *mon;
MonitorQMP *qmp_mon; MonitorQMP *qmp_mon;
QEMU_LOCK_GUARD(&monitor_lock);
QTAILQ_FOREACH(mon, &mon_list, entry) { QTAILQ_FOREACH(mon, &mon_list, entry) {
if (!monitor_is_qmp(mon)) { if (!monitor_is_qmp(mon)) {
continue; continue;
@ -215,6 +213,10 @@ void coroutine_fn monitor_qmp_dispatcher_co(void *data)
MonitorQMP *mon; MonitorQMP *mon;
while (true) { while (true) {
/*
* busy must be set to true again by whoever
* rescheduled us to avoid double scheduling
*/
assert(qatomic_mb_read(&qmp_dispatcher_co_busy) == true); assert(qatomic_mb_read(&qmp_dispatcher_co_busy) == true);
/* /*
@ -224,36 +226,23 @@ void coroutine_fn monitor_qmp_dispatcher_co(void *data)
*/ */
qatomic_mb_set(&qmp_dispatcher_co_busy, false); qatomic_mb_set(&qmp_dispatcher_co_busy, false);
WITH_QEMU_LOCK_GUARD(&monitor_lock) {
/* On shutdown, don't take any more requests from the queue */ /* On shutdown, don't take any more requests from the queue */
if (qmp_dispatcher_co_shutdown) { if (qmp_dispatcher_co_shutdown) {
qatomic_set(&qmp_dispatcher_co, NULL); return NULL;
return;
} }
while (!(req_obj = monitor_qmp_requests_pop_any_with_lock())) { req_obj = monitor_qmp_requests_pop_any_with_lock();
}
if (!req_obj) {
/* /*
* No more requests to process. Wait to be reentered from * No more requests to process. Wait to be reentered from
* handle_qmp_command() when it pushes more requests, or * handle_qmp_command() when it pushes more requests, or
* from monitor_cleanup() when it requests shutdown. * from monitor_cleanup() when it requests shutdown.
*/ */
if (!qmp_dispatcher_co_shutdown) {
qemu_coroutine_yield(); qemu_coroutine_yield();
continue;
/*
* busy must be set to true again by whoever
* rescheduled us to avoid double scheduling
*/
assert(qatomic_xchg(&qmp_dispatcher_co_busy, false) == true);
}
/*
* qmp_dispatcher_co_shutdown may have changed if we
* yielded and were reentered from monitor_cleanup()
*/
if (qmp_dispatcher_co_shutdown) {
qatomic_set(&qmp_dispatcher_co, NULL);
return;
}
} }
trace_monitor_qmp_in_band_dequeue(req_obj, trace_monitor_qmp_in_band_dequeue(req_obj,
@ -342,6 +331,7 @@ void coroutine_fn monitor_qmp_dispatcher_co(void *data)
aio_co_schedule(iohandler_get_aio_context(), qmp_dispatcher_co); aio_co_schedule(iohandler_get_aio_context(), qmp_dispatcher_co);
qemu_coroutine_yield(); qemu_coroutine_yield();
} }
qatomic_set(&qmp_dispatcher_co, NULL);
} }
static void handle_qmp_command(void *opaque, QObject *req, Error *err) static void handle_qmp_command(void *opaque, QObject *req, Error *err)