Merge remote-tracking branch 'regmap/for-next'
[deliverable/linux.git] / net / batman-adv / originator.c
CommitLineData
0046b040 1/* Copyright (C) 2009-2016 B.A.T.M.A.N. contributors:
c6c8fea2
SE
2 *
3 * Marek Lindner, Simon Wunderlich
4 *
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of version 2 of the GNU General Public
7 * License as published by the Free Software Foundation.
8 *
9 * This program is distributed in the hope that it will be useful, but
10 * WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * General Public License for more details.
13 *
14 * You should have received a copy of the GNU General Public License
ebf38fb7 15 * along with this program; if not, see <http://www.gnu.org/licenses/>.
c6c8fea2
SE
16 */
17
1e2c2a4f 18#include "originator.h"
c6c8fea2 19#include "main.h"
1e2c2a4f 20
7c124391 21#include <linux/atomic.h>
1e2c2a4f
SE
22#include <linux/errno.h>
23#include <linux/etherdevice.h>
24#include <linux/fs.h>
25#include <linux/jiffies.h>
26#include <linux/kernel.h>
90f564df 27#include <linux/kref.h>
1e2c2a4f
SE
28#include <linux/list.h>
29#include <linux/lockdep.h>
30#include <linux/netdevice.h>
85cf8c85 31#include <linux/netlink.h>
d0fa4f3f 32#include <linux/rculist.h>
1e2c2a4f 33#include <linux/seq_file.h>
85cf8c85 34#include <linux/skbuff.h>
1e2c2a4f
SE
35#include <linux/slab.h>
36#include <linux/spinlock.h>
37#include <linux/workqueue.h>
85cf8c85
MS
38#include <net/sock.h>
39#include <uapi/linux/batman_adv.h>
1e2c2a4f 40
01d350d1 41#include "bat_algo.h"
785ea114 42#include "distributed-arp-table.h"
1e2c2a4f 43#include "fragmentation.h"
c6c8fea2
SE
44#include "gateway_client.h"
45#include "hard-interface.h"
1e2c2a4f 46#include "hash.h"
ba412080 47#include "log.h"
60432d75 48#include "multicast.h"
85cf8c85 49#include "netlink.h"
1e2c2a4f
SE
50#include "network-coding.h"
51#include "routing.h"
85cf8c85 52#include "soft-interface.h"
1e2c2a4f 53#include "translation-table.h"
c6c8fea2 54
dec05074
AQ
55/* hash class keys */
56static struct lock_class_key batadv_orig_hash_lock_class_key;
57
03fc7f86 58static void batadv_purge_orig(struct work_struct *work);
c6c8fea2 59
62fe710f 60/**
7afcbbef
SE
61 * batadv_compare_orig - comparing function used in the originator hash table
62 * @node: node in the local table
63 * @data2: second object to compare the node to
62fe710f 64 *
4b426b10 65 * Return: true if they are the same originator
62fe710f 66 */
4b426b10 67bool batadv_compare_orig(const struct hlist_node *node, const void *data2)
b8e2dd13 68{
56303d34
SE
69 const void *data1 = container_of(node, struct batadv_orig_node,
70 hash_entry);
b8e2dd13 71
323813ed 72 return batadv_compare_eth(data1, data2);
b8e2dd13
SE
73}
74
7ea7b4a1
AQ
75/**
76 * batadv_orig_node_vlan_get - get an orig_node_vlan object
77 * @orig_node: the originator serving the VLAN
78 * @vid: the VLAN identifier
79 *
62fe710f 80 * Return: the vlan object identified by vid and belonging to orig_node or NULL
7ea7b4a1
AQ
81 * if it does not exist.
82 */
83struct batadv_orig_node_vlan *
84batadv_orig_node_vlan_get(struct batadv_orig_node *orig_node,
85 unsigned short vid)
86{
87 struct batadv_orig_node_vlan *vlan = NULL, *tmp;
88
89 rcu_read_lock();
d0fa4f3f 90 hlist_for_each_entry_rcu(tmp, &orig_node->vlan_list, list) {
7ea7b4a1
AQ
91 if (tmp->vid != vid)
92 continue;
93
161a3be9 94 if (!kref_get_unless_zero(&tmp->refcount))
7ea7b4a1
AQ
95 continue;
96
97 vlan = tmp;
98
99 break;
100 }
101 rcu_read_unlock();
102
103 return vlan;
104}
105
106/**
107 * batadv_orig_node_vlan_new - search and possibly create an orig_node_vlan
108 * object
109 * @orig_node: the originator serving the VLAN
110 * @vid: the VLAN identifier
111 *
62fe710f 112 * Return: NULL in case of failure or the vlan object identified by vid and
7ea7b4a1
AQ
113 * belonging to orig_node otherwise. The object is created and added to the list
114 * if it does not exist.
115 *
116 * The object is returned with refcounter increased by 1.
117 */
118struct batadv_orig_node_vlan *
119batadv_orig_node_vlan_new(struct batadv_orig_node *orig_node,
120 unsigned short vid)
121{
122 struct batadv_orig_node_vlan *vlan;
123
124 spin_lock_bh(&orig_node->vlan_list_lock);
125
126 /* first look if an object for this vid already exists */
127 vlan = batadv_orig_node_vlan_get(orig_node, vid);
128 if (vlan)
129 goto out;
130
131 vlan = kzalloc(sizeof(*vlan), GFP_ATOMIC);
132 if (!vlan)
133 goto out;
134
161a3be9 135 kref_init(&vlan->refcount);
7ea7b4a1
AQ
136 vlan->vid = vid;
137
09537d18 138 kref_get(&vlan->refcount);
d0fa4f3f 139 hlist_add_head_rcu(&vlan->list, &orig_node->vlan_list);
7ea7b4a1
AQ
140
141out:
142 spin_unlock_bh(&orig_node->vlan_list_lock);
143
144 return vlan;
145}
146
147/**
161a3be9
SE
148 * batadv_orig_node_vlan_release - release originator-vlan object from lists
149 * and queue for free after rcu grace period
150 * @ref: kref pointer of the originator-vlan object
151 */
152static void batadv_orig_node_vlan_release(struct kref *ref)
153{
154 struct batadv_orig_node_vlan *orig_vlan;
155
156 orig_vlan = container_of(ref, struct batadv_orig_node_vlan, refcount);
157
158 kfree_rcu(orig_vlan, rcu);
159}
160
161/**
21754e25
SE
162 * batadv_orig_node_vlan_put - decrement the refcounter and possibly release
163 * the originator-vlan object
7ea7b4a1
AQ
164 * @orig_vlan: the originator-vlan object to release
165 */
21754e25 166void batadv_orig_node_vlan_put(struct batadv_orig_node_vlan *orig_vlan)
7ea7b4a1 167{
161a3be9 168 kref_put(&orig_vlan->refcount, batadv_orig_node_vlan_release);
7ea7b4a1
AQ
169}
170
56303d34 171int batadv_originator_init(struct batadv_priv *bat_priv)
c6c8fea2
SE
172{
173 if (bat_priv->orig_hash)
5346c35e 174 return 0;
c6c8fea2 175
1a8eaf07 176 bat_priv->orig_hash = batadv_hash_new(1024);
c6c8fea2
SE
177
178 if (!bat_priv->orig_hash)
179 goto err;
180
dec05074
AQ
181 batadv_hash_set_lock_class(bat_priv->orig_hash,
182 &batadv_orig_hash_lock_class_key);
183
72414442
AQ
184 INIT_DELAYED_WORK(&bat_priv->orig_work, batadv_purge_orig);
185 queue_delayed_work(batadv_event_workqueue,
186 &bat_priv->orig_work,
187 msecs_to_jiffies(BATADV_ORIG_WORK_PERIOD));
188
5346c35e 189 return 0;
c6c8fea2
SE
190
191err:
5346c35e 192 return -ENOMEM;
c6c8fea2
SE
193}
194
89652331 195/**
ae3e1e36
SE
196 * batadv_neigh_ifinfo_release - release neigh_ifinfo from lists and queue for
197 * free after rcu grace period
962c6832 198 * @ref: kref pointer of the neigh_ifinfo
89652331 199 */
962c6832 200static void batadv_neigh_ifinfo_release(struct kref *ref)
89652331 201{
962c6832
SE
202 struct batadv_neigh_ifinfo *neigh_ifinfo;
203
204 neigh_ifinfo = container_of(ref, struct batadv_neigh_ifinfo, refcount);
205
ae3e1e36 206 if (neigh_ifinfo->if_outgoing != BATADV_IF_DEFAULT)
82047ad7 207 batadv_hardif_put(neigh_ifinfo->if_outgoing);
ae3e1e36
SE
208
209 kfree_rcu(neigh_ifinfo, rcu);
89652331
SW
210}
211
212/**
044fa3ae 213 * batadv_neigh_ifinfo_put - decrement the refcounter and possibly release
89652331
SW
214 * the neigh_ifinfo
215 * @neigh_ifinfo: the neigh_ifinfo object to release
216 */
044fa3ae 217void batadv_neigh_ifinfo_put(struct batadv_neigh_ifinfo *neigh_ifinfo)
89652331 218{
962c6832 219 kref_put(&neigh_ifinfo->refcount, batadv_neigh_ifinfo_release);
89652331
SW
220}
221
cef63419 222/**
f6389692
SE
223 * batadv_hardif_neigh_release - release hardif neigh node from lists and
224 * queue for free after rcu grace period
90f564df 225 * @ref: kref pointer of the neigh_node
cef63419 226 */
90f564df 227static void batadv_hardif_neigh_release(struct kref *ref)
cef63419 228{
90f564df
SE
229 struct batadv_hardif_neigh_node *hardif_neigh;
230
231 hardif_neigh = container_of(ref, struct batadv_hardif_neigh_node,
232 refcount);
233
f6389692
SE
234 spin_lock_bh(&hardif_neigh->if_incoming->neigh_list_lock);
235 hlist_del_init_rcu(&hardif_neigh->list);
236 spin_unlock_bh(&hardif_neigh->if_incoming->neigh_list_lock);
bab7c6c3 237
82047ad7 238 batadv_hardif_put(hardif_neigh->if_incoming);
f6389692 239 kfree_rcu(hardif_neigh, rcu);
cef63419
ML
240}
241
242/**
accadc35 243 * batadv_hardif_neigh_put - decrement the hardif neighbors refcounter
f6389692 244 * and possibly release it
cef63419
ML
245 * @hardif_neigh: hardif neigh neighbor to free
246 */
accadc35 247void batadv_hardif_neigh_put(struct batadv_hardif_neigh_node *hardif_neigh)
cef63419 248{
90f564df 249 kref_put(&hardif_neigh->refcount, batadv_hardif_neigh_release);
cef63419
ML
250}
251
89652331 252/**
b4d922cf
SE
253 * batadv_neigh_node_release - release neigh_node from lists and queue for
254 * free after rcu grace period
77ae32e8 255 * @ref: kref pointer of the neigh_node
89652331 256 */
77ae32e8 257static void batadv_neigh_node_release(struct kref *ref)
89652331
SW
258{
259 struct hlist_node *node_tmp;
77ae32e8 260 struct batadv_neigh_node *neigh_node;
89652331
SW
261 struct batadv_neigh_ifinfo *neigh_ifinfo;
262
77ae32e8 263 neigh_node = container_of(ref, struct batadv_neigh_node, refcount);
89652331
SW
264
265 hlist_for_each_entry_safe(neigh_ifinfo, node_tmp,
266 &neigh_node->ifinfo_list, list) {
044fa3ae 267 batadv_neigh_ifinfo_put(neigh_ifinfo);
89652331 268 }
bcef1f3c 269
abe59c65 270 batadv_hardif_neigh_put(neigh_node->hardif_neigh);
cef63419 271
82047ad7 272 batadv_hardif_put(neigh_node->if_incoming);
89652331 273
b4d922cf 274 kfree_rcu(neigh_node, rcu);
89652331
SW
275}
276
89652331 277/**
25bb2509 278 * batadv_neigh_node_put - decrement the neighbors refcounter and possibly
77ae32e8 279 * release it
89652331
SW
280 * @neigh_node: neigh neighbor to free
281 */
25bb2509 282void batadv_neigh_node_put(struct batadv_neigh_node *neigh_node)
a4c135c5 283{
77ae32e8 284 kref_put(&neigh_node->refcount, batadv_neigh_node_release);
a4c135c5
SW
285}
286
7351a482 287/**
6d030de8 288 * batadv_orig_router_get - router to the originator depending on iface
7351a482
SW
289 * @orig_node: the orig node for the router
290 * @if_outgoing: the interface where the payload packet has been received or
291 * the OGM should be sent to
292 *
62fe710f 293 * Return: the neighbor which should be router for this orig_node/iface.
7351a482
SW
294 *
295 * The object is returned with refcounter increased by 1.
296 */
56303d34 297struct batadv_neigh_node *
7351a482
SW
298batadv_orig_router_get(struct batadv_orig_node *orig_node,
299 const struct batadv_hard_iface *if_outgoing)
e1a5382f 300{
7351a482
SW
301 struct batadv_orig_ifinfo *orig_ifinfo;
302 struct batadv_neigh_node *router = NULL;
e1a5382f
LL
303
304 rcu_read_lock();
7351a482
SW
305 hlist_for_each_entry_rcu(orig_ifinfo, &orig_node->ifinfo_list, list) {
306 if (orig_ifinfo->if_outgoing != if_outgoing)
307 continue;
308
309 router = rcu_dereference(orig_ifinfo->router);
310 break;
311 }
e1a5382f 312
77ae32e8 313 if (router && !kref_get_unless_zero(&router->refcount))
e1a5382f
LL
314 router = NULL;
315
316 rcu_read_unlock();
317 return router;
318}
319
7351a482
SW
320/**
321 * batadv_orig_ifinfo_get - find the ifinfo from an orig_node
322 * @orig_node: the orig node to be queried
323 * @if_outgoing: the interface for which the ifinfo should be acquired
324 *
62fe710f 325 * Return: the requested orig_ifinfo or NULL if not found.
7351a482
SW
326 *
327 * The object is returned with refcounter increased by 1.
328 */
329struct batadv_orig_ifinfo *
330batadv_orig_ifinfo_get(struct batadv_orig_node *orig_node,
331 struct batadv_hard_iface *if_outgoing)
332{
333 struct batadv_orig_ifinfo *tmp, *orig_ifinfo = NULL;
334
335 rcu_read_lock();
336 hlist_for_each_entry_rcu(tmp, &orig_node->ifinfo_list,
337 list) {
338 if (tmp->if_outgoing != if_outgoing)
339 continue;
340
a6ba0d34 341 if (!kref_get_unless_zero(&tmp->refcount))
7351a482
SW
342 continue;
343
344 orig_ifinfo = tmp;
345 break;
346 }
347 rcu_read_unlock();
348
349 return orig_ifinfo;
350}
351
352/**
353 * batadv_orig_ifinfo_new - search and possibly create an orig_ifinfo object
354 * @orig_node: the orig node to be queried
355 * @if_outgoing: the interface for which the ifinfo should be acquired
356 *
62fe710f 357 * Return: NULL in case of failure or the orig_ifinfo object for the if_outgoing
7351a482
SW
358 * interface otherwise. The object is created and added to the list
359 * if it does not exist.
360 *
361 * The object is returned with refcounter increased by 1.
362 */
363struct batadv_orig_ifinfo *
364batadv_orig_ifinfo_new(struct batadv_orig_node *orig_node,
365 struct batadv_hard_iface *if_outgoing)
366{
367 struct batadv_orig_ifinfo *orig_ifinfo = NULL;
368 unsigned long reset_time;
369
370 spin_lock_bh(&orig_node->neigh_list_lock);
371
372 orig_ifinfo = batadv_orig_ifinfo_get(orig_node, if_outgoing);
373 if (orig_ifinfo)
374 goto out;
375
376 orig_ifinfo = kzalloc(sizeof(*orig_ifinfo), GFP_ATOMIC);
377 if (!orig_ifinfo)
378 goto out;
379
17a86915
SE
380 if (if_outgoing != BATADV_IF_DEFAULT)
381 kref_get(&if_outgoing->refcount);
7351a482
SW
382
383 reset_time = jiffies - 1;
384 reset_time -= msecs_to_jiffies(BATADV_RESET_PROTECTION_MS);
385 orig_ifinfo->batman_seqno_reset = reset_time;
386 orig_ifinfo->if_outgoing = if_outgoing;
387 INIT_HLIST_NODE(&orig_ifinfo->list);
a6ba0d34 388 kref_init(&orig_ifinfo->refcount);
f257b99b 389
a6ba0d34 390 kref_get(&orig_ifinfo->refcount);
7351a482
SW
391 hlist_add_head_rcu(&orig_ifinfo->list,
392 &orig_node->ifinfo_list);
393out:
394 spin_unlock_bh(&orig_node->neigh_list_lock);
395 return orig_ifinfo;
396}
397
89652331
SW
398/**
399 * batadv_neigh_ifinfo_get - find the ifinfo from an neigh_node
e51f0397 400 * @neigh: the neigh node to be queried
89652331
SW
401 * @if_outgoing: the interface for which the ifinfo should be acquired
402 *
403 * The object is returned with refcounter increased by 1.
404 *
62fe710f 405 * Return: the requested neigh_ifinfo or NULL if not found
89652331
SW
406 */
407struct batadv_neigh_ifinfo *
408batadv_neigh_ifinfo_get(struct batadv_neigh_node *neigh,
409 struct batadv_hard_iface *if_outgoing)
410{
411 struct batadv_neigh_ifinfo *neigh_ifinfo = NULL,
412 *tmp_neigh_ifinfo;
413
414 rcu_read_lock();
415 hlist_for_each_entry_rcu(tmp_neigh_ifinfo, &neigh->ifinfo_list,
416 list) {
417 if (tmp_neigh_ifinfo->if_outgoing != if_outgoing)
418 continue;
419
962c6832 420 if (!kref_get_unless_zero(&tmp_neigh_ifinfo->refcount))
89652331
SW
421 continue;
422
423 neigh_ifinfo = tmp_neigh_ifinfo;
424 break;
425 }
426 rcu_read_unlock();
427
428 return neigh_ifinfo;
429}
430
431/**
432 * batadv_neigh_ifinfo_new - search and possibly create an neigh_ifinfo object
e51f0397 433 * @neigh: the neigh node to be queried
89652331
SW
434 * @if_outgoing: the interface for which the ifinfo should be acquired
435 *
62fe710f 436 * Return: NULL in case of failure or the neigh_ifinfo object for the
89652331
SW
437 * if_outgoing interface otherwise. The object is created and added to the list
438 * if it does not exist.
439 *
440 * The object is returned with refcounter increased by 1.
441 */
442struct batadv_neigh_ifinfo *
443batadv_neigh_ifinfo_new(struct batadv_neigh_node *neigh,
444 struct batadv_hard_iface *if_outgoing)
445{
446 struct batadv_neigh_ifinfo *neigh_ifinfo;
447
448 spin_lock_bh(&neigh->ifinfo_lock);
449
450 neigh_ifinfo = batadv_neigh_ifinfo_get(neigh, if_outgoing);
451 if (neigh_ifinfo)
452 goto out;
453
454 neigh_ifinfo = kzalloc(sizeof(*neigh_ifinfo), GFP_ATOMIC);
455 if (!neigh_ifinfo)
456 goto out;
457
17a86915
SE
458 if (if_outgoing)
459 kref_get(&if_outgoing->refcount);
89652331
SW
460
461 INIT_HLIST_NODE(&neigh_ifinfo->list);
962c6832 462 kref_init(&neigh_ifinfo->refcount);
89652331
SW
463 neigh_ifinfo->if_outgoing = if_outgoing;
464
2e774ac2 465 kref_get(&neigh_ifinfo->refcount);
89652331
SW
466 hlist_add_head_rcu(&neigh_ifinfo->list, &neigh->ifinfo_list);
467
468out:
469 spin_unlock_bh(&neigh->ifinfo_lock);
470
471 return neigh_ifinfo;
472}
473
ed292663
ML
474/**
475 * batadv_neigh_node_get - retrieve a neighbour from the list
476 * @orig_node: originator which the neighbour belongs to
477 * @hard_iface: the interface where this neighbour is connected to
478 * @addr: the address of the neighbour
479 *
480 * Looks for and possibly returns a neighbour belonging to this originator list
481 * which is connected through the provided hard interface.
62fe710f
SE
482 *
483 * Return: neighbor when found. Othwerwise NULL
ed292663
ML
484 */
485static struct batadv_neigh_node *
486batadv_neigh_node_get(const struct batadv_orig_node *orig_node,
487 const struct batadv_hard_iface *hard_iface,
488 const u8 *addr)
489{
490 struct batadv_neigh_node *tmp_neigh_node, *res = NULL;
491
492 rcu_read_lock();
493 hlist_for_each_entry_rcu(tmp_neigh_node, &orig_node->neigh_list, list) {
494 if (!batadv_compare_eth(tmp_neigh_node->addr, addr))
495 continue;
496
497 if (tmp_neigh_node->if_incoming != hard_iface)
498 continue;
499
77ae32e8 500 if (!kref_get_unless_zero(&tmp_neigh_node->refcount))
ed292663
ML
501 continue;
502
503 res = tmp_neigh_node;
504 break;
505 }
506 rcu_read_unlock();
507
508 return res;
509}
510
cef63419
ML
511/**
512 * batadv_hardif_neigh_create - create a hardif neighbour node
513 * @hard_iface: the interface this neighbour is connected to
514 * @neigh_addr: the interface address of the neighbour to retrieve
515 *
62fe710f 516 * Return: the hardif neighbour node if found or created or NULL otherwise.
cef63419
ML
517 */
518static struct batadv_hardif_neigh_node *
519batadv_hardif_neigh_create(struct batadv_hard_iface *hard_iface,
520 const u8 *neigh_addr)
521{
8248a4c7 522 struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
cef63419
ML
523 struct batadv_hardif_neigh_node *hardif_neigh = NULL;
524
525 spin_lock_bh(&hard_iface->neigh_list_lock);
526
527 /* check if neighbor hasn't been added in the meantime */
528 hardif_neigh = batadv_hardif_neigh_get(hard_iface, neigh_addr);
529 if (hardif_neigh)
530 goto out;
531
cef63419 532 hardif_neigh = kzalloc(sizeof(*hardif_neigh), GFP_ATOMIC);
17a86915 533 if (!hardif_neigh)
cef63419 534 goto out;
cef63419 535
17a86915 536 kref_get(&hard_iface->refcount);
cef63419
ML
537 INIT_HLIST_NODE(&hardif_neigh->list);
538 ether_addr_copy(hardif_neigh->addr, neigh_addr);
539 hardif_neigh->if_incoming = hard_iface;
540 hardif_neigh->last_seen = jiffies;
541
90f564df 542 kref_init(&hardif_neigh->refcount);
cef63419 543
29824a55
AQ
544 if (bat_priv->algo_ops->neigh.hardif_init)
545 bat_priv->algo_ops->neigh.hardif_init(hardif_neigh);
8248a4c7 546
cef63419
ML
547 hlist_add_head(&hardif_neigh->list, &hard_iface->neigh_list);
548
549out:
550 spin_unlock_bh(&hard_iface->neigh_list_lock);
551 return hardif_neigh;
552}
553
554/**
555 * batadv_hardif_neigh_get_or_create - retrieve or create a hardif neighbour
556 * node
557 * @hard_iface: the interface this neighbour is connected to
558 * @neigh_addr: the interface address of the neighbour to retrieve
559 *
62fe710f 560 * Return: the hardif neighbour node if found or created or NULL otherwise.
cef63419
ML
561 */
562static struct batadv_hardif_neigh_node *
563batadv_hardif_neigh_get_or_create(struct batadv_hard_iface *hard_iface,
564 const u8 *neigh_addr)
565{
566 struct batadv_hardif_neigh_node *hardif_neigh = NULL;
567
568 /* first check without locking to avoid the overhead */
569 hardif_neigh = batadv_hardif_neigh_get(hard_iface, neigh_addr);
570 if (hardif_neigh)
571 return hardif_neigh;
572
573 return batadv_hardif_neigh_create(hard_iface, neigh_addr);
574}
575
576/**
577 * batadv_hardif_neigh_get - retrieve a hardif neighbour from the list
578 * @hard_iface: the interface where this neighbour is connected to
579 * @neigh_addr: the address of the neighbour
580 *
581 * Looks for and possibly returns a neighbour belonging to this hard interface.
62fe710f
SE
582 *
583 * Return: neighbor when found. Othwerwise NULL
cef63419
ML
584 */
585struct batadv_hardif_neigh_node *
586batadv_hardif_neigh_get(const struct batadv_hard_iface *hard_iface,
587 const u8 *neigh_addr)
588{
589 struct batadv_hardif_neigh_node *tmp_hardif_neigh, *hardif_neigh = NULL;
590
591 rcu_read_lock();
592 hlist_for_each_entry_rcu(tmp_hardif_neigh,
593 &hard_iface->neigh_list, list) {
594 if (!batadv_compare_eth(tmp_hardif_neigh->addr, neigh_addr))
595 continue;
596
90f564df 597 if (!kref_get_unless_zero(&tmp_hardif_neigh->refcount))
cef63419
ML
598 continue;
599
600 hardif_neigh = tmp_hardif_neigh;
601 break;
602 }
603 rcu_read_unlock();
604
605 return hardif_neigh;
606}
607
0538f759 608/**
6f0a6b5e 609 * batadv_neigh_node_create - create a neigh node object
3f32f8a6 610 * @orig_node: originator object representing the neighbour
0538f759
AQ
611 * @hard_iface: the interface where the neighbour is connected to
612 * @neigh_addr: the mac address of the neighbour interface
0538f759
AQ
613 *
614 * Allocates a new neigh_node object and initialises all the generic fields.
62fe710f 615 *
6f0a6b5e 616 * Return: the neighbour node if found or created or NULL otherwise.
0538f759 617 */
6f0a6b5e
ML
618static struct batadv_neigh_node *
619batadv_neigh_node_create(struct batadv_orig_node *orig_node,
620 struct batadv_hard_iface *hard_iface,
621 const u8 *neigh_addr)
c6c8fea2 622{
56303d34 623 struct batadv_neigh_node *neigh_node;
cef63419 624 struct batadv_hardif_neigh_node *hardif_neigh = NULL;
c6c8fea2 625
e123705e
LL
626 spin_lock_bh(&orig_node->neigh_list_lock);
627
741aa06b
ML
628 neigh_node = batadv_neigh_node_get(orig_node, hard_iface, neigh_addr);
629 if (neigh_node)
630 goto out;
631
cef63419
ML
632 hardif_neigh = batadv_hardif_neigh_get_or_create(hard_iface,
633 neigh_addr);
634 if (!hardif_neigh)
635 goto out;
636
704509b8 637 neigh_node = kzalloc(sizeof(*neigh_node), GFP_ATOMIC);
c6c8fea2 638 if (!neigh_node)
7ae8b285 639 goto out;
c6c8fea2 640
9591a79f 641 INIT_HLIST_NODE(&neigh_node->list);
89652331
SW
642 INIT_HLIST_HEAD(&neigh_node->ifinfo_list);
643 spin_lock_init(&neigh_node->ifinfo_lock);
c6c8fea2 644
17a86915 645 kref_get(&hard_iface->refcount);
8fdd0153 646 ether_addr_copy(neigh_node->addr, neigh_addr);
0538f759
AQ
647 neigh_node->if_incoming = hard_iface;
648 neigh_node->orig_node = orig_node;
e48474ed 649 neigh_node->last_seen = jiffies;
0538f759 650
abe59c65
SE
651 /* increment unique neighbor refcount */
652 kref_get(&hardif_neigh->refcount);
653 neigh_node->hardif_neigh = hardif_neigh;
654
1605d0d6 655 /* extra reference for return */
77ae32e8 656 kref_init(&neigh_node->refcount);
c6c8fea2 657
84274458 658 kref_get(&neigh_node->refcount);
741aa06b 659 hlist_add_head_rcu(&neigh_node->list, &orig_node->neigh_list);
741aa06b
ML
660
661 batadv_dbg(BATADV_DBG_BATMAN, orig_node->bat_priv,
662 "Creating new neighbor %pM for orig_node %pM on interface %s\n",
663 neigh_addr, orig_node->orig, hard_iface->net_dev->name);
664
7ae8b285 665out:
e123705e
LL
666 spin_unlock_bh(&orig_node->neigh_list_lock);
667
cef63419 668 if (hardif_neigh)
accadc35 669 batadv_hardif_neigh_put(hardif_neigh);
c6c8fea2
SE
670 return neigh_node;
671}
672
6f0a6b5e
ML
673/**
674 * batadv_neigh_node_get_or_create - retrieve or create a neigh node object
675 * @orig_node: originator object representing the neighbour
676 * @hard_iface: the interface where the neighbour is connected to
677 * @neigh_addr: the mac address of the neighbour interface
678 *
679 * Return: the neighbour node if found or created or NULL otherwise.
680 */
681struct batadv_neigh_node *
682batadv_neigh_node_get_or_create(struct batadv_orig_node *orig_node,
683 struct batadv_hard_iface *hard_iface,
684 const u8 *neigh_addr)
685{
686 struct batadv_neigh_node *neigh_node = NULL;
687
688 /* first check without locking to avoid the overhead */
689 neigh_node = batadv_neigh_node_get(orig_node, hard_iface, neigh_addr);
690 if (neigh_node)
691 return neigh_node;
692
693 return batadv_neigh_node_create(orig_node, hard_iface, neigh_addr);
694}
695
dc1cbd14 696#ifdef CONFIG_BATMAN_ADV_DEBUGFS
7587405a
ML
697/**
698 * batadv_hardif_neigh_seq_print_text - print the single hop neighbour list
699 * @seq: neighbour table seq_file struct
700 * @offset: not used
701 *
62fe710f 702 * Return: always 0
7587405a
ML
703 */
704int batadv_hardif_neigh_seq_print_text(struct seq_file *seq, void *offset)
705{
706 struct net_device *net_dev = (struct net_device *)seq->private;
707 struct batadv_priv *bat_priv = netdev_priv(net_dev);
708 struct batadv_hard_iface *primary_if;
709
710 primary_if = batadv_seq_print_text_primary_if_get(seq);
711 if (!primary_if)
712 return 0;
713
714 seq_printf(seq, "[B.A.T.M.A.N. adv %s, MainIF/MAC: %s/%pM (%s %s)]\n",
715 BATADV_SOURCE_VERSION, primary_if->net_dev->name,
716 primary_if->net_dev->dev_addr, net_dev->name,
29824a55 717 bat_priv->algo_ops->name);
7587405a 718
82047ad7 719 batadv_hardif_put(primary_if);
7587405a 720
29824a55 721 if (!bat_priv->algo_ops->neigh.print) {
7587405a
ML
722 seq_puts(seq,
723 "No printing function for this routing protocol\n");
724 return 0;
725 }
726
29824a55 727 bat_priv->algo_ops->neigh.print(bat_priv, seq);
7587405a
ML
728 return 0;
729}
dc1cbd14 730#endif
7587405a 731
85cf8c85
MS
732/**
733 * batadv_hardif_neigh_dump - Dump to netlink the neighbor infos for a specific
734 * outgoing interface
735 * @msg: message to dump into
736 * @cb: parameters for the dump
737 *
738 * Return: 0 or error value
739 */
740int batadv_hardif_neigh_dump(struct sk_buff *msg, struct netlink_callback *cb)
741{
742 struct net *net = sock_net(cb->skb->sk);
743 struct net_device *soft_iface;
744 struct net_device *hard_iface = NULL;
745 struct batadv_hard_iface *hardif = BATADV_IF_DEFAULT;
746 struct batadv_priv *bat_priv;
747 struct batadv_hard_iface *primary_if = NULL;
748 int ret;
749 int ifindex, hard_ifindex;
750
751 ifindex = batadv_netlink_get_ifindex(cb->nlh, BATADV_ATTR_MESH_IFINDEX);
752 if (!ifindex)
753 return -EINVAL;
754
755 soft_iface = dev_get_by_index(net, ifindex);
756 if (!soft_iface || !batadv_softif_is_valid(soft_iface)) {
757 ret = -ENODEV;
758 goto out;
759 }
760
761 bat_priv = netdev_priv(soft_iface);
762
763 primary_if = batadv_primary_if_get_selected(bat_priv);
764 if (!primary_if || primary_if->if_status != BATADV_IF_ACTIVE) {
765 ret = -ENOENT;
766 goto out;
767 }
768
769 hard_ifindex = batadv_netlink_get_ifindex(cb->nlh,
770 BATADV_ATTR_HARD_IFINDEX);
771 if (hard_ifindex) {
772 hard_iface = dev_get_by_index(net, hard_ifindex);
773 if (hard_iface)
774 hardif = batadv_hardif_get_by_netdev(hard_iface);
775
776 if (!hardif) {
777 ret = -ENODEV;
778 goto out;
779 }
780
781 if (hardif->soft_iface != soft_iface) {
782 ret = -ENOENT;
783 goto out;
784 }
785 }
786
787 if (!bat_priv->algo_ops->neigh.dump) {
788 ret = -EOPNOTSUPP;
789 goto out;
790 }
791
792 bat_priv->algo_ops->neigh.dump(msg, cb, bat_priv, hardif);
793
794 ret = msg->len;
795
796 out:
797 if (hardif)
798 batadv_hardif_put(hardif);
799 if (hard_iface)
800 dev_put(hard_iface);
801 if (primary_if)
802 batadv_hardif_put(primary_if);
803 if (soft_iface)
804 dev_put(soft_iface);
805
806 return ret;
807}
808
7351a482 809/**
2baa753c
SE
810 * batadv_orig_ifinfo_release - release orig_ifinfo from lists and queue for
811 * free after rcu grace period
a6ba0d34 812 * @ref: kref pointer of the orig_ifinfo
7351a482 813 */
a6ba0d34 814static void batadv_orig_ifinfo_release(struct kref *ref)
7351a482 815{
a6ba0d34 816 struct batadv_orig_ifinfo *orig_ifinfo;
000c8dff 817 struct batadv_neigh_node *router;
7351a482 818
a6ba0d34
SE
819 orig_ifinfo = container_of(ref, struct batadv_orig_ifinfo, refcount);
820
7351a482 821 if (orig_ifinfo->if_outgoing != BATADV_IF_DEFAULT)
82047ad7 822 batadv_hardif_put(orig_ifinfo->if_outgoing);
7351a482 823
000c8dff
SW
824 /* this is the last reference to this object */
825 router = rcu_dereference_protected(orig_ifinfo->router, true);
826 if (router)
25bb2509 827 batadv_neigh_node_put(router);
2baa753c
SE
828
829 kfree_rcu(orig_ifinfo, rcu);
7351a482
SW
830}
831
832/**
35f94779 833 * batadv_orig_ifinfo_put - decrement the refcounter and possibly release
deed9660 834 * the orig_ifinfo
7351a482
SW
835 * @orig_ifinfo: the orig_ifinfo object to release
836 */
35f94779 837void batadv_orig_ifinfo_put(struct batadv_orig_ifinfo *orig_ifinfo)
7351a482 838{
a6ba0d34 839 kref_put(&orig_ifinfo->refcount, batadv_orig_ifinfo_release);
7351a482
SW
840}
841
842/**
deed9660
SE
843 * batadv_orig_node_free_rcu - free the orig_node
844 * @rcu: rcu pointer of the orig_node
7351a482 845 */
deed9660 846static void batadv_orig_node_free_rcu(struct rcu_head *rcu)
7351a482 847{
deed9660
SE
848 struct batadv_orig_node *orig_node;
849
850 orig_node = container_of(rcu, struct batadv_orig_node, rcu);
851
852 batadv_mcast_purge_orig(orig_node);
853
854 batadv_frag_purge_orig(orig_node, NULL);
855
29824a55
AQ
856 if (orig_node->bat_priv->algo_ops->orig.free)
857 orig_node->bat_priv->algo_ops->orig.free(orig_node);
deed9660
SE
858
859 kfree(orig_node->tt_buff);
860 kfree(orig_node);
7351a482
SW
861}
862
deed9660
SE
863/**
864 * batadv_orig_node_release - release orig_node from lists and queue for
865 * free after rcu grace period
7c124391 866 * @ref: kref pointer of the orig_node
deed9660 867 */
7c124391 868static void batadv_orig_node_release(struct kref *ref)
c6c8fea2 869{
b67bfe0d 870 struct hlist_node *node_tmp;
f6c8b711 871 struct batadv_neigh_node *neigh_node;
7c124391 872 struct batadv_orig_node *orig_node;
7351a482 873 struct batadv_orig_ifinfo *orig_ifinfo;
33fbb1f3 874 struct batadv_orig_node_vlan *vlan;
cbef1e10 875 struct batadv_orig_ifinfo *last_candidate;
16b1aba8 876
7c124391
SE
877 orig_node = container_of(ref, struct batadv_orig_node, refcount);
878
f987ed6e
ML
879 spin_lock_bh(&orig_node->neigh_list_lock);
880
c6c8fea2 881 /* for all neighbors towards this originator ... */
b67bfe0d 882 hlist_for_each_entry_safe(neigh_node, node_tmp,
9591a79f 883 &orig_node->neigh_list, list) {
f987ed6e 884 hlist_del_rcu(&neigh_node->list);
25bb2509 885 batadv_neigh_node_put(neigh_node);
c6c8fea2
SE
886 }
887
7351a482
SW
888 hlist_for_each_entry_safe(orig_ifinfo, node_tmp,
889 &orig_node->ifinfo_list, list) {
890 hlist_del_rcu(&orig_ifinfo->list);
35f94779 891 batadv_orig_ifinfo_put(orig_ifinfo);
7351a482 892 }
cbef1e10
SE
893
894 last_candidate = orig_node->last_bonding_candidate;
895 orig_node->last_bonding_candidate = NULL;
f987ed6e
ML
896 spin_unlock_bh(&orig_node->neigh_list_lock);
897
cbef1e10
SE
898 if (last_candidate)
899 batadv_orig_ifinfo_put(last_candidate);
900
33fbb1f3
SE
901 spin_lock_bh(&orig_node->vlan_list_lock);
902 hlist_for_each_entry_safe(vlan, node_tmp, &orig_node->vlan_list, list) {
903 hlist_del_rcu(&vlan->list);
904 batadv_orig_node_vlan_put(vlan);
905 }
906 spin_unlock_bh(&orig_node->vlan_list_lock);
907
d56b1705
MH
908 /* Free nc_nodes */
909 batadv_nc_purge_orig(orig_node->bat_priv, orig_node, NULL);
910
deed9660 911 call_rcu(&orig_node->rcu, batadv_orig_node_free_rcu);
c6c8fea2
SE
912}
913
72822225 914/**
5d967310 915 * batadv_orig_node_put - decrement the orig node refcounter and possibly
deed9660 916 * release it
72822225
LL
917 * @orig_node: the orig node to free
918 */
5d967310 919void batadv_orig_node_put(struct batadv_orig_node *orig_node)
7b36e8ee 920{
7c124391 921 kref_put(&orig_node->refcount, batadv_orig_node_release);
7b36e8ee
ML
922}
923
56303d34 924void batadv_originator_free(struct batadv_priv *bat_priv)
c6c8fea2 925{
5bf74e9c 926 struct batadv_hashtable *hash = bat_priv->orig_hash;
b67bfe0d 927 struct hlist_node *node_tmp;
16b1aba8 928 struct hlist_head *head;
16b1aba8 929 spinlock_t *list_lock; /* spinlock to protect write access */
56303d34 930 struct batadv_orig_node *orig_node;
6b5e971a 931 u32 i;
16b1aba8
ML
932
933 if (!hash)
c6c8fea2
SE
934 return;
935
936 cancel_delayed_work_sync(&bat_priv->orig_work);
937
c6c8fea2 938 bat_priv->orig_hash = NULL;
16b1aba8
ML
939
940 for (i = 0; i < hash->size; i++) {
941 head = &hash->table[i];
942 list_lock = &hash->list_locks[i];
943
944 spin_lock_bh(list_lock);
b67bfe0d 945 hlist_for_each_entry_safe(orig_node, node_tmp,
7aadf889 946 head, hash_entry) {
b67bfe0d 947 hlist_del_rcu(&orig_node->hash_entry);
5d967310 948 batadv_orig_node_put(orig_node);
16b1aba8
ML
949 }
950 spin_unlock_bh(list_lock);
951 }
952
1a8eaf07 953 batadv_hash_destroy(hash);
c6c8fea2
SE
954}
955
bbad0a5e
AQ
956/**
957 * batadv_orig_node_new - creates a new orig_node
958 * @bat_priv: the bat priv with all the soft interface information
959 * @addr: the mac address of the originator
960 *
961 * Creates a new originator object and initialise all the generic fields.
962 * The new object is not added to the originator list.
62fe710f
SE
963 *
964 * Return: the newly created object or NULL on failure.
9cfc7bd6 965 */
bbad0a5e 966struct batadv_orig_node *batadv_orig_node_new(struct batadv_priv *bat_priv,
6b5e971a 967 const u8 *addr)
c6c8fea2 968{
56303d34 969 struct batadv_orig_node *orig_node;
7ea7b4a1 970 struct batadv_orig_node_vlan *vlan;
42d0b044 971 unsigned long reset_time;
bbad0a5e 972 int i;
c6c8fea2 973
39c75a51
SE
974 batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
975 "Creating new originator: %pM\n", addr);
c6c8fea2 976
704509b8 977 orig_node = kzalloc(sizeof(*orig_node), GFP_ATOMIC);
c6c8fea2
SE
978 if (!orig_node)
979 return NULL;
980
9591a79f 981 INIT_HLIST_HEAD(&orig_node->neigh_list);
d0fa4f3f 982 INIT_HLIST_HEAD(&orig_node->vlan_list);
7351a482 983 INIT_HLIST_HEAD(&orig_node->ifinfo_list);
f3e0008f 984 spin_lock_init(&orig_node->bcast_seqno_lock);
f987ed6e 985 spin_lock_init(&orig_node->neigh_list_lock);
a73105b8 986 spin_lock_init(&orig_node->tt_buff_lock);
a70a9aa9 987 spin_lock_init(&orig_node->tt_lock);
7ea7b4a1 988 spin_lock_init(&orig_node->vlan_list_lock);
7b36e8ee 989
d56b1705
MH
990 batadv_nc_init_orig(orig_node);
991
7b36e8ee 992 /* extra reference for return */
7c124391 993 kref_init(&orig_node->refcount);
c6c8fea2 994
16b1aba8 995 orig_node->bat_priv = bat_priv;
8fdd0153 996 ether_addr_copy(orig_node->orig, addr);
785ea114 997 batadv_dat_init_orig_node_addr(orig_node);
c8c991bf 998 atomic_set(&orig_node->last_ttvn, 0);
2dafb49d 999 orig_node->tt_buff = NULL;
a73105b8 1000 orig_node->tt_buff_len = 0;
2c667a33 1001 orig_node->last_seen = jiffies;
42d0b044
SE
1002 reset_time = jiffies - 1 - msecs_to_jiffies(BATADV_RESET_PROTECTION_MS);
1003 orig_node->bcast_seqno_reset = reset_time;
8a4023c5 1004
60432d75
LL
1005#ifdef CONFIG_BATMAN_ADV_MCAST
1006 orig_node->mcast_flags = BATADV_NO_FLAGS;
8a4023c5
LL
1007 INIT_HLIST_NODE(&orig_node->mcast_want_all_unsnoopables_node);
1008 INIT_HLIST_NODE(&orig_node->mcast_want_all_ipv4_node);
1009 INIT_HLIST_NODE(&orig_node->mcast_want_all_ipv6_node);
1010 spin_lock_init(&orig_node->mcast_handler_lock);
60432d75 1011#endif
c6c8fea2 1012
7ea7b4a1
AQ
1013 /* create a vlan object for the "untagged" LAN */
1014 vlan = batadv_orig_node_vlan_new(orig_node, BATADV_NO_FLAGS);
1015 if (!vlan)
1016 goto free_orig_node;
1017 /* batadv_orig_node_vlan_new() increases the refcounter.
1018 * Immediately release vlan since it is not needed anymore in this
1019 * context
1020 */
21754e25 1021 batadv_orig_node_vlan_put(vlan);
7ea7b4a1 1022
610bfc6b
MH
1023 for (i = 0; i < BATADV_FRAG_BUFFER_COUNT; i++) {
1024 INIT_HLIST_HEAD(&orig_node->fragments[i].head);
1025 spin_lock_init(&orig_node->fragments[i].lock);
1026 orig_node->fragments[i].size = 0;
1027 }
1028
c6c8fea2 1029 return orig_node;
c6c8fea2
SE
1030free_orig_node:
1031 kfree(orig_node);
1032 return NULL;
1033}
1034
709de13f
SW
1035/**
1036 * batadv_purge_neigh_ifinfo - purge obsolete ifinfo entries from neighbor
1037 * @bat_priv: the bat priv with all the soft interface information
1038 * @neigh: orig node which is to be checked
1039 */
1040static void
1041batadv_purge_neigh_ifinfo(struct batadv_priv *bat_priv,
1042 struct batadv_neigh_node *neigh)
1043{
1044 struct batadv_neigh_ifinfo *neigh_ifinfo;
1045 struct batadv_hard_iface *if_outgoing;
1046 struct hlist_node *node_tmp;
1047
1048 spin_lock_bh(&neigh->ifinfo_lock);
1049
1050 /* for all ifinfo objects for this neighinator */
1051 hlist_for_each_entry_safe(neigh_ifinfo, node_tmp,
1052 &neigh->ifinfo_list, list) {
1053 if_outgoing = neigh_ifinfo->if_outgoing;
1054
1055 /* always keep the default interface */
1056 if (if_outgoing == BATADV_IF_DEFAULT)
1057 continue;
1058
1059 /* don't purge if the interface is not (going) down */
1060 if ((if_outgoing->if_status != BATADV_IF_INACTIVE) &&
1061 (if_outgoing->if_status != BATADV_IF_NOT_IN_USE) &&
1062 (if_outgoing->if_status != BATADV_IF_TO_BE_REMOVED))
1063 continue;
1064
1065 batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1066 "neighbor/ifinfo purge: neighbor %pM, iface: %s\n",
1067 neigh->addr, if_outgoing->net_dev->name);
1068
1069 hlist_del_rcu(&neigh_ifinfo->list);
044fa3ae 1070 batadv_neigh_ifinfo_put(neigh_ifinfo);
709de13f
SW
1071 }
1072
1073 spin_unlock_bh(&neigh->ifinfo_lock);
1074}
1075
7351a482
SW
1076/**
1077 * batadv_purge_orig_ifinfo - purge obsolete ifinfo entries from originator
1078 * @bat_priv: the bat priv with all the soft interface information
1079 * @orig_node: orig node which is to be checked
1080 *
62fe710f 1081 * Return: true if any ifinfo entry was purged, false otherwise.
7351a482
SW
1082 */
1083static bool
1084batadv_purge_orig_ifinfo(struct batadv_priv *bat_priv,
1085 struct batadv_orig_node *orig_node)
1086{
1087 struct batadv_orig_ifinfo *orig_ifinfo;
1088 struct batadv_hard_iface *if_outgoing;
1089 struct hlist_node *node_tmp;
1090 bool ifinfo_purged = false;
1091
1092 spin_lock_bh(&orig_node->neigh_list_lock);
1093
1094 /* for all ifinfo objects for this originator */
1095 hlist_for_each_entry_safe(orig_ifinfo, node_tmp,
1096 &orig_node->ifinfo_list, list) {
1097 if_outgoing = orig_ifinfo->if_outgoing;
1098
1099 /* always keep the default interface */
1100 if (if_outgoing == BATADV_IF_DEFAULT)
1101 continue;
1102
1103 /* don't purge if the interface is not (going) down */
1104 if ((if_outgoing->if_status != BATADV_IF_INACTIVE) &&
1105 (if_outgoing->if_status != BATADV_IF_NOT_IN_USE) &&
1106 (if_outgoing->if_status != BATADV_IF_TO_BE_REMOVED))
1107 continue;
1108
1109 batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1110 "router/ifinfo purge: originator %pM, iface: %s\n",
1111 orig_node->orig, if_outgoing->net_dev->name);
1112
1113 ifinfo_purged = true;
1114
1115 hlist_del_rcu(&orig_ifinfo->list);
35f94779 1116 batadv_orig_ifinfo_put(orig_ifinfo);
f3b3d901
SW
1117 if (orig_node->last_bonding_candidate == orig_ifinfo) {
1118 orig_node->last_bonding_candidate = NULL;
35f94779 1119 batadv_orig_ifinfo_put(orig_ifinfo);
f3b3d901 1120 }
7351a482
SW
1121 }
1122
1123 spin_unlock_bh(&orig_node->neigh_list_lock);
1124
1125 return ifinfo_purged;
1126}
1127
89652331
SW
1128/**
1129 * batadv_purge_orig_neighbors - purges neighbors from originator
1130 * @bat_priv: the bat priv with all the soft interface information
1131 * @orig_node: orig node which is to be checked
1132 *
62fe710f 1133 * Return: true if any neighbor was purged, false otherwise
89652331 1134 */
56303d34
SE
1135static bool
1136batadv_purge_orig_neighbors(struct batadv_priv *bat_priv,
89652331 1137 struct batadv_orig_node *orig_node)
c6c8fea2 1138{
b67bfe0d 1139 struct hlist_node *node_tmp;
56303d34 1140 struct batadv_neigh_node *neigh_node;
c6c8fea2 1141 bool neigh_purged = false;
0b0094e0 1142 unsigned long last_seen;
56303d34 1143 struct batadv_hard_iface *if_incoming;
c6c8fea2 1144
f987ed6e
ML
1145 spin_lock_bh(&orig_node->neigh_list_lock);
1146
c6c8fea2 1147 /* for all neighbors towards this originator ... */
b67bfe0d 1148 hlist_for_each_entry_safe(neigh_node, node_tmp,
9591a79f 1149 &orig_node->neigh_list, list) {
1eda58bf
SE
1150 last_seen = neigh_node->last_seen;
1151 if_incoming = neigh_node->if_incoming;
1152
42d0b044 1153 if ((batadv_has_timed_out(last_seen, BATADV_PURGE_TIMEOUT)) ||
e9a4f295
SE
1154 (if_incoming->if_status == BATADV_IF_INACTIVE) ||
1155 (if_incoming->if_status == BATADV_IF_NOT_IN_USE) ||
1156 (if_incoming->if_status == BATADV_IF_TO_BE_REMOVED)) {
e9a4f295
SE
1157 if ((if_incoming->if_status == BATADV_IF_INACTIVE) ||
1158 (if_incoming->if_status == BATADV_IF_NOT_IN_USE) ||
1159 (if_incoming->if_status == BATADV_IF_TO_BE_REMOVED))
39c75a51 1160 batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1eda58bf
SE
1161 "neighbor purge: originator %pM, neighbor: %pM, iface: %s\n",
1162 orig_node->orig, neigh_node->addr,
1163 if_incoming->net_dev->name);
c6c8fea2 1164 else
39c75a51 1165 batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1eda58bf
SE
1166 "neighbor timeout: originator %pM, neighbor: %pM, last_seen: %u\n",
1167 orig_node->orig, neigh_node->addr,
1168 jiffies_to_msecs(last_seen));
c6c8fea2
SE
1169
1170 neigh_purged = true;
9591a79f 1171
f987ed6e 1172 hlist_del_rcu(&neigh_node->list);
25bb2509 1173 batadv_neigh_node_put(neigh_node);
709de13f
SW
1174 } else {
1175 /* only necessary if not the whole neighbor is to be
1176 * deleted, but some interface has been removed.
1177 */
1178 batadv_purge_neigh_ifinfo(bat_priv, neigh_node);
c6c8fea2
SE
1179 }
1180 }
f987ed6e
ML
1181
1182 spin_unlock_bh(&orig_node->neigh_list_lock);
c6c8fea2
SE
1183 return neigh_purged;
1184}
1185
89652331
SW
1186/**
1187 * batadv_find_best_neighbor - finds the best neighbor after purging
1188 * @bat_priv: the bat priv with all the soft interface information
1189 * @orig_node: orig node which is to be checked
1190 * @if_outgoing: the interface for which the metric should be compared
1191 *
62fe710f 1192 * Return: the current best neighbor, with refcount increased.
89652331
SW
1193 */
1194static struct batadv_neigh_node *
1195batadv_find_best_neighbor(struct batadv_priv *bat_priv,
1196 struct batadv_orig_node *orig_node,
1197 struct batadv_hard_iface *if_outgoing)
1198{
1199 struct batadv_neigh_node *best = NULL, *neigh;
29824a55 1200 struct batadv_algo_ops *bao = bat_priv->algo_ops;
89652331
SW
1201
1202 rcu_read_lock();
1203 hlist_for_each_entry_rcu(neigh, &orig_node->neigh_list, list) {
29824a55
AQ
1204 if (best && (bao->neigh.cmp(neigh, if_outgoing, best,
1205 if_outgoing) <= 0))
89652331
SW
1206 continue;
1207
77ae32e8 1208 if (!kref_get_unless_zero(&neigh->refcount))
89652331
SW
1209 continue;
1210
1211 if (best)
25bb2509 1212 batadv_neigh_node_put(best);
89652331
SW
1213
1214 best = neigh;
1215 }
1216 rcu_read_unlock();
1217
1218 return best;
1219}
1220
7351a482
SW
1221/**
1222 * batadv_purge_orig_node - purges obsolete information from an orig_node
1223 * @bat_priv: the bat priv with all the soft interface information
1224 * @orig_node: orig node which is to be checked
1225 *
1226 * This function checks if the orig_node or substructures of it have become
1227 * obsolete, and purges this information if that's the case.
1228 *
62fe710f 1229 * Return: true if the orig_node is to be removed, false otherwise.
7351a482 1230 */
56303d34
SE
1231static bool batadv_purge_orig_node(struct batadv_priv *bat_priv,
1232 struct batadv_orig_node *orig_node)
c6c8fea2 1233{
56303d34 1234 struct batadv_neigh_node *best_neigh_node;
7351a482 1235 struct batadv_hard_iface *hard_iface;
7b955a9f 1236 bool changed_ifinfo, changed_neigh;
c6c8fea2 1237
42d0b044
SE
1238 if (batadv_has_timed_out(orig_node->last_seen,
1239 2 * BATADV_PURGE_TIMEOUT)) {
39c75a51 1240 batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
1eda58bf
SE
1241 "Originator timeout: originator %pM, last_seen %u\n",
1242 orig_node->orig,
1243 jiffies_to_msecs(orig_node->last_seen));
c6c8fea2 1244 return true;
c6c8fea2 1245 }
7b955a9f
SW
1246 changed_ifinfo = batadv_purge_orig_ifinfo(bat_priv, orig_node);
1247 changed_neigh = batadv_purge_orig_neighbors(bat_priv, orig_node);
7351a482 1248
7b955a9f 1249 if (!changed_ifinfo && !changed_neigh)
89652331
SW
1250 return false;
1251
7351a482 1252 /* first for NULL ... */
89652331
SW
1253 best_neigh_node = batadv_find_best_neighbor(bat_priv, orig_node,
1254 BATADV_IF_DEFAULT);
7351a482
SW
1255 batadv_update_route(bat_priv, orig_node, BATADV_IF_DEFAULT,
1256 best_neigh_node);
89652331 1257 if (best_neigh_node)
25bb2509 1258 batadv_neigh_node_put(best_neigh_node);
c6c8fea2 1259
7351a482
SW
1260 /* ... then for all other interfaces. */
1261 rcu_read_lock();
1262 list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) {
1263 if (hard_iface->if_status != BATADV_IF_ACTIVE)
1264 continue;
1265
1266 if (hard_iface->soft_iface != bat_priv->soft_iface)
1267 continue;
1268
27353446
SE
1269 if (!kref_get_unless_zero(&hard_iface->refcount))
1270 continue;
1271
7351a482
SW
1272 best_neigh_node = batadv_find_best_neighbor(bat_priv,
1273 orig_node,
1274 hard_iface);
1275 batadv_update_route(bat_priv, orig_node, hard_iface,
1276 best_neigh_node);
1277 if (best_neigh_node)
25bb2509 1278 batadv_neigh_node_put(best_neigh_node);
27353446
SE
1279
1280 batadv_hardif_put(hard_iface);
7351a482
SW
1281 }
1282 rcu_read_unlock();
1283
c6c8fea2
SE
1284 return false;
1285}
1286
56303d34 1287static void _batadv_purge_orig(struct batadv_priv *bat_priv)
c6c8fea2 1288{
5bf74e9c 1289 struct batadv_hashtable *hash = bat_priv->orig_hash;
b67bfe0d 1290 struct hlist_node *node_tmp;
c6c8fea2 1291 struct hlist_head *head;
fb778ea1 1292 spinlock_t *list_lock; /* spinlock to protect write access */
56303d34 1293 struct batadv_orig_node *orig_node;
6b5e971a 1294 u32 i;
c6c8fea2
SE
1295
1296 if (!hash)
1297 return;
1298
c6c8fea2
SE
1299 /* for all origins... */
1300 for (i = 0; i < hash->size; i++) {
1301 head = &hash->table[i];
fb778ea1 1302 list_lock = &hash->list_locks[i];
c6c8fea2 1303
fb778ea1 1304 spin_lock_bh(list_lock);
b67bfe0d 1305 hlist_for_each_entry_safe(orig_node, node_tmp,
7aadf889 1306 head, hash_entry) {
03fc7f86 1307 if (batadv_purge_orig_node(bat_priv, orig_node)) {
414254e3 1308 batadv_gw_node_delete(bat_priv, orig_node);
b67bfe0d 1309 hlist_del_rcu(&orig_node->hash_entry);
9d31b3ce
LL
1310 batadv_tt_global_del_orig(orig_node->bat_priv,
1311 orig_node, -1,
1312 "originator timed out");
5d967310 1313 batadv_orig_node_put(orig_node);
fb778ea1 1314 continue;
c6c8fea2 1315 }
610bfc6b
MH
1316
1317 batadv_frag_purge_orig(orig_node,
1318 batadv_frag_check_entry);
c6c8fea2 1319 }
fb778ea1 1320 spin_unlock_bh(list_lock);
c6c8fea2
SE
1321 }
1322
7cf06bc6 1323 batadv_gw_election(bat_priv);
c6c8fea2
SE
1324}
1325
03fc7f86 1326static void batadv_purge_orig(struct work_struct *work)
c6c8fea2 1327{
56303d34
SE
1328 struct delayed_work *delayed_work;
1329 struct batadv_priv *bat_priv;
c6c8fea2 1330
4ba4bc0f 1331 delayed_work = to_delayed_work(work);
56303d34 1332 bat_priv = container_of(delayed_work, struct batadv_priv, orig_work);
03fc7f86 1333 _batadv_purge_orig(bat_priv);
72414442
AQ
1334 queue_delayed_work(batadv_event_workqueue,
1335 &bat_priv->orig_work,
1336 msecs_to_jiffies(BATADV_ORIG_WORK_PERIOD));
c6c8fea2
SE
1337}
1338
56303d34 1339void batadv_purge_orig_ref(struct batadv_priv *bat_priv)
c6c8fea2 1340{
03fc7f86 1341 _batadv_purge_orig(bat_priv);
c6c8fea2
SE
1342}
1343
dc1cbd14 1344#ifdef CONFIG_BATMAN_ADV_DEBUGFS
7d211efc 1345int batadv_orig_seq_print_text(struct seq_file *seq, void *offset)
c6c8fea2
SE
1346{
1347 struct net_device *net_dev = (struct net_device *)seq->private;
56303d34 1348 struct batadv_priv *bat_priv = netdev_priv(net_dev);
56303d34 1349 struct batadv_hard_iface *primary_if;
32ae9b22 1350
30da63a6
ML
1351 primary_if = batadv_seq_print_text_primary_if_get(seq);
1352 if (!primary_if)
737a2a22 1353 return 0;
c6c8fea2 1354
737a2a22 1355 seq_printf(seq, "[B.A.T.M.A.N. adv %s, MainIF/MAC: %s/%pM (%s %s)]\n",
42d0b044 1356 BATADV_SOURCE_VERSION, primary_if->net_dev->name,
737a2a22 1357 primary_if->net_dev->dev_addr, net_dev->name,
29824a55 1358 bat_priv->algo_ops->name);
c6c8fea2 1359
82047ad7 1360 batadv_hardif_put(primary_if);
c6c8fea2 1361
29824a55 1362 if (!bat_priv->algo_ops->orig.print) {
737a2a22
AQ
1363 seq_puts(seq,
1364 "No printing function for this routing protocol\n");
1365 return 0;
c6c8fea2
SE
1366 }
1367
29824a55 1368 bat_priv->algo_ops->orig.print(bat_priv, seq, BATADV_IF_DEFAULT);
c6c8fea2 1369
30da63a6 1370 return 0;
c6c8fea2
SE
1371}
1372
cb1c92ec
SW
1373/**
1374 * batadv_orig_hardif_seq_print_text - writes originator infos for a specific
1375 * outgoing interface
1376 * @seq: debugfs table seq_file struct
1377 * @offset: not used
1378 *
62fe710f 1379 * Return: 0
cb1c92ec
SW
1380 */
1381int batadv_orig_hardif_seq_print_text(struct seq_file *seq, void *offset)
1382{
1383 struct net_device *net_dev = (struct net_device *)seq->private;
1384 struct batadv_hard_iface *hard_iface;
1385 struct batadv_priv *bat_priv;
1386
1387 hard_iface = batadv_hardif_get_by_netdev(net_dev);
1388
1389 if (!hard_iface || !hard_iface->soft_iface) {
1390 seq_puts(seq, "Interface not known to B.A.T.M.A.N.\n");
1391 goto out;
1392 }
1393
1394 bat_priv = netdev_priv(hard_iface->soft_iface);
29824a55 1395 if (!bat_priv->algo_ops->orig.print) {
cb1c92ec
SW
1396 seq_puts(seq,
1397 "No printing function for this routing protocol\n");
1398 goto out;
1399 }
1400
1401 if (hard_iface->if_status != BATADV_IF_ACTIVE) {
1402 seq_puts(seq, "Interface not active\n");
1403 goto out;
1404 }
1405
1406 seq_printf(seq, "[B.A.T.M.A.N. adv %s, IF/MAC: %s/%pM (%s %s)]\n",
1407 BATADV_SOURCE_VERSION, hard_iface->net_dev->name,
1408 hard_iface->net_dev->dev_addr,
29824a55 1409 hard_iface->soft_iface->name, bat_priv->algo_ops->name);
cb1c92ec 1410
29824a55 1411 bat_priv->algo_ops->orig.print(bat_priv, seq, hard_iface);
cb1c92ec
SW
1412
1413out:
16a41423 1414 if (hard_iface)
82047ad7 1415 batadv_hardif_put(hard_iface);
cb1c92ec
SW
1416 return 0;
1417}
dc1cbd14 1418#endif
cb1c92ec 1419
85cf8c85
MS
1420/**
1421 * batadv_orig_dump - Dump to netlink the originator infos for a specific
1422 * outgoing interface
1423 * @msg: message to dump into
1424 * @cb: parameters for the dump
1425 *
1426 * Return: 0 or error value
1427 */
1428int batadv_orig_dump(struct sk_buff *msg, struct netlink_callback *cb)
1429{
1430 struct net *net = sock_net(cb->skb->sk);
1431 struct net_device *soft_iface;
1432 struct net_device *hard_iface = NULL;
1433 struct batadv_hard_iface *hardif = BATADV_IF_DEFAULT;
1434 struct batadv_priv *bat_priv;
1435 struct batadv_hard_iface *primary_if = NULL;
1436 int ret;
1437 int ifindex, hard_ifindex;
1438
1439 ifindex = batadv_netlink_get_ifindex(cb->nlh, BATADV_ATTR_MESH_IFINDEX);
1440 if (!ifindex)
1441 return -EINVAL;
1442
1443 soft_iface = dev_get_by_index(net, ifindex);
1444 if (!soft_iface || !batadv_softif_is_valid(soft_iface)) {
1445 ret = -ENODEV;
1446 goto out;
1447 }
1448
1449 bat_priv = netdev_priv(soft_iface);
1450
1451 primary_if = batadv_primary_if_get_selected(bat_priv);
1452 if (!primary_if || primary_if->if_status != BATADV_IF_ACTIVE) {
1453 ret = -ENOENT;
1454 goto out;
1455 }
1456
1457 hard_ifindex = batadv_netlink_get_ifindex(cb->nlh,
1458 BATADV_ATTR_HARD_IFINDEX);
1459 if (hard_ifindex) {
1460 hard_iface = dev_get_by_index(net, hard_ifindex);
1461 if (hard_iface)
1462 hardif = batadv_hardif_get_by_netdev(hard_iface);
1463
1464 if (!hardif) {
1465 ret = -ENODEV;
1466 goto out;
1467 }
1468
1469 if (hardif->soft_iface != soft_iface) {
1470 ret = -ENOENT;
1471 goto out;
1472 }
1473 }
1474
1475 if (!bat_priv->algo_ops->orig.dump) {
1476 ret = -EOPNOTSUPP;
1477 goto out;
1478 }
1479
1480 bat_priv->algo_ops->orig.dump(msg, cb, bat_priv, hardif);
1481
1482 ret = msg->len;
1483
1484 out:
1485 if (hardif)
1486 batadv_hardif_put(hardif);
1487 if (hard_iface)
1488 dev_put(hard_iface);
1489 if (primary_if)
1490 batadv_hardif_put(primary_if);
1491 if (soft_iface)
1492 dev_put(soft_iface);
1493
1494 return ret;
1495}
1496
56303d34
SE
1497int batadv_orig_hash_add_if(struct batadv_hard_iface *hard_iface,
1498 int max_if_num)
c6c8fea2 1499{
56303d34 1500 struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
29824a55 1501 struct batadv_algo_ops *bao = bat_priv->algo_ops;
5bf74e9c 1502 struct batadv_hashtable *hash = bat_priv->orig_hash;
c6c8fea2 1503 struct hlist_head *head;
56303d34 1504 struct batadv_orig_node *orig_node;
6b5e971a 1505 u32 i;
c90681b8 1506 int ret;
c6c8fea2
SE
1507
1508 /* resize all orig nodes because orig_node->bcast_own(_sum) depend on
9cfc7bd6
SE
1509 * if_num
1510 */
c6c8fea2
SE
1511 for (i = 0; i < hash->size; i++) {
1512 head = &hash->table[i];
1513
fb778ea1 1514 rcu_read_lock();
b67bfe0d 1515 hlist_for_each_entry_rcu(orig_node, head, hash_entry) {
d0015fdd 1516 ret = 0;
29824a55
AQ
1517 if (bao->orig.add_if)
1518 ret = bao->orig.add_if(orig_node, max_if_num);
5346c35e 1519 if (ret == -ENOMEM)
c6c8fea2
SE
1520 goto err;
1521 }
fb778ea1 1522 rcu_read_unlock();
c6c8fea2
SE
1523 }
1524
c6c8fea2
SE
1525 return 0;
1526
1527err:
fb778ea1 1528 rcu_read_unlock();
c6c8fea2
SE
1529 return -ENOMEM;
1530}
1531
56303d34
SE
1532int batadv_orig_hash_del_if(struct batadv_hard_iface *hard_iface,
1533 int max_if_num)
c6c8fea2 1534{
56303d34 1535 struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
5bf74e9c 1536 struct batadv_hashtable *hash = bat_priv->orig_hash;
c6c8fea2 1537 struct hlist_head *head;
56303d34
SE
1538 struct batadv_hard_iface *hard_iface_tmp;
1539 struct batadv_orig_node *orig_node;
29824a55 1540 struct batadv_algo_ops *bao = bat_priv->algo_ops;
6b5e971a 1541 u32 i;
c90681b8 1542 int ret;
c6c8fea2
SE
1543
1544 /* resize all orig nodes because orig_node->bcast_own(_sum) depend on
9cfc7bd6
SE
1545 * if_num
1546 */
c6c8fea2
SE
1547 for (i = 0; i < hash->size; i++) {
1548 head = &hash->table[i];
1549
fb778ea1 1550 rcu_read_lock();
b67bfe0d 1551 hlist_for_each_entry_rcu(orig_node, head, hash_entry) {
d0015fdd 1552 ret = 0;
29824a55
AQ
1553 if (bao->orig.del_if)
1554 ret = bao->orig.del_if(orig_node, max_if_num,
1555 hard_iface->if_num);
5346c35e 1556 if (ret == -ENOMEM)
c6c8fea2
SE
1557 goto err;
1558 }
fb778ea1 1559 rcu_read_unlock();
c6c8fea2
SE
1560 }
1561
1562 /* renumber remaining batman interfaces _inside_ of orig_hash_lock */
1563 rcu_read_lock();
3193e8fd 1564 list_for_each_entry_rcu(hard_iface_tmp, &batadv_hardif_list, list) {
e9a4f295 1565 if (hard_iface_tmp->if_status == BATADV_IF_NOT_IN_USE)
c6c8fea2
SE
1566 continue;
1567
e6c10f43 1568 if (hard_iface == hard_iface_tmp)
c6c8fea2
SE
1569 continue;
1570
e6c10f43 1571 if (hard_iface->soft_iface != hard_iface_tmp->soft_iface)
c6c8fea2
SE
1572 continue;
1573
e6c10f43
ML
1574 if (hard_iface_tmp->if_num > hard_iface->if_num)
1575 hard_iface_tmp->if_num--;
c6c8fea2
SE
1576 }
1577 rcu_read_unlock();
1578
e6c10f43 1579 hard_iface->if_num = -1;
c6c8fea2
SE
1580 return 0;
1581
1582err:
fb778ea1 1583 rcu_read_unlock();
c6c8fea2
SE
1584 return -ENOMEM;
1585}
This page took 0.458486 seconds and 5 git commands to generate.