Committer: Michael Beasley <mike@snafu.setup>
[mikesnafu-overlay.git] / drivers / message / fusion / mptlan.c
blob7950fc678ed17c281e826529b290c76efa8cca11
1 /*
2 * linux/drivers/message/fusion/mptlan.c
3 * IP Over Fibre Channel device driver.
4 * For use with LSI Fibre Channel PCI chip/adapters
5 * running LSI Fusion MPT (Message Passing Technology) firmware.
7 * Copyright (c) 2000-2007 LSI Corporation
8 * (mailto:DL-MPTFusionLinux@lsi.com)
11 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
13 This program is free software; you can redistribute it and/or modify
14 it under the terms of the GNU General Public License as published by
15 the Free Software Foundation; version 2 of the License.
17 This program is distributed in the hope that it will be useful,
18 but WITHOUT ANY WARRANTY; without even the implied warranty of
19 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
20 GNU General Public License for more details.
22 NO WARRANTY
23 THE PROGRAM IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OR
24 CONDITIONS OF ANY KIND, EITHER EXPRESS OR IMPLIED INCLUDING, WITHOUT
25 LIMITATION, ANY WARRANTIES OR CONDITIONS OF TITLE, NON-INFRINGEMENT,
26 MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE. Each Recipient is
27 solely responsible for determining the appropriateness of using and
28 distributing the Program and assumes all risks associated with its
29 exercise of rights under this Agreement, including but not limited to
30 the risks and costs of program errors, damage to or loss of data,
31 programs or equipment, and unavailability or interruption of operations.
33 DISCLAIMER OF LIABILITY
34 NEITHER RECIPIENT NOR ANY CONTRIBUTORS SHALL HAVE ANY LIABILITY FOR ANY
35 DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
36 DAMAGES (INCLUDING WITHOUT LIMITATION LOST PROFITS), HOWEVER CAUSED AND
37 ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR
38 TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
39 USE OR DISTRIBUTION OF THE PROGRAM OR THE EXERCISE OF ANY RIGHTS GRANTED
40 HEREUNDER, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGES
42 You should have received a copy of the GNU General Public License
43 along with this program; if not, write to the Free Software
44 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
47 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
49 * Define statements used for debugging
51 //#define MPT_LAN_IO_DEBUG
53 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
55 #include "mptlan.h"
56 #include <linux/init.h>
57 #include <linux/module.h>
58 #include <linux/fs.h>
60 #define my_VERSION MPT_LINUX_VERSION_COMMON
61 #define MYNAM "mptlan"
63 MODULE_LICENSE("GPL");
64 MODULE_VERSION(my_VERSION);
66 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
68 * MPT LAN message sizes without variable part.
70 #define MPT_LAN_RECEIVE_POST_REQUEST_SIZE \
71 (sizeof(LANReceivePostRequest_t) - sizeof(SGE_MPI_UNION))
73 #define MPT_LAN_TRANSACTION32_SIZE \
74 (sizeof(SGETransaction32_t) - sizeof(u32))
77 * Fusion MPT LAN private structures
80 struct NAA_Hosed {
81 u16 NAA;
82 u8 ieee[FC_ALEN];
83 struct NAA_Hosed *next;
86 struct BufferControl {
87 struct sk_buff *skb;
88 dma_addr_t dma;
89 unsigned int len;
92 struct mpt_lan_priv {
93 MPT_ADAPTER *mpt_dev;
94 u8 pnum; /* Port number in the IOC. This is not a Unix network port! */
96 atomic_t buckets_out; /* number of unused buckets on IOC */
97 int bucketthresh; /* Send more when this many left */
99 int *mpt_txfidx; /* Free Tx Context list */
100 int mpt_txfidx_tail;
101 spinlock_t txfidx_lock;
103 int *mpt_rxfidx; /* Free Rx Context list */
104 int mpt_rxfidx_tail;
105 spinlock_t rxfidx_lock;
107 struct BufferControl *RcvCtl; /* Receive BufferControl structs */
108 struct BufferControl *SendCtl; /* Send BufferControl structs */
110 int max_buckets_out; /* Max buckets to send to IOC */
111 int tx_max_out; /* IOC's Tx queue len */
113 u32 total_posted;
114 u32 total_received;
115 struct net_device_stats stats; /* Per device statistics */
117 struct delayed_work post_buckets_task;
118 struct net_device *dev;
119 unsigned long post_buckets_active;
122 struct mpt_lan_ohdr {
123 u16 dtype;
124 u8 daddr[FC_ALEN];
125 u16 stype;
126 u8 saddr[FC_ALEN];
129 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
132 * Forward protos...
134 static int lan_reply (MPT_ADAPTER *ioc, MPT_FRAME_HDR *mf,
135 MPT_FRAME_HDR *reply);
136 static int mpt_lan_open(struct net_device *dev);
137 static int mpt_lan_reset(struct net_device *dev);
138 static int mpt_lan_close(struct net_device *dev);
139 static void mpt_lan_post_receive_buckets(struct mpt_lan_priv *priv);
140 static void mpt_lan_wake_post_buckets_task(struct net_device *dev,
141 int priority);
142 static int mpt_lan_receive_post_turbo(struct net_device *dev, u32 tmsg);
143 static int mpt_lan_receive_post_reply(struct net_device *dev,
144 LANReceivePostReply_t *pRecvRep);
145 static int mpt_lan_send_turbo(struct net_device *dev, u32 tmsg);
146 static int mpt_lan_send_reply(struct net_device *dev,
147 LANSendReply_t *pSendRep);
148 static int mpt_lan_ioc_reset(MPT_ADAPTER *ioc, int reset_phase);
149 static int mpt_lan_event_process(MPT_ADAPTER *ioc, EventNotificationReply_t *pEvReply);
150 static unsigned short mpt_lan_type_trans(struct sk_buff *skb,
151 struct net_device *dev);
153 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
155 * Fusion MPT LAN private data
157 static u8 LanCtx = MPT_MAX_PROTOCOL_DRIVERS;
159 static u32 max_buckets_out = 127;
160 static u32 tx_max_out_p = 127 - 16;
162 #ifdef QLOGIC_NAA_WORKAROUND
163 static struct NAA_Hosed *mpt_bad_naa = NULL;
164 DEFINE_RWLOCK(bad_naa_lock);
165 #endif
167 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
169 * lan_reply - Handle all data sent from the hardware.
170 * @ioc: Pointer to MPT_ADAPTER structure
171 * @mf: Pointer to original MPT request frame (NULL if TurboReply)
172 * @reply: Pointer to MPT reply frame
174 * Returns 1 indicating original alloc'd request frame ptr
175 * should be freed, or 0 if it shouldn't.
177 static int
178 lan_reply (MPT_ADAPTER *ioc, MPT_FRAME_HDR *mf, MPT_FRAME_HDR *reply)
180 struct net_device *dev = ioc->netdev;
181 int FreeReqFrame = 0;
183 dioprintk((KERN_INFO MYNAM ": %s/%s: Got reply.\n",
184 IOC_AND_NETDEV_NAMES_s_s(dev)));
186 // dioprintk((KERN_INFO MYNAM "@lan_reply: mf = %p, reply = %p\n",
187 // mf, reply));
189 if (mf == NULL) {
190 u32 tmsg = CAST_PTR_TO_U32(reply);
192 dioprintk((KERN_INFO MYNAM ": %s/%s: @lan_reply, tmsg %08x\n",
193 IOC_AND_NETDEV_NAMES_s_s(dev),
194 tmsg));
196 switch (GET_LAN_FORM(tmsg)) {
198 // NOTE! (Optimization) First case here is now caught in
199 // mptbase.c::mpt_interrupt() routine and callcack here
200 // is now skipped for this case!
201 #if 0
202 case LAN_REPLY_FORM_MESSAGE_CONTEXT:
203 // dioprintk((KERN_INFO MYNAM "/lan_reply: "
204 // "MessageContext turbo reply received\n"));
205 FreeReqFrame = 1;
206 break;
207 #endif
209 case LAN_REPLY_FORM_SEND_SINGLE:
210 // dioprintk((MYNAM "/lan_reply: "
211 // "calling mpt_lan_send_reply (turbo)\n"));
213 // Potential BUG here?
214 // FreeReqFrame = mpt_lan_send_turbo(dev, tmsg);
215 // If/when mpt_lan_send_turbo would return 1 here,
216 // calling routine (mptbase.c|mpt_interrupt)
217 // would Oops because mf has already been set
218 // to NULL. So after return from this func,
219 // mpt_interrupt() will attempt to put (NULL) mf ptr
220 // item back onto its adapter FreeQ - Oops!:-(
221 // It's Ok, since mpt_lan_send_turbo() *currently*
222 // always returns 0, but..., just in case:
224 (void) mpt_lan_send_turbo(dev, tmsg);
225 FreeReqFrame = 0;
227 break;
229 case LAN_REPLY_FORM_RECEIVE_SINGLE:
230 // dioprintk((KERN_INFO MYNAM "@lan_reply: "
231 // "rcv-Turbo = %08x\n", tmsg));
232 mpt_lan_receive_post_turbo(dev, tmsg);
233 break;
235 default:
236 printk (KERN_ERR MYNAM "/lan_reply: Got a turbo reply "
237 "that I don't know what to do with\n");
239 /* CHECKME! Hmmm... FreeReqFrame is 0 here; is that right? */
241 break;
244 return FreeReqFrame;
247 // msg = (u32 *) reply;
248 // dioprintk((KERN_INFO MYNAM "@lan_reply: msg = %08x %08x %08x %08x\n",
249 // le32_to_cpu(msg[0]), le32_to_cpu(msg[1]),
250 // le32_to_cpu(msg[2]), le32_to_cpu(msg[3])));
251 // dioprintk((KERN_INFO MYNAM "@lan_reply: Function = %02xh\n",
252 // reply->u.hdr.Function));
254 switch (reply->u.hdr.Function) {
256 case MPI_FUNCTION_LAN_SEND:
258 LANSendReply_t *pSendRep;
260 pSendRep = (LANSendReply_t *) reply;
261 FreeReqFrame = mpt_lan_send_reply(dev, pSendRep);
262 break;
265 case MPI_FUNCTION_LAN_RECEIVE:
267 LANReceivePostReply_t *pRecvRep;
269 pRecvRep = (LANReceivePostReply_t *) reply;
270 if (pRecvRep->NumberOfContexts) {
271 mpt_lan_receive_post_reply(dev, pRecvRep);
272 if (!(pRecvRep->MsgFlags & MPI_MSGFLAGS_CONTINUATION_REPLY))
273 FreeReqFrame = 1;
274 } else
275 dioprintk((KERN_INFO MYNAM "@lan_reply: zero context "
276 "ReceivePostReply received.\n"));
277 break;
280 case MPI_FUNCTION_LAN_RESET:
281 /* Just a default reply. Might want to check it to
282 * make sure that everything went ok.
284 FreeReqFrame = 1;
285 break;
287 case MPI_FUNCTION_EVENT_NOTIFICATION:
288 case MPI_FUNCTION_EVENT_ACK:
289 /* _EVENT_NOTIFICATION should NOT come down this path any more.
290 * Should be routed to mpt_lan_event_process(), but just in case...
292 FreeReqFrame = 1;
293 break;
295 default:
296 printk (KERN_ERR MYNAM "/lan_reply: Got a non-turbo "
297 "reply that I don't know what to do with\n");
299 /* CHECKME! Hmmm... FreeReqFrame is 0 here; is that right? */
300 FreeReqFrame = 1;
302 break;
305 return FreeReqFrame;
308 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
309 static int
310 mpt_lan_ioc_reset(MPT_ADAPTER *ioc, int reset_phase)
312 struct net_device *dev = ioc->netdev;
313 struct mpt_lan_priv *priv;
315 if (dev == NULL)
316 return(1);
317 else
318 priv = netdev_priv(dev);
320 dlprintk((KERN_INFO MYNAM ": IOC %s_reset routed to LAN driver!\n",
321 reset_phase==MPT_IOC_SETUP_RESET ? "setup" : (
322 reset_phase==MPT_IOC_PRE_RESET ? "pre" : "post")));
324 if (priv->mpt_rxfidx == NULL)
325 return (1);
327 if (reset_phase == MPT_IOC_SETUP_RESET) {
329 } else if (reset_phase == MPT_IOC_PRE_RESET) {
330 int i;
331 unsigned long flags;
333 netif_stop_queue(dev);
335 dlprintk ((KERN_INFO "mptlan/ioc_reset: called netif_stop_queue for %s.\n", dev->name));
337 atomic_set(&priv->buckets_out, 0);
339 /* Reset Rx Free Tail index and re-populate the queue. */
340 spin_lock_irqsave(&priv->rxfidx_lock, flags);
341 priv->mpt_rxfidx_tail = -1;
342 for (i = 0; i < priv->max_buckets_out; i++)
343 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = i;
344 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
345 } else {
346 mpt_lan_post_receive_buckets(priv);
347 netif_wake_queue(dev);
350 return 1;
353 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
354 static int
355 mpt_lan_event_process(MPT_ADAPTER *ioc, EventNotificationReply_t *pEvReply)
357 dlprintk((KERN_INFO MYNAM ": MPT event routed to LAN driver!\n"));
359 switch (le32_to_cpu(pEvReply->Event)) {
360 case MPI_EVENT_NONE: /* 00 */
361 case MPI_EVENT_LOG_DATA: /* 01 */
362 case MPI_EVENT_STATE_CHANGE: /* 02 */
363 case MPI_EVENT_UNIT_ATTENTION: /* 03 */
364 case MPI_EVENT_IOC_BUS_RESET: /* 04 */
365 case MPI_EVENT_EXT_BUS_RESET: /* 05 */
366 case MPI_EVENT_RESCAN: /* 06 */
367 /* Ok, do we need to do anything here? As far as
368 I can tell, this is when a new device gets added
369 to the loop. */
370 case MPI_EVENT_LINK_STATUS_CHANGE: /* 07 */
371 case MPI_EVENT_LOOP_STATE_CHANGE: /* 08 */
372 case MPI_EVENT_LOGOUT: /* 09 */
373 case MPI_EVENT_EVENT_CHANGE: /* 0A */
374 default:
375 break;
379 * NOTE: pEvent->AckRequired handling now done in mptbase.c;
380 * Do NOT do it here now!
383 return 1;
386 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
387 static int
388 mpt_lan_open(struct net_device *dev)
390 struct mpt_lan_priv *priv = netdev_priv(dev);
391 int i;
393 if (mpt_lan_reset(dev) != 0) {
394 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
396 printk (KERN_WARNING MYNAM "/lan_open: lan_reset failed.");
398 if (mpt_dev->active)
399 printk ("The ioc is active. Perhaps it needs to be"
400 " reset?\n");
401 else
402 printk ("The ioc in inactive, most likely in the "
403 "process of being reset. Please try again in "
404 "a moment.\n");
407 priv->mpt_txfidx = kmalloc(priv->tx_max_out * sizeof(int), GFP_KERNEL);
408 if (priv->mpt_txfidx == NULL)
409 goto out;
410 priv->mpt_txfidx_tail = -1;
412 priv->SendCtl = kcalloc(priv->tx_max_out, sizeof(struct BufferControl),
413 GFP_KERNEL);
414 if (priv->SendCtl == NULL)
415 goto out_mpt_txfidx;
416 for (i = 0; i < priv->tx_max_out; i++)
417 priv->mpt_txfidx[++priv->mpt_txfidx_tail] = i;
419 dlprintk((KERN_INFO MYNAM "@lo: Finished initializing SendCtl\n"));
421 priv->mpt_rxfidx = kmalloc(priv->max_buckets_out * sizeof(int),
422 GFP_KERNEL);
423 if (priv->mpt_rxfidx == NULL)
424 goto out_SendCtl;
425 priv->mpt_rxfidx_tail = -1;
427 priv->RcvCtl = kcalloc(priv->max_buckets_out,
428 sizeof(struct BufferControl),
429 GFP_KERNEL);
430 if (priv->RcvCtl == NULL)
431 goto out_mpt_rxfidx;
432 for (i = 0; i < priv->max_buckets_out; i++)
433 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = i;
435 /**/ dlprintk((KERN_INFO MYNAM "/lo: txfidx contains - "));
436 /**/ for (i = 0; i < priv->tx_max_out; i++)
437 /**/ dlprintk((" %xh", priv->mpt_txfidx[i]));
438 /**/ dlprintk(("\n"));
440 dlprintk((KERN_INFO MYNAM "/lo: Finished initializing RcvCtl\n"));
442 mpt_lan_post_receive_buckets(priv);
443 printk(KERN_INFO MYNAM ": %s/%s: interface up & active\n",
444 IOC_AND_NETDEV_NAMES_s_s(dev));
446 if (mpt_event_register(LanCtx, mpt_lan_event_process) != 0) {
447 printk (KERN_WARNING MYNAM "/lo: Unable to register for Event"
448 " Notifications. This is a bad thing! We're not going "
449 "to go ahead, but I'd be leery of system stability at "
450 "this point.\n");
453 netif_start_queue(dev);
454 dlprintk((KERN_INFO MYNAM "/lo: Done.\n"));
456 return 0;
457 out_mpt_rxfidx:
458 kfree(priv->mpt_rxfidx);
459 priv->mpt_rxfidx = NULL;
460 out_SendCtl:
461 kfree(priv->SendCtl);
462 priv->SendCtl = NULL;
463 out_mpt_txfidx:
464 kfree(priv->mpt_txfidx);
465 priv->mpt_txfidx = NULL;
466 out: return -ENOMEM;
469 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
470 /* Send a LanReset message to the FW. This should result in the FW returning
471 any buckets it still has. */
472 static int
473 mpt_lan_reset(struct net_device *dev)
475 MPT_FRAME_HDR *mf;
476 LANResetRequest_t *pResetReq;
477 struct mpt_lan_priv *priv = netdev_priv(dev);
479 mf = mpt_get_msg_frame(LanCtx, priv->mpt_dev);
481 if (mf == NULL) {
482 /* dlprintk((KERN_ERR MYNAM "/reset: Evil funkiness abounds! "
483 "Unable to allocate a request frame.\n"));
485 return -1;
488 pResetReq = (LANResetRequest_t *) mf;
490 pResetReq->Function = MPI_FUNCTION_LAN_RESET;
491 pResetReq->ChainOffset = 0;
492 pResetReq->Reserved = 0;
493 pResetReq->PortNumber = priv->pnum;
494 pResetReq->MsgFlags = 0;
495 pResetReq->Reserved2 = 0;
497 mpt_put_msg_frame(LanCtx, priv->mpt_dev, mf);
499 return 0;
502 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
503 static int
504 mpt_lan_close(struct net_device *dev)
506 struct mpt_lan_priv *priv = netdev_priv(dev);
507 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
508 unsigned long timeout;
509 int i;
511 dlprintk((KERN_INFO MYNAM ": mpt_lan_close called\n"));
513 mpt_event_deregister(LanCtx);
515 dlprintk((KERN_INFO MYNAM ":lan_close: Posted %d buckets "
516 "since driver was loaded, %d still out\n",
517 priv->total_posted,atomic_read(&priv->buckets_out)));
519 netif_stop_queue(dev);
521 mpt_lan_reset(dev);
523 timeout = jiffies + 2 * HZ;
524 while (atomic_read(&priv->buckets_out) && time_before(jiffies, timeout))
525 schedule_timeout_interruptible(1);
527 for (i = 0; i < priv->max_buckets_out; i++) {
528 if (priv->RcvCtl[i].skb != NULL) {
529 /**/ dlprintk((KERN_INFO MYNAM "/lan_close: bucket %05x "
530 /**/ "is still out\n", i));
531 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[i].dma,
532 priv->RcvCtl[i].len,
533 PCI_DMA_FROMDEVICE);
534 dev_kfree_skb(priv->RcvCtl[i].skb);
538 kfree(priv->RcvCtl);
539 kfree(priv->mpt_rxfidx);
541 for (i = 0; i < priv->tx_max_out; i++) {
542 if (priv->SendCtl[i].skb != NULL) {
543 pci_unmap_single(mpt_dev->pcidev, priv->SendCtl[i].dma,
544 priv->SendCtl[i].len,
545 PCI_DMA_TODEVICE);
546 dev_kfree_skb(priv->SendCtl[i].skb);
550 kfree(priv->SendCtl);
551 kfree(priv->mpt_txfidx);
553 atomic_set(&priv->buckets_out, 0);
555 printk(KERN_INFO MYNAM ": %s/%s: interface down & inactive\n",
556 IOC_AND_NETDEV_NAMES_s_s(dev));
558 return 0;
561 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
562 static struct net_device_stats *
563 mpt_lan_get_stats(struct net_device *dev)
565 struct mpt_lan_priv *priv = netdev_priv(dev);
567 return (struct net_device_stats *) &priv->stats;
570 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
571 static int
572 mpt_lan_change_mtu(struct net_device *dev, int new_mtu)
574 if ((new_mtu < MPT_LAN_MIN_MTU) || (new_mtu > MPT_LAN_MAX_MTU))
575 return -EINVAL;
576 dev->mtu = new_mtu;
577 return 0;
580 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
581 /* Tx timeout handler. */
582 static void
583 mpt_lan_tx_timeout(struct net_device *dev)
585 struct mpt_lan_priv *priv = netdev_priv(dev);
586 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
588 if (mpt_dev->active) {
589 dlprintk (("mptlan/tx_timeout: calling netif_wake_queue for %s.\n", dev->name));
590 netif_wake_queue(dev);
594 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
595 //static inline int
596 static int
597 mpt_lan_send_turbo(struct net_device *dev, u32 tmsg)
599 struct mpt_lan_priv *priv = netdev_priv(dev);
600 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
601 struct sk_buff *sent;
602 unsigned long flags;
603 u32 ctx;
605 ctx = GET_LAN_BUFFER_CONTEXT(tmsg);
606 sent = priv->SendCtl[ctx].skb;
608 priv->stats.tx_packets++;
609 priv->stats.tx_bytes += sent->len;
611 dioprintk((KERN_INFO MYNAM ": %s/%s: @%s, skb %p sent.\n",
612 IOC_AND_NETDEV_NAMES_s_s(dev),
613 __FUNCTION__, sent));
615 priv->SendCtl[ctx].skb = NULL;
616 pci_unmap_single(mpt_dev->pcidev, priv->SendCtl[ctx].dma,
617 priv->SendCtl[ctx].len, PCI_DMA_TODEVICE);
618 dev_kfree_skb_irq(sent);
620 spin_lock_irqsave(&priv->txfidx_lock, flags);
621 priv->mpt_txfidx[++priv->mpt_txfidx_tail] = ctx;
622 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
624 netif_wake_queue(dev);
625 return 0;
628 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
629 static int
630 mpt_lan_send_reply(struct net_device *dev, LANSendReply_t *pSendRep)
632 struct mpt_lan_priv *priv = netdev_priv(dev);
633 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
634 struct sk_buff *sent;
635 unsigned long flags;
636 int FreeReqFrame = 0;
637 u32 *pContext;
638 u32 ctx;
639 u8 count;
641 count = pSendRep->NumberOfContexts;
643 dioprintk((KERN_INFO MYNAM ": send_reply: IOCStatus: %04x\n",
644 le16_to_cpu(pSendRep->IOCStatus)));
646 /* Add check for Loginfo Flag in IOCStatus */
648 switch (le16_to_cpu(pSendRep->IOCStatus) & MPI_IOCSTATUS_MASK) {
649 case MPI_IOCSTATUS_SUCCESS:
650 priv->stats.tx_packets += count;
651 break;
653 case MPI_IOCSTATUS_LAN_CANCELED:
654 case MPI_IOCSTATUS_LAN_TRANSMIT_ABORTED:
655 break;
657 case MPI_IOCSTATUS_INVALID_SGL:
658 priv->stats.tx_errors += count;
659 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Invalid SGL sent to IOC!\n",
660 IOC_AND_NETDEV_NAMES_s_s(dev));
661 goto out;
663 default:
664 priv->stats.tx_errors += count;
665 break;
668 pContext = &pSendRep->BufferContext;
670 spin_lock_irqsave(&priv->txfidx_lock, flags);
671 while (count > 0) {
672 ctx = GET_LAN_BUFFER_CONTEXT(le32_to_cpu(*pContext));
674 sent = priv->SendCtl[ctx].skb;
675 priv->stats.tx_bytes += sent->len;
677 dioprintk((KERN_INFO MYNAM ": %s/%s: @%s, skb %p sent.\n",
678 IOC_AND_NETDEV_NAMES_s_s(dev),
679 __FUNCTION__, sent));
681 priv->SendCtl[ctx].skb = NULL;
682 pci_unmap_single(mpt_dev->pcidev, priv->SendCtl[ctx].dma,
683 priv->SendCtl[ctx].len, PCI_DMA_TODEVICE);
684 dev_kfree_skb_irq(sent);
686 priv->mpt_txfidx[++priv->mpt_txfidx_tail] = ctx;
688 pContext++;
689 count--;
691 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
693 out:
694 if (!(pSendRep->MsgFlags & MPI_MSGFLAGS_CONTINUATION_REPLY))
695 FreeReqFrame = 1;
697 netif_wake_queue(dev);
698 return FreeReqFrame;
701 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
702 static int
703 mpt_lan_sdu_send (struct sk_buff *skb, struct net_device *dev)
705 struct mpt_lan_priv *priv = netdev_priv(dev);
706 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
707 MPT_FRAME_HDR *mf;
708 LANSendRequest_t *pSendReq;
709 SGETransaction32_t *pTrans;
710 SGESimple64_t *pSimple;
711 const unsigned char *mac;
712 dma_addr_t dma;
713 unsigned long flags;
714 int ctx;
715 u16 cur_naa = 0x1000;
717 dioprintk((KERN_INFO MYNAM ": %s called, skb_addr = %p\n",
718 __FUNCTION__, skb));
720 spin_lock_irqsave(&priv->txfidx_lock, flags);
721 if (priv->mpt_txfidx_tail < 0) {
722 netif_stop_queue(dev);
723 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
725 printk (KERN_ERR "%s: no tx context available: %u\n",
726 __FUNCTION__, priv->mpt_txfidx_tail);
727 return 1;
730 mf = mpt_get_msg_frame(LanCtx, mpt_dev);
731 if (mf == NULL) {
732 netif_stop_queue(dev);
733 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
735 printk (KERN_ERR "%s: Unable to alloc request frame\n",
736 __FUNCTION__);
737 return 1;
740 ctx = priv->mpt_txfidx[priv->mpt_txfidx_tail--];
741 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
743 // dioprintk((KERN_INFO MYNAM ": %s/%s: Creating new msg frame (send).\n",
744 // IOC_AND_NETDEV_NAMES_s_s(dev)));
746 pSendReq = (LANSendRequest_t *) mf;
748 /* Set the mac.raw pointer, since this apparently isn't getting
749 * done before we get the skb. Pull the data pointer past the mac data.
751 skb_reset_mac_header(skb);
752 skb_pull(skb, 12);
754 dma = pci_map_single(mpt_dev->pcidev, skb->data, skb->len,
755 PCI_DMA_TODEVICE);
757 priv->SendCtl[ctx].skb = skb;
758 priv->SendCtl[ctx].dma = dma;
759 priv->SendCtl[ctx].len = skb->len;
761 /* Message Header */
762 pSendReq->Reserved = 0;
763 pSendReq->Function = MPI_FUNCTION_LAN_SEND;
764 pSendReq->ChainOffset = 0;
765 pSendReq->Reserved2 = 0;
766 pSendReq->MsgFlags = 0;
767 pSendReq->PortNumber = priv->pnum;
769 /* Transaction Context Element */
770 pTrans = (SGETransaction32_t *) pSendReq->SG_List;
772 /* No Flags, 8 bytes of Details, 32bit Context (bloody turbo replies) */
773 pTrans->ContextSize = sizeof(u32);
774 pTrans->DetailsLength = 2 * sizeof(u32);
775 pTrans->Flags = 0;
776 pTrans->TransactionContext[0] = cpu_to_le32(ctx);
778 // dioprintk((KERN_INFO MYNAM ": %s/%s: BC = %08x, skb = %p, buff = %p\n",
779 // IOC_AND_NETDEV_NAMES_s_s(dev),
780 // ctx, skb, skb->data));
782 mac = skb_mac_header(skb);
783 #ifdef QLOGIC_NAA_WORKAROUND
785 struct NAA_Hosed *nh;
787 /* Munge the NAA for Tx packets to QLogic boards, which don't follow
788 RFC 2625. The longer I look at this, the more my opinion of Qlogic
789 drops. */
790 read_lock_irq(&bad_naa_lock);
791 for (nh = mpt_bad_naa; nh != NULL; nh=nh->next) {
792 if ((nh->ieee[0] == mac[0]) &&
793 (nh->ieee[1] == mac[1]) &&
794 (nh->ieee[2] == mac[2]) &&
795 (nh->ieee[3] == mac[3]) &&
796 (nh->ieee[4] == mac[4]) &&
797 (nh->ieee[5] == mac[5])) {
798 cur_naa = nh->NAA;
799 dlprintk ((KERN_INFO "mptlan/sdu_send: using NAA value "
800 "= %04x.\n", cur_naa));
801 break;
804 read_unlock_irq(&bad_naa_lock);
806 #endif
808 pTrans->TransactionDetails[0] = cpu_to_le32((cur_naa << 16) |
809 (mac[0] << 8) |
810 (mac[1] << 0));
811 pTrans->TransactionDetails[1] = cpu_to_le32((mac[2] << 24) |
812 (mac[3] << 16) |
813 (mac[4] << 8) |
814 (mac[5] << 0));
816 pSimple = (SGESimple64_t *) &pTrans->TransactionDetails[2];
818 /* If we ever decide to send more than one Simple SGE per LANSend, then
819 we will need to make sure that LAST_ELEMENT only gets set on the
820 last one. Otherwise, bad voodoo and evil funkiness will commence. */
821 pSimple->FlagsLength = cpu_to_le32(
822 ((MPI_SGE_FLAGS_LAST_ELEMENT |
823 MPI_SGE_FLAGS_END_OF_BUFFER |
824 MPI_SGE_FLAGS_SIMPLE_ELEMENT |
825 MPI_SGE_FLAGS_SYSTEM_ADDRESS |
826 MPI_SGE_FLAGS_HOST_TO_IOC |
827 MPI_SGE_FLAGS_64_BIT_ADDRESSING |
828 MPI_SGE_FLAGS_END_OF_LIST) << MPI_SGE_FLAGS_SHIFT) |
829 skb->len);
830 pSimple->Address.Low = cpu_to_le32((u32) dma);
831 if (sizeof(dma_addr_t) > sizeof(u32))
832 pSimple->Address.High = cpu_to_le32((u32) ((u64) dma >> 32));
833 else
834 pSimple->Address.High = 0;
836 mpt_put_msg_frame (LanCtx, mpt_dev, mf);
837 dev->trans_start = jiffies;
839 dioprintk((KERN_INFO MYNAM ": %s/%s: Sending packet. FlagsLength = %08x.\n",
840 IOC_AND_NETDEV_NAMES_s_s(dev),
841 le32_to_cpu(pSimple->FlagsLength)));
843 return 0;
846 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
847 static void
848 mpt_lan_wake_post_buckets_task(struct net_device *dev, int priority)
850 * @priority: 0 = put it on the timer queue, 1 = put it on the immediate queue
853 struct mpt_lan_priv *priv = dev->priv;
855 if (test_and_set_bit(0, &priv->post_buckets_active) == 0) {
856 if (priority) {
857 schedule_delayed_work(&priv->post_buckets_task, 0);
858 } else {
859 schedule_delayed_work(&priv->post_buckets_task, 1);
860 dioprintk((KERN_INFO MYNAM ": post_buckets queued on "
861 "timer.\n"));
863 dioprintk((KERN_INFO MYNAM ": %s/%s: Queued post_buckets task.\n",
864 IOC_AND_NETDEV_NAMES_s_s(dev) ));
868 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
869 static int
870 mpt_lan_receive_skb(struct net_device *dev, struct sk_buff *skb)
872 struct mpt_lan_priv *priv = dev->priv;
874 skb->protocol = mpt_lan_type_trans(skb, dev);
876 dioprintk((KERN_INFO MYNAM ": %s/%s: Incoming packet (%d bytes) "
877 "delivered to upper level.\n",
878 IOC_AND_NETDEV_NAMES_s_s(dev), skb->len));
880 priv->stats.rx_bytes += skb->len;
881 priv->stats.rx_packets++;
883 skb->dev = dev;
884 netif_rx(skb);
886 dioprintk((MYNAM "/receive_skb: %d buckets remaining\n",
887 atomic_read(&priv->buckets_out)));
889 if (atomic_read(&priv->buckets_out) < priv->bucketthresh)
890 mpt_lan_wake_post_buckets_task(dev, 1);
892 dioprintk((KERN_INFO MYNAM "/receive_post_reply: %d buckets "
893 "remaining, %d received back since sod\n",
894 atomic_read(&priv->buckets_out), priv->total_received));
896 return 0;
899 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
900 //static inline int
901 static int
902 mpt_lan_receive_post_turbo(struct net_device *dev, u32 tmsg)
904 struct mpt_lan_priv *priv = dev->priv;
905 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
906 struct sk_buff *skb, *old_skb;
907 unsigned long flags;
908 u32 ctx, len;
910 ctx = GET_LAN_BUCKET_CONTEXT(tmsg);
911 skb = priv->RcvCtl[ctx].skb;
913 len = GET_LAN_PACKET_LENGTH(tmsg);
915 if (len < MPT_LAN_RX_COPYBREAK) {
916 old_skb = skb;
918 skb = (struct sk_buff *)dev_alloc_skb(len);
919 if (!skb) {
920 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Can't allocate skb! (%s@%d)\n",
921 IOC_AND_NETDEV_NAMES_s_s(dev),
922 __FILE__, __LINE__);
923 return -ENOMEM;
926 pci_dma_sync_single_for_cpu(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
927 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
929 skb_copy_from_linear_data(old_skb, skb_put(skb, len), len);
931 pci_dma_sync_single_for_device(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
932 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
933 goto out;
936 skb_put(skb, len);
938 priv->RcvCtl[ctx].skb = NULL;
940 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
941 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
943 out:
944 spin_lock_irqsave(&priv->rxfidx_lock, flags);
945 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
946 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
948 atomic_dec(&priv->buckets_out);
949 priv->total_received++;
951 return mpt_lan_receive_skb(dev, skb);
954 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
955 static int
956 mpt_lan_receive_post_free(struct net_device *dev,
957 LANReceivePostReply_t *pRecvRep)
959 struct mpt_lan_priv *priv = dev->priv;
960 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
961 unsigned long flags;
962 struct sk_buff *skb;
963 u32 ctx;
964 int count;
965 int i;
967 count = pRecvRep->NumberOfContexts;
969 /**/ dlprintk((KERN_INFO MYNAM "/receive_post_reply: "
970 "IOC returned %d buckets, freeing them...\n", count));
972 spin_lock_irqsave(&priv->rxfidx_lock, flags);
973 for (i = 0; i < count; i++) {
974 ctx = le32_to_cpu(pRecvRep->BucketContext[i]);
976 skb = priv->RcvCtl[ctx].skb;
978 // dlprintk((KERN_INFO MYNAM ": %s: dev_name = %s\n",
979 // IOC_AND_NETDEV_NAMES_s_s(dev)));
980 // dlprintk((KERN_INFO MYNAM "@rpr[2], priv = %p, buckets_out addr = %p",
981 // priv, &(priv->buckets_out)));
982 // dlprintk((KERN_INFO MYNAM "@rpr[2] TC + 3\n"));
984 priv->RcvCtl[ctx].skb = NULL;
985 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
986 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
987 dev_kfree_skb_any(skb);
989 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
991 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
993 atomic_sub(count, &priv->buckets_out);
995 // for (i = 0; i < priv->max_buckets_out; i++)
996 // if (priv->RcvCtl[i].skb != NULL)
997 // dlprintk((KERN_INFO MYNAM "@rpr: bucket %03x "
998 // "is still out\n", i));
1000 /* dlprintk((KERN_INFO MYNAM "/receive_post_reply: freed %d buckets\n",
1001 count));
1003 /**/ dlprintk((KERN_INFO MYNAM "@receive_post_reply: %d buckets "
1004 /**/ "remaining, %d received back since sod.\n",
1005 /**/ atomic_read(&priv->buckets_out), priv->total_received));
1006 return 0;
1009 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1010 static int
1011 mpt_lan_receive_post_reply(struct net_device *dev,
1012 LANReceivePostReply_t *pRecvRep)
1014 struct mpt_lan_priv *priv = dev->priv;
1015 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
1016 struct sk_buff *skb, *old_skb;
1017 unsigned long flags;
1018 u32 len, ctx, offset;
1019 u32 remaining = le32_to_cpu(pRecvRep->BucketsRemaining);
1020 int count;
1021 int i, l;
1023 dioprintk((KERN_INFO MYNAM ": mpt_lan_receive_post_reply called\n"));
1024 dioprintk((KERN_INFO MYNAM ": receive_post_reply: IOCStatus: %04x\n",
1025 le16_to_cpu(pRecvRep->IOCStatus)));
1027 if ((le16_to_cpu(pRecvRep->IOCStatus) & MPI_IOCSTATUS_MASK) ==
1028 MPI_IOCSTATUS_LAN_CANCELED)
1029 return mpt_lan_receive_post_free(dev, pRecvRep);
1031 len = le32_to_cpu(pRecvRep->PacketLength);
1032 if (len == 0) {
1033 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Got a non-TURBO "
1034 "ReceivePostReply w/ PacketLength zero!\n",
1035 IOC_AND_NETDEV_NAMES_s_s(dev));
1036 printk (KERN_ERR MYNAM ": MsgFlags = %02x, IOCStatus = %04x\n",
1037 pRecvRep->MsgFlags, le16_to_cpu(pRecvRep->IOCStatus));
1038 return -1;
1041 ctx = le32_to_cpu(pRecvRep->BucketContext[0]);
1042 count = pRecvRep->NumberOfContexts;
1043 skb = priv->RcvCtl[ctx].skb;
1045 offset = le32_to_cpu(pRecvRep->PacketOffset);
1046 // if (offset != 0) {
1047 // printk (KERN_INFO MYNAM ": %s/%s: Got a ReceivePostReply "
1048 // "w/ PacketOffset %u\n",
1049 // IOC_AND_NETDEV_NAMES_s_s(dev),
1050 // offset);
1051 // }
1053 dioprintk((KERN_INFO MYNAM ": %s/%s: @rpr, offset = %d, len = %d\n",
1054 IOC_AND_NETDEV_NAMES_s_s(dev),
1055 offset, len));
1057 if (count > 1) {
1058 int szrem = len;
1060 // dioprintk((KERN_INFO MYNAM ": %s/%s: Multiple buckets returned "
1061 // "for single packet, concatenating...\n",
1062 // IOC_AND_NETDEV_NAMES_s_s(dev)));
1064 skb = (struct sk_buff *)dev_alloc_skb(len);
1065 if (!skb) {
1066 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Can't allocate skb! (%s@%d)\n",
1067 IOC_AND_NETDEV_NAMES_s_s(dev),
1068 __FILE__, __LINE__);
1069 return -ENOMEM;
1072 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1073 for (i = 0; i < count; i++) {
1075 ctx = le32_to_cpu(pRecvRep->BucketContext[i]);
1076 old_skb = priv->RcvCtl[ctx].skb;
1078 l = priv->RcvCtl[ctx].len;
1079 if (szrem < l)
1080 l = szrem;
1082 // dioprintk((KERN_INFO MYNAM ": %s/%s: Buckets = %d, len = %u\n",
1083 // IOC_AND_NETDEV_NAMES_s_s(dev),
1084 // i, l));
1086 pci_dma_sync_single_for_cpu(mpt_dev->pcidev,
1087 priv->RcvCtl[ctx].dma,
1088 priv->RcvCtl[ctx].len,
1089 PCI_DMA_FROMDEVICE);
1090 skb_copy_from_linear_data(old_skb, skb_put(skb, l), l);
1092 pci_dma_sync_single_for_device(mpt_dev->pcidev,
1093 priv->RcvCtl[ctx].dma,
1094 priv->RcvCtl[ctx].len,
1095 PCI_DMA_FROMDEVICE);
1097 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1098 szrem -= l;
1100 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1102 } else if (len < MPT_LAN_RX_COPYBREAK) {
1104 old_skb = skb;
1106 skb = (struct sk_buff *)dev_alloc_skb(len);
1107 if (!skb) {
1108 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Can't allocate skb! (%s@%d)\n",
1109 IOC_AND_NETDEV_NAMES_s_s(dev),
1110 __FILE__, __LINE__);
1111 return -ENOMEM;
1114 pci_dma_sync_single_for_cpu(mpt_dev->pcidev,
1115 priv->RcvCtl[ctx].dma,
1116 priv->RcvCtl[ctx].len,
1117 PCI_DMA_FROMDEVICE);
1119 skb_copy_from_linear_data(old_skb, skb_put(skb, len), len);
1121 pci_dma_sync_single_for_device(mpt_dev->pcidev,
1122 priv->RcvCtl[ctx].dma,
1123 priv->RcvCtl[ctx].len,
1124 PCI_DMA_FROMDEVICE);
1126 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1127 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1128 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1130 } else {
1131 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1133 priv->RcvCtl[ctx].skb = NULL;
1135 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
1136 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
1137 priv->RcvCtl[ctx].dma = 0;
1139 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1140 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1142 skb_put(skb,len);
1145 atomic_sub(count, &priv->buckets_out);
1146 priv->total_received += count;
1148 if (priv->mpt_rxfidx_tail >= MPT_LAN_MAX_BUCKETS_OUT) {
1149 printk (KERN_ERR MYNAM ": %s/%s: Yoohoo! mpt_rxfidx_tail = %d, "
1150 "MPT_LAN_MAX_BUCKETS_OUT = %d\n",
1151 IOC_AND_NETDEV_NAMES_s_s(dev),
1152 priv->mpt_rxfidx_tail,
1153 MPT_LAN_MAX_BUCKETS_OUT);
1155 return -1;
1158 if (remaining == 0)
1159 printk (KERN_WARNING MYNAM ": %s/%s: WARNING - IOC out of buckets! "
1160 "(priv->buckets_out = %d)\n",
1161 IOC_AND_NETDEV_NAMES_s_s(dev),
1162 atomic_read(&priv->buckets_out));
1163 else if (remaining < 10)
1164 printk (KERN_INFO MYNAM ": %s/%s: IOC says %d buckets left. "
1165 "(priv->buckets_out = %d)\n",
1166 IOC_AND_NETDEV_NAMES_s_s(dev),
1167 remaining, atomic_read(&priv->buckets_out));
1169 if ((remaining < priv->bucketthresh) &&
1170 ((atomic_read(&priv->buckets_out) - remaining) >
1171 MPT_LAN_BUCKETS_REMAIN_MISMATCH_THRESH)) {
1173 printk (KERN_WARNING MYNAM " Mismatch between driver's "
1174 "buckets_out count and fw's BucketsRemaining "
1175 "count has crossed the threshold, issuing a "
1176 "LanReset to clear the fw's hashtable. You may "
1177 "want to check your /var/log/messages for \"CRC "
1178 "error\" event notifications.\n");
1180 mpt_lan_reset(dev);
1181 mpt_lan_wake_post_buckets_task(dev, 0);
1184 return mpt_lan_receive_skb(dev, skb);
1187 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1188 /* Simple SGE's only at the moment */
1190 static void
1191 mpt_lan_post_receive_buckets(struct mpt_lan_priv *priv)
1193 struct net_device *dev = priv->dev;
1194 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
1195 MPT_FRAME_HDR *mf;
1196 LANReceivePostRequest_t *pRecvReq;
1197 SGETransaction32_t *pTrans;
1198 SGESimple64_t *pSimple;
1199 struct sk_buff *skb;
1200 dma_addr_t dma;
1201 u32 curr, buckets, count, max;
1202 u32 len = (dev->mtu + dev->hard_header_len + 4);
1203 unsigned long flags;
1204 int i;
1206 curr = atomic_read(&priv->buckets_out);
1207 buckets = (priv->max_buckets_out - curr);
1209 dioprintk((KERN_INFO MYNAM ": %s/%s: @%s, Start_buckets = %u, buckets_out = %u\n",
1210 IOC_AND_NETDEV_NAMES_s_s(dev),
1211 __FUNCTION__, buckets, curr));
1213 max = (mpt_dev->req_sz - MPT_LAN_RECEIVE_POST_REQUEST_SIZE) /
1214 (MPT_LAN_TRANSACTION32_SIZE + sizeof(SGESimple64_t));
1216 while (buckets) {
1217 mf = mpt_get_msg_frame(LanCtx, mpt_dev);
1218 if (mf == NULL) {
1219 printk (KERN_ERR "%s: Unable to alloc request frame\n",
1220 __FUNCTION__);
1221 dioprintk((KERN_ERR "%s: %u buckets remaining\n",
1222 __FUNCTION__, buckets));
1223 goto out;
1225 pRecvReq = (LANReceivePostRequest_t *) mf;
1227 i = le16_to_cpu(mf->u.frame.hwhdr.msgctxu.fld.req_idx);
1228 mpt_dev->RequestNB[i] = 0;
1229 count = buckets;
1230 if (count > max)
1231 count = max;
1233 pRecvReq->Function = MPI_FUNCTION_LAN_RECEIVE;
1234 pRecvReq->ChainOffset = 0;
1235 pRecvReq->MsgFlags = 0;
1236 pRecvReq->PortNumber = priv->pnum;
1238 pTrans = (SGETransaction32_t *) pRecvReq->SG_List;
1239 pSimple = NULL;
1241 for (i = 0; i < count; i++) {
1242 int ctx;
1244 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1245 if (priv->mpt_rxfidx_tail < 0) {
1246 printk (KERN_ERR "%s: Can't alloc context\n",
1247 __FUNCTION__);
1248 spin_unlock_irqrestore(&priv->rxfidx_lock,
1249 flags);
1250 break;
1253 ctx = priv->mpt_rxfidx[priv->mpt_rxfidx_tail--];
1255 skb = priv->RcvCtl[ctx].skb;
1256 if (skb && (priv->RcvCtl[ctx].len != len)) {
1257 pci_unmap_single(mpt_dev->pcidev,
1258 priv->RcvCtl[ctx].dma,
1259 priv->RcvCtl[ctx].len,
1260 PCI_DMA_FROMDEVICE);
1261 dev_kfree_skb(priv->RcvCtl[ctx].skb);
1262 skb = priv->RcvCtl[ctx].skb = NULL;
1265 if (skb == NULL) {
1266 skb = dev_alloc_skb(len);
1267 if (skb == NULL) {
1268 printk (KERN_WARNING
1269 MYNAM "/%s: Can't alloc skb\n",
1270 __FUNCTION__);
1271 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1272 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1273 break;
1276 dma = pci_map_single(mpt_dev->pcidev, skb->data,
1277 len, PCI_DMA_FROMDEVICE);
1279 priv->RcvCtl[ctx].skb = skb;
1280 priv->RcvCtl[ctx].dma = dma;
1281 priv->RcvCtl[ctx].len = len;
1284 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1286 pTrans->ContextSize = sizeof(u32);
1287 pTrans->DetailsLength = 0;
1288 pTrans->Flags = 0;
1289 pTrans->TransactionContext[0] = cpu_to_le32(ctx);
1291 pSimple = (SGESimple64_t *) pTrans->TransactionDetails;
1293 pSimple->FlagsLength = cpu_to_le32(
1294 ((MPI_SGE_FLAGS_END_OF_BUFFER |
1295 MPI_SGE_FLAGS_SIMPLE_ELEMENT |
1296 MPI_SGE_FLAGS_64_BIT_ADDRESSING) << MPI_SGE_FLAGS_SHIFT) | len);
1297 pSimple->Address.Low = cpu_to_le32((u32) priv->RcvCtl[ctx].dma);
1298 if (sizeof(dma_addr_t) > sizeof(u32))
1299 pSimple->Address.High = cpu_to_le32((u32) ((u64) priv->RcvCtl[ctx].dma >> 32));
1300 else
1301 pSimple->Address.High = 0;
1303 pTrans = (SGETransaction32_t *) (pSimple + 1);
1306 if (pSimple == NULL) {
1307 /**/ printk (KERN_WARNING MYNAM "/%s: No buckets posted\n",
1308 /**/ __FUNCTION__);
1309 mpt_free_msg_frame(mpt_dev, mf);
1310 goto out;
1313 pSimple->FlagsLength |= cpu_to_le32(MPI_SGE_FLAGS_END_OF_LIST << MPI_SGE_FLAGS_SHIFT);
1315 pRecvReq->BucketCount = cpu_to_le32(i);
1317 /* printk(KERN_INFO MYNAM ": posting buckets\n ");
1318 * for (i = 0; i < j + 2; i ++)
1319 * printk (" %08x", le32_to_cpu(msg[i]));
1320 * printk ("\n");
1323 mpt_put_msg_frame(LanCtx, mpt_dev, mf);
1325 priv->total_posted += i;
1326 buckets -= i;
1327 atomic_add(i, &priv->buckets_out);
1330 out:
1331 dioprintk((KERN_INFO MYNAM "/%s: End_buckets = %u, priv->buckets_out = %u\n",
1332 __FUNCTION__, buckets, atomic_read(&priv->buckets_out)));
1333 dioprintk((KERN_INFO MYNAM "/%s: Posted %u buckets and received %u back\n",
1334 __FUNCTION__, priv->total_posted, priv->total_received));
1336 clear_bit(0, &priv->post_buckets_active);
1339 static void
1340 mpt_lan_post_receive_buckets_work(struct work_struct *work)
1342 mpt_lan_post_receive_buckets(container_of(work, struct mpt_lan_priv,
1343 post_buckets_task.work));
1346 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1347 static struct net_device *
1348 mpt_register_lan_device (MPT_ADAPTER *mpt_dev, int pnum)
1350 struct net_device *dev;
1351 struct mpt_lan_priv *priv;
1352 u8 HWaddr[FC_ALEN], *a;
1354 dev = alloc_fcdev(sizeof(struct mpt_lan_priv));
1355 if (!dev)
1356 return NULL;
1358 dev->mtu = MPT_LAN_MTU;
1360 priv = netdev_priv(dev);
1362 priv->dev = dev;
1363 priv->mpt_dev = mpt_dev;
1364 priv->pnum = pnum;
1366 INIT_DELAYED_WORK(&priv->post_buckets_task,
1367 mpt_lan_post_receive_buckets_work);
1368 priv->post_buckets_active = 0;
1370 dlprintk((KERN_INFO MYNAM "@%d: bucketlen = %d\n",
1371 __LINE__, dev->mtu + dev->hard_header_len + 4));
1373 atomic_set(&priv->buckets_out, 0);
1374 priv->total_posted = 0;
1375 priv->total_received = 0;
1376 priv->max_buckets_out = max_buckets_out;
1377 if (mpt_dev->pfacts[0].MaxLanBuckets < max_buckets_out)
1378 priv->max_buckets_out = mpt_dev->pfacts[0].MaxLanBuckets;
1380 dlprintk((KERN_INFO MYNAM "@%d: MaxLanBuckets=%d, max_buckets_out/priv=%d/%d\n",
1381 __LINE__,
1382 mpt_dev->pfacts[0].MaxLanBuckets,
1383 max_buckets_out,
1384 priv->max_buckets_out));
1386 priv->bucketthresh = priv->max_buckets_out * 2 / 3;
1387 spin_lock_init(&priv->txfidx_lock);
1388 spin_lock_init(&priv->rxfidx_lock);
1390 /* Grab pre-fetched LANPage1 stuff. :-) */
1391 a = (u8 *) &mpt_dev->lan_cnfg_page1.HardwareAddressLow;
1393 HWaddr[0] = a[5];
1394 HWaddr[1] = a[4];
1395 HWaddr[2] = a[3];
1396 HWaddr[3] = a[2];
1397 HWaddr[4] = a[1];
1398 HWaddr[5] = a[0];
1400 dev->addr_len = FC_ALEN;
1401 memcpy(dev->dev_addr, HWaddr, FC_ALEN);
1402 memset(dev->broadcast, 0xff, FC_ALEN);
1404 /* The Tx queue is 127 deep on the 909.
1405 * Give ourselves some breathing room.
1407 priv->tx_max_out = (tx_max_out_p <= MPT_TX_MAX_OUT_LIM) ?
1408 tx_max_out_p : MPT_TX_MAX_OUT_LIM;
1410 dev->open = mpt_lan_open;
1411 dev->stop = mpt_lan_close;
1412 dev->get_stats = mpt_lan_get_stats;
1413 dev->set_multicast_list = NULL;
1414 dev->change_mtu = mpt_lan_change_mtu;
1415 dev->hard_start_xmit = mpt_lan_sdu_send;
1417 /* Not in 2.3.42. Need 2.3.45+ */
1418 dev->tx_timeout = mpt_lan_tx_timeout;
1419 dev->watchdog_timeo = MPT_LAN_TX_TIMEOUT;
1421 dlprintk((KERN_INFO MYNAM ": Finished registering dev "
1422 "and setting initial values\n"));
1424 if (register_netdev(dev) != 0) {
1425 free_netdev(dev);
1426 dev = NULL;
1428 return dev;
1431 static int
1432 mptlan_probe(struct pci_dev *pdev, const struct pci_device_id *id)
1434 MPT_ADAPTER *ioc = pci_get_drvdata(pdev);
1435 struct net_device *dev;
1436 int i;
1438 for (i = 0; i < ioc->facts.NumberOfPorts; i++) {
1439 printk(KERN_INFO MYNAM ": %s: PortNum=%x, "
1440 "ProtocolFlags=%02Xh (%c%c%c%c)\n",
1441 ioc->name, ioc->pfacts[i].PortNumber,
1442 ioc->pfacts[i].ProtocolFlags,
1443 MPT_PROTOCOL_FLAGS_c_c_c_c(
1444 ioc->pfacts[i].ProtocolFlags));
1446 if (!(ioc->pfacts[i].ProtocolFlags &
1447 MPI_PORTFACTS_PROTOCOL_LAN)) {
1448 printk(KERN_INFO MYNAM ": %s: Hmmm... LAN protocol "
1449 "seems to be disabled on this adapter port!\n",
1450 ioc->name);
1451 continue;
1454 dev = mpt_register_lan_device(ioc, i);
1455 if (!dev) {
1456 printk(KERN_ERR MYNAM ": %s: Unable to register "
1457 "port%d as a LAN device\n", ioc->name,
1458 ioc->pfacts[i].PortNumber);
1459 continue;
1462 printk(KERN_INFO MYNAM ": %s: Fusion MPT LAN device "
1463 "registered as '%s'\n", ioc->name, dev->name);
1464 printk(KERN_INFO MYNAM ": %s/%s: "
1465 "LanAddr = %02X:%02X:%02X:%02X:%02X:%02X\n",
1466 IOC_AND_NETDEV_NAMES_s_s(dev),
1467 dev->dev_addr[0], dev->dev_addr[1],
1468 dev->dev_addr[2], dev->dev_addr[3],
1469 dev->dev_addr[4], dev->dev_addr[5]);
1471 ioc->netdev = dev;
1473 return 0;
1476 return -ENODEV;
1479 static void
1480 mptlan_remove(struct pci_dev *pdev)
1482 MPT_ADAPTER *ioc = pci_get_drvdata(pdev);
1483 struct net_device *dev = ioc->netdev;
1485 if(dev != NULL) {
1486 unregister_netdev(dev);
1487 free_netdev(dev);
1491 static struct mpt_pci_driver mptlan_driver = {
1492 .probe = mptlan_probe,
1493 .remove = mptlan_remove,
1496 static int __init mpt_lan_init (void)
1498 show_mptmod_ver(LANAME, LANVER);
1500 if ((LanCtx = mpt_register(lan_reply, MPTLAN_DRIVER)) <= 0) {
1501 printk (KERN_ERR MYNAM ": Failed to register with MPT base driver\n");
1502 return -EBUSY;
1505 dlprintk((KERN_INFO MYNAM ": assigned context of %d\n", LanCtx));
1507 if (mpt_reset_register(LanCtx, mpt_lan_ioc_reset)) {
1508 printk(KERN_ERR MYNAM ": Eieee! unable to register a reset "
1509 "handler with mptbase! The world is at an end! "
1510 "Everything is fading to black! Goodbye.\n");
1511 return -EBUSY;
1514 dlprintk((KERN_INFO MYNAM ": Registered for IOC reset notifications\n"));
1516 mpt_device_driver_register(&mptlan_driver, MPTLAN_DRIVER);
1517 return 0;
1520 static void __exit mpt_lan_exit(void)
1522 mpt_device_driver_deregister(MPTLAN_DRIVER);
1523 mpt_reset_deregister(LanCtx);
1525 if (LanCtx) {
1526 mpt_deregister(LanCtx);
1527 LanCtx = MPT_MAX_PROTOCOL_DRIVERS;
1531 module_init(mpt_lan_init);
1532 module_exit(mpt_lan_exit);
1534 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1535 static unsigned short
1536 mpt_lan_type_trans(struct sk_buff *skb, struct net_device *dev)
1538 struct mpt_lan_ohdr *fch = (struct mpt_lan_ohdr *)skb->data;
1539 struct fcllc *fcllc;
1541 skb_reset_mac_header(skb);
1542 skb_pull(skb, sizeof(struct mpt_lan_ohdr));
1544 if (fch->dtype == htons(0xffff)) {
1545 u32 *p = (u32 *) fch;
1547 swab32s(p + 0);
1548 swab32s(p + 1);
1549 swab32s(p + 2);
1550 swab32s(p + 3);
1552 printk (KERN_WARNING MYNAM ": %s: WARNING - Broadcast swap F/W bug detected!\n",
1553 NETDEV_PTR_TO_IOC_NAME_s(dev));
1554 printk (KERN_WARNING MYNAM ": Please update sender @ MAC_addr = %02x:%02x:%02x:%02x:%02x:%02x\n",
1555 fch->saddr[0], fch->saddr[1], fch->saddr[2],
1556 fch->saddr[3], fch->saddr[4], fch->saddr[5]);
1559 if (*fch->daddr & 1) {
1560 if (!memcmp(fch->daddr, dev->broadcast, FC_ALEN)) {
1561 skb->pkt_type = PACKET_BROADCAST;
1562 } else {
1563 skb->pkt_type = PACKET_MULTICAST;
1565 } else {
1566 if (memcmp(fch->daddr, dev->dev_addr, FC_ALEN)) {
1567 skb->pkt_type = PACKET_OTHERHOST;
1568 } else {
1569 skb->pkt_type = PACKET_HOST;
1573 fcllc = (struct fcllc *)skb->data;
1575 #ifdef QLOGIC_NAA_WORKAROUND
1577 u16 source_naa = fch->stype, found = 0;
1579 /* Workaround for QLogic not following RFC 2625 in regards to the NAA
1580 value. */
1582 if ((source_naa & 0xF000) == 0)
1583 source_naa = swab16(source_naa);
1585 if (fcllc->ethertype == htons(ETH_P_ARP))
1586 dlprintk ((KERN_INFO "mptlan/type_trans: got arp req/rep w/ naa of "
1587 "%04x.\n", source_naa));
1589 if ((fcllc->ethertype == htons(ETH_P_ARP)) &&
1590 ((source_naa >> 12) != MPT_LAN_NAA_RFC2625)){
1591 struct NAA_Hosed *nh, *prevnh;
1592 int i;
1594 dlprintk ((KERN_INFO "mptlan/type_trans: ARP Req/Rep from "
1595 "system with non-RFC 2625 NAA value (%04x).\n",
1596 source_naa));
1598 write_lock_irq(&bad_naa_lock);
1599 for (prevnh = nh = mpt_bad_naa; nh != NULL;
1600 prevnh=nh, nh=nh->next) {
1601 if ((nh->ieee[0] == fch->saddr[0]) &&
1602 (nh->ieee[1] == fch->saddr[1]) &&
1603 (nh->ieee[2] == fch->saddr[2]) &&
1604 (nh->ieee[3] == fch->saddr[3]) &&
1605 (nh->ieee[4] == fch->saddr[4]) &&
1606 (nh->ieee[5] == fch->saddr[5])) {
1607 found = 1;
1608 dlprintk ((KERN_INFO "mptlan/type_trans: ARP Re"
1609 "q/Rep w/ bad NAA from system already"
1610 " in DB.\n"));
1611 break;
1615 if ((!found) && (nh == NULL)) {
1617 nh = kmalloc(sizeof(struct NAA_Hosed), GFP_KERNEL);
1618 dlprintk ((KERN_INFO "mptlan/type_trans: ARP Req/Rep w/"
1619 " bad NAA from system not yet in DB.\n"));
1621 if (nh != NULL) {
1622 nh->next = NULL;
1623 if (!mpt_bad_naa)
1624 mpt_bad_naa = nh;
1625 if (prevnh)
1626 prevnh->next = nh;
1628 nh->NAA = source_naa; /* Set the S_NAA value. */
1629 for (i = 0; i < FC_ALEN; i++)
1630 nh->ieee[i] = fch->saddr[i];
1631 dlprintk ((KERN_INFO "Got ARP from %02x:%02x:%02x:%02x:"
1632 "%02x:%02x with non-compliant S_NAA value.\n",
1633 fch->saddr[0], fch->saddr[1], fch->saddr[2],
1634 fch->saddr[3], fch->saddr[4],fch->saddr[5]));
1635 } else {
1636 printk (KERN_ERR "mptlan/type_trans: Unable to"
1637 " kmalloc a NAA_Hosed struct.\n");
1639 } else if (!found) {
1640 printk (KERN_ERR "mptlan/type_trans: found not"
1641 " set, but nh isn't null. Evil "
1642 "funkiness abounds.\n");
1644 write_unlock_irq(&bad_naa_lock);
1647 #endif
1649 /* Strip the SNAP header from ARP packets since we don't
1650 * pass them through to the 802.2/SNAP layers.
1652 if (fcllc->dsap == EXTENDED_SAP &&
1653 (fcllc->ethertype == htons(ETH_P_IP) ||
1654 fcllc->ethertype == htons(ETH_P_ARP))) {
1655 skb_pull(skb, sizeof(struct fcllc));
1656 return fcllc->ethertype;
1659 return htons(ETH_P_802_2);
1662 /*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/