From mboxrd@z Thu Jan  1 00:00:00 1970
Received: from mailman by lists.gnu.org with tmda-scanned (Exim 4.43)
	id 1MSzzL-0005CY-78
	for qemu-devel@nongnu.org; Mon, 20 Jul 2009 17:01:35 -0400
Received: from exim by lists.gnu.org with spam-scanned (Exim 4.43)
	id 1MSzzF-0005CJ-R8
	for qemu-devel@nongnu.org; Mon, 20 Jul 2009 17:01:33 -0400
Received: from [199.232.76.173] (port=45984 helo=monty-python.gnu.org)
	by lists.gnu.org with esmtp (Exim 4.43) id 1MSzzF-0005CG-L7
	for qemu-devel@nongnu.org; Mon, 20 Jul 2009 17:01:29 -0400
Received: from phong.sigbus.net ([65.49.35.42]:58037)
	by monty-python.gnu.org with esmtps
	(TLS-1.0:DHE_RSA_AES_256_CBC_SHA1:32) (Exim 4.60)
	(envelope-from <nolan@voxel.sigbus.net>) id 1MSzzF-0008Sc-3g
	for qemu-devel@nongnu.org; Mon, 20 Jul 2009 17:01:29 -0400
Received: from localhost (unknown [71.198.47.97])
	by phong.sigbus.net (Postfix) with ESMTPSA id B7F0795C0D8
	for <qemu-devel@nongnu.org>; Mon, 20 Jul 2009 14:01:26 -0700 (PDT)
From: Nolan <nolan@sigbus.net>
Content-Type: text/plain
Content-Transfer-Encoding: 7bit
Date: Mon, 20 Jul 2009 14:01:25 -0700
Message-Id: <1248123685.4449.232.camel@voxel>
Mime-Version: 1.0
Subject: [Qemu-devel] [PATCH] Handle BH's queued by AIO completions in
	qemu_aio_flush()
List-Id: qemu-devel.nongnu.org
List-Unsubscribe: <http://lists.nongnu.org/mailman/listinfo/qemu-devel>,
	<mailto:qemu-devel-request@nongnu.org?subject=unsubscribe>
List-Archive: <http://lists.gnu.org/pipermail/qemu-devel>
List-Post: <mailto:qemu-devel@nongnu.org>
List-Help: <mailto:qemu-devel-request@nongnu.org?subject=help>
List-Subscribe: <http://lists.nongnu.org/mailman/listinfo/qemu-devel>,
	<mailto:qemu-devel-request@nongnu.org?subject=subscribe>
To: "qemu-devel@nongnu.org" <qemu-devel@nongnu.org>

Without this, the call to qemu_aio_flush during migration doesn't
actually flush all in-flight SCSI IOs.

Signed-off-by: Nolan Leake <nolan <at> sigbus.net>

diff --git a/aio.c b/aio.c
index dc9b85d..efc63fd 100644
--- a/aio.c
+++ b/aio.c
@@ -112,7 +112,7 @@ void qemu_aio_flush(void)
         LIST_FOREACH(node, &aio_handlers, node) {
             ret |= node->io_flush(node->opaque);
         }
-    } while (ret > 0);
+    } while (qemu_bh_poll() || ret > 0);
 }
 
 void qemu_aio_wait(void)