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_SPINLOCK(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
, const 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
, const struct in6_addr
*pmca
,
101 int sfmode
, int sfcount
, const struct in6_addr
*psfsrc
,
103 static int ip6_mc_add_src(struct inet6_dev
*idev
, const struct in6_addr
*pmca
,
104 int sfmode
, int sfcount
, const 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 #define for_each_pmc_rcu(np, pmc) \
127 for (pmc = rcu_dereference(np->ipv6_mc_list); \
129 pmc = rcu_dereference(pmc->next))
131 int ipv6_sock_mc_join(struct sock
*sk
, int ifindex
, const struct in6_addr
*addr
)
133 struct net_device
*dev
= NULL
;
134 struct ipv6_mc_socklist
*mc_lst
;
135 struct ipv6_pinfo
*np
= inet6_sk(sk
);
136 struct net
*net
= sock_net(sk
);
139 if (!ipv6_addr_is_multicast(addr
))
143 for_each_pmc_rcu(np
, mc_lst
) {
144 if ((ifindex
== 0 || mc_lst
->ifindex
== ifindex
) &&
145 ipv6_addr_equal(&mc_lst
->addr
, addr
)) {
152 mc_lst
= sock_kmalloc(sk
, sizeof(struct ipv6_mc_socklist
), GFP_KERNEL
);
158 mc_lst
->addr
= *addr
;
163 rt
= rt6_lookup(net
, addr
, NULL
, 0, 0);
169 dev
= dev_get_by_index_rcu(net
, ifindex
);
173 sock_kfree_s(sk
, mc_lst
, sizeof(*mc_lst
));
177 mc_lst
->ifindex
= dev
->ifindex
;
178 mc_lst
->sfmode
= MCAST_EXCLUDE
;
179 rwlock_init(&mc_lst
->sflock
);
180 mc_lst
->sflist
= NULL
;
183 * now add/increase the group membership on the device
186 err
= ipv6_dev_mc_inc(dev
, addr
);
190 sock_kfree_s(sk
, mc_lst
, sizeof(*mc_lst
));
194 spin_lock(&ipv6_sk_mc_lock
);
195 mc_lst
->next
= np
->ipv6_mc_list
;
196 rcu_assign_pointer(np
->ipv6_mc_list
, mc_lst
);
197 spin_unlock(&ipv6_sk_mc_lock
);
205 * socket leave on multicast group
207 int ipv6_sock_mc_drop(struct sock
*sk
, int ifindex
, const struct in6_addr
*addr
)
209 struct ipv6_pinfo
*np
= inet6_sk(sk
);
210 struct ipv6_mc_socklist
*mc_lst
;
211 struct ipv6_mc_socklist __rcu
**lnk
;
212 struct net
*net
= sock_net(sk
);
214 if (!ipv6_addr_is_multicast(addr
))
217 spin_lock(&ipv6_sk_mc_lock
);
218 for (lnk
= &np
->ipv6_mc_list
;
219 (mc_lst
= rcu_dereference_protected(*lnk
,
220 lockdep_is_held(&ipv6_sk_mc_lock
))) !=NULL
;
221 lnk
= &mc_lst
->next
) {
222 if ((ifindex
== 0 || mc_lst
->ifindex
== ifindex
) &&
223 ipv6_addr_equal(&mc_lst
->addr
, addr
)) {
224 struct net_device
*dev
;
227 spin_unlock(&ipv6_sk_mc_lock
);
230 dev
= dev_get_by_index_rcu(net
, mc_lst
->ifindex
);
232 struct inet6_dev
*idev
= __in6_dev_get(dev
);
234 (void) ip6_mc_leave_src(sk
, mc_lst
, idev
);
236 __ipv6_dev_mc_dec(idev
, &mc_lst
->addr
);
238 (void) ip6_mc_leave_src(sk
, mc_lst
, NULL
);
240 atomic_sub(sizeof(*mc_lst
), &sk
->sk_omem_alloc
);
241 kfree_rcu(mc_lst
, rcu
);
245 spin_unlock(&ipv6_sk_mc_lock
);
247 return -EADDRNOTAVAIL
;
250 /* called with rcu_read_lock() */
251 static struct inet6_dev
*ip6_mc_find_dev_rcu(struct net
*net
,
252 const struct in6_addr
*group
,
255 struct net_device
*dev
= NULL
;
256 struct inet6_dev
*idev
= NULL
;
259 struct rt6_info
*rt
= rt6_lookup(net
, group
, NULL
, 0, 0);
266 dev
= dev_get_by_index_rcu(net
, ifindex
);
270 idev
= __in6_dev_get(dev
);
273 read_lock_bh(&idev
->lock
);
275 read_unlock_bh(&idev
->lock
);
281 void ipv6_sock_mc_close(struct sock
*sk
)
283 struct ipv6_pinfo
*np
= inet6_sk(sk
);
284 struct ipv6_mc_socklist
*mc_lst
;
285 struct net
*net
= sock_net(sk
);
287 if (!rcu_access_pointer(np
->ipv6_mc_list
))
290 spin_lock(&ipv6_sk_mc_lock
);
291 while ((mc_lst
= rcu_dereference_protected(np
->ipv6_mc_list
,
292 lockdep_is_held(&ipv6_sk_mc_lock
))) != NULL
) {
293 struct net_device
*dev
;
295 np
->ipv6_mc_list
= mc_lst
->next
;
296 spin_unlock(&ipv6_sk_mc_lock
);
299 dev
= dev_get_by_index_rcu(net
, mc_lst
->ifindex
);
301 struct inet6_dev
*idev
= __in6_dev_get(dev
);
303 (void) ip6_mc_leave_src(sk
, mc_lst
, idev
);
305 __ipv6_dev_mc_dec(idev
, &mc_lst
->addr
);
307 (void) ip6_mc_leave_src(sk
, mc_lst
, NULL
);
310 atomic_sub(sizeof(*mc_lst
), &sk
->sk_omem_alloc
);
311 kfree_rcu(mc_lst
, rcu
);
313 spin_lock(&ipv6_sk_mc_lock
);
315 spin_unlock(&ipv6_sk_mc_lock
);
318 int ip6_mc_source(int add
, int omode
, struct sock
*sk
,
319 struct group_source_req
*pgsr
)
321 struct in6_addr
*source
, *group
;
322 struct ipv6_mc_socklist
*pmc
;
323 struct inet6_dev
*idev
;
324 struct ipv6_pinfo
*inet6
= inet6_sk(sk
);
325 struct ip6_sf_socklist
*psl
;
326 struct net
*net
= sock_net(sk
);
332 source
= &((struct sockaddr_in6
*)&pgsr
->gsr_source
)->sin6_addr
;
333 group
= &((struct sockaddr_in6
*)&pgsr
->gsr_group
)->sin6_addr
;
335 if (!ipv6_addr_is_multicast(group
))
339 idev
= ip6_mc_find_dev_rcu(net
, group
, pgsr
->gsr_interface
);
345 err
= -EADDRNOTAVAIL
;
347 for_each_pmc_rcu(inet6
, pmc
) {
348 if (pgsr
->gsr_interface
&& pmc
->ifindex
!= pgsr
->gsr_interface
)
350 if (ipv6_addr_equal(&pmc
->addr
, group
))
353 if (!pmc
) { /* must have a prior join */
357 /* if a source filter was set, must be the same mode as before */
359 if (pmc
->sfmode
!= omode
) {
363 } else if (pmc
->sfmode
!= omode
) {
364 /* allow mode switches for empty-set filters */
365 ip6_mc_add_src(idev
, group
, omode
, 0, NULL
, 0);
366 ip6_mc_del_src(idev
, group
, pmc
->sfmode
, 0, NULL
, 0);
370 write_lock(&pmc
->sflock
);
376 goto done
; /* err = -EADDRNOTAVAIL */
378 for (i
=0; i
<psl
->sl_count
; i
++) {
379 rv
= !ipv6_addr_equal(&psl
->sl_addr
[i
], source
);
383 if (rv
) /* source not found */
384 goto done
; /* err = -EADDRNOTAVAIL */
386 /* special case - (INCLUDE, empty) == LEAVE_GROUP */
387 if (psl
->sl_count
== 1 && omode
== MCAST_INCLUDE
) {
392 /* update the interface filter */
393 ip6_mc_del_src(idev
, group
, omode
, 1, source
, 1);
395 for (j
=i
+1; j
<psl
->sl_count
; j
++)
396 psl
->sl_addr
[j
-1] = psl
->sl_addr
[j
];
401 /* else, add a new source to the filter */
403 if (psl
&& psl
->sl_count
>= sysctl_mld_max_msf
) {
407 if (!psl
|| psl
->sl_count
== psl
->sl_max
) {
408 struct ip6_sf_socklist
*newpsl
;
409 int count
= IP6_SFBLOCK
;
412 count
+= psl
->sl_max
;
413 newpsl
= sock_kmalloc(sk
, IP6_SFLSIZE(count
), GFP_ATOMIC
);
418 newpsl
->sl_max
= count
;
419 newpsl
->sl_count
= count
- IP6_SFBLOCK
;
421 for (i
=0; i
<psl
->sl_count
; i
++)
422 newpsl
->sl_addr
[i
] = psl
->sl_addr
[i
];
423 sock_kfree_s(sk
, psl
, IP6_SFLSIZE(psl
->sl_max
));
425 pmc
->sflist
= psl
= newpsl
;
427 rv
= 1; /* > 0 for insert logic below if sl_count is 0 */
428 for (i
=0; i
<psl
->sl_count
; i
++) {
429 rv
= !ipv6_addr_equal(&psl
->sl_addr
[i
], source
);
430 if (rv
== 0) /* There is an error in the address. */
433 for (j
=psl
->sl_count
-1; j
>=i
; j
--)
434 psl
->sl_addr
[j
+1] = psl
->sl_addr
[j
];
435 psl
->sl_addr
[i
] = *source
;
438 /* update the interface list */
439 ip6_mc_add_src(idev
, group
, omode
, 1, source
, 1);
442 write_unlock(&pmc
->sflock
);
443 read_unlock_bh(&idev
->lock
);
446 return ipv6_sock_mc_drop(sk
, pgsr
->gsr_interface
, group
);
450 int ip6_mc_msfilter(struct sock
*sk
, struct group_filter
*gsf
)
452 const struct in6_addr
*group
;
453 struct ipv6_mc_socklist
*pmc
;
454 struct inet6_dev
*idev
;
455 struct ipv6_pinfo
*inet6
= inet6_sk(sk
);
456 struct ip6_sf_socklist
*newpsl
, *psl
;
457 struct net
*net
= sock_net(sk
);
461 group
= &((struct sockaddr_in6
*)&gsf
->gf_group
)->sin6_addr
;
463 if (!ipv6_addr_is_multicast(group
))
465 if (gsf
->gf_fmode
!= MCAST_INCLUDE
&&
466 gsf
->gf_fmode
!= MCAST_EXCLUDE
)
470 idev
= ip6_mc_find_dev_rcu(net
, group
, gsf
->gf_interface
);
479 if (gsf
->gf_fmode
== MCAST_INCLUDE
&& gsf
->gf_numsrc
== 0) {
484 for_each_pmc_rcu(inet6
, pmc
) {
485 if (pmc
->ifindex
!= gsf
->gf_interface
)
487 if (ipv6_addr_equal(&pmc
->addr
, group
))
490 if (!pmc
) { /* must have a prior join */
494 if (gsf
->gf_numsrc
) {
495 newpsl
= sock_kmalloc(sk
, IP6_SFLSIZE(gsf
->gf_numsrc
),
501 newpsl
->sl_max
= newpsl
->sl_count
= gsf
->gf_numsrc
;
502 for (i
=0; i
<newpsl
->sl_count
; ++i
) {
503 struct sockaddr_in6
*psin6
;
505 psin6
= (struct sockaddr_in6
*)&gsf
->gf_slist
[i
];
506 newpsl
->sl_addr
[i
] = psin6
->sin6_addr
;
508 err
= ip6_mc_add_src(idev
, group
, gsf
->gf_fmode
,
509 newpsl
->sl_count
, newpsl
->sl_addr
, 0);
511 sock_kfree_s(sk
, newpsl
, IP6_SFLSIZE(newpsl
->sl_max
));
516 (void) ip6_mc_add_src(idev
, group
, gsf
->gf_fmode
, 0, NULL
, 0);
519 write_lock(&pmc
->sflock
);
522 (void) ip6_mc_del_src(idev
, group
, pmc
->sfmode
,
523 psl
->sl_count
, psl
->sl_addr
, 0);
524 sock_kfree_s(sk
, psl
, IP6_SFLSIZE(psl
->sl_max
));
526 (void) ip6_mc_del_src(idev
, group
, pmc
->sfmode
, 0, NULL
, 0);
527 pmc
->sflist
= newpsl
;
528 pmc
->sfmode
= gsf
->gf_fmode
;
529 write_unlock(&pmc
->sflock
);
532 read_unlock_bh(&idev
->lock
);
535 err
= ipv6_sock_mc_drop(sk
, gsf
->gf_interface
, group
);
539 int ip6_mc_msfget(struct sock
*sk
, struct group_filter
*gsf
,
540 struct group_filter __user
*optval
, int __user
*optlen
)
542 int err
, i
, count
, copycount
;
543 const struct in6_addr
*group
;
544 struct ipv6_mc_socklist
*pmc
;
545 struct inet6_dev
*idev
;
546 struct ipv6_pinfo
*inet6
= inet6_sk(sk
);
547 struct ip6_sf_socklist
*psl
;
548 struct net
*net
= sock_net(sk
);
550 group
= &((struct sockaddr_in6
*)&gsf
->gf_group
)->sin6_addr
;
552 if (!ipv6_addr_is_multicast(group
))
556 idev
= ip6_mc_find_dev_rcu(net
, group
, gsf
->gf_interface
);
563 err
= -EADDRNOTAVAIL
;
565 * changes to the ipv6_mc_list require the socket lock and
566 * a read lock on ip6_sk_mc_lock. We have the socket lock,
567 * so reading the list is safe.
570 for_each_pmc_rcu(inet6
, pmc
) {
571 if (pmc
->ifindex
!= gsf
->gf_interface
)
573 if (ipv6_addr_equal(group
, &pmc
->addr
))
576 if (!pmc
) /* must have a prior join */
578 gsf
->gf_fmode
= pmc
->sfmode
;
580 count
= psl
? psl
->sl_count
: 0;
581 read_unlock_bh(&idev
->lock
);
584 copycount
= count
< gsf
->gf_numsrc
? count
: gsf
->gf_numsrc
;
585 gsf
->gf_numsrc
= count
;
586 if (put_user(GROUP_FILTER_SIZE(copycount
), optlen
) ||
587 copy_to_user(optval
, gsf
, GROUP_FILTER_SIZE(0))) {
590 /* changes to psl require the socket lock, a read lock on
591 * on ipv6_sk_mc_lock and a write lock on pmc->sflock. We
592 * have the socket lock, so reading here is safe.
594 for (i
=0; i
<copycount
; i
++) {
595 struct sockaddr_in6
*psin6
;
596 struct sockaddr_storage ss
;
598 psin6
= (struct sockaddr_in6
*)&ss
;
599 memset(&ss
, 0, sizeof(ss
));
600 psin6
->sin6_family
= AF_INET6
;
601 psin6
->sin6_addr
= psl
->sl_addr
[i
];
602 if (copy_to_user(&optval
->gf_slist
[i
], &ss
, sizeof(ss
)))
607 read_unlock_bh(&idev
->lock
);
612 bool 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
;
621 for_each_pmc_rcu(np
, mc
) {
622 if (ipv6_addr_equal(&mc
->addr
, mc_addr
))
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
);
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 if (IPV6_ADDR_MC_SCOPE(&mc
->mca_addr
) <
665 IPV6_ADDR_SCOPE_LINKLOCAL
)
668 spin_lock_bh(&mc
->mca_lock
);
669 if (!(mc
->mca_flags
&MAF_LOADED
)) {
670 mc
->mca_flags
|= MAF_LOADED
;
671 if (ndisc_mc_map(&mc
->mca_addr
, buf
, dev
, 0) == 0)
672 dev_mc_add(dev
, buf
);
674 spin_unlock_bh(&mc
->mca_lock
);
676 if (!(dev
->flags
& IFF_UP
) || (mc
->mca_flags
& MAF_NOREPORT
))
679 if (MLD_V1_SEEN(mc
->idev
)) {
680 igmp6_join_group(mc
);
685 mc
->mca_crcount
= mc
->idev
->mc_qrv
;
686 mld_ifc_event(mc
->idev
);
689 static void igmp6_group_dropped(struct ifmcaddr6
*mc
)
691 struct net_device
*dev
= mc
->idev
->dev
;
692 char buf
[MAX_ADDR_LEN
];
694 if (IPV6_ADDR_MC_SCOPE(&mc
->mca_addr
) <
695 IPV6_ADDR_SCOPE_LINKLOCAL
)
698 spin_lock_bh(&mc
->mca_lock
);
699 if (mc
->mca_flags
&MAF_LOADED
) {
700 mc
->mca_flags
&= ~MAF_LOADED
;
701 if (ndisc_mc_map(&mc
->mca_addr
, buf
, dev
, 0) == 0)
702 dev_mc_del(dev
, buf
);
705 if (mc
->mca_flags
& MAF_NOREPORT
)
707 spin_unlock_bh(&mc
->mca_lock
);
710 igmp6_leave_group(mc
);
712 spin_lock_bh(&mc
->mca_lock
);
713 if (del_timer(&mc
->mca_timer
))
714 atomic_dec(&mc
->mca_refcnt
);
716 ip6_mc_clear_src(mc
);
717 spin_unlock_bh(&mc
->mca_lock
);
721 * deleted ifmcaddr6 manipulation
723 static void mld_add_delrec(struct inet6_dev
*idev
, struct ifmcaddr6
*im
)
725 struct ifmcaddr6
*pmc
;
727 /* this is an "ifmcaddr6" for convenience; only the fields below
728 * are actually used. In particular, the refcnt and users are not
729 * used for management of the delete list. Using the same structure
730 * for deleted items allows change reports to use common code with
731 * non-deleted or query-response MCA's.
733 pmc
= kzalloc(sizeof(*pmc
), GFP_ATOMIC
);
737 spin_lock_bh(&im
->mca_lock
);
738 spin_lock_init(&pmc
->mca_lock
);
739 pmc
->idev
= im
->idev
;
741 pmc
->mca_addr
= im
->mca_addr
;
742 pmc
->mca_crcount
= idev
->mc_qrv
;
743 pmc
->mca_sfmode
= im
->mca_sfmode
;
744 if (pmc
->mca_sfmode
== MCAST_INCLUDE
) {
745 struct ip6_sf_list
*psf
;
747 pmc
->mca_tomb
= im
->mca_tomb
;
748 pmc
->mca_sources
= im
->mca_sources
;
749 im
->mca_tomb
= im
->mca_sources
= NULL
;
750 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
)
751 psf
->sf_crcount
= pmc
->mca_crcount
;
753 spin_unlock_bh(&im
->mca_lock
);
755 spin_lock_bh(&idev
->mc_lock
);
756 pmc
->next
= idev
->mc_tomb
;
758 spin_unlock_bh(&idev
->mc_lock
);
761 static void mld_del_delrec(struct inet6_dev
*idev
, const struct in6_addr
*pmca
)
763 struct ifmcaddr6
*pmc
, *pmc_prev
;
764 struct ip6_sf_list
*psf
, *psf_next
;
766 spin_lock_bh(&idev
->mc_lock
);
768 for (pmc
=idev
->mc_tomb
; pmc
; pmc
=pmc
->next
) {
769 if (ipv6_addr_equal(&pmc
->mca_addr
, pmca
))
775 pmc_prev
->next
= pmc
->next
;
777 idev
->mc_tomb
= pmc
->next
;
779 spin_unlock_bh(&idev
->mc_lock
);
782 for (psf
=pmc
->mca_tomb
; psf
; psf
=psf_next
) {
783 psf_next
= psf
->sf_next
;
786 in6_dev_put(pmc
->idev
);
791 static void mld_clear_delrec(struct inet6_dev
*idev
)
793 struct ifmcaddr6
*pmc
, *nextpmc
;
795 spin_lock_bh(&idev
->mc_lock
);
797 idev
->mc_tomb
= NULL
;
798 spin_unlock_bh(&idev
->mc_lock
);
800 for (; pmc
; pmc
= nextpmc
) {
802 ip6_mc_clear_src(pmc
);
803 in6_dev_put(pmc
->idev
);
807 /* clear dead sources, too */
808 read_lock_bh(&idev
->lock
);
809 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
810 struct ip6_sf_list
*psf
, *psf_next
;
812 spin_lock_bh(&pmc
->mca_lock
);
814 pmc
->mca_tomb
= NULL
;
815 spin_unlock_bh(&pmc
->mca_lock
);
816 for (; psf
; psf
=psf_next
) {
817 psf_next
= psf
->sf_next
;
821 read_unlock_bh(&idev
->lock
);
826 * device multicast group inc (add if not found)
828 int ipv6_dev_mc_inc(struct net_device
*dev
, const struct in6_addr
*addr
)
830 struct ifmcaddr6
*mc
;
831 struct inet6_dev
*idev
;
833 /* we need to take a reference on idev */
834 idev
= in6_dev_get(dev
);
839 write_lock_bh(&idev
->lock
);
841 write_unlock_bh(&idev
->lock
);
846 for (mc
= idev
->mc_list
; mc
; mc
= mc
->next
) {
847 if (ipv6_addr_equal(&mc
->mca_addr
, addr
)) {
849 write_unlock_bh(&idev
->lock
);
850 ip6_mc_add_src(idev
, &mc
->mca_addr
, MCAST_EXCLUDE
, 0,
858 * not found: create a new one.
861 mc
= kzalloc(sizeof(struct ifmcaddr6
), GFP_ATOMIC
);
864 write_unlock_bh(&idev
->lock
);
869 setup_timer(&mc
->mca_timer
, igmp6_timer_handler
, (unsigned long)mc
);
871 mc
->mca_addr
= *addr
;
872 mc
->idev
= idev
; /* (reference taken) */
874 /* mca_stamp should be updated upon changes */
875 mc
->mca_cstamp
= mc
->mca_tstamp
= jiffies
;
876 atomic_set(&mc
->mca_refcnt
, 2);
877 spin_lock_init(&mc
->mca_lock
);
879 /* initial mode is (EX, empty) */
880 mc
->mca_sfmode
= MCAST_EXCLUDE
;
881 mc
->mca_sfcount
[MCAST_EXCLUDE
] = 1;
883 if (ipv6_addr_is_ll_all_nodes(&mc
->mca_addr
) ||
884 IPV6_ADDR_MC_SCOPE(&mc
->mca_addr
) < IPV6_ADDR_SCOPE_LINKLOCAL
)
885 mc
->mca_flags
|= MAF_NOREPORT
;
887 mc
->next
= idev
->mc_list
;
889 write_unlock_bh(&idev
->lock
);
891 mld_del_delrec(idev
, &mc
->mca_addr
);
892 igmp6_group_added(mc
);
898 * device multicast group del
900 int __ipv6_dev_mc_dec(struct inet6_dev
*idev
, const struct in6_addr
*addr
)
902 struct ifmcaddr6
*ma
, **map
;
904 write_lock_bh(&idev
->lock
);
905 for (map
= &idev
->mc_list
; (ma
=*map
) != NULL
; map
= &ma
->next
) {
906 if (ipv6_addr_equal(&ma
->mca_addr
, addr
)) {
907 if (--ma
->mca_users
== 0) {
909 write_unlock_bh(&idev
->lock
);
911 igmp6_group_dropped(ma
);
916 write_unlock_bh(&idev
->lock
);
920 write_unlock_bh(&idev
->lock
);
925 int ipv6_dev_mc_dec(struct net_device
*dev
, const struct in6_addr
*addr
)
927 struct inet6_dev
*idev
;
932 idev
= __in6_dev_get(dev
);
936 err
= __ipv6_dev_mc_dec(idev
, addr
);
943 * check if the interface/address pair is valid
945 bool ipv6_chk_mcast_addr(struct net_device
*dev
, const struct in6_addr
*group
,
946 const struct in6_addr
*src_addr
)
948 struct inet6_dev
*idev
;
949 struct ifmcaddr6
*mc
;
953 idev
= __in6_dev_get(dev
);
955 read_lock_bh(&idev
->lock
);
956 for (mc
= idev
->mc_list
; mc
; mc
=mc
->next
) {
957 if (ipv6_addr_equal(&mc
->mca_addr
, group
))
961 if (src_addr
&& !ipv6_addr_any(src_addr
)) {
962 struct ip6_sf_list
*psf
;
964 spin_lock_bh(&mc
->mca_lock
);
965 for (psf
=mc
->mca_sources
;psf
;psf
=psf
->sf_next
) {
966 if (ipv6_addr_equal(&psf
->sf_addr
, src_addr
))
970 rv
= psf
->sf_count
[MCAST_INCLUDE
] ||
971 psf
->sf_count
[MCAST_EXCLUDE
] !=
972 mc
->mca_sfcount
[MCAST_EXCLUDE
];
974 rv
= mc
->mca_sfcount
[MCAST_EXCLUDE
] !=0;
975 spin_unlock_bh(&mc
->mca_lock
);
977 rv
= true; /* don't filter unspecified source */
979 read_unlock_bh(&idev
->lock
);
985 static void mld_gq_start_timer(struct inet6_dev
*idev
)
987 int tv
= net_random() % idev
->mc_maxdelay
;
989 idev
->mc_gq_running
= 1;
990 if (!mod_timer(&idev
->mc_gq_timer
, jiffies
+tv
+2))
994 static void mld_ifc_start_timer(struct inet6_dev
*idev
, int delay
)
996 int tv
= net_random() % delay
;
998 if (!mod_timer(&idev
->mc_ifc_timer
, jiffies
+tv
+2))
1003 * IGMP handling (alias multicast ICMPv6 messages)
1006 static void igmp6_group_queried(struct ifmcaddr6
*ma
, unsigned long resptime
)
1008 unsigned long delay
= resptime
;
1010 /* Do not start timer for these addresses */
1011 if (ipv6_addr_is_ll_all_nodes(&ma
->mca_addr
) ||
1012 IPV6_ADDR_MC_SCOPE(&ma
->mca_addr
) < IPV6_ADDR_SCOPE_LINKLOCAL
)
1015 if (del_timer(&ma
->mca_timer
)) {
1016 atomic_dec(&ma
->mca_refcnt
);
1017 delay
= ma
->mca_timer
.expires
- jiffies
;
1020 if (delay
>= resptime
) {
1022 delay
= net_random() % resptime
;
1026 ma
->mca_timer
.expires
= jiffies
+ delay
;
1027 if (!mod_timer(&ma
->mca_timer
, jiffies
+ delay
))
1028 atomic_inc(&ma
->mca_refcnt
);
1029 ma
->mca_flags
|= MAF_TIMER_RUNNING
;
1032 /* mark EXCLUDE-mode sources */
1033 static bool mld_xmarksources(struct ifmcaddr6
*pmc
, int nsrcs
,
1034 const struct in6_addr
*srcs
)
1036 struct ip6_sf_list
*psf
;
1040 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1041 if (scount
== nsrcs
)
1043 for (i
=0; i
<nsrcs
; i
++) {
1044 /* skip inactive filters */
1045 if (psf
->sf_count
[MCAST_INCLUDE
] ||
1046 pmc
->mca_sfcount
[MCAST_EXCLUDE
] !=
1047 psf
->sf_count
[MCAST_EXCLUDE
])
1049 if (ipv6_addr_equal(&srcs
[i
], &psf
->sf_addr
)) {
1055 pmc
->mca_flags
&= ~MAF_GSQUERY
;
1056 if (scount
== nsrcs
) /* all sources excluded */
1061 static bool mld_marksources(struct ifmcaddr6
*pmc
, int nsrcs
,
1062 const struct in6_addr
*srcs
)
1064 struct ip6_sf_list
*psf
;
1067 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
)
1068 return mld_xmarksources(pmc
, nsrcs
, srcs
);
1070 /* mark INCLUDE-mode sources */
1073 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1074 if (scount
== nsrcs
)
1076 for (i
=0; i
<nsrcs
; i
++) {
1077 if (ipv6_addr_equal(&srcs
[i
], &psf
->sf_addr
)) {
1085 pmc
->mca_flags
&= ~MAF_GSQUERY
;
1088 pmc
->mca_flags
|= MAF_GSQUERY
;
1092 /* called with rcu_read_lock() */
1093 int igmp6_event_query(struct sk_buff
*skb
)
1095 struct mld2_query
*mlh2
= NULL
;
1096 struct ifmcaddr6
*ma
;
1097 const struct in6_addr
*group
;
1098 unsigned long max_delay
;
1099 struct inet6_dev
*idev
;
1100 struct mld_msg
*mld
;
1105 if (!pskb_may_pull(skb
, sizeof(struct in6_addr
)))
1108 /* compute payload length excluding extension headers */
1109 len
= ntohs(ipv6_hdr(skb
)->payload_len
) + sizeof(struct ipv6hdr
);
1110 len
-= skb_network_header_len(skb
);
1112 /* Drop queries with not link local source */
1113 if (!(ipv6_addr_type(&ipv6_hdr(skb
)->saddr
) & IPV6_ADDR_LINKLOCAL
))
1116 idev
= __in6_dev_get(skb
->dev
);
1121 mld
= (struct mld_msg
*)icmp6_hdr(skb
);
1122 group
= &mld
->mld_mca
;
1123 group_type
= ipv6_addr_type(group
);
1125 if (group_type
!= IPV6_ADDR_ANY
&&
1126 !(group_type
&IPV6_ADDR_MULTICAST
))
1131 /* MLDv1 router present */
1133 /* Translate milliseconds to jiffies */
1134 max_delay
= (ntohs(mld
->mld_maxdelay
)*HZ
)/1000;
1136 switchback
= (idev
->mc_qrv
+ 1) * max_delay
;
1137 idev
->mc_v1_seen
= jiffies
+ switchback
;
1139 /* cancel the interface change timer */
1140 idev
->mc_ifc_count
= 0;
1141 if (del_timer(&idev
->mc_ifc_timer
))
1142 __in6_dev_put(idev
);
1143 /* clear deleted report items */
1144 mld_clear_delrec(idev
);
1145 } else if (len
>= 28) {
1146 int srcs_offset
= sizeof(struct mld2_query
) -
1147 sizeof(struct icmp6hdr
);
1148 if (!pskb_may_pull(skb
, srcs_offset
))
1151 mlh2
= (struct mld2_query
*)skb_transport_header(skb
);
1152 max_delay
= (MLDV2_MRC(ntohs(mlh2
->mld2q_mrc
))*HZ
)/1000;
1155 idev
->mc_maxdelay
= max_delay
;
1156 if (mlh2
->mld2q_qrv
)
1157 idev
->mc_qrv
= mlh2
->mld2q_qrv
;
1158 if (group_type
== IPV6_ADDR_ANY
) { /* general query */
1159 if (mlh2
->mld2q_nsrcs
)
1160 return -EINVAL
; /* no sources allowed */
1162 mld_gq_start_timer(idev
);
1165 /* mark sources to include, if group & source-specific */
1166 if (mlh2
->mld2q_nsrcs
!= 0) {
1167 if (!pskb_may_pull(skb
, srcs_offset
+
1168 ntohs(mlh2
->mld2q_nsrcs
) * sizeof(struct in6_addr
)))
1171 mlh2
= (struct mld2_query
*)skb_transport_header(skb
);
1177 read_lock_bh(&idev
->lock
);
1178 if (group_type
== IPV6_ADDR_ANY
) {
1179 for (ma
= idev
->mc_list
; ma
; ma
=ma
->next
) {
1180 spin_lock_bh(&ma
->mca_lock
);
1181 igmp6_group_queried(ma
, max_delay
);
1182 spin_unlock_bh(&ma
->mca_lock
);
1185 for (ma
= idev
->mc_list
; ma
; ma
=ma
->next
) {
1186 if (!ipv6_addr_equal(group
, &ma
->mca_addr
))
1188 spin_lock_bh(&ma
->mca_lock
);
1189 if (ma
->mca_flags
& MAF_TIMER_RUNNING
) {
1190 /* gsquery <- gsquery && mark */
1192 ma
->mca_flags
&= ~MAF_GSQUERY
;
1194 /* gsquery <- mark */
1196 ma
->mca_flags
|= MAF_GSQUERY
;
1198 ma
->mca_flags
&= ~MAF_GSQUERY
;
1200 if (!(ma
->mca_flags
& MAF_GSQUERY
) ||
1201 mld_marksources(ma
, ntohs(mlh2
->mld2q_nsrcs
), mlh2
->mld2q_srcs
))
1202 igmp6_group_queried(ma
, max_delay
);
1203 spin_unlock_bh(&ma
->mca_lock
);
1207 read_unlock_bh(&idev
->lock
);
1212 /* called with rcu_read_lock() */
1213 int igmp6_event_report(struct sk_buff
*skb
)
1215 struct ifmcaddr6
*ma
;
1216 struct inet6_dev
*idev
;
1217 struct mld_msg
*mld
;
1220 /* Our own report looped back. Ignore it. */
1221 if (skb
->pkt_type
== PACKET_LOOPBACK
)
1224 /* send our report if the MC router may not have heard this report */
1225 if (skb
->pkt_type
!= PACKET_MULTICAST
&&
1226 skb
->pkt_type
!= PACKET_BROADCAST
)
1229 if (!pskb_may_pull(skb
, sizeof(*mld
) - sizeof(struct icmp6hdr
)))
1232 mld
= (struct mld_msg
*)icmp6_hdr(skb
);
1234 /* Drop reports with not link local source */
1235 addr_type
= ipv6_addr_type(&ipv6_hdr(skb
)->saddr
);
1236 if (addr_type
!= IPV6_ADDR_ANY
&&
1237 !(addr_type
&IPV6_ADDR_LINKLOCAL
))
1240 idev
= __in6_dev_get(skb
->dev
);
1245 * Cancel the timer for this group
1248 read_lock_bh(&idev
->lock
);
1249 for (ma
= idev
->mc_list
; ma
; ma
=ma
->next
) {
1250 if (ipv6_addr_equal(&ma
->mca_addr
, &mld
->mld_mca
)) {
1251 spin_lock(&ma
->mca_lock
);
1252 if (del_timer(&ma
->mca_timer
))
1253 atomic_dec(&ma
->mca_refcnt
);
1254 ma
->mca_flags
&= ~(MAF_LAST_REPORTER
|MAF_TIMER_RUNNING
);
1255 spin_unlock(&ma
->mca_lock
);
1259 read_unlock_bh(&idev
->lock
);
1263 static bool is_in(struct ifmcaddr6
*pmc
, struct ip6_sf_list
*psf
, int type
,
1264 int gdeleted
, int sdeleted
)
1267 case MLD2_MODE_IS_INCLUDE
:
1268 case MLD2_MODE_IS_EXCLUDE
:
1269 if (gdeleted
|| sdeleted
)
1271 if (!((pmc
->mca_flags
& MAF_GSQUERY
) && !psf
->sf_gsresp
)) {
1272 if (pmc
->mca_sfmode
== MCAST_INCLUDE
)
1274 /* don't include if this source is excluded
1277 if (psf
->sf_count
[MCAST_INCLUDE
])
1278 return type
== MLD2_MODE_IS_INCLUDE
;
1279 return pmc
->mca_sfcount
[MCAST_EXCLUDE
] ==
1280 psf
->sf_count
[MCAST_EXCLUDE
];
1283 case MLD2_CHANGE_TO_INCLUDE
:
1284 if (gdeleted
|| sdeleted
)
1286 return psf
->sf_count
[MCAST_INCLUDE
] != 0;
1287 case MLD2_CHANGE_TO_EXCLUDE
:
1288 if (gdeleted
|| sdeleted
)
1290 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
] == 0 ||
1291 psf
->sf_count
[MCAST_INCLUDE
])
1293 return pmc
->mca_sfcount
[MCAST_EXCLUDE
] ==
1294 psf
->sf_count
[MCAST_EXCLUDE
];
1295 case MLD2_ALLOW_NEW_SOURCES
:
1296 if (gdeleted
|| !psf
->sf_crcount
)
1298 return (pmc
->mca_sfmode
== MCAST_INCLUDE
) ^ sdeleted
;
1299 case MLD2_BLOCK_OLD_SOURCES
:
1300 if (pmc
->mca_sfmode
== MCAST_INCLUDE
)
1301 return gdeleted
|| (psf
->sf_crcount
&& sdeleted
);
1302 return psf
->sf_crcount
&& !gdeleted
&& !sdeleted
;
1308 mld_scount(struct ifmcaddr6
*pmc
, int type
, int gdeleted
, int sdeleted
)
1310 struct ip6_sf_list
*psf
;
1313 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1314 if (!is_in(pmc
, psf
, type
, gdeleted
, sdeleted
))
1321 static void ip6_mc_hdr(struct sock
*sk
, struct sk_buff
*skb
,
1322 struct net_device
*dev
,
1323 const struct in6_addr
*saddr
,
1324 const struct in6_addr
*daddr
,
1327 struct ipv6hdr
*hdr
;
1329 skb
->protocol
= htons(ETH_P_IPV6
);
1332 skb_reset_network_header(skb
);
1333 skb_put(skb
, sizeof(struct ipv6hdr
));
1334 hdr
= ipv6_hdr(skb
);
1336 ip6_flow_hdr(hdr
, 0, 0);
1338 hdr
->payload_len
= htons(len
);
1339 hdr
->nexthdr
= proto
;
1340 hdr
->hop_limit
= inet6_sk(sk
)->hop_limit
;
1342 hdr
->saddr
= *saddr
;
1343 hdr
->daddr
= *daddr
;
1346 static struct sk_buff
*mld_newpack(struct net_device
*dev
, int size
)
1348 struct net
*net
= dev_net(dev
);
1349 struct sock
*sk
= net
->ipv6
.igmp_sk
;
1350 struct sk_buff
*skb
;
1351 struct mld2_report
*pmr
;
1352 struct in6_addr addr_buf
;
1353 const struct in6_addr
*saddr
;
1354 int hlen
= LL_RESERVED_SPACE(dev
);
1355 int tlen
= dev
->needed_tailroom
;
1357 u8 ra
[8] = { IPPROTO_ICMPV6
, 0,
1358 IPV6_TLV_ROUTERALERT
, 2, 0, 0,
1361 /* we assume size > sizeof(ra) here */
1362 size
+= hlen
+ tlen
;
1363 /* limit our allocations to order-0 page */
1364 size
= min_t(int, size
, SKB_MAX_ORDER(0, 0));
1365 skb
= sock_alloc_send_skb(sk
, size
, 1, &err
);
1370 skb_reserve(skb
, hlen
);
1372 if (ipv6_get_lladdr(dev
, &addr_buf
, IFA_F_TENTATIVE
)) {
1373 /* <draft-ietf-magma-mld-source-05.txt>:
1374 * use unspecified address as the source address
1375 * when a valid link-local address is not available.
1377 saddr
= &in6addr_any
;
1381 ip6_mc_hdr(sk
, skb
, dev
, saddr
, &mld2_all_mcr
, NEXTHDR_HOP
, 0);
1383 memcpy(skb_put(skb
, sizeof(ra
)), ra
, sizeof(ra
));
1385 skb_set_transport_header(skb
, skb_tail_pointer(skb
) - skb
->data
);
1386 skb_put(skb
, sizeof(*pmr
));
1387 pmr
= (struct mld2_report
*)skb_transport_header(skb
);
1388 pmr
->mld2r_type
= ICMPV6_MLD2_REPORT
;
1389 pmr
->mld2r_resv1
= 0;
1390 pmr
->mld2r_cksum
= 0;
1391 pmr
->mld2r_resv2
= 0;
1392 pmr
->mld2r_ngrec
= 0;
1396 static void mld_sendpack(struct sk_buff
*skb
)
1398 struct ipv6hdr
*pip6
= ipv6_hdr(skb
);
1399 struct mld2_report
*pmr
=
1400 (struct mld2_report
*)skb_transport_header(skb
);
1401 int payload_len
, mldlen
;
1402 struct inet6_dev
*idev
;
1403 struct net
*net
= dev_net(skb
->dev
);
1406 struct dst_entry
*dst
;
1409 idev
= __in6_dev_get(skb
->dev
);
1410 IP6_UPD_PO_STATS(net
, idev
, IPSTATS_MIB_OUT
, skb
->len
);
1412 payload_len
= (skb_tail_pointer(skb
) - skb_network_header(skb
)) -
1414 mldlen
= skb_tail_pointer(skb
) - skb_transport_header(skb
);
1415 pip6
->payload_len
= htons(payload_len
);
1417 pmr
->mld2r_cksum
= csum_ipv6_magic(&pip6
->saddr
, &pip6
->daddr
, mldlen
,
1419 csum_partial(skb_transport_header(skb
),
1422 icmpv6_flow_init(net
->ipv6
.igmp_sk
, &fl6
, ICMPV6_MLD2_REPORT
,
1423 &ipv6_hdr(skb
)->saddr
, &ipv6_hdr(skb
)->daddr
,
1425 dst
= icmp6_dst_alloc(skb
->dev
, &fl6
);
1432 skb_dst_set(skb
, dst
);
1436 payload_len
= skb
->len
;
1438 err
= NF_HOOK(NFPROTO_IPV6
, NF_INET_LOCAL_OUT
, skb
, NULL
, skb
->dev
,
1442 ICMP6MSGOUT_INC_STATS_BH(net
, idev
, ICMPV6_MLD2_REPORT
);
1443 ICMP6_INC_STATS_BH(net
, idev
, ICMP6_MIB_OUTMSGS
);
1444 IP6_UPD_PO_STATS_BH(net
, idev
, IPSTATS_MIB_OUTMCAST
, payload_len
);
1446 IP6_INC_STATS_BH(net
, idev
, IPSTATS_MIB_OUTDISCARDS
);
1456 static int grec_size(struct ifmcaddr6
*pmc
, int type
, int gdel
, int sdel
)
1458 return sizeof(struct mld2_grec
) + 16 * mld_scount(pmc
,type
,gdel
,sdel
);
1461 static struct sk_buff
*add_grhead(struct sk_buff
*skb
, struct ifmcaddr6
*pmc
,
1462 int type
, struct mld2_grec
**ppgr
)
1464 struct net_device
*dev
= pmc
->idev
->dev
;
1465 struct mld2_report
*pmr
;
1466 struct mld2_grec
*pgr
;
1469 skb
= mld_newpack(dev
, dev
->mtu
);
1472 pgr
= (struct mld2_grec
*)skb_put(skb
, sizeof(struct mld2_grec
));
1473 pgr
->grec_type
= type
;
1474 pgr
->grec_auxwords
= 0;
1475 pgr
->grec_nsrcs
= 0;
1476 pgr
->grec_mca
= pmc
->mca_addr
; /* structure copy */
1477 pmr
= (struct mld2_report
*)skb_transport_header(skb
);
1478 pmr
->mld2r_ngrec
= htons(ntohs(pmr
->mld2r_ngrec
)+1);
1483 #define AVAILABLE(skb) ((skb) ? ((skb)->dev ? (skb)->dev->mtu - (skb)->len : \
1484 skb_tailroom(skb)) : 0)
1486 static struct sk_buff
*add_grec(struct sk_buff
*skb
, struct ifmcaddr6
*pmc
,
1487 int type
, int gdeleted
, int sdeleted
)
1489 struct net_device
*dev
= pmc
->idev
->dev
;
1490 struct mld2_report
*pmr
;
1491 struct mld2_grec
*pgr
= NULL
;
1492 struct ip6_sf_list
*psf
, *psf_next
, *psf_prev
, **psf_list
;
1493 int scount
, stotal
, first
, isquery
, truncate
;
1495 if (pmc
->mca_flags
& MAF_NOREPORT
)
1498 isquery
= type
== MLD2_MODE_IS_INCLUDE
||
1499 type
== MLD2_MODE_IS_EXCLUDE
;
1500 truncate
= type
== MLD2_MODE_IS_EXCLUDE
||
1501 type
== MLD2_CHANGE_TO_EXCLUDE
;
1503 stotal
= scount
= 0;
1505 psf_list
= sdeleted
? &pmc
->mca_tomb
: &pmc
->mca_sources
;
1510 pmr
= skb
? (struct mld2_report
*)skb_transport_header(skb
) : NULL
;
1512 /* EX and TO_EX get a fresh packet, if needed */
1514 if (pmr
&& pmr
->mld2r_ngrec
&&
1515 AVAILABLE(skb
) < grec_size(pmc
, type
, gdeleted
, sdeleted
)) {
1518 skb
= mld_newpack(dev
, dev
->mtu
);
1523 for (psf
=*psf_list
; psf
; psf
=psf_next
) {
1524 struct in6_addr
*psrc
;
1526 psf_next
= psf
->sf_next
;
1528 if (!is_in(pmc
, psf
, type
, gdeleted
, sdeleted
)) {
1533 /* clear marks on query responses */
1537 if (AVAILABLE(skb
) < sizeof(*psrc
) +
1538 first
*sizeof(struct mld2_grec
)) {
1539 if (truncate
&& !first
)
1540 break; /* truncate these */
1542 pgr
->grec_nsrcs
= htons(scount
);
1545 skb
= mld_newpack(dev
, dev
->mtu
);
1550 skb
= add_grhead(skb
, pmc
, type
, &pgr
);
1555 psrc
= (struct in6_addr
*)skb_put(skb
, sizeof(*psrc
));
1556 *psrc
= psf
->sf_addr
;
1558 if ((type
== MLD2_ALLOW_NEW_SOURCES
||
1559 type
== MLD2_BLOCK_OLD_SOURCES
) && psf
->sf_crcount
) {
1561 if ((sdeleted
|| gdeleted
) && psf
->sf_crcount
== 0) {
1563 psf_prev
->sf_next
= psf
->sf_next
;
1565 *psf_list
= psf
->sf_next
;
1575 if (type
== MLD2_ALLOW_NEW_SOURCES
||
1576 type
== MLD2_BLOCK_OLD_SOURCES
)
1578 if (pmc
->mca_crcount
|| isquery
) {
1579 /* make sure we have room for group header */
1580 if (skb
&& AVAILABLE(skb
) < sizeof(struct mld2_grec
)) {
1582 skb
= NULL
; /* add_grhead will get a new one */
1584 skb
= add_grhead(skb
, pmc
, type
, &pgr
);
1588 pgr
->grec_nsrcs
= htons(scount
);
1591 pmc
->mca_flags
&= ~MAF_GSQUERY
; /* clear query state */
1595 static void mld_send_report(struct inet6_dev
*idev
, struct ifmcaddr6
*pmc
)
1597 struct sk_buff
*skb
= NULL
;
1601 read_lock_bh(&idev
->lock
);
1602 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
1603 if (pmc
->mca_flags
& MAF_NOREPORT
)
1605 spin_lock_bh(&pmc
->mca_lock
);
1606 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
])
1607 type
= MLD2_MODE_IS_EXCLUDE
;
1609 type
= MLD2_MODE_IS_INCLUDE
;
1610 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1611 spin_unlock_bh(&pmc
->mca_lock
);
1613 read_unlock_bh(&idev
->lock
);
1615 spin_lock_bh(&pmc
->mca_lock
);
1616 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
])
1617 type
= MLD2_MODE_IS_EXCLUDE
;
1619 type
= MLD2_MODE_IS_INCLUDE
;
1620 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1621 spin_unlock_bh(&pmc
->mca_lock
);
1628 * remove zero-count source records from a source filter list
1630 static void mld_clear_zeros(struct ip6_sf_list
**ppsf
)
1632 struct ip6_sf_list
*psf_prev
, *psf_next
, *psf
;
1635 for (psf
=*ppsf
; psf
; psf
= psf_next
) {
1636 psf_next
= psf
->sf_next
;
1637 if (psf
->sf_crcount
== 0) {
1639 psf_prev
->sf_next
= psf
->sf_next
;
1641 *ppsf
= psf
->sf_next
;
1648 static void mld_send_cr(struct inet6_dev
*idev
)
1650 struct ifmcaddr6
*pmc
, *pmc_prev
, *pmc_next
;
1651 struct sk_buff
*skb
= NULL
;
1654 read_lock_bh(&idev
->lock
);
1655 spin_lock(&idev
->mc_lock
);
1659 for (pmc
=idev
->mc_tomb
; pmc
; pmc
=pmc_next
) {
1660 pmc_next
= pmc
->next
;
1661 if (pmc
->mca_sfmode
== MCAST_INCLUDE
) {
1662 type
= MLD2_BLOCK_OLD_SOURCES
;
1663 dtype
= MLD2_BLOCK_OLD_SOURCES
;
1664 skb
= add_grec(skb
, pmc
, type
, 1, 0);
1665 skb
= add_grec(skb
, pmc
, dtype
, 1, 1);
1667 if (pmc
->mca_crcount
) {
1668 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
) {
1669 type
= MLD2_CHANGE_TO_INCLUDE
;
1670 skb
= add_grec(skb
, pmc
, type
, 1, 0);
1673 if (pmc
->mca_crcount
== 0) {
1674 mld_clear_zeros(&pmc
->mca_tomb
);
1675 mld_clear_zeros(&pmc
->mca_sources
);
1678 if (pmc
->mca_crcount
== 0 && !pmc
->mca_tomb
&&
1679 !pmc
->mca_sources
) {
1681 pmc_prev
->next
= pmc_next
;
1683 idev
->mc_tomb
= pmc_next
;
1684 in6_dev_put(pmc
->idev
);
1689 spin_unlock(&idev
->mc_lock
);
1692 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
1693 spin_lock_bh(&pmc
->mca_lock
);
1694 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
]) {
1695 type
= MLD2_BLOCK_OLD_SOURCES
;
1696 dtype
= MLD2_ALLOW_NEW_SOURCES
;
1698 type
= MLD2_ALLOW_NEW_SOURCES
;
1699 dtype
= MLD2_BLOCK_OLD_SOURCES
;
1701 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1702 skb
= add_grec(skb
, pmc
, dtype
, 0, 1); /* deleted sources */
1704 /* filter mode changes */
1705 if (pmc
->mca_crcount
) {
1706 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
)
1707 type
= MLD2_CHANGE_TO_EXCLUDE
;
1709 type
= MLD2_CHANGE_TO_INCLUDE
;
1710 skb
= add_grec(skb
, pmc
, type
, 0, 0);
1713 spin_unlock_bh(&pmc
->mca_lock
);
1715 read_unlock_bh(&idev
->lock
);
1718 (void) mld_sendpack(skb
);
1721 static void igmp6_send(struct in6_addr
*addr
, struct net_device
*dev
, int type
)
1723 struct net
*net
= dev_net(dev
);
1724 struct sock
*sk
= net
->ipv6
.igmp_sk
;
1725 struct inet6_dev
*idev
;
1726 struct sk_buff
*skb
;
1727 struct mld_msg
*hdr
;
1728 const struct in6_addr
*snd_addr
, *saddr
;
1729 struct in6_addr addr_buf
;
1730 int hlen
= LL_RESERVED_SPACE(dev
);
1731 int tlen
= dev
->needed_tailroom
;
1732 int err
, len
, payload_len
, full_len
;
1733 u8 ra
[8] = { IPPROTO_ICMPV6
, 0,
1734 IPV6_TLV_ROUTERALERT
, 2, 0, 0,
1737 struct dst_entry
*dst
;
1739 if (type
== ICMPV6_MGM_REDUCTION
)
1740 snd_addr
= &in6addr_linklocal_allrouters
;
1744 len
= sizeof(struct icmp6hdr
) + sizeof(struct in6_addr
);
1745 payload_len
= len
+ sizeof(ra
);
1746 full_len
= sizeof(struct ipv6hdr
) + payload_len
;
1749 IP6_UPD_PO_STATS(net
, __in6_dev_get(dev
),
1750 IPSTATS_MIB_OUT
, full_len
);
1753 skb
= sock_alloc_send_skb(sk
, hlen
+ tlen
+ full_len
, 1, &err
);
1757 IP6_INC_STATS(net
, __in6_dev_get(dev
),
1758 IPSTATS_MIB_OUTDISCARDS
);
1763 skb_reserve(skb
, hlen
);
1765 if (ipv6_get_lladdr(dev
, &addr_buf
, IFA_F_TENTATIVE
)) {
1766 /* <draft-ietf-magma-mld-source-05.txt>:
1767 * use unspecified address as the source address
1768 * when a valid link-local address is not available.
1770 saddr
= &in6addr_any
;
1774 ip6_mc_hdr(sk
, skb
, dev
, saddr
, snd_addr
, NEXTHDR_HOP
, payload_len
);
1776 memcpy(skb_put(skb
, sizeof(ra
)), ra
, sizeof(ra
));
1778 hdr
= (struct mld_msg
*) skb_put(skb
, sizeof(struct mld_msg
));
1779 memset(hdr
, 0, sizeof(struct mld_msg
));
1780 hdr
->mld_type
= type
;
1781 hdr
->mld_mca
= *addr
;
1783 hdr
->mld_cksum
= csum_ipv6_magic(saddr
, snd_addr
, len
,
1785 csum_partial(hdr
, len
, 0));
1788 idev
= __in6_dev_get(skb
->dev
);
1790 icmpv6_flow_init(sk
, &fl6
, type
,
1791 &ipv6_hdr(skb
)->saddr
, &ipv6_hdr(skb
)->daddr
,
1793 dst
= icmp6_dst_alloc(skb
->dev
, &fl6
);
1799 skb_dst_set(skb
, dst
);
1800 err
= NF_HOOK(NFPROTO_IPV6
, NF_INET_LOCAL_OUT
, skb
, NULL
, skb
->dev
,
1804 ICMP6MSGOUT_INC_STATS(net
, idev
, type
);
1805 ICMP6_INC_STATS(net
, idev
, ICMP6_MIB_OUTMSGS
);
1806 IP6_UPD_PO_STATS(net
, idev
, IPSTATS_MIB_OUTMCAST
, full_len
);
1808 IP6_INC_STATS(net
, idev
, IPSTATS_MIB_OUTDISCARDS
);
1818 static int ip6_mc_del1_src(struct ifmcaddr6
*pmc
, int sfmode
,
1819 const struct in6_addr
*psfsrc
)
1821 struct ip6_sf_list
*psf
, *psf_prev
;
1825 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1826 if (ipv6_addr_equal(&psf
->sf_addr
, psfsrc
))
1830 if (!psf
|| psf
->sf_count
[sfmode
] == 0) {
1831 /* source filter not found, or count wrong => bug */
1834 psf
->sf_count
[sfmode
]--;
1835 if (!psf
->sf_count
[MCAST_INCLUDE
] && !psf
->sf_count
[MCAST_EXCLUDE
]) {
1836 struct inet6_dev
*idev
= pmc
->idev
;
1838 /* no more filters for this source */
1840 psf_prev
->sf_next
= psf
->sf_next
;
1842 pmc
->mca_sources
= psf
->sf_next
;
1843 if (psf
->sf_oldin
&& !(pmc
->mca_flags
& MAF_NOREPORT
) &&
1844 !MLD_V1_SEEN(idev
)) {
1845 psf
->sf_crcount
= idev
->mc_qrv
;
1846 psf
->sf_next
= pmc
->mca_tomb
;
1847 pmc
->mca_tomb
= psf
;
1855 static int ip6_mc_del_src(struct inet6_dev
*idev
, const struct in6_addr
*pmca
,
1856 int sfmode
, int sfcount
, const struct in6_addr
*psfsrc
,
1859 struct ifmcaddr6
*pmc
;
1865 read_lock_bh(&idev
->lock
);
1866 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
1867 if (ipv6_addr_equal(pmca
, &pmc
->mca_addr
))
1871 /* MCA not found?? bug */
1872 read_unlock_bh(&idev
->lock
);
1875 spin_lock_bh(&pmc
->mca_lock
);
1878 if (!pmc
->mca_sfcount
[sfmode
]) {
1879 spin_unlock_bh(&pmc
->mca_lock
);
1880 read_unlock_bh(&idev
->lock
);
1883 pmc
->mca_sfcount
[sfmode
]--;
1886 for (i
=0; i
<sfcount
; i
++) {
1887 int rv
= ip6_mc_del1_src(pmc
, sfmode
, &psfsrc
[i
]);
1889 changerec
|= rv
> 0;
1893 if (pmc
->mca_sfmode
== MCAST_EXCLUDE
&&
1894 pmc
->mca_sfcount
[MCAST_EXCLUDE
] == 0 &&
1895 pmc
->mca_sfcount
[MCAST_INCLUDE
]) {
1896 struct ip6_sf_list
*psf
;
1898 /* filter mode change */
1899 pmc
->mca_sfmode
= MCAST_INCLUDE
;
1900 pmc
->mca_crcount
= idev
->mc_qrv
;
1901 idev
->mc_ifc_count
= pmc
->mca_crcount
;
1902 for (psf
=pmc
->mca_sources
; psf
; psf
= psf
->sf_next
)
1903 psf
->sf_crcount
= 0;
1904 mld_ifc_event(pmc
->idev
);
1905 } else if (sf_setstate(pmc
) || changerec
)
1906 mld_ifc_event(pmc
->idev
);
1907 spin_unlock_bh(&pmc
->mca_lock
);
1908 read_unlock_bh(&idev
->lock
);
1913 * Add multicast single-source filter to the interface list
1915 static int ip6_mc_add1_src(struct ifmcaddr6
*pmc
, int sfmode
,
1916 const struct in6_addr
*psfsrc
)
1918 struct ip6_sf_list
*psf
, *psf_prev
;
1921 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1922 if (ipv6_addr_equal(&psf
->sf_addr
, psfsrc
))
1927 psf
= kzalloc(sizeof(*psf
), GFP_ATOMIC
);
1931 psf
->sf_addr
= *psfsrc
;
1933 psf_prev
->sf_next
= psf
;
1935 pmc
->mca_sources
= psf
;
1937 psf
->sf_count
[sfmode
]++;
1941 static void sf_markstate(struct ifmcaddr6
*pmc
)
1943 struct ip6_sf_list
*psf
;
1944 int mca_xcount
= pmc
->mca_sfcount
[MCAST_EXCLUDE
];
1946 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
)
1947 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
]) {
1948 psf
->sf_oldin
= mca_xcount
==
1949 psf
->sf_count
[MCAST_EXCLUDE
] &&
1950 !psf
->sf_count
[MCAST_INCLUDE
];
1952 psf
->sf_oldin
= psf
->sf_count
[MCAST_INCLUDE
] != 0;
1955 static int sf_setstate(struct ifmcaddr6
*pmc
)
1957 struct ip6_sf_list
*psf
, *dpsf
;
1958 int mca_xcount
= pmc
->mca_sfcount
[MCAST_EXCLUDE
];
1959 int qrv
= pmc
->idev
->mc_qrv
;
1963 for (psf
=pmc
->mca_sources
; psf
; psf
=psf
->sf_next
) {
1964 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
]) {
1965 new_in
= mca_xcount
== psf
->sf_count
[MCAST_EXCLUDE
] &&
1966 !psf
->sf_count
[MCAST_INCLUDE
];
1968 new_in
= psf
->sf_count
[MCAST_INCLUDE
] != 0;
1970 if (!psf
->sf_oldin
) {
1971 struct ip6_sf_list
*prev
= NULL
;
1973 for (dpsf
=pmc
->mca_tomb
; dpsf
;
1974 dpsf
=dpsf
->sf_next
) {
1975 if (ipv6_addr_equal(&dpsf
->sf_addr
,
1982 prev
->sf_next
= dpsf
->sf_next
;
1984 pmc
->mca_tomb
= dpsf
->sf_next
;
1987 psf
->sf_crcount
= qrv
;
1990 } else if (psf
->sf_oldin
) {
1991 psf
->sf_crcount
= 0;
1993 * add or update "delete" records if an active filter
1996 for (dpsf
=pmc
->mca_tomb
; dpsf
; dpsf
=dpsf
->sf_next
)
1997 if (ipv6_addr_equal(&dpsf
->sf_addr
,
2001 dpsf
= kmalloc(sizeof(*dpsf
), GFP_ATOMIC
);
2005 /* pmc->mca_lock held by callers */
2006 dpsf
->sf_next
= pmc
->mca_tomb
;
2007 pmc
->mca_tomb
= dpsf
;
2009 dpsf
->sf_crcount
= qrv
;
2017 * Add multicast source filter list to the interface list
2019 static int ip6_mc_add_src(struct inet6_dev
*idev
, const struct in6_addr
*pmca
,
2020 int sfmode
, int sfcount
, const struct in6_addr
*psfsrc
,
2023 struct ifmcaddr6
*pmc
;
2029 read_lock_bh(&idev
->lock
);
2030 for (pmc
=idev
->mc_list
; pmc
; pmc
=pmc
->next
) {
2031 if (ipv6_addr_equal(pmca
, &pmc
->mca_addr
))
2035 /* MCA not found?? bug */
2036 read_unlock_bh(&idev
->lock
);
2039 spin_lock_bh(&pmc
->mca_lock
);
2042 isexclude
= pmc
->mca_sfmode
== MCAST_EXCLUDE
;
2044 pmc
->mca_sfcount
[sfmode
]++;
2046 for (i
=0; i
<sfcount
; i
++) {
2047 err
= ip6_mc_add1_src(pmc
, sfmode
, &psfsrc
[i
]);
2055 pmc
->mca_sfcount
[sfmode
]--;
2057 ip6_mc_del1_src(pmc
, sfmode
, &psfsrc
[j
]);
2058 } else if (isexclude
!= (pmc
->mca_sfcount
[MCAST_EXCLUDE
] != 0)) {
2059 struct ip6_sf_list
*psf
;
2061 /* filter mode change */
2062 if (pmc
->mca_sfcount
[MCAST_EXCLUDE
])
2063 pmc
->mca_sfmode
= MCAST_EXCLUDE
;
2064 else if (pmc
->mca_sfcount
[MCAST_INCLUDE
])
2065 pmc
->mca_sfmode
= MCAST_INCLUDE
;
2066 /* else no filters; keep old mode for reports */
2068 pmc
->mca_crcount
= idev
->mc_qrv
;
2069 idev
->mc_ifc_count
= pmc
->mca_crcount
;
2070 for (psf
=pmc
->mca_sources
; psf
; psf
= psf
->sf_next
)
2071 psf
->sf_crcount
= 0;
2072 mld_ifc_event(idev
);
2073 } else if (sf_setstate(pmc
))
2074 mld_ifc_event(idev
);
2075 spin_unlock_bh(&pmc
->mca_lock
);
2076 read_unlock_bh(&idev
->lock
);
2080 static void ip6_mc_clear_src(struct ifmcaddr6
*pmc
)
2082 struct ip6_sf_list
*psf
, *nextpsf
;
2084 for (psf
=pmc
->mca_tomb
; psf
; psf
=nextpsf
) {
2085 nextpsf
= psf
->sf_next
;
2088 pmc
->mca_tomb
= NULL
;
2089 for (psf
=pmc
->mca_sources
; psf
; psf
=nextpsf
) {
2090 nextpsf
= psf
->sf_next
;
2093 pmc
->mca_sources
= NULL
;
2094 pmc
->mca_sfmode
= MCAST_EXCLUDE
;
2095 pmc
->mca_sfcount
[MCAST_INCLUDE
] = 0;
2096 pmc
->mca_sfcount
[MCAST_EXCLUDE
] = 1;
2100 static void igmp6_join_group(struct ifmcaddr6
*ma
)
2102 unsigned long delay
;
2104 if (ma
->mca_flags
& MAF_NOREPORT
)
2107 igmp6_send(&ma
->mca_addr
, ma
->idev
->dev
, ICMPV6_MGM_REPORT
);
2109 delay
= net_random() % IGMP6_UNSOLICITED_IVAL
;
2111 spin_lock_bh(&ma
->mca_lock
);
2112 if (del_timer(&ma
->mca_timer
)) {
2113 atomic_dec(&ma
->mca_refcnt
);
2114 delay
= ma
->mca_timer
.expires
- jiffies
;
2117 if (!mod_timer(&ma
->mca_timer
, jiffies
+ delay
))
2118 atomic_inc(&ma
->mca_refcnt
);
2119 ma
->mca_flags
|= MAF_TIMER_RUNNING
| MAF_LAST_REPORTER
;
2120 spin_unlock_bh(&ma
->mca_lock
);
2123 static int ip6_mc_leave_src(struct sock
*sk
, struct ipv6_mc_socklist
*iml
,
2124 struct inet6_dev
*idev
)
2128 /* callers have the socket lock and a write lock on ipv6_sk_mc_lock,
2129 * so no other readers or writers of iml or its sflist
2132 /* any-source empty exclude case */
2133 return ip6_mc_del_src(idev
, &iml
->addr
, iml
->sfmode
, 0, NULL
, 0);
2135 err
= ip6_mc_del_src(idev
, &iml
->addr
, iml
->sfmode
,
2136 iml
->sflist
->sl_count
, iml
->sflist
->sl_addr
, 0);
2137 sock_kfree_s(sk
, iml
->sflist
, IP6_SFLSIZE(iml
->sflist
->sl_max
));
2142 static void igmp6_leave_group(struct ifmcaddr6
*ma
)
2144 if (MLD_V1_SEEN(ma
->idev
)) {
2145 if (ma
->mca_flags
& MAF_LAST_REPORTER
)
2146 igmp6_send(&ma
->mca_addr
, ma
->idev
->dev
,
2147 ICMPV6_MGM_REDUCTION
);
2149 mld_add_delrec(ma
->idev
, ma
);
2150 mld_ifc_event(ma
->idev
);
2154 static void mld_gq_timer_expire(unsigned long data
)
2156 struct inet6_dev
*idev
= (struct inet6_dev
*)data
;
2158 idev
->mc_gq_running
= 0;
2159 mld_send_report(idev
, NULL
);
2160 __in6_dev_put(idev
);
2163 static void mld_ifc_timer_expire(unsigned long data
)
2165 struct inet6_dev
*idev
= (struct inet6_dev
*)data
;
2168 if (idev
->mc_ifc_count
) {
2169 idev
->mc_ifc_count
--;
2170 if (idev
->mc_ifc_count
)
2171 mld_ifc_start_timer(idev
, idev
->mc_maxdelay
);
2173 __in6_dev_put(idev
);
2176 static void mld_ifc_event(struct inet6_dev
*idev
)
2178 if (MLD_V1_SEEN(idev
))
2180 idev
->mc_ifc_count
= idev
->mc_qrv
;
2181 mld_ifc_start_timer(idev
, 1);
2185 static void igmp6_timer_handler(unsigned long data
)
2187 struct ifmcaddr6
*ma
= (struct ifmcaddr6
*) data
;
2189 if (MLD_V1_SEEN(ma
->idev
))
2190 igmp6_send(&ma
->mca_addr
, ma
->idev
->dev
, ICMPV6_MGM_REPORT
);
2192 mld_send_report(ma
->idev
, ma
);
2194 spin_lock(&ma
->mca_lock
);
2195 ma
->mca_flags
|= MAF_LAST_REPORTER
;
2196 ma
->mca_flags
&= ~MAF_TIMER_RUNNING
;
2197 spin_unlock(&ma
->mca_lock
);
2201 /* Device changing type */
2203 void ipv6_mc_unmap(struct inet6_dev
*idev
)
2205 struct ifmcaddr6
*i
;
2207 /* Install multicast list, except for all-nodes (already installed) */
2209 read_lock_bh(&idev
->lock
);
2210 for (i
= idev
->mc_list
; i
; i
= i
->next
)
2211 igmp6_group_dropped(i
);
2212 read_unlock_bh(&idev
->lock
);
2215 void ipv6_mc_remap(struct inet6_dev
*idev
)
2220 /* Device going down */
2222 void ipv6_mc_down(struct inet6_dev
*idev
)
2224 struct ifmcaddr6
*i
;
2226 /* Withdraw multicast list */
2228 read_lock_bh(&idev
->lock
);
2229 idev
->mc_ifc_count
= 0;
2230 if (del_timer(&idev
->mc_ifc_timer
))
2231 __in6_dev_put(idev
);
2232 idev
->mc_gq_running
= 0;
2233 if (del_timer(&idev
->mc_gq_timer
))
2234 __in6_dev_put(idev
);
2236 for (i
= idev
->mc_list
; i
; i
=i
->next
)
2237 igmp6_group_dropped(i
);
2238 read_unlock_bh(&idev
->lock
);
2240 mld_clear_delrec(idev
);
2244 /* Device going up */
2246 void ipv6_mc_up(struct inet6_dev
*idev
)
2248 struct ifmcaddr6
*i
;
2250 /* Install multicast list, except for all-nodes (already installed) */
2252 read_lock_bh(&idev
->lock
);
2253 for (i
= idev
->mc_list
; i
; i
=i
->next
)
2254 igmp6_group_added(i
);
2255 read_unlock_bh(&idev
->lock
);
2258 /* IPv6 device initialization. */
2260 void ipv6_mc_init_dev(struct inet6_dev
*idev
)
2262 write_lock_bh(&idev
->lock
);
2263 spin_lock_init(&idev
->mc_lock
);
2264 idev
->mc_gq_running
= 0;
2265 setup_timer(&idev
->mc_gq_timer
, mld_gq_timer_expire
,
2266 (unsigned long)idev
);
2267 idev
->mc_tomb
= NULL
;
2268 idev
->mc_ifc_count
= 0;
2269 setup_timer(&idev
->mc_ifc_timer
, mld_ifc_timer_expire
,
2270 (unsigned long)idev
);
2271 idev
->mc_qrv
= MLD_QRV_DEFAULT
;
2272 idev
->mc_maxdelay
= IGMP6_UNSOLICITED_IVAL
;
2273 idev
->mc_v1_seen
= 0;
2274 write_unlock_bh(&idev
->lock
);
2278 * Device is about to be destroyed: clean up.
2281 void ipv6_mc_destroy_dev(struct inet6_dev
*idev
)
2283 struct ifmcaddr6
*i
;
2285 /* Deactivate timers */
2288 /* Delete all-nodes address. */
2289 /* We cannot call ipv6_dev_mc_dec() directly, our caller in
2290 * addrconf.c has NULL'd out dev->ip6_ptr so in6_dev_get() will
2293 __ipv6_dev_mc_dec(idev
, &in6addr_linklocal_allnodes
);
2295 if (idev
->cnf
.forwarding
)
2296 __ipv6_dev_mc_dec(idev
, &in6addr_linklocal_allrouters
);
2298 write_lock_bh(&idev
->lock
);
2299 while ((i
= idev
->mc_list
) != NULL
) {
2300 idev
->mc_list
= i
->next
;
2301 write_unlock_bh(&idev
->lock
);
2303 igmp6_group_dropped(i
);
2306 write_lock_bh(&idev
->lock
);
2308 write_unlock_bh(&idev
->lock
);
2311 #ifdef CONFIG_PROC_FS
2312 struct igmp6_mc_iter_state
{
2313 struct seq_net_private p
;
2314 struct net_device
*dev
;
2315 struct inet6_dev
*idev
;
2318 #define igmp6_mc_seq_private(seq) ((struct igmp6_mc_iter_state *)(seq)->private)
2320 static inline struct ifmcaddr6
*igmp6_mc_get_first(struct seq_file
*seq
)
2322 struct ifmcaddr6
*im
= NULL
;
2323 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2324 struct net
*net
= seq_file_net(seq
);
2327 for_each_netdev_rcu(net
, state
->dev
) {
2328 struct inet6_dev
*idev
;
2329 idev
= __in6_dev_get(state
->dev
);
2332 read_lock_bh(&idev
->lock
);
2338 read_unlock_bh(&idev
->lock
);
2343 static struct ifmcaddr6
*igmp6_mc_get_next(struct seq_file
*seq
, struct ifmcaddr6
*im
)
2345 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2349 if (likely(state
->idev
!= NULL
))
2350 read_unlock_bh(&state
->idev
->lock
);
2352 state
->dev
= next_net_device_rcu(state
->dev
);
2357 state
->idev
= __in6_dev_get(state
->dev
);
2360 read_lock_bh(&state
->idev
->lock
);
2361 im
= state
->idev
->mc_list
;
2366 static struct ifmcaddr6
*igmp6_mc_get_idx(struct seq_file
*seq
, loff_t pos
)
2368 struct ifmcaddr6
*im
= igmp6_mc_get_first(seq
);
2370 while (pos
&& (im
= igmp6_mc_get_next(seq
, im
)) != NULL
)
2372 return pos
? NULL
: im
;
2375 static void *igmp6_mc_seq_start(struct seq_file
*seq
, loff_t
*pos
)
2379 return igmp6_mc_get_idx(seq
, *pos
);
2382 static void *igmp6_mc_seq_next(struct seq_file
*seq
, void *v
, loff_t
*pos
)
2384 struct ifmcaddr6
*im
= igmp6_mc_get_next(seq
, v
);
2390 static void igmp6_mc_seq_stop(struct seq_file
*seq
, void *v
)
2393 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2395 if (likely(state
->idev
!= NULL
)) {
2396 read_unlock_bh(&state
->idev
->lock
);
2403 static int igmp6_mc_seq_show(struct seq_file
*seq
, void *v
)
2405 struct ifmcaddr6
*im
= (struct ifmcaddr6
*)v
;
2406 struct igmp6_mc_iter_state
*state
= igmp6_mc_seq_private(seq
);
2409 "%-4d %-15s %pi6 %5d %08X %ld\n",
2410 state
->dev
->ifindex
, state
->dev
->name
,
2412 im
->mca_users
, im
->mca_flags
,
2413 (im
->mca_flags
&MAF_TIMER_RUNNING
) ?
2414 jiffies_to_clock_t(im
->mca_timer
.expires
-jiffies
) : 0);
2418 static const struct seq_operations igmp6_mc_seq_ops
= {
2419 .start
= igmp6_mc_seq_start
,
2420 .next
= igmp6_mc_seq_next
,
2421 .stop
= igmp6_mc_seq_stop
,
2422 .show
= igmp6_mc_seq_show
,
2425 static int igmp6_mc_seq_open(struct inode
*inode
, struct file
*file
)
2427 return seq_open_net(inode
, file
, &igmp6_mc_seq_ops
,
2428 sizeof(struct igmp6_mc_iter_state
));
2431 static const struct file_operations igmp6_mc_seq_fops
= {
2432 .owner
= THIS_MODULE
,
2433 .open
= igmp6_mc_seq_open
,
2435 .llseek
= seq_lseek
,
2436 .release
= seq_release_net
,
2439 struct igmp6_mcf_iter_state
{
2440 struct seq_net_private p
;
2441 struct net_device
*dev
;
2442 struct inet6_dev
*idev
;
2443 struct ifmcaddr6
*im
;
2446 #define igmp6_mcf_seq_private(seq) ((struct igmp6_mcf_iter_state *)(seq)->private)
2448 static inline struct ip6_sf_list
*igmp6_mcf_get_first(struct seq_file
*seq
)
2450 struct ip6_sf_list
*psf
= NULL
;
2451 struct ifmcaddr6
*im
= NULL
;
2452 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2453 struct net
*net
= seq_file_net(seq
);
2457 for_each_netdev_rcu(net
, state
->dev
) {
2458 struct inet6_dev
*idev
;
2459 idev
= __in6_dev_get(state
->dev
);
2460 if (unlikely(idev
== NULL
))
2462 read_lock_bh(&idev
->lock
);
2464 if (likely(im
!= NULL
)) {
2465 spin_lock_bh(&im
->mca_lock
);
2466 psf
= im
->mca_sources
;
2467 if (likely(psf
!= NULL
)) {
2472 spin_unlock_bh(&im
->mca_lock
);
2474 read_unlock_bh(&idev
->lock
);
2479 static struct ip6_sf_list
*igmp6_mcf_get_next(struct seq_file
*seq
, struct ip6_sf_list
*psf
)
2481 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2485 spin_unlock_bh(&state
->im
->mca_lock
);
2486 state
->im
= state
->im
->next
;
2487 while (!state
->im
) {
2488 if (likely(state
->idev
!= NULL
))
2489 read_unlock_bh(&state
->idev
->lock
);
2491 state
->dev
= next_net_device_rcu(state
->dev
);
2496 state
->idev
= __in6_dev_get(state
->dev
);
2499 read_lock_bh(&state
->idev
->lock
);
2500 state
->im
= state
->idev
->mc_list
;
2504 spin_lock_bh(&state
->im
->mca_lock
);
2505 psf
= state
->im
->mca_sources
;
2511 static struct ip6_sf_list
*igmp6_mcf_get_idx(struct seq_file
*seq
, loff_t pos
)
2513 struct ip6_sf_list
*psf
= igmp6_mcf_get_first(seq
);
2515 while (pos
&& (psf
= igmp6_mcf_get_next(seq
, psf
)) != NULL
)
2517 return pos
? NULL
: psf
;
2520 static void *igmp6_mcf_seq_start(struct seq_file
*seq
, loff_t
*pos
)
2524 return *pos
? igmp6_mcf_get_idx(seq
, *pos
- 1) : SEQ_START_TOKEN
;
2527 static void *igmp6_mcf_seq_next(struct seq_file
*seq
, void *v
, loff_t
*pos
)
2529 struct ip6_sf_list
*psf
;
2530 if (v
== SEQ_START_TOKEN
)
2531 psf
= igmp6_mcf_get_first(seq
);
2533 psf
= igmp6_mcf_get_next(seq
, v
);
2538 static void igmp6_mcf_seq_stop(struct seq_file
*seq
, void *v
)
2541 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2542 if (likely(state
->im
!= NULL
)) {
2543 spin_unlock_bh(&state
->im
->mca_lock
);
2546 if (likely(state
->idev
!= NULL
)) {
2547 read_unlock_bh(&state
->idev
->lock
);
2554 static int igmp6_mcf_seq_show(struct seq_file
*seq
, void *v
)
2556 struct ip6_sf_list
*psf
= (struct ip6_sf_list
*)v
;
2557 struct igmp6_mcf_iter_state
*state
= igmp6_mcf_seq_private(seq
);
2559 if (v
== SEQ_START_TOKEN
) {
2562 "%32s %32s %6s %6s\n", "Idx",
2563 "Device", "Multicast Address",
2564 "Source Address", "INC", "EXC");
2567 "%3d %6.6s %pi6 %pi6 %6lu %6lu\n",
2568 state
->dev
->ifindex
, state
->dev
->name
,
2569 &state
->im
->mca_addr
,
2571 psf
->sf_count
[MCAST_INCLUDE
],
2572 psf
->sf_count
[MCAST_EXCLUDE
]);
2577 static const struct seq_operations igmp6_mcf_seq_ops
= {
2578 .start
= igmp6_mcf_seq_start
,
2579 .next
= igmp6_mcf_seq_next
,
2580 .stop
= igmp6_mcf_seq_stop
,
2581 .show
= igmp6_mcf_seq_show
,
2584 static int igmp6_mcf_seq_open(struct inode
*inode
, struct file
*file
)
2586 return seq_open_net(inode
, file
, &igmp6_mcf_seq_ops
,
2587 sizeof(struct igmp6_mcf_iter_state
));
2590 static const struct file_operations igmp6_mcf_seq_fops
= {
2591 .owner
= THIS_MODULE
,
2592 .open
= igmp6_mcf_seq_open
,
2594 .llseek
= seq_lseek
,
2595 .release
= seq_release_net
,
2598 static int __net_init
igmp6_proc_init(struct net
*net
)
2603 if (!proc_create("igmp6", S_IRUGO
, net
->proc_net
, &igmp6_mc_seq_fops
))
2605 if (!proc_create("mcfilter6", S_IRUGO
, net
->proc_net
,
2606 &igmp6_mcf_seq_fops
))
2607 goto out_proc_net_igmp6
;
2614 remove_proc_entry("igmp6", net
->proc_net
);
2618 static void __net_exit
igmp6_proc_exit(struct net
*net
)
2620 remove_proc_entry("mcfilter6", net
->proc_net
);
2621 remove_proc_entry("igmp6", net
->proc_net
);
2624 static inline int igmp6_proc_init(struct net
*net
)
2628 static inline void igmp6_proc_exit(struct net
*net
)
2633 static int __net_init
igmp6_net_init(struct net
*net
)
2637 err
= inet_ctl_sock_create(&net
->ipv6
.igmp_sk
, PF_INET6
,
2638 SOCK_RAW
, IPPROTO_ICMPV6
, net
);
2640 pr_err("Failed to initialize the IGMP6 control socket (err %d)\n",
2645 inet6_sk(net
->ipv6
.igmp_sk
)->hop_limit
= 1;
2647 err
= igmp6_proc_init(net
);
2649 goto out_sock_create
;
2654 inet_ctl_sock_destroy(net
->ipv6
.igmp_sk
);
2658 static void __net_exit
igmp6_net_exit(struct net
*net
)
2660 inet_ctl_sock_destroy(net
->ipv6
.igmp_sk
);
2661 igmp6_proc_exit(net
);
2664 static struct pernet_operations igmp6_net_ops
= {
2665 .init
= igmp6_net_init
,
2666 .exit
= igmp6_net_exit
,
2669 int __init
igmp6_init(void)
2671 return register_pernet_subsys(&igmp6_net_ops
);
2674 void igmp6_cleanup(void)
2676 unregister_pernet_subsys(&igmp6_net_ops
);