2 * rionet - Ethernet driver over RapidIO messaging services
4 * Copyright 2005 MontaVista Software, Inc.
5 * Matt Porter <mporter@kernel.crashing.org>
7 * This program is free software; you can redistribute it and/or modify it
8 * under the terms of the GNU General Public License as published by the
9 * Free Software Foundation; either version 2 of the License, or (at your
10 * option) any later version.
13 #include <linux/module.h>
14 #include <linux/kernel.h>
15 #include <linux/dma-mapping.h>
16 #include <linux/delay.h>
17 #include <linux/rio.h>
18 #include <linux/rio_drv.h>
19 #include <linux/slab.h>
20 #include <linux/rio_ids.h>
22 #include <linux/netdevice.h>
23 #include <linux/etherdevice.h>
24 #include <linux/skbuff.h>
25 #include <linux/crc32.h>
26 #include <linux/ethtool.h>
28 #define DRV_NAME "rionet"
29 #define DRV_VERSION "0.3"
30 #define DRV_AUTHOR "Matt Porter <mporter@kernel.crashing.org>"
31 #define DRV_DESC "Ethernet over RapidIO"
33 MODULE_AUTHOR(DRV_AUTHOR
);
34 MODULE_DESCRIPTION(DRV_DESC
);
35 MODULE_LICENSE("GPL");
37 #define RIONET_DEFAULT_MSGLEVEL \
43 #define RIONET_DOORBELL_JOIN 0x1000
44 #define RIONET_DOORBELL_LEAVE 0x1001
46 #define RIONET_MAILBOX 0
48 #define RIONET_TX_RING_SIZE CONFIG_RIONET_TX_SIZE
49 #define RIONET_RX_RING_SIZE CONFIG_RIONET_RX_SIZE
50 #define RIONET_MAX_NETS 8
52 struct rionet_private
{
53 struct rio_mport
*mport
;
54 struct sk_buff
*rx_skb
[RIONET_RX_RING_SIZE
];
55 struct sk_buff
*tx_skb
[RIONET_TX_RING_SIZE
];
66 struct list_head node
;
72 struct net_device
*ndev
;
73 struct list_head peers
;
74 struct rio_dev
**active
;
75 int nact
; /* number of active peers */
78 static struct rionet_net nets
[RIONET_MAX_NETS
];
80 #define is_rionet_capable(src_ops, dst_ops) \
81 ((src_ops & RIO_SRC_OPS_DATA_MSG) && \
82 (dst_ops & RIO_DST_OPS_DATA_MSG) && \
83 (src_ops & RIO_SRC_OPS_DOORBELL) && \
84 (dst_ops & RIO_DST_OPS_DOORBELL))
85 #define dev_rionet_capable(dev) \
86 is_rionet_capable(dev->src_ops, dev->dst_ops)
88 #define RIONET_MAC_MATCH(x) (!memcmp((x), "\00\01\00\01", 4))
89 #define RIONET_GET_DESTID(x) ((*((u8 *)x + 4) << 8) | *((u8 *)x + 5))
91 static int rionet_rx_clean(struct net_device
*ndev
)
95 struct rionet_private
*rnet
= netdev_priv(ndev
);
101 if (!rnet
->rx_skb
[i
])
104 if (!(data
= rio_get_inb_message(rnet
->mport
, RIONET_MAILBOX
)))
107 rnet
->rx_skb
[i
]->data
= data
;
108 skb_put(rnet
->rx_skb
[i
], RIO_MAX_MSG_SIZE
);
109 rnet
->rx_skb
[i
]->protocol
=
110 eth_type_trans(rnet
->rx_skb
[i
], ndev
);
111 error
= netif_rx(rnet
->rx_skb
[i
]);
113 if (error
== NET_RX_DROP
) {
114 ndev
->stats
.rx_dropped
++;
116 ndev
->stats
.rx_packets
++;
117 ndev
->stats
.rx_bytes
+= RIO_MAX_MSG_SIZE
;
120 } while ((i
= (i
+ 1) % RIONET_RX_RING_SIZE
) != rnet
->rx_slot
);
125 static void rionet_rx_fill(struct net_device
*ndev
, int end
)
128 struct rionet_private
*rnet
= netdev_priv(ndev
);
132 rnet
->rx_skb
[i
] = dev_alloc_skb(RIO_MAX_MSG_SIZE
);
134 if (!rnet
->rx_skb
[i
])
137 rio_add_inb_buffer(rnet
->mport
, RIONET_MAILBOX
,
138 rnet
->rx_skb
[i
]->data
);
139 } while ((i
= (i
+ 1) % RIONET_RX_RING_SIZE
) != end
);
144 static int rionet_queue_tx_msg(struct sk_buff
*skb
, struct net_device
*ndev
,
145 struct rio_dev
*rdev
)
147 struct rionet_private
*rnet
= netdev_priv(ndev
);
149 rio_add_outb_message(rnet
->mport
, rdev
, 0, skb
->data
, skb
->len
);
150 rnet
->tx_skb
[rnet
->tx_slot
] = skb
;
152 ndev
->stats
.tx_packets
++;
153 ndev
->stats
.tx_bytes
+= skb
->len
;
155 if (++rnet
->tx_cnt
== RIONET_TX_RING_SIZE
)
156 netif_stop_queue(ndev
);
159 rnet
->tx_slot
&= (RIONET_TX_RING_SIZE
- 1);
161 if (netif_msg_tx_queued(rnet
))
162 printk(KERN_INFO
"%s: queued skb len %8.8x\n", DRV_NAME
,
168 static int rionet_start_xmit(struct sk_buff
*skb
, struct net_device
*ndev
)
171 struct rionet_private
*rnet
= netdev_priv(ndev
);
172 struct ethhdr
*eth
= (struct ethhdr
*)skb
->data
;
177 local_irq_save(flags
);
178 if (!spin_trylock(&rnet
->tx_lock
)) {
179 local_irq_restore(flags
);
180 return NETDEV_TX_LOCKED
;
183 if (is_multicast_ether_addr(eth
->h_dest
))
184 add_num
= nets
[rnet
->mport
->id
].nact
;
186 if ((rnet
->tx_cnt
+ add_num
) > RIONET_TX_RING_SIZE
) {
187 netif_stop_queue(ndev
);
188 spin_unlock_irqrestore(&rnet
->tx_lock
, flags
);
189 printk(KERN_ERR
"%s: BUG! Tx Ring full when queue awake!\n",
191 return NETDEV_TX_BUSY
;
194 if (is_multicast_ether_addr(eth
->h_dest
)) {
197 for (i
= 0; i
< RIO_MAX_ROUTE_ENTRIES(rnet
->mport
->sys_size
);
199 if (nets
[rnet
->mport
->id
].active
[i
]) {
200 rionet_queue_tx_msg(skb
, ndev
,
201 nets
[rnet
->mport
->id
].active
[i
]);
203 atomic_inc(&skb
->users
);
206 } else if (RIONET_MAC_MATCH(eth
->h_dest
)) {
207 destid
= RIONET_GET_DESTID(eth
->h_dest
);
208 if (nets
[rnet
->mport
->id
].active
[destid
])
209 rionet_queue_tx_msg(skb
, ndev
,
210 nets
[rnet
->mport
->id
].active
[destid
]);
213 * If the target device was removed from the list of
214 * active peers but we still have TX packets targeting
215 * it just report sending a packet to the target
216 * (without actual packet transfer).
218 dev_kfree_skb_any(skb
);
219 ndev
->stats
.tx_packets
++;
220 ndev
->stats
.tx_bytes
+= skb
->len
;
224 spin_unlock_irqrestore(&rnet
->tx_lock
, flags
);
229 static void rionet_dbell_event(struct rio_mport
*mport
, void *dev_id
, u16 sid
, u16 tid
,
232 struct net_device
*ndev
= dev_id
;
233 struct rionet_private
*rnet
= netdev_priv(ndev
);
234 struct rionet_peer
*peer
;
236 if (netif_msg_intr(rnet
))
237 printk(KERN_INFO
"%s: doorbell sid %4.4x tid %4.4x info %4.4x",
238 DRV_NAME
, sid
, tid
, info
);
239 if (info
== RIONET_DOORBELL_JOIN
) {
240 if (!nets
[rnet
->mport
->id
].active
[sid
]) {
241 list_for_each_entry(peer
,
242 &nets
[rnet
->mport
->id
].peers
, node
) {
243 if (peer
->rdev
->destid
== sid
) {
244 nets
[rnet
->mport
->id
].active
[sid
] =
246 nets
[rnet
->mport
->id
].nact
++;
249 rio_mport_send_doorbell(mport
, sid
,
250 RIONET_DOORBELL_JOIN
);
252 } else if (info
== RIONET_DOORBELL_LEAVE
) {
253 nets
[rnet
->mport
->id
].active
[sid
] = NULL
;
254 nets
[rnet
->mport
->id
].nact
--;
256 if (netif_msg_intr(rnet
))
257 printk(KERN_WARNING
"%s: unhandled doorbell\n",
262 static void rionet_inb_msg_event(struct rio_mport
*mport
, void *dev_id
, int mbox
, int slot
)
265 struct net_device
*ndev
= dev_id
;
266 struct rionet_private
*rnet
= netdev_priv(ndev
);
268 if (netif_msg_intr(rnet
))
269 printk(KERN_INFO
"%s: inbound message event, mbox %d slot %d\n",
270 DRV_NAME
, mbox
, slot
);
272 spin_lock(&rnet
->lock
);
273 if ((n
= rionet_rx_clean(ndev
)) != rnet
->rx_slot
)
274 rionet_rx_fill(ndev
, n
);
275 spin_unlock(&rnet
->lock
);
278 static void rionet_outb_msg_event(struct rio_mport
*mport
, void *dev_id
, int mbox
, int slot
)
280 struct net_device
*ndev
= dev_id
;
281 struct rionet_private
*rnet
= netdev_priv(ndev
);
283 spin_lock(&rnet
->lock
);
285 if (netif_msg_intr(rnet
))
287 "%s: outbound message event, mbox %d slot %d\n",
288 DRV_NAME
, mbox
, slot
);
290 while (rnet
->tx_cnt
&& (rnet
->ack_slot
!= slot
)) {
291 /* dma unmap single */
292 dev_kfree_skb_irq(rnet
->tx_skb
[rnet
->ack_slot
]);
293 rnet
->tx_skb
[rnet
->ack_slot
] = NULL
;
295 rnet
->ack_slot
&= (RIONET_TX_RING_SIZE
- 1);
299 if (rnet
->tx_cnt
< RIONET_TX_RING_SIZE
)
300 netif_wake_queue(ndev
);
302 spin_unlock(&rnet
->lock
);
305 static int rionet_open(struct net_device
*ndev
)
308 struct rionet_peer
*peer
, *tmp
;
309 struct rionet_private
*rnet
= netdev_priv(ndev
);
311 if (netif_msg_ifup(rnet
))
312 printk(KERN_INFO
"%s: open\n", DRV_NAME
);
314 if ((rc
= rio_request_inb_dbell(rnet
->mport
,
316 RIONET_DOORBELL_JOIN
,
317 RIONET_DOORBELL_LEAVE
,
318 rionet_dbell_event
)) < 0)
321 if ((rc
= rio_request_inb_mbox(rnet
->mport
,
325 rionet_inb_msg_event
)) < 0)
328 if ((rc
= rio_request_outb_mbox(rnet
->mport
,
332 rionet_outb_msg_event
)) < 0)
335 /* Initialize inbound message ring */
336 for (i
= 0; i
< RIONET_RX_RING_SIZE
; i
++)
337 rnet
->rx_skb
[i
] = NULL
;
339 rionet_rx_fill(ndev
, 0);
345 netif_carrier_on(ndev
);
346 netif_start_queue(ndev
);
348 list_for_each_entry_safe(peer
, tmp
,
349 &nets
[rnet
->mport
->id
].peers
, node
) {
350 if (!(peer
->res
= rio_request_outb_dbell(peer
->rdev
,
351 RIONET_DOORBELL_JOIN
,
352 RIONET_DOORBELL_LEAVE
)))
354 printk(KERN_ERR
"%s: error requesting doorbells\n",
359 /* Send a join message */
360 rio_send_doorbell(peer
->rdev
, RIONET_DOORBELL_JOIN
);
367 static int rionet_close(struct net_device
*ndev
)
369 struct rionet_private
*rnet
= netdev_priv(ndev
);
370 struct rionet_peer
*peer
, *tmp
;
373 if (netif_msg_ifup(rnet
))
374 printk(KERN_INFO
"%s: close %s\n", DRV_NAME
, ndev
->name
);
376 netif_stop_queue(ndev
);
377 netif_carrier_off(ndev
);
379 for (i
= 0; i
< RIONET_RX_RING_SIZE
; i
++)
380 kfree_skb(rnet
->rx_skb
[i
]);
382 list_for_each_entry_safe(peer
, tmp
,
383 &nets
[rnet
->mport
->id
].peers
, node
) {
384 if (nets
[rnet
->mport
->id
].active
[peer
->rdev
->destid
]) {
385 rio_send_doorbell(peer
->rdev
, RIONET_DOORBELL_LEAVE
);
386 nets
[rnet
->mport
->id
].active
[peer
->rdev
->destid
] = NULL
;
388 rio_release_outb_dbell(peer
->rdev
, peer
->res
);
391 rio_release_inb_dbell(rnet
->mport
, RIONET_DOORBELL_JOIN
,
392 RIONET_DOORBELL_LEAVE
);
393 rio_release_inb_mbox(rnet
->mport
, RIONET_MAILBOX
);
394 rio_release_outb_mbox(rnet
->mport
, RIONET_MAILBOX
);
399 static int rionet_remove_dev(struct device
*dev
, struct subsys_interface
*sif
)
401 struct rio_dev
*rdev
= to_rio_dev(dev
);
402 unsigned char netid
= rdev
->net
->hport
->id
;
403 struct rionet_peer
*peer
, *tmp
;
405 if (dev_rionet_capable(rdev
)) {
406 list_for_each_entry_safe(peer
, tmp
, &nets
[netid
].peers
, node
) {
407 if (peer
->rdev
== rdev
) {
408 if (nets
[netid
].active
[rdev
->destid
]) {
409 nets
[netid
].active
[rdev
->destid
] = NULL
;
413 list_del(&peer
->node
);
423 static void rionet_get_drvinfo(struct net_device
*ndev
,
424 struct ethtool_drvinfo
*info
)
426 struct rionet_private
*rnet
= netdev_priv(ndev
);
428 strlcpy(info
->driver
, DRV_NAME
, sizeof(info
->driver
));
429 strlcpy(info
->version
, DRV_VERSION
, sizeof(info
->version
));
430 strlcpy(info
->fw_version
, "n/a", sizeof(info
->fw_version
));
431 strlcpy(info
->bus_info
, rnet
->mport
->name
, sizeof(info
->bus_info
));
434 static u32
rionet_get_msglevel(struct net_device
*ndev
)
436 struct rionet_private
*rnet
= netdev_priv(ndev
);
438 return rnet
->msg_enable
;
441 static void rionet_set_msglevel(struct net_device
*ndev
, u32 value
)
443 struct rionet_private
*rnet
= netdev_priv(ndev
);
445 rnet
->msg_enable
= value
;
448 static const struct ethtool_ops rionet_ethtool_ops
= {
449 .get_drvinfo
= rionet_get_drvinfo
,
450 .get_msglevel
= rionet_get_msglevel
,
451 .set_msglevel
= rionet_set_msglevel
,
452 .get_link
= ethtool_op_get_link
,
455 static const struct net_device_ops rionet_netdev_ops
= {
456 .ndo_open
= rionet_open
,
457 .ndo_stop
= rionet_close
,
458 .ndo_start_xmit
= rionet_start_xmit
,
459 .ndo_change_mtu
= eth_change_mtu
,
460 .ndo_validate_addr
= eth_validate_addr
,
461 .ndo_set_mac_address
= eth_mac_addr
,
464 static int rionet_setup_netdev(struct rio_mport
*mport
, struct net_device
*ndev
)
467 struct rionet_private
*rnet
;
469 const size_t rionet_active_bytes
= sizeof(void *) *
470 RIO_MAX_ROUTE_ENTRIES(mport
->sys_size
);
472 nets
[mport
->id
].active
= (struct rio_dev
**)__get_free_pages(GFP_KERNEL
,
473 get_order(rionet_active_bytes
));
474 if (!nets
[mport
->id
].active
) {
478 memset((void *)nets
[mport
->id
].active
, 0, rionet_active_bytes
);
480 /* Set up private area */
481 rnet
= netdev_priv(ndev
);
484 /* Set the default MAC address */
485 device_id
= rio_local_get_device_id(mport
);
486 ndev
->dev_addr
[0] = 0x00;
487 ndev
->dev_addr
[1] = 0x01;
488 ndev
->dev_addr
[2] = 0x00;
489 ndev
->dev_addr
[3] = 0x01;
490 ndev
->dev_addr
[4] = device_id
>> 8;
491 ndev
->dev_addr
[5] = device_id
& 0xff;
493 ndev
->netdev_ops
= &rionet_netdev_ops
;
494 ndev
->mtu
= RIO_MAX_MSG_SIZE
- 14;
495 ndev
->features
= NETIF_F_LLTX
;
496 SET_ETHTOOL_OPS(ndev
, &rionet_ethtool_ops
);
498 spin_lock_init(&rnet
->lock
);
499 spin_lock_init(&rnet
->tx_lock
);
501 rnet
->msg_enable
= RIONET_DEFAULT_MSGLEVEL
;
503 rc
= register_netdev(ndev
);
507 printk(KERN_INFO
"%s: %s %s Version %s, MAC %pM, %s\n",
519 static unsigned long net_table
[RIONET_MAX_NETS
/sizeof(unsigned long) + 1];
521 static int rionet_add_dev(struct device
*dev
, struct subsys_interface
*sif
)
524 u32 lsrc_ops
, ldst_ops
;
525 struct rionet_peer
*peer
;
526 struct net_device
*ndev
= NULL
;
527 struct rio_dev
*rdev
= to_rio_dev(dev
);
528 unsigned char netid
= rdev
->net
->hport
->id
;
531 if (netid
>= RIONET_MAX_NETS
)
534 oldnet
= test_and_set_bit(netid
, net_table
);
537 * If first time through this net, make sure local device is rionet
538 * capable and setup netdev (this step will be skipped in later probes
542 rio_local_read_config_32(rdev
->net
->hport
, RIO_SRC_OPS_CAR
,
544 rio_local_read_config_32(rdev
->net
->hport
, RIO_DST_OPS_CAR
,
546 if (!is_rionet_capable(lsrc_ops
, ldst_ops
)) {
548 "%s: local device %s is not network capable\n",
549 DRV_NAME
, rdev
->net
->hport
->name
);
553 /* Allocate our net_device structure */
554 ndev
= alloc_etherdev(sizeof(struct rionet_private
));
559 nets
[netid
].ndev
= ndev
;
560 rc
= rionet_setup_netdev(rdev
->net
->hport
, ndev
);
562 printk(KERN_ERR
"%s: failed to setup netdev (rc=%d)\n",
567 INIT_LIST_HEAD(&nets
[netid
].peers
);
568 nets
[netid
].nact
= 0;
569 } else if (nets
[netid
].ndev
== NULL
)
573 * If the remote device has mailbox/doorbell capabilities,
574 * add it to the peer list.
576 if (dev_rionet_capable(rdev
)) {
577 if (!(peer
= kmalloc(sizeof(struct rionet_peer
), GFP_KERNEL
))) {
582 list_add_tail(&peer
->node
, &nets
[netid
].peers
);
591 static struct rio_device_id rionet_id_table
[] = {
592 {RIO_DEVICE(RIO_ANY_ID
, RIO_ANY_ID
)},
593 { 0, } /* terminate list */
596 MODULE_DEVICE_TABLE(rapidio
, rionet_id_table
);
599 static struct subsys_interface rionet_interface
= {
601 .subsys
= &rio_bus_type
,
602 .add_dev
= rionet_add_dev
,
603 .remove_dev
= rionet_remove_dev
,
606 static int __init
rionet_init(void)
608 return subsys_interface_register(&rionet_interface
);
611 static void __exit
rionet_exit(void)
613 struct rionet_private
*rnet
;
614 struct net_device
*ndev
;
615 struct rionet_peer
*peer
, *tmp
;
618 for (i
= 0; i
< RIONET_MAX_NETS
; i
++) {
619 if (nets
[i
].ndev
!= NULL
) {
621 rnet
= netdev_priv(ndev
);
622 unregister_netdev(ndev
);
624 list_for_each_entry_safe(peer
,
625 tmp
, &nets
[i
].peers
, node
) {
626 list_del(&peer
->node
);
630 free_pages((unsigned long)nets
[i
].active
,
631 get_order(sizeof(void *) *
632 RIO_MAX_ROUTE_ENTRIES(rnet
->mport
->sys_size
)));
633 nets
[i
].active
= NULL
;
639 subsys_interface_unregister(&rionet_interface
);
642 late_initcall(rionet_init
);
643 module_exit(rionet_exit
);