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