[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [RFC][PATCH 12/12] qcow2: Serialize all requests
From: |
Stefan Hajnoczi |
Subject: |
[Qemu-devel] [RFC][PATCH 12/12] qcow2: Serialize all requests |
Date: |
Sat, 22 Jan 2011 09:29:27 +0000 |
QCOW2 with coroutines is not safe because synchronous code paths are no
longer guaranteed to execute without interference from pending requests.
A blocking call like bdrv_pread() causes the coroutine to yield and
another request can be processed during that time, causing to race
conditions or interference between pending requests.
The simple solution is to serialize all requests. This is bad for
performance and a fine-grained solution needs to be implemented in
future patches.
Using this patch, QCOW2 with coroutines can reliably install a RHEL6 VM
with a virtio-blk disk.
Signed-off-by: Stefan Hajnoczi <address@hidden>
---
block/qcow2.c | 21 ++++++++++++++++++++-
block/qcow2.h | 5 +++--
2 files changed, 23 insertions(+), 3 deletions(-)
diff --git a/block/qcow2.c b/block/qcow2.c
index 4b33ef3..0cea0e8 100644
--- a/block/qcow2.c
+++ b/block/qcow2.c
@@ -231,6 +231,7 @@ static int qcow2_open(BlockDriverState *bs, int flags)
}
QLIST_INIT(&s->cluster_allocs);
+ QTAILQ_INIT(&s->request_list);
/* read qcow2 extensions */
if (header.backing_file_offset) {
@@ -365,6 +366,7 @@ typedef struct QCowAIOCB {
QEMUBH *bh;
QCowL2Meta l2meta;
QLIST_ENTRY(QCowAIOCB) next_depend;
+ QTAILQ_ENTRY(QCowAIOCB) next_request;
Coroutine *coroutine;
int ret; /* return code for user callback */
} QCowAIOCB;
@@ -385,11 +387,20 @@ static AIOPool qcow2_aio_pool = {
static void qcow2_aio_bh(void *opaque)
{
QCowAIOCB *acb = opaque;
+ BDRVQcowState *s = acb->common.bs->opaque;
+
qemu_bh_delete(acb->bh);
acb->bh = NULL;
acb->common.cb(acb->common.opaque, acb->ret);
qemu_iovec_destroy(&acb->hd_qiov);
+ QTAILQ_REMOVE(&s->request_list, acb, next_request);
qemu_aio_release(acb);
+
+ /* Start next request */
+ if (!QTAILQ_EMPTY(&s->request_list)) {
+ acb = QTAILQ_FIRST(&s->request_list);
+ qemu_coroutine_enter(acb->coroutine, acb);
+ }
}
static int qcow2_schedule_bh(QEMUBHFunc *cb, QCowAIOCB *acb)
@@ -548,8 +559,10 @@ static BlockDriverAIOCB *qcow2_aio_setup(BlockDriverState
*bs,
int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
BlockDriverCompletionFunc *cb, void *opaque, int is_write)
{
+ BDRVQcowState *s = bs->opaque;
QCowAIOCB *acb;
Coroutine *coroutine;
+ int start_request;
acb = qemu_aio_get(&qcow2_aio_pool, bs, cb, opaque);
if (!acb)
@@ -569,7 +582,13 @@ static BlockDriverAIOCB *qcow2_aio_setup(BlockDriverState
*bs,
coroutine = qemu_coroutine_create(is_write ? qcow2_co_write
: qcow2_co_read);
acb->coroutine = coroutine;
- qemu_coroutine_enter(coroutine, acb);
+
+ /* Kick off the request if no others are currently executing */
+ start_request = QTAILQ_EMPTY(&s->request_list);
+ QTAILQ_INSERT_TAIL(&s->request_list, acb, next_request);
+ if (start_request) {
+ qemu_coroutine_enter(coroutine, acb);
+ }
return &acb->common;
}
diff --git a/block/qcow2.h b/block/qcow2.h
index 5217bea..159f86b 100644
--- a/block/qcow2.h
+++ b/block/qcow2.h
@@ -78,6 +78,8 @@ typedef struct QCowSnapshot {
uint64_t vm_clock_nsec;
} QCowSnapshot;
+struct QCowAIOCB;
+
typedef struct BDRVQcowState {
int cluster_bits;
int cluster_size;
@@ -98,6 +100,7 @@ typedef struct BDRVQcowState {
uint8_t *cluster_data;
uint64_t cluster_cache_offset;
QLIST_HEAD(QCowClusterAlloc, QCowL2Meta) cluster_allocs;
+ QTAILQ_HEAD(, QCowAIOCB) request_list;
uint64_t *refcount_table;
uint64_t refcount_table_offset;
@@ -128,8 +131,6 @@ typedef struct QCowCreateState {
int64_t refcount_block_offset;
} QCowCreateState;
-struct QCowAIOCB;
-
/* XXX This could be private for qcow2-cluster.c */
typedef struct QCowL2Meta
{
--
1.7.2.3
- [Qemu-devel] [RFC][PATCH 00/12] qcow2: Convert qcow2 to use coroutines for async I/O, Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 07/12] coroutine: Add coroutine_is_leader(), Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 08/12] coroutine: Add qemu_in_coroutine(), Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 04/12] coroutine: Use thread-local leader and current variables, Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 09/12] block: Add bdrv_co_readv() and bdrv_co_writev(), Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 10/12] block: Add coroutine support to synchronous I/O functions, Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 06/12] coroutine: Add qemu_coroutine_self(), Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 12/12] qcow2: Serialize all requests,
Stefan Hajnoczi <=
- [Qemu-devel] [RFC][PATCH 05/12] coroutine: Add coroutines, Stefan Hajnoczi, 2011/01/22
- [Qemu-devel] [RFC][PATCH 11/12] qcow2: Convert qcow2 to use coroutines for async I/O, Stefan Hajnoczi, 2011/01/22