9ae3a8
From 6a307262a0a30089eff547a9e6489ae8fd9d242d Mon Sep 17 00:00:00 2001
9ae3a8
From: Paolo Bonzini <pbonzini@redhat.com>
9ae3a8
Date: Fri, 18 Oct 2013 08:14:32 +0200
9ae3a8
Subject: [PATCH 07/81] block: remove bdrv_is_allocated_above/bdrv_co_is_allocated_above distinction
9ae3a8
9ae3a8
RH-Author: Paolo Bonzini <pbonzini@redhat.com>
9ae3a8
Message-id: <1382084091-16636-8-git-send-email-pbonzini@redhat.com>
9ae3a8
Patchwork-id: 54990
9ae3a8
O-Subject: [RHEL 7.0 qemu-kvm PATCH 07/26] block: remove bdrv_is_allocated_above/bdrv_co_is_allocated_above distinction
9ae3a8
Bugzilla: 989646
9ae3a8
RH-Acked-by: Stefan Hajnoczi <stefanha@redhat.com>
9ae3a8
RH-Acked-by: Max Reitz <mreitz@redhat.com>
9ae3a8
RH-Acked-by: Kevin Wolf <kwolf@redhat.com>
9ae3a8
9ae3a8
Now that bdrv_is_allocated detects coroutine context, the two can
9ae3a8
use the same code.
9ae3a8
9ae3a8
Reviewed-by: Eric Blake <eblake@redhat.com>
9ae3a8
Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
9ae3a8
(cherry picked from commit 4f5786376e41980e78af45a123c56ebdc5295099)
9ae3a8
---
9ae3a8
 block.c               | 46 ++++------------------------------------------
9ae3a8
 block/commit.c        |  6 +++---
9ae3a8
 block/mirror.c        |  4 ++--
9ae3a8
 block/stream.c        |  4 ++--
9ae3a8
 include/block/block.h |  4 ----
9ae3a8
 5 files changed, 11 insertions(+), 53 deletions(-)
9ae3a8
9ae3a8
Signed-off-by: Miroslav Rezanina <mrezanin@redhat.com>
9ae3a8
---
9ae3a8
 block.c               |   46 ++++------------------------------------------
9ae3a8
 block/commit.c        |    6 +++---
9ae3a8
 block/mirror.c        |    4 ++--
9ae3a8
 block/stream.c        |    4 ++--
9ae3a8
 include/block/block.h |    4 ----
9ae3a8
 5 files changed, 11 insertions(+), 53 deletions(-)
9ae3a8
9ae3a8
diff --git a/block.c b/block.c
9ae3a8
index 9ea8221..46d9420 100644
9ae3a8
--- a/block.c
9ae3a8
+++ b/block.c
9ae3a8
@@ -3110,10 +3110,10 @@ int bdrv_is_allocated(BlockDriverState *bs, int64_t sector_num, int nb_sectors,
9ae3a8
  *  allocated/unallocated state.
9ae3a8
  *
9ae3a8
  */
9ae3a8
-int coroutine_fn bdrv_co_is_allocated_above(BlockDriverState *top,
9ae3a8
-                                            BlockDriverState *base,
9ae3a8
-                                            int64_t sector_num,
9ae3a8
-                                            int nb_sectors, int *pnum)
9ae3a8
+int bdrv_is_allocated_above(BlockDriverState *top,
9ae3a8
+                            BlockDriverState *base,
9ae3a8
+                            int64_t sector_num,
9ae3a8
+                            int nb_sectors, int *pnum)
9ae3a8
 {
9ae3a8
     BlockDriverState *intermediate;
9ae3a8
     int ret, n = nb_sectors;
9ae3a8
@@ -3149,44 +3149,6 @@ int coroutine_fn bdrv_co_is_allocated_above(BlockDriverState *top,
9ae3a8
     return 0;
9ae3a8
 }
9ae3a8
 
9ae3a8
-/* Coroutine wrapper for bdrv_is_allocated_above() */
9ae3a8
-static void coroutine_fn bdrv_is_allocated_above_co_entry(void *opaque)
9ae3a8
-{
9ae3a8
-    BdrvCoIsAllocatedData *data = opaque;
9ae3a8
-    BlockDriverState *top = data->bs;
9ae3a8
-    BlockDriverState *base = data->base;
9ae3a8
-
9ae3a8
-    data->ret = bdrv_co_is_allocated_above(top, base, data->sector_num,
9ae3a8
-                                           data->nb_sectors, data->pnum);
9ae3a8
-    data->done = true;
9ae3a8
-}
9ae3a8
-
9ae3a8
-/*
9ae3a8
- * Synchronous wrapper around bdrv_co_is_allocated_above().
9ae3a8
- *
9ae3a8
- * See bdrv_co_is_allocated_above() for details.
9ae3a8
- */
9ae3a8
-int bdrv_is_allocated_above(BlockDriverState *top, BlockDriverState *base,
9ae3a8
-                            int64_t sector_num, int nb_sectors, int *pnum)
9ae3a8
-{
9ae3a8
-    Coroutine *co;
9ae3a8
-    BdrvCoIsAllocatedData data = {
9ae3a8
-        .bs = top,
9ae3a8
-        .base = base,
9ae3a8
-        .sector_num = sector_num,
9ae3a8
-        .nb_sectors = nb_sectors,
9ae3a8
-        .pnum = pnum,
9ae3a8
-        .done = false,
9ae3a8
-    };
9ae3a8
-
9ae3a8
-    co = qemu_coroutine_create(bdrv_is_allocated_above_co_entry);
9ae3a8
-    qemu_coroutine_enter(co, &data);
9ae3a8
-    while (!data.done) {
9ae3a8
-        qemu_aio_wait();
9ae3a8
-    }
9ae3a8
-    return data.ret;
9ae3a8
-}
9ae3a8
-
9ae3a8
 BlockInfo *bdrv_query_info(BlockDriverState *bs)
9ae3a8
 {
9ae3a8
     BlockInfo *info = g_malloc0(sizeof(*info));
9ae3a8
diff --git a/block/commit.c b/block/commit.c
9ae3a8
index 553447e..74c209a 100644
9ae3a8
--- a/block/commit.c
9ae3a8
+++ b/block/commit.c
9ae3a8
@@ -108,9 +108,9 @@ wait:
9ae3a8
             break;
9ae3a8
         }
9ae3a8
         /* Copy if allocated above the base */
9ae3a8
-        ret = bdrv_co_is_allocated_above(top, base, sector_num,
9ae3a8
-                                         COMMIT_BUFFER_SIZE / BDRV_SECTOR_SIZE,
9ae3a8
-                                         &n);
9ae3a8
+        ret = bdrv_is_allocated_above(top, base, sector_num,
9ae3a8
+                                      COMMIT_BUFFER_SIZE / BDRV_SECTOR_SIZE,
9ae3a8
+                                      &n);
9ae3a8
         copy = (ret == 1);
9ae3a8
         trace_commit_one_iteration(s, sector_num, n, ret);
9ae3a8
         if (copy) {
9ae3a8
diff --git a/block/mirror.c b/block/mirror.c
9ae3a8
index 1ae724f..dad1e3e 100644
9ae3a8
--- a/block/mirror.c
9ae3a8
+++ b/block/mirror.c
9ae3a8
@@ -338,8 +338,8 @@ static void coroutine_fn mirror_run(void *opaque)
9ae3a8
         base = s->mode == MIRROR_SYNC_MODE_FULL ? NULL : bs->backing_hd;
9ae3a8
         for (sector_num = 0; sector_num < end; ) {
9ae3a8
             int64_t next = (sector_num | (sectors_per_chunk - 1)) + 1;
9ae3a8
-            ret = bdrv_co_is_allocated_above(bs, base,
9ae3a8
-                                             sector_num, next - sector_num, &n);
9ae3a8
+            ret = bdrv_is_allocated_above(bs, base,
9ae3a8
+                                          sector_num, next - sector_num, &n);
9ae3a8
 
9ae3a8
             if (ret < 0) {
9ae3a8
                 goto immediate_exit;
9ae3a8
diff --git a/block/stream.c b/block/stream.c
9ae3a8
index f8efa8a..9674c31 100644
9ae3a8
--- a/block/stream.c
9ae3a8
+++ b/block/stream.c
9ae3a8
@@ -123,8 +123,8 @@ wait:
9ae3a8
         } else {
9ae3a8
             /* Copy if allocated in the intermediate images.  Limit to the
9ae3a8
              * known-unallocated area [sector_num, sector_num+n).  */
9ae3a8
-            ret = bdrv_co_is_allocated_above(bs->backing_hd, base,
9ae3a8
-                                             sector_num, n, &n);
9ae3a8
+            ret = bdrv_is_allocated_above(bs->backing_hd, base,
9ae3a8
+                                          sector_num, n, &n);
9ae3a8
 
9ae3a8
             /* Finish early if end of backing file has been reached */
9ae3a8
             if (ret == 0 && n == 0) {
9ae3a8
diff --git a/include/block/block.h b/include/block/block.h
9ae3a8
index 1932e67..ec4d4aa 100644
9ae3a8
--- a/include/block/block.h
9ae3a8
+++ b/include/block/block.h
9ae3a8
@@ -192,10 +192,6 @@ int coroutine_fn bdrv_co_writev(BlockDriverState *bs, int64_t sector_num,
9ae3a8
  */
9ae3a8
 int coroutine_fn bdrv_co_write_zeroes(BlockDriverState *bs, int64_t sector_num,
9ae3a8
     int nb_sectors);
9ae3a8
-int coroutine_fn bdrv_co_is_allocated_above(BlockDriverState *top,
9ae3a8
-                                            BlockDriverState *base,
9ae3a8
-                                            int64_t sector_num,
9ae3a8
-                                            int nb_sectors, int *pnum);
9ae3a8
 BlockDriverState *bdrv_find_backing_image(BlockDriverState *bs,
9ae3a8
     const char *backing_file);
9ae3a8
 int bdrv_get_backing_file_depth(BlockDriverState *bs);
9ae3a8
-- 
9ae3a8
1.7.1
9ae3a8