mwifiex: add multi-queue support

This patch adds support for multiple TX queues inside mwifiex
driver. Four different queues according to WMM access categories
are defined for each virtual interface. When a packet is
received from netdev for transmission, tx pending count for
particular queue is incremented and if tx pending count has
reached upper water-mark, this queue is stopped instead of
stopping all queues. Similarly when a packet is successfully
transmitted from device, tx pending count is decremented per
queue and if pending count falls below lower water-mark, queue
operations are again resumed. This ensures that not all
tranmission is blocked if traffic with particular TOS value
suddenly increases.

Also wake all queues after association/IBSS_join/uAP_BSS_start
to enable traffic on all queues.

Signed-off-by: Avinash Patil <patila@marvell.com>
Signed-off-by: Bing Zhao <bzhao@marvell.com>
Signed-off-by: John W. Linville <linville@tuxdriver.com>

1 files changed, 8 insertions, 2 deletions

diff --git a/drivers/net/wireless/mwifiex/debugfs.c b/drivers/net/wireless/mwifiex/debugfs.c
index a870b5885c09..46e34aa65d1c 100644
--- a/drivers/net/wireless/mwifiex/debugfs.c
+++ b/drivers/net/wireless/mwifiex/debugfs.c
@@ -178,6 +178,7 @@ mwifiex_info_read(struct file *file, char __user *ubuf,
                 (struct mwifiex_private *) file->private_data;
         struct net_device *netdev = priv->netdev;
         struct netdev_hw_addr *ha;
+        struct netdev_queue *txq;
         unsigned long page = get_zeroed_page(GFP_KERNEL);
         char *p = (char *) page, fmt[64];
         struct mwifiex_bss_info info;
@@ -229,8 +230,13 @@ mwifiex_info_read(struct file *file, char __user *ubuf,
         p += sprintf(p, "num_rx_pkts_err = %lu\n", priv->stats.rx_errors);
         p += sprintf(p, "carrier %s\n", ((netif_carrier_ok(priv->netdev))
                                          ? "on" : "off"));
-        p += sprintf(p, "tx queue %s\n", ((netif_queue_stopped(priv->netdev))
-                                          ? "stopped" : "started"));
+        p += sprintf(p, "tx queue");
+        for (i = 0; i < netdev->num_tx_queues; i++) {
+                txq = netdev_get_tx_queue(netdev, i);
+                p += sprintf(p, " %d:%s", i, netif_tx_queue_stopped(txq) ?
+                             "stopped" : "started");
+        }
+        p += sprintf(p, "\n");
 
         ret = simple_read_from_buffer(ubuf, count, ppos, (char *) page,
                                       (unsigned long) p - page);