diff options
author | David S. Miller <davem@davemloft.net> | 2008-07-17 03:34:19 -0400 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2008-07-17 22:21:00 -0400 |
commit | e8a0464cc950972824e2e128028ae3db666ec1ed (patch) | |
tree | 5022b95396c0f3b313531bc39b19543c03551b9a /net/mac80211/wme.c | |
parent | 070825b3840a743e21ebcc44f8279708a4fed977 (diff) |
netdev: Allocate multiple queues for TX.
alloc_netdev_mq() now allocates an array of netdev_queue
structures for TX, based upon the queue_count argument.
Furthermore, all accesses to the TX queues are now vectored
through the netdev_get_tx_queue() and netdev_for_each_tx_queue()
interfaces. This makes it easy to grep the tree for all
things that want to get to a TX queue of a net device.
Problem spots which are not really multiqueue aware yet, and
only work with one queue, can easily be spotted by grepping
for all netdev_get_tx_queue() calls that pass in a zero index.
Signed-off-by: David S. Miller <davem@davemloft.net>
Diffstat (limited to 'net/mac80211/wme.c')
-rw-r--r-- | net/mac80211/wme.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/net/mac80211/wme.c b/net/mac80211/wme.c index 6ae43a3c7726..f014cd38c2d0 100644 --- a/net/mac80211/wme.c +++ b/net/mac80211/wme.c | |||
@@ -574,7 +574,7 @@ static struct Qdisc_ops wme_qdisc_ops __read_mostly = | |||
574 | 574 | ||
575 | void ieee80211_install_qdisc(struct net_device *dev) | 575 | void ieee80211_install_qdisc(struct net_device *dev) |
576 | { | 576 | { |
577 | struct netdev_queue *txq = &dev->tx_queue; | 577 | struct netdev_queue *txq = netdev_get_tx_queue(dev, 0); |
578 | struct Qdisc *qdisc; | 578 | struct Qdisc *qdisc; |
579 | 579 | ||
580 | qdisc = qdisc_create_dflt(dev, txq, | 580 | qdisc = qdisc_create_dflt(dev, txq, |
@@ -596,7 +596,7 @@ void ieee80211_install_qdisc(struct net_device *dev) | |||
596 | 596 | ||
597 | int ieee80211_qdisc_installed(struct net_device *dev) | 597 | int ieee80211_qdisc_installed(struct net_device *dev) |
598 | { | 598 | { |
599 | struct netdev_queue *txq = &dev->tx_queue; | 599 | struct netdev_queue *txq = netdev_get_tx_queue(dev, 0); |
600 | 600 | ||
601 | return txq->qdisc_sleeping->ops == &wme_qdisc_ops; | 601 | return txq->qdisc_sleeping->ops == &wme_qdisc_ops; |
602 | } | 602 | } |
@@ -617,7 +617,7 @@ int ieee80211_ht_agg_queue_add(struct ieee80211_local *local, | |||
617 | struct sta_info *sta, u16 tid) | 617 | struct sta_info *sta, u16 tid) |
618 | { | 618 | { |
619 | int i; | 619 | int i; |
620 | struct netdev_queue *txq = &local->mdev->tx_queue; | 620 | struct netdev_queue *txq = netdev_get_tx_queue(local->mdev, 0); |
621 | struct ieee80211_sched_data *q = | 621 | struct ieee80211_sched_data *q = |
622 | qdisc_priv(txq->qdisc_sleeping); | 622 | qdisc_priv(txq->qdisc_sleeping); |
623 | DECLARE_MAC_BUF(mac); | 623 | DECLARE_MAC_BUF(mac); |
@@ -652,14 +652,14 @@ int ieee80211_ht_agg_queue_add(struct ieee80211_local *local, | |||
652 | } | 652 | } |
653 | 653 | ||
654 | /** | 654 | /** |
655 | * the caller needs to hold local->mdev->tx_queue.lock | 655 | * the caller needs to hold netdev_get_tx_queue(local->mdev, X)->lock |
656 | */ | 656 | */ |
657 | void ieee80211_ht_agg_queue_remove(struct ieee80211_local *local, | 657 | void ieee80211_ht_agg_queue_remove(struct ieee80211_local *local, |
658 | struct sta_info *sta, u16 tid, | 658 | struct sta_info *sta, u16 tid, |
659 | u8 requeue) | 659 | u8 requeue) |
660 | { | 660 | { |
661 | struct ieee80211_hw *hw = &local->hw; | 661 | struct ieee80211_hw *hw = &local->hw; |
662 | struct netdev_queue *txq = &local->mdev->tx_queue; | 662 | struct netdev_queue *txq = netdev_get_tx_queue(local->mdev, 0); |
663 | struct ieee80211_sched_data *q = | 663 | struct ieee80211_sched_data *q = |
664 | qdisc_priv(txq->qdisc_sleeping); | 664 | qdisc_priv(txq->qdisc_sleeping); |
665 | int agg_queue = sta->tid_to_tx_q[tid]; | 665 | int agg_queue = sta->tid_to_tx_q[tid]; |
@@ -676,7 +676,7 @@ void ieee80211_ht_agg_queue_remove(struct ieee80211_local *local, | |||
676 | 676 | ||
677 | void ieee80211_requeue(struct ieee80211_local *local, int queue) | 677 | void ieee80211_requeue(struct ieee80211_local *local, int queue) |
678 | { | 678 | { |
679 | struct netdev_queue *txq = &local->mdev->tx_queue; | 679 | struct netdev_queue *txq = netdev_get_tx_queue(local->mdev, 0); |
680 | struct Qdisc *root_qd = txq->qdisc_sleeping; | 680 | struct Qdisc *root_qd = txq->qdisc_sleeping; |
681 | struct ieee80211_sched_data *q = qdisc_priv(root_qd); | 681 | struct ieee80211_sched_data *q = qdisc_priv(root_qd); |
682 | struct Qdisc *qdisc = q->queues[queue]; | 682 | struct Qdisc *qdisc = q->queues[queue]; |