source: src/linux/universal/linux-4.4/drivers/infiniband/ulp/ipoib/ipoib_main.c @ 31662

Last change on this file since 31662 was 31662, checked in by brainslayer, 4 months ago

use new squashfs in all kernels

File size: 51.2 KB
Line 
1/*
2 * Copyright (c) 2004 Topspin Communications.  All rights reserved.
3 * Copyright (c) 2005 Sun Microsystems, Inc. All rights reserved.
4 * Copyright (c) 2004 Voltaire, Inc. All rights reserved.
5 *
6 * This software is available to you under a choice of one of two
7 * licenses.  You may choose to be licensed under the terms of the GNU
8 * General Public License (GPL) Version 2, available from the file
9 * COPYING in the main directory of this source tree, or the
10 * OpenIB.org BSD license below:
11 *
12 *     Redistribution and use in source and binary forms, with or
13 *     without modification, are permitted provided that the following
14 *     conditions are met:
15 *
16 *      - Redistributions of source code must retain the above
17 *        copyright notice, this list of conditions and the following
18 *        disclaimer.
19 *
20 *      - Redistributions in binary form must reproduce the above
21 *        copyright notice, this list of conditions and the following
22 *        disclaimer in the documentation and/or other materials
23 *        provided with the distribution.
24 *
25 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
26 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
27 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
28 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
29 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
30 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
31 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
32 * SOFTWARE.
33 */
34
35#include "ipoib.h"
36
37#include <linux/module.h>
38
39#include <linux/init.h>
40#include <linux/slab.h>
41#include <linux/kernel.h>
42#include <linux/vmalloc.h>
43
44#include <linux/if_arp.h>       /* For ARPHRD_xxx */
45
46#include <linux/ip.h>
47#include <linux/in.h>
48
49#include <linux/jhash.h>
50#include <net/arp.h>
51#include <net/addrconf.h>
52#include <linux/inetdevice.h>
53#include <rdma/ib_cache.h>
54
55#define DRV_VERSION "1.0.0"
56
57const char ipoib_driver_version[] = DRV_VERSION;
58
59MODULE_AUTHOR("Roland Dreier");
60MODULE_DESCRIPTION("IP-over-InfiniBand net driver");
61MODULE_LICENSE("Dual BSD/GPL");
62MODULE_VERSION(DRV_VERSION);
63
64int ipoib_sendq_size __read_mostly = IPOIB_TX_RING_SIZE;
65int ipoib_recvq_size __read_mostly = IPOIB_RX_RING_SIZE;
66
67module_param_named(send_queue_size, ipoib_sendq_size, int, 0444);
68MODULE_PARM_DESC(send_queue_size, "Number of descriptors in send queue");
69module_param_named(recv_queue_size, ipoib_recvq_size, int, 0444);
70MODULE_PARM_DESC(recv_queue_size, "Number of descriptors in receive queue");
71
72#ifdef CONFIG_INFINIBAND_IPOIB_DEBUG
73int ipoib_debug_level;
74
75module_param_named(debug_level, ipoib_debug_level, int, 0644);
76MODULE_PARM_DESC(debug_level, "Enable debug tracing if > 0");
77#endif
78
79struct ipoib_path_iter {
80        struct net_device *dev;
81        struct ipoib_path  path;
82};
83
84static const u8 ipv4_bcast_addr[] = {
85        0x00, 0xff, 0xff, 0xff,
86        0xff, 0x12, 0x40, 0x1b, 0x00, 0x00, 0x00, 0x00,
87        0x00, 0x00, 0x00, 0x00, 0xff, 0xff, 0xff, 0xff
88};
89
90struct workqueue_struct *ipoib_workqueue;
91
92struct ib_sa_client ipoib_sa_client;
93
94static void ipoib_add_one(struct ib_device *device);
95static void ipoib_remove_one(struct ib_device *device, void *client_data);
96static void ipoib_neigh_reclaim(struct rcu_head *rp);
97static struct net_device *ipoib_get_net_dev_by_params(
98                struct ib_device *dev, u8 port, u16 pkey,
99                const union ib_gid *gid, const struct sockaddr *addr,
100                void *client_data);
101
102static struct ib_client ipoib_client = {
103        .name   = "ipoib",
104        .add    = ipoib_add_one,
105        .remove = ipoib_remove_one,
106        .get_net_dev_by_params = ipoib_get_net_dev_by_params,
107};
108
109int ipoib_open(struct net_device *dev)
110{
111        struct ipoib_dev_priv *priv = netdev_priv(dev);
112
113        ipoib_dbg(priv, "bringing up interface\n");
114
115        netif_carrier_off(dev);
116
117        set_bit(IPOIB_FLAG_ADMIN_UP, &priv->flags);
118
119        if (ipoib_ib_dev_open(dev)) {
120                if (!test_bit(IPOIB_PKEY_ASSIGNED, &priv->flags))
121                        return 0;
122                goto err_disable;
123        }
124
125        if (ipoib_ib_dev_up(dev))
126                goto err_stop;
127
128        if (!test_bit(IPOIB_FLAG_SUBINTERFACE, &priv->flags)) {
129                struct ipoib_dev_priv *cpriv;
130
131                /* Bring up any child interfaces too */
132                down_read(&priv->vlan_rwsem);
133                list_for_each_entry(cpriv, &priv->child_intfs, list) {
134                        int flags;
135
136                        flags = cpriv->dev->flags;
137                        if (flags & IFF_UP)
138                                continue;
139
140                        dev_change_flags(cpriv->dev, flags | IFF_UP);
141                }
142                up_read(&priv->vlan_rwsem);
143        }
144
145        netif_start_queue(dev);
146
147        return 0;
148
149err_stop:
150        ipoib_ib_dev_stop(dev);
151
152err_disable:
153        clear_bit(IPOIB_FLAG_ADMIN_UP, &priv->flags);
154
155        return -EINVAL;
156}
157
158static int ipoib_stop(struct net_device *dev)
159{
160        struct ipoib_dev_priv *priv = netdev_priv(dev);
161
162        ipoib_dbg(priv, "stopping interface\n");
163
164        clear_bit(IPOIB_FLAG_ADMIN_UP, &priv->flags);
165
166        netif_stop_queue(dev);
167
168        ipoib_ib_dev_down(dev);
169        ipoib_ib_dev_stop(dev);
170
171        if (!test_bit(IPOIB_FLAG_SUBINTERFACE, &priv->flags)) {
172                struct ipoib_dev_priv *cpriv;
173
174                /* Bring down any child interfaces too */
175                down_read(&priv->vlan_rwsem);
176                list_for_each_entry(cpriv, &priv->child_intfs, list) {
177                        int flags;
178
179                        flags = cpriv->dev->flags;
180                        if (!(flags & IFF_UP))
181                                continue;
182
183                        dev_change_flags(cpriv->dev, flags & ~IFF_UP);
184                }
185                up_read(&priv->vlan_rwsem);
186        }
187
188        return 0;
189}
190
191static void ipoib_uninit(struct net_device *dev)
192{
193        ipoib_dev_cleanup(dev);
194}
195
196static netdev_features_t ipoib_fix_features(struct net_device *dev, netdev_features_t features)
197{
198        struct ipoib_dev_priv *priv = netdev_priv(dev);
199
200        if (test_bit(IPOIB_FLAG_ADMIN_CM, &priv->flags))
201                features &= ~(NETIF_F_IP_CSUM | NETIF_F_TSO);
202
203        return features;
204}
205
206static int ipoib_change_mtu(struct net_device *dev, int new_mtu)
207{
208        struct ipoib_dev_priv *priv = netdev_priv(dev);
209
210        /* dev->mtu > 2K ==> connected mode */
211        if (ipoib_cm_admin_enabled(dev)) {
212                if (new_mtu > ipoib_cm_max_mtu(dev))
213                        return -EINVAL;
214
215                if (new_mtu > priv->mcast_mtu)
216                        ipoib_warn(priv, "mtu > %d will cause multicast packet drops.\n",
217                                   priv->mcast_mtu);
218
219                dev->mtu = new_mtu;
220                return 0;
221        }
222
223        if (new_mtu > IPOIB_UD_MTU(priv->max_ib_mtu))
224                return -EINVAL;
225
226        priv->admin_mtu = new_mtu;
227
228        dev->mtu = min(priv->mcast_mtu, priv->admin_mtu);
229
230        return 0;
231}
232
233/* Called with an RCU read lock taken */
234static bool ipoib_is_dev_match_addr_rcu(const struct sockaddr *addr,
235                                        struct net_device *dev)
236{
237        struct net *net = dev_net(dev);
238        struct in_device *in_dev;
239        struct sockaddr_in *addr_in = (struct sockaddr_in *)addr;
240        struct sockaddr_in6 *addr_in6 = (struct sockaddr_in6 *)addr;
241        __be32 ret_addr;
242
243        switch (addr->sa_family) {
244        case AF_INET:
245                in_dev = in_dev_get(dev);
246                if (!in_dev)
247                        return false;
248
249                ret_addr = inet_confirm_addr(net, in_dev, 0,
250                                             addr_in->sin_addr.s_addr,
251                                             RT_SCOPE_HOST);
252                in_dev_put(in_dev);
253                if (ret_addr)
254                        return true;
255
256                break;
257        case AF_INET6:
258                if (IS_ENABLED(CONFIG_IPV6) &&
259                    ipv6_chk_addr(net, &addr_in6->sin6_addr, dev, 1))
260                        return true;
261
262                break;
263        }
264        return false;
265}
266
267/**
268 * Find the master net_device on top of the given net_device.
269 * @dev: base IPoIB net_device
270 *
271 * Returns the master net_device with a reference held, or the same net_device
272 * if no master exists.
273 */
274static struct net_device *ipoib_get_master_net_dev(struct net_device *dev)
275{
276        struct net_device *master;
277
278        rcu_read_lock();
279        master = netdev_master_upper_dev_get_rcu(dev);
280        if (master)
281                dev_hold(master);
282        rcu_read_unlock();
283
284        if (master)
285                return master;
286
287        dev_hold(dev);
288        return dev;
289}
290
291/**
292 * Find a net_device matching the given address, which is an upper device of
293 * the given net_device.
294 * @addr: IP address to look for.
295 * @dev: base IPoIB net_device
296 *
297 * If found, returns the net_device with a reference held. Otherwise return
298 * NULL.
299 */
300static struct net_device *ipoib_get_net_dev_match_addr(
301                const struct sockaddr *addr, struct net_device *dev)
302{
303        struct net_device *upper,
304                          *result = NULL;
305        struct list_head *iter;
306
307        rcu_read_lock();
308        if (ipoib_is_dev_match_addr_rcu(addr, dev)) {
309                dev_hold(dev);
310                result = dev;
311                goto out;
312        }
313
314        netdev_for_each_all_upper_dev_rcu(dev, upper, iter) {
315                if (ipoib_is_dev_match_addr_rcu(addr, upper)) {
316                        dev_hold(upper);
317                        result = upper;
318                        break;
319                }
320        }
321out:
322        rcu_read_unlock();
323        return result;
324}
325
326/* returns the number of IPoIB netdevs on top a given ipoib device matching a
327 * pkey_index and address, if one exists.
328 *
329 * @found_net_dev: contains a matching net_device if the return value >= 1,
330 * with a reference held. */
331static int ipoib_match_gid_pkey_addr(struct ipoib_dev_priv *priv,
332                                     const union ib_gid *gid,
333                                     u16 pkey_index,
334                                     const struct sockaddr *addr,
335                                     int nesting,
336                                     struct net_device **found_net_dev)
337{
338        struct ipoib_dev_priv *child_priv;
339        struct net_device *net_dev = NULL;
340        int matches = 0;
341
342        if (priv->pkey_index == pkey_index &&
343            (!gid || !memcmp(gid, &priv->local_gid, sizeof(*gid)))) {
344                if (!addr) {
345                        net_dev = ipoib_get_master_net_dev(priv->dev);
346                } else {
347                        /* Verify the net_device matches the IP address, as
348                         * IPoIB child devices currently share a GID. */
349                        net_dev = ipoib_get_net_dev_match_addr(addr, priv->dev);
350                }
351                if (net_dev) {
352                        if (!*found_net_dev)
353                                *found_net_dev = net_dev;
354                        else
355                                dev_put(net_dev);
356                        ++matches;
357                }
358        }
359
360        /* Check child interfaces */
361        down_read_nested(&priv->vlan_rwsem, nesting);
362        list_for_each_entry(child_priv, &priv->child_intfs, list) {
363                matches += ipoib_match_gid_pkey_addr(child_priv, gid,
364                                                    pkey_index, addr,
365                                                    nesting + 1,
366                                                    found_net_dev);
367                if (matches > 1)
368                        break;
369        }
370        up_read(&priv->vlan_rwsem);
371
372        return matches;
373}
374
375/* Returns the number of matching net_devs found (between 0 and 2). Also
376 * return the matching net_device in the @net_dev parameter, holding a
377 * reference to the net_device, if the number of matches >= 1 */
378static int __ipoib_get_net_dev_by_params(struct list_head *dev_list, u8 port,
379                                         u16 pkey_index,
380                                         const union ib_gid *gid,
381                                         const struct sockaddr *addr,
382                                         struct net_device **net_dev)
383{
384        struct ipoib_dev_priv *priv;
385        int matches = 0;
386
387        *net_dev = NULL;
388
389        list_for_each_entry(priv, dev_list, list) {
390                if (priv->port != port)
391                        continue;
392
393                matches += ipoib_match_gid_pkey_addr(priv, gid, pkey_index,
394                                                     addr, 0, net_dev);
395                if (matches > 1)
396                        break;
397        }
398
399        return matches;
400}
401
402static struct net_device *ipoib_get_net_dev_by_params(
403                struct ib_device *dev, u8 port, u16 pkey,
404                const union ib_gid *gid, const struct sockaddr *addr,
405                void *client_data)
406{
407        struct net_device *net_dev;
408        struct list_head *dev_list = client_data;
409        u16 pkey_index;
410        int matches;
411        int ret;
412
413        if (!rdma_protocol_ib(dev, port))
414                return NULL;
415
416        ret = ib_find_cached_pkey(dev, port, pkey, &pkey_index);
417        if (ret)
418                return NULL;
419
420        if (!dev_list)
421                return NULL;
422
423        /* See if we can find a unique device matching the L2 parameters */
424        matches = __ipoib_get_net_dev_by_params(dev_list, port, pkey_index,
425                                                gid, NULL, &net_dev);
426
427        switch (matches) {
428        case 0:
429                return NULL;
430        case 1:
431                return net_dev;
432        }
433
434        dev_put(net_dev);
435
436        /* Couldn't find a unique device with L2 parameters only. Use L3
437         * address to uniquely match the net device */
438        matches = __ipoib_get_net_dev_by_params(dev_list, port, pkey_index,
439                                                gid, addr, &net_dev);
440        switch (matches) {
441        case 0:
442                return NULL;
443        default:
444                dev_warn_ratelimited(&dev->dev,
445                                     "duplicate IP address detected\n");
446                /* Fall through */
447        case 1:
448                return net_dev;
449        }
450}
451
452int ipoib_set_mode(struct net_device *dev, const char *buf)
453{
454        struct ipoib_dev_priv *priv = netdev_priv(dev);
455
456        /* flush paths if we switch modes so that connections are restarted */
457        if (IPOIB_CM_SUPPORTED(dev->dev_addr) && !strcmp(buf, "connected\n")) {
458                set_bit(IPOIB_FLAG_ADMIN_CM, &priv->flags);
459                ipoib_warn(priv, "enabling connected mode "
460                           "will cause multicast packet drops\n");
461                netdev_update_features(dev);
462                dev_set_mtu(dev, ipoib_cm_max_mtu(dev));
463                rtnl_unlock();
464                priv->tx_wr.wr.send_flags &= ~IB_SEND_IP_CSUM;
465
466                ipoib_flush_paths(dev);
467                return (!rtnl_trylock()) ? -EBUSY : 0;
468        }
469
470        if (!strcmp(buf, "datagram\n")) {
471                clear_bit(IPOIB_FLAG_ADMIN_CM, &priv->flags);
472                netdev_update_features(dev);
473                dev_set_mtu(dev, min(priv->mcast_mtu, dev->mtu));
474                rtnl_unlock();
475                ipoib_flush_paths(dev);
476                return (!rtnl_trylock()) ? -EBUSY : 0;
477        }
478
479        return -EINVAL;
480}
481
482struct ipoib_path *__path_find(struct net_device *dev, void *gid)
483{
484        struct ipoib_dev_priv *priv = netdev_priv(dev);
485        struct rb_node *n = priv->path_tree.rb_node;
486        struct ipoib_path *path;
487        int ret;
488
489        while (n) {
490                path = rb_entry(n, struct ipoib_path, rb_node);
491
492                ret = memcmp(gid, path->pathrec.dgid.raw,
493                             sizeof (union ib_gid));
494
495                if (ret < 0)
496                        n = n->rb_left;
497                else if (ret > 0)
498                        n = n->rb_right;
499                else
500                        return path;
501        }
502
503        return NULL;
504}
505
506static int __path_add(struct net_device *dev, struct ipoib_path *path)
507{
508        struct ipoib_dev_priv *priv = netdev_priv(dev);
509        struct rb_node **n = &priv->path_tree.rb_node;
510        struct rb_node *pn = NULL;
511        struct ipoib_path *tpath;
512        int ret;
513
514        while (*n) {
515                pn = *n;
516                tpath = rb_entry(pn, struct ipoib_path, rb_node);
517
518                ret = memcmp(path->pathrec.dgid.raw, tpath->pathrec.dgid.raw,
519                             sizeof (union ib_gid));
520                if (ret < 0)
521                        n = &pn->rb_left;
522                else if (ret > 0)
523                        n = &pn->rb_right;
524                else
525                        return -EEXIST;
526        }
527
528        rb_link_node(&path->rb_node, pn, n);
529        rb_insert_color(&path->rb_node, &priv->path_tree);
530
531        list_add_tail(&path->list, &priv->path_list);
532
533        return 0;
534}
535
536static void path_free(struct net_device *dev, struct ipoib_path *path)
537{
538        struct sk_buff *skb;
539
540        while ((skb = __skb_dequeue(&path->queue)))
541                dev_kfree_skb_irq(skb);
542
543        ipoib_dbg(netdev_priv(dev), "path_free\n");
544
545        /* remove all neigh connected to this path */
546        ipoib_del_neighs_by_gid(dev, path->pathrec.dgid.raw);
547
548        if (path->ah)
549                ipoib_put_ah(path->ah);
550
551        kfree(path);
552}
553
554#ifdef CONFIG_INFINIBAND_IPOIB_DEBUG
555
556struct ipoib_path_iter *ipoib_path_iter_init(struct net_device *dev)
557{
558        struct ipoib_path_iter *iter;
559
560        iter = kmalloc(sizeof *iter, GFP_KERNEL);
561        if (!iter)
562                return NULL;
563
564        iter->dev = dev;
565        memset(iter->path.pathrec.dgid.raw, 0, 16);
566
567        if (ipoib_path_iter_next(iter)) {
568                kfree(iter);
569                return NULL;
570        }
571
572        return iter;
573}
574
575int ipoib_path_iter_next(struct ipoib_path_iter *iter)
576{
577        struct ipoib_dev_priv *priv = netdev_priv(iter->dev);
578        struct rb_node *n;
579        struct ipoib_path *path;
580        int ret = 1;
581
582        spin_lock_irq(&priv->lock);
583
584        n = rb_first(&priv->path_tree);
585
586        while (n) {
587                path = rb_entry(n, struct ipoib_path, rb_node);
588
589                if (memcmp(iter->path.pathrec.dgid.raw, path->pathrec.dgid.raw,
590                           sizeof (union ib_gid)) < 0) {
591                        iter->path = *path;
592                        ret = 0;
593                        break;
594                }
595
596                n = rb_next(n);
597        }
598
599        spin_unlock_irq(&priv->lock);
600
601        return ret;
602}
603
604void ipoib_path_iter_read(struct ipoib_path_iter *iter,
605                          struct ipoib_path *path)
606{
607        *path = iter->path;
608}
609
610#endif /* CONFIG_INFINIBAND_IPOIB_DEBUG */
611
612void ipoib_mark_paths_invalid(struct net_device *dev)
613{
614        struct ipoib_dev_priv *priv = netdev_priv(dev);
615        struct ipoib_path *path, *tp;
616
617        spin_lock_irq(&priv->lock);
618
619        list_for_each_entry_safe(path, tp, &priv->path_list, list) {
620                ipoib_dbg(priv, "mark path LID 0x%04x GID %pI6 invalid\n",
621                        be16_to_cpu(path->pathrec.dlid),
622                        path->pathrec.dgid.raw);
623                path->valid =  0;
624        }
625
626        spin_unlock_irq(&priv->lock);
627}
628
629static void push_pseudo_header(struct sk_buff *skb, const char *daddr)
630{
631        struct ipoib_pseudo_header *phdr;
632
633        phdr = (struct ipoib_pseudo_header *)skb_push(skb, sizeof(*phdr));
634        memcpy(phdr->hwaddr, daddr, INFINIBAND_ALEN);
635}
636
637void ipoib_flush_paths(struct net_device *dev)
638{
639        struct ipoib_dev_priv *priv = netdev_priv(dev);
640        struct ipoib_path *path, *tp;
641        LIST_HEAD(remove_list);
642        unsigned long flags;
643
644        netif_tx_lock_bh(dev);
645        spin_lock_irqsave(&priv->lock, flags);
646
647        list_splice_init(&priv->path_list, &remove_list);
648
649        list_for_each_entry(path, &remove_list, list)
650                rb_erase(&path->rb_node, &priv->path_tree);
651
652        list_for_each_entry_safe(path, tp, &remove_list, list) {
653                if (path->query)
654                        ib_sa_cancel_query(path->query_id, path->query);
655                spin_unlock_irqrestore(&priv->lock, flags);
656                netif_tx_unlock_bh(dev);
657                wait_for_completion(&path->done);
658                path_free(dev, path);
659                netif_tx_lock_bh(dev);
660                spin_lock_irqsave(&priv->lock, flags);
661        }
662
663        spin_unlock_irqrestore(&priv->lock, flags);
664        netif_tx_unlock_bh(dev);
665}
666
667static void path_rec_completion(int status,
668                                struct ib_sa_path_rec *pathrec,
669                                void *path_ptr)
670{
671        struct ipoib_path *path = path_ptr;
672        struct net_device *dev = path->dev;
673        struct ipoib_dev_priv *priv = netdev_priv(dev);
674        struct ipoib_ah *ah = NULL;
675        struct ipoib_ah *old_ah = NULL;
676        struct ipoib_neigh *neigh, *tn;
677        struct sk_buff_head skqueue;
678        struct sk_buff *skb;
679        unsigned long flags;
680
681        if (!status)
682                ipoib_dbg(priv, "PathRec LID 0x%04x for GID %pI6\n",
683                          be16_to_cpu(pathrec->dlid), pathrec->dgid.raw);
684        else
685                ipoib_dbg(priv, "PathRec status %d for GID %pI6\n",
686                          status, path->pathrec.dgid.raw);
687
688        skb_queue_head_init(&skqueue);
689
690        if (!status) {
691                struct ib_ah_attr av;
692
693                if (!ib_init_ah_from_path(priv->ca, priv->port, pathrec, &av))
694                        ah = ipoib_create_ah(dev, priv->pd, &av);
695        }
696
697        spin_lock_irqsave(&priv->lock, flags);
698
699        if (!IS_ERR_OR_NULL(ah)) {
700                path->pathrec = *pathrec;
701
702                old_ah   = path->ah;
703                path->ah = ah;
704
705                ipoib_dbg(priv, "created address handle %p for LID 0x%04x, SL %d\n",
706                          ah, be16_to_cpu(pathrec->dlid), pathrec->sl);
707
708                while ((skb = __skb_dequeue(&path->queue)))
709                        __skb_queue_tail(&skqueue, skb);
710
711                list_for_each_entry_safe(neigh, tn, &path->neigh_list, list) {
712                        if (neigh->ah) {
713                                WARN_ON(neigh->ah != old_ah);
714                                /*
715                                 * Dropping the ah reference inside
716                                 * priv->lock is safe here, because we
717                                 * will hold one more reference from
718                                 * the original value of path->ah (ie
719                                 * old_ah).
720                                 */
721                                ipoib_put_ah(neigh->ah);
722                        }
723                        kref_get(&path->ah->ref);
724                        neigh->ah = path->ah;
725
726                        if (ipoib_cm_enabled(dev, neigh->daddr)) {
727                                if (!ipoib_cm_get(neigh))
728                                        ipoib_cm_set(neigh, ipoib_cm_create_tx(dev,
729                                                                               path,
730                                                                               neigh));
731                                if (!ipoib_cm_get(neigh)) {
732                                        ipoib_neigh_free(neigh);
733                                        continue;
734                                }
735                        }
736
737                        while ((skb = __skb_dequeue(&neigh->queue)))
738                                __skb_queue_tail(&skqueue, skb);
739                }
740                path->valid = 1;
741        }
742
743        path->query = NULL;
744        complete(&path->done);
745
746        spin_unlock_irqrestore(&priv->lock, flags);
747
748        if (IS_ERR_OR_NULL(ah))
749                ipoib_del_neighs_by_gid(dev, path->pathrec.dgid.raw);
750
751        if (old_ah)
752                ipoib_put_ah(old_ah);
753
754        while ((skb = __skb_dequeue(&skqueue))) {
755                skb->dev = dev;
756                if (dev_queue_xmit(skb))
757                        ipoib_warn(priv, "dev_queue_xmit failed "
758                                   "to requeue packet\n");
759        }
760}
761
762static struct ipoib_path *path_rec_create(struct net_device *dev, void *gid)
763{
764        struct ipoib_dev_priv *priv = netdev_priv(dev);
765        struct ipoib_path *path;
766
767        if (!priv->broadcast)
768                return NULL;
769
770        path = kzalloc(sizeof *path, GFP_ATOMIC);
771        if (!path)
772                return NULL;
773
774        path->dev = dev;
775
776        skb_queue_head_init(&path->queue);
777
778        INIT_LIST_HEAD(&path->neigh_list);
779
780        memcpy(path->pathrec.dgid.raw, gid, sizeof (union ib_gid));
781        path->pathrec.sgid          = priv->local_gid;
782        path->pathrec.pkey          = cpu_to_be16(priv->pkey);
783        path->pathrec.numb_path     = 1;
784        path->pathrec.traffic_class = priv->broadcast->mcmember.traffic_class;
785
786        return path;
787}
788
789static int path_rec_start(struct net_device *dev,
790                          struct ipoib_path *path)
791{
792        struct ipoib_dev_priv *priv = netdev_priv(dev);
793
794        ipoib_dbg(priv, "Start path record lookup for %pI6\n",
795                  path->pathrec.dgid.raw);
796
797        init_completion(&path->done);
798
799        path->query_id =
800                ib_sa_path_rec_get(&ipoib_sa_client, priv->ca, priv->port,
801                                   &path->pathrec,
802                                   IB_SA_PATH_REC_DGID          |
803                                   IB_SA_PATH_REC_SGID          |
804                                   IB_SA_PATH_REC_NUMB_PATH     |
805                                   IB_SA_PATH_REC_TRAFFIC_CLASS |
806                                   IB_SA_PATH_REC_PKEY,
807                                   1000, GFP_ATOMIC,
808                                   path_rec_completion,
809                                   path, &path->query);
810        if (path->query_id < 0) {
811                ipoib_warn(priv, "ib_sa_path_rec_get failed: %d\n", path->query_id);
812                path->query = NULL;
813                complete(&path->done);
814                return path->query_id;
815        }
816
817        return 0;
818}
819
820static void neigh_add_path(struct sk_buff *skb, u8 *daddr,
821                           struct net_device *dev)
822{
823        struct ipoib_dev_priv *priv = netdev_priv(dev);
824        struct ipoib_path *path;
825        struct ipoib_neigh *neigh;
826        unsigned long flags;
827
828        spin_lock_irqsave(&priv->lock, flags);
829        neigh = ipoib_neigh_alloc(daddr, dev);
830        if (!neigh) {
831                spin_unlock_irqrestore(&priv->lock, flags);
832                ++dev->stats.tx_dropped;
833                dev_kfree_skb_any(skb);
834                return;
835        }
836
837        path = __path_find(dev, daddr + 4);
838        if (!path) {
839                path = path_rec_create(dev, daddr + 4);
840                if (!path)
841                        goto err_path;
842
843                __path_add(dev, path);
844        }
845
846        list_add_tail(&neigh->list, &path->neigh_list);
847
848        if (path->ah) {
849                kref_get(&path->ah->ref);
850                neigh->ah = path->ah;
851
852                if (ipoib_cm_enabled(dev, neigh->daddr)) {
853                        if (!ipoib_cm_get(neigh))
854                                ipoib_cm_set(neigh, ipoib_cm_create_tx(dev, path, neigh));
855                        if (!ipoib_cm_get(neigh)) {
856                                ipoib_neigh_free(neigh);
857                                goto err_drop;
858                        }
859                        if (skb_queue_len(&neigh->queue) <
860                            IPOIB_MAX_PATH_REC_QUEUE) {
861                                push_pseudo_header(skb, neigh->daddr);
862                                __skb_queue_tail(&neigh->queue, skb);
863                        } else {
864                                ipoib_warn(priv, "queue length limit %d. Packet drop.\n",
865                                           skb_queue_len(&neigh->queue));
866                                goto err_drop;
867                        }
868                } else {
869                        spin_unlock_irqrestore(&priv->lock, flags);
870                        ipoib_send(dev, skb, path->ah, IPOIB_QPN(daddr));
871                        ipoib_neigh_put(neigh);
872                        return;
873                }
874        } else {
875                neigh->ah  = NULL;
876
877                if (!path->query && path_rec_start(dev, path))
878                        goto err_path;
879                if (skb_queue_len(&neigh->queue) < IPOIB_MAX_PATH_REC_QUEUE) {
880                        push_pseudo_header(skb, neigh->daddr);
881                        __skb_queue_tail(&neigh->queue, skb);
882                } else {
883                        goto err_drop;
884                }
885        }
886
887        spin_unlock_irqrestore(&priv->lock, flags);
888        ipoib_neigh_put(neigh);
889        return;
890
891err_path:
892        ipoib_neigh_free(neigh);
893err_drop:
894        ++dev->stats.tx_dropped;
895        dev_kfree_skb_any(skb);
896
897        spin_unlock_irqrestore(&priv->lock, flags);
898        ipoib_neigh_put(neigh);
899}
900
901static void unicast_arp_send(struct sk_buff *skb, struct net_device *dev,
902                             struct ipoib_pseudo_header *phdr)
903{
904        struct ipoib_dev_priv *priv = netdev_priv(dev);
905        struct ipoib_path *path;
906        unsigned long flags;
907
908        spin_lock_irqsave(&priv->lock, flags);
909
910        path = __path_find(dev, phdr->hwaddr + 4);
911        if (!path || !path->valid) {
912                int new_path = 0;
913
914                if (!path) {
915                        path = path_rec_create(dev, phdr->hwaddr + 4);
916                        new_path = 1;
917                }
918                if (path) {
919                        if (skb_queue_len(&path->queue) < IPOIB_MAX_PATH_REC_QUEUE) {
920                                push_pseudo_header(skb, phdr->hwaddr);
921                                __skb_queue_tail(&path->queue, skb);
922                        } else {
923                                ++dev->stats.tx_dropped;
924                                dev_kfree_skb_any(skb);
925                        }
926
927                        if (!path->query && path_rec_start(dev, path)) {
928                                spin_unlock_irqrestore(&priv->lock, flags);
929                                if (new_path)
930                                        path_free(dev, path);
931                                return;
932                        } else
933                                __path_add(dev, path);
934                } else {
935                        ++dev->stats.tx_dropped;
936                        dev_kfree_skb_any(skb);
937                }
938
939                spin_unlock_irqrestore(&priv->lock, flags);
940                return;
941        }
942
943        if (path->ah) {
944                ipoib_dbg(priv, "Send unicast ARP to %04x\n",
945                          be16_to_cpu(path->pathrec.dlid));
946
947                spin_unlock_irqrestore(&priv->lock, flags);
948                ipoib_send(dev, skb, path->ah, IPOIB_QPN(phdr->hwaddr));
949                return;
950        } else if ((path->query || !path_rec_start(dev, path)) &&
951                   skb_queue_len(&path->queue) < IPOIB_MAX_PATH_REC_QUEUE) {
952                push_pseudo_header(skb, phdr->hwaddr);
953                __skb_queue_tail(&path->queue, skb);
954        } else {
955                ++dev->stats.tx_dropped;
956                dev_kfree_skb_any(skb);
957        }
958
959        spin_unlock_irqrestore(&priv->lock, flags);
960}
961
962static int ipoib_start_xmit(struct sk_buff *skb, struct net_device *dev)
963{
964        struct ipoib_dev_priv *priv = netdev_priv(dev);
965        struct ipoib_neigh *neigh;
966        struct ipoib_pseudo_header *phdr;
967        struct ipoib_header *header;
968        unsigned long flags;
969
970        phdr = (struct ipoib_pseudo_header *) skb->data;
971        skb_pull(skb, sizeof(*phdr));
972        header = (struct ipoib_header *) skb->data;
973
974        if (unlikely(phdr->hwaddr[4] == 0xff)) {
975                /* multicast, arrange "if" according to probability */
976                if ((header->proto != htons(ETH_P_IP)) &&
977                    (header->proto != htons(ETH_P_IPV6)) &&
978                    (header->proto != htons(ETH_P_ARP)) &&
979                    (header->proto != htons(ETH_P_RARP)) &&
980                    (header->proto != htons(ETH_P_TIPC))) {
981                        /* ethertype not supported by IPoIB */
982                        ++dev->stats.tx_dropped;
983                        dev_kfree_skb_any(skb);
984                        return NETDEV_TX_OK;
985                }
986                /* Add in the P_Key for multicast*/
987                phdr->hwaddr[8] = (priv->pkey >> 8) & 0xff;
988                phdr->hwaddr[9] = priv->pkey & 0xff;
989
990                neigh = ipoib_neigh_get(dev, phdr->hwaddr);
991                if (likely(neigh))
992                        goto send_using_neigh;
993                ipoib_mcast_send(dev, phdr->hwaddr, skb);
994                return NETDEV_TX_OK;
995        }
996
997        /* unicast, arrange "switch" according to probability */
998        switch (header->proto) {
999        case htons(ETH_P_IP):
1000        case htons(ETH_P_IPV6):
1001        case htons(ETH_P_TIPC):
1002                neigh = ipoib_neigh_get(dev, phdr->hwaddr);
1003                if (unlikely(!neigh)) {
1004                        neigh_add_path(skb, phdr->hwaddr, dev);
1005                        return NETDEV_TX_OK;
1006                }
1007                break;
1008        case htons(ETH_P_ARP):
1009        case htons(ETH_P_RARP):
1010                /* for unicast ARP and RARP should always perform path find */
1011                unicast_arp_send(skb, dev, phdr);
1012                return NETDEV_TX_OK;
1013        default:
1014                /* ethertype not supported by IPoIB */
1015                ++dev->stats.tx_dropped;
1016                dev_kfree_skb_any(skb);
1017                return NETDEV_TX_OK;
1018        }
1019
1020send_using_neigh:
1021        /* note we now hold a ref to neigh */
1022        if (ipoib_cm_get(neigh)) {
1023                if (ipoib_cm_up(neigh)) {
1024                        ipoib_cm_send(dev, skb, ipoib_cm_get(neigh));
1025                        goto unref;
1026                }
1027        } else if (neigh->ah) {
1028                ipoib_send(dev, skb, neigh->ah, IPOIB_QPN(phdr->hwaddr));
1029                goto unref;
1030        }
1031
1032        if (skb_queue_len(&neigh->queue) < IPOIB_MAX_PATH_REC_QUEUE) {
1033                push_pseudo_header(skb, phdr->hwaddr);
1034                spin_lock_irqsave(&priv->lock, flags);
1035                __skb_queue_tail(&neigh->queue, skb);
1036                spin_unlock_irqrestore(&priv->lock, flags);
1037        } else {
1038                ++dev->stats.tx_dropped;
1039                dev_kfree_skb_any(skb);
1040        }
1041
1042unref:
1043        ipoib_neigh_put(neigh);
1044
1045        return NETDEV_TX_OK;
1046}
1047
1048static void ipoib_timeout(struct net_device *dev)
1049{
1050        struct ipoib_dev_priv *priv = netdev_priv(dev);
1051
1052        ipoib_warn(priv, "transmit timeout: latency %d msecs\n",
1053                   jiffies_to_msecs(jiffies - dev->trans_start));
1054        ipoib_warn(priv, "queue stopped %d, tx_head %u, tx_tail %u\n",
1055                   netif_queue_stopped(dev),
1056                   priv->tx_head, priv->tx_tail);
1057        /* XXX reset QP, etc. */
1058}
1059
1060static int ipoib_hard_header(struct sk_buff *skb,
1061                             struct net_device *dev,
1062                             unsigned short type,
1063                             const void *daddr, const void *saddr, unsigned len)
1064{
1065        struct ipoib_header *header;
1066
1067        header = (struct ipoib_header *) skb_push(skb, sizeof *header);
1068
1069        header->proto = htons(type);
1070        header->reserved = 0;
1071
1072        /*
1073         * we don't rely on dst_entry structure,  always stuff the
1074         * destination address into skb hard header so we can figure out where
1075         * to send the packet later.
1076         */
1077        push_pseudo_header(skb, daddr);
1078
1079        return IPOIB_HARD_LEN;
1080}
1081
1082static void ipoib_set_mcast_list(struct net_device *dev)
1083{
1084        struct ipoib_dev_priv *priv = netdev_priv(dev);
1085
1086        if (!test_bit(IPOIB_FLAG_OPER_UP, &priv->flags)) {
1087                ipoib_dbg(priv, "IPOIB_FLAG_OPER_UP not set");
1088                return;
1089        }
1090
1091        queue_work(priv->wq, &priv->restart_task);
1092}
1093
1094static int ipoib_get_iflink(const struct net_device *dev)
1095{
1096        struct ipoib_dev_priv *priv = netdev_priv(dev);
1097
1098        /* parent interface */
1099        if (!test_bit(IPOIB_FLAG_SUBINTERFACE, &priv->flags))
1100                return dev->ifindex;
1101
1102        /* child/vlan interface */
1103        return priv->parent->ifindex;
1104}
1105
1106static u32 ipoib_addr_hash(struct ipoib_neigh_hash *htbl, u8 *daddr)
1107{
1108        /*
1109         * Use only the address parts that contributes to spreading
1110         * The subnet prefix is not used as one can not connect to
1111         * same remote port (GUID) using the same remote QPN via two
1112         * different subnets.
1113         */
1114         /* qpn octets[1:4) & port GUID octets[12:20) */
1115        u32 *d32 = (u32 *) daddr;
1116        u32 hv;
1117
1118        hv = jhash_3words(d32[3], d32[4], IPOIB_QPN_MASK & d32[0], 0);
1119        return hv & htbl->mask;
1120}
1121
1122struct ipoib_neigh *ipoib_neigh_get(struct net_device *dev, u8 *daddr)
1123{
1124        struct ipoib_dev_priv *priv = netdev_priv(dev);
1125        struct ipoib_neigh_table *ntbl = &priv->ntbl;
1126        struct ipoib_neigh_hash *htbl;
1127        struct ipoib_neigh *neigh = NULL;
1128        u32 hash_val;
1129
1130        rcu_read_lock_bh();
1131
1132        htbl = rcu_dereference_bh(ntbl->htbl);
1133
1134        if (!htbl)
1135                goto out_unlock;
1136
1137        hash_val = ipoib_addr_hash(htbl, daddr);
1138        for (neigh = rcu_dereference_bh(htbl->buckets[hash_val]);
1139             neigh != NULL;
1140             neigh = rcu_dereference_bh(neigh->hnext)) {
1141                if (memcmp(daddr, neigh->daddr, INFINIBAND_ALEN) == 0) {
1142                        /* found, take one ref on behalf of the caller */
1143                        if (!atomic_inc_not_zero(&neigh->refcnt)) {
1144                                /* deleted */
1145                                neigh = NULL;
1146                                goto out_unlock;
1147                        }
1148
1149                        if (likely(skb_queue_len(&neigh->queue) < IPOIB_MAX_PATH_REC_QUEUE))
1150                                neigh->alive = jiffies;
1151                        goto out_unlock;
1152                }
1153        }
1154
1155out_unlock:
1156        rcu_read_unlock_bh();
1157        return neigh;
1158}
1159
1160static void __ipoib_reap_neigh(struct ipoib_dev_priv *priv)
1161{
1162        struct ipoib_neigh_table *ntbl = &priv->ntbl;
1163        struct ipoib_neigh_hash *htbl;
1164        unsigned long neigh_obsolete;
1165        unsigned long dt;
1166        unsigned long flags;
1167        int i;
1168        LIST_HEAD(remove_list);
1169        struct ipoib_mcast *mcast, *tmcast;
1170        struct net_device *dev = priv->dev;
1171
1172        if (test_bit(IPOIB_STOP_NEIGH_GC, &priv->flags))
1173                return;
1174
1175        spin_lock_irqsave(&priv->lock, flags);
1176
1177        htbl = rcu_dereference_protected(ntbl->htbl,
1178                                         lockdep_is_held(&priv->lock));
1179
1180        if (!htbl)
1181                goto out_unlock;
1182
1183        /* neigh is obsolete if it was idle for two GC periods */
1184        dt = 2 * arp_tbl.gc_interval;
1185        neigh_obsolete = jiffies - dt;
1186        /* handle possible race condition */
1187        if (test_bit(IPOIB_STOP_NEIGH_GC, &priv->flags))
1188                goto out_unlock;
1189
1190        for (i = 0; i < htbl->size; i++) {
1191                struct ipoib_neigh *neigh;
1192                struct ipoib_neigh __rcu **np = &htbl->buckets[i];
1193
1194                while ((neigh = rcu_dereference_protected(*np,
1195                                                          lockdep_is_held(&priv->lock))) != NULL) {
1196                        /* was the neigh idle for two GC periods */
1197                        if (time_after(neigh_obsolete, neigh->alive)) {
1198                                u8 *mgid = neigh->daddr + 4;
1199
1200                                /* Is this multicast ? */
1201                                if (*mgid == 0xff) {
1202                                        mcast = __ipoib_mcast_find(dev, mgid);
1203
1204                                        if (mcast && test_bit(IPOIB_MCAST_FLAG_SENDONLY, &mcast->flags)) {
1205                                                list_del(&mcast->list);
1206                                                rb_erase(&mcast->rb_node, &priv->multicast_tree);
1207                                                list_add_tail(&mcast->list, &remove_list);
1208                                        }
1209                                }
1210
1211                                rcu_assign_pointer(*np,
1212                                                   rcu_dereference_protected(neigh->hnext,
1213                                                                             lockdep_is_held(&priv->lock)));
1214                                /* remove from path/mc list */
1215                                list_del(&neigh->list);
1216                                call_rcu(&neigh->rcu, ipoib_neigh_reclaim);
1217                        } else {
1218                                np = &neigh->hnext;
1219                        }
1220
1221                }
1222        }
1223
1224out_unlock:
1225        spin_unlock_irqrestore(&priv->lock, flags);
1226        list_for_each_entry_safe(mcast, tmcast, &remove_list, list) {
1227                ipoib_mcast_leave(dev, mcast);
1228                ipoib_mcast_free(mcast);
1229        }
1230}
1231
1232static void ipoib_reap_neigh(struct work_struct *work)
1233{
1234        struct ipoib_dev_priv *priv =
1235                container_of(work, struct ipoib_dev_priv, neigh_reap_task.work);
1236
1237        __ipoib_reap_neigh(priv);
1238
1239        if (!test_bit(IPOIB_STOP_NEIGH_GC, &priv->flags))
1240                queue_delayed_work(priv->wq, &priv->neigh_reap_task,
1241                                   arp_tbl.gc_interval);
1242}
1243
1244
1245static struct ipoib_neigh *ipoib_neigh_ctor(u8 *daddr,
1246                                      struct net_device *dev)
1247{
1248        struct ipoib_neigh *neigh;
1249
1250        neigh = kzalloc(sizeof *neigh, GFP_ATOMIC);
1251        if (!neigh)
1252                return NULL;
1253
1254        neigh->dev = dev;
1255        memcpy(&neigh->daddr, daddr, sizeof(neigh->daddr));
1256        skb_queue_head_init(&neigh->queue);
1257        INIT_LIST_HEAD(&neigh->list);
1258        ipoib_cm_set(neigh, NULL);
1259        /* one ref on behalf of the caller */
1260        atomic_set(&neigh->refcnt, 1);
1261
1262        return neigh;
1263}
1264
1265struct ipoib_neigh *ipoib_neigh_alloc(u8 *daddr,
1266                                      struct net_device *dev)
1267{
1268        struct ipoib_dev_priv *priv = netdev_priv(dev);
1269        struct ipoib_neigh_table *ntbl = &priv->ntbl;
1270        struct ipoib_neigh_hash *htbl;
1271        struct ipoib_neigh *neigh;
1272        u32 hash_val;
1273
1274        htbl = rcu_dereference_protected(ntbl->htbl,
1275                                         lockdep_is_held(&priv->lock));
1276        if (!htbl) {
1277                neigh = NULL;
1278                goto out_unlock;
1279        }
1280
1281        /* need to add a new neigh, but maybe some other thread succeeded?
1282         * recalc hash, maybe hash resize took place so we do a search
1283         */
1284        hash_val = ipoib_addr_hash(htbl, daddr);
1285        for (neigh = rcu_dereference_protected(htbl->buckets[hash_val],
1286                                               lockdep_is_held(&priv->lock));
1287             neigh != NULL;
1288             neigh = rcu_dereference_protected(neigh->hnext,
1289                                               lockdep_is_held(&priv->lock))) {
1290                if (memcmp(daddr, neigh->daddr, INFINIBAND_ALEN) == 0) {
1291                        /* found, take one ref on behalf of the caller */
1292                        if (!atomic_inc_not_zero(&neigh->refcnt)) {
1293                                /* deleted */
1294                                neigh = NULL;
1295                                break;
1296                        }
1297                        neigh->alive = jiffies;
1298                        goto out_unlock;
1299                }
1300        }
1301
1302        neigh = ipoib_neigh_ctor(daddr, dev);
1303        if (!neigh)
1304                goto out_unlock;
1305
1306        /* one ref on behalf of the hash table */
1307        atomic_inc(&neigh->refcnt);
1308        neigh->alive = jiffies;
1309        /* put in hash */
1310        rcu_assign_pointer(neigh->hnext,
1311                           rcu_dereference_protected(htbl->buckets[hash_val],
1312                                                     lockdep_is_held(&priv->lock)));
1313        rcu_assign_pointer(htbl->buckets[hash_val], neigh);
1314        atomic_inc(&ntbl->entries);
1315
1316out_unlock:
1317
1318        return neigh;
1319}
1320
1321void ipoib_neigh_dtor(struct ipoib_neigh *neigh)
1322{
1323        /* neigh reference count was dropprd to zero */
1324        struct net_device *dev = neigh->dev;
1325        struct ipoib_dev_priv *priv = netdev_priv(dev);
1326        struct sk_buff *skb;
1327        if (neigh->ah)
1328                ipoib_put_ah(neigh->ah);
1329        while ((skb = __skb_dequeue(&neigh->queue))) {
1330                ++dev->stats.tx_dropped;
1331                dev_kfree_skb_any(skb);
1332        }
1333        if (ipoib_cm_get(neigh))
1334                ipoib_cm_destroy_tx(ipoib_cm_get(neigh));
1335        ipoib_dbg(netdev_priv(dev),
1336                  "neigh free for %06x %pI6\n",
1337                  IPOIB_QPN(neigh->daddr),
1338                  neigh->daddr + 4);
1339        kfree(neigh);
1340        if (atomic_dec_and_test(&priv->ntbl.entries)) {
1341                if (test_bit(IPOIB_NEIGH_TBL_FLUSH, &priv->flags))
1342                        complete(&priv->ntbl.flushed);
1343        }
1344}
1345
1346static void ipoib_neigh_reclaim(struct rcu_head *rp)
1347{
1348        /* Called as a result of removal from hash table */
1349        struct ipoib_neigh *neigh = container_of(rp, struct ipoib_neigh, rcu);
1350        /* note TX context may hold another ref */
1351        ipoib_neigh_put(neigh);
1352}
1353
1354void ipoib_neigh_free(struct ipoib_neigh *neigh)
1355{
1356        struct net_device *dev = neigh->dev;
1357        struct ipoib_dev_priv *priv = netdev_priv(dev);
1358        struct ipoib_neigh_table *ntbl = &priv->ntbl;
1359        struct ipoib_neigh_hash *htbl;
1360        struct ipoib_neigh __rcu **np;
1361        struct ipoib_neigh *n;
1362        u32 hash_val;
1363
1364        htbl = rcu_dereference_protected(ntbl->htbl,
1365                                        lockdep_is_held(&priv->lock));
1366        if (!htbl)
1367                return;
1368
1369        hash_val = ipoib_addr_hash(htbl, neigh->daddr);
1370        np = &htbl->buckets[hash_val];
1371        for (n = rcu_dereference_protected(*np,
1372                                            lockdep_is_held(&priv->lock));
1373             n != NULL;
1374             n = rcu_dereference_protected(*np,
1375                                        lockdep_is_held(&priv->lock))) {
1376                if (n == neigh) {
1377                        /* found */
1378                        rcu_assign_pointer(*np,
1379                                           rcu_dereference_protected(neigh->hnext,
1380                                                                     lockdep_is_held(&priv->lock)));
1381                        /* remove from parent list */
1382                        list_del(&neigh->list);
1383                        call_rcu(&neigh->rcu, ipoib_neigh_reclaim);
1384                        return;
1385                } else {
1386                        np = &n->hnext;
1387                }
1388        }
1389}
1390
1391static int ipoib_neigh_hash_init(struct ipoib_dev_priv *priv)
1392{
1393        struct ipoib_neigh_table *ntbl = &priv->ntbl;
1394        struct ipoib_neigh_hash *htbl;
1395        struct ipoib_neigh __rcu **buckets;
1396        u32 size;
1397
1398        clear_bit(IPOIB_NEIGH_TBL_FLUSH, &priv->flags);
1399        ntbl->htbl = NULL;
1400        htbl = kzalloc(sizeof(*htbl), GFP_KERNEL);
1401        if (!htbl)
1402                return -ENOMEM;
1403        set_bit(IPOIB_STOP_NEIGH_GC, &priv->flags);
1404        size = roundup_pow_of_two(arp_tbl.gc_thresh3);
1405        buckets = kzalloc(size * sizeof(*buckets), GFP_KERNEL);
1406        if (!buckets) {
1407                kfree(htbl);
1408                return -ENOMEM;
1409        }
1410        htbl->size = size;
1411        htbl->mask = (size - 1);
1412        htbl->buckets = buckets;
1413        RCU_INIT_POINTER(ntbl->htbl, htbl);
1414        htbl->ntbl = ntbl;
1415        atomic_set(&ntbl->entries, 0);
1416
1417        /* start garbage collection */
1418        clear_bit(IPOIB_STOP_NEIGH_GC, &priv->flags);
1419        queue_delayed_work(priv->wq, &priv->neigh_reap_task,
1420                           arp_tbl.gc_interval);
1421
1422        return 0;
1423}
1424
1425static void neigh_hash_free_rcu(struct rcu_head *head)
1426{
1427        struct ipoib_neigh_hash *htbl = container_of(head,
1428                                                    struct ipoib_neigh_hash,
1429                                                    rcu);
1430        struct ipoib_neigh __rcu **buckets = htbl->buckets;
1431        struct ipoib_neigh_table *ntbl = htbl->ntbl;
1432
1433        kfree(buckets);
1434        kfree(htbl);
1435        complete(&ntbl->deleted);
1436}
1437
1438void ipoib_del_neighs_by_gid(struct net_device *dev, u8 *gid)
1439{
1440        struct ipoib_dev_priv *priv = netdev_priv(dev);
1441        struct ipoib_neigh_table *ntbl = &priv->ntbl;
1442        struct ipoib_neigh_hash *htbl;
1443        unsigned long flags;
1444        int i;
1445
1446        /* remove all neigh connected to a given path or mcast */
1447        spin_lock_irqsave(&priv->lock, flags);
1448
1449        htbl = rcu_dereference_protected(ntbl->htbl,
1450                                         lockdep_is_held(&priv->lock));
1451
1452        if (!htbl)
1453                goto out_unlock;
1454
1455        for (i = 0; i < htbl->size; i++) {
1456                struct ipoib_neigh *neigh;
1457                struct ipoib_neigh __rcu **np = &htbl->buckets[i];
1458
1459                while ((neigh = rcu_dereference_protected(*np,
1460                                                          lockdep_is_held(&priv->lock))) != NULL) {
1461                        /* delete neighs belong to this parent */
1462                        if (!memcmp(gid, neigh->daddr + 4, sizeof (union ib_gid))) {
1463                                rcu_assign_pointer(*np,
1464                                                   rcu_dereference_protected(neigh->hnext,
1465                                                                             lockdep_is_held(&priv->lock)));
1466                                /* remove from parent list */
1467                                list_del(&neigh->list);
1468                                call_rcu(&neigh->rcu, ipoib_neigh_reclaim);
1469                        } else {
1470                                np = &neigh->hnext;
1471                        }
1472
1473                }
1474        }
1475out_unlock:
1476        spin_unlock_irqrestore(&priv->lock, flags);
1477}
1478
1479static void ipoib_flush_neighs(struct ipoib_dev_priv *priv)
1480{
1481        struct ipoib_neigh_table *ntbl = &priv->ntbl;
1482        struct ipoib_neigh_hash *htbl;
1483        unsigned long flags;
1484        int i, wait_flushed = 0;
1485
1486        init_completion(&priv->ntbl.flushed);
1487
1488        spin_lock_irqsave(&priv->lock, flags);
1489
1490        htbl = rcu_dereference_protected(ntbl->htbl,
1491                                        lockdep_is_held(&priv->lock));
1492        if (!htbl)
1493                goto out_unlock;
1494
1495        wait_flushed = atomic_read(&priv->ntbl.entries);
1496        if (!wait_flushed)
1497                goto free_htbl;
1498
1499        for (i = 0; i < htbl->size; i++) {
1500                struct ipoib_neigh *neigh;
1501                struct ipoib_neigh __rcu **np = &htbl->buckets[i];
1502
1503                while ((neigh = rcu_dereference_protected(*np,
1504                                       lockdep_is_held(&priv->lock))) != NULL) {
1505                        rcu_assign_pointer(*np,
1506                                           rcu_dereference_protected(neigh->hnext,
1507                                                                     lockdep_is_held(&priv->lock)));
1508                        /* remove from path/mc list */
1509                        list_del(&neigh->list);
1510                        call_rcu(&neigh->rcu, ipoib_neigh_reclaim);
1511                }
1512        }
1513
1514free_htbl:
1515        rcu_assign_pointer(ntbl->htbl, NULL);
1516        call_rcu(&htbl->rcu, neigh_hash_free_rcu);
1517
1518out_unlock:
1519        spin_unlock_irqrestore(&priv->lock, flags);
1520        if (wait_flushed)
1521                wait_for_completion(&priv->ntbl.flushed);
1522}
1523
1524static void ipoib_neigh_hash_uninit(struct net_device *dev)
1525{
1526        struct ipoib_dev_priv *priv = netdev_priv(dev);
1527        int stopped;
1528
1529        ipoib_dbg(priv, "ipoib_neigh_hash_uninit\n");
1530        init_completion(&priv->ntbl.deleted);
1531        set_bit(IPOIB_NEIGH_TBL_FLUSH, &priv->flags);
1532
1533        /* Stop GC if called at init fail need to cancel work */
1534        stopped = test_and_set_bit(IPOIB_STOP_NEIGH_GC, &priv->flags);
1535        if (!stopped)
1536                cancel_delayed_work(&priv->neigh_reap_task);
1537
1538        ipoib_flush_neighs(priv);
1539
1540        wait_for_completion(&priv->ntbl.deleted);
1541}
1542
1543
1544int ipoib_dev_init(struct net_device *dev, struct ib_device *ca, int port)
1545{
1546        struct ipoib_dev_priv *priv = netdev_priv(dev);
1547
1548        /* Allocate RX/TX "rings" to hold queued skbs */
1549        priv->rx_ring = kzalloc(ipoib_recvq_size * sizeof *priv->rx_ring,
1550                                GFP_KERNEL);
1551        if (!priv->rx_ring) {
1552                printk(KERN_WARNING "%s: failed to allocate RX ring (%d entries)\n",
1553                       ca->name, ipoib_recvq_size);
1554                goto out;
1555        }
1556
1557        priv->tx_ring = vzalloc(ipoib_sendq_size * sizeof *priv->tx_ring);
1558        if (!priv->tx_ring) {
1559                printk(KERN_WARNING "%s: failed to allocate TX ring (%d entries)\n",
1560                       ca->name, ipoib_sendq_size);
1561                goto out_rx_ring_cleanup;
1562        }
1563
1564        /* priv->tx_head, tx_tail & tx_outstanding are already 0 */
1565
1566        if (ipoib_ib_dev_init(dev, ca, port))
1567                goto out_tx_ring_cleanup;
1568
1569        /*
1570         * Must be after ipoib_ib_dev_init so we can allocate a per
1571         * device wq there and use it here
1572         */
1573        if (ipoib_neigh_hash_init(priv) < 0)
1574                goto out_dev_uninit;
1575
1576        return 0;
1577
1578out_dev_uninit:
1579        ipoib_ib_dev_cleanup(dev);
1580
1581out_tx_ring_cleanup:
1582        vfree(priv->tx_ring);
1583
1584out_rx_ring_cleanup:
1585        kfree(priv->rx_ring);
1586
1587out:
1588        return -ENOMEM;
1589}
1590
1591void ipoib_dev_cleanup(struct net_device *dev)
1592{
1593        struct ipoib_dev_priv *priv = netdev_priv(dev), *cpriv, *tcpriv;
1594        LIST_HEAD(head);
1595
1596        ASSERT_RTNL();
1597
1598        ipoib_delete_debug_files(dev);
1599
1600        /* Delete any child interfaces first */
1601        list_for_each_entry_safe(cpriv, tcpriv, &priv->child_intfs, list) {
1602                /* Stop GC on child */
1603                set_bit(IPOIB_STOP_NEIGH_GC, &cpriv->flags);
1604                cancel_delayed_work(&cpriv->neigh_reap_task);
1605                unregister_netdevice_queue(cpriv->dev, &head);
1606        }
1607        unregister_netdevice_many(&head);
1608
1609        /*
1610         * Must be before ipoib_ib_dev_cleanup or we delete an in use
1611         * work queue
1612         */
1613        ipoib_neigh_hash_uninit(dev);
1614
1615        ipoib_ib_dev_cleanup(dev);
1616
1617        kfree(priv->rx_ring);
1618        vfree(priv->tx_ring);
1619
1620        priv->rx_ring = NULL;
1621        priv->tx_ring = NULL;
1622}
1623
1624static const struct header_ops ipoib_header_ops = {
1625        .create = ipoib_hard_header,
1626};
1627
1628static const struct net_device_ops ipoib_netdev_ops = {
1629        .ndo_uninit              = ipoib_uninit,
1630        .ndo_open                = ipoib_open,
1631        .ndo_stop                = ipoib_stop,
1632        .ndo_change_mtu          = ipoib_change_mtu,
1633        .ndo_fix_features        = ipoib_fix_features,
1634        .ndo_start_xmit          = ipoib_start_xmit,
1635        .ndo_tx_timeout          = ipoib_timeout,
1636        .ndo_set_rx_mode         = ipoib_set_mcast_list,
1637        .ndo_get_iflink          = ipoib_get_iflink,
1638};
1639
1640void ipoib_setup(struct net_device *dev)
1641{
1642        struct ipoib_dev_priv *priv = netdev_priv(dev);
1643
1644        dev->netdev_ops          = &ipoib_netdev_ops;
1645        dev->header_ops          = &ipoib_header_ops;
1646
1647        ipoib_set_ethtool_ops(dev);
1648
1649        netif_napi_add(dev, &priv->napi, ipoib_poll, NAPI_POLL_WEIGHT);
1650
1651        dev->watchdog_timeo      = HZ;
1652
1653        dev->flags              |= IFF_BROADCAST | IFF_MULTICAST;
1654
1655        dev->hard_header_len     = IPOIB_HARD_LEN;
1656        dev->addr_len            = INFINIBAND_ALEN;
1657        dev->type                = ARPHRD_INFINIBAND;
1658        dev->tx_queue_len        = ipoib_sendq_size * 2;
1659        dev->features            = (NETIF_F_VLAN_CHALLENGED     |
1660                                    NETIF_F_HIGHDMA);
1661        netif_keep_dst(dev);
1662
1663        memcpy(dev->broadcast, ipv4_bcast_addr, INFINIBAND_ALEN);
1664
1665        priv->dev = dev;
1666
1667        spin_lock_init(&priv->lock);
1668
1669        init_rwsem(&priv->vlan_rwsem);
1670
1671        INIT_LIST_HEAD(&priv->path_list);
1672        INIT_LIST_HEAD(&priv->child_intfs);
1673        INIT_LIST_HEAD(&priv->dead_ahs);
1674        INIT_LIST_HEAD(&priv->multicast_list);
1675
1676        INIT_DELAYED_WORK(&priv->mcast_task,   ipoib_mcast_join_task);
1677        INIT_WORK(&priv->carrier_on_task, ipoib_mcast_carrier_on_task);
1678        INIT_WORK(&priv->flush_light,   ipoib_ib_dev_flush_light);
1679        INIT_WORK(&priv->flush_normal,   ipoib_ib_dev_flush_normal);
1680        INIT_WORK(&priv->flush_heavy,   ipoib_ib_dev_flush_heavy);
1681        INIT_WORK(&priv->restart_task, ipoib_mcast_restart_task);
1682        INIT_DELAYED_WORK(&priv->ah_reap_task, ipoib_reap_ah);
1683        INIT_DELAYED_WORK(&priv->neigh_reap_task, ipoib_reap_neigh);
1684}
1685
1686struct ipoib_dev_priv *ipoib_intf_alloc(const char *name)
1687{
1688        struct net_device *dev;
1689
1690        dev = alloc_netdev((int)sizeof(struct ipoib_dev_priv), name,
1691                           NET_NAME_UNKNOWN, ipoib_setup);
1692        if (!dev)
1693                return NULL;
1694
1695        return netdev_priv(dev);
1696}
1697
1698static ssize_t show_pkey(struct device *dev,
1699                         struct device_attribute *attr, char *buf)
1700{
1701        struct ipoib_dev_priv *priv = netdev_priv(to_net_dev(dev));
1702
1703        return sprintf(buf, "0x%04x\n", priv->pkey);
1704}
1705static DEVICE_ATTR(pkey, S_IRUGO, show_pkey, NULL);
1706
1707static ssize_t show_umcast(struct device *dev,
1708                           struct device_attribute *attr, char *buf)
1709{
1710        struct ipoib_dev_priv *priv = netdev_priv(to_net_dev(dev));
1711
1712        return sprintf(buf, "%d\n", test_bit(IPOIB_FLAG_UMCAST, &priv->flags));
1713}
1714
1715void ipoib_set_umcast(struct net_device *ndev, int umcast_val)
1716{
1717        struct ipoib_dev_priv *priv = netdev_priv(ndev);
1718
1719        if (umcast_val > 0) {
1720                set_bit(IPOIB_FLAG_UMCAST, &priv->flags);
1721                ipoib_warn(priv, "ignoring multicast groups joined directly "
1722                                "by userspace\n");
1723        } else
1724                clear_bit(IPOIB_FLAG_UMCAST, &priv->flags);
1725}
1726
1727static ssize_t set_umcast(struct device *dev,
1728                          struct device_attribute *attr,
1729                          const char *buf, size_t count)
1730{
1731        unsigned long umcast_val = simple_strtoul(buf, NULL, 0);
1732
1733        ipoib_set_umcast(to_net_dev(dev), umcast_val);
1734
1735        return count;
1736}
1737static DEVICE_ATTR(umcast, S_IWUSR | S_IRUGO, show_umcast, set_umcast);
1738
1739int ipoib_add_umcast_attr(struct net_device *dev)
1740{
1741        return device_create_file(&dev->dev, &dev_attr_umcast);
1742}
1743
1744static ssize_t create_child(struct device *dev,
1745                            struct device_attribute *attr,
1746                            const char *buf, size_t count)
1747{
1748        int pkey;
1749        int ret;
1750
1751        if (sscanf(buf, "%i", &pkey) != 1)
1752                return -EINVAL;
1753
1754        if (pkey <= 0 || pkey > 0xffff || pkey == 0x8000)
1755                return -EINVAL;
1756
1757        /*
1758         * Set the full membership bit, so that we join the right
1759         * broadcast group, etc.
1760         */
1761        pkey |= 0x8000;
1762
1763        ret = ipoib_vlan_add(to_net_dev(dev), pkey);
1764
1765        return ret ? ret : count;
1766}
1767static DEVICE_ATTR(create_child, S_IWUSR, NULL, create_child);
1768
1769static ssize_t delete_child(struct device *dev,
1770                            struct device_attribute *attr,
1771                            const char *buf, size_t count)
1772{
1773        int pkey;
1774        int ret;
1775
1776        if (sscanf(buf, "%i", &pkey) != 1)
1777                return -EINVAL;
1778
1779        if (pkey < 0 || pkey > 0xffff)
1780                return -EINVAL;
1781
1782        ret = ipoib_vlan_delete(to_net_dev(dev), pkey);
1783
1784        return ret ? ret : count;
1785
1786}
1787static DEVICE_ATTR(delete_child, S_IWUSR, NULL, delete_child);
1788
1789int ipoib_add_pkey_attr(struct net_device *dev)
1790{
1791        return device_create_file(&dev->dev, &dev_attr_pkey);
1792}
1793
1794int ipoib_set_dev_features(struct ipoib_dev_priv *priv, struct ib_device *hca)
1795{
1796        struct ib_device_attr *device_attr;
1797        int result = -ENOMEM;
1798
1799        device_attr = kmalloc(sizeof *device_attr, GFP_KERNEL);
1800        if (!device_attr) {
1801                printk(KERN_WARNING "%s: allocation of %zu bytes failed\n",
1802                       hca->name, sizeof *device_attr);
1803                return result;
1804        }
1805
1806        result = ib_query_device(hca, device_attr);
1807        if (result) {
1808                printk(KERN_WARNING "%s: ib_query_device failed (ret = %d)\n",
1809                       hca->name, result);
1810                kfree(device_attr);
1811                return result;
1812        }
1813        priv->hca_caps = device_attr->device_cap_flags;
1814
1815        kfree(device_attr);
1816
1817        if (priv->hca_caps & IB_DEVICE_UD_IP_CSUM) {
1818                priv->dev->hw_features = NETIF_F_SG |
1819                        NETIF_F_IP_CSUM | NETIF_F_RXCSUM;
1820
1821                if (priv->hca_caps & IB_DEVICE_UD_TSO)
1822                        priv->dev->hw_features |= NETIF_F_TSO;
1823
1824                priv->dev->features |= priv->dev->hw_features;
1825        }
1826
1827        return 0;
1828}
1829
1830static struct net_device *ipoib_add_port(const char *format,
1831                                         struct ib_device *hca, u8 port)
1832{
1833        struct ipoib_dev_priv *priv;
1834        struct ib_port_attr attr;
1835        int result = -ENOMEM;
1836
1837        priv = ipoib_intf_alloc(format);
1838        if (!priv)
1839                goto alloc_mem_failed;
1840
1841        SET_NETDEV_DEV(priv->dev, hca->dma_device);
1842        priv->dev->dev_id = port - 1;
1843
1844        result = ib_query_port(hca, port, &attr);
1845        if (!result)
1846                priv->max_ib_mtu = ib_mtu_enum_to_int(attr.max_mtu);
1847        else {
1848                printk(KERN_WARNING "%s: ib_query_port %d failed\n",
1849                       hca->name, port);
1850                goto device_init_failed;
1851        }
1852
1853        /* MTU will be reset when mcast join happens */
1854        priv->dev->mtu  = IPOIB_UD_MTU(priv->max_ib_mtu);
1855        priv->mcast_mtu  = priv->admin_mtu = priv->dev->mtu;
1856
1857        priv->dev->neigh_priv_len = sizeof(struct ipoib_neigh);
1858
1859        result = ib_query_pkey(hca, port, 0, &priv->pkey);
1860        if (result) {
1861                printk(KERN_WARNING "%s: ib_query_pkey port %d failed (ret = %d)\n",
1862                       hca->name, port, result);
1863                goto device_init_failed;
1864        }
1865
1866        result = ipoib_set_dev_features(priv, hca);
1867        if (result)
1868                goto device_init_failed;
1869
1870        /*
1871         * Set the full membership bit, so that we join the right
1872         * broadcast group, etc.
1873         */
1874        priv->pkey |= 0x8000;
1875
1876        priv->dev->broadcast[8] = priv->pkey >> 8;
1877        priv->dev->broadcast[9] = priv->pkey & 0xff;
1878
1879        result = ib_query_gid(hca, port, 0, &priv->local_gid, NULL);
1880        if (result) {
1881                printk(KERN_WARNING "%s: ib_query_gid port %d failed (ret = %d)\n",
1882                       hca->name, port, result);
1883                goto device_init_failed;
1884        } else
1885                memcpy(priv->dev->dev_addr + 4, priv->local_gid.raw, sizeof (union ib_gid));
1886
1887        result = ipoib_dev_init(priv->dev, hca, port);
1888        if (result < 0) {
1889                printk(KERN_WARNING "%s: failed to initialize port %d (ret = %d)\n",
1890                       hca->name, port, result);
1891                goto device_init_failed;
1892        }
1893
1894        INIT_IB_EVENT_HANDLER(&priv->event_handler,
1895                              priv->ca, ipoib_event);
1896        result = ib_register_event_handler(&priv->event_handler);
1897        if (result < 0) {
1898                printk(KERN_WARNING "%s: ib_register_event_handler failed for "
1899                       "port %d (ret = %d)\n",
1900                       hca->name, port, result);
1901                goto event_failed;
1902        }
1903
1904        result = register_netdev(priv->dev);
1905        if (result) {
1906                printk(KERN_WARNING "%s: couldn't register ipoib port %d; error %d\n",
1907                       hca->name, port, result);
1908                goto register_failed;
1909        }
1910
1911        ipoib_create_debug_files(priv->dev);
1912
1913        if (ipoib_cm_add_mode_attr(priv->dev))
1914                goto sysfs_failed;
1915        if (ipoib_add_pkey_attr(priv->dev))
1916                goto sysfs_failed;
1917        if (ipoib_add_umcast_attr(priv->dev))
1918                goto sysfs_failed;
1919        if (device_create_file(&priv->dev->dev, &dev_attr_create_child))
1920                goto sysfs_failed;
1921        if (device_create_file(&priv->dev->dev, &dev_attr_delete_child))
1922                goto sysfs_failed;
1923
1924        return priv->dev;
1925
1926sysfs_failed:
1927        ipoib_delete_debug_files(priv->dev);
1928        unregister_netdev(priv->dev);
1929
1930register_failed:
1931        ib_unregister_event_handler(&priv->event_handler);
1932        flush_workqueue(ipoib_workqueue);
1933        /* Stop GC if started before flush */
1934        set_bit(IPOIB_STOP_NEIGH_GC, &priv->flags);
1935        cancel_delayed_work(&priv->neigh_reap_task);
1936        flush_workqueue(priv->wq);
1937
1938event_failed:
1939        ipoib_dev_cleanup(priv->dev);
1940
1941device_init_failed:
1942        free_netdev(priv->dev);
1943
1944alloc_mem_failed:
1945        return ERR_PTR(result);
1946}
1947
1948static void ipoib_add_one(struct ib_device *device)
1949{
1950        struct list_head *dev_list;
1951        struct net_device *dev;
1952        struct ipoib_dev_priv *priv;
1953        int p;
1954        int count = 0;
1955
1956        dev_list = kmalloc(sizeof *dev_list, GFP_KERNEL);
1957        if (!dev_list)
1958                return;
1959
1960        INIT_LIST_HEAD(dev_list);
1961
1962        for (p = rdma_start_port(device); p <= rdma_end_port(device); ++p) {
1963                if (!rdma_protocol_ib(device, p))
1964                        continue;
1965                dev = ipoib_add_port("ib%d", device, p);
1966                if (!IS_ERR(dev)) {
1967                        priv = netdev_priv(dev);
1968                        list_add_tail(&priv->list, dev_list);
1969                        count++;
1970                }
1971        }
1972
1973        if (!count) {
1974                kfree(dev_list);
1975                return;
1976        }
1977
1978        ib_set_client_data(device, &ipoib_client, dev_list);
1979}
1980
1981static void ipoib_remove_one(struct ib_device *device, void *client_data)
1982{
1983        struct ipoib_dev_priv *priv, *tmp;
1984        struct list_head *dev_list = client_data;
1985
1986        if (!dev_list)
1987                return;
1988
1989        list_for_each_entry_safe(priv, tmp, dev_list, list) {
1990                ib_unregister_event_handler(&priv->event_handler);
1991                flush_workqueue(ipoib_workqueue);
1992
1993                rtnl_lock();
1994                dev_change_flags(priv->dev, priv->dev->flags & ~IFF_UP);
1995                rtnl_unlock();
1996
1997                /* Stop GC */
1998                set_bit(IPOIB_STOP_NEIGH_GC, &priv->flags);
1999                cancel_delayed_work(&priv->neigh_reap_task);
2000                flush_workqueue(priv->wq);
2001
2002                unregister_netdev(priv->dev);
2003                free_netdev(priv->dev);
2004        }
2005
2006        kfree(dev_list);
2007}
2008
2009static int __init ipoib_init_module(void)
2010{
2011        int ret;
2012
2013        ipoib_recvq_size = roundup_pow_of_two(ipoib_recvq_size);
2014        ipoib_recvq_size = min(ipoib_recvq_size, IPOIB_MAX_QUEUE_SIZE);
2015        ipoib_recvq_size = max(ipoib_recvq_size, IPOIB_MIN_QUEUE_SIZE);
2016
2017        ipoib_sendq_size = roundup_pow_of_two(ipoib_sendq_size);
2018        ipoib_sendq_size = min(ipoib_sendq_size, IPOIB_MAX_QUEUE_SIZE);
2019        ipoib_sendq_size = max3(ipoib_sendq_size, 2 * MAX_SEND_CQE, IPOIB_MIN_QUEUE_SIZE);
2020#ifdef CONFIG_INFINIBAND_IPOIB_CM
2021        ipoib_max_conn_qp = min(ipoib_max_conn_qp, IPOIB_CM_MAX_CONN_QP);
2022#endif
2023
2024        /*
2025         * When copying small received packets, we only copy from the
2026         * linear data part of the SKB, so we rely on this condition.
2027         */
2028        BUILD_BUG_ON(IPOIB_CM_COPYBREAK > IPOIB_CM_HEAD_SIZE);
2029
2030        ret = ipoib_register_debugfs();
2031        if (ret)
2032                return ret;
2033
2034        /*
2035         * We create a global workqueue here that is used for all flush
2036         * operations.  However, if you attempt to flush a workqueue
2037         * from a task on that same workqueue, it deadlocks the system.
2038         * We want to be able to flush the tasks associated with a
2039         * specific net device, so we also create a workqueue for each
2040         * netdevice.  We queue up the tasks for that device only on
2041         * its private workqueue, and we only queue up flush events
2042         * on our global flush workqueue.  This avoids the deadlocks.
2043         */
2044        ipoib_workqueue = create_singlethread_workqueue("ipoib_flush");
2045        if (!ipoib_workqueue) {
2046                ret = -ENOMEM;
2047                goto err_fs;
2048        }
2049
2050        ib_sa_register_client(&ipoib_sa_client);
2051
2052        ret = ib_register_client(&ipoib_client);
2053        if (ret)
2054                goto err_sa;
2055
2056        ret = ipoib_netlink_init();
2057        if (ret)
2058                goto err_client;
2059
2060        return 0;
2061
2062err_client:
2063        ib_unregister_client(&ipoib_client);
2064
2065err_sa:
2066        ib_sa_unregister_client(&ipoib_sa_client);
2067        destroy_workqueue(ipoib_workqueue);
2068
2069err_fs:
2070        ipoib_unregister_debugfs();
2071
2072        return ret;
2073}
2074
2075static void __exit ipoib_cleanup_module(void)
2076{
2077        ipoib_netlink_fini();
2078        ib_unregister_client(&ipoib_client);
2079        ib_sa_unregister_client(&ipoib_sa_client);
2080        ipoib_unregister_debugfs();
2081        destroy_workqueue(ipoib_workqueue);
2082}
2083
2084module_init(ipoib_init_module);
2085module_exit(ipoib_cleanup_module);
Note: See TracBrowser for help on using the repository browser.