1 /* Copyright (C) 2013-2016 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/bug.h>
23 #include <linux/cache.h>
24 #include <linux/init.h>
25 #include <linux/jiffies.h>
26 #include <linux/netdevice.h>
27 #include <linux/rculist.h>
28 #include <linux/rcupdate.h>
29 #include <linux/seq_file.h>
30 #include <linux/types.h>
31 #include <linux/workqueue.h>
33 #include "bat_v_elp.h"
34 #include "bat_v_ogm.h"
35 #include "hard-interface.h"
37 #include "originator.h"
40 static void batadv_v_iface_activate(struct batadv_hard_iface
*hard_iface
)
42 /* B.A.T.M.A.N. V does not use any queuing mechanism, therefore it can
43 * set the interface as ACTIVE right away, without any risk of race
46 if (hard_iface
->if_status
== BATADV_IF_TO_BE_ACTIVATED
)
47 hard_iface
->if_status
= BATADV_IF_ACTIVE
;
50 static int batadv_v_iface_enable(struct batadv_hard_iface
*hard_iface
)
54 ret
= batadv_v_elp_iface_enable(hard_iface
);
58 ret
= batadv_v_ogm_iface_enable(hard_iface
);
60 batadv_v_elp_iface_disable(hard_iface
);
62 /* enable link throughput auto-detection by setting the throughput
65 atomic_set(&hard_iface
->bat_v
.throughput_override
, 0);
70 static void batadv_v_iface_disable(struct batadv_hard_iface
*hard_iface
)
72 batadv_v_elp_iface_disable(hard_iface
);
75 static void batadv_v_iface_update_mac(struct batadv_hard_iface
*hard_iface
)
79 static void batadv_v_primary_iface_set(struct batadv_hard_iface
*hard_iface
)
81 batadv_v_elp_primary_iface_set(hard_iface
);
82 batadv_v_ogm_primary_iface_set(hard_iface
);
86 batadv_v_hardif_neigh_init(struct batadv_hardif_neigh_node
*hardif_neigh
)
88 ewma_throughput_init(&hardif_neigh
->bat_v
.throughput
);
89 INIT_WORK(&hardif_neigh
->bat_v
.metric_work
,
90 batadv_v_elp_throughput_metric_update
);
93 static void batadv_v_ogm_schedule(struct batadv_hard_iface
*hard_iface
)
97 static void batadv_v_ogm_emit(struct batadv_forw_packet
*forw_packet
)
102 * batadv_v_orig_print_neigh - print neighbors for the originator table
103 * @orig_node: the orig_node for which the neighbors are printed
104 * @if_outgoing: outgoing interface for these entries
105 * @seq: debugfs table seq_file struct
107 * Must be called while holding an rcu lock.
110 batadv_v_orig_print_neigh(struct batadv_orig_node
*orig_node
,
111 struct batadv_hard_iface
*if_outgoing
,
112 struct seq_file
*seq
)
114 struct batadv_neigh_node
*neigh_node
;
115 struct batadv_neigh_ifinfo
*n_ifinfo
;
117 hlist_for_each_entry_rcu(neigh_node
, &orig_node
->neigh_list
, list
) {
118 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
, if_outgoing
);
122 seq_printf(seq
, " %pM (%9u.%1u)",
124 n_ifinfo
->bat_v
.throughput
/ 10,
125 n_ifinfo
->bat_v
.throughput
% 10);
127 batadv_neigh_ifinfo_put(n_ifinfo
);
132 * batadv_v_hardif_neigh_print - print a single ELP neighbour node
133 * @seq: neighbour table seq_file struct
134 * @hardif_neigh: hardif neighbour information
137 batadv_v_hardif_neigh_print(struct seq_file
*seq
,
138 struct batadv_hardif_neigh_node
*hardif_neigh
)
140 int last_secs
, last_msecs
;
143 last_secs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) / 1000;
144 last_msecs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) % 1000;
145 throughput
= ewma_throughput_read(&hardif_neigh
->bat_v
.throughput
);
147 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) [%10s]\n",
148 hardif_neigh
->addr
, last_secs
, last_msecs
, throughput
/ 10,
149 throughput
% 10, hardif_neigh
->if_incoming
->net_dev
->name
);
153 * batadv_v_neigh_print - print the single hop neighbour list
154 * @bat_priv: the bat priv with all the soft interface information
155 * @seq: neighbour table seq_file struct
157 static void batadv_v_neigh_print(struct batadv_priv
*bat_priv
,
158 struct seq_file
*seq
)
160 struct net_device
*net_dev
= (struct net_device
*)seq
->private;
161 struct batadv_hardif_neigh_node
*hardif_neigh
;
162 struct batadv_hard_iface
*hard_iface
;
163 int batman_count
= 0;
166 " Neighbor last-seen ( throughput) [ IF]\n");
169 list_for_each_entry_rcu(hard_iface
, &batadv_hardif_list
, list
) {
170 if (hard_iface
->soft_iface
!= net_dev
)
173 hlist_for_each_entry_rcu(hardif_neigh
,
174 &hard_iface
->neigh_list
, list
) {
175 batadv_v_hardif_neigh_print(seq
, hardif_neigh
);
181 if (batman_count
== 0)
182 seq_puts(seq
, "No batman nodes in range ...\n");
186 * batadv_v_orig_print - print the originator table
187 * @bat_priv: the bat priv with all the soft interface information
188 * @seq: debugfs table seq_file struct
189 * @if_outgoing: the outgoing interface for which this should be printed
191 static void batadv_v_orig_print(struct batadv_priv
*bat_priv
,
192 struct seq_file
*seq
,
193 struct batadv_hard_iface
*if_outgoing
)
195 struct batadv_neigh_node
*neigh_node
;
196 struct batadv_hashtable
*hash
= bat_priv
->orig_hash
;
197 int last_seen_msecs
, last_seen_secs
;
198 struct batadv_orig_node
*orig_node
;
199 struct batadv_neigh_ifinfo
*n_ifinfo
;
200 unsigned long last_seen_jiffies
;
201 struct hlist_head
*head
;
202 int batman_count
= 0;
206 " Originator last-seen ( throughput) Nexthop [outgoingIF]: Potential nexthops ...\n");
208 for (i
= 0; i
< hash
->size
; i
++) {
209 head
= &hash
->table
[i
];
212 hlist_for_each_entry_rcu(orig_node
, head
, hash_entry
) {
213 neigh_node
= batadv_orig_router_get(orig_node
,
218 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
,
223 last_seen_jiffies
= jiffies
- orig_node
->last_seen
;
224 last_seen_msecs
= jiffies_to_msecs(last_seen_jiffies
);
225 last_seen_secs
= last_seen_msecs
/ 1000;
226 last_seen_msecs
= last_seen_msecs
% 1000;
228 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) %pM [%10s]:",
229 orig_node
->orig
, last_seen_secs
,
231 n_ifinfo
->bat_v
.throughput
/ 10,
232 n_ifinfo
->bat_v
.throughput
% 10,
234 neigh_node
->if_incoming
->net_dev
->name
);
236 batadv_v_orig_print_neigh(orig_node
, if_outgoing
, seq
);
241 batadv_neigh_node_put(neigh_node
);
243 batadv_neigh_ifinfo_put(n_ifinfo
);
248 if (batman_count
== 0)
249 seq_puts(seq
, "No batman nodes in range ...\n");
252 static int batadv_v_neigh_cmp(struct batadv_neigh_node
*neigh1
,
253 struct batadv_hard_iface
*if_outgoing1
,
254 struct batadv_neigh_node
*neigh2
,
255 struct batadv_hard_iface
*if_outgoing2
)
257 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
259 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
260 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
262 if (WARN_ON(!ifinfo1
|| !ifinfo2
))
265 return ifinfo1
->bat_v
.throughput
- ifinfo2
->bat_v
.throughput
;
268 static bool batadv_v_neigh_is_sob(struct batadv_neigh_node
*neigh1
,
269 struct batadv_hard_iface
*if_outgoing1
,
270 struct batadv_neigh_node
*neigh2
,
271 struct batadv_hard_iface
*if_outgoing2
)
273 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
276 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
277 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
279 threshold
= ifinfo1
->bat_v
.throughput
/ 4;
280 threshold
= ifinfo1
->bat_v
.throughput
- threshold
;
282 return ifinfo2
->bat_v
.throughput
> threshold
;
285 static struct batadv_algo_ops batadv_batman_v __read_mostly
= {
287 .bat_iface_activate
= batadv_v_iface_activate
,
288 .bat_iface_enable
= batadv_v_iface_enable
,
289 .bat_iface_disable
= batadv_v_iface_disable
,
290 .bat_iface_update_mac
= batadv_v_iface_update_mac
,
291 .bat_primary_iface_set
= batadv_v_primary_iface_set
,
292 .bat_hardif_neigh_init
= batadv_v_hardif_neigh_init
,
293 .bat_ogm_emit
= batadv_v_ogm_emit
,
294 .bat_ogm_schedule
= batadv_v_ogm_schedule
,
295 .bat_orig_print
= batadv_v_orig_print
,
296 .bat_neigh_cmp
= batadv_v_neigh_cmp
,
297 .bat_neigh_is_similar_or_better
= batadv_v_neigh_is_sob
,
298 .bat_neigh_print
= batadv_v_neigh_print
,
302 * batadv_v_mesh_init - initialize the B.A.T.M.A.N. V private resources for a
304 * @bat_priv: the object representing the mesh interface to initialise
306 * Return: 0 on success or a negative error code otherwise
308 int batadv_v_mesh_init(struct batadv_priv
*bat_priv
)
310 return batadv_v_ogm_init(bat_priv
);
314 * batadv_v_mesh_free - free the B.A.T.M.A.N. V private resources for a mesh
315 * @bat_priv: the object representing the mesh interface to free
317 void batadv_v_mesh_free(struct batadv_priv
*bat_priv
)
319 batadv_v_ogm_free(bat_priv
);
323 * batadv_v_init - B.A.T.M.A.N. V initialization function
325 * Description: Takes care of initializing all the subcomponents.
326 * It is invoked upon module load only.
328 * Return: 0 on success or a negative error code otherwise
330 int __init
batadv_v_init(void)
334 /* B.A.T.M.A.N. V echo location protocol packet */
335 ret
= batadv_recv_handler_register(BATADV_ELP
,
336 batadv_v_elp_packet_recv
);
340 ret
= batadv_recv_handler_register(BATADV_OGM2
,
341 batadv_v_ogm_packet_recv
);
345 ret
= batadv_algo_register(&batadv_batman_v
);
352 batadv_recv_handler_unregister(BATADV_OGM2
);
355 batadv_recv_handler_unregister(BATADV_ELP
);