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 /* B.A.T.M.A.N. V does not use any queuing mechanism, therefore it can
44 * set the interface as ACTIVE right away, without any risk of race
47 if (hard_iface
->if_status
== BATADV_IF_TO_BE_ACTIVATED
)
48 hard_iface
->if_status
= BATADV_IF_ACTIVE
;
51 static int batadv_v_iface_enable(struct batadv_hard_iface
*hard_iface
)
55 ret
= batadv_v_elp_iface_enable(hard_iface
);
59 ret
= batadv_v_ogm_iface_enable(hard_iface
);
61 batadv_v_elp_iface_disable(hard_iface
);
63 /* enable link throughput auto-detection by setting the throughput
66 atomic_set(&hard_iface
->bat_v
.throughput_override
, 0);
71 static void batadv_v_iface_disable(struct batadv_hard_iface
*hard_iface
)
73 batadv_v_elp_iface_disable(hard_iface
);
76 static void batadv_v_iface_update_mac(struct batadv_hard_iface
*hard_iface
)
80 static void batadv_v_primary_iface_set(struct batadv_hard_iface
*hard_iface
)
82 batadv_v_elp_primary_iface_set(hard_iface
);
83 batadv_v_ogm_primary_iface_set(hard_iface
);
87 batadv_v_hardif_neigh_init(struct batadv_hardif_neigh_node
*hardif_neigh
)
89 ewma_throughput_init(&hardif_neigh
->bat_v
.throughput
);
90 INIT_WORK(&hardif_neigh
->bat_v
.metric_work
,
91 batadv_v_elp_throughput_metric_update
);
94 static void batadv_v_ogm_schedule(struct batadv_hard_iface
*hard_iface
)
98 static void batadv_v_ogm_emit(struct batadv_forw_packet
*forw_packet
)
103 * batadv_v_orig_print_neigh - print neighbors for the originator table
104 * @orig_node: the orig_node for which the neighbors are printed
105 * @if_outgoing: outgoing interface for these entries
106 * @seq: debugfs table seq_file struct
108 * Must be called while holding an rcu lock.
111 batadv_v_orig_print_neigh(struct batadv_orig_node
*orig_node
,
112 struct batadv_hard_iface
*if_outgoing
,
113 struct seq_file
*seq
)
115 struct batadv_neigh_node
*neigh_node
;
116 struct batadv_neigh_ifinfo
*n_ifinfo
;
118 hlist_for_each_entry_rcu(neigh_node
, &orig_node
->neigh_list
, list
) {
119 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
, if_outgoing
);
123 seq_printf(seq
, " %pM (%9u.%1u)",
125 n_ifinfo
->bat_v
.throughput
/ 10,
126 n_ifinfo
->bat_v
.throughput
% 10);
128 batadv_neigh_ifinfo_put(n_ifinfo
);
133 * batadv_v_hardif_neigh_print - print a single ELP neighbour node
134 * @seq: neighbour table seq_file struct
135 * @hardif_neigh: hardif neighbour information
138 batadv_v_hardif_neigh_print(struct seq_file
*seq
,
139 struct batadv_hardif_neigh_node
*hardif_neigh
)
141 int last_secs
, last_msecs
;
144 last_secs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) / 1000;
145 last_msecs
= jiffies_to_msecs(jiffies
- hardif_neigh
->last_seen
) % 1000;
146 throughput
= ewma_throughput_read(&hardif_neigh
->bat_v
.throughput
);
148 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) [%10s]\n",
149 hardif_neigh
->addr
, last_secs
, last_msecs
, throughput
/ 10,
150 throughput
% 10, hardif_neigh
->if_incoming
->net_dev
->name
);
154 * batadv_v_neigh_print - print the single hop neighbour list
155 * @bat_priv: the bat priv with all the soft interface information
156 * @seq: neighbour table seq_file struct
158 static void batadv_v_neigh_print(struct batadv_priv
*bat_priv
,
159 struct seq_file
*seq
)
161 struct net_device
*net_dev
= (struct net_device
*)seq
->private;
162 struct batadv_hardif_neigh_node
*hardif_neigh
;
163 struct batadv_hard_iface
*hard_iface
;
164 int batman_count
= 0;
167 " Neighbor last-seen ( throughput) [ IF]\n");
170 list_for_each_entry_rcu(hard_iface
, &batadv_hardif_list
, list
) {
171 if (hard_iface
->soft_iface
!= net_dev
)
174 hlist_for_each_entry_rcu(hardif_neigh
,
175 &hard_iface
->neigh_list
, list
) {
176 batadv_v_hardif_neigh_print(seq
, hardif_neigh
);
182 if (batman_count
== 0)
183 seq_puts(seq
, "No batman nodes in range ...\n");
187 * batadv_v_orig_print - print the originator table
188 * @bat_priv: the bat priv with all the soft interface information
189 * @seq: debugfs table seq_file struct
190 * @if_outgoing: the outgoing interface for which this should be printed
192 static void batadv_v_orig_print(struct batadv_priv
*bat_priv
,
193 struct seq_file
*seq
,
194 struct batadv_hard_iface
*if_outgoing
)
196 struct batadv_neigh_node
*neigh_node
;
197 struct batadv_hashtable
*hash
= bat_priv
->orig_hash
;
198 int last_seen_msecs
, last_seen_secs
;
199 struct batadv_orig_node
*orig_node
;
200 struct batadv_neigh_ifinfo
*n_ifinfo
;
201 unsigned long last_seen_jiffies
;
202 struct hlist_head
*head
;
203 int batman_count
= 0;
207 " Originator last-seen ( throughput) Nexthop [outgoingIF]: Potential nexthops ...\n");
209 for (i
= 0; i
< hash
->size
; i
++) {
210 head
= &hash
->table
[i
];
213 hlist_for_each_entry_rcu(orig_node
, head
, hash_entry
) {
214 neigh_node
= batadv_orig_router_get(orig_node
,
219 n_ifinfo
= batadv_neigh_ifinfo_get(neigh_node
,
224 last_seen_jiffies
= jiffies
- orig_node
->last_seen
;
225 last_seen_msecs
= jiffies_to_msecs(last_seen_jiffies
);
226 last_seen_secs
= last_seen_msecs
/ 1000;
227 last_seen_msecs
= last_seen_msecs
% 1000;
229 seq_printf(seq
, "%pM %4i.%03is (%9u.%1u) %pM [%10s]:",
230 orig_node
->orig
, last_seen_secs
,
232 n_ifinfo
->bat_v
.throughput
/ 10,
233 n_ifinfo
->bat_v
.throughput
% 10,
235 neigh_node
->if_incoming
->net_dev
->name
);
237 batadv_v_orig_print_neigh(orig_node
, if_outgoing
, seq
);
242 batadv_neigh_node_put(neigh_node
);
244 batadv_neigh_ifinfo_put(n_ifinfo
);
249 if (batman_count
== 0)
250 seq_puts(seq
, "No batman nodes in range ...\n");
253 static int batadv_v_neigh_cmp(struct batadv_neigh_node
*neigh1
,
254 struct batadv_hard_iface
*if_outgoing1
,
255 struct batadv_neigh_node
*neigh2
,
256 struct batadv_hard_iface
*if_outgoing2
)
258 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
260 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
261 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
263 if (WARN_ON(!ifinfo1
|| !ifinfo2
))
266 return ifinfo1
->bat_v
.throughput
- ifinfo2
->bat_v
.throughput
;
269 static bool batadv_v_neigh_is_sob(struct batadv_neigh_node
*neigh1
,
270 struct batadv_hard_iface
*if_outgoing1
,
271 struct batadv_neigh_node
*neigh2
,
272 struct batadv_hard_iface
*if_outgoing2
)
274 struct batadv_neigh_ifinfo
*ifinfo1
, *ifinfo2
;
277 ifinfo1
= batadv_neigh_ifinfo_get(neigh1
, if_outgoing1
);
278 ifinfo2
= batadv_neigh_ifinfo_get(neigh2
, if_outgoing2
);
280 if (WARN_ON(!ifinfo1
|| !ifinfo2
))
283 threshold
= ifinfo1
->bat_v
.throughput
/ 4;
284 threshold
= ifinfo1
->bat_v
.throughput
- threshold
;
286 return ifinfo2
->bat_v
.throughput
> threshold
;
289 static struct batadv_algo_ops batadv_batman_v __read_mostly
= {
291 .bat_iface_activate
= batadv_v_iface_activate
,
292 .bat_iface_enable
= batadv_v_iface_enable
,
293 .bat_iface_disable
= batadv_v_iface_disable
,
294 .bat_iface_update_mac
= batadv_v_iface_update_mac
,
295 .bat_primary_iface_set
= batadv_v_primary_iface_set
,
296 .bat_hardif_neigh_init
= batadv_v_hardif_neigh_init
,
297 .bat_ogm_emit
= batadv_v_ogm_emit
,
298 .bat_ogm_schedule
= batadv_v_ogm_schedule
,
299 .bat_orig_print
= batadv_v_orig_print
,
300 .bat_neigh_cmp
= batadv_v_neigh_cmp
,
301 .bat_neigh_is_similar_or_better
= batadv_v_neigh_is_sob
,
302 .bat_neigh_print
= batadv_v_neigh_print
,
306 * batadv_v_mesh_init - initialize the B.A.T.M.A.N. V private resources for a
308 * @bat_priv: the object representing the mesh interface to initialise
310 * Return: 0 on success or a negative error code otherwise
312 int batadv_v_mesh_init(struct batadv_priv
*bat_priv
)
314 return batadv_v_ogm_init(bat_priv
);
318 * batadv_v_mesh_free - free the B.A.T.M.A.N. V private resources for a mesh
319 * @bat_priv: the object representing the mesh interface to free
321 void batadv_v_mesh_free(struct batadv_priv
*bat_priv
)
323 batadv_v_ogm_free(bat_priv
);
327 * batadv_v_init - B.A.T.M.A.N. V initialization function
329 * Description: Takes care of initializing all the subcomponents.
330 * It is invoked upon module load only.
332 * Return: 0 on success or a negative error code otherwise
334 int __init
batadv_v_init(void)
338 /* B.A.T.M.A.N. V echo location protocol packet */
339 ret
= batadv_recv_handler_register(BATADV_ELP
,
340 batadv_v_elp_packet_recv
);
344 ret
= batadv_recv_handler_register(BATADV_OGM2
,
345 batadv_v_ogm_packet_recv
);
349 ret
= batadv_algo_register(&batadv_batman_v
);
356 batadv_recv_handler_unregister(BATADV_OGM2
);
359 batadv_recv_handler_unregister(BATADV_ELP
);