git.oblomov.eu Git - linux-2.6/blob - drivers/net/tokenring/lanstreamer.c

   1 /*
   2  *   lanstreamer.c -- driver for the IBM Auto LANStreamer PCI Adapter
   3  *
   4  *  Written By: Mike Sullivan, IBM Corporation
   5  *
   6  *  Copyright (C) 1999 IBM Corporation
   7  *
   8  *  Linux driver for IBM PCI tokenring cards based on the LanStreamer MPC
   9  *  chipset.
  10  *
  11  *  This driver is based on the olympic driver for IBM PCI TokenRing cards (Pit/Pit-Phy/Olympic
  12  *  chipsets) written  by:
  13  *      1999 Peter De Schrijver All Rights Reserved
  14  *      1999 Mike Phillips (phillim@amtrak.com)
  15  *
  16  *  Base Driver Skeleton:
  17  *      Written 1993-94 by Donald Becker.
  18  *
  19  *      Copyright 1993 United States Government as represented by the
  20  *      Director, National Security Agency.
  21  *
  22  * This program is free software; you can redistribute it and/or modify
  23  * it under the terms of the GNU General Public License as published by
  24  * the Free Software Foundation; either version 2 of the License, or
  25  * (at your option) any later version.
  26  *
  27  * This program is distributed in the hope that it will be useful,
  28  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  29  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  30  * GNU General Public License for more details.
  31  *
  32  * NO WARRANTY
  33  * THE PROGRAM IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OR
  34  * CONDITIONS OF ANY KIND, EITHER EXPRESS OR IMPLIED INCLUDING, WITHOUT
  35  * LIMITATION, ANY WARRANTIES OR CONDITIONS OF TITLE, NON-INFRINGEMENT,
  36  * MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE. Each Recipient is
  37  * solely responsible for determining the appropriateness of using and
  38  * distributing the Program and assumes all risks associated with its
  39  * exercise of rights under this Agreement, including but not limited to
  40  * the risks and costs of program errors, damage to or loss of data,
  41  * programs or equipment, and unavailability or interruption of operations.
  42  *
  43  * DISCLAIMER OF LIABILITY
  44  * NEITHER RECIPIENT NOR ANY CONTRIBUTORS SHALL HAVE ANY LIABILITY FOR ANY
  45  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  46  * DAMAGES (INCLUDING WITHOUT LIMITATION LOST PROFITS), HOWEVER CAUSED AND
  47  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR
  48  * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
  49  * USE OR DISTRIBUTION OF THE PROGRAM OR THE EXERCISE OF ANY RIGHTS GRANTED
  50  * HEREUNDER, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGES
  51  *
  52  * You should have received a copy of the GNU General Public License
  53  * along with this program; if not, write to the Free Software
  54  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  55  *
  56  *
  57  *  12/10/99 - Alpha Release 0.1.0
  58  *            First release to the public
  59  *  03/03/00 - Merged to kernel, indented -kr -i8 -bri0, fixed some missing
  60  *              malloc free checks, reviewed code. <alan@redhat.com>
  61  *  03/13/00 - Added spinlocks for smp
  62  *  03/08/01 - Added support for module_init() and module_exit()
  63  *  08/15/01 - Added ioctl() functionality for debugging, changed netif_*_queue
  64  *             calls and other incorrectness - Kent Yoder <yoder1@us.ibm.com>
  65  *  11/05/01 - Restructured the interrupt function, added delays, reduced the
  66  *             the number of TX descriptors to 1, which together can prevent
  67  *             the card from locking up the box - <yoder1@us.ibm.com>
  68  *  09/27/02 - New PCI interface + bug fix. - <yoder1@us.ibm.com>
  69  *  11/13/02 - Removed free_irq calls which could cause a hang, added
  70  *             netif_carrier_{on|off} - <yoder1@us.ibm.com>
  71  *
  72  *  To Do:
  73  *
  74  *
  75  *  If Problems do Occur
  76  *  Most problems can be rectified by either closing and opening the interface
  77  *  (ifconfig down and up) or rmmod and insmod'ing the driver (a bit difficult
  78  *  if compiled into the kernel).
  79  */
  80
  81 /* Change STREAMER_DEBUG to 1 to get verbose, and I mean really verbose, messages */
  82
  83 #define STREAMER_DEBUG 0
  84 #define STREAMER_DEBUG_PACKETS 0
  85
  86 /* Change STREAMER_NETWORK_MONITOR to receive mac frames through the arb channel.
  87  * Will also create a /proc/net/streamer_tr entry if proc_fs is compiled into the
  88  * kernel.
  89  * Intended to be used to create a ring-error reporting network module
  90  * i.e. it will give you the source address of beaconers on the ring
  91  */
  92
  93 #define STREAMER_NETWORK_MONITOR 0
  94
  95 /* #define CONFIG_PROC_FS */
  96
  97 /*
  98  *  Allow or disallow ioctl's for debugging
  99  */
 100
 101 #define STREAMER_IOCTL 0
 102
 103 #include <linux/module.h>
 104 #include <linux/kernel.h>
 105 #include <linux/errno.h>
 106 #include <linux/timer.h>
 107 #include <linux/in.h>
 108 #include <linux/ioport.h>
 109 #include <linux/string.h>
 110 #include <linux/proc_fs.h>
 111 #include <linux/ptrace.h>
 112 #include <linux/skbuff.h>
 113 #include <linux/interrupt.h>
 114 #include <linux/delay.h>
 115 #include <linux/netdevice.h>
 116 #include <linux/trdevice.h>
 117 #include <linux/stddef.h>
 118 #include <linux/init.h>
 119 #include <linux/pci.h>
 120 #include <linux/dma-mapping.h>
 121 #include <linux/spinlock.h>
 122 #include <linux/version.h>
 123 #include <linux/bitops.h>
 124 #include <linux/jiffies.h>
 125
 126 #include <net/checksum.h>
 127
 128 #include <asm/io.h>
 129 #include <asm/system.h>
 130
 131 #include "lanstreamer.h"
 132
 133 #if (BITS_PER_LONG == 64)
 134 #error broken on 64-bit: stores pointer to rx_ring->buffer in 32-bit int
 135 #endif
 136
 137
 138 /* I've got to put some intelligence into the version number so that Peter and I know
 139  * which version of the code somebody has got.
 140  * Version Number = a.b.c.d  where a.b.c is the level of code and d is the latest author.
 141  * So 0.0.1.pds = Peter, 0.0.1.mlp = Mike
 142  *
 143  * Official releases will only have an a.b.c version number format.
 144  */
 145
 146 static char version[] = "LanStreamer.c v0.4.0 03/08/01 - Mike Sullivan\n"
 147                         "              v0.5.3 11/13/02 - Kent Yoder";
 148
 149 static struct pci_device_id streamer_pci_tbl[] = {
 150         { PCI_VENDOR_ID_IBM, PCI_DEVICE_ID_IBM_TR, PCI_ANY_ID, PCI_ANY_ID,},
 151         {}      /* terminating entry */
 152 };
 153 MODULE_DEVICE_TABLE(pci,streamer_pci_tbl);
 154
 155
 156 static char *open_maj_error[] = {
 157         "No error", "Lobe Media Test", "Physical Insertion",
 158         "Address Verification", "Neighbor Notification (Ring Poll)",
 159         "Request Parameters", "FDX Registration Request",
 160         "FDX Lobe Media Test", "FDX Duplicate Address Check",
 161         "Unknown stage"
 162 };
 163
 164 static char *open_min_error[] = {
 165         "No error", "Function Failure", "Signal Lost", "Wire Fault",
 166         "Ring Speed Mismatch", "Timeout", "Ring Failure", "Ring Beaconing",
 167         "Duplicate Node Address", "Request Parameters", "Remove Received",
 168         "Reserved", "Reserved", "No Monitor Detected for RPL",
 169         "Monitor Contention failer for RPL", "FDX Protocol Error"
 170 };
 171
 172 /* Module paramters */
 173
 174 /* Ring Speed 0,4,16
 175  * 0 = Autosense
 176  * 4,16 = Selected speed only, no autosense
 177  * This allows the card to be the first on the ring
 178  * and become the active monitor.
 179  *
 180  * WARNING: Some hubs will allow you to insert
 181  * at the wrong speed
 182  */
 183
 184 static int ringspeed[STREAMER_MAX_ADAPTERS] = { 0, };
 185
 186 module_param_array(ringspeed, int, NULL, 0);
 187
 188 /* Packet buffer size */
 189
 190 static int pkt_buf_sz[STREAMER_MAX_ADAPTERS] = { 0, };
 191
 192 module_param_array(pkt_buf_sz, int, NULL, 0);
 193
 194 /* Message Level */
 195
 196 static int message_level[STREAMER_MAX_ADAPTERS] = { 1, };
 197
 198 module_param_array(message_level, int, NULL, 0);
 199
 200 #if STREAMER_IOCTL
 201 static int streamer_ioctl(struct net_device *, struct ifreq *, int);
 202 #endif
 203
 204 static int streamer_reset(struct net_device *dev);
 205 static int streamer_open(struct net_device *dev);
 206 static int streamer_xmit(struct sk_buff *skb, struct net_device *dev);
 207 static int streamer_close(struct net_device *dev);
 208 static void streamer_set_rx_mode(struct net_device *dev);
 209 static irqreturn_t streamer_interrupt(int irq, void *dev_id);
 210 static struct net_device_stats *streamer_get_stats(struct net_device *dev);
 211 static int streamer_set_mac_address(struct net_device *dev, void *addr);
 212 static void streamer_arb_cmd(struct net_device *dev);
 213 static int streamer_change_mtu(struct net_device *dev, int mtu);
 214 static void streamer_srb_bh(struct net_device *dev);
 215 static void streamer_asb_bh(struct net_device *dev);
 216 #if STREAMER_NETWORK_MONITOR
 217 #ifdef CONFIG_PROC_FS
 218 static int streamer_proc_info(char *buffer, char **start, off_t offset,
 219                               int length, int *eof, void *data);
 220 static int sprintf_info(char *buffer, struct net_device *dev);
 221 struct streamer_private *dev_streamer=NULL;
 222 #endif
 223 #endif
 224
 225 static int __devinit streamer_init_one(struct pci_dev *pdev,
 226                                        const struct pci_device_id *ent)
 227 {
 228         struct net_device *dev;
 229         struct streamer_private *streamer_priv;
 230         unsigned long pio_start, pio_end, pio_flags, pio_len;
 231         unsigned long mmio_start, mmio_end, mmio_flags, mmio_len;
 232         int rc = 0;
 233         static int card_no=-1;
 234         u16 pcr;
 235
 236 #if STREAMER_DEBUG
 237         printk("lanstreamer::streamer_init_one, entry pdev %p\n",pdev);
 238 #endif
 239
 240         card_no++;
 241         dev = alloc_trdev(sizeof(*streamer_priv));
 242         if (dev==NULL) {
 243                 printk(KERN_ERR "lanstreamer: out of memory.\n");
 244                 return -ENOMEM;
 245         }
 246
 247         SET_MODULE_OWNER(dev);
 248         streamer_priv = dev->priv;
 249
 250 #if STREAMER_NETWORK_MONITOR
 251 #ifdef CONFIG_PROC_FS
 252         if (!dev_streamer)
 253                 create_proc_read_entry("net/streamer_tr", 0, 0,
 254                                         streamer_proc_info, NULL);
 255         streamer_priv->next = dev_streamer;
 256         dev_streamer = streamer_priv;
 257 #endif
 258 #endif
 259
 260         rc = pci_set_dma_mask(pdev, DMA_32BIT_MASK);
 261         if (rc) {
 262                 printk(KERN_ERR "%s: No suitable PCI mapping available.\n",
 263                                 dev->name);
 264                 rc = -ENODEV;
 265                 goto err_out;
 266         }
 267
 268         rc = pci_enable_device(pdev);
 269         if (rc) {
 270                 printk(KERN_ERR "lanstreamer: unable to enable pci device\n");
 271                 rc=-EIO;
 272                 goto err_out;
 273         }
 274
 275         pci_set_master(pdev);
 276
 277         rc = pci_set_mwi(pdev);
 278         if (rc) {
 279                 printk(KERN_ERR "lanstreamer: unable to enable MWI on pci device\n");
 280                 goto err_out_disable;
 281         }
 282
 283         pio_start = pci_resource_start(pdev, 0);
 284         pio_end = pci_resource_end(pdev, 0);
 285         pio_flags = pci_resource_flags(pdev, 0);
 286         pio_len = pci_resource_len(pdev, 0);
 287
 288         mmio_start = pci_resource_start(pdev, 1);
 289         mmio_end = pci_resource_end(pdev, 1);
 290         mmio_flags = pci_resource_flags(pdev, 1);
 291         mmio_len = pci_resource_len(pdev, 1);
 292
 293 #if STREAMER_DEBUG
 294         printk("lanstreamer: pio_start %x pio_end %x pio_len %x pio_flags %x\n",
 295                 pio_start, pio_end, pio_len, pio_flags);
 296         printk("lanstreamer: mmio_start %x mmio_end %x mmio_len %x mmio_flags %x\n",
 297                 mmio_start, mmio_end, mmio_flags, mmio_len);
 298 #endif
 299
 300         if (!request_region(pio_start, pio_len, "lanstreamer")) {
 301                 printk(KERN_ERR "lanstreamer: unable to get pci io addr %lx\n",
 302                         pio_start);
 303                 rc= -EBUSY;
 304                 goto err_out_mwi;
 305         }
 306
 307         if (!request_mem_region(mmio_start, mmio_len, "lanstreamer")) {
 308                 printk(KERN_ERR "lanstreamer: unable to get pci mmio addr %lx\n",
 309                         mmio_start);
 310                 rc= -EBUSY;
 311                 goto err_out_free_pio;
 312         }
 313
 314         streamer_priv->streamer_mmio=ioremap(mmio_start, mmio_len);
 315         if (streamer_priv->streamer_mmio == NULL) {
 316                 printk(KERN_ERR "lanstreamer: unable to remap MMIO %lx\n",
 317                         mmio_start);
 318                 rc= -EIO;
 319                 goto err_out_free_mmio;
 320         }
 321
 322         init_waitqueue_head(&streamer_priv->srb_wait);
 323         init_waitqueue_head(&streamer_priv->trb_wait);
 324
 325         dev->open = &streamer_open;
 326         dev->hard_start_xmit = &streamer_xmit;
 327         dev->change_mtu = &streamer_change_mtu;
 328         dev->stop = &streamer_close;
 329 #if STREAMER_IOCTL
 330         dev->do_ioctl = &streamer_ioctl;
 331 #else
 332         dev->do_ioctl = NULL;
 333 #endif
 334         dev->set_multicast_list = &streamer_set_rx_mode;
 335         dev->get_stats = &streamer_get_stats;
 336         dev->set_mac_address = &streamer_set_mac_address;
 337         dev->irq = pdev->irq;
 338         dev->base_addr=pio_start;
 339         SET_NETDEV_DEV(dev, &pdev->dev);
 340
 341         streamer_priv->streamer_card_name = (char *)pdev->resource[0].name;
 342         streamer_priv->pci_dev = pdev;
 343
 344         if ((pkt_buf_sz[card_no] < 100) || (pkt_buf_sz[card_no] > 18000))
 345                 streamer_priv->pkt_buf_sz = PKT_BUF_SZ;
 346         else
 347                 streamer_priv->pkt_buf_sz = pkt_buf_sz[card_no];
 348
 349         streamer_priv->streamer_ring_speed = ringspeed[card_no];
 350         streamer_priv->streamer_message_level = message_level[card_no];
 351
 352         pci_set_drvdata(pdev, dev);
 353
 354         spin_lock_init(&streamer_priv->streamer_lock);
 355
 356         pci_read_config_word (pdev, PCI_COMMAND, &pcr);
 357         pcr |= PCI_COMMAND_SERR;
 358         pci_write_config_word (pdev, PCI_COMMAND, pcr);
 359
 360         printk("%s \n", version);
 361         printk("%s: %s. I/O at %hx, MMIO at %p, using irq %d\n",dev->name,
 362                 streamer_priv->streamer_card_name,
 363                 (unsigned int) dev->base_addr,
 364                 streamer_priv->streamer_mmio,
 365                 dev->irq);
 366
 367         if (streamer_reset(dev))
 368                 goto err_out_unmap;
 369
 370         rc = register_netdev(dev);
 371         if (rc)
 372                 goto err_out_unmap;
 373         return 0;
 374
 375 err_out_unmap:
 376         iounmap(streamer_priv->streamer_mmio);
 377 err_out_free_mmio:
 378         release_mem_region(mmio_start, mmio_len);
 379 err_out_free_pio:
 380         release_region(pio_start, pio_len);
 381 err_out_mwi:
 382         pci_clear_mwi(pdev);
 383 err_out_disable:
 384         pci_disable_device(pdev);
 385 err_out:
 386         free_netdev(dev);
 387 #if STREAMER_DEBUG
 388         printk("lanstreamer: Exit error %x\n",rc);
 389 #endif
 390         return rc;
 391 }
 392
 393 static void __devexit streamer_remove_one(struct pci_dev *pdev)
 394 {
 395         struct net_device *dev=pci_get_drvdata(pdev);
 396         struct streamer_private *streamer_priv;
 397
 398 #if STREAMER_DEBUG
 399         printk("lanstreamer::streamer_remove_one entry pdev %p\n",pdev);
 400 #endif
 401
 402         if (dev == NULL) {
 403                 printk(KERN_ERR "lanstreamer::streamer_remove_one, ERROR dev is NULL\n");
 404                 return;
 405         }
 406
 407         streamer_priv=dev->priv;
 408         if (streamer_priv == NULL) {
 409                 printk(KERN_ERR "lanstreamer::streamer_remove_one, ERROR dev->priv is NULL\n");
 410                 return;
 411         }
 412
 413 #if STREAMER_NETWORK_MONITOR
 414 #ifdef CONFIG_PROC_FS
 415         {
 416                 struct streamer_private **p, **next;
 417
 418                 for (p = &dev_streamer; *p; p = next) {
 419                         next = &(*p)->next;
 420                         if (*p == streamer_priv) {
 421                                 *p = *next;
 422                                 break;
 423                         }
 424                 }
 425                 if (!dev_streamer)
 426                         remove_proc_entry("net/streamer_tr", NULL);
 427         }
 428 #endif
 429 #endif
 430
 431         unregister_netdev(dev);
 432         iounmap(streamer_priv->streamer_mmio);
 433         release_mem_region(pci_resource_start(pdev, 1), pci_resource_len(pdev,1));
 434         release_region(pci_resource_start(pdev, 0), pci_resource_len(pdev,0));
 435         pci_clear_mwi(pdev);
 436         pci_disable_device(pdev);
 437         free_netdev(dev);
 438         pci_set_drvdata(pdev, NULL);
 439 }
 440
 441
 442 static int streamer_reset(struct net_device *dev)
 443 {
 444         struct streamer_private *streamer_priv;
 445         __u8 __iomem *streamer_mmio;
 446         unsigned long t;
 447         unsigned int uaa_addr;
 448         struct sk_buff *skb = NULL;
 449         __u16 misr;
 450
 451         streamer_priv = (struct streamer_private *) dev->priv;
 452         streamer_mmio = streamer_priv->streamer_mmio;
 453
 454         writew(readw(streamer_mmio + BCTL) | BCTL_SOFTRESET, streamer_mmio + BCTL);
 455         t = jiffies;
 456         /* Hold soft reset bit for a while */
 457         ssleep(1);
 458
 459         writew(readw(streamer_mmio + BCTL) & ~BCTL_SOFTRESET,
 460                streamer_mmio + BCTL);
 461
 462 #if STREAMER_DEBUG
 463         printk("BCTL: %x\n", readw(streamer_mmio + BCTL));
 464         printk("GPR: %x\n", readw(streamer_mmio + GPR));
 465         printk("SISRMASK: %x\n", readw(streamer_mmio + SISR_MASK));
 466 #endif
 467         writew(readw(streamer_mmio + BCTL) | (BCTL_RX_FIFO_8 | BCTL_TX_FIFO_8), streamer_mmio + BCTL );
 468
 469         if (streamer_priv->streamer_ring_speed == 0) {  /* Autosense */
 470                 writew(readw(streamer_mmio + GPR) | GPR_AUTOSENSE,
 471                        streamer_mmio + GPR);
 472                 if (streamer_priv->streamer_message_level)
 473                         printk(KERN_INFO "%s: Ringspeed autosense mode on\n",
 474                                dev->name);
 475         } else if (streamer_priv->streamer_ring_speed == 16) {
 476                 if (streamer_priv->streamer_message_level)
 477                         printk(KERN_INFO "%s: Trying to open at 16 Mbps as requested\n",
 478                                dev->name);
 479                 writew(GPR_16MBPS, streamer_mmio + GPR);
 480         } else if (streamer_priv->streamer_ring_speed == 4) {
 481                 if (streamer_priv->streamer_message_level)
 482                         printk(KERN_INFO "%s: Trying to open at 4 Mbps as requested\n",
 483                                dev->name);
 484                 writew(0, streamer_mmio + GPR);
 485         }
 486
 487         skb = dev_alloc_skb(streamer_priv->pkt_buf_sz);
 488         if (!skb) {
 489                 printk(KERN_INFO "%s: skb allocation for diagnostics failed...proceeding\n",
 490                        dev->name);
 491         } else {
 492                 struct streamer_rx_desc *rx_ring;
 493                 u8 *data;
 494
 495                 rx_ring=(struct streamer_rx_desc *)skb->data;
 496                 data=((u8 *)skb->data)+sizeof(struct streamer_rx_desc);
 497                 rx_ring->forward=0;
 498                 rx_ring->status=0;
 499                 rx_ring->buffer=cpu_to_le32(pci_map_single(streamer_priv->pci_dev, data,
 500                                                         512, PCI_DMA_FROMDEVICE));
 501                 rx_ring->framelen_buflen=512;
 502                 writel(cpu_to_le32(pci_map_single(streamer_priv->pci_dev, rx_ring, 512, PCI_DMA_FROMDEVICE)),
 503                         streamer_mmio+RXBDA);
 504         }
 505
 506 #if STREAMER_DEBUG
 507         printk("GPR = %x\n", readw(streamer_mmio + GPR));
 508 #endif
 509         /* start solo init */
 510         writew(SISR_MI, streamer_mmio + SISR_MASK_SUM);
 511
 512         while (!((readw(streamer_mmio + SISR)) & SISR_SRB_REPLY)) {
 513                 msleep_interruptible(100);
 514                 if (time_after(jiffies, t + 40 * HZ)) {
 515                         printk(KERN_ERR
 516                                "IBM PCI tokenring card not responding\n");
 517                         release_region(dev->base_addr, STREAMER_IO_SPACE);
 518                         if (skb)
 519                                 dev_kfree_skb(skb);
 520                         return -1;
 521                 }
 522         }
 523         writew(~SISR_SRB_REPLY, streamer_mmio + SISR_RUM);
 524         misr = readw(streamer_mmio + MISR_RUM);
 525         writew(~misr, streamer_mmio + MISR_RUM);
 526
 527         if (skb)
 528                 dev_kfree_skb(skb);     /* release skb used for diagnostics */
 529
 530 #if STREAMER_DEBUG
 531         printk("LAPWWO: %x, LAPA: %x LAPE:  %x\n",
 532                readw(streamer_mmio + LAPWWO), readw(streamer_mmio + LAPA),
 533                readw(streamer_mmio + LAPE));
 534 #endif
 535
 536 #if STREAMER_DEBUG
 537         {
 538                 int i;
 539                 writew(readw(streamer_mmio + LAPWWO),
 540                        streamer_mmio + LAPA);
 541                 printk("initialization response srb dump: ");
 542                 for (i = 0; i < 10; i++)
 543                         printk("%x:",
 544                                ntohs(readw(streamer_mmio + LAPDINC)));
 545                 printk("\n");
 546         }
 547 #endif
 548
 549         writew(readw(streamer_mmio + LAPWWO) + 6, streamer_mmio + LAPA);
 550         if (readw(streamer_mmio + LAPD)) {
 551                 printk(KERN_INFO "tokenring card initialization failed. errorcode : %x\n",
 552                        ntohs(readw(streamer_mmio + LAPD)));
 553                 release_region(dev->base_addr, STREAMER_IO_SPACE);
 554                 return -1;
 555         }
 556
 557         writew(readw(streamer_mmio + LAPWWO) + 8, streamer_mmio + LAPA);
 558         uaa_addr = ntohs(readw(streamer_mmio + LAPDINC));
 559         readw(streamer_mmio + LAPDINC); /* skip over Level.Addr field */
 560         streamer_priv->streamer_addr_table_addr = ntohs(readw(streamer_mmio + LAPDINC));
 561         streamer_priv->streamer_parms_addr = ntohs(readw(streamer_mmio + LAPDINC));
 562
 563 #if STREAMER_DEBUG
 564         printk("UAA resides at %x\n", uaa_addr);
 565 #endif
 566
 567         /* setup uaa area for access with LAPD */
 568         {
 569                 int i;
 570                 __u16 addr;
 571                 writew(uaa_addr, streamer_mmio + LAPA);
 572                 for (i = 0; i < 6; i += 2) {
 573                         addr=ntohs(readw(streamer_mmio+LAPDINC));
 574                         dev->dev_addr[i]= (addr >> 8) & 0xff;
 575                         dev->dev_addr[i+1]= addr & 0xff;
 576                 }
 577 #if STREAMER_DEBUG
 578                 printk("Adapter address: ");
 579                 for (i = 0; i < 6; i++) {
 580                         printk("%02x:", dev->dev_addr[i]);
 581                 }
 582                 printk("\n");
 583 #endif
 584         }
 585         return 0;
 586 }
 587
 588 static int streamer_open(struct net_device *dev)
 589 {
 590         struct streamer_private *streamer_priv = (struct streamer_private *) dev->priv;
 591         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
 592         unsigned long flags;
 593         char open_error[255];
 594         int i, open_finished = 1;
 595         __u16 srb_word;
 596         __u16 srb_open;
 597         int rc;
 598
 599         if (readw(streamer_mmio+BMCTL_SUM) & BMCTL_RX_ENABLED) {
 600                 rc=streamer_reset(dev);
 601         }
 602
 603         if (request_irq(dev->irq, &streamer_interrupt, IRQF_SHARED, "lanstreamer", dev)) {
 604                 return -EAGAIN;
 605         }
 606 #if STREAMER_DEBUG
 607         printk("BMCTL: %x\n", readw(streamer_mmio + BMCTL_SUM));
 608         printk("pending ints: %x\n", readw(streamer_mmio + SISR));
 609 #endif
 610
 611         writew(SISR_MI | SISR_SRB_REPLY, streamer_mmio + SISR_MASK);    /* more ints later, doesn't stop arb cmd interrupt */
 612         writew(LISR_LIE, streamer_mmio + LISR); /* more ints later */
 613
 614         /* adapter is closed, so SRB is pointed to by LAPWWO */
 615         writew(readw(streamer_mmio + LAPWWO), streamer_mmio + LAPA);
 616
 617 #if STREAMER_DEBUG
 618         printk("LAPWWO: %x, LAPA: %x\n", readw(streamer_mmio + LAPWWO),
 619                readw(streamer_mmio + LAPA));
 620         printk("LAPE: %x\n", readw(streamer_mmio + LAPE));
 621         printk("SISR Mask = %04x\n", readw(streamer_mmio + SISR_MASK));
 622 #endif
 623         do {
 624                 int i;
 625
 626                 for (i = 0; i < SRB_COMMAND_SIZE; i += 2) {
 627                         writew(0, streamer_mmio + LAPDINC);
 628                 }
 629
 630                 writew(readw(streamer_mmio+LAPWWO),streamer_mmio+LAPA);
 631                 writew(htons(SRB_OPEN_ADAPTER<<8),streamer_mmio+LAPDINC) ;      /* open */
 632                 writew(htons(STREAMER_CLEAR_RET_CODE<<8),streamer_mmio+LAPDINC);
 633                 writew(STREAMER_CLEAR_RET_CODE, streamer_mmio + LAPDINC);
 634
 635                 writew(readw(streamer_mmio + LAPWWO) + 8, streamer_mmio + LAPA);
 636 #if STREAMER_NETWORK_MONITOR
 637                 /* If Network Monitor, instruct card to copy MAC frames through the ARB */
 638                 writew(htons(OPEN_ADAPTER_ENABLE_FDX | OPEN_ADAPTER_PASS_ADC_MAC | OPEN_ADAPTER_PASS_ATT_MAC | OPEN_ADAPTER_PASS_BEACON), streamer_mmio + LAPDINC);     /* offset 8 word contains open options */
 639 #else
 640                 writew(htons(OPEN_ADAPTER_ENABLE_FDX), streamer_mmio + LAPDINC);        /* Offset 8 word contains Open.Options */
 641 #endif
 642
 643                 if (streamer_priv->streamer_laa[0]) {
 644                         writew(readw(streamer_mmio + LAPWWO) + 12, streamer_mmio + LAPA);
 645                         writew(htons((streamer_priv->streamer_laa[0] << 8) |
 646                                      streamer_priv->streamer_laa[1]),streamer_mmio+LAPDINC);
 647                         writew(htons((streamer_priv->streamer_laa[2] << 8) |
 648                                      streamer_priv->streamer_laa[3]),streamer_mmio+LAPDINC);
 649                         writew(htons((streamer_priv->streamer_laa[4] << 8) |
 650                                      streamer_priv->streamer_laa[5]),streamer_mmio+LAPDINC);
 651                         memcpy(dev->dev_addr, streamer_priv->streamer_laa, dev->addr_len);
 652                 }
 653
 654                 /* save off srb open offset */
 655                 srb_open = readw(streamer_mmio + LAPWWO);
 656 #if STREAMER_DEBUG
 657                 writew(readw(streamer_mmio + LAPWWO),
 658                        streamer_mmio + LAPA);
 659                 printk("srb open request: \n");
 660                 for (i = 0; i < 16; i++) {
 661                         printk("%x:", ntohs(readw(streamer_mmio + LAPDINC)));
 662                 }
 663                 printk("\n");
 664 #endif
 665                 spin_lock_irqsave(&streamer_priv->streamer_lock, flags);
 666                 streamer_priv->srb_queued = 1;
 667
 668                 /* signal solo that SRB command has been issued */
 669                 writew(LISR_SRB_CMD, streamer_mmio + LISR_SUM);
 670                 spin_unlock_irqrestore(&streamer_priv->streamer_lock, flags);
 671
 672                 while (streamer_priv->srb_queued) {
 673                         interruptible_sleep_on_timeout(&streamer_priv->srb_wait, 5 * HZ);
 674                         if (signal_pending(current)) {
 675                                 printk(KERN_WARNING "%s: SRB timed out.\n", dev->name);
 676                                 printk(KERN_WARNING "SISR=%x MISR=%x, LISR=%x\n",
 677                                        readw(streamer_mmio + SISR),
 678                                        readw(streamer_mmio + MISR_RUM),
 679                                        readw(streamer_mmio + LISR));
 680                                 streamer_priv->srb_queued = 0;
 681                                 break;
 682                         }
 683                 }
 684
 685 #if STREAMER_DEBUG
 686                 printk("SISR_MASK: %x\n", readw(streamer_mmio + SISR_MASK));
 687                 printk("srb open response:\n");
 688                 writew(srb_open, streamer_mmio + LAPA);
 689                 for (i = 0; i < 10; i++) {
 690                         printk("%x:",
 691                                ntohs(readw(streamer_mmio + LAPDINC)));
 692                 }
 693 #endif
 694
 695                 /* If we get the same return response as we set, the interrupt wasn't raised and the open
 696                  * timed out.
 697                  */
 698                 writew(srb_open + 2, streamer_mmio + LAPA);
 699                 srb_word = ntohs(readw(streamer_mmio + LAPD)) >> 8;
 700                 if (srb_word == STREAMER_CLEAR_RET_CODE) {
 701                         printk(KERN_WARNING "%s: Adapter Open time out or error.\n",
 702                                dev->name);
 703                         return -EIO;
 704                 }
 705
 706                 if (srb_word != 0) {
 707                         if (srb_word == 0x07) {
 708                                 if (!streamer_priv->streamer_ring_speed && open_finished) {     /* Autosense , first time around */
 709                                         printk(KERN_WARNING "%s: Retrying at different ring speed \n",
 710                                                dev->name);
 711                                         open_finished = 0;
 712                                 } else {
 713                                         __u16 error_code;
 714
 715                                         writew(srb_open + 6, streamer_mmio + LAPA);
 716                                         error_code = ntohs(readw(streamer_mmio + LAPD));
 717                                         strcpy(open_error, open_maj_error[(error_code & 0xf0) >> 4]);
 718                                         strcat(open_error, " - ");
 719                                         strcat(open_error, open_min_error[(error_code & 0x0f)]);
 720
 721                                         if (!streamer_priv->streamer_ring_speed
 722                                             && ((error_code & 0x0f) == 0x0d))
 723                                         {
 724                                                 printk(KERN_WARNING "%s: Tried to autosense ring speed with no monitors present\n", dev->name);
 725                                                 printk(KERN_WARNING "%s: Please try again with a specified ring speed \n", dev->name);
 726                                                 free_irq(dev->irq, dev);
 727                                                 return -EIO;
 728                                         }
 729
 730                                         printk(KERN_WARNING "%s: %s\n",
 731                                                dev->name, open_error);
 732                                         free_irq(dev->irq, dev);
 733                                         return -EIO;
 734
 735                                 }       /* if autosense && open_finished */
 736                         } else {
 737                                 printk(KERN_WARNING "%s: Bad OPEN response: %x\n",
 738                                        dev->name, srb_word);
 739                                 free_irq(dev->irq, dev);
 740                                 return -EIO;
 741                         }
 742                 } else
 743                         open_finished = 1;
 744         } while (!(open_finished));     /* Will only loop if ring speed mismatch re-open attempted && autosense is on */
 745
 746         writew(srb_open + 18, streamer_mmio + LAPA);
 747         srb_word=ntohs(readw(streamer_mmio+LAPD)) >> 8;
 748         if (srb_word & (1 << 3))
 749                 if (streamer_priv->streamer_message_level)
 750                         printk(KERN_INFO "%s: Opened in FDX Mode\n", dev->name);
 751
 752         if (srb_word & 1)
 753                 streamer_priv->streamer_ring_speed = 16;
 754         else
 755                 streamer_priv->streamer_ring_speed = 4;
 756
 757         if (streamer_priv->streamer_message_level)
 758                 printk(KERN_INFO "%s: Opened in %d Mbps mode\n",
 759                         dev->name,
 760                         streamer_priv->streamer_ring_speed);
 761
 762         writew(srb_open + 8, streamer_mmio + LAPA);
 763         streamer_priv->asb = ntohs(readw(streamer_mmio + LAPDINC));
 764         streamer_priv->srb = ntohs(readw(streamer_mmio + LAPDINC));
 765         streamer_priv->arb = ntohs(readw(streamer_mmio + LAPDINC));
 766         readw(streamer_mmio + LAPDINC); /* offset 14 word is rsvd */
 767         streamer_priv->trb = ntohs(readw(streamer_mmio + LAPDINC));
 768
 769         streamer_priv->streamer_receive_options = 0x00;
 770         streamer_priv->streamer_copy_all_options = 0;
 771
 772         /* setup rx ring */
 773         /* enable rx channel */
 774         writew(~BMCTL_RX_DIS, streamer_mmio + BMCTL_RUM);
 775
 776         /* setup rx descriptors */
 777         streamer_priv->streamer_rx_ring=
 778             kmalloc( sizeof(struct streamer_rx_desc)*
 779                      STREAMER_RX_RING_SIZE,GFP_KERNEL);
 780         if (!streamer_priv->streamer_rx_ring) {
 781             printk(KERN_WARNING "%s ALLOC of streamer rx ring FAILED!!\n",dev->name);
 782             return -EIO;
 783         }
 784
 785         for (i = 0; i < STREAMER_RX_RING_SIZE; i++) {
 786                 struct sk_buff *skb;
 787
 788                 skb = dev_alloc_skb(streamer_priv->pkt_buf_sz);
 789                 if (skb == NULL)
 790                         break;
 791
 792                 skb->dev = dev;
 793
 794                 streamer_priv->streamer_rx_ring[i].forward =
 795                         cpu_to_le32(pci_map_single(streamer_priv->pci_dev, &streamer_priv->streamer_rx_ring[i + 1],
 796                                         sizeof(struct streamer_rx_desc), PCI_DMA_FROMDEVICE));
 797                 streamer_priv->streamer_rx_ring[i].status = 0;
 798                 streamer_priv->streamer_rx_ring[i].buffer =
 799                         cpu_to_le32(pci_map_single(streamer_priv->pci_dev, skb->data,
 800                                               streamer_priv->pkt_buf_sz, PCI_DMA_FROMDEVICE));
 801                 streamer_priv->streamer_rx_ring[i].framelen_buflen = streamer_priv->pkt_buf_sz;
 802                 streamer_priv->rx_ring_skb[i] = skb;
 803         }
 804         streamer_priv->streamer_rx_ring[STREAMER_RX_RING_SIZE - 1].forward =
 805                                 cpu_to_le32(pci_map_single(streamer_priv->pci_dev, &streamer_priv->streamer_rx_ring[0],
 806                                                 sizeof(struct streamer_rx_desc), PCI_DMA_FROMDEVICE));
 807
 808         if (i == 0) {
 809                 printk(KERN_WARNING "%s: Not enough memory to allocate rx buffers. Adapter disabled\n", dev->name);
 810                 free_irq(dev->irq, dev);
 811                 return -EIO;
 812         }
 813
 814         streamer_priv->rx_ring_last_received = STREAMER_RX_RING_SIZE - 1;       /* last processed rx status */
 815
 816         writel(cpu_to_le32(pci_map_single(streamer_priv->pci_dev, &streamer_priv->streamer_rx_ring[0],
 817                                 sizeof(struct streamer_rx_desc), PCI_DMA_TODEVICE)),
 818                 streamer_mmio + RXBDA);
 819         writel(cpu_to_le32(pci_map_single(streamer_priv->pci_dev, &streamer_priv->streamer_rx_ring[STREAMER_RX_RING_SIZE - 1],
 820                                 sizeof(struct streamer_rx_desc), PCI_DMA_TODEVICE)),
 821                 streamer_mmio + RXLBDA);
 822
 823         /* set bus master interrupt event mask */
 824         writew(MISR_RX_NOBUF | MISR_RX_EOF, streamer_mmio + MISR_MASK);
 825
 826
 827         /* setup tx ring */
 828         streamer_priv->streamer_tx_ring=kmalloc(sizeof(struct streamer_tx_desc)*
 829                                                 STREAMER_TX_RING_SIZE,GFP_KERNEL);
 830         if (!streamer_priv->streamer_tx_ring) {
 831             printk(KERN_WARNING "%s ALLOC of streamer_tx_ring FAILED\n",dev->name);
 832             return -EIO;
 833         }
 834
 835         writew(~BMCTL_TX2_DIS, streamer_mmio + BMCTL_RUM);      /* Enables TX channel 2 */
 836         for (i = 0; i < STREAMER_TX_RING_SIZE; i++) {
 837                 streamer_priv->streamer_tx_ring[i].forward = cpu_to_le32(pci_map_single(streamer_priv->pci_dev,
 838                                                                                 &streamer_priv->streamer_tx_ring[i + 1],
 839                                                                                 sizeof(struct streamer_tx_desc),
 840                                                                                 PCI_DMA_TODEVICE));
 841                 streamer_priv->streamer_tx_ring[i].status = 0;
 842                 streamer_priv->streamer_tx_ring[i].bufcnt_framelen = 0;
 843                 streamer_priv->streamer_tx_ring[i].buffer = 0;
 844                 streamer_priv->streamer_tx_ring[i].buflen = 0;
 845                 streamer_priv->streamer_tx_ring[i].rsvd1 = 0;
 846                 streamer_priv->streamer_tx_ring[i].rsvd2 = 0;
 847                 streamer_priv->streamer_tx_ring[i].rsvd3 = 0;
 848         }
 849         streamer_priv->streamer_tx_ring[STREAMER_TX_RING_SIZE - 1].forward =
 850                                         cpu_to_le32(pci_map_single(streamer_priv->pci_dev, &streamer_priv->streamer_tx_ring[0],
 851                                                         sizeof(struct streamer_tx_desc), PCI_DMA_TODEVICE));
 852
 853         streamer_priv->free_tx_ring_entries = STREAMER_TX_RING_SIZE;
 854         streamer_priv->tx_ring_free = 0;        /* next entry in tx ring to use */
 855         streamer_priv->tx_ring_last_status = STREAMER_TX_RING_SIZE - 1;
 856
 857         /* set Busmaster interrupt event mask (handle receives on interrupt only */
 858         writew(MISR_TX2_EOF | MISR_RX_NOBUF | MISR_RX_EOF, streamer_mmio + MISR_MASK);
 859         /* set system event interrupt mask */
 860         writew(SISR_ADAPTER_CHECK | SISR_ARB_CMD | SISR_TRB_REPLY | SISR_ASB_FREE, streamer_mmio + SISR_MASK_SUM);
 861
 862 #if STREAMER_DEBUG
 863         printk("BMCTL: %x\n", readw(streamer_mmio + BMCTL_SUM));
 864         printk("SISR MASK: %x\n", readw(streamer_mmio + SISR_MASK));
 865 #endif
 866
 867 #if STREAMER_NETWORK_MONITOR
 868
 869         writew(streamer_priv->streamer_addr_table_addr, streamer_mmio + LAPA);
 870         printk("%s: Node Address: %04x:%04x:%04x\n", dev->name,
 871                 ntohs(readw(streamer_mmio + LAPDINC)),
 872                 ntohs(readw(streamer_mmio + LAPDINC)),
 873                 ntohs(readw(streamer_mmio + LAPDINC)));
 874         readw(streamer_mmio + LAPDINC);
 875         readw(streamer_mmio + LAPDINC);
 876         printk("%s: Functional Address: %04x:%04x\n", dev->name,
 877                 ntohs(readw(streamer_mmio + LAPDINC)),
 878                 ntohs(readw(streamer_mmio + LAPDINC)));
 879
 880         writew(streamer_priv->streamer_parms_addr + 4,
 881                 streamer_mmio + LAPA);
 882         printk("%s: NAUN Address: %04x:%04x:%04x\n", dev->name,
 883                 ntohs(readw(streamer_mmio + LAPDINC)),
 884                 ntohs(readw(streamer_mmio + LAPDINC)),
 885                 ntohs(readw(streamer_mmio + LAPDINC)));
 886 #endif
 887
 888         netif_start_queue(dev);
 889         netif_carrier_on(dev);
 890         return 0;
 891 }
 892
 893 /*
 894  *      When we enter the rx routine we do not know how many frames have been
 895  *      queued on the rx channel.  Therefore we start at the next rx status
 896  *      position and travel around the receive ring until we have completed
 897  *      all the frames.
 898  *
 899  *      This means that we may process the frame before we receive the end
 900  *      of frame interrupt. This is why we always test the status instead
 901  *      of blindly processing the next frame.
 902  *
 903  */
 904 static void streamer_rx(struct net_device *dev)
 905 {
 906         struct streamer_private *streamer_priv =
 907             (struct streamer_private *) dev->priv;
 908         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
 909         struct streamer_rx_desc *rx_desc;
 910         int rx_ring_last_received, length, frame_length, buffer_cnt = 0;
 911         struct sk_buff *skb, *skb2;
 912
 913         /* setup the next rx descriptor to be received */
 914         rx_desc = &streamer_priv->streamer_rx_ring[(streamer_priv->rx_ring_last_received + 1) & (STREAMER_RX_RING_SIZE - 1)];
 915         rx_ring_last_received = streamer_priv->rx_ring_last_received;
 916
 917         while (rx_desc->status & 0x01000000) {  /* While processed descriptors are available */
 918                 if (rx_ring_last_received != streamer_priv->rx_ring_last_received)
 919                 {
 920                         printk(KERN_WARNING "RX Error 1 rx_ring_last_received not the same %x %x\n",
 921                                 rx_ring_last_received, streamer_priv->rx_ring_last_received);
 922                 }
 923                 streamer_priv->rx_ring_last_received = (streamer_priv->rx_ring_last_received + 1) & (STREAMER_RX_RING_SIZE - 1);
 924                 rx_ring_last_received = streamer_priv->rx_ring_last_received;
 925
 926                 length = rx_desc->framelen_buflen & 0xffff;     /* buffer length */
 927                 frame_length = (rx_desc->framelen_buflen >> 16) & 0xffff;
 928
 929                 if (rx_desc->status & 0x7E830000) {     /* errors */
 930                         if (streamer_priv->streamer_message_level) {
 931                                 printk(KERN_WARNING "%s: Rx Error %x \n",
 932                                        dev->name, rx_desc->status);
 933                         }
 934                 } else {        /* received without errors */
 935                         if (rx_desc->status & 0x80000000) {     /* frame complete */
 936                                 buffer_cnt = 1;
 937                                 skb = dev_alloc_skb(streamer_priv->pkt_buf_sz);
 938                         } else {
 939                                 skb = dev_alloc_skb(frame_length);
 940                         }
 941
 942                         if (skb == NULL)
 943                         {
 944                                 printk(KERN_WARNING "%s: Not enough memory to copy packet to upper layers. \n", dev->name);
 945                                 streamer_priv->streamer_stats.rx_dropped++;
 946                         } else {        /* we allocated an skb OK */
 947                                 skb->dev = dev;
 948
 949                                 if (buffer_cnt == 1) {
 950                                         /* release the DMA mapping */
 951                                         pci_unmap_single(streamer_priv->pci_dev,
 952                                                 le32_to_cpu(streamer_priv->streamer_rx_ring[rx_ring_last_received].buffer),
 953                                                 streamer_priv->pkt_buf_sz,
 954                                                 PCI_DMA_FROMDEVICE);
 955                                         skb2 = streamer_priv->rx_ring_skb[rx_ring_last_received];
 956 #if STREAMER_DEBUG_PACKETS
 957                                         {
 958                                                 int i;
 959                                                 printk("streamer_rx packet print: skb->data2 %p  skb->head %p\n", skb2->data, skb2->head);
 960                                                 for (i = 0; i < frame_length; i++)
 961                                                 {
 962                                                         printk("%x:", skb2->data[i]);
 963                                                         if (((i + 1) % 16) == 0)
 964                                                                 printk("\n");
 965                                                 }
 966                                                 printk("\n");
 967                                         }
 968 #endif
 969                                         skb_put(skb2, length);
 970                                         skb2->protocol = tr_type_trans(skb2, dev);
 971                                         /* recycle this descriptor */
 972                                         streamer_priv->streamer_rx_ring[rx_ring_last_received].status = 0;
 973                                         streamer_priv->streamer_rx_ring[rx_ring_last_received].framelen_buflen = streamer_priv->pkt_buf_sz;
 974                                         streamer_priv->streamer_rx_ring[rx_ring_last_received].buffer =
 975                                                 cpu_to_le32(pci_map_single(streamer_priv->pci_dev, skb->data, streamer_priv->pkt_buf_sz,
 976                                                                 PCI_DMA_FROMDEVICE));
 977                                         streamer_priv->rx_ring_skb[rx_ring_last_received] = skb;
 978                                         /* place recycled descriptor back on the adapter */
 979                                         writel(cpu_to_le32(pci_map_single(streamer_priv->pci_dev,
 980                                                                         &streamer_priv->streamer_rx_ring[rx_ring_last_received],
 981                                                                         sizeof(struct streamer_rx_desc), PCI_DMA_FROMDEVICE)),
 982                                                 streamer_mmio + RXLBDA);
 983                                         /* pass the received skb up to the protocol */
 984                                         netif_rx(skb2);
 985                                 } else {
 986                                         do {    /* Walk the buffers */
 987                                                 pci_unmap_single(streamer_priv->pci_dev, le32_to_cpu(rx_desc->buffer), length, PCI_DMA_FROMDEVICE),
 988                                                 memcpy(skb_put(skb, length), (void *)rx_desc->buffer, length);  /* copy this fragment */
 989                                                 streamer_priv->streamer_rx_ring[rx_ring_last_received].status = 0;
 990                                                 streamer_priv->streamer_rx_ring[rx_ring_last_received].framelen_buflen = streamer_priv->pkt_buf_sz;
 991
 992                                                 /* give descriptor back to the adapter */
 993                                                 writel(cpu_to_le32(pci_map_single(streamer_priv->pci_dev,
 994                                                                         &streamer_priv->streamer_rx_ring[rx_ring_last_received],
 995                                                                         length, PCI_DMA_FROMDEVICE)),
 996                                                         streamer_mmio + RXLBDA);
 997
 998                                                 if (rx_desc->status & 0x80000000)
 999                                                         break;  /* this descriptor completes the frame */
1000
1001                                                 /* else get the next pending descriptor */
1002                                                 if (rx_ring_last_received!= streamer_priv->rx_ring_last_received)
1003                                                 {
1004                                                         printk("RX Error rx_ring_last_received not the same %x %x\n",
1005                                                                 rx_ring_last_received,
1006                                                                 streamer_priv->rx_ring_last_received);
1007                                                 }
1008                                                 rx_desc = &streamer_priv->streamer_rx_ring[(streamer_priv->rx_ring_last_received+1) & (STREAMER_RX_RING_SIZE-1)];
1009
1010                                                 length = rx_desc->framelen_buflen & 0xffff;     /* buffer length */
1011                                                 streamer_priv->rx_ring_last_received =  (streamer_priv->rx_ring_last_received+1) & (STREAMER_RX_RING_SIZE - 1);
1012                                                 rx_ring_last_received = streamer_priv->rx_ring_last_received;
1013                                         } while (1);
1014
1015                                         skb->protocol = tr_type_trans(skb, dev);
1016                                         /* send up to the protocol */
1017                                         netif_rx(skb);
1018                                 }
1019                                 dev->last_rx = jiffies;
1020                                 streamer_priv->streamer_stats.rx_packets++;
1021                                 streamer_priv->streamer_stats.rx_bytes += length;
1022                         }       /* if skb == null */
1023                 }               /* end received without errors */
1024
1025                 /* try the next one */
1026                 rx_desc = &streamer_priv->streamer_rx_ring[(rx_ring_last_received + 1) & (STREAMER_RX_RING_SIZE - 1)];
1027         }                       /* end for all completed rx descriptors */
1028 }
1029
1030 static irqreturn_t streamer_interrupt(int irq, void *dev_id)
1031 {
1032         struct net_device *dev = (struct net_device *) dev_id;
1033         struct streamer_private *streamer_priv =
1034             (struct streamer_private *) dev->priv;
1035         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1036         __u16 sisr;
1037         __u16 misr;
1038         u8 max_intr = MAX_INTR;
1039
1040         spin_lock(&streamer_priv->streamer_lock);
1041         sisr = readw(streamer_mmio + SISR);
1042
1043         while((sisr & (SISR_MI | SISR_SRB_REPLY | SISR_ADAPTER_CHECK | SISR_ASB_FREE |
1044                        SISR_ARB_CMD | SISR_TRB_REPLY | SISR_PAR_ERR | SISR_SERR_ERR))
1045                && (max_intr > 0)) {
1046
1047                 if(sisr & SISR_PAR_ERR) {
1048                         writew(~SISR_PAR_ERR, streamer_mmio + SISR_RUM);
1049                         (void)readw(streamer_mmio + SISR_RUM);
1050                 }
1051
1052                 else if(sisr & SISR_SERR_ERR) {
1053                         writew(~SISR_SERR_ERR, streamer_mmio + SISR_RUM);
1054                         (void)readw(streamer_mmio + SISR_RUM);
1055                 }
1056
1057                 else if(sisr & SISR_MI) {
1058                         misr = readw(streamer_mmio + MISR_RUM);
1059
1060                 if (misr & MISR_TX2_EOF) {
1061                                 while(streamer_priv->streamer_tx_ring[(streamer_priv->tx_ring_last_status + 1) & (STREAMER_TX_RING_SIZE - 1)].status) {
1062                                 streamer_priv->tx_ring_last_status = (streamer_priv->tx_ring_last_status + 1) & (STREAMER_TX_RING_SIZE - 1);
1063                                 streamer_priv->free_tx_ring_entries++;
1064                                 streamer_priv->streamer_stats.tx_bytes += streamer_priv->tx_ring_skb[streamer_priv->tx_ring_last_status]->len;
1065                                 streamer_priv->streamer_stats.tx_packets++;
1066                                 dev_kfree_skb_irq(streamer_priv->tx_ring_skb[streamer_priv->tx_ring_last_status]);
1067                                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_last_status].buffer = 0xdeadbeef;
1068                                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_last_status].status = 0;
1069                                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_last_status].bufcnt_framelen = 0;
1070                                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_last_status].buflen = 0;
1071                                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_last_status].rsvd1 = 0;
1072                                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_last_status].rsvd2 = 0;
1073                                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_last_status].rsvd3 = 0;
1074                         }
1075                         netif_wake_queue(dev);
1076                 }
1077
1078                 if (misr & MISR_RX_EOF) {
1079                         streamer_rx(dev);
1080                 }
1081                 /* MISR_RX_EOF */
1082
1083                         if (misr & MISR_RX_NOBUF) {
1084                                 /* According to the documentation, we don't have to do anything,
1085                                  * but trapping it keeps it out of /var/log/messages.
1086                                  */
1087                         }               /* SISR_RX_NOBUF */
1088
1089                         writew(~misr, streamer_mmio + MISR_RUM);
1090                         (void)readw(streamer_mmio + MISR_RUM);
1091                 }
1092
1093                 else if (sisr & SISR_SRB_REPLY) {
1094                         if (streamer_priv->srb_queued == 1) {
1095                                 wake_up_interruptible(&streamer_priv->srb_wait);
1096                         } else if (streamer_priv->srb_queued == 2) {
1097                                 streamer_srb_bh(dev);
1098                         }
1099                         streamer_priv->srb_queued = 0;
1100
1101                         writew(~SISR_SRB_REPLY, streamer_mmio + SISR_RUM);
1102                         (void)readw(streamer_mmio + SISR_RUM);
1103                 }
1104
1105                 else if (sisr & SISR_ADAPTER_CHECK) {
1106                         printk(KERN_WARNING "%s: Adapter Check Interrupt Raised, 8 bytes of information follow:\n", dev->name);
1107                         writel(readl(streamer_mmio + LAPWWO), streamer_mmio + LAPA);
1108                         printk(KERN_WARNING "%s: Words %x:%x:%x:%x:\n",
1109                                dev->name, readw(streamer_mmio + LAPDINC),
1110                                ntohs(readw(streamer_mmio + LAPDINC)),
1111                                ntohs(readw(streamer_mmio + LAPDINC)),
1112                                ntohs(readw(streamer_mmio + LAPDINC)));
1113                         netif_stop_queue(dev);
1114                         netif_carrier_off(dev);
1115                         printk(KERN_WARNING "%s: Adapter must be manually reset.\n", dev->name);
1116                 }
1117
1118                 /* SISR_ADAPTER_CHECK */
1119                 else if (sisr & SISR_ASB_FREE) {
1120                         /* Wake up anything that is waiting for the asb response */
1121                         if (streamer_priv->asb_queued) {
1122                                 streamer_asb_bh(dev);
1123                         }
1124                         writew(~SISR_ASB_FREE, streamer_mmio + SISR_RUM);
1125                         (void)readw(streamer_mmio + SISR_RUM);
1126                 }
1127                 /* SISR_ASB_FREE */
1128                 else if (sisr & SISR_ARB_CMD) {
1129                         streamer_arb_cmd(dev);
1130                         writew(~SISR_ARB_CMD, streamer_mmio + SISR_RUM);
1131                         (void)readw(streamer_mmio + SISR_RUM);
1132                 }
1133                 /* SISR_ARB_CMD */
1134                 else if (sisr & SISR_TRB_REPLY) {
1135                         /* Wake up anything that is waiting for the trb response */
1136                         if (streamer_priv->trb_queued) {
1137                                 wake_up_interruptible(&streamer_priv->
1138                                                       trb_wait);
1139                         }
1140                         streamer_priv->trb_queued = 0;
1141                         writew(~SISR_TRB_REPLY, streamer_mmio + SISR_RUM);
1142                         (void)readw(streamer_mmio + SISR_RUM);
1143                 }
1144                 /* SISR_TRB_REPLY */
1145
1146                 sisr = readw(streamer_mmio + SISR);
1147                 max_intr--;
1148         } /* while() */
1149
1150         spin_unlock(&streamer_priv->streamer_lock) ;
1151         return IRQ_HANDLED;
1152 }
1153
1154 static int streamer_xmit(struct sk_buff *skb, struct net_device *dev)
1155 {
1156         struct streamer_private *streamer_priv =
1157             (struct streamer_private *) dev->priv;
1158         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1159         unsigned long flags ;
1160
1161         spin_lock_irqsave(&streamer_priv->streamer_lock, flags);
1162
1163         if (streamer_priv->free_tx_ring_entries) {
1164                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free].status = 0;
1165                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free].bufcnt_framelen = 0x00020000 | skb->len;
1166                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free].buffer =
1167                         cpu_to_le32(pci_map_single(streamer_priv->pci_dev, skb->data, skb->len, PCI_DMA_TODEVICE));
1168                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free].rsvd1 = skb->len;
1169                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free].rsvd2 = 0;
1170                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free].rsvd3 = 0;
1171                 streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free].buflen = skb->len;
1172
1173                 streamer_priv->tx_ring_skb[streamer_priv->tx_ring_free] = skb;
1174                 streamer_priv->free_tx_ring_entries--;
1175 #if STREAMER_DEBUG_PACKETS
1176                 {
1177                         int i;
1178                         printk("streamer_xmit packet print:\n");
1179                         for (i = 0; i < skb->len; i++) {
1180                                 printk("%x:", skb->data[i]);
1181                                 if (((i + 1) % 16) == 0)
1182                                         printk("\n");
1183                         }
1184                         printk("\n");
1185                 }
1186 #endif
1187
1188                 writel(cpu_to_le32(pci_map_single(streamer_priv->pci_dev,
1189                                         &streamer_priv->streamer_tx_ring[streamer_priv->tx_ring_free],
1190                                         sizeof(struct streamer_tx_desc), PCI_DMA_TODEVICE)),
1191                         streamer_mmio + TX2LFDA);
1192                 (void)readl(streamer_mmio + TX2LFDA);
1193
1194                 streamer_priv->tx_ring_free = (streamer_priv->tx_ring_free + 1) & (STREAMER_TX_RING_SIZE - 1);
1195                 spin_unlock_irqrestore(&streamer_priv->streamer_lock,flags);
1196                 return 0;
1197         } else {
1198                 netif_stop_queue(dev);
1199                 spin_unlock_irqrestore(&streamer_priv->streamer_lock,flags);
1200                 return 1;
1201         }
1202 }
1203
1204
1205 static int streamer_close(struct net_device *dev)
1206 {
1207         struct streamer_private *streamer_priv =
1208             (struct streamer_private *) dev->priv;
1209         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1210         unsigned long flags;
1211         int i;
1212
1213         netif_stop_queue(dev);
1214         netif_carrier_off(dev);
1215         writew(streamer_priv->srb, streamer_mmio + LAPA);
1216         writew(htons(SRB_CLOSE_ADAPTER << 8),streamer_mmio+LAPDINC);
1217         writew(htons(STREAMER_CLEAR_RET_CODE << 8), streamer_mmio+LAPDINC);
1218
1219         spin_lock_irqsave(&streamer_priv->streamer_lock, flags);
1220
1221         streamer_priv->srb_queued = 1;
1222         writew(LISR_SRB_CMD, streamer_mmio + LISR_SUM);
1223
1224         spin_unlock_irqrestore(&streamer_priv->streamer_lock, flags);
1225
1226         while (streamer_priv->srb_queued)
1227         {
1228                 interruptible_sleep_on_timeout(&streamer_priv->srb_wait,
1229                                                jiffies + 60 * HZ);
1230                 if (signal_pending(current))
1231                 {
1232                         printk(KERN_WARNING "%s: SRB timed out.\n", dev->name);
1233                         printk(KERN_WARNING "SISR=%x MISR=%x LISR=%x\n",
1234                                readw(streamer_mmio + SISR),
1235                                readw(streamer_mmio + MISR_RUM),
1236                                readw(streamer_mmio + LISR));
1237                         streamer_priv->srb_queued = 0;
1238                         break;
1239                 }
1240         }
1241
1242         streamer_priv->rx_ring_last_received = (streamer_priv->rx_ring_last_received + 1) & (STREAMER_RX_RING_SIZE - 1);
1243
1244         for (i = 0; i < STREAMER_RX_RING_SIZE; i++) {
1245                 if (streamer_priv->rx_ring_skb[streamer_priv->rx_ring_last_received]) {
1246                         dev_kfree_skb(streamer_priv->rx_ring_skb[streamer_priv->rx_ring_last_received]);
1247                 }
1248                 streamer_priv->rx_ring_last_received = (streamer_priv->rx_ring_last_received + 1) & (STREAMER_RX_RING_SIZE - 1);
1249         }
1250
1251         /* reset tx/rx fifo's and busmaster logic */
1252
1253         /* TBD. Add graceful way to reset the LLC channel without doing a soft reset.
1254            writel(readl(streamer_mmio+BCTL)|(3<<13),streamer_mmio+BCTL);
1255            udelay(1);
1256            writel(readl(streamer_mmio+BCTL)&~(3<<13),streamer_mmio+BCTL);
1257          */
1258
1259 #if STREAMER_DEBUG
1260         writew(streamer_priv->srb, streamer_mmio + LAPA);
1261         printk("srb): ");
1262         for (i = 0; i < 2; i++) {
1263                 printk("%x ", ntohs(readw(streamer_mmio + LAPDINC)));
1264         }
1265         printk("\n");
1266 #endif
1267         free_irq(dev->irq, dev);
1268         return 0;
1269 }
1270
1271 static void streamer_set_rx_mode(struct net_device *dev)
1272 {
1273         struct streamer_private *streamer_priv =
1274             (struct streamer_private *) dev->priv;
1275         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1276         __u8 options = 0;
1277         struct dev_mc_list *dmi;
1278         unsigned char dev_mc_address[5];
1279         int i;
1280
1281         writel(streamer_priv->srb, streamer_mmio + LAPA);
1282         options = streamer_priv->streamer_copy_all_options;
1283
1284         if (dev->flags & IFF_PROMISC)
1285                 options |= (3 << 5);    /* All LLC and MAC frames, all through the main rx channel */
1286         else
1287                 options &= ~(3 << 5);
1288
1289         /* Only issue the srb if there is a change in options */
1290
1291         if ((options ^ streamer_priv->streamer_copy_all_options))
1292         {
1293                 /* Now to issue the srb command to alter the copy.all.options */
1294                 writew(htons(SRB_MODIFY_RECEIVE_OPTIONS << 8), streamer_mmio+LAPDINC);
1295                 writew(htons(STREAMER_CLEAR_RET_CODE << 8), streamer_mmio+LAPDINC);
1296                 writew(htons((streamer_priv->streamer_receive_options << 8) | options),streamer_mmio+LAPDINC);
1297                 writew(htons(0x4a41),streamer_mmio+LAPDINC);
1298                 writew(htons(0x4d45),streamer_mmio+LAPDINC);
1299                 writew(htons(0x5320),streamer_mmio+LAPDINC);
1300                 writew(0x2020, streamer_mmio + LAPDINC);
1301
1302                 streamer_priv->srb_queued = 2;  /* Can't sleep, use srb_bh */
1303
1304                 writel(LISR_SRB_CMD, streamer_mmio + LISR_SUM);
1305
1306                 streamer_priv->streamer_copy_all_options = options;
1307                 return;
1308         }
1309
1310         /* Set the functional addresses we need for multicast */
1311         writel(streamer_priv->srb,streamer_mmio+LAPA);
1312         dev_mc_address[0] = dev_mc_address[1] = dev_mc_address[2] = dev_mc_address[3] = 0 ;
1313
1314         for (i=0,dmi=dev->mc_list;i < dev->mc_count; i++,dmi = dmi->next)
1315         {
1316                 dev_mc_address[0] |= dmi->dmi_addr[2] ;
1317                 dev_mc_address[1] |= dmi->dmi_addr[3] ;
1318                 dev_mc_address[2] |= dmi->dmi_addr[4] ;
1319                 dev_mc_address[3] |= dmi->dmi_addr[5] ;
1320         }
1321
1322         writew(htons(SRB_SET_FUNC_ADDRESS << 8),streamer_mmio+LAPDINC);
1323         writew(htons(STREAMER_CLEAR_RET_CODE << 8), streamer_mmio+LAPDINC);
1324         writew(0,streamer_mmio+LAPDINC);
1325         writew(htons( (dev_mc_address[0] << 8) | dev_mc_address[1]),streamer_mmio+LAPDINC);
1326         writew(htons( (dev_mc_address[2] << 8) | dev_mc_address[3]),streamer_mmio+LAPDINC);
1327         streamer_priv->srb_queued = 2 ;
1328         writel(LISR_SRB_CMD,streamer_mmio+LISR_SUM);
1329 }
1330
1331 static void streamer_srb_bh(struct net_device *dev)
1332 {
1333         struct streamer_private *streamer_priv = (struct streamer_private *) dev->priv;
1334         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1335         __u16 srb_word;
1336
1337         writew(streamer_priv->srb, streamer_mmio + LAPA);
1338         srb_word=ntohs(readw(streamer_mmio+LAPDINC)) >> 8;
1339
1340         switch (srb_word) {
1341
1342                 /* SRB_MODIFY_RECEIVE_OPTIONS i.e. set_multicast_list options (promiscuous)
1343                  * At some point we should do something if we get an error, such as
1344                  * resetting the IFF_PROMISC flag in dev
1345                  */
1346
1347         case SRB_MODIFY_RECEIVE_OPTIONS:
1348                 srb_word=ntohs(readw(streamer_mmio+LAPDINC)) >> 8;
1349
1350                 switch (srb_word) {
1351                 case 0x01:
1352                         printk(KERN_WARNING "%s: Unrecognized srb command\n", dev->name);
1353                         break;
1354                 case 0x04:
1355                         printk(KERN_WARNING "%s: Adapter must be open for this operation, doh!!\n", dev->name);
1356                         break;
1357                 default:
1358                         if (streamer_priv->streamer_message_level)
1359                                 printk(KERN_WARNING "%s: Receive Options Modified to %x,%x\n",
1360                                        dev->name,
1361                                        streamer_priv->streamer_copy_all_options,
1362                                        streamer_priv->streamer_receive_options);
1363                         break;
1364                 }               /* switch srb[2] */
1365                 break;
1366
1367
1368                 /* SRB_SET_GROUP_ADDRESS - Multicast group setting
1369                  */
1370         case SRB_SET_GROUP_ADDRESS:
1371                 srb_word=ntohs(readw(streamer_mmio+LAPDINC)) >> 8;
1372                 switch (srb_word) {
1373                 case 0x00:
1374                         break;
1375                 case 0x01:
1376                         printk(KERN_WARNING "%s: Unrecognized srb command \n",dev->name);
1377                         break;
1378                 case 0x04:
1379                         printk(KERN_WARNING "%s: Adapter must be open for this operation, doh!!\n", dev->name);
1380                         break;
1381                 case 0x3c:
1382                         printk(KERN_WARNING "%s: Group/Functional address indicator bits not set correctly\n", dev->name);
1383                         break;
1384                 case 0x3e:      /* If we ever implement individual multicast addresses, will need to deal with this */
1385                         printk(KERN_WARNING "%s: Group address registers full\n", dev->name);
1386                         break;
1387                 case 0x55:
1388                         printk(KERN_INFO "%s: Group Address already set.\n", dev->name);
1389                         break;
1390                 default:
1391                         break;
1392                 }               /* switch srb[2] */
1393                 break;
1394
1395
1396                 /* SRB_RESET_GROUP_ADDRESS - Remove a multicast address from group list
1397                  */
1398         case SRB_RESET_GROUP_ADDRESS:
1399                 srb_word=ntohs(readw(streamer_mmio+LAPDINC)) >> 8;
1400                 switch (srb_word) {
1401                 case 0x00:
1402                         break;
1403                 case 0x01:
1404                         printk(KERN_WARNING "%s: Unrecognized srb command \n", dev->name);
1405                         break;
1406                 case 0x04:
1407                         printk(KERN_WARNING "%s: Adapter must be open for this operation, doh!!\n", dev->name);
1408                         break;
1409                 case 0x39:      /* Must deal with this if individual multicast addresses used */
1410                         printk(KERN_INFO "%s: Group address not found \n", dev->name);
1411                         break;
1412                 default:
1413                         break;
1414                 }               /* switch srb[2] */
1415                 break;
1416
1417
1418                 /* SRB_SET_FUNC_ADDRESS - Called by the set_rx_mode
1419                  */
1420
1421         case SRB_SET_FUNC_ADDRESS:
1422                 srb_word=ntohs(readw(streamer_mmio+LAPDINC)) >> 8;
1423                 switch (srb_word) {
1424                 case 0x00:
1425                         if (streamer_priv->streamer_message_level)
1426                                 printk(KERN_INFO "%s: Functional Address Mask Set \n", dev->name);
1427                         break;
1428                 case 0x01:
1429                         printk(KERN_WARNING "%s: Unrecognized srb command \n", dev->name);
1430                         break;
1431                 case 0x04:
1432                         printk(KERN_WARNING "%s: Adapter must be open for this operation, doh!!\n", dev->name);
1433                         break;
1434                 default:
1435                         break;
1436                 }               /* switch srb[2] */
1437                 break;
1438
1439                 /* SRB_READ_LOG - Read and reset the adapter error counters
1440                  */
1441
1442         case SRB_READ_LOG:
1443                 srb_word=ntohs(readw(streamer_mmio+LAPDINC)) >> 8;
1444                 switch (srb_word) {
1445                 case 0x00:
1446                         {
1447                                 int i;
1448                                 if (streamer_priv->streamer_message_level)
1449                                         printk(KERN_INFO "%s: Read Log command complete\n", dev->name);
1450                                 printk("Read Log statistics: ");
1451                                 writew(streamer_priv->srb + 6,
1452                                        streamer_mmio + LAPA);
1453                                 for (i = 0; i < 5; i++) {
1454                                         printk("%x:", ntohs(readw(streamer_mmio + LAPDINC)));
1455                                 }
1456                                 printk("\n");
1457                         }
1458                         break;
1459                 case 0x01:
1460                         printk(KERN_WARNING "%s: Unrecognized srb command \n", dev->name);
1461                         break;
1462                 case 0x04:
1463                         printk(KERN_WARNING "%s: Adapter must be open for this operation, doh!!\n", dev->name);
1464                         break;
1465
1466                 }               /* switch srb[2] */
1467                 break;
1468
1469                 /* SRB_READ_SR_COUNTERS - Read and reset the source routing bridge related counters */
1470
1471         case SRB_READ_SR_COUNTERS:
1472                 srb_word=ntohs(readw(streamer_mmio+LAPDINC)) >> 8;
1473                 switch (srb_word) {
1474                 case 0x00:
1475                         if (streamer_priv->streamer_message_level)
1476                                 printk(KERN_INFO "%s: Read Source Routing Counters issued\n", dev->name);
1477                         break;
1478                 case 0x01:
1479                         printk(KERN_WARNING "%s: Unrecognized srb command \n", dev->name);
1480                         break;
1481                 case 0x04:
1482                         printk(KERN_WARNING "%s: Adapter must be open for this operation, doh!!\n", dev->name);
1483                         break;
1484                 default:
1485                         break;
1486                 }               /* switch srb[2] */
1487                 break;
1488
1489         default:
1490                 printk(KERN_WARNING "%s: Unrecognized srb bh return value.\n", dev->name);
1491                 break;
1492         }                       /* switch srb[0] */
1493 }
1494
1495 static struct net_device_stats *streamer_get_stats(struct net_device *dev)
1496 {
1497         struct streamer_private *streamer_priv;
1498         streamer_priv = (struct streamer_private *) dev->priv;
1499         return (struct net_device_stats *) &streamer_priv->streamer_stats;
1500 }
1501
1502 static int streamer_set_mac_address(struct net_device *dev, void *addr)
1503 {
1504         struct sockaddr *saddr = addr;
1505         struct streamer_private *streamer_priv = (struct streamer_private *) dev->priv;
1506
1507         if (netif_running(dev))
1508         {
1509                 printk(KERN_WARNING "%s: Cannot set mac/laa address while card is open\n", dev->name);
1510                 return -EIO;
1511         }
1512
1513         memcpy(streamer_priv->streamer_laa, saddr->sa_data, dev->addr_len);
1514
1515         if (streamer_priv->streamer_message_level) {
1516                 printk(KERN_INFO "%s: MAC/LAA Set to  = %x.%x.%x.%x.%x.%x\n",
1517                        dev->name, streamer_priv->streamer_laa[0],
1518                        streamer_priv->streamer_laa[1],
1519                        streamer_priv->streamer_laa[2],
1520                        streamer_priv->streamer_laa[3],
1521                        streamer_priv->streamer_laa[4],
1522                        streamer_priv->streamer_laa[5]);
1523         }
1524         return 0;
1525 }
1526
1527 static void streamer_arb_cmd(struct net_device *dev)
1528 {
1529         struct streamer_private *streamer_priv =
1530             (struct streamer_private *) dev->priv;
1531         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1532         __u8 header_len;
1533         __u16 frame_len, buffer_len;
1534         struct sk_buff *mac_frame;
1535         __u8 frame_data[256];
1536         __u16 buff_off;
1537         __u16 lan_status = 0, lan_status_diff;  /* Initialize to stop compiler warning */
1538         __u8 fdx_prot_error;
1539         __u16 next_ptr;
1540         __u16 arb_word;
1541
1542 #if STREAMER_NETWORK_MONITOR
1543         struct trh_hdr *mac_hdr;
1544 #endif
1545
1546         writew(streamer_priv->arb, streamer_mmio + LAPA);
1547         arb_word=ntohs(readw(streamer_mmio+LAPD)) >> 8;
1548
1549         if (arb_word == ARB_RECEIVE_DATA) {     /* Receive.data, MAC frames */
1550                 writew(streamer_priv->arb + 6, streamer_mmio + LAPA);
1551                 streamer_priv->mac_rx_buffer = buff_off = ntohs(readw(streamer_mmio + LAPDINC));
1552                 header_len=ntohs(readw(streamer_mmio+LAPDINC)) >> 8; /* 802.5 Token-Ring Header Length */
1553                 frame_len = ntohs(readw(streamer_mmio + LAPDINC));
1554
1555 #if STREAMER_DEBUG
1556                 {
1557                         int i;
1558                         __u16 next;
1559                         __u8 status;
1560                         __u16 len;
1561
1562                         writew(ntohs(buff_off), streamer_mmio + LAPA);  /*setup window to frame data */
1563                         next = htons(readw(streamer_mmio + LAPDINC));
1564                         status =
1565                             ntohs(readw(streamer_mmio + LAPDINC)) & 0xff;
1566                         len = ntohs(readw(streamer_mmio + LAPDINC));
1567
1568                         /* print out 1st 14 bytes of frame data */
1569                         for (i = 0; i < 7; i++) {
1570                                 printk("Loc %d = %04x\n", i,
1571                                        ntohs(readw
1572                                              (streamer_mmio + LAPDINC)));
1573                         }
1574
1575                         printk("next %04x, fs %02x, len %04x \n", next,
1576                                status, len);
1577                 }
1578 #endif
1579                 if (!(mac_frame = dev_alloc_skb(frame_len))) {
1580                         printk(KERN_WARNING "%s: Memory squeeze, dropping frame.\n",
1581                                dev->name);
1582                         goto drop_frame;
1583                 }
1584                 /* Walk the buffer chain, creating the frame */
1585
1586                 do {
1587                         int i;
1588                         __u16 rx_word;
1589
1590                         writew(htons(buff_off), streamer_mmio + LAPA);  /* setup window to frame data */
1591                         next_ptr = ntohs(readw(streamer_mmio + LAPDINC));
1592                         readw(streamer_mmio + LAPDINC); /* read thru status word */
1593                         buffer_len = ntohs(readw(streamer_mmio + LAPDINC));
1594
1595                         if (buffer_len > 256)
1596                                 break;
1597
1598                         i = 0;
1599                         while (i < buffer_len) {
1600                                 rx_word=ntohs(readw(streamer_mmio+LAPDINC));
1601                                 frame_data[i]=rx_word >> 8;
1602                                 frame_data[i+1]=rx_word & 0xff;
1603                                 i += 2;
1604                         }
1605
1606                         memcpy(skb_put(mac_frame, buffer_len),
1607                                       frame_data, buffer_len);
1608                 } while (next_ptr && (buff_off = next_ptr));
1609
1610 #if STREAMER_NETWORK_MONITOR
1611                 printk(KERN_WARNING "%s: Received MAC Frame, details: \n",
1612                        dev->name);
1613                 mac_hdr = (struct trh_hdr *) mac_frame->data;
1614                 printk(KERN_WARNING
1615                        "%s: MAC Frame Dest. Addr: %02x:%02x:%02x:%02x:%02x:%02x \n",
1616                        dev->name, mac_hdr->daddr[0], mac_hdr->daddr[1],
1617                        mac_hdr->daddr[2], mac_hdr->daddr[3],
1618                        mac_hdr->daddr[4], mac_hdr->daddr[5]);
1619                 printk(KERN_WARNING
1620                        "%s: MAC Frame Srce. Addr: %02x:%02x:%02x:%02x:%02x:%02x \n",
1621                        dev->name, mac_hdr->saddr[0], mac_hdr->saddr[1],
1622                        mac_hdr->saddr[2], mac_hdr->saddr[3],
1623                        mac_hdr->saddr[4], mac_hdr->saddr[5]);
1624 #endif
1625                 mac_frame->dev = dev;
1626                 mac_frame->protocol = tr_type_trans(mac_frame, dev);
1627                 netif_rx(mac_frame);
1628
1629                 /* Now tell the card we have dealt with the received frame */
1630 drop_frame:
1631                 /* Set LISR Bit 1 */
1632                 writel(LISR_ARB_FREE, streamer_priv->streamer_mmio + LISR_SUM);
1633
1634                 /* Is the ASB free ? */
1635
1636                 if (!(readl(streamer_priv->streamer_mmio + SISR) & SISR_ASB_FREE))
1637                 {
1638                         streamer_priv->asb_queued = 1;
1639                         writel(LISR_ASB_FREE_REQ, streamer_priv->streamer_mmio + LISR_SUM);
1640                         return;
1641                         /* Drop out and wait for the bottom half to be run */
1642                 }
1643
1644
1645                 writew(streamer_priv->asb, streamer_mmio + LAPA);
1646                 writew(htons(ASB_RECEIVE_DATA << 8), streamer_mmio+LAPDINC);
1647                 writew(htons(STREAMER_CLEAR_RET_CODE << 8), streamer_mmio+LAPDINC);
1648                 writew(0, streamer_mmio + LAPDINC);
1649                 writew(htons(streamer_priv->mac_rx_buffer), streamer_mmio + LAPD);
1650
1651                 writel(LISR_ASB_REPLY | LISR_ASB_FREE_REQ, streamer_priv->streamer_mmio + LISR_SUM);
1652
1653                 streamer_priv->asb_queued = 2;
1654                 return;
1655
1656         } else if (arb_word == ARB_LAN_CHANGE_STATUS) { /* Lan.change.status */
1657                 writew(streamer_priv->arb + 6, streamer_mmio + LAPA);
1658                 lan_status = ntohs(readw(streamer_mmio + LAPDINC));
1659                 fdx_prot_error = ntohs(readw(streamer_mmio+LAPD)) >> 8;
1660
1661                 /* Issue ARB Free */
1662                 writew(LISR_ARB_FREE, streamer_priv->streamer_mmio + LISR_SUM);
1663
1664                 lan_status_diff = (streamer_priv->streamer_lan_status ^ lan_status) &
1665                     lan_status;
1666
1667                 if (lan_status_diff & (LSC_LWF | LSC_ARW | LSC_FPE | LSC_RR))
1668                 {
1669                         if (lan_status_diff & LSC_LWF)
1670                                 printk(KERN_WARNING "%s: Short circuit detected on the lobe\n", dev->name);
1671                         if (lan_status_diff & LSC_ARW)
1672                                 printk(KERN_WARNING "%s: Auto removal error\n", dev->name);
1673                         if (lan_status_diff & LSC_FPE)
1674                                 printk(KERN_WARNING "%s: FDX Protocol Error\n", dev->name);
1675                         if (lan_status_diff & LSC_RR)
1676                                 printk(KERN_WARNING "%s: Force remove MAC frame received\n", dev->name);
1677
1678                         /* Adapter has been closed by the hardware */
1679
1680                         /* reset tx/rx fifo's and busmaster logic */
1681
1682                         /* @TBD. no llc reset on autostreamer writel(readl(streamer_mmio+BCTL)|(3<<13),streamer_mmio+BCTL);
1683                            udelay(1);
1684                            writel(readl(streamer_mmio+BCTL)&~(3<<13),streamer_mmio+BCTL); */
1685
1686                         netif_stop_queue(dev);
1687                         netif_carrier_off(dev);
1688                         printk(KERN_WARNING "%s: Adapter must be manually reset.\n", dev->name);
1689                 }
1690                 /* If serious error */
1691                 if (streamer_priv->streamer_message_level) {
1692                         if (lan_status_diff & LSC_SIG_LOSS)
1693                                 printk(KERN_WARNING "%s: No receive signal detected \n", dev->name);
1694                         if (lan_status_diff & LSC_HARD_ERR)
1695                                 printk(KERN_INFO "%s: Beaconing \n", dev->name);
1696                         if (lan_status_diff & LSC_SOFT_ERR)
1697                                 printk(KERN_WARNING "%s: Adapter transmitted Soft Error Report Mac Frame \n", dev->name);
1698                         if (lan_status_diff & LSC_TRAN_BCN)
1699                                 printk(KERN_INFO "%s: We are tranmitting the beacon, aaah\n", dev->name);
1700                         if (lan_status_diff & LSC_SS)
1701                                 printk(KERN_INFO "%s: Single Station on the ring \n", dev->name);
1702                         if (lan_status_diff & LSC_RING_REC)
1703                                 printk(KERN_INFO "%s: Ring recovery ongoing\n", dev->name);
1704                         if (lan_status_diff & LSC_FDX_MODE)
1705                                 printk(KERN_INFO "%s: Operating in FDX mode\n", dev->name);
1706                 }
1707
1708                 if (lan_status_diff & LSC_CO) {
1709                         if (streamer_priv->streamer_message_level)
1710                                 printk(KERN_INFO "%s: Counter Overflow \n", dev->name);
1711
1712                         /* Issue READ.LOG command */
1713
1714                         writew(streamer_priv->srb, streamer_mmio + LAPA);
1715                         writew(htons(SRB_READ_LOG << 8),streamer_mmio+LAPDINC);
1716                         writew(htons(STREAMER_CLEAR_RET_CODE << 8), streamer_mmio+LAPDINC);
1717                         writew(0, streamer_mmio + LAPDINC);
1718                         streamer_priv->srb_queued = 2;  /* Can't sleep, use srb_bh */
1719
1720                         writew(LISR_SRB_CMD, streamer_mmio + LISR_SUM);
1721                 }
1722
1723                 if (lan_status_diff & LSC_SR_CO) {
1724                         if (streamer_priv->streamer_message_level)
1725                                 printk(KERN_INFO "%s: Source routing counters overflow\n", dev->name);
1726
1727                         /* Issue a READ.SR.COUNTERS */
1728                         writew(streamer_priv->srb, streamer_mmio + LAPA);
1729                         writew(htons(SRB_READ_SR_COUNTERS << 8),
1730                                streamer_mmio+LAPDINC);
1731                         writew(htons(STREAMER_CLEAR_RET_CODE << 8),
1732                                streamer_mmio+LAPDINC);
1733                         streamer_priv->srb_queued = 2;  /* Can't sleep, use srb_bh */
1734                         writew(LISR_SRB_CMD, streamer_mmio + LISR_SUM);
1735
1736                 }
1737                 streamer_priv->streamer_lan_status = lan_status;
1738         } /* Lan.change.status */
1739         else
1740                 printk(KERN_WARNING "%s: Unknown arb command \n", dev->name);
1741 }
1742
1743 static void streamer_asb_bh(struct net_device *dev)
1744 {
1745         struct streamer_private *streamer_priv =
1746             (struct streamer_private *) dev->priv;
1747         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1748
1749         if (streamer_priv->asb_queued == 1)
1750         {
1751                 /* Dropped through the first time */
1752
1753                 writew(streamer_priv->asb, streamer_mmio + LAPA);
1754                 writew(htons(ASB_RECEIVE_DATA << 8),streamer_mmio+LAPDINC);
1755                 writew(htons(STREAMER_CLEAR_RET_CODE << 8), streamer_mmio+LAPDINC);
1756                 writew(0, streamer_mmio + LAPDINC);
1757                 writew(htons(streamer_priv->mac_rx_buffer), streamer_mmio + LAPD);
1758
1759                 writel(LISR_ASB_REPLY | LISR_ASB_FREE_REQ, streamer_priv->streamer_mmio + LISR_SUM);
1760                 streamer_priv->asb_queued = 2;
1761
1762                 return;
1763         }
1764
1765         if (streamer_priv->asb_queued == 2) {
1766                 __u8 rc;
1767                 writew(streamer_priv->asb + 2, streamer_mmio + LAPA);
1768                 rc=ntohs(readw(streamer_mmio+LAPD)) >> 8;
1769                 switch (rc) {
1770                 case 0x01:
1771                         printk(KERN_WARNING "%s: Unrecognized command code \n", dev->name);
1772                         break;
1773                 case 0x26:
1774                         printk(KERN_WARNING "%s: Unrecognized buffer address \n", dev->name);
1775                         break;
1776                 case 0xFF:
1777                         /* Valid response, everything should be ok again */
1778                         break;
1779                 default:
1780                         printk(KERN_WARNING "%s: Invalid return code in asb\n", dev->name);
1781                         break;
1782                 }
1783         }
1784         streamer_priv->asb_queued = 0;
1785 }
1786
1787 static int streamer_change_mtu(struct net_device *dev, int mtu)
1788 {
1789         struct streamer_private *streamer_priv =
1790             (struct streamer_private *) dev->priv;
1791         __u16 max_mtu;
1792
1793         if (streamer_priv->streamer_ring_speed == 4)
1794                 max_mtu = 4500;
1795         else
1796                 max_mtu = 18000;
1797
1798         if (mtu > max_mtu)
1799                 return -EINVAL;
1800         if (mtu < 100)
1801                 return -EINVAL;
1802
1803         dev->mtu = mtu;
1804         streamer_priv->pkt_buf_sz = mtu + TR_HLEN;
1805
1806         return 0;
1807 }
1808
1809 #if STREAMER_NETWORK_MONITOR
1810 #ifdef CONFIG_PROC_FS
1811 static int streamer_proc_info(char *buffer, char **start, off_t offset,
1812                               int length, int *eof, void *data)
1813 {
1814   struct streamer_private *sdev=NULL;
1815         struct pci_dev *pci_device = NULL;
1816         int len = 0;
1817         off_t begin = 0;
1818         off_t pos = 0;
1819         int size;
1820
1821   struct net_device *dev;
1822
1823         size = sprintf(buffer, "IBM LanStreamer/MPC Chipset Token Ring Adapters\n");
1824
1825         pos += size;
1826         len += size;
1827
1828   for(sdev=dev_streamer; sdev; sdev=sdev->next) {
1829     pci_device=sdev->pci_dev;
1830     dev=pci_get_drvdata(pci_device);
1831
1832                                 size = sprintf_info(buffer + len, dev);
1833                                 len += size;
1834                                 pos = begin + len;
1835
1836                                 if (pos < offset) {
1837                                         len = 0;
1838                                         begin = pos;
1839                                 }
1840                                 if (pos > offset + length)
1841                                         break;
1842                 }               /* for */
1843
1844         *start = buffer + (offset - begin);     /* Start of wanted data */
1845         len -= (offset - begin);        /* Start slop */
1846         if (len > length)
1847                 len = length;   /* Ending slop */
1848         return len;
1849 }
1850
1851 static int sprintf_info(char *buffer, struct net_device *dev)
1852 {
1853         struct streamer_private *streamer_priv =
1854             (struct streamer_private *) dev->priv;
1855         __u8 __iomem *streamer_mmio = streamer_priv->streamer_mmio;
1856         struct streamer_adapter_addr_table sat;
1857         struct streamer_parameters_table spt;
1858         int size = 0;
1859         int i;
1860
1861         writew(streamer_priv->streamer_addr_table_addr, streamer_mmio + LAPA);
1862         for (i = 0; i < 14; i += 2) {
1863                 __u16 io_word;
1864                 __u8 *datap = (__u8 *) & sat;
1865                 io_word=ntohs(readw(streamer_mmio+LAPDINC));
1866                 datap[size]=io_word >> 8;
1867                 datap[size+1]=io_word & 0xff;
1868         }
1869         writew(streamer_priv->streamer_parms_addr, streamer_mmio + LAPA);
1870         for (i = 0; i < 68; i += 2) {
1871                 __u16 io_word;
1872                 __u8 *datap = (__u8 *) & spt;
1873                 io_word=ntohs(readw(streamer_mmio+LAPDINC));
1874                 datap[size]=io_word >> 8;
1875                 datap[size+1]=io_word & 0xff;
1876         }
1877
1878         size = sprintf(buffer, "\n%6s: Adapter Address   : Node Address      : Functional Addr\n", dev->name);
1879
1880         size += sprintf(buffer + size,
1881                     "%6s: %02x:%02x:%02x:%02x:%02x:%02x : %02x:%02x:%02x:%02x:%02x:%02x : %02x:%02x:%02x:%02x\n",
1882                     dev->name, dev->dev_addr[0], dev->dev_addr[1],
1883                     dev->dev_addr[2], dev->dev_addr[3], dev->dev_addr[4],
1884                     dev->dev_addr[5], sat.node_addr[0], sat.node_addr[1],
1885                     sat.node_addr[2], sat.node_addr[3], sat.node_addr[4],
1886                     sat.node_addr[5], sat.func_addr[0], sat.func_addr[1],
1887                     sat.func_addr[2], sat.func_addr[3]);
1888
1889         size += sprintf(buffer + size, "\n%6s: Token Ring Parameters Table:\n", dev->name);
1890
1891         size += sprintf(buffer + size, "%6s: Physical Addr : Up Node Address   : Poll Address      : AccPri : Auth Src : Att Code :\n", dev->name);
1892
1893         size += sprintf(buffer + size,
1894                     "%6s: %02x:%02x:%02x:%02x   : %02x:%02x:%02x:%02x:%02x:%02x : %02x:%02x:%02x:%02x:%02x:%02x : %04x   : %04x     :  %04x    :\n",
1895                     dev->name, spt.phys_addr[0], spt.phys_addr[1],
1896                     spt.phys_addr[2], spt.phys_addr[3],
1897                     spt.up_node_addr[0], spt.up_node_addr[1],
1898                     spt.up_node_addr[2], spt.up_node_addr[3],
1899                     spt.up_node_addr[4], spt.up_node_addr[4],
1900                     spt.poll_addr[0], spt.poll_addr[1], spt.poll_addr[2],
1901                     spt.poll_addr[3], spt.poll_addr[4], spt.poll_addr[5],
1902                     ntohs(spt.acc_priority), ntohs(spt.auth_source_class),
1903                     ntohs(spt.att_code));
1904
1905         size += sprintf(buffer + size, "%6s: Source Address    : Bcn T : Maj. V : Lan St : Lcl Rg : Mon Err : Frame Correl : \n", dev->name);
1906
1907         size += sprintf(buffer + size,
1908                     "%6s: %02x:%02x:%02x:%02x:%02x:%02x : %04x  : %04x   : %04x   : %04x   : %04x    :     %04x     : \n",
1909                     dev->name, spt.source_addr[0], spt.source_addr[1],
1910                     spt.source_addr[2], spt.source_addr[3],
1911                     spt.source_addr[4], spt.source_addr[5],
1912                     ntohs(spt.beacon_type), ntohs(spt.major_vector),
1913                     ntohs(spt.lan_status), ntohs(spt.local_ring),
1914                     ntohs(spt.mon_error), ntohs(spt.frame_correl));
1915
1916         size += sprintf(buffer + size, "%6s: Beacon Details :  Tx  :  Rx  : NAUN Node Address : NAUN Node Phys : \n",
1917                     dev->name);
1918
1919         size += sprintf(buffer + size,
1920                     "%6s:                :  %02x  :  %02x  : %02x:%02x:%02x:%02x:%02x:%02x : %02x:%02x:%02x:%02x    : \n",
1921                     dev->name, ntohs(spt.beacon_transmit),
1922                     ntohs(spt.beacon_receive), spt.beacon_naun[0],
1923                     spt.beacon_naun[1], spt.beacon_naun[2],
1924                     spt.beacon_naun[3], spt.beacon_naun[4],
1925                     spt.beacon_naun[5], spt.beacon_phys[0],
1926                     spt.beacon_phys[1], spt.beacon_phys[2],
1927                     spt.beacon_phys[3]);
1928         return size;
1929 }
1930 #endif
1931 #endif
1932
1933 static struct pci_driver streamer_pci_driver = {
1934   .name     = "lanstreamer",
1935   .id_table = streamer_pci_tbl,
1936   .probe    = streamer_init_one,
1937   .remove   = __devexit_p(streamer_remove_one),
1938 };
1939
1940 static int __init streamer_init_module(void) {
1941   return pci_register_driver(&streamer_pci_driver);
1942 }
1943
1944 static void __exit streamer_cleanup_module(void) {
1945   pci_unregister_driver(&streamer_pci_driver);
1946 }
1947
1948 module_init(streamer_init_module);
1949 module_exit(streamer_cleanup_module);
1950 MODULE_LICENSE("GPL");