2 * Multicast support for IPv6
3 * Linux INET6 implementation
6 * Pedro Roque <roque@di.fc.ul.pt>
8 * Based on linux/ipv4/igmp.c and linux/ipv4/ip_sockglue.c
10 * This program is free software; you can redistribute it and/or
11 * modify it under the terms of the GNU General Public License
12 * as published by the Free Software Foundation; either version
13 * 2 of the License, or (at your option) any later version.
18 * yoshfuji : fix format of router-alert option
19 * YOSHIFUJI Hideaki @USAGI:
20 * Fixed source address for MLD message based on
21 * <draft-ietf-magma-mld-source-05.txt>.
22 * YOSHIFUJI Hideaki @USAGI:
23 * - Ignore Queries for invalid addresses.
24 * - MLD for link-local addresses.
25 * David L Stevens <dlstevens@us.ibm.com>:
29 #include <linux/module.h>
30 #include <linux/errno.h>
31 #include <linux/types.h>
32 #include <linux/string.h>
33 #include <linux/socket.h>
34 #include <linux/sockios.h>
35 #include <linux/jiffies.h>
36 #include <linux/times.h>
37 #include <linux/net.h>
39 #include <linux/in6.h>
40 #include <linux/netdevice.h>
41 #include <linux/if_arp.h>
42 #include <linux/route.h>
43 #include <linux/init.h>
44 #include <linux/proc_fs.h>
45 #include <linux/seq_file.h>
46 #include <linux/slab.h>
49 #include <linux/netfilter.h>
50 #include <linux/netfilter_ipv6.h>
52 #include <net/net_namespace.h>
57 #include <net/protocol.h>
58 #include <net/if_inet6.h>
59 #include <net/ndisc.h>
60 #include <net/addrconf.h>
61 #include <net/ip6_route.h>
62 #include <net/inet_common.h>
64 #include <net/ip6_checksum.h>
66 /* Set to 3 to get tracing... */
70 #define MDBG(x) printk x
75 /* Ensure that we have struct in6_addr aligned on 32bit word. */
76 static void *__mld2_query_bugs
[] __attribute__((__unused__
)) = {
77 BUILD_BUG_ON_NULL(offsetof(struct mld2_query
, mld2q_srcs
) % 4),
78 BUILD_BUG_ON_NULL(offsetof(struct mld2_report
, mld2r_grec
) % 4),
79 BUILD_BUG_ON_NULL(offsetof(struct mld2_grec
, grec_mca
) % 4)
82 static struct in6_addr mld2_all_mcr
= MLD2_ALL_MCR_INIT
;
84 /* Big mc list lock for all the sockets */
85 static DEFINE_RWLOCK(ipv6_sk_mc_lock
);
87 static void igmp6_join_group(struct ifmcaddr6
*ma
);
88 static void igmp6_leave_group(struct ifmcaddr6
*ma
);
89 static void igmp6_timer_handler(unsigned long data
);
91 static void mld_gq_timer_expire(unsigned long data
);
92 static void mld_ifc_timer_expire(unsigned long data
);
93 static void mld_ifc_event(struct inet6_dev
*idev
);
94 static void mld_add_delrec(struct inet6_dev
*idev
, struct ifmcaddr6
*pmc
);
95 static void mld_del_delrec(struct inet6_dev
*idev
, struct in6_addr
*addr
);
96 static void mld_clear_delrec(struct inet6_dev
*idev
);
97 static int sf_setstate(struct ifmcaddr6
*pmc
);
98 static void sf_markstate(struct ifmcaddr6
*pmc
);
99 static void ip6_mc_clear_src(struct ifmcaddr6
*pmc
);
100 static int ip6_mc_del_src(struct inet6_dev
*idev
, struct in6_addr
*pmca
,
101 int sfmode
, int sfcount
, struct in6_addr
*psfsrc
,
103 static int ip6_mc_add_src(struct inet6_dev
*idev
, struct in6_addr
*pmca
,
104 int sfmode
, int sfcount
, struct in6_addr
*psfsrc
,
106 static int ip6_mc_leave_src(struct sock
*sk
, struct ipv6_mc_socklist
*iml
,
107 struct inet6_dev
*idev
);
110 #define IGMP6_UNSOLICITED_IVAL (10*HZ)
111 #define MLD_QRV_DEFAULT 2
113 #define MLD_V1_SEEN(idev) (dev_net((idev)->dev)->ipv6.devconf_all->force_mld_version == 1 || \
114 (idev)->cnf.force_mld_version == 1 || \
115 ((idev)->mc_v1_seen && \
116 time_before(jiffies, (idev)->mc_v1_seen)))
118 #define IPV6_MLD_MAX_MSF 64
120 int sysctl_mld_max_msf __read_mostly
= IPV6_MLD_MAX_MSF
;
123 * socket join on multicast group
126 int ipv6_sock_mc_join(struct sock
*sk
, int ifindex
, const struct in6_addr
*addr
)
128 struct net_device
*dev
= NULL
;
129 struct ipv6_mc_socklist
*mc_lst
;
130 struct ipv6_pinfo
*np
= inet6_sk(sk
);
131 struct net
*net
= sock_net(sk
);
134 if (!ipv6_addr_is_multicast(addr
))
137 read_lock_bh(&ipv6_sk_mc_lock
);
138 for (mc_lst
=np
->ipv6_mc_list
; mc_lst
; mc_lst
=mc_lst
->next
) {
139 if ((ifindex
== 0 || mc_lst
->ifindex
== ifindex
) &&
140 ipv6_addr_equal(&mc_lst
->addr
, addr
)) {
141 read_unlock_bh(&ipv6_sk_mc_lock
);
145 read_unlock_bh(&ipv6_sk_mc_lock
);
147 mc_lst
= sock_kmalloc(sk
, sizeof(struct ipv6_mc_socklist
), GFP_KERNEL
);
153 ipv6_addr_copy(&mc_lst
->addr
, addr
);
157 rt
= rt6_lookup(net
, addr
, NULL
, 0, 0);
161 dst_release(&rt
->u
.dst
);
164 dev
= dev_get_by_index(net
, ifindex
);
167 sock_kfree_s(sk
, mc_lst
, sizeof(*mc_lst
));
171 mc_lst
->ifindex
= dev
->ifindex
;
172 mc_lst
->sfmode
= MCAST_EXCLUDE
;
173 rwlock_init(&mc_lst
->sflock
);
174 mc_lst
->sflist
= NULL
;
177 * now add/increase the group membership on the device
180 err
= ipv6_dev_mc_inc(dev
, addr
);
183 sock_kfree_s(sk
, mc_lst
, sizeof(*mc_lst
));
188 write_lock_bh(&ipv6_sk_mc_lock
);
189 mc_lst
->next
= np
->ipv6_mc_list
;
190 np
->ipv6_mc_list
= mc_lst
;
191 write_unlock_bh(&ipv6_sk_mc_lock
);
199 * socket leave on multicast group
201 int ipv6_sock_mc_drop(struct sock
*sk
, int ifindex
, const struct in6_addr
*addr
)
203 struct ipv6_pinfo
*np
= inet6_sk(sk
);
204 struct ipv6_mc_socklist
*mc_lst
, **lnk
;
205 struct net
*net
= sock_net(sk
);
207 write_lock_bh(&ipv6_sk_mc_lock
);
208 for (lnk
= &np
->ipv6_mc_list
; (mc_lst
= *lnk
) !=NULL
; lnk
= &mc_lst
->next
) {
209 if ((ifindex
== 0 || mc_lst
->ifindex
== ifindex
) &&
210 ipv6_addr_equal(&mc_lst
->addr
, addr
)) {
211 struct net_device
*dev
;
214 write_unlock_bh(&ipv6_sk_mc_lock
);
216 dev
= dev_get_by_index(net
, mc_lst
->ifindex
);
218 struct inet6_dev
*idev
= in6_dev_get(dev
);
220 (void) ip6_mc_leave_src(sk
, mc_lst
, idev
);
222 __ipv6_dev_mc_dec(idev
, &mc_lst
->addr
);
227 (void) ip6_mc_leave_src(sk
, mc_lst
, NULL
);
228 sock_kfree_s(sk
, mc_lst
, sizeof(*mc_lst
));
232 write_unlock_bh(&ipv6_sk_mc_lock
);
234 return -EADDRNOTAVAIL
;
237 static struct inet6_dev
*ip6_mc_find_dev(struct net
*net
,
238 struct in6_addr
*group
,
241 struct net_device
*dev
= NULL
;
242 struct inet6_dev
*idev
= NULL
;
247 rt
= rt6_lookup(net
, group
, NULL
, 0, 0);
251 dst_release(&rt
->u
.dst
);
254 dev
= dev_get_by_index(net
, ifindex
);
258 idev
= in6_dev_get(dev
);
261 read_lock_bh(&idev
->lock
);
268 read_unlock_bh(&idev
->lock
);
276 void ipv6_sock_mc_close(struct sock
*sk
)
278 struct ipv6_pinfo
*np
= inet6_sk(sk
);
279 struct ipv6_mc_socklist
*mc_lst
;
280 struct net
*net
= sock_net(sk
);
282 write_lock_bh(&ipv6_sk_mc_lock
);
283 while ((mc_lst
= np
->ipv6_mc_list
) != NULL
) {
284 struct net_device
*dev
;
286 np
->ipv6_mc_list
= mc_lst
->next
;
287 write_unlock_bh(&ipv6_sk_mc_lock
);
289 dev
= dev_get_by_index(net
, mc_lst
->ifindex
);
291 struct inet6_dev
*idev
= in6_dev_get(dev
);
293 (void) ip6_mc_leave_src(sk
, mc_lst
, idev
);
295 __ipv6_dev_mc_dec(idev
, &mc_lst
->addr
);
300 (void) ip6_mc_leave_src(sk
, mc_lst
, NULL
);
302 sock_kfree_s(sk
, mc_lst
, sizeof(*mc_lst
));
304 write_lock_bh(&ipv6_sk_mc_lock
);
306 write_unlock_bh(&ipv6_sk_mc_lock
);
309 int ip6_mc_source(int add
, int omode
, struct sock
*sk
,
310 struct group_source_req
*pgsr
)
312 struct in6_addr
*source
, *group
;
313 struct ipv6_mc_socklist
*pmc
;
314 struct net_device
*dev
;
315 struct inet6_dev
*idev
;
316 struct ipv6_pinfo
*inet6
= inet6_sk(sk
);
317 struct ip6_sf_socklist
*psl
;
318 struct net
*net
= sock_net(sk
);
324 source
= &((struct sockaddr_in6
*)&pgsr
->gsr_source
)->sin6_addr
;
325 group
= &((struct sockaddr_in6
*)&pgsr
->gsr_group
)->sin6_addr
;
327 if (!ipv6_addr_is_multicast(group
))
330 idev
= ip6_mc_find_dev(net
, group
, pgsr
->gsr_interface
);
335 err
= -EADDRNOTAVAIL
;
337 read_lock_bh(&ipv6_sk_mc_lock
);
338 for (pmc
=inet6
->ipv6_mc_list
; pmc
; pmc
=pmc
->next
) {
339 if (pgsr
->gsr_interface
&& pmc
->ifindex
!= pgsr
->gsr_interface
)
341 if (ipv6_addr_equal(&pmc
->addr
, group
))
344 if (!pmc
) { /* must have a prior join */
348 /* if a source filter was set, must be the same mode as before */
350 if (pmc
->sfmode
!= omode
) {
354 } else if (pmc
->sfmode
!= omode
) {
355 /* allow mode switches for empty-set filters */
356 ip6_mc_add_src(idev
, group
, omode
, 0, NULL
, 0);
357 ip6_mc_del_src(idev
, group
, pmc
->sfmode
, 0, NULL
, 0);
361 write_lock_bh(&pmc
->sflock
);
367 goto done
; /* err = -EADDRNOTAVAIL */
369 for (i
=0; i
<psl
->sl_count
; i
++) {
370 rv
= memcmp(&psl
->sl_addr
[i
], source
,
371 sizeof(struct in6_addr
));
375 if (rv
) /* source not found */
376 goto done
; /* err = -EADDRNOTAVAIL */
378 /* special case - (INCLUDE, empty) == LEAVE_GROUP */
379 if (psl
->sl_count
== 1 && omode
== MCAST_INCLUDE
) {
384 /* update the interface filter */
385 ip6_mc_del_src(idev
, group
, omode
, 1, source
, 1);
387 for (j
=i
+1; j
<psl
->sl_count
; j
++)
388 psl
->sl_addr
[j
-1] = psl
->sl_addr
[j
];
393 /* else, add a new source to the filter */
395 if (psl
&& psl
->sl_count
>= sysctl_mld_max_msf
) {
399 if (!psl
|| psl
->sl_count
== psl
->sl_max
) {
400 struct ip6_sf_socklist
*newpsl
;
401 int count
= IP6_SFBLOCK
;
404 count
+= psl
->sl_max
;
405 newpsl
= sock_kmalloc(sk
, IP6_SFLSIZE(count
), GFP_ATOMIC
);
410 newpsl
->sl_max
= count
;
411 newpsl
->sl_count
= count
- IP6_SFBLOCK
;
413 for (i
=0; i
<psl
->sl_count
; i
++)
414 newpsl
->sl_addr
[i
] = psl
->sl_addr
[i
];
415 sock_kfree_s(sk
, psl
, IP6_SFLSIZE(psl
->sl_max
));
417 pmc
->sflist
= psl
= newpsl
;
419 rv
= 1; /* > 0 for insert logic below if sl_count is 0 */
420 for (i
=0; i
<psl
->sl_count
; i
++) {
421 rv
= memcmp(&psl
->sl_addr
[i
], source
, sizeof(struct in6_addr
));
425 if (rv
== 0) /* address already there is an error */
427 for (j
=psl
->sl_count
-1; j
>=i
; j
--)
428 psl
->sl_addr
[j
+1] = psl
->sl_addr
[j
];
429 psl
->sl_addr
[i
] = *source
;
432 /* update the interface list */
433 ip6_mc_add_src(idev
, group
, omode
, 1, source
, 1);
436 write_unlock_bh(&pmc
->sflock
);
437 read_unlock_bh(&ipv6_sk_mc_lock
);
438 read_unlock_bh(&idev
->lock
);
442 return ipv6_sock_mc_drop(sk
, pgsr
->gsr_interface
, group
);
446 int ip6_mc_msfilter(struct sock
*sk
, struct group_filter
*gsf
)
448 struct in6_addr
*group
;
449 struct ipv6_mc_socklist
*pmc
;
450 struct net_device
*dev
;
451 struct inet6_dev
*idev
;
452 struct ipv6_pinfo
*inet6
= inet6_sk(sk
);
453 struct ip6_sf_socklist
*newpsl
, *psl
;
454 struct net
*net
= sock_net(sk
);
458 group
= &((struct sockaddr_in6
*)&gsf
->gf_group
)->sin6_addr
;
460 if (!ipv6_addr_is_multicast(group
))
462 if (gsf
->gf_fmode
!= MCAST_INCLUDE
&&
463 gsf
->gf_fmode
!= MCAST_EXCLUDE
)
466 idev
= ip6_mc_find_dev(net
, group
, gsf
->gf_interface
);
473 read_lock_bh(&ipv6_sk_mc_lock
);
475 if (gsf
->gf_fmode
== MCAST_INCLUDE
&& gsf
->gf_numsrc
== 0) {
480 for (pmc
=inet6
->ipv6_mc_list
; pmc
; pmc
=pmc
->next
) {
481 if (pmc
->ifindex
!= gsf
->gf_interface
)
483 if (ipv6_addr_equal(&pmc
->addr
, group
))
486 if (!pmc
) { /* must have a prior join */
490 if (gsf
->gf_numsrc
) {
491 newpsl
= sock_kmalloc(sk
, IP6_SFLSIZE(gsf
->gf_numsrc
),
497 newpsl
->sl_max
= newpsl
->sl_count
= gsf
->gf_numsrc
;
498 for (i
=0; i
<newpsl
->sl_count
; ++i
) {
499 struct sockaddr_in6
*psin6
;
501 psin6
= (struct sockaddr_in6
*)&gsf
->gf_slist
[i
];
502 newpsl
->sl_addr
[i
] = psin6
->sin6_addr
;
504 err
= ip6_mc_add_src(idev
, group
, gsf
->gf_fmode
,
505 newpsl
->sl_count
, newpsl
->sl_addr
, 0);
507 sock_kfree_s(sk
, newpsl
, IP6_SFLSIZE(newpsl
->sl_max
));
512 (void) ip6_mc_add_src(idev
, group
, gsf
->gf_fmode
, 0, NULL
, 0);
515 write_lock_bh(&pmc
->sflock
);
518 (void) ip6_mc_del_src(idev
, group
, pmc
->sfmode
,
519 psl
->sl_count
, psl
->sl_addr
, 0);
520 sock_kfree_s(sk
, psl
, IP6_SFLSIZE(psl
->sl_max
));
522 (void) ip6_mc_del_src(idev
, group
, pmc
->sfmode
, 0, NULL
, 0);
523 pmc
->sflist
= newpsl
;
524 pmc
->sfmode
= gsf
->gf_fmode
;
525 write_unlock_bh(&pmc
->sflock
);
528 read_unlock_bh(&ipv6_sk_mc_lock
);
529 read_unlock_bh(&idev
->lock
);
533 err
= ipv6_sock_mc_drop(sk
, gsf
->gf_interface
, group
);
537 int ip6_mc_msfget(struct sock
*sk
, struct group_filter
*gsf
,
538 struct group_filter __user
*optval
, int __user
*optlen
)
540 int err
, i
, count
, copycount
;
541 struct in6_addr
*group
;
542 struct ipv6_mc_socklist
*pmc
;
543 struct inet6_dev
*idev
;
544 struct net_device
*dev
;
545 struct ipv6_pinfo
*inet6
= inet6_sk(sk
);
546 struct ip6_sf_socklist
*psl
;
547 struct net
*net
= sock_net(sk
);
549 group
= &((struct sockaddr_in6
*)&gsf
->gf_group
)->sin6_addr
;
551 if (!ipv6_addr_is_multicast(group
))
554 idev
= ip6_mc_find_dev(net
, group
, gsf
->gf_interface
);
561 err
= -EADDRNOTAVAIL
;
563 * changes to the ipv6_mc_list require the socket lock and
564 * a read lock on ip6_sk_mc_lock. We have the socket lock,
565 * so reading the list is safe.
568 for (pmc
=inet6
->ipv6_mc_list
; pmc
; pmc
=pmc
->next
) {
569 if (pmc
->ifindex
!= gsf
->gf_interface
)
571 if (ipv6_addr_equal(group
, &pmc
->addr
))
574 if (!pmc
) /* must have a prior join */
576 gsf
->gf_fmode
= pmc
->sfmode
;
578 count
= psl
? psl
->sl_count
: 0;
579 read_unlock_bh(&idev
->lock
);
583 copycount
= count
< gsf
->gf_numsrc
? count
: gsf
->gf_numsrc
;
584 gsf
->gf_numsrc
= count
;
585 if (put_user(GROUP_FILTER_SIZE(copycount
), optlen
) ||
586 copy_to_user(optval
, gsf
, GROUP_FILTER_SIZE(0))) {
589 /* changes to psl require the socket lock, a read lock on
590 * on ipv6_sk_mc_lock and a write lock on pmc->sflock. We
591 * have the socket lock, so reading here is safe.
593 for (i
=0; i
<copycount
; i
++) {
594 struct sockaddr_in6
*psin6
;
595 struct sockaddr_storage ss
;
597 psin6
= (struct sockaddr_in6
*)&ss
;
598 memset(&ss
, 0, sizeof(ss
));
599 psin6
->sin6_family
= AF_INET6
;
600 psin6
->sin6_addr
= psl
->sl_addr
[i
];
601 if (copy_to_user(&optval
->gf_slist
[i
], &ss
, sizeof(ss
)))
606 read_unlock_bh(&idev
->lock
);
612 int inet6_mc_check(struct sock
*sk
, const struct in6_addr
*mc_addr
,
613 const struct in6_addr
*src_addr
)
615 struct ipv6_pinfo
*np
= inet6_sk(sk
);
616 struct ipv6_mc_socklist
*mc
;
617 struct ip6_sf_socklist
*psl
;
620 read_lock(&ipv6_sk_mc_lock
);
621 for (mc
= np
->ipv6_mc_list
; mc
; mc
= mc
->next
) {
622 if (ipv6_addr_equal(&mc
->addr
, mc_addr
))
626 read_unlock(&ipv6_sk_mc_lock
);
629 read_lock(&mc
->sflock
);
632 rv
= mc
->sfmode
== MCAST_EXCLUDE
;
636 for (i
=0; i
<psl
->sl_count
; i
++) {
637 if (ipv6_addr_equal(&psl
->sl_addr
[i
], src_addr
))
640 if (mc
->sfmode
== MCAST_INCLUDE
&& i
>= psl
->sl_count
)
642 if (mc
->sfmode
== MCAST_EXCLUDE
&& i
< psl
->sl_count
)
645 read_unlock(&mc
->sflock
);
646 read_unlock(&ipv6_sk_mc_lock
);
651 static void ma_put(struct ifmcaddr6
*mc
)
653 if (atomic_dec_and_test(&mc
->mca_refcnt
)) {
654 in6_dev_put(mc
->idev
);
659 static void igmp6_group_added(struct ifmcaddr6
*mc
)
661 struct net_device
*dev
= mc
->idev
->dev
;
662 char buf
[MAX_ADDR_LEN
];
664 spin_lock_bh(&mc
->mca_lock
);
665 if (!(mc
->mca_flags
&MAF_LOADED
)) {
666 mc
->mca_flags
|= MAF_LOADED
;
667 if (ndisc_mc_map(&mc
->mca_addr
, buf
, dev
, 0) == 0)
668 dev_mc_add(dev
, buf
);
670 spin_unlock_bh(&mc
->mca_lock
);
672 if (!(dev
->flags
& IFF_UP
) || (mc
->mca_flags
& MAF_NOREPORT
))
675 if (MLD_V1_SEEN(mc
->idev
)) {
676 igmp6_join_group(mc
);
681 mc
->mca_crcount
= mc
->idev
->mc_qrv
;
682 mld_ifc_event(mc
->idev
);
685 static void igmp6_group_dropped(struct ifmcaddr6
*mc
)
687 struct net_device
*dev
= mc
->idev
->dev
;
688 char buf
[MAX_ADDR_LEN
];
690 spin_lock_bh(&mc
->mca_lock
);
691 if (mc
->mca_flags
&MAF_LOADED
) {
692 mc
->mca_flags
&= ~MAF_LOADED
;
693 if (ndisc_mc_map(&mc
->mca_addr
, buf
, dev
, 0) == 0)
694 dev_mc_del(dev
, buf
);
697 if (mc
->mca_flags
& MAF_NOREPORT
)
699 spin_unlock_bh(&mc
->mca_lock
);
702 igmp6_leave_group(mc
);
704 spin_lock_bh(&mc
->mca_lock
);
705 if (del_timer(&mc
->mca_timer
))
706 atomic_dec(&mc
->mca_refcnt
);
708 ip6_mc_clear_src(mc
);
709 spin_unlock_bh(&mc
->mca_lock
);
713 * deleted ifmcaddr6 manipulation
715 static void mld_add_delrec(struct inet6_dev
*idev
, struct ifmcaddr6
*im
)
717 struct ifmcaddr6
*pmc
;
719 /* this is an "ifmcaddr6" for convenience; only the fields below
720 * are actually used. In particular, the refcnt and users are not
721 * used for management of the delete list. Using the same structure
722 * for deleted items allows change reports to use common code with
723 * non-deleted or query-response MCA's.
725 pmc
= kzalloc(sizeof(*pmc
), GFP_ATOMIC
);
729 spin_lock_bh(&im
->mca_lock
);
730 spin_lock_init(&pmc
->mca_lock
);
731 pmc
->idev
= im
->idev
;
733 pmc
->mca_addr
= im
->mca_addr
;
734 pmc
->mca_crcount
= idev
->mc_qrv
;
735 pmc
->mca_sfmode
= im
->mca_sfmode
;
736 if (pmc
->mca_sfmode
== MCAST_INCLUDE
) {
737 struct ip6_sf_list
*psf
;
739 pmc
->mca_tomb
= im
->mca_tomb
;
740 pmc
->mca_sources
= im
->mca_sources
;
741 im
->mca_tomb
= im
->mca_sources
= NULL
;
742 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
)
743 psf
->sf_crcount
= pmc
->mca_crcount
;
745 spin_unlock_bh(&im
->mca_lock
);
747 spin_lock_bh(&idev
->mc_lock
);
748 pmc
->next
= idev
->mc_tomb
;
750 spin_unlock_bh(&idev
->mc_lock
);
753 static void mld_del_delrec(struct inet6_dev
*idev
, struct in6_addr
*pmca
)
755 struct ifmcaddr6
*pmc
, *pmc_prev
;
756 struct ip6_sf_list
*psf
, *psf_next
;
758 spin_lock_bh(&idev
->mc_lock
);
760 for (pmc
=idev
->mc_tomb
; pmc
; pmc
=pmc
->next
) {
761 if (ipv6_addr_equal(&pmc
->mca_addr
, pmca
))
767 pmc_prev
->next
= pmc
->next
;
769 idev
->mc_tomb
= pmc
->next
;
771 spin_unlock_bh(&idev
->mc_lock
);
774 for (psf
=pmc
->mca_tomb
; psf
; psf
=psf_next
) {
775 psf_next
= psf
->sf_next
;
778 in6_dev_put(pmc
->idev
);
783 static void mld_clear_delrec(struct inet6_dev
*idev
)
785 struct ifmcaddr6
*pmc
, *nextpmc
;
787 spin_lock_bh(&idev
->mc_lock
);
789 idev
->mc_tomb
= NULL
;
790 spin_unlock_bh(&idev
->mc_lock
);
792 for (; pmc
; pmc
= nextpmc
) {
794 ip6_mc_clear_src(pmc
);
795 in6_dev_put(pmc
->idev
);
799 /* clear dead sources, too */
800 read_lock_bh(&idev
->lock
);
801 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
802 struct ip6_sf_list
*psf
, *psf_next
;
804 spin_lock_bh(&pmc
->mca_lock
);
806 pmc
->mca_tomb
= NULL
;
807 spin_unlock_bh(&pmc
->mca_lock
);
808 for (; psf
; psf
=psf_next
) {
809 psf_next
= psf
->sf_next
;
813 read_unlock_bh(&idev
->lock
);
818 * device multicast group inc (add if not found)
820 int ipv6_dev_mc_inc(struct net_device
*dev
, const struct in6_addr
*addr
)
822 struct ifmcaddr6
*mc
;
823 struct inet6_dev
*idev
;
825 idev
= in6_dev_get(dev
);
830 write_lock_bh(&idev
->lock
);
832 write_unlock_bh(&idev
->lock
);
837 for (mc
= idev
->mc_list
; mc
; mc
= mc
->next
) {
838 if (ipv6_addr_equal(&mc
->mca_addr
, addr
)) {
840 write_unlock_bh(&idev
->lock
);
841 ip6_mc_add_src(idev
, &mc
->mca_addr
, MCAST_EXCLUDE
, 0,
849 * not found: create a new one.
852 mc
= kzalloc(sizeof(struct ifmcaddr6
), GFP_ATOMIC
);
855 write_unlock_bh(&idev
->lock
);
860 setup_timer(&mc
->mca_timer
, igmp6_timer_handler
, (unsigned long)mc
);
862 ipv6_addr_copy(&mc
->mca_addr
, addr
);
865 /* mca_stamp should be updated upon changes */
866 mc
->mca_cstamp
= mc
->mca_tstamp
= jiffies
;
867 atomic_set(&mc
->mca_refcnt
, 2);
868 spin_lock_init(&mc
->mca_lock
);
870 /* initial mode is (EX, empty) */
871 mc
->mca_sfmode
= MCAST_EXCLUDE
;
872 mc
->mca_sfcount
[MCAST_EXCLUDE
] = 1;
874 if (ipv6_addr_is_ll_all_nodes(&mc
->mca_addr
) ||
875 IPV6_ADDR_MC_SCOPE(&mc
->mca_addr
) < IPV6_ADDR_SCOPE_LINKLOCAL
)
876 mc
->mca_flags
|= MAF_NOREPORT
;
878 mc
->next
= idev
->mc_list
;
880 write_unlock_bh(&idev
->lock
);
882 mld_del_delrec(idev
, &mc
->mca_addr
);
883 igmp6_group_added(mc
);
889 * device multicast group del
891 int __ipv6_dev_mc_dec(struct inet6_dev
*idev
, const struct in6_addr
*addr
)
893 struct ifmcaddr6
*ma
, **map
;
895 write_lock_bh(&idev
->lock
);
896 for (map
= &idev
->mc_list
; (ma
=*map
) != NULL
; map
= &ma
->next
) {
897 if (ipv6_addr_equal(&ma
->mca_addr
, addr
)) {
898 if (--ma
->mca_users
== 0) {
900 write_unlock_bh(&idev
->lock
);
902 igmp6_group_dropped(ma
);
907 write_unlock_bh(&idev
->lock
);
911 write_unlock_bh(&idev
->lock
);
916 int ipv6_dev_mc_dec(struct net_device
*dev
, const struct in6_addr
*addr
)
918 struct inet6_dev
*idev
= in6_dev_get(dev
);
924 err
= __ipv6_dev_mc_dec(idev
, addr
);
932 * identify MLD packets for MLD filter exceptions
934 int ipv6_is_mld(struct sk_buff
*skb
, int nexthdr
)
936 struct icmp6hdr
*pic
;
938 if (nexthdr
!= IPPROTO_ICMPV6
)
941 if (!pskb_may_pull(skb
, sizeof(struct icmp6hdr
)))
944 pic
= icmp6_hdr(skb
);
946 switch (pic
->icmp6_type
) {
947 case ICMPV6_MGM_QUERY
:
948 case ICMPV6_MGM_REPORT
:
949 case ICMPV6_MGM_REDUCTION
:
950 case ICMPV6_MLD2_REPORT
:
959 * check if the interface/address pair is valid
961 int ipv6_chk_mcast_addr(struct net_device
*dev
, const struct in6_addr
*group
,
962 const struct in6_addr
*src_addr
)
964 struct inet6_dev
*idev
;
965 struct ifmcaddr6
*mc
;
968 idev
= in6_dev_get(dev
);
970 read_lock_bh(&idev
->lock
);
971 for (mc
= idev
->mc_list
; mc
; mc
=mc
->next
) {
972 if (ipv6_addr_equal(&mc
->mca_addr
, group
))
976 if (src_addr
&& !ipv6_addr_any(src_addr
)) {
977 struct ip6_sf_list
*psf
;
979 spin_lock_bh(&mc
->mca_lock
);
980 for (psf
=mc
->mca_sources
;psf
;psf
=psf
->sf_next
) {
981 if (ipv6_addr_equal(&psf
->sf_addr
, src_addr
))
985 rv
= psf
->sf_count
[MCAST_INCLUDE
] ||
986 psf
->sf_count
[MCAST_EXCLUDE
] !=
987 mc
->mca_sfcount
[MCAST_EXCLUDE
];
989 rv
= mc
->mca_sfcount
[MCAST_EXCLUDE
] !=0;
990 spin_unlock_bh(&mc
->mca_lock
);
992 rv
= 1; /* don't filter unspecified source */
994 read_unlock_bh(&idev
->lock
);
1000 static void mld_gq_start_timer(struct inet6_dev
*idev
)
1002 int tv
= net_random() % idev
->mc_maxdelay
;
1004 idev
->mc_gq_running
= 1;
1005 if (!mod_timer(&idev
->mc_gq_timer
, jiffies
+tv
+2))
1009 static void mld_ifc_start_timer(struct inet6_dev
*idev
, int delay
)
1011 int tv
= net_random() % delay
;
1013 if (!mod_timer(&idev
->mc_ifc_timer
, jiffies
+tv
+2))
1018 * IGMP handling (alias multicast ICMPv6 messages)
1021 static void igmp6_group_queried(struct ifmcaddr6
*ma
, unsigned long resptime
)
1023 unsigned long delay
= resptime
;
1025 /* Do not start timer for these addresses */
1026 if (ipv6_addr_is_ll_all_nodes(&ma
->mca_addr
) ||
1027 IPV6_ADDR_MC_SCOPE(&ma
->mca_addr
) < IPV6_ADDR_SCOPE_LINKLOCAL
)
1030 if (del_timer(&ma
->mca_timer
)) {
1031 atomic_dec(&ma
->mca_refcnt
);
1032 delay
= ma
->mca_timer
.expires
- jiffies
;
1035 if (delay
>= resptime
) {
1037 delay
= net_random() % resptime
;
1041 ma
->mca_timer
.expires
= jiffies
+ delay
;
1042 if (!mod_timer(&ma
->mca_timer
, jiffies
+ delay
))
1043 atomic_inc(&ma
->mca_refcnt
);
1044 ma
->mca_flags
|= MAF_TIMER_RUNNING
;
1047 /* mark EXCLUDE-mode sources */
1048 static int mld_xmarksources(struct ifmcaddr6
*pmc
, int nsrcs
,
1049 struct in6_addr
*srcs
)
1051 struct ip6_sf_list
*psf
;
1055 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1056 if (scount
== nsrcs
)
1058 for (i
=0; i
<nsrcs
; i
++) {
1059 /* skip inactive filters */
1060 if (pmc
->mca_sfcount
[MCAST_INCLUDE
] ||
1061 pmc
->mca_sfcount
[MCAST_EXCLUDE
] !=
1062 psf
->sf_count
[MCAST_EXCLUDE
])
1064 if (ipv6_addr_equal(&srcs
[i
], &psf
->sf_addr
)) {
1070 pmc
->mca_flags
&= ~MAF_GSQUERY
;
1071 if (scount
== nsrcs
) /* all sources excluded */
1076 static int mld_marksources(struct ifmcaddr6
*pmc
, int nsrcs
,
1077 struct in6_addr
*srcs
)
1079 struct ip6_sf_list
*psf
;
1082 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
)
1083 return mld_xmarksources(pmc
, nsrcs
, srcs
);
1085 /* mark INCLUDE-mode sources */
1088 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1089 if (scount
== nsrcs
)
1091 for (i
=0; i
<nsrcs
; i
++) {
1092 if (ipv6_addr_equal(&srcs
[i
], &psf
->sf_addr
)) {
1100 pmc
->mca_flags
&= ~MAF_GSQUERY
;
1103 pmc
->mca_flags
|= MAF_GSQUERY
;
1107 int igmp6_event_query(struct sk_buff
*skb
)
1109 struct mld2_query
*mlh2
= NULL
;
1110 struct ifmcaddr6
*ma
;
1111 struct in6_addr
*group
;
1112 unsigned long max_delay
;
1113 struct inet6_dev
*idev
;
1114 struct mld_msg
*mld
;
1119 if (!pskb_may_pull(skb
, sizeof(struct in6_addr
)))
1122 /* compute payload length excluding extension headers */
1123 len
= ntohs(ipv6_hdr(skb
)->payload_len
) + sizeof(struct ipv6hdr
);
1124 len
-= skb_network_header_len(skb
);
1126 /* Drop queries with not link local source */
1127 if (!(ipv6_addr_type(&ipv6_hdr(skb
)->saddr
) & IPV6_ADDR_LINKLOCAL
))
1130 idev
= in6_dev_get(skb
->dev
);
1135 mld
= (struct mld_msg
*)icmp6_hdr(skb
);
1136 group
= &mld
->mld_mca
;
1137 group_type
= ipv6_addr_type(group
);
1139 if (group_type
!= IPV6_ADDR_ANY
&&
1140 !(group_type
&IPV6_ADDR_MULTICAST
)) {
1147 /* MLDv1 router present */
1149 /* Translate milliseconds to jiffies */
1150 max_delay
= (ntohs(mld
->mld_maxdelay
)*HZ
)/1000;
1152 switchback
= (idev
->mc_qrv
+ 1) * max_delay
;
1153 idev
->mc_v1_seen
= jiffies
+ switchback
;
1155 /* cancel the interface change timer */
1156 idev
->mc_ifc_count
= 0;
1157 if (del_timer(&idev
->mc_ifc_timer
))
1158 __in6_dev_put(idev
);
1159 /* clear deleted report items */
1160 mld_clear_delrec(idev
);
1161 } else if (len
>= 28) {
1162 int srcs_offset
= sizeof(struct mld2_query
) -
1163 sizeof(struct icmp6hdr
);
1164 if (!pskb_may_pull(skb
, srcs_offset
)) {
1168 mlh2
= (struct mld2_query
*)skb_transport_header(skb
);
1169 max_delay
= (MLDV2_MRC(ntohs(mlh2
->mld2q_mrc
))*HZ
)/1000;
1172 idev
->mc_maxdelay
= max_delay
;
1173 if (mlh2
->mld2q_qrv
)
1174 idev
->mc_qrv
= mlh2
->mld2q_qrv
;
1175 if (group_type
== IPV6_ADDR_ANY
) { /* general query */
1176 if (mlh2
->mld2q_nsrcs
) {
1178 return -EINVAL
; /* no sources allowed */
1180 mld_gq_start_timer(idev
);
1184 /* mark sources to include, if group & source-specific */
1185 if (mlh2
->mld2q_nsrcs
!= 0) {
1186 if (!pskb_may_pull(skb
, srcs_offset
+
1187 ntohs(mlh2
->mld2q_nsrcs
) * sizeof(struct in6_addr
))) {
1191 mlh2
= (struct mld2_query
*)skb_transport_header(skb
);
1199 read_lock_bh(&idev
->lock
);
1200 if (group_type
== IPV6_ADDR_ANY
) {
1201 for (ma
= idev
->mc_list
; ma
; ma
=ma
->next
) {
1202 spin_lock_bh(&ma
->mca_lock
);
1203 igmp6_group_queried(ma
, max_delay
);
1204 spin_unlock_bh(&ma
->mca_lock
);
1207 for (ma
= idev
->mc_list
; ma
; ma
=ma
->next
) {
1208 if (!ipv6_addr_equal(group
, &ma
->mca_addr
))
1210 spin_lock_bh(&ma
->mca_lock
);
1211 if (ma
->mca_flags
& MAF_TIMER_RUNNING
) {
1212 /* gsquery <- gsquery && mark */
1214 ma
->mca_flags
&= ~MAF_GSQUERY
;
1216 /* gsquery <- mark */
1218 ma
->mca_flags
|= MAF_GSQUERY
;
1220 ma
->mca_flags
&= ~MAF_GSQUERY
;
1222 if (!(ma
->mca_flags
& MAF_GSQUERY
) ||
1223 mld_marksources(ma
, ntohs(mlh2
->mld2q_nsrcs
), mlh2
->mld2q_srcs
))
1224 igmp6_group_queried(ma
, max_delay
);
1225 spin_unlock_bh(&ma
->mca_lock
);
1229 read_unlock_bh(&idev
->lock
);
1236 int igmp6_event_report(struct sk_buff
*skb
)
1238 struct ifmcaddr6
*ma
;
1239 struct inet6_dev
*idev
;
1240 struct mld_msg
*mld
;
1243 /* Our own report looped back. Ignore it. */
1244 if (skb
->pkt_type
== PACKET_LOOPBACK
)
1247 /* send our report if the MC router may not have heard this report */
1248 if (skb
->pkt_type
!= PACKET_MULTICAST
&&
1249 skb
->pkt_type
!= PACKET_BROADCAST
)
1252 if (!pskb_may_pull(skb
, sizeof(*mld
) - sizeof(struct icmp6hdr
)))
1255 mld
= (struct mld_msg
*)icmp6_hdr(skb
);
1257 /* Drop reports with not link local source */
1258 addr_type
= ipv6_addr_type(&ipv6_hdr(skb
)->saddr
);
1259 if (addr_type
!= IPV6_ADDR_ANY
&&
1260 !(addr_type
&IPV6_ADDR_LINKLOCAL
))
1263 idev
= in6_dev_get(skb
->dev
);
1268 * Cancel the timer for this group
1271 read_lock_bh(&idev
->lock
);
1272 for (ma
= idev
->mc_list
; ma
; ma
=ma
->next
) {
1273 if (ipv6_addr_equal(&ma
->mca_addr
, &mld
->mld_mca
)) {
1274 spin_lock(&ma
->mca_lock
);
1275 if (del_timer(&ma
->mca_timer
))
1276 atomic_dec(&ma
->mca_refcnt
);
1277 ma
->mca_flags
&= ~(MAF_LAST_REPORTER
|MAF_TIMER_RUNNING
);
1278 spin_unlock(&ma
->mca_lock
);
1282 read_unlock_bh(&idev
->lock
);
1287 static int is_in(struct ifmcaddr6
*pmc
, struct ip6_sf_list
*psf
, int type
,
1288 int gdeleted
, int sdeleted
)
1291 case MLD2_MODE_IS_INCLUDE
:
1292 case MLD2_MODE_IS_EXCLUDE
:
1293 if (gdeleted
|| sdeleted
)
1295 if (!((pmc
->mca_flags
& MAF_GSQUERY
) && !psf
->sf_gsresp
)) {
1296 if (pmc
->mca_sfmode
== MCAST_INCLUDE
)
1298 /* don't include if this source is excluded
1301 if (psf
->sf_count
[MCAST_INCLUDE
])
1302 return type
== MLD2_MODE_IS_INCLUDE
;
1303 return pmc
->mca_sfcount
[MCAST_EXCLUDE
] ==
1304 psf
->sf_count
[MCAST_EXCLUDE
];
1307 case MLD2_CHANGE_TO_INCLUDE
:
1308 if (gdeleted
|| sdeleted
)
1310 return psf
->sf_count
[MCAST_INCLUDE
] != 0;
1311 case MLD2_CHANGE_TO_EXCLUDE
:
1312 if (gdeleted
|| sdeleted
)
1314 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
] == 0 ||
1315 psf
->sf_count
[MCAST_INCLUDE
])
1317 return pmc
->mca_sfcount
[MCAST_EXCLUDE
] ==
1318 psf
->sf_count
[MCAST_EXCLUDE
];
1319 case MLD2_ALLOW_NEW_SOURCES
:
1320 if (gdeleted
|| !psf
->sf_crcount
)
1322 return (pmc
->mca_sfmode
== MCAST_INCLUDE
) ^ sdeleted
;
1323 case MLD2_BLOCK_OLD_SOURCES
:
1324 if (pmc
->mca_sfmode
== MCAST_INCLUDE
)
1325 return gdeleted
|| (psf
->sf_crcount
&& sdeleted
);
1326 return psf
->sf_crcount
&& !gdeleted
&& !sdeleted
;
1332 mld_scount(struct ifmcaddr6
*pmc
, int type
, int gdeleted
, int sdeleted
)
1334 struct ip6_sf_list
*psf
;
1337 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1338 if (!is_in(pmc
, psf
, type
, gdeleted
, sdeleted
))
1345 static struct sk_buff
*mld_newpack(struct net_device
*dev
, int size
)
1347 struct net
*net
= dev_net(dev
);
1348 struct sock
*sk
= net
->ipv6
.igmp_sk
;
1349 struct sk_buff
*skb
;
1350 struct mld2_report
*pmr
;
1351 struct in6_addr addr_buf
;
1352 const struct in6_addr
*saddr
;
1354 u8 ra
[8] = { IPPROTO_ICMPV6
, 0,
1355 IPV6_TLV_ROUTERALERT
, 2, 0, 0,
1358 /* we assume size > sizeof(ra) here */
1359 skb
= sock_alloc_send_skb(sk
, size
+ LL_ALLOCATED_SPACE(dev
), 1, &err
);
1364 skb_reserve(skb
, LL_RESERVED_SPACE(dev
));
1366 if (ipv6_get_lladdr(dev
, &addr_buf
, IFA_F_TENTATIVE
)) {
1367 /* <draft-ietf-magma-mld-source-05.txt>:
1368 * use unspecified address as the source address
1369 * when a valid link-local address is not available.
1371 saddr
= &in6addr_any
;
1375 ip6_nd_hdr(sk
, skb
, dev
, saddr
, &mld2_all_mcr
, NEXTHDR_HOP
, 0);
1377 memcpy(skb_put(skb
, sizeof(ra
)), ra
, sizeof(ra
));
1379 skb_set_transport_header(skb
, skb_tail_pointer(skb
) - skb
->data
);
1380 skb_put(skb
, sizeof(*pmr
));
1381 pmr
= (struct mld2_report
*)skb_transport_header(skb
);
1382 pmr
->mld2r_type
= ICMPV6_MLD2_REPORT
;
1383 pmr
->mld2r_resv1
= 0;
1384 pmr
->mld2r_cksum
= 0;
1385 pmr
->mld2r_resv2
= 0;
1386 pmr
->mld2r_ngrec
= 0;
1390 static void mld_sendpack(struct sk_buff
*skb
)
1392 struct ipv6hdr
*pip6
= ipv6_hdr(skb
);
1393 struct mld2_report
*pmr
=
1394 (struct mld2_report
*)skb_transport_header(skb
);
1395 int payload_len
, mldlen
;
1396 struct inet6_dev
*idev
= in6_dev_get(skb
->dev
);
1397 struct net
*net
= dev_net(skb
->dev
);
1400 struct dst_entry
*dst
;
1402 IP6_UPD_PO_STATS(net
, idev
, IPSTATS_MIB_OUT
, skb
->len
);
1404 payload_len
= (skb
->tail
- skb
->network_header
) - sizeof(*pip6
);
1405 mldlen
= skb
->tail
- skb
->transport_header
;
1406 pip6
->payload_len
= htons(payload_len
);
1408 pmr
->mld2r_cksum
= csum_ipv6_magic(&pip6
->saddr
, &pip6
->daddr
, mldlen
,
1410 csum_partial(skb_transport_header(skb
),
1413 dst
= icmp6_dst_alloc(skb
->dev
, NULL
, &ipv6_hdr(skb
)->daddr
);
1420 icmpv6_flow_init(net
->ipv6
.igmp_sk
, &fl
, ICMPV6_MLD2_REPORT
,
1421 &ipv6_hdr(skb
)->saddr
, &ipv6_hdr(skb
)->daddr
,
1424 err
= xfrm_lookup(net
, &dst
, &fl
, NULL
, 0);
1425 skb_dst_set(skb
, dst
);
1429 payload_len
= skb
->len
;
1431 err
= NF_HOOK(PF_INET6
, NF_INET_LOCAL_OUT
, skb
, NULL
, skb
->dev
,
1435 ICMP6MSGOUT_INC_STATS_BH(net
, idev
, ICMPV6_MLD2_REPORT
);
1436 ICMP6_INC_STATS_BH(net
, idev
, ICMP6_MIB_OUTMSGS
);
1437 IP6_UPD_PO_STATS_BH(net
, idev
, IPSTATS_MIB_OUTMCAST
, payload_len
);
1439 IP6_INC_STATS_BH(net
, idev
, IPSTATS_MIB_OUTDISCARDS
);
1441 if (likely(idev
!= NULL
))
1450 static int grec_size(struct ifmcaddr6
*pmc
, int type
, int gdel
, int sdel
)
1452 return sizeof(struct mld2_grec
) + 16 * mld_scount(pmc
,type
,gdel
,sdel
);
1455 static struct sk_buff
*add_grhead(struct sk_buff
*skb
, struct ifmcaddr6
*pmc
,
1456 int type
, struct mld2_grec
**ppgr
)
1458 struct net_device
*dev
= pmc
->idev
->dev
;
1459 struct mld2_report
*pmr
;
1460 struct mld2_grec
*pgr
;
1463 skb
= mld_newpack(dev
, dev
->mtu
);
1466 pgr
= (struct mld2_grec
*)skb_put(skb
, sizeof(struct mld2_grec
));
1467 pgr
->grec_type
= type
;
1468 pgr
->grec_auxwords
= 0;
1469 pgr
->grec_nsrcs
= 0;
1470 pgr
->grec_mca
= pmc
->mca_addr
; /* structure copy */
1471 pmr
= (struct mld2_report
*)skb_transport_header(skb
);
1472 pmr
->mld2r_ngrec
= htons(ntohs(pmr
->mld2r_ngrec
)+1);
1477 #define AVAILABLE(skb) ((skb) ? ((skb)->dev ? (skb)->dev->mtu - (skb)->len : \
1478 skb_tailroom(skb)) : 0)
1480 static struct sk_buff
*add_grec(struct sk_buff
*skb
, struct ifmcaddr6
*pmc
,
1481 int type
, int gdeleted
, int sdeleted
)
1483 struct net_device
*dev
= pmc
->idev
->dev
;
1484 struct mld2_report
*pmr
;
1485 struct mld2_grec
*pgr
= NULL
;
1486 struct ip6_sf_list
*psf
, *psf_next
, *psf_prev
, **psf_list
;
1487 int scount
, stotal
, first
, isquery
, truncate
;
1489 if (pmc
->mca_flags
& MAF_NOREPORT
)
1492 isquery
= type
== MLD2_MODE_IS_INCLUDE
||
1493 type
== MLD2_MODE_IS_EXCLUDE
;
1494 truncate
= type
== MLD2_MODE_IS_EXCLUDE
||
1495 type
== MLD2_CHANGE_TO_EXCLUDE
;
1497 stotal
= scount
= 0;
1499 psf_list
= sdeleted
? &pmc
->mca_tomb
: &pmc
->mca_sources
;
1504 pmr
= skb
? (struct mld2_report
*)skb_transport_header(skb
) : NULL
;
1506 /* EX and TO_EX get a fresh packet, if needed */
1508 if (pmr
&& pmr
->mld2r_ngrec
&&
1509 AVAILABLE(skb
) < grec_size(pmc
, type
, gdeleted
, sdeleted
)) {
1512 skb
= mld_newpack(dev
, dev
->mtu
);
1517 for (psf
=*psf_list
; psf
; psf
=psf_next
) {
1518 struct in6_addr
*psrc
;
1520 psf_next
= psf
->sf_next
;
1522 if (!is_in(pmc
, psf
, type
, gdeleted
, sdeleted
)) {
1527 /* clear marks on query responses */
1531 if (AVAILABLE(skb
) < sizeof(*psrc
) +
1532 first
*sizeof(struct mld2_grec
)) {
1533 if (truncate
&& !first
)
1534 break; /* truncate these */
1536 pgr
->grec_nsrcs
= htons(scount
);
1539 skb
= mld_newpack(dev
, dev
->mtu
);
1544 skb
= add_grhead(skb
, pmc
, type
, &pgr
);
1549 psrc
= (struct in6_addr
*)skb_put(skb
, sizeof(*psrc
));
1550 *psrc
= psf
->sf_addr
;
1552 if ((type
== MLD2_ALLOW_NEW_SOURCES
||
1553 type
== MLD2_BLOCK_OLD_SOURCES
) && psf
->sf_crcount
) {
1555 if ((sdeleted
|| gdeleted
) && psf
->sf_crcount
== 0) {
1557 psf_prev
->sf_next
= psf
->sf_next
;
1559 *psf_list
= psf
->sf_next
;
1569 if (type
== MLD2_ALLOW_NEW_SOURCES
||
1570 type
== MLD2_BLOCK_OLD_SOURCES
)
1572 if (pmc
->mca_crcount
|| isquery
) {
1573 /* make sure we have room for group header */
1574 if (skb
&& AVAILABLE(skb
) < sizeof(struct mld2_grec
)) {
1576 skb
= NULL
; /* add_grhead will get a new one */
1578 skb
= add_grhead(skb
, pmc
, type
, &pgr
);
1582 pgr
->grec_nsrcs
= htons(scount
);
1585 pmc
->mca_flags
&= ~MAF_GSQUERY
; /* clear query state */
1589 static void mld_send_report(struct inet6_dev
*idev
, struct ifmcaddr6
*pmc
)
1591 struct sk_buff
*skb
= NULL
;
1595 read_lock_bh(&idev
->lock
);
1596 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
1597 if (pmc
->mca_flags
& MAF_NOREPORT
)
1599 spin_lock_bh(&pmc
->mca_lock
);
1600 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
])
1601 type
= MLD2_MODE_IS_EXCLUDE
;
1603 type
= MLD2_MODE_IS_INCLUDE
;
1604 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1605 spin_unlock_bh(&pmc
->mca_lock
);
1607 read_unlock_bh(&idev
->lock
);
1609 spin_lock_bh(&pmc
->mca_lock
);
1610 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
])
1611 type
= MLD2_MODE_IS_EXCLUDE
;
1613 type
= MLD2_MODE_IS_INCLUDE
;
1614 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1615 spin_unlock_bh(&pmc
->mca_lock
);
1622 * remove zero-count source records from a source filter list
1624 static void mld_clear_zeros(struct ip6_sf_list
**ppsf
)
1626 struct ip6_sf_list
*psf_prev
, *psf_next
, *psf
;
1629 for (psf
=*ppsf
; psf
; psf
= psf_next
) {
1630 psf_next
= psf
->sf_next
;
1631 if (psf
->sf_crcount
== 0) {
1633 psf_prev
->sf_next
= psf
->sf_next
;
1635 *ppsf
= psf
->sf_next
;
1642 static void mld_send_cr(struct inet6_dev
*idev
)
1644 struct ifmcaddr6
*pmc
, *pmc_prev
, *pmc_next
;
1645 struct sk_buff
*skb
= NULL
;
1648 read_lock_bh(&idev
->lock
);
1649 spin_lock(&idev
->mc_lock
);
1653 for (pmc
=idev
->mc_tomb
; pmc
; pmc
=pmc_next
) {
1654 pmc_next
= pmc
->next
;
1655 if (pmc
->mca_sfmode
== MCAST_INCLUDE
) {
1656 type
= MLD2_BLOCK_OLD_SOURCES
;
1657 dtype
= MLD2_BLOCK_OLD_SOURCES
;
1658 skb
= add_grec(skb
, pmc
, type
, 1, 0);
1659 skb
= add_grec(skb
, pmc
, dtype
, 1, 1);
1661 if (pmc
->mca_crcount
) {
1662 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
) {
1663 type
= MLD2_CHANGE_TO_INCLUDE
;
1664 skb
= add_grec(skb
, pmc
, type
, 1, 0);
1667 if (pmc
->mca_crcount
== 0) {
1668 mld_clear_zeros(&pmc
->mca_tomb
);
1669 mld_clear_zeros(&pmc
->mca_sources
);
1672 if (pmc
->mca_crcount
== 0 && !pmc
->mca_tomb
&&
1673 !pmc
->mca_sources
) {
1675 pmc_prev
->next
= pmc_next
;
1677 idev
->mc_tomb
= pmc_next
;
1678 in6_dev_put(pmc
->idev
);
1683 spin_unlock(&idev
->mc_lock
);
1686 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
1687 spin_lock_bh(&pmc
->mca_lock
);
1688 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
]) {
1689 type
= MLD2_BLOCK_OLD_SOURCES
;
1690 dtype
= MLD2_ALLOW_NEW_SOURCES
;
1692 type
= MLD2_ALLOW_NEW_SOURCES
;
1693 dtype
= MLD2_BLOCK_OLD_SOURCES
;
1695 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1696 skb
= add_grec(skb
, pmc
, dtype
, 0, 1); /* deleted sources */
1698 /* filter mode changes */
1699 if (pmc
->mca_crcount
) {
1700 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
)
1701 type
= MLD2_CHANGE_TO_EXCLUDE
;
1703 type
= MLD2_CHANGE_TO_INCLUDE
;
1704 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1707 spin_unlock_bh(&pmc
->mca_lock
);
1709 read_unlock_bh(&idev
->lock
);
1712 (void) mld_sendpack(skb
);
1715 static void igmp6_send(struct in6_addr
*addr
, struct net_device
*dev
, int type
)
1717 struct net
*net
= dev_net(dev
);
1718 struct sock
*sk
= net
->ipv6
.igmp_sk
;
1719 struct inet6_dev
*idev
;
1720 struct sk_buff
*skb
;
1721 struct mld_msg
*hdr
;
1722 const struct in6_addr
*snd_addr
, *saddr
;
1723 struct in6_addr addr_buf
;
1724 int err
, len
, payload_len
, full_len
;
1725 u8 ra
[8] = { IPPROTO_ICMPV6
, 0,
1726 IPV6_TLV_ROUTERALERT
, 2, 0, 0,
1729 struct dst_entry
*dst
;
1731 if (type
== ICMPV6_MGM_REDUCTION
)
1732 snd_addr
= &in6addr_linklocal_allrouters
;
1736 len
= sizeof(struct icmp6hdr
) + sizeof(struct in6_addr
);
1737 payload_len
= len
+ sizeof(ra
);
1738 full_len
= sizeof(struct ipv6hdr
) + payload_len
;
1741 IP6_UPD_PO_STATS(net
, __in6_dev_get(dev
),
1742 IPSTATS_MIB_OUT
, full_len
);
1745 skb
= sock_alloc_send_skb(sk
, LL_ALLOCATED_SPACE(dev
) + full_len
, 1, &err
);
1749 IP6_INC_STATS(net
, __in6_dev_get(dev
),
1750 IPSTATS_MIB_OUTDISCARDS
);
1755 skb_reserve(skb
, LL_RESERVED_SPACE(dev
));
1757 if (ipv6_get_lladdr(dev
, &addr_buf
, IFA_F_TENTATIVE
)) {
1758 /* <draft-ietf-magma-mld-source-05.txt>:
1759 * use unspecified address as the source address
1760 * when a valid link-local address is not available.
1762 saddr
= &in6addr_any
;
1766 ip6_nd_hdr(sk
, skb
, dev
, saddr
, snd_addr
, NEXTHDR_HOP
, payload_len
);
1768 memcpy(skb_put(skb
, sizeof(ra
)), ra
, sizeof(ra
));
1770 hdr
= (struct mld_msg
*) skb_put(skb
, sizeof(struct mld_msg
));
1771 memset(hdr
, 0, sizeof(struct mld_msg
));
1772 hdr
->mld_type
= type
;
1773 ipv6_addr_copy(&hdr
->mld_mca
, addr
);
1775 hdr
->mld_cksum
= csum_ipv6_magic(saddr
, snd_addr
, len
,
1777 csum_partial(hdr
, len
, 0));
1779 idev
= in6_dev_get(skb
->dev
);
1781 dst
= icmp6_dst_alloc(skb
->dev
, NULL
, &ipv6_hdr(skb
)->daddr
);
1787 icmpv6_flow_init(sk
, &fl
, type
,
1788 &ipv6_hdr(skb
)->saddr
, &ipv6_hdr(skb
)->daddr
,
1791 err
= xfrm_lookup(net
, &dst
, &fl
, NULL
, 0);
1795 skb_dst_set(skb
, dst
);
1796 err
= NF_HOOK(PF_INET6
, NF_INET_LOCAL_OUT
, skb
, NULL
, skb
->dev
,
1800 ICMP6MSGOUT_INC_STATS(net
, idev
, type
);
1801 ICMP6_INC_STATS(net
, idev
, ICMP6_MIB_OUTMSGS
);
1802 IP6_UPD_PO_STATS(net
, idev
, IPSTATS_MIB_OUTMCAST
, full_len
);
1804 IP6_INC_STATS(net
, idev
, IPSTATS_MIB_OUTDISCARDS
);
1806 if (likely(idev
!= NULL
))
1815 static int ip6_mc_del1_src(struct ifmcaddr6
*pmc
, int sfmode
,
1816 struct in6_addr
*psfsrc
)
1818 struct ip6_sf_list
*psf
, *psf_prev
;
1822 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1823 if (ipv6_addr_equal(&psf
->sf_addr
, psfsrc
))
1827 if (!psf
|| psf
->sf_count
[sfmode
] == 0) {
1828 /* source filter not found, or count wrong => bug */
1831 psf
->sf_count
[sfmode
]--;
1832 if (!psf
->sf_count
[MCAST_INCLUDE
] && !psf
->sf_count
[MCAST_EXCLUDE
]) {
1833 struct inet6_dev
*idev
= pmc
->idev
;
1835 /* no more filters for this source */
1837 psf_prev
->sf_next
= psf
->sf_next
;
1839 pmc
->mca_sources
= psf
->sf_next
;
1840 if (psf
->sf_oldin
&& !(pmc
->mca_flags
& MAF_NOREPORT
) &&
1841 !MLD_V1_SEEN(idev
)) {
1842 psf
->sf_crcount
= idev
->mc_qrv
;
1843 psf
->sf_next
= pmc
->mca_tomb
;
1844 pmc
->mca_tomb
= psf
;
1852 static int ip6_mc_del_src(struct inet6_dev
*idev
, struct in6_addr
*pmca
,
1853 int sfmode
, int sfcount
, struct in6_addr
*psfsrc
,
1856 struct ifmcaddr6
*pmc
;
1862 read_lock_bh(&idev
->lock
);
1863 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
1864 if (ipv6_addr_equal(pmca
, &pmc
->mca_addr
))
1868 /* MCA not found?? bug */
1869 read_unlock_bh(&idev
->lock
);
1872 spin_lock_bh(&pmc
->mca_lock
);
1875 if (!pmc
->mca_sfcount
[sfmode
]) {
1876 spin_unlock_bh(&pmc
->mca_lock
);
1877 read_unlock_bh(&idev
->lock
);
1880 pmc
->mca_sfcount
[sfmode
]--;
1883 for (i
=0; i
<sfcount
; i
++) {
1884 int rv
= ip6_mc_del1_src(pmc
, sfmode
, &psfsrc
[i
]);
1886 changerec
|= rv
> 0;
1890 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
&&
1891 pmc
->mca_sfcount
[MCAST_EXCLUDE
] == 0 &&
1892 pmc
->mca_sfcount
[MCAST_INCLUDE
]) {
1893 struct ip6_sf_list
*psf
;
1895 /* filter mode change */
1896 pmc
->mca_sfmode
= MCAST_INCLUDE
;
1897 pmc
->mca_crcount
= idev
->mc_qrv
;
1898 idev
->mc_ifc_count
= pmc
->mca_crcount
;
1899 for (psf
=pmc
->mca_sources
; psf
; psf
= psf
->sf_next
)
1900 psf
->sf_crcount
= 0;
1901 mld_ifc_event(pmc
->idev
);
1902 } else if (sf_setstate(pmc
) || changerec
)
1903 mld_ifc_event(pmc
->idev
);
1904 spin_unlock_bh(&pmc
->mca_lock
);
1905 read_unlock_bh(&idev
->lock
);
1910 * Add multicast single-source filter to the interface list
1912 static int ip6_mc_add1_src(struct ifmcaddr6
*pmc
, int sfmode
,
1913 struct in6_addr
*psfsrc
, int delta
)
1915 struct ip6_sf_list
*psf
, *psf_prev
;
1918 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1919 if (ipv6_addr_equal(&psf
->sf_addr
, psfsrc
))
1924 psf
= kzalloc(sizeof(*psf
), GFP_ATOMIC
);
1928 psf
->sf_addr
= *psfsrc
;
1930 psf_prev
->sf_next
= psf
;
1932 pmc
->mca_sources
= psf
;
1934 psf
->sf_count
[sfmode
]++;
1938 static void sf_markstate(struct ifmcaddr6
*pmc
)
1940 struct ip6_sf_list
*psf
;
1941 int mca_xcount
= pmc
->mca_sfcount
[MCAST_EXCLUDE
];
1943 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
)
1944 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
]) {
1945 psf
->sf_oldin
= mca_xcount
==
1946 psf
->sf_count
[MCAST_EXCLUDE
] &&
1947 !psf
->sf_count
[MCAST_INCLUDE
];
1949 psf
->sf_oldin
= psf
->sf_count
[MCAST_INCLUDE
] != 0;
1952 static int sf_setstate(struct ifmcaddr6
*pmc
)
1954 struct ip6_sf_list
*psf
, *dpsf
;
1955 int mca_xcount
= pmc
->mca_sfcount
[MCAST_EXCLUDE
];
1956 int qrv
= pmc
->idev
->mc_qrv
;
1960 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1961 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
]) {
1962 new_in
= mca_xcount
== psf
->sf_count
[MCAST_EXCLUDE
] &&
1963 !psf
->sf_count
[MCAST_INCLUDE
];
1965 new_in
= psf
->sf_count
[MCAST_INCLUDE
] != 0;
1967 if (!psf
->sf_oldin
) {
1968 struct ip6_sf_list
*prev
= NULL
;
1970 for (dpsf
=pmc
->mca_tomb
; dpsf
;
1971 dpsf
=dpsf
->sf_next
) {
1972 if (ipv6_addr_equal(&dpsf
->sf_addr
,
1979 prev
->sf_next
= dpsf
->sf_next
;
1981 pmc
->mca_tomb
= dpsf
->sf_next
;
1984 psf
->sf_crcount
= qrv
;
1987 } else if (psf
->sf_oldin
) {
1988 psf
->sf_crcount
= 0;
1990 * add or update "delete" records if an active filter
1993 for (dpsf
=pmc
->mca_tomb
; dpsf
; dpsf
=dpsf
->sf_next
)
1994 if (ipv6_addr_equal(&dpsf
->sf_addr
,
1998 dpsf
= (struct ip6_sf_list
*)
1999 kmalloc(sizeof(*dpsf
), GFP_ATOMIC
);
2003 /* pmc->mca_lock held by callers */
2004 dpsf
->sf_next
= pmc
->mca_tomb
;
2005 pmc
->mca_tomb
= dpsf
;
2007 dpsf
->sf_crcount
= qrv
;
2015 * Add multicast source filter list to the interface list
2017 static int ip6_mc_add_src(struct inet6_dev
*idev
, struct in6_addr
*pmca
,
2018 int sfmode
, int sfcount
, struct in6_addr
*psfsrc
,
2021 struct ifmcaddr6
*pmc
;
2027 read_lock_bh(&idev
->lock
);
2028 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
2029 if (ipv6_addr_equal(pmca
, &pmc
->mca_addr
))
2033 /* MCA not found?? bug */
2034 read_unlock_bh(&idev
->lock
);
2037 spin_lock_bh(&pmc
->mca_lock
);
2040 isexclude
= pmc
->mca_sfmode
== MCAST_EXCLUDE
;
2042 pmc
->mca_sfcount
[sfmode
]++;
2044 for (i
=0; i
<sfcount
; i
++) {
2045 err
= ip6_mc_add1_src(pmc
, sfmode
, &psfsrc
[i
], delta
);
2053 pmc
->mca_sfcount
[sfmode
]--;
2055 (void) ip6_mc_del1_src(pmc
, sfmode
, &psfsrc
[i
]);
2056 } else if (isexclude
!= (pmc
->mca_sfcount
[MCAST_EXCLUDE
] != 0)) {
2057 struct ip6_sf_list
*psf
;
2059 /* filter mode change */
2060 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
])
2061 pmc
->mca_sfmode
= MCAST_EXCLUDE
;
2062 else if (pmc
->mca_sfcount
[MCAST_INCLUDE
])
2063 pmc
->mca_sfmode
= MCAST_INCLUDE
;
2064 /* else no filters; keep old mode for reports */
2066 pmc
->mca_crcount
= idev
->mc_qrv
;
2067 idev
->mc_ifc_count
= pmc
->mca_crcount
;
2068 for (psf
=pmc
->mca_sources
; psf
; psf
= psf
->sf_next
)
2069 psf
->sf_crcount
= 0;
2070 mld_ifc_event(idev
);
2071 } else if (sf_setstate(pmc
))
2072 mld_ifc_event(idev
);
2073 spin_unlock_bh(&pmc
->mca_lock
);
2074 read_unlock_bh(&idev
->lock
);
2078 static void ip6_mc_clear_src(struct ifmcaddr6
*pmc
)
2080 struct ip6_sf_list
*psf
, *nextpsf
;
2082 for (psf
=pmc
->mca_tomb
; psf
; psf
=nextpsf
) {
2083 nextpsf
= psf
->sf_next
;
2086 pmc
->mca_tomb
= NULL
;
2087 for (psf
=pmc
->mca_sources
; psf
; psf
=nextpsf
) {
2088 nextpsf
= psf
->sf_next
;
2091 pmc
->mca_sources
= NULL
;
2092 pmc
->mca_sfmode
= MCAST_EXCLUDE
;
2093 pmc
->mca_sfcount
[MCAST_INCLUDE
] = 0;
2094 pmc
->mca_sfcount
[MCAST_EXCLUDE
] = 1;
2098 static void igmp6_join_group(struct ifmcaddr6
*ma
)
2100 unsigned long delay
;
2102 if (ma
->mca_flags
& MAF_NOREPORT
)
2105 igmp6_send(&ma
->mca_addr
, ma
->idev
->dev
, ICMPV6_MGM_REPORT
);
2107 delay
= net_random() % IGMP6_UNSOLICITED_IVAL
;
2109 spin_lock_bh(&ma
->mca_lock
);
2110 if (del_timer(&ma
->mca_timer
)) {
2111 atomic_dec(&ma
->mca_refcnt
);
2112 delay
= ma
->mca_timer
.expires
- jiffies
;
2115 if (!mod_timer(&ma
->mca_timer
, jiffies
+ delay
))
2116 atomic_inc(&ma
->mca_refcnt
);
2117 ma
->mca_flags
|= MAF_TIMER_RUNNING
| MAF_LAST_REPORTER
;
2118 spin_unlock_bh(&ma
->mca_lock
);
2121 static int ip6_mc_leave_src(struct sock
*sk
, struct ipv6_mc_socklist
*iml
,
2122 struct inet6_dev
*idev
)
2126 /* callers have the socket lock and a write lock on ipv6_sk_mc_lock,
2127 * so no other readers or writers of iml or its sflist
2130 /* any-source empty exclude case */
2131 return ip6_mc_del_src(idev
, &iml
->addr
, iml
->sfmode
, 0, NULL
, 0);
2133 err
= ip6_mc_del_src(idev
, &iml
->addr
, iml
->sfmode
,
2134 iml
->sflist
->sl_count
, iml
->sflist
->sl_addr
, 0);
2135 sock_kfree_s(sk
, iml
->sflist
, IP6_SFLSIZE(iml
->sflist
->sl_max
));
2140 static void igmp6_leave_group(struct ifmcaddr6
*ma
)
2142 if (MLD_V1_SEEN(ma
->idev
)) {
2143 if (ma
->mca_flags
& MAF_LAST_REPORTER
)
2144 igmp6_send(&ma
->mca_addr
, ma
->idev
->dev
,
2145 ICMPV6_MGM_REDUCTION
);
2147 mld_add_delrec(ma
->idev
, ma
);
2148 mld_ifc_event(ma
->idev
);
2152 static void mld_gq_timer_expire(unsigned long data
)
2154 struct inet6_dev
*idev
= (struct inet6_dev
*)data
;
2156 idev
->mc_gq_running
= 0;
2157 mld_send_report(idev
, NULL
);
2158 __in6_dev_put(idev
);
2161 static void mld_ifc_timer_expire(unsigned long data
)
2163 struct inet6_dev
*idev
= (struct inet6_dev
*)data
;
2166 if (idev
->mc_ifc_count
) {
2167 idev
->mc_ifc_count
--;
2168 if (idev
->mc_ifc_count
)
2169 mld_ifc_start_timer(idev
, idev
->mc_maxdelay
);
2171 __in6_dev_put(idev
);
2174 static void mld_ifc_event(struct inet6_dev
*idev
)
2176 if (MLD_V1_SEEN(idev
))
2178 idev
->mc_ifc_count
= idev
->mc_qrv
;
2179 mld_ifc_start_timer(idev
, 1);
2183 static void igmp6_timer_handler(unsigned long data
)
2185 struct ifmcaddr6
*ma
= (struct ifmcaddr6
*) data
;
2187 if (MLD_V1_SEEN(ma
->idev
))
2188 igmp6_send(&ma
->mca_addr
, ma
->idev
->dev
, ICMPV6_MGM_REPORT
);
2190 mld_send_report(ma
->idev
, ma
);
2192 spin_lock(&ma
->mca_lock
);
2193 ma
->mca_flags
|= MAF_LAST_REPORTER
;
2194 ma
->mca_flags
&= ~MAF_TIMER_RUNNING
;
2195 spin_unlock(&ma
->mca_lock
);
2199 /* Device changing type */
2201 void ipv6_mc_unmap(struct inet6_dev
*idev
)
2203 struct ifmcaddr6
*i
;
2205 /* Install multicast list, except for all-nodes (already installed) */
2207 read_lock_bh(&idev
->lock
);
2208 for (i
= idev
->mc_list
; i
; i
= i
->next
)
2209 igmp6_group_dropped(i
);
2210 read_unlock_bh(&idev
->lock
);
2213 void ipv6_mc_remap(struct inet6_dev
*idev
)
2218 /* Device going down */
2220 void ipv6_mc_down(struct inet6_dev
*idev
)
2222 struct ifmcaddr6
*i
;
2224 /* Withdraw multicast list */
2226 read_lock_bh(&idev
->lock
);
2227 idev
->mc_ifc_count
= 0;
2228 if (del_timer(&idev
->mc_ifc_timer
))
2229 __in6_dev_put(idev
);
2230 idev
->mc_gq_running
= 0;
2231 if (del_timer(&idev
->mc_gq_timer
))
2232 __in6_dev_put(idev
);
2234 for (i
= idev
->mc_list
; i
; i
=i
->next
)
2235 igmp6_group_dropped(i
);
2236 read_unlock_bh(&idev
->lock
);
2238 mld_clear_delrec(idev
);
2242 /* Device going up */
2244 void ipv6_mc_up(struct inet6_dev
*idev
)
2246 struct ifmcaddr6
*i
;
2248 /* Install multicast list, except for all-nodes (already installed) */
2250 read_lock_bh(&idev
->lock
);
2251 for (i
= idev
->mc_list
; i
; i
=i
->next
)
2252 igmp6_group_added(i
);
2253 read_unlock_bh(&idev
->lock
);
2256 /* IPv6 device initialization. */
2258 void ipv6_mc_init_dev(struct inet6_dev
*idev
)
2260 write_lock_bh(&idev
->lock
);
2261 spin_lock_init(&idev
->mc_lock
);
2262 idev
->mc_gq_running
= 0;
2263 setup_timer(&idev
->mc_gq_timer
, mld_gq_timer_expire
,
2264 (unsigned long)idev
);
2265 idev
->mc_tomb
= NULL
;
2266 idev
->mc_ifc_count
= 0;
2267 setup_timer(&idev
->mc_ifc_timer
, mld_ifc_timer_expire
,
2268 (unsigned long)idev
);
2269 idev
->mc_qrv
= MLD_QRV_DEFAULT
;
2270 idev
->mc_maxdelay
= IGMP6_UNSOLICITED_IVAL
;
2271 idev
->mc_v1_seen
= 0;
2272 write_unlock_bh(&idev
->lock
);
2276 * Device is about to be destroyed: clean up.
2279 void ipv6_mc_destroy_dev(struct inet6_dev
*idev
)
2281 struct ifmcaddr6
*i
;
2283 /* Deactivate timers */
2286 /* Delete all-nodes address. */
2287 /* We cannot call ipv6_dev_mc_dec() directly, our caller in
2288 * addrconf.c has NULL'd out dev->ip6_ptr so in6_dev_get() will
2291 __ipv6_dev_mc_dec(idev
, &in6addr_linklocal_allnodes
);
2293 if (idev
->cnf
.forwarding
)
2294 __ipv6_dev_mc_dec(idev
, &in6addr_linklocal_allrouters
);
2296 write_lock_bh(&idev
->lock
);
2297 while ((i
= idev
->mc_list
) != NULL
) {
2298 idev
->mc_list
= i
->next
;
2299 write_unlock_bh(&idev
->lock
);
2301 igmp6_group_dropped(i
);
2304 write_lock_bh(&idev
->lock
);
2306 write_unlock_bh(&idev
->lock
);
2309 #ifdef CONFIG_PROC_FS
2310 struct igmp6_mc_iter_state
{
2311 struct seq_net_private p
;
2312 struct net_device
*dev
;
2313 struct inet6_dev
*idev
;
2316 #define igmp6_mc_seq_private(seq) ((struct igmp6_mc_iter_state *)(seq)->private)
2318 static inline struct ifmcaddr6
*igmp6_mc_get_first(struct seq_file
*seq
)
2320 struct ifmcaddr6
*im
= NULL
;
2321 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2322 struct net
*net
= seq_file_net(seq
);
2325 for_each_netdev_rcu(net
, state
->dev
) {
2326 struct inet6_dev
*idev
;
2327 idev
= __in6_dev_get(state
->dev
);
2330 read_lock_bh(&idev
->lock
);
2336 read_unlock_bh(&idev
->lock
);
2341 static struct ifmcaddr6
*igmp6_mc_get_next(struct seq_file
*seq
, struct ifmcaddr6
*im
)
2343 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2347 if (likely(state
->idev
!= NULL
))
2348 read_unlock_bh(&state
->idev
->lock
);
2350 state
->dev
= next_net_device_rcu(state
->dev
);
2355 state
->idev
= __in6_dev_get(state
->dev
);
2358 read_lock_bh(&state
->idev
->lock
);
2359 im
= state
->idev
->mc_list
;
2364 static struct ifmcaddr6
*igmp6_mc_get_idx(struct seq_file
*seq
, loff_t pos
)
2366 struct ifmcaddr6
*im
= igmp6_mc_get_first(seq
);
2368 while (pos
&& (im
= igmp6_mc_get_next(seq
, im
)) != NULL
)
2370 return pos
? NULL
: im
;
2373 static void *igmp6_mc_seq_start(struct seq_file
*seq
, loff_t
*pos
)
2377 return igmp6_mc_get_idx(seq
, *pos
);
2380 static void *igmp6_mc_seq_next(struct seq_file
*seq
, void *v
, loff_t
*pos
)
2382 struct ifmcaddr6
*im
= igmp6_mc_get_next(seq
, v
);
2388 static void igmp6_mc_seq_stop(struct seq_file
*seq
, void *v
)
2391 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2393 if (likely(state
->idev
!= NULL
)) {
2394 read_unlock_bh(&state
->idev
->lock
);
2401 static int igmp6_mc_seq_show(struct seq_file
*seq
, void *v
)
2403 struct ifmcaddr6
*im
= (struct ifmcaddr6
*)v
;
2404 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2407 "%-4d %-15s %pi6 %5d %08X %ld\n",
2408 state
->dev
->ifindex
, state
->dev
->name
,
2410 im
->mca_users
, im
->mca_flags
,
2411 (im
->mca_flags
&MAF_TIMER_RUNNING
) ?
2412 jiffies_to_clock_t(im
->mca_timer
.expires
-jiffies
) : 0);
2416 static const struct seq_operations igmp6_mc_seq_ops
= {
2417 .start
= igmp6_mc_seq_start
,
2418 .next
= igmp6_mc_seq_next
,
2419 .stop
= igmp6_mc_seq_stop
,
2420 .show
= igmp6_mc_seq_show
,
2423 static int igmp6_mc_seq_open(struct inode
*inode
, struct file
*file
)
2425 return seq_open_net(inode
, file
, &igmp6_mc_seq_ops
,
2426 sizeof(struct igmp6_mc_iter_state
));
2429 static const struct file_operations igmp6_mc_seq_fops
= {
2430 .owner
= THIS_MODULE
,
2431 .open
= igmp6_mc_seq_open
,
2433 .llseek
= seq_lseek
,
2434 .release
= seq_release_net
,
2437 struct igmp6_mcf_iter_state
{
2438 struct seq_net_private p
;
2439 struct net_device
*dev
;
2440 struct inet6_dev
*idev
;
2441 struct ifmcaddr6
*im
;
2444 #define igmp6_mcf_seq_private(seq) ((struct igmp6_mcf_iter_state *)(seq)->private)
2446 static inline struct ip6_sf_list
*igmp6_mcf_get_first(struct seq_file
*seq
)
2448 struct ip6_sf_list
*psf
= NULL
;
2449 struct ifmcaddr6
*im
= NULL
;
2450 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2451 struct net
*net
= seq_file_net(seq
);
2455 for_each_netdev_rcu(net
, state
->dev
) {
2456 struct inet6_dev
*idev
;
2457 idev
= __in6_dev_get(state
->dev
);
2458 if (unlikely(idev
== NULL
))
2460 read_lock_bh(&idev
->lock
);
2462 if (likely(im
!= NULL
)) {
2463 spin_lock_bh(&im
->mca_lock
);
2464 psf
= im
->mca_sources
;
2465 if (likely(psf
!= NULL
)) {
2470 spin_unlock_bh(&im
->mca_lock
);
2472 read_unlock_bh(&idev
->lock
);
2477 static struct ip6_sf_list
*igmp6_mcf_get_next(struct seq_file
*seq
, struct ip6_sf_list
*psf
)
2479 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2483 spin_unlock_bh(&state
->im
->mca_lock
);
2484 state
->im
= state
->im
->next
;
2485 while (!state
->im
) {
2486 if (likely(state
->idev
!= NULL
))
2487 read_unlock_bh(&state
->idev
->lock
);
2489 state
->dev
= next_net_device_rcu(state
->dev
);
2494 state
->idev
= __in6_dev_get(state
->dev
);
2497 read_lock_bh(&state
->idev
->lock
);
2498 state
->im
= state
->idev
->mc_list
;
2502 spin_lock_bh(&state
->im
->mca_lock
);
2503 psf
= state
->im
->mca_sources
;
2509 static struct ip6_sf_list
*igmp6_mcf_get_idx(struct seq_file
*seq
, loff_t pos
)
2511 struct ip6_sf_list
*psf
= igmp6_mcf_get_first(seq
);
2513 while (pos
&& (psf
= igmp6_mcf_get_next(seq
, psf
)) != NULL
)
2515 return pos
? NULL
: psf
;
2518 static void *igmp6_mcf_seq_start(struct seq_file
*seq
, loff_t
*pos
)
2522 return *pos
? igmp6_mcf_get_idx(seq
, *pos
- 1) : SEQ_START_TOKEN
;
2525 static void *igmp6_mcf_seq_next(struct seq_file
*seq
, void *v
, loff_t
*pos
)
2527 struct ip6_sf_list
*psf
;
2528 if (v
== SEQ_START_TOKEN
)
2529 psf
= igmp6_mcf_get_first(seq
);
2531 psf
= igmp6_mcf_get_next(seq
, v
);
2536 static void igmp6_mcf_seq_stop(struct seq_file
*seq
, void *v
)
2539 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2540 if (likely(state
->im
!= NULL
)) {
2541 spin_unlock_bh(&state
->im
->mca_lock
);
2544 if (likely(state
->idev
!= NULL
)) {
2545 read_unlock_bh(&state
->idev
->lock
);
2552 static int igmp6_mcf_seq_show(struct seq_file
*seq
, void *v
)
2554 struct ip6_sf_list
*psf
= (struct ip6_sf_list
*)v
;
2555 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2557 if (v
== SEQ_START_TOKEN
) {
2560 "%32s %32s %6s %6s\n", "Idx",
2561 "Device", "Multicast Address",
2562 "Source Address", "INC", "EXC");
2565 "%3d %6.6s %pi6 %pi6 %6lu %6lu\n",
2566 state
->dev
->ifindex
, state
->dev
->name
,
2567 &state
->im
->mca_addr
,
2569 psf
->sf_count
[MCAST_INCLUDE
],
2570 psf
->sf_count
[MCAST_EXCLUDE
]);
2575 static const struct seq_operations igmp6_mcf_seq_ops
= {
2576 .start
= igmp6_mcf_seq_start
,
2577 .next
= igmp6_mcf_seq_next
,
2578 .stop
= igmp6_mcf_seq_stop
,
2579 .show
= igmp6_mcf_seq_show
,
2582 static int igmp6_mcf_seq_open(struct inode
*inode
, struct file
*file
)
2584 return seq_open_net(inode
, file
, &igmp6_mcf_seq_ops
,
2585 sizeof(struct igmp6_mcf_iter_state
));
2588 static const struct file_operations igmp6_mcf_seq_fops
= {
2589 .owner
= THIS_MODULE
,
2590 .open
= igmp6_mcf_seq_open
,
2592 .llseek
= seq_lseek
,
2593 .release
= seq_release_net
,
2596 static int __net_init
igmp6_proc_init(struct net
*net
)
2601 if (!proc_net_fops_create(net
, "igmp6", S_IRUGO
, &igmp6_mc_seq_fops
))
2603 if (!proc_net_fops_create(net
, "mcfilter6", S_IRUGO
,
2604 &igmp6_mcf_seq_fops
))
2605 goto out_proc_net_igmp6
;
2612 proc_net_remove(net
, "igmp6");
2616 static void __net_exit
igmp6_proc_exit(struct net
*net
)
2618 proc_net_remove(net
, "mcfilter6");
2619 proc_net_remove(net
, "igmp6");
2622 static inline int igmp6_proc_init(struct net
*net
)
2626 static inline void igmp6_proc_exit(struct net
*net
)
2631 static int __net_init
igmp6_net_init(struct net
*net
)
2635 err
= inet_ctl_sock_create(&net
->ipv6
.igmp_sk
, PF_INET6
,
2636 SOCK_RAW
, IPPROTO_ICMPV6
, net
);
2639 "Failed to initialize the IGMP6 control socket (err %d).\n",
2644 inet6_sk(net
->ipv6
.igmp_sk
)->hop_limit
= 1;
2646 err
= igmp6_proc_init(net
);
2648 goto out_sock_create
;
2653 inet_ctl_sock_destroy(net
->ipv6
.igmp_sk
);
2657 static void __net_exit
igmp6_net_exit(struct net
*net
)
2659 inet_ctl_sock_destroy(net
->ipv6
.igmp_sk
);
2660 igmp6_proc_exit(net
);
2663 static struct pernet_operations igmp6_net_ops
= {
2664 .init
= igmp6_net_init
,
2665 .exit
= igmp6_net_exit
,
2668 int __init
igmp6_init(void)
2670 return register_pernet_subsys(&igmp6_net_ops
);
2673 void igmp6_cleanup(void)
2675 unregister_pernet_subsys(&igmp6_net_ops
);