yeahuh / rpms / qemu-kvm

Forked from rpms/qemu-kvm 2 years ago
Clone
9ae3a8
From 0923f651d0a8ec837dc2c85dc6fbb9cfabd86172 Mon Sep 17 00:00:00 2001
9ae3a8
Message-Id: <0923f651d0a8ec837dc2c85dc6fbb9cfabd86172.1389014116.git.minovotn@redhat.com>
9ae3a8
In-Reply-To: <c8cc35838d42aa286242772d97e3a9be7bb786ba.1389014116.git.minovotn@redhat.com>
9ae3a8
References: <c8cc35838d42aa286242772d97e3a9be7bb786ba.1389014116.git.minovotn@redhat.com>
9ae3a8
From: Paolo Bonzini <pbonzini@redhat.com>
9ae3a8
Date: Mon, 9 Dec 2013 14:09:06 +0100
9ae3a8
Subject: [PATCH 18/50] iscsi: add bdrv_co_write_zeroes
9ae3a8
9ae3a8
RH-Author: Paolo Bonzini <pbonzini@redhat.com>
9ae3a8
Message-id: <1386598178-11845-21-git-send-email-pbonzini@redhat.com>
9ae3a8
Patchwork-id: 56057
9ae3a8
O-Subject: [RHEL 7.0 qemu-kvm PATCH 20/52] iscsi: add bdrv_co_write_zeroes
9ae3a8
Bugzilla: 1007815
9ae3a8
RH-Acked-by: Jeffrey Cody <jcody@redhat.com>
9ae3a8
RH-Acked-by: Fam Zheng <famz@redhat.com>
9ae3a8
RH-Acked-by: Stefan Hajnoczi <stefanha@redhat.com>
9ae3a8
9ae3a8
From: Peter Lieven <pl@kamp.de>
9ae3a8
9ae3a8
Signed-off-by: Peter Lieven <pl@kamp.de>
9ae3a8
Signed-off-by: Stefan Hajnoczi <stefanha@redhat.com>
9ae3a8
(cherry picked from commit d4cd961507e6f013fd0f9b1dc609f15ed2aaa40d)
9ae3a8
---
9ae3a8
 block/iscsi.c | 64 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
9ae3a8
 1 file changed, 64 insertions(+)
9ae3a8
9ae3a8
Signed-off-by: Michal Novotny <minovotn@redhat.com>
9ae3a8
---
9ae3a8
 block/iscsi.c | 64 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
9ae3a8
 1 file changed, 64 insertions(+)
9ae3a8
9ae3a8
diff --git a/block/iscsi.c b/block/iscsi.c
9ae3a8
index 567a63a..3e3ae64 100644
9ae3a8
--- a/block/iscsi.c
9ae3a8
+++ b/block/iscsi.c
9ae3a8
@@ -56,6 +56,7 @@ typedef struct IscsiLun {
9ae3a8
     uint8_t lbprz;
9ae3a8
     struct scsi_inquiry_logical_block_provisioning lbp;
9ae3a8
     struct scsi_inquiry_block_limits bl;
9ae3a8
+    unsigned char *zeroblock;
9ae3a8
 } IscsiLun;
9ae3a8
 
9ae3a8
 typedef struct IscsiTask {
9ae3a8
@@ -961,6 +962,65 @@ retry:
9ae3a8
     return 0;
9ae3a8
 }
9ae3a8
 
9ae3a8
+#if defined(SCSI_SENSE_ASCQ_CAPACITY_DATA_HAS_CHANGED)
9ae3a8
+
9ae3a8
+static int
9ae3a8
+coroutine_fn iscsi_co_write_zeroes(BlockDriverState *bs, int64_t sector_num,
9ae3a8
+                                   int nb_sectors, BdrvRequestFlags flags)
9ae3a8
+{
9ae3a8
+    IscsiLun *iscsilun = bs->opaque;
9ae3a8
+    struct IscsiTask iTask;
9ae3a8
+    uint64_t lba;
9ae3a8
+    uint32_t nb_blocks;
9ae3a8
+
9ae3a8
+    if (!is_request_lun_aligned(sector_num, nb_sectors, iscsilun)) {
9ae3a8
+        return -EINVAL;
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    if (!iscsilun->lbp.lbpws) {
9ae3a8
+        /* WRITE SAME is not supported by the target */
9ae3a8
+        return -ENOTSUP;
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    lba = sector_qemu2lun(sector_num, iscsilun);
9ae3a8
+    nb_blocks = sector_qemu2lun(nb_sectors, iscsilun);
9ae3a8
+
9ae3a8
+    if (iscsilun->zeroblock == NULL) {
9ae3a8
+        iscsilun->zeroblock = g_malloc0(iscsilun->block_size);
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    iscsi_co_init_iscsitask(iscsilun, &iTask);
9ae3a8
+retry:
9ae3a8
+    if (iscsi_writesame16_task(iscsilun->iscsi, iscsilun->lun, lba,
9ae3a8
+                               iscsilun->zeroblock, iscsilun->block_size,
9ae3a8
+                               nb_blocks, 0, !!(flags & BDRV_REQ_MAY_UNMAP),
9ae3a8
+                               0, 0, iscsi_co_generic_cb, &iTask) == NULL) {
9ae3a8
+        return -EIO;
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    while (!iTask.complete) {
9ae3a8
+        iscsi_set_events(iscsilun);
9ae3a8
+        qemu_coroutine_yield();
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    if (iTask.task != NULL) {
9ae3a8
+        scsi_free_scsi_task(iTask.task);
9ae3a8
+        iTask.task = NULL;
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    if (iTask.do_retry) {
9ae3a8
+        goto retry;
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    if (iTask.status != SCSI_STATUS_GOOD) {
9ae3a8
+        return -EIO;
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    return 0;
9ae3a8
+}
9ae3a8
+
9ae3a8
+#endif /* SCSI_SENSE_ASCQ_CAPACITY_DATA_HAS_CHANGED */
9ae3a8
+
9ae3a8
 static int parse_chap(struct iscsi_context *iscsi, const char *target)
9ae3a8
 {
9ae3a8
     QemuOptsList *list;
9ae3a8
@@ -1423,6 +1483,7 @@ static void iscsi_close(BlockDriverState *bs)
9ae3a8
     }
9ae3a8
     qemu_aio_set_fd_handler(iscsi_get_fd(iscsi), NULL, NULL, NULL, NULL);
9ae3a8
     iscsi_destroy_context(iscsi);
9ae3a8
+    g_free(iscsilun->zeroblock);
9ae3a8
     memset(iscsilun, 0, sizeof(IscsiLun));
9ae3a8
 }
9ae3a8
 
9ae3a8
@@ -1538,6 +1599,9 @@ static BlockDriver bdrv_iscsi = {
9ae3a8
 
9ae3a8
     .bdrv_co_get_block_status = iscsi_co_get_block_status,
9ae3a8
     .bdrv_co_discard      = iscsi_co_discard,
9ae3a8
+#if defined(SCSI_SENSE_ASCQ_CAPACITY_DATA_HAS_CHANGED)
9ae3a8
+    .bdrv_co_write_zeroes = iscsi_co_write_zeroes,
9ae3a8
+#endif
9ae3a8
 
9ae3a8
     .bdrv_aio_readv  = iscsi_aio_readv,
9ae3a8
     .bdrv_aio_writev = iscsi_aio_writev,
9ae3a8
-- 
9ae3a8
1.7.11.7
9ae3a8