]> git.proxmox.com Git - mirror_ubuntu-bionic-kernel.git/blame - drivers/message/fusion/mptlan.c
[TCP]: Use skb_set_mac_header in tcp_collapse
[mirror_ubuntu-bionic-kernel.git] / drivers / message / fusion / mptlan.c
CommitLineData
1da177e4
LT
1/*
2 * linux/drivers/message/fusion/mptlan.c
3 * IP Over Fibre Channel device driver.
748b77b1 4 * For use with LSI Logic Fibre Channel PCI chip/adapters
1da177e4
LT
5 * running LSI Logic Fusion MPT (Message Passing Technology) firmware.
6 *
9f4203b3 7 * Copyright (c) 2000-2007 LSI Logic Corporation
07c861d6 8 * (mailto:mpt_linux_developer@lsi.com)
1da177e4 9 *
1da177e4
LT
10 */
11/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
12/*
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.
16
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.
21
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.
32
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
41
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
45*/
46
47/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
48/*
49 * Define statements used for debugging
50 */
51//#define MPT_LAN_IO_DEBUG
52
53/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
54
55#include "mptlan.h"
56#include <linux/init.h>
57#include <linux/module.h>
58#include <linux/fs.h>
59
9f4203b3 60#define my_VERSION MPT_LINUX_VERSION_COMMON
1da177e4
LT
61#define MYNAM "mptlan"
62
63MODULE_LICENSE("GPL");
9f4203b3 64MODULE_VERSION(my_VERSION);
1da177e4
LT
65
66/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
67/*
68 * MPT LAN message sizes without variable part.
69 */
70#define MPT_LAN_RECEIVE_POST_REQUEST_SIZE \
71 (sizeof(LANReceivePostRequest_t) - sizeof(SGE_MPI_UNION))
72
73#define MPT_LAN_TRANSACTION32_SIZE \
74 (sizeof(SGETransaction32_t) - sizeof(u32))
75
76/*
77 * Fusion MPT LAN private structures
78 */
79
80struct NAA_Hosed {
81 u16 NAA;
82 u8 ieee[FC_ALEN];
83 struct NAA_Hosed *next;
84};
85
86struct BufferControl {
87 struct sk_buff *skb;
88 dma_addr_t dma;
89 unsigned int len;
90};
91
92struct mpt_lan_priv {
93 MPT_ADAPTER *mpt_dev;
94 u8 pnum; /* Port number in the IOC. This is not a Unix network port! */
95
96 atomic_t buckets_out; /* number of unused buckets on IOC */
97 int bucketthresh; /* Send more when this many left */
98
99 int *mpt_txfidx; /* Free Tx Context list */
100 int mpt_txfidx_tail;
101 spinlock_t txfidx_lock;
102
103 int *mpt_rxfidx; /* Free Rx Context list */
104 int mpt_rxfidx_tail;
105 spinlock_t rxfidx_lock;
106
107 struct BufferControl *RcvCtl; /* Receive BufferControl structs */
108 struct BufferControl *SendCtl; /* Send BufferControl structs */
109
110 int max_buckets_out; /* Max buckets to send to IOC */
111 int tx_max_out; /* IOC's Tx queue len */
112
113 u32 total_posted;
114 u32 total_received;
115 struct net_device_stats stats; /* Per device statistics */
116
c4028958
DH
117 struct delayed_work post_buckets_task;
118 struct net_device *dev;
1da177e4
LT
119 unsigned long post_buckets_active;
120};
121
122struct mpt_lan_ohdr {
123 u16 dtype;
124 u8 daddr[FC_ALEN];
125 u16 stype;
126 u8 saddr[FC_ALEN];
127};
128
129/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
130
131/*
132 * Forward protos...
133 */
134static int lan_reply (MPT_ADAPTER *ioc, MPT_FRAME_HDR *mf,
135 MPT_FRAME_HDR *reply);
136static int mpt_lan_open(struct net_device *dev);
137static int mpt_lan_reset(struct net_device *dev);
138static int mpt_lan_close(struct net_device *dev);
c4028958 139static void mpt_lan_post_receive_buckets(struct mpt_lan_priv *priv);
1da177e4
LT
140static void mpt_lan_wake_post_buckets_task(struct net_device *dev,
141 int priority);
142static int mpt_lan_receive_post_turbo(struct net_device *dev, u32 tmsg);
143static int mpt_lan_receive_post_reply(struct net_device *dev,
144 LANReceivePostReply_t *pRecvRep);
145static int mpt_lan_send_turbo(struct net_device *dev, u32 tmsg);
146static int mpt_lan_send_reply(struct net_device *dev,
147 LANSendReply_t *pSendRep);
148static int mpt_lan_ioc_reset(MPT_ADAPTER *ioc, int reset_phase);
149static int mpt_lan_event_process(MPT_ADAPTER *ioc, EventNotificationReply_t *pEvReply);
150static unsigned short mpt_lan_type_trans(struct sk_buff *skb,
151 struct net_device *dev);
152
153/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
154/*
155 * Fusion MPT LAN private data
156 */
157static int LanCtx = -1;
158
159static u32 max_buckets_out = 127;
160static u32 tx_max_out_p = 127 - 16;
161
162#ifdef QLOGIC_NAA_WORKAROUND
163static struct NAA_Hosed *mpt_bad_naa = NULL;
164DEFINE_RWLOCK(bad_naa_lock);
165#endif
166
167/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
168/*
169 * Fusion MPT LAN external data
170 */
171extern int mpt_lan_index;
172
173/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
174/**
175 * lan_reply - Handle all data sent from the hardware.
176 * @ioc: Pointer to MPT_ADAPTER structure
177 * @mf: Pointer to original MPT request frame (NULL if TurboReply)
178 * @reply: Pointer to MPT reply frame
179 *
180 * Returns 1 indicating original alloc'd request frame ptr
181 * should be freed, or 0 if it shouldn't.
182 */
183static int
184lan_reply (MPT_ADAPTER *ioc, MPT_FRAME_HDR *mf, MPT_FRAME_HDR *reply)
185{
186 struct net_device *dev = ioc->netdev;
187 int FreeReqFrame = 0;
188
189 dioprintk((KERN_INFO MYNAM ": %s/%s: Got reply.\n",
190 IOC_AND_NETDEV_NAMES_s_s(dev)));
191
192// dioprintk((KERN_INFO MYNAM "@lan_reply: mf = %p, reply = %p\n",
193// mf, reply));
194
195 if (mf == NULL) {
196 u32 tmsg = CAST_PTR_TO_U32(reply);
197
198 dioprintk((KERN_INFO MYNAM ": %s/%s: @lan_reply, tmsg %08x\n",
199 IOC_AND_NETDEV_NAMES_s_s(dev),
200 tmsg));
201
202 switch (GET_LAN_FORM(tmsg)) {
203
204 // NOTE! (Optimization) First case here is now caught in
205 // mptbase.c::mpt_interrupt() routine and callcack here
748b77b1 206 // is now skipped for this case!
1da177e4
LT
207#if 0
208 case LAN_REPLY_FORM_MESSAGE_CONTEXT:
209// dioprintk((KERN_INFO MYNAM "/lan_reply: "
210// "MessageContext turbo reply received\n"));
211 FreeReqFrame = 1;
212 break;
213#endif
214
215 case LAN_REPLY_FORM_SEND_SINGLE:
216// dioprintk((MYNAM "/lan_reply: "
217// "calling mpt_lan_send_reply (turbo)\n"));
218
748b77b1 219 // Potential BUG here?
1da177e4
LT
220 // FreeReqFrame = mpt_lan_send_turbo(dev, tmsg);
221 // If/when mpt_lan_send_turbo would return 1 here,
222 // calling routine (mptbase.c|mpt_interrupt)
223 // would Oops because mf has already been set
224 // to NULL. So after return from this func,
225 // mpt_interrupt() will attempt to put (NULL) mf ptr
226 // item back onto its adapter FreeQ - Oops!:-(
227 // It's Ok, since mpt_lan_send_turbo() *currently*
228 // always returns 0, but..., just in case:
229
230 (void) mpt_lan_send_turbo(dev, tmsg);
231 FreeReqFrame = 0;
232
233 break;
234
235 case LAN_REPLY_FORM_RECEIVE_SINGLE:
236// dioprintk((KERN_INFO MYNAM "@lan_reply: "
237// "rcv-Turbo = %08x\n", tmsg));
238 mpt_lan_receive_post_turbo(dev, tmsg);
239 break;
240
241 default:
242 printk (KERN_ERR MYNAM "/lan_reply: Got a turbo reply "
243 "that I don't know what to do with\n");
244
245 /* CHECKME! Hmmm... FreeReqFrame is 0 here; is that right? */
246
247 break;
248 }
249
250 return FreeReqFrame;
251 }
252
253// msg = (u32 *) reply;
254// dioprintk((KERN_INFO MYNAM "@lan_reply: msg = %08x %08x %08x %08x\n",
255// le32_to_cpu(msg[0]), le32_to_cpu(msg[1]),
256// le32_to_cpu(msg[2]), le32_to_cpu(msg[3])));
257// dioprintk((KERN_INFO MYNAM "@lan_reply: Function = %02xh\n",
258// reply->u.hdr.Function));
259
260 switch (reply->u.hdr.Function) {
261
262 case MPI_FUNCTION_LAN_SEND:
263 {
264 LANSendReply_t *pSendRep;
265
266 pSendRep = (LANSendReply_t *) reply;
267 FreeReqFrame = mpt_lan_send_reply(dev, pSendRep);
268 break;
269 }
270
271 case MPI_FUNCTION_LAN_RECEIVE:
272 {
273 LANReceivePostReply_t *pRecvRep;
274
275 pRecvRep = (LANReceivePostReply_t *) reply;
276 if (pRecvRep->NumberOfContexts) {
277 mpt_lan_receive_post_reply(dev, pRecvRep);
278 if (!(pRecvRep->MsgFlags & MPI_MSGFLAGS_CONTINUATION_REPLY))
279 FreeReqFrame = 1;
280 } else
281 dioprintk((KERN_INFO MYNAM "@lan_reply: zero context "
282 "ReceivePostReply received.\n"));
283 break;
284 }
285
286 case MPI_FUNCTION_LAN_RESET:
287 /* Just a default reply. Might want to check it to
288 * make sure that everything went ok.
289 */
290 FreeReqFrame = 1;
291 break;
292
293 case MPI_FUNCTION_EVENT_NOTIFICATION:
294 case MPI_FUNCTION_EVENT_ACK:
748b77b1 295 /* _EVENT_NOTIFICATION should NOT come down this path any more.
1da177e4
LT
296 * Should be routed to mpt_lan_event_process(), but just in case...
297 */
298 FreeReqFrame = 1;
299 break;
300
301 default:
302 printk (KERN_ERR MYNAM "/lan_reply: Got a non-turbo "
303 "reply that I don't know what to do with\n");
304
305 /* CHECKME! Hmmm... FreeReqFrame is 0 here; is that right? */
306 FreeReqFrame = 1;
307
308 break;
309 }
310
311 return FreeReqFrame;
312}
313
314/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
315static int
316mpt_lan_ioc_reset(MPT_ADAPTER *ioc, int reset_phase)
317{
318 struct net_device *dev = ioc->netdev;
466544d8
MED
319 struct mpt_lan_priv *priv;
320
321 if (dev == NULL)
322 return(1);
323 else
324 priv = netdev_priv(dev);
1da177e4
LT
325
326 dlprintk((KERN_INFO MYNAM ": IOC %s_reset routed to LAN driver!\n",
327 reset_phase==MPT_IOC_SETUP_RESET ? "setup" : (
328 reset_phase==MPT_IOC_PRE_RESET ? "pre" : "post")));
329
330 if (priv->mpt_rxfidx == NULL)
331 return (1);
332
333 if (reset_phase == MPT_IOC_SETUP_RESET) {
334 ;
335 } else if (reset_phase == MPT_IOC_PRE_RESET) {
336 int i;
337 unsigned long flags;
338
339 netif_stop_queue(dev);
340
341 dlprintk ((KERN_INFO "mptlan/ioc_reset: called netif_stop_queue for %s.\n", dev->name));
342
343 atomic_set(&priv->buckets_out, 0);
344
345 /* Reset Rx Free Tail index and re-populate the queue. */
346 spin_lock_irqsave(&priv->rxfidx_lock, flags);
347 priv->mpt_rxfidx_tail = -1;
348 for (i = 0; i < priv->max_buckets_out; i++)
349 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = i;
350 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
351 } else {
c4028958 352 mpt_lan_post_receive_buckets(priv);
1da177e4
LT
353 netif_wake_queue(dev);
354 }
355
356 return 1;
357}
358
359/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
360static int
361mpt_lan_event_process(MPT_ADAPTER *ioc, EventNotificationReply_t *pEvReply)
362{
363 dlprintk((KERN_INFO MYNAM ": MPT event routed to LAN driver!\n"));
364
365 switch (le32_to_cpu(pEvReply->Event)) {
366 case MPI_EVENT_NONE: /* 00 */
367 case MPI_EVENT_LOG_DATA: /* 01 */
368 case MPI_EVENT_STATE_CHANGE: /* 02 */
369 case MPI_EVENT_UNIT_ATTENTION: /* 03 */
370 case MPI_EVENT_IOC_BUS_RESET: /* 04 */
371 case MPI_EVENT_EXT_BUS_RESET: /* 05 */
372 case MPI_EVENT_RESCAN: /* 06 */
373 /* Ok, do we need to do anything here? As far as
374 I can tell, this is when a new device gets added
375 to the loop. */
376 case MPI_EVENT_LINK_STATUS_CHANGE: /* 07 */
377 case MPI_EVENT_LOOP_STATE_CHANGE: /* 08 */
378 case MPI_EVENT_LOGOUT: /* 09 */
379 case MPI_EVENT_EVENT_CHANGE: /* 0A */
380 default:
381 break;
382 }
383
384 /*
385 * NOTE: pEvent->AckRequired handling now done in mptbase.c;
386 * Do NOT do it here now!
387 */
388
389 return 1;
390}
391
392/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
393static int
394mpt_lan_open(struct net_device *dev)
395{
396 struct mpt_lan_priv *priv = netdev_priv(dev);
397 int i;
398
399 if (mpt_lan_reset(dev) != 0) {
400 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
401
402 printk (KERN_WARNING MYNAM "/lan_open: lan_reset failed.");
403
404 if (mpt_dev->active)
405 printk ("The ioc is active. Perhaps it needs to be"
406 " reset?\n");
407 else
408 printk ("The ioc in inactive, most likely in the "
409 "process of being reset. Please try again in "
410 "a moment.\n");
411 }
412
413 priv->mpt_txfidx = kmalloc(priv->tx_max_out * sizeof(int), GFP_KERNEL);
414 if (priv->mpt_txfidx == NULL)
415 goto out;
416 priv->mpt_txfidx_tail = -1;
417
1ca00bb7 418 priv->SendCtl = kcalloc(priv->tx_max_out, sizeof(struct BufferControl),
1da177e4
LT
419 GFP_KERNEL);
420 if (priv->SendCtl == NULL)
421 goto out_mpt_txfidx;
1ca00bb7 422 for (i = 0; i < priv->tx_max_out; i++)
1da177e4 423 priv->mpt_txfidx[++priv->mpt_txfidx_tail] = i;
1da177e4
LT
424
425 dlprintk((KERN_INFO MYNAM "@lo: Finished initializing SendCtl\n"));
426
427 priv->mpt_rxfidx = kmalloc(priv->max_buckets_out * sizeof(int),
428 GFP_KERNEL);
429 if (priv->mpt_rxfidx == NULL)
430 goto out_SendCtl;
431 priv->mpt_rxfidx_tail = -1;
432
1ca00bb7
CH
433 priv->RcvCtl = kcalloc(priv->max_buckets_out,
434 sizeof(struct BufferControl),
1da177e4
LT
435 GFP_KERNEL);
436 if (priv->RcvCtl == NULL)
437 goto out_mpt_rxfidx;
1ca00bb7 438 for (i = 0; i < priv->max_buckets_out; i++)
1da177e4 439 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = i;
1da177e4
LT
440
441/**/ dlprintk((KERN_INFO MYNAM "/lo: txfidx contains - "));
442/**/ for (i = 0; i < priv->tx_max_out; i++)
443/**/ dlprintk((" %xh", priv->mpt_txfidx[i]));
444/**/ dlprintk(("\n"));
445
446 dlprintk((KERN_INFO MYNAM "/lo: Finished initializing RcvCtl\n"));
447
c4028958 448 mpt_lan_post_receive_buckets(priv);
1da177e4
LT
449 printk(KERN_INFO MYNAM ": %s/%s: interface up & active\n",
450 IOC_AND_NETDEV_NAMES_s_s(dev));
451
452 if (mpt_event_register(LanCtx, mpt_lan_event_process) != 0) {
453 printk (KERN_WARNING MYNAM "/lo: Unable to register for Event"
454 " Notifications. This is a bad thing! We're not going "
455 "to go ahead, but I'd be leery of system stability at "
456 "this point.\n");
457 }
458
459 netif_start_queue(dev);
460 dlprintk((KERN_INFO MYNAM "/lo: Done.\n"));
461
462 return 0;
463out_mpt_rxfidx:
464 kfree(priv->mpt_rxfidx);
465 priv->mpt_rxfidx = NULL;
466out_SendCtl:
467 kfree(priv->SendCtl);
468 priv->SendCtl = NULL;
469out_mpt_txfidx:
470 kfree(priv->mpt_txfidx);
471 priv->mpt_txfidx = NULL;
472out: return -ENOMEM;
473}
474
475/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
476/* Send a LanReset message to the FW. This should result in the FW returning
477 any buckets it still has. */
478static int
479mpt_lan_reset(struct net_device *dev)
480{
481 MPT_FRAME_HDR *mf;
482 LANResetRequest_t *pResetReq;
483 struct mpt_lan_priv *priv = netdev_priv(dev);
484
485 mf = mpt_get_msg_frame(LanCtx, priv->mpt_dev);
486
487 if (mf == NULL) {
488/* dlprintk((KERN_ERR MYNAM "/reset: Evil funkiness abounds! "
489 "Unable to allocate a request frame.\n"));
490*/
491 return -1;
492 }
493
494 pResetReq = (LANResetRequest_t *) mf;
495
496 pResetReq->Function = MPI_FUNCTION_LAN_RESET;
497 pResetReq->ChainOffset = 0;
498 pResetReq->Reserved = 0;
499 pResetReq->PortNumber = priv->pnum;
500 pResetReq->MsgFlags = 0;
501 pResetReq->Reserved2 = 0;
502
503 mpt_put_msg_frame(LanCtx, priv->mpt_dev, mf);
504
505 return 0;
506}
507
508/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
509static int
510mpt_lan_close(struct net_device *dev)
511{
512 struct mpt_lan_priv *priv = netdev_priv(dev);
513 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
6521018d 514 unsigned long timeout;
1da177e4
LT
515 int i;
516
517 dlprintk((KERN_INFO MYNAM ": mpt_lan_close called\n"));
518
519 mpt_event_deregister(LanCtx);
520
521 dlprintk((KERN_INFO MYNAM ":lan_close: Posted %d buckets "
522 "since driver was loaded, %d still out\n",
523 priv->total_posted,atomic_read(&priv->buckets_out)));
524
525 netif_stop_queue(dev);
526
527 mpt_lan_reset(dev);
528
6521018d
NA
529 timeout = jiffies + 2 * HZ;
530 while (atomic_read(&priv->buckets_out) && time_before(jiffies, timeout))
531 schedule_timeout_interruptible(1);
1da177e4
LT
532
533 for (i = 0; i < priv->max_buckets_out; i++) {
534 if (priv->RcvCtl[i].skb != NULL) {
535/**/ dlprintk((KERN_INFO MYNAM "/lan_close: bucket %05x "
536/**/ "is still out\n", i));
537 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[i].dma,
538 priv->RcvCtl[i].len,
539 PCI_DMA_FROMDEVICE);
540 dev_kfree_skb(priv->RcvCtl[i].skb);
541 }
542 }
543
d485eb83
MED
544 kfree(priv->RcvCtl);
545 kfree(priv->mpt_rxfidx);
1da177e4
LT
546
547 for (i = 0; i < priv->tx_max_out; i++) {
548 if (priv->SendCtl[i].skb != NULL) {
549 pci_unmap_single(mpt_dev->pcidev, priv->SendCtl[i].dma,
550 priv->SendCtl[i].len,
551 PCI_DMA_TODEVICE);
552 dev_kfree_skb(priv->SendCtl[i].skb);
553 }
554 }
555
556 kfree(priv->SendCtl);
557 kfree(priv->mpt_txfidx);
558
559 atomic_set(&priv->buckets_out, 0);
560
561 printk(KERN_INFO MYNAM ": %s/%s: interface down & inactive\n",
562 IOC_AND_NETDEV_NAMES_s_s(dev));
563
564 return 0;
565}
566
567/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
568static struct net_device_stats *
569mpt_lan_get_stats(struct net_device *dev)
570{
571 struct mpt_lan_priv *priv = netdev_priv(dev);
572
573 return (struct net_device_stats *) &priv->stats;
574}
575
576/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
577static int
578mpt_lan_change_mtu(struct net_device *dev, int new_mtu)
579{
580 if ((new_mtu < MPT_LAN_MIN_MTU) || (new_mtu > MPT_LAN_MAX_MTU))
581 return -EINVAL;
582 dev->mtu = new_mtu;
583 return 0;
584}
585
586/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
587/* Tx timeout handler. */
588static void
589mpt_lan_tx_timeout(struct net_device *dev)
590{
591 struct mpt_lan_priv *priv = netdev_priv(dev);
592 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
593
594 if (mpt_dev->active) {
595 dlprintk (("mptlan/tx_timeout: calling netif_wake_queue for %s.\n", dev->name));
596 netif_wake_queue(dev);
597 }
598}
599
600/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
601//static inline int
602static int
603mpt_lan_send_turbo(struct net_device *dev, u32 tmsg)
604{
605 struct mpt_lan_priv *priv = netdev_priv(dev);
606 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
607 struct sk_buff *sent;
608 unsigned long flags;
609 u32 ctx;
610
611 ctx = GET_LAN_BUFFER_CONTEXT(tmsg);
612 sent = priv->SendCtl[ctx].skb;
613
614 priv->stats.tx_packets++;
615 priv->stats.tx_bytes += sent->len;
616
617 dioprintk((KERN_INFO MYNAM ": %s/%s: @%s, skb %p sent.\n",
618 IOC_AND_NETDEV_NAMES_s_s(dev),
619 __FUNCTION__, sent));
620
621 priv->SendCtl[ctx].skb = NULL;
622 pci_unmap_single(mpt_dev->pcidev, priv->SendCtl[ctx].dma,
623 priv->SendCtl[ctx].len, PCI_DMA_TODEVICE);
624 dev_kfree_skb_irq(sent);
625
626 spin_lock_irqsave(&priv->txfidx_lock, flags);
627 priv->mpt_txfidx[++priv->mpt_txfidx_tail] = ctx;
628 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
629
630 netif_wake_queue(dev);
631 return 0;
632}
633
634/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
635static int
636mpt_lan_send_reply(struct net_device *dev, LANSendReply_t *pSendRep)
637{
638 struct mpt_lan_priv *priv = netdev_priv(dev);
639 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
640 struct sk_buff *sent;
641 unsigned long flags;
642 int FreeReqFrame = 0;
643 u32 *pContext;
644 u32 ctx;
645 u8 count;
646
647 count = pSendRep->NumberOfContexts;
648
649 dioprintk((KERN_INFO MYNAM ": send_reply: IOCStatus: %04x\n",
650 le16_to_cpu(pSendRep->IOCStatus)));
651
652 /* Add check for Loginfo Flag in IOCStatus */
653
654 switch (le16_to_cpu(pSendRep->IOCStatus) & MPI_IOCSTATUS_MASK) {
655 case MPI_IOCSTATUS_SUCCESS:
656 priv->stats.tx_packets += count;
657 break;
658
659 case MPI_IOCSTATUS_LAN_CANCELED:
660 case MPI_IOCSTATUS_LAN_TRANSMIT_ABORTED:
661 break;
662
663 case MPI_IOCSTATUS_INVALID_SGL:
664 priv->stats.tx_errors += count;
665 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Invalid SGL sent to IOC!\n",
666 IOC_AND_NETDEV_NAMES_s_s(dev));
667 goto out;
668
669 default:
670 priv->stats.tx_errors += count;
671 break;
672 }
673
674 pContext = &pSendRep->BufferContext;
675
676 spin_lock_irqsave(&priv->txfidx_lock, flags);
677 while (count > 0) {
678 ctx = GET_LAN_BUFFER_CONTEXT(le32_to_cpu(*pContext));
679
680 sent = priv->SendCtl[ctx].skb;
681 priv->stats.tx_bytes += sent->len;
682
683 dioprintk((KERN_INFO MYNAM ": %s/%s: @%s, skb %p sent.\n",
684 IOC_AND_NETDEV_NAMES_s_s(dev),
685 __FUNCTION__, sent));
686
687 priv->SendCtl[ctx].skb = NULL;
688 pci_unmap_single(mpt_dev->pcidev, priv->SendCtl[ctx].dma,
689 priv->SendCtl[ctx].len, PCI_DMA_TODEVICE);
690 dev_kfree_skb_irq(sent);
691
692 priv->mpt_txfidx[++priv->mpt_txfidx_tail] = ctx;
693
694 pContext++;
695 count--;
696 }
697 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
698
699out:
700 if (!(pSendRep->MsgFlags & MPI_MSGFLAGS_CONTINUATION_REPLY))
701 FreeReqFrame = 1;
702
703 netif_wake_queue(dev);
704 return FreeReqFrame;
705}
706
707/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
708static int
709mpt_lan_sdu_send (struct sk_buff *skb, struct net_device *dev)
710{
711 struct mpt_lan_priv *priv = netdev_priv(dev);
712 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
713 MPT_FRAME_HDR *mf;
714 LANSendRequest_t *pSendReq;
715 SGETransaction32_t *pTrans;
716 SGESimple64_t *pSimple;
717 dma_addr_t dma;
718 unsigned long flags;
719 int ctx;
720 u16 cur_naa = 0x1000;
721
722 dioprintk((KERN_INFO MYNAM ": %s called, skb_addr = %p\n",
723 __FUNCTION__, skb));
724
725 spin_lock_irqsave(&priv->txfidx_lock, flags);
726 if (priv->mpt_txfidx_tail < 0) {
727 netif_stop_queue(dev);
728 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
729
730 printk (KERN_ERR "%s: no tx context available: %u\n",
731 __FUNCTION__, priv->mpt_txfidx_tail);
732 return 1;
733 }
734
735 mf = mpt_get_msg_frame(LanCtx, mpt_dev);
736 if (mf == NULL) {
737 netif_stop_queue(dev);
738 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
739
740 printk (KERN_ERR "%s: Unable to alloc request frame\n",
741 __FUNCTION__);
742 return 1;
743 }
744
745 ctx = priv->mpt_txfidx[priv->mpt_txfidx_tail--];
746 spin_unlock_irqrestore(&priv->txfidx_lock, flags);
747
748// dioprintk((KERN_INFO MYNAM ": %s/%s: Creating new msg frame (send).\n",
749// IOC_AND_NETDEV_NAMES_s_s(dev)));
750
751 pSendReq = (LANSendRequest_t *) mf;
752
753 /* Set the mac.raw pointer, since this apparently isn't getting
754 * done before we get the skb. Pull the data pointer past the mac data.
755 */
459a98ed 756 skb_reset_mac_header(skb);
1da177e4
LT
757 skb_pull(skb, 12);
758
759 dma = pci_map_single(mpt_dev->pcidev, skb->data, skb->len,
760 PCI_DMA_TODEVICE);
761
762 priv->SendCtl[ctx].skb = skb;
763 priv->SendCtl[ctx].dma = dma;
764 priv->SendCtl[ctx].len = skb->len;
765
766 /* Message Header */
767 pSendReq->Reserved = 0;
768 pSendReq->Function = MPI_FUNCTION_LAN_SEND;
769 pSendReq->ChainOffset = 0;
770 pSendReq->Reserved2 = 0;
771 pSendReq->MsgFlags = 0;
772 pSendReq->PortNumber = priv->pnum;
773
774 /* Transaction Context Element */
775 pTrans = (SGETransaction32_t *) pSendReq->SG_List;
776
777 /* No Flags, 8 bytes of Details, 32bit Context (bloody turbo replies) */
778 pTrans->ContextSize = sizeof(u32);
779 pTrans->DetailsLength = 2 * sizeof(u32);
780 pTrans->Flags = 0;
781 pTrans->TransactionContext[0] = cpu_to_le32(ctx);
782
783// dioprintk((KERN_INFO MYNAM ": %s/%s: BC = %08x, skb = %p, buff = %p\n",
784// IOC_AND_NETDEV_NAMES_s_s(dev),
785// ctx, skb, skb->data));
786
787#ifdef QLOGIC_NAA_WORKAROUND
788{
789 struct NAA_Hosed *nh;
790
791 /* Munge the NAA for Tx packets to QLogic boards, which don't follow
792 RFC 2625. The longer I look at this, the more my opinion of Qlogic
793 drops. */
794 read_lock_irq(&bad_naa_lock);
795 for (nh = mpt_bad_naa; nh != NULL; nh=nh->next) {
796 if ((nh->ieee[0] == skb->mac.raw[0]) &&
797 (nh->ieee[1] == skb->mac.raw[1]) &&
798 (nh->ieee[2] == skb->mac.raw[2]) &&
799 (nh->ieee[3] == skb->mac.raw[3]) &&
800 (nh->ieee[4] == skb->mac.raw[4]) &&
801 (nh->ieee[5] == skb->mac.raw[5])) {
802 cur_naa = nh->NAA;
803 dlprintk ((KERN_INFO "mptlan/sdu_send: using NAA value "
804 "= %04x.\n", cur_naa));
805 break;
806 }
807 }
808 read_unlock_irq(&bad_naa_lock);
809}
810#endif
811
812 pTrans->TransactionDetails[0] = cpu_to_le32((cur_naa << 16) |
813 (skb->mac.raw[0] << 8) |
814 (skb->mac.raw[1] << 0));
815 pTrans->TransactionDetails[1] = cpu_to_le32((skb->mac.raw[2] << 24) |
816 (skb->mac.raw[3] << 16) |
817 (skb->mac.raw[4] << 8) |
818 (skb->mac.raw[5] << 0));
819
820 pSimple = (SGESimple64_t *) &pTrans->TransactionDetails[2];
821
822 /* If we ever decide to send more than one Simple SGE per LANSend, then
823 we will need to make sure that LAST_ELEMENT only gets set on the
824 last one. Otherwise, bad voodoo and evil funkiness will commence. */
825 pSimple->FlagsLength = cpu_to_le32(
826 ((MPI_SGE_FLAGS_LAST_ELEMENT |
827 MPI_SGE_FLAGS_END_OF_BUFFER |
828 MPI_SGE_FLAGS_SIMPLE_ELEMENT |
829 MPI_SGE_FLAGS_SYSTEM_ADDRESS |
830 MPI_SGE_FLAGS_HOST_TO_IOC |
831 MPI_SGE_FLAGS_64_BIT_ADDRESSING |
832 MPI_SGE_FLAGS_END_OF_LIST) << MPI_SGE_FLAGS_SHIFT) |
833 skb->len);
834 pSimple->Address.Low = cpu_to_le32((u32) dma);
835 if (sizeof(dma_addr_t) > sizeof(u32))
836 pSimple->Address.High = cpu_to_le32((u32) ((u64) dma >> 32));
837 else
838 pSimple->Address.High = 0;
839
840 mpt_put_msg_frame (LanCtx, mpt_dev, mf);
841 dev->trans_start = jiffies;
842
843 dioprintk((KERN_INFO MYNAM ": %s/%s: Sending packet. FlagsLength = %08x.\n",
844 IOC_AND_NETDEV_NAMES_s_s(dev),
845 le32_to_cpu(pSimple->FlagsLength)));
846
847 return 0;
848}
849
850/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
858119e1 851static void
1da177e4
LT
852mpt_lan_wake_post_buckets_task(struct net_device *dev, int priority)
853/*
854 * @priority: 0 = put it on the timer queue, 1 = put it on the immediate queue
855 */
856{
857 struct mpt_lan_priv *priv = dev->priv;
858
859 if (test_and_set_bit(0, &priv->post_buckets_active) == 0) {
860 if (priority) {
c4028958 861 schedule_delayed_work(&priv->post_buckets_task, 0);
1da177e4
LT
862 } else {
863 schedule_delayed_work(&priv->post_buckets_task, 1);
864 dioprintk((KERN_INFO MYNAM ": post_buckets queued on "
865 "timer.\n"));
866 }
867 dioprintk((KERN_INFO MYNAM ": %s/%s: Queued post_buckets task.\n",
868 IOC_AND_NETDEV_NAMES_s_s(dev) ));
869 }
870}
871
872/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
858119e1 873static int
1da177e4
LT
874mpt_lan_receive_skb(struct net_device *dev, struct sk_buff *skb)
875{
876 struct mpt_lan_priv *priv = dev->priv;
877
878 skb->protocol = mpt_lan_type_trans(skb, dev);
879
880 dioprintk((KERN_INFO MYNAM ": %s/%s: Incoming packet (%d bytes) "
881 "delivered to upper level.\n",
882 IOC_AND_NETDEV_NAMES_s_s(dev), skb->len));
883
884 priv->stats.rx_bytes += skb->len;
885 priv->stats.rx_packets++;
886
887 skb->dev = dev;
888 netif_rx(skb);
889
890 dioprintk((MYNAM "/receive_skb: %d buckets remaining\n",
891 atomic_read(&priv->buckets_out)));
892
893 if (atomic_read(&priv->buckets_out) < priv->bucketthresh)
894 mpt_lan_wake_post_buckets_task(dev, 1);
895
896 dioprintk((KERN_INFO MYNAM "/receive_post_reply: %d buckets "
897 "remaining, %d received back since sod\n",
898 atomic_read(&priv->buckets_out), priv->total_received));
899
900 return 0;
901}
902
903/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
904//static inline int
905static int
906mpt_lan_receive_post_turbo(struct net_device *dev, u32 tmsg)
907{
908 struct mpt_lan_priv *priv = dev->priv;
909 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
910 struct sk_buff *skb, *old_skb;
911 unsigned long flags;
912 u32 ctx, len;
913
914 ctx = GET_LAN_BUCKET_CONTEXT(tmsg);
915 skb = priv->RcvCtl[ctx].skb;
916
917 len = GET_LAN_PACKET_LENGTH(tmsg);
918
919 if (len < MPT_LAN_RX_COPYBREAK) {
920 old_skb = skb;
921
922 skb = (struct sk_buff *)dev_alloc_skb(len);
923 if (!skb) {
924 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Can't allocate skb! (%s@%d)\n",
925 IOC_AND_NETDEV_NAMES_s_s(dev),
926 __FILE__, __LINE__);
927 return -ENOMEM;
928 }
929
930 pci_dma_sync_single_for_cpu(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
931 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
932
933 memcpy(skb_put(skb, len), old_skb->data, len);
934
935 pci_dma_sync_single_for_device(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
936 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
937 goto out;
938 }
939
940 skb_put(skb, len);
941
942 priv->RcvCtl[ctx].skb = NULL;
943
944 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
945 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
946
947out:
948 spin_lock_irqsave(&priv->rxfidx_lock, flags);
949 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
950 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
951
952 atomic_dec(&priv->buckets_out);
953 priv->total_received++;
954
955 return mpt_lan_receive_skb(dev, skb);
956}
957
958/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
959static int
960mpt_lan_receive_post_free(struct net_device *dev,
961 LANReceivePostReply_t *pRecvRep)
962{
963 struct mpt_lan_priv *priv = dev->priv;
964 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
965 unsigned long flags;
966 struct sk_buff *skb;
967 u32 ctx;
968 int count;
969 int i;
970
971 count = pRecvRep->NumberOfContexts;
972
973/**/ dlprintk((KERN_INFO MYNAM "/receive_post_reply: "
974 "IOC returned %d buckets, freeing them...\n", count));
975
976 spin_lock_irqsave(&priv->rxfidx_lock, flags);
977 for (i = 0; i < count; i++) {
978 ctx = le32_to_cpu(pRecvRep->BucketContext[i]);
979
980 skb = priv->RcvCtl[ctx].skb;
981
982// dlprintk((KERN_INFO MYNAM ": %s: dev_name = %s\n",
983// IOC_AND_NETDEV_NAMES_s_s(dev)));
984// dlprintk((KERN_INFO MYNAM "@rpr[2], priv = %p, buckets_out addr = %p",
985// priv, &(priv->buckets_out)));
986// dlprintk((KERN_INFO MYNAM "@rpr[2] TC + 3\n"));
987
988 priv->RcvCtl[ctx].skb = NULL;
989 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
990 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
991 dev_kfree_skb_any(skb);
992
993 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
994 }
995 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
996
997 atomic_sub(count, &priv->buckets_out);
998
999// for (i = 0; i < priv->max_buckets_out; i++)
1000// if (priv->RcvCtl[i].skb != NULL)
1001// dlprintk((KERN_INFO MYNAM "@rpr: bucket %03x "
1002// "is still out\n", i));
1003
1004/* dlprintk((KERN_INFO MYNAM "/receive_post_reply: freed %d buckets\n",
1005 count));
1006*/
1007/**/ dlprintk((KERN_INFO MYNAM "@receive_post_reply: %d buckets "
1008/**/ "remaining, %d received back since sod.\n",
1009/**/ atomic_read(&priv->buckets_out), priv->total_received));
1010 return 0;
1011}
1012
1013/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1014static int
1015mpt_lan_receive_post_reply(struct net_device *dev,
1016 LANReceivePostReply_t *pRecvRep)
1017{
1018 struct mpt_lan_priv *priv = dev->priv;
1019 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
1020 struct sk_buff *skb, *old_skb;
1021 unsigned long flags;
1022 u32 len, ctx, offset;
1023 u32 remaining = le32_to_cpu(pRecvRep->BucketsRemaining);
1024 int count;
1025 int i, l;
1026
1027 dioprintk((KERN_INFO MYNAM ": mpt_lan_receive_post_reply called\n"));
1028 dioprintk((KERN_INFO MYNAM ": receive_post_reply: IOCStatus: %04x\n",
1029 le16_to_cpu(pRecvRep->IOCStatus)));
1030
1031 if ((le16_to_cpu(pRecvRep->IOCStatus) & MPI_IOCSTATUS_MASK) ==
1032 MPI_IOCSTATUS_LAN_CANCELED)
1033 return mpt_lan_receive_post_free(dev, pRecvRep);
1034
1035 len = le32_to_cpu(pRecvRep->PacketLength);
1036 if (len == 0) {
1037 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Got a non-TURBO "
1038 "ReceivePostReply w/ PacketLength zero!\n",
1039 IOC_AND_NETDEV_NAMES_s_s(dev));
1040 printk (KERN_ERR MYNAM ": MsgFlags = %02x, IOCStatus = %04x\n",
1041 pRecvRep->MsgFlags, le16_to_cpu(pRecvRep->IOCStatus));
1042 return -1;
1043 }
1044
1045 ctx = le32_to_cpu(pRecvRep->BucketContext[0]);
1046 count = pRecvRep->NumberOfContexts;
1047 skb = priv->RcvCtl[ctx].skb;
1048
1049 offset = le32_to_cpu(pRecvRep->PacketOffset);
1050// if (offset != 0) {
1051// printk (KERN_INFO MYNAM ": %s/%s: Got a ReceivePostReply "
1052// "w/ PacketOffset %u\n",
1053// IOC_AND_NETDEV_NAMES_s_s(dev),
1054// offset);
1055// }
1056
1057 dioprintk((KERN_INFO MYNAM ": %s/%s: @rpr, offset = %d, len = %d\n",
1058 IOC_AND_NETDEV_NAMES_s_s(dev),
1059 offset, len));
1060
1061 if (count > 1) {
1062 int szrem = len;
1063
1064// dioprintk((KERN_INFO MYNAM ": %s/%s: Multiple buckets returned "
1065// "for single packet, concatenating...\n",
1066// IOC_AND_NETDEV_NAMES_s_s(dev)));
1067
1068 skb = (struct sk_buff *)dev_alloc_skb(len);
1069 if (!skb) {
1070 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Can't allocate skb! (%s@%d)\n",
1071 IOC_AND_NETDEV_NAMES_s_s(dev),
1072 __FILE__, __LINE__);
1073 return -ENOMEM;
1074 }
1075
1076 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1077 for (i = 0; i < count; i++) {
1078
1079 ctx = le32_to_cpu(pRecvRep->BucketContext[i]);
1080 old_skb = priv->RcvCtl[ctx].skb;
1081
1082 l = priv->RcvCtl[ctx].len;
1083 if (szrem < l)
1084 l = szrem;
1085
1086// dioprintk((KERN_INFO MYNAM ": %s/%s: Buckets = %d, len = %u\n",
1087// IOC_AND_NETDEV_NAMES_s_s(dev),
1088// i, l));
1089
1090 pci_dma_sync_single_for_cpu(mpt_dev->pcidev,
1091 priv->RcvCtl[ctx].dma,
1092 priv->RcvCtl[ctx].len,
1093 PCI_DMA_FROMDEVICE);
1094 memcpy(skb_put(skb, l), old_skb->data, l);
1095
1096 pci_dma_sync_single_for_device(mpt_dev->pcidev,
1097 priv->RcvCtl[ctx].dma,
1098 priv->RcvCtl[ctx].len,
1099 PCI_DMA_FROMDEVICE);
1100
1101 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1102 szrem -= l;
1103 }
1104 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1105
1106 } else if (len < MPT_LAN_RX_COPYBREAK) {
1107
1108 old_skb = skb;
1109
1110 skb = (struct sk_buff *)dev_alloc_skb(len);
1111 if (!skb) {
1112 printk (KERN_ERR MYNAM ": %s/%s: ERROR - Can't allocate skb! (%s@%d)\n",
1113 IOC_AND_NETDEV_NAMES_s_s(dev),
1114 __FILE__, __LINE__);
1115 return -ENOMEM;
1116 }
1117
1118 pci_dma_sync_single_for_cpu(mpt_dev->pcidev,
1119 priv->RcvCtl[ctx].dma,
1120 priv->RcvCtl[ctx].len,
1121 PCI_DMA_FROMDEVICE);
1122
1123 memcpy(skb_put(skb, len), old_skb->data, len);
1124
1125 pci_dma_sync_single_for_device(mpt_dev->pcidev,
1126 priv->RcvCtl[ctx].dma,
1127 priv->RcvCtl[ctx].len,
1128 PCI_DMA_FROMDEVICE);
1129
1130 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1131 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1132 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1133
1134 } else {
1135 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1136
1137 priv->RcvCtl[ctx].skb = NULL;
1138
1139 pci_unmap_single(mpt_dev->pcidev, priv->RcvCtl[ctx].dma,
1140 priv->RcvCtl[ctx].len, PCI_DMA_FROMDEVICE);
1141 priv->RcvCtl[ctx].dma = 0;
1142
1143 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1144 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1145
1146 skb_put(skb,len);
1147 }
1148
1149 atomic_sub(count, &priv->buckets_out);
1150 priv->total_received += count;
1151
1152 if (priv->mpt_rxfidx_tail >= MPT_LAN_MAX_BUCKETS_OUT) {
1153 printk (KERN_ERR MYNAM ": %s/%s: Yoohoo! mpt_rxfidx_tail = %d, "
1154 "MPT_LAN_MAX_BUCKETS_OUT = %d\n",
1155 IOC_AND_NETDEV_NAMES_s_s(dev),
1156 priv->mpt_rxfidx_tail,
1157 MPT_LAN_MAX_BUCKETS_OUT);
1158
4f8d98ab 1159 return -1;
1da177e4
LT
1160 }
1161
1162 if (remaining == 0)
1163 printk (KERN_WARNING MYNAM ": %s/%s: WARNING - IOC out of buckets! "
1164 "(priv->buckets_out = %d)\n",
1165 IOC_AND_NETDEV_NAMES_s_s(dev),
1166 atomic_read(&priv->buckets_out));
1167 else if (remaining < 10)
1168 printk (KERN_INFO MYNAM ": %s/%s: IOC says %d buckets left. "
1169 "(priv->buckets_out = %d)\n",
1170 IOC_AND_NETDEV_NAMES_s_s(dev),
1171 remaining, atomic_read(&priv->buckets_out));
1172
1173 if ((remaining < priv->bucketthresh) &&
1174 ((atomic_read(&priv->buckets_out) - remaining) >
1175 MPT_LAN_BUCKETS_REMAIN_MISMATCH_THRESH)) {
1176
1177 printk (KERN_WARNING MYNAM " Mismatch between driver's "
1178 "buckets_out count and fw's BucketsRemaining "
1179 "count has crossed the threshold, issuing a "
1180 "LanReset to clear the fw's hashtable. You may "
1181 "want to check your /var/log/messages for \"CRC "
1182 "error\" event notifications.\n");
1183
1184 mpt_lan_reset(dev);
1185 mpt_lan_wake_post_buckets_task(dev, 0);
1186 }
1187
1188 return mpt_lan_receive_skb(dev, skb);
1189}
1190
1191/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1192/* Simple SGE's only at the moment */
1193
1194static void
c4028958 1195mpt_lan_post_receive_buckets(struct mpt_lan_priv *priv)
1da177e4 1196{
c4028958 1197 struct net_device *dev = priv->dev;
1da177e4
LT
1198 MPT_ADAPTER *mpt_dev = priv->mpt_dev;
1199 MPT_FRAME_HDR *mf;
1200 LANReceivePostRequest_t *pRecvReq;
1201 SGETransaction32_t *pTrans;
1202 SGESimple64_t *pSimple;
1203 struct sk_buff *skb;
1204 dma_addr_t dma;
1205 u32 curr, buckets, count, max;
1206 u32 len = (dev->mtu + dev->hard_header_len + 4);
1207 unsigned long flags;
1208 int i;
1209
1210 curr = atomic_read(&priv->buckets_out);
1211 buckets = (priv->max_buckets_out - curr);
1212
1213 dioprintk((KERN_INFO MYNAM ": %s/%s: @%s, Start_buckets = %u, buckets_out = %u\n",
1214 IOC_AND_NETDEV_NAMES_s_s(dev),
1215 __FUNCTION__, buckets, curr));
1216
1217 max = (mpt_dev->req_sz - MPT_LAN_RECEIVE_POST_REQUEST_SIZE) /
1218 (MPT_LAN_TRANSACTION32_SIZE + sizeof(SGESimple64_t));
1219
1220 while (buckets) {
1221 mf = mpt_get_msg_frame(LanCtx, mpt_dev);
1222 if (mf == NULL) {
1223 printk (KERN_ERR "%s: Unable to alloc request frame\n",
1224 __FUNCTION__);
1225 dioprintk((KERN_ERR "%s: %u buckets remaining\n",
1226 __FUNCTION__, buckets));
1227 goto out;
1228 }
1229 pRecvReq = (LANReceivePostRequest_t *) mf;
1230
1231 count = buckets;
1232 if (count > max)
1233 count = max;
1234
1235 pRecvReq->Function = MPI_FUNCTION_LAN_RECEIVE;
1236 pRecvReq->ChainOffset = 0;
1237 pRecvReq->MsgFlags = 0;
1238 pRecvReq->PortNumber = priv->pnum;
1239
1240 pTrans = (SGETransaction32_t *) pRecvReq->SG_List;
1241 pSimple = NULL;
1242
1243 for (i = 0; i < count; i++) {
1244 int ctx;
1245
1246 spin_lock_irqsave(&priv->rxfidx_lock, flags);
1247 if (priv->mpt_rxfidx_tail < 0) {
1248 printk (KERN_ERR "%s: Can't alloc context\n",
1249 __FUNCTION__);
1250 spin_unlock_irqrestore(&priv->rxfidx_lock,
1251 flags);
1252 break;
1253 }
1254
1255 ctx = priv->mpt_rxfidx[priv->mpt_rxfidx_tail--];
1256
1257 skb = priv->RcvCtl[ctx].skb;
1258 if (skb && (priv->RcvCtl[ctx].len != len)) {
1259 pci_unmap_single(mpt_dev->pcidev,
1260 priv->RcvCtl[ctx].dma,
1261 priv->RcvCtl[ctx].len,
1262 PCI_DMA_FROMDEVICE);
1263 dev_kfree_skb(priv->RcvCtl[ctx].skb);
1264 skb = priv->RcvCtl[ctx].skb = NULL;
1265 }
1266
1267 if (skb == NULL) {
1268 skb = dev_alloc_skb(len);
1269 if (skb == NULL) {
1270 printk (KERN_WARNING
1271 MYNAM "/%s: Can't alloc skb\n",
1272 __FUNCTION__);
1273 priv->mpt_rxfidx[++priv->mpt_rxfidx_tail] = ctx;
1274 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1275 break;
1276 }
1277
1278 dma = pci_map_single(mpt_dev->pcidev, skb->data,
1279 len, PCI_DMA_FROMDEVICE);
1280
1281 priv->RcvCtl[ctx].skb = skb;
1282 priv->RcvCtl[ctx].dma = dma;
1283 priv->RcvCtl[ctx].len = len;
1284 }
1285
1286 spin_unlock_irqrestore(&priv->rxfidx_lock, flags);
1287
1288 pTrans->ContextSize = sizeof(u32);
1289 pTrans->DetailsLength = 0;
1290 pTrans->Flags = 0;
1291 pTrans->TransactionContext[0] = cpu_to_le32(ctx);
1292
1293 pSimple = (SGESimple64_t *) pTrans->TransactionDetails;
1294
1295 pSimple->FlagsLength = cpu_to_le32(
1296 ((MPI_SGE_FLAGS_END_OF_BUFFER |
1297 MPI_SGE_FLAGS_SIMPLE_ELEMENT |
1298 MPI_SGE_FLAGS_64_BIT_ADDRESSING) << MPI_SGE_FLAGS_SHIFT) | len);
1299 pSimple->Address.Low = cpu_to_le32((u32) priv->RcvCtl[ctx].dma);
1300 if (sizeof(dma_addr_t) > sizeof(u32))
1301 pSimple->Address.High = cpu_to_le32((u32) ((u64) priv->RcvCtl[ctx].dma >> 32));
1302 else
1303 pSimple->Address.High = 0;
1304
1305 pTrans = (SGETransaction32_t *) (pSimple + 1);
1306 }
1307
1308 if (pSimple == NULL) {
1309/**/ printk (KERN_WARNING MYNAM "/%s: No buckets posted\n",
1310/**/ __FUNCTION__);
1311 mpt_free_msg_frame(mpt_dev, mf);
1312 goto out;
1313 }
1314
1315 pSimple->FlagsLength |= cpu_to_le32(MPI_SGE_FLAGS_END_OF_LIST << MPI_SGE_FLAGS_SHIFT);
1316
1317 pRecvReq->BucketCount = cpu_to_le32(i);
1318
1319/* printk(KERN_INFO MYNAM ": posting buckets\n ");
1320 * for (i = 0; i < j + 2; i ++)
1321 * printk (" %08x", le32_to_cpu(msg[i]));
1322 * printk ("\n");
1323 */
1324
1325 mpt_put_msg_frame(LanCtx, mpt_dev, mf);
1326
1327 priv->total_posted += i;
1328 buckets -= i;
1329 atomic_add(i, &priv->buckets_out);
1330 }
1331
1332out:
1333 dioprintk((KERN_INFO MYNAM "/%s: End_buckets = %u, priv->buckets_out = %u\n",
1334 __FUNCTION__, buckets, atomic_read(&priv->buckets_out)));
1335 dioprintk((KERN_INFO MYNAM "/%s: Posted %u buckets and received %u back\n",
1336 __FUNCTION__, priv->total_posted, priv->total_received));
1337
1338 clear_bit(0, &priv->post_buckets_active);
1339}
1340
c4028958
DH
1341static void
1342mpt_lan_post_receive_buckets_work(struct work_struct *work)
1343{
1344 mpt_lan_post_receive_buckets(container_of(work, struct mpt_lan_priv,
1345 post_buckets_task.work));
1346}
1347
1da177e4
LT
1348/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1349static struct net_device *
1350mpt_register_lan_device (MPT_ADAPTER *mpt_dev, int pnum)
1351{
1352 struct net_device *dev = alloc_fcdev(sizeof(struct mpt_lan_priv));
1353 struct mpt_lan_priv *priv = NULL;
1354 u8 HWaddr[FC_ALEN], *a;
1355
1356 if (!dev)
1357 return NULL;
1358
1359 dev->mtu = MPT_LAN_MTU;
1360
1361 priv = netdev_priv(dev);
1362
c4028958 1363 priv->dev = dev;
1da177e4
LT
1364 priv->mpt_dev = mpt_dev;
1365 priv->pnum = pnum;
1366
c4028958
DH
1367 memset(&priv->post_buckets_task, 0, sizeof(priv->post_buckets_task));
1368 INIT_DELAYED_WORK(&priv->post_buckets_task,
1369 mpt_lan_post_receive_buckets_work);
1da177e4
LT
1370 priv->post_buckets_active = 0;
1371
1372 dlprintk((KERN_INFO MYNAM "@%d: bucketlen = %d\n",
1373 __LINE__, dev->mtu + dev->hard_header_len + 4));
1374
1375 atomic_set(&priv->buckets_out, 0);
1376 priv->total_posted = 0;
1377 priv->total_received = 0;
1378 priv->max_buckets_out = max_buckets_out;
1379 if (mpt_dev->pfacts[0].MaxLanBuckets < max_buckets_out)
1380 priv->max_buckets_out = mpt_dev->pfacts[0].MaxLanBuckets;
1381
1382 dlprintk((KERN_INFO MYNAM "@%d: MaxLanBuckets=%d, max_buckets_out/priv=%d/%d\n",
1383 __LINE__,
1384 mpt_dev->pfacts[0].MaxLanBuckets,
1385 max_buckets_out,
1386 priv->max_buckets_out));
1387
1388 priv->bucketthresh = priv->max_buckets_out * 2 / 3;
1389 spin_lock_init(&priv->txfidx_lock);
1390 spin_lock_init(&priv->rxfidx_lock);
1391
1392 memset(&priv->stats, 0, sizeof(priv->stats));
1393
1394 /* Grab pre-fetched LANPage1 stuff. :-) */
1395 a = (u8 *) &mpt_dev->lan_cnfg_page1.HardwareAddressLow;
1396
1397 HWaddr[0] = a[5];
1398 HWaddr[1] = a[4];
1399 HWaddr[2] = a[3];
1400 HWaddr[3] = a[2];
1401 HWaddr[4] = a[1];
1402 HWaddr[5] = a[0];
1403
1404 dev->addr_len = FC_ALEN;
1405 memcpy(dev->dev_addr, HWaddr, FC_ALEN);
1406 memset(dev->broadcast, 0xff, FC_ALEN);
1407
1408 /* The Tx queue is 127 deep on the 909.
1409 * Give ourselves some breathing room.
1410 */
1411 priv->tx_max_out = (tx_max_out_p <= MPT_TX_MAX_OUT_LIM) ?
1412 tx_max_out_p : MPT_TX_MAX_OUT_LIM;
1413
1414 dev->open = mpt_lan_open;
1415 dev->stop = mpt_lan_close;
1416 dev->get_stats = mpt_lan_get_stats;
1417 dev->set_multicast_list = NULL;
1418 dev->change_mtu = mpt_lan_change_mtu;
1419 dev->hard_start_xmit = mpt_lan_sdu_send;
1420
1421/* Not in 2.3.42. Need 2.3.45+ */
1422 dev->tx_timeout = mpt_lan_tx_timeout;
1423 dev->watchdog_timeo = MPT_LAN_TX_TIMEOUT;
1424
1425 dlprintk((KERN_INFO MYNAM ": Finished registering dev "
1426 "and setting initial values\n"));
1427
1428 SET_MODULE_OWNER(dev);
1429
1430 if (register_netdev(dev) != 0) {
1431 free_netdev(dev);
1432 dev = NULL;
1433 }
1434 return dev;
1435}
1436
1437static int
1438mptlan_probe(struct pci_dev *pdev, const struct pci_device_id *id)
1439{
1440 MPT_ADAPTER *ioc = pci_get_drvdata(pdev);
1441 struct net_device *dev;
1442 int i;
1443
1444 for (i = 0; i < ioc->facts.NumberOfPorts; i++) {
1445 printk(KERN_INFO MYNAM ": %s: PortNum=%x, "
1446 "ProtocolFlags=%02Xh (%c%c%c%c)\n",
1447 ioc->name, ioc->pfacts[i].PortNumber,
1448 ioc->pfacts[i].ProtocolFlags,
1449 MPT_PROTOCOL_FLAGS_c_c_c_c(
1450 ioc->pfacts[i].ProtocolFlags));
1451
1452 if (!(ioc->pfacts[i].ProtocolFlags &
1453 MPI_PORTFACTS_PROTOCOL_LAN)) {
1454 printk(KERN_INFO MYNAM ": %s: Hmmm... LAN protocol "
1455 "seems to be disabled on this adapter port!\n",
1456 ioc->name);
1457 continue;
1458 }
1459
1460 dev = mpt_register_lan_device(ioc, i);
1461 if (!dev) {
1462 printk(KERN_ERR MYNAM ": %s: Unable to register "
1463 "port%d as a LAN device\n", ioc->name,
1464 ioc->pfacts[i].PortNumber);
1465 continue;
1466 }
1467
1468 printk(KERN_INFO MYNAM ": %s: Fusion MPT LAN device "
1469 "registered as '%s'\n", ioc->name, dev->name);
1470 printk(KERN_INFO MYNAM ": %s/%s: "
1471 "LanAddr = %02X:%02X:%02X:%02X:%02X:%02X\n",
1472 IOC_AND_NETDEV_NAMES_s_s(dev),
1473 dev->dev_addr[0], dev->dev_addr[1],
1474 dev->dev_addr[2], dev->dev_addr[3],
1475 dev->dev_addr[4], dev->dev_addr[5]);
1476
1477 ioc->netdev = dev;
1478
1479 return 0;
1480 }
1481
1482 return -ENODEV;
1483}
1484
1485static void
1486mptlan_remove(struct pci_dev *pdev)
1487{
1488 MPT_ADAPTER *ioc = pci_get_drvdata(pdev);
1489 struct net_device *dev = ioc->netdev;
1490
1491 if(dev != NULL) {
1492 unregister_netdev(dev);
1493 free_netdev(dev);
1494 }
1495}
1496
1497static struct mpt_pci_driver mptlan_driver = {
1498 .probe = mptlan_probe,
1499 .remove = mptlan_remove,
1500};
1501
1502static int __init mpt_lan_init (void)
1503{
1504 show_mptmod_ver(LANAME, LANVER);
1505
1506 if ((LanCtx = mpt_register(lan_reply, MPTLAN_DRIVER)) <= 0) {
1507 printk (KERN_ERR MYNAM ": Failed to register with MPT base driver\n");
1508 return -EBUSY;
1509 }
1510
1511 /* Set the callback index to be used by driver core for turbo replies */
1512 mpt_lan_index = LanCtx;
1513
1514 dlprintk((KERN_INFO MYNAM ": assigned context of %d\n", LanCtx));
1515
1516 if (mpt_reset_register(LanCtx, mpt_lan_ioc_reset)) {
1517 printk(KERN_ERR MYNAM ": Eieee! unable to register a reset "
1518 "handler with mptbase! The world is at an end! "
1519 "Everything is fading to black! Goodbye.\n");
1520 return -EBUSY;
1521 }
1522
1523 dlprintk((KERN_INFO MYNAM ": Registered for IOC reset notifications\n"));
1524
1525 if (mpt_device_driver_register(&mptlan_driver, MPTLAN_DRIVER))
1526 dprintk((KERN_INFO MYNAM ": failed to register dd callbacks\n"));
1527 return 0;
1528}
1529
1530static void __exit mpt_lan_exit(void)
1531{
1532 mpt_device_driver_deregister(MPTLAN_DRIVER);
1533 mpt_reset_deregister(LanCtx);
1534
1535 if (LanCtx >= 0) {
1536 mpt_deregister(LanCtx);
1537 LanCtx = -1;
1538 mpt_lan_index = 0;
1539 }
1540}
1541
1542module_init(mpt_lan_init);
1543module_exit(mpt_lan_exit);
1544
1545/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/
1546static unsigned short
1547mpt_lan_type_trans(struct sk_buff *skb, struct net_device *dev)
1548{
1549 struct mpt_lan_ohdr *fch = (struct mpt_lan_ohdr *)skb->data;
1550 struct fcllc *fcllc;
1551
459a98ed 1552 skb_reset_mac_header(skb);
1da177e4
LT
1553 skb_pull(skb, sizeof(struct mpt_lan_ohdr));
1554
1555 if (fch->dtype == htons(0xffff)) {
1556 u32 *p = (u32 *) fch;
1557
1558 swab32s(p + 0);
1559 swab32s(p + 1);
1560 swab32s(p + 2);
1561 swab32s(p + 3);
1562
1563 printk (KERN_WARNING MYNAM ": %s: WARNING - Broadcast swap F/W bug detected!\n",
1564 NETDEV_PTR_TO_IOC_NAME_s(dev));
1565 printk (KERN_WARNING MYNAM ": Please update sender @ MAC_addr = %02x:%02x:%02x:%02x:%02x:%02x\n",
1566 fch->saddr[0], fch->saddr[1], fch->saddr[2],
1567 fch->saddr[3], fch->saddr[4], fch->saddr[5]);
1568 }
1569
1570 if (*fch->daddr & 1) {
1571 if (!memcmp(fch->daddr, dev->broadcast, FC_ALEN)) {
1572 skb->pkt_type = PACKET_BROADCAST;
1573 } else {
1574 skb->pkt_type = PACKET_MULTICAST;
1575 }
1576 } else {
1577 if (memcmp(fch->daddr, dev->dev_addr, FC_ALEN)) {
1578 skb->pkt_type = PACKET_OTHERHOST;
1579 } else {
1580 skb->pkt_type = PACKET_HOST;
1581 }
1582 }
1583
1584 fcllc = (struct fcllc *)skb->data;
1585
1586#ifdef QLOGIC_NAA_WORKAROUND
1587{
1588 u16 source_naa = fch->stype, found = 0;
1589
1590 /* Workaround for QLogic not following RFC 2625 in regards to the NAA
1591 value. */
1592
1593 if ((source_naa & 0xF000) == 0)
1594 source_naa = swab16(source_naa);
1595
1596 if (fcllc->ethertype == htons(ETH_P_ARP))
1597 dlprintk ((KERN_INFO "mptlan/type_trans: got arp req/rep w/ naa of "
1598 "%04x.\n", source_naa));
1599
1600 if ((fcllc->ethertype == htons(ETH_P_ARP)) &&
1601 ((source_naa >> 12) != MPT_LAN_NAA_RFC2625)){
1602 struct NAA_Hosed *nh, *prevnh;
1603 int i;
1604
1605 dlprintk ((KERN_INFO "mptlan/type_trans: ARP Req/Rep from "
1606 "system with non-RFC 2625 NAA value (%04x).\n",
1607 source_naa));
1608
1609 write_lock_irq(&bad_naa_lock);
1610 for (prevnh = nh = mpt_bad_naa; nh != NULL;
1611 prevnh=nh, nh=nh->next) {
1612 if ((nh->ieee[0] == fch->saddr[0]) &&
1613 (nh->ieee[1] == fch->saddr[1]) &&
1614 (nh->ieee[2] == fch->saddr[2]) &&
1615 (nh->ieee[3] == fch->saddr[3]) &&
1616 (nh->ieee[4] == fch->saddr[4]) &&
1617 (nh->ieee[5] == fch->saddr[5])) {
1618 found = 1;
1619 dlprintk ((KERN_INFO "mptlan/type_trans: ARP Re"
1620 "q/Rep w/ bad NAA from system already"
1621 " in DB.\n"));
1622 break;
1623 }
1624 }
1625
1626 if ((!found) && (nh == NULL)) {
1627
1628 nh = kmalloc(sizeof(struct NAA_Hosed), GFP_KERNEL);
1629 dlprintk ((KERN_INFO "mptlan/type_trans: ARP Req/Rep w/"
1630 " bad NAA from system not yet in DB.\n"));
1631
1632 if (nh != NULL) {
1633 nh->next = NULL;
1634 if (!mpt_bad_naa)
1635 mpt_bad_naa = nh;
1636 if (prevnh)
1637 prevnh->next = nh;
1638
1639 nh->NAA = source_naa; /* Set the S_NAA value. */
1640 for (i = 0; i < FC_ALEN; i++)
1641 nh->ieee[i] = fch->saddr[i];
1642 dlprintk ((KERN_INFO "Got ARP from %02x:%02x:%02x:%02x:"
1643 "%02x:%02x with non-compliant S_NAA value.\n",
1644 fch->saddr[0], fch->saddr[1], fch->saddr[2],
1645 fch->saddr[3], fch->saddr[4],fch->saddr[5]));
1646 } else {
1647 printk (KERN_ERR "mptlan/type_trans: Unable to"
1648 " kmalloc a NAA_Hosed struct.\n");
1649 }
1650 } else if (!found) {
1651 printk (KERN_ERR "mptlan/type_trans: found not"
1652 " set, but nh isn't null. Evil "
1653 "funkiness abounds.\n");
1654 }
1655 write_unlock_irq(&bad_naa_lock);
1656 }
1657}
1658#endif
1659
1660 /* Strip the SNAP header from ARP packets since we don't
1661 * pass them through to the 802.2/SNAP layers.
1662 */
1663 if (fcllc->dsap == EXTENDED_SAP &&
1664 (fcllc->ethertype == htons(ETH_P_IP) ||
1665 fcllc->ethertype == htons(ETH_P_ARP))) {
1666 skb_pull(skb, sizeof(struct fcllc));
1667 return fcllc->ethertype;
1668 }
1669
1670 return htons(ETH_P_802_2);
1671}
1672
1673/*=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=*/