Thanks Johannes for the review, please see comments below,

On 19/10/16 3:32 PM, "Johannes Thumshirn" <jthumsh...@suse.de> wrote:

>On Wed, Oct 19, 2016 at 01:01:10AM -0400, manish.rangan...@cavium.com
>wrote:
>> From: Manish Rangankar <manish.rangan...@cavium.com>
>> 
>> The QLogic FastLinQ Driver for iSCSI (qedi) is the iSCSI specific module
>> for 41000 Series Converged Network Adapters by QLogic.
>> 
>> This patch consists of following changes:
>>   - MAINTAINERS Makefile and Kconfig changes for qedi,
>>   - PCI driver registration,
>>   - iSCSI host level initialization,
>>   - Debugfs and log level infrastructure.
>> 
>> Signed-off-by: Nilesh Javali <nilesh.jav...@cavium.com>
>> Signed-off-by: Adheer Chandravanshi <adheer.chandravan...@qlogic.com>
>> Signed-off-by: Chad Dupuis <chad.dup...@cavium.com>
>> Signed-off-by: Saurav Kashyap <saurav.kash...@cavium.com>
>> Signed-off-by: Arun Easi <arun.e...@cavium.com>
>> Signed-off-by: Manish Rangankar <manish.rangan...@cavium.com>
>> ---
>
>[...]
>
>> +static inline void *qedi_get_task_mem(struct qed_iscsi_tid *info, u32
>>tid)
>> +{
>> +    return (void *)(info->blocks[tid / info->num_tids_per_block] +
>> +                    (tid % info->num_tids_per_block) * info->size);
>> +}
>
>Unnecessary cast here.

Noted

>
>
>[...]
>
>> +void
>> +qedi_dbg_err(struct qedi_dbg_ctx *qedi, const char *func, u32 line,
>> +         const char *fmt, ...)
>> +{
>> +    va_list va;
>> +    struct va_format vaf;
>> +    char nfunc[32];
>> +
>> +    memset(nfunc, 0, sizeof(nfunc));
>> +    memcpy(nfunc, func, sizeof(nfunc) - 1);
>> +
>> +    va_start(va, fmt);
>> +
>> +    vaf.fmt = fmt;
>> +    vaf.va = &va;
>> +
>> +    if (likely(qedi) && likely(qedi->pdev))
>> +            pr_crit("[%s]:[%s:%d]:%d: %pV", dev_name(&qedi->pdev->dev),
>> +                    nfunc, line, qedi->host_no, &vaf);
>> +    else
>> +            pr_crit("[0000:00:00.0]:[%s:%d]: %pV", nfunc, line, &vaf);
>
>pr_crit, seriously?

We will change it to pr_err.

>
>[...]
>
>> +static void qedi_int_fp(struct qedi_ctx *qedi)
>> +{
>> +    struct qedi_fastpath *fp;
>> +    int id;
>> +
>> +    memset((void *)qedi->fp_array, 0, MIN_NUM_CPUS_MSIX(qedi) *
>> +           sizeof(*qedi->fp_array));
>> +    memset((void *)qedi->sb_array, 0, MIN_NUM_CPUS_MSIX(qedi) *
>> +           sizeof(*qedi->sb_array));
>
>I don't think the cast is necessary here.

Noted


>
>[...]
>
>> +static int qedi_setup_cid_que(struct qedi_ctx *qedi)
>> +{
>> +    int i;
>> +
>> +    qedi->cid_que.cid_que_base = kmalloc((qedi->max_active_conns *
>> +                                          sizeof(u32)), GFP_KERNEL);
>> +    if (!qedi->cid_que.cid_que_base)
>> +            return -ENOMEM;
>> +
>> +    qedi->cid_que.conn_cid_tbl = kmalloc((qedi->max_active_conns *
>> +                                          sizeof(struct qedi_conn *)),
>> +                                         GFP_KERNEL);
>
>Please use kmalloc_array() here.

Will do.

>
>[...]
>
>> +/* MSI-X fastpath handler code */
>> +static irqreturn_t qedi_msix_handler(int irq, void *dev_id)
>> +{
>> +    struct qedi_fastpath *fp = dev_id;
>> +    struct qedi_ctx *qedi = fp->qedi;
>> +    bool wake_io_thread = true;
>> +
>> +    qed_sb_ack(fp->sb_info, IGU_INT_DISABLE, 0);
>> +
>> +process_again:
>> +    wake_io_thread = qedi_process_completions(fp);
>> +    if (wake_io_thread) {
>> +            QEDI_INFO(&qedi->dbg_ctx, QEDI_LOG_DISC,
>> +                      "process already running\n");
>> +    }
>> +
>> +    if (qedi_fp_has_work(fp) == 0)
>> +            qed_sb_update_sb_idx(fp->sb_info);
>> +
>> +    /* Check for more work */
>> +    rmb();
>> +
>> +    if (qedi_fp_has_work(fp) == 0)
>> +            qed_sb_ack(fp->sb_info, IGU_INT_ENABLE, 1);
>> +    else
>> +            goto process_again;
>> +
>> +    return IRQ_HANDLED;
>> +}
>
>You might want to consider workqueues here.

We will revisit this code.

>
>[...]
>
>> +static int qedi_alloc_itt(struct qedi_ctx *qedi)
>> +{
>> +    qedi->itt_map = kzalloc((sizeof(struct qedi_itt_map) *
>> +                            MAX_ISCSI_TASK_ENTRIES), GFP_KERNEL);
>
>that screams for kcalloc()
>
>> +    if (!qedi->itt_map) {
>> +            QEDI_ERR(&qedi->dbg_ctx,
>> +                     "Unable to allocate itt map array memory\n");
>> +            return -ENOMEM;
>> +    }
>> +    return 0;
>> +}
>> +
>> +static void qedi_free_itt(struct qedi_ctx *qedi)
>> +{
>> +    kfree(qedi->itt_map);
>> +}
>> +
>> +static struct qed_ll2_cb_ops qedi_ll2_cb_ops = {
>> +    .rx_cb = qedi_ll2_rx,
>> +    .tx_cb = NULL,
>> +};
>> +
>> +static int qedi_percpu_io_thread(void *arg)
>> +{
>> +    struct qedi_percpu_s *p = arg;
>> +    struct qedi_work *work, *tmp;
>> +    unsigned long flags;
>> +    LIST_HEAD(work_list);
>> +
>> +    set_user_nice(current, -20);
>> +
>> +    while (!kthread_should_stop()) {
>> +            spin_lock_irqsave(&p->p_work_lock, flags);
>> +            while (!list_empty(&p->work_list)) {
>> +                    list_splice_init(&p->work_list, &work_list);
>> +                    spin_unlock_irqrestore(&p->p_work_lock, flags);
>> +
>> +                    list_for_each_entry_safe(work, tmp, &work_list, list) {
>> +                            list_del_init(&work->list);
>> +                            qedi_fp_process_cqes(work->qedi, &work->cqe,
>> +                                                 work->que_idx);
>> +                            kfree(work);
>> +                    }
>> +                    spin_lock_irqsave(&p->p_work_lock, flags);
>> +            }
>> +            set_current_state(TASK_INTERRUPTIBLE);
>> +            spin_unlock_irqrestore(&p->p_work_lock, flags);
>> +            schedule();
>> +    }
>> +    __set_current_state(TASK_RUNNING);
>> +
>> +    return 0;
>> +}
>
>A kthread with prio -20 IRQs turned off looping over a list, what could
>possibly go wrong here. I bet you your favorite beverage that this will
>cause Soft Lockups when running I/O stress tests BTDT.

Will remove this.

>
>[...]
>
>> +    if (mode != QEDI_MODE_RECOVERY) {
>> +            if (iscsi_host_add(qedi->shost, &pdev->dev)) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "Could not add iscsi host\n");
>> +                    rc = -ENOMEM;
>> +                    goto remove_host;
>> +            }
>> +
>> +            /* Allocate uio buffers */
>> +            rc = qedi_alloc_uio_rings(qedi);
>> +            if (rc) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "UIO alloc ring failed err=%d\n", rc);
>> +                    goto remove_host;
>> +            }
>> +
>> +            rc = qedi_init_uio(qedi);
>> +            if (rc) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "UIO init failed, err=%d\n", rc);
>> +                    goto free_uio;
>> +            }
>> +
>> +            /* host the array on iscsi_conn */
>> +            rc = qedi_setup_cid_que(qedi);
>> +            if (rc) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "Could not setup cid que\n");
>> +                    goto free_uio;
>> +            }
>> +
>> +            rc = qedi_cm_alloc_mem(qedi);
>> +            if (rc) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "Could not alloc cm memory\n");
>> +                    goto free_cid_que;
>> +            }
>> +
>> +            rc = qedi_alloc_itt(qedi);
>> +            if (rc) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "Could not alloc itt memory\n");
>> +                    goto free_cid_que;
>> +            }
>> +
>> +            sprintf(host_buf, "host_%d", qedi->shost->host_no);
>> +            qedi->tmf_thread = create_singlethread_workqueue(host_buf);
>> +            if (!qedi->tmf_thread) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "Unable to start tmf thread!\n");
>> +                    rc = -ENODEV;
>> +                    goto free_cid_que;
>> +            }
>> +
>> +            sprintf(host_buf, "qedi_ofld%d", qedi->shost->host_no);
>> +            qedi->offload_thread = create_workqueue(host_buf);
>> +            if (!qedi->offload_thread) {
>> +                    QEDI_ERR(&qedi->dbg_ctx,
>> +                             "Unable to start offload thread!\n");
>> +                    rc = -ENODEV;
>> +                    goto free_cid_que;
>> +            }
>> +
>> +            /* F/w needs 1st task context memory entry for performance */
>> +            set_bit(QEDI_RESERVE_TASK_ID, qedi->task_idx_map);
>> +            atomic_set(&qedi->num_offloads, 0);
>> +    }
>> +
>> +    QEDI_INFO(&qedi->dbg_ctx, QEDI_LOG_INFO,
>> +              "QLogic FastLinQ iSCSI Module qedi %s, FW %d.%d.%d.%d\n",
>> +              QEDI_MODULE_VERSION, FW_MAJOR_VERSION, FW_MINOR_VERSION,
>> +               FW_REVISION_VERSION, FW_ENGINEERING_VERSION);
>> +    return 0;
>
>Please put the QEDI_INFO() above the if and invert the condition.

Will do.

--
To unsubscribe from this list: send the line "unsubscribe linux-scsi" in
the body of a message to majord...@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html

Reply via email to