yeahuh / rpms / qemu-kvm

Forked from rpms/qemu-kvm 2 years ago
Clone
9ae3a8
From 7f3514b0392635f132a8e1158d91536e5aed7783 Mon Sep 17 00:00:00 2001
9ae3a8
Message-Id: <7f3514b0392635f132a8e1158d91536e5aed7783.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:08:51 +0100
9ae3a8
Subject: [PATCH 03/50] iscsi: add logical block provisioning information to
9ae3a8
 iscsilun
9ae3a8
9ae3a8
RH-Author: Paolo Bonzini <pbonzini@redhat.com>
9ae3a8
Message-id: <1386598178-11845-6-git-send-email-pbonzini@redhat.com>
9ae3a8
Patchwork-id: 56042
9ae3a8
O-Subject: [RHEL 7.0 qemu-kvm PATCH 05/52] iscsi: add logical block provisioning information to iscsilun
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: Paolo Bonzini <pbonzini@redhat.com>
9ae3a8
(cherry picked from commit f18a7cbb0992a02225d26afd336aaf47de75e11c)
9ae3a8
---
9ae3a8
 block/iscsi.c | 77 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
9ae3a8
 1 file changed, 77 insertions(+)
9ae3a8
9ae3a8
Signed-off-by: Michal Novotny <minovotn@redhat.com>
9ae3a8
---
9ae3a8
 block/iscsi.c | 77 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
9ae3a8
 1 file changed, 77 insertions(+)
9ae3a8
9ae3a8
diff --git a/block/iscsi.c b/block/iscsi.c
9ae3a8
index 8086957..6804b6d 100644
9ae3a8
--- a/block/iscsi.c
9ae3a8
+++ b/block/iscsi.c
9ae3a8
@@ -52,6 +52,10 @@ typedef struct IscsiLun {
9ae3a8
     uint64_t num_blocks;
9ae3a8
     int events;
9ae3a8
     QEMUTimer *nop_timer;
9ae3a8
+    uint8_t lbpme;
9ae3a8
+    uint8_t lbprz;
9ae3a8
+    struct scsi_inquiry_logical_block_provisioning lbp;
9ae3a8
+    struct scsi_inquiry_block_limits bl;
9ae3a8
 } IscsiLun;
9ae3a8
 
9ae3a8
 typedef struct IscsiAIOCB {
9ae3a8
@@ -1005,6 +1009,8 @@ static int iscsi_readcapacity_sync(IscsiLun *iscsilun)
9ae3a8
                 } else {
9ae3a8
                     iscsilun->block_size = rc16->block_length;
9ae3a8
                     iscsilun->num_blocks = rc16->returned_lba + 1;
9ae3a8
+                    iscsilun->lbpme = rc16->lbpme;
9ae3a8
+                    iscsilun->lbprz = rc16->lbprz;
9ae3a8
                 }
9ae3a8
             }
9ae3a8
             break;
9ae3a8
@@ -1057,6 +1063,37 @@ static QemuOptsList runtime_opts = {
9ae3a8
     },
9ae3a8
 };
9ae3a8
 
9ae3a8
+static struct scsi_task *iscsi_do_inquiry(struct iscsi_context *iscsi,
9ae3a8
+                                          int lun, int evpd, int pc) {
9ae3a8
+        int full_size;
9ae3a8
+        struct scsi_task *task = NULL;
9ae3a8
+        task = iscsi_inquiry_sync(iscsi, lun, evpd, pc, 64);
9ae3a8
+        if (task == NULL || task->status != SCSI_STATUS_GOOD) {
9ae3a8
+            goto fail;
9ae3a8
+        }
9ae3a8
+        full_size = scsi_datain_getfullsize(task);
9ae3a8
+        if (full_size > task->datain.size) {
9ae3a8
+            scsi_free_scsi_task(task);
9ae3a8
+
9ae3a8
+            /* we need more data for the full list */
9ae3a8
+            task = iscsi_inquiry_sync(iscsi, lun, evpd, pc, full_size);
9ae3a8
+            if (task == NULL || task->status != SCSI_STATUS_GOOD) {
9ae3a8
+                goto fail;
9ae3a8
+            }
9ae3a8
+        }
9ae3a8
+
9ae3a8
+        return task;
9ae3a8
+
9ae3a8
+fail:
9ae3a8
+        error_report("iSCSI: Inquiry command failed : %s",
9ae3a8
+                     iscsi_get_error(iscsi));
9ae3a8
+        if (task) {
9ae3a8
+            scsi_free_scsi_task(task);
9ae3a8
+            return NULL;
9ae3a8
+        }
9ae3a8
+        return NULL;
9ae3a8
+}
9ae3a8
+
9ae3a8
 /*
9ae3a8
  * We support iscsi url's on the form
9ae3a8
  * iscsi://[<username>%<password>@]<host>[:<port>]/<targetname>/<lun>
9ae3a8
@@ -1187,6 +1224,46 @@ static int iscsi_open(BlockDriverState *bs, QDict *options, int flags,
9ae3a8
         bs->sg = 1;
9ae3a8
     }
9ae3a8
 
9ae3a8
+    if (iscsilun->lbpme) {
9ae3a8
+        struct scsi_inquiry_logical_block_provisioning *inq_lbp;
9ae3a8
+        task = iscsi_do_inquiry(iscsilun->iscsi, iscsilun->lun, 1,
9ae3a8
+                                SCSI_INQUIRY_PAGECODE_LOGICAL_BLOCK_PROVISIONING);
9ae3a8
+        if (task == NULL) {
9ae3a8
+            ret = -EINVAL;
9ae3a8
+            goto out;
9ae3a8
+        }
9ae3a8
+        inq_lbp = scsi_datain_unmarshall(task);
9ae3a8
+        if (inq_lbp == NULL) {
9ae3a8
+            error_report("iSCSI: failed to unmarshall inquiry datain blob");
9ae3a8
+            ret = -EINVAL;
9ae3a8
+            goto out;
9ae3a8
+        }
9ae3a8
+        memcpy(&iscsilun->lbp, inq_lbp,
9ae3a8
+               sizeof(struct scsi_inquiry_logical_block_provisioning));
9ae3a8
+        scsi_free_scsi_task(task);
9ae3a8
+        task = NULL;
9ae3a8
+    }
9ae3a8
+
9ae3a8
+    if (iscsilun->lbp.lbpu || iscsilun->lbp.lbpws) {
9ae3a8
+        struct scsi_inquiry_block_limits *inq_bl;
9ae3a8
+        task = iscsi_do_inquiry(iscsilun->iscsi, iscsilun->lun, 1,
9ae3a8
+                                SCSI_INQUIRY_PAGECODE_BLOCK_LIMITS);
9ae3a8
+        if (task == NULL) {
9ae3a8
+            ret = -EINVAL;
9ae3a8
+            goto out;
9ae3a8
+        }
9ae3a8
+        inq_bl = scsi_datain_unmarshall(task);
9ae3a8
+        if (inq_bl == NULL) {
9ae3a8
+            error_report("iSCSI: failed to unmarshall inquiry datain blob");
9ae3a8
+            ret = -EINVAL;
9ae3a8
+            goto out;
9ae3a8
+        }
9ae3a8
+        memcpy(&iscsilun->bl, inq_bl,
9ae3a8
+               sizeof(struct scsi_inquiry_block_limits));
9ae3a8
+        scsi_free_scsi_task(task);
9ae3a8
+        task = NULL;
9ae3a8
+    }
9ae3a8
+
9ae3a8
 #if defined(LIBISCSI_FEATURE_NOP_COUNTER)
9ae3a8
     /* Set up a timer for sending out iSCSI NOPs */
9ae3a8
     iscsilun->nop_timer = qemu_new_timer_ms(rt_clock, iscsi_nop_timed_event, iscsilun);
9ae3a8
-- 
9ae3a8
1.7.11.7
9ae3a8