1*7db7d9f3SSven Eckelmann // SPDX-License-Identifier: GPL-2.0 2ac79cbb9SSven Eckelmann /* Copyright (C) 2013-2017 B.A.T.M.A.N. contributors: 30da00359SAntonio Quartulli * 40da00359SAntonio Quartulli * Antonio Quartulli 50da00359SAntonio Quartulli * 60da00359SAntonio Quartulli * This program is free software; you can redistribute it and/or 70da00359SAntonio Quartulli * modify it under the terms of version 2 of the GNU General Public 80da00359SAntonio Quartulli * License as published by the Free Software Foundation. 90da00359SAntonio Quartulli * 100da00359SAntonio Quartulli * This program is distributed in the hope that it will be useful, but 110da00359SAntonio Quartulli * WITHOUT ANY WARRANTY; without even the implied warranty of 120da00359SAntonio Quartulli * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 130da00359SAntonio Quartulli * General Public License for more details. 140da00359SAntonio Quartulli * 150da00359SAntonio Quartulli * You should have received a copy of the GNU General Public License 160da00359SAntonio Quartulli * along with this program; if not, see <http://www.gnu.org/licenses/>. 170da00359SAntonio Quartulli */ 180da00359SAntonio Quartulli 190da00359SAntonio Quartulli #include "bat_v_ogm.h" 200da00359SAntonio Quartulli #include "main.h" 210da00359SAntonio Quartulli 220da00359SAntonio Quartulli #include <linux/atomic.h> 230da00359SAntonio Quartulli #include <linux/byteorder/generic.h> 240da00359SAntonio Quartulli #include <linux/errno.h> 250da00359SAntonio Quartulli #include <linux/etherdevice.h> 260da00359SAntonio Quartulli #include <linux/fs.h> 270da00359SAntonio Quartulli #include <linux/if_ether.h> 280da00359SAntonio Quartulli #include <linux/jiffies.h> 290da00359SAntonio Quartulli #include <linux/kernel.h> 3027353446SSven Eckelmann #include <linux/kref.h> 319323158eSAntonio Quartulli #include <linux/list.h> 320da00359SAntonio Quartulli #include <linux/netdevice.h> 330da00359SAntonio Quartulli #include <linux/random.h> 340da00359SAntonio Quartulli #include <linux/rculist.h> 350da00359SAntonio Quartulli #include <linux/rcupdate.h> 360da00359SAntonio Quartulli #include <linux/skbuff.h> 370da00359SAntonio Quartulli #include <linux/slab.h> 380da00359SAntonio Quartulli #include <linux/stddef.h> 390da00359SAntonio Quartulli #include <linux/string.h> 400da00359SAntonio Quartulli #include <linux/types.h> 410da00359SAntonio Quartulli #include <linux/workqueue.h> 420da00359SAntonio Quartulli 4301d350d1SSven Eckelmann #include "bat_algo.h" 440da00359SAntonio Quartulli #include "hard-interface.h" 459323158eSAntonio Quartulli #include "hash.h" 46ba412080SSven Eckelmann #include "log.h" 479323158eSAntonio Quartulli #include "originator.h" 480da00359SAntonio Quartulli #include "packet.h" 490da00359SAntonio Quartulli #include "routing.h" 500da00359SAntonio Quartulli #include "send.h" 510da00359SAntonio Quartulli #include "translation-table.h" 521f8dce49SMarkus Pargmann #include "tvlv.h" 530da00359SAntonio Quartulli 540da00359SAntonio Quartulli /** 559323158eSAntonio Quartulli * batadv_v_ogm_orig_get - retrieve and possibly create an originator node 569323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 579323158eSAntonio Quartulli * @addr: the address of the originator 589323158eSAntonio Quartulli * 599323158eSAntonio Quartulli * Return: the orig_node corresponding to the specified address. If such object 609323158eSAntonio Quartulli * does not exist it is allocated here. In case of allocation failure returns 619323158eSAntonio Quartulli * NULL. 629323158eSAntonio Quartulli */ 639323158eSAntonio Quartulli struct batadv_orig_node *batadv_v_ogm_orig_get(struct batadv_priv *bat_priv, 649323158eSAntonio Quartulli const u8 *addr) 659323158eSAntonio Quartulli { 669323158eSAntonio Quartulli struct batadv_orig_node *orig_node; 679323158eSAntonio Quartulli int hash_added; 689323158eSAntonio Quartulli 699323158eSAntonio Quartulli orig_node = batadv_orig_hash_find(bat_priv, addr); 709323158eSAntonio Quartulli if (orig_node) 719323158eSAntonio Quartulli return orig_node; 729323158eSAntonio Quartulli 739323158eSAntonio Quartulli orig_node = batadv_orig_node_new(bat_priv, addr); 749323158eSAntonio Quartulli if (!orig_node) 759323158eSAntonio Quartulli return NULL; 769323158eSAntonio Quartulli 7755db2d59SSven Eckelmann kref_get(&orig_node->refcount); 789323158eSAntonio Quartulli hash_added = batadv_hash_add(bat_priv->orig_hash, batadv_compare_orig, 799323158eSAntonio Quartulli batadv_choose_orig, orig_node, 809323158eSAntonio Quartulli &orig_node->hash_entry); 819323158eSAntonio Quartulli if (hash_added != 0) { 8255db2d59SSven Eckelmann /* remove refcnt for newly created orig_node and hash entry */ 839323158eSAntonio Quartulli batadv_orig_node_put(orig_node); 849323158eSAntonio Quartulli batadv_orig_node_put(orig_node); 859323158eSAntonio Quartulli orig_node = NULL; 869323158eSAntonio Quartulli } 879323158eSAntonio Quartulli 889323158eSAntonio Quartulli return orig_node; 899323158eSAntonio Quartulli } 909323158eSAntonio Quartulli 919323158eSAntonio Quartulli /** 920da00359SAntonio Quartulli * batadv_v_ogm_start_timer - restart the OGM sending timer 930da00359SAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 940da00359SAntonio Quartulli */ 950da00359SAntonio Quartulli static void batadv_v_ogm_start_timer(struct batadv_priv *bat_priv) 960da00359SAntonio Quartulli { 970da00359SAntonio Quartulli unsigned long msecs; 980da00359SAntonio Quartulli /* this function may be invoked in different contexts (ogm rescheduling 990da00359SAntonio Quartulli * or hard_iface activation), but the work timer should not be reset 1000da00359SAntonio Quartulli */ 1010da00359SAntonio Quartulli if (delayed_work_pending(&bat_priv->bat_v.ogm_wq)) 1020da00359SAntonio Quartulli return; 1030da00359SAntonio Quartulli 1040da00359SAntonio Quartulli msecs = atomic_read(&bat_priv->orig_interval) - BATADV_JITTER; 1050da00359SAntonio Quartulli msecs += prandom_u32() % (2 * BATADV_JITTER); 1060da00359SAntonio Quartulli queue_delayed_work(batadv_event_workqueue, &bat_priv->bat_v.ogm_wq, 1070da00359SAntonio Quartulli msecs_to_jiffies(msecs)); 1080da00359SAntonio Quartulli } 1090da00359SAntonio Quartulli 1100da00359SAntonio Quartulli /** 1110da00359SAntonio Quartulli * batadv_v_ogm_send_to_if - send a batman ogm using a given interface 1120da00359SAntonio Quartulli * @skb: the OGM to send 1130da00359SAntonio Quartulli * @hard_iface: the interface to use to send the OGM 1140da00359SAntonio Quartulli */ 1150da00359SAntonio Quartulli static void batadv_v_ogm_send_to_if(struct sk_buff *skb, 1160da00359SAntonio Quartulli struct batadv_hard_iface *hard_iface) 1170da00359SAntonio Quartulli { 1180da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); 1190da00359SAntonio Quartulli 1200da00359SAntonio Quartulli if (hard_iface->if_status != BATADV_IF_ACTIVE) 1210da00359SAntonio Quartulli return; 1220da00359SAntonio Quartulli 1230da00359SAntonio Quartulli batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_TX); 1240da00359SAntonio Quartulli batadv_add_counter(bat_priv, BATADV_CNT_MGMT_TX_BYTES, 1250da00359SAntonio Quartulli skb->len + ETH_HLEN); 1260da00359SAntonio Quartulli 12795d39278SAntonio Quartulli batadv_send_broadcast_skb(skb, hard_iface); 1280da00359SAntonio Quartulli } 1290da00359SAntonio Quartulli 1300da00359SAntonio Quartulli /** 1310da00359SAntonio Quartulli * batadv_v_ogm_send - periodic worker broadcasting the own OGM 1320da00359SAntonio Quartulli * @work: work queue item 1330da00359SAntonio Quartulli */ 1340da00359SAntonio Quartulli static void batadv_v_ogm_send(struct work_struct *work) 1350da00359SAntonio Quartulli { 1360da00359SAntonio Quartulli struct batadv_hard_iface *hard_iface; 1370da00359SAntonio Quartulli struct batadv_priv_bat_v *bat_v; 1380da00359SAntonio Quartulli struct batadv_priv *bat_priv; 1390da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 1400da00359SAntonio Quartulli struct sk_buff *skb, *skb_tmp; 141e04de486SSven Eckelmann unsigned char *ogm_buff; 1420da00359SAntonio Quartulli int ogm_buff_len; 1430da00359SAntonio Quartulli u16 tvlv_len = 0; 1443111beedSLinus Lüssing int ret; 1450da00359SAntonio Quartulli 1460da00359SAntonio Quartulli bat_v = container_of(work, struct batadv_priv_bat_v, ogm_wq.work); 1470da00359SAntonio Quartulli bat_priv = container_of(bat_v, struct batadv_priv, bat_v); 1480da00359SAntonio Quartulli 1490da00359SAntonio Quartulli if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_DEACTIVATING) 1500da00359SAntonio Quartulli goto out; 1510da00359SAntonio Quartulli 1520da00359SAntonio Quartulli ogm_buff = bat_priv->bat_v.ogm_buff; 1530da00359SAntonio Quartulli ogm_buff_len = bat_priv->bat_v.ogm_buff_len; 1540da00359SAntonio Quartulli /* tt changes have to be committed before the tvlv data is 1550da00359SAntonio Quartulli * appended as it may alter the tt tvlv container 1560da00359SAntonio Quartulli */ 1570da00359SAntonio Quartulli batadv_tt_local_commit_changes(bat_priv); 1580da00359SAntonio Quartulli tvlv_len = batadv_tvlv_container_ogm_append(bat_priv, &ogm_buff, 1590da00359SAntonio Quartulli &ogm_buff_len, 1600da00359SAntonio Quartulli BATADV_OGM2_HLEN); 1610da00359SAntonio Quartulli 1620da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff = ogm_buff; 1630da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff_len = ogm_buff_len; 1640da00359SAntonio Quartulli 1650da00359SAntonio Quartulli skb = netdev_alloc_skb_ip_align(NULL, ETH_HLEN + ogm_buff_len); 1660da00359SAntonio Quartulli if (!skb) 1670da00359SAntonio Quartulli goto reschedule; 1680da00359SAntonio Quartulli 1690da00359SAntonio Quartulli skb_reserve(skb, ETH_HLEN); 170e04de486SSven Eckelmann skb_put_data(skb, ogm_buff, ogm_buff_len); 1710da00359SAntonio Quartulli 1720da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)skb->data; 1730da00359SAntonio Quartulli ogm_packet->seqno = htonl(atomic_read(&bat_priv->bat_v.ogm_seqno)); 1740da00359SAntonio Quartulli atomic_inc(&bat_priv->bat_v.ogm_seqno); 1750da00359SAntonio Quartulli ogm_packet->tvlv_len = htons(tvlv_len); 1760da00359SAntonio Quartulli 1770da00359SAntonio Quartulli /* broadcast on every interface */ 1780da00359SAntonio Quartulli rcu_read_lock(); 1790da00359SAntonio Quartulli list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) { 1800da00359SAntonio Quartulli if (hard_iface->soft_iface != bat_priv->soft_iface) 1810da00359SAntonio Quartulli continue; 1820da00359SAntonio Quartulli 18327353446SSven Eckelmann if (!kref_get_unless_zero(&hard_iface->refcount)) 18427353446SSven Eckelmann continue; 18527353446SSven Eckelmann 1863111beedSLinus Lüssing ret = batadv_hardif_no_broadcast(hard_iface, NULL, NULL); 1873111beedSLinus Lüssing if (ret) { 1883111beedSLinus Lüssing char *type; 1893111beedSLinus Lüssing 1903111beedSLinus Lüssing switch (ret) { 1913111beedSLinus Lüssing case BATADV_HARDIF_BCAST_NORECIPIENT: 1923111beedSLinus Lüssing type = "no neighbor"; 1933111beedSLinus Lüssing break; 1943111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPFWD: 1953111beedSLinus Lüssing type = "single neighbor is source"; 1963111beedSLinus Lüssing break; 1973111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPORIG: 1983111beedSLinus Lüssing type = "single neighbor is originator"; 1993111beedSLinus Lüssing break; 2003111beedSLinus Lüssing default: 2013111beedSLinus Lüssing type = "unknown"; 2023111beedSLinus Lüssing } 2033111beedSLinus Lüssing 204f25cbb2aSColin Ian King batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 from ourselves on %s suppressed: %s\n", 2053111beedSLinus Lüssing hard_iface->net_dev->name, type); 2063111beedSLinus Lüssing 2073111beedSLinus Lüssing batadv_hardif_put(hard_iface); 2083111beedSLinus Lüssing continue; 2093111beedSLinus Lüssing } 2103111beedSLinus Lüssing 2110da00359SAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 2120da00359SAntonio Quartulli "Sending own OGM2 packet (originator %pM, seqno %u, throughput %u, TTL %d) on interface %s [%pM]\n", 2130da00359SAntonio Quartulli ogm_packet->orig, ntohl(ogm_packet->seqno), 2140da00359SAntonio Quartulli ntohl(ogm_packet->throughput), ogm_packet->ttl, 2150da00359SAntonio Quartulli hard_iface->net_dev->name, 2160da00359SAntonio Quartulli hard_iface->net_dev->dev_addr); 2170da00359SAntonio Quartulli 2180da00359SAntonio Quartulli /* this skb gets consumed by batadv_v_ogm_send_to_if() */ 2190da00359SAntonio Quartulli skb_tmp = skb_clone(skb, GFP_ATOMIC); 22027353446SSven Eckelmann if (!skb_tmp) { 22127353446SSven Eckelmann batadv_hardif_put(hard_iface); 2220da00359SAntonio Quartulli break; 22327353446SSven Eckelmann } 2240da00359SAntonio Quartulli 2250da00359SAntonio Quartulli batadv_v_ogm_send_to_if(skb_tmp, hard_iface); 22627353446SSven Eckelmann batadv_hardif_put(hard_iface); 2270da00359SAntonio Quartulli } 2280da00359SAntonio Quartulli rcu_read_unlock(); 2290da00359SAntonio Quartulli 2300da00359SAntonio Quartulli consume_skb(skb); 2310da00359SAntonio Quartulli 2320da00359SAntonio Quartulli reschedule: 2330da00359SAntonio Quartulli batadv_v_ogm_start_timer(bat_priv); 2340da00359SAntonio Quartulli out: 2350da00359SAntonio Quartulli return; 2360da00359SAntonio Quartulli } 2370da00359SAntonio Quartulli 2380da00359SAntonio Quartulli /** 2390da00359SAntonio Quartulli * batadv_v_ogm_iface_enable - prepare an interface for B.A.T.M.A.N. V 2400da00359SAntonio Quartulli * @hard_iface: the interface to prepare 2410da00359SAntonio Quartulli * 2420da00359SAntonio Quartulli * Takes care of scheduling own OGM sending routine for this interface. 2430da00359SAntonio Quartulli * 2440da00359SAntonio Quartulli * Return: 0 on success or a negative error code otherwise 2450da00359SAntonio Quartulli */ 2460da00359SAntonio Quartulli int batadv_v_ogm_iface_enable(struct batadv_hard_iface *hard_iface) 2470da00359SAntonio Quartulli { 2480da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); 2490da00359SAntonio Quartulli 2500da00359SAntonio Quartulli batadv_v_ogm_start_timer(bat_priv); 2510da00359SAntonio Quartulli 2520da00359SAntonio Quartulli return 0; 2530da00359SAntonio Quartulli } 2540da00359SAntonio Quartulli 2550da00359SAntonio Quartulli /** 2560da00359SAntonio Quartulli * batadv_v_ogm_primary_iface_set - set a new primary interface 2570da00359SAntonio Quartulli * @primary_iface: the new primary interface 2580da00359SAntonio Quartulli */ 2590da00359SAntonio Quartulli void batadv_v_ogm_primary_iface_set(struct batadv_hard_iface *primary_iface) 2600da00359SAntonio Quartulli { 2610da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(primary_iface->soft_iface); 2620da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 2630da00359SAntonio Quartulli 2640da00359SAntonio Quartulli if (!bat_priv->bat_v.ogm_buff) 2650da00359SAntonio Quartulli return; 2660da00359SAntonio Quartulli 2670da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)bat_priv->bat_v.ogm_buff; 2680da00359SAntonio Quartulli ether_addr_copy(ogm_packet->orig, primary_iface->net_dev->dev_addr); 2690da00359SAntonio Quartulli } 2700da00359SAntonio Quartulli 2710da00359SAntonio Quartulli /** 2729323158eSAntonio Quartulli * batadv_v_forward_penalty - apply a penalty to the throughput metric forwarded 2739323158eSAntonio Quartulli * with B.A.T.M.A.N. V OGMs 2749323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 2759323158eSAntonio Quartulli * @if_incoming: the interface where the OGM has been received 2769323158eSAntonio Quartulli * @if_outgoing: the interface where the OGM has to be forwarded to 2779323158eSAntonio Quartulli * @throughput: the current throughput 2789323158eSAntonio Quartulli * 2799323158eSAntonio Quartulli * Apply a penalty on the current throughput metric value based on the 2809323158eSAntonio Quartulli * characteristic of the interface where the OGM has been received. The return 2819323158eSAntonio Quartulli * value is computed as follows: 2829323158eSAntonio Quartulli * - throughput * 50% if the incoming and outgoing interface are the 2839323158eSAntonio Quartulli * same WiFi interface and the throughput is above 2849323158eSAntonio Quartulli * 1MBit/s 2859323158eSAntonio Quartulli * - throughput if the outgoing interface is the default 2869323158eSAntonio Quartulli * interface (i.e. this OGM is processed for the 2879323158eSAntonio Quartulli * internal table and not forwarded) 2889323158eSAntonio Quartulli * - throughput * hop penalty otherwise 2899323158eSAntonio Quartulli * 2909323158eSAntonio Quartulli * Return: the penalised throughput metric. 2919323158eSAntonio Quartulli */ 2929323158eSAntonio Quartulli static u32 batadv_v_forward_penalty(struct batadv_priv *bat_priv, 2939323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 2949323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing, 2959323158eSAntonio Quartulli u32 throughput) 2969323158eSAntonio Quartulli { 2979323158eSAntonio Quartulli int hop_penalty = atomic_read(&bat_priv->hop_penalty); 2989323158eSAntonio Quartulli int hop_penalty_max = BATADV_TQ_MAX_VALUE; 2999323158eSAntonio Quartulli 3009323158eSAntonio Quartulli /* Don't apply hop penalty in default originator table. */ 3019323158eSAntonio Quartulli if (if_outgoing == BATADV_IF_DEFAULT) 3029323158eSAntonio Quartulli return throughput; 3039323158eSAntonio Quartulli 3049323158eSAntonio Quartulli /* Forwarding on the same WiFi interface cuts the throughput in half 3059323158eSAntonio Quartulli * due to the store & forward characteristics of WIFI. 3069323158eSAntonio Quartulli * Very low throughput values are the exception. 3079323158eSAntonio Quartulli */ 308825ffe1fSSven Eckelmann if (throughput > 10 && 309825ffe1fSSven Eckelmann if_incoming == if_outgoing && 310c833484eSAntonio Quartulli !(if_incoming->bat_v.flags & BATADV_FULL_DUPLEX)) 3119323158eSAntonio Quartulli return throughput / 2; 3129323158eSAntonio Quartulli 3139323158eSAntonio Quartulli /* hop penalty of 255 equals 100% */ 3149323158eSAntonio Quartulli return throughput * (hop_penalty_max - hop_penalty) / hop_penalty_max; 3159323158eSAntonio Quartulli } 3169323158eSAntonio Quartulli 3179323158eSAntonio Quartulli /** 318efcc9d30SSimon Wunderlich * batadv_v_ogm_forward - check conditions and forward an OGM to the given 319efcc9d30SSimon Wunderlich * outgoing interface 3209323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 3219323158eSAntonio Quartulli * @ogm_received: previously received OGM to be forwarded 322efcc9d30SSimon Wunderlich * @orig_node: the originator which has been updated 323efcc9d30SSimon Wunderlich * @neigh_node: the neigh_node through with the OGM has been received 3249323158eSAntonio Quartulli * @if_incoming: the interface on which this OGM was received on 3259323158eSAntonio Quartulli * @if_outgoing: the interface to which the OGM has to be forwarded to 3269323158eSAntonio Quartulli * 3279323158eSAntonio Quartulli * Forward an OGM to an interface after having altered the throughput metric and 3289323158eSAntonio Quartulli * the TTL value contained in it. The original OGM isn't modified. 3299323158eSAntonio Quartulli */ 3309323158eSAntonio Quartulli static void batadv_v_ogm_forward(struct batadv_priv *bat_priv, 3319323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm_received, 332efcc9d30SSimon Wunderlich struct batadv_orig_node *orig_node, 333efcc9d30SSimon Wunderlich struct batadv_neigh_node *neigh_node, 3349323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 3359323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 3369323158eSAntonio Quartulli { 337efcc9d30SSimon Wunderlich struct batadv_neigh_ifinfo *neigh_ifinfo = NULL; 338efcc9d30SSimon Wunderlich struct batadv_orig_ifinfo *orig_ifinfo = NULL; 339efcc9d30SSimon Wunderlich struct batadv_neigh_node *router = NULL; 3409323158eSAntonio Quartulli struct batadv_ogm2_packet *ogm_forward; 3419323158eSAntonio Quartulli unsigned char *skb_buff; 3429323158eSAntonio Quartulli struct sk_buff *skb; 3439323158eSAntonio Quartulli size_t packet_len; 3449323158eSAntonio Quartulli u16 tvlv_len; 3459323158eSAntonio Quartulli 346efcc9d30SSimon Wunderlich /* only forward for specific interfaces, not for the default one. */ 347efcc9d30SSimon Wunderlich if (if_outgoing == BATADV_IF_DEFAULT) 348efcc9d30SSimon Wunderlich goto out; 349efcc9d30SSimon Wunderlich 350efcc9d30SSimon Wunderlich orig_ifinfo = batadv_orig_ifinfo_new(orig_node, if_outgoing); 351efcc9d30SSimon Wunderlich if (!orig_ifinfo) 352efcc9d30SSimon Wunderlich goto out; 353efcc9d30SSimon Wunderlich 354efcc9d30SSimon Wunderlich /* acquire possibly updated router */ 355efcc9d30SSimon Wunderlich router = batadv_orig_router_get(orig_node, if_outgoing); 356efcc9d30SSimon Wunderlich 357efcc9d30SSimon Wunderlich /* strict rule: forward packets coming from the best next hop only */ 358efcc9d30SSimon Wunderlich if (neigh_node != router) 359efcc9d30SSimon Wunderlich goto out; 360efcc9d30SSimon Wunderlich 361efcc9d30SSimon Wunderlich /* don't forward the same seqno twice on one interface */ 362efcc9d30SSimon Wunderlich if (orig_ifinfo->last_seqno_forwarded == ntohl(ogm_received->seqno)) 363efcc9d30SSimon Wunderlich goto out; 364efcc9d30SSimon Wunderlich 365efcc9d30SSimon Wunderlich orig_ifinfo->last_seqno_forwarded = ntohl(ogm_received->seqno); 366efcc9d30SSimon Wunderlich 3679323158eSAntonio Quartulli if (ogm_received->ttl <= 1) { 3689323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "ttl exceeded\n"); 369efcc9d30SSimon Wunderlich goto out; 3709323158eSAntonio Quartulli } 3719323158eSAntonio Quartulli 372efcc9d30SSimon Wunderlich neigh_ifinfo = batadv_neigh_ifinfo_get(neigh_node, if_outgoing); 373efcc9d30SSimon Wunderlich if (!neigh_ifinfo) 374efcc9d30SSimon Wunderlich goto out; 375efcc9d30SSimon Wunderlich 3769323158eSAntonio Quartulli tvlv_len = ntohs(ogm_received->tvlv_len); 3779323158eSAntonio Quartulli 3789323158eSAntonio Quartulli packet_len = BATADV_OGM2_HLEN + tvlv_len; 3799323158eSAntonio Quartulli skb = netdev_alloc_skb_ip_align(if_outgoing->net_dev, 3809323158eSAntonio Quartulli ETH_HLEN + packet_len); 3819323158eSAntonio Quartulli if (!skb) 382efcc9d30SSimon Wunderlich goto out; 3839323158eSAntonio Quartulli 3849323158eSAntonio Quartulli skb_reserve(skb, ETH_HLEN); 38559ae1d12SJohannes Berg skb_buff = skb_put_data(skb, ogm_received, packet_len); 3869323158eSAntonio Quartulli 3879323158eSAntonio Quartulli /* apply forward penalty */ 3889323158eSAntonio Quartulli ogm_forward = (struct batadv_ogm2_packet *)skb_buff; 389efcc9d30SSimon Wunderlich ogm_forward->throughput = htonl(neigh_ifinfo->bat_v.throughput); 3909323158eSAntonio Quartulli ogm_forward->ttl--; 3919323158eSAntonio Quartulli 3929323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 3939323158eSAntonio Quartulli "Forwarding OGM2 packet on %s: throughput %u, ttl %u, received via %s\n", 394efcc9d30SSimon Wunderlich if_outgoing->net_dev->name, ntohl(ogm_forward->throughput), 395efcc9d30SSimon Wunderlich ogm_forward->ttl, if_incoming->net_dev->name); 3969323158eSAntonio Quartulli 3979323158eSAntonio Quartulli batadv_v_ogm_send_to_if(skb, if_outgoing); 398efcc9d30SSimon Wunderlich 399efcc9d30SSimon Wunderlich out: 400efcc9d30SSimon Wunderlich if (orig_ifinfo) 401efcc9d30SSimon Wunderlich batadv_orig_ifinfo_put(orig_ifinfo); 402efcc9d30SSimon Wunderlich if (router) 403efcc9d30SSimon Wunderlich batadv_neigh_node_put(router); 404efcc9d30SSimon Wunderlich if (neigh_ifinfo) 405efcc9d30SSimon Wunderlich batadv_neigh_ifinfo_put(neigh_ifinfo); 4069323158eSAntonio Quartulli } 4079323158eSAntonio Quartulli 4089323158eSAntonio Quartulli /** 4099323158eSAntonio Quartulli * batadv_v_ogm_metric_update - update route metric based on OGM 4109323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 4119323158eSAntonio Quartulli * @ogm2: OGM2 structure 4129323158eSAntonio Quartulli * @orig_node: Originator structure for which the OGM has been received 4139323158eSAntonio Quartulli * @neigh_node: the neigh_node through with the OGM has been received 4149323158eSAntonio Quartulli * @if_incoming: the interface where this packet was received 4159323158eSAntonio Quartulli * @if_outgoing: the interface for which the packet should be considered 4169323158eSAntonio Quartulli * 4179323158eSAntonio Quartulli * Return: 4189323158eSAntonio Quartulli * 1 if the OGM is new, 4199323158eSAntonio Quartulli * 0 if it is not new but valid, 4209323158eSAntonio Quartulli * <0 on error (e.g. old OGM) 4219323158eSAntonio Quartulli */ 4229323158eSAntonio Quartulli static int batadv_v_ogm_metric_update(struct batadv_priv *bat_priv, 4239323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm2, 4249323158eSAntonio Quartulli struct batadv_orig_node *orig_node, 4259323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node, 4269323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 4279323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 4289323158eSAntonio Quartulli { 429422d2f77SSven Eckelmann struct batadv_orig_ifinfo *orig_ifinfo; 4309323158eSAntonio Quartulli struct batadv_neigh_ifinfo *neigh_ifinfo = NULL; 4319323158eSAntonio Quartulli bool protection_started = false; 4329323158eSAntonio Quartulli int ret = -EINVAL; 4339323158eSAntonio Quartulli u32 path_throughput; 4349323158eSAntonio Quartulli s32 seq_diff; 4359323158eSAntonio Quartulli 4369323158eSAntonio Quartulli orig_ifinfo = batadv_orig_ifinfo_new(orig_node, if_outgoing); 4379323158eSAntonio Quartulli if (!orig_ifinfo) 4389323158eSAntonio Quartulli goto out; 4399323158eSAntonio Quartulli 4409323158eSAntonio Quartulli seq_diff = ntohl(ogm2->seqno) - orig_ifinfo->last_real_seqno; 4419323158eSAntonio Quartulli 4429323158eSAntonio Quartulli if (!hlist_empty(&orig_node->neigh_list) && 4439323158eSAntonio Quartulli batadv_window_protected(bat_priv, seq_diff, 4449323158eSAntonio Quartulli BATADV_OGM_MAX_AGE, 4459323158eSAntonio Quartulli &orig_ifinfo->batman_seqno_reset, 4469323158eSAntonio Quartulli &protection_started)) { 4479323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 4489323158eSAntonio Quartulli "Drop packet: packet within window protection time from %pM\n", 4499323158eSAntonio Quartulli ogm2->orig); 4509323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 4519323158eSAntonio Quartulli "Last reset: %ld, %ld\n", 4529323158eSAntonio Quartulli orig_ifinfo->batman_seqno_reset, jiffies); 4539323158eSAntonio Quartulli goto out; 4549323158eSAntonio Quartulli } 4559323158eSAntonio Quartulli 4569323158eSAntonio Quartulli /* drop packets with old seqnos, however accept the first packet after 4579323158eSAntonio Quartulli * a host has been rebooted. 4589323158eSAntonio Quartulli */ 459825ffe1fSSven Eckelmann if (seq_diff < 0 && !protection_started) 4609323158eSAntonio Quartulli goto out; 4619323158eSAntonio Quartulli 4629323158eSAntonio Quartulli neigh_node->last_seen = jiffies; 4639323158eSAntonio Quartulli 4649323158eSAntonio Quartulli orig_node->last_seen = jiffies; 4659323158eSAntonio Quartulli 4669323158eSAntonio Quartulli orig_ifinfo->last_real_seqno = ntohl(ogm2->seqno); 4679323158eSAntonio Quartulli orig_ifinfo->last_ttl = ogm2->ttl; 4689323158eSAntonio Quartulli 4699323158eSAntonio Quartulli neigh_ifinfo = batadv_neigh_ifinfo_new(neigh_node, if_outgoing); 4709323158eSAntonio Quartulli if (!neigh_ifinfo) 4719323158eSAntonio Quartulli goto out; 4729323158eSAntonio Quartulli 4739323158eSAntonio Quartulli path_throughput = batadv_v_forward_penalty(bat_priv, if_incoming, 4749323158eSAntonio Quartulli if_outgoing, 4759323158eSAntonio Quartulli ntohl(ogm2->throughput)); 4769323158eSAntonio Quartulli neigh_ifinfo->bat_v.throughput = path_throughput; 4779323158eSAntonio Quartulli neigh_ifinfo->bat_v.last_seqno = ntohl(ogm2->seqno); 4789323158eSAntonio Quartulli neigh_ifinfo->last_ttl = ogm2->ttl; 4799323158eSAntonio Quartulli 4809323158eSAntonio Quartulli if (seq_diff > 0 || protection_started) 4819323158eSAntonio Quartulli ret = 1; 4829323158eSAntonio Quartulli else 4839323158eSAntonio Quartulli ret = 0; 4849323158eSAntonio Quartulli out: 4859323158eSAntonio Quartulli if (orig_ifinfo) 4869323158eSAntonio Quartulli batadv_orig_ifinfo_put(orig_ifinfo); 4879323158eSAntonio Quartulli if (neigh_ifinfo) 4889323158eSAntonio Quartulli batadv_neigh_ifinfo_put(neigh_ifinfo); 4899323158eSAntonio Quartulli 4909323158eSAntonio Quartulli return ret; 4919323158eSAntonio Quartulli } 4929323158eSAntonio Quartulli 4939323158eSAntonio Quartulli /** 4949323158eSAntonio Quartulli * batadv_v_ogm_route_update - update routes based on OGM 4959323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 4969323158eSAntonio Quartulli * @ethhdr: the Ethernet header of the OGM2 4979323158eSAntonio Quartulli * @ogm2: OGM2 structure 4989323158eSAntonio Quartulli * @orig_node: Originator structure for which the OGM has been received 4999323158eSAntonio Quartulli * @neigh_node: the neigh_node through with the OGM has been received 5009323158eSAntonio Quartulli * @if_incoming: the interface where this packet was received 5019323158eSAntonio Quartulli * @if_outgoing: the interface for which the packet should be considered 502efcc9d30SSimon Wunderlich * 503efcc9d30SSimon Wunderlich * Return: true if the packet should be forwarded, false otherwise 5049323158eSAntonio Quartulli */ 505efcc9d30SSimon Wunderlich static bool batadv_v_ogm_route_update(struct batadv_priv *bat_priv, 5069323158eSAntonio Quartulli const struct ethhdr *ethhdr, 5079323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm2, 5089323158eSAntonio Quartulli struct batadv_orig_node *orig_node, 5099323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node, 5109323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 5119323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 5129323158eSAntonio Quartulli { 5139323158eSAntonio Quartulli struct batadv_neigh_node *router = NULL; 514422d2f77SSven Eckelmann struct batadv_orig_node *orig_neigh_node; 5159323158eSAntonio Quartulli struct batadv_neigh_node *orig_neigh_router = NULL; 51686de37c1SSimon Wunderlich struct batadv_neigh_ifinfo *router_ifinfo = NULL, *neigh_ifinfo = NULL; 51786de37c1SSimon Wunderlich u32 router_throughput, neigh_throughput; 51886de37c1SSimon Wunderlich u32 router_last_seqno; 51986de37c1SSimon Wunderlich u32 neigh_last_seqno; 52086de37c1SSimon Wunderlich s32 neigh_seq_diff; 521efcc9d30SSimon Wunderlich bool forward = false; 5229323158eSAntonio Quartulli 5239323158eSAntonio Quartulli orig_neigh_node = batadv_v_ogm_orig_get(bat_priv, ethhdr->h_source); 5249323158eSAntonio Quartulli if (!orig_neigh_node) 5259323158eSAntonio Quartulli goto out; 5269323158eSAntonio Quartulli 5279323158eSAntonio Quartulli orig_neigh_router = batadv_orig_router_get(orig_neigh_node, 5289323158eSAntonio Quartulli if_outgoing); 5299323158eSAntonio Quartulli 5309323158eSAntonio Quartulli /* drop packet if sender is not a direct neighbor and if we 5319323158eSAntonio Quartulli * don't route towards it 5329323158eSAntonio Quartulli */ 5339323158eSAntonio Quartulli router = batadv_orig_router_get(orig_node, if_outgoing); 5349323158eSAntonio Quartulli if (router && router->orig_node != orig_node && !orig_neigh_router) { 5359323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 5369323158eSAntonio Quartulli "Drop packet: OGM via unknown neighbor!\n"); 5379323158eSAntonio Quartulli goto out; 5389323158eSAntonio Quartulli } 5399323158eSAntonio Quartulli 54086de37c1SSimon Wunderlich /* Mark the OGM to be considered for forwarding, and update routes 54186de37c1SSimon Wunderlich * if needed. 54286de37c1SSimon Wunderlich */ 543efcc9d30SSimon Wunderlich forward = true; 54486de37c1SSimon Wunderlich 54586de37c1SSimon Wunderlich batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 54686de37c1SSimon Wunderlich "Searching and updating originator entry of received packet\n"); 54786de37c1SSimon Wunderlich 54886de37c1SSimon Wunderlich /* if this neighbor already is our next hop there is nothing 54986de37c1SSimon Wunderlich * to change 55086de37c1SSimon Wunderlich */ 55186de37c1SSimon Wunderlich if (router == neigh_node) 55286de37c1SSimon Wunderlich goto out; 55386de37c1SSimon Wunderlich 55486de37c1SSimon Wunderlich /* don't consider neighbours with worse throughput. 55586de37c1SSimon Wunderlich * also switch route if this seqno is BATADV_V_MAX_ORIGDIFF newer than 55686de37c1SSimon Wunderlich * the last received seqno from our best next hop. 55786de37c1SSimon Wunderlich */ 55886de37c1SSimon Wunderlich if (router) { 55986de37c1SSimon Wunderlich router_ifinfo = batadv_neigh_ifinfo_get(router, if_outgoing); 56086de37c1SSimon Wunderlich neigh_ifinfo = batadv_neigh_ifinfo_get(neigh_node, if_outgoing); 56186de37c1SSimon Wunderlich 56286de37c1SSimon Wunderlich /* if these are not allocated, something is wrong. */ 56386de37c1SSimon Wunderlich if (!router_ifinfo || !neigh_ifinfo) 56486de37c1SSimon Wunderlich goto out; 56586de37c1SSimon Wunderlich 56686de37c1SSimon Wunderlich neigh_last_seqno = neigh_ifinfo->bat_v.last_seqno; 56786de37c1SSimon Wunderlich router_last_seqno = router_ifinfo->bat_v.last_seqno; 56886de37c1SSimon Wunderlich neigh_seq_diff = neigh_last_seqno - router_last_seqno; 56986de37c1SSimon Wunderlich router_throughput = router_ifinfo->bat_v.throughput; 57086de37c1SSimon Wunderlich neigh_throughput = neigh_ifinfo->bat_v.throughput; 57186de37c1SSimon Wunderlich 572825ffe1fSSven Eckelmann if (neigh_seq_diff < BATADV_OGM_MAX_ORIGDIFF && 573825ffe1fSSven Eckelmann router_throughput >= neigh_throughput) 57486de37c1SSimon Wunderlich goto out; 57586de37c1SSimon Wunderlich } 57686de37c1SSimon Wunderlich 57786de37c1SSimon Wunderlich batadv_update_route(bat_priv, orig_node, if_outgoing, neigh_node); 5789323158eSAntonio Quartulli out: 5799323158eSAntonio Quartulli if (router) 5809323158eSAntonio Quartulli batadv_neigh_node_put(router); 5819323158eSAntonio Quartulli if (orig_neigh_router) 5829323158eSAntonio Quartulli batadv_neigh_node_put(orig_neigh_router); 5839323158eSAntonio Quartulli if (orig_neigh_node) 5849323158eSAntonio Quartulli batadv_orig_node_put(orig_neigh_node); 58586de37c1SSimon Wunderlich if (router_ifinfo) 58686de37c1SSimon Wunderlich batadv_neigh_ifinfo_put(router_ifinfo); 58786de37c1SSimon Wunderlich if (neigh_ifinfo) 58886de37c1SSimon Wunderlich batadv_neigh_ifinfo_put(neigh_ifinfo); 589efcc9d30SSimon Wunderlich 590efcc9d30SSimon Wunderlich return forward; 5919323158eSAntonio Quartulli } 5929323158eSAntonio Quartulli 5939323158eSAntonio Quartulli /** 5949323158eSAntonio Quartulli * batadv_v_ogm_process_per_outif - process a batman v OGM for an outgoing if 5959323158eSAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 5969323158eSAntonio Quartulli * @ethhdr: the Ethernet header of the OGM2 5979323158eSAntonio Quartulli * @ogm2: OGM2 structure 5989323158eSAntonio Quartulli * @orig_node: Originator structure for which the OGM has been received 5999323158eSAntonio Quartulli * @neigh_node: the neigh_node through with the OGM has been received 6009323158eSAntonio Quartulli * @if_incoming: the interface where this packet was received 6019323158eSAntonio Quartulli * @if_outgoing: the interface for which the packet should be considered 6029323158eSAntonio Quartulli */ 6039323158eSAntonio Quartulli static void 6049323158eSAntonio Quartulli batadv_v_ogm_process_per_outif(struct batadv_priv *bat_priv, 6059323158eSAntonio Quartulli const struct ethhdr *ethhdr, 6069323158eSAntonio Quartulli const struct batadv_ogm2_packet *ogm2, 6079323158eSAntonio Quartulli struct batadv_orig_node *orig_node, 6089323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node, 6099323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming, 6109323158eSAntonio Quartulli struct batadv_hard_iface *if_outgoing) 6119323158eSAntonio Quartulli { 6129323158eSAntonio Quartulli int seqno_age; 613efcc9d30SSimon Wunderlich bool forward; 6149323158eSAntonio Quartulli 6159323158eSAntonio Quartulli /* first, update the metric with according sanity checks */ 6169323158eSAntonio Quartulli seqno_age = batadv_v_ogm_metric_update(bat_priv, ogm2, orig_node, 6179323158eSAntonio Quartulli neigh_node, if_incoming, 6189323158eSAntonio Quartulli if_outgoing); 6199323158eSAntonio Quartulli 6209323158eSAntonio Quartulli /* outdated sequence numbers are to be discarded */ 6219323158eSAntonio Quartulli if (seqno_age < 0) 6229323158eSAntonio Quartulli return; 6239323158eSAntonio Quartulli 6249323158eSAntonio Quartulli /* only unknown & newer OGMs contain TVLVs we are interested in */ 625825ffe1fSSven Eckelmann if (seqno_age > 0 && if_outgoing == BATADV_IF_DEFAULT) 6269323158eSAntonio Quartulli batadv_tvlv_containers_process(bat_priv, true, orig_node, 6279323158eSAntonio Quartulli NULL, NULL, 6289323158eSAntonio Quartulli (unsigned char *)(ogm2 + 1), 6299323158eSAntonio Quartulli ntohs(ogm2->tvlv_len)); 6309323158eSAntonio Quartulli 6319323158eSAntonio Quartulli /* if the metric update went through, update routes if needed */ 632efcc9d30SSimon Wunderlich forward = batadv_v_ogm_route_update(bat_priv, ethhdr, ogm2, orig_node, 633efcc9d30SSimon Wunderlich neigh_node, if_incoming, 634efcc9d30SSimon Wunderlich if_outgoing); 635efcc9d30SSimon Wunderlich 636efcc9d30SSimon Wunderlich /* if the routes have been processed correctly, check and forward */ 637efcc9d30SSimon Wunderlich if (forward) 638efcc9d30SSimon Wunderlich batadv_v_ogm_forward(bat_priv, ogm2, orig_node, neigh_node, 639efcc9d30SSimon Wunderlich if_incoming, if_outgoing); 6409323158eSAntonio Quartulli } 6419323158eSAntonio Quartulli 6429323158eSAntonio Quartulli /** 6439323158eSAntonio Quartulli * batadv_v_ogm_aggr_packet - checks if there is another OGM aggregated 6449323158eSAntonio Quartulli * @buff_pos: current position in the skb 6459323158eSAntonio Quartulli * @packet_len: total length of the skb 6469323158eSAntonio Quartulli * @tvlv_len: tvlv length of the previously considered OGM 6479323158eSAntonio Quartulli * 6489323158eSAntonio Quartulli * Return: true if there is enough space for another OGM, false otherwise. 6499323158eSAntonio Quartulli */ 6509323158eSAntonio Quartulli static bool batadv_v_ogm_aggr_packet(int buff_pos, int packet_len, 6519323158eSAntonio Quartulli __be16 tvlv_len) 6529323158eSAntonio Quartulli { 6539323158eSAntonio Quartulli int next_buff_pos = 0; 6549323158eSAntonio Quartulli 6559323158eSAntonio Quartulli next_buff_pos += buff_pos + BATADV_OGM2_HLEN; 6569323158eSAntonio Quartulli next_buff_pos += ntohs(tvlv_len); 6579323158eSAntonio Quartulli 6589323158eSAntonio Quartulli return (next_buff_pos <= packet_len) && 6599323158eSAntonio Quartulli (next_buff_pos <= BATADV_MAX_AGGREGATION_BYTES); 6609323158eSAntonio Quartulli } 6619323158eSAntonio Quartulli 6629323158eSAntonio Quartulli /** 6639323158eSAntonio Quartulli * batadv_v_ogm_process - process an incoming batman v OGM 6649323158eSAntonio Quartulli * @skb: the skb containing the OGM 6659323158eSAntonio Quartulli * @ogm_offset: offset to the OGM which should be processed (for aggregates) 6669323158eSAntonio Quartulli * @if_incoming: the interface where this packet was receved 6679323158eSAntonio Quartulli */ 6689323158eSAntonio Quartulli static void batadv_v_ogm_process(const struct sk_buff *skb, int ogm_offset, 6699323158eSAntonio Quartulli struct batadv_hard_iface *if_incoming) 6709323158eSAntonio Quartulli { 6719323158eSAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface); 6729323158eSAntonio Quartulli struct ethhdr *ethhdr; 6739323158eSAntonio Quartulli struct batadv_orig_node *orig_node = NULL; 6749323158eSAntonio Quartulli struct batadv_hardif_neigh_node *hardif_neigh = NULL; 6759323158eSAntonio Quartulli struct batadv_neigh_node *neigh_node = NULL; 6769323158eSAntonio Quartulli struct batadv_hard_iface *hard_iface; 6779323158eSAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 6789323158eSAntonio Quartulli u32 ogm_throughput, link_throughput, path_throughput; 6793111beedSLinus Lüssing int ret; 6809323158eSAntonio Quartulli 6819323158eSAntonio Quartulli ethhdr = eth_hdr(skb); 6829323158eSAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)(skb->data + ogm_offset); 6839323158eSAntonio Quartulli 6849323158eSAntonio Quartulli ogm_throughput = ntohl(ogm_packet->throughput); 6859323158eSAntonio Quartulli 6869323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 687f25cbb2aSColin 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", 6889323158eSAntonio Quartulli ethhdr->h_source, if_incoming->net_dev->name, 6899323158eSAntonio Quartulli if_incoming->net_dev->dev_addr, ogm_packet->orig, 6909323158eSAntonio Quartulli ntohl(ogm_packet->seqno), ogm_throughput, ogm_packet->ttl, 6919323158eSAntonio Quartulli ogm_packet->version, ntohs(ogm_packet->tvlv_len)); 6929323158eSAntonio Quartulli 693f25cbb2aSColin Ian King /* If the throughput metric is 0, immediately drop the packet. No need 694f25cbb2aSColin Ian King * to create orig_node / neigh_node for an unusable route. 6959323158eSAntonio Quartulli */ 6969323158eSAntonio Quartulli if (ogm_throughput == 0) { 6979323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 698f25cbb2aSColin Ian King "Drop packet: originator packet with throughput metric of 0\n"); 6999323158eSAntonio Quartulli return; 7009323158eSAntonio Quartulli } 7019323158eSAntonio Quartulli 7029323158eSAntonio Quartulli /* require ELP packets be to received from this neighbor first */ 7039323158eSAntonio Quartulli hardif_neigh = batadv_hardif_neigh_get(if_incoming, ethhdr->h_source); 7049323158eSAntonio Quartulli if (!hardif_neigh) { 7059323158eSAntonio Quartulli batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 7069323158eSAntonio Quartulli "Drop packet: OGM via unknown neighbor!\n"); 7079323158eSAntonio Quartulli goto out; 7089323158eSAntonio Quartulli } 7099323158eSAntonio Quartulli 7109323158eSAntonio Quartulli orig_node = batadv_v_ogm_orig_get(bat_priv, ogm_packet->orig); 7119323158eSAntonio Quartulli if (!orig_node) 7129323158eSAntonio Quartulli return; 7139323158eSAntonio Quartulli 7146f0a6b5eSMarek Lindner neigh_node = batadv_neigh_node_get_or_create(orig_node, if_incoming, 7159323158eSAntonio Quartulli ethhdr->h_source); 7169323158eSAntonio Quartulli if (!neigh_node) 7179323158eSAntonio Quartulli goto out; 7189323158eSAntonio Quartulli 7199323158eSAntonio Quartulli /* Update the received throughput metric to match the link 7209323158eSAntonio Quartulli * characteristic: 7219323158eSAntonio Quartulli * - If this OGM traveled one hop so far (emitted by single hop 7229323158eSAntonio Quartulli * neighbor) the path throughput metric equals the link throughput. 7239323158eSAntonio Quartulli * - For OGMs traversing more than hop the path throughput metric is 7249323158eSAntonio Quartulli * the smaller of the path throughput and the link throughput. 7259323158eSAntonio Quartulli */ 7269323158eSAntonio Quartulli link_throughput = ewma_throughput_read(&hardif_neigh->bat_v.throughput); 7279323158eSAntonio Quartulli path_throughput = min_t(u32, link_throughput, ogm_throughput); 7289323158eSAntonio Quartulli ogm_packet->throughput = htonl(path_throughput); 7299323158eSAntonio Quartulli 7309323158eSAntonio Quartulli batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet, orig_node, 7319323158eSAntonio Quartulli neigh_node, if_incoming, 7329323158eSAntonio Quartulli BATADV_IF_DEFAULT); 7339323158eSAntonio Quartulli 7349323158eSAntonio Quartulli rcu_read_lock(); 7359323158eSAntonio Quartulli list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) { 7369323158eSAntonio Quartulli if (hard_iface->if_status != BATADV_IF_ACTIVE) 7379323158eSAntonio Quartulli continue; 7389323158eSAntonio Quartulli 7399323158eSAntonio Quartulli if (hard_iface->soft_iface != bat_priv->soft_iface) 7409323158eSAntonio Quartulli continue; 7419323158eSAntonio Quartulli 74227353446SSven Eckelmann if (!kref_get_unless_zero(&hard_iface->refcount)) 74327353446SSven Eckelmann continue; 74427353446SSven Eckelmann 7453111beedSLinus Lüssing ret = batadv_hardif_no_broadcast(hard_iface, 7463111beedSLinus Lüssing ogm_packet->orig, 7473111beedSLinus Lüssing hardif_neigh->orig); 7483111beedSLinus Lüssing 7493111beedSLinus Lüssing if (ret) { 7503111beedSLinus Lüssing char *type; 7513111beedSLinus Lüssing 7523111beedSLinus Lüssing switch (ret) { 7533111beedSLinus Lüssing case BATADV_HARDIF_BCAST_NORECIPIENT: 7543111beedSLinus Lüssing type = "no neighbor"; 7553111beedSLinus Lüssing break; 7563111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPFWD: 7573111beedSLinus Lüssing type = "single neighbor is source"; 7583111beedSLinus Lüssing break; 7593111beedSLinus Lüssing case BATADV_HARDIF_BCAST_DUPORIG: 7603111beedSLinus Lüssing type = "single neighbor is originator"; 7613111beedSLinus Lüssing break; 7623111beedSLinus Lüssing default: 7633111beedSLinus Lüssing type = "unknown"; 7643111beedSLinus Lüssing } 7653111beedSLinus Lüssing 766f25cbb2aSColin Ian King batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 packet from %pM on %s suppressed: %s\n", 7673111beedSLinus Lüssing ogm_packet->orig, hard_iface->net_dev->name, 7683111beedSLinus Lüssing type); 7693111beedSLinus Lüssing 7703111beedSLinus Lüssing batadv_hardif_put(hard_iface); 7713111beedSLinus Lüssing continue; 7723111beedSLinus Lüssing } 7733111beedSLinus Lüssing 7749323158eSAntonio Quartulli batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet, 7759323158eSAntonio Quartulli orig_node, neigh_node, 7769323158eSAntonio Quartulli if_incoming, hard_iface); 77727353446SSven Eckelmann 77827353446SSven Eckelmann batadv_hardif_put(hard_iface); 7799323158eSAntonio Quartulli } 7809323158eSAntonio Quartulli rcu_read_unlock(); 7819323158eSAntonio Quartulli out: 7829323158eSAntonio Quartulli if (orig_node) 7839323158eSAntonio Quartulli batadv_orig_node_put(orig_node); 7849323158eSAntonio Quartulli if (neigh_node) 7859323158eSAntonio Quartulli batadv_neigh_node_put(neigh_node); 7869323158eSAntonio Quartulli if (hardif_neigh) 7879323158eSAntonio Quartulli batadv_hardif_neigh_put(hardif_neigh); 7889323158eSAntonio Quartulli } 7899323158eSAntonio Quartulli 7909323158eSAntonio Quartulli /** 7910da00359SAntonio Quartulli * batadv_v_ogm_packet_recv - OGM2 receiving handler 7920da00359SAntonio Quartulli * @skb: the received OGM 7930da00359SAntonio Quartulli * @if_incoming: the interface where this OGM has been received 7940da00359SAntonio Quartulli * 7950da00359SAntonio Quartulli * Return: NET_RX_SUCCESS and consume the skb on success or returns NET_RX_DROP 7960da00359SAntonio Quartulli * (without freeing the skb) on failure 7970da00359SAntonio Quartulli */ 7980da00359SAntonio Quartulli int batadv_v_ogm_packet_recv(struct sk_buff *skb, 7990da00359SAntonio Quartulli struct batadv_hard_iface *if_incoming) 8000da00359SAntonio Quartulli { 8010da00359SAntonio Quartulli struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface); 8020da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 8030da00359SAntonio Quartulli struct ethhdr *ethhdr = eth_hdr(skb); 8049323158eSAntonio Quartulli int ogm_offset; 8059323158eSAntonio Quartulli u8 *packet_pos; 8069323158eSAntonio Quartulli int ret = NET_RX_DROP; 8070da00359SAntonio Quartulli 8080da00359SAntonio Quartulli /* did we receive a OGM2 packet on an interface that does not have 8090da00359SAntonio Quartulli * B.A.T.M.A.N. V enabled ? 8100da00359SAntonio Quartulli */ 81129824a55SAntonio Quartulli if (strcmp(bat_priv->algo_ops->name, "BATMAN_V") != 0) 812b91a2543SSven Eckelmann goto free_skb; 8130da00359SAntonio Quartulli 8140da00359SAntonio Quartulli if (!batadv_check_management_packet(skb, if_incoming, BATADV_OGM2_HLEN)) 815b91a2543SSven Eckelmann goto free_skb; 8160da00359SAntonio Quartulli 8170da00359SAntonio Quartulli if (batadv_is_my_mac(bat_priv, ethhdr->h_source)) 818b91a2543SSven Eckelmann goto free_skb; 8190da00359SAntonio Quartulli 8200da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)skb->data; 8210da00359SAntonio Quartulli 8220da00359SAntonio Quartulli if (batadv_is_my_mac(bat_priv, ogm_packet->orig)) 823b91a2543SSven Eckelmann goto free_skb; 8240da00359SAntonio Quartulli 8250da00359SAntonio Quartulli batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_RX); 8260da00359SAntonio Quartulli batadv_add_counter(bat_priv, BATADV_CNT_MGMT_RX_BYTES, 8270da00359SAntonio Quartulli skb->len + ETH_HLEN); 8280da00359SAntonio Quartulli 8299323158eSAntonio Quartulli ogm_offset = 0; 8309323158eSAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)skb->data; 8319323158eSAntonio Quartulli 8329323158eSAntonio Quartulli while (batadv_v_ogm_aggr_packet(ogm_offset, skb_headlen(skb), 8339323158eSAntonio Quartulli ogm_packet->tvlv_len)) { 8349323158eSAntonio Quartulli batadv_v_ogm_process(skb, ogm_offset, if_incoming); 8359323158eSAntonio Quartulli 8369323158eSAntonio Quartulli ogm_offset += BATADV_OGM2_HLEN; 8379323158eSAntonio Quartulli ogm_offset += ntohs(ogm_packet->tvlv_len); 8389323158eSAntonio Quartulli 8399323158eSAntonio Quartulli packet_pos = skb->data + ogm_offset; 8409323158eSAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)packet_pos; 8419323158eSAntonio Quartulli } 8429323158eSAntonio Quartulli 8439323158eSAntonio Quartulli ret = NET_RX_SUCCESS; 844b91a2543SSven Eckelmann 845b91a2543SSven Eckelmann free_skb: 846b91a2543SSven Eckelmann if (ret == NET_RX_SUCCESS) 8470da00359SAntonio Quartulli consume_skb(skb); 848b91a2543SSven Eckelmann else 849b91a2543SSven Eckelmann kfree_skb(skb); 8509323158eSAntonio Quartulli 8519323158eSAntonio Quartulli return ret; 8520da00359SAntonio Quartulli } 8530da00359SAntonio Quartulli 8540da00359SAntonio Quartulli /** 8550da00359SAntonio Quartulli * batadv_v_ogm_init - initialise the OGM2 engine 8560da00359SAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 8570da00359SAntonio Quartulli * 8580da00359SAntonio Quartulli * Return: 0 on success or a negative error code in case of failure 8590da00359SAntonio Quartulli */ 8600da00359SAntonio Quartulli int batadv_v_ogm_init(struct batadv_priv *bat_priv) 8610da00359SAntonio Quartulli { 8620da00359SAntonio Quartulli struct batadv_ogm2_packet *ogm_packet; 8630da00359SAntonio Quartulli unsigned char *ogm_buff; 8640da00359SAntonio Quartulli u32 random_seqno; 8650da00359SAntonio Quartulli 8660da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff_len = BATADV_OGM2_HLEN; 8670da00359SAntonio Quartulli ogm_buff = kzalloc(bat_priv->bat_v.ogm_buff_len, GFP_ATOMIC); 8680da00359SAntonio Quartulli if (!ogm_buff) 8690da00359SAntonio Quartulli return -ENOMEM; 8700da00359SAntonio Quartulli 8710da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff = ogm_buff; 8720da00359SAntonio Quartulli ogm_packet = (struct batadv_ogm2_packet *)ogm_buff; 8730da00359SAntonio Quartulli ogm_packet->packet_type = BATADV_OGM2; 8740da00359SAntonio Quartulli ogm_packet->version = BATADV_COMPAT_VERSION; 8750da00359SAntonio Quartulli ogm_packet->ttl = BATADV_TTL; 8760da00359SAntonio Quartulli ogm_packet->flags = BATADV_NO_FLAGS; 8770da00359SAntonio Quartulli ogm_packet->throughput = htonl(BATADV_THROUGHPUT_MAX_VALUE); 8780da00359SAntonio Quartulli 8790da00359SAntonio Quartulli /* randomize initial seqno to avoid collision */ 8800da00359SAntonio Quartulli get_random_bytes(&random_seqno, sizeof(random_seqno)); 8810da00359SAntonio Quartulli atomic_set(&bat_priv->bat_v.ogm_seqno, random_seqno); 8820da00359SAntonio Quartulli INIT_DELAYED_WORK(&bat_priv->bat_v.ogm_wq, batadv_v_ogm_send); 8830da00359SAntonio Quartulli 8840da00359SAntonio Quartulli return 0; 8850da00359SAntonio Quartulli } 8860da00359SAntonio Quartulli 8870da00359SAntonio Quartulli /** 8880da00359SAntonio Quartulli * batadv_v_ogm_free - free OGM private resources 8890da00359SAntonio Quartulli * @bat_priv: the bat priv with all the soft interface information 8900da00359SAntonio Quartulli */ 8910da00359SAntonio Quartulli void batadv_v_ogm_free(struct batadv_priv *bat_priv) 8920da00359SAntonio Quartulli { 8930da00359SAntonio Quartulli cancel_delayed_work_sync(&bat_priv->bat_v.ogm_wq); 8940da00359SAntonio Quartulli 8950da00359SAntonio Quartulli kfree(bat_priv->bat_v.ogm_buff); 8960da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff = NULL; 8970da00359SAntonio Quartulli bat_priv->bat_v.ogm_buff_len = 0; 8980da00359SAntonio Quartulli } 899