linux/drivers/infiniband/ulp/ipoib/ipoib_multicast.c

/*
 * Copyright (c) 2004, 2005 Topspin Communications.  All rights reserved.
 * Copyright (c) 2005 Sun Microsystems, Inc. All rights reserved.
 * Copyright (c) 2004 Voltaire, Inc. All rights reserved.
 *
 * This software is available to you under a choice of one of two
 * licenses.  You may choose to be licensed under the terms of the GNU
 * General Public License (GPL) Version 2, available from the file
 * COPYING in the main directory of this source tree, or the
 * OpenIB.org BSD license below:
 *
 *     Redistribution and use in source and binary forms, with or
 *     without modification, are permitted provided that the following
 *     conditions are met:
 *
 *      - Redistributions of source code must retain the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer.
 *
 *      - Redistributions in binary form must reproduce the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer in the documentation and/or other materials
 *        provided with the distribution.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */

#include <linux/skbuff.h>
#include <linux/rtnetlink.h>
#include <linux/moduleparam.h>
#include <linux/ip.h>
#include <linux/in.h>
#include <linux/igmp.h>
#include <linux/inetdevice.h>
#include <linux/delay.h>
#include <linux/completion.h>
#include <linux/slab.h>

#include <net/dst.h>

#include "ipoib.h"

#ifdef CONFIG_INFINIBAND_IPOIB_DEBUG
static int mcast_debug_level;

module_param(mcast_debug_level, int, 0644);
MODULE_PARM_DESC(…) …;
#endif

struct ipoib_mcast_iter { … };

/* join state that allows creating mcg with sendonly member request */
#define SENDONLY_FULLMEMBER_JOIN …

/*
 * This should be called with the priv->lock held
 */
static void __ipoib_mcast_schedule_join_thread(struct ipoib_dev_priv *priv,
					       struct ipoib_mcast *mcast,
					       bool delay)
{ … }

static void ipoib_mcast_free(struct ipoib_mcast *mcast)
{ … }

static struct ipoib_mcast *ipoib_mcast_alloc(struct net_device *dev)
{ … }

static struct ipoib_mcast *__ipoib_mcast_find(struct net_device *dev, void *mgid)
{ … }

static int __ipoib_mcast_add(struct net_device *dev, struct ipoib_mcast *mcast)
{ … }

static int ipoib_mcast_join_finish(struct ipoib_mcast *mcast,
				   struct ib_sa_mcmember_rec *mcmember)
{ … }

void ipoib_mcast_carrier_on_task(struct work_struct *work)
{ … }

static int ipoib_mcast_join_complete(int status,
				     struct ib_sa_multicast *multicast)
{ … }

/*
 * Caller must hold 'priv->lock'
 */
static int ipoib_mcast_join(struct net_device *dev, struct ipoib_mcast *mcast)
{ … }

void ipoib_mcast_join_task(struct work_struct *work)
{ … }

void ipoib_mcast_start_thread(struct net_device *dev)
{ … }

void ipoib_mcast_stop_thread(struct net_device *dev)
{ … }

static int ipoib_mcast_leave(struct net_device *dev, struct ipoib_mcast *mcast)
{ … }

/*
 * Check if the multicast group is sendonly. If so remove it from the maps
 * and add to the remove list
 */
void ipoib_check_and_add_mcast_sendonly(struct ipoib_dev_priv *priv, u8 *mgid,
				struct list_head *remove_list)
{ … }

void ipoib_mcast_remove_list(struct list_head *remove_list)
{ … }

void ipoib_mcast_send(struct net_device *dev, u8 *daddr, struct sk_buff *skb)
{ … }

void ipoib_mcast_dev_flush(struct net_device *dev)
{ … }

static int ipoib_mcast_addr_is_valid(const u8 *addr, const u8 *broadcast)
{ … }

void ipoib_mcast_restart_task(struct work_struct *work)
{ … }

#ifdef CONFIG_INFINIBAND_IPOIB_DEBUG

struct ipoib_mcast_iter *ipoib_mcast_iter_init(struct net_device *dev)
{ … }

int ipoib_mcast_iter_next(struct ipoib_mcast_iter *iter)
{ … }

void ipoib_mcast_iter_read(struct ipoib_mcast_iter *iter,
			   union ib_gid *mgid,
			   unsigned long *created,
			   unsigned int *queuelen,
			   unsigned int *complete,
			   unsigned int *send_only)
{ … }

#endif /* CONFIG_INFINIBAND_IPOIB_DEBUG */