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/stddef.h>
31 #include <linux/types.h>
32 #include <linux/workqueue.h>
34 #include "bat_v_elp.h"
35 #include "bat_v_ogm.h"
36 #include "hard-interface.h"
38 #include "originator.h"
41 static void batadv_v_iface_activate(struct batadv_hard_iface
*hard_iface
)
43 struct batadv_priv
*bat_priv
= netdev_priv(hard_iface
->soft_iface
);
44 struct batadv_hard_iface
*primary_if
;
46 primary_if
= batadv_primary_if_get_selected(bat_priv
);
49 batadv_v_elp_iface_activate(primary_if
, hard_iface
);
50 batadv_hardif_put(primary_if
);
53 /* B.A.T.M.A.N. V does not use any queuing mechanism, therefore it can
54 * set the interface as ACTIVE right away, without any risk of race
57 if (hard_iface
->if_status
== BATADV_IF_TO_BE_ACTIVATED
)
58 hard_iface
->if_status
= BATADV_IF_ACTIVE
;
61 static int batadv_v_iface_enable(struct batadv_hard_iface
*hard_iface
)
65 ret
= batadv_v_elp_iface_enable(hard_iface
);
69 ret
= batadv_v_ogm_iface_enable(hard_iface
);
71 batadv_v_elp_iface_disable(hard_iface
);
73 /* enable link throughput auto-detection by setting the throughput
76 atomic_set(&hard_iface
->bat_v
.throughput_override
, 0);
81 static void batadv_v_iface_disable(struct batadv_hard_iface
*hard_iface
)
83 batadv_v_elp_iface_disable(hard_iface
);
86 static void batadv_v_primary_iface_set(struct batadv_hard_iface
*hard_iface
)
88 batadv_v_elp_primary_iface_set(hard_iface
);
89 batadv_v_ogm_primary_iface_set(hard_iface
);
93 * batadv_v_iface_update_mac - react to hard-interface MAC address change
94 * @hard_iface: the modified interface
96 * If the modified interface is the primary one, update the originator
97 * address in the ELP and OGM messages to reflect the new MAC address.
99 static void batadv_v_iface_update_mac(struct batadv_hard_iface
*hard_iface
)
101 struct batadv_priv
*bat_priv
= netdev_priv(hard_iface
->soft_iface
);
102 struct batadv_hard_iface
*primary_if
;
104 primary_if
= batadv_primary_if_get_selected(bat_priv
);
105 if (primary_if
!= hard_iface
)
108 batadv_v_primary_iface_set(hard_iface
);
111 batadv_hardif_put(primary_if
);
115 batadv_v_hardif_neigh_init(struct batadv_hardif_neigh_node
*hardif_neigh
)
117 ewma_throughput_init(&hardif_neigh
->bat_v
.throughput
);
118 INIT_WORK(&hardif_neigh
->bat_v
.metric_work
,
119 batadv_v_elp_throughput_metric_update
);
123 * batadv_v_orig_print_neigh - print neighbors for the originator table
124 * @orig_node: the orig_node for which the neighbors are printed
125 * @if_outgoing: outgoing interface for these entries
126 * @seq: debugfs table seq_file struct
128 * Must be called while holding an rcu lock.
131 batadv_v_orig_print_neigh(struct batadv_orig_node
*orig_node
,
132 struct batadv_hard_iface
*if_outgoing
,
133 struct seq_file
*seq
)
135 struct batadv_neigh_node
*neigh_node
;
136 struct batadv_neigh_ifinfo
*n_ifinfo
;
138 hlist_for_each_entry_rcu(neigh_node
, &orig_node
->neigh_list
, list
) {
139 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
, if_outgoing
);
143 seq_printf(seq
, " %pM (%9u.%1u)",
145 n_ifinfo
->bat_v
.throughput
/ 10,
146 n_ifinfo
->bat_v
.throughput
% 10);
148 batadv_neigh_ifinfo_put(n_ifinfo
);
153 * batadv_v_hardif_neigh_print - print a single ELP neighbour node
154 * @seq: neighbour table seq_file struct
155 * @hardif_neigh: hardif neighbour information
158 batadv_v_hardif_neigh_print(struct seq_file
*seq
,
159 struct batadv_hardif_neigh_node
*hardif_neigh
)
161 int last_secs
, last_msecs
;
164 last_secs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) / 1000;
165 last_msecs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) % 1000;
166 throughput
= ewma_throughput_read(&hardif_neigh
->bat_v
.throughput
);
168 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) [%10s]\n",
169 hardif_neigh
->addr
, last_secs
, last_msecs
, throughput
/ 10,
170 throughput
% 10, hardif_neigh
->if_incoming
->net_dev
->name
);
174 * batadv_v_neigh_print - print the single hop neighbour list
175 * @bat_priv: the bat priv with all the soft interface information
176 * @seq: neighbour table seq_file struct
178 static void batadv_v_neigh_print(struct batadv_priv
*bat_priv
,
179 struct seq_file
*seq
)
181 struct net_device
*net_dev
= (struct net_device
*)seq
->private;
182 struct batadv_hardif_neigh_node
*hardif_neigh
;
183 struct batadv_hard_iface
*hard_iface
;
184 int batman_count
= 0;
187 " Neighbor last-seen ( throughput) [ IF]\n");
190 list_for_each_entry_rcu(hard_iface
, &batadv_hardif_list
, list
) {
191 if (hard_iface
->soft_iface
!= net_dev
)
194 hlist_for_each_entry_rcu(hardif_neigh
,
195 &hard_iface
->neigh_list
, list
) {
196 batadv_v_hardif_neigh_print(seq
, hardif_neigh
);
202 if (batman_count
== 0)
203 seq_puts(seq
, "No batman nodes in range ...\n");
207 * batadv_v_orig_print - print the originator table
208 * @bat_priv: the bat priv with all the soft interface information
209 * @seq: debugfs table seq_file struct
210 * @if_outgoing: the outgoing interface for which this should be printed
212 static void batadv_v_orig_print(struct batadv_priv
*bat_priv
,
213 struct seq_file
*seq
,
214 struct batadv_hard_iface
*if_outgoing
)
216 struct batadv_neigh_node
*neigh_node
;
217 struct batadv_hashtable
*hash
= bat_priv
->orig_hash
;
218 int last_seen_msecs
, last_seen_secs
;
219 struct batadv_orig_node
*orig_node
;
220 struct batadv_neigh_ifinfo
*n_ifinfo
;
221 unsigned long last_seen_jiffies
;
222 struct hlist_head
*head
;
223 int batman_count
= 0;
227 " Originator last-seen ( throughput) Nexthop [outgoingIF]: Potential nexthops ...\n");
229 for (i
= 0; i
< hash
->size
; i
++) {
230 head
= &hash
->table
[i
];
233 hlist_for_each_entry_rcu(orig_node
, head
, hash_entry
) {
234 neigh_node
= batadv_orig_router_get(orig_node
,
239 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
,
244 last_seen_jiffies
= jiffies
- orig_node
->last_seen
;
245 last_seen_msecs
= jiffies_to_msecs(last_seen_jiffies
);
246 last_seen_secs
= last_seen_msecs
/ 1000;
247 last_seen_msecs
= last_seen_msecs
% 1000;
249 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) %pM [%10s]:",
250 orig_node
->orig
, last_seen_secs
,
252 n_ifinfo
->bat_v
.throughput
/ 10,
253 n_ifinfo
->bat_v
.throughput
% 10,
255 neigh_node
->if_incoming
->net_dev
->name
);
257 batadv_v_orig_print_neigh(orig_node
, if_outgoing
, seq
);
262 batadv_neigh_node_put(neigh_node
);
264 batadv_neigh_ifinfo_put(n_ifinfo
);
269 if (batman_count
== 0)
270 seq_puts(seq
, "No batman nodes in range ...\n");
273 static int batadv_v_neigh_cmp(struct batadv_neigh_node
*neigh1
,
274 struct batadv_hard_iface
*if_outgoing1
,
275 struct batadv_neigh_node
*neigh2
,
276 struct batadv_hard_iface
*if_outgoing2
)
278 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
281 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
282 if (WARN_ON(!ifinfo1
))
285 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
286 if (WARN_ON(!ifinfo2
))
289 ret
= ifinfo1
->bat_v
.throughput
- ifinfo2
->bat_v
.throughput
;
291 batadv_neigh_ifinfo_put(ifinfo2
);
293 batadv_neigh_ifinfo_put(ifinfo1
);
298 static bool batadv_v_neigh_is_sob(struct batadv_neigh_node
*neigh1
,
299 struct batadv_hard_iface
*if_outgoing1
,
300 struct batadv_neigh_node
*neigh2
,
301 struct batadv_hard_iface
*if_outgoing2
)
303 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
307 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
308 if (WARN_ON(!ifinfo1
))
311 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
312 if (WARN_ON(!ifinfo2
))
315 threshold
= ifinfo1
->bat_v
.throughput
/ 4;
316 threshold
= ifinfo1
->bat_v
.throughput
- threshold
;
318 ret
= ifinfo2
->bat_v
.throughput
> threshold
;
320 batadv_neigh_ifinfo_put(ifinfo2
);
322 batadv_neigh_ifinfo_put(ifinfo1
);
327 static struct batadv_algo_ops batadv_batman_v __read_mostly
= {
329 .bat_iface_activate
= batadv_v_iface_activate
,
330 .bat_iface_enable
= batadv_v_iface_enable
,
331 .bat_iface_disable
= batadv_v_iface_disable
,
332 .bat_iface_update_mac
= batadv_v_iface_update_mac
,
333 .bat_primary_iface_set
= batadv_v_primary_iface_set
,
334 .bat_hardif_neigh_init
= batadv_v_hardif_neigh_init
,
335 .bat_orig_print
= batadv_v_orig_print
,
336 .bat_neigh_cmp
= batadv_v_neigh_cmp
,
337 .bat_neigh_is_similar_or_better
= batadv_v_neigh_is_sob
,
338 .bat_neigh_print
= batadv_v_neigh_print
,
342 * batadv_v_mesh_init - initialize the B.A.T.M.A.N. V private resources for a
344 * @bat_priv: the object representing the mesh interface to initialise
346 * Return: 0 on success or a negative error code otherwise
348 int batadv_v_mesh_init(struct batadv_priv
*bat_priv
)
350 return batadv_v_ogm_init(bat_priv
);
354 * batadv_v_mesh_free - free the B.A.T.M.A.N. V private resources for a mesh
355 * @bat_priv: the object representing the mesh interface to free
357 void batadv_v_mesh_free(struct batadv_priv
*bat_priv
)
359 batadv_v_ogm_free(bat_priv
);
363 * batadv_v_init - B.A.T.M.A.N. V initialization function
365 * Description: Takes care of initializing all the subcomponents.
366 * It is invoked upon module load only.
368 * Return: 0 on success or a negative error code otherwise
370 int __init
batadv_v_init(void)
374 /* B.A.T.M.A.N. V echo location protocol packet */
375 ret
= batadv_recv_handler_register(BATADV_ELP
,
376 batadv_v_elp_packet_recv
);
380 ret
= batadv_recv_handler_register(BATADV_OGM2
,
381 batadv_v_ogm_packet_recv
);
385 ret
= batadv_algo_register(&batadv_batman_v
);
392 batadv_recv_handler_unregister(BATADV_OGM2
);
395 batadv_recv_handler_unregister(BATADV_ELP
);