Allocate discovered targets onto the channel-group list that matches
their protocol.

When a target is created, use the discovered protocol type to decide
which list it belongs on. This keeps protocol-specific discovery
results isolated and allows later state-machine and remote-port code to
walk the correct target set.

Signed-off-by: Tyrel Datwyler <[email protected]>
---
 drivers/scsi/ibmvscsi/ibmvfc-core.c | 22 +++++++++++++++++-----
 1 file changed, 17 insertions(+), 5 deletions(-)

diff --git a/drivers/scsi/ibmvscsi/ibmvfc-core.c 
b/drivers/scsi/ibmvscsi/ibmvfc-core.c
index 363bf75d6244..4b95e4344947 100644
--- a/drivers/scsi/ibmvscsi/ibmvfc-core.c
+++ b/drivers/scsi/ibmvscsi/ibmvfc-core.c
@@ -4938,25 +4938,32 @@ static void ibmvfc_tgt_query_target(struct 
ibmvfc_target *tgt)
  *     0 on success / other on failure
  **/
 static int ibmvfc_alloc_target(struct ibmvfc_host *vhost,
-                              struct ibmvfc_discover_targets_entry *target)
+                              struct ibmvfc_discover_targets_entry *target,
+                              enum ibmvfc_protocol protocol)
 {
        struct ibmvfc_target *stgt = NULL;
        struct ibmvfc_target *wtgt = NULL;
        struct ibmvfc_target *tgt;
+       struct ibmvfc_channels *channels;
        unsigned long flags;
        u64 scsi_id = be32_to_cpu(target->scsi_id) & 
IBMVFC_DISC_TGT_SCSI_ID_MASK;
        u64 wwpn = be64_to_cpu(target->wwpn);
 
+       if (protocol == IBMVFC_PROTO_SCSI)
+               channels = &vhost->scsi_scrqs;
+       else
+               channels = &vhost->nvme_scrqs;
+
        /* Look to see if we already have a target allocated for this SCSI ID 
or WWPN */
        spin_lock_irqsave(vhost->host->host_lock, flags);
-       list_for_each_entry(tgt, &vhost->scsi_scrqs.targets, queue) {
+       list_for_each_entry(tgt, &channels->targets, queue) {
                if (tgt->wwpn == wwpn) {
                        wtgt = tgt;
                        break;
                }
        }
 
-       list_for_each_entry(tgt, &vhost->scsi_scrqs.targets, queue) {
+       list_for_each_entry(tgt, &channels->targets, queue) {
                if (tgt->scsi_id == scsi_id) {
                        stgt = tgt;
                        break;
@@ -5004,6 +5011,7 @@ static int ibmvfc_alloc_target(struct ibmvfc_host *vhost,
 
        tgt = mempool_alloc(vhost->tgt_pool, GFP_NOIO);
        memset(tgt, 0, sizeof(*tgt));
+       tgt->protocol = protocol;
        tgt->scsi_id = scsi_id;
        tgt->wwpn = wwpn;
        tgt->vhost = vhost;
@@ -5013,7 +5021,7 @@ static int ibmvfc_alloc_target(struct ibmvfc_host *vhost,
        ibmvfc_init_tgt(tgt, ibmvfc_tgt_implicit_logout);
        spin_lock_irqsave(vhost->host->host_lock, flags);
        tgt->cancel_key = vhost->task_set++;
-       list_add_tail(&tgt->queue, &vhost->scsi_scrqs.targets);
+       list_add_tail(&tgt->queue, &channels->targets);
 
 unlock_out:
        spin_unlock_irqrestore(vhost->host->host_lock, flags);
@@ -5032,7 +5040,11 @@ static int ibmvfc_alloc_targets(struct ibmvfc_host 
*vhost)
        int i, rc;
 
        for (i = 0, rc = 0; !rc && i < vhost->scsi_scrqs.num_targets; i++)
-               rc = ibmvfc_alloc_target(vhost, &vhost->scsi_scrqs.disc_buf[i]);
+               rc = ibmvfc_alloc_target(vhost, &vhost->scsi_scrqs.disc_buf[i],
+                                        vhost->scsi_scrqs.protocol);
+       for (i = 0; !rc && i < vhost->nvme_scrqs.num_targets; i++)
+               rc = ibmvfc_alloc_target(vhost, &vhost->nvme_scrqs.disc_buf[i],
+                                        vhost->nvme_scrqs.protocol);
 
        return rc;
 }
-- 
2.54.0


Reply via email to