[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH v2 03/17] tests: adjust test-aio to new aio_poll
From: |
Paolo Bonzini |
Subject: |
Re: [Qemu-devel] [PATCH v2 03/17] tests: adjust test-aio to new aio_poll() semantics |
Date: |
Wed, 17 Apr 2013 15:12:36 +0200 |
User-agent: |
Mozilla/5.0 (X11; Linux x86_64; rv:17.0) Gecko/20130311 Thunderbird/17.0.4 |
Il 17/04/2013 15:07, Stefan Hajnoczi ha scritto:
> aio_poll(ctx, true) will soon block if any fd handlers have been set.
> Previously it would only block when .io_flush() returned true.
>
> This means that callers must check their wait condition *before*
> aio_poll() to avoid deadlock.
>
> Signed-off-by: Stefan Hajnoczi <address@hidden>
> ---
> tests/test-aio.c | 26 +++++++++++++++++---------
> 1 file changed, 17 insertions(+), 9 deletions(-)
>
> diff --git a/tests/test-aio.c b/tests/test-aio.c
> index c173870..20bf5e6 100644
> --- a/tests/test-aio.c
> +++ b/tests/test-aio.c
> @@ -15,6 +15,13 @@
>
> AioContext *ctx;
>
> +typedef struct {
> + EventNotifier e;
> + int n;
> + int active;
> + bool auto_set;
> +} EventNotifierTestData;
> +
> /* Wait until there are no more BHs or AIO requests */
> static void wait_for_aio(void)
> {
> @@ -23,6 +30,14 @@ static void wait_for_aio(void)
> }
> }
>
> +/* Wait until event notifier becomes inactive */
> +static void wait_until_inactive(EventNotifierTestData *data)
> +{
> + while (data->active > 0) {
> + aio_poll(ctx, true);
> + }
> +}
> +
> /* Simple callbacks for testing. */
>
> typedef struct {
> @@ -50,13 +65,6 @@ static void bh_delete_cb(void *opaque)
> }
> }
>
> -typedef struct {
> - EventNotifier e;
> - int n;
> - int active;
> - bool auto_set;
> -} EventNotifierTestData;
> -
> static int event_active_cb(EventNotifier *e)
> {
> EventNotifierTestData *data = container_of(e, EventNotifierTestData, e);
> @@ -281,7 +289,7 @@ static void test_flush_event_notifier(void)
> g_assert_cmpint(data.active, ==, 9);
> g_assert(aio_poll(ctx, false));
>
> - wait_for_aio();
> + wait_until_inactive(&data);
> g_assert_cmpint(data.n, ==, 10);
> g_assert_cmpint(data.active, ==, 0);
> g_assert(!aio_poll(ctx, false));
> @@ -325,7 +333,7 @@ static void test_wait_event_notifier_noflush(void)
> g_assert_cmpint(data.n, ==, 2);
>
> event_notifier_set(&dummy.e);
> - wait_for_aio();
> + wait_until_inactive(&dummy);
> g_assert_cmpint(data.n, ==, 2);
> g_assert_cmpint(dummy.n, ==, 1);
> g_assert_cmpint(dummy.active, ==, 0);
>
Reviewed-by: Polo Bonzini <address@hidden>
- [Qemu-devel] [PATCH v2 09/17] block/linux-aio: drop qemu_laio_completion_cb(), (continued)
- [Qemu-devel] [PATCH v2 09/17] block/linux-aio: drop qemu_laio_completion_cb(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 10/17] block/nbd: drop nbd_have_request(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 02/17] dataplane/virtio-blk: check exit conditions before aio_poll(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 05/17] aio: stop using .io_flush(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 04/17] tests: adjust test-thread-pool to new aio_poll() semantics, Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 13/17] block/ssh: drop return_true(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 03/17] tests: adjust test-aio to new aio_poll() semantics, Stefan Hajnoczi, 2013/04/17
- Re: [Qemu-devel] [PATCH v2 03/17] tests: adjust test-aio to new aio_poll() semantics,
Paolo Bonzini <=
- [Qemu-devel] [PATCH v2 08/17] block/iscsi: drop iscsi_process_flush(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 12/17] block/sheepdog: drop have_co_req() and aio_flush_request(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 16/17] tests: drop event_active_cb(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 11/17] block/rbd: drop qemu_rbd_aio_flush_cb(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 07/17] block/gluster: drop qemu_gluster_aio_flush_cb(), Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 17/17] aio: drop io_flush argument, Stefan Hajnoczi, 2013/04/17
- [Qemu-devel] [PATCH v2 15/17] thread-pool: drop thread_pool_active(), Stefan Hajnoczi, 2013/04/17