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);