17db7d9f3SSven Eckelmann // SPDX-License-Identifier: GPL-2.0
2cfa55c6dSSven Eckelmann /* Copyright (C) B.A.T.M.A.N. contributors:
3d6f94d91SLinus Luessing *
4d6f94d91SLinus Luessing * Linus Lüssing, Marek Lindner
5d6f94d91SLinus Luessing */
6d6f94d91SLinus Luessing
7a2d08166SSven Eckelmann #include "bat_v.h"
8d6f94d91SLinus Luessing #include "main.h"
9d6f94d91SLinus Luessing
100b5ecc68SAntonio Quartulli #include <linux/atomic.h>
11d6f94d91SLinus Luessing #include <linux/cache.h>
1208686943SAntonio Quartulli #include <linux/errno.h>
13f02a478fSMatthias Schiffer #include <linux/if_ether.h>
14d6f94d91SLinus Luessing #include <linux/init.h>
15261e264dSAntonio Quartulli #include <linux/jiffies.h>
1650164d8fSAntonio Quartulli #include <linux/kref.h>
17*6f96d46fSSven Eckelmann #include <linux/limits.h>
189264c85cSSven Eckelmann #include <linux/list.h>
19fcd193e1SSven Eckelmann #include <linux/minmax.h>
20261e264dSAntonio Quartulli #include <linux/netdevice.h>
21f02a478fSMatthias Schiffer #include <linux/netlink.h>
22261e264dSAntonio Quartulli #include <linux/rculist.h>
23261e264dSAntonio Quartulli #include <linux/rcupdate.h>
2468a600deSSven Eckelmann #include <linux/skbuff.h>
259264c85cSSven Eckelmann #include <linux/spinlock.h>
26a45e932aSSven Eckelmann #include <linux/stddef.h>
2797869060SAntonio Quartulli #include <linux/types.h>
28c833484eSAntonio Quartulli #include <linux/workqueue.h>
29f02a478fSMatthias Schiffer #include <net/genetlink.h>
30f02a478fSMatthias Schiffer #include <net/netlink.h>
31fec149f5SSven Eckelmann #include <uapi/linux/batadv_packet.h>
32f02a478fSMatthias Schiffer #include <uapi/linux/batman_adv.h>
33d6f94d91SLinus Luessing
34a2d08166SSven Eckelmann #include "bat_algo.h"
35d6f94d91SLinus Luessing #include "bat_v_elp.h"
360da00359SAntonio Quartulli #include "bat_v_ogm.h"
3708686943SAntonio Quartulli #include "gateway_client.h"
38b6cf5d49SAntonio Quartulli #include "hard-interface.h"
39261e264dSAntonio Quartulli #include "hash.h"
4050164d8fSAntonio Quartulli #include "log.h"
41f02a478fSMatthias Schiffer #include "netlink.h"
4297869060SAntonio Quartulli #include "originator.h"
43d6f94d91SLinus Luessing
batadv_v_iface_activate(struct batadv_hard_iface * hard_iface)44b6cf5d49SAntonio Quartulli static void batadv_v_iface_activate(struct batadv_hard_iface *hard_iface)
45b6cf5d49SAntonio Quartulli {
46ebe24ceaSMarek Lindner struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
47ebe24ceaSMarek Lindner struct batadv_hard_iface *primary_if;
48ebe24ceaSMarek Lindner
49ebe24ceaSMarek Lindner primary_if = batadv_primary_if_get_selected(bat_priv);
50ebe24ceaSMarek Lindner
51ebe24ceaSMarek Lindner if (primary_if) {
52ebe24ceaSMarek Lindner batadv_v_elp_iface_activate(primary_if, hard_iface);
53ebe24ceaSMarek Lindner batadv_hardif_put(primary_if);
54ebe24ceaSMarek Lindner }
55ebe24ceaSMarek Lindner
56b6cf5d49SAntonio Quartulli /* B.A.T.M.A.N. V does not use any queuing mechanism, therefore it can
57b6cf5d49SAntonio Quartulli * set the interface as ACTIVE right away, without any risk of race
58b6cf5d49SAntonio Quartulli * condition
59b6cf5d49SAntonio Quartulli */
60b6cf5d49SAntonio Quartulli if (hard_iface->if_status == BATADV_IF_TO_BE_ACTIVATED)
61b6cf5d49SAntonio Quartulli hard_iface->if_status = BATADV_IF_ACTIVE;
62b6cf5d49SAntonio Quartulli }
63b6cf5d49SAntonio Quartulli
batadv_v_iface_enable(struct batadv_hard_iface * hard_iface)64d6f94d91SLinus Luessing static int batadv_v_iface_enable(struct batadv_hard_iface *hard_iface)
65d6f94d91SLinus Luessing {
660da00359SAntonio Quartulli int ret;
670da00359SAntonio Quartulli
680da00359SAntonio Quartulli ret = batadv_v_elp_iface_enable(hard_iface);
690da00359SAntonio Quartulli if (ret < 0)
700da00359SAntonio Quartulli return ret;
710da00359SAntonio Quartulli
720da00359SAntonio Quartulli ret = batadv_v_ogm_iface_enable(hard_iface);
730da00359SAntonio Quartulli if (ret < 0)
740da00359SAntonio Quartulli batadv_v_elp_iface_disable(hard_iface);
750da00359SAntonio Quartulli
760da00359SAntonio Quartulli return ret;
77d6f94d91SLinus Luessing }
78d6f94d91SLinus Luessing
batadv_v_iface_disable(struct batadv_hard_iface * hard_iface)79d6f94d91SLinus Luessing static void batadv_v_iface_disable(struct batadv_hard_iface *hard_iface)
80d6f94d91SLinus Luessing {
81f89255a0SLinus Lüssing batadv_v_ogm_iface_disable(hard_iface);
82d6f94d91SLinus Luessing batadv_v_elp_iface_disable(hard_iface);
83d6f94d91SLinus Luessing }
84d6f94d91SLinus Luessing
batadv_v_primary_iface_set(struct batadv_hard_iface * hard_iface)85d6f94d91SLinus Luessing static void batadv_v_primary_iface_set(struct batadv_hard_iface *hard_iface)
86d6f94d91SLinus Luessing {
87d6f94d91SLinus Luessing batadv_v_elp_primary_iface_set(hard_iface);
880da00359SAntonio Quartulli batadv_v_ogm_primary_iface_set(hard_iface);
89d6f94d91SLinus Luessing }
90d6f94d91SLinus Luessing
911653f61dSAntonio Quartulli /**
927e9a8c2cSSven Eckelmann * batadv_v_iface_update_mac() - react to hard-interface MAC address change
931653f61dSAntonio Quartulli * @hard_iface: the modified interface
941653f61dSAntonio Quartulli *
951653f61dSAntonio Quartulli * If the modified interface is the primary one, update the originator
961653f61dSAntonio Quartulli * address in the ELP and OGM messages to reflect the new MAC address.
971653f61dSAntonio Quartulli */
batadv_v_iface_update_mac(struct batadv_hard_iface * hard_iface)981653f61dSAntonio Quartulli static void batadv_v_iface_update_mac(struct batadv_hard_iface *hard_iface)
991653f61dSAntonio Quartulli {
1001653f61dSAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);
1011653f61dSAntonio Quartulli struct batadv_hard_iface *primary_if;
1021653f61dSAntonio Quartulli
1031653f61dSAntonio Quartulli primary_if = batadv_primary_if_get_selected(bat_priv);
1041653f61dSAntonio Quartulli if (primary_if != hard_iface)
1051653f61dSAntonio Quartulli goto out;
1061653f61dSAntonio Quartulli
1071653f61dSAntonio Quartulli batadv_v_primary_iface_set(hard_iface);
1081653f61dSAntonio Quartulli out:
1091653f61dSAntonio Quartulli batadv_hardif_put(primary_if);
1101653f61dSAntonio Quartulli }
1111653f61dSAntonio Quartulli
112162bd64cSLinus Luessing static void
batadv_v_hardif_neigh_init(struct batadv_hardif_neigh_node * hardif_neigh)113162bd64cSLinus Luessing batadv_v_hardif_neigh_init(struct batadv_hardif_neigh_node *hardif_neigh)
114162bd64cSLinus Luessing {
115162bd64cSLinus Luessing ewma_throughput_init(&hardif_neigh->bat_v.throughput);
116c833484eSAntonio Quartulli INIT_WORK(&hardif_neigh->bat_v.metric_work,
117c833484eSAntonio Quartulli batadv_v_elp_throughput_metric_update);
118162bd64cSLinus Luessing }
119162bd64cSLinus Luessing
120626d23e8SLinus Luessing /**
1217e9a8c2cSSven Eckelmann * batadv_v_neigh_dump_neigh() - Dump a neighbour into a message
122f02a478fSMatthias Schiffer * @msg: Netlink message to dump into
123f02a478fSMatthias Schiffer * @portid: Port making netlink request
124f02a478fSMatthias Schiffer * @seq: Sequence number of netlink message
125f02a478fSMatthias Schiffer * @hardif_neigh: Neighbour to dump
126f02a478fSMatthias Schiffer *
127f02a478fSMatthias Schiffer * Return: Error code, or 0 on success
128f02a478fSMatthias Schiffer */
129f02a478fSMatthias Schiffer static int
batadv_v_neigh_dump_neigh(struct sk_buff * msg,u32 portid,u32 seq,struct batadv_hardif_neigh_node * hardif_neigh)130f02a478fSMatthias Schiffer batadv_v_neigh_dump_neigh(struct sk_buff *msg, u32 portid, u32 seq,
131f02a478fSMatthias Schiffer struct batadv_hardif_neigh_node *hardif_neigh)
132f02a478fSMatthias Schiffer {
133f02a478fSMatthias Schiffer void *hdr;
134f02a478fSMatthias Schiffer unsigned int last_seen_msecs;
135f02a478fSMatthias Schiffer u32 throughput;
136f02a478fSMatthias Schiffer
137f02a478fSMatthias Schiffer last_seen_msecs = jiffies_to_msecs(jiffies - hardif_neigh->last_seen);
138f02a478fSMatthias Schiffer throughput = ewma_throughput_read(&hardif_neigh->bat_v.throughput);
139f02a478fSMatthias Schiffer throughput = throughput * 100;
140f02a478fSMatthias Schiffer
141f02a478fSMatthias Schiffer hdr = genlmsg_put(msg, portid, seq, &batadv_netlink_family, NLM_F_MULTI,
142f02a478fSMatthias Schiffer BATADV_CMD_GET_NEIGHBORS);
143f02a478fSMatthias Schiffer if (!hdr)
144f02a478fSMatthias Schiffer return -ENOBUFS;
145f02a478fSMatthias Schiffer
146f02a478fSMatthias Schiffer if (nla_put(msg, BATADV_ATTR_NEIGH_ADDRESS, ETH_ALEN,
147f02a478fSMatthias Schiffer hardif_neigh->addr) ||
148d295345aSSven Eckelmann nla_put_string(msg, BATADV_ATTR_HARD_IFNAME,
149d295345aSSven Eckelmann hardif_neigh->if_incoming->net_dev->name) ||
150f02a478fSMatthias Schiffer nla_put_u32(msg, BATADV_ATTR_HARD_IFINDEX,
151f02a478fSMatthias Schiffer hardif_neigh->if_incoming->net_dev->ifindex) ||
152f02a478fSMatthias Schiffer nla_put_u32(msg, BATADV_ATTR_LAST_SEEN_MSECS,
153f02a478fSMatthias Schiffer last_seen_msecs) ||
154f02a478fSMatthias Schiffer nla_put_u32(msg, BATADV_ATTR_THROUGHPUT, throughput))
155f02a478fSMatthias Schiffer goto nla_put_failure;
156f02a478fSMatthias Schiffer
157f02a478fSMatthias Schiffer genlmsg_end(msg, hdr);
158f02a478fSMatthias Schiffer return 0;
159f02a478fSMatthias Schiffer
160f02a478fSMatthias Schiffer nla_put_failure:
161f02a478fSMatthias Schiffer genlmsg_cancel(msg, hdr);
162f02a478fSMatthias Schiffer return -EMSGSIZE;
163f02a478fSMatthias Schiffer }
164f02a478fSMatthias Schiffer
165f02a478fSMatthias Schiffer /**
1667e9a8c2cSSven Eckelmann * batadv_v_neigh_dump_hardif() - Dump the neighbours of a hard interface into
167f02a478fSMatthias Schiffer * a message
168f02a478fSMatthias Schiffer * @msg: Netlink message to dump into
169f02a478fSMatthias Schiffer * @portid: Port making netlink request
170f02a478fSMatthias Schiffer * @seq: Sequence number of netlink message
171f02a478fSMatthias Schiffer * @bat_priv: The bat priv with all the soft interface information
172f02a478fSMatthias Schiffer * @hard_iface: The hard interface to be dumped
173f02a478fSMatthias Schiffer * @idx_s: Entries to be skipped
174f02a478fSMatthias Schiffer *
175f02a478fSMatthias Schiffer * This function assumes the caller holds rcu_read_lock().
176f02a478fSMatthias Schiffer *
177f02a478fSMatthias Schiffer * Return: Error code, or 0 on success
178f02a478fSMatthias Schiffer */
179f02a478fSMatthias Schiffer static int
batadv_v_neigh_dump_hardif(struct sk_buff * msg,u32 portid,u32 seq,struct batadv_priv * bat_priv,struct batadv_hard_iface * hard_iface,int * idx_s)180f02a478fSMatthias Schiffer batadv_v_neigh_dump_hardif(struct sk_buff *msg, u32 portid, u32 seq,
181f02a478fSMatthias Schiffer struct batadv_priv *bat_priv,
182f02a478fSMatthias Schiffer struct batadv_hard_iface *hard_iface,
183f02a478fSMatthias Schiffer int *idx_s)
184f02a478fSMatthias Schiffer {
185f02a478fSMatthias Schiffer struct batadv_hardif_neigh_node *hardif_neigh;
186f02a478fSMatthias Schiffer int idx = 0;
187f02a478fSMatthias Schiffer
188f02a478fSMatthias Schiffer hlist_for_each_entry_rcu(hardif_neigh,
189f02a478fSMatthias Schiffer &hard_iface->neigh_list, list) {
190f02a478fSMatthias Schiffer if (idx++ < *idx_s)
191f02a478fSMatthias Schiffer continue;
192f02a478fSMatthias Schiffer
193f02a478fSMatthias Schiffer if (batadv_v_neigh_dump_neigh(msg, portid, seq, hardif_neigh)) {
194f02a478fSMatthias Schiffer *idx_s = idx - 1;
195f02a478fSMatthias Schiffer return -EMSGSIZE;
196f02a478fSMatthias Schiffer }
197f02a478fSMatthias Schiffer }
198f02a478fSMatthias Schiffer
199f02a478fSMatthias Schiffer *idx_s = 0;
200f02a478fSMatthias Schiffer return 0;
201f02a478fSMatthias Schiffer }
202f02a478fSMatthias Schiffer
203f02a478fSMatthias Schiffer /**
2047e9a8c2cSSven Eckelmann * batadv_v_neigh_dump() - Dump the neighbours of a hard interface into a
205f02a478fSMatthias Schiffer * message
206f02a478fSMatthias Schiffer * @msg: Netlink message to dump into
207f02a478fSMatthias Schiffer * @cb: Control block containing additional options
208f02a478fSMatthias Schiffer * @bat_priv: The bat priv with all the soft interface information
209f02a478fSMatthias Schiffer * @single_hardif: Limit dumping to this hard interface
210f02a478fSMatthias Schiffer */
211f02a478fSMatthias Schiffer static void
batadv_v_neigh_dump(struct sk_buff * msg,struct netlink_callback * cb,struct batadv_priv * bat_priv,struct batadv_hard_iface * single_hardif)212f02a478fSMatthias Schiffer batadv_v_neigh_dump(struct sk_buff *msg, struct netlink_callback *cb,
213f02a478fSMatthias Schiffer struct batadv_priv *bat_priv,
214f02a478fSMatthias Schiffer struct batadv_hard_iface *single_hardif)
215f02a478fSMatthias Schiffer {
216f02a478fSMatthias Schiffer struct batadv_hard_iface *hard_iface;
217f02a478fSMatthias Schiffer int i_hardif = 0;
218f02a478fSMatthias Schiffer int i_hardif_s = cb->args[0];
219f02a478fSMatthias Schiffer int idx = cb->args[1];
220f02a478fSMatthias Schiffer int portid = NETLINK_CB(cb->skb).portid;
221f02a478fSMatthias Schiffer
222f02a478fSMatthias Schiffer rcu_read_lock();
223f02a478fSMatthias Schiffer if (single_hardif) {
224f02a478fSMatthias Schiffer if (i_hardif_s == 0) {
225f02a478fSMatthias Schiffer if (batadv_v_neigh_dump_hardif(msg, portid,
226f02a478fSMatthias Schiffer cb->nlh->nlmsg_seq,
227f02a478fSMatthias Schiffer bat_priv, single_hardif,
228f02a478fSMatthias Schiffer &idx) == 0)
229f02a478fSMatthias Schiffer i_hardif++;
230f02a478fSMatthias Schiffer }
231f02a478fSMatthias Schiffer } else {
232f02a478fSMatthias Schiffer list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) {
233f02a478fSMatthias Schiffer if (hard_iface->soft_iface != bat_priv->soft_iface)
234f02a478fSMatthias Schiffer continue;
235f02a478fSMatthias Schiffer
236f02a478fSMatthias Schiffer if (i_hardif++ < i_hardif_s)
237f02a478fSMatthias Schiffer continue;
238f02a478fSMatthias Schiffer
239f02a478fSMatthias Schiffer if (batadv_v_neigh_dump_hardif(msg, portid,
240f02a478fSMatthias Schiffer cb->nlh->nlmsg_seq,
241f02a478fSMatthias Schiffer bat_priv, hard_iface,
242f02a478fSMatthias Schiffer &idx)) {
243f02a478fSMatthias Schiffer i_hardif--;
244f02a478fSMatthias Schiffer break;
245f02a478fSMatthias Schiffer }
246f02a478fSMatthias Schiffer }
247f02a478fSMatthias Schiffer }
248f02a478fSMatthias Schiffer rcu_read_unlock();
249f02a478fSMatthias Schiffer
250f02a478fSMatthias Schiffer cb->args[0] = i_hardif;
251f02a478fSMatthias Schiffer cb->args[1] = idx;
252f02a478fSMatthias Schiffer }
253f02a478fSMatthias Schiffer
254f02a478fSMatthias Schiffer /**
2557e9a8c2cSSven Eckelmann * batadv_v_orig_dump_subentry() - Dump an originator subentry into a message
256f02a478fSMatthias Schiffer * @msg: Netlink message to dump into
257f02a478fSMatthias Schiffer * @portid: Port making netlink request
258f02a478fSMatthias Schiffer * @seq: Sequence number of netlink message
259f02a478fSMatthias Schiffer * @bat_priv: The bat priv with all the soft interface information
260f02a478fSMatthias Schiffer * @if_outgoing: Limit dump to entries with this outgoing interface
261f02a478fSMatthias Schiffer * @orig_node: Originator to dump
262f02a478fSMatthias Schiffer * @neigh_node: Single hops neighbour
263f02a478fSMatthias Schiffer * @best: Is the best originator
264f02a478fSMatthias Schiffer *
265f02a478fSMatthias Schiffer * Return: Error code, or 0 on success
266f02a478fSMatthias Schiffer */
267f02a478fSMatthias Schiffer static int
batadv_v_orig_dump_subentry(struct sk_buff * msg,u32 portid,u32 seq,struct batadv_priv * bat_priv,struct batadv_hard_iface * if_outgoing,struct batadv_orig_node * orig_node,struct batadv_neigh_node * neigh_node,bool best)268f02a478fSMatthias Schiffer batadv_v_orig_dump_subentry(struct sk_buff *msg, u32 portid, u32 seq,
269f02a478fSMatthias Schiffer struct batadv_priv *bat_priv,
270f02a478fSMatthias Schiffer struct batadv_hard_iface *if_outgoing,
271f02a478fSMatthias Schiffer struct batadv_orig_node *orig_node,
272f02a478fSMatthias Schiffer struct batadv_neigh_node *neigh_node,
273f02a478fSMatthias Schiffer bool best)
274f02a478fSMatthias Schiffer {
275f02a478fSMatthias Schiffer struct batadv_neigh_ifinfo *n_ifinfo;
276f02a478fSMatthias Schiffer unsigned int last_seen_msecs;
277f02a478fSMatthias Schiffer u32 throughput;
278f02a478fSMatthias Schiffer void *hdr;
279f02a478fSMatthias Schiffer
280f02a478fSMatthias Schiffer n_ifinfo = batadv_neigh_ifinfo_get(neigh_node, if_outgoing);
281f02a478fSMatthias Schiffer if (!n_ifinfo)
282f02a478fSMatthias Schiffer return 0;
283f02a478fSMatthias Schiffer
284f02a478fSMatthias Schiffer throughput = n_ifinfo->bat_v.throughput * 100;
285f02a478fSMatthias Schiffer
286f02a478fSMatthias Schiffer batadv_neigh_ifinfo_put(n_ifinfo);
287f02a478fSMatthias Schiffer
288f02a478fSMatthias Schiffer last_seen_msecs = jiffies_to_msecs(jiffies - orig_node->last_seen);
289f02a478fSMatthias Schiffer
290f02a478fSMatthias Schiffer if (if_outgoing != BATADV_IF_DEFAULT &&
291f02a478fSMatthias Schiffer if_outgoing != neigh_node->if_incoming)
292f02a478fSMatthias Schiffer return 0;
293f02a478fSMatthias Schiffer
294f02a478fSMatthias Schiffer hdr = genlmsg_put(msg, portid, seq, &batadv_netlink_family, NLM_F_MULTI,
295f02a478fSMatthias Schiffer BATADV_CMD_GET_ORIGINATORS);
296f02a478fSMatthias Schiffer if (!hdr)
297f02a478fSMatthias Schiffer return -ENOBUFS;
298f02a478fSMatthias Schiffer
299f02a478fSMatthias Schiffer if (nla_put(msg, BATADV_ATTR_ORIG_ADDRESS, ETH_ALEN, orig_node->orig) ||
300f02a478fSMatthias Schiffer nla_put(msg, BATADV_ATTR_NEIGH_ADDRESS, ETH_ALEN,
301f02a478fSMatthias Schiffer neigh_node->addr) ||
302d295345aSSven Eckelmann nla_put_string(msg, BATADV_ATTR_HARD_IFNAME,
303d295345aSSven Eckelmann neigh_node->if_incoming->net_dev->name) ||
304f02a478fSMatthias Schiffer nla_put_u32(msg, BATADV_ATTR_HARD_IFINDEX,
305f02a478fSMatthias Schiffer neigh_node->if_incoming->net_dev->ifindex) ||
306f02a478fSMatthias Schiffer nla_put_u32(msg, BATADV_ATTR_THROUGHPUT, throughput) ||
307f02a478fSMatthias Schiffer nla_put_u32(msg, BATADV_ATTR_LAST_SEEN_MSECS,
308f02a478fSMatthias Schiffer last_seen_msecs))
309f02a478fSMatthias Schiffer goto nla_put_failure;
310f02a478fSMatthias Schiffer
311f02a478fSMatthias Schiffer if (best && nla_put_flag(msg, BATADV_ATTR_FLAG_BEST))
312f02a478fSMatthias Schiffer goto nla_put_failure;
313f02a478fSMatthias Schiffer
314f02a478fSMatthias Schiffer genlmsg_end(msg, hdr);
315f02a478fSMatthias Schiffer return 0;
316f02a478fSMatthias Schiffer
317f02a478fSMatthias Schiffer nla_put_failure:
318f02a478fSMatthias Schiffer genlmsg_cancel(msg, hdr);
319f02a478fSMatthias Schiffer return -EMSGSIZE;
320f02a478fSMatthias Schiffer }
321f02a478fSMatthias Schiffer
322f02a478fSMatthias Schiffer /**
3237e9a8c2cSSven Eckelmann * batadv_v_orig_dump_entry() - Dump an originator entry into a message
324f02a478fSMatthias Schiffer * @msg: Netlink message to dump into
325f02a478fSMatthias Schiffer * @portid: Port making netlink request
326f02a478fSMatthias Schiffer * @seq: Sequence number of netlink message
327f02a478fSMatthias Schiffer * @bat_priv: The bat priv with all the soft interface information
328f02a478fSMatthias Schiffer * @if_outgoing: Limit dump to entries with this outgoing interface
329f02a478fSMatthias Schiffer * @orig_node: Originator to dump
330f02a478fSMatthias Schiffer * @sub_s: Number of sub entries to skip
331f02a478fSMatthias Schiffer *
332f02a478fSMatthias Schiffer * This function assumes the caller holds rcu_read_lock().
333f02a478fSMatthias Schiffer *
334f02a478fSMatthias Schiffer * Return: Error code, or 0 on success
335f02a478fSMatthias Schiffer */
336f02a478fSMatthias Schiffer static int
batadv_v_orig_dump_entry(struct sk_buff * msg,u32 portid,u32 seq,struct batadv_priv * bat_priv,struct batadv_hard_iface * if_outgoing,struct batadv_orig_node * orig_node,int * sub_s)337f02a478fSMatthias Schiffer batadv_v_orig_dump_entry(struct sk_buff *msg, u32 portid, u32 seq,
338f02a478fSMatthias Schiffer struct batadv_priv *bat_priv,
339f02a478fSMatthias Schiffer struct batadv_hard_iface *if_outgoing,
340f02a478fSMatthias Schiffer struct batadv_orig_node *orig_node, int *sub_s)
341f02a478fSMatthias Schiffer {
342f02a478fSMatthias Schiffer struct batadv_neigh_node *neigh_node_best;
343f02a478fSMatthias Schiffer struct batadv_neigh_node *neigh_node;
344f02a478fSMatthias Schiffer int sub = 0;
345f02a478fSMatthias Schiffer bool best;
346f02a478fSMatthias Schiffer
347f02a478fSMatthias Schiffer neigh_node_best = batadv_orig_router_get(orig_node, if_outgoing);
348f02a478fSMatthias Schiffer if (!neigh_node_best)
349f02a478fSMatthias Schiffer goto out;
350f02a478fSMatthias Schiffer
351f02a478fSMatthias Schiffer hlist_for_each_entry_rcu(neigh_node, &orig_node->neigh_list, list) {
352f02a478fSMatthias Schiffer if (sub++ < *sub_s)
353f02a478fSMatthias Schiffer continue;
354f02a478fSMatthias Schiffer
355f02a478fSMatthias Schiffer best = (neigh_node == neigh_node_best);
356f02a478fSMatthias Schiffer
357f02a478fSMatthias Schiffer if (batadv_v_orig_dump_subentry(msg, portid, seq, bat_priv,
358f02a478fSMatthias Schiffer if_outgoing, orig_node,
359f02a478fSMatthias Schiffer neigh_node, best)) {
360f02a478fSMatthias Schiffer batadv_neigh_node_put(neigh_node_best);
361f02a478fSMatthias Schiffer
362f02a478fSMatthias Schiffer *sub_s = sub - 1;
363f02a478fSMatthias Schiffer return -EMSGSIZE;
364f02a478fSMatthias Schiffer }
365f02a478fSMatthias Schiffer }
366f02a478fSMatthias Schiffer
367f02a478fSMatthias Schiffer out:
368f02a478fSMatthias Schiffer batadv_neigh_node_put(neigh_node_best);
369f02a478fSMatthias Schiffer
370f02a478fSMatthias Schiffer *sub_s = 0;
371f02a478fSMatthias Schiffer return 0;
372f02a478fSMatthias Schiffer }
373f02a478fSMatthias Schiffer
374f02a478fSMatthias Schiffer /**
3757e9a8c2cSSven Eckelmann * batadv_v_orig_dump_bucket() - Dump an originator bucket into a message
376f02a478fSMatthias Schiffer * @msg: Netlink message to dump into
377f02a478fSMatthias Schiffer * @portid: Port making netlink request
378f02a478fSMatthias Schiffer * @seq: Sequence number of netlink message
379f02a478fSMatthias Schiffer * @bat_priv: The bat priv with all the soft interface information
380f02a478fSMatthias Schiffer * @if_outgoing: Limit dump to entries with this outgoing interface
381f02a478fSMatthias Schiffer * @head: Bucket to be dumped
382f02a478fSMatthias Schiffer * @idx_s: Number of entries to be skipped
383f02a478fSMatthias Schiffer * @sub: Number of sub entries to be skipped
384f02a478fSMatthias Schiffer *
385f02a478fSMatthias Schiffer * Return: Error code, or 0 on success
386f02a478fSMatthias Schiffer */
387f02a478fSMatthias Schiffer static int
batadv_v_orig_dump_bucket(struct sk_buff * msg,u32 portid,u32 seq,struct batadv_priv * bat_priv,struct batadv_hard_iface * if_outgoing,struct hlist_head * head,int * idx_s,int * sub)388f02a478fSMatthias Schiffer batadv_v_orig_dump_bucket(struct sk_buff *msg, u32 portid, u32 seq,
389f02a478fSMatthias Schiffer struct batadv_priv *bat_priv,
390f02a478fSMatthias Schiffer struct batadv_hard_iface *if_outgoing,
391f02a478fSMatthias Schiffer struct hlist_head *head, int *idx_s, int *sub)
392f02a478fSMatthias Schiffer {
393f02a478fSMatthias Schiffer struct batadv_orig_node *orig_node;
394f02a478fSMatthias Schiffer int idx = 0;
395f02a478fSMatthias Schiffer
396f02a478fSMatthias Schiffer rcu_read_lock();
397f02a478fSMatthias Schiffer hlist_for_each_entry_rcu(orig_node, head, hash_entry) {
398f02a478fSMatthias Schiffer if (idx++ < *idx_s)
399f02a478fSMatthias Schiffer continue;
400f02a478fSMatthias Schiffer
401f02a478fSMatthias Schiffer if (batadv_v_orig_dump_entry(msg, portid, seq, bat_priv,
402f02a478fSMatthias Schiffer if_outgoing, orig_node, sub)) {
403f02a478fSMatthias Schiffer rcu_read_unlock();
404f02a478fSMatthias Schiffer *idx_s = idx - 1;
405f02a478fSMatthias Schiffer return -EMSGSIZE;
406f02a478fSMatthias Schiffer }
407f02a478fSMatthias Schiffer }
408f02a478fSMatthias Schiffer rcu_read_unlock();
409f02a478fSMatthias Schiffer
410f02a478fSMatthias Schiffer *idx_s = 0;
411f02a478fSMatthias Schiffer *sub = 0;
412f02a478fSMatthias Schiffer return 0;
413f02a478fSMatthias Schiffer }
414f02a478fSMatthias Schiffer
415f02a478fSMatthias Schiffer /**
4167e9a8c2cSSven Eckelmann * batadv_v_orig_dump() - Dump the originators into a message
417f02a478fSMatthias Schiffer * @msg: Netlink message to dump into
418f02a478fSMatthias Schiffer * @cb: Control block containing additional options
419f02a478fSMatthias Schiffer * @bat_priv: The bat priv with all the soft interface information
420f02a478fSMatthias Schiffer * @if_outgoing: Limit dump to entries with this outgoing interface
421f02a478fSMatthias Schiffer */
422f02a478fSMatthias Schiffer static void
batadv_v_orig_dump(struct sk_buff * msg,struct netlink_callback * cb,struct batadv_priv * bat_priv,struct batadv_hard_iface * if_outgoing)423f02a478fSMatthias Schiffer batadv_v_orig_dump(struct sk_buff *msg, struct netlink_callback *cb,
424f02a478fSMatthias Schiffer struct batadv_priv *bat_priv,
425f02a478fSMatthias Schiffer struct batadv_hard_iface *if_outgoing)
426f02a478fSMatthias Schiffer {
427f02a478fSMatthias Schiffer struct batadv_hashtable *hash = bat_priv->orig_hash;
428f02a478fSMatthias Schiffer struct hlist_head *head;
429f02a478fSMatthias Schiffer int bucket = cb->args[0];
430f02a478fSMatthias Schiffer int idx = cb->args[1];
431f02a478fSMatthias Schiffer int sub = cb->args[2];
432f02a478fSMatthias Schiffer int portid = NETLINK_CB(cb->skb).portid;
433f02a478fSMatthias Schiffer
434f02a478fSMatthias Schiffer while (bucket < hash->size) {
435f02a478fSMatthias Schiffer head = &hash->table[bucket];
436f02a478fSMatthias Schiffer
437f02a478fSMatthias Schiffer if (batadv_v_orig_dump_bucket(msg, portid,
438f02a478fSMatthias Schiffer cb->nlh->nlmsg_seq,
439f02a478fSMatthias Schiffer bat_priv, if_outgoing, head, &idx,
440f02a478fSMatthias Schiffer &sub))
441f02a478fSMatthias Schiffer break;
442f02a478fSMatthias Schiffer
443f02a478fSMatthias Schiffer bucket++;
444f02a478fSMatthias Schiffer }
445f02a478fSMatthias Schiffer
446f02a478fSMatthias Schiffer cb->args[0] = bucket;
447f02a478fSMatthias Schiffer cb->args[1] = idx;
448f02a478fSMatthias Schiffer cb->args[2] = sub;
449f02a478fSMatthias Schiffer }
450f02a478fSMatthias Schiffer
batadv_v_neigh_cmp(struct batadv_neigh_node * neigh1,struct batadv_hard_iface * if_outgoing1,struct batadv_neigh_node * neigh2,struct batadv_hard_iface * if_outgoing2)45197869060SAntonio Quartulli static int batadv_v_neigh_cmp(struct batadv_neigh_node *neigh1,
45297869060SAntonio Quartulli struct batadv_hard_iface *if_outgoing1,
45397869060SAntonio Quartulli struct batadv_neigh_node *neigh2,
45497869060SAntonio Quartulli struct batadv_hard_iface *if_outgoing2)
45597869060SAntonio Quartulli {
45697869060SAntonio Quartulli struct batadv_neigh_ifinfo *ifinfo1, *ifinfo2;
45771f9d27dSSven Eckelmann int ret = 0;
45897869060SAntonio Quartulli
45997869060SAntonio Quartulli ifinfo1 = batadv_neigh_ifinfo_get(neigh1, if_outgoing1);
4606a4bc44bSSven Eckelmann if (!ifinfo1)
46171f9d27dSSven Eckelmann goto err_ifinfo1;
46271f9d27dSSven Eckelmann
46397869060SAntonio Quartulli ifinfo2 = batadv_neigh_ifinfo_get(neigh2, if_outgoing2);
4646a4bc44bSSven Eckelmann if (!ifinfo2)
46571f9d27dSSven Eckelmann goto err_ifinfo2;
46697869060SAntonio Quartulli
46771f9d27dSSven Eckelmann ret = ifinfo1->bat_v.throughput - ifinfo2->bat_v.throughput;
46897869060SAntonio Quartulli
46971f9d27dSSven Eckelmann batadv_neigh_ifinfo_put(ifinfo2);
47071f9d27dSSven Eckelmann err_ifinfo2:
47171f9d27dSSven Eckelmann batadv_neigh_ifinfo_put(ifinfo1);
47271f9d27dSSven Eckelmann err_ifinfo1:
47371f9d27dSSven Eckelmann return ret;
47497869060SAntonio Quartulli }
47597869060SAntonio Quartulli
batadv_v_neigh_is_sob(struct batadv_neigh_node * neigh1,struct batadv_hard_iface * if_outgoing1,struct batadv_neigh_node * neigh2,struct batadv_hard_iface * if_outgoing2)47697869060SAntonio Quartulli static bool batadv_v_neigh_is_sob(struct batadv_neigh_node *neigh1,
47797869060SAntonio Quartulli struct batadv_hard_iface *if_outgoing1,
47897869060SAntonio Quartulli struct batadv_neigh_node *neigh2,
47997869060SAntonio Quartulli struct batadv_hard_iface *if_outgoing2)
48097869060SAntonio Quartulli {
48197869060SAntonio Quartulli struct batadv_neigh_ifinfo *ifinfo1, *ifinfo2;
48297869060SAntonio Quartulli u32 threshold;
48371f9d27dSSven Eckelmann bool ret = false;
48497869060SAntonio Quartulli
48597869060SAntonio Quartulli ifinfo1 = batadv_neigh_ifinfo_get(neigh1, if_outgoing1);
4866a4bc44bSSven Eckelmann if (!ifinfo1)
48771f9d27dSSven Eckelmann goto err_ifinfo1;
48897869060SAntonio Quartulli
48971f9d27dSSven Eckelmann ifinfo2 = batadv_neigh_ifinfo_get(neigh2, if_outgoing2);
4906a4bc44bSSven Eckelmann if (!ifinfo2)
49171f9d27dSSven Eckelmann goto err_ifinfo2;
492a45e932aSSven Eckelmann
49397869060SAntonio Quartulli threshold = ifinfo1->bat_v.throughput / 4;
49497869060SAntonio Quartulli threshold = ifinfo1->bat_v.throughput - threshold;
49597869060SAntonio Quartulli
49671f9d27dSSven Eckelmann ret = ifinfo2->bat_v.throughput > threshold;
49771f9d27dSSven Eckelmann
49871f9d27dSSven Eckelmann batadv_neigh_ifinfo_put(ifinfo2);
49971f9d27dSSven Eckelmann err_ifinfo2:
50071f9d27dSSven Eckelmann batadv_neigh_ifinfo_put(ifinfo1);
50171f9d27dSSven Eckelmann err_ifinfo1:
50271f9d27dSSven Eckelmann return ret;
50397869060SAntonio Quartulli }
50497869060SAntonio Quartulli
5051a9070ecSSven Eckelmann /**
5067e9a8c2cSSven Eckelmann * batadv_v_init_sel_class() - initialize GW selection class
5071a9070ecSSven Eckelmann * @bat_priv: the bat priv with all the soft interface information
5081a9070ecSSven Eckelmann */
batadv_v_init_sel_class(struct batadv_priv * bat_priv)5091a9070ecSSven Eckelmann static void batadv_v_init_sel_class(struct batadv_priv *bat_priv)
5101a9070ecSSven Eckelmann {
5111a9070ecSSven Eckelmann /* set default throughput difference threshold to 5Mbps */
5121a9070ecSSven Eckelmann atomic_set(&bat_priv->gw.sel_class, 50);
5131a9070ecSSven Eckelmann }
5141a9070ecSSven Eckelmann
51550164d8fSAntonio Quartulli /**
5167e9a8c2cSSven Eckelmann * batadv_v_gw_throughput_get() - retrieve the GW-bandwidth for a given GW
51750164d8fSAntonio Quartulli * @gw_node: the GW to retrieve the metric for
51850164d8fSAntonio Quartulli * @bw: the pointer where the metric will be stored. The metric is computed as
51950164d8fSAntonio Quartulli * the minimum between the GW advertised throughput and the path throughput to
52050164d8fSAntonio Quartulli * it in the mesh
52150164d8fSAntonio Quartulli *
52250164d8fSAntonio Quartulli * Return: 0 on success, -1 on failure
52350164d8fSAntonio Quartulli */
batadv_v_gw_throughput_get(struct batadv_gw_node * gw_node,u32 * bw)52450164d8fSAntonio Quartulli static int batadv_v_gw_throughput_get(struct batadv_gw_node *gw_node, u32 *bw)
52550164d8fSAntonio Quartulli {
52650164d8fSAntonio Quartulli struct batadv_neigh_ifinfo *router_ifinfo = NULL;
52750164d8fSAntonio Quartulli struct batadv_orig_node *orig_node;
52850164d8fSAntonio Quartulli struct batadv_neigh_node *router;
52950164d8fSAntonio Quartulli int ret = -1;
53050164d8fSAntonio Quartulli
53150164d8fSAntonio Quartulli orig_node = gw_node->orig_node;
53250164d8fSAntonio Quartulli router = batadv_orig_router_get(orig_node, BATADV_IF_DEFAULT);
53350164d8fSAntonio Quartulli if (!router)
53450164d8fSAntonio Quartulli goto out;
53550164d8fSAntonio Quartulli
53650164d8fSAntonio Quartulli router_ifinfo = batadv_neigh_ifinfo_get(router, BATADV_IF_DEFAULT);
53750164d8fSAntonio Quartulli if (!router_ifinfo)
53850164d8fSAntonio Quartulli goto out;
53950164d8fSAntonio Quartulli
54050164d8fSAntonio Quartulli /* the GW metric is computed as the minimum between the path throughput
54150164d8fSAntonio Quartulli * to reach the GW itself and the advertised bandwidth.
54250164d8fSAntonio Quartulli * This gives us an approximation of the effective throughput that the
54350164d8fSAntonio Quartulli * client can expect via this particular GW node
54450164d8fSAntonio Quartulli */
54550164d8fSAntonio Quartulli *bw = router_ifinfo->bat_v.throughput;
54650164d8fSAntonio Quartulli *bw = min_t(u32, *bw, gw_node->bandwidth_down);
54750164d8fSAntonio Quartulli
54850164d8fSAntonio Quartulli ret = 0;
54950164d8fSAntonio Quartulli out:
55050164d8fSAntonio Quartulli batadv_neigh_node_put(router);
55150164d8fSAntonio Quartulli batadv_neigh_ifinfo_put(router_ifinfo);
55250164d8fSAntonio Quartulli
55350164d8fSAntonio Quartulli return ret;
55450164d8fSAntonio Quartulli }
55550164d8fSAntonio Quartulli
55650164d8fSAntonio Quartulli /**
5577e9a8c2cSSven Eckelmann * batadv_v_gw_get_best_gw_node() - retrieve the best GW node
55850164d8fSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information
55950164d8fSAntonio Quartulli *
56050164d8fSAntonio Quartulli * Return: the GW node having the best GW-metric, NULL if no GW is known
56150164d8fSAntonio Quartulli */
56250164d8fSAntonio Quartulli static struct batadv_gw_node *
batadv_v_gw_get_best_gw_node(struct batadv_priv * bat_priv)56350164d8fSAntonio Quartulli batadv_v_gw_get_best_gw_node(struct batadv_priv *bat_priv)
56450164d8fSAntonio Quartulli {
56550164d8fSAntonio Quartulli struct batadv_gw_node *gw_node, *curr_gw = NULL;
56650164d8fSAntonio Quartulli u32 max_bw = 0, bw;
56750164d8fSAntonio Quartulli
56850164d8fSAntonio Quartulli rcu_read_lock();
56970ea5ceeSSven Eckelmann hlist_for_each_entry_rcu(gw_node, &bat_priv->gw.gateway_list, list) {
57050164d8fSAntonio Quartulli if (!kref_get_unless_zero(&gw_node->refcount))
57150164d8fSAntonio Quartulli continue;
57250164d8fSAntonio Quartulli
57350164d8fSAntonio Quartulli if (batadv_v_gw_throughput_get(gw_node, &bw) < 0)
57450164d8fSAntonio Quartulli goto next;
57550164d8fSAntonio Quartulli
576825ffe1fSSven Eckelmann if (curr_gw && bw <= max_bw)
57750164d8fSAntonio Quartulli goto next;
57850164d8fSAntonio Quartulli
57950164d8fSAntonio Quartulli batadv_gw_node_put(curr_gw);
58050164d8fSAntonio Quartulli
58150164d8fSAntonio Quartulli curr_gw = gw_node;
58250164d8fSAntonio Quartulli kref_get(&curr_gw->refcount);
58350164d8fSAntonio Quartulli max_bw = bw;
58450164d8fSAntonio Quartulli
58550164d8fSAntonio Quartulli next:
58650164d8fSAntonio Quartulli batadv_gw_node_put(gw_node);
58750164d8fSAntonio Quartulli }
58850164d8fSAntonio Quartulli rcu_read_unlock();
58950164d8fSAntonio Quartulli
59050164d8fSAntonio Quartulli return curr_gw;
59150164d8fSAntonio Quartulli }
59250164d8fSAntonio Quartulli
59350164d8fSAntonio Quartulli /**
5947e9a8c2cSSven Eckelmann * batadv_v_gw_is_eligible() - check if a originator would be selected as GW
59550164d8fSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information
59650164d8fSAntonio Quartulli * @curr_gw_orig: originator representing the currently selected GW
59750164d8fSAntonio Quartulli * @orig_node: the originator representing the new candidate
59850164d8fSAntonio Quartulli *
59950164d8fSAntonio Quartulli * Return: true if orig_node can be selected as current GW, false otherwise
60050164d8fSAntonio Quartulli */
batadv_v_gw_is_eligible(struct batadv_priv * bat_priv,struct batadv_orig_node * curr_gw_orig,struct batadv_orig_node * orig_node)60150164d8fSAntonio Quartulli static bool batadv_v_gw_is_eligible(struct batadv_priv *bat_priv,
60250164d8fSAntonio Quartulli struct batadv_orig_node *curr_gw_orig,
60350164d8fSAntonio Quartulli struct batadv_orig_node *orig_node)
60450164d8fSAntonio Quartulli {
605422d2f77SSven Eckelmann struct batadv_gw_node *curr_gw, *orig_gw = NULL;
60650164d8fSAntonio Quartulli u32 gw_throughput, orig_throughput, threshold;
60750164d8fSAntonio Quartulli bool ret = false;
60850164d8fSAntonio Quartulli
60950164d8fSAntonio Quartulli threshold = atomic_read(&bat_priv->gw.sel_class);
61050164d8fSAntonio Quartulli
61150164d8fSAntonio Quartulli curr_gw = batadv_gw_node_get(bat_priv, curr_gw_orig);
61250164d8fSAntonio Quartulli if (!curr_gw) {
61350164d8fSAntonio Quartulli ret = true;
61450164d8fSAntonio Quartulli goto out;
61550164d8fSAntonio Quartulli }
61650164d8fSAntonio Quartulli
61750164d8fSAntonio Quartulli if (batadv_v_gw_throughput_get(curr_gw, &gw_throughput) < 0) {
61850164d8fSAntonio Quartulli ret = true;
61950164d8fSAntonio Quartulli goto out;
62050164d8fSAntonio Quartulli }
62150164d8fSAntonio Quartulli
62250164d8fSAntonio Quartulli orig_gw = batadv_gw_node_get(bat_priv, orig_node);
623198a62ddSSven Eckelmann if (!orig_gw)
62450164d8fSAntonio Quartulli goto out;
62550164d8fSAntonio Quartulli
62650164d8fSAntonio Quartulli if (batadv_v_gw_throughput_get(orig_gw, &orig_throughput) < 0)
62750164d8fSAntonio Quartulli goto out;
62850164d8fSAntonio Quartulli
62950164d8fSAntonio Quartulli if (orig_throughput < gw_throughput)
63050164d8fSAntonio Quartulli goto out;
63150164d8fSAntonio Quartulli
63250164d8fSAntonio Quartulli if ((orig_throughput - gw_throughput) < threshold)
63350164d8fSAntonio Quartulli goto out;
63450164d8fSAntonio Quartulli
63550164d8fSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv,
63650164d8fSAntonio Quartulli "Restarting gateway selection: better gateway found (throughput curr: %u, throughput new: %u)\n",
63750164d8fSAntonio Quartulli gw_throughput, orig_throughput);
63850164d8fSAntonio Quartulli
63950164d8fSAntonio Quartulli ret = true;
64050164d8fSAntonio Quartulli out:
64150164d8fSAntonio Quartulli batadv_gw_node_put(curr_gw);
64250164d8fSAntonio Quartulli batadv_gw_node_put(orig_gw);
64350164d8fSAntonio Quartulli
64450164d8fSAntonio Quartulli return ret;
64550164d8fSAntonio Quartulli }
64650164d8fSAntonio Quartulli
647b71bb6f9SSven Eckelmann /**
6487e9a8c2cSSven Eckelmann * batadv_v_gw_dump_entry() - Dump a gateway into a message
649b71bb6f9SSven Eckelmann * @msg: Netlink message to dump into
650b71bb6f9SSven Eckelmann * @portid: Port making netlink request
6519264c85cSSven Eckelmann * @cb: Control block containing additional options
652b71bb6f9SSven Eckelmann * @bat_priv: The bat priv with all the soft interface information
653b71bb6f9SSven Eckelmann * @gw_node: Gateway to be dumped
654b71bb6f9SSven Eckelmann *
655b71bb6f9SSven Eckelmann * Return: Error code, or 0 on success
656b71bb6f9SSven Eckelmann */
batadv_v_gw_dump_entry(struct sk_buff * msg,u32 portid,struct netlink_callback * cb,struct batadv_priv * bat_priv,struct batadv_gw_node * gw_node)6579264c85cSSven Eckelmann static int batadv_v_gw_dump_entry(struct sk_buff *msg, u32 portid,
6589264c85cSSven Eckelmann struct netlink_callback *cb,
659b71bb6f9SSven Eckelmann struct batadv_priv *bat_priv,
660b71bb6f9SSven Eckelmann struct batadv_gw_node *gw_node)
661b71bb6f9SSven Eckelmann {
662b71bb6f9SSven Eckelmann struct batadv_neigh_ifinfo *router_ifinfo = NULL;
663b71bb6f9SSven Eckelmann struct batadv_neigh_node *router;
6649713cb0cSSven Eckelmann struct batadv_gw_node *curr_gw = NULL;
665011c935fSSven Eckelmann int ret = 0;
666b71bb6f9SSven Eckelmann void *hdr;
667b71bb6f9SSven Eckelmann
668b71bb6f9SSven Eckelmann router = batadv_orig_router_get(gw_node->orig_node, BATADV_IF_DEFAULT);
669b71bb6f9SSven Eckelmann if (!router)
670b71bb6f9SSven Eckelmann goto out;
671b71bb6f9SSven Eckelmann
672b71bb6f9SSven Eckelmann router_ifinfo = batadv_neigh_ifinfo_get(router, BATADV_IF_DEFAULT);
673b71bb6f9SSven Eckelmann if (!router_ifinfo)
674b71bb6f9SSven Eckelmann goto out;
675b71bb6f9SSven Eckelmann
676b71bb6f9SSven Eckelmann curr_gw = batadv_gw_get_selected_gw_node(bat_priv);
677b71bb6f9SSven Eckelmann
6789264c85cSSven Eckelmann hdr = genlmsg_put(msg, portid, cb->nlh->nlmsg_seq,
6799264c85cSSven Eckelmann &batadv_netlink_family, NLM_F_MULTI,
6809264c85cSSven Eckelmann BATADV_CMD_GET_GATEWAYS);
681b71bb6f9SSven Eckelmann if (!hdr) {
682b71bb6f9SSven Eckelmann ret = -ENOBUFS;
683b71bb6f9SSven Eckelmann goto out;
684b71bb6f9SSven Eckelmann }
685b71bb6f9SSven Eckelmann
6869264c85cSSven Eckelmann genl_dump_check_consistent(cb, hdr);
6879264c85cSSven Eckelmann
688b71bb6f9SSven Eckelmann ret = -EMSGSIZE;
689b71bb6f9SSven Eckelmann
690b71bb6f9SSven Eckelmann if (curr_gw == gw_node) {
691b71bb6f9SSven Eckelmann if (nla_put_flag(msg, BATADV_ATTR_FLAG_BEST)) {
692b71bb6f9SSven Eckelmann genlmsg_cancel(msg, hdr);
693b71bb6f9SSven Eckelmann goto out;
694b71bb6f9SSven Eckelmann }
695b71bb6f9SSven Eckelmann }
696b71bb6f9SSven Eckelmann
697b71bb6f9SSven Eckelmann if (nla_put(msg, BATADV_ATTR_ORIG_ADDRESS, ETH_ALEN,
698b71bb6f9SSven Eckelmann gw_node->orig_node->orig)) {
699b71bb6f9SSven Eckelmann genlmsg_cancel(msg, hdr);
700b71bb6f9SSven Eckelmann goto out;
701b71bb6f9SSven Eckelmann }
702b71bb6f9SSven Eckelmann
703b71bb6f9SSven Eckelmann if (nla_put_u32(msg, BATADV_ATTR_THROUGHPUT,
704b71bb6f9SSven Eckelmann router_ifinfo->bat_v.throughput)) {
705b71bb6f9SSven Eckelmann genlmsg_cancel(msg, hdr);
706b71bb6f9SSven Eckelmann goto out;
707b71bb6f9SSven Eckelmann }
708b71bb6f9SSven Eckelmann
709b71bb6f9SSven Eckelmann if (nla_put(msg, BATADV_ATTR_ROUTER, ETH_ALEN, router->addr)) {
710b71bb6f9SSven Eckelmann genlmsg_cancel(msg, hdr);
711b71bb6f9SSven Eckelmann goto out;
712b71bb6f9SSven Eckelmann }
713b71bb6f9SSven Eckelmann
714b71bb6f9SSven Eckelmann if (nla_put_string(msg, BATADV_ATTR_HARD_IFNAME,
715b71bb6f9SSven Eckelmann router->if_incoming->net_dev->name)) {
716b71bb6f9SSven Eckelmann genlmsg_cancel(msg, hdr);
717b71bb6f9SSven Eckelmann goto out;
718b71bb6f9SSven Eckelmann }
719b71bb6f9SSven Eckelmann
720d295345aSSven Eckelmann if (nla_put_u32(msg, BATADV_ATTR_HARD_IFINDEX,
721d295345aSSven Eckelmann router->if_incoming->net_dev->ifindex)) {
722d295345aSSven Eckelmann genlmsg_cancel(msg, hdr);
723d295345aSSven Eckelmann goto out;
724d295345aSSven Eckelmann }
725d295345aSSven Eckelmann
726b71bb6f9SSven Eckelmann if (nla_put_u32(msg, BATADV_ATTR_BANDWIDTH_DOWN,
727b71bb6f9SSven Eckelmann gw_node->bandwidth_down)) {
728b71bb6f9SSven Eckelmann genlmsg_cancel(msg, hdr);
729b71bb6f9SSven Eckelmann goto out;
730b71bb6f9SSven Eckelmann }
731b71bb6f9SSven Eckelmann
732b71bb6f9SSven Eckelmann if (nla_put_u32(msg, BATADV_ATTR_BANDWIDTH_UP, gw_node->bandwidth_up)) {
733b71bb6f9SSven Eckelmann genlmsg_cancel(msg, hdr);
734b71bb6f9SSven Eckelmann goto out;
735b71bb6f9SSven Eckelmann }
736b71bb6f9SSven Eckelmann
737b71bb6f9SSven Eckelmann genlmsg_end(msg, hdr);
738b71bb6f9SSven Eckelmann ret = 0;
739b71bb6f9SSven Eckelmann
740b71bb6f9SSven Eckelmann out:
7419713cb0cSSven Eckelmann batadv_gw_node_put(curr_gw);
742b71bb6f9SSven Eckelmann batadv_neigh_ifinfo_put(router_ifinfo);
743b71bb6f9SSven Eckelmann batadv_neigh_node_put(router);
744b71bb6f9SSven Eckelmann return ret;
745b71bb6f9SSven Eckelmann }
746b71bb6f9SSven Eckelmann
747b71bb6f9SSven Eckelmann /**
7487e9a8c2cSSven Eckelmann * batadv_v_gw_dump() - Dump gateways into a message
749b71bb6f9SSven Eckelmann * @msg: Netlink message to dump into
750b71bb6f9SSven Eckelmann * @cb: Control block containing additional options
751b71bb6f9SSven Eckelmann * @bat_priv: The bat priv with all the soft interface information
752b71bb6f9SSven Eckelmann */
batadv_v_gw_dump(struct sk_buff * msg,struct netlink_callback * cb,struct batadv_priv * bat_priv)753b71bb6f9SSven Eckelmann static void batadv_v_gw_dump(struct sk_buff *msg, struct netlink_callback *cb,
754b71bb6f9SSven Eckelmann struct batadv_priv *bat_priv)
755b71bb6f9SSven Eckelmann {
756b71bb6f9SSven Eckelmann int portid = NETLINK_CB(cb->skb).portid;
757b71bb6f9SSven Eckelmann struct batadv_gw_node *gw_node;
758b71bb6f9SSven Eckelmann int idx_skip = cb->args[0];
759b71bb6f9SSven Eckelmann int idx = 0;
760b71bb6f9SSven Eckelmann
7619264c85cSSven Eckelmann spin_lock_bh(&bat_priv->gw.list_lock);
7629264c85cSSven Eckelmann cb->seq = bat_priv->gw.generation << 1 | 1;
7639264c85cSSven Eckelmann
7649264c85cSSven Eckelmann hlist_for_each_entry(gw_node, &bat_priv->gw.gateway_list, list) {
765b71bb6f9SSven Eckelmann if (idx++ < idx_skip)
766b71bb6f9SSven Eckelmann continue;
767b71bb6f9SSven Eckelmann
7689264c85cSSven Eckelmann if (batadv_v_gw_dump_entry(msg, portid, cb, bat_priv,
7699264c85cSSven Eckelmann gw_node)) {
770b71bb6f9SSven Eckelmann idx_skip = idx - 1;
771b71bb6f9SSven Eckelmann goto unlock;
772b71bb6f9SSven Eckelmann }
773b71bb6f9SSven Eckelmann }
774b71bb6f9SSven Eckelmann
775b71bb6f9SSven Eckelmann idx_skip = idx;
776b71bb6f9SSven Eckelmann unlock:
7779264c85cSSven Eckelmann spin_unlock_bh(&bat_priv->gw.list_lock);
778b71bb6f9SSven Eckelmann
779b71bb6f9SSven Eckelmann cb->args[0] = idx_skip;
780b71bb6f9SSven Eckelmann }
781b71bb6f9SSven Eckelmann
782d6f94d91SLinus Luessing static struct batadv_algo_ops batadv_batman_v __read_mostly = {
783d6f94d91SLinus Luessing .name = "BATMAN_V",
78429824a55SAntonio Quartulli .iface = {
78529824a55SAntonio Quartulli .activate = batadv_v_iface_activate,
78629824a55SAntonio Quartulli .enable = batadv_v_iface_enable,
78729824a55SAntonio Quartulli .disable = batadv_v_iface_disable,
78829824a55SAntonio Quartulli .update_mac = batadv_v_iface_update_mac,
78929824a55SAntonio Quartulli .primary_set = batadv_v_primary_iface_set,
79029824a55SAntonio Quartulli },
79129824a55SAntonio Quartulli .neigh = {
79229824a55SAntonio Quartulli .hardif_init = batadv_v_hardif_neigh_init,
79329824a55SAntonio Quartulli .cmp = batadv_v_neigh_cmp,
79429824a55SAntonio Quartulli .is_similar_or_better = batadv_v_neigh_is_sob,
795f02a478fSMatthias Schiffer .dump = batadv_v_neigh_dump,
79629824a55SAntonio Quartulli },
79729824a55SAntonio Quartulli .orig = {
798f02a478fSMatthias Schiffer .dump = batadv_v_orig_dump,
79929824a55SAntonio Quartulli },
80008686943SAntonio Quartulli .gw = {
8011a9070ecSSven Eckelmann .init_sel_class = batadv_v_init_sel_class,
802*6f96d46fSSven Eckelmann .sel_class_max = U32_MAX,
80350164d8fSAntonio Quartulli .get_best_gw_node = batadv_v_gw_get_best_gw_node,
80450164d8fSAntonio Quartulli .is_eligible = batadv_v_gw_is_eligible,
805b71bb6f9SSven Eckelmann .dump = batadv_v_gw_dump,
80608686943SAntonio Quartulli },
807d6f94d91SLinus Luessing };
808d6f94d91SLinus Luessing
809d6f94d91SLinus Luessing /**
8107e9a8c2cSSven Eckelmann * batadv_v_hardif_init() - initialize the algorithm specific fields in the
8117db682d1SMarek Lindner * hard-interface object
8127db682d1SMarek Lindner * @hard_iface: the hard-interface to initialize
8137db682d1SMarek Lindner */
batadv_v_hardif_init(struct batadv_hard_iface * hard_iface)8147db682d1SMarek Lindner void batadv_v_hardif_init(struct batadv_hard_iface *hard_iface)
8157db682d1SMarek Lindner {
8167db682d1SMarek Lindner /* enable link throughput auto-detection by setting the throughput
8177db682d1SMarek Lindner * override to zero
8187db682d1SMarek Lindner */
8197db682d1SMarek Lindner atomic_set(&hard_iface->bat_v.throughput_override, 0);
8207db682d1SMarek Lindner atomic_set(&hard_iface->bat_v.elp_interval, 500);
821f89255a0SLinus Lüssing
822f89255a0SLinus Lüssing hard_iface->bat_v.aggr_len = 0;
823f89255a0SLinus Lüssing skb_queue_head_init(&hard_iface->bat_v.aggr_list);
824f89255a0SLinus Lüssing INIT_DELAYED_WORK(&hard_iface->bat_v.aggr_wq,
825f89255a0SLinus Lüssing batadv_v_ogm_aggr_work);
8267db682d1SMarek Lindner }
8277db682d1SMarek Lindner
8287db682d1SMarek Lindner /**
8297e9a8c2cSSven Eckelmann * batadv_v_mesh_init() - initialize the B.A.T.M.A.N. V private resources for a
8300da00359SAntonio Quartulli * mesh
8310da00359SAntonio Quartulli * @bat_priv: the object representing the mesh interface to initialise
8320da00359SAntonio Quartulli *
8330da00359SAntonio Quartulli * Return: 0 on success or a negative error code otherwise
8340da00359SAntonio Quartulli */
batadv_v_mesh_init(struct batadv_priv * bat_priv)8350da00359SAntonio Quartulli int batadv_v_mesh_init(struct batadv_priv *bat_priv)
8360da00359SAntonio Quartulli {
83750164d8fSAntonio Quartulli int ret = 0;
83850164d8fSAntonio Quartulli
83950164d8fSAntonio Quartulli ret = batadv_v_ogm_init(bat_priv);
84050164d8fSAntonio Quartulli if (ret < 0)
84150164d8fSAntonio Quartulli return ret;
84250164d8fSAntonio Quartulli
84350164d8fSAntonio Quartulli return 0;
8440da00359SAntonio Quartulli }
8450da00359SAntonio Quartulli
8460da00359SAntonio Quartulli /**
8477e9a8c2cSSven Eckelmann * batadv_v_mesh_free() - free the B.A.T.M.A.N. V private resources for a mesh
8480da00359SAntonio Quartulli * @bat_priv: the object representing the mesh interface to free
8490da00359SAntonio Quartulli */
batadv_v_mesh_free(struct batadv_priv * bat_priv)8500da00359SAntonio Quartulli void batadv_v_mesh_free(struct batadv_priv *bat_priv)
8510da00359SAntonio Quartulli {
8520da00359SAntonio Quartulli batadv_v_ogm_free(bat_priv);
8530da00359SAntonio Quartulli }
8540da00359SAntonio Quartulli
8550da00359SAntonio Quartulli /**
8567e9a8c2cSSven Eckelmann * batadv_v_init() - B.A.T.M.A.N. V initialization function
857d6f94d91SLinus Luessing *
858d6f94d91SLinus Luessing * Description: Takes care of initializing all the subcomponents.
859d6f94d91SLinus Luessing * It is invoked upon module load only.
860d6f94d91SLinus Luessing *
861d6f94d91SLinus Luessing * Return: 0 on success or a negative error code otherwise
862d6f94d91SLinus Luessing */
batadv_v_init(void)863d6f94d91SLinus Luessing int __init batadv_v_init(void)
864d6f94d91SLinus Luessing {
865162bd64cSLinus Luessing int ret;
866162bd64cSLinus Luessing
867162bd64cSLinus Luessing /* B.A.T.M.A.N. V echo location protocol packet */
868162bd64cSLinus Luessing ret = batadv_recv_handler_register(BATADV_ELP,
869162bd64cSLinus Luessing batadv_v_elp_packet_recv);
870162bd64cSLinus Luessing if (ret < 0)
871162bd64cSLinus Luessing return ret;
872162bd64cSLinus Luessing
8730da00359SAntonio Quartulli ret = batadv_recv_handler_register(BATADV_OGM2,
8740da00359SAntonio Quartulli batadv_v_ogm_packet_recv);
875162bd64cSLinus Luessing if (ret < 0)
8760da00359SAntonio Quartulli goto elp_unregister;
8770da00359SAntonio Quartulli
8780da00359SAntonio Quartulli ret = batadv_algo_register(&batadv_batman_v);
8790da00359SAntonio Quartulli if (ret < 0)
8800da00359SAntonio Quartulli goto ogm_unregister;
8810da00359SAntonio Quartulli
8820da00359SAntonio Quartulli return ret;
8830da00359SAntonio Quartulli
8840da00359SAntonio Quartulli ogm_unregister:
8850da00359SAntonio Quartulli batadv_recv_handler_unregister(BATADV_OGM2);
8860da00359SAntonio Quartulli
8870da00359SAntonio Quartulli elp_unregister:
888162bd64cSLinus Luessing batadv_recv_handler_unregister(BATADV_ELP);
889162bd64cSLinus Luessing
890162bd64cSLinus Luessing return ret;
891d6f94d91SLinus Luessing }
892