1 // SPDX-License-Identifier: GPL-2.0
2 /* Copyright (C) B.A.T.M.A.N. contributors:
10 #include <linux/atomic.h>
11 #include <linux/bitops.h>
12 #include <linux/bug.h>
13 #include <linux/byteorder/generic.h>
14 #include <linux/errno.h>
15 #include <linux/etherdevice.h>
16 #include <linux/gfp.h>
17 #include <linux/icmpv6.h>
18 #include <linux/if_bridge.h>
19 #include <linux/if_ether.h>
20 #include <linux/igmp.h>
22 #include <linux/in6.h>
23 #include <linux/inetdevice.h>
25 #include <linux/ipv6.h>
26 #include <linux/jiffies.h>
27 #include <linux/kernel.h>
28 #include <linux/kref.h>
29 #include <linux/list.h>
30 #include <linux/lockdep.h>
31 #include <linux/netdevice.h>
32 #include <linux/netlink.h>
33 #include <linux/printk.h>
34 #include <linux/rculist.h>
35 #include <linux/rcupdate.h>
36 #include <linux/skbuff.h>
37 #include <linux/slab.h>
38 #include <linux/spinlock.h>
39 #include <linux/stddef.h>
40 #include <linux/string.h>
41 #include <linux/types.h>
42 #include <linux/workqueue.h>
43 #include <net/addrconf.h>
44 #include <net/genetlink.h>
45 #include <net/if_inet6.h>
48 #include <net/netlink.h>
50 #include <uapi/linux/batadv_packet.h>
51 #include <uapi/linux/batman_adv.h>
53 #include "bridge_loop_avoidance.h"
54 #include "hard-interface.h"
59 #include "soft-interface.h"
60 #include "translation-table.h"
63 static void batadv_mcast_mla_update(struct work_struct
*work
);
66 * batadv_mcast_start_timer() - schedule the multicast periodic worker
67 * @bat_priv: the bat priv with all the soft interface information
69 static void batadv_mcast_start_timer(struct batadv_priv
*bat_priv
)
71 queue_delayed_work(batadv_event_workqueue
, &bat_priv
->mcast
.work
,
72 msecs_to_jiffies(BATADV_MCAST_WORK_PERIOD
));
76 * batadv_mcast_get_bridge() - get the bridge on top of the softif if it exists
77 * @soft_iface: netdev struct of the mesh interface
79 * If the given soft interface has a bridge on top then the refcount
80 * of the according net device is increased.
82 * Return: NULL if no such bridge exists. Otherwise the net device of the
85 static struct net_device
*batadv_mcast_get_bridge(struct net_device
*soft_iface
)
87 struct net_device
*upper
= soft_iface
;
91 upper
= netdev_master_upper_dev_get_rcu(upper
);
92 } while (upper
&& !(upper
->priv_flags
& IFF_EBRIDGE
));
101 * batadv_mcast_mla_rtr_flags_softif_get_ipv4() - get mcast router flags from
103 * @dev: the interface to check
105 * Checks the presence of an IPv4 multicast router on this node.
107 * Caller needs to hold rcu read lock.
109 * Return: BATADV_NO_FLAGS if present, BATADV_MCAST_WANT_NO_RTR4 otherwise.
111 static u8
batadv_mcast_mla_rtr_flags_softif_get_ipv4(struct net_device
*dev
)
113 struct in_device
*in_dev
= __in_dev_get_rcu(dev
);
115 if (in_dev
&& IN_DEV_MFORWARD(in_dev
))
116 return BATADV_NO_FLAGS
;
118 return BATADV_MCAST_WANT_NO_RTR4
;
122 * batadv_mcast_mla_rtr_flags_softif_get_ipv6() - get mcast router flags from
124 * @dev: the interface to check
126 * Checks the presence of an IPv6 multicast router on this node.
128 * Caller needs to hold rcu read lock.
130 * Return: BATADV_NO_FLAGS if present, BATADV_MCAST_WANT_NO_RTR6 otherwise.
132 #if IS_ENABLED(CONFIG_IPV6_MROUTE)
133 static u8
batadv_mcast_mla_rtr_flags_softif_get_ipv6(struct net_device
*dev
)
135 struct inet6_dev
*in6_dev
= __in6_dev_get(dev
);
137 if (in6_dev
&& in6_dev
->cnf
.mc_forwarding
)
138 return BATADV_NO_FLAGS
;
140 return BATADV_MCAST_WANT_NO_RTR6
;
144 batadv_mcast_mla_rtr_flags_softif_get_ipv6(struct net_device
*dev
)
146 return BATADV_MCAST_WANT_NO_RTR6
;
151 * batadv_mcast_mla_rtr_flags_softif_get() - get mcast router flags from node
152 * @bat_priv: the bat priv with all the soft interface information
153 * @bridge: bridge interface on top of the soft_iface if present,
154 * otherwise pass NULL
156 * Checks the presence of IPv4 and IPv6 multicast routers on this
160 * BATADV_NO_FLAGS: Both an IPv4 and IPv6 multicast router is present
161 * BATADV_MCAST_WANT_NO_RTR4: No IPv4 multicast router is present
162 * BATADV_MCAST_WANT_NO_RTR6: No IPv6 multicast router is present
163 * The former two OR'd: no multicast router is present
165 static u8
batadv_mcast_mla_rtr_flags_softif_get(struct batadv_priv
*bat_priv
,
166 struct net_device
*bridge
)
168 struct net_device
*dev
= bridge
? bridge
: bat_priv
->soft_iface
;
169 u8 flags
= BATADV_NO_FLAGS
;
173 flags
|= batadv_mcast_mla_rtr_flags_softif_get_ipv4(dev
);
174 flags
|= batadv_mcast_mla_rtr_flags_softif_get_ipv6(dev
);
182 * batadv_mcast_mla_rtr_flags_bridge_get() - get mcast router flags from bridge
183 * @bat_priv: the bat priv with all the soft interface information
184 * @bridge: bridge interface on top of the soft_iface if present,
185 * otherwise pass NULL
187 * Checks the presence of IPv4 and IPv6 multicast routers behind a bridge.
190 * BATADV_NO_FLAGS: Both an IPv4 and IPv6 multicast router is present
191 * BATADV_MCAST_WANT_NO_RTR4: No IPv4 multicast router is present
192 * BATADV_MCAST_WANT_NO_RTR6: No IPv6 multicast router is present
193 * The former two OR'd: no multicast router is present
195 static u8
batadv_mcast_mla_rtr_flags_bridge_get(struct batadv_priv
*bat_priv
,
196 struct net_device
*bridge
)
198 struct net_device
*dev
= bat_priv
->soft_iface
;
199 u8 flags
= BATADV_NO_FLAGS
;
202 return BATADV_MCAST_WANT_NO_RTR4
| BATADV_MCAST_WANT_NO_RTR6
;
204 if (!br_multicast_has_router_adjacent(dev
, ETH_P_IP
))
205 flags
|= BATADV_MCAST_WANT_NO_RTR4
;
206 if (!br_multicast_has_router_adjacent(dev
, ETH_P_IPV6
))
207 flags
|= BATADV_MCAST_WANT_NO_RTR6
;
213 * batadv_mcast_mla_rtr_flags_get() - get multicast router flags
214 * @bat_priv: the bat priv with all the soft interface information
215 * @bridge: bridge interface on top of the soft_iface if present,
216 * otherwise pass NULL
218 * Checks the presence of IPv4 and IPv6 multicast routers on this
219 * node or behind its bridge.
222 * BATADV_NO_FLAGS: Both an IPv4 and IPv6 multicast router is present
223 * BATADV_MCAST_WANT_NO_RTR4: No IPv4 multicast router is present
224 * BATADV_MCAST_WANT_NO_RTR6: No IPv6 multicast router is present
225 * The former two OR'd: no multicast router is present
227 static u8
batadv_mcast_mla_rtr_flags_get(struct batadv_priv
*bat_priv
,
228 struct net_device
*bridge
)
230 u8 flags
= BATADV_MCAST_WANT_NO_RTR4
| BATADV_MCAST_WANT_NO_RTR6
;
232 flags
&= batadv_mcast_mla_rtr_flags_softif_get(bat_priv
, bridge
);
233 flags
&= batadv_mcast_mla_rtr_flags_bridge_get(bat_priv
, bridge
);
239 * batadv_mcast_mla_flags_get() - get the new multicast flags
240 * @bat_priv: the bat priv with all the soft interface information
242 * Return: A set of flags for the current/next TVLV, querier and
245 static struct batadv_mcast_mla_flags
246 batadv_mcast_mla_flags_get(struct batadv_priv
*bat_priv
)
248 struct net_device
*dev
= bat_priv
->soft_iface
;
249 struct batadv_mcast_querier_state
*qr4
, *qr6
;
250 struct batadv_mcast_mla_flags mla_flags
;
251 struct net_device
*bridge
;
253 bridge
= batadv_mcast_get_bridge(dev
);
255 memset(&mla_flags
, 0, sizeof(mla_flags
));
256 mla_flags
.enabled
= 1;
257 mla_flags
.tvlv_flags
|= batadv_mcast_mla_rtr_flags_get(bat_priv
,
265 mla_flags
.bridged
= 1;
266 qr4
= &mla_flags
.querier_ipv4
;
267 qr6
= &mla_flags
.querier_ipv6
;
269 if (!IS_ENABLED(CONFIG_BRIDGE_IGMP_SNOOPING
))
270 pr_warn_once("No bridge IGMP snooping compiled - multicast optimizations disabled\n");
272 qr4
->exists
= br_multicast_has_querier_anywhere(dev
, ETH_P_IP
);
273 qr4
->shadowing
= br_multicast_has_querier_adjacent(dev
, ETH_P_IP
);
275 qr6
->exists
= br_multicast_has_querier_anywhere(dev
, ETH_P_IPV6
);
276 qr6
->shadowing
= br_multicast_has_querier_adjacent(dev
, ETH_P_IPV6
);
278 mla_flags
.tvlv_flags
|= BATADV_MCAST_WANT_ALL_UNSNOOPABLES
;
280 /* 1) If no querier exists at all, then multicast listeners on
281 * our local TT clients behind the bridge will keep silent.
282 * 2) If the selected querier is on one of our local TT clients,
283 * behind the bridge, then this querier might shadow multicast
284 * listeners on our local TT clients, behind this bridge.
286 * In both cases, we will signalize other batman nodes that
287 * we need all multicast traffic of the according protocol.
289 if (!qr4
->exists
|| qr4
->shadowing
) {
290 mla_flags
.tvlv_flags
|= BATADV_MCAST_WANT_ALL_IPV4
;
291 mla_flags
.tvlv_flags
&= ~BATADV_MCAST_WANT_NO_RTR4
;
294 if (!qr6
->exists
|| qr6
->shadowing
) {
295 mla_flags
.tvlv_flags
|= BATADV_MCAST_WANT_ALL_IPV6
;
296 mla_flags
.tvlv_flags
&= ~BATADV_MCAST_WANT_NO_RTR6
;
303 * batadv_mcast_mla_is_duplicate() - check whether an address is in a list
304 * @mcast_addr: the multicast address to check
305 * @mcast_list: the list with multicast addresses to search in
307 * Return: true if the given address is already in the given list.
308 * Otherwise returns false.
310 static bool batadv_mcast_mla_is_duplicate(u8
*mcast_addr
,
311 struct hlist_head
*mcast_list
)
313 struct batadv_hw_addr
*mcast_entry
;
315 hlist_for_each_entry(mcast_entry
, mcast_list
, list
)
316 if (batadv_compare_eth(mcast_entry
->addr
, mcast_addr
))
323 * batadv_mcast_mla_softif_get_ipv4() - get softif IPv4 multicast listeners
324 * @dev: the device to collect multicast addresses from
325 * @mcast_list: a list to put found addresses into
326 * @flags: flags indicating the new multicast state
328 * Collects multicast addresses of IPv4 multicast listeners residing
329 * on this kernel on the given soft interface, dev, in
330 * the given mcast_list. In general, multicast listeners provided by
331 * your multicast receiving applications run directly on this node.
333 * Return: -ENOMEM on memory allocation error or the number of
334 * items added to the mcast_list otherwise.
337 batadv_mcast_mla_softif_get_ipv4(struct net_device
*dev
,
338 struct hlist_head
*mcast_list
,
339 struct batadv_mcast_mla_flags
*flags
)
341 struct batadv_hw_addr
*new;
342 struct in_device
*in_dev
;
343 u8 mcast_addr
[ETH_ALEN
];
344 struct ip_mc_list
*pmc
;
347 if (flags
->tvlv_flags
& BATADV_MCAST_WANT_ALL_IPV4
)
352 in_dev
= __in_dev_get_rcu(dev
);
358 for (pmc
= rcu_dereference(in_dev
->mc_list
); pmc
;
359 pmc
= rcu_dereference(pmc
->next_rcu
)) {
360 if (flags
->tvlv_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
&&
361 ipv4_is_local_multicast(pmc
->multiaddr
))
364 if (!(flags
->tvlv_flags
& BATADV_MCAST_WANT_NO_RTR4
) &&
365 !ipv4_is_local_multicast(pmc
->multiaddr
))
368 ip_eth_mc_map(pmc
->multiaddr
, mcast_addr
);
370 if (batadv_mcast_mla_is_duplicate(mcast_addr
, mcast_list
))
373 new = kmalloc(sizeof(*new), GFP_ATOMIC
);
379 ether_addr_copy(new->addr
, mcast_addr
);
380 hlist_add_head(&new->list
, mcast_list
);
389 * batadv_mcast_mla_softif_get_ipv6() - get softif IPv6 multicast listeners
390 * @dev: the device to collect multicast addresses from
391 * @mcast_list: a list to put found addresses into
392 * @flags: flags indicating the new multicast state
394 * Collects multicast addresses of IPv6 multicast listeners residing
395 * on this kernel on the given soft interface, dev, in
396 * the given mcast_list. In general, multicast listeners provided by
397 * your multicast receiving applications run directly on this node.
399 * Return: -ENOMEM on memory allocation error or the number of
400 * items added to the mcast_list otherwise.
402 #if IS_ENABLED(CONFIG_IPV6)
404 batadv_mcast_mla_softif_get_ipv6(struct net_device
*dev
,
405 struct hlist_head
*mcast_list
,
406 struct batadv_mcast_mla_flags
*flags
)
408 struct batadv_hw_addr
*new;
409 struct inet6_dev
*in6_dev
;
410 u8 mcast_addr
[ETH_ALEN
];
411 struct ifmcaddr6
*pmc6
;
414 if (flags
->tvlv_flags
& BATADV_MCAST_WANT_ALL_IPV6
)
419 in6_dev
= __in6_dev_get(dev
);
425 for (pmc6
= rcu_dereference(in6_dev
->mc_list
);
427 pmc6
= rcu_dereference(pmc6
->next
)) {
428 if (IPV6_ADDR_MC_SCOPE(&pmc6
->mca_addr
) <
429 IPV6_ADDR_SCOPE_LINKLOCAL
)
432 if (flags
->tvlv_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
&&
433 ipv6_addr_is_ll_all_nodes(&pmc6
->mca_addr
))
436 if (!(flags
->tvlv_flags
& BATADV_MCAST_WANT_NO_RTR6
) &&
437 IPV6_ADDR_MC_SCOPE(&pmc6
->mca_addr
) >
438 IPV6_ADDR_SCOPE_LINKLOCAL
)
441 ipv6_eth_mc_map(&pmc6
->mca_addr
, mcast_addr
);
443 if (batadv_mcast_mla_is_duplicate(mcast_addr
, mcast_list
))
446 new = kmalloc(sizeof(*new), GFP_ATOMIC
);
452 ether_addr_copy(new->addr
, mcast_addr
);
453 hlist_add_head(&new->list
, mcast_list
);
462 batadv_mcast_mla_softif_get_ipv6(struct net_device
*dev
,
463 struct hlist_head
*mcast_list
,
464 struct batadv_mcast_mla_flags
*flags
)
471 * batadv_mcast_mla_softif_get() - get softif multicast listeners
472 * @dev: the device to collect multicast addresses from
473 * @mcast_list: a list to put found addresses into
474 * @flags: flags indicating the new multicast state
476 * Collects multicast addresses of multicast listeners residing
477 * on this kernel on the given soft interface, dev, in
478 * the given mcast_list. In general, multicast listeners provided by
479 * your multicast receiving applications run directly on this node.
481 * If there is a bridge interface on top of dev, collect from that one
482 * instead. Just like with IP addresses and routes, multicast listeners
483 * will(/should) register to the bridge interface instead of an
486 * Return: -ENOMEM on memory allocation error or the number of
487 * items added to the mcast_list otherwise.
490 batadv_mcast_mla_softif_get(struct net_device
*dev
,
491 struct hlist_head
*mcast_list
,
492 struct batadv_mcast_mla_flags
*flags
)
494 struct net_device
*bridge
= batadv_mcast_get_bridge(dev
);
500 ret4
= batadv_mcast_mla_softif_get_ipv4(dev
, mcast_list
, flags
);
504 ret6
= batadv_mcast_mla_softif_get_ipv6(dev
, mcast_list
, flags
);
517 * batadv_mcast_mla_br_addr_cpy() - copy a bridge multicast address
518 * @dst: destination to write to - a multicast MAC address
519 * @src: source to read from - a multicast IP address
521 * Converts a given multicast IPv4/IPv6 address from a bridge
522 * to its matching multicast MAC address and copies it into the given
523 * destination buffer.
525 * Caller needs to make sure the destination buffer can hold
526 * at least ETH_ALEN bytes.
528 static void batadv_mcast_mla_br_addr_cpy(char *dst
, const struct br_ip
*src
)
530 if (src
->proto
== htons(ETH_P_IP
))
531 ip_eth_mc_map(src
->dst
.ip4
, dst
);
532 #if IS_ENABLED(CONFIG_IPV6)
533 else if (src
->proto
== htons(ETH_P_IPV6
))
534 ipv6_eth_mc_map(&src
->dst
.ip6
, dst
);
541 * batadv_mcast_mla_bridge_get() - get bridged-in multicast listeners
542 * @dev: a bridge slave whose bridge to collect multicast addresses from
543 * @mcast_list: a list to put found addresses into
544 * @flags: flags indicating the new multicast state
546 * Collects multicast addresses of multicast listeners residing
547 * on foreign, non-mesh devices which we gave access to our mesh via
548 * a bridge on top of the given soft interface, dev, in the given
551 * Return: -ENOMEM on memory allocation error or the number of
552 * items added to the mcast_list otherwise.
554 static int batadv_mcast_mla_bridge_get(struct net_device
*dev
,
555 struct hlist_head
*mcast_list
,
556 struct batadv_mcast_mla_flags
*flags
)
558 struct list_head bridge_mcast_list
= LIST_HEAD_INIT(bridge_mcast_list
);
559 struct br_ip_list
*br_ip_entry
, *tmp
;
560 u8 tvlv_flags
= flags
->tvlv_flags
;
561 struct batadv_hw_addr
*new;
562 u8 mcast_addr
[ETH_ALEN
];
565 /* we don't need to detect these devices/listeners, the IGMP/MLD
566 * snooping code of the Linux bridge already does that for us
568 ret
= br_multicast_list_adjacent(dev
, &bridge_mcast_list
);
572 list_for_each_entry(br_ip_entry
, &bridge_mcast_list
, list
) {
573 if (br_ip_entry
->addr
.proto
== htons(ETH_P_IP
)) {
574 if (tvlv_flags
& BATADV_MCAST_WANT_ALL_IPV4
)
577 if (tvlv_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
&&
578 ipv4_is_local_multicast(br_ip_entry
->addr
.dst
.ip4
))
581 if (!(tvlv_flags
& BATADV_MCAST_WANT_NO_RTR4
) &&
582 !ipv4_is_local_multicast(br_ip_entry
->addr
.dst
.ip4
))
586 #if IS_ENABLED(CONFIG_IPV6)
587 if (br_ip_entry
->addr
.proto
== htons(ETH_P_IPV6
)) {
588 if (tvlv_flags
& BATADV_MCAST_WANT_ALL_IPV6
)
591 if (tvlv_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
&&
592 ipv6_addr_is_ll_all_nodes(&br_ip_entry
->addr
.dst
.ip6
))
595 if (!(tvlv_flags
& BATADV_MCAST_WANT_NO_RTR6
) &&
596 IPV6_ADDR_MC_SCOPE(&br_ip_entry
->addr
.dst
.ip6
) >
597 IPV6_ADDR_SCOPE_LINKLOCAL
)
602 batadv_mcast_mla_br_addr_cpy(mcast_addr
, &br_ip_entry
->addr
);
603 if (batadv_mcast_mla_is_duplicate(mcast_addr
, mcast_list
))
606 new = kmalloc(sizeof(*new), GFP_ATOMIC
);
612 ether_addr_copy(new->addr
, mcast_addr
);
613 hlist_add_head(&new->list
, mcast_list
);
617 list_for_each_entry_safe(br_ip_entry
, tmp
, &bridge_mcast_list
, list
) {
618 list_del(&br_ip_entry
->list
);
626 * batadv_mcast_mla_list_free() - free a list of multicast addresses
627 * @mcast_list: the list to free
629 * Removes and frees all items in the given mcast_list.
631 static void batadv_mcast_mla_list_free(struct hlist_head
*mcast_list
)
633 struct batadv_hw_addr
*mcast_entry
;
634 struct hlist_node
*tmp
;
636 hlist_for_each_entry_safe(mcast_entry
, tmp
, mcast_list
, list
) {
637 hlist_del(&mcast_entry
->list
);
643 * batadv_mcast_mla_tt_retract() - clean up multicast listener announcements
644 * @bat_priv: the bat priv with all the soft interface information
645 * @mcast_list: a list of addresses which should _not_ be removed
647 * Retracts the announcement of any multicast listener from the
648 * translation table except the ones listed in the given mcast_list.
650 * If mcast_list is NULL then all are retracted.
652 static void batadv_mcast_mla_tt_retract(struct batadv_priv
*bat_priv
,
653 struct hlist_head
*mcast_list
)
655 struct batadv_hw_addr
*mcast_entry
;
656 struct hlist_node
*tmp
;
658 hlist_for_each_entry_safe(mcast_entry
, tmp
, &bat_priv
->mcast
.mla_list
,
661 batadv_mcast_mla_is_duplicate(mcast_entry
->addr
,
665 batadv_tt_local_remove(bat_priv
, mcast_entry
->addr
,
667 "mcast TT outdated", false);
669 hlist_del(&mcast_entry
->list
);
675 * batadv_mcast_mla_tt_add() - add multicast listener announcements
676 * @bat_priv: the bat priv with all the soft interface information
677 * @mcast_list: a list of addresses which are going to get added
679 * Adds multicast listener announcements from the given mcast_list to the
680 * translation table if they have not been added yet.
682 static void batadv_mcast_mla_tt_add(struct batadv_priv
*bat_priv
,
683 struct hlist_head
*mcast_list
)
685 struct batadv_hw_addr
*mcast_entry
;
686 struct hlist_node
*tmp
;
691 hlist_for_each_entry_safe(mcast_entry
, tmp
, mcast_list
, list
) {
692 if (batadv_mcast_mla_is_duplicate(mcast_entry
->addr
,
693 &bat_priv
->mcast
.mla_list
))
696 if (!batadv_tt_local_add(bat_priv
->soft_iface
,
697 mcast_entry
->addr
, BATADV_NO_FLAGS
,
698 BATADV_NULL_IFINDEX
, BATADV_NO_MARK
))
701 hlist_del(&mcast_entry
->list
);
702 hlist_add_head(&mcast_entry
->list
, &bat_priv
->mcast
.mla_list
);
707 * batadv_mcast_querier_log() - debug output regarding the querier status on
709 * @bat_priv: the bat priv with all the soft interface information
710 * @str_proto: a string for the querier protocol (e.g. "IGMP" or "MLD")
711 * @old_state: the previous querier state on our link
712 * @new_state: the new querier state on our link
714 * Outputs debug messages to the logging facility with log level 'mcast'
715 * regarding changes to the querier status on the link which are relevant
716 * to our multicast optimizations.
718 * Usually this is about whether a querier appeared or vanished in
719 * our mesh or whether the querier is in the suboptimal position of being
720 * behind our local bridge segment: Snooping switches will directly
721 * forward listener reports to the querier, therefore batman-adv and
722 * the bridge will potentially not see these listeners - the querier is
723 * potentially shadowing listeners from us then.
725 * This is only interesting for nodes with a bridge on top of their
729 batadv_mcast_querier_log(struct batadv_priv
*bat_priv
, char *str_proto
,
730 struct batadv_mcast_querier_state
*old_state
,
731 struct batadv_mcast_querier_state
*new_state
)
733 if (!old_state
->exists
&& new_state
->exists
)
734 batadv_info(bat_priv
->soft_iface
, "%s Querier appeared\n",
736 else if (old_state
->exists
&& !new_state
->exists
)
737 batadv_info(bat_priv
->soft_iface
,
738 "%s Querier disappeared - multicast optimizations disabled\n",
740 else if (!bat_priv
->mcast
.mla_flags
.bridged
&& !new_state
->exists
)
741 batadv_info(bat_priv
->soft_iface
,
742 "No %s Querier present - multicast optimizations disabled\n",
745 if (new_state
->exists
) {
746 if ((!old_state
->shadowing
&& new_state
->shadowing
) ||
747 (!old_state
->exists
&& new_state
->shadowing
))
748 batadv_dbg(BATADV_DBG_MCAST
, bat_priv
,
749 "%s Querier is behind our bridged segment: Might shadow listeners\n",
751 else if (old_state
->shadowing
&& !new_state
->shadowing
)
752 batadv_dbg(BATADV_DBG_MCAST
, bat_priv
,
753 "%s Querier is not behind our bridged segment\n",
759 * batadv_mcast_bridge_log() - debug output for topology changes in bridged
761 * @bat_priv: the bat priv with all the soft interface information
762 * @new_flags: flags indicating the new multicast state
764 * If no bridges are ever used on this node, then this function does nothing.
766 * Otherwise this function outputs debug information to the 'mcast' log level
767 * which might be relevant to our multicast optimizations.
769 * More precisely, it outputs information when a bridge interface is added or
770 * removed from a soft interface. And when a bridge is present, it further
771 * outputs information about the querier state which is relevant for the
772 * multicast flags this node is going to set.
775 batadv_mcast_bridge_log(struct batadv_priv
*bat_priv
,
776 struct batadv_mcast_mla_flags
*new_flags
)
778 struct batadv_mcast_mla_flags
*old_flags
= &bat_priv
->mcast
.mla_flags
;
780 if (!old_flags
->bridged
&& new_flags
->bridged
)
781 batadv_dbg(BATADV_DBG_MCAST
, bat_priv
,
782 "Bridge added: Setting Unsnoopables(U)-flag\n");
783 else if (old_flags
->bridged
&& !new_flags
->bridged
)
784 batadv_dbg(BATADV_DBG_MCAST
, bat_priv
,
785 "Bridge removed: Unsetting Unsnoopables(U)-flag\n");
787 if (new_flags
->bridged
) {
788 batadv_mcast_querier_log(bat_priv
, "IGMP",
789 &old_flags
->querier_ipv4
,
790 &new_flags
->querier_ipv4
);
791 batadv_mcast_querier_log(bat_priv
, "MLD",
792 &old_flags
->querier_ipv6
,
793 &new_flags
->querier_ipv6
);
798 * batadv_mcast_flags_log() - output debug information about mcast flag changes
799 * @bat_priv: the bat priv with all the soft interface information
800 * @flags: TVLV flags indicating the new multicast state
802 * Whenever the multicast TVLV flags this node announces change, this function
803 * should be used to notify userspace about the change.
805 static void batadv_mcast_flags_log(struct batadv_priv
*bat_priv
, u8 flags
)
807 bool old_enabled
= bat_priv
->mcast
.mla_flags
.enabled
;
808 u8 old_flags
= bat_priv
->mcast
.mla_flags
.tvlv_flags
;
809 char str_old_flags
[] = "[.... . ]";
811 sprintf(str_old_flags
, "[%c%c%c%s%s]",
812 (old_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
) ? 'U' : '.',
813 (old_flags
& BATADV_MCAST_WANT_ALL_IPV4
) ? '4' : '.',
814 (old_flags
& BATADV_MCAST_WANT_ALL_IPV6
) ? '6' : '.',
815 !(old_flags
& BATADV_MCAST_WANT_NO_RTR4
) ? "R4" : ". ",
816 !(old_flags
& BATADV_MCAST_WANT_NO_RTR6
) ? "R6" : ". ");
818 batadv_dbg(BATADV_DBG_MCAST
, bat_priv
,
819 "Changing multicast flags from '%s' to '[%c%c%c%s%s]'\n",
820 old_enabled
? str_old_flags
: "<undefined>",
821 (flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
) ? 'U' : '.',
822 (flags
& BATADV_MCAST_WANT_ALL_IPV4
) ? '4' : '.',
823 (flags
& BATADV_MCAST_WANT_ALL_IPV6
) ? '6' : '.',
824 !(flags
& BATADV_MCAST_WANT_NO_RTR4
) ? "R4" : ". ",
825 !(flags
& BATADV_MCAST_WANT_NO_RTR6
) ? "R6" : ". ");
829 * batadv_mcast_mla_flags_update() - update multicast flags
830 * @bat_priv: the bat priv with all the soft interface information
831 * @flags: flags indicating the new multicast state
833 * Updates the own multicast tvlv with our current multicast related settings,
834 * capabilities and inabilities.
837 batadv_mcast_mla_flags_update(struct batadv_priv
*bat_priv
,
838 struct batadv_mcast_mla_flags
*flags
)
840 struct batadv_tvlv_mcast_data mcast_data
;
842 if (!memcmp(flags
, &bat_priv
->mcast
.mla_flags
, sizeof(*flags
)))
845 batadv_mcast_bridge_log(bat_priv
, flags
);
846 batadv_mcast_flags_log(bat_priv
, flags
->tvlv_flags
);
848 mcast_data
.flags
= flags
->tvlv_flags
;
849 memset(mcast_data
.reserved
, 0, sizeof(mcast_data
.reserved
));
851 batadv_tvlv_container_register(bat_priv
, BATADV_TVLV_MCAST
, 2,
852 &mcast_data
, sizeof(mcast_data
));
854 bat_priv
->mcast
.mla_flags
= *flags
;
858 * __batadv_mcast_mla_update() - update the own MLAs
859 * @bat_priv: the bat priv with all the soft interface information
861 * Updates the own multicast listener announcements in the translation
862 * table as well as the own, announced multicast tvlv container.
864 * Note that non-conflicting reads and writes to bat_priv->mcast.mla_list
865 * in batadv_mcast_mla_tt_retract() and batadv_mcast_mla_tt_add() are
866 * ensured by the non-parallel execution of the worker this function
869 static void __batadv_mcast_mla_update(struct batadv_priv
*bat_priv
)
871 struct net_device
*soft_iface
= bat_priv
->soft_iface
;
872 struct hlist_head mcast_list
= HLIST_HEAD_INIT
;
873 struct batadv_mcast_mla_flags flags
;
876 flags
= batadv_mcast_mla_flags_get(bat_priv
);
878 ret
= batadv_mcast_mla_softif_get(soft_iface
, &mcast_list
, &flags
);
882 ret
= batadv_mcast_mla_bridge_get(soft_iface
, &mcast_list
, &flags
);
886 spin_lock(&bat_priv
->mcast
.mla_lock
);
887 batadv_mcast_mla_tt_retract(bat_priv
, &mcast_list
);
888 batadv_mcast_mla_tt_add(bat_priv
, &mcast_list
);
889 batadv_mcast_mla_flags_update(bat_priv
, &flags
);
890 spin_unlock(&bat_priv
->mcast
.mla_lock
);
893 batadv_mcast_mla_list_free(&mcast_list
);
897 * batadv_mcast_mla_update() - update the own MLAs
898 * @work: kernel work struct
900 * Updates the own multicast listener announcements in the translation
901 * table as well as the own, announced multicast tvlv container.
903 * In the end, reschedules the work timer.
905 static void batadv_mcast_mla_update(struct work_struct
*work
)
907 struct delayed_work
*delayed_work
;
908 struct batadv_priv_mcast
*priv_mcast
;
909 struct batadv_priv
*bat_priv
;
911 delayed_work
= to_delayed_work(work
);
912 priv_mcast
= container_of(delayed_work
, struct batadv_priv_mcast
, work
);
913 bat_priv
= container_of(priv_mcast
, struct batadv_priv
, mcast
);
915 __batadv_mcast_mla_update(bat_priv
);
916 batadv_mcast_start_timer(bat_priv
);
920 * batadv_mcast_is_report_ipv4() - check for IGMP reports
921 * @skb: the ethernet frame destined for the mesh
923 * This call might reallocate skb data.
925 * Checks whether the given frame is a valid IGMP report.
927 * Return: If so then true, otherwise false.
929 static bool batadv_mcast_is_report_ipv4(struct sk_buff
*skb
)
931 if (ip_mc_check_igmp(skb
) < 0)
934 switch (igmp_hdr(skb
)->type
) {
935 case IGMP_HOST_MEMBERSHIP_REPORT
:
936 case IGMPV2_HOST_MEMBERSHIP_REPORT
:
937 case IGMPV3_HOST_MEMBERSHIP_REPORT
:
945 * batadv_mcast_forw_mode_check_ipv4() - check for optimized forwarding
947 * @bat_priv: the bat priv with all the soft interface information
948 * @skb: the IPv4 packet to check
949 * @is_unsnoopable: stores whether the destination is snoopable
950 * @is_routable: stores whether the destination is routable
952 * Checks whether the given IPv4 packet has the potential to be forwarded with a
953 * mode more optimal than classic flooding.
955 * Return: If so then 0. Otherwise -EINVAL or -ENOMEM in case of memory
956 * allocation failure.
958 static int batadv_mcast_forw_mode_check_ipv4(struct batadv_priv
*bat_priv
,
960 bool *is_unsnoopable
,
965 /* We might fail due to out-of-memory -> drop it */
966 if (!pskb_may_pull(skb
, sizeof(struct ethhdr
) + sizeof(*iphdr
)))
969 if (batadv_mcast_is_report_ipv4(skb
))
974 /* link-local multicast listeners behind a bridge are
975 * not snoopable (see RFC4541, section 2.1.2.2)
977 if (ipv4_is_local_multicast(iphdr
->daddr
))
978 *is_unsnoopable
= true;
980 *is_routable
= ETH_P_IP
;
986 * batadv_mcast_is_report_ipv6() - check for MLD reports
987 * @skb: the ethernet frame destined for the mesh
989 * This call might reallocate skb data.
991 * Checks whether the given frame is a valid MLD report.
993 * Return: If so then true, otherwise false.
995 static bool batadv_mcast_is_report_ipv6(struct sk_buff
*skb
)
997 if (ipv6_mc_check_mld(skb
) < 0)
1000 switch (icmp6_hdr(skb
)->icmp6_type
) {
1001 case ICMPV6_MGM_REPORT
:
1002 case ICMPV6_MLD2_REPORT
:
1010 * batadv_mcast_forw_mode_check_ipv6() - check for optimized forwarding
1012 * @bat_priv: the bat priv with all the soft interface information
1013 * @skb: the IPv6 packet to check
1014 * @is_unsnoopable: stores whether the destination is snoopable
1015 * @is_routable: stores whether the destination is routable
1017 * Checks whether the given IPv6 packet has the potential to be forwarded with a
1018 * mode more optimal than classic flooding.
1020 * Return: If so then 0. Otherwise -EINVAL is or -ENOMEM if we are out of memory
1022 static int batadv_mcast_forw_mode_check_ipv6(struct batadv_priv
*bat_priv
,
1023 struct sk_buff
*skb
,
1024 bool *is_unsnoopable
,
1027 struct ipv6hdr
*ip6hdr
;
1029 /* We might fail due to out-of-memory -> drop it */
1030 if (!pskb_may_pull(skb
, sizeof(struct ethhdr
) + sizeof(*ip6hdr
)))
1033 if (batadv_mcast_is_report_ipv6(skb
))
1036 ip6hdr
= ipv6_hdr(skb
);
1038 if (IPV6_ADDR_MC_SCOPE(&ip6hdr
->daddr
) < IPV6_ADDR_SCOPE_LINKLOCAL
)
1041 /* link-local-all-nodes multicast listeners behind a bridge are
1042 * not snoopable (see RFC4541, section 3, paragraph 3)
1044 if (ipv6_addr_is_ll_all_nodes(&ip6hdr
->daddr
))
1045 *is_unsnoopable
= true;
1046 else if (IPV6_ADDR_MC_SCOPE(&ip6hdr
->daddr
) > IPV6_ADDR_SCOPE_LINKLOCAL
)
1047 *is_routable
= ETH_P_IPV6
;
1053 * batadv_mcast_forw_mode_check() - check for optimized forwarding potential
1054 * @bat_priv: the bat priv with all the soft interface information
1055 * @skb: the multicast frame to check
1056 * @is_unsnoopable: stores whether the destination is snoopable
1057 * @is_routable: stores whether the destination is routable
1059 * Checks whether the given multicast ethernet frame has the potential to be
1060 * forwarded with a mode more optimal than classic flooding.
1062 * Return: If so then 0. Otherwise -EINVAL is or -ENOMEM if we are out of memory
1064 static int batadv_mcast_forw_mode_check(struct batadv_priv
*bat_priv
,
1065 struct sk_buff
*skb
,
1066 bool *is_unsnoopable
,
1069 struct ethhdr
*ethhdr
= eth_hdr(skb
);
1071 if (!atomic_read(&bat_priv
->multicast_mode
))
1074 switch (ntohs(ethhdr
->h_proto
)) {
1076 return batadv_mcast_forw_mode_check_ipv4(bat_priv
, skb
,
1080 if (!IS_ENABLED(CONFIG_IPV6
))
1083 return batadv_mcast_forw_mode_check_ipv6(bat_priv
, skb
,
1092 * batadv_mcast_forw_want_all_ip_count() - count nodes with unspecific mcast
1094 * @bat_priv: the bat priv with all the soft interface information
1095 * @ethhdr: ethernet header of a packet
1097 * Return: the number of nodes which want all IPv4 multicast traffic if the
1098 * given ethhdr is from an IPv4 packet or the number of nodes which want all
1099 * IPv6 traffic if it matches an IPv6 packet.
1101 static int batadv_mcast_forw_want_all_ip_count(struct batadv_priv
*bat_priv
,
1102 struct ethhdr
*ethhdr
)
1104 switch (ntohs(ethhdr
->h_proto
)) {
1106 return atomic_read(&bat_priv
->mcast
.num_want_all_ipv4
);
1108 return atomic_read(&bat_priv
->mcast
.num_want_all_ipv6
);
1110 /* we shouldn't be here... */
1116 * batadv_mcast_forw_rtr_count() - count nodes with a multicast router
1117 * @bat_priv: the bat priv with all the soft interface information
1118 * @protocol: the ethernet protocol type to count multicast routers for
1120 * Return: the number of nodes which want all routable IPv4 multicast traffic
1121 * if the protocol is ETH_P_IP or the number of nodes which want all routable
1122 * IPv6 traffic if the protocol is ETH_P_IPV6. Otherwise returns 0.
1125 static int batadv_mcast_forw_rtr_count(struct batadv_priv
*bat_priv
,
1130 return atomic_read(&bat_priv
->mcast
.num_want_all_rtr4
);
1132 return atomic_read(&bat_priv
->mcast
.num_want_all_rtr6
);
1139 * batadv_mcast_forw_tt_node_get() - get a multicast tt node
1140 * @bat_priv: the bat priv with all the soft interface information
1141 * @ethhdr: the ether header containing the multicast destination
1143 * Return: an orig_node matching the multicast address provided by ethhdr
1144 * via a translation table lookup. This increases the returned nodes refcount.
1146 static struct batadv_orig_node
*
1147 batadv_mcast_forw_tt_node_get(struct batadv_priv
*bat_priv
,
1148 struct ethhdr
*ethhdr
)
1150 return batadv_transtable_search(bat_priv
, NULL
, ethhdr
->h_dest
,
1155 * batadv_mcast_forw_ipv4_node_get() - get a node with an ipv4 flag
1156 * @bat_priv: the bat priv with all the soft interface information
1158 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV4 flag set and
1159 * increases its refcount.
1161 static struct batadv_orig_node
*
1162 batadv_mcast_forw_ipv4_node_get(struct batadv_priv
*bat_priv
)
1164 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
1167 hlist_for_each_entry_rcu(tmp_orig_node
,
1168 &bat_priv
->mcast
.want_all_ipv4_list
,
1169 mcast_want_all_ipv4_node
) {
1170 if (!kref_get_unless_zero(&tmp_orig_node
->refcount
))
1173 orig_node
= tmp_orig_node
;
1182 * batadv_mcast_forw_ipv6_node_get() - get a node with an ipv6 flag
1183 * @bat_priv: the bat priv with all the soft interface information
1185 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV6 flag set
1186 * and increases its refcount.
1188 static struct batadv_orig_node
*
1189 batadv_mcast_forw_ipv6_node_get(struct batadv_priv
*bat_priv
)
1191 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
1194 hlist_for_each_entry_rcu(tmp_orig_node
,
1195 &bat_priv
->mcast
.want_all_ipv6_list
,
1196 mcast_want_all_ipv6_node
) {
1197 if (!kref_get_unless_zero(&tmp_orig_node
->refcount
))
1200 orig_node
= tmp_orig_node
;
1209 * batadv_mcast_forw_ip_node_get() - get a node with an ipv4/ipv6 flag
1210 * @bat_priv: the bat priv with all the soft interface information
1211 * @ethhdr: an ethernet header to determine the protocol family from
1213 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV4 or
1214 * BATADV_MCAST_WANT_ALL_IPV6 flag, depending on the provided ethhdr, sets and
1215 * increases its refcount.
1217 static struct batadv_orig_node
*
1218 batadv_mcast_forw_ip_node_get(struct batadv_priv
*bat_priv
,
1219 struct ethhdr
*ethhdr
)
1221 switch (ntohs(ethhdr
->h_proto
)) {
1223 return batadv_mcast_forw_ipv4_node_get(bat_priv
);
1225 return batadv_mcast_forw_ipv6_node_get(bat_priv
);
1227 /* we shouldn't be here... */
1233 * batadv_mcast_forw_unsnoop_node_get() - get a node with an unsnoopable flag
1234 * @bat_priv: the bat priv with all the soft interface information
1236 * Return: an orig_node which has the BATADV_MCAST_WANT_ALL_UNSNOOPABLES flag
1237 * set and increases its refcount.
1239 static struct batadv_orig_node
*
1240 batadv_mcast_forw_unsnoop_node_get(struct batadv_priv
*bat_priv
)
1242 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
1245 hlist_for_each_entry_rcu(tmp_orig_node
,
1246 &bat_priv
->mcast
.want_all_unsnoopables_list
,
1247 mcast_want_all_unsnoopables_node
) {
1248 if (!kref_get_unless_zero(&tmp_orig_node
->refcount
))
1251 orig_node
= tmp_orig_node
;
1260 * batadv_mcast_forw_rtr4_node_get() - get a node with an ipv4 mcast router flag
1261 * @bat_priv: the bat priv with all the soft interface information
1263 * Return: an orig_node which has the BATADV_MCAST_WANT_NO_RTR4 flag unset and
1264 * increases its refcount.
1266 static struct batadv_orig_node
*
1267 batadv_mcast_forw_rtr4_node_get(struct batadv_priv
*bat_priv
)
1269 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
1272 hlist_for_each_entry_rcu(tmp_orig_node
,
1273 &bat_priv
->mcast
.want_all_rtr4_list
,
1274 mcast_want_all_rtr4_node
) {
1275 if (!kref_get_unless_zero(&tmp_orig_node
->refcount
))
1278 orig_node
= tmp_orig_node
;
1287 * batadv_mcast_forw_rtr6_node_get() - get a node with an ipv6 mcast router flag
1288 * @bat_priv: the bat priv with all the soft interface information
1290 * Return: an orig_node which has the BATADV_MCAST_WANT_NO_RTR6 flag unset
1291 * and increases its refcount.
1293 static struct batadv_orig_node
*
1294 batadv_mcast_forw_rtr6_node_get(struct batadv_priv
*bat_priv
)
1296 struct batadv_orig_node
*tmp_orig_node
, *orig_node
= NULL
;
1299 hlist_for_each_entry_rcu(tmp_orig_node
,
1300 &bat_priv
->mcast
.want_all_rtr6_list
,
1301 mcast_want_all_rtr6_node
) {
1302 if (!kref_get_unless_zero(&tmp_orig_node
->refcount
))
1305 orig_node
= tmp_orig_node
;
1314 * batadv_mcast_forw_rtr_node_get() - get a node with an ipv4/ipv6 router flag
1315 * @bat_priv: the bat priv with all the soft interface information
1316 * @ethhdr: an ethernet header to determine the protocol family from
1318 * Return: an orig_node which has no BATADV_MCAST_WANT_NO_RTR4 or
1319 * BATADV_MCAST_WANT_NO_RTR6 flag, depending on the provided ethhdr, set and
1320 * increases its refcount.
1322 static struct batadv_orig_node
*
1323 batadv_mcast_forw_rtr_node_get(struct batadv_priv
*bat_priv
,
1324 struct ethhdr
*ethhdr
)
1326 switch (ntohs(ethhdr
->h_proto
)) {
1328 return batadv_mcast_forw_rtr4_node_get(bat_priv
);
1330 return batadv_mcast_forw_rtr6_node_get(bat_priv
);
1332 /* we shouldn't be here... */
1338 * batadv_mcast_forw_mode() - check on how to forward a multicast packet
1339 * @bat_priv: the bat priv with all the soft interface information
1340 * @skb: The multicast packet to check
1341 * @orig: an originator to be set to forward the skb to
1343 * Return: the forwarding mode as enum batadv_forw_mode and in case of
1344 * BATADV_FORW_SINGLE set the orig to the single originator the skb
1345 * should be forwarded to.
1347 enum batadv_forw_mode
1348 batadv_mcast_forw_mode(struct batadv_priv
*bat_priv
, struct sk_buff
*skb
,
1349 struct batadv_orig_node
**orig
)
1351 int ret
, tt_count
, ip_count
, unsnoop_count
, total_count
;
1352 bool is_unsnoopable
= false;
1353 unsigned int mcast_fanout
;
1354 struct ethhdr
*ethhdr
;
1355 int is_routable
= 0;
1358 ret
= batadv_mcast_forw_mode_check(bat_priv
, skb
, &is_unsnoopable
,
1361 return BATADV_FORW_NONE
;
1363 return BATADV_FORW_ALL
;
1365 ethhdr
= eth_hdr(skb
);
1367 tt_count
= batadv_tt_global_hash_count(bat_priv
, ethhdr
->h_dest
,
1369 ip_count
= batadv_mcast_forw_want_all_ip_count(bat_priv
, ethhdr
);
1370 unsnoop_count
= !is_unsnoopable
? 0 :
1371 atomic_read(&bat_priv
->mcast
.num_want_all_unsnoopables
);
1372 rtr_count
= batadv_mcast_forw_rtr_count(bat_priv
, is_routable
);
1374 total_count
= tt_count
+ ip_count
+ unsnoop_count
+ rtr_count
;
1376 switch (total_count
) {
1379 *orig
= batadv_mcast_forw_tt_node_get(bat_priv
, ethhdr
);
1381 *orig
= batadv_mcast_forw_ip_node_get(bat_priv
, ethhdr
);
1382 else if (unsnoop_count
)
1383 *orig
= batadv_mcast_forw_unsnoop_node_get(bat_priv
);
1385 *orig
= batadv_mcast_forw_rtr_node_get(bat_priv
,
1389 return BATADV_FORW_SINGLE
;
1393 return BATADV_FORW_NONE
;
1395 mcast_fanout
= atomic_read(&bat_priv
->multicast_fanout
);
1397 if (!unsnoop_count
&& total_count
<= mcast_fanout
)
1398 return BATADV_FORW_SOME
;
1401 return BATADV_FORW_ALL
;
1405 * batadv_mcast_forw_send_orig() - send a multicast packet to an originator
1406 * @bat_priv: the bat priv with all the soft interface information
1407 * @skb: the multicast packet to send
1408 * @vid: the vlan identifier
1409 * @orig_node: the originator to send the packet to
1411 * Return: NET_XMIT_DROP in case of error or NET_XMIT_SUCCESS otherwise.
1413 int batadv_mcast_forw_send_orig(struct batadv_priv
*bat_priv
,
1414 struct sk_buff
*skb
,
1416 struct batadv_orig_node
*orig_node
)
1418 /* Avoid sending multicast-in-unicast packets to other BLA
1419 * gateways - they already got the frame from the LAN side
1420 * we share with them.
1421 * TODO: Refactor to take BLA into account earlier, to avoid
1422 * reducing the mcast_fanout count.
1424 if (batadv_bla_is_backbone_gw_orig(bat_priv
, orig_node
->orig
, vid
)) {
1426 return NET_XMIT_SUCCESS
;
1429 return batadv_send_skb_unicast(bat_priv
, skb
, BATADV_UNICAST
, 0,
1434 * batadv_mcast_forw_tt() - forwards a packet to multicast listeners
1435 * @bat_priv: the bat priv with all the soft interface information
1436 * @skb: the multicast packet to transmit
1437 * @vid: the vlan identifier
1439 * Sends copies of a frame with multicast destination to any multicast
1440 * listener registered in the translation table. A transmission is performed
1441 * via a batman-adv unicast packet for each such destination node.
1443 * Return: NET_XMIT_DROP on memory allocation failure, NET_XMIT_SUCCESS
1447 batadv_mcast_forw_tt(struct batadv_priv
*bat_priv
, struct sk_buff
*skb
,
1450 int ret
= NET_XMIT_SUCCESS
;
1451 struct sk_buff
*newskb
;
1453 struct batadv_tt_orig_list_entry
*orig_entry
;
1455 struct batadv_tt_global_entry
*tt_global
;
1456 const u8
*addr
= eth_hdr(skb
)->h_dest
;
1458 tt_global
= batadv_tt_global_hash_find(bat_priv
, addr
, vid
);
1463 hlist_for_each_entry_rcu(orig_entry
, &tt_global
->orig_list
, list
) {
1464 newskb
= skb_copy(skb
, GFP_ATOMIC
);
1466 ret
= NET_XMIT_DROP
;
1470 batadv_mcast_forw_send_orig(bat_priv
, newskb
, vid
,
1471 orig_entry
->orig_node
);
1475 batadv_tt_global_entry_put(tt_global
);
1482 * batadv_mcast_forw_want_all_ipv4() - forward to nodes with want-all-ipv4
1483 * @bat_priv: the bat priv with all the soft interface information
1484 * @skb: the multicast packet to transmit
1485 * @vid: the vlan identifier
1487 * Sends copies of a frame with multicast destination to any node with a
1488 * BATADV_MCAST_WANT_ALL_IPV4 flag set. A transmission is performed via a
1489 * batman-adv unicast packet for each such destination node.
1491 * Return: NET_XMIT_DROP on memory allocation failure, NET_XMIT_SUCCESS
1495 batadv_mcast_forw_want_all_ipv4(struct batadv_priv
*bat_priv
,
1496 struct sk_buff
*skb
, unsigned short vid
)
1498 struct batadv_orig_node
*orig_node
;
1499 int ret
= NET_XMIT_SUCCESS
;
1500 struct sk_buff
*newskb
;
1503 hlist_for_each_entry_rcu(orig_node
,
1504 &bat_priv
->mcast
.want_all_ipv4_list
,
1505 mcast_want_all_ipv4_node
) {
1506 newskb
= skb_copy(skb
, GFP_ATOMIC
);
1508 ret
= NET_XMIT_DROP
;
1512 batadv_mcast_forw_send_orig(bat_priv
, newskb
, vid
, orig_node
);
1519 * batadv_mcast_forw_want_all_ipv6() - forward to nodes with want-all-ipv6
1520 * @bat_priv: the bat priv with all the soft interface information
1521 * @skb: The multicast packet to transmit
1522 * @vid: the vlan identifier
1524 * Sends copies of a frame with multicast destination to any node with a
1525 * BATADV_MCAST_WANT_ALL_IPV6 flag set. A transmission is performed via a
1526 * batman-adv unicast packet for each such destination node.
1528 * Return: NET_XMIT_DROP on memory allocation failure, NET_XMIT_SUCCESS
1532 batadv_mcast_forw_want_all_ipv6(struct batadv_priv
*bat_priv
,
1533 struct sk_buff
*skb
, unsigned short vid
)
1535 struct batadv_orig_node
*orig_node
;
1536 int ret
= NET_XMIT_SUCCESS
;
1537 struct sk_buff
*newskb
;
1540 hlist_for_each_entry_rcu(orig_node
,
1541 &bat_priv
->mcast
.want_all_ipv6_list
,
1542 mcast_want_all_ipv6_node
) {
1543 newskb
= skb_copy(skb
, GFP_ATOMIC
);
1545 ret
= NET_XMIT_DROP
;
1549 batadv_mcast_forw_send_orig(bat_priv
, newskb
, vid
, orig_node
);
1556 * batadv_mcast_forw_want_all() - forward packet to nodes in a want-all list
1557 * @bat_priv: the bat priv with all the soft interface information
1558 * @skb: the multicast packet to transmit
1559 * @vid: the vlan identifier
1561 * Sends copies of a frame with multicast destination to any node with a
1562 * BATADV_MCAST_WANT_ALL_IPV4 or BATADV_MCAST_WANT_ALL_IPV6 flag set. A
1563 * transmission is performed via a batman-adv unicast packet for each such
1566 * Return: NET_XMIT_DROP on memory allocation failure or if the protocol family
1567 * is neither IPv4 nor IPv6. NET_XMIT_SUCCESS otherwise.
1570 batadv_mcast_forw_want_all(struct batadv_priv
*bat_priv
,
1571 struct sk_buff
*skb
, unsigned short vid
)
1573 switch (ntohs(eth_hdr(skb
)->h_proto
)) {
1575 return batadv_mcast_forw_want_all_ipv4(bat_priv
, skb
, vid
);
1577 return batadv_mcast_forw_want_all_ipv6(bat_priv
, skb
, vid
);
1579 /* we shouldn't be here... */
1580 return NET_XMIT_DROP
;
1585 * batadv_mcast_forw_want_all_rtr4() - forward to nodes with want-all-rtr4
1586 * @bat_priv: the bat priv with all the soft interface information
1587 * @skb: the multicast packet to transmit
1588 * @vid: the vlan identifier
1590 * Sends copies of a frame with multicast destination to any node with a
1591 * BATADV_MCAST_WANT_NO_RTR4 flag unset. A transmission is performed via a
1592 * batman-adv unicast packet for each such destination node.
1594 * Return: NET_XMIT_DROP on memory allocation failure, NET_XMIT_SUCCESS
1598 batadv_mcast_forw_want_all_rtr4(struct batadv_priv
*bat_priv
,
1599 struct sk_buff
*skb
, unsigned short vid
)
1601 struct batadv_orig_node
*orig_node
;
1602 int ret
= NET_XMIT_SUCCESS
;
1603 struct sk_buff
*newskb
;
1606 hlist_for_each_entry_rcu(orig_node
,
1607 &bat_priv
->mcast
.want_all_rtr4_list
,
1608 mcast_want_all_rtr4_node
) {
1609 newskb
= skb_copy(skb
, GFP_ATOMIC
);
1611 ret
= NET_XMIT_DROP
;
1615 batadv_mcast_forw_send_orig(bat_priv
, newskb
, vid
, orig_node
);
1622 * batadv_mcast_forw_want_all_rtr6() - forward to nodes with want-all-rtr6
1623 * @bat_priv: the bat priv with all the soft interface information
1624 * @skb: The multicast packet to transmit
1625 * @vid: the vlan identifier
1627 * Sends copies of a frame with multicast destination to any node with a
1628 * BATADV_MCAST_WANT_NO_RTR6 flag unset. A transmission is performed via a
1629 * batman-adv unicast packet for each such destination node.
1631 * Return: NET_XMIT_DROP on memory allocation failure, NET_XMIT_SUCCESS
1635 batadv_mcast_forw_want_all_rtr6(struct batadv_priv
*bat_priv
,
1636 struct sk_buff
*skb
, unsigned short vid
)
1638 struct batadv_orig_node
*orig_node
;
1639 int ret
= NET_XMIT_SUCCESS
;
1640 struct sk_buff
*newskb
;
1643 hlist_for_each_entry_rcu(orig_node
,
1644 &bat_priv
->mcast
.want_all_rtr6_list
,
1645 mcast_want_all_rtr6_node
) {
1646 newskb
= skb_copy(skb
, GFP_ATOMIC
);
1648 ret
= NET_XMIT_DROP
;
1652 batadv_mcast_forw_send_orig(bat_priv
, newskb
, vid
, orig_node
);
1659 * batadv_mcast_forw_want_rtr() - forward packet to nodes in a want-all-rtr list
1660 * @bat_priv: the bat priv with all the soft interface information
1661 * @skb: the multicast packet to transmit
1662 * @vid: the vlan identifier
1664 * Sends copies of a frame with multicast destination to any node with a
1665 * BATADV_MCAST_WANT_NO_RTR4 or BATADV_MCAST_WANT_NO_RTR6 flag unset. A
1666 * transmission is performed via a batman-adv unicast packet for each such
1669 * Return: NET_XMIT_DROP on memory allocation failure or if the protocol family
1670 * is neither IPv4 nor IPv6. NET_XMIT_SUCCESS otherwise.
1673 batadv_mcast_forw_want_rtr(struct batadv_priv
*bat_priv
,
1674 struct sk_buff
*skb
, unsigned short vid
)
1676 switch (ntohs(eth_hdr(skb
)->h_proto
)) {
1678 return batadv_mcast_forw_want_all_rtr4(bat_priv
, skb
, vid
);
1680 return batadv_mcast_forw_want_all_rtr6(bat_priv
, skb
, vid
);
1682 /* we shouldn't be here... */
1683 return NET_XMIT_DROP
;
1688 * batadv_mcast_forw_send() - send packet to any detected multicast recipient
1689 * @bat_priv: the bat priv with all the soft interface information
1690 * @skb: the multicast packet to transmit
1691 * @vid: the vlan identifier
1693 * Sends copies of a frame with multicast destination to any node that signaled
1694 * interest in it, that is either via the translation table or the according
1695 * want-all flags. A transmission is performed via a batman-adv unicast packet
1696 * for each such destination node.
1698 * The given skb is consumed/freed.
1700 * Return: NET_XMIT_DROP on memory allocation failure or if the protocol family
1701 * is neither IPv4 nor IPv6. NET_XMIT_SUCCESS otherwise.
1703 int batadv_mcast_forw_send(struct batadv_priv
*bat_priv
, struct sk_buff
*skb
,
1708 ret
= batadv_mcast_forw_tt(bat_priv
, skb
, vid
);
1709 if (ret
!= NET_XMIT_SUCCESS
) {
1714 ret
= batadv_mcast_forw_want_all(bat_priv
, skb
, vid
);
1715 if (ret
!= NET_XMIT_SUCCESS
) {
1720 ret
= batadv_mcast_forw_want_rtr(bat_priv
, skb
, vid
);
1721 if (ret
!= NET_XMIT_SUCCESS
) {
1731 * batadv_mcast_want_unsnoop_update() - update unsnoop counter and list
1732 * @bat_priv: the bat priv with all the soft interface information
1733 * @orig: the orig_node which multicast state might have changed of
1734 * @mcast_flags: flags indicating the new multicast state
1736 * If the BATADV_MCAST_WANT_ALL_UNSNOOPABLES flag of this originator,
1737 * orig, has toggled then this method updates the counter and the list
1740 * Caller needs to hold orig->mcast_handler_lock.
1742 static void batadv_mcast_want_unsnoop_update(struct batadv_priv
*bat_priv
,
1743 struct batadv_orig_node
*orig
,
1746 struct hlist_node
*node
= &orig
->mcast_want_all_unsnoopables_node
;
1747 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_unsnoopables_list
;
1749 lockdep_assert_held(&orig
->mcast_handler_lock
);
1751 /* switched from flag unset to set */
1752 if (mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
&&
1753 !(orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
)) {
1754 atomic_inc(&bat_priv
->mcast
.num_want_all_unsnoopables
);
1756 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1757 /* flag checks above + mcast_handler_lock prevents this */
1758 WARN_ON(!hlist_unhashed(node
));
1760 hlist_add_head_rcu(node
, head
);
1761 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1762 /* switched from flag set to unset */
1763 } else if (!(mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
) &&
1764 orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_UNSNOOPABLES
) {
1765 atomic_dec(&bat_priv
->mcast
.num_want_all_unsnoopables
);
1767 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1768 /* flag checks above + mcast_handler_lock prevents this */
1769 WARN_ON(hlist_unhashed(node
));
1771 hlist_del_init_rcu(node
);
1772 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1777 * batadv_mcast_want_ipv4_update() - update want-all-ipv4 counter and list
1778 * @bat_priv: the bat priv with all the soft interface information
1779 * @orig: the orig_node which multicast state might have changed of
1780 * @mcast_flags: flags indicating the new multicast state
1782 * If the BATADV_MCAST_WANT_ALL_IPV4 flag of this originator, orig, has
1783 * toggled then this method updates the counter and the list accordingly.
1785 * Caller needs to hold orig->mcast_handler_lock.
1787 static void batadv_mcast_want_ipv4_update(struct batadv_priv
*bat_priv
,
1788 struct batadv_orig_node
*orig
,
1791 struct hlist_node
*node
= &orig
->mcast_want_all_ipv4_node
;
1792 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_ipv4_list
;
1794 lockdep_assert_held(&orig
->mcast_handler_lock
);
1796 /* switched from flag unset to set */
1797 if (mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
&&
1798 !(orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
)) {
1799 atomic_inc(&bat_priv
->mcast
.num_want_all_ipv4
);
1801 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1802 /* flag checks above + mcast_handler_lock prevents this */
1803 WARN_ON(!hlist_unhashed(node
));
1805 hlist_add_head_rcu(node
, head
);
1806 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1807 /* switched from flag set to unset */
1808 } else if (!(mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
) &&
1809 orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
) {
1810 atomic_dec(&bat_priv
->mcast
.num_want_all_ipv4
);
1812 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1813 /* flag checks above + mcast_handler_lock prevents this */
1814 WARN_ON(hlist_unhashed(node
));
1816 hlist_del_init_rcu(node
);
1817 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1822 * batadv_mcast_want_ipv6_update() - update want-all-ipv6 counter and list
1823 * @bat_priv: the bat priv with all the soft interface information
1824 * @orig: the orig_node which multicast state might have changed of
1825 * @mcast_flags: flags indicating the new multicast state
1827 * If the BATADV_MCAST_WANT_ALL_IPV6 flag of this originator, orig, has
1828 * toggled then this method updates the counter and the list accordingly.
1830 * Caller needs to hold orig->mcast_handler_lock.
1832 static void batadv_mcast_want_ipv6_update(struct batadv_priv
*bat_priv
,
1833 struct batadv_orig_node
*orig
,
1836 struct hlist_node
*node
= &orig
->mcast_want_all_ipv6_node
;
1837 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_ipv6_list
;
1839 lockdep_assert_held(&orig
->mcast_handler_lock
);
1841 /* switched from flag unset to set */
1842 if (mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
&&
1843 !(orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
)) {
1844 atomic_inc(&bat_priv
->mcast
.num_want_all_ipv6
);
1846 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1847 /* flag checks above + mcast_handler_lock prevents this */
1848 WARN_ON(!hlist_unhashed(node
));
1850 hlist_add_head_rcu(node
, head
);
1851 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1852 /* switched from flag set to unset */
1853 } else if (!(mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
) &&
1854 orig
->mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
) {
1855 atomic_dec(&bat_priv
->mcast
.num_want_all_ipv6
);
1857 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1858 /* flag checks above + mcast_handler_lock prevents this */
1859 WARN_ON(hlist_unhashed(node
));
1861 hlist_del_init_rcu(node
);
1862 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1867 * batadv_mcast_want_rtr4_update() - update want-all-rtr4 counter and list
1868 * @bat_priv: the bat priv with all the soft interface information
1869 * @orig: the orig_node which multicast state might have changed of
1870 * @mcast_flags: flags indicating the new multicast state
1872 * If the BATADV_MCAST_WANT_NO_RTR4 flag of this originator, orig, has
1873 * toggled then this method updates the counter and the list accordingly.
1875 * Caller needs to hold orig->mcast_handler_lock.
1877 static void batadv_mcast_want_rtr4_update(struct batadv_priv
*bat_priv
,
1878 struct batadv_orig_node
*orig
,
1881 struct hlist_node
*node
= &orig
->mcast_want_all_rtr4_node
;
1882 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_rtr4_list
;
1884 lockdep_assert_held(&orig
->mcast_handler_lock
);
1886 /* switched from flag set to unset */
1887 if (!(mcast_flags
& BATADV_MCAST_WANT_NO_RTR4
) &&
1888 orig
->mcast_flags
& BATADV_MCAST_WANT_NO_RTR4
) {
1889 atomic_inc(&bat_priv
->mcast
.num_want_all_rtr4
);
1891 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1892 /* flag checks above + mcast_handler_lock prevents this */
1893 WARN_ON(!hlist_unhashed(node
));
1895 hlist_add_head_rcu(node
, head
);
1896 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1897 /* switched from flag unset to set */
1898 } else if (mcast_flags
& BATADV_MCAST_WANT_NO_RTR4
&&
1899 !(orig
->mcast_flags
& BATADV_MCAST_WANT_NO_RTR4
)) {
1900 atomic_dec(&bat_priv
->mcast
.num_want_all_rtr4
);
1902 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1903 /* flag checks above + mcast_handler_lock prevents this */
1904 WARN_ON(hlist_unhashed(node
));
1906 hlist_del_init_rcu(node
);
1907 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1912 * batadv_mcast_want_rtr6_update() - update want-all-rtr6 counter and list
1913 * @bat_priv: the bat priv with all the soft interface information
1914 * @orig: the orig_node which multicast state might have changed of
1915 * @mcast_flags: flags indicating the new multicast state
1917 * If the BATADV_MCAST_WANT_NO_RTR6 flag of this originator, orig, has
1918 * toggled then this method updates the counter and the list accordingly.
1920 * Caller needs to hold orig->mcast_handler_lock.
1922 static void batadv_mcast_want_rtr6_update(struct batadv_priv
*bat_priv
,
1923 struct batadv_orig_node
*orig
,
1926 struct hlist_node
*node
= &orig
->mcast_want_all_rtr6_node
;
1927 struct hlist_head
*head
= &bat_priv
->mcast
.want_all_rtr6_list
;
1929 lockdep_assert_held(&orig
->mcast_handler_lock
);
1931 /* switched from flag set to unset */
1932 if (!(mcast_flags
& BATADV_MCAST_WANT_NO_RTR6
) &&
1933 orig
->mcast_flags
& BATADV_MCAST_WANT_NO_RTR6
) {
1934 atomic_inc(&bat_priv
->mcast
.num_want_all_rtr6
);
1936 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1937 /* flag checks above + mcast_handler_lock prevents this */
1938 WARN_ON(!hlist_unhashed(node
));
1940 hlist_add_head_rcu(node
, head
);
1941 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1942 /* switched from flag unset to set */
1943 } else if (mcast_flags
& BATADV_MCAST_WANT_NO_RTR6
&&
1944 !(orig
->mcast_flags
& BATADV_MCAST_WANT_NO_RTR6
)) {
1945 atomic_dec(&bat_priv
->mcast
.num_want_all_rtr6
);
1947 spin_lock_bh(&bat_priv
->mcast
.want_lists_lock
);
1948 /* flag checks above + mcast_handler_lock prevents this */
1949 WARN_ON(hlist_unhashed(node
));
1951 hlist_del_init_rcu(node
);
1952 spin_unlock_bh(&bat_priv
->mcast
.want_lists_lock
);
1957 * batadv_mcast_tvlv_flags_get() - get multicast flags from an OGM TVLV
1958 * @enabled: whether the originator has multicast TVLV support enabled
1959 * @tvlv_value: tvlv buffer containing the multicast flags
1960 * @tvlv_value_len: tvlv buffer length
1962 * Return: multicast flags for the given tvlv buffer
1965 batadv_mcast_tvlv_flags_get(bool enabled
, void *tvlv_value
, u16 tvlv_value_len
)
1967 u8 mcast_flags
= BATADV_NO_FLAGS
;
1969 if (enabled
&& tvlv_value
&& tvlv_value_len
>= sizeof(mcast_flags
))
1970 mcast_flags
= *(u8
*)tvlv_value
;
1973 mcast_flags
|= BATADV_MCAST_WANT_ALL_IPV4
;
1974 mcast_flags
|= BATADV_MCAST_WANT_ALL_IPV6
;
1977 /* remove redundant flags to avoid sending duplicate packets later */
1978 if (mcast_flags
& BATADV_MCAST_WANT_ALL_IPV4
)
1979 mcast_flags
|= BATADV_MCAST_WANT_NO_RTR4
;
1981 if (mcast_flags
& BATADV_MCAST_WANT_ALL_IPV6
)
1982 mcast_flags
|= BATADV_MCAST_WANT_NO_RTR6
;
1988 * batadv_mcast_tvlv_ogm_handler() - process incoming multicast tvlv container
1989 * @bat_priv: the bat priv with all the soft interface information
1990 * @orig: the orig_node of the ogm
1991 * @flags: flags indicating the tvlv state (see batadv_tvlv_handler_flags)
1992 * @tvlv_value: tvlv buffer containing the multicast data
1993 * @tvlv_value_len: tvlv buffer length
1995 static void batadv_mcast_tvlv_ogm_handler(struct batadv_priv
*bat_priv
,
1996 struct batadv_orig_node
*orig
,
2001 bool orig_mcast_enabled
= !(flags
& BATADV_TVLV_HANDLER_OGM_CIFNOTFND
);
2004 mcast_flags
= batadv_mcast_tvlv_flags_get(orig_mcast_enabled
,
2005 tvlv_value
, tvlv_value_len
);
2007 spin_lock_bh(&orig
->mcast_handler_lock
);
2009 if (orig_mcast_enabled
&&
2010 !test_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
)) {
2011 set_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
);
2012 } else if (!orig_mcast_enabled
&&
2013 test_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
)) {
2014 clear_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capabilities
);
2017 set_bit(BATADV_ORIG_CAPA_HAS_MCAST
, &orig
->capa_initialized
);
2019 batadv_mcast_want_unsnoop_update(bat_priv
, orig
, mcast_flags
);
2020 batadv_mcast_want_ipv4_update(bat_priv
, orig
, mcast_flags
);
2021 batadv_mcast_want_ipv6_update(bat_priv
, orig
, mcast_flags
);
2022 batadv_mcast_want_rtr4_update(bat_priv
, orig
, mcast_flags
);
2023 batadv_mcast_want_rtr6_update(bat_priv
, orig
, mcast_flags
);
2025 orig
->mcast_flags
= mcast_flags
;
2026 spin_unlock_bh(&orig
->mcast_handler_lock
);
2030 * batadv_mcast_init() - initialize the multicast optimizations structures
2031 * @bat_priv: the bat priv with all the soft interface information
2033 void batadv_mcast_init(struct batadv_priv
*bat_priv
)
2035 batadv_tvlv_handler_register(bat_priv
, batadv_mcast_tvlv_ogm_handler
,
2036 NULL
, BATADV_TVLV_MCAST
, 2,
2037 BATADV_TVLV_HANDLER_OGM_CIFNOTFND
);
2039 INIT_DELAYED_WORK(&bat_priv
->mcast
.work
, batadv_mcast_mla_update
);
2040 batadv_mcast_start_timer(bat_priv
);
2044 * batadv_mcast_mesh_info_put() - put multicast info into a netlink message
2045 * @msg: buffer for the message
2046 * @bat_priv: the bat priv with all the soft interface information
2048 * Return: 0 or error code.
2050 int batadv_mcast_mesh_info_put(struct sk_buff
*msg
,
2051 struct batadv_priv
*bat_priv
)
2053 u32 flags
= bat_priv
->mcast
.mla_flags
.tvlv_flags
;
2054 u32 flags_priv
= BATADV_NO_FLAGS
;
2056 if (bat_priv
->mcast
.mla_flags
.bridged
) {
2057 flags_priv
|= BATADV_MCAST_FLAGS_BRIDGED
;
2059 if (bat_priv
->mcast
.mla_flags
.querier_ipv4
.exists
)
2060 flags_priv
|= BATADV_MCAST_FLAGS_QUERIER_IPV4_EXISTS
;
2061 if (bat_priv
->mcast
.mla_flags
.querier_ipv6
.exists
)
2062 flags_priv
|= BATADV_MCAST_FLAGS_QUERIER_IPV6_EXISTS
;
2063 if (bat_priv
->mcast
.mla_flags
.querier_ipv4
.shadowing
)
2064 flags_priv
|= BATADV_MCAST_FLAGS_QUERIER_IPV4_SHADOWING
;
2065 if (bat_priv
->mcast
.mla_flags
.querier_ipv6
.shadowing
)
2066 flags_priv
|= BATADV_MCAST_FLAGS_QUERIER_IPV6_SHADOWING
;
2069 if (nla_put_u32(msg
, BATADV_ATTR_MCAST_FLAGS
, flags
) ||
2070 nla_put_u32(msg
, BATADV_ATTR_MCAST_FLAGS_PRIV
, flags_priv
))
2077 * batadv_mcast_flags_dump_entry() - dump one entry of the multicast flags table
2078 * to a netlink socket
2079 * @msg: buffer for the message
2080 * @portid: netlink port
2081 * @cb: Control block containing additional options
2082 * @orig_node: originator to dump the multicast flags of
2084 * Return: 0 or error code.
2087 batadv_mcast_flags_dump_entry(struct sk_buff
*msg
, u32 portid
,
2088 struct netlink_callback
*cb
,
2089 struct batadv_orig_node
*orig_node
)
2093 hdr
= genlmsg_put(msg
, portid
, cb
->nlh
->nlmsg_seq
,
2094 &batadv_netlink_family
, NLM_F_MULTI
,
2095 BATADV_CMD_GET_MCAST_FLAGS
);
2099 genl_dump_check_consistent(cb
, hdr
);
2101 if (nla_put(msg
, BATADV_ATTR_ORIG_ADDRESS
, ETH_ALEN
,
2103 genlmsg_cancel(msg
, hdr
);
2107 if (test_bit(BATADV_ORIG_CAPA_HAS_MCAST
,
2108 &orig_node
->capabilities
)) {
2109 if (nla_put_u32(msg
, BATADV_ATTR_MCAST_FLAGS
,
2110 orig_node
->mcast_flags
)) {
2111 genlmsg_cancel(msg
, hdr
);
2116 genlmsg_end(msg
, hdr
);
2121 * batadv_mcast_flags_dump_bucket() - dump one bucket of the multicast flags
2122 * table to a netlink socket
2123 * @msg: buffer for the message
2124 * @portid: netlink port
2125 * @cb: Control block containing additional options
2126 * @hash: hash to dump
2127 * @bucket: bucket index to dump
2128 * @idx_skip: How many entries to skip
2130 * Return: 0 or error code.
2133 batadv_mcast_flags_dump_bucket(struct sk_buff
*msg
, u32 portid
,
2134 struct netlink_callback
*cb
,
2135 struct batadv_hashtable
*hash
,
2136 unsigned int bucket
, long *idx_skip
)
2138 struct batadv_orig_node
*orig_node
;
2141 spin_lock_bh(&hash
->list_locks
[bucket
]);
2142 cb
->seq
= atomic_read(&hash
->generation
) << 1 | 1;
2144 hlist_for_each_entry(orig_node
, &hash
->table
[bucket
], hash_entry
) {
2145 if (!test_bit(BATADV_ORIG_CAPA_HAS_MCAST
,
2146 &orig_node
->capa_initialized
))
2149 if (idx
< *idx_skip
)
2152 if (batadv_mcast_flags_dump_entry(msg
, portid
, cb
, orig_node
)) {
2153 spin_unlock_bh(&hash
->list_locks
[bucket
]);
2162 spin_unlock_bh(&hash
->list_locks
[bucket
]);
2168 * __batadv_mcast_flags_dump() - dump multicast flags table to a netlink socket
2169 * @msg: buffer for the message
2170 * @portid: netlink port
2171 * @cb: Control block containing additional options
2172 * @bat_priv: the bat priv with all the soft interface information
2173 * @bucket: current bucket to dump
2174 * @idx: index in current bucket to the next entry to dump
2176 * Return: 0 or error code.
2179 __batadv_mcast_flags_dump(struct sk_buff
*msg
, u32 portid
,
2180 struct netlink_callback
*cb
,
2181 struct batadv_priv
*bat_priv
, long *bucket
, long *idx
)
2183 struct batadv_hashtable
*hash
= bat_priv
->orig_hash
;
2184 long bucket_tmp
= *bucket
;
2185 long idx_tmp
= *idx
;
2187 while (bucket_tmp
< hash
->size
) {
2188 if (batadv_mcast_flags_dump_bucket(msg
, portid
, cb
, hash
,
2189 bucket_tmp
, &idx_tmp
))
2196 *bucket
= bucket_tmp
;
2203 * batadv_mcast_netlink_get_primary() - get primary interface from netlink
2205 * @cb: netlink callback structure
2206 * @primary_if: the primary interface pointer to return the result in
2208 * Return: 0 or error code.
2211 batadv_mcast_netlink_get_primary(struct netlink_callback
*cb
,
2212 struct batadv_hard_iface
**primary_if
)
2214 struct batadv_hard_iface
*hard_iface
= NULL
;
2215 struct net
*net
= sock_net(cb
->skb
->sk
);
2216 struct net_device
*soft_iface
;
2217 struct batadv_priv
*bat_priv
;
2221 ifindex
= batadv_netlink_get_ifindex(cb
->nlh
, BATADV_ATTR_MESH_IFINDEX
);
2225 soft_iface
= dev_get_by_index(net
, ifindex
);
2226 if (!soft_iface
|| !batadv_softif_is_valid(soft_iface
)) {
2231 bat_priv
= netdev_priv(soft_iface
);
2233 hard_iface
= batadv_primary_if_get_selected(bat_priv
);
2234 if (!hard_iface
|| hard_iface
->if_status
!= BATADV_IF_ACTIVE
) {
2240 dev_put(soft_iface
);
2242 if (!ret
&& primary_if
)
2243 *primary_if
= hard_iface
;
2245 batadv_hardif_put(hard_iface
);
2251 * batadv_mcast_flags_dump() - dump multicast flags table to a netlink socket
2252 * @msg: buffer for the message
2253 * @cb: callback structure containing arguments
2255 * Return: message length.
2257 int batadv_mcast_flags_dump(struct sk_buff
*msg
, struct netlink_callback
*cb
)
2259 struct batadv_hard_iface
*primary_if
= NULL
;
2260 int portid
= NETLINK_CB(cb
->skb
).portid
;
2261 struct batadv_priv
*bat_priv
;
2262 long *bucket
= &cb
->args
[0];
2263 long *idx
= &cb
->args
[1];
2266 ret
= batadv_mcast_netlink_get_primary(cb
, &primary_if
);
2270 bat_priv
= netdev_priv(primary_if
->soft_iface
);
2271 ret
= __batadv_mcast_flags_dump(msg
, portid
, cb
, bat_priv
, bucket
, idx
);
2273 batadv_hardif_put(primary_if
);
2278 * batadv_mcast_free() - free the multicast optimizations structures
2279 * @bat_priv: the bat priv with all the soft interface information
2281 void batadv_mcast_free(struct batadv_priv
*bat_priv
)
2283 cancel_delayed_work_sync(&bat_priv
->mcast
.work
);
2285 batadv_tvlv_container_unregister(bat_priv
, BATADV_TVLV_MCAST
, 2);
2286 batadv_tvlv_handler_unregister(bat_priv
, BATADV_TVLV_MCAST
, 2);
2288 /* safely calling outside of worker, as worker was canceled above */
2289 batadv_mcast_mla_tt_retract(bat_priv
, NULL
);
2293 * batadv_mcast_purge_orig() - reset originator global mcast state modifications
2294 * @orig: the originator which is going to get purged
2296 void batadv_mcast_purge_orig(struct batadv_orig_node
*orig
)
2298 struct batadv_priv
*bat_priv
= orig
->bat_priv
;
2300 spin_lock_bh(&orig
->mcast_handler_lock
);
2302 batadv_mcast_want_unsnoop_update(bat_priv
, orig
, BATADV_NO_FLAGS
);
2303 batadv_mcast_want_ipv4_update(bat_priv
, orig
, BATADV_NO_FLAGS
);
2304 batadv_mcast_want_ipv6_update(bat_priv
, orig
, BATADV_NO_FLAGS
);
2305 batadv_mcast_want_rtr4_update(bat_priv
, orig
,
2306 BATADV_MCAST_WANT_NO_RTR4
);
2307 batadv_mcast_want_rtr6_update(bat_priv
, orig
,
2308 BATADV_MCAST_WANT_NO_RTR6
);
2310 spin_unlock_bh(&orig
->mcast_handler_lock
);