linux/drivers/net/usb/pegasus.c
<<
>>
Prefs
   1/*
   2 *  Copyright (c) 1999-2005 Petko Manolov (petkan@users.sourceforge.net)
   3 *
   4 * This program is free software; you can redistribute it and/or modify
   5 * it under the terms of the GNU General Public License version 2 as
   6 * published by the Free Software Foundation.
   7 *
   8 *      ChangeLog:
   9 *              ....    Most of the time spent on reading sources & docs.
  10 *              v0.2.x  First official release for the Linux kernel.
  11 *              v0.3.0  Beutified and structured, some bugs fixed.
  12 *              v0.3.x  URBifying bulk requests and bugfixing. First relatively
  13 *                      stable release. Still can touch device's registers only
  14 *                      from top-halves.
  15 *              v0.4.0  Control messages remained unurbified are now URBs.
  16 *                      Now we can touch the HW at any time.
  17 *              v0.4.9  Control urbs again use process context to wait. Argh...
  18 *                      Some long standing bugs (enable_net_traffic) fixed.
  19 *                      Also nasty trick about resubmiting control urb from
  20 *                      interrupt context used. Please let me know how it
  21 *                      behaves. Pegasus II support added since this version.
  22 *                      TODO: suppressing HCD warnings spewage on disconnect.
  23 *              v0.4.13 Ethernet address is now set at probe(), not at open()
  24 *                      time as this seems to break dhcpd.
  25 *              v0.5.0  branch to 2.5.x kernels
  26 *              v0.5.1  ethtool support added
  27 *              v0.5.5  rx socket buffers are in a pool and the their allocation
  28 *                      is out of the interrupt routine.
  29 */
  30
  31#include <linux/sched.h>
  32#include <linux/slab.h>
  33#include <linux/init.h>
  34#include <linux/delay.h>
  35#include <linux/netdevice.h>
  36#include <linux/etherdevice.h>
  37#include <linux/ethtool.h>
  38#include <linux/mii.h>
  39#include <linux/usb.h>
  40#include <linux/module.h>
  41#include <asm/byteorder.h>
  42#include <asm/uaccess.h>
  43#include "pegasus.h"
  44
  45/*
  46 * Version Information
  47 */
  48#define DRIVER_VERSION "v0.6.14 (2006/09/27)"
  49#define DRIVER_AUTHOR "Petko Manolov <petkan@users.sourceforge.net>"
  50#define DRIVER_DESC "Pegasus/Pegasus II USB Ethernet driver"
  51
  52static const char driver_name[] = "pegasus";
  53
  54#undef  PEGASUS_WRITE_EEPROM
  55#define BMSR_MEDIA      (BMSR_10HALF | BMSR_10FULL | BMSR_100HALF | \
  56                        BMSR_100FULL | BMSR_ANEGCAPABLE)
  57
  58static int loopback;
  59static int mii_mode;
  60static char *devid;
  61
  62static struct usb_eth_dev usb_dev_id[] = {
  63#define PEGASUS_DEV(pn, vid, pid, flags)        \
  64        {.name = pn, .vendor = vid, .device = pid, .private = flags},
  65#define PEGASUS_DEV_CLASS(pn, vid, pid, dclass, flags) \
  66        PEGASUS_DEV(pn, vid, pid, flags)
  67#include "pegasus.h"
  68#undef  PEGASUS_DEV
  69#undef  PEGASUS_DEV_CLASS
  70        {NULL, 0, 0, 0},
  71        {NULL, 0, 0, 0}
  72};
  73
  74static struct usb_device_id pegasus_ids[] = {
  75#define PEGASUS_DEV(pn, vid, pid, flags) \
  76        {.match_flags = USB_DEVICE_ID_MATCH_DEVICE, .idVendor = vid, .idProduct = pid},
  77/*
  78 * The Belkin F8T012xx1 bluetooth adaptor has the same vendor and product
  79 * IDs as the Belkin F5D5050, so we need to teach the pegasus driver to
  80 * ignore adaptors belonging to the "Wireless" class 0xE0. For this one
  81 * case anyway, seeing as the pegasus is for "Wired" adaptors.
  82 */
  83#define PEGASUS_DEV_CLASS(pn, vid, pid, dclass, flags) \
  84        {.match_flags = (USB_DEVICE_ID_MATCH_DEVICE | USB_DEVICE_ID_MATCH_DEV_CLASS), \
  85        .idVendor = vid, .idProduct = pid, .bDeviceClass = dclass},
  86#include "pegasus.h"
  87#undef  PEGASUS_DEV
  88#undef  PEGASUS_DEV_CLASS
  89        {},
  90        {}
  91};
  92
  93MODULE_AUTHOR(DRIVER_AUTHOR);
  94MODULE_DESCRIPTION(DRIVER_DESC);
  95MODULE_LICENSE("GPL");
  96module_param(loopback, bool, 0);
  97module_param(mii_mode, bool, 0);
  98module_param(devid, charp, 0);
  99MODULE_PARM_DESC(loopback, "Enable MAC loopback mode (bit 0)");
 100MODULE_PARM_DESC(mii_mode, "Enable HomePNA mode (bit 0),default=MII mode = 0");
 101MODULE_PARM_DESC(devid, "The format is: 'DEV_name:VendorID:DeviceID:Flags'");
 102
 103/* use ethtool to change the level for any given device */
 104static int msg_level = -1;
 105module_param(msg_level, int, 0);
 106MODULE_PARM_DESC(msg_level, "Override default message level");
 107
 108MODULE_DEVICE_TABLE(usb, pegasus_ids);
 109static const struct net_device_ops pegasus_netdev_ops;
 110
 111static int update_eth_regs_async(pegasus_t *);
 112/* Aargh!!! I _really_ hate such tweaks */
 113static void ctrl_callback(struct urb *urb)
 114{
 115        pegasus_t *pegasus = urb->context;
 116        int status = urb->status;
 117
 118        if (!pegasus)
 119                return;
 120
 121        switch (status) {
 122        case 0:
 123                if (pegasus->flags & ETH_REGS_CHANGE) {
 124                        pegasus->flags &= ~ETH_REGS_CHANGE;
 125                        pegasus->flags |= ETH_REGS_CHANGED;
 126                        update_eth_regs_async(pegasus);
 127                        return;
 128                }
 129                break;
 130        case -EINPROGRESS:
 131                return;
 132        case -ENOENT:
 133                break;
 134        default:
 135                if (net_ratelimit())
 136                        netif_dbg(pegasus, drv, pegasus->net,
 137                                  "%s, status %d\n", __func__, status);
 138                break;
 139        }
 140        pegasus->flags &= ~ETH_REGS_CHANGED;
 141        wake_up(&pegasus->ctrl_wait);
 142}
 143
 144static int get_registers(pegasus_t *pegasus, __u16 indx, __u16 size,
 145                         void *data)
 146{
 147        int ret;
 148        char *buffer;
 149        DECLARE_WAITQUEUE(wait, current);
 150
 151        buffer = kmalloc(size, GFP_KERNEL);
 152        if (!buffer) {
 153                netif_warn(pegasus, drv, pegasus->net,
 154                           "out of memory in %s\n", __func__);
 155                return -ENOMEM;
 156        }
 157        add_wait_queue(&pegasus->ctrl_wait, &wait);
 158        set_current_state(TASK_UNINTERRUPTIBLE);
 159        while (pegasus->flags & ETH_REGS_CHANGED)
 160                schedule();
 161        remove_wait_queue(&pegasus->ctrl_wait, &wait);
 162        set_current_state(TASK_RUNNING);
 163
 164        pegasus->dr.bRequestType = PEGASUS_REQT_READ;
 165        pegasus->dr.bRequest = PEGASUS_REQ_GET_REGS;
 166        pegasus->dr.wValue = cpu_to_le16(0);
 167        pegasus->dr.wIndex = cpu_to_le16(indx);
 168        pegasus->dr.wLength = cpu_to_le16(size);
 169        pegasus->ctrl_urb->transfer_buffer_length = size;
 170
 171        usb_fill_control_urb(pegasus->ctrl_urb, pegasus->usb,
 172                             usb_rcvctrlpipe(pegasus->usb, 0),
 173                             (char *) &pegasus->dr,
 174                             buffer, size, ctrl_callback, pegasus);
 175
 176        add_wait_queue(&pegasus->ctrl_wait, &wait);
 177        set_current_state(TASK_UNINTERRUPTIBLE);
 178
 179        /* using ATOMIC, we'd never wake up if we slept */
 180        if ((ret = usb_submit_urb(pegasus->ctrl_urb, GFP_ATOMIC))) {
 181                set_current_state(TASK_RUNNING);
 182                if (ret == -ENODEV)
 183                        netif_device_detach(pegasus->net);
 184                if (net_ratelimit())
 185                        netif_err(pegasus, drv, pegasus->net,
 186                                  "%s, status %d\n", __func__, ret);
 187                goto out;
 188        }
 189
 190        schedule();
 191out:
 192        remove_wait_queue(&pegasus->ctrl_wait, &wait);
 193        memcpy(data, buffer, size);
 194        kfree(buffer);
 195
 196        return ret;
 197}
 198
 199static int set_registers(pegasus_t *pegasus, __u16 indx, __u16 size,
 200                         void *data)
 201{
 202        int ret;
 203        char *buffer;
 204        DECLARE_WAITQUEUE(wait, current);
 205
 206        buffer = kmemdup(data, size, GFP_KERNEL);
 207        if (!buffer) {
 208                netif_warn(pegasus, drv, pegasus->net,
 209                           "out of memory in %s\n", __func__);
 210                return -ENOMEM;
 211        }
 212
 213        add_wait_queue(&pegasus->ctrl_wait, &wait);
 214        set_current_state(TASK_UNINTERRUPTIBLE);
 215        while (pegasus->flags & ETH_REGS_CHANGED)
 216                schedule();
 217        remove_wait_queue(&pegasus->ctrl_wait, &wait);
 218        set_current_state(TASK_RUNNING);
 219
 220        pegasus->dr.bRequestType = PEGASUS_REQT_WRITE;
 221        pegasus->dr.bRequest = PEGASUS_REQ_SET_REGS;
 222        pegasus->dr.wValue = cpu_to_le16(0);
 223        pegasus->dr.wIndex = cpu_to_le16(indx);
 224        pegasus->dr.wLength = cpu_to_le16(size);
 225        pegasus->ctrl_urb->transfer_buffer_length = size;
 226
 227        usb_fill_control_urb(pegasus->ctrl_urb, pegasus->usb,
 228                             usb_sndctrlpipe(pegasus->usb, 0),
 229                             (char *) &pegasus->dr,
 230                             buffer, size, ctrl_callback, pegasus);
 231
 232        add_wait_queue(&pegasus->ctrl_wait, &wait);
 233        set_current_state(TASK_UNINTERRUPTIBLE);
 234
 235        if ((ret = usb_submit_urb(pegasus->ctrl_urb, GFP_ATOMIC))) {
 236                if (ret == -ENODEV)
 237                        netif_device_detach(pegasus->net);
 238                netif_err(pegasus, drv, pegasus->net,
 239                          "%s, status %d\n", __func__, ret);
 240                goto out;
 241        }
 242
 243        schedule();
 244out:
 245        remove_wait_queue(&pegasus->ctrl_wait, &wait);
 246        kfree(buffer);
 247
 248        return ret;
 249}
 250
 251static int set_register(pegasus_t *pegasus, __u16 indx, __u8 data)
 252{
 253        int ret;
 254        char *tmp;
 255        DECLARE_WAITQUEUE(wait, current);
 256
 257        tmp = kmemdup(&data, 1, GFP_KERNEL);
 258        if (!tmp) {
 259                netif_warn(pegasus, drv, pegasus->net,
 260                           "out of memory in %s\n", __func__);
 261                return -ENOMEM;
 262        }
 263        add_wait_queue(&pegasus->ctrl_wait, &wait);
 264        set_current_state(TASK_UNINTERRUPTIBLE);
 265        while (pegasus->flags & ETH_REGS_CHANGED)
 266                schedule();
 267        remove_wait_queue(&pegasus->ctrl_wait, &wait);
 268        set_current_state(TASK_RUNNING);
 269
 270        pegasus->dr.bRequestType = PEGASUS_REQT_WRITE;
 271        pegasus->dr.bRequest = PEGASUS_REQ_SET_REG;
 272        pegasus->dr.wValue = cpu_to_le16(data);
 273        pegasus->dr.wIndex = cpu_to_le16(indx);
 274        pegasus->dr.wLength = cpu_to_le16(1);
 275        pegasus->ctrl_urb->transfer_buffer_length = 1;
 276
 277        usb_fill_control_urb(pegasus->ctrl_urb, pegasus->usb,
 278                             usb_sndctrlpipe(pegasus->usb, 0),
 279                             (char *) &pegasus->dr,
 280                             tmp, 1, ctrl_callback, pegasus);
 281
 282        add_wait_queue(&pegasus->ctrl_wait, &wait);
 283        set_current_state(TASK_UNINTERRUPTIBLE);
 284
 285        if ((ret = usb_submit_urb(pegasus->ctrl_urb, GFP_ATOMIC))) {
 286                if (ret == -ENODEV)
 287                        netif_device_detach(pegasus->net);
 288                if (net_ratelimit())
 289                        netif_err(pegasus, drv, pegasus->net,
 290                                  "%s, status %d\n", __func__, ret);
 291                goto out;
 292        }
 293
 294        schedule();
 295out:
 296        remove_wait_queue(&pegasus->ctrl_wait, &wait);
 297        kfree(tmp);
 298
 299        return ret;
 300}
 301
 302static int update_eth_regs_async(pegasus_t *pegasus)
 303{
 304        int ret;
 305
 306        pegasus->dr.bRequestType = PEGASUS_REQT_WRITE;
 307        pegasus->dr.bRequest = PEGASUS_REQ_SET_REGS;
 308        pegasus->dr.wValue = cpu_to_le16(0);
 309        pegasus->dr.wIndex = cpu_to_le16(EthCtrl0);
 310        pegasus->dr.wLength = cpu_to_le16(3);
 311        pegasus->ctrl_urb->transfer_buffer_length = 3;
 312
 313        usb_fill_control_urb(pegasus->ctrl_urb, pegasus->usb,
 314                             usb_sndctrlpipe(pegasus->usb, 0),
 315                             (char *) &pegasus->dr,
 316                             pegasus->eth_regs, 3, ctrl_callback, pegasus);
 317
 318        if ((ret = usb_submit_urb(pegasus->ctrl_urb, GFP_ATOMIC))) {
 319                if (ret == -ENODEV)
 320                        netif_device_detach(pegasus->net);
 321                netif_err(pegasus, drv, pegasus->net,
 322                          "%s, status %d\n", __func__, ret);
 323        }
 324
 325        return ret;
 326}
 327
 328/* Returns 0 on success, error on failure */
 329static int read_mii_word(pegasus_t *pegasus, __u8 phy, __u8 indx, __u16 *regd)
 330{
 331        int i;
 332        __u8 data[4] = { phy, 0, 0, indx };
 333        __le16 regdi;
 334        int ret;
 335
 336        set_register(pegasus, PhyCtrl, 0);
 337        set_registers(pegasus, PhyAddr, sizeof(data), data);
 338        set_register(pegasus, PhyCtrl, (indx | PHY_READ));
 339        for (i = 0; i < REG_TIMEOUT; i++) {
 340                ret = get_registers(pegasus, PhyCtrl, 1, data);
 341                if (ret == -ESHUTDOWN)
 342                        goto fail;
 343                if (data[0] & PHY_DONE)
 344                        break;
 345        }
 346
 347        if (i >= REG_TIMEOUT)
 348                goto fail;
 349
 350        ret = get_registers(pegasus, PhyData, 2, &regdi);
 351        *regd = le16_to_cpu(regdi);
 352        return ret;
 353
 354fail:
 355        netif_warn(pegasus, drv, pegasus->net, "%s failed\n", __func__);
 356
 357        return ret;
 358}
 359
 360static int mdio_read(struct net_device *dev, int phy_id, int loc)
 361{
 362        pegasus_t *pegasus = netdev_priv(dev);
 363        u16 res;
 364
 365        read_mii_word(pegasus, phy_id, loc, &res);
 366        return (int)res;
 367}
 368
 369static int write_mii_word(pegasus_t *pegasus, __u8 phy, __u8 indx, __u16 regd)
 370{
 371        int i;
 372        __u8 data[4] = { phy, 0, 0, indx };
 373        int ret;
 374
 375        data[1] = (u8) regd;
 376        data[2] = (u8) (regd >> 8);
 377        set_register(pegasus, PhyCtrl, 0);
 378        set_registers(pegasus, PhyAddr, sizeof(data), data);
 379        set_register(pegasus, PhyCtrl, (indx | PHY_WRITE));
 380        for (i = 0; i < REG_TIMEOUT; i++) {
 381                ret = get_registers(pegasus, PhyCtrl, 1, data);
 382                if (ret == -ESHUTDOWN)
 383                        goto fail;
 384                if (data[0] & PHY_DONE)
 385                        break;
 386        }
 387
 388        if (i >= REG_TIMEOUT)
 389                goto fail;
 390
 391        return ret;
 392
 393fail:
 394        netif_warn(pegasus, drv, pegasus->net, "%s failed\n", __func__);
 395        return -ETIMEDOUT;
 396}
 397
 398static void mdio_write(struct net_device *dev, int phy_id, int loc, int val)
 399{
 400        pegasus_t *pegasus = netdev_priv(dev);
 401
 402        write_mii_word(pegasus, phy_id, loc, val);
 403}
 404
 405static int read_eprom_word(pegasus_t *pegasus, __u8 index, __u16 *retdata)
 406{
 407        int i;
 408        __u8 tmp;
 409        __le16 retdatai;
 410        int ret;
 411
 412        set_register(pegasus, EpromCtrl, 0);
 413        set_register(pegasus, EpromOffset, index);
 414        set_register(pegasus, EpromCtrl, EPROM_READ);
 415
 416        for (i = 0; i < REG_TIMEOUT; i++) {
 417                ret = get_registers(pegasus, EpromCtrl, 1, &tmp);
 418                if (tmp & EPROM_DONE)
 419                        break;
 420                if (ret == -ESHUTDOWN)
 421                        goto fail;
 422        }
 423        if (i >= REG_TIMEOUT)
 424                goto fail;
 425
 426        ret = get_registers(pegasus, EpromData, 2, &retdatai);
 427        *retdata = le16_to_cpu(retdatai);
 428        return ret;
 429
 430fail:
 431        netif_warn(pegasus, drv, pegasus->net, "%s failed\n", __func__);
 432        return -ETIMEDOUT;
 433}
 434
 435#ifdef  PEGASUS_WRITE_EEPROM
 436static inline void enable_eprom_write(pegasus_t *pegasus)
 437{
 438        __u8 tmp;
 439        int ret;
 440
 441        get_registers(pegasus, EthCtrl2, 1, &tmp);
 442        set_register(pegasus, EthCtrl2, tmp | EPROM_WR_ENABLE);
 443}
 444
 445static inline void disable_eprom_write(pegasus_t *pegasus)
 446{
 447        __u8 tmp;
 448        int ret;
 449
 450        get_registers(pegasus, EthCtrl2, 1, &tmp);
 451        set_register(pegasus, EpromCtrl, 0);
 452        set_register(pegasus, EthCtrl2, tmp & ~EPROM_WR_ENABLE);
 453}
 454
 455static int write_eprom_word(pegasus_t *pegasus, __u8 index, __u16 data)
 456{
 457        int i;
 458        __u8 tmp, d[4] = { 0x3f, 0, 0, EPROM_WRITE };
 459        int ret;
 460        __le16 le_data = cpu_to_le16(data);
 461
 462        set_registers(pegasus, EpromOffset, 4, d);
 463        enable_eprom_write(pegasus);
 464        set_register(pegasus, EpromOffset, index);
 465        set_registers(pegasus, EpromData, 2, &le_data);
 466        set_register(pegasus, EpromCtrl, EPROM_WRITE);
 467
 468        for (i = 0; i < REG_TIMEOUT; i++) {
 469                ret = get_registers(pegasus, EpromCtrl, 1, &tmp);
 470                if (ret == -ESHUTDOWN)
 471                        goto fail;
 472                if (tmp & EPROM_DONE)
 473                        break;
 474        }
 475        disable_eprom_write(pegasus);
 476        if (i >= REG_TIMEOUT)
 477                goto fail;
 478
 479        return ret;
 480
 481fail:
 482        netif_warn(pegasus, drv, pegasus->net, "%s failed\n", __func__);
 483        return -ETIMEDOUT;
 484}
 485#endif                          /* PEGASUS_WRITE_EEPROM */
 486
 487static inline void get_node_id(pegasus_t *pegasus, __u8 *id)
 488{
 489        int i;
 490        __u16 w16;
 491
 492        for (i = 0; i < 3; i++) {
 493                read_eprom_word(pegasus, i, &w16);
 494                ((__le16 *) id)[i] = cpu_to_le16(w16);
 495        }
 496}
 497
 498static void set_ethernet_addr(pegasus_t *pegasus)
 499{
 500        __u8 node_id[6];
 501
 502        if (pegasus->features & PEGASUS_II) {
 503                get_registers(pegasus, 0x10, sizeof(node_id), node_id);
 504        } else {
 505                get_node_id(pegasus, node_id);
 506                set_registers(pegasus, EthID, sizeof(node_id), node_id);
 507        }
 508        memcpy(pegasus->net->dev_addr, node_id, sizeof(node_id));
 509}
 510
 511static inline int reset_mac(pegasus_t *pegasus)
 512{
 513        __u8 data = 0x8;
 514        int i;
 515
 516        set_register(pegasus, EthCtrl1, data);
 517        for (i = 0; i < REG_TIMEOUT; i++) {
 518                get_registers(pegasus, EthCtrl1, 1, &data);
 519                if (~data & 0x08) {
 520                        if (loopback & 1)
 521                                break;
 522                        if (mii_mode && (pegasus->features & HAS_HOME_PNA))
 523                                set_register(pegasus, Gpio1, 0x34);
 524                        else
 525                                set_register(pegasus, Gpio1, 0x26);
 526                        set_register(pegasus, Gpio0, pegasus->features);
 527                        set_register(pegasus, Gpio0, DEFAULT_GPIO_SET);
 528                        break;
 529                }
 530        }
 531        if (i == REG_TIMEOUT)
 532                return -ETIMEDOUT;
 533
 534        if (usb_dev_id[pegasus->dev_index].vendor == VENDOR_LINKSYS ||
 535            usb_dev_id[pegasus->dev_index].vendor == VENDOR_DLINK) {
 536                set_register(pegasus, Gpio0, 0x24);
 537                set_register(pegasus, Gpio0, 0x26);
 538        }
 539        if (usb_dev_id[pegasus->dev_index].vendor == VENDOR_ELCON) {
 540                __u16 auxmode;
 541                read_mii_word(pegasus, 3, 0x1b, &auxmode);
 542                write_mii_word(pegasus, 3, 0x1b, auxmode | 4);
 543        }
 544
 545        return 0;
 546}
 547
 548static int enable_net_traffic(struct net_device *dev, struct usb_device *usb)
 549{
 550        __u16 linkpart;
 551        __u8 data[4];
 552        pegasus_t *pegasus = netdev_priv(dev);
 553        int ret;
 554
 555        read_mii_word(pegasus, pegasus->phy, MII_LPA, &linkpart);
 556        data[0] = 0xc9;
 557        data[1] = 0;
 558        if (linkpart & (ADVERTISE_100FULL | ADVERTISE_10FULL))
 559                data[1] |= 0x20;        /* set full duplex */
 560        if (linkpart & (ADVERTISE_100FULL | ADVERTISE_100HALF))
 561                data[1] |= 0x10;        /* set 100 Mbps */
 562        if (mii_mode)
 563                data[1] = 0;
 564        data[2] = (loopback & 1) ? 0x09 : 0x01;
 565
 566        memcpy(pegasus->eth_regs, data, sizeof(data));
 567        ret = set_registers(pegasus, EthCtrl0, 3, data);
 568
 569        if (usb_dev_id[pegasus->dev_index].vendor == VENDOR_LINKSYS ||
 570            usb_dev_id[pegasus->dev_index].vendor == VENDOR_LINKSYS2 ||
 571            usb_dev_id[pegasus->dev_index].vendor == VENDOR_DLINK) {
 572                u16 auxmode;
 573                read_mii_word(pegasus, 0, 0x1b, &auxmode);
 574                write_mii_word(pegasus, 0, 0x1b, auxmode | 4);
 575        }
 576
 577        return ret;
 578}
 579
 580static void fill_skb_pool(pegasus_t *pegasus)
 581{
 582        int i;
 583
 584        for (i = 0; i < RX_SKBS; i++) {
 585                if (pegasus->rx_pool[i])
 586                        continue;
 587                pegasus->rx_pool[i] = dev_alloc_skb(PEGASUS_MTU + 2);
 588                /*
 589                 ** we give up if the allocation fail. the tasklet will be
 590                 ** rescheduled again anyway...
 591                 */
 592                if (pegasus->rx_pool[i] == NULL)
 593                        return;
 594                skb_reserve(pegasus->rx_pool[i], 2);
 595        }
 596}
 597
 598static void free_skb_pool(pegasus_t *pegasus)
 599{
 600        int i;
 601
 602        for (i = 0; i < RX_SKBS; i++) {
 603                if (pegasus->rx_pool[i]) {
 604                        dev_kfree_skb(pegasus->rx_pool[i]);
 605                        pegasus->rx_pool[i] = NULL;
 606                }
 607        }
 608}
 609
 610static inline struct sk_buff *pull_skb(pegasus_t * pegasus)
 611{
 612        int i;
 613        struct sk_buff *skb;
 614
 615        for (i = 0; i < RX_SKBS; i++) {
 616                if (likely(pegasus->rx_pool[i] != NULL)) {
 617                        skb = pegasus->rx_pool[i];
 618                        pegasus->rx_pool[i] = NULL;
 619                        return skb;
 620                }
 621        }
 622        return NULL;
 623}
 624
 625static void read_bulk_callback(struct urb *urb)
 626{
 627        pegasus_t *pegasus = urb->context;
 628        struct net_device *net;
 629        int rx_status, count = urb->actual_length;
 630        int status = urb->status;
 631        u8 *buf = urb->transfer_buffer;
 632        __u16 pkt_len;
 633
 634        if (!pegasus)
 635                return;
 636
 637        net = pegasus->net;
 638        if (!netif_device_present(net) || !netif_running(net))
 639                return;
 640
 641        switch (status) {
 642        case 0:
 643                break;
 644        case -ETIME:
 645                netif_dbg(pegasus, rx_err, net, "reset MAC\n");
 646                pegasus->flags &= ~PEGASUS_RX_BUSY;
 647                break;
 648        case -EPIPE:            /* stall, or disconnect from TT */
 649                /* FIXME schedule work to clear the halt */
 650                netif_warn(pegasus, rx_err, net, "no rx stall recovery\n");
 651                return;
 652        case -ENOENT:
 653        case -ECONNRESET:
 654        case -ESHUTDOWN:
 655                netif_dbg(pegasus, ifdown, net, "rx unlink, %d\n", status);
 656                return;
 657        default:
 658                netif_dbg(pegasus, rx_err, net, "RX status %d\n", status);
 659                goto goon;
 660        }
 661
 662        if (!count || count < 4)
 663                goto goon;
 664
 665        rx_status = buf[count - 2];
 666        if (rx_status & 0x1e) {
 667                netif_dbg(pegasus, rx_err, net,
 668                          "RX packet error %x\n", rx_status);
 669                pegasus->stats.rx_errors++;
 670                if (rx_status & 0x06)   /* long or runt */
 671                        pegasus->stats.rx_length_errors++;
 672                if (rx_status & 0x08)
 673                        pegasus->stats.rx_crc_errors++;
 674                if (rx_status & 0x10)   /* extra bits   */
 675                        pegasus->stats.rx_frame_errors++;
 676                goto goon;
 677        }
 678        if (pegasus->chip == 0x8513) {
 679                pkt_len = le32_to_cpu(*(__le32 *)urb->transfer_buffer);
 680                pkt_len &= 0x0fff;
 681                pegasus->rx_skb->data += 2;
 682        } else {
 683                pkt_len = buf[count - 3] << 8;
 684                pkt_len += buf[count - 4];
 685                pkt_len &= 0xfff;
 686                pkt_len -= 8;
 687        }
 688
 689        /*
 690         * If the packet is unreasonably long, quietly drop it rather than
 691         * kernel panicing by calling skb_put.
 692         */
 693        if (pkt_len > PEGASUS_MTU)
 694                goto goon;
 695
 696        /*
 697         * at this point we are sure pegasus->rx_skb != NULL
 698         * so we go ahead and pass up the packet.
 699         */
 700        skb_put(pegasus->rx_skb, pkt_len);
 701        pegasus->rx_skb->protocol = eth_type_trans(pegasus->rx_skb, net);
 702        netif_rx(pegasus->rx_skb);
 703        pegasus->stats.rx_packets++;
 704        pegasus->stats.rx_bytes += pkt_len;
 705
 706        if (pegasus->flags & PEGASUS_UNPLUG)
 707                return;
 708
 709        spin_lock(&pegasus->rx_pool_lock);
 710        pegasus->rx_skb = pull_skb(pegasus);
 711        spin_unlock(&pegasus->rx_pool_lock);
 712
 713        if (pegasus->rx_skb == NULL)
 714                goto tl_sched;
 715goon:
 716        usb_fill_bulk_urb(pegasus->rx_urb, pegasus->usb,
 717                          usb_rcvbulkpipe(pegasus->usb, 1),
 718                          pegasus->rx_skb->data, PEGASUS_MTU + 8,
 719                          read_bulk_callback, pegasus);
 720        rx_status = usb_submit_urb(pegasus->rx_urb, GFP_ATOMIC);
 721        if (rx_status == -ENODEV)
 722                netif_device_detach(pegasus->net);
 723        else if (rx_status) {
 724                pegasus->flags |= PEGASUS_RX_URB_FAIL;
 725                goto tl_sched;
 726        } else {
 727                pegasus->flags &= ~PEGASUS_RX_URB_FAIL;
 728        }
 729
 730        return;
 731
 732tl_sched:
 733        tasklet_schedule(&pegasus->rx_tl);
 734}
 735
 736static void rx_fixup(unsigned long data)
 737{
 738        pegasus_t *pegasus;
 739        unsigned long flags;
 740        int status;
 741
 742        pegasus = (pegasus_t *) data;
 743        if (pegasus->flags & PEGASUS_UNPLUG)
 744                return;
 745
 746        spin_lock_irqsave(&pegasus->rx_pool_lock, flags);
 747        fill_skb_pool(pegasus);
 748        if (pegasus->flags & PEGASUS_RX_URB_FAIL)
 749                if (pegasus->rx_skb)
 750                        goto try_again;
 751        if (pegasus->rx_skb == NULL)
 752                pegasus->rx_skb = pull_skb(pegasus);
 753        if (pegasus->rx_skb == NULL) {
 754                netif_warn(pegasus, rx_err, pegasus->net, "low on memory\n");
 755                tasklet_schedule(&pegasus->rx_tl);
 756                goto done;
 757        }
 758        usb_fill_bulk_urb(pegasus->rx_urb, pegasus->usb,
 759                          usb_rcvbulkpipe(pegasus->usb, 1),
 760                          pegasus->rx_skb->data, PEGASUS_MTU + 8,
 761                          read_bulk_callback, pegasus);
 762try_again:
 763        status = usb_submit_urb(pegasus->rx_urb, GFP_ATOMIC);
 764        if (status == -ENODEV)
 765                netif_device_detach(pegasus->net);
 766        else if (status) {
 767                pegasus->flags |= PEGASUS_RX_URB_FAIL;
 768                tasklet_schedule(&pegasus->rx_tl);
 769        } else {
 770                pegasus->flags &= ~PEGASUS_RX_URB_FAIL;
 771        }
 772done:
 773        spin_unlock_irqrestore(&pegasus->rx_pool_lock, flags);
 774}
 775
 776static void write_bulk_callback(struct urb *urb)
 777{
 778        pegasus_t *pegasus = urb->context;
 779        struct net_device *net;
 780        int status = urb->status;
 781
 782        if (!pegasus)
 783                return;
 784
 785        net = pegasus->net;
 786
 787        if (!netif_device_present(net) || !netif_running(net))
 788                return;
 789
 790        switch (status) {
 791        case -EPIPE:
 792                /* FIXME schedule_work() to clear the tx halt */
 793                netif_stop_queue(net);
 794                netif_warn(pegasus, tx_err, net, "no tx stall recovery\n");
 795                return;
 796        case -ENOENT:
 797        case -ECONNRESET:
 798        case -ESHUTDOWN:
 799                netif_dbg(pegasus, ifdown, net, "tx unlink, %d\n", status);
 800                return;
 801        default:
 802                netif_info(pegasus, tx_err, net, "TX status %d\n", status);
 803                /* FALL THROUGH */
 804        case 0:
 805                break;
 806        }
 807
 808        net->trans_start = jiffies; /* prevent tx timeout */
 809        netif_wake_queue(net);
 810}
 811
 812static void intr_callback(struct urb *urb)
 813{
 814        pegasus_t *pegasus = urb->context;
 815        struct net_device *net;
 816        int res, status = urb->status;
 817
 818        if (!pegasus)
 819                return;
 820        net = pegasus->net;
 821
 822        switch (status) {
 823        case 0:
 824                break;
 825        case -ECONNRESET:       /* unlink */
 826        case -ENOENT:
 827        case -ESHUTDOWN:
 828                return;
 829        default:
 830                /* some Pegasus-I products report LOTS of data
 831                 * toggle errors... avoid log spamming
 832                 */
 833                netif_dbg(pegasus, timer, net, "intr status %d\n", status);
 834        }
 835
 836        if (urb->actual_length >= 6) {
 837                u8 *d = urb->transfer_buffer;
 838
 839                /* byte 0 == tx_status1, reg 2B */
 840                if (d[0] & (TX_UNDERRUN|EXCESSIVE_COL
 841                                        |LATE_COL|JABBER_TIMEOUT)) {
 842                        pegasus->stats.tx_errors++;
 843                        if (d[0] & TX_UNDERRUN)
 844                                pegasus->stats.tx_fifo_errors++;
 845                        if (d[0] & (EXCESSIVE_COL | JABBER_TIMEOUT))
 846                                pegasus->stats.tx_aborted_errors++;
 847                        if (d[0] & LATE_COL)
 848                                pegasus->stats.tx_window_errors++;
 849                }
 850
 851                /* d[5].LINK_STATUS lies on some adapters.
 852                 * d[0].NO_CARRIER kicks in only with failed TX.
 853                 * ... so monitoring with MII may be safest.
 854                 */
 855
 856                /* bytes 3-4 == rx_lostpkt, reg 2E/2F */
 857                pegasus->stats.rx_missed_errors += ((d[3] & 0x7f) << 8) | d[4];
 858        }
 859
 860        res = usb_submit_urb(urb, GFP_ATOMIC);
 861        if (res == -ENODEV)
 862                netif_device_detach(pegasus->net);
 863        if (res)
 864                netif_err(pegasus, timer, net,
 865                          "can't resubmit interrupt urb, %d\n", res);
 866}
 867
 868static void pegasus_tx_timeout(struct net_device *net)
 869{
 870        pegasus_t *pegasus = netdev_priv(net);
 871        netif_warn(pegasus, timer, net, "tx timeout\n");
 872        usb_unlink_urb(pegasus->tx_urb);
 873        pegasus->stats.tx_errors++;
 874}
 875
 876static netdev_tx_t pegasus_start_xmit(struct sk_buff *skb,
 877                                            struct net_device *net)
 878{
 879        pegasus_t *pegasus = netdev_priv(net);
 880        int count = ((skb->len + 2) & 0x3f) ? skb->len + 2 : skb->len + 3;
 881        int res;
 882        __u16 l16 = skb->len;
 883
 884        netif_stop_queue(net);
 885
 886        ((__le16 *) pegasus->tx_buff)[0] = cpu_to_le16(l16);
 887        skb_copy_from_linear_data(skb, pegasus->tx_buff + 2, skb->len);
 888        usb_fill_bulk_urb(pegasus->tx_urb, pegasus->usb,
 889                          usb_sndbulkpipe(pegasus->usb, 2),
 890                          pegasus->tx_buff, count,
 891                          write_bulk_callback, pegasus);
 892        if ((res = usb_submit_urb(pegasus->tx_urb, GFP_ATOMIC))) {
 893                netif_warn(pegasus, tx_err, net, "fail tx, %d\n", res);
 894                switch (res) {
 895                case -EPIPE:            /* stall, or disconnect from TT */
 896                        /* cleanup should already have been scheduled */
 897                        break;
 898                case -ENODEV:           /* disconnect() upcoming */
 899                case -EPERM:
 900                        netif_device_detach(pegasus->net);
 901                        break;
 902                default:
 903                        pegasus->stats.tx_errors++;
 904                        netif_start_queue(net);
 905                }
 906        } else {
 907                pegasus->stats.tx_packets++;
 908                pegasus->stats.tx_bytes += skb->len;
 909        }
 910        dev_kfree_skb(skb);
 911
 912        return NETDEV_TX_OK;
 913}
 914
 915static struct net_device_stats *pegasus_netdev_stats(struct net_device *dev)
 916{
 917        return &((pegasus_t *) netdev_priv(dev))->stats;
 918}
 919
 920static inline void disable_net_traffic(pegasus_t *pegasus)
 921{
 922        __le16 tmp = cpu_to_le16(0);
 923
 924        set_registers(pegasus, EthCtrl0, sizeof(tmp), &tmp);
 925}
 926
 927static inline void get_interrupt_interval(pegasus_t *pegasus)
 928{
 929        u16 data;
 930        u8 interval;
 931
 932        read_eprom_word(pegasus, 4, &data);
 933        interval = data >> 8;
 934        if (pegasus->usb->speed != USB_SPEED_HIGH) {
 935                if (interval < 0x80) {
 936                        netif_info(pegasus, timer, pegasus->net,
 937                                   "intr interval changed from %ums to %ums\n",
 938                                   interval, 0x80);
 939                        interval = 0x80;
 940                        data = (data & 0x00FF) | ((u16)interval << 8);
 941#ifdef PEGASUS_WRITE_EEPROM
 942                        write_eprom_word(pegasus, 4, data);
 943#endif
 944                }
 945        }
 946        pegasus->intr_interval = interval;
 947}
 948
 949static void set_carrier(struct net_device *net)
 950{
 951        pegasus_t *pegasus = netdev_priv(net);
 952        u16 tmp;
 953
 954        if (read_mii_word(pegasus, pegasus->phy, MII_BMSR, &tmp))
 955                return;
 956
 957        if (tmp & BMSR_LSTATUS)
 958                netif_carrier_on(net);
 959        else
 960                netif_carrier_off(net);
 961}
 962
 963static void free_all_urbs(pegasus_t *pegasus)
 964{
 965        usb_free_urb(pegasus->intr_urb);
 966        usb_free_urb(pegasus->tx_urb);
 967        usb_free_urb(pegasus->rx_urb);
 968        usb_free_urb(pegasus->ctrl_urb);
 969}
 970
 971static void unlink_all_urbs(pegasus_t *pegasus)
 972{
 973        usb_kill_urb(pegasus->intr_urb);
 974        usb_kill_urb(pegasus->tx_urb);
 975        usb_kill_urb(pegasus->rx_urb);
 976        usb_kill_urb(pegasus->ctrl_urb);
 977}
 978
 979static int alloc_urbs(pegasus_t *pegasus)
 980{
 981        pegasus->ctrl_urb = usb_alloc_urb(0, GFP_KERNEL);
 982        if (!pegasus->ctrl_urb)
 983                return 0;
 984        pegasus->rx_urb = usb_alloc_urb(0, GFP_KERNEL);
 985        if (!pegasus->rx_urb) {
 986                usb_free_urb(pegasus->ctrl_urb);
 987                return 0;
 988        }
 989        pegasus->tx_urb = usb_alloc_urb(0, GFP_KERNEL);
 990        if (!pegasus->tx_urb) {
 991                usb_free_urb(pegasus->rx_urb);
 992                usb_free_urb(pegasus->ctrl_urb);
 993                return 0;
 994        }
 995        pegasus->intr_urb = usb_alloc_urb(0, GFP_KERNEL);
 996        if (!pegasus->intr_urb) {
 997                usb_free_urb(pegasus->tx_urb);
 998                usb_free_urb(pegasus->rx_urb);
 999                usb_free_urb(pegasus->ctrl_urb);
1000                return 0;
1001        }
1002
1003        return 1;
1004}
1005
1006static int pegasus_open(struct net_device *net)
1007{
1008        pegasus_t *pegasus = netdev_priv(net);
1009        int res;
1010
1011        if (pegasus->rx_skb == NULL)
1012                pegasus->rx_skb = pull_skb(pegasus);
1013        /*
1014         ** Note: no point to free the pool.  it is empty :-)
1015         */
1016        if (!pegasus->rx_skb)
1017                return -ENOMEM;
1018
1019        res = set_registers(pegasus, EthID, 6, net->dev_addr);
1020
1021        usb_fill_bulk_urb(pegasus->rx_urb, pegasus->usb,
1022                          usb_rcvbulkpipe(pegasus->usb, 1),
1023                          pegasus->rx_skb->data, PEGASUS_MTU + 8,
1024                          read_bulk_callback, pegasus);
1025        if ((res = usb_submit_urb(pegasus->rx_urb, GFP_KERNEL))) {
1026                if (res == -ENODEV)
1027                        netif_device_detach(pegasus->net);
1028                netif_dbg(pegasus, ifup, net, "failed rx_urb, %d\n", res);
1029                goto exit;
1030        }
1031
1032        usb_fill_int_urb(pegasus->intr_urb, pegasus->usb,
1033                         usb_rcvintpipe(pegasus->usb, 3),
1034                         pegasus->intr_buff, sizeof(pegasus->intr_buff),
1035                         intr_callback, pegasus, pegasus->intr_interval);
1036        if ((res = usb_submit_urb(pegasus->intr_urb, GFP_KERNEL))) {
1037                if (res == -ENODEV)
1038                        netif_device_detach(pegasus->net);
1039                netif_dbg(pegasus, ifup, net, "failed intr_urb, %d\n", res);
1040                usb_kill_urb(pegasus->rx_urb);
1041                goto exit;
1042        }
1043        if ((res = enable_net_traffic(net, pegasus->usb))) {
1044                netif_dbg(pegasus, ifup, net,
1045                          "can't enable_net_traffic() - %d\n", res);
1046                res = -EIO;
1047                usb_kill_urb(pegasus->rx_urb);
1048                usb_kill_urb(pegasus->intr_urb);
1049                free_skb_pool(pegasus);
1050                goto exit;
1051        }
1052        set_carrier(net);
1053        netif_start_queue(net);
1054        netif_dbg(pegasus, ifup, net, "open\n");
1055        res = 0;
1056exit:
1057        return res;
1058}
1059
1060static int pegasus_close(struct net_device *net)
1061{
1062        pegasus_t *pegasus = netdev_priv(net);
1063
1064        netif_stop_queue(net);
1065        if (!(pegasus->flags & PEGASUS_UNPLUG))
1066                disable_net_traffic(pegasus);
1067        tasklet_kill(&pegasus->rx_tl);
1068        unlink_all_urbs(pegasus);
1069
1070        return 0;
1071}
1072
1073static void pegasus_get_drvinfo(struct net_device *dev,
1074                                struct ethtool_drvinfo *info)
1075{
1076        pegasus_t *pegasus = netdev_priv(dev);
1077        strncpy(info->driver, driver_name, sizeof(info->driver) - 1);
1078        strncpy(info->version, DRIVER_VERSION, sizeof(info->version) - 1);
1079        usb_make_path(pegasus->usb, info->bus_info, sizeof(info->bus_info));
1080}
1081
1082/* also handles three patterns of some kind in hardware */
1083#define WOL_SUPPORTED   (WAKE_MAGIC|WAKE_PHY)
1084
1085static void
1086pegasus_get_wol(struct net_device *dev, struct ethtool_wolinfo *wol)
1087{
1088        pegasus_t       *pegasus = netdev_priv(dev);
1089
1090        wol->supported = WAKE_MAGIC | WAKE_PHY;
1091        wol->wolopts = pegasus->wolopts;
1092}
1093
1094static int
1095pegasus_set_wol(struct net_device *dev, struct ethtool_wolinfo *wol)
1096{
1097        pegasus_t       *pegasus = netdev_priv(dev);
1098        u8              reg78 = 0x04;
1099
1100        if (wol->wolopts & ~WOL_SUPPORTED)
1101                return -EINVAL;
1102
1103        if (wol->wolopts & WAKE_MAGIC)
1104                reg78 |= 0x80;
1105        if (wol->wolopts & WAKE_PHY)
1106                reg78 |= 0x40;
1107        /* FIXME this 0x10 bit still needs to get set in the chip... */
1108        if (wol->wolopts)
1109                pegasus->eth_regs[0] |= 0x10;
1110        else
1111                pegasus->eth_regs[0] &= ~0x10;
1112        pegasus->wolopts = wol->wolopts;
1113        return set_register(pegasus, WakeupControl, reg78);
1114}
1115
1116static inline void pegasus_reset_wol(struct net_device *dev)
1117{
1118        struct ethtool_wolinfo wol;
1119
1120        memset(&wol, 0, sizeof wol);
1121        (void) pegasus_set_wol(dev, &wol);
1122}
1123
1124static int
1125pegasus_get_settings(struct net_device *dev, struct ethtool_cmd *ecmd)
1126{
1127        pegasus_t *pegasus;
1128
1129        pegasus = netdev_priv(dev);
1130        mii_ethtool_gset(&pegasus->mii, ecmd);
1131        return 0;
1132}
1133
1134static int
1135pegasus_set_settings(struct net_device *dev, struct ethtool_cmd *ecmd)
1136{
1137        pegasus_t *pegasus = netdev_priv(dev);
1138        return mii_ethtool_sset(&pegasus->mii, ecmd);
1139}
1140
1141static int pegasus_nway_reset(struct net_device *dev)
1142{
1143        pegasus_t *pegasus = netdev_priv(dev);
1144        return mii_nway_restart(&pegasus->mii);
1145}
1146
1147static u32 pegasus_get_link(struct net_device *dev)
1148{
1149        pegasus_t *pegasus = netdev_priv(dev);
1150        return mii_link_ok(&pegasus->mii);
1151}
1152
1153static u32 pegasus_get_msglevel(struct net_device *dev)
1154{
1155        pegasus_t *pegasus = netdev_priv(dev);
1156        return pegasus->msg_enable;
1157}
1158
1159static void pegasus_set_msglevel(struct net_device *dev, u32 v)
1160{
1161        pegasus_t *pegasus = netdev_priv(dev);
1162        pegasus->msg_enable = v;
1163}
1164
1165static const struct ethtool_ops ops = {
1166        .get_drvinfo = pegasus_get_drvinfo,
1167        .get_settings = pegasus_get_settings,
1168        .set_settings = pegasus_set_settings,
1169        .nway_reset = pegasus_nway_reset,
1170        .get_link = pegasus_get_link,
1171        .get_msglevel = pegasus_get_msglevel,
1172        .set_msglevel = pegasus_set_msglevel,
1173        .get_wol = pegasus_get_wol,
1174        .set_wol = pegasus_set_wol,
1175};
1176
1177static int pegasus_ioctl(struct net_device *net, struct ifreq *rq, int cmd)
1178{
1179        __u16 *data = (__u16 *) &rq->ifr_ifru;
1180        pegasus_t *pegasus = netdev_priv(net);
1181        int res;
1182
1183        switch (cmd) {
1184        case SIOCDEVPRIVATE:
1185                data[0] = pegasus->phy;
1186        case SIOCDEVPRIVATE + 1:
1187                read_mii_word(pegasus, data[0], data[1] & 0x1f, &data[3]);
1188                res = 0;
1189                break;
1190        case SIOCDEVPRIVATE + 2:
1191                if (!capable(CAP_NET_ADMIN))
1192                        return -EPERM;
1193                write_mii_word(pegasus, pegasus->phy, data[1] & 0x1f, data[2]);
1194                res = 0;
1195                break;
1196        default:
1197                res = -EOPNOTSUPP;
1198        }
1199        return res;
1200}
1201
1202static void pegasus_set_multicast(struct net_device *net)
1203{
1204        pegasus_t *pegasus = netdev_priv(net);
1205
1206        if (net->flags & IFF_PROMISC) {
1207                pegasus->eth_regs[EthCtrl2] |= RX_PROMISCUOUS;
1208                netif_info(pegasus, link, net, "Promiscuous mode enabled\n");
1209        } else if (!netdev_mc_empty(net) || (net->flags & IFF_ALLMULTI)) {
1210                pegasus->eth_regs[EthCtrl0] |= RX_MULTICAST;
1211                pegasus->eth_regs[EthCtrl2] &= ~RX_PROMISCUOUS;
1212                netif_dbg(pegasus, link, net, "set allmulti\n");
1213        } else {
1214                pegasus->eth_regs[EthCtrl0] &= ~RX_MULTICAST;
1215                pegasus->eth_regs[EthCtrl2] &= ~RX_PROMISCUOUS;
1216        }
1217
1218        pegasus->ctrl_urb->status = 0;
1219
1220        pegasus->flags |= ETH_REGS_CHANGE;
1221        ctrl_callback(pegasus->ctrl_urb);
1222}
1223
1224static __u8 mii_phy_probe(pegasus_t *pegasus)
1225{
1226        int i;
1227        __u16 tmp;
1228
1229        for (i = 0; i < 32; i++) {
1230                read_mii_word(pegasus, i, MII_BMSR, &tmp);
1231                if (tmp == 0 || tmp == 0xffff || (tmp & BMSR_MEDIA) == 0)
1232                        continue;
1233                else
1234                        return i;
1235        }
1236
1237        return 0xff;
1238}
1239
1240static inline void setup_pegasus_II(pegasus_t *pegasus)
1241{
1242        __u8 data = 0xa5;
1243
1244        set_register(pegasus, Reg1d, 0);
1245        set_register(pegasus, Reg7b, 1);
1246        mdelay(100);
1247        if ((pegasus->features & HAS_HOME_PNA) && mii_mode)
1248                set_register(pegasus, Reg7b, 0);
1249        else
1250                set_register(pegasus, Reg7b, 2);
1251
1252        set_register(pegasus, 0x83, data);
1253        get_registers(pegasus, 0x83, 1, &data);
1254
1255        if (data == 0xa5)
1256                pegasus->chip = 0x8513;
1257        else
1258                pegasus->chip = 0;
1259
1260        set_register(pegasus, 0x80, 0xc0);
1261        set_register(pegasus, 0x83, 0xff);
1262        set_register(pegasus, 0x84, 0x01);
1263
1264        if (pegasus->features & HAS_HOME_PNA && mii_mode)
1265                set_register(pegasus, Reg81, 6);
1266        else
1267                set_register(pegasus, Reg81, 2);
1268}
1269
1270
1271static int pegasus_count;
1272static struct workqueue_struct *pegasus_workqueue;
1273#define CARRIER_CHECK_DELAY (2 * HZ)
1274
1275static void check_carrier(struct work_struct *work)
1276{
1277        pegasus_t *pegasus = container_of(work, pegasus_t, carrier_check.work);
1278        set_carrier(pegasus->net);
1279        if (!(pegasus->flags & PEGASUS_UNPLUG)) {
1280                queue_delayed_work(pegasus_workqueue, &pegasus->carrier_check,
1281                        CARRIER_CHECK_DELAY);
1282        }
1283}
1284
1285static int pegasus_blacklisted(struct usb_device *udev)
1286{
1287        struct usb_device_descriptor *udd = &udev->descriptor;
1288
1289        /* Special quirk to keep the driver from handling the Belkin Bluetooth
1290         * dongle which happens to have the same ID.
1291         */
1292        if ((udd->idVendor == cpu_to_le16(VENDOR_BELKIN)) &&
1293            (udd->idProduct == cpu_to_le16(0x0121)) &&
1294            (udd->bDeviceClass == USB_CLASS_WIRELESS_CONTROLLER) &&
1295            (udd->bDeviceProtocol == 1))
1296                return 1;
1297
1298        return 0;
1299}
1300
1301/* we rely on probe() and remove() being serialized so we
1302 * don't need extra locking on pegasus_count.
1303 */
1304static void pegasus_dec_workqueue(void)
1305{
1306        pegasus_count--;
1307        if (pegasus_count == 0) {
1308                destroy_workqueue(pegasus_workqueue);
1309                pegasus_workqueue = NULL;
1310        }
1311}
1312
1313static int pegasus_probe(struct usb_interface *intf,
1314                         const struct usb_device_id *id)
1315{
1316        struct usb_device *dev = interface_to_usbdev(intf);
1317        struct net_device *net;
1318        pegasus_t *pegasus;
1319        int dev_index = id - pegasus_ids;
1320        int res = -ENOMEM;
1321
1322        if (pegasus_blacklisted(dev))
1323                return -ENODEV;
1324
1325        if (pegasus_count == 0) {
1326                pegasus_workqueue = create_singlethread_workqueue("pegasus");
1327                if (!pegasus_workqueue)
1328                        return -ENOMEM;
1329        }
1330        pegasus_count++;
1331
1332        usb_get_dev(dev);
1333
1334        net = alloc_etherdev(sizeof(struct pegasus));
1335        if (!net) {
1336                dev_err(&intf->dev, "can't allocate %s\n", "device");
1337                goto out;
1338        }
1339
1340        pegasus = netdev_priv(net);
1341        pegasus->dev_index = dev_index;
1342        init_waitqueue_head(&pegasus->ctrl_wait);
1343
1344        if (!alloc_urbs(pegasus)) {
1345                dev_err(&intf->dev, "can't allocate %s\n", "urbs");
1346                goto out1;
1347        }
1348
1349        tasklet_init(&pegasus->rx_tl, rx_fixup, (unsigned long) pegasus);
1350
1351        INIT_DELAYED_WORK(&pegasus->carrier_check, check_carrier);
1352
1353        pegasus->intf = intf;
1354        pegasus->usb = dev;
1355        pegasus->net = net;
1356
1357
1358        net->watchdog_timeo = PEGASUS_TX_TIMEOUT;
1359        net->netdev_ops = &pegasus_netdev_ops;
1360        SET_ETHTOOL_OPS(net, &ops);
1361        pegasus->mii.dev = net;
1362        pegasus->mii.mdio_read = mdio_read;
1363        pegasus->mii.mdio_write = mdio_write;
1364        pegasus->mii.phy_id_mask = 0x1f;
1365        pegasus->mii.reg_num_mask = 0x1f;
1366        spin_lock_init(&pegasus->rx_pool_lock);
1367        pegasus->msg_enable = netif_msg_init(msg_level, NETIF_MSG_DRV
1368                                | NETIF_MSG_PROBE | NETIF_MSG_LINK);
1369
1370        pegasus->features = usb_dev_id[dev_index].private;
1371        get_interrupt_interval(pegasus);
1372        if (reset_mac(pegasus)) {
1373                dev_err(&intf->dev, "can't reset MAC\n");
1374                res = -EIO;
1375                goto out2;
1376        }
1377        set_ethernet_addr(pegasus);
1378        fill_skb_pool(pegasus);
1379        if (pegasus->features & PEGASUS_II) {
1380                dev_info(&intf->dev, "setup Pegasus II specific registers\n");
1381                setup_pegasus_II(pegasus);
1382        }
1383        pegasus->phy = mii_phy_probe(pegasus);
1384        if (pegasus->phy == 0xff) {
1385                dev_warn(&intf->dev, "can't locate MII phy, using default\n");
1386                pegasus->phy = 1;
1387        }
1388        pegasus->mii.phy_id = pegasus->phy;
1389        usb_set_intfdata(intf, pegasus);
1390        SET_NETDEV_DEV(net, &intf->dev);
1391        pegasus_reset_wol(net);
1392        res = register_netdev(net);
1393        if (res)
1394                goto out3;
1395        queue_delayed_work(pegasus_workqueue, &pegasus->carrier_check,
1396                                CARRIER_CHECK_DELAY);
1397
1398        dev_info(&intf->dev, "%s, %s, %pM\n",
1399                 net->name,
1400                 usb_dev_id[dev_index].name,
1401                 net->dev_addr);
1402        return 0;
1403
1404out3:
1405        usb_set_intfdata(intf, NULL);
1406        free_skb_pool(pegasus);
1407out2:
1408        free_all_urbs(pegasus);
1409out1:
1410        free_netdev(net);
1411out:
1412        usb_put_dev(dev);
1413        pegasus_dec_workqueue();
1414        return res;
1415}
1416
1417static void pegasus_disconnect(struct usb_interface *intf)
1418{
1419        struct pegasus *pegasus = usb_get_intfdata(intf);
1420
1421        usb_set_intfdata(intf, NULL);
1422        if (!pegasus) {
1423                dev_dbg(&intf->dev, "unregistering non-bound device?\n");
1424                return;
1425        }
1426
1427        pegasus->flags |= PEGASUS_UNPLUG;
1428        cancel_delayed_work(&pegasus->carrier_check);
1429        unregister_netdev(pegasus->net);
1430        usb_put_dev(interface_to_usbdev(intf));
1431        unlink_all_urbs(pegasus);
1432        free_all_urbs(pegasus);
1433        free_skb_pool(pegasus);
1434        if (pegasus->rx_skb != NULL) {
1435                dev_kfree_skb(pegasus->rx_skb);
1436                pegasus->rx_skb = NULL;
1437        }
1438        free_netdev(pegasus->net);
1439        pegasus_dec_workqueue();
1440}
1441
1442static int pegasus_suspend(struct usb_interface *intf, pm_message_t message)
1443{
1444        struct pegasus *pegasus = usb_get_intfdata(intf);
1445
1446        netif_device_detach(pegasus->net);
1447        cancel_delayed_work(&pegasus->carrier_check);
1448        if (netif_running(pegasus->net)) {
1449                usb_kill_urb(pegasus->rx_urb);
1450                usb_kill_urb(pegasus->intr_urb);
1451        }
1452        return 0;
1453}
1454
1455static int pegasus_resume(struct usb_interface *intf)
1456{
1457        struct pegasus *pegasus = usb_get_intfdata(intf);
1458
1459        netif_device_attach(pegasus->net);
1460        if (netif_running(pegasus->net)) {
1461                pegasus->rx_urb->status = 0;
1462                pegasus->rx_urb->actual_length = 0;
1463                read_bulk_callback(pegasus->rx_urb);
1464
1465                pegasus->intr_urb->status = 0;
1466                pegasus->intr_urb->actual_length = 0;
1467                intr_callback(pegasus->intr_urb);
1468        }
1469        queue_delayed_work(pegasus_workqueue, &pegasus->carrier_check,
1470                                CARRIER_CHECK_DELAY);
1471        return 0;
1472}
1473
1474static const struct net_device_ops pegasus_netdev_ops = {
1475        .ndo_open =                     pegasus_open,
1476        .ndo_stop =                     pegasus_close,
1477        .ndo_do_ioctl =                 pegasus_ioctl,
1478        .ndo_start_xmit =               pegasus_start_xmit,
1479        .ndo_set_multicast_list =       pegasus_set_multicast,
1480        .ndo_get_stats =                pegasus_netdev_stats,
1481        .ndo_tx_timeout =               pegasus_tx_timeout,
1482        .ndo_change_mtu =               eth_change_mtu,
1483        .ndo_set_mac_address =          eth_mac_addr,
1484        .ndo_validate_addr =            eth_validate_addr,
1485};
1486
1487static struct usb_driver pegasus_driver = {
1488        .name = driver_name,
1489        .probe = pegasus_probe,
1490        .disconnect = pegasus_disconnect,
1491        .id_table = pegasus_ids,
1492        .suspend = pegasus_suspend,
1493        .resume = pegasus_resume,
1494};
1495
1496static void __init parse_id(char *id)
1497{
1498        unsigned int vendor_id = 0, device_id = 0, flags = 0, i = 0;
1499        char *token, *name = NULL;
1500
1501        if ((token = strsep(&id, ":")) != NULL)
1502                name = token;
1503        /* name now points to a null terminated string*/
1504        if ((token = strsep(&id, ":")) != NULL)
1505                vendor_id = simple_strtoul(token, NULL, 16);
1506        if ((token = strsep(&id, ":")) != NULL)
1507                device_id = simple_strtoul(token, NULL, 16);
1508        flags = simple_strtoul(id, NULL, 16);
1509        pr_info("%s: new device %s, vendor ID 0x%04x, device ID 0x%04x, flags: 0x%x\n",
1510                driver_name, name, vendor_id, device_id, flags);
1511
1512        if (vendor_id > 0x10000 || vendor_id == 0)
1513                return;
1514        if (device_id > 0x10000 || device_id == 0)
1515                return;
1516
1517        for (i = 0; usb_dev_id[i].name; i++);
1518        usb_dev_id[i].name = name;
1519        usb_dev_id[i].vendor = vendor_id;
1520        usb_dev_id[i].device = device_id;
1521        usb_dev_id[i].private = flags;
1522        pegasus_ids[i].match_flags = USB_DEVICE_ID_MATCH_DEVICE;
1523        pegasus_ids[i].idVendor = vendor_id;
1524        pegasus_ids[i].idProduct = device_id;
1525}
1526
1527static int __init pegasus_init(void)
1528{
1529        pr_info("%s: %s, " DRIVER_DESC "\n", driver_name, DRIVER_VERSION);
1530        if (devid)
1531                parse_id(devid);
1532        return usb_register(&pegasus_driver);
1533}
1534
1535static void __exit pegasus_exit(void)
1536{
1537        usb_deregister(&pegasus_driver);
1538}
1539
1540module_init(pegasus_init);
1541module_exit(pegasus_exit);
1542