From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from eggs.gnu.org ([2001:4830:134:3::10]:35907) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1bjPC4-0002RA-Ru for qemu-devel@nongnu.org; Mon, 12 Sep 2016 07:14:33 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1bjPC0-0007ol-KX for qemu-devel@nongnu.org; Mon, 12 Sep 2016 07:14:31 -0400 Received: from mail-wm0-f66.google.com ([74.125.82.66]:36352) by eggs.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1bjPC0-0007gk-ET for qemu-devel@nongnu.org; Mon, 12 Sep 2016 07:14:28 -0400 Received: by mail-wm0-f66.google.com with SMTP id z194so750746wmd.3 for ; Mon, 12 Sep 2016 04:14:07 -0700 (PDT) Sender: Paolo Bonzini From: Paolo Bonzini Date: Mon, 12 Sep 2016 13:12:39 +0200 Message-Id: <1473678761-8885-15-git-send-email-pbonzini@redhat.com> In-Reply-To: <1473678761-8885-1-git-send-email-pbonzini@redhat.com> References: <1473678761-8885-1-git-send-email-pbonzini@redhat.com> Subject: [Qemu-devel] [PATCH 14/16] cpus-common: Introduce async_safe_run_on_cpu() List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: qemu-devel@nongnu.org Cc: sergey.fedorov@linaro.org, alex.bennee@linaro.org Signed-off-by: Paolo Bonzini --- cpus-common.c | 25 +++++++++++++++++++++++-- include/qom/cpu.h | 11 +++++++++++ 2 files changed, 34 insertions(+), 2 deletions(-) diff --git a/cpus-common.c b/cpus-common.c index 12c8e69..50a92dd 100644 --- a/cpus-common.c +++ b/cpus-common.c @@ -106,7 +106,7 @@ struct qemu_work_item { struct qemu_work_item *next; run_on_cpu_func func; void *data; - bool free, done; + bool free, exclusive, done; }; static void queue_work_on_cpu(CPUState *cpu, struct qemu_work_item *wi) @@ -139,6 +139,7 @@ void do_run_on_cpu(CPUState *cpu, run_on_cpu_func func, void *data, wi.data = data; wi.done = false; wi.free = false; + wi.exclusive = false; queue_work_on_cpu(cpu, &wi); while (!atomic_mb_read(&wi.done)) { @@ -157,6 +158,7 @@ void async_run_on_cpu(CPUState *cpu, run_on_cpu_func func, void *data) wi->func = func; wi->data = data; wi->free = true; + wi->exclusive = false; queue_work_on_cpu(cpu, wi); } @@ -230,6 +232,19 @@ void cpu_exec_end(CPUState *cpu) qemu_mutex_unlock(&qemu_cpu_list_mutex); } +void async_safe_run_on_cpu(CPUState *cpu, run_on_cpu_func func, void *data) +{ + struct qemu_work_item *wi; + + wi = g_malloc0(sizeof(struct qemu_work_item)); + wi->func = func; + wi->data = data; + wi->free = true; + wi->exclusive = true; + + queue_work_on_cpu(cpu, wi); +} + void process_queued_cpu_work(CPUState *cpu) { struct qemu_work_item *wi; @@ -246,7 +261,13 @@ void process_queued_cpu_work(CPUState *cpu) cpu->queued_work_last = NULL; } qemu_mutex_unlock(&cpu->work_mutex); - wi->func(cpu, wi->data); + if (wi->exclusive) { + start_exclusive(); + wi->func(cpu, wi->data); + end_exclusive(); + } else { + wi->func(cpu, wi->data); + } qemu_mutex_lock(&cpu->work_mutex); if (wi->free) { g_free(wi); diff --git a/include/qom/cpu.h b/include/qom/cpu.h index 934c07a..d1ca31c 100644 --- a/include/qom/cpu.h +++ b/include/qom/cpu.h @@ -656,6 +656,17 @@ void run_on_cpu(CPUState *cpu, run_on_cpu_func func, void *data); void async_run_on_cpu(CPUState *cpu, run_on_cpu_func func, void *data); /** + * async_safe_run_on_cpu: + * @cpu: The vCPU to run on. + * @func: The function to be executed. + * @data: Data to pass to the function. + * + * Schedules the function @func for execution on the vCPU @cpu asynchronously, + * while all other vCPUs are sleeping. + */ +void async_safe_run_on_cpu(CPUState *cpu, run_on_cpu_func func, void *data); + +/** * qemu_get_cpu: * @index: The CPUState@cpu_index value of the CPU to obtain. * -- 2.7.4