originator.c 39.4 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 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778
	kfree(orig_ifinfo);
}

/**
 * batadv_orig_ifinfo_free_ref - decrement the refcounter and possibly free
 *  the orig_ifinfo (without rcu callback)
 * @orig_ifinfo: the orig_ifinfo object to release
 */
static void
batadv_orig_ifinfo_free_ref_now(struct batadv_orig_ifinfo *orig_ifinfo)
{
	if (atomic_dec_and_test(&orig_ifinfo->refcount))
		batadv_orig_ifinfo_free_rcu(&orig_ifinfo->rcu);
}

/**
 * batadv_orig_ifinfo_free_ref - decrement the refcounter and possibly free
 *  the orig_ifinfo
 * @orig_ifinfo: the orig_ifinfo object to release
 */
void batadv_orig_ifinfo_free_ref(struct batadv_orig_ifinfo *orig_ifinfo)
{
	if (atomic_dec_and_test(&orig_ifinfo->refcount))
		call_rcu(&orig_ifinfo->rcu, batadv_orig_ifinfo_free_rcu);
}

779
static void batadv_orig_node_free_rcu(struct rcu_head *rcu)
780
{
781
	struct hlist_node *node_tmp;
782
	struct batadv_neigh_node *neigh_node;
783
	struct batadv_orig_node *orig_node;
784
	struct batadv_orig_ifinfo *orig_ifinfo;
785

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

788 789
	spin_lock_bh(&orig_node->neigh_list_lock);

790
	/* for all neighbors towards this originator ... */
791
	hlist_for_each_entry_safe(neigh_node, node_tmp,
792
				  &orig_node->neigh_list, list) {
793
		hlist_del_rcu(&neigh_node->list);
794
		batadv_neigh_node_free_ref_now(neigh_node);
795 796
	}

797 798 799 800 801
	hlist_for_each_entry_safe(orig_ifinfo, node_tmp,
				  &orig_node->ifinfo_list, list) {
		hlist_del_rcu(&orig_ifinfo->list);
		batadv_orig_ifinfo_free_ref_now(orig_ifinfo);
	}
802 803
	spin_unlock_bh(&orig_node->neigh_list_lock);

804 805
	batadv_mcast_purge_orig(orig_node);

806 807 808
	/* Free nc_nodes */
	batadv_nc_purge_orig(orig_node->bat_priv, orig_node, NULL);

809 810
	batadv_frag_purge_orig(orig_node, NULL);

811 812 813
	if (orig_node->bat_priv->bat_algo_ops->bat_orig_free)
		orig_node->bat_priv->bat_algo_ops->bat_orig_free(orig_node);

814
	kfree(orig_node->tt_buff);
815 816 817
	kfree(orig_node);
}

818 819 820 821 822
/**
 * batadv_orig_node_free_ref - decrement the orig node refcounter and possibly
 * schedule an rcu callback for freeing it
 * @orig_node: the orig node to free
 */
823
void batadv_orig_node_free_ref(struct batadv_orig_node *orig_node)
824 825
{
	if (atomic_dec_and_test(&orig_node->refcount))
826
		call_rcu(&orig_node->rcu, batadv_orig_node_free_rcu);
827 828
}

829 830 831 832 833 834 835 836 837 838 839
/**
 * 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);
}

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

	if (!hash)
850 851 852 853 854
		return;

	cancel_delayed_work_sync(&bat_priv->orig_work);

	bat_priv->orig_hash = NULL;
855 856 857 858 859 860

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

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

869
	batadv_hash_destroy(hash);
870 871
}

872 873 874 875 876 877 878 879
/**
 * 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.
880
 */
881
struct batadv_orig_node *batadv_orig_node_new(struct batadv_priv *bat_priv,
882
					      const u8 *addr)
883
{
884
	struct batadv_orig_node *orig_node;
885
	struct batadv_orig_node_vlan *vlan;
886
	unsigned long reset_time;
887
	int i;
888

889 890
	batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
		   "Creating new originator: %pM\n", addr);
891

892
	orig_node = kzalloc(sizeof(*orig_node), GFP_ATOMIC);
893 894 895
	if (!orig_node)
		return NULL;

896
	INIT_HLIST_HEAD(&orig_node->neigh_list);
897
	INIT_HLIST_HEAD(&orig_node->vlan_list);
898
	INIT_HLIST_HEAD(&orig_node->ifinfo_list);
899
	spin_lock_init(&orig_node->bcast_seqno_lock);
900
	spin_lock_init(&orig_node->neigh_list_lock);
901
	spin_lock_init(&orig_node->tt_buff_lock);
902
	spin_lock_init(&orig_node->tt_lock);
903
	spin_lock_init(&orig_node->vlan_list_lock);
904

905 906
	batadv_nc_init_orig(orig_node);

907 908
	/* extra reference for return */
	atomic_set(&orig_node->refcount, 2);
909

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

920 921
#ifdef CONFIG_BATMAN_ADV_MCAST
	orig_node->mcast_flags = BATADV_NO_FLAGS;
922 923 924 925
	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);
926
#endif
927

928 929 930 931 932 933 934 935 936 937
	/* 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);

938 939 940 941 942 943
	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;
	}

944 945 946 947 948 949
	return orig_node;
free_orig_node:
	kfree(orig_node);
	return NULL;
}

950 951 952 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
/**
 * 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);
}

991 992 993 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
/**
 * 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 已提交
1032 1033 1034 1035
		if (orig_node->last_bonding_candidate == orig_ifinfo) {
			orig_node->last_bonding_candidate = NULL;
			batadv_orig_ifinfo_free_ref(orig_ifinfo);
		}
1036 1037 1038 1039 1040 1041 1042
	}

	spin_unlock_bh(&orig_node->neigh_list_lock);

	return ifinfo_purged;
}

1043 1044 1045 1046 1047 1048 1049
/**
 * 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
 */
1050 1051
static bool
batadv_purge_orig_neighbors(struct batadv_priv *bat_priv,
1052
			    struct batadv_orig_node *orig_node)
1053
{
1054
	struct hlist_node *node_tmp;
1055
	struct batadv_neigh_node *neigh_node;
1056
	bool neigh_purged = false;
1057
	unsigned long last_seen;
1058
	struct batadv_hard_iface *if_incoming;
1059

1060 1061
	spin_lock_bh(&orig_node->neigh_list_lock);

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

1068
		if ((batadv_has_timed_out(last_seen, BATADV_PURGE_TIMEOUT)) ||
1069 1070 1071 1072 1073 1074
		    (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))
1075
				batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1076 1077 1078
					   "neighbor purge: originator %pM, neighbor: %pM, iface: %s\n",
					   orig_node->orig, neigh_node->addr,
					   if_incoming->net_dev->name);
1079
			else
1080
				batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1081 1082 1083
					   "neighbor timeout: originator %pM, neighbor: %pM, last_seen: %u\n",
					   orig_node->orig, neigh_node->addr,
					   jiffies_to_msecs(last_seen));
1084 1085

			neigh_purged = true;
1086

1087
			hlist_del_rcu(&neigh_node->list);
1088
			batadv_neigh_node_free_ref(neigh_node);
1089 1090 1091 1092 1093
		} 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);
1094 1095
		}
	}
1096 1097

	spin_unlock_bh(&orig_node->neigh_list_lock);
1098 1099 1100
	return neigh_purged;
}

1101 1102 1103 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
/**
 * 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;
}

1136 1137 1138 1139 1140 1141 1142 1143 1144 1145
/**
 * 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.
 */
1146 1147
static bool batadv_purge_orig_node(struct batadv_priv *bat_priv,
				   struct batadv_orig_node *orig_node)
1148
{
1149
	struct batadv_neigh_node *best_neigh_node;
1150
	struct batadv_hard_iface *hard_iface;
1151
	bool changed_ifinfo, changed_neigh;
1152

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

1164
	if (!changed_ifinfo && !changed_neigh)
1165 1166
		return false;

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

1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193
	/* ... 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();

1194 1195 1196
	return false;
}

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

	if (!hash)
		return;

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

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

			batadv_frag_purge_orig(orig_node,
					       batadv_frag_check_entry);
1229
		}
1230
		spin_unlock_bh(list_lock);
1231 1232
	}

1233
	batadv_gw_election(bat_priv);
1234 1235
}

1236
static void batadv_purge_orig(struct work_struct *work)
1237
{
1238 1239
	struct delayed_work *delayed_work;
	struct batadv_priv *bat_priv;
1240

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

1249
void batadv_purge_orig_ref(struct batadv_priv *bat_priv)
1250
{
1251
	_batadv_purge_orig(bat_priv);
1252 1253
}

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

1260 1261
	primary_if = batadv_seq_print_text_primary_if_get(seq);
	if (!primary_if)
1262
		return 0;
1263

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

1269
	batadv_hardif_free_ref(primary_if);
1270

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

1277 1278
	bat_priv->bat_algo_ops->bat_orig_print(bat_priv, seq,
					       BATADV_IF_DEFAULT);
1279

1280
	return 0;
1281 1282
}

1283 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
/**
 * 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:
1324 1325
	if (hard_iface)
		batadv_hardif_free_ref(hard_iface);
1326 1327 1328
	return 0;
}

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

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

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

	return 0;

err:
1361
	rcu_read_unlock();
1362 1363 1364
	return -ENOMEM;
}

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

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

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

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

1402
		if (hard_iface == hard_iface_tmp)
1403 1404
			continue;

1405
		if (hard_iface->soft_iface != hard_iface_tmp->soft_iface)
1406 1407
			continue;

1408 1409
		if (hard_iface_tmp->if_num > hard_iface->if_num)
			hard_iface_tmp->if_num--;
1410 1411 1412
	}
	rcu_read_unlock();

1413
	hard_iface->if_num = -1;
1414 1415 1416
	return 0;

err:
1417
	rcu_read_unlock();
1418 1419
	return -ENOMEM;
}