1 /* Copyright (C) 2014-2016 B.A.T.M.A.N. contributors:
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of version 2 of the GNU General Public
7 * License as published by the Free Software Foundation.
9 * This program is distributed in the hope that it will be useful, but
10 * WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, see <http://www.gnu.org/licenses/>.
18 #include "multicast.h"
21 #include <linux/atomic.h>
22 #include <linux/bitops.h>
23 #include <linux/bug.h>
24 #include <linux/byteorder/generic.h>
25 #include <linux/errno.h>
26 #include <linux/etherdevice.h>
28 #include <linux/if_ether.h>
29 #include <linux/in6.h>
32 #include <linux/ipv6.h>
33 #include <linux/list.h>
34 #include <linux/lockdep.h>
35 #include <linux/netdevice.h>
36 #include <linux/rculist.h>
37 #include <linux/rcupdate.h>
38 #include <linux/skbuff.h>
39 #include <linux/slab.h>
40 #include <linux/spinlock.h>
41 #include <linux/stddef.h>
42 #include <linux/string.h>
43 #include <linux/types.h>
44 #include <net/addrconf.h>
48 #include "translation-table.h"
51 * batadv_mcast_mla_softif_get - get softif multicast listeners
52 * @dev: the device to collect multicast addresses from
53 * @mcast_list: a list to put found addresses into
55 * Collect multicast addresses of the local multicast listeners
56 * on the given soft interface, dev, in the given mcast_list.
58 * Return: -ENOMEM on memory allocation error or the number of
59 * items added to the mcast_list otherwise.
61 static int batadv_mcast_mla_softif_get(struct net_device
*dev
,
62 struct hlist_head
*mcast_list
)
64 struct netdev_hw_addr
*mc_list_entry
;
65 struct batadv_hw_addr
*new;
68 netif_addr_lock_bh(dev
);
69 netdev_for_each_mc_addr(mc_list_entry
, dev
) {
70 new = kmalloc(sizeof(*new), GFP_ATOMIC
);
76 ether_addr_copy(new->addr
, mc_list_entry
->addr
);
77 hlist_add_head(&new->list
, mcast_list
);
80 netif_addr_unlock_bh(dev
);
86 * batadv_mcast_mla_is_duplicate - check whether an address is in a list
87 * @mcast_addr: the multicast address to check
88 * @mcast_list: the list with multicast addresses to search in
90 * Return: true if the given address is already in the given list.
91 * Otherwise returns false.
93 static bool batadv_mcast_mla_is_duplicate(u8
*mcast_addr
,
94 struct hlist_head
*mcast_list
)
96 struct batadv_hw_addr
*mcast_entry
;
98 hlist_for_each_entry(mcast_entry
, mcast_list
, list
)
99 if (batadv_compare_eth(mcast_entry
->addr
, mcast_addr
))
106 * batadv_mcast_mla_list_free - free a list of multicast addresses
107 * @bat_priv: the bat priv with all the soft interface information
108 * @mcast_list: the list to free
110 * Removes and frees all items in the given mcast_list.
112 static void batadv_mcast_mla_list_free(struct batadv_priv
*bat_priv
,
113 struct hlist_head
*mcast_list
)
115 struct batadv_hw_addr
*mcast_entry
;
116 struct hlist_node
*tmp
;
118 lockdep_assert_held(&bat_priv
->tt
.commit_lock
);
120 hlist_for_each_entry_safe(mcast_entry
, tmp
, mcast_list
, list
) {
121 hlist_del(&mcast_entry
->list
);
127 * batadv_mcast_mla_tt_retract - clean up multicast listener announcements
128 * @bat_priv: the bat priv with all the soft interface information
129 * @mcast_list: a list of addresses which should _not_ be removed
131 * Retracts the announcement of any multicast listener from the
132 * translation table except the ones listed in the given mcast_list.
134 * If mcast_list is NULL then all are retracted.
136 static void batadv_mcast_mla_tt_retract(struct batadv_priv
*bat_priv
,
137 struct hlist_head
*mcast_list
)
139 struct batadv_hw_addr
*mcast_entry
;
140 struct hlist_node
*tmp
;
142 lockdep_assert_held(&bat_priv
->tt
.commit_lock
);
144 hlist_for_each_entry_safe(mcast_entry
, tmp
, &bat_priv
->mcast
.mla_list
,
147 batadv_mcast_mla_is_duplicate(mcast_entry
->addr
,
151 batadv_tt_local_remove(bat_priv
, mcast_entry
->addr
,
153 "mcast TT outdated", false);
155 hlist_del(&mcast_entry
->list
);
161 * batadv_mcast_mla_tt_add - add multicast listener announcements
162 * @bat_priv: the bat priv with all the soft interface information
163 * @mcast_list: a list of addresses which are going to get added
165 * Adds multicast listener announcements from the given mcast_list to the
166 * translation table if they have not been added yet.
168 static void batadv_mcast_mla_tt_add(struct batadv_priv
*bat_priv
,
169 struct hlist_head
*mcast_list
)
171 struct batadv_hw_addr
*mcast_entry
;
172 struct hlist_node
*tmp
;
174 lockdep_assert_held(&bat_priv
->tt
.commit_lock
);
179 hlist_for_each_entry_safe(mcast_entry
, tmp
, mcast_list
, list
) {
180 if (batadv_mcast_mla_is_duplicate(mcast_entry
->addr
,
181 &bat_priv
->mcast
.mla_list
))
184 if (!batadv_tt_local_add(bat_priv
->soft_iface
,
185 mcast_entry
->addr
, BATADV_NO_FLAGS
,
186 BATADV_NULL_IFINDEX
, BATADV_NO_MARK
))
189 hlist_del(&mcast_entry
->list
);
190 hlist_add_head(&mcast_entry
->list
, &bat_priv
->mcast
.mla_list
);
195 * batadv_mcast_has_bridge - check whether the soft-iface is bridged
196 * @bat_priv: the bat priv with all the soft interface information
198 * Checks whether there is a bridge on top of our soft interface.
200 * Return: true if there is a bridge, false otherwise.
202 static bool batadv_mcast_has_bridge(struct batadv_priv
*bat_priv
)
204 struct net_device
*upper
= bat_priv
->soft_iface
;
208 upper
= netdev_master_upper_dev_get_rcu(upper
);
209 } while (upper
&& !(upper
->priv_flags
& IFF_EBRIDGE
));
216 * batadv_mcast_mla_tvlv_update - update multicast tvlv
217 * @bat_priv: the bat priv with all the soft interface information
219 * Updates the own multicast tvlv with our current multicast related settings,
220 * capabilities and inabilities.
222 * Return: true if the tvlv container is registered afterwards. Otherwise
225 static bool batadv_mcast_mla_tvlv_update(struct batadv_priv
*bat_priv
)
227 struct batadv_tvlv_mcast_data mcast_data
;
229 mcast_data
.flags
= BATADV_NO_FLAGS
;
230 memset(mcast_data
.reserved
, 0, sizeof(mcast_data
.reserved
));
232 /* Avoid attaching MLAs, if there is a bridge on top of our soft
233 * interface, we don't support that yet (TODO)
235 if (batadv_mcast_has_bridge(bat_priv
)) {
236 if (bat_priv
->mcast
.enabled
) {
237 batadv_tvlv_container_unregister(bat_priv
,
238 BATADV_TVLV_MCAST
, 1);
239 bat_priv
->mcast
.enabled
= false;
245 if (!bat_priv
->mcast
.enabled
||
246 mcast_data
.flags
!= bat_priv
->mcast
.flags
) {
247 batadv_tvlv_container_register(bat_priv
, BATADV_TVLV_MCAST
, 1,
248 &mcast_data
, sizeof(mcast_data
));
249 bat_priv
->mcast
.flags
= mcast_data
.flags
;
250 bat_priv
->mcast
.enabled
= true;
257 * batadv_mcast_mla_update - update the own MLAs
258 * @bat_priv: the bat priv with all the soft interface information
260 * Updates the own multicast listener announcements in the translation
261 * table as well as the own, announced multicast tvlv container.
263 void batadv_mcast_mla_update(struct batadv_priv
*bat_priv
)
265 struct net_device
*soft_iface
= bat_priv
->soft_iface
;
266 struct hlist_head mcast_list
= HLIST_HEAD_INIT
;
269 if (!batadv_mcast_mla_tvlv_update(bat_priv
))
272 ret
= batadv_mcast_mla_softif_get(soft_iface
, &mcast_list
);
277 batadv_mcast_mla_tt_retract(bat_priv
, &mcast_list
);
278 batadv_mcast_mla_tt_add(bat_priv
, &mcast_list
);
281 batadv_mcast_mla_list_free(bat_priv
, &mcast_list
);
285 * batadv_mcast_forw_mode_check_ipv4 - check for optimized forwarding potential
286 * @bat_priv: the bat priv with all the soft interface information
287 * @skb: the IPv4 packet to check
288 * @is_unsnoopable: stores whether the destination is snoopable
290 * Checks whether the given IPv4 packet has the potential to be forwarded with a
291 * mode more optimal than classic flooding.
293 * Return: If so then 0. Otherwise -EINVAL or -ENOMEM in case of memory
294 * allocation failure.
296 static int batadv_mcast_forw_mode_check_ipv4(struct batadv_priv
*bat_priv
,
298 bool *is_unsnoopable
)
302 /* We might fail due to out-of-memory -> drop it */
303 if (!pskb_may_pull(skb
, sizeof(struct ethhdr
) + sizeof(*iphdr
)))
308 /* TODO: Implement Multicast Router Discovery (RFC4286),
309 * then allow scope > link local, too
311 if (!ipv4_is_local_multicast(iphdr
->daddr
))
314 /* link-local multicast listeners behind a bridge are
315 * not snoopable (see RFC4541, section 2.1.2.2)
317 *is_unsnoopable
= true;
323 * batadv_mcast_forw_mode_check_ipv6 - check for optimized forwarding potential
324 * @bat_priv: the bat priv with all the soft interface information
325 * @skb: the IPv6 packet to check
326 * @is_unsnoopable: stores whether the destination is snoopable
328 * Checks whether the given IPv6 packet has the potential to be forwarded with a
329 * mode more optimal than classic flooding.
331 * Return: If so then 0. Otherwise -EINVAL is or -ENOMEM if we are out of memory
333 static int batadv_mcast_forw_mode_check_ipv6(struct batadv_priv
*bat_priv
,
335 bool *is_unsnoopable
)
337 struct ipv6hdr
*ip6hdr
;
339 /* We might fail due to out-of-memory -> drop it */
340 if (!pskb_may_pull(skb
, sizeof(struct ethhdr
) + sizeof(*ip6hdr
)))
343 ip6hdr
= ipv6_hdr(skb
);
345 /* TODO: Implement Multicast Router Discovery (RFC4286),
346 * then allow scope > link local, too
348 if (IPV6_ADDR_MC_SCOPE(&ip6hdr
->daddr
) != IPV6_ADDR_SCOPE_LINKLOCAL
)
351 /* link-local-all-nodes multicast listeners behind a bridge are
352 * not snoopable (see RFC4541, section 3, paragraph 3)
354 if (ipv6_addr_is_ll_all_nodes(&ip6hdr
->daddr
))
355 *is_unsnoopable
= true;
361 * batadv_mcast_forw_mode_check - check for optimized forwarding potential
362 * @bat_priv: the bat priv with all the soft interface information
363 * @skb: the multicast frame to check
364 * @is_unsnoopable: stores whether the destination is snoopable
366 * Checks whether the given multicast ethernet frame has the potential to be
367 * forwarded with a mode more optimal than classic flooding.
369 * Return: If so then 0. Otherwise -EINVAL is or -ENOMEM if we are out of memory
371 static int batadv_mcast_forw_mode_check(struct batadv_priv
*bat_priv
,
373 bool *is_unsnoopable
)
375 struct ethhdr
*ethhdr
= eth_hdr(skb
);
377 if (!atomic_read(&bat_priv
->multicast_mode
))
380 if (atomic_read(&bat_priv
->mcast
.num_disabled
))
383 switch (ntohs(ethhdr
->h_proto
)) {
385 return batadv_mcast_forw_mode_check_ipv4(bat_priv
, skb
,
388 return batadv_mcast_forw_mode_check_ipv6(bat_priv
, skb
,
396 * batadv_mcast_want_all_ip_count - count nodes with unspecific mcast interest
397 * @bat_priv: the bat priv with all the soft interface information
398 * @ethhdr: ethernet header of a packet
400 * Return: the number of nodes which want all IPv4 multicast traffic if the
401 * given ethhdr is from an IPv4 packet or the number of nodes which want all
402 * IPv6 traffic if it matches an IPv6 packet.
404 static int batadv_mcast_forw_want_all_ip_count(struct batadv_priv
*bat_priv
,
405 struct ethhdr
*ethhdr
)
407 switch (ntohs(ethhdr
->h_proto
)) {
409 return atomic_read(&bat_priv
->mcast
.num_want_all_ipv4
);
411 return atomic_read(&bat_priv
->mcast
.num_want_all_ipv6
);
413 /* we shouldn't be here... */
419 * batadv_mcast_forw_tt_node_get - get a multicast tt node
420 * @bat_priv: the bat priv with all the soft interface information
421 * @ethhdr: the ether header containing the multicast destination
423 * Return: an orig_node matching the multicast address provided by ethhdr
424 * via a translation table lookup. This increases the returned nodes refcount.
426 static struct batadv_orig_node
*
427 batadv_mcast_forw_tt_node_get(struct batadv_priv
*bat_priv
,
428 struct ethhdr
*ethhdr
)
430 return batadv_transtable_search(bat_priv
, ethhdr
->h_source
,
431 ethhdr
->h_dest
, BATADV_NO_FLAGS
);
435 * batadv_mcast_want_forw_ipv4_node_get - get a node with an ipv4 flag
436 * @bat_priv: the bat priv with all the soft interface information
438 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV4 flag set and
439 * increases its refcount.
441 static struct batadv_orig_node
*
442 batadv_mcast_forw_ipv4_node_get(struct batadv_priv
*bat_priv
)
444 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
447 hlist_for_each_entry_rcu(tmp_orig_node
,
448 &bat_priv
->mcast
.want_all_ipv4_list
,
449 mcast_want_all_ipv4_node
) {
450 if (!atomic_inc_not_zero(&tmp_orig_node
->refcount
))
453 orig_node
= tmp_orig_node
;
462 * batadv_mcast_want_forw_ipv6_node_get - get a node with an ipv6 flag
463 * @bat_priv: the bat priv with all the soft interface information
465 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV6 flag set
466 * and increases its refcount.
468 static struct batadv_orig_node
*
469 batadv_mcast_forw_ipv6_node_get(struct batadv_priv
*bat_priv
)
471 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
474 hlist_for_each_entry_rcu(tmp_orig_node
,
475 &bat_priv
->mcast
.want_all_ipv6_list
,
476 mcast_want_all_ipv6_node
) {
477 if (!atomic_inc_not_zero(&tmp_orig_node
->refcount
))
480 orig_node
= tmp_orig_node
;
489 * batadv_mcast_want_forw_ip_node_get - get a node with an ipv4/ipv6 flag
490 * @bat_priv: the bat priv with all the soft interface information
491 * @ethhdr: an ethernet header to determine the protocol family from
493 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV4 or
494 * BATADV_MCAST_WANT_ALL_IPV6 flag, depending on the provided ethhdr, set and
495 * increases its refcount.
497 static struct batadv_orig_node
*
498 batadv_mcast_forw_ip_node_get(struct batadv_priv
*bat_priv
,
499 struct ethhdr
*ethhdr
)
501 switch (ntohs(ethhdr
->h_proto
)) {
503 return batadv_mcast_forw_ipv4_node_get(bat_priv
);
505 return batadv_mcast_forw_ipv6_node_get(bat_priv
);
507 /* we shouldn't be here... */
513 * batadv_mcast_want_forw_unsnoop_node_get - get a node with an unsnoopable flag
514 * @bat_priv: the bat priv with all the soft interface information
516 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_UNSNOOPABLES flag
517 * set and increases its refcount.
519 static struct batadv_orig_node
*
520 batadv_mcast_forw_unsnoop_node_get(struct batadv_priv
*bat_priv
)
522 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
525 hlist_for_each_entry_rcu(tmp_orig_node
,
526 &bat_priv
->mcast
.want_all_unsnoopables_list
,
527 mcast_want_all_unsnoopables_node
) {
528 if (!atomic_inc_not_zero(&tmp_orig_node
->refcount
))
531 orig_node
= tmp_orig_node
;
540 * batadv_mcast_forw_mode - check on how to forward a multicast packet
541 * @bat_priv: the bat priv with all the soft interface information
542 * @skb: The multicast packet to check
543 * @orig: an originator to be set to forward the skb to
545 * Return: the forwarding mode as enum batadv_forw_mode and in case of
546 * BATADV_FORW_SINGLE set the orig to the single originator the skb
547 * should be forwarded to.
549 enum batadv_forw_mode
550 batadv_mcast_forw_mode(struct batadv_priv
*bat_priv
, struct sk_buff
*skb
,
551 struct batadv_orig_node
**orig
)
553 int ret
, tt_count
, ip_count
, unsnoop_count
, total_count
;
554 bool is_unsnoopable
= false;
555 struct ethhdr
*ethhdr
;
557 ret
= batadv_mcast_forw_mode_check(bat_priv
, skb
, &is_unsnoopable
);
559 return BATADV_FORW_NONE
;
561 return BATADV_FORW_ALL
;
563 ethhdr
= eth_hdr(skb
);
565 tt_count
= batadv_tt_global_hash_count(bat_priv
, ethhdr
->h_dest
,
567 ip_count
= batadv_mcast_forw_want_all_ip_count(bat_priv
, ethhdr
);
568 unsnoop_count
= !is_unsnoopable
? 0 :
569 atomic_read(&bat_priv
->mcast
.num_want_all_unsnoopables
);
571 total_count
= tt_count
+ ip_count
+ unsnoop_count
;
573 switch (total_count
) {
576 *orig
= batadv_mcast_forw_tt_node_get(bat_priv
, ethhdr
);
578 *orig
= batadv_mcast_forw_ip_node_get(bat_priv
, ethhdr
);
579 else if (unsnoop_count
)
580 *orig
= batadv_mcast_forw_unsnoop_node_get(bat_priv
);
583 return BATADV_FORW_SINGLE
;
587 return BATADV_FORW_NONE
;
589 return BATADV_FORW_ALL
;
594 * batadv_mcast_want_unsnoop_update - update unsnoop counter and list
595 * @bat_priv: the bat priv with all the soft interface information
596 * @orig: the orig_node which multicast state might have changed of
597 * @mcast_flags: flags indicating the new multicast state
599 * If the BATADV_MCAST_WANT_ALL_UNSNOOPABLES flag of this originator,
600 * orig, has toggled then this method updates counter and list accordingly.
602 * Caller needs to hold orig->mcast_handler_lock.
604 static void batadv_mcast_want_unsnoop_update(struct batadv_priv
*bat_priv
,
605 struct batadv_orig_node
*orig
,
608 struct hlist_node
*node
= &orig
->mcast_want_all_unsnoopables_node
;
609 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_unsnoopables_list
;
611 lockdep_assert_held(&orig
->mcast_handler_lock
);
613 /* switched from flag unset to set */
614 if (mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
&&
615 !(orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
)) {
616 atomic_inc(&bat_priv
->mcast
.num_want_all_unsnoopables
);
618 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
619 /* flag checks above + mcast_handler_lock prevents this */
620 WARN_ON(!hlist_unhashed(node
));
622 hlist_add_head_rcu(node
, head
);
623 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
624 /* switched from flag set to unset */
625 } else if (!(mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
) &&
626 orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
) {
627 atomic_dec(&bat_priv
->mcast
.num_want_all_unsnoopables
);
629 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
630 /* flag checks above + mcast_handler_lock prevents this */
631 WARN_ON(hlist_unhashed(node
));
633 hlist_del_init_rcu(node
);
634 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
639 * batadv_mcast_want_ipv4_update - update want-all-ipv4 counter and list
640 * @bat_priv: the bat priv with all the soft interface information
641 * @orig: the orig_node which multicast state might have changed of
642 * @mcast_flags: flags indicating the new multicast state
644 * If the BATADV_MCAST_WANT_ALL_IPV4 flag of this originator, orig, has
645 * toggled then this method updates counter and list accordingly.
647 * Caller needs to hold orig->mcast_handler_lock.
649 static void batadv_mcast_want_ipv4_update(struct batadv_priv
*bat_priv
,
650 struct batadv_orig_node
*orig
,
653 struct hlist_node
*node
= &orig
->mcast_want_all_ipv4_node
;
654 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_ipv4_list
;
656 lockdep_assert_held(&orig
->mcast_handler_lock
);
658 /* switched from flag unset to set */
659 if (mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
&&
660 !(orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
)) {
661 atomic_inc(&bat_priv
->mcast
.num_want_all_ipv4
);
663 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
664 /* flag checks above + mcast_handler_lock prevents this */
665 WARN_ON(!hlist_unhashed(node
));
667 hlist_add_head_rcu(node
, head
);
668 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
669 /* switched from flag set to unset */
670 } else if (!(mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
) &&
671 orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
) {
672 atomic_dec(&bat_priv
->mcast
.num_want_all_ipv4
);
674 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
675 /* flag checks above + mcast_handler_lock prevents this */
676 WARN_ON(hlist_unhashed(node
));
678 hlist_del_init_rcu(node
);
679 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
684 * batadv_mcast_want_ipv6_update - update want-all-ipv6 counter and list
685 * @bat_priv: the bat priv with all the soft interface information
686 * @orig: the orig_node which multicast state might have changed of
687 * @mcast_flags: flags indicating the new multicast state
689 * If the BATADV_MCAST_WANT_ALL_IPV6 flag of this originator, orig, has
690 * toggled then this method updates counter and list accordingly.
692 * Caller needs to hold orig->mcast_handler_lock.
694 static void batadv_mcast_want_ipv6_update(struct batadv_priv
*bat_priv
,
695 struct batadv_orig_node
*orig
,
698 struct hlist_node
*node
= &orig
->mcast_want_all_ipv6_node
;
699 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_ipv6_list
;
701 lockdep_assert_held(&orig
->mcast_handler_lock
);
703 /* switched from flag unset to set */
704 if (mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
&&
705 !(orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
)) {
706 atomic_inc(&bat_priv
->mcast
.num_want_all_ipv6
);
708 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
709 /* flag checks above + mcast_handler_lock prevents this */
710 WARN_ON(!hlist_unhashed(node
));
712 hlist_add_head_rcu(node
, head
);
713 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
714 /* switched from flag set to unset */
715 } else if (!(mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
) &&
716 orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
) {
717 atomic_dec(&bat_priv
->mcast
.num_want_all_ipv6
);
719 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
720 /* flag checks above + mcast_handler_lock prevents this */
721 WARN_ON(hlist_unhashed(node
));
723 hlist_del_init_rcu(node
);
724 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
729 * batadv_mcast_tvlv_ogm_handler_v1 - process incoming multicast tvlv container
730 * @bat_priv: the bat priv with all the soft interface information
731 * @orig: the orig_node of the ogm
732 * @flags: flags indicating the tvlv state (see batadv_tvlv_handler_flags)
733 * @tvlv_value: tvlv buffer containing the multicast data
734 * @tvlv_value_len: tvlv buffer length
736 static void batadv_mcast_tvlv_ogm_handler_v1(struct batadv_priv
*bat_priv
,
737 struct batadv_orig_node
*orig
,
742 bool orig_mcast_enabled
= !(flags
& BATADV_TVLV_HANDLER_OGM_CIFNOTFND
);
743 u8 mcast_flags
= BATADV_NO_FLAGS
;
744 bool orig_initialized
;
746 if (orig_mcast_enabled
&& tvlv_value
&&
747 (tvlv_value_len
>= sizeof(mcast_flags
)))
748 mcast_flags
= *(u8
*)tvlv_value
;
750 spin_lock_bh(&orig
->mcast_handler_lock
);
751 orig_initialized
= test_bit(BATADV_ORIG_CAPA_HAS_MCAST
,
752 &orig
->capa_initialized
);
754 /* If mcast support is turned on decrease the disabled mcast node
755 * counter only if we had increased it for this node before. If this
756 * is a completely new orig_node no need to decrease the counter.
758 if (orig_mcast_enabled
&&
759 !test_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
)) {
760 if (orig_initialized
)
761 atomic_dec(&bat_priv
->mcast
.num_disabled
);
762 set_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
);
763 /* If mcast support is being switched off or if this is an initial
764 * OGM without mcast support then increase the disabled mcast
767 } else if (!orig_mcast_enabled
&&
768 (test_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
) ||
769 !orig_initialized
)) {
770 atomic_inc(&bat_priv
->mcast
.num_disabled
);
771 clear_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
);
774 set_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capa_initialized
);
776 batadv_mcast_want_unsnoop_update(bat_priv
, orig
, mcast_flags
);
777 batadv_mcast_want_ipv4_update(bat_priv
, orig
, mcast_flags
);
778 batadv_mcast_want_ipv6_update(bat_priv
, orig
, mcast_flags
);
780 orig
->mcast_flags
= mcast_flags
;
781 spin_unlock_bh(&orig
->mcast_handler_lock
);
785 * batadv_mcast_init - initialize the multicast optimizations structures
786 * @bat_priv: the bat priv with all the soft interface information
788 void batadv_mcast_init(struct batadv_priv
*bat_priv
)
790 batadv_tvlv_handler_register(bat_priv
, batadv_mcast_tvlv_ogm_handler_v1
,
791 NULL
, BATADV_TVLV_MCAST
, 1,
792 BATADV_TVLV_HANDLER_OGM_CIFNOTFND
);
796 * batadv_mcast_free - free the multicast optimizations structures
797 * @bat_priv: the bat priv with all the soft interface information
799 void batadv_mcast_free(struct batadv_priv
*bat_priv
)
801 batadv_tvlv_container_unregister(bat_priv
, BATADV_TVLV_MCAST
, 1);
802 batadv_tvlv_handler_unregister(bat_priv
, BATADV_TVLV_MCAST
, 1);
804 spin_lock_bh(&bat_priv
->tt
.commit_lock
);
805 batadv_mcast_mla_tt_retract(bat_priv
, NULL
);
806 spin_unlock_bh(&bat_priv
->tt
.commit_lock
);
810 * batadv_mcast_purge_orig - reset originator global mcast state modifications
811 * @orig: the originator which is going to get purged
813 void batadv_mcast_purge_orig(struct batadv_orig_node
*orig
)
815 struct batadv_priv
*bat_priv
= orig
->bat_priv
;
817 spin_lock_bh(&orig
->mcast_handler_lock
);
819 if (!test_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
) &&
820 test_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capa_initialized
))
821 atomic_dec(&bat_priv
->mcast
.num_disabled
);
823 batadv_mcast_want_unsnoop_update(bat_priv
, orig
, BATADV_NO_FLAGS
);
824 batadv_mcast_want_ipv4_update(bat_priv
, orig
, BATADV_NO_FLAGS
);
825 batadv_mcast_want_ipv6_update(bat_priv
, orig
, BATADV_NO_FLAGS
);
827 spin_unlock_bh(&orig
->mcast_handler_lock
);