Blame view
net/batman-adv/multicast.c
41 KB
ac79cbb96 batman-adv: updat... |
1 |
/* Copyright (C) 2014-2017 B.A.T.M.A.N. contributors: |
c5caf4ef3 batman-adv: Multi... |
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
* * Linus Lüssing * * This program is free software; you can redistribute it and/or * modify it under the terms of version 2 of the GNU General Public * License as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, see <http://www.gnu.org/licenses/>. */ |
c5caf4ef3 batman-adv: Multi... |
17 |
#include "multicast.h" |
1e2c2a4fe batman-adv: Add r... |
18 19 20 |
#include "main.h" #include <linux/atomic.h> |
9c936e3f4 batman-adv: Make ... |
21 |
#include <linux/bitops.h> |
8a4023c5b batman-adv: Fix p... |
22 |
#include <linux/bug.h> |
1e2c2a4fe batman-adv: Add r... |
23 24 25 26 |
#include <linux/byteorder/generic.h> #include <linux/errno.h> #include <linux/etherdevice.h> #include <linux/fs.h> |
bd2a979e5 batman-adv: Alway... |
27 |
#include <linux/icmpv6.h> |
687937ab3 batman-adv: Add m... |
28 |
#include <linux/if_bridge.h> |
1e2c2a4fe batman-adv: Add r... |
29 |
#include <linux/if_ether.h> |
bd2a979e5 batman-adv: Alway... |
30 |
#include <linux/igmp.h> |
1e2c2a4fe batman-adv: Add r... |
31 |
#include <linux/in.h> |
bd2a979e5 batman-adv: Alway... |
32 |
#include <linux/in6.h> |
1e2c2a4fe batman-adv: Add r... |
33 34 |
#include <linux/ip.h> #include <linux/ipv6.h> |
cbebd363b batman-adv: Use o... |
35 |
#include <linux/jiffies.h> |
72f7b2dea batman-adv: Addin... |
36 |
#include <linux/kernel.h> |
7c1243911 batman-adv: Conve... |
37 |
#include <linux/kref.h> |
1e2c2a4fe batman-adv: Add r... |
38 |
#include <linux/list.h> |
2c72d655b batman-adv: Annot... |
39 |
#include <linux/lockdep.h> |
1e2c2a4fe batman-adv: Add r... |
40 |
#include <linux/netdevice.h> |
687937ab3 batman-adv: Add m... |
41 |
#include <linux/printk.h> |
1e2c2a4fe batman-adv: Add r... |
42 43 |
#include <linux/rculist.h> #include <linux/rcupdate.h> |
4e3e823b5 batman-adv: Add d... |
44 |
#include <linux/seq_file.h> |
1e2c2a4fe batman-adv: Add r... |
45 46 47 48 49 50 |
#include <linux/skbuff.h> #include <linux/slab.h> #include <linux/spinlock.h> #include <linux/stddef.h> #include <linux/string.h> #include <linux/types.h> |
cbebd363b batman-adv: Use o... |
51 |
#include <linux/workqueue.h> |
1e2c2a4fe batman-adv: Add r... |
52 |
#include <net/addrconf.h> |
687937ab3 batman-adv: Add m... |
53 54 |
#include <net/if_inet6.h> #include <net/ip.h> |
1e2c2a4fe batman-adv: Add r... |
55 |
#include <net/ipv6.h> |
4e3e823b5 batman-adv: Add d... |
56 57 |
#include "hard-interface.h" #include "hash.h" |
ba412080f batman-adv: Conso... |
58 |
#include "log.h" |
1e2c2a4fe batman-adv: Add r... |
59 |
#include "packet.h" |
c5caf4ef3 batman-adv: Multi... |
60 |
#include "translation-table.h" |
1f8dce499 batman-adv: split... |
61 |
#include "tvlv.h" |
c5caf4ef3 batman-adv: Multi... |
62 |
|
cbebd363b batman-adv: Use o... |
63 64 65 66 67 68 69 70 71 72 73 |
static void batadv_mcast_mla_update(struct work_struct *work); /** * batadv_mcast_start_timer - schedule the multicast periodic worker * @bat_priv: the bat priv with all the soft interface information */ static void batadv_mcast_start_timer(struct batadv_priv *bat_priv) { queue_delayed_work(batadv_event_workqueue, &bat_priv->mcast.work, msecs_to_jiffies(BATADV_MCAST_WORK_PERIOD)); } |
c5caf4ef3 batman-adv: Multi... |
74 |
/** |
687937ab3 batman-adv: Add m... |
75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 |
* batadv_mcast_get_bridge - get the bridge on top of the softif if it exists * @soft_iface: netdev struct of the mesh interface * * If the given soft interface has a bridge on top then the refcount * of the according net device is increased. * * Return: NULL if no such bridge exists. Otherwise the net device of the * bridge. */ static struct net_device *batadv_mcast_get_bridge(struct net_device *soft_iface) { struct net_device *upper = soft_iface; rcu_read_lock(); do { upper = netdev_master_upper_dev_get_rcu(upper); } while (upper && !(upper->priv_flags & IFF_EBRIDGE)); if (upper) dev_hold(upper); rcu_read_unlock(); return upper; } /** |
c5caf4ef3 batman-adv: Multi... |
101 102 103 104 |
* batadv_mcast_mla_softif_get - get softif multicast listeners * @dev: the device to collect multicast addresses from * @mcast_list: a list to put found addresses into * |
687937ab3 batman-adv: Add m... |
105 106 107 108 109 110 111 112 113 |
* Collects multicast addresses of multicast listeners residing * on this kernel on the given soft interface, dev, in * the given mcast_list. In general, multicast listeners provided by * your multicast receiving applications run directly on this node. * * If there is a bridge interface on top of dev, collects from that one * instead. Just like with IP addresses and routes, multicast listeners * will(/should) register to the bridge interface instead of an * enslaved bat0. |
c5caf4ef3 batman-adv: Multi... |
114 |
* |
62fe710f6 batman-adv: Fix k... |
115 |
* Return: -ENOMEM on memory allocation error or the number of |
c5caf4ef3 batman-adv: Multi... |
116 117 118 119 120 |
* items added to the mcast_list otherwise. */ static int batadv_mcast_mla_softif_get(struct net_device *dev, struct hlist_head *mcast_list) { |
687937ab3 batman-adv: Add m... |
121 |
struct net_device *bridge = batadv_mcast_get_bridge(dev); |
c5caf4ef3 batman-adv: Multi... |
122 123 124 |
struct netdev_hw_addr *mc_list_entry; struct batadv_hw_addr *new; int ret = 0; |
687937ab3 batman-adv: Add m... |
125 126 |
netif_addr_lock_bh(bridge ? bridge : dev); netdev_for_each_mc_addr(mc_list_entry, bridge ? bridge : dev) { |
c5caf4ef3 batman-adv: Multi... |
127 128 129 130 131 132 133 134 135 136 |
new = kmalloc(sizeof(*new), GFP_ATOMIC); if (!new) { ret = -ENOMEM; break; } ether_addr_copy(new->addr, mc_list_entry->addr); hlist_add_head(&new->list, mcast_list); ret++; } |
687937ab3 batman-adv: Add m... |
137 138 139 140 |
netif_addr_unlock_bh(bridge ? bridge : dev); if (bridge) dev_put(bridge); |
c5caf4ef3 batman-adv: Multi... |
141 142 143 144 145 146 147 148 149 |
return ret; } /** * batadv_mcast_mla_is_duplicate - check whether an address is in a list * @mcast_addr: the multicast address to check * @mcast_list: the list with multicast addresses to search in * |
62fe710f6 batman-adv: Fix k... |
150 |
* Return: true if the given address is already in the given list. |
c5caf4ef3 batman-adv: Multi... |
151 152 |
* Otherwise returns false. */ |
6b5e971a2 batman-adv: Repla... |
153 |
static bool batadv_mcast_mla_is_duplicate(u8 *mcast_addr, |
c5caf4ef3 batman-adv: Multi... |
154 155 156 157 158 159 160 161 162 163 164 165 |
struct hlist_head *mcast_list) { struct batadv_hw_addr *mcast_entry; hlist_for_each_entry(mcast_entry, mcast_list, list) if (batadv_compare_eth(mcast_entry->addr, mcast_addr)) return true; return false; } /** |
687937ab3 batman-adv: Add m... |
166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 |
* batadv_mcast_mla_br_addr_cpy - copy a bridge multicast address * @dst: destination to write to - a multicast MAC address * @src: source to read from - a multicast IP address * * Converts a given multicast IPv4/IPv6 address from a bridge * to its matching multicast MAC address and copies it into the given * destination buffer. * * Caller needs to make sure the destination buffer can hold * at least ETH_ALEN bytes. */ static void batadv_mcast_mla_br_addr_cpy(char *dst, const struct br_ip *src) { if (src->proto == htons(ETH_P_IP)) ip_eth_mc_map(src->u.ip4, dst); #if IS_ENABLED(CONFIG_IPV6) else if (src->proto == htons(ETH_P_IPV6)) ipv6_eth_mc_map(&src->u.ip6, dst); #endif else eth_zero_addr(dst); } /** * batadv_mcast_mla_bridge_get - get bridged-in multicast listeners * @dev: a bridge slave whose bridge to collect multicast addresses from * @mcast_list: a list to put found addresses into * * Collects multicast addresses of multicast listeners residing * on foreign, non-mesh devices which we gave access to our mesh via * a bridge on top of the given soft interface, dev, in the given * mcast_list. * * Return: -ENOMEM on memory allocation error or the number of * items added to the mcast_list otherwise. */ static int batadv_mcast_mla_bridge_get(struct net_device *dev, struct hlist_head *mcast_list) { struct list_head bridge_mcast_list = LIST_HEAD_INIT(bridge_mcast_list); struct br_ip_list *br_ip_entry, *tmp; struct batadv_hw_addr *new; u8 mcast_addr[ETH_ALEN]; int ret; /* we don't need to detect these devices/listeners, the IGMP/MLD * snooping code of the Linux bridge already does that for us */ ret = br_multicast_list_adjacent(dev, &bridge_mcast_list); if (ret < 0) goto out; list_for_each_entry(br_ip_entry, &bridge_mcast_list, list) { batadv_mcast_mla_br_addr_cpy(mcast_addr, &br_ip_entry->addr); if (batadv_mcast_mla_is_duplicate(mcast_addr, mcast_list)) continue; new = kmalloc(sizeof(*new), GFP_ATOMIC); if (!new) { ret = -ENOMEM; break; } ether_addr_copy(new->addr, mcast_addr); hlist_add_head(&new->list, mcast_list); } out: list_for_each_entry_safe(br_ip_entry, tmp, &bridge_mcast_list, list) { list_del(&br_ip_entry->list); kfree(br_ip_entry); } return ret; } /** |
c5caf4ef3 batman-adv: Multi... |
243 244 245 246 247 |
* batadv_mcast_mla_list_free - free a list of multicast addresses * @mcast_list: the list to free * * Removes and frees all items in the given mcast_list. */ |
b77697633 batman-adv: Remov... |
248 |
static void batadv_mcast_mla_list_free(struct hlist_head *mcast_list) |
c5caf4ef3 batman-adv: Multi... |
249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 |
{ struct batadv_hw_addr *mcast_entry; struct hlist_node *tmp; hlist_for_each_entry_safe(mcast_entry, tmp, mcast_list, list) { hlist_del(&mcast_entry->list); kfree(mcast_entry); } } /** * batadv_mcast_mla_tt_retract - clean up multicast listener announcements * @bat_priv: the bat priv with all the soft interface information * @mcast_list: a list of addresses which should _not_ be removed * * Retracts the announcement of any multicast listener from the * translation table except the ones listed in the given mcast_list. * * If mcast_list is NULL then all are retracted. |
cbebd363b batman-adv: Use o... |
268 269 |
* * Do not call outside of the mcast worker! (or cancel mcast worker first) |
c5caf4ef3 batman-adv: Multi... |
270 271 272 273 274 275 |
*/ static void batadv_mcast_mla_tt_retract(struct batadv_priv *bat_priv, struct hlist_head *mcast_list) { struct batadv_hw_addr *mcast_entry; struct hlist_node *tmp; |
cbebd363b batman-adv: Use o... |
276 |
WARN_ON(delayed_work_pending(&bat_priv->mcast.work)); |
2c72d655b batman-adv: Annot... |
277 |
|
c5caf4ef3 batman-adv: Multi... |
278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 |
hlist_for_each_entry_safe(mcast_entry, tmp, &bat_priv->mcast.mla_list, list) { if (mcast_list && batadv_mcast_mla_is_duplicate(mcast_entry->addr, mcast_list)) continue; batadv_tt_local_remove(bat_priv, mcast_entry->addr, BATADV_NO_FLAGS, "mcast TT outdated", false); hlist_del(&mcast_entry->list); kfree(mcast_entry); } } /** * batadv_mcast_mla_tt_add - add multicast listener announcements * @bat_priv: the bat priv with all the soft interface information * @mcast_list: a list of addresses which are going to get added * * Adds multicast listener announcements from the given mcast_list to the * translation table if they have not been added yet. |
cbebd363b batman-adv: Use o... |
301 302 |
* * Do not call outside of the mcast worker! (or cancel mcast worker first) |
c5caf4ef3 batman-adv: Multi... |
303 304 305 306 307 308 |
*/ static void batadv_mcast_mla_tt_add(struct batadv_priv *bat_priv, struct hlist_head *mcast_list) { struct batadv_hw_addr *mcast_entry; struct hlist_node *tmp; |
cbebd363b batman-adv: Use o... |
309 |
WARN_ON(delayed_work_pending(&bat_priv->mcast.work)); |
2c72d655b batman-adv: Annot... |
310 |
|
c5caf4ef3 batman-adv: Multi... |
311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 |
if (!mcast_list) return; hlist_for_each_entry_safe(mcast_entry, tmp, mcast_list, list) { if (batadv_mcast_mla_is_duplicate(mcast_entry->addr, &bat_priv->mcast.mla_list)) continue; if (!batadv_tt_local_add(bat_priv->soft_iface, mcast_entry->addr, BATADV_NO_FLAGS, BATADV_NULL_IFINDEX, BATADV_NO_MARK)) continue; hlist_del(&mcast_entry->list); hlist_add_head(&mcast_entry->list, &bat_priv->mcast.mla_list); } } /** * batadv_mcast_has_bridge - check whether the soft-iface is bridged * @bat_priv: the bat priv with all the soft interface information * |
62fe710f6 batman-adv: Fix k... |
333 334 335 |
* Checks whether there is a bridge on top of our soft interface. * * Return: true if there is a bridge, false otherwise. |
c5caf4ef3 batman-adv: Multi... |
336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 |
*/ static bool batadv_mcast_has_bridge(struct batadv_priv *bat_priv) { struct net_device *upper = bat_priv->soft_iface; rcu_read_lock(); do { upper = netdev_master_upper_dev_get_rcu(upper); } while (upper && !(upper->priv_flags & IFF_EBRIDGE)); rcu_read_unlock(); return upper; } /** |
72f7b2dea batman-adv: Addin... |
351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 |
* batadv_mcast_querier_log - debug output regarding the querier status on link * @bat_priv: the bat priv with all the soft interface information * @str_proto: a string for the querier protocol (e.g. "IGMP" or "MLD") * @old_state: the previous querier state on our link * @new_state: the new querier state on our link * * Outputs debug messages to the logging facility with log level 'mcast' * regarding changes to the querier status on the link which are relevant * to our multicast optimizations. * * Usually this is about whether a querier appeared or vanished in * our mesh or whether the querier is in the suboptimal position of being * behind our local bridge segment: Snooping switches will directly * forward listener reports to the querier, therefore batman-adv and * the bridge will potentially not see these listeners - the querier is * potentially shadowing listeners from us then. * * This is only interesting for nodes with a bridge on top of their * soft interface. */ static void batadv_mcast_querier_log(struct batadv_priv *bat_priv, char *str_proto, struct batadv_mcast_querier_state *old_state, struct batadv_mcast_querier_state *new_state) { if (!old_state->exists && new_state->exists) batadv_info(bat_priv->soft_iface, "%s Querier appeared ", str_proto); else if (old_state->exists && !new_state->exists) batadv_info(bat_priv->soft_iface, "%s Querier disappeared - multicast optimizations disabled ", str_proto); else if (!bat_priv->mcast.bridged && !new_state->exists) batadv_info(bat_priv->soft_iface, "No %s Querier present - multicast optimizations disabled ", str_proto); if (new_state->exists) { if ((!old_state->shadowing && new_state->shadowing) || (!old_state->exists && new_state->shadowing)) batadv_dbg(BATADV_DBG_MCAST, bat_priv, "%s Querier is behind our bridged segment: Might shadow listeners ", str_proto); else if (old_state->shadowing && !new_state->shadowing) batadv_dbg(BATADV_DBG_MCAST, bat_priv, "%s Querier is not behind our bridged segment ", str_proto); } } /** * batadv_mcast_bridge_log - debug output for topology changes in bridged setups * @bat_priv: the bat priv with all the soft interface information * @bridged: a flag about whether the soft interface is currently bridged or not * @querier_ipv4: (maybe) new status of a potential, selected IGMP querier * @querier_ipv6: (maybe) new status of a potential, selected MLD querier * * If no bridges are ever used on this node, then this function does nothing. * * Otherwise this function outputs debug information to the 'mcast' log level * which might be relevant to our multicast optimizations. * * More precisely, it outputs information when a bridge interface is added or * removed from a soft interface. And when a bridge is present, it further * outputs information about the querier state which is relevant for the * multicast flags this node is going to set. */ static void batadv_mcast_bridge_log(struct batadv_priv *bat_priv, bool bridged, struct batadv_mcast_querier_state *querier_ipv4, struct batadv_mcast_querier_state *querier_ipv6) { if (!bat_priv->mcast.bridged && bridged) batadv_dbg(BATADV_DBG_MCAST, bat_priv, "Bridge added: Setting Unsnoopables(U)-flag "); else if (bat_priv->mcast.bridged && !bridged) batadv_dbg(BATADV_DBG_MCAST, bat_priv, "Bridge removed: Unsetting Unsnoopables(U)-flag "); if (bridged) { batadv_mcast_querier_log(bat_priv, "IGMP", &bat_priv->mcast.querier_ipv4, querier_ipv4); batadv_mcast_querier_log(bat_priv, "MLD", &bat_priv->mcast.querier_ipv6, querier_ipv6); } } /** * batadv_mcast_flags_logs - output debug information about mcast flag changes * @bat_priv: the bat priv with all the soft interface information * @flags: flags indicating the new multicast state * * Whenever the multicast flags this nodes announces changes (@mcast_flags vs. * bat_priv->mcast.flags), this notifies userspace via the 'mcast' log level. */ static void batadv_mcast_flags_log(struct batadv_priv *bat_priv, u8 flags) { u8 old_flags = bat_priv->mcast.flags; char str_old_flags[] = "[...]"; sprintf(str_old_flags, "[%c%c%c]", (old_flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES) ? 'U' : '.', (old_flags & BATADV_MCAST_WANT_ALL_IPV4) ? '4' : '.', (old_flags & BATADV_MCAST_WANT_ALL_IPV6) ? '6' : '.'); batadv_dbg(BATADV_DBG_MCAST, bat_priv, "Changing multicast flags from '%s' to '[%c%c%c]' ", bat_priv->mcast.enabled ? str_old_flags : "<undefined>", (flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES) ? 'U' : '.', (flags & BATADV_MCAST_WANT_ALL_IPV4) ? '4' : '.', (flags & BATADV_MCAST_WANT_ALL_IPV6) ? '6' : '.'); } /** |
60432d756 batman-adv: Annou... |
475 476 477 478 479 480 |
* batadv_mcast_mla_tvlv_update - update multicast tvlv * @bat_priv: the bat priv with all the soft interface information * * Updates the own multicast tvlv with our current multicast related settings, * capabilities and inabilities. * |
687937ab3 batman-adv: Add m... |
481 482 |
* Return: false if we want all IPv4 && IPv6 multicast traffic and true * otherwise. |
60432d756 batman-adv: Annou... |
483 484 485 486 |
*/ static bool batadv_mcast_mla_tvlv_update(struct batadv_priv *bat_priv) { struct batadv_tvlv_mcast_data mcast_data; |
687937ab3 batman-adv: Add m... |
487 488 489 |
struct batadv_mcast_querier_state querier4 = {false, false}; struct batadv_mcast_querier_state querier6 = {false, false}; struct net_device *dev = bat_priv->soft_iface; |
72f7b2dea batman-adv: Addin... |
490 |
bool bridged; |
60432d756 batman-adv: Annou... |
491 492 493 |
mcast_data.flags = BATADV_NO_FLAGS; memset(mcast_data.reserved, 0, sizeof(mcast_data.reserved)); |
72f7b2dea batman-adv: Addin... |
494 495 |
bridged = batadv_mcast_has_bridge(bat_priv); if (!bridged) |
687937ab3 batman-adv: Add m... |
496 |
goto update; |
c1bacea05 batman-adv: Reduc... |
497 498 499 |
if (!IS_ENABLED(CONFIG_BRIDGE_IGMP_SNOOPING)) pr_warn_once("No bridge IGMP snooping compiled - multicast optimizations disabled "); |
687937ab3 batman-adv: Add m... |
500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 |
querier4.exists = br_multicast_has_querier_anywhere(dev, ETH_P_IP); querier4.shadowing = br_multicast_has_querier_adjacent(dev, ETH_P_IP); querier6.exists = br_multicast_has_querier_anywhere(dev, ETH_P_IPV6); querier6.shadowing = br_multicast_has_querier_adjacent(dev, ETH_P_IPV6); mcast_data.flags |= BATADV_MCAST_WANT_ALL_UNSNOOPABLES; /* 1) If no querier exists at all, then multicast listeners on * our local TT clients behind the bridge will keep silent. * 2) If the selected querier is on one of our local TT clients, * behind the bridge, then this querier might shadow multicast * listeners on our local TT clients, behind this bridge. * * In both cases, we will signalize other batman nodes that * we need all multicast traffic of the according protocol. |
60432d756 batman-adv: Annou... |
517 |
*/ |
687937ab3 batman-adv: Add m... |
518 519 |
if (!querier4.exists || querier4.shadowing) mcast_data.flags |= BATADV_MCAST_WANT_ALL_IPV4; |
60432d756 batman-adv: Annou... |
520 |
|
687937ab3 batman-adv: Add m... |
521 522 |
if (!querier6.exists || querier6.shadowing) mcast_data.flags |= BATADV_MCAST_WANT_ALL_IPV6; |
60432d756 batman-adv: Annou... |
523 |
|
687937ab3 batman-adv: Add m... |
524 |
update: |
72f7b2dea batman-adv: Addin... |
525 526 527 528 529 530 531 532 533 |
batadv_mcast_bridge_log(bat_priv, bridged, &querier4, &querier6); bat_priv->mcast.querier_ipv4.exists = querier4.exists; bat_priv->mcast.querier_ipv4.shadowing = querier4.shadowing; bat_priv->mcast.querier_ipv6.exists = querier6.exists; bat_priv->mcast.querier_ipv6.shadowing = querier6.shadowing; bat_priv->mcast.bridged = bridged; |
60432d756 batman-adv: Annou... |
534 535 |
if (!bat_priv->mcast.enabled || mcast_data.flags != bat_priv->mcast.flags) { |
72f7b2dea batman-adv: Addin... |
536 |
batadv_mcast_flags_log(bat_priv, mcast_data.flags); |
bd2a979e5 batman-adv: Alway... |
537 |
batadv_tvlv_container_register(bat_priv, BATADV_TVLV_MCAST, 2, |
60432d756 batman-adv: Annou... |
538 539 540 541 |
&mcast_data, sizeof(mcast_data)); bat_priv->mcast.flags = mcast_data.flags; bat_priv->mcast.enabled = true; } |
5f8156fd3 batman-adv: Fix m... |
542 543 |
return !(mcast_data.flags & BATADV_MCAST_WANT_ALL_IPV4 && mcast_data.flags & BATADV_MCAST_WANT_ALL_IPV6); |
60432d756 batman-adv: Annou... |
544 545 546 |
} /** |
cbebd363b batman-adv: Use o... |
547 |
* __batadv_mcast_mla_update - update the own MLAs |
c5caf4ef3 batman-adv: Multi... |
548 549 |
* @bat_priv: the bat priv with all the soft interface information * |
60432d756 batman-adv: Annou... |
550 551 |
* Updates the own multicast listener announcements in the translation * table as well as the own, announced multicast tvlv container. |
cbebd363b batman-adv: Use o... |
552 553 554 555 556 |
* * Note that non-conflicting reads and writes to bat_priv->mcast.mla_list * in batadv_mcast_mla_tt_retract() and batadv_mcast_mla_tt_add() are * ensured by the non-parallel execution of the worker this function * belongs to. |
c5caf4ef3 batman-adv: Multi... |
557 |
*/ |
cbebd363b batman-adv: Use o... |
558 |
static void __batadv_mcast_mla_update(struct batadv_priv *bat_priv) |
c5caf4ef3 batman-adv: Multi... |
559 560 561 562 |
{ struct net_device *soft_iface = bat_priv->soft_iface; struct hlist_head mcast_list = HLIST_HEAD_INIT; int ret; |
60432d756 batman-adv: Annou... |
563 |
if (!batadv_mcast_mla_tvlv_update(bat_priv)) |
c5caf4ef3 batman-adv: Multi... |
564 565 566 567 568 |
goto update; ret = batadv_mcast_mla_softif_get(soft_iface, &mcast_list); if (ret < 0) goto out; |
687937ab3 batman-adv: Add m... |
569 570 571 |
ret = batadv_mcast_mla_bridge_get(soft_iface, &mcast_list); if (ret < 0) goto out; |
c5caf4ef3 batman-adv: Multi... |
572 573 574 575 576 |
update: batadv_mcast_mla_tt_retract(bat_priv, &mcast_list); batadv_mcast_mla_tt_add(bat_priv, &mcast_list); out: |
b77697633 batman-adv: Remov... |
577 |
batadv_mcast_mla_list_free(&mcast_list); |
c5caf4ef3 batman-adv: Multi... |
578 579 580 |
} /** |
cbebd363b batman-adv: Use o... |
581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 |
* batadv_mcast_mla_update - update the own MLAs * @work: kernel work struct * * Updates the own multicast listener announcements in the translation * table as well as the own, announced multicast tvlv container. * * In the end, reschedules the work timer. */ static void batadv_mcast_mla_update(struct work_struct *work) { struct delayed_work *delayed_work; struct batadv_priv_mcast *priv_mcast; struct batadv_priv *bat_priv; delayed_work = to_delayed_work(work); priv_mcast = container_of(delayed_work, struct batadv_priv_mcast, work); bat_priv = container_of(priv_mcast, struct batadv_priv, mcast); __batadv_mcast_mla_update(bat_priv); batadv_mcast_start_timer(bat_priv); } /** |
bd2a979e5 batman-adv: Alway... |
604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 |
* batadv_mcast_is_report_ipv4 - check for IGMP reports * @skb: the ethernet frame destined for the mesh * * This call might reallocate skb data. * * Checks whether the given frame is a valid IGMP report. * * Return: If so then true, otherwise false. */ static bool batadv_mcast_is_report_ipv4(struct sk_buff *skb) { if (ip_mc_check_igmp(skb, NULL) < 0) return false; switch (igmp_hdr(skb)->type) { case IGMP_HOST_MEMBERSHIP_REPORT: case IGMPV2_HOST_MEMBERSHIP_REPORT: case IGMPV3_HOST_MEMBERSHIP_REPORT: return true; } return false; } /** |
ab49886e3 batman-adv: Add I... |
629 630 631 632 633 634 635 636 |
* batadv_mcast_forw_mode_check_ipv4 - check for optimized forwarding potential * @bat_priv: the bat priv with all the soft interface information * @skb: the IPv4 packet to check * @is_unsnoopable: stores whether the destination is snoopable * * Checks whether the given IPv4 packet has the potential to be forwarded with a * mode more optimal than classic flooding. * |
62fe710f6 batman-adv: Fix k... |
637 638 |
* Return: If so then 0. Otherwise -EINVAL or -ENOMEM in case of memory * allocation failure. |
ab49886e3 batman-adv: Add I... |
639 640 641 642 643 644 645 646 647 648 |
*/ static int batadv_mcast_forw_mode_check_ipv4(struct batadv_priv *bat_priv, struct sk_buff *skb, bool *is_unsnoopable) { struct iphdr *iphdr; /* We might fail due to out-of-memory -> drop it */ if (!pskb_may_pull(skb, sizeof(struct ethhdr) + sizeof(*iphdr))) return -ENOMEM; |
bd2a979e5 batman-adv: Alway... |
649 650 |
if (batadv_mcast_is_report_ipv4(skb)) return -EINVAL; |
ab49886e3 batman-adv: Add I... |
651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 |
iphdr = ip_hdr(skb); /* TODO: Implement Multicast Router Discovery (RFC4286), * then allow scope > link local, too */ if (!ipv4_is_local_multicast(iphdr->daddr)) return -EINVAL; /* link-local multicast listeners behind a bridge are * not snoopable (see RFC4541, section 2.1.2.2) */ *is_unsnoopable = true; return 0; } |
bd2a979e5 batman-adv: Alway... |
666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 |
/** * batadv_mcast_is_report_ipv6 - check for MLD reports * @skb: the ethernet frame destined for the mesh * * This call might reallocate skb data. * * Checks whether the given frame is a valid MLD report. * * Return: If so then true, otherwise false. */ static bool batadv_mcast_is_report_ipv6(struct sk_buff *skb) { if (ipv6_mc_check_mld(skb, NULL) < 0) return false; switch (icmp6_hdr(skb)->icmp6_type) { case ICMPV6_MGM_REPORT: case ICMPV6_MLD2_REPORT: return true; } return false; } |
ab49886e3 batman-adv: Add I... |
689 |
/** |
1d8ab8d3c batman-adv: Modif... |
690 691 692 |
* batadv_mcast_forw_mode_check_ipv6 - check for optimized forwarding potential * @bat_priv: the bat priv with all the soft interface information * @skb: the IPv6 packet to check |
ab49886e3 batman-adv: Add I... |
693 |
* @is_unsnoopable: stores whether the destination is snoopable |
1d8ab8d3c batman-adv: Modif... |
694 695 696 697 |
* * Checks whether the given IPv6 packet has the potential to be forwarded with a * mode more optimal than classic flooding. * |
62fe710f6 batman-adv: Fix k... |
698 |
* Return: If so then 0. Otherwise -EINVAL is or -ENOMEM if we are out of memory |
1d8ab8d3c batman-adv: Modif... |
699 700 |
*/ static int batadv_mcast_forw_mode_check_ipv6(struct batadv_priv *bat_priv, |
ab49886e3 batman-adv: Add I... |
701 702 |
struct sk_buff *skb, bool *is_unsnoopable) |
1d8ab8d3c batman-adv: Modif... |
703 704 705 706 707 708 |
{ struct ipv6hdr *ip6hdr; /* We might fail due to out-of-memory -> drop it */ if (!pskb_may_pull(skb, sizeof(struct ethhdr) + sizeof(*ip6hdr))) return -ENOMEM; |
bd2a979e5 batman-adv: Alway... |
709 710 |
if (batadv_mcast_is_report_ipv6(skb)) return -EINVAL; |
1d8ab8d3c batman-adv: Modif... |
711 712 713 714 715 716 717 718 719 720 721 722 |
ip6hdr = ipv6_hdr(skb); /* TODO: Implement Multicast Router Discovery (RFC4286), * then allow scope > link local, too */ if (IPV6_ADDR_MC_SCOPE(&ip6hdr->daddr) != IPV6_ADDR_SCOPE_LINKLOCAL) return -EINVAL; /* link-local-all-nodes multicast listeners behind a bridge are * not snoopable (see RFC4541, section 3, paragraph 3) */ if (ipv6_addr_is_ll_all_nodes(&ip6hdr->daddr)) |
ab49886e3 batman-adv: Add I... |
723 |
*is_unsnoopable = true; |
1d8ab8d3c batman-adv: Modif... |
724 725 726 727 728 729 730 731 |
return 0; } /** * batadv_mcast_forw_mode_check - check for optimized forwarding potential * @bat_priv: the bat priv with all the soft interface information * @skb: the multicast frame to check |
ab49886e3 batman-adv: Add I... |
732 |
* @is_unsnoopable: stores whether the destination is snoopable |
1d8ab8d3c batman-adv: Modif... |
733 734 735 736 |
* * Checks whether the given multicast ethernet frame has the potential to be * forwarded with a mode more optimal than classic flooding. * |
62fe710f6 batman-adv: Fix k... |
737 |
* Return: If so then 0. Otherwise -EINVAL is or -ENOMEM if we are out of memory |
1d8ab8d3c batman-adv: Modif... |
738 739 |
*/ static int batadv_mcast_forw_mode_check(struct batadv_priv *bat_priv, |
ab49886e3 batman-adv: Add I... |
740 741 |
struct sk_buff *skb, bool *is_unsnoopable) |
1d8ab8d3c batman-adv: Modif... |
742 743 744 745 746 747 748 749 750 751 |
{ struct ethhdr *ethhdr = eth_hdr(skb); if (!atomic_read(&bat_priv->multicast_mode)) return -EINVAL; if (atomic_read(&bat_priv->mcast.num_disabled)) return -EINVAL; switch (ntohs(ethhdr->h_proto)) { |
ab49886e3 batman-adv: Add I... |
752 753 754 |
case ETH_P_IP: return batadv_mcast_forw_mode_check_ipv4(bat_priv, skb, is_unsnoopable); |
1d8ab8d3c batman-adv: Modif... |
755 |
case ETH_P_IPV6: |
c1bacea05 batman-adv: Reduc... |
756 757 |
if (!IS_ENABLED(CONFIG_IPV6)) return -EINVAL; |
ab49886e3 batman-adv: Add I... |
758 759 |
return batadv_mcast_forw_mode_check_ipv6(bat_priv, skb, is_unsnoopable); |
1d8ab8d3c batman-adv: Modif... |
760 761 762 763 764 765 |
default: return -EINVAL; } } /** |
6d030de89 batman-adv: fix w... |
766 767 |
* batadv_mcast_forw_want_all_ip_count - count nodes with unspecific mcast * interest |
4c8755d69 batman-adv: Send ... |
768 769 770 |
* @bat_priv: the bat priv with all the soft interface information * @ethhdr: ethernet header of a packet * |
62fe710f6 batman-adv: Fix k... |
771 |
* Return: the number of nodes which want all IPv4 multicast traffic if the |
4c8755d69 batman-adv: Send ... |
772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 |
* given ethhdr is from an IPv4 packet or the number of nodes which want all * IPv6 traffic if it matches an IPv6 packet. */ static int batadv_mcast_forw_want_all_ip_count(struct batadv_priv *bat_priv, struct ethhdr *ethhdr) { switch (ntohs(ethhdr->h_proto)) { case ETH_P_IP: return atomic_read(&bat_priv->mcast.num_want_all_ipv4); case ETH_P_IPV6: return atomic_read(&bat_priv->mcast.num_want_all_ipv6); default: /* we shouldn't be here... */ return 0; } } /** |
1d8ab8d3c batman-adv: Modif... |
790 791 792 793 |
* batadv_mcast_forw_tt_node_get - get a multicast tt node * @bat_priv: the bat priv with all the soft interface information * @ethhdr: the ether header containing the multicast destination * |
62fe710f6 batman-adv: Fix k... |
794 |
* Return: an orig_node matching the multicast address provided by ethhdr |
1d8ab8d3c batman-adv: Modif... |
795 796 797 798 799 800 |
* via a translation table lookup. This increases the returned nodes refcount. */ static struct batadv_orig_node * batadv_mcast_forw_tt_node_get(struct batadv_priv *bat_priv, struct ethhdr *ethhdr) { |
110a7c19d batman-adv: fix m... |
801 802 |
return batadv_transtable_search(bat_priv, NULL, ethhdr->h_dest, BATADV_NO_FLAGS); |
1d8ab8d3c batman-adv: Modif... |
803 804 805 |
} /** |
6d030de89 batman-adv: fix w... |
806 |
* batadv_mcast_forw_ipv4_node_get - get a node with an ipv4 flag |
4c8755d69 batman-adv: Send ... |
807 808 |
* @bat_priv: the bat priv with all the soft interface information * |
62fe710f6 batman-adv: Fix k... |
809 |
* Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV4 flag set and |
4c8755d69 batman-adv: Send ... |
810 811 812 813 814 815 816 817 818 819 820 |
* increases its refcount. */ static struct batadv_orig_node * batadv_mcast_forw_ipv4_node_get(struct batadv_priv *bat_priv) { struct batadv_orig_node *tmp_orig_node, *orig_node = NULL; rcu_read_lock(); hlist_for_each_entry_rcu(tmp_orig_node, &bat_priv->mcast.want_all_ipv4_list, mcast_want_all_ipv4_node) { |
7c1243911 batman-adv: Conve... |
821 |
if (!kref_get_unless_zero(&tmp_orig_node->refcount)) |
4c8755d69 batman-adv: Send ... |
822 823 824 825 826 827 828 829 830 831 832 |
continue; orig_node = tmp_orig_node; break; } rcu_read_unlock(); return orig_node; } /** |
6d030de89 batman-adv: fix w... |
833 |
* batadv_mcast_forw_ipv6_node_get - get a node with an ipv6 flag |
4c8755d69 batman-adv: Send ... |
834 835 |
* @bat_priv: the bat priv with all the soft interface information * |
62fe710f6 batman-adv: Fix k... |
836 |
* Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV6 flag set |
4c8755d69 batman-adv: Send ... |
837 838 839 840 841 842 843 844 845 846 847 |
* and increases its refcount. */ static struct batadv_orig_node * batadv_mcast_forw_ipv6_node_get(struct batadv_priv *bat_priv) { struct batadv_orig_node *tmp_orig_node, *orig_node = NULL; rcu_read_lock(); hlist_for_each_entry_rcu(tmp_orig_node, &bat_priv->mcast.want_all_ipv6_list, mcast_want_all_ipv6_node) { |
7c1243911 batman-adv: Conve... |
848 |
if (!kref_get_unless_zero(&tmp_orig_node->refcount)) |
4c8755d69 batman-adv: Send ... |
849 850 851 852 853 854 855 856 857 858 859 |
continue; orig_node = tmp_orig_node; break; } rcu_read_unlock(); return orig_node; } /** |
6d030de89 batman-adv: fix w... |
860 |
* batadv_mcast_forw_ip_node_get - get a node with an ipv4/ipv6 flag |
4c8755d69 batman-adv: Send ... |
861 862 863 |
* @bat_priv: the bat priv with all the soft interface information * @ethhdr: an ethernet header to determine the protocol family from * |
62fe710f6 batman-adv: Fix k... |
864 |
* Return: an orig_node which has the BATADV_MCAST_WANT_ALL_IPV4 or |
4c8755d69 batman-adv: Send ... |
865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 |
* BATADV_MCAST_WANT_ALL_IPV6 flag, depending on the provided ethhdr, set and * increases its refcount. */ static struct batadv_orig_node * batadv_mcast_forw_ip_node_get(struct batadv_priv *bat_priv, struct ethhdr *ethhdr) { switch (ntohs(ethhdr->h_proto)) { case ETH_P_IP: return batadv_mcast_forw_ipv4_node_get(bat_priv); case ETH_P_IPV6: return batadv_mcast_forw_ipv6_node_get(bat_priv); default: /* we shouldn't be here... */ return NULL; } } /** |
6d030de89 batman-adv: fix w... |
884 |
* batadv_mcast_forw_unsnoop_node_get - get a node with an unsnoopable flag |
ab49886e3 batman-adv: Add I... |
885 886 |
* @bat_priv: the bat priv with all the soft interface information * |
62fe710f6 batman-adv: Fix k... |
887 |
* Return: an orig_node which has the BATADV_MCAST_WANT_ALL_UNSNOOPABLES flag |
ab49886e3 batman-adv: Add I... |
888 889 890 891 892 893 894 895 896 897 898 |
* set and increases its refcount. */ static struct batadv_orig_node * batadv_mcast_forw_unsnoop_node_get(struct batadv_priv *bat_priv) { struct batadv_orig_node *tmp_orig_node, *orig_node = NULL; rcu_read_lock(); hlist_for_each_entry_rcu(tmp_orig_node, &bat_priv->mcast.want_all_unsnoopables_list, mcast_want_all_unsnoopables_node) { |
7c1243911 batman-adv: Conve... |
899 |
if (!kref_get_unless_zero(&tmp_orig_node->refcount)) |
ab49886e3 batman-adv: Add I... |
900 901 902 903 904 905 906 907 908 909 910 |
continue; orig_node = tmp_orig_node; break; } rcu_read_unlock(); return orig_node; } /** |
1d8ab8d3c batman-adv: Modif... |
911 912 913 914 915 |
* batadv_mcast_forw_mode - check on how to forward a multicast packet * @bat_priv: the bat priv with all the soft interface information * @skb: The multicast packet to check * @orig: an originator to be set to forward the skb to * |
62fe710f6 batman-adv: Fix k... |
916 |
* Return: the forwarding mode as enum batadv_forw_mode and in case of |
1d8ab8d3c batman-adv: Modif... |
917 918 919 920 921 922 923 |
* BATADV_FORW_SINGLE set the orig to the single originator the skb * should be forwarded to. */ enum batadv_forw_mode batadv_mcast_forw_mode(struct batadv_priv *bat_priv, struct sk_buff *skb, struct batadv_orig_node **orig) { |
4c8755d69 batman-adv: Send ... |
924 |
int ret, tt_count, ip_count, unsnoop_count, total_count; |
ab49886e3 batman-adv: Add I... |
925 |
bool is_unsnoopable = false; |
1d8ab8d3c batman-adv: Modif... |
926 |
struct ethhdr *ethhdr; |
1d8ab8d3c batman-adv: Modif... |
927 |
|
ab49886e3 batman-adv: Add I... |
928 |
ret = batadv_mcast_forw_mode_check(bat_priv, skb, &is_unsnoopable); |
1d8ab8d3c batman-adv: Modif... |
929 930 931 932 933 934 935 936 937 |
if (ret == -ENOMEM) return BATADV_FORW_NONE; else if (ret < 0) return BATADV_FORW_ALL; ethhdr = eth_hdr(skb); tt_count = batadv_tt_global_hash_count(bat_priv, ethhdr->h_dest, BATADV_NO_FLAGS); |
4c8755d69 batman-adv: Send ... |
938 |
ip_count = batadv_mcast_forw_want_all_ip_count(bat_priv, ethhdr); |
ab49886e3 batman-adv: Add I... |
939 940 |
unsnoop_count = !is_unsnoopable ? 0 : atomic_read(&bat_priv->mcast.num_want_all_unsnoopables); |
4c8755d69 batman-adv: Send ... |
941 |
total_count = tt_count + ip_count + unsnoop_count; |
1d8ab8d3c batman-adv: Modif... |
942 |
|
ab49886e3 batman-adv: Add I... |
943 |
switch (total_count) { |
1d8ab8d3c batman-adv: Modif... |
944 |
case 1: |
ab49886e3 batman-adv: Add I... |
945 946 |
if (tt_count) *orig = batadv_mcast_forw_tt_node_get(bat_priv, ethhdr); |
4c8755d69 batman-adv: Send ... |
947 948 |
else if (ip_count) *orig = batadv_mcast_forw_ip_node_get(bat_priv, ethhdr); |
ab49886e3 batman-adv: Add I... |
949 950 |
else if (unsnoop_count) *orig = batadv_mcast_forw_unsnoop_node_get(bat_priv); |
1d8ab8d3c batman-adv: Modif... |
951 952 953 954 955 956 957 958 959 960 961 962 |
if (*orig) return BATADV_FORW_SINGLE; /* fall through */ case 0: return BATADV_FORW_NONE; default: return BATADV_FORW_ALL; } } /** |
ab49886e3 batman-adv: Add I... |
963 964 965 966 967 968 969 |
* batadv_mcast_want_unsnoop_update - update unsnoop counter and list * @bat_priv: the bat priv with all the soft interface information * @orig: the orig_node which multicast state might have changed of * @mcast_flags: flags indicating the new multicast state * * If the BATADV_MCAST_WANT_ALL_UNSNOOPABLES flag of this originator, * orig, has toggled then this method updates counter and list accordingly. |
8a4023c5b batman-adv: Fix p... |
970 971 |
* * Caller needs to hold orig->mcast_handler_lock. |
ab49886e3 batman-adv: Add I... |
972 973 974 |
*/ static void batadv_mcast_want_unsnoop_update(struct batadv_priv *bat_priv, struct batadv_orig_node *orig, |
6b5e971a2 batman-adv: Repla... |
975 |
u8 mcast_flags) |
ab49886e3 batman-adv: Add I... |
976 |
{ |
8a4023c5b batman-adv: Fix p... |
977 978 |
struct hlist_node *node = &orig->mcast_want_all_unsnoopables_node; struct hlist_head *head = &bat_priv->mcast.want_all_unsnoopables_list; |
5274cd68d batman-adv: Add l... |
979 |
lockdep_assert_held(&orig->mcast_handler_lock); |
ab49886e3 batman-adv: Add I... |
980 981 982 983 984 985 |
/* switched from flag unset to set */ if (mcast_flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES && !(orig->mcast_flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES)) { atomic_inc(&bat_priv->mcast.num_want_all_unsnoopables); spin_lock_bh(&bat_priv->mcast.want_lists_lock); |
8a4023c5b batman-adv: Fix p... |
986 987 988 989 |
/* flag checks above + mcast_handler_lock prevents this */ WARN_ON(!hlist_unhashed(node)); hlist_add_head_rcu(node, head); |
ab49886e3 batman-adv: Add I... |
990 991 992 993 994 995 996 |
spin_unlock_bh(&bat_priv->mcast.want_lists_lock); /* switched from flag set to unset */ } else if (!(mcast_flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES) && orig->mcast_flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES) { atomic_dec(&bat_priv->mcast.num_want_all_unsnoopables); spin_lock_bh(&bat_priv->mcast.want_lists_lock); |
8a4023c5b batman-adv: Fix p... |
997 998 999 1000 |
/* flag checks above + mcast_handler_lock prevents this */ WARN_ON(hlist_unhashed(node)); hlist_del_init_rcu(node); |
ab49886e3 batman-adv: Add I... |
1001 1002 1003 1004 1005 |
spin_unlock_bh(&bat_priv->mcast.want_lists_lock); } } /** |
4c8755d69 batman-adv: Send ... |
1006 1007 1008 1009 1010 1011 1012 |
* batadv_mcast_want_ipv4_update - update want-all-ipv4 counter and list * @bat_priv: the bat priv with all the soft interface information * @orig: the orig_node which multicast state might have changed of * @mcast_flags: flags indicating the new multicast state * * If the BATADV_MCAST_WANT_ALL_IPV4 flag of this originator, orig, has * toggled then this method updates counter and list accordingly. |
8a4023c5b batman-adv: Fix p... |
1013 1014 |
* * Caller needs to hold orig->mcast_handler_lock. |
4c8755d69 batman-adv: Send ... |
1015 1016 1017 |
*/ static void batadv_mcast_want_ipv4_update(struct batadv_priv *bat_priv, struct batadv_orig_node *orig, |
6b5e971a2 batman-adv: Repla... |
1018 |
u8 mcast_flags) |
4c8755d69 batman-adv: Send ... |
1019 |
{ |
8a4023c5b batman-adv: Fix p... |
1020 1021 |
struct hlist_node *node = &orig->mcast_want_all_ipv4_node; struct hlist_head *head = &bat_priv->mcast.want_all_ipv4_list; |
5274cd68d batman-adv: Add l... |
1022 |
lockdep_assert_held(&orig->mcast_handler_lock); |
4c8755d69 batman-adv: Send ... |
1023 1024 1025 1026 1027 1028 |
/* switched from flag unset to set */ if (mcast_flags & BATADV_MCAST_WANT_ALL_IPV4 && !(orig->mcast_flags & BATADV_MCAST_WANT_ALL_IPV4)) { atomic_inc(&bat_priv->mcast.num_want_all_ipv4); spin_lock_bh(&bat_priv->mcast.want_lists_lock); |
8a4023c5b batman-adv: Fix p... |
1029 1030 1031 1032 |
/* flag checks above + mcast_handler_lock prevents this */ WARN_ON(!hlist_unhashed(node)); hlist_add_head_rcu(node, head); |
4c8755d69 batman-adv: Send ... |
1033 1034 1035 1036 1037 1038 1039 |
spin_unlock_bh(&bat_priv->mcast.want_lists_lock); /* switched from flag set to unset */ } else if (!(mcast_flags & BATADV_MCAST_WANT_ALL_IPV4) && orig->mcast_flags & BATADV_MCAST_WANT_ALL_IPV4) { atomic_dec(&bat_priv->mcast.num_want_all_ipv4); spin_lock_bh(&bat_priv->mcast.want_lists_lock); |
8a4023c5b batman-adv: Fix p... |
1040 1041 1042 1043 |
/* flag checks above + mcast_handler_lock prevents this */ WARN_ON(hlist_unhashed(node)); hlist_del_init_rcu(node); |
4c8755d69 batman-adv: Send ... |
1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 |
spin_unlock_bh(&bat_priv->mcast.want_lists_lock); } } /** * batadv_mcast_want_ipv6_update - update want-all-ipv6 counter and list * @bat_priv: the bat priv with all the soft interface information * @orig: the orig_node which multicast state might have changed of * @mcast_flags: flags indicating the new multicast state * * If the BATADV_MCAST_WANT_ALL_IPV6 flag of this originator, orig, has * toggled then this method updates counter and list accordingly. |
8a4023c5b batman-adv: Fix p... |
1056 1057 |
* * Caller needs to hold orig->mcast_handler_lock. |
4c8755d69 batman-adv: Send ... |
1058 1059 1060 |
*/ static void batadv_mcast_want_ipv6_update(struct batadv_priv *bat_priv, struct batadv_orig_node *orig, |
6b5e971a2 batman-adv: Repla... |
1061 |
u8 mcast_flags) |
4c8755d69 batman-adv: Send ... |
1062 |
{ |
8a4023c5b batman-adv: Fix p... |
1063 1064 |
struct hlist_node *node = &orig->mcast_want_all_ipv6_node; struct hlist_head *head = &bat_priv->mcast.want_all_ipv6_list; |
5274cd68d batman-adv: Add l... |
1065 |
lockdep_assert_held(&orig->mcast_handler_lock); |
4c8755d69 batman-adv: Send ... |
1066 1067 1068 1069 1070 1071 |
/* switched from flag unset to set */ if (mcast_flags & BATADV_MCAST_WANT_ALL_IPV6 && !(orig->mcast_flags & BATADV_MCAST_WANT_ALL_IPV6)) { atomic_inc(&bat_priv->mcast.num_want_all_ipv6); spin_lock_bh(&bat_priv->mcast.want_lists_lock); |
8a4023c5b batman-adv: Fix p... |
1072 1073 1074 1075 |
/* flag checks above + mcast_handler_lock prevents this */ WARN_ON(!hlist_unhashed(node)); hlist_add_head_rcu(node, head); |
4c8755d69 batman-adv: Send ... |
1076 1077 1078 1079 1080 1081 1082 |
spin_unlock_bh(&bat_priv->mcast.want_lists_lock); /* switched from flag set to unset */ } else if (!(mcast_flags & BATADV_MCAST_WANT_ALL_IPV6) && orig->mcast_flags & BATADV_MCAST_WANT_ALL_IPV6) { atomic_dec(&bat_priv->mcast.num_want_all_ipv6); spin_lock_bh(&bat_priv->mcast.want_lists_lock); |
8a4023c5b batman-adv: Fix p... |
1083 1084 1085 1086 |
/* flag checks above + mcast_handler_lock prevents this */ WARN_ON(hlist_unhashed(node)); hlist_del_init_rcu(node); |
4c8755d69 batman-adv: Send ... |
1087 1088 1089 1090 1091 |
spin_unlock_bh(&bat_priv->mcast.want_lists_lock); } } /** |
bd2a979e5 batman-adv: Alway... |
1092 |
* batadv_mcast_tvlv_ogm_handler - process incoming multicast tvlv container |
60432d756 batman-adv: Annou... |
1093 1094 1095 1096 1097 1098 |
* @bat_priv: the bat priv with all the soft interface information * @orig: the orig_node of the ogm * @flags: flags indicating the tvlv state (see batadv_tvlv_handler_flags) * @tvlv_value: tvlv buffer containing the multicast data * @tvlv_value_len: tvlv buffer length */ |
bd2a979e5 batman-adv: Alway... |
1099 1100 1101 1102 1103 |
static void batadv_mcast_tvlv_ogm_handler(struct batadv_priv *bat_priv, struct batadv_orig_node *orig, u8 flags, void *tvlv_value, u16 tvlv_value_len) |
60432d756 batman-adv: Annou... |
1104 1105 |
{ bool orig_mcast_enabled = !(flags & BATADV_TVLV_HANDLER_OGM_CIFNOTFND); |
6b5e971a2 batman-adv: Repla... |
1106 |
u8 mcast_flags = BATADV_NO_FLAGS; |
60432d756 batman-adv: Annou... |
1107 |
bool orig_initialized; |
8a4023c5b batman-adv: Fix p... |
1108 1109 |
if (orig_mcast_enabled && tvlv_value && (tvlv_value_len >= sizeof(mcast_flags))) |
6b5e971a2 batman-adv: Repla... |
1110 |
mcast_flags = *(u8 *)tvlv_value; |
8a4023c5b batman-adv: Fix p... |
1111 1112 |
spin_lock_bh(&orig->mcast_handler_lock); |
9c936e3f4 batman-adv: Make ... |
1113 1114 |
orig_initialized = test_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capa_initialized); |
60432d756 batman-adv: Annou... |
1115 1116 1117 1118 1119 1120 |
/* If mcast support is turned on decrease the disabled mcast node * counter only if we had increased it for this node before. If this * is a completely new orig_node no need to decrease the counter. */ if (orig_mcast_enabled && |
9c936e3f4 batman-adv: Make ... |
1121 |
!test_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capabilities)) { |
60432d756 batman-adv: Annou... |
1122 1123 |
if (orig_initialized) atomic_dec(&bat_priv->mcast.num_disabled); |
9c936e3f4 batman-adv: Make ... |
1124 |
set_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capabilities); |
e8829f007 batman-adv: fix c... |
1125 1126 1127 |
/* If mcast support is being switched off or if this is an initial * OGM without mcast support then increase the disabled mcast * node counter. |
60432d756 batman-adv: Annou... |
1128 1129 |
*/ } else if (!orig_mcast_enabled && |
9c936e3f4 batman-adv: Make ... |
1130 |
(test_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capabilities) || |
e8829f007 batman-adv: fix c... |
1131 |
!orig_initialized)) { |
60432d756 batman-adv: Annou... |
1132 |
atomic_inc(&bat_priv->mcast.num_disabled); |
9c936e3f4 batman-adv: Make ... |
1133 |
clear_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capabilities); |
60432d756 batman-adv: Annou... |
1134 |
} |
9c936e3f4 batman-adv: Make ... |
1135 |
set_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capa_initialized); |
60432d756 batman-adv: Annou... |
1136 |
|
ab49886e3 batman-adv: Add I... |
1137 |
batadv_mcast_want_unsnoop_update(bat_priv, orig, mcast_flags); |
4c8755d69 batman-adv: Send ... |
1138 1139 |
batadv_mcast_want_ipv4_update(bat_priv, orig, mcast_flags); batadv_mcast_want_ipv6_update(bat_priv, orig, mcast_flags); |
ab49886e3 batman-adv: Add I... |
1140 |
|
60432d756 batman-adv: Annou... |
1141 |
orig->mcast_flags = mcast_flags; |
8a4023c5b batman-adv: Fix p... |
1142 |
spin_unlock_bh(&orig->mcast_handler_lock); |
60432d756 batman-adv: Annou... |
1143 1144 1145 1146 1147 1148 1149 1150 |
} /** * batadv_mcast_init - initialize the multicast optimizations structures * @bat_priv: the bat priv with all the soft interface information */ void batadv_mcast_init(struct batadv_priv *bat_priv) { |
bd2a979e5 batman-adv: Alway... |
1151 1152 |
batadv_tvlv_handler_register(bat_priv, batadv_mcast_tvlv_ogm_handler, NULL, BATADV_TVLV_MCAST, 2, |
60432d756 batman-adv: Annou... |
1153 |
BATADV_TVLV_HANDLER_OGM_CIFNOTFND); |
cbebd363b batman-adv: Use o... |
1154 1155 1156 |
INIT_DELAYED_WORK(&bat_priv->mcast.work, batadv_mcast_mla_update); batadv_mcast_start_timer(bat_priv); |
60432d756 batman-adv: Annou... |
1157 |
} |
dc1cbd145 batman-adv: Allow... |
1158 |
#ifdef CONFIG_BATMAN_ADV_DEBUGFS |
60432d756 batman-adv: Annou... |
1159 |
/** |
4e3e823b5 batman-adv: Add d... |
1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 |
* batadv_mcast_flags_print_header - print own mcast flags to debugfs table * @bat_priv: the bat priv with all the soft interface information * @seq: debugfs table seq_file struct * * Prints our own multicast flags including a more specific reason why * they are set, that is prints the bridge and querier state too, to * the debugfs table specified via @seq. */ static void batadv_mcast_flags_print_header(struct batadv_priv *bat_priv, struct seq_file *seq) { u8 flags = bat_priv->mcast.flags; char querier4, querier6, shadowing4, shadowing6; bool bridged = bat_priv->mcast.bridged; if (bridged) { querier4 = bat_priv->mcast.querier_ipv4.exists ? '.' : '4'; querier6 = bat_priv->mcast.querier_ipv6.exists ? '.' : '6'; shadowing4 = bat_priv->mcast.querier_ipv4.shadowing ? '4' : '.'; shadowing6 = bat_priv->mcast.querier_ipv6.shadowing ? '6' : '.'; } else { querier4 = '?'; querier6 = '?'; shadowing4 = '?'; shadowing6 = '?'; } seq_printf(seq, "Multicast flags (own flags: [%c%c%c]) ", (flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES) ? 'U' : '.', (flags & BATADV_MCAST_WANT_ALL_IPV4) ? '4' : '.', (flags & BATADV_MCAST_WANT_ALL_IPV6) ? '6' : '.'); seq_printf(seq, "* Bridged [U]\t\t\t\t%c ", bridged ? 'U' : '.'); seq_printf(seq, "* No IGMP/MLD Querier [4/6]:\t\t%c/%c ", querier4, querier6); seq_printf(seq, "* Shadowing IGMP/MLD Querier [4/6]:\t%c/%c ", shadowing4, shadowing6); seq_puts(seq, "------------------------------------------- "); seq_printf(seq, " %-10s %s ", "Originator", "Flags"); } /** * batadv_mcast_flags_seq_print_text - print the mcast flags of other nodes * @seq: seq file to print on * @offset: not used * * This prints a table of (primary) originators and their according * multicast flags, including (in the header) our own. * * Return: always 0 */ int batadv_mcast_flags_seq_print_text(struct seq_file *seq, void *offset) { struct net_device *net_dev = (struct net_device *)seq->private; struct batadv_priv *bat_priv = netdev_priv(net_dev); struct batadv_hard_iface *primary_if; struct batadv_hashtable *hash = bat_priv->orig_hash; struct batadv_orig_node *orig_node; struct hlist_head *head; u8 flags; u32 i; primary_if = batadv_seq_print_text_primary_if_get(seq); if (!primary_if) return 0; batadv_mcast_flags_print_header(bat_priv, seq); for (i = 0; i < hash->size; i++) { head = &hash->table[i]; rcu_read_lock(); hlist_for_each_entry_rcu(orig_node, head, hash_entry) { if (!test_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig_node->capa_initialized)) continue; if (!test_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig_node->capabilities)) { seq_printf(seq, "%pM - ", orig_node->orig); continue; } flags = orig_node->mcast_flags; seq_printf(seq, "%pM [%c%c%c] ", orig_node->orig, (flags & BATADV_MCAST_WANT_ALL_UNSNOOPABLES) ? 'U' : '.', (flags & BATADV_MCAST_WANT_ALL_IPV4) ? '4' : '.', (flags & BATADV_MCAST_WANT_ALL_IPV6) ? '6' : '.'); } rcu_read_unlock(); } batadv_hardif_put(primary_if); return 0; } |
dc1cbd145 batman-adv: Allow... |
1267 |
#endif |
4e3e823b5 batman-adv: Add d... |
1268 1269 |
/** |
c5caf4ef3 batman-adv: Multi... |
1270 1271 1272 1273 1274 |
* batadv_mcast_free - free the multicast optimizations structures * @bat_priv: the bat priv with all the soft interface information */ void batadv_mcast_free(struct batadv_priv *bat_priv) { |
cbebd363b batman-adv: Use o... |
1275 |
cancel_delayed_work_sync(&bat_priv->mcast.work); |
bd2a979e5 batman-adv: Alway... |
1276 1277 |
batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_MCAST, 2); batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_MCAST, 2); |
60432d756 batman-adv: Annou... |
1278 |
|
cbebd363b batman-adv: Use o... |
1279 |
/* safely calling outside of worker, as worker was canceled above */ |
c5caf4ef3 batman-adv: Multi... |
1280 1281 |
batadv_mcast_mla_tt_retract(bat_priv, NULL); } |
60432d756 batman-adv: Annou... |
1282 1283 1284 1285 1286 1287 1288 1289 |
/** * batadv_mcast_purge_orig - reset originator global mcast state modifications * @orig: the originator which is going to get purged */ void batadv_mcast_purge_orig(struct batadv_orig_node *orig) { struct batadv_priv *bat_priv = orig->bat_priv; |
8a4023c5b batman-adv: Fix p... |
1290 |
spin_lock_bh(&orig->mcast_handler_lock); |
9c936e3f4 batman-adv: Make ... |
1291 1292 |
if (!test_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capabilities) && test_bit(BATADV_ORIG_CAPA_HAS_MCAST, &orig->capa_initialized)) |
60432d756 batman-adv: Annou... |
1293 |
atomic_dec(&bat_priv->mcast.num_disabled); |
ab49886e3 batman-adv: Add I... |
1294 1295 |
batadv_mcast_want_unsnoop_update(bat_priv, orig, BATADV_NO_FLAGS); |
4c8755d69 batman-adv: Send ... |
1296 1297 |
batadv_mcast_want_ipv4_update(bat_priv, orig, BATADV_NO_FLAGS); batadv_mcast_want_ipv6_update(bat_priv, orig, BATADV_NO_FLAGS); |
8a4023c5b batman-adv: Fix p... |
1298 1299 |
spin_unlock_bh(&orig->mcast_handler_lock); |
60432d756 batman-adv: Annou... |
1300 |
} |