2 * Copyright (c) 1999-2013 Petko Manolov (petkan@nucleusys.com)
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.
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
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.
30 * v0.9.3 simplified [get|set]_register(s), async update registers
31 * logic revisited, receive skb_pool removed.
34 #include <linux/sched.h>
35 #include <linux/slab.h>
36 #include <linux/init.h>
37 #include <linux/delay.h>
38 #include <linux/netdevice.h>
39 #include <linux/etherdevice.h>
40 #include <linux/ethtool.h>
41 #include <linux/mii.h>
42 #include <linux/usb.h>
43 #include <linux/module.h>
44 #include <asm/byteorder.h>
45 #include <asm/uaccess.h>
51 #define DRIVER_VERSION "v0.9.3 (2013/04/25)"
52 #define DRIVER_AUTHOR "Petko Manolov <petkan@nucleusys.com>"
53 #define DRIVER_DESC "Pegasus/Pegasus II USB Ethernet driver"
55 static const char driver_name
[] = "pegasus";
57 #undef PEGASUS_WRITE_EEPROM
58 #define BMSR_MEDIA (BMSR_10HALF | BMSR_10FULL | BMSR_100HALF | \
59 BMSR_100FULL | BMSR_ANEGCAPABLE)
65 static struct usb_eth_dev usb_dev_id
[] = {
66 #define PEGASUS_DEV(pn, vid, pid, flags) \
67 {.name = pn, .vendor = vid, .device = pid, .private = flags},
68 #define PEGASUS_DEV_CLASS(pn, vid, pid, dclass, flags) \
69 PEGASUS_DEV(pn, vid, pid, flags)
72 #undef PEGASUS_DEV_CLASS
77 static struct usb_device_id pegasus_ids
[] = {
78 #define PEGASUS_DEV(pn, vid, pid, flags) \
79 {.match_flags = USB_DEVICE_ID_MATCH_DEVICE, .idVendor = vid, .idProduct = pid},
81 * The Belkin F8T012xx1 bluetooth adaptor has the same vendor and product
82 * IDs as the Belkin F5D5050, so we need to teach the pegasus driver to
83 * ignore adaptors belonging to the "Wireless" class 0xE0. For this one
84 * case anyway, seeing as the pegasus is for "Wired" adaptors.
86 #define PEGASUS_DEV_CLASS(pn, vid, pid, dclass, flags) \
87 {.match_flags = (USB_DEVICE_ID_MATCH_DEVICE | USB_DEVICE_ID_MATCH_DEV_CLASS), \
88 .idVendor = vid, .idProduct = pid, .bDeviceClass = dclass},
91 #undef PEGASUS_DEV_CLASS
96 MODULE_AUTHOR(DRIVER_AUTHOR
);
97 MODULE_DESCRIPTION(DRIVER_DESC
);
98 MODULE_LICENSE("GPL");
99 module_param(loopback
, bool, 0);
100 module_param(mii_mode
, bool, 0);
101 module_param(devid
, charp
, 0);
102 MODULE_PARM_DESC(loopback
, "Enable MAC loopback mode (bit 0)");
103 MODULE_PARM_DESC(mii_mode
, "Enable HomePNA mode (bit 0),default=MII mode = 0");
104 MODULE_PARM_DESC(devid
, "The format is: 'DEV_name:VendorID:DeviceID:Flags'");
106 /* use ethtool to change the level for any given device */
107 static int msg_level
= -1;
108 module_param(msg_level
, int, 0);
109 MODULE_PARM_DESC(msg_level
, "Override default message level");
111 MODULE_DEVICE_TABLE(usb
, pegasus_ids
);
112 static const struct net_device_ops pegasus_netdev_ops
;
116 static void async_ctrl_callback(struct urb
*urb
)
118 struct usb_ctrlrequest
*req
= (struct usb_ctrlrequest
*)urb
->context
;
119 int status
= urb
->status
;
122 dev_dbg(&urb
->dev
->dev
, "%s failed with %d", __func__
, status
);
127 static int get_registers(pegasus_t
*pegasus
, __u16 indx
, __u16 size
, void *data
)
132 buf
= kmalloc(size
, GFP_NOIO
);
136 ret
= usb_control_msg(pegasus
->usb
, usb_rcvctrlpipe(pegasus
->usb
, 0),
137 PEGASUS_REQ_GET_REGS
, PEGASUS_REQT_READ
, 0,
138 indx
, buf
, size
, 1000);
140 netif_dbg(pegasus
, drv
, pegasus
->net
,
141 "%s returned %d\n", __func__
, ret
);
142 else if (ret
<= size
)
143 memcpy(data
, buf
, ret
);
148 static int set_registers(pegasus_t
*pegasus
, __u16 indx
, __u16 size
,
154 buf
= kmemdup(data
, size
, GFP_NOIO
);
158 ret
= usb_control_msg(pegasus
->usb
, usb_sndctrlpipe(pegasus
->usb
, 0),
159 PEGASUS_REQ_SET_REGS
, PEGASUS_REQT_WRITE
, 0,
160 indx
, buf
, size
, 100);
162 netif_dbg(pegasus
, drv
, pegasus
->net
,
163 "%s returned %d\n", __func__
, ret
);
168 static int set_register(pegasus_t
*pegasus
, __u16 indx
, __u8 data
)
173 buf
= kmemdup(&data
, 1, GFP_NOIO
);
177 ret
= usb_control_msg(pegasus
->usb
, usb_sndctrlpipe(pegasus
->usb
, 0),
178 PEGASUS_REQ_SET_REG
, PEGASUS_REQT_WRITE
, data
,
181 netif_dbg(pegasus
, drv
, pegasus
->net
,
182 "%s returned %d\n", __func__
, ret
);
187 static int update_eth_regs_async(pegasus_t
*pegasus
)
190 struct urb
*async_urb
;
191 struct usb_ctrlrequest
*req
;
193 req
= kmalloc(sizeof(struct usb_ctrlrequest
), GFP_ATOMIC
);
197 async_urb
= usb_alloc_urb(0, GFP_ATOMIC
);
198 if (async_urb
== NULL
) {
202 req
->bRequestType
= PEGASUS_REQT_WRITE
;
203 req
->bRequest
= PEGASUS_REQ_SET_REGS
;
204 req
->wValue
= cpu_to_le16(0);
205 req
->wIndex
= cpu_to_le16(EthCtrl0
);
206 req
->wLength
= cpu_to_le16(3);
208 usb_fill_control_urb(async_urb
, pegasus
->usb
,
209 usb_sndctrlpipe(pegasus
->usb
, 0), (void *)req
,
210 pegasus
->eth_regs
, 3, async_ctrl_callback
, req
);
212 ret
= usb_submit_urb(async_urb
, GFP_ATOMIC
);
215 netif_device_detach(pegasus
->net
);
216 netif_err(pegasus
, drv
, pegasus
->net
,
217 "%s returned %d\n", __func__
, ret
);
222 static int __mii_op(pegasus_t
*p
, __u8 phy
, __u8 indx
, __u16
*regd
, __u8 cmd
)
225 __u8 data
[4] = { phy
, 0, 0, indx
};
227 int ret
= -ETIMEDOUT
;
229 if (cmd
& PHY_WRITE
) {
230 __le16
*t
= (__le16
*) & data
[1];
231 *t
= cpu_to_le16(*regd
);
233 set_register(p
, PhyCtrl
, 0);
234 set_registers(p
, PhyAddr
, sizeof(data
), data
);
235 set_register(p
, PhyCtrl
, (indx
| cmd
));
236 for (i
= 0; i
< REG_TIMEOUT
; i
++) {
237 ret
= get_registers(p
, PhyCtrl
, 1, data
);
240 if (data
[0] & PHY_DONE
)
243 if (i
>= REG_TIMEOUT
)
245 if (cmd
& PHY_READ
) {
246 ret
= get_registers(p
, PhyData
, 2, ®di
);
247 *regd
= le16_to_cpu(regdi
);
252 netif_dbg(p
, drv
, p
->net
, "%s failed\n", __func__
);
256 /* Returns non-negative int on success, error on failure */
257 static int read_mii_word(pegasus_t
*pegasus
, __u8 phy
, __u8 indx
, __u16
*regd
)
259 return __mii_op(pegasus
, phy
, indx
, regd
, PHY_READ
);
262 /* Returns zero on success, error on failure */
263 static int write_mii_word(pegasus_t
*pegasus
, __u8 phy
, __u8 indx
, __u16
*regd
)
265 return __mii_op(pegasus
, phy
, indx
, regd
, PHY_WRITE
);
268 static int mdio_read(struct net_device
*dev
, int phy_id
, int loc
)
270 pegasus_t
*pegasus
= netdev_priv(dev
);
273 read_mii_word(pegasus
, phy_id
, loc
, &res
);
277 static void mdio_write(struct net_device
*dev
, int phy_id
, int loc
, int val
)
279 pegasus_t
*pegasus
= netdev_priv(dev
);
282 write_mii_word(pegasus
, phy_id
, loc
, &data
);
285 static int read_eprom_word(pegasus_t
*pegasus
, __u8 index
, __u16
*retdata
)
292 set_register(pegasus
, EpromCtrl
, 0);
293 set_register(pegasus
, EpromOffset
, index
);
294 set_register(pegasus
, EpromCtrl
, EPROM_READ
);
296 for (i
= 0; i
< REG_TIMEOUT
; i
++) {
297 ret
= get_registers(pegasus
, EpromCtrl
, 1, &tmp
);
298 if (tmp
& EPROM_DONE
)
300 if (ret
== -ESHUTDOWN
)
303 if (i
>= REG_TIMEOUT
)
306 ret
= get_registers(pegasus
, EpromData
, 2, &retdatai
);
307 *retdata
= le16_to_cpu(retdatai
);
311 netif_warn(pegasus
, drv
, pegasus
->net
, "%s failed\n", __func__
);
315 #ifdef PEGASUS_WRITE_EEPROM
316 static inline void enable_eprom_write(pegasus_t
*pegasus
)
320 get_registers(pegasus
, EthCtrl2
, 1, &tmp
);
321 set_register(pegasus
, EthCtrl2
, tmp
| EPROM_WR_ENABLE
);
324 static inline void disable_eprom_write(pegasus_t
*pegasus
)
328 get_registers(pegasus
, EthCtrl2
, 1, &tmp
);
329 set_register(pegasus
, EpromCtrl
, 0);
330 set_register(pegasus
, EthCtrl2
, tmp
& ~EPROM_WR_ENABLE
);
333 static int write_eprom_word(pegasus_t
*pegasus
, __u8 index
, __u16 data
)
336 __u8 tmp
, d
[4] = { 0x3f, 0, 0, EPROM_WRITE
};
338 __le16 le_data
= cpu_to_le16(data
);
340 set_registers(pegasus
, EpromOffset
, 4, d
);
341 enable_eprom_write(pegasus
);
342 set_register(pegasus
, EpromOffset
, index
);
343 set_registers(pegasus
, EpromData
, 2, &le_data
);
344 set_register(pegasus
, EpromCtrl
, EPROM_WRITE
);
346 for (i
= 0; i
< REG_TIMEOUT
; i
++) {
347 ret
= get_registers(pegasus
, EpromCtrl
, 1, &tmp
);
348 if (ret
== -ESHUTDOWN
)
350 if (tmp
& EPROM_DONE
)
353 disable_eprom_write(pegasus
);
354 if (i
>= REG_TIMEOUT
)
360 netif_warn(pegasus
, drv
, pegasus
->net
, "%s failed\n", __func__
);
363 #endif /* PEGASUS_WRITE_EEPROM */
365 static inline void get_node_id(pegasus_t
*pegasus
, __u8
*id
)
370 for (i
= 0; i
< 3; i
++) {
371 read_eprom_word(pegasus
, i
, &w16
);
372 ((__le16
*) id
)[i
] = cpu_to_le16(w16
);
376 static void set_ethernet_addr(pegasus_t
*pegasus
)
380 if (pegasus
->features
& PEGASUS_II
) {
381 get_registers(pegasus
, 0x10, sizeof(node_id
), node_id
);
383 get_node_id(pegasus
, node_id
);
384 set_registers(pegasus
, EthID
, sizeof(node_id
), node_id
);
386 memcpy(pegasus
->net
->dev_addr
, node_id
, sizeof(node_id
));
389 static inline int reset_mac(pegasus_t
*pegasus
)
394 set_register(pegasus
, EthCtrl1
, data
);
395 for (i
= 0; i
< REG_TIMEOUT
; i
++) {
396 get_registers(pegasus
, EthCtrl1
, 1, &data
);
400 if (mii_mode
&& (pegasus
->features
& HAS_HOME_PNA
))
401 set_register(pegasus
, Gpio1
, 0x34);
403 set_register(pegasus
, Gpio1
, 0x26);
404 set_register(pegasus
, Gpio0
, pegasus
->features
);
405 set_register(pegasus
, Gpio0
, DEFAULT_GPIO_SET
);
409 if (i
== REG_TIMEOUT
)
412 if (usb_dev_id
[pegasus
->dev_index
].vendor
== VENDOR_LINKSYS
||
413 usb_dev_id
[pegasus
->dev_index
].vendor
== VENDOR_DLINK
) {
414 set_register(pegasus
, Gpio0
, 0x24);
415 set_register(pegasus
, Gpio0
, 0x26);
417 if (usb_dev_id
[pegasus
->dev_index
].vendor
== VENDOR_ELCON
) {
419 read_mii_word(pegasus
, 3, 0x1b, &auxmode
);
421 write_mii_word(pegasus
, 3, 0x1b, &auxmode
);
427 static int enable_net_traffic(struct net_device
*dev
, struct usb_device
*usb
)
431 pegasus_t
*pegasus
= netdev_priv(dev
);
434 read_mii_word(pegasus
, pegasus
->phy
, MII_LPA
, &linkpart
);
437 if (linkpart
& (ADVERTISE_100FULL
| ADVERTISE_10FULL
))
438 data
[1] |= 0x20; /* set full duplex */
439 if (linkpart
& (ADVERTISE_100FULL
| ADVERTISE_100HALF
))
440 data
[1] |= 0x10; /* set 100 Mbps */
443 data
[2] = loopback
? 0x09 : 0x01;
445 memcpy(pegasus
->eth_regs
, data
, sizeof(data
));
446 ret
= set_registers(pegasus
, EthCtrl0
, 3, data
);
448 if (usb_dev_id
[pegasus
->dev_index
].vendor
== VENDOR_LINKSYS
||
449 usb_dev_id
[pegasus
->dev_index
].vendor
== VENDOR_LINKSYS2
||
450 usb_dev_id
[pegasus
->dev_index
].vendor
== VENDOR_DLINK
) {
452 read_mii_word(pegasus
, 0, 0x1b, &auxmode
);
454 write_mii_word(pegasus
, 0, 0x1b, &auxmode
);
460 static void read_bulk_callback(struct urb
*urb
)
462 pegasus_t
*pegasus
= urb
->context
;
463 struct net_device
*net
;
464 int rx_status
, count
= urb
->actual_length
;
465 int status
= urb
->status
;
466 u8
*buf
= urb
->transfer_buffer
;
473 if (!netif_device_present(net
) || !netif_running(net
))
480 netif_dbg(pegasus
, rx_err
, net
, "reset MAC\n");
481 pegasus
->flags
&= ~PEGASUS_RX_BUSY
;
483 case -EPIPE
: /* stall, or disconnect from TT */
484 /* FIXME schedule work to clear the halt */
485 netif_warn(pegasus
, rx_err
, net
, "no rx stall recovery\n");
490 netif_dbg(pegasus
, ifdown
, net
, "rx unlink, %d\n", status
);
493 netif_dbg(pegasus
, rx_err
, net
, "RX status %d\n", status
);
497 if (!count
|| count
< 4)
500 rx_status
= buf
[count
- 2];
501 if (rx_status
& 0x1e) {
502 netif_dbg(pegasus
, rx_err
, net
,
503 "RX packet error %x\n", rx_status
);
504 pegasus
->stats
.rx_errors
++;
505 if (rx_status
& 0x06) /* long or runt */
506 pegasus
->stats
.rx_length_errors
++;
507 if (rx_status
& 0x08)
508 pegasus
->stats
.rx_crc_errors
++;
509 if (rx_status
& 0x10) /* extra bits */
510 pegasus
->stats
.rx_frame_errors
++;
513 if (pegasus
->chip
== 0x8513) {
514 pkt_len
= le32_to_cpu(*(__le32
*)urb
->transfer_buffer
);
516 pegasus
->rx_skb
->data
+= 2;
518 pkt_len
= buf
[count
- 3] << 8;
519 pkt_len
+= buf
[count
- 4];
525 * If the packet is unreasonably long, quietly drop it rather than
526 * kernel panicing by calling skb_put.
528 if (pkt_len
> PEGASUS_MTU
)
532 * at this point we are sure pegasus->rx_skb != NULL
533 * so we go ahead and pass up the packet.
535 skb_put(pegasus
->rx_skb
, pkt_len
);
536 pegasus
->rx_skb
->protocol
= eth_type_trans(pegasus
->rx_skb
, net
);
537 netif_rx(pegasus
->rx_skb
);
538 pegasus
->stats
.rx_packets
++;
539 pegasus
->stats
.rx_bytes
+= pkt_len
;
541 if (pegasus
->flags
& PEGASUS_UNPLUG
)
544 pegasus
->rx_skb
= __netdev_alloc_skb_ip_align(pegasus
->net
, PEGASUS_MTU
,
547 if (pegasus
->rx_skb
== NULL
)
550 usb_fill_bulk_urb(pegasus
->rx_urb
, pegasus
->usb
,
551 usb_rcvbulkpipe(pegasus
->usb
, 1),
552 pegasus
->rx_skb
->data
, PEGASUS_MTU
+ 8,
553 read_bulk_callback
, pegasus
);
554 rx_status
= usb_submit_urb(pegasus
->rx_urb
, GFP_ATOMIC
);
555 if (rx_status
== -ENODEV
)
556 netif_device_detach(pegasus
->net
);
557 else if (rx_status
) {
558 pegasus
->flags
|= PEGASUS_RX_URB_FAIL
;
561 pegasus
->flags
&= ~PEGASUS_RX_URB_FAIL
;
567 tasklet_schedule(&pegasus
->rx_tl
);
570 static void rx_fixup(unsigned long data
)
575 pegasus
= (pegasus_t
*) data
;
576 if (pegasus
->flags
& PEGASUS_UNPLUG
)
579 if (pegasus
->flags
& PEGASUS_RX_URB_FAIL
)
582 if (pegasus
->rx_skb
== NULL
)
583 pegasus
->rx_skb
= __netdev_alloc_skb_ip_align(pegasus
->net
,
586 if (pegasus
->rx_skb
== NULL
) {
587 netif_warn(pegasus
, rx_err
, pegasus
->net
, "low on memory\n");
588 tasklet_schedule(&pegasus
->rx_tl
);
591 usb_fill_bulk_urb(pegasus
->rx_urb
, pegasus
->usb
,
592 usb_rcvbulkpipe(pegasus
->usb
, 1),
593 pegasus
->rx_skb
->data
, PEGASUS_MTU
+ 8,
594 read_bulk_callback
, pegasus
);
596 status
= usb_submit_urb(pegasus
->rx_urb
, GFP_ATOMIC
);
597 if (status
== -ENODEV
)
598 netif_device_detach(pegasus
->net
);
600 pegasus
->flags
|= PEGASUS_RX_URB_FAIL
;
601 tasklet_schedule(&pegasus
->rx_tl
);
603 pegasus
->flags
&= ~PEGASUS_RX_URB_FAIL
;
607 static void write_bulk_callback(struct urb
*urb
)
609 pegasus_t
*pegasus
= urb
->context
;
610 struct net_device
*net
;
611 int status
= urb
->status
;
618 if (!netif_device_present(net
) || !netif_running(net
))
623 /* FIXME schedule_work() to clear the tx halt */
624 netif_stop_queue(net
);
625 netif_warn(pegasus
, tx_err
, net
, "no tx stall recovery\n");
630 netif_dbg(pegasus
, ifdown
, net
, "tx unlink, %d\n", status
);
633 netif_info(pegasus
, tx_err
, net
, "TX status %d\n", status
);
639 net
->trans_start
= jiffies
; /* prevent tx timeout */
640 netif_wake_queue(net
);
643 static void intr_callback(struct urb
*urb
)
645 pegasus_t
*pegasus
= urb
->context
;
646 struct net_device
*net
;
647 int res
, status
= urb
->status
;
656 case -ECONNRESET
: /* unlink */
661 /* some Pegasus-I products report LOTS of data
662 * toggle errors... avoid log spamming
664 netif_dbg(pegasus
, timer
, net
, "intr status %d\n", status
);
667 if (urb
->actual_length
>= 6) {
668 u8
*d
= urb
->transfer_buffer
;
670 /* byte 0 == tx_status1, reg 2B */
671 if (d
[0] & (TX_UNDERRUN
|EXCESSIVE_COL
672 |LATE_COL
|JABBER_TIMEOUT
)) {
673 pegasus
->stats
.tx_errors
++;
674 if (d
[0] & TX_UNDERRUN
)
675 pegasus
->stats
.tx_fifo_errors
++;
676 if (d
[0] & (EXCESSIVE_COL
| JABBER_TIMEOUT
))
677 pegasus
->stats
.tx_aborted_errors
++;
679 pegasus
->stats
.tx_window_errors
++;
682 /* d[5].LINK_STATUS lies on some adapters.
683 * d[0].NO_CARRIER kicks in only with failed TX.
684 * ... so monitoring with MII may be safest.
687 /* bytes 3-4 == rx_lostpkt, reg 2E/2F */
688 pegasus
->stats
.rx_missed_errors
+= ((d
[3] & 0x7f) << 8) | d
[4];
691 res
= usb_submit_urb(urb
, GFP_ATOMIC
);
693 netif_device_detach(pegasus
->net
);
695 netif_err(pegasus
, timer
, net
,
696 "can't resubmit interrupt urb, %d\n", res
);
699 static void pegasus_tx_timeout(struct net_device
*net
)
701 pegasus_t
*pegasus
= netdev_priv(net
);
702 netif_warn(pegasus
, timer
, net
, "tx timeout\n");
703 usb_unlink_urb(pegasus
->tx_urb
);
704 pegasus
->stats
.tx_errors
++;
707 static netdev_tx_t
pegasus_start_xmit(struct sk_buff
*skb
,
708 struct net_device
*net
)
710 pegasus_t
*pegasus
= netdev_priv(net
);
711 int count
= ((skb
->len
+ 2) & 0x3f) ? skb
->len
+ 2 : skb
->len
+ 3;
713 __u16 l16
= skb
->len
;
715 netif_stop_queue(net
);
717 ((__le16
*) pegasus
->tx_buff
)[0] = cpu_to_le16(l16
);
718 skb_copy_from_linear_data(skb
, pegasus
->tx_buff
+ 2, skb
->len
);
719 usb_fill_bulk_urb(pegasus
->tx_urb
, pegasus
->usb
,
720 usb_sndbulkpipe(pegasus
->usb
, 2),
721 pegasus
->tx_buff
, count
,
722 write_bulk_callback
, pegasus
);
723 if ((res
= usb_submit_urb(pegasus
->tx_urb
, GFP_ATOMIC
))) {
724 netif_warn(pegasus
, tx_err
, net
, "fail tx, %d\n", res
);
726 case -EPIPE
: /* stall, or disconnect from TT */
727 /* cleanup should already have been scheduled */
729 case -ENODEV
: /* disconnect() upcoming */
731 netif_device_detach(pegasus
->net
);
734 pegasus
->stats
.tx_errors
++;
735 netif_start_queue(net
);
738 pegasus
->stats
.tx_packets
++;
739 pegasus
->stats
.tx_bytes
+= skb
->len
;
746 static struct net_device_stats
*pegasus_netdev_stats(struct net_device
*dev
)
748 return &((pegasus_t
*) netdev_priv(dev
))->stats
;
751 static inline void disable_net_traffic(pegasus_t
*pegasus
)
753 __le16 tmp
= cpu_to_le16(0);
755 set_registers(pegasus
, EthCtrl0
, sizeof(tmp
), &tmp
);
758 static inline void get_interrupt_interval(pegasus_t
*pegasus
)
763 read_eprom_word(pegasus
, 4, &data
);
764 interval
= data
>> 8;
765 if (pegasus
->usb
->speed
!= USB_SPEED_HIGH
) {
766 if (interval
< 0x80) {
767 netif_info(pegasus
, timer
, pegasus
->net
,
768 "intr interval changed from %ums to %ums\n",
771 data
= (data
& 0x00FF) | ((u16
)interval
<< 8);
772 #ifdef PEGASUS_WRITE_EEPROM
773 write_eprom_word(pegasus
, 4, data
);
777 pegasus
->intr_interval
= interval
;
780 static void set_carrier(struct net_device
*net
)
782 pegasus_t
*pegasus
= netdev_priv(net
);
785 if (read_mii_word(pegasus
, pegasus
->phy
, MII_BMSR
, &tmp
))
788 if (tmp
& BMSR_LSTATUS
)
789 netif_carrier_on(net
);
791 netif_carrier_off(net
);
794 static void free_all_urbs(pegasus_t
*pegasus
)
796 usb_free_urb(pegasus
->intr_urb
);
797 usb_free_urb(pegasus
->tx_urb
);
798 usb_free_urb(pegasus
->rx_urb
);
801 static void unlink_all_urbs(pegasus_t
*pegasus
)
803 usb_kill_urb(pegasus
->intr_urb
);
804 usb_kill_urb(pegasus
->tx_urb
);
805 usb_kill_urb(pegasus
->rx_urb
);
808 static int alloc_urbs(pegasus_t
*pegasus
)
812 pegasus
->rx_urb
= usb_alloc_urb(0, GFP_KERNEL
);
813 if (!pegasus
->rx_urb
) {
816 pegasus
->tx_urb
= usb_alloc_urb(0, GFP_KERNEL
);
817 if (!pegasus
->tx_urb
) {
818 usb_free_urb(pegasus
->rx_urb
);
821 pegasus
->intr_urb
= usb_alloc_urb(0, GFP_KERNEL
);
822 if (!pegasus
->intr_urb
) {
823 usb_free_urb(pegasus
->tx_urb
);
824 usb_free_urb(pegasus
->rx_urb
);
831 static int pegasus_open(struct net_device
*net
)
833 pegasus_t
*pegasus
= netdev_priv(net
);
836 if (pegasus
->rx_skb
== NULL
)
837 pegasus
->rx_skb
= __netdev_alloc_skb_ip_align(pegasus
->net
,
840 if (!pegasus
->rx_skb
)
843 res
= set_registers(pegasus
, EthID
, 6, net
->dev_addr
);
845 usb_fill_bulk_urb(pegasus
->rx_urb
, pegasus
->usb
,
846 usb_rcvbulkpipe(pegasus
->usb
, 1),
847 pegasus
->rx_skb
->data
, PEGASUS_MTU
+ 8,
848 read_bulk_callback
, pegasus
);
849 if ((res
= usb_submit_urb(pegasus
->rx_urb
, GFP_KERNEL
))) {
851 netif_device_detach(pegasus
->net
);
852 netif_dbg(pegasus
, ifup
, net
, "failed rx_urb, %d\n", res
);
856 usb_fill_int_urb(pegasus
->intr_urb
, pegasus
->usb
,
857 usb_rcvintpipe(pegasus
->usb
, 3),
858 pegasus
->intr_buff
, sizeof(pegasus
->intr_buff
),
859 intr_callback
, pegasus
, pegasus
->intr_interval
);
860 if ((res
= usb_submit_urb(pegasus
->intr_urb
, GFP_KERNEL
))) {
862 netif_device_detach(pegasus
->net
);
863 netif_dbg(pegasus
, ifup
, net
, "failed intr_urb, %d\n", res
);
864 usb_kill_urb(pegasus
->rx_urb
);
867 res
= enable_net_traffic(net
, pegasus
->usb
);
869 netif_dbg(pegasus
, ifup
, net
,
870 "can't enable_net_traffic() - %d\n", res
);
872 usb_kill_urb(pegasus
->rx_urb
);
873 usb_kill_urb(pegasus
->intr_urb
);
877 netif_start_queue(net
);
878 netif_dbg(pegasus
, ifup
, net
, "open\n");
884 static int pegasus_close(struct net_device
*net
)
886 pegasus_t
*pegasus
= netdev_priv(net
);
888 netif_stop_queue(net
);
889 if (!(pegasus
->flags
& PEGASUS_UNPLUG
))
890 disable_net_traffic(pegasus
);
891 tasklet_kill(&pegasus
->rx_tl
);
892 unlink_all_urbs(pegasus
);
897 static void pegasus_get_drvinfo(struct net_device
*dev
,
898 struct ethtool_drvinfo
*info
)
900 pegasus_t
*pegasus
= netdev_priv(dev
);
902 strlcpy(info
->driver
, driver_name
, sizeof(info
->driver
));
903 strlcpy(info
->version
, DRIVER_VERSION
, sizeof(info
->version
));
904 usb_make_path(pegasus
->usb
, info
->bus_info
, sizeof(info
->bus_info
));
907 /* also handles three patterns of some kind in hardware */
908 #define WOL_SUPPORTED (WAKE_MAGIC|WAKE_PHY)
911 pegasus_get_wol(struct net_device
*dev
, struct ethtool_wolinfo
*wol
)
913 pegasus_t
*pegasus
= netdev_priv(dev
);
915 wol
->supported
= WAKE_MAGIC
| WAKE_PHY
;
916 wol
->wolopts
= pegasus
->wolopts
;
920 pegasus_set_wol(struct net_device
*dev
, struct ethtool_wolinfo
*wol
)
922 pegasus_t
*pegasus
= netdev_priv(dev
);
926 if (wol
->wolopts
& ~WOL_SUPPORTED
)
929 if (wol
->wolopts
& WAKE_MAGIC
)
931 if (wol
->wolopts
& WAKE_PHY
)
933 /* FIXME this 0x10 bit still needs to get set in the chip... */
935 pegasus
->eth_regs
[0] |= 0x10;
937 pegasus
->eth_regs
[0] &= ~0x10;
938 pegasus
->wolopts
= wol
->wolopts
;
940 ret
= set_register(pegasus
, WakeupControl
, reg78
);
942 ret
= device_set_wakeup_enable(&pegasus
->usb
->dev
,
947 static inline void pegasus_reset_wol(struct net_device
*dev
)
949 struct ethtool_wolinfo wol
;
951 memset(&wol
, 0, sizeof wol
);
952 (void) pegasus_set_wol(dev
, &wol
);
956 pegasus_get_settings(struct net_device
*dev
, struct ethtool_cmd
*ecmd
)
960 pegasus
= netdev_priv(dev
);
961 mii_ethtool_gset(&pegasus
->mii
, ecmd
);
966 pegasus_set_settings(struct net_device
*dev
, struct ethtool_cmd
*ecmd
)
968 pegasus_t
*pegasus
= netdev_priv(dev
);
969 return mii_ethtool_sset(&pegasus
->mii
, ecmd
);
972 static int pegasus_nway_reset(struct net_device
*dev
)
974 pegasus_t
*pegasus
= netdev_priv(dev
);
975 return mii_nway_restart(&pegasus
->mii
);
978 static u32
pegasus_get_link(struct net_device
*dev
)
980 pegasus_t
*pegasus
= netdev_priv(dev
);
981 return mii_link_ok(&pegasus
->mii
);
984 static u32
pegasus_get_msglevel(struct net_device
*dev
)
986 pegasus_t
*pegasus
= netdev_priv(dev
);
987 return pegasus
->msg_enable
;
990 static void pegasus_set_msglevel(struct net_device
*dev
, u32 v
)
992 pegasus_t
*pegasus
= netdev_priv(dev
);
993 pegasus
->msg_enable
= v
;
996 static const struct ethtool_ops ops
= {
997 .get_drvinfo
= pegasus_get_drvinfo
,
998 .get_settings
= pegasus_get_settings
,
999 .set_settings
= pegasus_set_settings
,
1000 .nway_reset
= pegasus_nway_reset
,
1001 .get_link
= pegasus_get_link
,
1002 .get_msglevel
= pegasus_get_msglevel
,
1003 .set_msglevel
= pegasus_set_msglevel
,
1004 .get_wol
= pegasus_get_wol
,
1005 .set_wol
= pegasus_set_wol
,
1008 static int pegasus_ioctl(struct net_device
*net
, struct ifreq
*rq
, int cmd
)
1010 __u16
*data
= (__u16
*) &rq
->ifr_ifru
;
1011 pegasus_t
*pegasus
= netdev_priv(net
);
1015 case SIOCDEVPRIVATE
:
1016 data
[0] = pegasus
->phy
;
1017 case SIOCDEVPRIVATE
+ 1:
1018 read_mii_word(pegasus
, data
[0], data
[1] & 0x1f, &data
[3]);
1021 case SIOCDEVPRIVATE
+ 2:
1022 if (!capable(CAP_NET_ADMIN
))
1024 write_mii_word(pegasus
, pegasus
->phy
, data
[1] & 0x1f, &data
[2]);
1033 static void pegasus_set_multicast(struct net_device
*net
)
1035 pegasus_t
*pegasus
= netdev_priv(net
);
1037 if (net
->flags
& IFF_PROMISC
) {
1038 pegasus
->eth_regs
[EthCtrl2
] |= RX_PROMISCUOUS
;
1039 netif_info(pegasus
, link
, net
, "Promiscuous mode enabled\n");
1040 } else if (!netdev_mc_empty(net
) || (net
->flags
& IFF_ALLMULTI
)) {
1041 pegasus
->eth_regs
[EthCtrl0
] |= RX_MULTICAST
;
1042 pegasus
->eth_regs
[EthCtrl2
] &= ~RX_PROMISCUOUS
;
1043 netif_dbg(pegasus
, link
, net
, "set allmulti\n");
1045 pegasus
->eth_regs
[EthCtrl0
] &= ~RX_MULTICAST
;
1046 pegasus
->eth_regs
[EthCtrl2
] &= ~RX_PROMISCUOUS
;
1048 update_eth_regs_async(pegasus
);
1051 static __u8
mii_phy_probe(pegasus_t
*pegasus
)
1056 for (i
= 0; i
< 32; i
++) {
1057 read_mii_word(pegasus
, i
, MII_BMSR
, &tmp
);
1058 if (tmp
== 0 || tmp
== 0xffff || (tmp
& BMSR_MEDIA
) == 0)
1067 static inline void setup_pegasus_II(pegasus_t
*pegasus
)
1071 set_register(pegasus
, Reg1d
, 0);
1072 set_register(pegasus
, Reg7b
, 1);
1074 if ((pegasus
->features
& HAS_HOME_PNA
) && mii_mode
)
1075 set_register(pegasus
, Reg7b
, 0);
1077 set_register(pegasus
, Reg7b
, 2);
1079 set_register(pegasus
, 0x83, data
);
1080 get_registers(pegasus
, 0x83, 1, &data
);
1083 pegasus
->chip
= 0x8513;
1087 set_register(pegasus
, 0x80, 0xc0);
1088 set_register(pegasus
, 0x83, 0xff);
1089 set_register(pegasus
, 0x84, 0x01);
1091 if (pegasus
->features
& HAS_HOME_PNA
&& mii_mode
)
1092 set_register(pegasus
, Reg81
, 6);
1094 set_register(pegasus
, Reg81
, 2);
1098 static int pegasus_count
;
1099 static struct workqueue_struct
*pegasus_workqueue
;
1100 #define CARRIER_CHECK_DELAY (2 * HZ)
1102 static void check_carrier(struct work_struct
*work
)
1104 pegasus_t
*pegasus
= container_of(work
, pegasus_t
, carrier_check
.work
);
1105 set_carrier(pegasus
->net
);
1106 if (!(pegasus
->flags
& PEGASUS_UNPLUG
)) {
1107 queue_delayed_work(pegasus_workqueue
, &pegasus
->carrier_check
,
1108 CARRIER_CHECK_DELAY
);
1112 static int pegasus_blacklisted(struct usb_device
*udev
)
1114 struct usb_device_descriptor
*udd
= &udev
->descriptor
;
1116 /* Special quirk to keep the driver from handling the Belkin Bluetooth
1117 * dongle which happens to have the same ID.
1119 if ((udd
->idVendor
== cpu_to_le16(VENDOR_BELKIN
)) &&
1120 (udd
->idProduct
== cpu_to_le16(0x0121)) &&
1121 (udd
->bDeviceClass
== USB_CLASS_WIRELESS_CONTROLLER
) &&
1122 (udd
->bDeviceProtocol
== 1))
1128 /* we rely on probe() and remove() being serialized so we
1129 * don't need extra locking on pegasus_count.
1131 static void pegasus_dec_workqueue(void)
1134 if (pegasus_count
== 0) {
1135 destroy_workqueue(pegasus_workqueue
);
1136 pegasus_workqueue
= NULL
;
1140 static int pegasus_probe(struct usb_interface
*intf
,
1141 const struct usb_device_id
*id
)
1143 struct usb_device
*dev
= interface_to_usbdev(intf
);
1144 struct net_device
*net
;
1146 int dev_index
= id
- pegasus_ids
;
1149 if (pegasus_blacklisted(dev
))
1152 if (pegasus_count
== 0) {
1153 pegasus_workqueue
= create_singlethread_workqueue("pegasus");
1154 if (!pegasus_workqueue
)
1159 net
= alloc_etherdev(sizeof(struct pegasus
));
1163 pegasus
= netdev_priv(net
);
1164 pegasus
->dev_index
= dev_index
;
1166 res
= alloc_urbs(pegasus
);
1168 dev_err(&intf
->dev
, "can't allocate %s\n", "urbs");
1172 tasklet_init(&pegasus
->rx_tl
, rx_fixup
, (unsigned long) pegasus
);
1174 INIT_DELAYED_WORK(&pegasus
->carrier_check
, check_carrier
);
1176 pegasus
->intf
= intf
;
1181 net
->watchdog_timeo
= PEGASUS_TX_TIMEOUT
;
1182 net
->netdev_ops
= &pegasus_netdev_ops
;
1183 net
->ethtool_ops
= &ops
;
1184 pegasus
->mii
.dev
= net
;
1185 pegasus
->mii
.mdio_read
= mdio_read
;
1186 pegasus
->mii
.mdio_write
= mdio_write
;
1187 pegasus
->mii
.phy_id_mask
= 0x1f;
1188 pegasus
->mii
.reg_num_mask
= 0x1f;
1189 pegasus
->msg_enable
= netif_msg_init(msg_level
, NETIF_MSG_DRV
1190 | NETIF_MSG_PROBE
| NETIF_MSG_LINK
);
1192 pegasus
->features
= usb_dev_id
[dev_index
].private;
1193 get_interrupt_interval(pegasus
);
1194 if (reset_mac(pegasus
)) {
1195 dev_err(&intf
->dev
, "can't reset MAC\n");
1199 set_ethernet_addr(pegasus
);
1200 if (pegasus
->features
& PEGASUS_II
) {
1201 dev_info(&intf
->dev
, "setup Pegasus II specific registers\n");
1202 setup_pegasus_II(pegasus
);
1204 pegasus
->phy
= mii_phy_probe(pegasus
);
1205 if (pegasus
->phy
== 0xff) {
1206 dev_warn(&intf
->dev
, "can't locate MII phy, using default\n");
1209 pegasus
->mii
.phy_id
= pegasus
->phy
;
1210 usb_set_intfdata(intf
, pegasus
);
1211 SET_NETDEV_DEV(net
, &intf
->dev
);
1212 pegasus_reset_wol(net
);
1213 res
= register_netdev(net
);
1216 queue_delayed_work(pegasus_workqueue
, &pegasus
->carrier_check
,
1217 CARRIER_CHECK_DELAY
);
1218 dev_info(&intf
->dev
, "%s, %s, %pM\n", net
->name
,
1219 usb_dev_id
[dev_index
].name
, net
->dev_addr
);
1223 usb_set_intfdata(intf
, NULL
);
1225 free_all_urbs(pegasus
);
1229 pegasus_dec_workqueue();
1233 static void pegasus_disconnect(struct usb_interface
*intf
)
1235 struct pegasus
*pegasus
= usb_get_intfdata(intf
);
1237 usb_set_intfdata(intf
, NULL
);
1239 dev_dbg(&intf
->dev
, "unregistering non-bound device?\n");
1243 pegasus
->flags
|= PEGASUS_UNPLUG
;
1244 cancel_delayed_work(&pegasus
->carrier_check
);
1245 unregister_netdev(pegasus
->net
);
1246 unlink_all_urbs(pegasus
);
1247 free_all_urbs(pegasus
);
1248 if (pegasus
->rx_skb
!= NULL
) {
1249 dev_kfree_skb(pegasus
->rx_skb
);
1250 pegasus
->rx_skb
= NULL
;
1252 free_netdev(pegasus
->net
);
1253 pegasus_dec_workqueue();
1256 static int pegasus_suspend(struct usb_interface
*intf
, pm_message_t message
)
1258 struct pegasus
*pegasus
= usb_get_intfdata(intf
);
1260 netif_device_detach(pegasus
->net
);
1261 cancel_delayed_work(&pegasus
->carrier_check
);
1262 if (netif_running(pegasus
->net
)) {
1263 usb_kill_urb(pegasus
->rx_urb
);
1264 usb_kill_urb(pegasus
->intr_urb
);
1269 static int pegasus_resume(struct usb_interface
*intf
)
1271 struct pegasus
*pegasus
= usb_get_intfdata(intf
);
1273 netif_device_attach(pegasus
->net
);
1274 if (netif_running(pegasus
->net
)) {
1275 pegasus
->rx_urb
->status
= 0;
1276 pegasus
->rx_urb
->actual_length
= 0;
1277 read_bulk_callback(pegasus
->rx_urb
);
1279 pegasus
->intr_urb
->status
= 0;
1280 pegasus
->intr_urb
->actual_length
= 0;
1281 intr_callback(pegasus
->intr_urb
);
1283 queue_delayed_work(pegasus_workqueue
, &pegasus
->carrier_check
,
1284 CARRIER_CHECK_DELAY
);
1288 static const struct net_device_ops pegasus_netdev_ops
= {
1289 .ndo_open
= pegasus_open
,
1290 .ndo_stop
= pegasus_close
,
1291 .ndo_do_ioctl
= pegasus_ioctl
,
1292 .ndo_start_xmit
= pegasus_start_xmit
,
1293 .ndo_set_rx_mode
= pegasus_set_multicast
,
1294 .ndo_get_stats
= pegasus_netdev_stats
,
1295 .ndo_tx_timeout
= pegasus_tx_timeout
,
1296 .ndo_change_mtu
= eth_change_mtu
,
1297 .ndo_set_mac_address
= eth_mac_addr
,
1298 .ndo_validate_addr
= eth_validate_addr
,
1301 static struct usb_driver pegasus_driver
= {
1302 .name
= driver_name
,
1303 .probe
= pegasus_probe
,
1304 .disconnect
= pegasus_disconnect
,
1305 .id_table
= pegasus_ids
,
1306 .suspend
= pegasus_suspend
,
1307 .resume
= pegasus_resume
,
1308 .disable_hub_initiated_lpm
= 1,
1311 static void __init
parse_id(char *id
)
1313 unsigned int vendor_id
= 0, device_id
= 0, flags
= 0, i
= 0;
1314 char *token
, *name
= NULL
;
1316 if ((token
= strsep(&id
, ":")) != NULL
)
1318 /* name now points to a null terminated string*/
1319 if ((token
= strsep(&id
, ":")) != NULL
)
1320 vendor_id
= simple_strtoul(token
, NULL
, 16);
1321 if ((token
= strsep(&id
, ":")) != NULL
)
1322 device_id
= simple_strtoul(token
, NULL
, 16);
1323 flags
= simple_strtoul(id
, NULL
, 16);
1324 pr_info("%s: new device %s, vendor ID 0x%04x, device ID 0x%04x, flags: 0x%x\n",
1325 driver_name
, name
, vendor_id
, device_id
, flags
);
1327 if (vendor_id
> 0x10000 || vendor_id
== 0)
1329 if (device_id
> 0x10000 || device_id
== 0)
1332 for (i
= 0; usb_dev_id
[i
].name
; i
++);
1333 usb_dev_id
[i
].name
= name
;
1334 usb_dev_id
[i
].vendor
= vendor_id
;
1335 usb_dev_id
[i
].device
= device_id
;
1336 usb_dev_id
[i
].private = flags
;
1337 pegasus_ids
[i
].match_flags
= USB_DEVICE_ID_MATCH_DEVICE
;
1338 pegasus_ids
[i
].idVendor
= vendor_id
;
1339 pegasus_ids
[i
].idProduct
= device_id
;
1342 static int __init
pegasus_init(void)
1344 pr_info("%s: %s, " DRIVER_DESC
"\n", driver_name
, DRIVER_VERSION
);
1347 return usb_register(&pegasus_driver
);
1350 static void __exit
pegasus_exit(void)
1352 usb_deregister(&pegasus_driver
);
1355 module_init(pegasus_init
);
1356 module_exit(pegasus_exit
);