| xj | b04a402 | 2021-11-25 15:01:52 +0800 | [diff] [blame] | 1 | /* | 
|  | 2 | * rionet - Ethernet driver over RapidIO messaging services | 
|  | 3 | * | 
|  | 4 | * Copyright 2005 MontaVista Software, Inc. | 
|  | 5 | * Matt Porter <mporter@kernel.crashing.org> | 
|  | 6 | * | 
|  | 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. | 
|  | 11 | */ | 
|  | 12 |  | 
|  | 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> | 
|  | 21 |  | 
|  | 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> | 
|  | 27 | #include <linux/reboot.h> | 
|  | 28 |  | 
|  | 29 | #define DRV_NAME        "rionet" | 
|  | 30 | #define DRV_VERSION     "0.3" | 
|  | 31 | #define DRV_AUTHOR      "Matt Porter <mporter@kernel.crashing.org>" | 
|  | 32 | #define DRV_DESC        "Ethernet over RapidIO" | 
|  | 33 |  | 
|  | 34 | MODULE_AUTHOR(DRV_AUTHOR); | 
|  | 35 | MODULE_DESCRIPTION(DRV_DESC); | 
|  | 36 | MODULE_LICENSE("GPL"); | 
|  | 37 |  | 
|  | 38 | #define RIONET_DEFAULT_MSGLEVEL \ | 
|  | 39 | (NETIF_MSG_DRV          | \ | 
|  | 40 | NETIF_MSG_LINK         | \ | 
|  | 41 | NETIF_MSG_RX_ERR       | \ | 
|  | 42 | NETIF_MSG_TX_ERR) | 
|  | 43 |  | 
|  | 44 | #define RIONET_DOORBELL_JOIN	0x1000 | 
|  | 45 | #define RIONET_DOORBELL_LEAVE	0x1001 | 
|  | 46 |  | 
|  | 47 | #define RIONET_MAILBOX		0 | 
|  | 48 |  | 
|  | 49 | #define RIONET_TX_RING_SIZE	CONFIG_RIONET_TX_SIZE | 
|  | 50 | #define RIONET_RX_RING_SIZE	CONFIG_RIONET_RX_SIZE | 
|  | 51 | #define RIONET_MAX_NETS		8 | 
|  | 52 | #define RIONET_MSG_SIZE         RIO_MAX_MSG_SIZE | 
|  | 53 | #define RIONET_MAX_MTU          (RIONET_MSG_SIZE - ETH_HLEN) | 
|  | 54 |  | 
|  | 55 | struct rionet_private { | 
|  | 56 | struct rio_mport *mport; | 
|  | 57 | struct sk_buff *rx_skb[RIONET_RX_RING_SIZE]; | 
|  | 58 | struct sk_buff *tx_skb[RIONET_TX_RING_SIZE]; | 
|  | 59 | int rx_slot; | 
|  | 60 | int tx_slot; | 
|  | 61 | int tx_cnt; | 
|  | 62 | int ack_slot; | 
|  | 63 | spinlock_t lock; | 
|  | 64 | spinlock_t tx_lock; | 
|  | 65 | u32 msg_enable; | 
|  | 66 | bool open; | 
|  | 67 | }; | 
|  | 68 |  | 
|  | 69 | struct rionet_peer { | 
|  | 70 | struct list_head node; | 
|  | 71 | struct rio_dev *rdev; | 
|  | 72 | struct resource *res; | 
|  | 73 | }; | 
|  | 74 |  | 
|  | 75 | struct rionet_net { | 
|  | 76 | struct net_device *ndev; | 
|  | 77 | struct list_head peers; | 
|  | 78 | spinlock_t lock;	/* net info access lock */ | 
|  | 79 | struct rio_dev **active; | 
|  | 80 | int nact;	/* number of active peers */ | 
|  | 81 | }; | 
|  | 82 |  | 
|  | 83 | static struct rionet_net nets[RIONET_MAX_NETS]; | 
|  | 84 |  | 
|  | 85 | #define is_rionet_capable(src_ops, dst_ops)			\ | 
|  | 86 | ((src_ops & RIO_SRC_OPS_DATA_MSG) &&	\ | 
|  | 87 | (dst_ops & RIO_DST_OPS_DATA_MSG) &&	\ | 
|  | 88 | (src_ops & RIO_SRC_OPS_DOORBELL) &&	\ | 
|  | 89 | (dst_ops & RIO_DST_OPS_DOORBELL)) | 
|  | 90 | #define dev_rionet_capable(dev) \ | 
|  | 91 | is_rionet_capable(dev->src_ops, dev->dst_ops) | 
|  | 92 |  | 
|  | 93 | #define RIONET_MAC_MATCH(x)	(!memcmp((x), "\00\01\00\01", 4)) | 
|  | 94 | #define RIONET_GET_DESTID(x)	((*((u8 *)x + 4) << 8) | *((u8 *)x + 5)) | 
|  | 95 |  | 
|  | 96 | static int rionet_rx_clean(struct net_device *ndev) | 
|  | 97 | { | 
|  | 98 | int i; | 
|  | 99 | int error = 0; | 
|  | 100 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 101 | void *data; | 
|  | 102 |  | 
|  | 103 | i = rnet->rx_slot; | 
|  | 104 |  | 
|  | 105 | do { | 
|  | 106 | if (!rnet->rx_skb[i]) | 
|  | 107 | continue; | 
|  | 108 |  | 
|  | 109 | if (!(data = rio_get_inb_message(rnet->mport, RIONET_MAILBOX))) | 
|  | 110 | break; | 
|  | 111 |  | 
|  | 112 | rnet->rx_skb[i]->data = data; | 
|  | 113 | skb_put(rnet->rx_skb[i], RIO_MAX_MSG_SIZE); | 
|  | 114 | rnet->rx_skb[i]->protocol = | 
|  | 115 | eth_type_trans(rnet->rx_skb[i], ndev); | 
|  | 116 | error = netif_rx(rnet->rx_skb[i]); | 
|  | 117 |  | 
|  | 118 | if (error == NET_RX_DROP) { | 
|  | 119 | ndev->stats.rx_dropped++; | 
|  | 120 | } else { | 
|  | 121 | ndev->stats.rx_packets++; | 
|  | 122 | ndev->stats.rx_bytes += RIO_MAX_MSG_SIZE; | 
|  | 123 | } | 
|  | 124 |  | 
|  | 125 | } while ((i = (i + 1) % RIONET_RX_RING_SIZE) != rnet->rx_slot); | 
|  | 126 |  | 
|  | 127 | return i; | 
|  | 128 | } | 
|  | 129 |  | 
|  | 130 | static void rionet_rx_fill(struct net_device *ndev, int end) | 
|  | 131 | { | 
|  | 132 | int i; | 
|  | 133 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 134 |  | 
|  | 135 | i = rnet->rx_slot; | 
|  | 136 | do { | 
|  | 137 | rnet->rx_skb[i] = dev_alloc_skb(RIO_MAX_MSG_SIZE); | 
|  | 138 |  | 
|  | 139 | if (!rnet->rx_skb[i]) | 
|  | 140 | break; | 
|  | 141 |  | 
|  | 142 | rio_add_inb_buffer(rnet->mport, RIONET_MAILBOX, | 
|  | 143 | rnet->rx_skb[i]->data); | 
|  | 144 | } while ((i = (i + 1) % RIONET_RX_RING_SIZE) != end); | 
|  | 145 |  | 
|  | 146 | rnet->rx_slot = i; | 
|  | 147 | } | 
|  | 148 |  | 
|  | 149 | static int rionet_queue_tx_msg(struct sk_buff *skb, struct net_device *ndev, | 
|  | 150 | struct rio_dev *rdev) | 
|  | 151 | { | 
|  | 152 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 153 |  | 
|  | 154 | rio_add_outb_message(rnet->mport, rdev, 0, skb->data, skb->len); | 
|  | 155 | rnet->tx_skb[rnet->tx_slot] = skb; | 
|  | 156 |  | 
|  | 157 | ndev->stats.tx_packets++; | 
|  | 158 | ndev->stats.tx_bytes += skb->len; | 
|  | 159 |  | 
|  | 160 | if (++rnet->tx_cnt == RIONET_TX_RING_SIZE) | 
|  | 161 | netif_stop_queue(ndev); | 
|  | 162 |  | 
|  | 163 | ++rnet->tx_slot; | 
|  | 164 | rnet->tx_slot &= (RIONET_TX_RING_SIZE - 1); | 
|  | 165 |  | 
|  | 166 | if (netif_msg_tx_queued(rnet)) | 
|  | 167 | printk(KERN_INFO "%s: queued skb len %8.8x\n", DRV_NAME, | 
|  | 168 | skb->len); | 
|  | 169 |  | 
|  | 170 | return 0; | 
|  | 171 | } | 
|  | 172 |  | 
|  | 173 | static int rionet_start_xmit(struct sk_buff *skb, struct net_device *ndev) | 
|  | 174 | { | 
|  | 175 | int i; | 
|  | 176 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 177 | struct ethhdr *eth = (struct ethhdr *)skb->data; | 
|  | 178 | u16 destid; | 
|  | 179 | unsigned long flags; | 
|  | 180 | int add_num = 1; | 
|  | 181 |  | 
|  | 182 | spin_lock_irqsave(&rnet->tx_lock, flags); | 
|  | 183 |  | 
|  | 184 | if (is_multicast_ether_addr(eth->h_dest)) | 
|  | 185 | add_num = nets[rnet->mport->id].nact; | 
|  | 186 |  | 
|  | 187 | if ((rnet->tx_cnt + add_num) > RIONET_TX_RING_SIZE) { | 
|  | 188 | netif_stop_queue(ndev); | 
|  | 189 | spin_unlock_irqrestore(&rnet->tx_lock, flags); | 
|  | 190 | printk(KERN_ERR "%s: BUG! Tx Ring full when queue awake!\n", | 
|  | 191 | ndev->name); | 
|  | 192 | return NETDEV_TX_BUSY; | 
|  | 193 | } | 
|  | 194 |  | 
|  | 195 | if (is_multicast_ether_addr(eth->h_dest)) { | 
|  | 196 | int count = 0; | 
|  | 197 |  | 
|  | 198 | for (i = 0; i < RIO_MAX_ROUTE_ENTRIES(rnet->mport->sys_size); | 
|  | 199 | i++) | 
|  | 200 | if (nets[rnet->mport->id].active[i]) { | 
|  | 201 | rionet_queue_tx_msg(skb, ndev, | 
|  | 202 | nets[rnet->mport->id].active[i]); | 
|  | 203 | if (count) | 
|  | 204 | refcount_inc(&skb->users); | 
|  | 205 | count++; | 
|  | 206 | } | 
|  | 207 | } else if (RIONET_MAC_MATCH(eth->h_dest)) { | 
|  | 208 | destid = RIONET_GET_DESTID(eth->h_dest); | 
|  | 209 | if (nets[rnet->mport->id].active[destid]) | 
|  | 210 | rionet_queue_tx_msg(skb, ndev, | 
|  | 211 | nets[rnet->mport->id].active[destid]); | 
|  | 212 | else { | 
|  | 213 | /* | 
|  | 214 | * If the target device was removed from the list of | 
|  | 215 | * active peers but we still have TX packets targeting | 
|  | 216 | * it just report sending a packet to the target | 
|  | 217 | * (without actual packet transfer). | 
|  | 218 | */ | 
|  | 219 | ndev->stats.tx_packets++; | 
|  | 220 | ndev->stats.tx_bytes += skb->len; | 
|  | 221 | dev_kfree_skb_any(skb); | 
|  | 222 | } | 
|  | 223 | } | 
|  | 224 |  | 
|  | 225 | spin_unlock_irqrestore(&rnet->tx_lock, flags); | 
|  | 226 |  | 
|  | 227 | return NETDEV_TX_OK; | 
|  | 228 | } | 
|  | 229 |  | 
|  | 230 | static void rionet_dbell_event(struct rio_mport *mport, void *dev_id, u16 sid, u16 tid, | 
|  | 231 | u16 info) | 
|  | 232 | { | 
|  | 233 | struct net_device *ndev = dev_id; | 
|  | 234 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 235 | struct rionet_peer *peer; | 
|  | 236 | unsigned char netid = rnet->mport->id; | 
|  | 237 |  | 
|  | 238 | if (netif_msg_intr(rnet)) | 
|  | 239 | printk(KERN_INFO "%s: doorbell sid %4.4x tid %4.4x info %4.4x", | 
|  | 240 | DRV_NAME, sid, tid, info); | 
|  | 241 | if (info == RIONET_DOORBELL_JOIN) { | 
|  | 242 | if (!nets[netid].active[sid]) { | 
|  | 243 | spin_lock(&nets[netid].lock); | 
|  | 244 | list_for_each_entry(peer, &nets[netid].peers, node) { | 
|  | 245 | if (peer->rdev->destid == sid) { | 
|  | 246 | nets[netid].active[sid] = peer->rdev; | 
|  | 247 | nets[netid].nact++; | 
|  | 248 | } | 
|  | 249 | } | 
|  | 250 | spin_unlock(&nets[netid].lock); | 
|  | 251 |  | 
|  | 252 | rio_mport_send_doorbell(mport, sid, | 
|  | 253 | RIONET_DOORBELL_JOIN); | 
|  | 254 | } | 
|  | 255 | } else if (info == RIONET_DOORBELL_LEAVE) { | 
|  | 256 | spin_lock(&nets[netid].lock); | 
|  | 257 | if (nets[netid].active[sid]) { | 
|  | 258 | nets[netid].active[sid] = NULL; | 
|  | 259 | nets[netid].nact--; | 
|  | 260 | } | 
|  | 261 | spin_unlock(&nets[netid].lock); | 
|  | 262 | } else { | 
|  | 263 | if (netif_msg_intr(rnet)) | 
|  | 264 | printk(KERN_WARNING "%s: unhandled doorbell\n", | 
|  | 265 | DRV_NAME); | 
|  | 266 | } | 
|  | 267 | } | 
|  | 268 |  | 
|  | 269 | static void rionet_inb_msg_event(struct rio_mport *mport, void *dev_id, int mbox, int slot) | 
|  | 270 | { | 
|  | 271 | int n; | 
|  | 272 | struct net_device *ndev = dev_id; | 
|  | 273 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 274 |  | 
|  | 275 | if (netif_msg_intr(rnet)) | 
|  | 276 | printk(KERN_INFO "%s: inbound message event, mbox %d slot %d\n", | 
|  | 277 | DRV_NAME, mbox, slot); | 
|  | 278 |  | 
|  | 279 | spin_lock(&rnet->lock); | 
|  | 280 | if ((n = rionet_rx_clean(ndev)) != rnet->rx_slot) | 
|  | 281 | rionet_rx_fill(ndev, n); | 
|  | 282 | spin_unlock(&rnet->lock); | 
|  | 283 | } | 
|  | 284 |  | 
|  | 285 | static void rionet_outb_msg_event(struct rio_mport *mport, void *dev_id, int mbox, int slot) | 
|  | 286 | { | 
|  | 287 | struct net_device *ndev = dev_id; | 
|  | 288 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 289 |  | 
|  | 290 | spin_lock(&rnet->tx_lock); | 
|  | 291 |  | 
|  | 292 | if (netif_msg_intr(rnet)) | 
|  | 293 | printk(KERN_INFO | 
|  | 294 | "%s: outbound message event, mbox %d slot %d\n", | 
|  | 295 | DRV_NAME, mbox, slot); | 
|  | 296 |  | 
|  | 297 | while (rnet->tx_cnt && (rnet->ack_slot != slot)) { | 
|  | 298 | /* dma unmap single */ | 
|  | 299 | dev_kfree_skb_irq(rnet->tx_skb[rnet->ack_slot]); | 
|  | 300 | rnet->tx_skb[rnet->ack_slot] = NULL; | 
|  | 301 | ++rnet->ack_slot; | 
|  | 302 | rnet->ack_slot &= (RIONET_TX_RING_SIZE - 1); | 
|  | 303 | rnet->tx_cnt--; | 
|  | 304 | } | 
|  | 305 |  | 
|  | 306 | if (rnet->tx_cnt < RIONET_TX_RING_SIZE) | 
|  | 307 | netif_wake_queue(ndev); | 
|  | 308 |  | 
|  | 309 | spin_unlock(&rnet->tx_lock); | 
|  | 310 | } | 
|  | 311 |  | 
|  | 312 | static int rionet_open(struct net_device *ndev) | 
|  | 313 | { | 
|  | 314 | int i, rc = 0; | 
|  | 315 | struct rionet_peer *peer; | 
|  | 316 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 317 | unsigned char netid = rnet->mport->id; | 
|  | 318 | unsigned long flags; | 
|  | 319 |  | 
|  | 320 | if (netif_msg_ifup(rnet)) | 
|  | 321 | printk(KERN_INFO "%s: open\n", DRV_NAME); | 
|  | 322 |  | 
|  | 323 | if ((rc = rio_request_inb_dbell(rnet->mport, | 
|  | 324 | (void *)ndev, | 
|  | 325 | RIONET_DOORBELL_JOIN, | 
|  | 326 | RIONET_DOORBELL_LEAVE, | 
|  | 327 | rionet_dbell_event)) < 0) | 
|  | 328 | goto out; | 
|  | 329 |  | 
|  | 330 | if ((rc = rio_request_inb_mbox(rnet->mport, | 
|  | 331 | (void *)ndev, | 
|  | 332 | RIONET_MAILBOX, | 
|  | 333 | RIONET_RX_RING_SIZE, | 
|  | 334 | rionet_inb_msg_event)) < 0) | 
|  | 335 | goto out; | 
|  | 336 |  | 
|  | 337 | if ((rc = rio_request_outb_mbox(rnet->mport, | 
|  | 338 | (void *)ndev, | 
|  | 339 | RIONET_MAILBOX, | 
|  | 340 | RIONET_TX_RING_SIZE, | 
|  | 341 | rionet_outb_msg_event)) < 0) | 
|  | 342 | goto out; | 
|  | 343 |  | 
|  | 344 | /* Initialize inbound message ring */ | 
|  | 345 | for (i = 0; i < RIONET_RX_RING_SIZE; i++) | 
|  | 346 | rnet->rx_skb[i] = NULL; | 
|  | 347 | rnet->rx_slot = 0; | 
|  | 348 | rionet_rx_fill(ndev, 0); | 
|  | 349 |  | 
|  | 350 | rnet->tx_slot = 0; | 
|  | 351 | rnet->tx_cnt = 0; | 
|  | 352 | rnet->ack_slot = 0; | 
|  | 353 |  | 
|  | 354 | netif_carrier_on(ndev); | 
|  | 355 | netif_start_queue(ndev); | 
|  | 356 |  | 
|  | 357 | spin_lock_irqsave(&nets[netid].lock, flags); | 
|  | 358 | list_for_each_entry(peer, &nets[netid].peers, node) { | 
|  | 359 | /* Send a join message */ | 
|  | 360 | rio_send_doorbell(peer->rdev, RIONET_DOORBELL_JOIN); | 
|  | 361 | } | 
|  | 362 | spin_unlock_irqrestore(&nets[netid].lock, flags); | 
|  | 363 | rnet->open = true; | 
|  | 364 |  | 
|  | 365 | out: | 
|  | 366 | return rc; | 
|  | 367 | } | 
|  | 368 |  | 
|  | 369 | static int rionet_close(struct net_device *ndev) | 
|  | 370 | { | 
|  | 371 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 372 | struct rionet_peer *peer; | 
|  | 373 | unsigned char netid = rnet->mport->id; | 
|  | 374 | unsigned long flags; | 
|  | 375 | int i; | 
|  | 376 |  | 
|  | 377 | if (netif_msg_ifup(rnet)) | 
|  | 378 | printk(KERN_INFO "%s: close %s\n", DRV_NAME, ndev->name); | 
|  | 379 |  | 
|  | 380 | netif_stop_queue(ndev); | 
|  | 381 | netif_carrier_off(ndev); | 
|  | 382 | rnet->open = false; | 
|  | 383 |  | 
|  | 384 | for (i = 0; i < RIONET_RX_RING_SIZE; i++) | 
|  | 385 | kfree_skb(rnet->rx_skb[i]); | 
|  | 386 |  | 
|  | 387 | spin_lock_irqsave(&nets[netid].lock, flags); | 
|  | 388 | list_for_each_entry(peer, &nets[netid].peers, node) { | 
|  | 389 | if (nets[netid].active[peer->rdev->destid]) { | 
|  | 390 | rio_send_doorbell(peer->rdev, RIONET_DOORBELL_LEAVE); | 
|  | 391 | nets[netid].active[peer->rdev->destid] = NULL; | 
|  | 392 | } | 
|  | 393 | if (peer->res) | 
|  | 394 | rio_release_outb_dbell(peer->rdev, peer->res); | 
|  | 395 | } | 
|  | 396 | spin_unlock_irqrestore(&nets[netid].lock, flags); | 
|  | 397 |  | 
|  | 398 | rio_release_inb_dbell(rnet->mport, RIONET_DOORBELL_JOIN, | 
|  | 399 | RIONET_DOORBELL_LEAVE); | 
|  | 400 | rio_release_inb_mbox(rnet->mport, RIONET_MAILBOX); | 
|  | 401 | rio_release_outb_mbox(rnet->mport, RIONET_MAILBOX); | 
|  | 402 |  | 
|  | 403 | return 0; | 
|  | 404 | } | 
|  | 405 |  | 
|  | 406 | static void rionet_remove_dev(struct device *dev, struct subsys_interface *sif) | 
|  | 407 | { | 
|  | 408 | struct rio_dev *rdev = to_rio_dev(dev); | 
|  | 409 | unsigned char netid = rdev->net->hport->id; | 
|  | 410 | struct rionet_peer *peer; | 
|  | 411 | int state, found = 0; | 
|  | 412 | unsigned long flags; | 
|  | 413 |  | 
|  | 414 | if (!dev_rionet_capable(rdev)) | 
|  | 415 | return; | 
|  | 416 |  | 
|  | 417 | spin_lock_irqsave(&nets[netid].lock, flags); | 
|  | 418 | list_for_each_entry(peer, &nets[netid].peers, node) { | 
|  | 419 | if (peer->rdev == rdev) { | 
|  | 420 | list_del(&peer->node); | 
|  | 421 | if (nets[netid].active[rdev->destid]) { | 
|  | 422 | state = atomic_read(&rdev->state); | 
|  | 423 | if (state != RIO_DEVICE_GONE && | 
|  | 424 | state != RIO_DEVICE_INITIALIZING) { | 
|  | 425 | rio_send_doorbell(rdev, | 
|  | 426 | RIONET_DOORBELL_LEAVE); | 
|  | 427 | } | 
|  | 428 | nets[netid].active[rdev->destid] = NULL; | 
|  | 429 | nets[netid].nact--; | 
|  | 430 | } | 
|  | 431 | found = 1; | 
|  | 432 | break; | 
|  | 433 | } | 
|  | 434 | } | 
|  | 435 | spin_unlock_irqrestore(&nets[netid].lock, flags); | 
|  | 436 |  | 
|  | 437 | if (found) { | 
|  | 438 | if (peer->res) | 
|  | 439 | rio_release_outb_dbell(rdev, peer->res); | 
|  | 440 | kfree(peer); | 
|  | 441 | } | 
|  | 442 | } | 
|  | 443 |  | 
|  | 444 | static void rionet_get_drvinfo(struct net_device *ndev, | 
|  | 445 | struct ethtool_drvinfo *info) | 
|  | 446 | { | 
|  | 447 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 448 |  | 
|  | 449 | strlcpy(info->driver, DRV_NAME, sizeof(info->driver)); | 
|  | 450 | strlcpy(info->version, DRV_VERSION, sizeof(info->version)); | 
|  | 451 | strlcpy(info->fw_version, "n/a", sizeof(info->fw_version)); | 
|  | 452 | strlcpy(info->bus_info, rnet->mport->name, sizeof(info->bus_info)); | 
|  | 453 | } | 
|  | 454 |  | 
|  | 455 | static u32 rionet_get_msglevel(struct net_device *ndev) | 
|  | 456 | { | 
|  | 457 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 458 |  | 
|  | 459 | return rnet->msg_enable; | 
|  | 460 | } | 
|  | 461 |  | 
|  | 462 | static void rionet_set_msglevel(struct net_device *ndev, u32 value) | 
|  | 463 | { | 
|  | 464 | struct rionet_private *rnet = netdev_priv(ndev); | 
|  | 465 |  | 
|  | 466 | rnet->msg_enable = value; | 
|  | 467 | } | 
|  | 468 |  | 
|  | 469 | static const struct ethtool_ops rionet_ethtool_ops = { | 
|  | 470 | .get_drvinfo = rionet_get_drvinfo, | 
|  | 471 | .get_msglevel = rionet_get_msglevel, | 
|  | 472 | .set_msglevel = rionet_set_msglevel, | 
|  | 473 | .get_link = ethtool_op_get_link, | 
|  | 474 | }; | 
|  | 475 |  | 
|  | 476 | static const struct net_device_ops rionet_netdev_ops = { | 
|  | 477 | .ndo_open		= rionet_open, | 
|  | 478 | .ndo_stop		= rionet_close, | 
|  | 479 | .ndo_start_xmit		= rionet_start_xmit, | 
|  | 480 | .ndo_validate_addr	= eth_validate_addr, | 
|  | 481 | .ndo_set_mac_address	= eth_mac_addr, | 
|  | 482 | }; | 
|  | 483 |  | 
|  | 484 | static int rionet_setup_netdev(struct rio_mport *mport, struct net_device *ndev) | 
|  | 485 | { | 
|  | 486 | int rc = 0; | 
|  | 487 | struct rionet_private *rnet; | 
|  | 488 | u16 device_id; | 
|  | 489 | const size_t rionet_active_bytes = sizeof(void *) * | 
|  | 490 | RIO_MAX_ROUTE_ENTRIES(mport->sys_size); | 
|  | 491 |  | 
|  | 492 | nets[mport->id].active = (struct rio_dev **)__get_free_pages(GFP_KERNEL, | 
|  | 493 | get_order(rionet_active_bytes)); | 
|  | 494 | if (!nets[mport->id].active) { | 
|  | 495 | rc = -ENOMEM; | 
|  | 496 | goto out; | 
|  | 497 | } | 
|  | 498 | memset((void *)nets[mport->id].active, 0, rionet_active_bytes); | 
|  | 499 |  | 
|  | 500 | /* Set up private area */ | 
|  | 501 | rnet = netdev_priv(ndev); | 
|  | 502 | rnet->mport = mport; | 
|  | 503 | rnet->open = false; | 
|  | 504 |  | 
|  | 505 | /* Set the default MAC address */ | 
|  | 506 | device_id = rio_local_get_device_id(mport); | 
|  | 507 | ndev->dev_addr[0] = 0x00; | 
|  | 508 | ndev->dev_addr[1] = 0x01; | 
|  | 509 | ndev->dev_addr[2] = 0x00; | 
|  | 510 | ndev->dev_addr[3] = 0x01; | 
|  | 511 | ndev->dev_addr[4] = device_id >> 8; | 
|  | 512 | ndev->dev_addr[5] = device_id & 0xff; | 
|  | 513 |  | 
|  | 514 | ndev->netdev_ops = &rionet_netdev_ops; | 
|  | 515 | ndev->mtu = RIONET_MAX_MTU; | 
|  | 516 | /* MTU range: 68 - 4082 */ | 
|  | 517 | ndev->min_mtu = ETH_MIN_MTU; | 
|  | 518 | ndev->max_mtu = RIONET_MAX_MTU; | 
|  | 519 | ndev->features = NETIF_F_LLTX; | 
|  | 520 | SET_NETDEV_DEV(ndev, &mport->dev); | 
|  | 521 | ndev->ethtool_ops = &rionet_ethtool_ops; | 
|  | 522 |  | 
|  | 523 | spin_lock_init(&rnet->lock); | 
|  | 524 | spin_lock_init(&rnet->tx_lock); | 
|  | 525 |  | 
|  | 526 | rnet->msg_enable = RIONET_DEFAULT_MSGLEVEL; | 
|  | 527 |  | 
|  | 528 | rc = register_netdev(ndev); | 
|  | 529 | if (rc != 0) { | 
|  | 530 | free_pages((unsigned long)nets[mport->id].active, | 
|  | 531 | get_order(rionet_active_bytes)); | 
|  | 532 | goto out; | 
|  | 533 | } | 
|  | 534 |  | 
|  | 535 | printk(KERN_INFO "%s: %s %s Version %s, MAC %pM, %s\n", | 
|  | 536 | ndev->name, | 
|  | 537 | DRV_NAME, | 
|  | 538 | DRV_DESC, | 
|  | 539 | DRV_VERSION, | 
|  | 540 | ndev->dev_addr, | 
|  | 541 | mport->name); | 
|  | 542 |  | 
|  | 543 | out: | 
|  | 544 | return rc; | 
|  | 545 | } | 
|  | 546 |  | 
|  | 547 | static int rionet_add_dev(struct device *dev, struct subsys_interface *sif) | 
|  | 548 | { | 
|  | 549 | int rc = -ENODEV; | 
|  | 550 | u32 lsrc_ops, ldst_ops; | 
|  | 551 | struct rionet_peer *peer; | 
|  | 552 | struct net_device *ndev = NULL; | 
|  | 553 | struct rio_dev *rdev = to_rio_dev(dev); | 
|  | 554 | unsigned char netid = rdev->net->hport->id; | 
|  | 555 |  | 
|  | 556 | if (netid >= RIONET_MAX_NETS) | 
|  | 557 | return rc; | 
|  | 558 |  | 
|  | 559 | /* | 
|  | 560 | * If first time through this net, make sure local device is rionet | 
|  | 561 | * capable and setup netdev (this step will be skipped in later probes | 
|  | 562 | * on the same net). | 
|  | 563 | */ | 
|  | 564 | if (!nets[netid].ndev) { | 
|  | 565 | rio_local_read_config_32(rdev->net->hport, RIO_SRC_OPS_CAR, | 
|  | 566 | &lsrc_ops); | 
|  | 567 | rio_local_read_config_32(rdev->net->hport, RIO_DST_OPS_CAR, | 
|  | 568 | &ldst_ops); | 
|  | 569 | if (!is_rionet_capable(lsrc_ops, ldst_ops)) { | 
|  | 570 | printk(KERN_ERR | 
|  | 571 | "%s: local device %s is not network capable\n", | 
|  | 572 | DRV_NAME, rdev->net->hport->name); | 
|  | 573 | goto out; | 
|  | 574 | } | 
|  | 575 |  | 
|  | 576 | /* Allocate our net_device structure */ | 
|  | 577 | ndev = alloc_etherdev(sizeof(struct rionet_private)); | 
|  | 578 | if (ndev == NULL) { | 
|  | 579 | rc = -ENOMEM; | 
|  | 580 | goto out; | 
|  | 581 | } | 
|  | 582 |  | 
|  | 583 | rc = rionet_setup_netdev(rdev->net->hport, ndev); | 
|  | 584 | if (rc) { | 
|  | 585 | printk(KERN_ERR "%s: failed to setup netdev (rc=%d)\n", | 
|  | 586 | DRV_NAME, rc); | 
|  | 587 | free_netdev(ndev); | 
|  | 588 | goto out; | 
|  | 589 | } | 
|  | 590 |  | 
|  | 591 | INIT_LIST_HEAD(&nets[netid].peers); | 
|  | 592 | spin_lock_init(&nets[netid].lock); | 
|  | 593 | nets[netid].nact = 0; | 
|  | 594 | nets[netid].ndev = ndev; | 
|  | 595 | } | 
|  | 596 |  | 
|  | 597 | /* | 
|  | 598 | * If the remote device has mailbox/doorbell capabilities, | 
|  | 599 | * add it to the peer list. | 
|  | 600 | */ | 
|  | 601 | if (dev_rionet_capable(rdev)) { | 
|  | 602 | struct rionet_private *rnet; | 
|  | 603 | unsigned long flags; | 
|  | 604 |  | 
|  | 605 | rnet = netdev_priv(nets[netid].ndev); | 
|  | 606 |  | 
|  | 607 | peer = kzalloc(sizeof(*peer), GFP_KERNEL); | 
|  | 608 | if (!peer) { | 
|  | 609 | rc = -ENOMEM; | 
|  | 610 | goto out; | 
|  | 611 | } | 
|  | 612 | peer->rdev = rdev; | 
|  | 613 | peer->res = rio_request_outb_dbell(peer->rdev, | 
|  | 614 | RIONET_DOORBELL_JOIN, | 
|  | 615 | RIONET_DOORBELL_LEAVE); | 
|  | 616 | if (!peer->res) { | 
|  | 617 | pr_err("%s: error requesting doorbells\n", DRV_NAME); | 
|  | 618 | kfree(peer); | 
|  | 619 | rc = -ENOMEM; | 
|  | 620 | goto out; | 
|  | 621 | } | 
|  | 622 |  | 
|  | 623 | spin_lock_irqsave(&nets[netid].lock, flags); | 
|  | 624 | list_add_tail(&peer->node, &nets[netid].peers); | 
|  | 625 | spin_unlock_irqrestore(&nets[netid].lock, flags); | 
|  | 626 | pr_debug("%s: %s add peer %s\n", | 
|  | 627 | DRV_NAME, __func__, rio_name(rdev)); | 
|  | 628 |  | 
|  | 629 | /* If netdev is already opened, send join request to new peer */ | 
|  | 630 | if (rnet->open) | 
|  | 631 | rio_send_doorbell(peer->rdev, RIONET_DOORBELL_JOIN); | 
|  | 632 | } | 
|  | 633 |  | 
|  | 634 | return 0; | 
|  | 635 | out: | 
|  | 636 | return rc; | 
|  | 637 | } | 
|  | 638 |  | 
|  | 639 | static int rionet_shutdown(struct notifier_block *nb, unsigned long code, | 
|  | 640 | void *unused) | 
|  | 641 | { | 
|  | 642 | struct rionet_peer *peer; | 
|  | 643 | unsigned long flags; | 
|  | 644 | int i; | 
|  | 645 |  | 
|  | 646 | pr_debug("%s: %s\n", DRV_NAME, __func__); | 
|  | 647 |  | 
|  | 648 | for (i = 0; i < RIONET_MAX_NETS; i++) { | 
|  | 649 | if (!nets[i].ndev) | 
|  | 650 | continue; | 
|  | 651 |  | 
|  | 652 | spin_lock_irqsave(&nets[i].lock, flags); | 
|  | 653 | list_for_each_entry(peer, &nets[i].peers, node) { | 
|  | 654 | if (nets[i].active[peer->rdev->destid]) { | 
|  | 655 | rio_send_doorbell(peer->rdev, | 
|  | 656 | RIONET_DOORBELL_LEAVE); | 
|  | 657 | nets[i].active[peer->rdev->destid] = NULL; | 
|  | 658 | } | 
|  | 659 | } | 
|  | 660 | spin_unlock_irqrestore(&nets[i].lock, flags); | 
|  | 661 | } | 
|  | 662 |  | 
|  | 663 | return NOTIFY_DONE; | 
|  | 664 | } | 
|  | 665 |  | 
|  | 666 | static void rionet_remove_mport(struct device *dev, | 
|  | 667 | struct class_interface *class_intf) | 
|  | 668 | { | 
|  | 669 | struct rio_mport *mport = to_rio_mport(dev); | 
|  | 670 | struct net_device *ndev; | 
|  | 671 | int id = mport->id; | 
|  | 672 |  | 
|  | 673 | pr_debug("%s %s\n", __func__, mport->name); | 
|  | 674 |  | 
|  | 675 | WARN(nets[id].nact, "%s called when connected to %d peers\n", | 
|  | 676 | __func__, nets[id].nact); | 
|  | 677 | WARN(!nets[id].ndev, "%s called for mport without NDEV\n", | 
|  | 678 | __func__); | 
|  | 679 |  | 
|  | 680 | if (nets[id].ndev) { | 
|  | 681 | ndev = nets[id].ndev; | 
|  | 682 | netif_stop_queue(ndev); | 
|  | 683 | unregister_netdev(ndev); | 
|  | 684 |  | 
|  | 685 | free_pages((unsigned long)nets[id].active, | 
|  | 686 | get_order(sizeof(void *) * | 
|  | 687 | RIO_MAX_ROUTE_ENTRIES(mport->sys_size))); | 
|  | 688 | nets[id].active = NULL; | 
|  | 689 | free_netdev(ndev); | 
|  | 690 | nets[id].ndev = NULL; | 
|  | 691 | } | 
|  | 692 | } | 
|  | 693 |  | 
|  | 694 | #ifdef MODULE | 
|  | 695 | static struct rio_device_id rionet_id_table[] = { | 
|  | 696 | {RIO_DEVICE(RIO_ANY_ID, RIO_ANY_ID)}, | 
|  | 697 | { 0, }	/* terminate list */ | 
|  | 698 | }; | 
|  | 699 |  | 
|  | 700 | MODULE_DEVICE_TABLE(rapidio, rionet_id_table); | 
|  | 701 | #endif | 
|  | 702 |  | 
|  | 703 | static struct subsys_interface rionet_interface = { | 
|  | 704 | .name		= "rionet", | 
|  | 705 | .subsys		= &rio_bus_type, | 
|  | 706 | .add_dev	= rionet_add_dev, | 
|  | 707 | .remove_dev	= rionet_remove_dev, | 
|  | 708 | }; | 
|  | 709 |  | 
|  | 710 | static struct notifier_block rionet_notifier = { | 
|  | 711 | .notifier_call = rionet_shutdown, | 
|  | 712 | }; | 
|  | 713 |  | 
|  | 714 | /* the rio_mport_interface is used to handle local mport devices */ | 
|  | 715 | static struct class_interface rio_mport_interface __refdata = { | 
|  | 716 | .class = &rio_mport_class, | 
|  | 717 | .add_dev = NULL, | 
|  | 718 | .remove_dev = rionet_remove_mport, | 
|  | 719 | }; | 
|  | 720 |  | 
|  | 721 | static int __init rionet_init(void) | 
|  | 722 | { | 
|  | 723 | int ret; | 
|  | 724 |  | 
|  | 725 | ret = register_reboot_notifier(&rionet_notifier); | 
|  | 726 | if (ret) { | 
|  | 727 | pr_err("%s: failed to register reboot notifier (err=%d)\n", | 
|  | 728 | DRV_NAME, ret); | 
|  | 729 | return ret; | 
|  | 730 | } | 
|  | 731 |  | 
|  | 732 | ret = class_interface_register(&rio_mport_interface); | 
|  | 733 | if (ret) { | 
|  | 734 | pr_err("%s: class_interface_register error: %d\n", | 
|  | 735 | DRV_NAME, ret); | 
|  | 736 | return ret; | 
|  | 737 | } | 
|  | 738 |  | 
|  | 739 | return subsys_interface_register(&rionet_interface); | 
|  | 740 | } | 
|  | 741 |  | 
|  | 742 | static void __exit rionet_exit(void) | 
|  | 743 | { | 
|  | 744 | unregister_reboot_notifier(&rionet_notifier); | 
|  | 745 | subsys_interface_unregister(&rionet_interface); | 
|  | 746 | class_interface_unregister(&rio_mport_interface); | 
|  | 747 | } | 
|  | 748 |  | 
|  | 749 | late_initcall(rionet_init); | 
|  | 750 | module_exit(rionet_exit); |