stagingL vt6656: implement fall back rates reporting.
authorMalcolm Priestley <tvboxspy@gmail.com>
Sat, 5 Jul 2014 18:24:27 +0000 (19:24 +0100)
committerGreg Kroah-Hartman <gregkh@linuxfoundation.org>
Tue, 8 Jul 2014 23:03:57 +0000 (16:03 -0700)
The driver reports the rate tried in struct vnt_interrupt_data tsr* variables
which is available in INTnsProcessData via interrupt urb context.

Instead of closing apTD tx context in s_nsBulkOutIoCompleteWrite by setting
in_use to false. Keep the context open and allow vnt_int_report_rate to
close it.

If the tx_retry value is correct it will report back the sucessful RATE tried.

struct vnt_usb_send_context add pkt_no which is index of apTD

Signed-off-by: Malcolm Priestley <tvboxspy@gmail.com>
Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org>
drivers/staging/vt6656/device.h
drivers/staging/vt6656/int.c
drivers/staging/vt6656/main_usb.c
drivers/staging/vt6656/rxtx.c
drivers/staging/vt6656/usbpipe.c

index 4d1eb226260e938f101621f53a6621218bc4ca29..789c55d1050c9dd9618bddda87b2c9a5528f06b0 100644 (file)
@@ -246,6 +246,8 @@ struct vnt_usb_send_context {
        unsigned int buf_len;
        u16 tx_hdr_size;
        u8 type;
+       u8 pkt_no;
+       u8 fb_option;
        bool in_use;
        unsigned char data[MAX_TOTAL_SIZE_WITH_ALL_HEADERS];
 };
index 1913b73cbec686ff6b168a17d1f9d1fbf50b95af..1cc936455e8ed5c50755349e4ab575ac9365c767 100644 (file)
 
 static int msglevel = MSG_LEVEL_INFO; /* MSG_LEVEL_DEBUG */
 
+static const u8 fallback_rate0[5][5] = {
+       {RATE_18M, RATE_18M, RATE_12M, RATE_12M, RATE_12M},
+       {RATE_24M, RATE_24M, RATE_18M, RATE_12M, RATE_12M},
+       {RATE_36M, RATE_36M, RATE_24M, RATE_18M, RATE_18M},
+       {RATE_48M, RATE_48M, RATE_36M, RATE_24M, RATE_24M},
+       {RATE_54M, RATE_54M, RATE_48M, RATE_36M, RATE_36M}
+};
+
+static const u8 fallback_rate1[5][5] = {
+       {RATE_18M, RATE_18M, RATE_12M, RATE_6M, RATE_6M},
+       {RATE_24M, RATE_24M, RATE_18M, RATE_6M, RATE_6M},
+       {RATE_36M, RATE_36M, RATE_24M, RATE_12M, RATE_12M},
+       {RATE_48M, RATE_48M, RATE_24M, RATE_12M, RATE_12M},
+       {RATE_54M, RATE_54M, RATE_36M, RATE_18M, RATE_18M}
+};
+
 /*+
  *
  *  Function:   InterruptPollingThread
@@ -75,6 +91,62 @@ void INTvWorkItem(struct vnt_private *pDevice)
        spin_unlock_irqrestore(&pDevice->lock, flags);
 }
 
+static int vnt_int_report_rate(struct vnt_private *priv, u8 pkt_no, u8 tsr)
+{
+       struct vnt_usb_send_context *context;
+       struct ieee80211_tx_info *info;
+       struct ieee80211_rate *rate;
+       u8 tx_retry = (tsr & 0xf0) >> 4;
+       s8 idx;
+
+       if (pkt_no >= priv->cbTD)
+               return -EINVAL;
+
+       context = priv->apTD[pkt_no];
+
+       if (!context->skb)
+               return -EINVAL;
+
+       info = IEEE80211_SKB_CB(context->skb);
+       idx = info->control.rates[0].idx;
+
+       if (context->fb_option && !(tsr & (TSR_TMO | TSR_RETRYTMO))) {
+               u8 tx_rate;
+               u8 retry = tx_retry;
+
+               rate = ieee80211_get_tx_rate(priv->hw, info);
+               tx_rate = rate->hw_value - RATE_18M;
+
+               if (retry > 4)
+                       retry = 4;
+
+               if (context->fb_option == AUTO_FB_0)
+                       tx_rate = fallback_rate0[tx_rate][retry];
+               else if (context->fb_option == AUTO_FB_1)
+                       tx_rate = fallback_rate1[tx_rate][retry];
+
+               if (info->band == IEEE80211_BAND_5GHZ)
+                       idx = tx_rate - RATE_6M;
+               else
+                       idx = tx_rate;
+       }
+
+       ieee80211_tx_info_clear_status(info);
+
+       info->status.rates[0].count = tx_retry;
+
+       if (!(tsr & (TSR_TMO | TSR_RETRYTMO))) {
+               info->status.rates[0].idx = idx;
+               info->flags |= IEEE80211_TX_STAT_ACK;
+       }
+
+       ieee80211_tx_status_irqsafe(priv->hw, context->skb);
+
+       context->in_use = false;
+
+       return 0;
+}
+
 void INTnsProcessData(struct vnt_private *priv)
 {
        struct vnt_interrupt_data *int_data;
@@ -85,33 +157,17 @@ void INTnsProcessData(struct vnt_private *priv)
 
        int_data = (struct vnt_interrupt_data *)priv->int_buf.data_buf;
 
-       if (int_data->tsr0 & TSR_VALID) {
-               if (int_data->tsr0 & (TSR_TMO | TSR_RETRYTMO))
-                       priv->wstats.discard.retries++;
-               else
-                       stats->tx_packets++;
-       }
+       if (int_data->tsr0 & TSR_VALID)
+               vnt_int_report_rate(priv, int_data->pkt0, int_data->tsr0);
 
-       if (int_data->tsr1 & TSR_VALID) {
-               if (int_data->tsr1 & (TSR_TMO | TSR_RETRYTMO))
-                       priv->wstats.discard.retries++;
-               else
-                       stats->tx_packets++;
-       }
+       if (int_data->tsr1 & TSR_VALID)
+               vnt_int_report_rate(priv, int_data->pkt1, int_data->tsr1);
 
-       if (int_data->tsr2 & TSR_VALID) {
-               if (int_data->tsr2 & (TSR_TMO | TSR_RETRYTMO))
-                       priv->wstats.discard.retries++;
-               else
-                       stats->tx_packets++;
-       }
+       if (int_data->tsr2 & TSR_VALID)
+               vnt_int_report_rate(priv, int_data->pkt2, int_data->tsr2);
 
-       if (int_data->tsr3 & TSR_VALID) {
-               if (int_data->tsr3 & (TSR_TMO | TSR_RETRYTMO))
-                       priv->wstats.discard.retries++;
-               else
-                       stats->tx_packets++;
-       }
+       if (int_data->tsr3 & TSR_VALID)
+               vnt_int_report_rate(priv, int_data->pkt3, int_data->tsr3);
 
        if (int_data->isr0 != 0) {
                if (int_data->isr0 & ISR_BNTX &&
index 9d0441f3d9d91956068ce7a1de5c2fab30bce717..4cdf29eb593e494687677384e2530fb23d5afa4b 100644 (file)
@@ -557,6 +557,7 @@ static bool device_alloc_bufs(struct vnt_private *priv)
 
                priv->apTD[ii] = tx_context;
                tx_context->priv = priv;
+               tx_context->pkt_no = ii;
 
                /* allocate URBs */
                tx_context->urb = usb_alloc_urb(0, GFP_ATOMIC);
index 95b6cf307af6f94892481fd4eca8050843c8610e..264e3c9b6412c2884d5a5ea7f681bc50520356ad 100644 (file)
@@ -1021,6 +1021,8 @@ int vnt_tx_packet(struct vnt_private *priv, struct sk_buff *skb)
                }
        }
 
+       tx_context->fb_option = fb_option;
+
        duration_id = s_vGenerateTxParameter(tx_context, pkt_type, current_rate,
                                tx_buffer, &mic_hdr, need_mic, frame_size,
                                                need_ack, NULL, need_rts);
@@ -1050,8 +1052,7 @@ int vnt_tx_packet(struct vnt_private *priv, struct sk_buff *skb)
                                                IEEE80211_SCTL_SEQ) >> 4;
 
        tx_buffer->tx_byte_count = cpu_to_le16(tx_bytes);
-       tx_buffer->byPKTNO = (u8)(((current_rate << 4) & 0xf0) |
-               (priv->wSeqCounter & 0xf));
+       tx_buffer->byPKTNO = tx_context->pkt_no;
        tx_buffer->byType = 0x00;
 
        tx_bytes += 4;
@@ -1147,8 +1148,7 @@ static int vnt_beacon_xmit(struct vnt_private *priv,
        count = sizeof(struct vnt_tx_short_buf_head) + skb->len;
 
        beacon_buffer->tx_byte_count = cpu_to_le16(count);
-       beacon_buffer->byPKTNO = (u8)(((current_rate << 4) & 0xf0) |
-                               ((priv->wSeqCounter - 1) & 0x000f));
+       beacon_buffer->byPKTNO = context->pkt_no;
        beacon_buffer->byType = 0x01;
 
        context->type = CONTEXT_BEACON_PACKET;
index a7af4f58898e233a993fd89c2de0e5dcc1893a46..c8b0ed5adf7a967075d7412d0a8ede744296adc2 100644 (file)
@@ -398,7 +398,6 @@ static void s_nsBulkOutIoCompleteWrite(struct urb *urb)
 {
        struct vnt_usb_send_context *context = urb->context;
        struct vnt_private *priv = context->priv;
-       struct ieee80211_tx_info *info;
 
        switch (urb->status) {
        case 0:
@@ -415,25 +414,15 @@ static void s_nsBulkOutIoCompleteWrite(struct urb *urb)
                break;
        }
 
-       if (context->skb) {
-               s8 idx;
-
-               info = IEEE80211_SKB_CB(context->skb);
-
-               idx = info->control.rates[0].idx;
-
-               ieee80211_tx_info_clear_status(info);
-               info->status.rates[0].idx = idx;
-               info->status.rates[0].count = 0;
-               if (!urb->status)
-                       info->flags |= IEEE80211_TX_STAT_ACK;
-               ieee80211_tx_status_irqsafe(priv->hw, context->skb);
-       }
-
        if (context->type == CONTEXT_DATA_PACKET)
                ieee80211_wake_queues(priv->hw);
 
-       context->in_use = false;
+       if (urb->status || context->type == CONTEXT_BEACON_PACKET) {
+               if (context->skb)
+                       ieee80211_free_txskb(priv->hw, context->skb);
+
+               context->in_use = false;
+       }
 
        return;
 }