scsi: target: cxgbit: Remove tx flow control code
authorVarun Prakash <varun@chelsio.com>
Wed, 1 Jul 2020 16:47:12 +0000 (22:17 +0530)
committerMartin K. Petersen <martin.petersen@oracle.com>
Wed, 8 Jul 2020 05:48:24 +0000 (01:48 -0400)
Firmware does tx flow control so remove tx flow control code from the
driver.

Signed-off-by: Varun Prakash <varun@chelsio.com>
Signed-off-by: Martin K. Petersen <martin.petersen@oracle.com>
drivers/target/iscsi/cxgbit/cxgbit.h
drivers/target/iscsi/cxgbit/cxgbit_cm.c
drivers/target/iscsi/cxgbit/cxgbit_target.c

index c04cd0832decd024b20e3d14b567e3f22ba415c6..406903398dfdc722a8e36b69027c20251af2ab1e 100644 (file)
@@ -207,7 +207,6 @@ struct cxgbit_sock {
        /* socket lock */
        spinlock_t lock;
        wait_queue_head_t waitq;
-       wait_queue_head_t ack_waitq;
        bool lock_owner;
        struct kref kref;
        u32 max_iso_npdu;
index 493070cedbc719c8d8db3e84889990b2118e4b42..518ded214e74e31c6ccb6796d7af4e34cc2b7640 100644 (file)
@@ -1360,7 +1360,6 @@ cxgbit_pass_accept_req(struct cxgbit_device *cdev, struct sk_buff *skb)
        cxgbit_sock_reset_wr_list(csk);
        spin_lock_init(&csk->lock);
        init_waitqueue_head(&csk->waitq);
-       init_waitqueue_head(&csk->ack_waitq);
        csk->lock_owner = false;
 
        if (cxgbit_alloc_csk_skb(csk)) {
@@ -1887,7 +1886,6 @@ static void cxgbit_fw4_ack(struct cxgbit_sock *csk, struct sk_buff *skb)
                if (csk->snd_una != snd_una) {
                        csk->snd_una = snd_una;
                        dst_confirm(csk->dst);
-                       wake_up(&csk->ack_waitq);
                }
        }
 
index fcdc4211e3c27f2896d0782a9b2693dbeaf9f5d6..9b3eb2e8c92ad9e4a5233f8b88caab5ef757b9d3 100644 (file)
@@ -284,18 +284,6 @@ void cxgbit_push_tx_frames(struct cxgbit_sock *csk)
        }
 }
 
-static bool cxgbit_lock_sock(struct cxgbit_sock *csk)
-{
-       spin_lock_bh(&csk->lock);
-
-       if (before(csk->write_seq, csk->snd_una + csk->snd_win))
-               csk->lock_owner = true;
-
-       spin_unlock_bh(&csk->lock);
-
-       return csk->lock_owner;
-}
-
 static void cxgbit_unlock_sock(struct cxgbit_sock *csk)
 {
        struct sk_buff_head backlogq;
@@ -325,20 +313,16 @@ static int cxgbit_queue_skb(struct cxgbit_sock *csk, struct sk_buff *skb)
 {
        int ret = 0;
 
-       wait_event_interruptible(csk->ack_waitq, cxgbit_lock_sock(csk));
+       spin_lock_bh(&csk->lock);
+       csk->lock_owner = true;
+       spin_unlock_bh(&csk->lock);
 
        if (unlikely((csk->com.state != CSK_STATE_ESTABLISHED) ||
                     signal_pending(current))) {
                __kfree_skb(skb);
                __skb_queue_purge(&csk->ppodq);
                ret = -1;
-               spin_lock_bh(&csk->lock);
-               if (csk->lock_owner) {
-                       spin_unlock_bh(&csk->lock);
-                       goto unlock;
-               }
-               spin_unlock_bh(&csk->lock);
-               return ret;
+               goto unlock;
        }
 
        csk->write_seq += skb->len +