Commit 4bb6b515 authored by Vasu Dev's avatar Vasu Dev Committed by James Bottomley

[SCSI] fcoe: reduces lock cost when adding a new skb to fcoe_pending_queue

Currently fcoe_pending_queue.lock held twice for every new skb
adding to this queue when already least one pkt is pending in this
queue and that is not uncommon once skb pkts starts getting queued
here upon fcoe_start_io => dev_queue_xmit failure.

This patch moves most fcoe_pending_queue logic to fcoe_check_wait_queue
function, this new logic grabs fcoe_pending_queue.lock only once to
add a new skb instead twice as used to be.

I think after this patch call flow around fcoe_check_wait_queue
calling in fcoe_xmit is bit simplified with modified
fcoe_check_wait_queue function taking care of adding and
removing pending skb in one function.
Signed-off-by: default avatarVasu Dev <vasu.dev@intel.com>
Signed-off-by: default avatarJames Bottomley <James.Bottomley@HansenPartnership.com>
parent 30121d14
...@@ -71,7 +71,7 @@ static struct fc_lport *fcoe_hostlist_lookup(const struct net_device *); ...@@ -71,7 +71,7 @@ static struct fc_lport *fcoe_hostlist_lookup(const struct net_device *);
static int fcoe_hostlist_add(const struct fc_lport *); static int fcoe_hostlist_add(const struct fc_lport *);
static int fcoe_hostlist_remove(const struct fc_lport *); static int fcoe_hostlist_remove(const struct fc_lport *);
static int fcoe_check_wait_queue(struct fc_lport *); static void fcoe_check_wait_queue(struct fc_lport *, struct sk_buff *);
static int fcoe_device_notification(struct notifier_block *, ulong, void *); static int fcoe_device_notification(struct notifier_block *, ulong, void *);
static void fcoe_dev_setup(void); static void fcoe_dev_setup(void);
static void fcoe_dev_cleanup(void); static void fcoe_dev_cleanup(void);
...@@ -989,7 +989,7 @@ u32 fcoe_fc_crc(struct fc_frame *fp) ...@@ -989,7 +989,7 @@ u32 fcoe_fc_crc(struct fc_frame *fp)
*/ */
int fcoe_xmit(struct fc_lport *lp, struct fc_frame *fp) int fcoe_xmit(struct fc_lport *lp, struct fc_frame *fp)
{ {
int wlen, rc = 0; int wlen;
u32 crc; u32 crc;
struct ethhdr *eh; struct ethhdr *eh;
struct fcoe_crc_eof *cp; struct fcoe_crc_eof *cp;
...@@ -1108,18 +1108,9 @@ int fcoe_xmit(struct fc_lport *lp, struct fc_frame *fp) ...@@ -1108,18 +1108,9 @@ int fcoe_xmit(struct fc_lport *lp, struct fc_frame *fp)
/* send down to lld */ /* send down to lld */
fr_dev(fp) = lp; fr_dev(fp) = lp;
if (fc->fcoe_pending_queue.qlen) if (fc->fcoe_pending_queue.qlen)
rc = fcoe_check_wait_queue(lp); fcoe_check_wait_queue(lp, skb);
else if (fcoe_start_io(skb))
if (rc == 0) fcoe_check_wait_queue(lp, skb);
rc = fcoe_start_io(skb);
if (rc) {
spin_lock_bh(&fc->fcoe_pending_queue.lock);
__skb_queue_tail(&fc->fcoe_pending_queue, skb);
spin_unlock_bh(&fc->fcoe_pending_queue.lock);
if (fc->fcoe_pending_queue.qlen > FCOE_MAX_QUEUE_DEPTH)
lp->qfull = 1;
}
return 0; return 0;
} }
...@@ -1285,7 +1276,7 @@ void fcoe_watchdog(ulong vp) ...@@ -1285,7 +1276,7 @@ void fcoe_watchdog(ulong vp)
read_lock(&fcoe_hostlist_lock); read_lock(&fcoe_hostlist_lock);
list_for_each_entry(fc, &fcoe_hostlist, list) { list_for_each_entry(fc, &fcoe_hostlist, list) {
if (fc->ctlr.lp) if (fc->ctlr.lp)
fcoe_check_wait_queue(fc->ctlr.lp); fcoe_check_wait_queue(fc->ctlr.lp, NULL);
} }
read_unlock(&fcoe_hostlist_lock); read_unlock(&fcoe_hostlist_lock);
...@@ -1306,16 +1297,17 @@ void fcoe_watchdog(ulong vp) ...@@ -1306,16 +1297,17 @@ void fcoe_watchdog(ulong vp)
* The wait_queue is used when the skb transmit fails. skb will go * The wait_queue is used when the skb transmit fails. skb will go
* in the wait_queue which will be emptied by the timer function or * in the wait_queue which will be emptied by the timer function or
* by the next skb transmit. * by the next skb transmit.
*
* Returns: 0 for success
*/ */
static int fcoe_check_wait_queue(struct fc_lport *lp) static void fcoe_check_wait_queue(struct fc_lport *lp, struct sk_buff *skb)
{ {
struct fcoe_softc *fc = lport_priv(lp); struct fcoe_softc *fc = lport_priv(lp);
struct sk_buff *skb; int rc;
int rc = -1;
spin_lock_bh(&fc->fcoe_pending_queue.lock); spin_lock_bh(&fc->fcoe_pending_queue.lock);
if (skb)
__skb_queue_tail(&fc->fcoe_pending_queue, skb);
if (fc->fcoe_pending_queue_active) if (fc->fcoe_pending_queue_active)
goto out; goto out;
fc->fcoe_pending_queue_active = 1; fc->fcoe_pending_queue_active = 1;
...@@ -1342,10 +1334,11 @@ static int fcoe_check_wait_queue(struct fc_lport *lp) ...@@ -1342,10 +1334,11 @@ static int fcoe_check_wait_queue(struct fc_lport *lp)
if (fc->fcoe_pending_queue.qlen < FCOE_LOW_QUEUE_DEPTH) if (fc->fcoe_pending_queue.qlen < FCOE_LOW_QUEUE_DEPTH)
lp->qfull = 0; lp->qfull = 0;
fc->fcoe_pending_queue_active = 0; fc->fcoe_pending_queue_active = 0;
rc = fc->fcoe_pending_queue.qlen;
out: out:
if (fc->fcoe_pending_queue.qlen > FCOE_MAX_QUEUE_DEPTH)
lp->qfull = 1;
spin_unlock_bh(&fc->fcoe_pending_queue.lock); spin_unlock_bh(&fc->fcoe_pending_queue.lock);
return rc; return;
} }
/** /**
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment