diff options
Diffstat (limited to 'net/sched')
-rw-r--r-- | net/sched/sch_generic.c | 18 |
1 files changed, 14 insertions, 4 deletions
diff --git a/net/sched/sch_generic.c b/net/sched/sch_generic.c index 1b508bd1c06c..5e7e0bd38fe8 100644 --- a/net/sched/sch_generic.c +++ b/net/sched/sch_generic.c | |||
@@ -52,11 +52,21 @@ static inline int dev_requeue_skb(struct sk_buff *skb, struct Qdisc *q) | |||
52 | 52 | ||
53 | static inline struct sk_buff *dequeue_skb(struct Qdisc *q) | 53 | static inline struct sk_buff *dequeue_skb(struct Qdisc *q) |
54 | { | 54 | { |
55 | struct sk_buff *skb; | 55 | struct sk_buff *skb = skb_peek(&q->requeue); |
56 | 56 | ||
57 | skb = __skb_dequeue(&q->requeue); | 57 | if (unlikely(skb)) { |
58 | if (!skb) | 58 | struct net_device *dev = qdisc_dev(q); |
59 | struct netdev_queue *txq; | ||
60 | |||
61 | /* check the reason of requeuing without tx lock first */ | ||
62 | txq = netdev_get_tx_queue(dev, skb_get_queue_mapping(skb)); | ||
63 | if (!netif_tx_queue_stopped(txq) && !netif_tx_queue_frozen(txq)) | ||
64 | __skb_unlink(skb, &q->requeue); | ||
65 | else | ||
66 | skb = NULL; | ||
67 | } else { | ||
59 | skb = q->dequeue(q); | 68 | skb = q->dequeue(q); |
69 | } | ||
60 | 70 | ||
61 | return skb; | 71 | return skb; |
62 | } | 72 | } |