@@ -430,6 +430,7 @@ struct srb_iocb {
} nvme;
} u;
+ struct work_struct rq_work;
struct timer_list timer;
void (*timeout)(void *);
};
@@ -4132,6 +4133,7 @@ typedef struct scsi_qla_host {
atomic_t nvme_ref_count;
wait_queue_head_t nvme_waitq;
struct list_head nvme_rport_list;
+ struct workqueue_struct *nvme_io_wq;
atomic_t nvme_active_aen_cnt;
uint16_t nvme_last_rptd_aen;
@@ -156,6 +156,17 @@ static void qla_nvme_sp_ls_done(void *ptr, int res)
qla2x00_rel_sp(sp);
}
+static void qla_nvme_io_work(struct work_struct *work)
+{
+ srb_t *sp;
+ struct srb_iocb *nvme = container_of(work, struct srb_iocb, rq_work);
+ struct nvmefc_fcp_req *fd = nvme->u.nvme.desc;
+ sp = container_of(nvme, srb_t, u.iocb_cmd);
+
+ fd->done(fd);
+ qla2xxx_rel_qpair_sp(sp->qpair, sp);
+}
+
static void qla_nvme_sp_done(void *ptr, int res)
{
srb_t *sp = ptr;
@@ -177,7 +188,13 @@ static void qla_nvme_sp_done(void *ptr, int res)
fd->status = 0;
fd->rcv_rsplen = nvme->u.nvme.rsp_pyld_len;
- fd->done(fd);
+ if (res == QLA_FUNCTION_FAILED) {
+ INIT_WORK(&nvme->rq_work, qla_nvme_io_work);
+ queue_work(sp->fcport->vha->nvme_io_wq, &nvme->rq_work);
+ return;
+ } else {
+ fd->done(fd);
+ }
rel:
qla2xxx_rel_qpair_sp(sp->qpair, sp);
}
@@ -514,6 +531,7 @@ static int qla_nvme_post_cmd(struct nvme_fc_local_port *lport,
sp->done = qla_nvme_sp_done;
sp->qpair = qpair;
nvme = &sp->u.iocb_cmd;
+ INIT_WORK(&nvme->rq_work, qla_nvme_io_work);
nvme->u.nvme.desc = fd;
rval = qla2x00_start_nvme_mq(sp);
@@ -2751,7 +2751,6 @@ qla2x00_probe_one(struct pci_dev *pdev, const struct pci_device_id *id)
spin_lock_init(&ha->tgt.sess_lock);
spin_lock_init(&ha->tgt.atio_lock);
-
/* Clear our data area */
ha->bars = bars;
ha->mem_only = mem_only;
@@ -3286,6 +3285,13 @@ qla2x00_probe_one(struct pci_dev *pdev, const struct pci_device_id *id)
base_vha->flags.init_done = 1;
base_vha->flags.online = 1;
ha->prev_minidump_failed = 0;
+ atomic_set(&base_vha->nvme_active_aen_cnt, 0);
+ base_vha->nvme_io_wq = alloc_workqueue("qlnvme-io-wq", 0, 0);
+ if (!base_vha->nvme_io_wq) {
+ ql_log(ql_log_fatal, base_vha, 0x000b,
+ "Unable to allocate workqueue for nvme_io_wq\n");
+ goto disable_device;
+ }
ql_dbg(ql_dbg_init, base_vha, 0x00f2,
"Init done and hba is online.\n");
@@ -3559,6 +3565,8 @@ qla2x00_remove_one(struct pci_dev *pdev)
set_bit(UNLOADING, &base_vha->dpc_flags);
qla_nvme_delete(base_vha);
+ if (base_vha->nvme_io_wq)
+ destroy_workqueue(base_vha->nvme_io_wq);
dma_free_coherent(&ha->pdev->dev,
base_vha->gnl.size, base_vha->gnl.l, base_vha->gnl.ldma);