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