Home | History | Annotate | Line # | Download | only in netinet
igmp.c revision 1.47
      1  1.47   thorpej /*	$NetBSD: igmp.c,v 1.47 2008/04/23 05:26:50 thorpej Exp $	*/
      2  1.21    itojun 
      3  1.21    itojun /*
      4  1.21    itojun  * Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project.
      5  1.21    itojun  * All rights reserved.
      6  1.29    itojun  *
      7  1.21    itojun  * Redistribution and use in source and binary forms, with or without
      8  1.21    itojun  * modification, are permitted provided that the following conditions
      9  1.21    itojun  * are met:
     10  1.21    itojun  * 1. Redistributions of source code must retain the above copyright
     11  1.21    itojun  *    notice, this list of conditions and the following disclaimer.
     12  1.21    itojun  * 2. Redistributions in binary form must reproduce the above copyright
     13  1.21    itojun  *    notice, this list of conditions and the following disclaimer in the
     14  1.21    itojun  *    documentation and/or other materials provided with the distribution.
     15  1.21    itojun  * 3. Neither the name of the project nor the names of its contributors
     16  1.21    itojun  *    may be used to endorse or promote products derived from this software
     17  1.21    itojun  *    without specific prior written permission.
     18  1.29    itojun  *
     19  1.21    itojun  * THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
     20  1.21    itojun  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     21  1.21    itojun  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     22  1.21    itojun  * ARE DISCLAIMED.  IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
     23  1.21    itojun  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     24  1.21    itojun  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     25  1.21    itojun  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     26  1.21    itojun  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     27  1.21    itojun  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     28  1.21    itojun  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     29  1.21    itojun  * SUCH DAMAGE.
     30  1.21    itojun  */
     31   1.8       cgd 
     32   1.1   hpeyerl /*
     33  1.10   mycroft  * Internet Group Management Protocol (IGMP) routines.
     34   1.1   hpeyerl  *
     35  1.10   mycroft  * Written by Steve Deering, Stanford, May 1988.
     36  1.10   mycroft  * Modified by Rosen Sharma, Stanford, Aug 1994.
     37  1.10   mycroft  * Modified by Bill Fenner, Xerox PARC, Feb 1995.
     38   1.1   hpeyerl  *
     39  1.10   mycroft  * MULTICAST Revision: 1.3
     40   1.1   hpeyerl  */
     41  1.27     lukem 
     42  1.27     lukem #include <sys/cdefs.h>
     43  1.47   thorpej __KERNEL_RCSID(0, "$NetBSD: igmp.c,v 1.47 2008/04/23 05:26:50 thorpej Exp $");
     44  1.17    scottr 
     45  1.17    scottr #include "opt_mrouting.h"
     46   1.1   hpeyerl 
     47   1.1   hpeyerl #include <sys/param.h>
     48   1.1   hpeyerl #include <sys/mbuf.h>
     49   1.1   hpeyerl #include <sys/socket.h>
     50   1.1   hpeyerl #include <sys/protosw.h>
     51  1.15  christos #include <sys/systm.h>
     52  1.46   thorpej #include <sys/sysctl.h>
     53   1.1   hpeyerl 
     54   1.1   hpeyerl #include <net/if.h>
     55   1.1   hpeyerl #include <net/route.h>
     56  1.47   thorpej #include <net/net_stats.h>
     57   1.1   hpeyerl 
     58   1.1   hpeyerl #include <netinet/in.h>
     59   1.1   hpeyerl #include <netinet/in_var.h>
     60   1.1   hpeyerl #include <netinet/in_systm.h>
     61   1.1   hpeyerl #include <netinet/ip.h>
     62   1.1   hpeyerl #include <netinet/ip_var.h>
     63   1.1   hpeyerl #include <netinet/igmp.h>
     64   1.1   hpeyerl #include <netinet/igmp_var.h>
     65   1.1   hpeyerl 
     66  1.15  christos #include <machine/stdarg.h>
     67  1.15  christos 
     68  1.10   mycroft #define IP_MULTICASTOPTS	0
     69  1.10   mycroft 
     70  1.44        ad POOL_INIT(igmp_rti_pool, sizeof(struct router_info), 0, 0, 0, "igmppl", NULL,
     71  1.44        ad     IPL_SOFTNET);
     72  1.46   thorpej 
     73  1.46   thorpej static percpu_t *igmpstat_percpu;
     74  1.46   thorpej 
     75  1.47   thorpej #define	IGMP_STATINC(x)		_NET_STATINC(igmpstat_percpu, x)
     76  1.46   thorpej 
     77  1.25      matt int igmp_timers_are_running;
     78  1.33      matt static LIST_HEAD(, router_info) rti_head = LIST_HEAD_INITIALIZER(rti_head);
     79   1.1   hpeyerl 
     80  1.40     perry void igmp_sendpkt(struct in_multi *, int);
     81  1.40     perry static int rti_fill(struct in_multi *);
     82  1.40     perry static struct router_info *rti_find(struct ifnet *);
     83  1.34    itojun static void rti_delete(struct ifnet *);
     84   1.1   hpeyerl 
     85  1.10   mycroft static int
     86  1.41     perry rti_fill(struct in_multi *inm)
     87  1.10   mycroft {
     88  1.24  augustss 	struct router_info *rti;
     89  1.10   mycroft 
     90  1.43       tls 	/* this function is called at splsoftnet() */
     91  1.33      matt 	LIST_FOREACH(rti, &rti_head, rti_link) {
     92  1.10   mycroft 		if (rti->rti_ifp == inm->inm_ifp) {
     93  1.10   mycroft 			inm->inm_rti = rti;
     94  1.10   mycroft 			if (rti->rti_type == IGMP_v1_ROUTER)
     95  1.10   mycroft 				return (IGMP_v1_HOST_MEMBERSHIP_REPORT);
     96  1.10   mycroft 			else
     97  1.10   mycroft 				return (IGMP_v2_HOST_MEMBERSHIP_REPORT);
     98  1.10   mycroft 		}
     99  1.10   mycroft 	}
    100  1.10   mycroft 
    101  1.33      matt 	rti = pool_get(&igmp_rti_pool, PR_NOWAIT);
    102  1.33      matt 	if (rti == NULL)
    103  1.33      matt 		return 0;
    104  1.10   mycroft 	rti->rti_ifp = inm->inm_ifp;
    105  1.10   mycroft 	rti->rti_type = IGMP_v2_ROUTER;
    106  1.33      matt 	LIST_INSERT_HEAD(&rti_head, rti, rti_link);
    107  1.10   mycroft 	inm->inm_rti = rti;
    108  1.10   mycroft 	return (IGMP_v2_HOST_MEMBERSHIP_REPORT);
    109  1.10   mycroft }
    110  1.10   mycroft 
    111  1.10   mycroft static struct router_info *
    112  1.41     perry rti_find(struct ifnet *ifp)
    113  1.10   mycroft {
    114  1.24  augustss 	struct router_info *rti;
    115  1.43       tls 	int s = splsoftnet();
    116  1.10   mycroft 
    117  1.33      matt 	LIST_FOREACH(rti, &rti_head, rti_link) {
    118  1.10   mycroft 		if (rti->rti_ifp == ifp)
    119  1.10   mycroft 			return (rti);
    120  1.10   mycroft 	}
    121  1.10   mycroft 
    122  1.33      matt 	rti = pool_get(&igmp_rti_pool, PR_NOWAIT);
    123  1.43       tls 	if (rti == NULL) {
    124  1.43       tls 		splx(s);
    125  1.33      matt 		return NULL;
    126  1.43       tls 	}
    127  1.10   mycroft 	rti->rti_ifp = ifp;
    128  1.10   mycroft 	rti->rti_type = IGMP_v2_ROUTER;
    129  1.33      matt 	LIST_INSERT_HEAD(&rti_head, rti, rti_link);
    130  1.43       tls 	splx(s);
    131  1.10   mycroft 	return (rti);
    132   1.1   hpeyerl }
    133   1.1   hpeyerl 
    134  1.34    itojun static void
    135  1.43       tls rti_delete(struct ifnet *ifp)	/* MUST be called at splsoftnet */
    136  1.34    itojun {
    137  1.34    itojun 	struct router_info *rti;
    138  1.34    itojun 
    139  1.34    itojun 	LIST_FOREACH(rti, &rti_head, rti_link) {
    140  1.34    itojun 		if (rti->rti_ifp == ifp) {
    141  1.34    itojun 			LIST_REMOVE(rti, rti_link);
    142  1.34    itojun 			pool_put(&igmp_rti_pool, rti);
    143  1.34    itojun 			return;
    144  1.34    itojun 		}
    145  1.34    itojun 	}
    146  1.34    itojun }
    147  1.34    itojun 
    148   1.1   hpeyerl void
    149  1.46   thorpej igmp_init(void)
    150  1.46   thorpej {
    151  1.46   thorpej 
    152  1.46   thorpej 	igmpstat_percpu = percpu_alloc(sizeof(uint64_t) * IGMP_NSTATS);
    153  1.46   thorpej }
    154  1.46   thorpej 
    155  1.46   thorpej void
    156  1.15  christos igmp_input(struct mbuf *m, ...)
    157  1.15  christos {
    158  1.21    itojun 	int proto;
    159  1.24  augustss 	int iphlen;
    160  1.24  augustss 	struct ifnet *ifp = m->m_pkthdr.rcvif;
    161  1.24  augustss 	struct ip *ip = mtod(m, struct ip *);
    162  1.24  augustss 	struct igmp *igmp;
    163  1.32   thorpej 	u_int minlen;
    164  1.10   mycroft 	struct in_multi *inm;
    165  1.10   mycroft 	struct in_multistep step;
    166  1.10   mycroft 	struct router_info *rti;
    167  1.24  augustss 	struct in_ifaddr *ia;
    168  1.32   thorpej 	u_int timer;
    169  1.15  christos 	va_list ap;
    170  1.31    itojun 	u_int16_t ip_len;
    171  1.15  christos 
    172  1.15  christos 	va_start(ap, m);
    173  1.15  christos 	iphlen = va_arg(ap, int);
    174  1.21    itojun 	proto = va_arg(ap, int);
    175  1.15  christos 	va_end(ap);
    176   1.1   hpeyerl 
    177  1.46   thorpej 	IGMP_STATINC(IGMP_STAT_RCV_TOTAL);
    178   1.1   hpeyerl 
    179   1.1   hpeyerl 	/*
    180   1.1   hpeyerl 	 * Validate lengths
    181   1.1   hpeyerl 	 */
    182  1.19   mycroft 	minlen = iphlen + IGMP_MINLEN;
    183  1.31    itojun 	ip_len = ntohs(ip->ip_len);
    184  1.31    itojun 	if (ip_len < minlen) {
    185  1.46   thorpej 		IGMP_STATINC(IGMP_STAT_RCV_TOOSHORT);
    186   1.1   hpeyerl 		m_freem(m);
    187   1.1   hpeyerl 		return;
    188   1.1   hpeyerl 	}
    189  1.25      matt 	if (((m->m_flags & M_EXT) && (ip->ip_src.s_addr & IN_CLASSA_NET) == 0)
    190  1.25      matt 	    || m->m_len < minlen) {
    191  1.25      matt 		if ((m = m_pullup(m, minlen)) == 0) {
    192  1.46   thorpej 			IGMP_STATINC(IGMP_STAT_RCV_TOOSHORT);
    193  1.25      matt 			return;
    194  1.25      matt 		}
    195  1.25      matt 		ip = mtod(m, struct ip *);
    196   1.1   hpeyerl 	}
    197   1.1   hpeyerl 
    198   1.1   hpeyerl 	/*
    199   1.1   hpeyerl 	 * Validate checksum
    200   1.1   hpeyerl 	 */
    201   1.1   hpeyerl 	m->m_data += iphlen;
    202   1.1   hpeyerl 	m->m_len -= iphlen;
    203   1.1   hpeyerl 	igmp = mtod(m, struct igmp *);
    204  1.30   thorpej 	/* No need to assert alignment here. */
    205  1.31    itojun 	if (in_cksum(m, ip_len - iphlen)) {
    206  1.46   thorpej 		IGMP_STATINC(IGMP_STAT_RCV_BADSUM);
    207   1.1   hpeyerl 		m_freem(m);
    208   1.1   hpeyerl 		return;
    209   1.1   hpeyerl 	}
    210   1.1   hpeyerl 	m->m_data -= iphlen;
    211   1.1   hpeyerl 	m->m_len += iphlen;
    212   1.1   hpeyerl 
    213   1.1   hpeyerl 	switch (igmp->igmp_type) {
    214   1.1   hpeyerl 
    215   1.1   hpeyerl 	case IGMP_HOST_MEMBERSHIP_QUERY:
    216  1.46   thorpej 		IGMP_STATINC(IGMP_STAT_RCV_QUERIES);
    217   1.1   hpeyerl 
    218   1.6   mycroft 		if (ifp->if_flags & IFF_LOOPBACK)
    219   1.1   hpeyerl 			break;
    220   1.1   hpeyerl 
    221  1.10   mycroft 		if (igmp->igmp_code == 0) {
    222  1.10   mycroft 			rti = rti_find(ifp);
    223  1.33      matt 			if (rti == NULL)
    224  1.33      matt 				break;
    225  1.10   mycroft 			rti->rti_type = IGMP_v1_ROUTER;
    226  1.10   mycroft 			rti->rti_age = 0;
    227  1.10   mycroft 
    228  1.12   mycroft 			if (ip->ip_dst.s_addr != INADDR_ALLHOSTS_GROUP) {
    229  1.46   thorpej 				IGMP_STATINC(IGMP_STAT_RCV_BADQUERIES);
    230  1.10   mycroft 				m_freem(m);
    231  1.10   mycroft 				return;
    232  1.10   mycroft 			}
    233  1.10   mycroft 
    234  1.10   mycroft 			/*
    235  1.10   mycroft 			 * Start the timers in all of our membership records
    236  1.10   mycroft 			 * for the interface on which the query arrived,
    237  1.10   mycroft 			 * except those that are already running and those
    238  1.10   mycroft 			 * that belong to a "local" group (224.0.0.X).
    239  1.10   mycroft 			 */
    240  1.10   mycroft 			IN_FIRST_MULTI(step, inm);
    241  1.10   mycroft 			while (inm != NULL) {
    242  1.10   mycroft 				if (inm->inm_ifp == ifp &&
    243  1.10   mycroft 				    inm->inm_timer == 0 &&
    244  1.10   mycroft 				    !IN_LOCAL_GROUP(inm->inm_addr.s_addr)) {
    245  1.10   mycroft 					inm->inm_state = IGMP_DELAYING_MEMBER;
    246  1.10   mycroft 					inm->inm_timer = IGMP_RANDOM_DELAY(
    247  1.10   mycroft 					    IGMP_MAX_HOST_REPORT_DELAY * PR_FASTHZ);
    248  1.10   mycroft 					igmp_timers_are_running = 1;
    249  1.10   mycroft 				}
    250  1.10   mycroft 				IN_NEXT_MULTI(step, inm);
    251  1.10   mycroft 			}
    252  1.10   mycroft 		} else {
    253  1.12   mycroft 			if (!IN_MULTICAST(ip->ip_dst.s_addr)) {
    254  1.46   thorpej 				IGMP_STATINC(IGMP_STAT_RCV_BADQUERIES);
    255  1.10   mycroft 				m_freem(m);
    256  1.10   mycroft 				return;
    257  1.10   mycroft 			}
    258  1.10   mycroft 
    259  1.10   mycroft 			timer = igmp->igmp_code * PR_FASTHZ / IGMP_TIMER_SCALE;
    260  1.20       hwr 			if (timer == 0)
    261  1.20       hwr 				timer =1;
    262  1.10   mycroft 
    263  1.10   mycroft 			/*
    264  1.10   mycroft 			 * Start the timers in all of our membership records
    265  1.10   mycroft 			 * for the interface on which the query arrived,
    266  1.10   mycroft 			 * except those that are already running and those
    267  1.10   mycroft 			 * that belong to a "local" group (224.0.0.X).  For
    268  1.10   mycroft 			 * timers already running, check if they need to be
    269  1.10   mycroft 			 * reset.
    270  1.10   mycroft 			 */
    271  1.10   mycroft 			IN_FIRST_MULTI(step, inm);
    272  1.10   mycroft 			while (inm != NULL) {
    273  1.10   mycroft 				if (inm->inm_ifp == ifp &&
    274  1.10   mycroft 				    !IN_LOCAL_GROUP(inm->inm_addr.s_addr) &&
    275  1.12   mycroft 				    (ip->ip_dst.s_addr == INADDR_ALLHOSTS_GROUP ||
    276  1.16   mycroft 				     in_hosteq(ip->ip_dst, inm->inm_addr))) {
    277  1.10   mycroft 					switch (inm->inm_state) {
    278  1.10   mycroft 					case IGMP_DELAYING_MEMBER:
    279  1.10   mycroft 						if (inm->inm_timer <= timer)
    280  1.10   mycroft 							break;
    281  1.10   mycroft 						/* FALLTHROUGH */
    282  1.10   mycroft 					case IGMP_IDLE_MEMBER:
    283  1.10   mycroft 					case IGMP_LAZY_MEMBER:
    284  1.10   mycroft 					case IGMP_AWAKENING_MEMBER:
    285  1.10   mycroft 						inm->inm_state =
    286  1.10   mycroft 						    IGMP_DELAYING_MEMBER;
    287  1.10   mycroft 						inm->inm_timer =
    288  1.10   mycroft 						    IGMP_RANDOM_DELAY(timer);
    289  1.10   mycroft 						igmp_timers_are_running = 1;
    290  1.10   mycroft 						break;
    291  1.10   mycroft 					case IGMP_SLEEPING_MEMBER:
    292  1.10   mycroft 						inm->inm_state =
    293  1.10   mycroft 						    IGMP_AWAKENING_MEMBER;
    294  1.10   mycroft 						break;
    295  1.10   mycroft 					}
    296  1.10   mycroft 				}
    297  1.10   mycroft 				IN_NEXT_MULTI(step, inm);
    298  1.10   mycroft 			}
    299  1.10   mycroft 		}
    300  1.10   mycroft 
    301  1.10   mycroft 		break;
    302  1.10   mycroft 
    303  1.10   mycroft 	case IGMP_v1_HOST_MEMBERSHIP_REPORT:
    304  1.46   thorpej 		IGMP_STATINC(IGMP_STAT_RCV_REPORTS);
    305  1.10   mycroft 
    306  1.10   mycroft 		if (ifp->if_flags & IFF_LOOPBACK)
    307  1.10   mycroft 			break;
    308  1.10   mycroft 
    309  1.12   mycroft 		if (!IN_MULTICAST(igmp->igmp_group.s_addr) ||
    310  1.16   mycroft 		    !in_hosteq(igmp->igmp_group, ip->ip_dst)) {
    311  1.46   thorpej 			IGMP_STATINC(IGMP_STAT_RCV_BADREPORTS);
    312   1.1   hpeyerl 			m_freem(m);
    313   1.1   hpeyerl 			return;
    314   1.1   hpeyerl 		}
    315   1.1   hpeyerl 
    316   1.1   hpeyerl 		/*
    317  1.10   mycroft 		 * KLUDGE: if the IP source address of the report has an
    318  1.10   mycroft 		 * unspecified (i.e., zero) subnet number, as is allowed for
    319  1.10   mycroft 		 * a booting host, replace it with the correct subnet number
    320  1.10   mycroft 		 * so that a process-level multicast routing daemon can
    321  1.10   mycroft 		 * determine which subnet it arrived from.  This is necessary
    322  1.10   mycroft 		 * to compensate for the lack of any way for a process to
    323  1.10   mycroft 		 * determine the arrival interface of an incoming packet.
    324   1.1   hpeyerl 		 */
    325  1.12   mycroft 		if ((ip->ip_src.s_addr & IN_CLASSA_NET) == 0) {
    326  1.18       tls 			IFP_TO_IA(ifp, ia);		/* XXX */
    327  1.10   mycroft 			if (ia)
    328  1.12   mycroft 				ip->ip_src.s_addr = ia->ia_subnet;
    329  1.10   mycroft 		}
    330  1.10   mycroft 
    331  1.10   mycroft 		/*
    332  1.10   mycroft 		 * If we belong to the group being reported, stop
    333  1.10   mycroft 		 * our timer for that group.
    334  1.10   mycroft 		 */
    335  1.10   mycroft 		IN_LOOKUP_MULTI(igmp->igmp_group, ifp, inm);
    336  1.10   mycroft 		if (inm != NULL) {
    337  1.10   mycroft 			inm->inm_timer = 0;
    338  1.46   thorpej 			IGMP_STATINC(IGMP_STAT_RCV_OURREPORTS);
    339  1.10   mycroft 
    340  1.10   mycroft 			switch (inm->inm_state) {
    341  1.10   mycroft 			case IGMP_IDLE_MEMBER:
    342  1.10   mycroft 			case IGMP_LAZY_MEMBER:
    343  1.10   mycroft 			case IGMP_AWAKENING_MEMBER:
    344  1.10   mycroft 			case IGMP_SLEEPING_MEMBER:
    345  1.10   mycroft 				inm->inm_state = IGMP_SLEEPING_MEMBER;
    346  1.10   mycroft 				break;
    347  1.10   mycroft 			case IGMP_DELAYING_MEMBER:
    348  1.10   mycroft 				if (inm->inm_rti->rti_type == IGMP_v1_ROUTER)
    349  1.10   mycroft 					inm->inm_state = IGMP_LAZY_MEMBER;
    350  1.10   mycroft 				else
    351  1.10   mycroft 					inm->inm_state = IGMP_SLEEPING_MEMBER;
    352  1.10   mycroft 				break;
    353   1.1   hpeyerl 			}
    354   1.1   hpeyerl 		}
    355   1.1   hpeyerl 
    356   1.1   hpeyerl 		break;
    357   1.1   hpeyerl 
    358  1.10   mycroft 	case IGMP_v2_HOST_MEMBERSHIP_REPORT:
    359  1.10   mycroft #ifdef MROUTING
    360  1.10   mycroft 		/*
    361  1.10   mycroft 		 * Make sure we don't hear our own membership report.  Fast
    362  1.10   mycroft 		 * leave requires knowing that we are the only member of a
    363  1.10   mycroft 		 * group.
    364  1.10   mycroft 		 */
    365  1.18       tls 		IFP_TO_IA(ifp, ia);			/* XXX */
    366  1.16   mycroft 		if (ia && in_hosteq(ip->ip_src, ia->ia_addr.sin_addr))
    367  1.10   mycroft 			break;
    368  1.10   mycroft #endif
    369  1.10   mycroft 
    370  1.46   thorpej 		IGMP_STATINC(IGMP_STAT_RCV_REPORTS);
    371   1.1   hpeyerl 
    372   1.6   mycroft 		if (ifp->if_flags & IFF_LOOPBACK)
    373   1.1   hpeyerl 			break;
    374   1.1   hpeyerl 
    375  1.12   mycroft 		if (!IN_MULTICAST(igmp->igmp_group.s_addr) ||
    376  1.16   mycroft 		    !in_hosteq(igmp->igmp_group, ip->ip_dst)) {
    377  1.46   thorpej 			IGMP_STATINC(IGMP_STAT_RCV_BADREPORTS);
    378   1.1   hpeyerl 			m_freem(m);
    379   1.1   hpeyerl 			return;
    380   1.1   hpeyerl 		}
    381   1.1   hpeyerl 
    382   1.1   hpeyerl 		/*
    383   1.1   hpeyerl 		 * KLUDGE: if the IP source address of the report has an
    384   1.1   hpeyerl 		 * unspecified (i.e., zero) subnet number, as is allowed for
    385   1.1   hpeyerl 		 * a booting host, replace it with the correct subnet number
    386  1.10   mycroft 		 * so that a process-level multicast routing daemon can
    387   1.1   hpeyerl 		 * determine which subnet it arrived from.  This is necessary
    388   1.1   hpeyerl 		 * to compensate for the lack of any way for a process to
    389   1.1   hpeyerl 		 * determine the arrival interface of an incoming packet.
    390   1.1   hpeyerl 		 */
    391  1.12   mycroft 		if ((ip->ip_src.s_addr & IN_CLASSA_NET) == 0) {
    392  1.10   mycroft #ifndef MROUTING
    393  1.18       tls 			IFP_TO_IA(ifp, ia);		/* XXX */
    394  1.10   mycroft #endif
    395  1.10   mycroft 			if (ia)
    396  1.12   mycroft 				ip->ip_src.s_addr = ia->ia_subnet;
    397   1.1   hpeyerl 		}
    398   1.1   hpeyerl 
    399   1.1   hpeyerl 		/*
    400   1.1   hpeyerl 		 * If we belong to the group being reported, stop
    401   1.1   hpeyerl 		 * our timer for that group.
    402   1.1   hpeyerl 		 */
    403   1.1   hpeyerl 		IN_LOOKUP_MULTI(igmp->igmp_group, ifp, inm);
    404   1.1   hpeyerl 		if (inm != NULL) {
    405   1.1   hpeyerl 			inm->inm_timer = 0;
    406  1.46   thorpej 			IGMP_STATINC(IGMP_STAT_RCV_OURREPORTS);
    407  1.10   mycroft 
    408  1.10   mycroft 			switch (inm->inm_state) {
    409  1.10   mycroft 			case IGMP_DELAYING_MEMBER:
    410  1.10   mycroft 			case IGMP_IDLE_MEMBER:
    411  1.10   mycroft 			case IGMP_AWAKENING_MEMBER:
    412  1.10   mycroft 				inm->inm_state = IGMP_LAZY_MEMBER;
    413  1.10   mycroft 				break;
    414  1.10   mycroft 			case IGMP_LAZY_MEMBER:
    415  1.10   mycroft 			case IGMP_SLEEPING_MEMBER:
    416  1.10   mycroft 				break;
    417  1.10   mycroft 			}
    418   1.1   hpeyerl 		}
    419   1.1   hpeyerl 
    420   1.1   hpeyerl 		break;
    421  1.10   mycroft 
    422   1.1   hpeyerl 	}
    423   1.1   hpeyerl 
    424   1.1   hpeyerl 	/*
    425   1.1   hpeyerl 	 * Pass all valid IGMP packets up to any process(es) listening
    426   1.1   hpeyerl 	 * on a raw IGMP socket.
    427   1.1   hpeyerl 	 */
    428  1.21    itojun 	rip_input(m, iphlen, proto);
    429  1.21    itojun 	return;
    430   1.1   hpeyerl }
    431   1.1   hpeyerl 
    432  1.33      matt int
    433  1.41     perry igmp_joingroup(struct in_multi *inm)
    434   1.1   hpeyerl {
    435  1.33      matt 	int report_type;
    436  1.14   mycroft 	int s = splsoftnet();
    437  1.10   mycroft 
    438  1.10   mycroft 	inm->inm_state = IGMP_IDLE_MEMBER;
    439   1.1   hpeyerl 
    440  1.10   mycroft 	if (!IN_LOCAL_GROUP(inm->inm_addr.s_addr) &&
    441  1.10   mycroft 	    (inm->inm_ifp->if_flags & IFF_LOOPBACK) == 0) {
    442  1.33      matt 		report_type = rti_fill(inm);
    443  1.39  christos 		if (report_type == 0) {
    444  1.39  christos 			splx(s);
    445  1.33      matt 			return ENOMEM;
    446  1.39  christos 		}
    447  1.33      matt 		igmp_sendpkt(inm, report_type);
    448  1.10   mycroft 		inm->inm_state = IGMP_DELAYING_MEMBER;
    449  1.10   mycroft 		inm->inm_timer = IGMP_RANDOM_DELAY(
    450  1.10   mycroft 		    IGMP_MAX_HOST_REPORT_DELAY * PR_FASTHZ);
    451  1.10   mycroft 		igmp_timers_are_running = 1;
    452  1.10   mycroft 	} else
    453   1.1   hpeyerl 		inm->inm_timer = 0;
    454   1.1   hpeyerl 	splx(s);
    455  1.33      matt 	return 0;
    456   1.1   hpeyerl }
    457   1.1   hpeyerl 
    458   1.1   hpeyerl void
    459  1.41     perry igmp_leavegroup(struct in_multi *inm)
    460   1.1   hpeyerl {
    461  1.10   mycroft 
    462  1.10   mycroft 	switch (inm->inm_state) {
    463  1.10   mycroft 	case IGMP_DELAYING_MEMBER:
    464  1.10   mycroft 	case IGMP_IDLE_MEMBER:
    465  1.10   mycroft 		if (!IN_LOCAL_GROUP(inm->inm_addr.s_addr) &&
    466  1.10   mycroft 		    (inm->inm_ifp->if_flags & IFF_LOOPBACK) == 0)
    467  1.10   mycroft 			if (inm->inm_rti->rti_type != IGMP_v1_ROUTER)
    468  1.10   mycroft 				igmp_sendpkt(inm, IGMP_HOST_LEAVE_MESSAGE);
    469  1.10   mycroft 		break;
    470  1.10   mycroft 	case IGMP_LAZY_MEMBER:
    471  1.10   mycroft 	case IGMP_AWAKENING_MEMBER:
    472  1.10   mycroft 	case IGMP_SLEEPING_MEMBER:
    473  1.10   mycroft 		break;
    474  1.10   mycroft 	}
    475   1.1   hpeyerl }
    476   1.1   hpeyerl 
    477   1.1   hpeyerl void
    478  1.41     perry igmp_fasttimo(void)
    479   1.1   hpeyerl {
    480  1.24  augustss 	struct in_multi *inm;
    481   1.1   hpeyerl 	struct in_multistep step;
    482  1.10   mycroft 	int s;
    483   1.1   hpeyerl 
    484   1.1   hpeyerl 	/*
    485   1.1   hpeyerl 	 * Quick check to see if any work needs to be done, in order
    486   1.1   hpeyerl 	 * to minimize the overhead of fasttimo processing.
    487   1.1   hpeyerl 	 */
    488   1.1   hpeyerl 	if (!igmp_timers_are_running)
    489   1.1   hpeyerl 		return;
    490   1.1   hpeyerl 
    491  1.14   mycroft 	s = splsoftnet();
    492   1.1   hpeyerl 	igmp_timers_are_running = 0;
    493   1.1   hpeyerl 	IN_FIRST_MULTI(step, inm);
    494   1.1   hpeyerl 	while (inm != NULL) {
    495   1.1   hpeyerl 		if (inm->inm_timer == 0) {
    496   1.1   hpeyerl 			/* do nothing */
    497   1.1   hpeyerl 		} else if (--inm->inm_timer == 0) {
    498  1.10   mycroft 			if (inm->inm_state == IGMP_DELAYING_MEMBER) {
    499  1.10   mycroft 				if (inm->inm_rti->rti_type == IGMP_v1_ROUTER)
    500  1.10   mycroft 					igmp_sendpkt(inm,
    501  1.10   mycroft 					    IGMP_v1_HOST_MEMBERSHIP_REPORT);
    502  1.10   mycroft 				else
    503  1.10   mycroft 					igmp_sendpkt(inm,
    504  1.10   mycroft 					    IGMP_v2_HOST_MEMBERSHIP_REPORT);
    505  1.10   mycroft 				inm->inm_state = IGMP_IDLE_MEMBER;
    506  1.10   mycroft 			}
    507   1.1   hpeyerl 		} else {
    508   1.1   hpeyerl 			igmp_timers_are_running = 1;
    509   1.1   hpeyerl 		}
    510   1.1   hpeyerl 		IN_NEXT_MULTI(step, inm);
    511   1.1   hpeyerl 	}
    512   1.1   hpeyerl 	splx(s);
    513   1.1   hpeyerl }
    514   1.1   hpeyerl 
    515  1.10   mycroft void
    516  1.41     perry igmp_slowtimo(void)
    517  1.10   mycroft {
    518  1.24  augustss 	struct router_info *rti;
    519  1.10   mycroft 	int s;
    520  1.10   mycroft 
    521  1.14   mycroft 	s = splsoftnet();
    522  1.33      matt 	LIST_FOREACH(rti, &rti_head, rti_link) {
    523  1.10   mycroft 		if (rti->rti_type == IGMP_v1_ROUTER &&
    524  1.10   mycroft 		    ++rti->rti_age >= IGMP_AGE_THRESHOLD) {
    525  1.10   mycroft 			rti->rti_type = IGMP_v2_ROUTER;
    526  1.10   mycroft 		}
    527  1.10   mycroft 	}
    528  1.10   mycroft 	splx(s);
    529  1.10   mycroft }
    530  1.10   mycroft 
    531  1.10   mycroft void
    532  1.41     perry igmp_sendpkt(struct in_multi *inm, int type)
    533   1.1   hpeyerl {
    534  1.10   mycroft 	struct mbuf *m;
    535  1.10   mycroft 	struct igmp *igmp;
    536  1.10   mycroft 	struct ip *ip;
    537  1.10   mycroft 	struct ip_moptions imo;
    538  1.10   mycroft #ifdef MROUTING
    539  1.10   mycroft 	extern struct socket *ip_mrouter;
    540  1.10   mycroft #endif /* MROUTING */
    541   1.1   hpeyerl 
    542   1.1   hpeyerl 	MGETHDR(m, M_DONTWAIT, MT_HEADER);
    543   1.1   hpeyerl 	if (m == NULL)
    544   1.1   hpeyerl 		return;
    545   1.1   hpeyerl 	/*
    546   1.1   hpeyerl 	 * Assume max_linkhdr + sizeof(struct ip) + IGMP_MINLEN
    547   1.1   hpeyerl 	 * is smaller than mbuf size returned by MGETHDR.
    548   1.1   hpeyerl 	 */
    549   1.1   hpeyerl 	m->m_data += max_linkhdr;
    550   1.1   hpeyerl 	m->m_len = sizeof(struct ip) + IGMP_MINLEN;
    551   1.1   hpeyerl 	m->m_pkthdr.len = sizeof(struct ip) + IGMP_MINLEN;
    552   1.1   hpeyerl 
    553   1.1   hpeyerl 	ip = mtod(m, struct ip *);
    554   1.1   hpeyerl 	ip->ip_tos = 0;
    555  1.31    itojun 	ip->ip_len = htons(sizeof(struct ip) + IGMP_MINLEN);
    556  1.31    itojun 	ip->ip_off = htons(0);
    557   1.1   hpeyerl 	ip->ip_p = IPPROTO_IGMP;
    558  1.16   mycroft 	ip->ip_src = zeroin_addr;
    559   1.1   hpeyerl 	ip->ip_dst = inm->inm_addr;
    560   1.1   hpeyerl 
    561   1.7    brezak 	m->m_data += sizeof(struct ip);
    562   1.7    brezak 	m->m_len -= sizeof(struct ip);
    563   1.7    brezak 	igmp = mtod(m, struct igmp *);
    564  1.10   mycroft 	igmp->igmp_type = type;
    565   1.1   hpeyerl 	igmp->igmp_code = 0;
    566   1.1   hpeyerl 	igmp->igmp_group = inm->inm_addr;
    567   1.1   hpeyerl 	igmp->igmp_cksum = 0;
    568   1.1   hpeyerl 	igmp->igmp_cksum = in_cksum(m, IGMP_MINLEN);
    569   1.7    brezak 	m->m_data -= sizeof(struct ip);
    570   1.7    brezak 	m->m_len += sizeof(struct ip);
    571   1.1   hpeyerl 
    572  1.10   mycroft 	imo.imo_multicast_ifp = inm->inm_ifp;
    573  1.10   mycroft 	imo.imo_multicast_ttl = 1;
    574  1.10   mycroft #ifdef RSVP_ISI
    575  1.10   mycroft 	imo.imo_multicast_vif = -1;
    576  1.10   mycroft #endif
    577   1.1   hpeyerl 	/*
    578   1.1   hpeyerl 	 * Request loopback of the report if we are acting as a multicast
    579   1.1   hpeyerl 	 * router, so that the process-level routing demon can hear it.
    580   1.1   hpeyerl 	 */
    581   1.1   hpeyerl #ifdef MROUTING
    582  1.10   mycroft 	imo.imo_multicast_loop = (ip_mrouter != NULL);
    583  1.10   mycroft #else
    584  1.10   mycroft 	imo.imo_multicast_loop = 0;
    585  1.10   mycroft #endif /* MROUTING */
    586  1.10   mycroft 
    587  1.45    dyoung 	ip_output(m, NULL, NULL, IP_MULTICASTOPTS, &imo, NULL);
    588   1.1   hpeyerl 
    589  1.46   thorpej 	IGMP_STATINC(IGMP_STAT_SND_REPORTS);
    590  1.34    itojun }
    591  1.34    itojun 
    592  1.34    itojun void
    593  1.43       tls igmp_purgeif(struct ifnet *ifp)	/* MUST be called at splsoftnet() */
    594  1.34    itojun {
    595  1.43       tls 	rti_delete(ifp);	/* manipulates pools */
    596   1.1   hpeyerl }
    597  1.46   thorpej 
    598  1.46   thorpej static int
    599  1.46   thorpej sysctl_net_inet_igmp_stats(SYSCTLFN_ARGS)
    600  1.46   thorpej {
    601  1.47   thorpej 	netstat_sysctl_context ctx;
    602  1.46   thorpej 	uint64_t igmps[IGMP_NSTATS];
    603  1.46   thorpej 
    604  1.47   thorpej 	ctx.ctx_stat = igmpstat_percpu;
    605  1.47   thorpej 	ctx.ctx_counters = igmps;
    606  1.47   thorpej 	ctx.ctx_ncounters = IGMP_NSTATS;
    607  1.47   thorpej 	return (NETSTAT_SYSCTL(&ctx));
    608  1.46   thorpej }
    609  1.46   thorpej 
    610  1.46   thorpej SYSCTL_SETUP(sysctl_net_inet_igmp_setup, "sysctl net.inet.igmp subtree setup")
    611  1.46   thorpej {
    612  1.46   thorpej 
    613  1.46   thorpej 	sysctl_createv(clog, 0, NULL, NULL,
    614  1.46   thorpej 			CTLFLAG_PERMANENT,
    615  1.46   thorpej 			CTLTYPE_NODE, "net", NULL,
    616  1.46   thorpej 			NULL, 0, NULL, 0,
    617  1.46   thorpej 			CTL_NET, CTL_EOL);
    618  1.46   thorpej 	sysctl_createv(clog, 0, NULL, NULL,
    619  1.46   thorpej 			CTLFLAG_PERMANENT,
    620  1.46   thorpej 			CTLTYPE_NODE, "inet", NULL,
    621  1.46   thorpej 			NULL, 0, NULL, 0,
    622  1.46   thorpej 			CTL_NET, PF_INET, CTL_EOL);
    623  1.46   thorpej 	sysctl_createv(clog, 0, NULL, NULL,
    624  1.46   thorpej 			CTLFLAG_PERMANENT,
    625  1.46   thorpej 			CTLTYPE_NODE, "igmp",
    626  1.46   thorpej 			SYSCTL_DESCR("Internet Group Management Protocol"),
    627  1.46   thorpej 			NULL, 0, NULL, 0,
    628  1.46   thorpej 			CTL_NET, PF_INET, IPPROTO_IGMP, CTL_EOL);
    629  1.46   thorpej 
    630  1.46   thorpej 	sysctl_createv(clog, 0, NULL, NULL,
    631  1.46   thorpej 			CTLFLAG_PERMANENT,
    632  1.46   thorpej 			CTLTYPE_STRUCT, "stats",
    633  1.46   thorpej 			SYSCTL_DESCR("IGMP statistics"),
    634  1.46   thorpej 			sysctl_net_inet_igmp_stats, 0, NULL, 0,
    635  1.46   thorpej 			CTL_NET, PF_INET, IPPROTO_IGMP, CTL_CREATE, CTL_EOL);
    636  1.46   thorpej }
    637