From: Hannes Reinecke <h...@suse.com>

test_bit() is atomic, test_bit() || test_bit() is not.
So protect consecutive bit tests with a lock to avoid races.

Signed-off-by: Hannes Reinecke <h...@suse.com>
Signed-off-by: Saurav Kashyap <skash...@marvell.com>
---
 drivers/scsi/qedf/qedf_els.c  | 4 ++++
 drivers/scsi/qedf/qedf_main.c | 5 ++++-
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/drivers/scsi/qedf/qedf_els.c b/drivers/scsi/qedf/qedf_els.c
index aad1f7c..f1f57637 100644
--- a/drivers/scsi/qedf/qedf_els.c
+++ b/drivers/scsi/qedf/qedf_els.c
@@ -358,20 +358,24 @@ void qedf_restart_rport(struct qedf_rport *fcport)
        struct fc_lport *lport;
        struct fc_rport_priv *rdata;
        u32 port_id;
+       unsigned long flags;
 
        if (!fcport)
                return;
 
+       spin_lock_irqsave(&fcport->rport_lock, flags);
        if (test_bit(QEDF_RPORT_IN_RESET, &fcport->flags) ||
            !test_bit(QEDF_RPORT_SESSION_READY, &fcport->flags) ||
            test_bit(QEDF_RPORT_UPLOADING_CONNECTION, &fcport->flags)) {
                QEDF_ERR(&(fcport->qedf->dbg_ctx), "fcport %p already in reset 
or not offloaded.\n",
                    fcport);
+               spin_unlock_irqrestore(&fcport->rport_lock, flags);
                return;
        }
 
        /* Set that we are now in reset */
        set_bit(QEDF_RPORT_IN_RESET, &fcport->flags);
+       spin_unlock_irqrestore(&fcport->rport_lock, flags);
 
        rdata = fcport->rdata;
        if (rdata) {
diff --git a/drivers/scsi/qedf/qedf_main.c b/drivers/scsi/qedf/qedf_main.c
index fb9c288..880dcf2 100644
--- a/drivers/scsi/qedf/qedf_main.c
+++ b/drivers/scsi/qedf/qedf_main.c
@@ -1434,12 +1434,14 @@ static void qedf_rport_event_handler(struct fc_lport 
*lport,
                 */
                fcport = (struct qedf_rport *)&rp[1];
 
+               spin_lock_irqsave(&fcport->rport_lock, flags);
                /* Only free this fcport if it is offloaded already */
                if (test_bit(QEDF_RPORT_SESSION_READY, &fcport->flags) &&
                    !test_bit(QEDF_RPORT_UPLOADING_CONNECTION,
                    &fcport->flags)) {
                        set_bit(QEDF_RPORT_UPLOADING_CONNECTION,
                                &fcport->flags);
+                       spin_unlock_irqrestore(&fcport->rport_lock, flags);
                        qedf_cleanup_fcport(qedf, fcport);
                        /*
                         * Remove fcport to list of qedf_ctx list of offloaded
@@ -1452,8 +1454,9 @@ static void qedf_rport_event_handler(struct fc_lport 
*lport,
                        clear_bit(QEDF_RPORT_UPLOADING_CONNECTION,
                            &fcport->flags);
                        atomic_dec(&qedf->num_offloads);
+               } else {
+                       spin_unlock_irqrestore(&fcport->rport_lock, flags);
                }
-
                break;
 
        case RPORT_EV_NONE:
-- 
1.8.3.1

Reply via email to