rcu: run RCU callbacks under the BQL

This needs to go away sooner or later, but one complication is the
complex VFIO data structures that are modified in instance_finalize.
Take a shortcut for now.

Reviewed-by: Michael Roth <mdroth@linux.vnet.ibm.com>
Tested-by: Michael Roth <mdroth@linux.vnet.ibm.com>
Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
This commit is contained in:
Paolo Bonzini 2015-02-11 17:15:18 +01:00
parent a7d1d63679
commit a464982499
2 changed files with 6 additions and 1 deletions

View file

@ -255,7 +255,7 @@ tests/test-x86-cpuid$(EXESUF): tests/test-x86-cpuid.o
tests/test-xbzrle$(EXESUF): tests/test-xbzrle.o migration/xbzrle.o page_cache.o libqemuutil.a tests/test-xbzrle$(EXESUF): tests/test-xbzrle.o migration/xbzrle.o page_cache.o libqemuutil.a
tests/test-cutils$(EXESUF): tests/test-cutils.o util/cutils.o tests/test-cutils$(EXESUF): tests/test-cutils.o util/cutils.o
tests/test-int128$(EXESUF): tests/test-int128.o tests/test-int128$(EXESUF): tests/test-int128.o
tests/rcutorture$(EXESUF): tests/rcutorture.o libqemuutil.a tests/rcutorture$(EXESUF): tests/rcutorture.o libqemuutil.a libqemustub.a
tests/test-qdev-global-props$(EXESUF): tests/test-qdev-global-props.o \ tests/test-qdev-global-props$(EXESUF): tests/test-qdev-global-props.o \
hw/core/qdev.o hw/core/qdev-properties.o hw/core/hotplug.o\ hw/core/qdev.o hw/core/qdev-properties.o hw/core/hotplug.o\

View file

@ -35,6 +35,7 @@
#include "qemu/rcu.h" #include "qemu/rcu.h"
#include "qemu/atomic.h" #include "qemu/atomic.h"
#include "qemu/thread.h" #include "qemu/thread.h"
#include "qemu/main-loop.h"
/* /*
* Global grace period counter. Bit 0 is always one in rcu_gp_ctr. * Global grace period counter. Bit 0 is always one in rcu_gp_ctr.
@ -237,20 +238,24 @@ static void *call_rcu_thread(void *opaque)
atomic_sub(&rcu_call_count, n); atomic_sub(&rcu_call_count, n);
synchronize_rcu(); synchronize_rcu();
qemu_mutex_lock_iothread();
while (n > 0) { while (n > 0) {
node = try_dequeue(); node = try_dequeue();
while (!node) { while (!node) {
qemu_mutex_unlock_iothread();
qemu_event_reset(&rcu_call_ready_event); qemu_event_reset(&rcu_call_ready_event);
node = try_dequeue(); node = try_dequeue();
if (!node) { if (!node) {
qemu_event_wait(&rcu_call_ready_event); qemu_event_wait(&rcu_call_ready_event);
node = try_dequeue(); node = try_dequeue();
} }
qemu_mutex_lock_iothread();
} }
n--; n--;
node->func(node); node->func(node);
} }
qemu_mutex_unlock_iothread();
} }
abort(); abort();
} }