From nobody Tue May 7 03:36:16 2024 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; dkim=fail; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=redhat.com Return-Path: Received: from lists.gnu.org (208.118.235.17 [208.118.235.17]) by mx.zohomail.com with SMTPS id 1517672527873343.10485277962266; Sat, 3 Feb 2018 07:42:07 -0800 (PST) Received: from localhost ([::1]:43645 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzx3-00033z-8a for importer@patchew.org; Sat, 03 Feb 2018 10:42:01 -0500 Received: from eggs.gnu.org ([2001:4830:134:3::10]:48236) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzun-0001f0-NK for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:42 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1ehzul-0003zr-Bo for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:41 -0500 Received: from mail-qt0-x241.google.com ([2607:f8b0:400d:c0d::241]:36424) by eggs.gnu.org with esmtps (TLS1.0:RSA_AES_128_CBC_SHA1:16) (Exim 4.71) (envelope-from ) id 1ehzul-0003z7-7K; Sat, 03 Feb 2018 10:39:39 -0500 Received: by mail-qt0-x241.google.com with SMTP id t25so1033366qtg.3; Sat, 03 Feb 2018 07:39:39 -0800 (PST) Received: from localhost.localdomain (50-205-150-222-static.hfc.comcastbusiness.net. [50.205.150.222]) by smtp.gmail.com with ESMTPSA id z35sm3193790qtz.31.2018.02.03.07.39.37 (version=TLS1_2 cipher=ECDHE-RSA-CHACHA20-POLY1305 bits=256/256); Sat, 03 Feb 2018 07:39:37 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=sender:from:to:cc:subject:date:message-id:in-reply-to:references; bh=pmNMUGAmd9R98ODNJ6/cWd3WQ6z8tthrNiTvKCtfGzM=; b=PkBF+oNTP/y6r7i5SuLoEAgb4hZeIQvQXLCloCLVNrWKeaRjm2eCC70MIInP0gB4bt IgNZ7t7v5gkQujgEqRTOG+5Io1yHkh2KFwyUxnDGjTwVR0qGNQ3K97mSTKCrqZI3Lh5w 7h5gHwrqKqqj5tgveKXDWLH5czVyG7+CtnFT9RW/d3MxGFghEd4wfqETKih7yxk8zxdk 8/5wfufoI5qDL37M44wuRIs2psLl7dHIsbuvsFJhfHNGaLX62kp0LKABiOs2mCAeCl7U jePM8EGajsioXkuSc3IJ1uhDuxJTALNqRXniBsD/k9ZPgkGjYFgIfsSLlE/aKHbcPp02 xduA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:sender:from:to:cc:subject:date:message-id :in-reply-to:references; bh=pmNMUGAmd9R98ODNJ6/cWd3WQ6z8tthrNiTvKCtfGzM=; b=T5Bm5jzKaxgqm9OduFjhb0AkNRtoblCK9IeoT3EFCXMdPMoGZ6LWyPkX12Ugl49Q6b TXQs08mRFd1pcf6SaLfrFiyPCwINl7W1XUsybIjzFmpf1RJeqk/beROpbl6laUJ06t75 fgQmxz4J2dHrATHrXndahsFRQcTgNfePmcKuscsNYwRCEj0lTfOyonu4SNRnq4IFJJ+y YZTVKUNXJ5sJdGvT+kLsG2k0Wn2JSE7TKUAQBUi2veEbHKp4PKyErAJpSXcECOT7pzQK 20UTVG0V3rA6kFF0UK8cPWud1gkCdOoIqm1JUaAg17a3GJuV6JhwDGeS1tzm4XQV4Bsr bHew== X-Gm-Message-State: APf1xPBoCix9QqBk1EebqwZwR/aeV1/MkHGdz0HqEuPfan/95D+b2/Mk uJ2osLOVuQihek4rOmHu0ASLhI7h X-Google-Smtp-Source: AH8x227SVUe5cX5V7K5MkQwyrzKwxK4Rz+pKu6d7zdscLLjVEF8ic13IbgeCVaVcwqKgBPoflsptvA== X-Received: by 10.200.54.252 with SMTP id b57mr2119462qtc.187.1517672378378; Sat, 03 Feb 2018 07:39:38 -0800 (PST) From: Paolo Bonzini To: qemu-devel@nongnu.org Date: Sat, 3 Feb 2018 10:39:31 -0500 Message-Id: <20180203153935.8056-2-pbonzini@redhat.com> X-Mailer: git-send-email 2.14.3 In-Reply-To: <20180203153935.8056-1-pbonzini@redhat.com> References: <20180203153935.8056-1-pbonzini@redhat.com> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2607:f8b0:400d:c0d::241 Subject: [Qemu-devel] [PATCH 1/5] test-coroutine: add simple CoMutex test X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: famz@redhat.com, qemu-block@nongnu.org, stefanha@redhat.com Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail-DKIM: fail (Header signature does not verify) X-ZohoMail: RDKM_2 RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" In preparation for adding a similar test using QemuLockable, add a very simple testcase that has two interleaved calls to lock and unlock. Reviewed-by: Stefan Hajnoczi Signed-off-by: Paolo Bonzini Reviewed-by: Richard Henderson --- tests/test-coroutine.c | 50 ++++++++++++++++++++++++++++++++++++++++++++++= ++-- 1 file changed, 48 insertions(+), 2 deletions(-) diff --git a/tests/test-coroutine.c b/tests/test-coroutine.c index 76c646107e..010cb95ad6 100644 --- a/tests/test-coroutine.c +++ b/tests/test-coroutine.c @@ -175,7 +175,7 @@ static void coroutine_fn c1_fn(void *opaque) qemu_coroutine_enter(c2); } =20 -static void test_co_queue(void) +static void test_no_dangling_access(void) { Coroutine *c1; Coroutine *c2; @@ -195,6 +195,51 @@ static void test_co_queue(void) *c1 =3D tmp; } =20 +static bool locked; +static int done; + +static void coroutine_fn mutex_fn(void *opaque) +{ + CoMutex *m =3D opaque; + qemu_co_mutex_lock(m); + assert(!locked); + locked =3D true; + qemu_coroutine_yield(); + locked =3D false; + qemu_co_mutex_unlock(m); + done++; +} + +static void do_test_co_mutex(CoroutineEntry *entry, void *opaque) +{ + Coroutine *c1 =3D qemu_coroutine_create(entry, opaque); + Coroutine *c2 =3D qemu_coroutine_create(entry, opaque); + + done =3D 0; + qemu_coroutine_enter(c1); + g_assert(locked); + qemu_coroutine_enter(c2); + + /* Unlock queues c2. It is then started automatically when c1 yields = or + * terminates. + */ + qemu_coroutine_enter(c1); + g_assert_cmpint(done, =3D=3D, 1); + g_assert(locked); + + qemu_coroutine_enter(c2); + g_assert_cmpint(done, =3D=3D, 2); + g_assert(!locked); +} + +static void test_co_mutex(void) +{ + CoMutex m; + + qemu_co_mutex_init(&m); + do_test_co_mutex(mutex_fn, &m); +} + /* * Check that creation, enter, and return work */ @@ -422,7 +467,7 @@ int main(int argc, char **argv) * crash, so skip it. */ if (CONFIG_COROUTINE_POOL) { - g_test_add_func("/basic/co_queue", test_co_queue); + g_test_add_func("/basic/no-dangling-access", test_no_dangling_acce= ss); } =20 g_test_add_func("/basic/lifecycle", test_lifecycle); @@ -432,6 +477,7 @@ int main(int argc, char **argv) g_test_add_func("/basic/entered", test_entered); g_test_add_func("/basic/in_coroutine", test_in_coroutine); g_test_add_func("/basic/order", test_order); + g_test_add_func("/locking/co-mutex", test_co_mutex); if (g_test_perf()) { g_test_add_func("/perf/lifecycle", perf_lifecycle); g_test_add_func("/perf/nesting", perf_nesting); --=20 2.14.3 From nobody Tue May 7 03:36:16 2024 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; dkim=fail; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=redhat.com Return-Path: Received: from lists.gnu.org (lists.gnu.org [208.118.235.17]) by mx.zohomail.com with SMTPS id 1517672530921742.6468978916793; Sat, 3 Feb 2018 07:42:10 -0800 (PST) Received: from localhost ([::1]:43646 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzxB-000392-My for importer@patchew.org; Sat, 03 Feb 2018 10:42:09 -0500 Received: from eggs.gnu.org ([2001:4830:134:3::10]:48256) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzuo-0001fR-GF for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:44 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1ehzum-00041r-NR for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:42 -0500 Received: from mail-qt0-x22b.google.com ([2607:f8b0:400d:c0d::22b]:44379) by eggs.gnu.org with esmtps (TLS1.0:RSA_AES_128_CBC_SHA1:16) (Exim 4.71) (envelope-from ) id 1ehzum-000419-Hg; Sat, 03 Feb 2018 10:39:40 -0500 Received: by mail-qt0-x22b.google.com with SMTP id l20so34573121qtj.11; Sat, 03 Feb 2018 07:39:40 -0800 (PST) Received: from localhost.localdomain (50-205-150-222-static.hfc.comcastbusiness.net. [50.205.150.222]) by smtp.gmail.com with ESMTPSA id z35sm3193790qtz.31.2018.02.03.07.39.38 (version=TLS1_2 cipher=ECDHE-RSA-CHACHA20-POLY1305 bits=256/256); Sat, 03 Feb 2018 07:39:38 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=sender:from:to:cc:subject:date:message-id:in-reply-to:references; bh=K6wv/wNGooE2hU2/N/EgxFyxz+FA7JnhfewXDEIhwJY=; b=gDm0AuXkoMS7eaPcv+3jj/e3j43Ffu7X89RnGXUwB3R1gtFZk4GyDPD1HYePeZsHzi 6/jUVDRJ0bGIND+ezChfG2HKmdDo1rn5yzcXU2KDkNZ2bjZqwnRMbKaIg3EG0T2s3yEb jbkirdzZPsV1+33wNq0u6mNx61hF+OQuuUuPA8XNVf6bIcswFRgxEAeoPhetTX4vETVM ajIdpfux9ww4Y+EWoyUliprNO0Z5k2dVBmfzLt4kxSiVq0+wbd46j9iVlSJWRxP0T9HQ Mjq8C3Pv5rePYuvASxT/mSWkH8AjzCaoRtkhWCOMSfRvtxytSmncZYoxPaPeimVYl786 iBig== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:sender:from:to:cc:subject:date:message-id :in-reply-to:references; bh=K6wv/wNGooE2hU2/N/EgxFyxz+FA7JnhfewXDEIhwJY=; b=NC04qNn7LPKRs/IHOzw5J1vSk2lJBNsAuYCl01FN5mpbzhyNfxlMnPKnXRXvkzTXOW IISTJ/zbWMYK+zLykZ2uyDyiGlam18Vko5nzUUsf3/7n5LCoNOJa3LVD2EqZRLeL4dry sxaAVQ6a5NT1IFq2W8Ngp0cW/0mCMBo6YvzG/EurAdPA+Aq7Ty2RCkLIzyHRxPM3dzhd G8mFNyEiDEO3MK61a70yVxLnQPfHsuXg8DpWHxsSiKQE8tzDARV6UFKF8Yj5Y11u7Ivb jZkN3DVQvK+1Hr2c4iRl4IyiJy4n4kKCZZjyCJXPBLTMHzAS+FPYyKpjFfAYU8LL9cNH /y7w== X-Gm-Message-State: APf1xPDGkJ/Kct/cP0Kb+e3A6N4ubZGydbk965sygG/68zxG+oaXdRtW 7cfuLX8zCzsHCLWslWgRg5dsmmgF X-Google-Smtp-Source: AH8x227xmGXvCkaIVAxHuoy42gouQzO9k+q36+1hFi+k6XmZNMtvZ4mpKZBUtLVEsGpDz3L9Oh0XEQ== X-Received: by 10.237.47.101 with SMTP id l92mr4009790qtd.72.1517672379506; Sat, 03 Feb 2018 07:39:39 -0800 (PST) From: Paolo Bonzini To: qemu-devel@nongnu.org Date: Sat, 3 Feb 2018 10:39:32 -0500 Message-Id: <20180203153935.8056-3-pbonzini@redhat.com> X-Mailer: git-send-email 2.14.3 In-Reply-To: <20180203153935.8056-1-pbonzini@redhat.com> References: <20180203153935.8056-1-pbonzini@redhat.com> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2607:f8b0:400d:c0d::22b Subject: [Qemu-devel] [PATCH 2/5] lockable: add QemuLockable X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: famz@redhat.com, qemu-block@nongnu.org, stefanha@redhat.com Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail-DKIM: fail (Header signature does not verify) X-ZohoMail: RDKM_2 RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" QemuLockable is a polymorphic lock type that takes an object and knows which function to use for locking and unlocking. The implementation could use C11 _Generic, but since the support is not very widespread I am instead using __builtin_choose_expr and __builtin_types_compatible_p, which are already used by include/qemu/atomic.h. QemuLockable can be used to implement lock guards, or to pass around a lock in such a way that a function can release it and re-acquire it. The next patch will do this for CoQueue. Signed-off-by: Paolo Bonzini Reviewed-by: Richard Henderson Reviewed-by: Stefan Hajnoczi --- include/qemu/compiler.h | 40 ++++++++++++++++++++ include/qemu/coroutine.h | 4 +- include/qemu/lockable.h | 96 ++++++++++++++++++++++++++++++++++++++++++++= ++++ include/qemu/thread.h | 5 +-- include/qemu/typedefs.h | 4 ++ tests/test-coroutine.c | 25 +++++++++++++ 6 files changed, 169 insertions(+), 5 deletions(-) create mode 100644 include/qemu/lockable.h diff --git a/include/qemu/compiler.h b/include/qemu/compiler.h index 340e5fdc09..5179bedb1e 100644 --- a/include/qemu/compiler.h +++ b/include/qemu/compiler.h @@ -111,4 +111,44 @@ #define GCC_FMT_ATTR(n, m) #endif =20 +/* Implement C11 _Generic via GCC builtins. Example: + * + * QEMU_GENERIC(x, (float, sinf), (long double, sinl), sin) (x) + * + * The first argument is the discriminator. The last is the default value. + * The middle ones are tuples in "(type, expansion)" format. + */ + +/* First, find out the number of generic cases. */ +#define QEMU_GENERIC(x, ...) \ + QEMU_GENERIC_(typeof(x), __VA_ARGS__, 10, 9, 8, 7, 6, 5, 4, 3, 2, 1, 0) + +/* There will be extra arguments, but they are not used. */ +#define QEMU_GENERIC_(x, a0, a1, a2, a3, a4, a5, a6, a7, a8, a9, count, ..= .) \ + QEMU_GENERIC##count(x, a0, a1, a2, a3, a4, a5, a6, a7, a8, a9) + +/* Two more helper macros, this time to extract items from a parenthesized + * list. + */ +#define QEMU_FIRST_(a, b) a +#define QEMU_SECOND_(a, b) b + +/* ... and a final one for the common part of the "recursion". */ +#define QEMU_GENERIC_IF(x, type_then, else_) = \ + __builtin_choose_expr(__builtin_types_compatible_p(x, = \ + QEMU_FIRST_ type_th= en), \ + QEMU_SECOND_ type_then, else_) + +/* CPP poor man's "recursion". */ +#define QEMU_GENERIC1(x, a0, ...) (a0) +#define QEMU_GENERIC2(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC1(x, = __VA_ARGS__)) +#define QEMU_GENERIC3(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC2(x, = __VA_ARGS__)) +#define QEMU_GENERIC4(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC3(x, = __VA_ARGS__)) +#define QEMU_GENERIC5(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC4(x, = __VA_ARGS__)) +#define QEMU_GENERIC6(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC5(x, = __VA_ARGS__)) +#define QEMU_GENERIC7(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC6(x, = __VA_ARGS__)) +#define QEMU_GENERIC8(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC7(x, = __VA_ARGS__)) +#define QEMU_GENERIC9(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC8(x, = __VA_ARGS__)) +#define QEMU_GENERIC10(x, a0, ...) QEMU_GENERIC_IF(x, a0, QEMU_GENERIC9(x,= __VA_ARGS__)) + #endif /* COMPILER_H */ diff --git a/include/qemu/coroutine.h b/include/qemu/coroutine.h index ce2eb73670..8a5129741c 100644 --- a/include/qemu/coroutine.h +++ b/include/qemu/coroutine.h @@ -121,7 +121,7 @@ bool qemu_coroutine_entered(Coroutine *co); * Provides a mutex that can be used to synchronise coroutines */ struct CoWaitRecord; -typedef struct CoMutex { +struct CoMutex { /* Count of pending lockers; 0 for a free mutex, 1 for an * uncontended mutex. */ @@ -142,7 +142,7 @@ typedef struct CoMutex { unsigned handoff, sequence; =20 Coroutine *holder; -} CoMutex; +}; =20 /** * Initialises a CoMutex. This must be called before any other operation i= s used diff --git a/include/qemu/lockable.h b/include/qemu/lockable.h new file mode 100644 index 0000000000..826ac3f675 --- /dev/null +++ b/include/qemu/lockable.h @@ -0,0 +1,96 @@ +/* + * Polymorphic locking functions (aka poor man templates) + * + * Copyright Red Hat, Inc. 2017, 2018 + * + * Author: Paolo Bonzini + * + * This work is licensed under the terms of the GNU LGPL, version 2 or lat= er. + * See the COPYING.LIB file in the top-level directory. + * + */ + +#ifndef QEMU_LOCKABLE_H +#define QEMU_LOCKABLE_H + +#include "qemu/coroutine.h" +#include "qemu/thread.h" + +typedef void QemuLockUnlockFunc(void *); + +struct QemuLockable { + void *object; + QemuLockUnlockFunc *lock; + QemuLockUnlockFunc *unlock; +}; + +/* This function gives an error if an invalid, non-NULL pointer type is pa= ssed + * to QEMU_MAKE_LOCKABLE. For optimized builds, we can rely on dead-code = elimination + * from the compiler, and give the errors already at link time. + */ +#ifdef __OPTIMIZE__ +void unknown_lock_type(void *); +#else +static inline void unknown_lock_type(void *unused) +{ + abort(); +} +#endif + +static inline __attribute__((__always_inline__)) QemuLockable * +qemu_make_lockable(void *x, QemuLockable *lockable) +{ + /* We cannot test this in a macro, otherwise we get compiler + * warnings like "the address of 'm' will always evaluate as 'true'". + */ + return x ? lockable : NULL; +} + +/* Auxiliary macros to simplify QEMU_MAKE_LOCABLE. */ +#define QEMU_LOCK_FUNC(x) ((QemuLockUnlockFunc *) \ + QEMU_GENERIC(x, \ + (QemuMutex *, qemu_mutex_lock), \ + (CoMutex *, qemu_co_mutex_lock), \ + (QemuSpin *, qemu_spin_lock), \ + unknown_lock_type)) + +#define QEMU_UNLOCK_FUNC(x) ((QemuLockUnlockFunc *) \ + QEMU_GENERIC(x, \ + (QemuMutex *, qemu_mutex_unlock), \ + (CoMutex *, qemu_co_mutex_unlock), \ + (QemuSpin *, qemu_spin_unlock), \ + unknown_lock_type)) + +/* In C, compound literals have the lifetime of an automatic variable. + * In C++ it would be different, but then C++ wouldn't need QemuLockable + * either... + */ +#define QEMU_MAKE_LOCKABLE_(x) qemu_make_lockable((x), &(QemuLockable) { = \ + .object =3D (x), \ + .lock =3D QEMU_LOCK_FUNC(x), \ + .unlock =3D QEMU_UNLOCK_FUNC(x), \ + }) + +/* QEMU_MAKE_LOCKABLE - Make a polymorphic QemuLockable + * + * @x: a lock object (currently one of QemuMutex, CoMutex, QemuSpin). + * + * Returns a QemuLockable object that can be passed around + * to a function that can operate with locks of any kind. + */ +#define QEMU_MAKE_LOCKABLE(x) \ + QEMU_GENERIC(x, \ + (QemuLockable *, (x)), \ + QEMU_MAKE_LOCKABLE_(x)) + +static inline void qemu_lockable_lock(QemuLockable *x) +{ + x->lock(x->object); +} + +static inline void qemu_lockable_unlock(QemuLockable *x) +{ + x->unlock(x->object); +} + +#endif diff --git a/include/qemu/thread.h b/include/qemu/thread.h index 9af4e945aa..ef7bd16123 100644 --- a/include/qemu/thread.h +++ b/include/qemu/thread.h @@ -4,7 +4,6 @@ #include "qemu/processor.h" #include "qemu/atomic.h" =20 -typedef struct QemuMutex QemuMutex; typedef struct QemuCond QemuCond; typedef struct QemuSemaphore QemuSemaphore; typedef struct QemuEvent QemuEvent; @@ -97,9 +96,9 @@ struct Notifier; void qemu_thread_atexit_add(struct Notifier *notifier); void qemu_thread_atexit_remove(struct Notifier *notifier); =20 -typedef struct QemuSpin { +struct QemuSpin { int value; -} QemuSpin; +}; =20 static inline void qemu_spin_init(QemuSpin *spin) { diff --git a/include/qemu/typedefs.h b/include/qemu/typedefs.h index 9bd7a834ba..5923849cdd 100644 --- a/include/qemu/typedefs.h +++ b/include/qemu/typedefs.h @@ -19,6 +19,7 @@ typedef struct BusClass BusClass; typedef struct BusState BusState; typedef struct Chardev Chardev; typedef struct CompatProperty CompatProperty; +typedef struct CoMutex CoMutex; typedef struct CPUAddressSpace CPUAddressSpace; typedef struct CPUState CPUState; typedef struct DeviceListener DeviceListener; @@ -86,9 +87,12 @@ typedef struct QEMUBH QEMUBH; typedef struct QemuConsole QemuConsole; typedef struct QemuDmaBuf QemuDmaBuf; typedef struct QEMUFile QEMUFile; +typedef struct QemuLockable QemuLockable; +typedef struct QemuMutex QemuMutex; typedef struct QemuOpt QemuOpt; typedef struct QemuOpts QemuOpts; typedef struct QemuOptsList QemuOptsList; +typedef struct QemuSpin QemuSpin; typedef struct QEMUSGList QEMUSGList; typedef struct QEMUTimer QEMUTimer; typedef struct QEMUTimerListGroup QEMUTimerListGroup; diff --git a/tests/test-coroutine.c b/tests/test-coroutine.c index 010cb95ad6..6e4842bfda 100644 --- a/tests/test-coroutine.c +++ b/tests/test-coroutine.c @@ -14,6 +14,7 @@ #include "qemu/osdep.h" #include "qemu/coroutine.h" #include "qemu/coroutine_int.h" +#include "qemu/lockable.h" =20 /* * Check that qemu_in_coroutine() works @@ -210,6 +211,18 @@ static void coroutine_fn mutex_fn(void *opaque) done++; } =20 +static void coroutine_fn lockable_fn(void *opaque) +{ + QemuLockable *x =3D opaque; + qemu_lockable_lock(x); + assert(!locked); + locked =3D true; + qemu_coroutine_yield(); + locked =3D false; + qemu_lockable_unlock(x); + done++; +} + static void do_test_co_mutex(CoroutineEntry *entry, void *opaque) { Coroutine *c1 =3D qemu_coroutine_create(entry, opaque); @@ -240,6 +253,17 @@ static void test_co_mutex(void) do_test_co_mutex(mutex_fn, &m); } =20 +static void test_co_mutex_lockable(void) +{ + CoMutex m; + CoMutex *null_pointer =3D NULL; + + qemu_co_mutex_init(&m); + do_test_co_mutex(lockable_fn, QEMU_MAKE_LOCKABLE(&m)); + + g_assert(QEMU_MAKE_LOCKABLE(null_pointer) =3D=3D NULL); +} + /* * Check that creation, enter, and return work */ @@ -478,6 +502,7 @@ int main(int argc, char **argv) g_test_add_func("/basic/in_coroutine", test_in_coroutine); g_test_add_func("/basic/order", test_order); g_test_add_func("/locking/co-mutex", test_co_mutex); + g_test_add_func("/locking/co-mutex/lockable", test_co_mutex_lockable); if (g_test_perf()) { g_test_add_func("/perf/lifecycle", perf_lifecycle); g_test_add_func("/perf/nesting", perf_nesting); --=20 2.14.3 From nobody Tue May 7 03:36:16 2024 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; dkim=fail; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=redhat.com Return-Path: Received: from lists.gnu.org (lists.gnu.org [208.118.235.17]) by mx.zohomail.com with SMTPS id 1517672721740714.9656043626889; Sat, 3 Feb 2018 07:45:21 -0800 (PST) Received: from localhost ([::1]:43926 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ei00G-0005pJ-UQ for importer@patchew.org; Sat, 03 Feb 2018 10:45:21 -0500 Received: from eggs.gnu.org ([2001:4830:134:3::10]:48274) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzup-0001g0-FY for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:44 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1ehzuo-000459-HR for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:43 -0500 Received: from mail-qk0-x242.google.com ([2607:f8b0:400d:c09::242]:44464) by eggs.gnu.org with esmtps (TLS1.0:RSA_AES_128_CBC_SHA1:16) (Exim 4.71) (envelope-from ) id 1ehzuo-00044S-CZ; Sat, 03 Feb 2018 10:39:42 -0500 Received: by mail-qk0-x242.google.com with SMTP id n188so16290588qkn.11; Sat, 03 Feb 2018 07:39:42 -0800 (PST) Received: from localhost.localdomain (50-205-150-222-static.hfc.comcastbusiness.net. [50.205.150.222]) by smtp.gmail.com with ESMTPSA id z35sm3193790qtz.31.2018.02.03.07.39.39 (version=TLS1_2 cipher=ECDHE-RSA-CHACHA20-POLY1305 bits=256/256); Sat, 03 Feb 2018 07:39:39 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=sender:from:to:cc:subject:date:message-id:in-reply-to:references; bh=LoUFZAcUcnaHqzUJBuntOgHXCp6yCt4oc9+g/EMR6lM=; b=MzydH1LtDUnTfHsXXbTHmrnsGOXavOhl061WVWwrLqTmv/W0MkFQ+/JW1UonwT0UHT 3sj6/di6jCuM72W6GfS+RQtf9sGW0tCcA1dM5GChgfYQXuBIIm2+iKLgdh2JMcCu5t+V e1twr/DtYxIyy9aXhcP+7Iec47evFgw9dGhk1Je9aO7UfX86te52ySkeSaljy802crf+ ATrEjakqLH8R30ouYwIzyuV8CTPAQI9D9l2OghZetguHckUhR+yNFJDviW6Q2wuiy0fa CuFmWewcaA3zp9HpVYO1ZYN1feJ70+IoEwtE5o5XHUml5C2ncldlrYotWuBubsG8FK97 9xsw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:sender:from:to:cc:subject:date:message-id :in-reply-to:references; bh=LoUFZAcUcnaHqzUJBuntOgHXCp6yCt4oc9+g/EMR6lM=; b=CmQ3xzDHU34rYzYpWsjzLXE/bIf7xFOvYrY+mpPvSX/5BHc5jaHr4oEVmSpgk3ch6q uMhZaWgItNbLQ53x6HmCAE3MBzM5X1UmmHxj/7PwgesQKMJyZJm+eo2CPKmyBwU1zGOS LHhVY7h/dJi2iLKWZghCtbhdmL0Pjmr5nTcgwH8eRyvNeSKch0c+aNXfH9wMF9xmFpLm 5GCyKRlnmJrSBbBFOtAP+oXAIJXhjgrT2/EmoJmhfseeOsIzzWEypUgcaB6GTk2ys0hd Zi2SjBsF26+QD4LolOWmaOeFThZ20E283o4vAH3Z/IB774lD8FRToRqOJti1GRu29RTa L3MQ== X-Gm-Message-State: APf1xPBDRnFNfzhgDuRff9o1ENgJl/V4T9O+92MVuZhMvri1OhP8WIlt MDsjTs25EmIOaVp4QJ6csHMV2R6P X-Google-Smtp-Source: AH8x226N3VfEZGQxl0eLTwVcGXgbriZJRdJtGi7/uuDADSgo1EZ9fixoDNyJmh01gTiVdQW5gB+vNA== X-Received: by 10.55.20.42 with SMTP id e42mr10571984qkh.132.1517672381489; Sat, 03 Feb 2018 07:39:41 -0800 (PST) From: Paolo Bonzini To: qemu-devel@nongnu.org Date: Sat, 3 Feb 2018 10:39:33 -0500 Message-Id: <20180203153935.8056-4-pbonzini@redhat.com> X-Mailer: git-send-email 2.14.3 In-Reply-To: <20180203153935.8056-1-pbonzini@redhat.com> References: <20180203153935.8056-1-pbonzini@redhat.com> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2607:f8b0:400d:c09::242 Subject: [Qemu-devel] [PATCH 3/5] coroutine-lock: convert CoQueue to use QemuLockable X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: famz@redhat.com, qemu-block@nongnu.org, stefanha@redhat.com Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail-DKIM: fail (Header signature does not verify) X-ZohoMail: RDKM_2 RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" There are cases in which a queued coroutine must be restarted from non-coroutine context (with qemu_co_enter_next). In this cases, qemu_co_enter_next also needs to be thread-safe, but it cannot use a CoMutex and so cannot qemu_co_queue_wait. Use QemuLockable so that the CoQueue can interchangeably use CoMutex or QemuMutex. Reviewed-by: Stefan Hajnoczi Signed-off-by: Paolo Bonzini Reviewed-by: Richard Henderson --- include/qemu/coroutine.h | 6 +++++- util/qemu-coroutine-lock.c | 12 +++++++----- 2 files changed, 12 insertions(+), 6 deletions(-) diff --git a/include/qemu/coroutine.h b/include/qemu/coroutine.h index 8a5129741c..1e5f0957e6 100644 --- a/include/qemu/coroutine.h +++ b/include/qemu/coroutine.h @@ -183,7 +183,9 @@ void qemu_co_queue_init(CoQueue *queue); * caller of the coroutine. The mutex is unlocked during the wait and * locked again afterwards. */ -void coroutine_fn qemu_co_queue_wait(CoQueue *queue, CoMutex *mutex); +#define qemu_co_queue_wait(queue, lock) \ + qemu_co_queue_wait_impl(queue, QEMU_MAKE_LOCKABLE(lock)) +void coroutine_fn qemu_co_queue_wait_impl(CoQueue *queue, QemuLockable *lo= ck); =20 /** * Restarts the next coroutine in the CoQueue and removes it from the queu= e. @@ -271,4 +273,6 @@ void coroutine_fn qemu_co_sleep_ns(QEMUClockType type, = int64_t ns); */ void coroutine_fn yield_until_fd_readable(int fd); =20 +#include "qemu/lockable.h" + #endif /* QEMU_COROUTINE_H */ diff --git a/util/qemu-coroutine-lock.c b/util/qemu-coroutine-lock.c index 846ff9167f..2a66fc1467 100644 --- a/util/qemu-coroutine-lock.c +++ b/util/qemu-coroutine-lock.c @@ -40,13 +40,13 @@ void qemu_co_queue_init(CoQueue *queue) QSIMPLEQ_INIT(&queue->entries); } =20 -void coroutine_fn qemu_co_queue_wait(CoQueue *queue, CoMutex *mutex) +void coroutine_fn qemu_co_queue_wait_impl(CoQueue *queue, QemuLockable *lo= ck) { Coroutine *self =3D qemu_coroutine_self(); QSIMPLEQ_INSERT_TAIL(&queue->entries, self, co_queue_next); =20 - if (mutex) { - qemu_co_mutex_unlock(mutex); + if (lock) { + qemu_lockable_unlock(lock); } =20 /* There is no race condition here. Other threads will call @@ -60,9 +60,11 @@ void coroutine_fn qemu_co_queue_wait(CoQueue *queue, CoM= utex *mutex) /* TODO: OSv implements wait morphing here, where the wakeup * primitive automatically places the woken coroutine on the * mutex's queue. This avoids the thundering herd effect. + * This could be implemented for CoMutexes, but not really for + * other cases of QemuLockable. */ - if (mutex) { - qemu_co_mutex_lock(mutex); + if (lock) { + qemu_lockable_lock(lock); } } =20 --=20 2.14.3 From nobody Tue May 7 03:36:16 2024 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; dkim=fail; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=redhat.com Return-Path: Received: from lists.gnu.org (lists.gnu.org [208.118.235.17]) by mx.zohomail.com with SMTPS id 1517672535057470.9729373171989; Sat, 3 Feb 2018 07:42:15 -0800 (PST) Received: from localhost ([::1]:43647 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzxG-0003Ca-5r for importer@patchew.org; Sat, 03 Feb 2018 10:42:14 -0500 Received: from eggs.gnu.org ([2001:4830:134:3::10]:48302) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzuq-0001gj-Fm for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:46 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1ehzup-000465-H8 for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:44 -0500 Received: from mail-qk0-x241.google.com ([2607:f8b0:400d:c09::241]:43921) by eggs.gnu.org with esmtps (TLS1.0:RSA_AES_128_CBC_SHA1:16) (Exim 4.71) (envelope-from ) id 1ehzup-00045r-Ck; Sat, 03 Feb 2018 10:39:43 -0500 Received: by mail-qk0-x241.google.com with SMTP id a5so27668657qkg.10; Sat, 03 Feb 2018 07:39:43 -0800 (PST) Received: from localhost.localdomain (50-205-150-222-static.hfc.comcastbusiness.net. [50.205.150.222]) by smtp.gmail.com with ESMTPSA id z35sm3193790qtz.31.2018.02.03.07.39.41 (version=TLS1_2 cipher=ECDHE-RSA-CHACHA20-POLY1305 bits=256/256); Sat, 03 Feb 2018 07:39:41 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=sender:from:to:cc:subject:date:message-id:in-reply-to:references; bh=TAyPcChUbYxGtepxj1z0oJi1t5ofsBGEuvVnnYjiqww=; b=KLydh53sp/SWmzTwq66SVoiB/O88Z8jMTT3RNdpCdFUgn3uXne/Olht/2zp7PjWGKv G0UjGWI1PpxBSYe0vD7thHQnSv6N7xsXuQUDi+FE5u5aMXihdtJQxhYF13ofrfrDZsmG Jx+3bVlmBLEEkfV3Z2Bb4wK4qdUzt5NNNU+bVPO+J8Zt+7tPuasQWKfK4ZLgSMWXZ2Mv HMG5qGNhK3sSYJ4Bj/qRT3x5ALpeApSAObHGuF4p62mkfOOioNsQJJTRg9yorVsjO572 yZKkZklT+DfG9gjdnz1g7Et+GNarGIQU9cq9TUShqbJqIfa/F92IPjh5tItV9TiAeMTY yMsg== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:sender:from:to:cc:subject:date:message-id :in-reply-to:references; bh=TAyPcChUbYxGtepxj1z0oJi1t5ofsBGEuvVnnYjiqww=; b=S7O0AVC/Mk3JjjpBE3MmsiMxwpUJRxyXv4yQovYryo79qdsSPDcyUY1UOjZS+NzBn6 kMOLKhwfFO/fDTmT7gCikfE15/QD8U0Ao+nl5RuRVT/g0hrvAmy2SkOM3r2AG9U6tyxl VqW5332Rhr932KE44E8E6mUdflYhFq539vEZKT7l0UuLnQ2zuB1Mo1QoJ/U9YNWBLzNA RElSEmjJyVk1ZqJMK1JqwJ1wypeAQdfSpT0bPENoyyhQURrWIeKHfgAP/LX2fH2EKWje 4Jr5gj9XEsqDKtq2O8+8gwyGhVjnNHH3oDTzCf0zLSbrXnNQwl/0T/IvsHkLV3m9LDvv jdog== X-Gm-Message-State: APf1xPDJKme7tdkC0hI28jQ/jjC5Z/s3Rb8ghG1Hof/yR/yWTLjHIn4C FE5UtNSSovZHN0HXLz79AJYL0oy8 X-Google-Smtp-Source: AH8x2245mYyZXb9tSo9kr1uAwMIOln1cbm79Ve6+asORh99XKtVhbkXPdj8yH7ze0ylOksr9E61fYg== X-Received: by 10.55.26.234 with SMTP id l103mr13081478qkh.237.1517672382497; Sat, 03 Feb 2018 07:39:42 -0800 (PST) From: Paolo Bonzini To: qemu-devel@nongnu.org Date: Sat, 3 Feb 2018 10:39:34 -0500 Message-Id: <20180203153935.8056-5-pbonzini@redhat.com> X-Mailer: git-send-email 2.14.3 In-Reply-To: <20180203153935.8056-1-pbonzini@redhat.com> References: <20180203153935.8056-1-pbonzini@redhat.com> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2607:f8b0:400d:c09::241 Subject: [Qemu-devel] [PATCH 4/5] coroutine-lock: make qemu_co_enter_next thread-safe X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: famz@redhat.com, qemu-block@nongnu.org, stefanha@redhat.com Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail-DKIM: fail (Header signature does not verify) X-ZohoMail: RDKM_2 RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" qemu_co_queue_next does not need to release and re-acquire the mutex, because the queued coroutine does not run immediately. However, this does not hold for qemu_co_enter_next. Now that qemu_co_queue_wait can synchronize (via QemuLockable) with code that is not running in coroutine context, it's important that code using qemu_co_enter_next can easily use a standardized locking idiom. First of all, qemu_co_enter_next must use aio_co_wake to restart the coroutine. Second, the function gains a second argument, a QemuLockable*, and the comments of qemu_co_queue_next and qemu_co_queue_restart_all are adjusted to clarify the difference. Signed-off-by: Paolo Bonzini Reviewed-by: Stefan Hajnoczi --- fsdev/qemu-fsdev-throttle.c | 4 ++-- include/qemu/coroutine.h | 19 +++++++++++++------ util/qemu-coroutine-lock.c | 10 ++++++++-- 3 files changed, 23 insertions(+), 10 deletions(-) diff --git a/fsdev/qemu-fsdev-throttle.c b/fsdev/qemu-fsdev-throttle.c index 49eebb5412..1dc07fbc12 100644 --- a/fsdev/qemu-fsdev-throttle.c +++ b/fsdev/qemu-fsdev-throttle.c @@ -20,13 +20,13 @@ static void fsdev_throttle_read_timer_cb(void *opaque) { FsThrottle *fst =3D opaque; - qemu_co_enter_next(&fst->throttled_reqs[false]); + qemu_co_enter_next(&fst->throttled_reqs[false], NULL); } =20 static void fsdev_throttle_write_timer_cb(void *opaque) { FsThrottle *fst =3D opaque; - qemu_co_enter_next(&fst->throttled_reqs[true]); + qemu_co_enter_next(&fst->throttled_reqs[true], NULL); } =20 void fsdev_throttle_parse_opts(QemuOpts *opts, FsThrottle *fst, Error **er= rp) diff --git a/include/qemu/coroutine.h b/include/qemu/coroutine.h index 1e5f0957e6..3afee7169b 100644 --- a/include/qemu/coroutine.h +++ b/include/qemu/coroutine.h @@ -188,21 +188,28 @@ void qemu_co_queue_init(CoQueue *queue); void coroutine_fn qemu_co_queue_wait_impl(CoQueue *queue, QemuLockable *lo= ck); =20 /** - * Restarts the next coroutine in the CoQueue and removes it from the queu= e. - * - * Returns true if a coroutine was restarted, false if the queue is empty. + * Removes the next coroutine from the CoQueue, and wake it up. + * Returns true if a coroutine was removed, false if the queue is empty. */ bool coroutine_fn qemu_co_queue_next(CoQueue *queue); =20 /** - * Restarts all coroutines in the CoQueue and leaves the queue empty. + * Empties the CoQueue; all coroutines are woken up. */ void coroutine_fn qemu_co_queue_restart_all(CoQueue *queue); =20 /** - * Enter the next coroutine in the queue + * Removes the next coroutine from the CoQueue, and wake it up. Unlike + * qemu_co_queue_next, this function releases the lock during aio_co_wake + * because it is meant to be used outside coroutine context; in that case,= the + * coroutine is entered immediately, before qemu_co_enter_next returns. + * + * If used in coroutine context, qemu_co_enter_next is equivalent to + * qemu_co_queue_next. */ -bool qemu_co_enter_next(CoQueue *queue); +#define qemu_co_enter_next(queue, lock) \ + qemu_co_enter_next_impl(queue, QEMU_MAKE_LOCKABLE(lock)) +bool qemu_co_enter_next_impl(CoQueue *queue, QemuLockable *lock); =20 /** * Checks if the CoQueue is empty. diff --git a/util/qemu-coroutine-lock.c b/util/qemu-coroutine-lock.c index 2a66fc1467..78fb79acf8 100644 --- a/util/qemu-coroutine-lock.c +++ b/util/qemu-coroutine-lock.c @@ -132,7 +132,7 @@ void coroutine_fn qemu_co_queue_restart_all(CoQueue *qu= eue) qemu_co_queue_do_restart(queue, false); } =20 -bool qemu_co_enter_next(CoQueue *queue) +bool qemu_co_enter_next_impl(CoQueue *queue, QemuLockable *lock) { Coroutine *next; =20 @@ -142,7 +142,13 @@ bool qemu_co_enter_next(CoQueue *queue) } =20 QSIMPLEQ_REMOVE_HEAD(&queue->entries, co_queue_next); - qemu_coroutine_enter(next); + if (lock) { + qemu_lockable_unlock(lock); + } + aio_co_wake(next); + if (lock) { + qemu_lockable_lock(lock); + } return true; } =20 --=20 2.14.3 From nobody Tue May 7 03:36:16 2024 Delivered-To: importer@patchew.org Received-SPF: pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) client-ip=208.118.235.17; envelope-from=qemu-devel-bounces+importer=patchew.org@nongnu.org; helo=lists.gnu.org; Authentication-Results: mx.zohomail.com; dkim=fail; spf=pass (zoho.com: domain of gnu.org designates 208.118.235.17 as permitted sender) smtp.mailfrom=qemu-devel-bounces+importer=patchew.org@nongnu.org; dmarc=fail(p=none dis=none) header.from=redhat.com Return-Path: Received: from lists.gnu.org (lists.gnu.org [208.118.235.17]) by mx.zohomail.com with SMTPS id 1517672549685774.4221423396039; Sat, 3 Feb 2018 07:42:29 -0800 (PST) Received: from localhost ([::1]:43648 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzxU-0003LO-Ms for importer@patchew.org; Sat, 03 Feb 2018 10:42:28 -0500 Received: from eggs.gnu.org ([2001:4830:134:3::10]:48314) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1ehzur-0001hX-CI for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:46 -0500 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1ehzuq-00047g-Dw for qemu-devel@nongnu.org; Sat, 03 Feb 2018 10:39:45 -0500 Received: from mail-qk0-x241.google.com ([2607:f8b0:400d:c09::241]:44464) by eggs.gnu.org with esmtps (TLS1.0:RSA_AES_128_CBC_SHA1:16) (Exim 4.71) (envelope-from ) id 1ehzuq-00046l-9N; Sat, 03 Feb 2018 10:39:44 -0500 Received: by mail-qk0-x241.google.com with SMTP id n188so16290637qkn.11; Sat, 03 Feb 2018 07:39:44 -0800 (PST) Received: from localhost.localdomain (50-205-150-222-static.hfc.comcastbusiness.net. [50.205.150.222]) by smtp.gmail.com with ESMTPSA id z35sm3193790qtz.31.2018.02.03.07.39.42 (version=TLS1_2 cipher=ECDHE-RSA-CHACHA20-POLY1305 bits=256/256); Sat, 03 Feb 2018 07:39:42 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=sender:from:to:cc:subject:date:message-id:in-reply-to:references; bh=2YvlCWabKdL+I8FjttoOo1yKaWZ0H0Kvr+485G3eEP8=; b=KFIPTymhMhUekB+JACmWsKUjXsmepYm+507Iwsi5ePqWjJHGB6VxSn2IYbs3VAOFU8 QUixL7CYH5wpNlX4XgVpE1PGbSnHcLnBfhEK7YaPB0+Wp5ujMgMOUg2CmI+J5IO4Ej15 oMDtmU8mgkBsmvwJkbgH5kJx5Y5ao0pm/C2upFa1u4zO/4winlcXnwFMDevWLlffZs6I NH2mHfuragb/vjqYLYuAVafASPmDg+BqYDpIR6nCYM0BHIL2IwdHoIke2NoUFa754nUa Zhv3I0bb15f3r1vJb4B6wVKc1P4VWgaiQrrN7npCk0pRfNankhlx8je7sHVpU1Zf9YY+ 4XpA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:sender:from:to:cc:subject:date:message-id :in-reply-to:references; bh=2YvlCWabKdL+I8FjttoOo1yKaWZ0H0Kvr+485G3eEP8=; b=esu16z/qb5T9k1JnxEcjCp053Qi/GYZ81uwrKFzkK+dy4t2UeQ2mkPA1QX22e5LCEb cA/8Wfk0liBbaJoIR7pBB5KWSPQTHnkGwBOYExI0X05KwMpvuLMrXM5AMHU7WPTwscMV bNPmAe5VTqvCUrPquvodV9AeVvtU9A9HiP1HKo7dxzRhv7qUg7nvgqNsqFQFLbTJrYYJ mTEcUA49HF7DPsGimmuN6EZRB07u27+wrjuQydcXMkMiJpbcj8Zb/1hFdyrwgWgRaW1Z 1iu5bXtgZDIdk3Am5cdQy7guzuU9x2osLb+6g+GLRFuir9zt3rYRoyT/nJZqOTZ4WdeW 4dPQ== X-Gm-Message-State: APf1xPAZsWIberbLfXHyp78MRRIdS9kGiC7xauhEQsWReZwYJpS/yohU rZ/l2NAEoxGRAJFZH1ZdK7axsxRC X-Google-Smtp-Source: AH8x227RRUChTAullDwX0Gf/NUvUiBhWzUKmO10AAcj1Jwg8WKDVpSoz75kZjtGmzsZeSK2bffhrew== X-Received: by 10.55.139.132 with SMTP id n126mr8512628qkd.299.1517672383492; Sat, 03 Feb 2018 07:39:43 -0800 (PST) From: Paolo Bonzini To: qemu-devel@nongnu.org Date: Sat, 3 Feb 2018 10:39:35 -0500 Message-Id: <20180203153935.8056-6-pbonzini@redhat.com> X-Mailer: git-send-email 2.14.3 In-Reply-To: <20180203153935.8056-1-pbonzini@redhat.com> References: <20180203153935.8056-1-pbonzini@redhat.com> X-detected-operating-system: by eggs.gnu.org: Genre and OS details not recognized. X-Received-From: 2607:f8b0:400d:c09::241 Subject: [Qemu-devel] [PATCH 5/5] curl: convert to CoQueue X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.21 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: famz@redhat.com, qemu-block@nongnu.org, stefanha@redhat.com Errors-To: qemu-devel-bounces+importer=patchew.org@nongnu.org Sender: "Qemu-devel" X-ZohoMail-DKIM: fail (Header signature does not verify) X-ZohoMail: RDKM_2 RSF_0 Z_629925259 SPT_0 Content-Transfer-Encoding: quoted-printable MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Now that CoQueues can use a QemuMutex for thread-safety, there is no need for curl to roll its own coroutine queue. Coroutines can be placed directly on the queue instead of using a list of CURLAIOCBs. Reviewed-by: Stefan Hajnoczi Signed-off-by: Paolo Bonzini --- block/curl.c | 20 ++++---------------- 1 file changed, 4 insertions(+), 16 deletions(-) diff --git a/block/curl.c b/block/curl.c index 35cf417f59..cd578d3d14 100644 --- a/block/curl.c +++ b/block/curl.c @@ -101,8 +101,6 @@ typedef struct CURLAIOCB { =20 size_t start; size_t end; - - QSIMPLEQ_ENTRY(CURLAIOCB) next; } CURLAIOCB; =20 typedef struct CURLSocket { @@ -138,7 +136,7 @@ typedef struct BDRVCURLState { bool accept_range; AioContext *aio_context; QemuMutex mutex; - QSIMPLEQ_HEAD(, CURLAIOCB) free_state_waitq; + CoQueue free_state_waitq; char *username; char *password; char *proxyusername; @@ -538,7 +536,6 @@ static int curl_init_state(BDRVCURLState *s, CURLState = *state) /* Called with s->mutex held. */ static void curl_clean_state(CURLState *s) { - CURLAIOCB *next; int j; for (j =3D 0; j < CURL_NUM_ACB; j++) { assert(!s->acb[j]); @@ -556,13 +553,7 @@ static void curl_clean_state(CURLState *s) =20 s->in_use =3D 0; =20 - next =3D QSIMPLEQ_FIRST(&s->s->free_state_waitq); - if (next) { - QSIMPLEQ_REMOVE_HEAD(&s->s->free_state_waitq, next); - qemu_mutex_unlock(&s->s->mutex); - aio_co_wake(next->co); - qemu_mutex_lock(&s->s->mutex); - } + qemu_co_enter_next(&s->s->free_state_waitq, &s->s->mutex); } =20 static void curl_parse_filename(const char *filename, QDict *options, @@ -784,7 +775,7 @@ static int curl_open(BlockDriverState *bs, QDict *optio= ns, int flags, } =20 DPRINTF("CURL: Opening %s\n", file); - QSIMPLEQ_INIT(&s->free_state_waitq); + qemu_co_queue_init(&s->free_state_waitq); s->aio_context =3D bdrv_get_aio_context(bs); s->url =3D g_strdup(file); qemu_mutex_lock(&s->mutex); @@ -888,10 +879,7 @@ static void curl_setup_preadv(BlockDriverState *bs, CU= RLAIOCB *acb) if (state) { break; } - QSIMPLEQ_INSERT_TAIL(&s->free_state_waitq, acb, next); - qemu_mutex_unlock(&s->mutex); - qemu_coroutine_yield(); - qemu_mutex_lock(&s->mutex); + qemu_co_queue_wait(&s->free_state_waitq, &s->mutex); } =20 if (curl_init_state(s, state) < 0) { --=20 2.14.3