17db7d9f3SSven Eckelmann // SPDX-License-Identifier: GPL-2.0 268e039f9SSven Eckelmann /* Copyright (C) 2013-2020 B.A.T.M.A.N. contributors: 30da00359SAntonio Quartulli * 40da00359SAntonio Quartulli * Antonio Quartulli 50da00359SAntonio Quartulli */ 60da00359SAntonio Quartulli 70da00359SAntonio Quartulli #include "bat_v_ogm.h" 80da00359SAntonio Quartulli #include "main.h" 90da00359SAntonio Quartulli 100da00359SAntonio Quartulli #include <linux/atomic.h> 110da00359SAntonio Quartulli #include <linux/byteorder/generic.h> 120da00359SAntonio Quartulli #include <linux/errno.h> 130da00359SAntonio Quartulli #include <linux/etherdevice.h> 14b92b94acSSven Eckelmann #include <linux/gfp.h> 150da00359SAntonio Quartulli #include <linux/if_ether.h> 160da00359SAntonio Quartulli #include <linux/jiffies.h> 170da00359SAntonio Quartulli #include <linux/kernel.h> 1827353446SSven Eckelmann #include <linux/kref.h> 199323158eSAntonio Quartulli #include <linux/list.h> 20f89255a0SLinus Lüssing #include <linux/lockdep.h> 21a8d23cbbSSven Eckelmann #include <linux/mutex.h> 220da00359SAntonio Quartulli #include <linux/netdevice.h> 230da00359SAntonio Quartulli #include <linux/random.h> 240da00359SAntonio Quartulli #include <linux/rculist.h> 250da00359SAntonio Quartulli #include <linux/rcupdate.h> 260da00359SAntonio Quartulli #include <linux/skbuff.h> 270da00359SAntonio Quartulli #include <linux/slab.h> 28f89255a0SLinus Lüssing #include <linux/spinlock.h> 290da00359SAntonio Quartulli #include <linux/stddef.h> 300da00359SAntonio Quartulli #include <linux/string.h> 310da00359SAntonio Quartulli #include <linux/types.h> 320da00359SAntonio Quartulli #include <linux/workqueue.h> 33fec149f5SSven Eckelmann #include <uapi/linux/batadv_packet.h> 340da00359SAntonio Quartulli 3501d350d1SSven Eckelmann #include "bat_algo.h" 360da00359SAntonio Quartulli #include "hard-interface.h" 379323158eSAntonio Quartulli #include "hash.h" 38ba412080SSven Eckelmann #include "log.h" 399323158eSAntonio Quartulli #include "originator.h" 400da00359SAntonio Quartulli #include "routing.h" 410da00359SAntonio Quartulli #include "send.h" 420da00359SAntonio Quartulli #include "translation-table.h" 431f8dce49SMarkus Pargmann #include "tvlv.h" 440da00359SAntonio Quartulli 450da00359SAntonio Quartulli /** 467e9a8c2cSSven Eckelmann * batadv_v_ogm_orig_get() - retrieve and possibly create an originator node 479323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 489323158eSAntonio Quartulli * @addr: the address of the originator 499323158eSAntonio Quartulli * 509323158eSAntonio Quartulli * Return: the orig_node corresponding to the specified address. If such object 519323158eSAntonio Quartulli * does not exist it is allocated here. In case of allocation failure returns 529323158eSAntonio Quartulli * NULL. 539323158eSAntonio Quartulli */ 549323158eSAntonio Quartulli struct batadv_orig_node *batadv_v_ogm_orig_get(struct batadv_priv *bat_priv, 559323158eSAntonio Quartulli const u8 *addr) 569323158eSAntonio Quartulli { 579323158eSAntonio Quartulli struct batadv_orig_node *orig_node; 589323158eSAntonio Quartulli int hash_added; 599323158eSAntonio Quartulli 609323158eSAntonio Quartulli orig_node = batadv_orig_hash_find(bat_priv, addr); 619323158eSAntonio Quartulli if (orig_node) 629323158eSAntonio Quartulli return orig_node; 639323158eSAntonio Quartulli 649323158eSAntonio Quartulli orig_node = batadv_orig_node_new(bat_priv, addr); 659323158eSAntonio Quartulli if (!orig_node) 669323158eSAntonio Quartulli return NULL; 679323158eSAntonio Quartulli 6855db2d59SSven Eckelmann kref_get(&orig_node->refcount); 699323158eSAntonio Quartulli hash_added = batadv_hash_add(bat_priv->orig_hash, batadv_compare_orig, 709323158eSAntonio Quartulli batadv_choose_orig, orig_node, 719323158eSAntonio Quartulli &orig_node->hash_entry); 729323158eSAntonio Quartulli if (hash_added != 0) { 7355db2d59SSven Eckelmann /* remove refcnt for newly created orig_node and hash entry */ 749323158eSAntonio Quartulli batadv_orig_node_put(orig_node); 759323158eSAntonio Quartulli batadv_orig_node_put(orig_node); 769323158eSAntonio Quartulli orig_node = NULL; 779323158eSAntonio Quartulli } 789323158eSAntonio Quartulli 799323158eSAntonio Quartulli return orig_node; 809323158eSAntonio Quartulli } 819323158eSAntonio Quartulli 829323158eSAntonio Quartulli /** 83f89255a0SLinus Lüssing * batadv_v_ogm_start_queue_timer() - restart the OGM aggregation timer 84f89255a0SLinus Lüssing * @hard_iface: the interface to use to send the OGM 85f89255a0SLinus Lüssing */ 86f89255a0SLinus Lüssing static void batadv_v_ogm_start_queue_timer(struct batadv_hard_iface *hard_iface) 87f89255a0SLinus Lüssing { 88f89255a0SLinus Lüssing unsigned int msecs = BATADV_MAX_AGGREGATION_MS * 1000; 89f89255a0SLinus Lüssing 90f89255a0SLinus Lüssing /* msecs * [0.9, 1.1] */ 91f89255a0SLinus Lüssing msecs += prandom_u32() % (msecs / 5) - (msecs / 10); 92f89255a0SLinus Lüssing queue_delayed_work(batadv_event_workqueue, &hard_iface->bat_v.aggr_wq, 93f89255a0SLinus Lüssing msecs_to_jiffies(msecs / 1000)); 94f89255a0SLinus Lüssing } 95f89255a0SLinus Lüssing 96f89255a0SLinus Lüssing /** 977e9a8c2cSSven Eckelmann * batadv_v_ogm_start_timer() - restart the OGM sending timer 980da00359SAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 990da00359SAntonio Quartulli */ 1000da00359SAntonio Quartulli static void batadv_v_ogm_start_timer(struct batadv_priv *bat_priv) 1010da00359SAntonio Quartulli { 1020da00359SAntonio Quartulli unsigned long msecs; 1030da00359SAntonio Quartulli /* this function may be invoked in different contexts (ogm rescheduling 1040da00359SAntonio Quartulli * or hard_iface activation), but the work timer should not be reset 1050da00359SAntonio Quartulli */ 1060da00359SAntonio Quartulli if (delayed_work_pending(&bat_priv->bat_v.ogm_wq)) 1070da00359SAntonio Quartulli return; 1080da00359SAntonio Quartulli 1090da00359SAntonio Quartulli msecs = atomic_read(&bat_priv->orig_interval) - BATADV_JITTER; 1100da00359SAntonio Quartulli msecs += prandom_u32() % (2 * BATADV_JITTER); 1110da00359SAntonio Quartulli queue_delayed_work(batadv_event_workqueue, &bat_priv->bat_v.ogm_wq, 1120da00359SAntonio Quartulli msecs_to_jiffies(msecs)); 1130da00359SAntonio Quartulli } 1140da00359SAntonio Quartulli 1150da00359SAntonio Quartulli /** 1167e9a8c2cSSven Eckelmann * batadv_v_ogm_send_to_if() - send a batman ogm using a given interface 1170da00359SAntonio Quartulli * @skb: the OGM to send 1180da00359SAntonio Quartulli * @hard_iface: the interface to use to send the OGM 1190da00359SAntonio Quartulli */ 1200da00359SAntonio Quartulli static void batadv_v_ogm_send_to_if(struct sk_buff *skb, 1210da00359SAntonio Quartulli struct batadv_hard_iface *hard_iface) 1220da00359SAntonio Quartulli { 1230da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); 1240da00359SAntonio Quartulli 1250da00359SAntonio Quartulli if (hard_iface->if_status != BATADV_IF_ACTIVE) 1260da00359SAntonio Quartulli return; 1270da00359SAntonio Quartulli 1280da00359SAntonio Quartulli batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_TX); 1290da00359SAntonio Quartulli batadv_add_counter(bat_priv, BATADV_CNT_MGMT_TX_BYTES, 1300da00359SAntonio Quartulli skb->len + ETH_HLEN); 1310da00359SAntonio Quartulli 13295d39278SAntonio Quartulli batadv_send_broadcast_skb(skb, hard_iface); 1330da00359SAntonio Quartulli } 1340da00359SAntonio Quartulli 1350da00359SAntonio Quartulli /** 136f89255a0SLinus Lüssing * batadv_v_ogm_len() - OGMv2 packet length 137f89255a0SLinus Lüssing * @skb: the OGM to check 138f89255a0SLinus Lüssing * 139f89255a0SLinus Lüssing * Return: Length of the given OGMv2 packet, including tvlv length, excluding 140f89255a0SLinus Lüssing * ethernet header length. 141f89255a0SLinus Lüssing */ 142f89255a0SLinus Lüssing static unsigned int batadv_v_ogm_len(struct sk_buff *skb) 143f89255a0SLinus Lüssing { 144f89255a0SLinus Lüssing struct batadv_ogm2_packet *ogm_packet; 145f89255a0SLinus Lüssing 146f89255a0SLinus Lüssing ogm_packet = (struct batadv_ogm2_packet *)skb->data; 147f89255a0SLinus Lüssing return BATADV_OGM2_HLEN + ntohs(ogm_packet->tvlv_len); 148f89255a0SLinus Lüssing } 149f89255a0SLinus Lüssing 150f89255a0SLinus Lüssing /** 151f89255a0SLinus Lüssing * batadv_v_ogm_queue_left() - check if given OGM still fits aggregation queue 152f89255a0SLinus Lüssing * @skb: the OGM to check 153f89255a0SLinus Lüssing * @hard_iface: the interface to use to send the OGM 154f89255a0SLinus Lüssing * 155baa1e8a0SChristophe JAILLET * Caller needs to hold the hard_iface->bat_v.aggr_list.lock. 156f89255a0SLinus Lüssing * 157f89255a0SLinus Lüssing * Return: True, if the given OGMv2 packet still fits, false otherwise. 158f89255a0SLinus Lüssing */ 159f89255a0SLinus Lüssing static bool batadv_v_ogm_queue_left(struct sk_buff *skb, 160f89255a0SLinus Lüssing struct batadv_hard_iface *hard_iface) 161f89255a0SLinus Lüssing { 162f89255a0SLinus Lüssing unsigned int max = min_t(unsigned int, hard_iface->net_dev->mtu, 163f89255a0SLinus Lüssing BATADV_MAX_AGGREGATION_BYTES); 164f89255a0SLinus Lüssing unsigned int ogm_len = batadv_v_ogm_len(skb); 165f89255a0SLinus Lüssing 166baa1e8a0SChristophe JAILLET lockdep_assert_held(&hard_iface->bat_v.aggr_list.lock); 167f89255a0SLinus Lüssing 168f89255a0SLinus Lüssing return hard_iface->bat_v.aggr_len + ogm_len <= max; 169f89255a0SLinus Lüssing } 170f89255a0SLinus Lüssing 171f89255a0SLinus Lüssing /** 172f89255a0SLinus Lüssing * batadv_v_ogm_aggr_list_free - free all elements in an aggregation queue 173f89255a0SLinus Lüssing * @hard_iface: the interface holding the aggregation queue 174f89255a0SLinus Lüssing * 175f89255a0SLinus Lüssing * Empties the OGMv2 aggregation queue and frees all the skbs it contained. 176f89255a0SLinus Lüssing * 177baa1e8a0SChristophe JAILLET * Caller needs to hold the hard_iface->bat_v.aggr_list.lock. 178f89255a0SLinus Lüssing */ 179f89255a0SLinus Lüssing static void batadv_v_ogm_aggr_list_free(struct batadv_hard_iface *hard_iface) 180f89255a0SLinus Lüssing { 181baa1e8a0SChristophe JAILLET lockdep_assert_held(&hard_iface->bat_v.aggr_list.lock); 182f89255a0SLinus Lüssing 183baa1e8a0SChristophe JAILLET __skb_queue_purge(&hard_iface->bat_v.aggr_list); 184f89255a0SLinus Lüssing hard_iface->bat_v.aggr_len = 0; 185f89255a0SLinus Lüssing } 186f89255a0SLinus Lüssing 187f89255a0SLinus Lüssing /** 188f89255a0SLinus Lüssing * batadv_v_ogm_aggr_send() - flush & send aggregation queue 189f89255a0SLinus Lüssing * @hard_iface: the interface with the aggregation queue to flush 190f89255a0SLinus Lüssing * 1919cb9a178SLinus Lüssing * Aggregates all OGMv2 packets currently in the aggregation queue into a 1929cb9a178SLinus Lüssing * single OGMv2 packet and transmits this aggregate. 1939cb9a178SLinus Lüssing * 1949cb9a178SLinus Lüssing * The aggregation queue is empty after this call. 1959cb9a178SLinus Lüssing * 196baa1e8a0SChristophe JAILLET * Caller needs to hold the hard_iface->bat_v.aggr_list.lock. 197f89255a0SLinus Lüssing */ 198f89255a0SLinus Lüssing static void batadv_v_ogm_aggr_send(struct batadv_hard_iface *hard_iface) 199f89255a0SLinus Lüssing { 2009cb9a178SLinus Lüssing unsigned int aggr_len = hard_iface->bat_v.aggr_len; 2019cb9a178SLinus Lüssing struct sk_buff *skb_aggr; 2029cb9a178SLinus Lüssing unsigned int ogm_len; 203f89255a0SLinus Lüssing struct sk_buff *skb; 204f89255a0SLinus Lüssing 205baa1e8a0SChristophe JAILLET lockdep_assert_held(&hard_iface->bat_v.aggr_list.lock); 206f89255a0SLinus Lüssing 2079cb9a178SLinus Lüssing if (!aggr_len) 2089cb9a178SLinus Lüssing return; 2099cb9a178SLinus Lüssing 2109cb9a178SLinus Lüssing skb_aggr = dev_alloc_skb(aggr_len + ETH_HLEN + NET_IP_ALIGN); 2119cb9a178SLinus Lüssing if (!skb_aggr) { 2129cb9a178SLinus Lüssing batadv_v_ogm_aggr_list_free(hard_iface); 2139cb9a178SLinus Lüssing return; 2149cb9a178SLinus Lüssing } 2159cb9a178SLinus Lüssing 2169cb9a178SLinus Lüssing skb_reserve(skb_aggr, ETH_HLEN + NET_IP_ALIGN); 2179cb9a178SLinus Lüssing skb_reset_network_header(skb_aggr); 2189cb9a178SLinus Lüssing 219baa1e8a0SChristophe JAILLET while ((skb = __skb_dequeue(&hard_iface->bat_v.aggr_list))) { 220f89255a0SLinus Lüssing hard_iface->bat_v.aggr_len -= batadv_v_ogm_len(skb); 2219cb9a178SLinus Lüssing 2229cb9a178SLinus Lüssing ogm_len = batadv_v_ogm_len(skb); 2239cb9a178SLinus Lüssing skb_put_data(skb_aggr, skb->data, ogm_len); 2249cb9a178SLinus Lüssing 2259cb9a178SLinus Lüssing consume_skb(skb); 226f89255a0SLinus Lüssing } 2279cb9a178SLinus Lüssing 2289cb9a178SLinus Lüssing batadv_v_ogm_send_to_if(skb_aggr, hard_iface); 229f89255a0SLinus Lüssing } 230f89255a0SLinus Lüssing 231f89255a0SLinus Lüssing /** 232f89255a0SLinus Lüssing * batadv_v_ogm_queue_on_if() - queue a batman ogm on a given interface 233f89255a0SLinus Lüssing * @skb: the OGM to queue 234f89255a0SLinus Lüssing * @hard_iface: the interface to queue the OGM on 235f89255a0SLinus Lüssing */ 236f89255a0SLinus Lüssing static void batadv_v_ogm_queue_on_if(struct sk_buff *skb, 237f89255a0SLinus Lüssing struct batadv_hard_iface *hard_iface) 238f89255a0SLinus Lüssing { 239f89255a0SLinus Lüssing struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); 240f89255a0SLinus Lüssing 241f89255a0SLinus Lüssing if (!atomic_read(&bat_priv->aggregated_ogms)) { 242f89255a0SLinus Lüssing batadv_v_ogm_send_to_if(skb, hard_iface); 243f89255a0SLinus Lüssing return; 244f89255a0SLinus Lüssing } 245f89255a0SLinus Lüssing 246baa1e8a0SChristophe JAILLET spin_lock_bh(&hard_iface->bat_v.aggr_list.lock); 247f89255a0SLinus Lüssing if (!batadv_v_ogm_queue_left(skb, hard_iface)) 248f89255a0SLinus Lüssing batadv_v_ogm_aggr_send(hard_iface); 249f89255a0SLinus Lüssing 250f89255a0SLinus Lüssing hard_iface->bat_v.aggr_len += batadv_v_ogm_len(skb); 251baa1e8a0SChristophe JAILLET __skb_queue_tail(&hard_iface->bat_v.aggr_list, skb); 252baa1e8a0SChristophe JAILLET spin_unlock_bh(&hard_iface->bat_v.aggr_list.lock); 253f89255a0SLinus Lüssing } 254f89255a0SLinus Lüssing 255f89255a0SLinus Lüssing /** 256a8d23cbbSSven Eckelmann * batadv_v_ogm_send_softif() - periodic worker broadcasting the own OGM 257a8d23cbbSSven Eckelmann * @bat_priv: the bat priv with all the soft interface information 2580da00359SAntonio Quartulli */ 259a8d23cbbSSven Eckelmann static void batadv_v_ogm_send_softif(struct batadv_priv *bat_priv) 2600da00359SAntonio Quartulli { 2610da00359SAntonio Quartulli struct batadv_hard_iface *hard_iface; 2620da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 2630da00359SAntonio Quartulli struct sk_buff *skb, *skb_tmp; 264e04de486SSven Eckelmann unsigned char *ogm_buff; 2650da00359SAntonio Quartulli int ogm_buff_len; 2660da00359SAntonio Quartulli u16 tvlv_len = 0; 2673111beedSLinus Lüssing int ret; 2680da00359SAntonio Quartulli 269a8d23cbbSSven Eckelmann lockdep_assert_held(&bat_priv->bat_v.ogm_buff_mutex); 2700da00359SAntonio Quartulli 2710da00359SAntonio Quartulli if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_DEACTIVATING) 2720da00359SAntonio Quartulli goto out; 2730da00359SAntonio Quartulli 2740da00359SAntonio Quartulli ogm_buff = bat_priv->bat_v.ogm_buff; 2750da00359SAntonio Quartulli ogm_buff_len = bat_priv->bat_v.ogm_buff_len; 2760da00359SAntonio Quartulli /* tt changes have to be committed before the tvlv data is 2770da00359SAntonio Quartulli * appended as it may alter the tt tvlv container 2780da00359SAntonio Quartulli */ 2790da00359SAntonio Quartulli batadv_tt_local_commit_changes(bat_priv); 2800da00359SAntonio Quartulli tvlv_len = batadv_tvlv_container_ogm_append(bat_priv, &ogm_buff, 2810da00359SAntonio Quartulli &ogm_buff_len, 2820da00359SAntonio Quartulli BATADV_OGM2_HLEN); 2830da00359SAntonio Quartulli 2840da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff = ogm_buff; 2850da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff_len = ogm_buff_len; 2860da00359SAntonio Quartulli 2870da00359SAntonio Quartulli skb = netdev_alloc_skb_ip_align(NULL, ETH_HLEN + ogm_buff_len); 2880da00359SAntonio Quartulli if (!skb) 2890da00359SAntonio Quartulli goto reschedule; 2900da00359SAntonio Quartulli 2910da00359SAntonio Quartulli skb_reserve(skb, ETH_HLEN); 292e04de486SSven Eckelmann skb_put_data(skb, ogm_buff, ogm_buff_len); 2930da00359SAntonio Quartulli 2940da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)skb->data; 2950da00359SAntonio Quartulli ogm_packet->seqno = htonl(atomic_read(&bat_priv->bat_v.ogm_seqno)); 2960da00359SAntonio Quartulli atomic_inc(&bat_priv->bat_v.ogm_seqno); 2970da00359SAntonio Quartulli ogm_packet->tvlv_len = htons(tvlv_len); 2980da00359SAntonio Quartulli 2990da00359SAntonio Quartulli /* broadcast on every interface */ 3000da00359SAntonio Quartulli rcu_read_lock(); 3010da00359SAntonio Quartulli list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) { 3020da00359SAntonio Quartulli if (hard_iface->soft_iface != bat_priv->soft_iface) 3030da00359SAntonio Quartulli continue; 3040da00359SAntonio Quartulli 30527353446SSven Eckelmann if (!kref_get_unless_zero(&hard_iface->refcount)) 30627353446SSven Eckelmann continue; 30727353446SSven Eckelmann 3083111beedSLinus Lüssing ret = batadv_hardif_no_broadcast(hard_iface, NULL, NULL); 3093111beedSLinus Lüssing if (ret) { 3103111beedSLinus Lüssing char *type; 3113111beedSLinus Lüssing 3123111beedSLinus Lüssing switch (ret) { 3133111beedSLinus Lüssing case BATADV_HARDIF_BCAST_NORECIPIENT: 3143111beedSLinus Lüssing type = "no neighbor"; 3153111beedSLinus Lüssing break; 3163111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPFWD: 3173111beedSLinus Lüssing type = "single neighbor is source"; 3183111beedSLinus Lüssing break; 3193111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPORIG: 3203111beedSLinus Lüssing type = "single neighbor is originator"; 3213111beedSLinus Lüssing break; 3223111beedSLinus Lüssing default: 3233111beedSLinus Lüssing type = "unknown"; 3243111beedSLinus Lüssing } 3253111beedSLinus Lüssing 326f25cbb2aSColin Ian King batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 from ourselves on %s suppressed: %s\n", 3273111beedSLinus Lüssing hard_iface->net_dev->name, type); 3283111beedSLinus Lüssing 3293111beedSLinus Lüssing batadv_hardif_put(hard_iface); 3303111beedSLinus Lüssing continue; 3313111beedSLinus Lüssing } 3323111beedSLinus Lüssing 3330da00359SAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 3340da00359SAntonio Quartulli "Sending own OGM2 packet (originator %pM, seqno %u, throughput %u, TTL %d) on interface %s [%pM]\n", 3350da00359SAntonio Quartulli ogm_packet->orig, ntohl(ogm_packet->seqno), 3360da00359SAntonio Quartulli ntohl(ogm_packet->throughput), ogm_packet->ttl, 3370da00359SAntonio Quartulli hard_iface->net_dev->name, 3380da00359SAntonio Quartulli hard_iface->net_dev->dev_addr); 3390da00359SAntonio Quartulli 3400da00359SAntonio Quartulli /* this skb gets consumed by batadv_v_ogm_send_to_if() */ 3410da00359SAntonio Quartulli skb_tmp = skb_clone(skb, GFP_ATOMIC); 34227353446SSven Eckelmann if (!skb_tmp) { 34327353446SSven Eckelmann batadv_hardif_put(hard_iface); 3440da00359SAntonio Quartulli break; 34527353446SSven Eckelmann } 3460da00359SAntonio Quartulli 347f89255a0SLinus Lüssing batadv_v_ogm_queue_on_if(skb_tmp, hard_iface); 34827353446SSven Eckelmann batadv_hardif_put(hard_iface); 3490da00359SAntonio Quartulli } 3500da00359SAntonio Quartulli rcu_read_unlock(); 3510da00359SAntonio Quartulli 3520da00359SAntonio Quartulli consume_skb(skb); 3530da00359SAntonio Quartulli 3540da00359SAntonio Quartulli reschedule: 3550da00359SAntonio Quartulli batadv_v_ogm_start_timer(bat_priv); 3560da00359SAntonio Quartulli out: 3570da00359SAntonio Quartulli return; 3580da00359SAntonio Quartulli } 3590da00359SAntonio Quartulli 3600da00359SAntonio Quartulli /** 361a8d23cbbSSven Eckelmann * batadv_v_ogm_send() - periodic worker broadcasting the own OGM 362a8d23cbbSSven Eckelmann * @work: work queue item 363a8d23cbbSSven Eckelmann */ 364a8d23cbbSSven Eckelmann static void batadv_v_ogm_send(struct work_struct *work) 365a8d23cbbSSven Eckelmann { 366a8d23cbbSSven Eckelmann struct batadv_priv_bat_v *bat_v; 367a8d23cbbSSven Eckelmann struct batadv_priv *bat_priv; 368a8d23cbbSSven Eckelmann 369a8d23cbbSSven Eckelmann bat_v = container_of(work, struct batadv_priv_bat_v, ogm_wq.work); 370a8d23cbbSSven Eckelmann bat_priv = container_of(bat_v, struct batadv_priv, bat_v); 371a8d23cbbSSven Eckelmann 372a8d23cbbSSven Eckelmann mutex_lock(&bat_priv->bat_v.ogm_buff_mutex); 373a8d23cbbSSven Eckelmann batadv_v_ogm_send_softif(bat_priv); 374a8d23cbbSSven Eckelmann mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex); 375a8d23cbbSSven Eckelmann } 376a8d23cbbSSven Eckelmann 377a8d23cbbSSven Eckelmann /** 378f89255a0SLinus Lüssing * batadv_v_ogm_aggr_work() - OGM queue periodic task per interface 379f89255a0SLinus Lüssing * @work: work queue item 380f89255a0SLinus Lüssing * 381f89255a0SLinus Lüssing * Emits aggregated OGM message in regular intervals. 382f89255a0SLinus Lüssing */ 383f89255a0SLinus Lüssing void batadv_v_ogm_aggr_work(struct work_struct *work) 384f89255a0SLinus Lüssing { 385f89255a0SLinus Lüssing struct batadv_hard_iface_bat_v *batv; 386f89255a0SLinus Lüssing struct batadv_hard_iface *hard_iface; 387f89255a0SLinus Lüssing 388f89255a0SLinus Lüssing batv = container_of(work, struct batadv_hard_iface_bat_v, aggr_wq.work); 389f89255a0SLinus Lüssing hard_iface = container_of(batv, struct batadv_hard_iface, bat_v); 390f89255a0SLinus Lüssing 391baa1e8a0SChristophe JAILLET spin_lock_bh(&hard_iface->bat_v.aggr_list.lock); 392f89255a0SLinus Lüssing batadv_v_ogm_aggr_send(hard_iface); 393baa1e8a0SChristophe JAILLET spin_unlock_bh(&hard_iface->bat_v.aggr_list.lock); 394f89255a0SLinus Lüssing 395f89255a0SLinus Lüssing batadv_v_ogm_start_queue_timer(hard_iface); 396f89255a0SLinus Lüssing } 397f89255a0SLinus Lüssing 398f89255a0SLinus Lüssing /** 3997e9a8c2cSSven Eckelmann * batadv_v_ogm_iface_enable() - prepare an interface for B.A.T.M.A.N. V 4000da00359SAntonio Quartulli * @hard_iface: the interface to prepare 4010da00359SAntonio Quartulli * 4020da00359SAntonio Quartulli * Takes care of scheduling own OGM sending routine for this interface. 4030da00359SAntonio Quartulli * 4040da00359SAntonio Quartulli * Return: 0 on success or a negative error code otherwise 4050da00359SAntonio Quartulli */ 4060da00359SAntonio Quartulli int batadv_v_ogm_iface_enable(struct batadv_hard_iface *hard_iface) 4070da00359SAntonio Quartulli { 4080da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); 4090da00359SAntonio Quartulli 410f89255a0SLinus Lüssing batadv_v_ogm_start_queue_timer(hard_iface); 4110da00359SAntonio Quartulli batadv_v_ogm_start_timer(bat_priv); 4120da00359SAntonio Quartulli 4130da00359SAntonio Quartulli return 0; 4140da00359SAntonio Quartulli } 4150da00359SAntonio Quartulli 4160da00359SAntonio Quartulli /** 417f89255a0SLinus Lüssing * batadv_v_ogm_iface_disable() - release OGM interface private resources 418f89255a0SLinus Lüssing * @hard_iface: interface for which the resources have to be released 419f89255a0SLinus Lüssing */ 420f89255a0SLinus Lüssing void batadv_v_ogm_iface_disable(struct batadv_hard_iface *hard_iface) 421f89255a0SLinus Lüssing { 422f89255a0SLinus Lüssing cancel_delayed_work_sync(&hard_iface->bat_v.aggr_wq); 423f89255a0SLinus Lüssing 424baa1e8a0SChristophe JAILLET spin_lock_bh(&hard_iface->bat_v.aggr_list.lock); 425f89255a0SLinus Lüssing batadv_v_ogm_aggr_list_free(hard_iface); 426baa1e8a0SChristophe JAILLET spin_unlock_bh(&hard_iface->bat_v.aggr_list.lock); 427f89255a0SLinus Lüssing } 428f89255a0SLinus Lüssing 429f89255a0SLinus Lüssing /** 4307e9a8c2cSSven Eckelmann * batadv_v_ogm_primary_iface_set() - set a new primary interface 4310da00359SAntonio Quartulli * @primary_iface: the new primary interface 4320da00359SAntonio Quartulli */ 4330da00359SAntonio Quartulli void batadv_v_ogm_primary_iface_set(struct batadv_hard_iface *primary_iface) 4340da00359SAntonio Quartulli { 4350da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(primary_iface->soft_iface); 4360da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 4370da00359SAntonio Quartulli 438a8d23cbbSSven Eckelmann mutex_lock(&bat_priv->bat_v.ogm_buff_mutex); 4390da00359SAntonio Quartulli if (!bat_priv->bat_v.ogm_buff) 440a8d23cbbSSven Eckelmann goto unlock; 4410da00359SAntonio Quartulli 4420da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)bat_priv->bat_v.ogm_buff; 4430da00359SAntonio Quartulli ether_addr_copy(ogm_packet->orig, primary_iface->net_dev->dev_addr); 444a8d23cbbSSven Eckelmann 445a8d23cbbSSven Eckelmann unlock: 446a8d23cbbSSven Eckelmann mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex); 4470da00359SAntonio Quartulli } 4480da00359SAntonio Quartulli 4490da00359SAntonio Quartulli /** 4507e9a8c2cSSven Eckelmann * batadv_v_forward_penalty() - apply a penalty to the throughput metric 4517e9a8c2cSSven Eckelmann * forwarded with B.A.T.M.A.N. V OGMs 4529323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 4539323158eSAntonio Quartulli * @if_incoming: the interface where the OGM has been received 4549323158eSAntonio Quartulli * @if_outgoing: the interface where the OGM has to be forwarded to 4559323158eSAntonio Quartulli * @throughput: the current throughput 4569323158eSAntonio Quartulli * 4579323158eSAntonio Quartulli * Apply a penalty on the current throughput metric value based on the 4589323158eSAntonio Quartulli * characteristic of the interface where the OGM has been received. The return 4599323158eSAntonio Quartulli * value is computed as follows: 4609323158eSAntonio Quartulli * - throughput * 50% if the incoming and outgoing interface are the 4619323158eSAntonio Quartulli * same WiFi interface and the throughput is above 4629323158eSAntonio Quartulli * 1MBit/s 4639323158eSAntonio Quartulli * - throughput if the outgoing interface is the default 4649323158eSAntonio Quartulli * interface (i.e. this OGM is processed for the 4659323158eSAntonio Quartulli * internal table and not forwarded) 4669323158eSAntonio Quartulli * - throughput * hop penalty otherwise 4679323158eSAntonio Quartulli * 4689323158eSAntonio Quartulli * Return: the penalised throughput metric. 4699323158eSAntonio Quartulli */ 4709323158eSAntonio Quartulli static u32 batadv_v_forward_penalty(struct batadv_priv *bat_priv, 4719323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 4729323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing, 4739323158eSAntonio Quartulli u32 throughput) 4749323158eSAntonio Quartulli { 4759323158eSAntonio Quartulli int hop_penalty = atomic_read(&bat_priv->hop_penalty); 4769323158eSAntonio Quartulli int hop_penalty_max = BATADV_TQ_MAX_VALUE; 4779323158eSAntonio Quartulli 4789323158eSAntonio Quartulli /* Don't apply hop penalty in default originator table. */ 4799323158eSAntonio Quartulli if (if_outgoing == BATADV_IF_DEFAULT) 4809323158eSAntonio Quartulli return throughput; 4819323158eSAntonio Quartulli 4829323158eSAntonio Quartulli /* Forwarding on the same WiFi interface cuts the throughput in half 4839323158eSAntonio Quartulli * due to the store & forward characteristics of WIFI. 4849323158eSAntonio Quartulli * Very low throughput values are the exception. 4859323158eSAntonio Quartulli */ 486825ffe1fSSven Eckelmann if (throughput > 10 && 487825ffe1fSSven Eckelmann if_incoming == if_outgoing && 488c833484eSAntonio Quartulli !(if_incoming->bat_v.flags & BATADV_FULL_DUPLEX)) 4899323158eSAntonio Quartulli return throughput / 2; 4909323158eSAntonio Quartulli 4919323158eSAntonio Quartulli /* hop penalty of 255 equals 100% */ 4929323158eSAntonio Quartulli return throughput * (hop_penalty_max - hop_penalty) / hop_penalty_max; 4939323158eSAntonio Quartulli } 4949323158eSAntonio Quartulli 4959323158eSAntonio Quartulli /** 4967e9a8c2cSSven Eckelmann * batadv_v_ogm_forward() - check conditions and forward an OGM to the given 497efcc9d30SSimon Wunderlich * outgoing interface 4989323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 4999323158eSAntonio Quartulli * @ogm_received: previously received OGM to be forwarded 500efcc9d30SSimon Wunderlich * @orig_node: the originator which has been updated 501efcc9d30SSimon Wunderlich * @neigh_node: the neigh_node through with the OGM has been received 5029323158eSAntonio Quartulli * @if_incoming: the interface on which this OGM was received on 5039323158eSAntonio Quartulli * @if_outgoing: the interface to which the OGM has to be forwarded to 5049323158eSAntonio Quartulli * 5059323158eSAntonio Quartulli * Forward an OGM to an interface after having altered the throughput metric and 5069323158eSAntonio Quartulli * the TTL value contained in it. The original OGM isn't modified. 5079323158eSAntonio Quartulli */ 5089323158eSAntonio Quartulli static void batadv_v_ogm_forward(struct batadv_priv *bat_priv, 5099323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm_received, 510efcc9d30SSimon Wunderlich struct batadv_orig_node *orig_node, 511efcc9d30SSimon Wunderlich struct batadv_neigh_node *neigh_node, 5129323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 5139323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 5149323158eSAntonio Quartulli { 515efcc9d30SSimon Wunderlich struct batadv_neigh_ifinfo *neigh_ifinfo = NULL; 516efcc9d30SSimon Wunderlich struct batadv_orig_ifinfo *orig_ifinfo = NULL; 517efcc9d30SSimon Wunderlich struct batadv_neigh_node *router = NULL; 5189323158eSAntonio Quartulli struct batadv_ogm2_packet *ogm_forward; 5199323158eSAntonio Quartulli unsigned char *skb_buff; 5209323158eSAntonio Quartulli struct sk_buff *skb; 5219323158eSAntonio Quartulli size_t packet_len; 5229323158eSAntonio Quartulli u16 tvlv_len; 5239323158eSAntonio Quartulli 524efcc9d30SSimon Wunderlich /* only forward for specific interfaces, not for the default one. */ 525efcc9d30SSimon Wunderlich if (if_outgoing == BATADV_IF_DEFAULT) 526efcc9d30SSimon Wunderlich goto out; 527efcc9d30SSimon Wunderlich 528efcc9d30SSimon Wunderlich orig_ifinfo = batadv_orig_ifinfo_new(orig_node, if_outgoing); 529efcc9d30SSimon Wunderlich if (!orig_ifinfo) 530efcc9d30SSimon Wunderlich goto out; 531efcc9d30SSimon Wunderlich 532efcc9d30SSimon Wunderlich /* acquire possibly updated router */ 533efcc9d30SSimon Wunderlich router = batadv_orig_router_get(orig_node, if_outgoing); 534efcc9d30SSimon Wunderlich 535efcc9d30SSimon Wunderlich /* strict rule: forward packets coming from the best next hop only */ 536efcc9d30SSimon Wunderlich if (neigh_node != router) 537efcc9d30SSimon Wunderlich goto out; 538efcc9d30SSimon Wunderlich 539efcc9d30SSimon Wunderlich /* don't forward the same seqno twice on one interface */ 540efcc9d30SSimon Wunderlich if (orig_ifinfo->last_seqno_forwarded == ntohl(ogm_received->seqno)) 541efcc9d30SSimon Wunderlich goto out; 542efcc9d30SSimon Wunderlich 543efcc9d30SSimon Wunderlich orig_ifinfo->last_seqno_forwarded = ntohl(ogm_received->seqno); 544efcc9d30SSimon Wunderlich 5459323158eSAntonio Quartulli if (ogm_received->ttl <= 1) { 5469323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "ttl exceeded\n"); 547efcc9d30SSimon Wunderlich goto out; 5489323158eSAntonio Quartulli } 5499323158eSAntonio Quartulli 550efcc9d30SSimon Wunderlich neigh_ifinfo = batadv_neigh_ifinfo_get(neigh_node, if_outgoing); 551efcc9d30SSimon Wunderlich if (!neigh_ifinfo) 552efcc9d30SSimon Wunderlich goto out; 553efcc9d30SSimon Wunderlich 5549323158eSAntonio Quartulli tvlv_len = ntohs(ogm_received->tvlv_len); 5559323158eSAntonio Quartulli 5569323158eSAntonio Quartulli packet_len = BATADV_OGM2_HLEN + tvlv_len; 5579323158eSAntonio Quartulli skb = netdev_alloc_skb_ip_align(if_outgoing->net_dev, 5589323158eSAntonio Quartulli ETH_HLEN + packet_len); 5599323158eSAntonio Quartulli if (!skb) 560efcc9d30SSimon Wunderlich goto out; 5619323158eSAntonio Quartulli 5629323158eSAntonio Quartulli skb_reserve(skb, ETH_HLEN); 56359ae1d12SJohannes Berg skb_buff = skb_put_data(skb, ogm_received, packet_len); 5649323158eSAntonio Quartulli 5659323158eSAntonio Quartulli /* apply forward penalty */ 5669323158eSAntonio Quartulli ogm_forward = (struct batadv_ogm2_packet *)skb_buff; 567efcc9d30SSimon Wunderlich ogm_forward->throughput = htonl(neigh_ifinfo->bat_v.throughput); 5689323158eSAntonio Quartulli ogm_forward->ttl--; 5699323158eSAntonio Quartulli 5709323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 5719323158eSAntonio Quartulli "Forwarding OGM2 packet on %s: throughput %u, ttl %u, received via %s\n", 572efcc9d30SSimon Wunderlich if_outgoing->net_dev->name, ntohl(ogm_forward->throughput), 573efcc9d30SSimon Wunderlich ogm_forward->ttl, if_incoming->net_dev->name); 5749323158eSAntonio Quartulli 575f89255a0SLinus Lüssing batadv_v_ogm_queue_on_if(skb, if_outgoing); 576efcc9d30SSimon Wunderlich 577efcc9d30SSimon Wunderlich out: 578efcc9d30SSimon Wunderlich if (orig_ifinfo) 579efcc9d30SSimon Wunderlich batadv_orig_ifinfo_put(orig_ifinfo); 580efcc9d30SSimon Wunderlich if (router) 581efcc9d30SSimon Wunderlich batadv_neigh_node_put(router); 582efcc9d30SSimon Wunderlich if (neigh_ifinfo) 583efcc9d30SSimon Wunderlich batadv_neigh_ifinfo_put(neigh_ifinfo); 5849323158eSAntonio Quartulli } 5859323158eSAntonio Quartulli 5869323158eSAntonio Quartulli /** 5877e9a8c2cSSven Eckelmann * batadv_v_ogm_metric_update() - update route metric based on OGM 5889323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 5899323158eSAntonio Quartulli * @ogm2: OGM2 structure 5909323158eSAntonio Quartulli * @orig_node: Originator structure for which the OGM has been received 5919323158eSAntonio Quartulli * @neigh_node: the neigh_node through with the OGM has been received 5929323158eSAntonio Quartulli * @if_incoming: the interface where this packet was received 5939323158eSAntonio Quartulli * @if_outgoing: the interface for which the packet should be considered 5949323158eSAntonio Quartulli * 5959323158eSAntonio Quartulli * Return: 5969323158eSAntonio Quartulli * 1 if the OGM is new, 5979323158eSAntonio Quartulli * 0 if it is not new but valid, 5989323158eSAntonio Quartulli * <0 on error (e.g. old OGM) 5999323158eSAntonio Quartulli */ 6009323158eSAntonio Quartulli static int batadv_v_ogm_metric_update(struct batadv_priv *bat_priv, 6019323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm2, 6029323158eSAntonio Quartulli struct batadv_orig_node *orig_node, 6039323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node, 6049323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 6059323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 6069323158eSAntonio Quartulli { 607422d2f77SSven Eckelmann struct batadv_orig_ifinfo *orig_ifinfo; 6089323158eSAntonio Quartulli struct batadv_neigh_ifinfo *neigh_ifinfo = NULL; 6099323158eSAntonio Quartulli bool protection_started = false; 6109323158eSAntonio Quartulli int ret = -EINVAL; 6119323158eSAntonio Quartulli u32 path_throughput; 6129323158eSAntonio Quartulli s32 seq_diff; 6139323158eSAntonio Quartulli 6149323158eSAntonio Quartulli orig_ifinfo = batadv_orig_ifinfo_new(orig_node, if_outgoing); 6159323158eSAntonio Quartulli if (!orig_ifinfo) 6169323158eSAntonio Quartulli goto out; 6179323158eSAntonio Quartulli 6189323158eSAntonio Quartulli seq_diff = ntohl(ogm2->seqno) - orig_ifinfo->last_real_seqno; 6199323158eSAntonio Quartulli 6209323158eSAntonio Quartulli if (!hlist_empty(&orig_node->neigh_list) && 6219323158eSAntonio Quartulli batadv_window_protected(bat_priv, seq_diff, 6229323158eSAntonio Quartulli BATADV_OGM_MAX_AGE, 6239323158eSAntonio Quartulli &orig_ifinfo->batman_seqno_reset, 6249323158eSAntonio Quartulli &protection_started)) { 6259323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 6269323158eSAntonio Quartulli "Drop packet: packet within window protection time from %pM\n", 6279323158eSAntonio Quartulli ogm2->orig); 6289323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 6299323158eSAntonio Quartulli "Last reset: %ld, %ld\n", 6309323158eSAntonio Quartulli orig_ifinfo->batman_seqno_reset, jiffies); 6319323158eSAntonio Quartulli goto out; 6329323158eSAntonio Quartulli } 6339323158eSAntonio Quartulli 6349323158eSAntonio Quartulli /* drop packets with old seqnos, however accept the first packet after 6359323158eSAntonio Quartulli * a host has been rebooted. 6369323158eSAntonio Quartulli */ 637825ffe1fSSven Eckelmann if (seq_diff < 0 && !protection_started) 6389323158eSAntonio Quartulli goto out; 6399323158eSAntonio Quartulli 6409323158eSAntonio Quartulli neigh_node->last_seen = jiffies; 6419323158eSAntonio Quartulli 6429323158eSAntonio Quartulli orig_node->last_seen = jiffies; 6439323158eSAntonio Quartulli 6449323158eSAntonio Quartulli orig_ifinfo->last_real_seqno = ntohl(ogm2->seqno); 6459323158eSAntonio Quartulli orig_ifinfo->last_ttl = ogm2->ttl; 6469323158eSAntonio Quartulli 6479323158eSAntonio Quartulli neigh_ifinfo = batadv_neigh_ifinfo_new(neigh_node, if_outgoing); 6489323158eSAntonio Quartulli if (!neigh_ifinfo) 6499323158eSAntonio Quartulli goto out; 6509323158eSAntonio Quartulli 6519323158eSAntonio Quartulli path_throughput = batadv_v_forward_penalty(bat_priv, if_incoming, 6529323158eSAntonio Quartulli if_outgoing, 6539323158eSAntonio Quartulli ntohl(ogm2->throughput)); 6549323158eSAntonio Quartulli neigh_ifinfo->bat_v.throughput = path_throughput; 6559323158eSAntonio Quartulli neigh_ifinfo->bat_v.last_seqno = ntohl(ogm2->seqno); 6569323158eSAntonio Quartulli neigh_ifinfo->last_ttl = ogm2->ttl; 6579323158eSAntonio Quartulli 6589323158eSAntonio Quartulli if (seq_diff > 0 || protection_started) 6599323158eSAntonio Quartulli ret = 1; 6609323158eSAntonio Quartulli else 6619323158eSAntonio Quartulli ret = 0; 6629323158eSAntonio Quartulli out: 6639323158eSAntonio Quartulli if (orig_ifinfo) 6649323158eSAntonio Quartulli batadv_orig_ifinfo_put(orig_ifinfo); 6659323158eSAntonio Quartulli if (neigh_ifinfo) 6669323158eSAntonio Quartulli batadv_neigh_ifinfo_put(neigh_ifinfo); 6679323158eSAntonio Quartulli 6689323158eSAntonio Quartulli return ret; 6699323158eSAntonio Quartulli } 6709323158eSAntonio Quartulli 6719323158eSAntonio Quartulli /** 6727e9a8c2cSSven Eckelmann * batadv_v_ogm_route_update() - update routes based on OGM 6739323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 6749323158eSAntonio Quartulli * @ethhdr: the Ethernet header of the OGM2 6759323158eSAntonio Quartulli * @ogm2: OGM2 structure 6769323158eSAntonio Quartulli * @orig_node: Originator structure for which the OGM has been received 6779323158eSAntonio Quartulli * @neigh_node: the neigh_node through with the OGM has been received 6789323158eSAntonio Quartulli * @if_incoming: the interface where this packet was received 6799323158eSAntonio Quartulli * @if_outgoing: the interface for which the packet should be considered 680efcc9d30SSimon Wunderlich * 681efcc9d30SSimon Wunderlich * Return: true if the packet should be forwarded, false otherwise 6829323158eSAntonio Quartulli */ 683efcc9d30SSimon Wunderlich static bool batadv_v_ogm_route_update(struct batadv_priv *bat_priv, 6849323158eSAntonio Quartulli const struct ethhdr *ethhdr, 6859323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm2, 6869323158eSAntonio Quartulli struct batadv_orig_node *orig_node, 6879323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node, 6889323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 6899323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 6909323158eSAntonio Quartulli { 6919323158eSAntonio Quartulli struct batadv_neigh_node *router = NULL; 692422d2f77SSven Eckelmann struct batadv_orig_node *orig_neigh_node; 6939323158eSAntonio Quartulli struct batadv_neigh_node *orig_neigh_router = NULL; 69486de37c1SSimon Wunderlich struct batadv_neigh_ifinfo *router_ifinfo = NULL, *neigh_ifinfo = NULL; 69586de37c1SSimon Wunderlich u32 router_throughput, neigh_throughput; 69686de37c1SSimon Wunderlich u32 router_last_seqno; 69786de37c1SSimon Wunderlich u32 neigh_last_seqno; 69886de37c1SSimon Wunderlich s32 neigh_seq_diff; 699efcc9d30SSimon Wunderlich bool forward = false; 7009323158eSAntonio Quartulli 7019323158eSAntonio Quartulli orig_neigh_node = batadv_v_ogm_orig_get(bat_priv, ethhdr->h_source); 7029323158eSAntonio Quartulli if (!orig_neigh_node) 7039323158eSAntonio Quartulli goto out; 7049323158eSAntonio Quartulli 7059323158eSAntonio Quartulli orig_neigh_router = batadv_orig_router_get(orig_neigh_node, 7069323158eSAntonio Quartulli if_outgoing); 7079323158eSAntonio Quartulli 7089323158eSAntonio Quartulli /* drop packet if sender is not a direct neighbor and if we 7099323158eSAntonio Quartulli * don't route towards it 7109323158eSAntonio Quartulli */ 7119323158eSAntonio Quartulli router = batadv_orig_router_get(orig_node, if_outgoing); 7129323158eSAntonio Quartulli if (router && router->orig_node != orig_node && !orig_neigh_router) { 7139323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 7149323158eSAntonio Quartulli "Drop packet: OGM via unknown neighbor!\n"); 7159323158eSAntonio Quartulli goto out; 7169323158eSAntonio Quartulli } 7179323158eSAntonio Quartulli 71886de37c1SSimon Wunderlich /* Mark the OGM to be considered for forwarding, and update routes 71986de37c1SSimon Wunderlich * if needed. 72086de37c1SSimon Wunderlich */ 721efcc9d30SSimon Wunderlich forward = true; 72286de37c1SSimon Wunderlich 72386de37c1SSimon Wunderlich batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 72486de37c1SSimon Wunderlich "Searching and updating originator entry of received packet\n"); 72586de37c1SSimon Wunderlich 72686de37c1SSimon Wunderlich /* if this neighbor already is our next hop there is nothing 72786de37c1SSimon Wunderlich * to change 72886de37c1SSimon Wunderlich */ 72986de37c1SSimon Wunderlich if (router == neigh_node) 73086de37c1SSimon Wunderlich goto out; 73186de37c1SSimon Wunderlich 73286de37c1SSimon Wunderlich /* don't consider neighbours with worse throughput. 73386de37c1SSimon Wunderlich * also switch route if this seqno is BATADV_V_MAX_ORIGDIFF newer than 73486de37c1SSimon Wunderlich * the last received seqno from our best next hop. 73586de37c1SSimon Wunderlich */ 73686de37c1SSimon Wunderlich if (router) { 73786de37c1SSimon Wunderlich router_ifinfo = batadv_neigh_ifinfo_get(router, if_outgoing); 73886de37c1SSimon Wunderlich neigh_ifinfo = batadv_neigh_ifinfo_get(neigh_node, if_outgoing); 73986de37c1SSimon Wunderlich 74086de37c1SSimon Wunderlich /* if these are not allocated, something is wrong. */ 74186de37c1SSimon Wunderlich if (!router_ifinfo || !neigh_ifinfo) 74286de37c1SSimon Wunderlich goto out; 74386de37c1SSimon Wunderlich 74486de37c1SSimon Wunderlich neigh_last_seqno = neigh_ifinfo->bat_v.last_seqno; 74586de37c1SSimon Wunderlich router_last_seqno = router_ifinfo->bat_v.last_seqno; 74686de37c1SSimon Wunderlich neigh_seq_diff = neigh_last_seqno - router_last_seqno; 74786de37c1SSimon Wunderlich router_throughput = router_ifinfo->bat_v.throughput; 74886de37c1SSimon Wunderlich neigh_throughput = neigh_ifinfo->bat_v.throughput; 74986de37c1SSimon Wunderlich 750825ffe1fSSven Eckelmann if (neigh_seq_diff < BATADV_OGM_MAX_ORIGDIFF && 751825ffe1fSSven Eckelmann router_throughput >= neigh_throughput) 75286de37c1SSimon Wunderlich goto out; 75386de37c1SSimon Wunderlich } 75486de37c1SSimon Wunderlich 75586de37c1SSimon Wunderlich batadv_update_route(bat_priv, orig_node, if_outgoing, neigh_node); 7569323158eSAntonio Quartulli out: 7579323158eSAntonio Quartulli if (router) 7589323158eSAntonio Quartulli batadv_neigh_node_put(router); 7599323158eSAntonio Quartulli if (orig_neigh_router) 7609323158eSAntonio Quartulli batadv_neigh_node_put(orig_neigh_router); 7619323158eSAntonio Quartulli if (orig_neigh_node) 7629323158eSAntonio Quartulli batadv_orig_node_put(orig_neigh_node); 76386de37c1SSimon Wunderlich if (router_ifinfo) 76486de37c1SSimon Wunderlich batadv_neigh_ifinfo_put(router_ifinfo); 76586de37c1SSimon Wunderlich if (neigh_ifinfo) 76686de37c1SSimon Wunderlich batadv_neigh_ifinfo_put(neigh_ifinfo); 767efcc9d30SSimon Wunderlich 768efcc9d30SSimon Wunderlich return forward; 7699323158eSAntonio Quartulli } 7709323158eSAntonio Quartulli 7719323158eSAntonio Quartulli /** 7727e9a8c2cSSven Eckelmann * batadv_v_ogm_process_per_outif() - process a batman v OGM for an outgoing if 7739323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 7749323158eSAntonio Quartulli * @ethhdr: the Ethernet header of the OGM2 7759323158eSAntonio Quartulli * @ogm2: OGM2 structure 7769323158eSAntonio Quartulli * @orig_node: Originator structure for which the OGM has been received 7779323158eSAntonio Quartulli * @neigh_node: the neigh_node through with the OGM has been received 7789323158eSAntonio Quartulli * @if_incoming: the interface where this packet was received 7799323158eSAntonio Quartulli * @if_outgoing: the interface for which the packet should be considered 7809323158eSAntonio Quartulli */ 7819323158eSAntonio Quartulli static void 7829323158eSAntonio Quartulli batadv_v_ogm_process_per_outif(struct batadv_priv *bat_priv, 7839323158eSAntonio Quartulli const struct ethhdr *ethhdr, 7849323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm2, 7859323158eSAntonio Quartulli struct batadv_orig_node *orig_node, 7869323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node, 7879323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 7889323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 7899323158eSAntonio Quartulli { 7909323158eSAntonio Quartulli int seqno_age; 791efcc9d30SSimon Wunderlich bool forward; 7929323158eSAntonio Quartulli 7939323158eSAntonio Quartulli /* first, update the metric with according sanity checks */ 7949323158eSAntonio Quartulli seqno_age = batadv_v_ogm_metric_update(bat_priv, ogm2, orig_node, 7959323158eSAntonio Quartulli neigh_node, if_incoming, 7969323158eSAntonio Quartulli if_outgoing); 7979323158eSAntonio Quartulli 7989323158eSAntonio Quartulli /* outdated sequence numbers are to be discarded */ 7999323158eSAntonio Quartulli if (seqno_age < 0) 8009323158eSAntonio Quartulli return; 8019323158eSAntonio Quartulli 8029323158eSAntonio Quartulli /* only unknown & newer OGMs contain TVLVs we are interested in */ 803825ffe1fSSven Eckelmann if (seqno_age > 0 && if_outgoing == BATADV_IF_DEFAULT) 8049323158eSAntonio Quartulli batadv_tvlv_containers_process(bat_priv, true, orig_node, 8059323158eSAntonio Quartulli NULL, NULL, 8069323158eSAntonio Quartulli (unsigned char *)(ogm2 + 1), 8079323158eSAntonio Quartulli ntohs(ogm2->tvlv_len)); 8089323158eSAntonio Quartulli 8099323158eSAntonio Quartulli /* if the metric update went through, update routes if needed */ 810efcc9d30SSimon Wunderlich forward = batadv_v_ogm_route_update(bat_priv, ethhdr, ogm2, orig_node, 811efcc9d30SSimon Wunderlich neigh_node, if_incoming, 812efcc9d30SSimon Wunderlich if_outgoing); 813efcc9d30SSimon Wunderlich 814efcc9d30SSimon Wunderlich /* if the routes have been processed correctly, check and forward */ 815efcc9d30SSimon Wunderlich if (forward) 816efcc9d30SSimon Wunderlich batadv_v_ogm_forward(bat_priv, ogm2, orig_node, neigh_node, 817efcc9d30SSimon Wunderlich if_incoming, if_outgoing); 8189323158eSAntonio Quartulli } 8199323158eSAntonio Quartulli 8209323158eSAntonio Quartulli /** 8217e9a8c2cSSven Eckelmann * batadv_v_ogm_aggr_packet() - checks if there is another OGM aggregated 8229323158eSAntonio Quartulli * @buff_pos: current position in the skb 8239323158eSAntonio Quartulli * @packet_len: total length of the skb 8240ff0f15aSSven Eckelmann * @ogm2_packet: potential OGM2 in buffer 8259323158eSAntonio Quartulli * 8269323158eSAntonio Quartulli * Return: true if there is enough space for another OGM, false otherwise. 8279323158eSAntonio Quartulli */ 8280ff0f15aSSven Eckelmann static bool 8290ff0f15aSSven Eckelmann batadv_v_ogm_aggr_packet(int buff_pos, int packet_len, 8300ff0f15aSSven Eckelmann const struct batadv_ogm2_packet *ogm2_packet) 8319323158eSAntonio Quartulli { 8329323158eSAntonio Quartulli int next_buff_pos = 0; 8339323158eSAntonio Quartulli 8340ff0f15aSSven Eckelmann /* check if there is enough space for the header */ 8350ff0f15aSSven Eckelmann next_buff_pos += buff_pos + sizeof(*ogm2_packet); 8360ff0f15aSSven Eckelmann if (next_buff_pos > packet_len) 8370ff0f15aSSven Eckelmann return false; 8380ff0f15aSSven Eckelmann 8390ff0f15aSSven Eckelmann /* check if there is enough space for the optional TVLV */ 8400ff0f15aSSven Eckelmann next_buff_pos += ntohs(ogm2_packet->tvlv_len); 8419323158eSAntonio Quartulli 8429323158eSAntonio Quartulli return (next_buff_pos <= packet_len) && 8439323158eSAntonio Quartulli (next_buff_pos <= BATADV_MAX_AGGREGATION_BYTES); 8449323158eSAntonio Quartulli } 8459323158eSAntonio Quartulli 8469323158eSAntonio Quartulli /** 8477e9a8c2cSSven Eckelmann * batadv_v_ogm_process() - process an incoming batman v OGM 8489323158eSAntonio Quartulli * @skb: the skb containing the OGM 8499323158eSAntonio Quartulli * @ogm_offset: offset to the OGM which should be processed (for aggregates) 8509323158eSAntonio Quartulli * @if_incoming: the interface where this packet was receved 8519323158eSAntonio Quartulli */ 8529323158eSAntonio Quartulli static void batadv_v_ogm_process(const struct sk_buff *skb, int ogm_offset, 8539323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming) 8549323158eSAntonio Quartulli { 8559323158eSAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface); 8569323158eSAntonio Quartulli struct ethhdr *ethhdr; 8579323158eSAntonio Quartulli struct batadv_orig_node *orig_node = NULL; 8589323158eSAntonio Quartulli struct batadv_hardif_neigh_node *hardif_neigh = NULL; 8599323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node = NULL; 8609323158eSAntonio Quartulli struct batadv_hard_iface *hard_iface; 8619323158eSAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 8629323158eSAntonio Quartulli u32 ogm_throughput, link_throughput, path_throughput; 8633111beedSLinus Lüssing int ret; 8649323158eSAntonio Quartulli 8659323158eSAntonio Quartulli ethhdr = eth_hdr(skb); 8669323158eSAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)(skb->data + ogm_offset); 8679323158eSAntonio Quartulli 8689323158eSAntonio Quartulli ogm_throughput = ntohl(ogm_packet->throughput); 8699323158eSAntonio Quartulli 8709323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 871f25cbb2aSColin Ian King "Received OGM2 packet via NB: %pM, IF: %s [%pM] (from OG: %pM, seqno %u, throughput %u, TTL %u, V %u, tvlv_len %u)\n", 8729323158eSAntonio Quartulli ethhdr->h_source, if_incoming->net_dev->name, 8739323158eSAntonio Quartulli if_incoming->net_dev->dev_addr, ogm_packet->orig, 8749323158eSAntonio Quartulli ntohl(ogm_packet->seqno), ogm_throughput, ogm_packet->ttl, 8759323158eSAntonio Quartulli ogm_packet->version, ntohs(ogm_packet->tvlv_len)); 8769323158eSAntonio Quartulli 877f25cbb2aSColin Ian King /* If the throughput metric is 0, immediately drop the packet. No need 878f25cbb2aSColin Ian King * to create orig_node / neigh_node for an unusable route. 8799323158eSAntonio Quartulli */ 8809323158eSAntonio Quartulli if (ogm_throughput == 0) { 8819323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 882f25cbb2aSColin Ian King "Drop packet: originator packet with throughput metric of 0\n"); 8839323158eSAntonio Quartulli return; 8849323158eSAntonio Quartulli } 8859323158eSAntonio Quartulli 8869323158eSAntonio Quartulli /* require ELP packets be to received from this neighbor first */ 8879323158eSAntonio Quartulli hardif_neigh = batadv_hardif_neigh_get(if_incoming, ethhdr->h_source); 8889323158eSAntonio Quartulli if (!hardif_neigh) { 8899323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 8909323158eSAntonio Quartulli "Drop packet: OGM via unknown neighbor!\n"); 8919323158eSAntonio Quartulli goto out; 8929323158eSAntonio Quartulli } 8939323158eSAntonio Quartulli 8949323158eSAntonio Quartulli orig_node = batadv_v_ogm_orig_get(bat_priv, ogm_packet->orig); 8959323158eSAntonio Quartulli if (!orig_node) 896*6f91a3f7SXiyu Yang goto out; 8979323158eSAntonio Quartulli 8986f0a6b5eSMarek Lindner neigh_node = batadv_neigh_node_get_or_create(orig_node, if_incoming, 8999323158eSAntonio Quartulli ethhdr->h_source); 9009323158eSAntonio Quartulli if (!neigh_node) 9019323158eSAntonio Quartulli goto out; 9029323158eSAntonio Quartulli 9039323158eSAntonio Quartulli /* Update the received throughput metric to match the link 9049323158eSAntonio Quartulli * characteristic: 9059323158eSAntonio Quartulli * - If this OGM traveled one hop so far (emitted by single hop 9069323158eSAntonio Quartulli * neighbor) the path throughput metric equals the link throughput. 9079323158eSAntonio Quartulli * - For OGMs traversing more than hop the path throughput metric is 9089323158eSAntonio Quartulli * the smaller of the path throughput and the link throughput. 9099323158eSAntonio Quartulli */ 9109323158eSAntonio Quartulli link_throughput = ewma_throughput_read(&hardif_neigh->bat_v.throughput); 9119323158eSAntonio Quartulli path_throughput = min_t(u32, link_throughput, ogm_throughput); 9129323158eSAntonio Quartulli ogm_packet->throughput = htonl(path_throughput); 9139323158eSAntonio Quartulli 9149323158eSAntonio Quartulli batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet, orig_node, 9159323158eSAntonio Quartulli neigh_node, if_incoming, 9169323158eSAntonio Quartulli BATADV_IF_DEFAULT); 9179323158eSAntonio Quartulli 9189323158eSAntonio Quartulli rcu_read_lock(); 9199323158eSAntonio Quartulli list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) { 9209323158eSAntonio Quartulli if (hard_iface->if_status != BATADV_IF_ACTIVE) 9219323158eSAntonio Quartulli continue; 9229323158eSAntonio Quartulli 9239323158eSAntonio Quartulli if (hard_iface->soft_iface != bat_priv->soft_iface) 9249323158eSAntonio Quartulli continue; 9259323158eSAntonio Quartulli 92627353446SSven Eckelmann if (!kref_get_unless_zero(&hard_iface->refcount)) 92727353446SSven Eckelmann continue; 92827353446SSven Eckelmann 9293111beedSLinus Lüssing ret = batadv_hardif_no_broadcast(hard_iface, 9303111beedSLinus Lüssing ogm_packet->orig, 9313111beedSLinus Lüssing hardif_neigh->orig); 9323111beedSLinus Lüssing 9333111beedSLinus Lüssing if (ret) { 9343111beedSLinus Lüssing char *type; 9353111beedSLinus Lüssing 9363111beedSLinus Lüssing switch (ret) { 9373111beedSLinus Lüssing case BATADV_HARDIF_BCAST_NORECIPIENT: 9383111beedSLinus Lüssing type = "no neighbor"; 9393111beedSLinus Lüssing break; 9403111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPFWD: 9413111beedSLinus Lüssing type = "single neighbor is source"; 9423111beedSLinus Lüssing break; 9433111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPORIG: 9443111beedSLinus Lüssing type = "single neighbor is originator"; 9453111beedSLinus Lüssing break; 9463111beedSLinus Lüssing default: 9473111beedSLinus Lüssing type = "unknown"; 9483111beedSLinus Lüssing } 9493111beedSLinus Lüssing 950f25cbb2aSColin Ian King batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 packet from %pM on %s suppressed: %s\n", 9513111beedSLinus Lüssing ogm_packet->orig, hard_iface->net_dev->name, 9523111beedSLinus Lüssing type); 9533111beedSLinus Lüssing 9543111beedSLinus Lüssing batadv_hardif_put(hard_iface); 9553111beedSLinus Lüssing continue; 9563111beedSLinus Lüssing } 9573111beedSLinus Lüssing 9589323158eSAntonio Quartulli batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet, 9599323158eSAntonio Quartulli orig_node, neigh_node, 9609323158eSAntonio Quartulli if_incoming, hard_iface); 96127353446SSven Eckelmann 96227353446SSven Eckelmann batadv_hardif_put(hard_iface); 9639323158eSAntonio Quartulli } 9649323158eSAntonio Quartulli rcu_read_unlock(); 9659323158eSAntonio Quartulli out: 9669323158eSAntonio Quartulli if (orig_node) 9679323158eSAntonio Quartulli batadv_orig_node_put(orig_node); 9689323158eSAntonio Quartulli if (neigh_node) 9699323158eSAntonio Quartulli batadv_neigh_node_put(neigh_node); 9709323158eSAntonio Quartulli if (hardif_neigh) 9719323158eSAntonio Quartulli batadv_hardif_neigh_put(hardif_neigh); 9729323158eSAntonio Quartulli } 9739323158eSAntonio Quartulli 9749323158eSAntonio Quartulli /** 9757e9a8c2cSSven Eckelmann * batadv_v_ogm_packet_recv() - OGM2 receiving handler 9760da00359SAntonio Quartulli * @skb: the received OGM 9770da00359SAntonio Quartulli * @if_incoming: the interface where this OGM has been received 9780da00359SAntonio Quartulli * 9790da00359SAntonio Quartulli * Return: NET_RX_SUCCESS and consume the skb on success or returns NET_RX_DROP 9800da00359SAntonio Quartulli * (without freeing the skb) on failure 9810da00359SAntonio Quartulli */ 9820da00359SAntonio Quartulli int batadv_v_ogm_packet_recv(struct sk_buff *skb, 9830da00359SAntonio Quartulli struct batadv_hard_iface *if_incoming) 9840da00359SAntonio Quartulli { 9850da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface); 9860da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 9870da00359SAntonio Quartulli struct ethhdr *ethhdr = eth_hdr(skb); 9889323158eSAntonio Quartulli int ogm_offset; 9899323158eSAntonio Quartulli u8 *packet_pos; 9909323158eSAntonio Quartulli int ret = NET_RX_DROP; 9910da00359SAntonio Quartulli 9920da00359SAntonio Quartulli /* did we receive a OGM2 packet on an interface that does not have 9930da00359SAntonio Quartulli * B.A.T.M.A.N. V enabled ? 9940da00359SAntonio Quartulli */ 99529824a55SAntonio Quartulli if (strcmp(bat_priv->algo_ops->name, "BATMAN_V") != 0) 996b91a2543SSven Eckelmann goto free_skb; 9970da00359SAntonio Quartulli 9980da00359SAntonio Quartulli if (!batadv_check_management_packet(skb, if_incoming, BATADV_OGM2_HLEN)) 999b91a2543SSven Eckelmann goto free_skb; 10000da00359SAntonio Quartulli 10010da00359SAntonio Quartulli if (batadv_is_my_mac(bat_priv, ethhdr->h_source)) 1002b91a2543SSven Eckelmann goto free_skb; 10030da00359SAntonio Quartulli 10040da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)skb->data; 10050da00359SAntonio Quartulli 10060da00359SAntonio Quartulli if (batadv_is_my_mac(bat_priv, ogm_packet->orig)) 1007b91a2543SSven Eckelmann goto free_skb; 10080da00359SAntonio Quartulli 10090da00359SAntonio Quartulli batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_RX); 10100da00359SAntonio Quartulli batadv_add_counter(bat_priv, BATADV_CNT_MGMT_RX_BYTES, 10110da00359SAntonio Quartulli skb->len + ETH_HLEN); 10120da00359SAntonio Quartulli 10139323158eSAntonio Quartulli ogm_offset = 0; 10149323158eSAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)skb->data; 10159323158eSAntonio Quartulli 10169323158eSAntonio Quartulli while (batadv_v_ogm_aggr_packet(ogm_offset, skb_headlen(skb), 10170ff0f15aSSven Eckelmann ogm_packet)) { 10189323158eSAntonio Quartulli batadv_v_ogm_process(skb, ogm_offset, if_incoming); 10199323158eSAntonio Quartulli 10209323158eSAntonio Quartulli ogm_offset += BATADV_OGM2_HLEN; 10219323158eSAntonio Quartulli ogm_offset += ntohs(ogm_packet->tvlv_len); 10229323158eSAntonio Quartulli 10239323158eSAntonio Quartulli packet_pos = skb->data + ogm_offset; 10249323158eSAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)packet_pos; 10259323158eSAntonio Quartulli } 10269323158eSAntonio Quartulli 10279323158eSAntonio Quartulli ret = NET_RX_SUCCESS; 1028b91a2543SSven Eckelmann 1029b91a2543SSven Eckelmann free_skb: 1030b91a2543SSven Eckelmann if (ret == NET_RX_SUCCESS) 10310da00359SAntonio Quartulli consume_skb(skb); 1032b91a2543SSven Eckelmann else 1033b91a2543SSven Eckelmann kfree_skb(skb); 10349323158eSAntonio Quartulli 10359323158eSAntonio Quartulli return ret; 10360da00359SAntonio Quartulli } 10370da00359SAntonio Quartulli 10380da00359SAntonio Quartulli /** 10397e9a8c2cSSven Eckelmann * batadv_v_ogm_init() - initialise the OGM2 engine 10400da00359SAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 10410da00359SAntonio Quartulli * 10420da00359SAntonio Quartulli * Return: 0 on success or a negative error code in case of failure 10430da00359SAntonio Quartulli */ 10440da00359SAntonio Quartulli int batadv_v_ogm_init(struct batadv_priv *bat_priv) 10450da00359SAntonio Quartulli { 10460da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 10470da00359SAntonio Quartulli unsigned char *ogm_buff; 10480da00359SAntonio Quartulli u32 random_seqno; 10490da00359SAntonio Quartulli 10500da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff_len = BATADV_OGM2_HLEN; 10510da00359SAntonio Quartulli ogm_buff = kzalloc(bat_priv->bat_v.ogm_buff_len, GFP_ATOMIC); 10520da00359SAntonio Quartulli if (!ogm_buff) 10530da00359SAntonio Quartulli return -ENOMEM; 10540da00359SAntonio Quartulli 10550da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff = ogm_buff; 10560da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)ogm_buff; 10570da00359SAntonio Quartulli ogm_packet->packet_type = BATADV_OGM2; 10580da00359SAntonio Quartulli ogm_packet->version = BATADV_COMPAT_VERSION; 10590da00359SAntonio Quartulli ogm_packet->ttl = BATADV_TTL; 10600da00359SAntonio Quartulli ogm_packet->flags = BATADV_NO_FLAGS; 10610da00359SAntonio Quartulli ogm_packet->throughput = htonl(BATADV_THROUGHPUT_MAX_VALUE); 10620da00359SAntonio Quartulli 10630da00359SAntonio Quartulli /* randomize initial seqno to avoid collision */ 10640da00359SAntonio Quartulli get_random_bytes(&random_seqno, sizeof(random_seqno)); 10650da00359SAntonio Quartulli atomic_set(&bat_priv->bat_v.ogm_seqno, random_seqno); 10660da00359SAntonio Quartulli INIT_DELAYED_WORK(&bat_priv->bat_v.ogm_wq, batadv_v_ogm_send); 10670da00359SAntonio Quartulli 1068a8d23cbbSSven Eckelmann mutex_init(&bat_priv->bat_v.ogm_buff_mutex); 1069a8d23cbbSSven Eckelmann 10700da00359SAntonio Quartulli return 0; 10710da00359SAntonio Quartulli } 10720da00359SAntonio Quartulli 10730da00359SAntonio Quartulli /** 10747e9a8c2cSSven Eckelmann * batadv_v_ogm_free() - free OGM private resources 10750da00359SAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 10760da00359SAntonio Quartulli */ 10770da00359SAntonio Quartulli void batadv_v_ogm_free(struct batadv_priv *bat_priv) 10780da00359SAntonio Quartulli { 10790da00359SAntonio Quartulli cancel_delayed_work_sync(&bat_priv->bat_v.ogm_wq); 10800da00359SAntonio Quartulli 1081a8d23cbbSSven Eckelmann mutex_lock(&bat_priv->bat_v.ogm_buff_mutex); 1082a8d23cbbSSven Eckelmann 10830da00359SAntonio Quartulli kfree(bat_priv->bat_v.ogm_buff); 10840da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff = NULL; 10850da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff_len = 0; 1086a8d23cbbSSven Eckelmann 1087a8d23cbbSSven Eckelmann mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex); 10880da00359SAntonio Quartulli } 1089