vserver 1.9.5.x5
[linux-2.6.git] / drivers / net / wireless / prism54 / islpci_eth.c
index 3bc6c5f..5952e99 100644 (file)
@@ -1,7 +1,7 @@
-/*  $Header: /var/lib/cvs/prism54-ng/ksrc/islpci_eth.c,v 1.27 2004/01/30 16:24:00 ajfa Exp $
+/*
  *  
  *  Copyright (C) 2002 Intersil Americas Inc.
- *
+ *  Copyright (C) 2004 Aurelien Alleaume <slts@free.fr>
  *  This program is free software; you can redistribute it and/or modify
  *  it under the terms of the GNU General Public License as published by
  *  the Free Software Foundation; either version 2 of the License
 #include <linux/delay.h>
 #include <linux/netdevice.h>
 #include <linux/etherdevice.h>
+#include <linux/if_arp.h>
 
+#include "prismcompat.h"
 #include "isl_38xx.h"
 #include "islpci_eth.h"
 #include "islpci_mgt.h"
+#include "oid_mgt.h"
 
 /******************************************************************************
     Network Interface functions
@@ -102,7 +105,7 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
 
        /* check whether the destination queue has enough fragments for the frame */
        curr_frag = le32_to_cpu(cb->driver_curr_frag[ISL38XX_CB_TX_DATA_LQ]);
-       if (curr_frag - priv->free_data_tx >= ISL38XX_CB_TX_QSIZE) {
+       if (unlikely(curr_frag - priv->free_data_tx >= ISL38XX_CB_TX_QSIZE)) {
                printk(KERN_ERR "%s: transmit device queue full when awake\n",
                       ndev->name);
                netif_stop_queue(ndev);
@@ -118,7 +121,7 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
        /* Check alignment and WDS frame formatting. The start of the packet should
         * be aligned on a 4-byte boundary. If WDS is enabled add another 6 bytes
         * and add WDS address information */
-       if (((long) skb->data & 0x03) | init_wds) {
+       if (likely(((long) skb->data & 0x03) | init_wds)) {
                /* get the number of bytes to add and re-allign */
                offset = (4 - (long) skb->data) & 0x03;
                offset += init_wds ? 6 : 0;
@@ -153,6 +156,12 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
                } else {
                        newskb =
                            dev_alloc_skb(init_wds ? skb->len + 6 : skb->len);
+                       if (unlikely(newskb == NULL)) {
+                               printk(KERN_ERR "%s: Cannot allocate skb\n",
+                                      ndev->name);
+                               err = -ENOMEM;
+                               goto drop_free;
+                       }
                        newskb_offset = (4 - (long) newskb->data) & 0x03;
 
                        /* Check if newskb->data is aligned */
@@ -189,7 +198,7 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
        pci_map_address = pci_map_single(priv->pdev,
                                         (void *) skb->data, skb->len,
                                         PCI_DMA_TODEVICE);
-       if (pci_map_address == 0) {
+       if (unlikely(pci_map_address == 0)) {
                printk(KERN_WARNING "%s: cannot map buffer to PCI\n",
                       ndev->name);
 
@@ -205,7 +214,7 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
        priv->data_low_tx[index] = skb;
        /* set the proper fragment start address and size information */
        fragment->size = cpu_to_le16(frame_size);
-       fragment->flags = cpu_to_le16(0);  /* set to 1 if more fragments */
+       fragment->flags = cpu_to_le16(0);       /* set to 1 if more fragments */
        fragment->address = cpu_to_le32(pci_map_address);
        curr_frag++;
 
@@ -215,7 +224,7 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
        cb->driver_curr_frag[ISL38XX_CB_TX_DATA_LQ] = cpu_to_le32(curr_frag);
 
        if (curr_frag - priv->free_data_tx + ISL38XX_MIN_QTHRESHOLD
-                                                  > ISL38XX_CB_TX_QSIZE) {
+           > ISL38XX_CB_TX_QSIZE) {
                /* stop sends from upper layers */
                netif_stop_queue(ndev);
 
@@ -236,7 +245,7 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
 
        return 0;
 
- drop_free:
     drop_free:
        /* free the skbuf structure before aborting */
        dev_kfree_skb(skb);
        skb = NULL;
@@ -246,6 +255,69 @@ islpci_eth_transmit(struct sk_buff *skb, struct net_device *ndev)
        return err;
 }
 
+static inline int
+islpci_monitor_rx(islpci_private *priv, struct sk_buff **skb)
+{
+       /* The card reports full 802.11 packets but with a 20 bytes
+        * header and without the FCS. But there a is a bit that
+        * indicates if the packet is corrupted :-) */
+       struct rfmon_header *hdr = (struct rfmon_header *) (*skb)->data;
+       if (hdr->flags & 0x01)
+               /* This one is bad. Drop it ! */
+               return -1;
+       if (priv->ndev->type == ARPHRD_IEEE80211_PRISM) {
+               struct avs_80211_1_header *avs;
+               /* extract the relevant data from the header */
+               u32 clock = le32_to_cpu(hdr->clock);
+               u8 rate = hdr->rate;
+               u16 freq = le16_to_cpu(hdr->freq);
+               u8 rssi = hdr->rssi;
+
+               skb_pull(*skb, sizeof (struct rfmon_header));
+
+               if (skb_headroom(*skb) < sizeof (struct avs_80211_1_header)) {
+                       struct sk_buff *newskb = skb_copy_expand(*skb,
+                                                                sizeof (struct
+                                                                        avs_80211_1_header),
+                                                                0, GFP_ATOMIC);
+                       if (newskb) {
+                               dev_kfree_skb_irq(*skb);
+                               *skb = newskb;
+                       } else
+                               return -1;
+                       /* This behavior is not very subtile... */
+               }
+
+               /* make room for the new header and fill it. */
+               avs =
+                   (struct avs_80211_1_header *) skb_push(*skb,
+                                                          sizeof (struct
+                                                                  avs_80211_1_header));
+               
+               avs->version = cpu_to_be32(P80211CAPTURE_VERSION);
+               avs->length = cpu_to_be32(sizeof (struct avs_80211_1_header));
+               avs->mactime = cpu_to_be64(le64_to_cpu(clock));
+               avs->hosttime = cpu_to_be64(jiffies);
+               avs->phytype = cpu_to_be32(6);  /*OFDM: 6 for (g), 8 for (a) */
+               avs->channel = cpu_to_be32(channel_of_freq(freq));
+               avs->datarate = cpu_to_be32(rate * 5);
+               avs->antenna = cpu_to_be32(0);  /*unknown */
+               avs->priority = cpu_to_be32(0); /*unknown */
+               avs->ssi_type = cpu_to_be32(3); /*2: dBm, 3: raw RSSI */
+               avs->ssi_signal = cpu_to_be32(rssi & 0x7f);
+               avs->ssi_noise = cpu_to_be32(priv->local_iwstatistics.qual.noise);      /*better than 'undefined', I assume */
+               avs->preamble = cpu_to_be32(0); /*unknown */
+               avs->encoding = cpu_to_be32(0); /*unknown */
+       } else
+               skb_pull(*skb, sizeof (struct rfmon_header));
+
+       (*skb)->protocol = htons(ETH_P_802_2);
+       (*skb)->mac.raw = (*skb)->data;
+       (*skb)->pkt_type = PACKET_OTHERHOST;
+
+       return 0;
+}
+
 int
 islpci_eth_receive(islpci_private *priv)
 {
@@ -266,7 +338,8 @@ islpci_eth_receive(islpci_private *priv)
        index = priv->free_data_rx % ISL38XX_CB_RX_QSIZE;
        size = le16_to_cpu(control_block->rx_data_low[index].size);
        skb = priv->data_low_rx[index];
-       offset = ((unsigned long) le32_to_cpu(control_block->rx_data_low[index].address) -
+       offset = ((unsigned long)
+                 le32_to_cpu(control_block->rx_data_low[index].address) -
                  (unsigned long) skb->data) & 3;
 
 #if VERBOSE > SHOW_ERROR_MESSAGES
@@ -314,29 +387,32 @@ islpci_eth_receive(islpci_private *priv)
        /* do some additional sk_buff and network layer parameters */
        skb->dev = ndev;
 
-       /* take care of monitor mode */
-       if (priv->iw_mode == IW_MODE_MONITOR) {
-               /* The card reports full 802.11 packets but with a 20 bytes
-                * header and without the FCS. But there a is a bit that
-                * indicates if the packet is corrupted :-) */
-               /* int i; */
-               if (skb->data[8] & 0x01){
-                       /* This one is bad. Drop it !*/
-                       discard = 1;
-                       /* printk("BAD\n");*/
+       /* take care of monitor mode and spy monitoring. */
+       if (unlikely(priv->iw_mode == IW_MODE_MONITOR))
+               discard = islpci_monitor_rx(priv, &skb);
+       else {
+               if (unlikely(skb->data[2 * ETH_ALEN] == 0)) {
+                       /* The packet has a rx_annex. Read it for spy monitoring, Then
+                        * remove it, while keeping the 2 leading MAC addr.
+                        */
+                       struct iw_quality wstats;
+                       struct rx_annex_header *annex =
+                           (struct rx_annex_header *) skb->data;
+                       wstats.level = annex->rfmon.rssi;
+                       /* The noise value can be a bit outdated if nobody's 
+                        * reading wireless stats... */
+                       wstats.noise = priv->local_iwstatistics.qual.noise;
+                       wstats.qual = wstats.level - wstats.noise;
+                       wstats.updated = 0x07;
+                       /* Update spy records */
+                       wireless_spy_update(ndev, annex->addr2, &wstats);
+
+                       memcpy(skb->data + sizeof (struct rfmon_header),
+                              skb->data, 2 * ETH_ALEN);
+                       skb_pull(skb, sizeof (struct rfmon_header));
                }
-               /*
-               for(i=0;i<50;i++)
-                       printk("%2.2X:",skb->data[i]);
-               printk("\n");
-               */              
-               skb_pull(skb, 20);
-               skb->protocol = htons(ETH_P_802_2);
-               skb->mac.raw = skb->data;
-               skb->pkt_type = PACKET_OTHERHOST;
-       } else
                skb->protocol = eth_type_trans(skb, ndev);
-
+       }
        skb->ip_summed = CHECKSUM_NONE;
        priv->statistics.rx_packets++;
        priv->statistics.rx_bytes += size;
@@ -348,11 +424,10 @@ islpci_eth_receive(islpci_private *priv)
             skb->data[0], skb->data[1], skb->data[2], skb->data[3],
             skb->data[4], skb->data[5]);
 #endif
-       if (discard) {
-               dev_kfree_skb(skb);
+       if (unlikely(discard)) {
+               dev_kfree_skb_irq(skb);
                skb = NULL;
-       }
-       else
+       } else
                netif_rx(skb);
 
        /* increment the read index for the rx data low queue */
@@ -365,11 +440,13 @@ islpci_eth_receive(islpci_private *priv)
               index - priv->free_data_rx < ISL38XX_CB_RX_QSIZE) {
                /* allocate an sk_buff for received data frames storage
                 * include any required allignment operations */
-               if (skb = dev_alloc_skb(MAX_FRAGMENT_SIZE_RX + 2), skb == NULL) {
+               skb = dev_alloc_skb(MAX_FRAGMENT_SIZE_RX + 2);
+               if (unlikely(skb == NULL)) {
                        /* error allocating an sk_buff structure elements */
                        DEBUG(SHOW_ERROR_MESSAGES, "Error allocating skb \n");
                        break;
                }
+               skb_reserve(skb, (4 - (long) skb->data) & 0x03);
                /* store the new skb structure pointer */
                index = index % ISL38XX_CB_RX_QSIZE;
                priv->data_low_rx[index] = skb;
@@ -385,13 +462,13 @@ islpci_eth_receive(islpci_private *priv)
                    pci_map_single(priv->pdev, (void *) skb->data,
                                   MAX_FRAGMENT_SIZE_RX + 2,
                                   PCI_DMA_FROMDEVICE);
-               if (priv->pci_map_rx_address[index] == (dma_addr_t) NULL) {
+               if (unlikely(priv->pci_map_rx_address[index] == (dma_addr_t) NULL)) {
                        /* error mapping the buffer to device accessable memory address */
                        DEBUG(SHOW_ERROR_MESSAGES,
                              "Error mapping DMA address\n");
 
                        /* free the skbuf structure before aborting */
-                       dev_kfree_skb((struct sk_buff *) skb);
+                       dev_kfree_skb_irq((struct sk_buff *) skb);
                        skb = NULL;
                        break;
                }
@@ -403,7 +480,7 @@ islpci_eth_receive(islpci_private *priv)
                wmb();
 
                /* increment the driver read pointer */
-               add_le32p((u32 *) & control_block->
+               add_le32p((u32 *) &control_block->
                          driver_curr_frag[ISL38XX_CB_RX_DATA_LQ], 1);
        }
 
@@ -413,6 +490,15 @@ islpci_eth_receive(islpci_private *priv)
        return 0;
 }
 
+void
+islpci_do_reset_and_wake(void *data)
+{
+       islpci_private *priv = (islpci_private *) data;
+       islpci_reset(priv, 1);
+       netif_wake_queue(priv->ndev);
+       priv->reset_task_pending = 0;
+}
+
 void
 islpci_eth_tx_timeout(struct net_device *ndev)
 {
@@ -422,13 +508,12 @@ islpci_eth_tx_timeout(struct net_device *ndev)
        /* increment the transmit error counter */
        statistics->tx_errors++;
 
-#if 0
-       /* don't do this here! we are not allowed to sleep since we are in interrupt context */
-       if (islpci_reset(priv))
-               printk(KERN_ERR "%s: error on TX timeout card reset!\n",
-                      ndev->name);
-#endif
-
-       /* netif_wake_queue(ndev); */
-       return;
+       printk(KERN_WARNING "%s: tx_timeout", ndev->name);
+       if (!priv->reset_task_pending) {
+               priv->reset_task_pending = 1;
+               printk(", scheduling a reset");
+               netif_stop_queue(ndev);
+               schedule_work(&priv->reset_task);
+       }
+       printk("\n");
 }