originator.c 39.3 KB
Newer Older
1
/* Copyright (C) 2009-2015 B.A.T.M.A.N. contributors:
2 3 4 5 6 7 8 9 10 11 12 13 14
 *
 * Marek Lindner, Simon Wunderlich
 *
 * 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
15
 * along with this program; if not, see <http://www.gnu.org/licenses/>.
16 17
 */

18
#include "originator.h"
19
#include "main.h"
20 21 22 23 24 25 26 27 28

#include <linux/errno.h>
#include <linux/etherdevice.h>
#include <linux/fs.h>
#include <linux/jiffies.h>
#include <linux/kernel.h>
#include <linux/list.h>
#include <linux/lockdep.h>
#include <linux/netdevice.h>
29
#include <linux/rculist.h>
30 31 32 33 34
#include <linux/seq_file.h>
#include <linux/slab.h>
#include <linux/spinlock.h>
#include <linux/workqueue.h>

35
#include "distributed-arp-table.h"
36
#include "fragmentation.h"
37 38
#include "gateway_client.h"
#include "hard-interface.h"
39
#include "hash.h"
40
#include "multicast.h"
41 42 43
#include "network-coding.h"
#include "routing.h"
#include "translation-table.h"
44

45 46 47
/* hash class keys */
static struct lock_class_key batadv_orig_hash_lock_class_key;

48
static void batadv_purge_orig(struct work_struct *work);
49

50
/* returns 1 if they are the same originator */
51
int batadv_compare_orig(const struct hlist_node *node, const void *data2)
52
{
53 54
	const void *data1 = container_of(node, struct batadv_orig_node,
					 hash_entry);
55

56
	return batadv_compare_eth(data1, data2);
57 58
}

59 60 61 62 63 64 65 66 67 68 69 70 71 72 73
/**
 * batadv_orig_node_vlan_get - get an orig_node_vlan object
 * @orig_node: the originator serving the VLAN
 * @vid: the VLAN identifier
 *
 * Returns the vlan object identified by vid and belonging to orig_node or NULL
 * if it does not exist.
 */
struct batadv_orig_node_vlan *
batadv_orig_node_vlan_get(struct batadv_orig_node *orig_node,
			  unsigned short vid)
{
	struct batadv_orig_node_vlan *vlan = NULL, *tmp;

	rcu_read_lock();
74
	hlist_for_each_entry_rcu(tmp, &orig_node->vlan_list, list) {
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 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121
		if (tmp->vid != vid)
			continue;

		if (!atomic_inc_not_zero(&tmp->refcount))
			continue;

		vlan = tmp;

		break;
	}
	rcu_read_unlock();

	return vlan;
}

/**
 * batadv_orig_node_vlan_new - search and possibly create an orig_node_vlan
 *  object
 * @orig_node: the originator serving the VLAN
 * @vid: the VLAN identifier
 *
 * Returns NULL in case of failure or the vlan object identified by vid and
 * belonging to orig_node otherwise. The object is created and added to the list
 * if it does not exist.
 *
 * The object is returned with refcounter increased by 1.
 */
struct batadv_orig_node_vlan *
batadv_orig_node_vlan_new(struct batadv_orig_node *orig_node,
			  unsigned short vid)
{
	struct batadv_orig_node_vlan *vlan;

	spin_lock_bh(&orig_node->vlan_list_lock);

	/* first look if an object for this vid already exists */
	vlan = batadv_orig_node_vlan_get(orig_node, vid);
	if (vlan)
		goto out;

	vlan = kzalloc(sizeof(*vlan), GFP_ATOMIC);
	if (!vlan)
		goto out;

	atomic_set(&vlan->refcount, 2);
	vlan->vid = vid;

122
	hlist_add_head_rcu(&vlan->list, &orig_node->vlan_list);
123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140

out:
	spin_unlock_bh(&orig_node->vlan_list_lock);

	return vlan;
}

/**
 * batadv_orig_node_vlan_free_ref - decrement the refcounter and possibly free
 *  the originator-vlan object
 * @orig_vlan: the originator-vlan object to release
 */
void batadv_orig_node_vlan_free_ref(struct batadv_orig_node_vlan *orig_vlan)
{
	if (atomic_dec_and_test(&orig_vlan->refcount))
		kfree_rcu(orig_vlan, rcu);
}

141
int batadv_originator_init(struct batadv_priv *bat_priv)
142 143
{
	if (bat_priv->orig_hash)
144
		return 0;
145

146
	bat_priv->orig_hash = batadv_hash_new(1024);
147 148 149 150

	if (!bat_priv->orig_hash)
		goto err;

151 152 153
	batadv_hash_set_lock_class(bat_priv->orig_hash,
				   &batadv_orig_hash_lock_class_key);

154 155 156 157 158
	INIT_DELAYED_WORK(&bat_priv->orig_work, batadv_purge_orig);
	queue_delayed_work(batadv_event_workqueue,
			   &bat_priv->orig_work,
			   msecs_to_jiffies(BATADV_ORIG_WORK_PERIOD));

159
	return 0;
160 161

err:
162
	return -ENOMEM;
163 164
}

165 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
/**
 * batadv_neigh_ifinfo_free_rcu - free the neigh_ifinfo object
 * @rcu: rcu pointer of the neigh_ifinfo object
 */
static void batadv_neigh_ifinfo_free_rcu(struct rcu_head *rcu)
{
	struct batadv_neigh_ifinfo *neigh_ifinfo;

	neigh_ifinfo = container_of(rcu, struct batadv_neigh_ifinfo, rcu);

	if (neigh_ifinfo->if_outgoing != BATADV_IF_DEFAULT)
		batadv_hardif_free_ref_now(neigh_ifinfo->if_outgoing);

	kfree(neigh_ifinfo);
}

/**
 * batadv_neigh_ifinfo_free_now - decrement the refcounter and possibly free
 *  the neigh_ifinfo (without rcu callback)
 * @neigh_ifinfo: the neigh_ifinfo object to release
 */
static void
batadv_neigh_ifinfo_free_ref_now(struct batadv_neigh_ifinfo *neigh_ifinfo)
{
	if (atomic_dec_and_test(&neigh_ifinfo->refcount))
		batadv_neigh_ifinfo_free_rcu(&neigh_ifinfo->rcu);
}

/**
 * batadv_neigh_ifinfo_free_ref - decrement the refcounter and possibly free
 *  the neigh_ifinfo
 * @neigh_ifinfo: the neigh_ifinfo object to release
 */
void batadv_neigh_ifinfo_free_ref(struct batadv_neigh_ifinfo *neigh_ifinfo)
{
	if (atomic_dec_and_test(&neigh_ifinfo->refcount))
		call_rcu(&neigh_ifinfo->rcu, batadv_neigh_ifinfo_free_rcu);
}

204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225
/**
 * batadv_hardif_neigh_free_rcu - free the hardif neigh_node
 * @rcu: rcu pointer of the neigh_node
 */
static void batadv_hardif_neigh_free_rcu(struct rcu_head *rcu)
{
	struct batadv_hardif_neigh_node *hardif_neigh;

	hardif_neigh = container_of(rcu, struct batadv_hardif_neigh_node, rcu);

	batadv_hardif_free_ref_now(hardif_neigh->if_incoming);
	kfree(hardif_neigh);
}

/**
 * batadv_hardif_neigh_free_now - decrement the hardif neighbors refcounter
 *  and possibly free it (without rcu callback)
 * @hardif_neigh: hardif neigh neighbor to free
 */
static void
batadv_hardif_neigh_free_now(struct batadv_hardif_neigh_node *hardif_neigh)
{
226 227 228 229 230
	if (atomic_dec_and_test(&hardif_neigh->refcount)) {
		spin_lock_bh(&hardif_neigh->if_incoming->neigh_list_lock);
		hlist_del_init_rcu(&hardif_neigh->list);
		spin_unlock_bh(&hardif_neigh->if_incoming->neigh_list_lock);

231
		batadv_hardif_neigh_free_rcu(&hardif_neigh->rcu);
232
	}
233 234 235 236 237 238 239 240 241
}

/**
 * batadv_hardif_neigh_free_ref - decrement the hardif neighbors refcounter
 *  and possibly free it
 * @hardif_neigh: hardif neigh neighbor to free
 */
void batadv_hardif_neigh_free_ref(struct batadv_hardif_neigh_node *hardif_neigh)
{
242 243 244 245 246
	if (atomic_dec_and_test(&hardif_neigh->refcount)) {
		spin_lock_bh(&hardif_neigh->if_incoming->neigh_list_lock);
		hlist_del_init_rcu(&hardif_neigh->list);
		spin_unlock_bh(&hardif_neigh->if_incoming->neigh_list_lock);

247
		call_rcu(&hardif_neigh->rcu, batadv_hardif_neigh_free_rcu);
248
	}
249 250
}

251 252 253 254 255 256 257 258
/**
 * batadv_neigh_node_free_rcu - free the neigh_node
 * @rcu: rcu pointer of the neigh_node
 */
static void batadv_neigh_node_free_rcu(struct rcu_head *rcu)
{
	struct hlist_node *node_tmp;
	struct batadv_neigh_node *neigh_node;
259
	struct batadv_hardif_neigh_node *hardif_neigh;
260
	struct batadv_neigh_ifinfo *neigh_ifinfo;
261
	struct batadv_algo_ops *bao;
262 263

	neigh_node = container_of(rcu, struct batadv_neigh_node, rcu);
264
	bao = neigh_node->orig_node->bat_priv->bat_algo_ops;
265 266 267 268 269

	hlist_for_each_entry_safe(neigh_ifinfo, node_tmp,
				  &neigh_node->ifinfo_list, list) {
		batadv_neigh_ifinfo_free_ref_now(neigh_ifinfo);
	}
270

271 272 273 274 275 276 277 278
	hardif_neigh = batadv_hardif_neigh_get(neigh_node->if_incoming,
					       neigh_node->addr);
	if (hardif_neigh) {
		/* batadv_hardif_neigh_get() increases refcount too */
		batadv_hardif_neigh_free_now(hardif_neigh);
		batadv_hardif_neigh_free_now(hardif_neigh);
	}

279 280 281
	if (bao->bat_neigh_free)
		bao->bat_neigh_free(neigh_node);

282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303
	batadv_hardif_free_ref_now(neigh_node->if_incoming);

	kfree(neigh_node);
}

/**
 * batadv_neigh_node_free_ref_now - decrement the neighbors refcounter
 *  and possibly free it (without rcu callback)
 * @neigh_node: neigh neighbor to free
 */
static void
batadv_neigh_node_free_ref_now(struct batadv_neigh_node *neigh_node)
{
	if (atomic_dec_and_test(&neigh_node->refcount))
		batadv_neigh_node_free_rcu(&neigh_node->rcu);
}

/**
 * batadv_neigh_node_free_ref - decrement the neighbors refcounter
 *  and possibly free it
 * @neigh_node: neigh neighbor to free
 */
304
void batadv_neigh_node_free_ref(struct batadv_neigh_node *neigh_node)
305
{
306
	if (atomic_dec_and_test(&neigh_node->refcount))
307
		call_rcu(&neigh_node->rcu, batadv_neigh_node_free_rcu);
308 309
}

310 311 312 313 314 315 316 317 318 319
/**
 * batadv_orig_node_get_router - router to the originator depending on iface
 * @orig_node: the orig node for the router
 * @if_outgoing: the interface where the payload packet has been received or
 *  the OGM should be sent to
 *
 * Returns the neighbor which should be router for this orig_node/iface.
 *
 * The object is returned with refcounter increased by 1.
 */
320
struct batadv_neigh_node *
321 322
batadv_orig_router_get(struct batadv_orig_node *orig_node,
		       const struct batadv_hard_iface *if_outgoing)
323
{
324 325
	struct batadv_orig_ifinfo *orig_ifinfo;
	struct batadv_neigh_node *router = NULL;
326 327

	rcu_read_lock();
328 329 330 331 332 333 334
	hlist_for_each_entry_rcu(orig_ifinfo, &orig_node->ifinfo_list, list) {
		if (orig_ifinfo->if_outgoing != if_outgoing)
			continue;

		router = rcu_dereference(orig_ifinfo->router);
		break;
	}
335 336 337 338 339 340 341 342

	if (router && !atomic_inc_not_zero(&router->refcount))
		router = NULL;

	rcu_read_unlock();
	return router;
}

343 344 345 346 347 348 349 350 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
/**
 * batadv_orig_ifinfo_get - find the ifinfo from an orig_node
 * @orig_node: the orig node to be queried
 * @if_outgoing: the interface for which the ifinfo should be acquired
 *
 * Returns the requested orig_ifinfo or NULL if not found.
 *
 * The object is returned with refcounter increased by 1.
 */
struct batadv_orig_ifinfo *
batadv_orig_ifinfo_get(struct batadv_orig_node *orig_node,
		       struct batadv_hard_iface *if_outgoing)
{
	struct batadv_orig_ifinfo *tmp, *orig_ifinfo = NULL;

	rcu_read_lock();
	hlist_for_each_entry_rcu(tmp, &orig_node->ifinfo_list,
				 list) {
		if (tmp->if_outgoing != if_outgoing)
			continue;

		if (!atomic_inc_not_zero(&tmp->refcount))
			continue;

		orig_ifinfo = tmp;
		break;
	}
	rcu_read_unlock();

	return orig_ifinfo;
}

/**
 * batadv_orig_ifinfo_new - search and possibly create an orig_ifinfo object
 * @orig_node: the orig node to be queried
 * @if_outgoing: the interface for which the ifinfo should be acquired
 *
 * Returns NULL in case of failure or the orig_ifinfo object for the if_outgoing
 * interface otherwise. The object is created and added to the list
 * if it does not exist.
 *
 * The object is returned with refcounter increased by 1.
 */
struct batadv_orig_ifinfo *
batadv_orig_ifinfo_new(struct batadv_orig_node *orig_node,
		       struct batadv_hard_iface *if_outgoing)
{
	struct batadv_orig_ifinfo *orig_ifinfo = NULL;
	unsigned long reset_time;

	spin_lock_bh(&orig_node->neigh_list_lock);

	orig_ifinfo = batadv_orig_ifinfo_get(orig_node, if_outgoing);
	if (orig_ifinfo)
		goto out;

	orig_ifinfo = kzalloc(sizeof(*orig_ifinfo), GFP_ATOMIC);
	if (!orig_ifinfo)
		goto out;

	if (if_outgoing != BATADV_IF_DEFAULT &&
	    !atomic_inc_not_zero(&if_outgoing->refcount)) {
		kfree(orig_ifinfo);
		orig_ifinfo = NULL;
		goto out;
	}

	reset_time = jiffies - 1;
	reset_time -= msecs_to_jiffies(BATADV_RESET_PROTECTION_MS);
	orig_ifinfo->batman_seqno_reset = reset_time;
	orig_ifinfo->if_outgoing = if_outgoing;
	INIT_HLIST_NODE(&orig_ifinfo->list);
	atomic_set(&orig_ifinfo->refcount, 2);
	hlist_add_head_rcu(&orig_ifinfo->list,
			   &orig_node->ifinfo_list);
out:
	spin_unlock_bh(&orig_node->neigh_list_lock);
	return orig_ifinfo;
}

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 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500
/**
 * batadv_neigh_ifinfo_get - find the ifinfo from an neigh_node
 * @neigh_node: the neigh node to be queried
 * @if_outgoing: the interface for which the ifinfo should be acquired
 *
 * The object is returned with refcounter increased by 1.
 *
 * Returns the requested neigh_ifinfo or NULL if not found
 */
struct batadv_neigh_ifinfo *
batadv_neigh_ifinfo_get(struct batadv_neigh_node *neigh,
			struct batadv_hard_iface *if_outgoing)
{
	struct batadv_neigh_ifinfo *neigh_ifinfo = NULL,
				   *tmp_neigh_ifinfo;

	rcu_read_lock();
	hlist_for_each_entry_rcu(tmp_neigh_ifinfo, &neigh->ifinfo_list,
				 list) {
		if (tmp_neigh_ifinfo->if_outgoing != if_outgoing)
			continue;

		if (!atomic_inc_not_zero(&tmp_neigh_ifinfo->refcount))
			continue;

		neigh_ifinfo = tmp_neigh_ifinfo;
		break;
	}
	rcu_read_unlock();

	return neigh_ifinfo;
}

/**
 * batadv_neigh_ifinfo_new - search and possibly create an neigh_ifinfo object
 * @neigh_node: the neigh node to be queried
 * @if_outgoing: the interface for which the ifinfo should be acquired
 *
 * Returns NULL in case of failure or the neigh_ifinfo object for the
 * if_outgoing interface otherwise. The object is created and added to the list
 * if it does not exist.
 *
 * The object is returned with refcounter increased by 1.
 */
struct batadv_neigh_ifinfo *
batadv_neigh_ifinfo_new(struct batadv_neigh_node *neigh,
			struct batadv_hard_iface *if_outgoing)
{
	struct batadv_neigh_ifinfo *neigh_ifinfo;

	spin_lock_bh(&neigh->ifinfo_lock);

	neigh_ifinfo = batadv_neigh_ifinfo_get(neigh, if_outgoing);
	if (neigh_ifinfo)
		goto out;

	neigh_ifinfo = kzalloc(sizeof(*neigh_ifinfo), GFP_ATOMIC);
	if (!neigh_ifinfo)
		goto out;

	if (if_outgoing && !atomic_inc_not_zero(&if_outgoing->refcount)) {
		kfree(neigh_ifinfo);
		neigh_ifinfo = NULL;
		goto out;
	}

	INIT_HLIST_NODE(&neigh_ifinfo->list);
	atomic_set(&neigh_ifinfo->refcount, 2);
	neigh_ifinfo->if_outgoing = if_outgoing;

	hlist_add_head_rcu(&neigh_ifinfo->list, &neigh->ifinfo_list);

out:
	spin_unlock_bh(&neigh->ifinfo_lock);

	return neigh_ifinfo;
}

501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536
/**
 * batadv_neigh_node_get - retrieve a neighbour from the list
 * @orig_node: originator which the neighbour belongs to
 * @hard_iface: the interface where this neighbour is connected to
 * @addr: the address of the neighbour
 *
 * Looks for and possibly returns a neighbour belonging to this originator list
 * which is connected through the provided hard interface.
 * Returns NULL if the neighbour is not found.
 */
static struct batadv_neigh_node *
batadv_neigh_node_get(const struct batadv_orig_node *orig_node,
		      const struct batadv_hard_iface *hard_iface,
		      const u8 *addr)
{
	struct batadv_neigh_node *tmp_neigh_node, *res = NULL;

	rcu_read_lock();
	hlist_for_each_entry_rcu(tmp_neigh_node, &orig_node->neigh_list, list) {
		if (!batadv_compare_eth(tmp_neigh_node->addr, addr))
			continue;

		if (tmp_neigh_node->if_incoming != hard_iface)
			continue;

		if (!atomic_inc_not_zero(&tmp_neigh_node->refcount))
			continue;

		res = tmp_neigh_node;
		break;
	}
	rcu_read_unlock();

	return res;
}

537 538 539 540 541 542 543 544 545 546 547
/**
 * batadv_hardif_neigh_create - create a hardif neighbour node
 * @hard_iface: the interface this neighbour is connected to
 * @neigh_addr: the interface address of the neighbour to retrieve
 *
 * Returns the hardif neighbour node if found or created or NULL otherwise.
 */
static struct batadv_hardif_neigh_node *
batadv_hardif_neigh_create(struct batadv_hard_iface *hard_iface,
			   const u8 *neigh_addr)
{
548
	struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573
	struct batadv_hardif_neigh_node *hardif_neigh = NULL;

	spin_lock_bh(&hard_iface->neigh_list_lock);

	/* check if neighbor hasn't been added in the meantime */
	hardif_neigh = batadv_hardif_neigh_get(hard_iface, neigh_addr);
	if (hardif_neigh)
		goto out;

	if (!atomic_inc_not_zero(&hard_iface->refcount))
		goto out;

	hardif_neigh = kzalloc(sizeof(*hardif_neigh), GFP_ATOMIC);
	if (!hardif_neigh) {
		batadv_hardif_free_ref(hard_iface);
		goto out;
	}

	INIT_HLIST_NODE(&hardif_neigh->list);
	ether_addr_copy(hardif_neigh->addr, neigh_addr);
	hardif_neigh->if_incoming = hard_iface;
	hardif_neigh->last_seen = jiffies;

	atomic_set(&hardif_neigh->refcount, 1);

574 575 576
	if (bat_priv->bat_algo_ops->bat_hardif_neigh_init)
		bat_priv->bat_algo_ops->bat_hardif_neigh_init(hardif_neigh);

577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 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 629 630 631 632 633 634 635 636
	hlist_add_head(&hardif_neigh->list, &hard_iface->neigh_list);

out:
	spin_unlock_bh(&hard_iface->neigh_list_lock);
	return hardif_neigh;
}

/**
 * batadv_hardif_neigh_get_or_create - retrieve or create a hardif neighbour
 *  node
 * @hard_iface: the interface this neighbour is connected to
 * @neigh_addr: the interface address of the neighbour to retrieve
 *
 * Returns the hardif neighbour node if found or created or NULL otherwise.
 */
static struct batadv_hardif_neigh_node *
batadv_hardif_neigh_get_or_create(struct batadv_hard_iface *hard_iface,
				  const u8 *neigh_addr)
{
	struct batadv_hardif_neigh_node *hardif_neigh = NULL;

	/* first check without locking to avoid the overhead */
	hardif_neigh = batadv_hardif_neigh_get(hard_iface, neigh_addr);
	if (hardif_neigh)
		return hardif_neigh;

	return batadv_hardif_neigh_create(hard_iface, neigh_addr);
}

/**
 * batadv_hardif_neigh_get - retrieve a hardif neighbour from the list
 * @hard_iface: the interface where this neighbour is connected to
 * @neigh_addr: the address of the neighbour
 *
 * Looks for and possibly returns a neighbour belonging to this hard interface.
 * Returns NULL if the neighbour is not found.
 */
struct batadv_hardif_neigh_node *
batadv_hardif_neigh_get(const struct batadv_hard_iface *hard_iface,
			const u8 *neigh_addr)
{
	struct batadv_hardif_neigh_node *tmp_hardif_neigh, *hardif_neigh = NULL;

	rcu_read_lock();
	hlist_for_each_entry_rcu(tmp_hardif_neigh,
				 &hard_iface->neigh_list, list) {
		if (!batadv_compare_eth(tmp_hardif_neigh->addr, neigh_addr))
			continue;

		if (!atomic_inc_not_zero(&tmp_hardif_neigh->refcount))
			continue;

		hardif_neigh = tmp_hardif_neigh;
		break;
	}
	rcu_read_unlock();

	return hardif_neigh;
}

637 638
/**
 * batadv_neigh_node_new - create and init a new neigh_node object
639
 * @orig_node: originator object representing the neighbour
640 641 642 643 644 645
 * @hard_iface: the interface where the neighbour is connected to
 * @neigh_addr: the mac address of the neighbour interface
 *
 * Allocates a new neigh_node object and initialises all the generic fields.
 * Returns the new object or NULL on failure.
 */
646
struct batadv_neigh_node *
647 648 649
batadv_neigh_node_new(struct batadv_orig_node *orig_node,
		      struct batadv_hard_iface *hard_iface,
		      const u8 *neigh_addr)
650
{
651
	struct batadv_neigh_node *neigh_node;
652
	struct batadv_hardif_neigh_node *hardif_neigh = NULL;
653

654 655 656 657
	neigh_node = batadv_neigh_node_get(orig_node, hard_iface, neigh_addr);
	if (neigh_node)
		goto out;

658 659 660 661 662
	hardif_neigh = batadv_hardif_neigh_get_or_create(hard_iface,
							 neigh_addr);
	if (!hardif_neigh)
		goto out;

663
	neigh_node = kzalloc(sizeof(*neigh_node), GFP_ATOMIC);
664
	if (!neigh_node)
665
		goto out;
666

667 668 669 670 671 672
	if (!atomic_inc_not_zero(&hard_iface->refcount)) {
		kfree(neigh_node);
		neigh_node = NULL;
		goto out;
	}

673
	INIT_HLIST_NODE(&neigh_node->list);
674 675
	INIT_HLIST_HEAD(&neigh_node->ifinfo_list);
	spin_lock_init(&neigh_node->ifinfo_lock);
676

677
	ether_addr_copy(neigh_node->addr, neigh_addr);
678 679 680
	neigh_node->if_incoming = hard_iface;
	neigh_node->orig_node = orig_node;

681 682
	/* extra reference for return */
	atomic_set(&neigh_node->refcount, 2);
683

684 685 686 687
	spin_lock_bh(&orig_node->neigh_list_lock);
	hlist_add_head_rcu(&neigh_node->list, &orig_node->neigh_list);
	spin_unlock_bh(&orig_node->neigh_list_lock);

688 689 690
	/* increment unique neighbor refcount */
	atomic_inc(&hardif_neigh->refcount);

691 692 693 694
	batadv_dbg(BATADV_DBG_BATMAN, orig_node->bat_priv,
		   "Creating new neighbor %pM for orig_node %pM on interface %s\n",
		   neigh_addr, orig_node->orig, hard_iface->net_dev->name);

695
out:
696 697
	if (hardif_neigh)
		batadv_hardif_neigh_free_ref(hardif_neigh);
698 699 700
	return neigh_node;
}

701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734
/**
 * batadv_hardif_neigh_seq_print_text - print the single hop neighbour list
 * @seq: neighbour table seq_file struct
 * @offset: not used
 *
 * Always returns 0.
 */
int batadv_hardif_neigh_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;

	primary_if = batadv_seq_print_text_primary_if_get(seq);
	if (!primary_if)
		return 0;

	seq_printf(seq, "[B.A.T.M.A.N. adv %s, MainIF/MAC: %s/%pM (%s %s)]\n",
		   BATADV_SOURCE_VERSION, primary_if->net_dev->name,
		   primary_if->net_dev->dev_addr, net_dev->name,
		   bat_priv->bat_algo_ops->name);

	batadv_hardif_free_ref(primary_if);

	if (!bat_priv->bat_algo_ops->bat_neigh_print) {
		seq_puts(seq,
			 "No printing function for this routing protocol\n");
		return 0;
	}

	bat_priv->bat_algo_ops->bat_neigh_print(bat_priv, seq);
	return 0;
}

735 736 737 738 739 740 741
/**
 * batadv_orig_ifinfo_free_rcu - free the orig_ifinfo object
 * @rcu: rcu pointer of the orig_ifinfo object
 */
static void batadv_orig_ifinfo_free_rcu(struct rcu_head *rcu)
{
	struct batadv_orig_ifinfo *orig_ifinfo;
742
	struct batadv_neigh_node *router;
743 744 745 746 747 748

	orig_ifinfo = container_of(rcu, struct batadv_orig_ifinfo, rcu);

	if (orig_ifinfo->if_outgoing != BATADV_IF_DEFAULT)
		batadv_hardif_free_ref_now(orig_ifinfo->if_outgoing);

749 750 751 752
	/* this is the last reference to this object */
	router = rcu_dereference_protected(orig_ifinfo->router, true);
	if (router)
		batadv_neigh_node_free_ref_now(router);
753 754 755 756
	kfree(orig_ifinfo);
}

/**
757 758
 * batadv_orig_ifinfo_free_ref - decrement the refcounter and possibly release
 *  the orig_ifinfo
759 760
 * @orig_ifinfo: the orig_ifinfo object to release
 */
761
void batadv_orig_ifinfo_free_ref(struct batadv_orig_ifinfo *orig_ifinfo)
762 763
{
	if (atomic_dec_and_test(&orig_ifinfo->refcount))
764
		call_rcu(&orig_ifinfo->rcu, batadv_orig_ifinfo_free_rcu);
765 766 767
}

/**
768 769
 * batadv_orig_node_free_rcu - free the orig_node
 * @rcu: rcu pointer of the orig_node
770
 */
771
static void batadv_orig_node_free_rcu(struct rcu_head *rcu)
772
{
773 774 775 776 777 778 779 780 781 782 783 784 785
	struct batadv_orig_node *orig_node;

	orig_node = container_of(rcu, struct batadv_orig_node, rcu);

	batadv_mcast_purge_orig(orig_node);

	batadv_frag_purge_orig(orig_node, NULL);

	if (orig_node->bat_priv->bat_algo_ops->bat_orig_free)
		orig_node->bat_priv->bat_algo_ops->bat_orig_free(orig_node);

	kfree(orig_node->tt_buff);
	kfree(orig_node);
786 787
}

788 789 790 791 792 793
/**
 * batadv_orig_node_release - release orig_node from lists and queue for
 *  free after rcu grace period
 * @orig_node: the orig node to free
 */
static void batadv_orig_node_release(struct batadv_orig_node *orig_node)
794
{
795
	struct hlist_node *node_tmp;
796
	struct batadv_neigh_node *neigh_node;
797
	struct batadv_orig_ifinfo *orig_ifinfo;
798

799 800
	spin_lock_bh(&orig_node->neigh_list_lock);

801
	/* for all neighbors towards this originator ... */
802
	hlist_for_each_entry_safe(neigh_node, node_tmp,
803
				  &orig_node->neigh_list, list) {
804
		hlist_del_rcu(&neigh_node->list);
805
		batadv_neigh_node_free_ref(neigh_node);
806 807
	}

808 809 810
	hlist_for_each_entry_safe(orig_ifinfo, node_tmp,
				  &orig_node->ifinfo_list, list) {
		hlist_del_rcu(&orig_ifinfo->list);
811
		batadv_orig_ifinfo_free_ref(orig_ifinfo);
812
	}
813 814
	spin_unlock_bh(&orig_node->neigh_list_lock);

815 816 817
	/* Free nc_nodes */
	batadv_nc_purge_orig(orig_node->bat_priv, orig_node, NULL);

818
	call_rcu(&orig_node->rcu, batadv_orig_node_free_rcu);
819 820
}

821 822
/**
 * batadv_orig_node_free_ref - decrement the orig node refcounter and possibly
823
 *  release it
824 825
 * @orig_node: the orig node to free
 */
826
void batadv_orig_node_free_ref(struct batadv_orig_node *orig_node)
827 828
{
	if (atomic_dec_and_test(&orig_node->refcount))
829
		batadv_orig_node_release(orig_node);
830 831
}

832 833 834 835 836 837 838 839 840 841 842
/**
 * batadv_orig_node_free_ref_now - decrement the orig node refcounter and
 * possibly free it (without rcu callback)
 * @orig_node: the orig node to free
 */
void batadv_orig_node_free_ref_now(struct batadv_orig_node *orig_node)
{
	if (atomic_dec_and_test(&orig_node->refcount))
		batadv_orig_node_free_rcu(&orig_node->rcu);
}

843
void batadv_originator_free(struct batadv_priv *bat_priv)
844
{
845
	struct batadv_hashtable *hash = bat_priv->orig_hash;
846
	struct hlist_node *node_tmp;
847 848
	struct hlist_head *head;
	spinlock_t *list_lock; /* spinlock to protect write access */
849
	struct batadv_orig_node *orig_node;
850
	u32 i;
851 852

	if (!hash)
853 854 855 856 857
		return;

	cancel_delayed_work_sync(&bat_priv->orig_work);

	bat_priv->orig_hash = NULL;
858 859 860 861 862 863

	for (i = 0; i < hash->size; i++) {
		head = &hash->table[i];
		list_lock = &hash->list_locks[i];

		spin_lock_bh(list_lock);
864
		hlist_for_each_entry_safe(orig_node, node_tmp,
865
					  head, hash_entry) {
866
			hlist_del_rcu(&orig_node->hash_entry);
867
			batadv_orig_node_free_ref(orig_node);
868 869 870 871
		}
		spin_unlock_bh(list_lock);
	}

872
	batadv_hash_destroy(hash);
873 874
}

875 876 877 878 879 880 881 882
/**
 * batadv_orig_node_new - creates a new orig_node
 * @bat_priv: the bat priv with all the soft interface information
 * @addr: the mac address of the originator
 *
 * Creates a new originator object and initialise all the generic fields.
 * The new object is not added to the originator list.
 * Returns the newly created object or NULL on failure.
883
 */
884
struct batadv_orig_node *batadv_orig_node_new(struct batadv_priv *bat_priv,
885
					      const u8 *addr)
886
{
887
	struct batadv_orig_node *orig_node;
888
	struct batadv_orig_node_vlan *vlan;
889
	unsigned long reset_time;
890
	int i;
891

892 893
	batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
		   "Creating new originator: %pM\n", addr);
894

895
	orig_node = kzalloc(sizeof(*orig_node), GFP_ATOMIC);
896 897 898
	if (!orig_node)
		return NULL;

899
	INIT_HLIST_HEAD(&orig_node->neigh_list);
900
	INIT_HLIST_HEAD(&orig_node->vlan_list);
901
	INIT_HLIST_HEAD(&orig_node->ifinfo_list);
902
	spin_lock_init(&orig_node->bcast_seqno_lock);
903
	spin_lock_init(&orig_node->neigh_list_lock);
904
	spin_lock_init(&orig_node->tt_buff_lock);
905
	spin_lock_init(&orig_node->tt_lock);
906
	spin_lock_init(&orig_node->vlan_list_lock);
907

908 909
	batadv_nc_init_orig(orig_node);

910 911
	/* extra reference for return */
	atomic_set(&orig_node->refcount, 2);
912

913
	orig_node->bat_priv = bat_priv;
914
	ether_addr_copy(orig_node->orig, addr);
915
	batadv_dat_init_orig_node_addr(orig_node);
916
	atomic_set(&orig_node->last_ttvn, 0);
917
	orig_node->tt_buff = NULL;
918
	orig_node->tt_buff_len = 0;
919
	orig_node->last_seen = jiffies;
920 921
	reset_time = jiffies - 1 - msecs_to_jiffies(BATADV_RESET_PROTECTION_MS);
	orig_node->bcast_seqno_reset = reset_time;
922

923 924
#ifdef CONFIG_BATMAN_ADV_MCAST
	orig_node->mcast_flags = BATADV_NO_FLAGS;
925 926 927 928
	INIT_HLIST_NODE(&orig_node->mcast_want_all_unsnoopables_node);
	INIT_HLIST_NODE(&orig_node->mcast_want_all_ipv4_node);
	INIT_HLIST_NODE(&orig_node->mcast_want_all_ipv6_node);
	spin_lock_init(&orig_node->mcast_handler_lock);
929
#endif
930

931 932 933 934 935 936 937 938 939 940
	/* create a vlan object for the "untagged" LAN */
	vlan = batadv_orig_node_vlan_new(orig_node, BATADV_NO_FLAGS);
	if (!vlan)
		goto free_orig_node;
	/* batadv_orig_node_vlan_new() increases the refcounter.
	 * Immediately release vlan since it is not needed anymore in this
	 * context
	 */
	batadv_orig_node_vlan_free_ref(vlan);

941 942 943 944 945 946
	for (i = 0; i < BATADV_FRAG_BUFFER_COUNT; i++) {
		INIT_HLIST_HEAD(&orig_node->fragments[i].head);
		spin_lock_init(&orig_node->fragments[i].lock);
		orig_node->fragments[i].size = 0;
	}

947 948 949 950 951 952
	return orig_node;
free_orig_node:
	kfree(orig_node);
	return NULL;
}

953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993
/**
 * batadv_purge_neigh_ifinfo - purge obsolete ifinfo entries from neighbor
 * @bat_priv: the bat priv with all the soft interface information
 * @neigh: orig node which is to be checked
 */
static void
batadv_purge_neigh_ifinfo(struct batadv_priv *bat_priv,
			  struct batadv_neigh_node *neigh)
{
	struct batadv_neigh_ifinfo *neigh_ifinfo;
	struct batadv_hard_iface *if_outgoing;
	struct hlist_node *node_tmp;

	spin_lock_bh(&neigh->ifinfo_lock);

	/* for all ifinfo objects for this neighinator */
	hlist_for_each_entry_safe(neigh_ifinfo, node_tmp,
				  &neigh->ifinfo_list, list) {
		if_outgoing = neigh_ifinfo->if_outgoing;

		/* always keep the default interface */
		if (if_outgoing == BATADV_IF_DEFAULT)
			continue;

		/* don't purge if the interface is not (going) down */
		if ((if_outgoing->if_status != BATADV_IF_INACTIVE) &&
		    (if_outgoing->if_status != BATADV_IF_NOT_IN_USE) &&
		    (if_outgoing->if_status != BATADV_IF_TO_BE_REMOVED))
			continue;

		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
			   "neighbor/ifinfo purge: neighbor %pM, iface: %s\n",
			   neigh->addr, if_outgoing->net_dev->name);

		hlist_del_rcu(&neigh_ifinfo->list);
		batadv_neigh_ifinfo_free_ref(neigh_ifinfo);
	}

	spin_unlock_bh(&neigh->ifinfo_lock);
}

994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034
/**
 * batadv_purge_orig_ifinfo - purge obsolete ifinfo entries from originator
 * @bat_priv: the bat priv with all the soft interface information
 * @orig_node: orig node which is to be checked
 *
 * Returns true if any ifinfo entry was purged, false otherwise.
 */
static bool
batadv_purge_orig_ifinfo(struct batadv_priv *bat_priv,
			 struct batadv_orig_node *orig_node)
{
	struct batadv_orig_ifinfo *orig_ifinfo;
	struct batadv_hard_iface *if_outgoing;
	struct hlist_node *node_tmp;
	bool ifinfo_purged = false;

	spin_lock_bh(&orig_node->neigh_list_lock);

	/* for all ifinfo objects for this originator */
	hlist_for_each_entry_safe(orig_ifinfo, node_tmp,
				  &orig_node->ifinfo_list, list) {
		if_outgoing = orig_ifinfo->if_outgoing;

		/* always keep the default interface */
		if (if_outgoing == BATADV_IF_DEFAULT)
			continue;

		/* don't purge if the interface is not (going) down */
		if ((if_outgoing->if_status != BATADV_IF_INACTIVE) &&
		    (if_outgoing->if_status != BATADV_IF_NOT_IN_USE) &&
		    (if_outgoing->if_status != BATADV_IF_TO_BE_REMOVED))
			continue;

		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
			   "router/ifinfo purge: originator %pM, iface: %s\n",
			   orig_node->orig, if_outgoing->net_dev->name);

		ifinfo_purged = true;

		hlist_del_rcu(&orig_ifinfo->list);
		batadv_orig_ifinfo_free_ref(orig_ifinfo);
S
Simon Wunderlich 已提交
1035 1036 1037 1038
		if (orig_node->last_bonding_candidate == orig_ifinfo) {
			orig_node->last_bonding_candidate = NULL;
			batadv_orig_ifinfo_free_ref(orig_ifinfo);
		}
1039 1040 1041 1042 1043 1044 1045
	}

	spin_unlock_bh(&orig_node->neigh_list_lock);

	return ifinfo_purged;
}

1046 1047 1048 1049 1050 1051 1052
/**
 * batadv_purge_orig_neighbors - purges neighbors from originator
 * @bat_priv: the bat priv with all the soft interface information
 * @orig_node: orig node which is to be checked
 *
 * Returns true if any neighbor was purged, false otherwise
 */
1053 1054
static bool
batadv_purge_orig_neighbors(struct batadv_priv *bat_priv,
1055
			    struct batadv_orig_node *orig_node)
1056
{
1057
	struct hlist_node *node_tmp;
1058
	struct batadv_neigh_node *neigh_node;
1059
	bool neigh_purged = false;
1060
	unsigned long last_seen;
1061
	struct batadv_hard_iface *if_incoming;
1062

1063 1064
	spin_lock_bh(&orig_node->neigh_list_lock);

1065
	/* for all neighbors towards this originator ... */
1066
	hlist_for_each_entry_safe(neigh_node, node_tmp,
1067
				  &orig_node->neigh_list, list) {
1068 1069 1070
		last_seen = neigh_node->last_seen;
		if_incoming = neigh_node->if_incoming;

1071
		if ((batadv_has_timed_out(last_seen, BATADV_PURGE_TIMEOUT)) ||
1072 1073 1074 1075 1076 1077
		    (if_incoming->if_status == BATADV_IF_INACTIVE) ||
		    (if_incoming->if_status == BATADV_IF_NOT_IN_USE) ||
		    (if_incoming->if_status == BATADV_IF_TO_BE_REMOVED)) {
			if ((if_incoming->if_status == BATADV_IF_INACTIVE) ||
			    (if_incoming->if_status == BATADV_IF_NOT_IN_USE) ||
			    (if_incoming->if_status == BATADV_IF_TO_BE_REMOVED))
1078
				batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1079 1080 1081
					   "neighbor purge: originator %pM, neighbor: %pM, iface: %s\n",
					   orig_node->orig, neigh_node->addr,
					   if_incoming->net_dev->name);
1082
			else
1083
				batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1084 1085 1086
					   "neighbor timeout: originator %pM, neighbor: %pM, last_seen: %u\n",
					   orig_node->orig, neigh_node->addr,
					   jiffies_to_msecs(last_seen));
1087 1088

			neigh_purged = true;
1089

1090
			hlist_del_rcu(&neigh_node->list);
1091
			batadv_neigh_node_free_ref(neigh_node);
1092 1093 1094 1095 1096
		} else {
			/* only necessary if not the whole neighbor is to be
			 * deleted, but some interface has been removed.
			 */
			batadv_purge_neigh_ifinfo(bat_priv, neigh_node);
1097 1098
		}
	}
1099 1100

	spin_unlock_bh(&orig_node->neigh_list_lock);
1101 1102 1103
	return neigh_purged;
}

1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138
/**
 * batadv_find_best_neighbor - finds the best neighbor after purging
 * @bat_priv: the bat priv with all the soft interface information
 * @orig_node: orig node which is to be checked
 * @if_outgoing: the interface for which the metric should be compared
 *
 * Returns the current best neighbor, with refcount increased.
 */
static struct batadv_neigh_node *
batadv_find_best_neighbor(struct batadv_priv *bat_priv,
			  struct batadv_orig_node *orig_node,
			  struct batadv_hard_iface *if_outgoing)
{
	struct batadv_neigh_node *best = NULL, *neigh;
	struct batadv_algo_ops *bao = bat_priv->bat_algo_ops;

	rcu_read_lock();
	hlist_for_each_entry_rcu(neigh, &orig_node->neigh_list, list) {
		if (best && (bao->bat_neigh_cmp(neigh, if_outgoing,
						best, if_outgoing) <= 0))
			continue;

		if (!atomic_inc_not_zero(&neigh->refcount))
			continue;

		if (best)
			batadv_neigh_node_free_ref(best);

		best = neigh;
	}
	rcu_read_unlock();

	return best;
}

1139 1140 1141 1142 1143 1144 1145 1146 1147 1148
/**
 * batadv_purge_orig_node - purges obsolete information from an orig_node
 * @bat_priv: the bat priv with all the soft interface information
 * @orig_node: orig node which is to be checked
 *
 * This function checks if the orig_node or substructures of it have become
 * obsolete, and purges this information if that's the case.
 *
 * Returns true if the orig_node is to be removed, false otherwise.
 */
1149 1150
static bool batadv_purge_orig_node(struct batadv_priv *bat_priv,
				   struct batadv_orig_node *orig_node)
1151
{
1152
	struct batadv_neigh_node *best_neigh_node;
1153
	struct batadv_hard_iface *hard_iface;
1154
	bool changed_ifinfo, changed_neigh;
1155

1156 1157
	if (batadv_has_timed_out(orig_node->last_seen,
				 2 * BATADV_PURGE_TIMEOUT)) {
1158
		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1159 1160 1161
			   "Originator timeout: originator %pM, last_seen %u\n",
			   orig_node->orig,
			   jiffies_to_msecs(orig_node->last_seen));
1162 1163
		return true;
	}
1164 1165
	changed_ifinfo = batadv_purge_orig_ifinfo(bat_priv, orig_node);
	changed_neigh = batadv_purge_orig_neighbors(bat_priv, orig_node);
1166

1167
	if (!changed_ifinfo && !changed_neigh)
1168 1169
		return false;

1170
	/* first for NULL ... */
1171 1172
	best_neigh_node = batadv_find_best_neighbor(bat_priv, orig_node,
						    BATADV_IF_DEFAULT);
1173 1174
	batadv_update_route(bat_priv, orig_node, BATADV_IF_DEFAULT,
			    best_neigh_node);
1175 1176
	if (best_neigh_node)
		batadv_neigh_node_free_ref(best_neigh_node);
1177

1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196
	/* ... then for all other interfaces. */
	rcu_read_lock();
	list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) {
		if (hard_iface->if_status != BATADV_IF_ACTIVE)
			continue;

		if (hard_iface->soft_iface != bat_priv->soft_iface)
			continue;

		best_neigh_node = batadv_find_best_neighbor(bat_priv,
							    orig_node,
							    hard_iface);
		batadv_update_route(bat_priv, orig_node, hard_iface,
				    best_neigh_node);
		if (best_neigh_node)
			batadv_neigh_node_free_ref(best_neigh_node);
	}
	rcu_read_unlock();

1197 1198 1199
	return false;
}

1200
static void _batadv_purge_orig(struct batadv_priv *bat_priv)
1201
{
1202
	struct batadv_hashtable *hash = bat_priv->orig_hash;
1203
	struct hlist_node *node_tmp;
1204
	struct hlist_head *head;
1205
	spinlock_t *list_lock; /* spinlock to protect write access */
1206
	struct batadv_orig_node *orig_node;
1207
	u32 i;
1208 1209 1210 1211 1212 1213 1214

	if (!hash)
		return;

	/* for all origins... */
	for (i = 0; i < hash->size; i++) {
		head = &hash->table[i];
1215
		list_lock = &hash->list_locks[i];
1216

1217
		spin_lock_bh(list_lock);
1218
		hlist_for_each_entry_safe(orig_node, node_tmp,
1219
					  head, hash_entry) {
1220
			if (batadv_purge_orig_node(bat_priv, orig_node)) {
1221
				batadv_gw_node_delete(bat_priv, orig_node);
1222
				hlist_del_rcu(&orig_node->hash_entry);
1223 1224 1225
				batadv_tt_global_del_orig(orig_node->bat_priv,
							  orig_node, -1,
							  "originator timed out");
1226
				batadv_orig_node_free_ref(orig_node);
1227
				continue;
1228
			}
1229 1230 1231

			batadv_frag_purge_orig(orig_node,
					       batadv_frag_check_entry);
1232
		}
1233
		spin_unlock_bh(list_lock);
1234 1235
	}

1236
	batadv_gw_election(bat_priv);
1237 1238
}

1239
static void batadv_purge_orig(struct work_struct *work)
1240
{
1241 1242
	struct delayed_work *delayed_work;
	struct batadv_priv *bat_priv;
1243

1244 1245
	delayed_work = container_of(work, struct delayed_work, work);
	bat_priv = container_of(delayed_work, struct batadv_priv, orig_work);
1246
	_batadv_purge_orig(bat_priv);
1247 1248 1249
	queue_delayed_work(batadv_event_workqueue,
			   &bat_priv->orig_work,
			   msecs_to_jiffies(BATADV_ORIG_WORK_PERIOD));
1250 1251
}

1252
void batadv_purge_orig_ref(struct batadv_priv *bat_priv)
1253
{
1254
	_batadv_purge_orig(bat_priv);
1255 1256
}

1257
int batadv_orig_seq_print_text(struct seq_file *seq, void *offset)
1258 1259
{
	struct net_device *net_dev = (struct net_device *)seq->private;
1260 1261
	struct batadv_priv *bat_priv = netdev_priv(net_dev);
	struct batadv_hard_iface *primary_if;
1262

1263 1264
	primary_if = batadv_seq_print_text_primary_if_get(seq);
	if (!primary_if)
1265
		return 0;
1266

1267
	seq_printf(seq, "[B.A.T.M.A.N. adv %s, MainIF/MAC: %s/%pM (%s %s)]\n",
1268
		   BATADV_SOURCE_VERSION, primary_if->net_dev->name,
1269 1270
		   primary_if->net_dev->dev_addr, net_dev->name,
		   bat_priv->bat_algo_ops->name);
1271

1272
	batadv_hardif_free_ref(primary_if);
1273

1274 1275 1276 1277
	if (!bat_priv->bat_algo_ops->bat_orig_print) {
		seq_puts(seq,
			 "No printing function for this routing protocol\n");
		return 0;
1278 1279
	}

1280 1281
	bat_priv->bat_algo_ops->bat_orig_print(bat_priv, seq,
					       BATADV_IF_DEFAULT);
1282

1283
	return 0;
1284 1285
}

1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326
/**
 * batadv_orig_hardif_seq_print_text - writes originator infos for a specific
 *  outgoing interface
 * @seq: debugfs table seq_file struct
 * @offset: not used
 *
 * Returns 0
 */
int batadv_orig_hardif_seq_print_text(struct seq_file *seq, void *offset)
{
	struct net_device *net_dev = (struct net_device *)seq->private;
	struct batadv_hard_iface *hard_iface;
	struct batadv_priv *bat_priv;

	hard_iface = batadv_hardif_get_by_netdev(net_dev);

	if (!hard_iface || !hard_iface->soft_iface) {
		seq_puts(seq, "Interface not known to B.A.T.M.A.N.\n");
		goto out;
	}

	bat_priv = netdev_priv(hard_iface->soft_iface);
	if (!bat_priv->bat_algo_ops->bat_orig_print) {
		seq_puts(seq,
			 "No printing function for this routing protocol\n");
		goto out;
	}

	if (hard_iface->if_status != BATADV_IF_ACTIVE) {
		seq_puts(seq, "Interface not active\n");
		goto out;
	}

	seq_printf(seq, "[B.A.T.M.A.N. adv %s, IF/MAC: %s/%pM (%s %s)]\n",
		   BATADV_SOURCE_VERSION, hard_iface->net_dev->name,
		   hard_iface->net_dev->dev_addr,
		   hard_iface->soft_iface->name, bat_priv->bat_algo_ops->name);

	bat_priv->bat_algo_ops->bat_orig_print(bat_priv, seq, hard_iface);

out:
1327 1328
	if (hard_iface)
		batadv_hardif_free_ref(hard_iface);
1329 1330 1331
	return 0;
}

1332 1333
int batadv_orig_hash_add_if(struct batadv_hard_iface *hard_iface,
			    int max_if_num)
1334
{
1335
	struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
1336
	struct batadv_algo_ops *bao = bat_priv->bat_algo_ops;
1337
	struct batadv_hashtable *hash = bat_priv->orig_hash;
1338
	struct hlist_head *head;
1339
	struct batadv_orig_node *orig_node;
1340
	u32 i;
1341
	int ret;
1342 1343

	/* resize all orig nodes because orig_node->bcast_own(_sum) depend on
1344 1345
	 * if_num
	 */
1346 1347 1348
	for (i = 0; i < hash->size; i++) {
		head = &hash->table[i];

1349
		rcu_read_lock();
1350
		hlist_for_each_entry_rcu(orig_node, head, hash_entry) {
1351 1352 1353 1354
			ret = 0;
			if (bao->bat_orig_add_if)
				ret = bao->bat_orig_add_if(orig_node,
							   max_if_num);
1355
			if (ret == -ENOMEM)
1356 1357
				goto err;
		}
1358
		rcu_read_unlock();
1359 1360 1361 1362 1363
	}

	return 0;

err:
1364
	rcu_read_unlock();
1365 1366 1367
	return -ENOMEM;
}

1368 1369
int batadv_orig_hash_del_if(struct batadv_hard_iface *hard_iface,
			    int max_if_num)
1370
{
1371
	struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
1372
	struct batadv_hashtable *hash = bat_priv->orig_hash;
1373
	struct hlist_head *head;
1374 1375
	struct batadv_hard_iface *hard_iface_tmp;
	struct batadv_orig_node *orig_node;
1376
	struct batadv_algo_ops *bao = bat_priv->bat_algo_ops;
1377
	u32 i;
1378
	int ret;
1379 1380

	/* resize all orig nodes because orig_node->bcast_own(_sum) depend on
1381 1382
	 * if_num
	 */
1383 1384 1385
	for (i = 0; i < hash->size; i++) {
		head = &hash->table[i];

1386
		rcu_read_lock();
1387
		hlist_for_each_entry_rcu(orig_node, head, hash_entry) {
1388 1389 1390 1391 1392
			ret = 0;
			if (bao->bat_orig_del_if)
				ret = bao->bat_orig_del_if(orig_node,
							   max_if_num,
							   hard_iface->if_num);
1393
			if (ret == -ENOMEM)
1394 1395
				goto err;
		}
1396
		rcu_read_unlock();
1397 1398 1399 1400
	}

	/* renumber remaining batman interfaces _inside_ of orig_hash_lock */
	rcu_read_lock();
1401
	list_for_each_entry_rcu(hard_iface_tmp, &batadv_hardif_list, list) {
1402
		if (hard_iface_tmp->if_status == BATADV_IF_NOT_IN_USE)
1403 1404
			continue;

1405
		if (hard_iface == hard_iface_tmp)
1406 1407
			continue;

1408
		if (hard_iface->soft_iface != hard_iface_tmp->soft_iface)
1409 1410
			continue;

1411 1412
		if (hard_iface_tmp->if_num > hard_iface->if_num)
			hard_iface_tmp->if_num--;
1413 1414 1415
	}
	rcu_read_unlock();

1416
	hard_iface->if_num = -1;
1417 1418 1419
	return 0;

err:
1420
	rcu_read_unlock();
1421 1422
	return -ENOMEM;
}