1 /* Copyright (C) 2013-2017 B.A.T.M.A.N. contributors:
3 * Linus Lüssing, Marek Lindner
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.
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.
14 * 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/>.
21 #include <linux/atomic.h>
22 #include <linux/cache.h>
23 #include <linux/errno.h>
24 #include <linux/if_ether.h>
25 #include <linux/init.h>
26 #include <linux/jiffies.h>
27 #include <linux/kernel.h>
28 #include <linux/kref.h>
29 #include <linux/netdevice.h>
30 #include <linux/netlink.h>
31 #include <linux/rculist.h>
32 #include <linux/rcupdate.h>
33 #include <linux/seq_file.h>
34 #include <linux/stddef.h>
35 #include <linux/types.h>
36 #include <linux/workqueue.h>
37 #include <net/genetlink.h>
38 #include <net/netlink.h>
39 #include <uapi/linux/batman_adv.h>
42 #include "bat_v_elp.h"
43 #include "bat_v_ogm.h"
44 #include "gateway_client.h"
45 #include "gateway_common.h"
46 #include "hard-interface.h"
50 #include "originator.h"
55 static void batadv_v_iface_activate(struct batadv_hard_iface
*hard_iface
)
57 struct batadv_priv
*bat_priv
= netdev_priv(hard_iface
->soft_iface
);
58 struct batadv_hard_iface
*primary_if
;
60 primary_if
= batadv_primary_if_get_selected(bat_priv
);
63 batadv_v_elp_iface_activate(primary_if
, hard_iface
);
64 batadv_hardif_put(primary_if
);
67 /* B.A.T.M.A.N. V does not use any queuing mechanism, therefore it can
68 * set the interface as ACTIVE right away, without any risk of race
71 if (hard_iface
->if_status
== BATADV_IF_TO_BE_ACTIVATED
)
72 hard_iface
->if_status
= BATADV_IF_ACTIVE
;
75 static int batadv_v_iface_enable(struct batadv_hard_iface
*hard_iface
)
79 ret
= batadv_v_elp_iface_enable(hard_iface
);
83 ret
= batadv_v_ogm_iface_enable(hard_iface
);
85 batadv_v_elp_iface_disable(hard_iface
);
90 static void batadv_v_iface_disable(struct batadv_hard_iface
*hard_iface
)
92 batadv_v_elp_iface_disable(hard_iface
);
95 static void batadv_v_primary_iface_set(struct batadv_hard_iface
*hard_iface
)
97 batadv_v_elp_primary_iface_set(hard_iface
);
98 batadv_v_ogm_primary_iface_set(hard_iface
);
102 * batadv_v_iface_update_mac - react to hard-interface MAC address change
103 * @hard_iface: the modified interface
105 * If the modified interface is the primary one, update the originator
106 * address in the ELP and OGM messages to reflect the new MAC address.
108 static void batadv_v_iface_update_mac(struct batadv_hard_iface
*hard_iface
)
110 struct batadv_priv
*bat_priv
= netdev_priv(hard_iface
->soft_iface
);
111 struct batadv_hard_iface
*primary_if
;
113 primary_if
= batadv_primary_if_get_selected(bat_priv
);
114 if (primary_if
!= hard_iface
)
117 batadv_v_primary_iface_set(hard_iface
);
120 batadv_hardif_put(primary_if
);
124 batadv_v_hardif_neigh_init(struct batadv_hardif_neigh_node
*hardif_neigh
)
126 ewma_throughput_init(&hardif_neigh
->bat_v
.throughput
);
127 INIT_WORK(&hardif_neigh
->bat_v
.metric_work
,
128 batadv_v_elp_throughput_metric_update
);
131 #ifdef CONFIG_BATMAN_ADV_DEBUGFS
133 * batadv_v_orig_print_neigh - print neighbors for the originator table
134 * @orig_node: the orig_node for which the neighbors are printed
135 * @if_outgoing: outgoing interface for these entries
136 * @seq: debugfs table seq_file struct
138 * Must be called while holding an rcu lock.
141 batadv_v_orig_print_neigh(struct batadv_orig_node
*orig_node
,
142 struct batadv_hard_iface
*if_outgoing
,
143 struct seq_file
*seq
)
145 struct batadv_neigh_node
*neigh_node
;
146 struct batadv_neigh_ifinfo
*n_ifinfo
;
148 hlist_for_each_entry_rcu(neigh_node
, &orig_node
->neigh_list
, list
) {
149 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
, if_outgoing
);
153 seq_printf(seq
, " %pM (%9u.%1u)",
155 n_ifinfo
->bat_v
.throughput
/ 10,
156 n_ifinfo
->bat_v
.throughput
% 10);
158 batadv_neigh_ifinfo_put(n_ifinfo
);
163 * batadv_v_hardif_neigh_print - print a single ELP neighbour node
164 * @seq: neighbour table seq_file struct
165 * @hardif_neigh: hardif neighbour information
168 batadv_v_hardif_neigh_print(struct seq_file
*seq
,
169 struct batadv_hardif_neigh_node
*hardif_neigh
)
171 int last_secs
, last_msecs
;
174 last_secs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) / 1000;
175 last_msecs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) % 1000;
176 throughput
= ewma_throughput_read(&hardif_neigh
->bat_v
.throughput
);
178 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) [%10s]\n",
179 hardif_neigh
->addr
, last_secs
, last_msecs
, throughput
/ 10,
180 throughput
% 10, hardif_neigh
->if_incoming
->net_dev
->name
);
184 * batadv_v_neigh_print - print the single hop neighbour list
185 * @bat_priv: the bat priv with all the soft interface information
186 * @seq: neighbour table seq_file struct
188 static void batadv_v_neigh_print(struct batadv_priv
*bat_priv
,
189 struct seq_file
*seq
)
191 struct net_device
*net_dev
= (struct net_device
*)seq
->private;
192 struct batadv_hardif_neigh_node
*hardif_neigh
;
193 struct batadv_hard_iface
*hard_iface
;
194 int batman_count
= 0;
197 " Neighbor last-seen ( throughput) [ IF]\n");
200 list_for_each_entry_rcu(hard_iface
, &batadv_hardif_list
, list
) {
201 if (hard_iface
->soft_iface
!= net_dev
)
204 hlist_for_each_entry_rcu(hardif_neigh
,
205 &hard_iface
->neigh_list
, list
) {
206 batadv_v_hardif_neigh_print(seq
, hardif_neigh
);
212 if (batman_count
== 0)
213 seq_puts(seq
, "No batman nodes in range ...\n");
218 * batadv_v_neigh_dump_neigh - Dump a neighbour into a message
219 * @msg: Netlink message to dump into
220 * @portid: Port making netlink request
221 * @seq: Sequence number of netlink message
222 * @hardif_neigh: Neighbour to dump
224 * Return: Error code, or 0 on success
227 batadv_v_neigh_dump_neigh(struct sk_buff
*msg
, u32 portid
, u32 seq
,
228 struct batadv_hardif_neigh_node
*hardif_neigh
)
231 unsigned int last_seen_msecs
;
234 last_seen_msecs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
);
235 throughput
= ewma_throughput_read(&hardif_neigh
->bat_v
.throughput
);
236 throughput
= throughput
* 100;
238 hdr
= genlmsg_put(msg
, portid
, seq
, &batadv_netlink_family
, NLM_F_MULTI
,
239 BATADV_CMD_GET_NEIGHBORS
);
243 if (nla_put(msg
, BATADV_ATTR_NEIGH_ADDRESS
, ETH_ALEN
,
244 hardif_neigh
->addr
) ||
245 nla_put_u32(msg
, BATADV_ATTR_HARD_IFINDEX
,
246 hardif_neigh
->if_incoming
->net_dev
->ifindex
) ||
247 nla_put_u32(msg
, BATADV_ATTR_LAST_SEEN_MSECS
,
249 nla_put_u32(msg
, BATADV_ATTR_THROUGHPUT
, throughput
))
250 goto nla_put_failure
;
252 genlmsg_end(msg
, hdr
);
256 genlmsg_cancel(msg
, hdr
);
261 * batadv_v_neigh_dump_hardif - Dump the neighbours of a hard interface into
263 * @msg: Netlink message to dump into
264 * @portid: Port making netlink request
265 * @seq: Sequence number of netlink message
266 * @bat_priv: The bat priv with all the soft interface information
267 * @hard_iface: The hard interface to be dumped
268 * @idx_s: Entries to be skipped
270 * This function assumes the caller holds rcu_read_lock().
272 * Return: Error code, or 0 on success
275 batadv_v_neigh_dump_hardif(struct sk_buff
*msg
, u32 portid
, u32 seq
,
276 struct batadv_priv
*bat_priv
,
277 struct batadv_hard_iface
*hard_iface
,
280 struct batadv_hardif_neigh_node
*hardif_neigh
;
283 hlist_for_each_entry_rcu(hardif_neigh
,
284 &hard_iface
->neigh_list
, list
) {
288 if (batadv_v_neigh_dump_neigh(msg
, portid
, seq
, hardif_neigh
)) {
299 * batadv_v_neigh_dump - Dump the neighbours of a hard interface into a
301 * @msg: Netlink message to dump into
302 * @cb: Control block containing additional options
303 * @bat_priv: The bat priv with all the soft interface information
304 * @single_hardif: Limit dumping to this hard interface
307 batadv_v_neigh_dump(struct sk_buff
*msg
, struct netlink_callback
*cb
,
308 struct batadv_priv
*bat_priv
,
309 struct batadv_hard_iface
*single_hardif
)
311 struct batadv_hard_iface
*hard_iface
;
313 int i_hardif_s
= cb
->args
[0];
314 int idx
= cb
->args
[1];
315 int portid
= NETLINK_CB(cb
->skb
).portid
;
319 if (i_hardif_s
== 0) {
320 if (batadv_v_neigh_dump_hardif(msg
, portid
,
322 bat_priv
, single_hardif
,
327 list_for_each_entry_rcu(hard_iface
, &batadv_hardif_list
, list
) {
328 if (hard_iface
->soft_iface
!= bat_priv
->soft_iface
)
331 if (i_hardif
++ < i_hardif_s
)
334 if (batadv_v_neigh_dump_hardif(msg
, portid
,
336 bat_priv
, hard_iface
,
345 cb
->args
[0] = i_hardif
;
349 #ifdef CONFIG_BATMAN_ADV_DEBUGFS
351 * batadv_v_orig_print - print the originator table
352 * @bat_priv: the bat priv with all the soft interface information
353 * @seq: debugfs table seq_file struct
354 * @if_outgoing: the outgoing interface for which this should be printed
356 static void batadv_v_orig_print(struct batadv_priv
*bat_priv
,
357 struct seq_file
*seq
,
358 struct batadv_hard_iface
*if_outgoing
)
360 struct batadv_neigh_node
*neigh_node
;
361 struct batadv_hashtable
*hash
= bat_priv
->orig_hash
;
362 int last_seen_msecs
, last_seen_secs
;
363 struct batadv_orig_node
*orig_node
;
364 struct batadv_neigh_ifinfo
*n_ifinfo
;
365 unsigned long last_seen_jiffies
;
366 struct hlist_head
*head
;
367 int batman_count
= 0;
371 " Originator last-seen ( throughput) Nexthop [outgoingIF]: Potential nexthops ...\n");
373 for (i
= 0; i
< hash
->size
; i
++) {
374 head
= &hash
->table
[i
];
377 hlist_for_each_entry_rcu(orig_node
, head
, hash_entry
) {
378 neigh_node
= batadv_orig_router_get(orig_node
,
383 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
,
388 last_seen_jiffies
= jiffies
- orig_node
->last_seen
;
389 last_seen_msecs
= jiffies_to_msecs(last_seen_jiffies
);
390 last_seen_secs
= last_seen_msecs
/ 1000;
391 last_seen_msecs
= last_seen_msecs
% 1000;
393 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) %pM [%10s]:",
394 orig_node
->orig
, last_seen_secs
,
396 n_ifinfo
->bat_v
.throughput
/ 10,
397 n_ifinfo
->bat_v
.throughput
% 10,
399 neigh_node
->if_incoming
->net_dev
->name
);
401 batadv_v_orig_print_neigh(orig_node
, if_outgoing
, seq
);
406 batadv_neigh_node_put(neigh_node
);
408 batadv_neigh_ifinfo_put(n_ifinfo
);
413 if (batman_count
== 0)
414 seq_puts(seq
, "No batman nodes in range ...\n");
419 * batadv_v_orig_dump_subentry - Dump an originator subentry into a
421 * @msg: Netlink message to dump into
422 * @portid: Port making netlink request
423 * @seq: Sequence number of netlink message
424 * @bat_priv: The bat priv with all the soft interface information
425 * @if_outgoing: Limit dump to entries with this outgoing interface
426 * @orig_node: Originator to dump
427 * @neigh_node: Single hops neighbour
428 * @best: Is the best originator
430 * Return: Error code, or 0 on success
433 batadv_v_orig_dump_subentry(struct sk_buff
*msg
, u32 portid
, u32 seq
,
434 struct batadv_priv
*bat_priv
,
435 struct batadv_hard_iface
*if_outgoing
,
436 struct batadv_orig_node
*orig_node
,
437 struct batadv_neigh_node
*neigh_node
,
440 struct batadv_neigh_ifinfo
*n_ifinfo
;
441 unsigned int last_seen_msecs
;
445 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
, if_outgoing
);
449 throughput
= n_ifinfo
->bat_v
.throughput
* 100;
451 batadv_neigh_ifinfo_put(n_ifinfo
);
453 last_seen_msecs
= jiffies_to_msecs(jiffies
- orig_node
->last_seen
);
455 if (if_outgoing
!= BATADV_IF_DEFAULT
&&
456 if_outgoing
!= neigh_node
->if_incoming
)
459 hdr
= genlmsg_put(msg
, portid
, seq
, &batadv_netlink_family
, NLM_F_MULTI
,
460 BATADV_CMD_GET_ORIGINATORS
);
464 if (nla_put(msg
, BATADV_ATTR_ORIG_ADDRESS
, ETH_ALEN
, orig_node
->orig
) ||
465 nla_put(msg
, BATADV_ATTR_NEIGH_ADDRESS
, ETH_ALEN
,
467 nla_put_u32(msg
, BATADV_ATTR_HARD_IFINDEX
,
468 neigh_node
->if_incoming
->net_dev
->ifindex
) ||
469 nla_put_u32(msg
, BATADV_ATTR_THROUGHPUT
, throughput
) ||
470 nla_put_u32(msg
, BATADV_ATTR_LAST_SEEN_MSECS
,
472 goto nla_put_failure
;
474 if (best
&& nla_put_flag(msg
, BATADV_ATTR_FLAG_BEST
))
475 goto nla_put_failure
;
477 genlmsg_end(msg
, hdr
);
481 genlmsg_cancel(msg
, hdr
);
486 * batadv_v_orig_dump_entry - Dump an originator entry into a message
487 * @msg: Netlink message to dump into
488 * @portid: Port making netlink request
489 * @seq: Sequence number of netlink message
490 * @bat_priv: The bat priv with all the soft interface information
491 * @if_outgoing: Limit dump to entries with this outgoing interface
492 * @orig_node: Originator to dump
493 * @sub_s: Number of sub entries to skip
495 * This function assumes the caller holds rcu_read_lock().
497 * Return: Error code, or 0 on success
500 batadv_v_orig_dump_entry(struct sk_buff
*msg
, u32 portid
, u32 seq
,
501 struct batadv_priv
*bat_priv
,
502 struct batadv_hard_iface
*if_outgoing
,
503 struct batadv_orig_node
*orig_node
, int *sub_s
)
505 struct batadv_neigh_node
*neigh_node_best
;
506 struct batadv_neigh_node
*neigh_node
;
510 neigh_node_best
= batadv_orig_router_get(orig_node
, if_outgoing
);
511 if (!neigh_node_best
)
514 hlist_for_each_entry_rcu(neigh_node
, &orig_node
->neigh_list
, list
) {
518 best
= (neigh_node
== neigh_node_best
);
520 if (batadv_v_orig_dump_subentry(msg
, portid
, seq
, bat_priv
,
521 if_outgoing
, orig_node
,
523 batadv_neigh_node_put(neigh_node_best
);
532 batadv_neigh_node_put(neigh_node_best
);
539 * batadv_v_orig_dump_bucket - Dump an originator bucket into a
541 * @msg: Netlink message to dump into
542 * @portid: Port making netlink request
543 * @seq: Sequence number of netlink message
544 * @bat_priv: The bat priv with all the soft interface information
545 * @if_outgoing: Limit dump to entries with this outgoing interface
546 * @head: Bucket to be dumped
547 * @idx_s: Number of entries to be skipped
548 * @sub: Number of sub entries to be skipped
550 * Return: Error code, or 0 on success
553 batadv_v_orig_dump_bucket(struct sk_buff
*msg
, u32 portid
, u32 seq
,
554 struct batadv_priv
*bat_priv
,
555 struct batadv_hard_iface
*if_outgoing
,
556 struct hlist_head
*head
, int *idx_s
, int *sub
)
558 struct batadv_orig_node
*orig_node
;
562 hlist_for_each_entry_rcu(orig_node
, head
, hash_entry
) {
566 if (batadv_v_orig_dump_entry(msg
, portid
, seq
, bat_priv
,
567 if_outgoing
, orig_node
, sub
)) {
581 * batadv_v_orig_dump - Dump the originators into a message
582 * @msg: Netlink message to dump into
583 * @cb: Control block containing additional options
584 * @bat_priv: The bat priv with all the soft interface information
585 * @if_outgoing: Limit dump to entries with this outgoing interface
588 batadv_v_orig_dump(struct sk_buff
*msg
, struct netlink_callback
*cb
,
589 struct batadv_priv
*bat_priv
,
590 struct batadv_hard_iface
*if_outgoing
)
592 struct batadv_hashtable
*hash
= bat_priv
->orig_hash
;
593 struct hlist_head
*head
;
594 int bucket
= cb
->args
[0];
595 int idx
= cb
->args
[1];
596 int sub
= cb
->args
[2];
597 int portid
= NETLINK_CB(cb
->skb
).portid
;
599 while (bucket
< hash
->size
) {
600 head
= &hash
->table
[bucket
];
602 if (batadv_v_orig_dump_bucket(msg
, portid
,
604 bat_priv
, if_outgoing
, head
, &idx
,
611 cb
->args
[0] = bucket
;
616 static int batadv_v_neigh_cmp(struct batadv_neigh_node
*neigh1
,
617 struct batadv_hard_iface
*if_outgoing1
,
618 struct batadv_neigh_node
*neigh2
,
619 struct batadv_hard_iface
*if_outgoing2
)
621 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
624 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
628 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
632 ret
= ifinfo1
->bat_v
.throughput
- ifinfo2
->bat_v
.throughput
;
634 batadv_neigh_ifinfo_put(ifinfo2
);
636 batadv_neigh_ifinfo_put(ifinfo1
);
641 static bool batadv_v_neigh_is_sob(struct batadv_neigh_node
*neigh1
,
642 struct batadv_hard_iface
*if_outgoing1
,
643 struct batadv_neigh_node
*neigh2
,
644 struct batadv_hard_iface
*if_outgoing2
)
646 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
650 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
654 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
658 threshold
= ifinfo1
->bat_v
.throughput
/ 4;
659 threshold
= ifinfo1
->bat_v
.throughput
- threshold
;
661 ret
= ifinfo2
->bat_v
.throughput
> threshold
;
663 batadv_neigh_ifinfo_put(ifinfo2
);
665 batadv_neigh_ifinfo_put(ifinfo1
);
671 * batadv_v_init_sel_class - initialize GW selection class
672 * @bat_priv: the bat priv with all the soft interface information
674 static void batadv_v_init_sel_class(struct batadv_priv
*bat_priv
)
676 /* set default throughput difference threshold to 5Mbps */
677 atomic_set(&bat_priv
->gw
.sel_class
, 50);
680 static ssize_t
batadv_v_store_sel_class(struct batadv_priv
*bat_priv
,
681 char *buff
, size_t count
)
683 u32 old_class
, class;
685 if (!batadv_parse_throughput(bat_priv
->soft_iface
, buff
,
686 "B.A.T.M.A.N. V GW selection class",
690 old_class
= atomic_read(&bat_priv
->gw
.sel_class
);
691 atomic_set(&bat_priv
->gw
.sel_class
, class);
693 if (old_class
!= class)
694 batadv_gw_reselect(bat_priv
);
699 static ssize_t
batadv_v_show_sel_class(struct batadv_priv
*bat_priv
, char *buff
)
701 u32
class = atomic_read(&bat_priv
->gw
.sel_class
);
703 return sprintf(buff
, "%u.%u MBit\n", class / 10, class % 10);
707 * batadv_v_gw_throughput_get - retrieve the GW-bandwidth for a given GW
708 * @gw_node: the GW to retrieve the metric for
709 * @bw: the pointer where the metric will be stored. The metric is computed as
710 * the minimum between the GW advertised throughput and the path throughput to
713 * Return: 0 on success, -1 on failure
715 static int batadv_v_gw_throughput_get(struct batadv_gw_node
*gw_node
, u32
*bw
)
717 struct batadv_neigh_ifinfo
*router_ifinfo
= NULL
;
718 struct batadv_orig_node
*orig_node
;
719 struct batadv_neigh_node
*router
;
722 orig_node
= gw_node
->orig_node
;
723 router
= batadv_orig_router_get(orig_node
, BATADV_IF_DEFAULT
);
727 router_ifinfo
= batadv_neigh_ifinfo_get(router
, BATADV_IF_DEFAULT
);
731 /* the GW metric is computed as the minimum between the path throughput
732 * to reach the GW itself and the advertised bandwidth.
733 * This gives us an approximation of the effective throughput that the
734 * client can expect via this particular GW node
736 *bw
= router_ifinfo
->bat_v
.throughput
;
737 *bw
= min_t(u32
, *bw
, gw_node
->bandwidth_down
);
742 batadv_neigh_node_put(router
);
744 batadv_neigh_ifinfo_put(router_ifinfo
);
750 * batadv_v_gw_get_best_gw_node - retrieve the best GW node
751 * @bat_priv: the bat priv with all the soft interface information
753 * Return: the GW node having the best GW-metric, NULL if no GW is known
755 static struct batadv_gw_node
*
756 batadv_v_gw_get_best_gw_node(struct batadv_priv
*bat_priv
)
758 struct batadv_gw_node
*gw_node
, *curr_gw
= NULL
;
762 hlist_for_each_entry_rcu(gw_node
, &bat_priv
->gw
.gateway_list
, list
) {
763 if (!kref_get_unless_zero(&gw_node
->refcount
))
766 if (batadv_v_gw_throughput_get(gw_node
, &bw
) < 0)
769 if (curr_gw
&& bw
<= max_bw
)
773 batadv_gw_node_put(curr_gw
);
776 kref_get(&curr_gw
->refcount
);
780 batadv_gw_node_put(gw_node
);
788 * batadv_v_gw_is_eligible - check if a originator would be selected as GW
789 * @bat_priv: the bat priv with all the soft interface information
790 * @curr_gw_orig: originator representing the currently selected GW
791 * @orig_node: the originator representing the new candidate
793 * Return: true if orig_node can be selected as current GW, false otherwise
795 static bool batadv_v_gw_is_eligible(struct batadv_priv
*bat_priv
,
796 struct batadv_orig_node
*curr_gw_orig
,
797 struct batadv_orig_node
*orig_node
)
799 struct batadv_gw_node
*curr_gw
, *orig_gw
= NULL
;
800 u32 gw_throughput
, orig_throughput
, threshold
;
803 threshold
= atomic_read(&bat_priv
->gw
.sel_class
);
805 curr_gw
= batadv_gw_node_get(bat_priv
, curr_gw_orig
);
811 if (batadv_v_gw_throughput_get(curr_gw
, &gw_throughput
) < 0) {
816 orig_gw
= batadv_gw_node_get(bat_priv
, orig_node
);
820 if (batadv_v_gw_throughput_get(orig_gw
, &orig_throughput
) < 0)
823 if (orig_throughput
< gw_throughput
)
826 if ((orig_throughput
- gw_throughput
) < threshold
)
829 batadv_dbg(BATADV_DBG_BATMAN
, bat_priv
,
830 "Restarting gateway selection: better gateway found (throughput curr: %u, throughput new: %u)\n",
831 gw_throughput
, orig_throughput
);
836 batadv_gw_node_put(curr_gw
);
838 batadv_gw_node_put(orig_gw
);
843 #ifdef CONFIG_BATMAN_ADV_DEBUGFS
844 /* fails if orig_node has no router */
845 static int batadv_v_gw_write_buffer_text(struct batadv_priv
*bat_priv
,
846 struct seq_file
*seq
,
847 const struct batadv_gw_node
*gw_node
)
849 struct batadv_gw_node
*curr_gw
;
850 struct batadv_neigh_node
*router
;
851 struct batadv_neigh_ifinfo
*router_ifinfo
= NULL
;
854 router
= batadv_orig_router_get(gw_node
->orig_node
, BATADV_IF_DEFAULT
);
858 router_ifinfo
= batadv_neigh_ifinfo_get(router
, BATADV_IF_DEFAULT
);
862 curr_gw
= batadv_gw_get_selected_gw_node(bat_priv
);
864 seq_printf(seq
, "%s %pM (%9u.%1u) %pM [%10s]: %u.%u/%u.%u MBit\n",
865 (curr_gw
== gw_node
? "=>" : " "),
866 gw_node
->orig_node
->orig
,
867 router_ifinfo
->bat_v
.throughput
/ 10,
868 router_ifinfo
->bat_v
.throughput
% 10, router
->addr
,
869 router
->if_incoming
->net_dev
->name
,
870 gw_node
->bandwidth_down
/ 10,
871 gw_node
->bandwidth_down
% 10,
872 gw_node
->bandwidth_up
/ 10,
873 gw_node
->bandwidth_up
% 10);
874 ret
= seq_has_overflowed(seq
) ? -1 : 0;
877 batadv_gw_node_put(curr_gw
);
880 batadv_neigh_ifinfo_put(router_ifinfo
);
882 batadv_neigh_node_put(router
);
887 * batadv_v_gw_print - print the gateway list
888 * @bat_priv: the bat priv with all the soft interface information
889 * @seq: gateway table seq_file struct
891 static void batadv_v_gw_print(struct batadv_priv
*bat_priv
,
892 struct seq_file
*seq
)
894 struct batadv_gw_node
*gw_node
;
898 " Gateway ( throughput) Nexthop [outgoingIF]: advertised uplink bandwidth\n");
901 hlist_for_each_entry_rcu(gw_node
, &bat_priv
->gw
.gateway_list
, list
) {
902 /* fails if orig_node has no router */
903 if (batadv_v_gw_write_buffer_text(bat_priv
, seq
, gw_node
) < 0)
911 seq_puts(seq
, "No gateways in range ...\n");
916 * batadv_v_gw_dump_entry - Dump a gateway into a message
917 * @msg: Netlink message to dump into
918 * @portid: Port making netlink request
919 * @seq: Sequence number of netlink message
920 * @bat_priv: The bat priv with all the soft interface information
921 * @gw_node: Gateway to be dumped
923 * Return: Error code, or 0 on success
925 static int batadv_v_gw_dump_entry(struct sk_buff
*msg
, u32 portid
, u32 seq
,
926 struct batadv_priv
*bat_priv
,
927 struct batadv_gw_node
*gw_node
)
929 struct batadv_neigh_ifinfo
*router_ifinfo
= NULL
;
930 struct batadv_neigh_node
*router
;
931 struct batadv_gw_node
*curr_gw
;
935 router
= batadv_orig_router_get(gw_node
->orig_node
, BATADV_IF_DEFAULT
);
939 router_ifinfo
= batadv_neigh_ifinfo_get(router
, BATADV_IF_DEFAULT
);
943 curr_gw
= batadv_gw_get_selected_gw_node(bat_priv
);
945 hdr
= genlmsg_put(msg
, portid
, seq
, &batadv_netlink_family
,
946 NLM_F_MULTI
, BATADV_CMD_GET_GATEWAYS
);
954 if (curr_gw
== gw_node
) {
955 if (nla_put_flag(msg
, BATADV_ATTR_FLAG_BEST
)) {
956 genlmsg_cancel(msg
, hdr
);
961 if (nla_put(msg
, BATADV_ATTR_ORIG_ADDRESS
, ETH_ALEN
,
962 gw_node
->orig_node
->orig
)) {
963 genlmsg_cancel(msg
, hdr
);
967 if (nla_put_u32(msg
, BATADV_ATTR_THROUGHPUT
,
968 router_ifinfo
->bat_v
.throughput
)) {
969 genlmsg_cancel(msg
, hdr
);
973 if (nla_put(msg
, BATADV_ATTR_ROUTER
, ETH_ALEN
, router
->addr
)) {
974 genlmsg_cancel(msg
, hdr
);
978 if (nla_put_string(msg
, BATADV_ATTR_HARD_IFNAME
,
979 router
->if_incoming
->net_dev
->name
)) {
980 genlmsg_cancel(msg
, hdr
);
984 if (nla_put_u32(msg
, BATADV_ATTR_BANDWIDTH_DOWN
,
985 gw_node
->bandwidth_down
)) {
986 genlmsg_cancel(msg
, hdr
);
990 if (nla_put_u32(msg
, BATADV_ATTR_BANDWIDTH_UP
, gw_node
->bandwidth_up
)) {
991 genlmsg_cancel(msg
, hdr
);
995 genlmsg_end(msg
, hdr
);
1000 batadv_neigh_ifinfo_put(router_ifinfo
);
1002 batadv_neigh_node_put(router
);
1007 * batadv_v_gw_dump - Dump gateways into a message
1008 * @msg: Netlink message to dump into
1009 * @cb: Control block containing additional options
1010 * @bat_priv: The bat priv with all the soft interface information
1012 static void batadv_v_gw_dump(struct sk_buff
*msg
, struct netlink_callback
*cb
,
1013 struct batadv_priv
*bat_priv
)
1015 int portid
= NETLINK_CB(cb
->skb
).portid
;
1016 struct batadv_gw_node
*gw_node
;
1017 int idx_skip
= cb
->args
[0];
1021 hlist_for_each_entry_rcu(gw_node
, &bat_priv
->gw
.gateway_list
, list
) {
1022 if (idx
++ < idx_skip
)
1025 if (batadv_v_gw_dump_entry(msg
, portid
, cb
->nlh
->nlmsg_seq
,
1026 bat_priv
, gw_node
)) {
1036 cb
->args
[0] = idx_skip
;
1039 static struct batadv_algo_ops batadv_batman_v __read_mostly
= {
1042 .activate
= batadv_v_iface_activate
,
1043 .enable
= batadv_v_iface_enable
,
1044 .disable
= batadv_v_iface_disable
,
1045 .update_mac
= batadv_v_iface_update_mac
,
1046 .primary_set
= batadv_v_primary_iface_set
,
1049 .hardif_init
= batadv_v_hardif_neigh_init
,
1050 .cmp
= batadv_v_neigh_cmp
,
1051 .is_similar_or_better
= batadv_v_neigh_is_sob
,
1052 #ifdef CONFIG_BATMAN_ADV_DEBUGFS
1053 .print
= batadv_v_neigh_print
,
1055 .dump
= batadv_v_neigh_dump
,
1058 #ifdef CONFIG_BATMAN_ADV_DEBUGFS
1059 .print
= batadv_v_orig_print
,
1061 .dump
= batadv_v_orig_dump
,
1064 .init_sel_class
= batadv_v_init_sel_class
,
1065 .store_sel_class
= batadv_v_store_sel_class
,
1066 .show_sel_class
= batadv_v_show_sel_class
,
1067 .get_best_gw_node
= batadv_v_gw_get_best_gw_node
,
1068 .is_eligible
= batadv_v_gw_is_eligible
,
1069 #ifdef CONFIG_BATMAN_ADV_DEBUGFS
1070 .print
= batadv_v_gw_print
,
1072 .dump
= batadv_v_gw_dump
,
1077 * batadv_v_hardif_init - initialize the algorithm specific fields in the
1078 * hard-interface object
1079 * @hard_iface: the hard-interface to initialize
1081 void batadv_v_hardif_init(struct batadv_hard_iface
*hard_iface
)
1083 /* enable link throughput auto-detection by setting the throughput
1086 atomic_set(&hard_iface
->bat_v
.throughput_override
, 0);
1087 atomic_set(&hard_iface
->bat_v
.elp_interval
, 500);
1091 * batadv_v_mesh_init - initialize the B.A.T.M.A.N. V private resources for a
1093 * @bat_priv: the object representing the mesh interface to initialise
1095 * Return: 0 on success or a negative error code otherwise
1097 int batadv_v_mesh_init(struct batadv_priv
*bat_priv
)
1101 ret
= batadv_v_ogm_init(bat_priv
);
1109 * batadv_v_mesh_free - free the B.A.T.M.A.N. V private resources for a mesh
1110 * @bat_priv: the object representing the mesh interface to free
1112 void batadv_v_mesh_free(struct batadv_priv
*bat_priv
)
1114 batadv_v_ogm_free(bat_priv
);
1118 * batadv_v_init - B.A.T.M.A.N. V initialization function
1120 * Description: Takes care of initializing all the subcomponents.
1121 * It is invoked upon module load only.
1123 * Return: 0 on success or a negative error code otherwise
1125 int __init
batadv_v_init(void)
1129 /* B.A.T.M.A.N. V echo location protocol packet */
1130 ret
= batadv_recv_handler_register(BATADV_ELP
,
1131 batadv_v_elp_packet_recv
);
1135 ret
= batadv_recv_handler_register(BATADV_OGM2
,
1136 batadv_v_ogm_packet_recv
);
1138 goto elp_unregister
;
1140 ret
= batadv_algo_register(&batadv_batman_v
);
1142 goto ogm_unregister
;
1147 batadv_recv_handler_unregister(BATADV_OGM2
);
1150 batadv_recv_handler_unregister(BATADV_ELP
);