18c2ecf20Sopenharmony_ci// SPDX-License-Identifier: GPL-2.0 28c2ecf20Sopenharmony_ci/* Copyright (C) 2009-2020 B.A.T.M.A.N. contributors: 38c2ecf20Sopenharmony_ci * 48c2ecf20Sopenharmony_ci * Marek Lindner, Simon Wunderlich 58c2ecf20Sopenharmony_ci */ 68c2ecf20Sopenharmony_ci 78c2ecf20Sopenharmony_ci#include "originator.h" 88c2ecf20Sopenharmony_ci#include "main.h" 98c2ecf20Sopenharmony_ci 108c2ecf20Sopenharmony_ci#include <linux/atomic.h> 118c2ecf20Sopenharmony_ci#include <linux/errno.h> 128c2ecf20Sopenharmony_ci#include <linux/etherdevice.h> 138c2ecf20Sopenharmony_ci#include <linux/gfp.h> 148c2ecf20Sopenharmony_ci#include <linux/jiffies.h> 158c2ecf20Sopenharmony_ci#include <linux/kernel.h> 168c2ecf20Sopenharmony_ci#include <linux/kref.h> 178c2ecf20Sopenharmony_ci#include <linux/list.h> 188c2ecf20Sopenharmony_ci#include <linux/lockdep.h> 198c2ecf20Sopenharmony_ci#include <linux/netdevice.h> 208c2ecf20Sopenharmony_ci#include <linux/netlink.h> 218c2ecf20Sopenharmony_ci#include <linux/rculist.h> 228c2ecf20Sopenharmony_ci#include <linux/rcupdate.h> 238c2ecf20Sopenharmony_ci#include <linux/seq_file.h> 248c2ecf20Sopenharmony_ci#include <linux/skbuff.h> 258c2ecf20Sopenharmony_ci#include <linux/slab.h> 268c2ecf20Sopenharmony_ci#include <linux/spinlock.h> 278c2ecf20Sopenharmony_ci#include <linux/stddef.h> 288c2ecf20Sopenharmony_ci#include <linux/workqueue.h> 298c2ecf20Sopenharmony_ci#include <net/sock.h> 308c2ecf20Sopenharmony_ci#include <uapi/linux/batadv_packet.h> 318c2ecf20Sopenharmony_ci#include <uapi/linux/batman_adv.h> 328c2ecf20Sopenharmony_ci 338c2ecf20Sopenharmony_ci#include "bat_algo.h" 348c2ecf20Sopenharmony_ci#include "distributed-arp-table.h" 358c2ecf20Sopenharmony_ci#include "fragmentation.h" 368c2ecf20Sopenharmony_ci#include "gateway_client.h" 378c2ecf20Sopenharmony_ci#include "hard-interface.h" 388c2ecf20Sopenharmony_ci#include "hash.h" 398c2ecf20Sopenharmony_ci#include "log.h" 408c2ecf20Sopenharmony_ci#include "multicast.h" 418c2ecf20Sopenharmony_ci#include "netlink.h" 428c2ecf20Sopenharmony_ci#include "network-coding.h" 438c2ecf20Sopenharmony_ci#include "routing.h" 448c2ecf20Sopenharmony_ci#include "soft-interface.h" 458c2ecf20Sopenharmony_ci#include "translation-table.h" 468c2ecf20Sopenharmony_ci 478c2ecf20Sopenharmony_ci/* hash class keys */ 488c2ecf20Sopenharmony_cistatic struct lock_class_key batadv_orig_hash_lock_class_key; 498c2ecf20Sopenharmony_ci 508c2ecf20Sopenharmony_ci/** 518c2ecf20Sopenharmony_ci * batadv_orig_hash_find() - Find and return originator from orig_hash 528c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 538c2ecf20Sopenharmony_ci * @data: mac address of the originator 548c2ecf20Sopenharmony_ci * 558c2ecf20Sopenharmony_ci * Return: orig_node (with increased refcnt), NULL on errors 568c2ecf20Sopenharmony_ci */ 578c2ecf20Sopenharmony_cistruct batadv_orig_node * 588c2ecf20Sopenharmony_cibatadv_orig_hash_find(struct batadv_priv *bat_priv, const void *data) 598c2ecf20Sopenharmony_ci{ 608c2ecf20Sopenharmony_ci struct batadv_hashtable *hash = bat_priv->orig_hash; 618c2ecf20Sopenharmony_ci struct hlist_head *head; 628c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node, *orig_node_tmp = NULL; 638c2ecf20Sopenharmony_ci int index; 648c2ecf20Sopenharmony_ci 658c2ecf20Sopenharmony_ci if (!hash) 668c2ecf20Sopenharmony_ci return NULL; 678c2ecf20Sopenharmony_ci 688c2ecf20Sopenharmony_ci index = batadv_choose_orig(data, hash->size); 698c2ecf20Sopenharmony_ci head = &hash->table[index]; 708c2ecf20Sopenharmony_ci 718c2ecf20Sopenharmony_ci rcu_read_lock(); 728c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(orig_node, head, hash_entry) { 738c2ecf20Sopenharmony_ci if (!batadv_compare_eth(orig_node, data)) 748c2ecf20Sopenharmony_ci continue; 758c2ecf20Sopenharmony_ci 768c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&orig_node->refcount)) 778c2ecf20Sopenharmony_ci continue; 788c2ecf20Sopenharmony_ci 798c2ecf20Sopenharmony_ci orig_node_tmp = orig_node; 808c2ecf20Sopenharmony_ci break; 818c2ecf20Sopenharmony_ci } 828c2ecf20Sopenharmony_ci rcu_read_unlock(); 838c2ecf20Sopenharmony_ci 848c2ecf20Sopenharmony_ci return orig_node_tmp; 858c2ecf20Sopenharmony_ci} 868c2ecf20Sopenharmony_ci 878c2ecf20Sopenharmony_cistatic void batadv_purge_orig(struct work_struct *work); 888c2ecf20Sopenharmony_ci 898c2ecf20Sopenharmony_ci/** 908c2ecf20Sopenharmony_ci * batadv_compare_orig() - comparing function used in the originator hash table 918c2ecf20Sopenharmony_ci * @node: node in the local table 928c2ecf20Sopenharmony_ci * @data2: second object to compare the node to 938c2ecf20Sopenharmony_ci * 948c2ecf20Sopenharmony_ci * Return: true if they are the same originator 958c2ecf20Sopenharmony_ci */ 968c2ecf20Sopenharmony_cibool batadv_compare_orig(const struct hlist_node *node, const void *data2) 978c2ecf20Sopenharmony_ci{ 988c2ecf20Sopenharmony_ci const void *data1 = container_of(node, struct batadv_orig_node, 998c2ecf20Sopenharmony_ci hash_entry); 1008c2ecf20Sopenharmony_ci 1018c2ecf20Sopenharmony_ci return batadv_compare_eth(data1, data2); 1028c2ecf20Sopenharmony_ci} 1038c2ecf20Sopenharmony_ci 1048c2ecf20Sopenharmony_ci/** 1058c2ecf20Sopenharmony_ci * batadv_orig_node_vlan_get() - get an orig_node_vlan object 1068c2ecf20Sopenharmony_ci * @orig_node: the originator serving the VLAN 1078c2ecf20Sopenharmony_ci * @vid: the VLAN identifier 1088c2ecf20Sopenharmony_ci * 1098c2ecf20Sopenharmony_ci * Return: the vlan object identified by vid and belonging to orig_node or NULL 1108c2ecf20Sopenharmony_ci * if it does not exist. 1118c2ecf20Sopenharmony_ci */ 1128c2ecf20Sopenharmony_cistruct batadv_orig_node_vlan * 1138c2ecf20Sopenharmony_cibatadv_orig_node_vlan_get(struct batadv_orig_node *orig_node, 1148c2ecf20Sopenharmony_ci unsigned short vid) 1158c2ecf20Sopenharmony_ci{ 1168c2ecf20Sopenharmony_ci struct batadv_orig_node_vlan *vlan = NULL, *tmp; 1178c2ecf20Sopenharmony_ci 1188c2ecf20Sopenharmony_ci rcu_read_lock(); 1198c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(tmp, &orig_node->vlan_list, list) { 1208c2ecf20Sopenharmony_ci if (tmp->vid != vid) 1218c2ecf20Sopenharmony_ci continue; 1228c2ecf20Sopenharmony_ci 1238c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&tmp->refcount)) 1248c2ecf20Sopenharmony_ci continue; 1258c2ecf20Sopenharmony_ci 1268c2ecf20Sopenharmony_ci vlan = tmp; 1278c2ecf20Sopenharmony_ci 1288c2ecf20Sopenharmony_ci break; 1298c2ecf20Sopenharmony_ci } 1308c2ecf20Sopenharmony_ci rcu_read_unlock(); 1318c2ecf20Sopenharmony_ci 1328c2ecf20Sopenharmony_ci return vlan; 1338c2ecf20Sopenharmony_ci} 1348c2ecf20Sopenharmony_ci 1358c2ecf20Sopenharmony_ci/** 1368c2ecf20Sopenharmony_ci * batadv_orig_node_vlan_new() - search and possibly create an orig_node_vlan 1378c2ecf20Sopenharmony_ci * object 1388c2ecf20Sopenharmony_ci * @orig_node: the originator serving the VLAN 1398c2ecf20Sopenharmony_ci * @vid: the VLAN identifier 1408c2ecf20Sopenharmony_ci * 1418c2ecf20Sopenharmony_ci * Return: NULL in case of failure or the vlan object identified by vid and 1428c2ecf20Sopenharmony_ci * belonging to orig_node otherwise. The object is created and added to the list 1438c2ecf20Sopenharmony_ci * if it does not exist. 1448c2ecf20Sopenharmony_ci * 1458c2ecf20Sopenharmony_ci * The object is returned with refcounter increased by 1. 1468c2ecf20Sopenharmony_ci */ 1478c2ecf20Sopenharmony_cistruct batadv_orig_node_vlan * 1488c2ecf20Sopenharmony_cibatadv_orig_node_vlan_new(struct batadv_orig_node *orig_node, 1498c2ecf20Sopenharmony_ci unsigned short vid) 1508c2ecf20Sopenharmony_ci{ 1518c2ecf20Sopenharmony_ci struct batadv_orig_node_vlan *vlan; 1528c2ecf20Sopenharmony_ci 1538c2ecf20Sopenharmony_ci spin_lock_bh(&orig_node->vlan_list_lock); 1548c2ecf20Sopenharmony_ci 1558c2ecf20Sopenharmony_ci /* first look if an object for this vid already exists */ 1568c2ecf20Sopenharmony_ci vlan = batadv_orig_node_vlan_get(orig_node, vid); 1578c2ecf20Sopenharmony_ci if (vlan) 1588c2ecf20Sopenharmony_ci goto out; 1598c2ecf20Sopenharmony_ci 1608c2ecf20Sopenharmony_ci vlan = kzalloc(sizeof(*vlan), GFP_ATOMIC); 1618c2ecf20Sopenharmony_ci if (!vlan) 1628c2ecf20Sopenharmony_ci goto out; 1638c2ecf20Sopenharmony_ci 1648c2ecf20Sopenharmony_ci kref_init(&vlan->refcount); 1658c2ecf20Sopenharmony_ci vlan->vid = vid; 1668c2ecf20Sopenharmony_ci 1678c2ecf20Sopenharmony_ci kref_get(&vlan->refcount); 1688c2ecf20Sopenharmony_ci hlist_add_head_rcu(&vlan->list, &orig_node->vlan_list); 1698c2ecf20Sopenharmony_ci 1708c2ecf20Sopenharmony_ciout: 1718c2ecf20Sopenharmony_ci spin_unlock_bh(&orig_node->vlan_list_lock); 1728c2ecf20Sopenharmony_ci 1738c2ecf20Sopenharmony_ci return vlan; 1748c2ecf20Sopenharmony_ci} 1758c2ecf20Sopenharmony_ci 1768c2ecf20Sopenharmony_ci/** 1778c2ecf20Sopenharmony_ci * batadv_orig_node_vlan_release() - release originator-vlan object from lists 1788c2ecf20Sopenharmony_ci * and queue for free after rcu grace period 1798c2ecf20Sopenharmony_ci * @ref: kref pointer of the originator-vlan object 1808c2ecf20Sopenharmony_ci */ 1818c2ecf20Sopenharmony_civoid batadv_orig_node_vlan_release(struct kref *ref) 1828c2ecf20Sopenharmony_ci{ 1838c2ecf20Sopenharmony_ci struct batadv_orig_node_vlan *orig_vlan; 1848c2ecf20Sopenharmony_ci 1858c2ecf20Sopenharmony_ci orig_vlan = container_of(ref, struct batadv_orig_node_vlan, refcount); 1868c2ecf20Sopenharmony_ci 1878c2ecf20Sopenharmony_ci kfree_rcu(orig_vlan, rcu); 1888c2ecf20Sopenharmony_ci} 1898c2ecf20Sopenharmony_ci 1908c2ecf20Sopenharmony_ci/** 1918c2ecf20Sopenharmony_ci * batadv_originator_init() - Initialize all originator structures 1928c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 1938c2ecf20Sopenharmony_ci * 1948c2ecf20Sopenharmony_ci * Return: 0 on success or negative error number in case of failure 1958c2ecf20Sopenharmony_ci */ 1968c2ecf20Sopenharmony_ciint batadv_originator_init(struct batadv_priv *bat_priv) 1978c2ecf20Sopenharmony_ci{ 1988c2ecf20Sopenharmony_ci if (bat_priv->orig_hash) 1998c2ecf20Sopenharmony_ci return 0; 2008c2ecf20Sopenharmony_ci 2018c2ecf20Sopenharmony_ci bat_priv->orig_hash = batadv_hash_new(1024); 2028c2ecf20Sopenharmony_ci 2038c2ecf20Sopenharmony_ci if (!bat_priv->orig_hash) 2048c2ecf20Sopenharmony_ci goto err; 2058c2ecf20Sopenharmony_ci 2068c2ecf20Sopenharmony_ci batadv_hash_set_lock_class(bat_priv->orig_hash, 2078c2ecf20Sopenharmony_ci &batadv_orig_hash_lock_class_key); 2088c2ecf20Sopenharmony_ci 2098c2ecf20Sopenharmony_ci INIT_DELAYED_WORK(&bat_priv->orig_work, batadv_purge_orig); 2108c2ecf20Sopenharmony_ci queue_delayed_work(batadv_event_workqueue, 2118c2ecf20Sopenharmony_ci &bat_priv->orig_work, 2128c2ecf20Sopenharmony_ci msecs_to_jiffies(BATADV_ORIG_WORK_PERIOD)); 2138c2ecf20Sopenharmony_ci 2148c2ecf20Sopenharmony_ci return 0; 2158c2ecf20Sopenharmony_ci 2168c2ecf20Sopenharmony_cierr: 2178c2ecf20Sopenharmony_ci return -ENOMEM; 2188c2ecf20Sopenharmony_ci} 2198c2ecf20Sopenharmony_ci 2208c2ecf20Sopenharmony_ci/** 2218c2ecf20Sopenharmony_ci * batadv_neigh_ifinfo_release() - release neigh_ifinfo from lists and queue for 2228c2ecf20Sopenharmony_ci * free after rcu grace period 2238c2ecf20Sopenharmony_ci * @ref: kref pointer of the neigh_ifinfo 2248c2ecf20Sopenharmony_ci */ 2258c2ecf20Sopenharmony_civoid batadv_neigh_ifinfo_release(struct kref *ref) 2268c2ecf20Sopenharmony_ci{ 2278c2ecf20Sopenharmony_ci struct batadv_neigh_ifinfo *neigh_ifinfo; 2288c2ecf20Sopenharmony_ci 2298c2ecf20Sopenharmony_ci neigh_ifinfo = container_of(ref, struct batadv_neigh_ifinfo, refcount); 2308c2ecf20Sopenharmony_ci 2318c2ecf20Sopenharmony_ci if (neigh_ifinfo->if_outgoing != BATADV_IF_DEFAULT) 2328c2ecf20Sopenharmony_ci batadv_hardif_put(neigh_ifinfo->if_outgoing); 2338c2ecf20Sopenharmony_ci 2348c2ecf20Sopenharmony_ci kfree_rcu(neigh_ifinfo, rcu); 2358c2ecf20Sopenharmony_ci} 2368c2ecf20Sopenharmony_ci 2378c2ecf20Sopenharmony_ci/** 2388c2ecf20Sopenharmony_ci * batadv_hardif_neigh_release() - release hardif neigh node from lists and 2398c2ecf20Sopenharmony_ci * queue for free after rcu grace period 2408c2ecf20Sopenharmony_ci * @ref: kref pointer of the neigh_node 2418c2ecf20Sopenharmony_ci */ 2428c2ecf20Sopenharmony_civoid batadv_hardif_neigh_release(struct kref *ref) 2438c2ecf20Sopenharmony_ci{ 2448c2ecf20Sopenharmony_ci struct batadv_hardif_neigh_node *hardif_neigh; 2458c2ecf20Sopenharmony_ci 2468c2ecf20Sopenharmony_ci hardif_neigh = container_of(ref, struct batadv_hardif_neigh_node, 2478c2ecf20Sopenharmony_ci refcount); 2488c2ecf20Sopenharmony_ci 2498c2ecf20Sopenharmony_ci spin_lock_bh(&hardif_neigh->if_incoming->neigh_list_lock); 2508c2ecf20Sopenharmony_ci hlist_del_init_rcu(&hardif_neigh->list); 2518c2ecf20Sopenharmony_ci spin_unlock_bh(&hardif_neigh->if_incoming->neigh_list_lock); 2528c2ecf20Sopenharmony_ci 2538c2ecf20Sopenharmony_ci batadv_hardif_put(hardif_neigh->if_incoming); 2548c2ecf20Sopenharmony_ci kfree_rcu(hardif_neigh, rcu); 2558c2ecf20Sopenharmony_ci} 2568c2ecf20Sopenharmony_ci 2578c2ecf20Sopenharmony_ci/** 2588c2ecf20Sopenharmony_ci * batadv_neigh_node_release() - release neigh_node from lists and queue for 2598c2ecf20Sopenharmony_ci * free after rcu grace period 2608c2ecf20Sopenharmony_ci * @ref: kref pointer of the neigh_node 2618c2ecf20Sopenharmony_ci */ 2628c2ecf20Sopenharmony_civoid batadv_neigh_node_release(struct kref *ref) 2638c2ecf20Sopenharmony_ci{ 2648c2ecf20Sopenharmony_ci struct hlist_node *node_tmp; 2658c2ecf20Sopenharmony_ci struct batadv_neigh_node *neigh_node; 2668c2ecf20Sopenharmony_ci struct batadv_neigh_ifinfo *neigh_ifinfo; 2678c2ecf20Sopenharmony_ci 2688c2ecf20Sopenharmony_ci neigh_node = container_of(ref, struct batadv_neigh_node, refcount); 2698c2ecf20Sopenharmony_ci 2708c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(neigh_ifinfo, node_tmp, 2718c2ecf20Sopenharmony_ci &neigh_node->ifinfo_list, list) { 2728c2ecf20Sopenharmony_ci batadv_neigh_ifinfo_put(neigh_ifinfo); 2738c2ecf20Sopenharmony_ci } 2748c2ecf20Sopenharmony_ci 2758c2ecf20Sopenharmony_ci batadv_hardif_neigh_put(neigh_node->hardif_neigh); 2768c2ecf20Sopenharmony_ci 2778c2ecf20Sopenharmony_ci batadv_hardif_put(neigh_node->if_incoming); 2788c2ecf20Sopenharmony_ci 2798c2ecf20Sopenharmony_ci kfree_rcu(neigh_node, rcu); 2808c2ecf20Sopenharmony_ci} 2818c2ecf20Sopenharmony_ci 2828c2ecf20Sopenharmony_ci/** 2838c2ecf20Sopenharmony_ci * batadv_orig_router_get() - router to the originator depending on iface 2848c2ecf20Sopenharmony_ci * @orig_node: the orig node for the router 2858c2ecf20Sopenharmony_ci * @if_outgoing: the interface where the payload packet has been received or 2868c2ecf20Sopenharmony_ci * the OGM should be sent to 2878c2ecf20Sopenharmony_ci * 2888c2ecf20Sopenharmony_ci * Return: the neighbor which should be the router for this orig_node/iface. 2898c2ecf20Sopenharmony_ci * 2908c2ecf20Sopenharmony_ci * The object is returned with refcounter increased by 1. 2918c2ecf20Sopenharmony_ci */ 2928c2ecf20Sopenharmony_cistruct batadv_neigh_node * 2938c2ecf20Sopenharmony_cibatadv_orig_router_get(struct batadv_orig_node *orig_node, 2948c2ecf20Sopenharmony_ci const struct batadv_hard_iface *if_outgoing) 2958c2ecf20Sopenharmony_ci{ 2968c2ecf20Sopenharmony_ci struct batadv_orig_ifinfo *orig_ifinfo; 2978c2ecf20Sopenharmony_ci struct batadv_neigh_node *router = NULL; 2988c2ecf20Sopenharmony_ci 2998c2ecf20Sopenharmony_ci rcu_read_lock(); 3008c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(orig_ifinfo, &orig_node->ifinfo_list, list) { 3018c2ecf20Sopenharmony_ci if (orig_ifinfo->if_outgoing != if_outgoing) 3028c2ecf20Sopenharmony_ci continue; 3038c2ecf20Sopenharmony_ci 3048c2ecf20Sopenharmony_ci router = rcu_dereference(orig_ifinfo->router); 3058c2ecf20Sopenharmony_ci break; 3068c2ecf20Sopenharmony_ci } 3078c2ecf20Sopenharmony_ci 3088c2ecf20Sopenharmony_ci if (router && !kref_get_unless_zero(&router->refcount)) 3098c2ecf20Sopenharmony_ci router = NULL; 3108c2ecf20Sopenharmony_ci 3118c2ecf20Sopenharmony_ci rcu_read_unlock(); 3128c2ecf20Sopenharmony_ci return router; 3138c2ecf20Sopenharmony_ci} 3148c2ecf20Sopenharmony_ci 3158c2ecf20Sopenharmony_ci/** 3168c2ecf20Sopenharmony_ci * batadv_orig_ifinfo_get() - find the ifinfo from an orig_node 3178c2ecf20Sopenharmony_ci * @orig_node: the orig node to be queried 3188c2ecf20Sopenharmony_ci * @if_outgoing: the interface for which the ifinfo should be acquired 3198c2ecf20Sopenharmony_ci * 3208c2ecf20Sopenharmony_ci * Return: the requested orig_ifinfo or NULL if not found. 3218c2ecf20Sopenharmony_ci * 3228c2ecf20Sopenharmony_ci * The object is returned with refcounter increased by 1. 3238c2ecf20Sopenharmony_ci */ 3248c2ecf20Sopenharmony_cistruct batadv_orig_ifinfo * 3258c2ecf20Sopenharmony_cibatadv_orig_ifinfo_get(struct batadv_orig_node *orig_node, 3268c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_outgoing) 3278c2ecf20Sopenharmony_ci{ 3288c2ecf20Sopenharmony_ci struct batadv_orig_ifinfo *tmp, *orig_ifinfo = NULL; 3298c2ecf20Sopenharmony_ci 3308c2ecf20Sopenharmony_ci rcu_read_lock(); 3318c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(tmp, &orig_node->ifinfo_list, 3328c2ecf20Sopenharmony_ci list) { 3338c2ecf20Sopenharmony_ci if (tmp->if_outgoing != if_outgoing) 3348c2ecf20Sopenharmony_ci continue; 3358c2ecf20Sopenharmony_ci 3368c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&tmp->refcount)) 3378c2ecf20Sopenharmony_ci continue; 3388c2ecf20Sopenharmony_ci 3398c2ecf20Sopenharmony_ci orig_ifinfo = tmp; 3408c2ecf20Sopenharmony_ci break; 3418c2ecf20Sopenharmony_ci } 3428c2ecf20Sopenharmony_ci rcu_read_unlock(); 3438c2ecf20Sopenharmony_ci 3448c2ecf20Sopenharmony_ci return orig_ifinfo; 3458c2ecf20Sopenharmony_ci} 3468c2ecf20Sopenharmony_ci 3478c2ecf20Sopenharmony_ci/** 3488c2ecf20Sopenharmony_ci * batadv_orig_ifinfo_new() - search and possibly create an orig_ifinfo object 3498c2ecf20Sopenharmony_ci * @orig_node: the orig node to be queried 3508c2ecf20Sopenharmony_ci * @if_outgoing: the interface for which the ifinfo should be acquired 3518c2ecf20Sopenharmony_ci * 3528c2ecf20Sopenharmony_ci * Return: NULL in case of failure or the orig_ifinfo object for the if_outgoing 3538c2ecf20Sopenharmony_ci * interface otherwise. The object is created and added to the list 3548c2ecf20Sopenharmony_ci * if it does not exist. 3558c2ecf20Sopenharmony_ci * 3568c2ecf20Sopenharmony_ci * The object is returned with refcounter increased by 1. 3578c2ecf20Sopenharmony_ci */ 3588c2ecf20Sopenharmony_cistruct batadv_orig_ifinfo * 3598c2ecf20Sopenharmony_cibatadv_orig_ifinfo_new(struct batadv_orig_node *orig_node, 3608c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_outgoing) 3618c2ecf20Sopenharmony_ci{ 3628c2ecf20Sopenharmony_ci struct batadv_orig_ifinfo *orig_ifinfo; 3638c2ecf20Sopenharmony_ci unsigned long reset_time; 3648c2ecf20Sopenharmony_ci 3658c2ecf20Sopenharmony_ci spin_lock_bh(&orig_node->neigh_list_lock); 3668c2ecf20Sopenharmony_ci 3678c2ecf20Sopenharmony_ci orig_ifinfo = batadv_orig_ifinfo_get(orig_node, if_outgoing); 3688c2ecf20Sopenharmony_ci if (orig_ifinfo) 3698c2ecf20Sopenharmony_ci goto out; 3708c2ecf20Sopenharmony_ci 3718c2ecf20Sopenharmony_ci orig_ifinfo = kzalloc(sizeof(*orig_ifinfo), GFP_ATOMIC); 3728c2ecf20Sopenharmony_ci if (!orig_ifinfo) 3738c2ecf20Sopenharmony_ci goto out; 3748c2ecf20Sopenharmony_ci 3758c2ecf20Sopenharmony_ci if (if_outgoing != BATADV_IF_DEFAULT) 3768c2ecf20Sopenharmony_ci kref_get(&if_outgoing->refcount); 3778c2ecf20Sopenharmony_ci 3788c2ecf20Sopenharmony_ci reset_time = jiffies - 1; 3798c2ecf20Sopenharmony_ci reset_time -= msecs_to_jiffies(BATADV_RESET_PROTECTION_MS); 3808c2ecf20Sopenharmony_ci orig_ifinfo->batman_seqno_reset = reset_time; 3818c2ecf20Sopenharmony_ci orig_ifinfo->if_outgoing = if_outgoing; 3828c2ecf20Sopenharmony_ci INIT_HLIST_NODE(&orig_ifinfo->list); 3838c2ecf20Sopenharmony_ci kref_init(&orig_ifinfo->refcount); 3848c2ecf20Sopenharmony_ci 3858c2ecf20Sopenharmony_ci kref_get(&orig_ifinfo->refcount); 3868c2ecf20Sopenharmony_ci hlist_add_head_rcu(&orig_ifinfo->list, 3878c2ecf20Sopenharmony_ci &orig_node->ifinfo_list); 3888c2ecf20Sopenharmony_ciout: 3898c2ecf20Sopenharmony_ci spin_unlock_bh(&orig_node->neigh_list_lock); 3908c2ecf20Sopenharmony_ci return orig_ifinfo; 3918c2ecf20Sopenharmony_ci} 3928c2ecf20Sopenharmony_ci 3938c2ecf20Sopenharmony_ci/** 3948c2ecf20Sopenharmony_ci * batadv_neigh_ifinfo_get() - find the ifinfo from an neigh_node 3958c2ecf20Sopenharmony_ci * @neigh: the neigh node to be queried 3968c2ecf20Sopenharmony_ci * @if_outgoing: the interface for which the ifinfo should be acquired 3978c2ecf20Sopenharmony_ci * 3988c2ecf20Sopenharmony_ci * The object is returned with refcounter increased by 1. 3998c2ecf20Sopenharmony_ci * 4008c2ecf20Sopenharmony_ci * Return: the requested neigh_ifinfo or NULL if not found 4018c2ecf20Sopenharmony_ci */ 4028c2ecf20Sopenharmony_cistruct batadv_neigh_ifinfo * 4038c2ecf20Sopenharmony_cibatadv_neigh_ifinfo_get(struct batadv_neigh_node *neigh, 4048c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_outgoing) 4058c2ecf20Sopenharmony_ci{ 4068c2ecf20Sopenharmony_ci struct batadv_neigh_ifinfo *neigh_ifinfo = NULL, 4078c2ecf20Sopenharmony_ci *tmp_neigh_ifinfo; 4088c2ecf20Sopenharmony_ci 4098c2ecf20Sopenharmony_ci rcu_read_lock(); 4108c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(tmp_neigh_ifinfo, &neigh->ifinfo_list, 4118c2ecf20Sopenharmony_ci list) { 4128c2ecf20Sopenharmony_ci if (tmp_neigh_ifinfo->if_outgoing != if_outgoing) 4138c2ecf20Sopenharmony_ci continue; 4148c2ecf20Sopenharmony_ci 4158c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&tmp_neigh_ifinfo->refcount)) 4168c2ecf20Sopenharmony_ci continue; 4178c2ecf20Sopenharmony_ci 4188c2ecf20Sopenharmony_ci neigh_ifinfo = tmp_neigh_ifinfo; 4198c2ecf20Sopenharmony_ci break; 4208c2ecf20Sopenharmony_ci } 4218c2ecf20Sopenharmony_ci rcu_read_unlock(); 4228c2ecf20Sopenharmony_ci 4238c2ecf20Sopenharmony_ci return neigh_ifinfo; 4248c2ecf20Sopenharmony_ci} 4258c2ecf20Sopenharmony_ci 4268c2ecf20Sopenharmony_ci/** 4278c2ecf20Sopenharmony_ci * batadv_neigh_ifinfo_new() - search and possibly create an neigh_ifinfo object 4288c2ecf20Sopenharmony_ci * @neigh: the neigh node to be queried 4298c2ecf20Sopenharmony_ci * @if_outgoing: the interface for which the ifinfo should be acquired 4308c2ecf20Sopenharmony_ci * 4318c2ecf20Sopenharmony_ci * Return: NULL in case of failure or the neigh_ifinfo object for the 4328c2ecf20Sopenharmony_ci * if_outgoing interface otherwise. The object is created and added to the list 4338c2ecf20Sopenharmony_ci * if it does not exist. 4348c2ecf20Sopenharmony_ci * 4358c2ecf20Sopenharmony_ci * The object is returned with refcounter increased by 1. 4368c2ecf20Sopenharmony_ci */ 4378c2ecf20Sopenharmony_cistruct batadv_neigh_ifinfo * 4388c2ecf20Sopenharmony_cibatadv_neigh_ifinfo_new(struct batadv_neigh_node *neigh, 4398c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_outgoing) 4408c2ecf20Sopenharmony_ci{ 4418c2ecf20Sopenharmony_ci struct batadv_neigh_ifinfo *neigh_ifinfo; 4428c2ecf20Sopenharmony_ci 4438c2ecf20Sopenharmony_ci spin_lock_bh(&neigh->ifinfo_lock); 4448c2ecf20Sopenharmony_ci 4458c2ecf20Sopenharmony_ci neigh_ifinfo = batadv_neigh_ifinfo_get(neigh, if_outgoing); 4468c2ecf20Sopenharmony_ci if (neigh_ifinfo) 4478c2ecf20Sopenharmony_ci goto out; 4488c2ecf20Sopenharmony_ci 4498c2ecf20Sopenharmony_ci neigh_ifinfo = kzalloc(sizeof(*neigh_ifinfo), GFP_ATOMIC); 4508c2ecf20Sopenharmony_ci if (!neigh_ifinfo) 4518c2ecf20Sopenharmony_ci goto out; 4528c2ecf20Sopenharmony_ci 4538c2ecf20Sopenharmony_ci if (if_outgoing) 4548c2ecf20Sopenharmony_ci kref_get(&if_outgoing->refcount); 4558c2ecf20Sopenharmony_ci 4568c2ecf20Sopenharmony_ci INIT_HLIST_NODE(&neigh_ifinfo->list); 4578c2ecf20Sopenharmony_ci kref_init(&neigh_ifinfo->refcount); 4588c2ecf20Sopenharmony_ci neigh_ifinfo->if_outgoing = if_outgoing; 4598c2ecf20Sopenharmony_ci 4608c2ecf20Sopenharmony_ci kref_get(&neigh_ifinfo->refcount); 4618c2ecf20Sopenharmony_ci hlist_add_head_rcu(&neigh_ifinfo->list, &neigh->ifinfo_list); 4628c2ecf20Sopenharmony_ci 4638c2ecf20Sopenharmony_ciout: 4648c2ecf20Sopenharmony_ci spin_unlock_bh(&neigh->ifinfo_lock); 4658c2ecf20Sopenharmony_ci 4668c2ecf20Sopenharmony_ci return neigh_ifinfo; 4678c2ecf20Sopenharmony_ci} 4688c2ecf20Sopenharmony_ci 4698c2ecf20Sopenharmony_ci/** 4708c2ecf20Sopenharmony_ci * batadv_neigh_node_get() - retrieve a neighbour from the list 4718c2ecf20Sopenharmony_ci * @orig_node: originator which the neighbour belongs to 4728c2ecf20Sopenharmony_ci * @hard_iface: the interface where this neighbour is connected to 4738c2ecf20Sopenharmony_ci * @addr: the address of the neighbour 4748c2ecf20Sopenharmony_ci * 4758c2ecf20Sopenharmony_ci * Looks for and possibly returns a neighbour belonging to this originator list 4768c2ecf20Sopenharmony_ci * which is connected through the provided hard interface. 4778c2ecf20Sopenharmony_ci * 4788c2ecf20Sopenharmony_ci * Return: neighbor when found. Otherwise NULL 4798c2ecf20Sopenharmony_ci */ 4808c2ecf20Sopenharmony_cistatic struct batadv_neigh_node * 4818c2ecf20Sopenharmony_cibatadv_neigh_node_get(const struct batadv_orig_node *orig_node, 4828c2ecf20Sopenharmony_ci const struct batadv_hard_iface *hard_iface, 4838c2ecf20Sopenharmony_ci const u8 *addr) 4848c2ecf20Sopenharmony_ci{ 4858c2ecf20Sopenharmony_ci struct batadv_neigh_node *tmp_neigh_node, *res = NULL; 4868c2ecf20Sopenharmony_ci 4878c2ecf20Sopenharmony_ci rcu_read_lock(); 4888c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(tmp_neigh_node, &orig_node->neigh_list, list) { 4898c2ecf20Sopenharmony_ci if (!batadv_compare_eth(tmp_neigh_node->addr, addr)) 4908c2ecf20Sopenharmony_ci continue; 4918c2ecf20Sopenharmony_ci 4928c2ecf20Sopenharmony_ci if (tmp_neigh_node->if_incoming != hard_iface) 4938c2ecf20Sopenharmony_ci continue; 4948c2ecf20Sopenharmony_ci 4958c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&tmp_neigh_node->refcount)) 4968c2ecf20Sopenharmony_ci continue; 4978c2ecf20Sopenharmony_ci 4988c2ecf20Sopenharmony_ci res = tmp_neigh_node; 4998c2ecf20Sopenharmony_ci break; 5008c2ecf20Sopenharmony_ci } 5018c2ecf20Sopenharmony_ci rcu_read_unlock(); 5028c2ecf20Sopenharmony_ci 5038c2ecf20Sopenharmony_ci return res; 5048c2ecf20Sopenharmony_ci} 5058c2ecf20Sopenharmony_ci 5068c2ecf20Sopenharmony_ci/** 5078c2ecf20Sopenharmony_ci * batadv_hardif_neigh_create() - create a hardif neighbour node 5088c2ecf20Sopenharmony_ci * @hard_iface: the interface this neighbour is connected to 5098c2ecf20Sopenharmony_ci * @neigh_addr: the interface address of the neighbour to retrieve 5108c2ecf20Sopenharmony_ci * @orig_node: originator object representing the neighbour 5118c2ecf20Sopenharmony_ci * 5128c2ecf20Sopenharmony_ci * Return: the hardif neighbour node if found or created or NULL otherwise. 5138c2ecf20Sopenharmony_ci */ 5148c2ecf20Sopenharmony_cistatic struct batadv_hardif_neigh_node * 5158c2ecf20Sopenharmony_cibatadv_hardif_neigh_create(struct batadv_hard_iface *hard_iface, 5168c2ecf20Sopenharmony_ci const u8 *neigh_addr, 5178c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node) 5188c2ecf20Sopenharmony_ci{ 5198c2ecf20Sopenharmony_ci struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); 5208c2ecf20Sopenharmony_ci struct batadv_hardif_neigh_node *hardif_neigh; 5218c2ecf20Sopenharmony_ci 5228c2ecf20Sopenharmony_ci spin_lock_bh(&hard_iface->neigh_list_lock); 5238c2ecf20Sopenharmony_ci 5248c2ecf20Sopenharmony_ci /* check if neighbor hasn't been added in the meantime */ 5258c2ecf20Sopenharmony_ci hardif_neigh = batadv_hardif_neigh_get(hard_iface, neigh_addr); 5268c2ecf20Sopenharmony_ci if (hardif_neigh) 5278c2ecf20Sopenharmony_ci goto out; 5288c2ecf20Sopenharmony_ci 5298c2ecf20Sopenharmony_ci hardif_neigh = kzalloc(sizeof(*hardif_neigh), GFP_ATOMIC); 5308c2ecf20Sopenharmony_ci if (!hardif_neigh) 5318c2ecf20Sopenharmony_ci goto out; 5328c2ecf20Sopenharmony_ci 5338c2ecf20Sopenharmony_ci kref_get(&hard_iface->refcount); 5348c2ecf20Sopenharmony_ci INIT_HLIST_NODE(&hardif_neigh->list); 5358c2ecf20Sopenharmony_ci ether_addr_copy(hardif_neigh->addr, neigh_addr); 5368c2ecf20Sopenharmony_ci ether_addr_copy(hardif_neigh->orig, orig_node->orig); 5378c2ecf20Sopenharmony_ci hardif_neigh->if_incoming = hard_iface; 5388c2ecf20Sopenharmony_ci hardif_neigh->last_seen = jiffies; 5398c2ecf20Sopenharmony_ci 5408c2ecf20Sopenharmony_ci kref_init(&hardif_neigh->refcount); 5418c2ecf20Sopenharmony_ci 5428c2ecf20Sopenharmony_ci if (bat_priv->algo_ops->neigh.hardif_init) 5438c2ecf20Sopenharmony_ci bat_priv->algo_ops->neigh.hardif_init(hardif_neigh); 5448c2ecf20Sopenharmony_ci 5458c2ecf20Sopenharmony_ci hlist_add_head_rcu(&hardif_neigh->list, &hard_iface->neigh_list); 5468c2ecf20Sopenharmony_ci 5478c2ecf20Sopenharmony_ciout: 5488c2ecf20Sopenharmony_ci spin_unlock_bh(&hard_iface->neigh_list_lock); 5498c2ecf20Sopenharmony_ci return hardif_neigh; 5508c2ecf20Sopenharmony_ci} 5518c2ecf20Sopenharmony_ci 5528c2ecf20Sopenharmony_ci/** 5538c2ecf20Sopenharmony_ci * batadv_hardif_neigh_get_or_create() - retrieve or create a hardif neighbour 5548c2ecf20Sopenharmony_ci * node 5558c2ecf20Sopenharmony_ci * @hard_iface: the interface this neighbour is connected to 5568c2ecf20Sopenharmony_ci * @neigh_addr: the interface address of the neighbour to retrieve 5578c2ecf20Sopenharmony_ci * @orig_node: originator object representing the neighbour 5588c2ecf20Sopenharmony_ci * 5598c2ecf20Sopenharmony_ci * Return: the hardif neighbour node if found or created or NULL otherwise. 5608c2ecf20Sopenharmony_ci */ 5618c2ecf20Sopenharmony_cistatic struct batadv_hardif_neigh_node * 5628c2ecf20Sopenharmony_cibatadv_hardif_neigh_get_or_create(struct batadv_hard_iface *hard_iface, 5638c2ecf20Sopenharmony_ci const u8 *neigh_addr, 5648c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node) 5658c2ecf20Sopenharmony_ci{ 5668c2ecf20Sopenharmony_ci struct batadv_hardif_neigh_node *hardif_neigh; 5678c2ecf20Sopenharmony_ci 5688c2ecf20Sopenharmony_ci /* first check without locking to avoid the overhead */ 5698c2ecf20Sopenharmony_ci hardif_neigh = batadv_hardif_neigh_get(hard_iface, neigh_addr); 5708c2ecf20Sopenharmony_ci if (hardif_neigh) 5718c2ecf20Sopenharmony_ci return hardif_neigh; 5728c2ecf20Sopenharmony_ci 5738c2ecf20Sopenharmony_ci return batadv_hardif_neigh_create(hard_iface, neigh_addr, orig_node); 5748c2ecf20Sopenharmony_ci} 5758c2ecf20Sopenharmony_ci 5768c2ecf20Sopenharmony_ci/** 5778c2ecf20Sopenharmony_ci * batadv_hardif_neigh_get() - retrieve a hardif neighbour from the list 5788c2ecf20Sopenharmony_ci * @hard_iface: the interface where this neighbour is connected to 5798c2ecf20Sopenharmony_ci * @neigh_addr: the address of the neighbour 5808c2ecf20Sopenharmony_ci * 5818c2ecf20Sopenharmony_ci * Looks for and possibly returns a neighbour belonging to this hard interface. 5828c2ecf20Sopenharmony_ci * 5838c2ecf20Sopenharmony_ci * Return: neighbor when found. Otherwise NULL 5848c2ecf20Sopenharmony_ci */ 5858c2ecf20Sopenharmony_cistruct batadv_hardif_neigh_node * 5868c2ecf20Sopenharmony_cibatadv_hardif_neigh_get(const struct batadv_hard_iface *hard_iface, 5878c2ecf20Sopenharmony_ci const u8 *neigh_addr) 5888c2ecf20Sopenharmony_ci{ 5898c2ecf20Sopenharmony_ci struct batadv_hardif_neigh_node *tmp_hardif_neigh, *hardif_neigh = NULL; 5908c2ecf20Sopenharmony_ci 5918c2ecf20Sopenharmony_ci rcu_read_lock(); 5928c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(tmp_hardif_neigh, 5938c2ecf20Sopenharmony_ci &hard_iface->neigh_list, list) { 5948c2ecf20Sopenharmony_ci if (!batadv_compare_eth(tmp_hardif_neigh->addr, neigh_addr)) 5958c2ecf20Sopenharmony_ci continue; 5968c2ecf20Sopenharmony_ci 5978c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&tmp_hardif_neigh->refcount)) 5988c2ecf20Sopenharmony_ci continue; 5998c2ecf20Sopenharmony_ci 6008c2ecf20Sopenharmony_ci hardif_neigh = tmp_hardif_neigh; 6018c2ecf20Sopenharmony_ci break; 6028c2ecf20Sopenharmony_ci } 6038c2ecf20Sopenharmony_ci rcu_read_unlock(); 6048c2ecf20Sopenharmony_ci 6058c2ecf20Sopenharmony_ci return hardif_neigh; 6068c2ecf20Sopenharmony_ci} 6078c2ecf20Sopenharmony_ci 6088c2ecf20Sopenharmony_ci/** 6098c2ecf20Sopenharmony_ci * batadv_neigh_node_create() - create a neigh node object 6108c2ecf20Sopenharmony_ci * @orig_node: originator object representing the neighbour 6118c2ecf20Sopenharmony_ci * @hard_iface: the interface where the neighbour is connected to 6128c2ecf20Sopenharmony_ci * @neigh_addr: the mac address of the neighbour interface 6138c2ecf20Sopenharmony_ci * 6148c2ecf20Sopenharmony_ci * Allocates a new neigh_node object and initialises all the generic fields. 6158c2ecf20Sopenharmony_ci * 6168c2ecf20Sopenharmony_ci * Return: the neighbour node if found or created or NULL otherwise. 6178c2ecf20Sopenharmony_ci */ 6188c2ecf20Sopenharmony_cistatic struct batadv_neigh_node * 6198c2ecf20Sopenharmony_cibatadv_neigh_node_create(struct batadv_orig_node *orig_node, 6208c2ecf20Sopenharmony_ci struct batadv_hard_iface *hard_iface, 6218c2ecf20Sopenharmony_ci const u8 *neigh_addr) 6228c2ecf20Sopenharmony_ci{ 6238c2ecf20Sopenharmony_ci struct batadv_neigh_node *neigh_node; 6248c2ecf20Sopenharmony_ci struct batadv_hardif_neigh_node *hardif_neigh = NULL; 6258c2ecf20Sopenharmony_ci 6268c2ecf20Sopenharmony_ci spin_lock_bh(&orig_node->neigh_list_lock); 6278c2ecf20Sopenharmony_ci 6288c2ecf20Sopenharmony_ci neigh_node = batadv_neigh_node_get(orig_node, hard_iface, neigh_addr); 6298c2ecf20Sopenharmony_ci if (neigh_node) 6308c2ecf20Sopenharmony_ci goto out; 6318c2ecf20Sopenharmony_ci 6328c2ecf20Sopenharmony_ci hardif_neigh = batadv_hardif_neigh_get_or_create(hard_iface, 6338c2ecf20Sopenharmony_ci neigh_addr, orig_node); 6348c2ecf20Sopenharmony_ci if (!hardif_neigh) 6358c2ecf20Sopenharmony_ci goto out; 6368c2ecf20Sopenharmony_ci 6378c2ecf20Sopenharmony_ci neigh_node = kzalloc(sizeof(*neigh_node), GFP_ATOMIC); 6388c2ecf20Sopenharmony_ci if (!neigh_node) 6398c2ecf20Sopenharmony_ci goto out; 6408c2ecf20Sopenharmony_ci 6418c2ecf20Sopenharmony_ci INIT_HLIST_NODE(&neigh_node->list); 6428c2ecf20Sopenharmony_ci INIT_HLIST_HEAD(&neigh_node->ifinfo_list); 6438c2ecf20Sopenharmony_ci spin_lock_init(&neigh_node->ifinfo_lock); 6448c2ecf20Sopenharmony_ci 6458c2ecf20Sopenharmony_ci kref_get(&hard_iface->refcount); 6468c2ecf20Sopenharmony_ci ether_addr_copy(neigh_node->addr, neigh_addr); 6478c2ecf20Sopenharmony_ci neigh_node->if_incoming = hard_iface; 6488c2ecf20Sopenharmony_ci neigh_node->orig_node = orig_node; 6498c2ecf20Sopenharmony_ci neigh_node->last_seen = jiffies; 6508c2ecf20Sopenharmony_ci 6518c2ecf20Sopenharmony_ci /* increment unique neighbor refcount */ 6528c2ecf20Sopenharmony_ci kref_get(&hardif_neigh->refcount); 6538c2ecf20Sopenharmony_ci neigh_node->hardif_neigh = hardif_neigh; 6548c2ecf20Sopenharmony_ci 6558c2ecf20Sopenharmony_ci /* extra reference for return */ 6568c2ecf20Sopenharmony_ci kref_init(&neigh_node->refcount); 6578c2ecf20Sopenharmony_ci 6588c2ecf20Sopenharmony_ci kref_get(&neigh_node->refcount); 6598c2ecf20Sopenharmony_ci hlist_add_head_rcu(&neigh_node->list, &orig_node->neigh_list); 6608c2ecf20Sopenharmony_ci 6618c2ecf20Sopenharmony_ci batadv_dbg(BATADV_DBG_BATMAN, orig_node->bat_priv, 6628c2ecf20Sopenharmony_ci "Creating new neighbor %pM for orig_node %pM on interface %s\n", 6638c2ecf20Sopenharmony_ci neigh_addr, orig_node->orig, hard_iface->net_dev->name); 6648c2ecf20Sopenharmony_ci 6658c2ecf20Sopenharmony_ciout: 6668c2ecf20Sopenharmony_ci spin_unlock_bh(&orig_node->neigh_list_lock); 6678c2ecf20Sopenharmony_ci 6688c2ecf20Sopenharmony_ci if (hardif_neigh) 6698c2ecf20Sopenharmony_ci batadv_hardif_neigh_put(hardif_neigh); 6708c2ecf20Sopenharmony_ci return neigh_node; 6718c2ecf20Sopenharmony_ci} 6728c2ecf20Sopenharmony_ci 6738c2ecf20Sopenharmony_ci/** 6748c2ecf20Sopenharmony_ci * batadv_neigh_node_get_or_create() - retrieve or create a neigh node object 6758c2ecf20Sopenharmony_ci * @orig_node: originator object representing the neighbour 6768c2ecf20Sopenharmony_ci * @hard_iface: the interface where the neighbour is connected to 6778c2ecf20Sopenharmony_ci * @neigh_addr: the mac address of the neighbour interface 6788c2ecf20Sopenharmony_ci * 6798c2ecf20Sopenharmony_ci * Return: the neighbour node if found or created or NULL otherwise. 6808c2ecf20Sopenharmony_ci */ 6818c2ecf20Sopenharmony_cistruct batadv_neigh_node * 6828c2ecf20Sopenharmony_cibatadv_neigh_node_get_or_create(struct batadv_orig_node *orig_node, 6838c2ecf20Sopenharmony_ci struct batadv_hard_iface *hard_iface, 6848c2ecf20Sopenharmony_ci const u8 *neigh_addr) 6858c2ecf20Sopenharmony_ci{ 6868c2ecf20Sopenharmony_ci struct batadv_neigh_node *neigh_node; 6878c2ecf20Sopenharmony_ci 6888c2ecf20Sopenharmony_ci /* first check without locking to avoid the overhead */ 6898c2ecf20Sopenharmony_ci neigh_node = batadv_neigh_node_get(orig_node, hard_iface, neigh_addr); 6908c2ecf20Sopenharmony_ci if (neigh_node) 6918c2ecf20Sopenharmony_ci return neigh_node; 6928c2ecf20Sopenharmony_ci 6938c2ecf20Sopenharmony_ci return batadv_neigh_node_create(orig_node, hard_iface, neigh_addr); 6948c2ecf20Sopenharmony_ci} 6958c2ecf20Sopenharmony_ci 6968c2ecf20Sopenharmony_ci#ifdef CONFIG_BATMAN_ADV_DEBUGFS 6978c2ecf20Sopenharmony_ci/** 6988c2ecf20Sopenharmony_ci * batadv_hardif_neigh_seq_print_text() - print the single hop neighbour list 6998c2ecf20Sopenharmony_ci * @seq: neighbour table seq_file struct 7008c2ecf20Sopenharmony_ci * @offset: not used 7018c2ecf20Sopenharmony_ci * 7028c2ecf20Sopenharmony_ci * Return: always 0 7038c2ecf20Sopenharmony_ci */ 7048c2ecf20Sopenharmony_ciint batadv_hardif_neigh_seq_print_text(struct seq_file *seq, void *offset) 7058c2ecf20Sopenharmony_ci{ 7068c2ecf20Sopenharmony_ci struct net_device *net_dev = (struct net_device *)seq->private; 7078c2ecf20Sopenharmony_ci struct batadv_priv *bat_priv = netdev_priv(net_dev); 7088c2ecf20Sopenharmony_ci struct batadv_hard_iface *primary_if; 7098c2ecf20Sopenharmony_ci 7108c2ecf20Sopenharmony_ci primary_if = batadv_seq_print_text_primary_if_get(seq); 7118c2ecf20Sopenharmony_ci if (!primary_if) 7128c2ecf20Sopenharmony_ci return 0; 7138c2ecf20Sopenharmony_ci 7148c2ecf20Sopenharmony_ci seq_printf(seq, "[B.A.T.M.A.N. adv %s, MainIF/MAC: %s/%pM (%s %s)]\n", 7158c2ecf20Sopenharmony_ci BATADV_SOURCE_VERSION, primary_if->net_dev->name, 7168c2ecf20Sopenharmony_ci primary_if->net_dev->dev_addr, net_dev->name, 7178c2ecf20Sopenharmony_ci bat_priv->algo_ops->name); 7188c2ecf20Sopenharmony_ci 7198c2ecf20Sopenharmony_ci batadv_hardif_put(primary_if); 7208c2ecf20Sopenharmony_ci 7218c2ecf20Sopenharmony_ci if (!bat_priv->algo_ops->neigh.print) { 7228c2ecf20Sopenharmony_ci seq_puts(seq, 7238c2ecf20Sopenharmony_ci "No printing function for this routing protocol\n"); 7248c2ecf20Sopenharmony_ci return 0; 7258c2ecf20Sopenharmony_ci } 7268c2ecf20Sopenharmony_ci 7278c2ecf20Sopenharmony_ci bat_priv->algo_ops->neigh.print(bat_priv, seq); 7288c2ecf20Sopenharmony_ci return 0; 7298c2ecf20Sopenharmony_ci} 7308c2ecf20Sopenharmony_ci#endif 7318c2ecf20Sopenharmony_ci 7328c2ecf20Sopenharmony_ci/** 7338c2ecf20Sopenharmony_ci * batadv_hardif_neigh_dump() - Dump to netlink the neighbor infos for a 7348c2ecf20Sopenharmony_ci * specific outgoing interface 7358c2ecf20Sopenharmony_ci * @msg: message to dump into 7368c2ecf20Sopenharmony_ci * @cb: parameters for the dump 7378c2ecf20Sopenharmony_ci * 7388c2ecf20Sopenharmony_ci * Return: 0 or error value 7398c2ecf20Sopenharmony_ci */ 7408c2ecf20Sopenharmony_ciint batadv_hardif_neigh_dump(struct sk_buff *msg, struct netlink_callback *cb) 7418c2ecf20Sopenharmony_ci{ 7428c2ecf20Sopenharmony_ci struct net *net = sock_net(cb->skb->sk); 7438c2ecf20Sopenharmony_ci struct net_device *soft_iface; 7448c2ecf20Sopenharmony_ci struct net_device *hard_iface = NULL; 7458c2ecf20Sopenharmony_ci struct batadv_hard_iface *hardif = BATADV_IF_DEFAULT; 7468c2ecf20Sopenharmony_ci struct batadv_priv *bat_priv; 7478c2ecf20Sopenharmony_ci struct batadv_hard_iface *primary_if = NULL; 7488c2ecf20Sopenharmony_ci int ret; 7498c2ecf20Sopenharmony_ci int ifindex, hard_ifindex; 7508c2ecf20Sopenharmony_ci 7518c2ecf20Sopenharmony_ci ifindex = batadv_netlink_get_ifindex(cb->nlh, BATADV_ATTR_MESH_IFINDEX); 7528c2ecf20Sopenharmony_ci if (!ifindex) 7538c2ecf20Sopenharmony_ci return -EINVAL; 7548c2ecf20Sopenharmony_ci 7558c2ecf20Sopenharmony_ci soft_iface = dev_get_by_index(net, ifindex); 7568c2ecf20Sopenharmony_ci if (!soft_iface || !batadv_softif_is_valid(soft_iface)) { 7578c2ecf20Sopenharmony_ci ret = -ENODEV; 7588c2ecf20Sopenharmony_ci goto out; 7598c2ecf20Sopenharmony_ci } 7608c2ecf20Sopenharmony_ci 7618c2ecf20Sopenharmony_ci bat_priv = netdev_priv(soft_iface); 7628c2ecf20Sopenharmony_ci 7638c2ecf20Sopenharmony_ci primary_if = batadv_primary_if_get_selected(bat_priv); 7648c2ecf20Sopenharmony_ci if (!primary_if || primary_if->if_status != BATADV_IF_ACTIVE) { 7658c2ecf20Sopenharmony_ci ret = -ENOENT; 7668c2ecf20Sopenharmony_ci goto out; 7678c2ecf20Sopenharmony_ci } 7688c2ecf20Sopenharmony_ci 7698c2ecf20Sopenharmony_ci hard_ifindex = batadv_netlink_get_ifindex(cb->nlh, 7708c2ecf20Sopenharmony_ci BATADV_ATTR_HARD_IFINDEX); 7718c2ecf20Sopenharmony_ci if (hard_ifindex) { 7728c2ecf20Sopenharmony_ci hard_iface = dev_get_by_index(net, hard_ifindex); 7738c2ecf20Sopenharmony_ci if (hard_iface) 7748c2ecf20Sopenharmony_ci hardif = batadv_hardif_get_by_netdev(hard_iface); 7758c2ecf20Sopenharmony_ci 7768c2ecf20Sopenharmony_ci if (!hardif) { 7778c2ecf20Sopenharmony_ci ret = -ENODEV; 7788c2ecf20Sopenharmony_ci goto out; 7798c2ecf20Sopenharmony_ci } 7808c2ecf20Sopenharmony_ci 7818c2ecf20Sopenharmony_ci if (hardif->soft_iface != soft_iface) { 7828c2ecf20Sopenharmony_ci ret = -ENOENT; 7838c2ecf20Sopenharmony_ci goto out; 7848c2ecf20Sopenharmony_ci } 7858c2ecf20Sopenharmony_ci } 7868c2ecf20Sopenharmony_ci 7878c2ecf20Sopenharmony_ci if (!bat_priv->algo_ops->neigh.dump) { 7888c2ecf20Sopenharmony_ci ret = -EOPNOTSUPP; 7898c2ecf20Sopenharmony_ci goto out; 7908c2ecf20Sopenharmony_ci } 7918c2ecf20Sopenharmony_ci 7928c2ecf20Sopenharmony_ci bat_priv->algo_ops->neigh.dump(msg, cb, bat_priv, hardif); 7938c2ecf20Sopenharmony_ci 7948c2ecf20Sopenharmony_ci ret = msg->len; 7958c2ecf20Sopenharmony_ci 7968c2ecf20Sopenharmony_ci out: 7978c2ecf20Sopenharmony_ci if (hardif) 7988c2ecf20Sopenharmony_ci batadv_hardif_put(hardif); 7998c2ecf20Sopenharmony_ci if (hard_iface) 8008c2ecf20Sopenharmony_ci dev_put(hard_iface); 8018c2ecf20Sopenharmony_ci if (primary_if) 8028c2ecf20Sopenharmony_ci batadv_hardif_put(primary_if); 8038c2ecf20Sopenharmony_ci if (soft_iface) 8048c2ecf20Sopenharmony_ci dev_put(soft_iface); 8058c2ecf20Sopenharmony_ci 8068c2ecf20Sopenharmony_ci return ret; 8078c2ecf20Sopenharmony_ci} 8088c2ecf20Sopenharmony_ci 8098c2ecf20Sopenharmony_ci/** 8108c2ecf20Sopenharmony_ci * batadv_orig_ifinfo_release() - release orig_ifinfo from lists and queue for 8118c2ecf20Sopenharmony_ci * free after rcu grace period 8128c2ecf20Sopenharmony_ci * @ref: kref pointer of the orig_ifinfo 8138c2ecf20Sopenharmony_ci */ 8148c2ecf20Sopenharmony_civoid batadv_orig_ifinfo_release(struct kref *ref) 8158c2ecf20Sopenharmony_ci{ 8168c2ecf20Sopenharmony_ci struct batadv_orig_ifinfo *orig_ifinfo; 8178c2ecf20Sopenharmony_ci struct batadv_neigh_node *router; 8188c2ecf20Sopenharmony_ci 8198c2ecf20Sopenharmony_ci orig_ifinfo = container_of(ref, struct batadv_orig_ifinfo, refcount); 8208c2ecf20Sopenharmony_ci 8218c2ecf20Sopenharmony_ci if (orig_ifinfo->if_outgoing != BATADV_IF_DEFAULT) 8228c2ecf20Sopenharmony_ci batadv_hardif_put(orig_ifinfo->if_outgoing); 8238c2ecf20Sopenharmony_ci 8248c2ecf20Sopenharmony_ci /* this is the last reference to this object */ 8258c2ecf20Sopenharmony_ci router = rcu_dereference_protected(orig_ifinfo->router, true); 8268c2ecf20Sopenharmony_ci if (router) 8278c2ecf20Sopenharmony_ci batadv_neigh_node_put(router); 8288c2ecf20Sopenharmony_ci 8298c2ecf20Sopenharmony_ci kfree_rcu(orig_ifinfo, rcu); 8308c2ecf20Sopenharmony_ci} 8318c2ecf20Sopenharmony_ci 8328c2ecf20Sopenharmony_ci/** 8338c2ecf20Sopenharmony_ci * batadv_orig_node_free_rcu() - free the orig_node 8348c2ecf20Sopenharmony_ci * @rcu: rcu pointer of the orig_node 8358c2ecf20Sopenharmony_ci */ 8368c2ecf20Sopenharmony_cistatic void batadv_orig_node_free_rcu(struct rcu_head *rcu) 8378c2ecf20Sopenharmony_ci{ 8388c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node; 8398c2ecf20Sopenharmony_ci 8408c2ecf20Sopenharmony_ci orig_node = container_of(rcu, struct batadv_orig_node, rcu); 8418c2ecf20Sopenharmony_ci 8428c2ecf20Sopenharmony_ci batadv_mcast_purge_orig(orig_node); 8438c2ecf20Sopenharmony_ci 8448c2ecf20Sopenharmony_ci batadv_frag_purge_orig(orig_node, NULL); 8458c2ecf20Sopenharmony_ci 8468c2ecf20Sopenharmony_ci kfree(orig_node->tt_buff); 8478c2ecf20Sopenharmony_ci kfree(orig_node); 8488c2ecf20Sopenharmony_ci} 8498c2ecf20Sopenharmony_ci 8508c2ecf20Sopenharmony_ci/** 8518c2ecf20Sopenharmony_ci * batadv_orig_node_release() - release orig_node from lists and queue for 8528c2ecf20Sopenharmony_ci * free after rcu grace period 8538c2ecf20Sopenharmony_ci * @ref: kref pointer of the orig_node 8548c2ecf20Sopenharmony_ci */ 8558c2ecf20Sopenharmony_civoid batadv_orig_node_release(struct kref *ref) 8568c2ecf20Sopenharmony_ci{ 8578c2ecf20Sopenharmony_ci struct hlist_node *node_tmp; 8588c2ecf20Sopenharmony_ci struct batadv_neigh_node *neigh_node; 8598c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node; 8608c2ecf20Sopenharmony_ci struct batadv_orig_ifinfo *orig_ifinfo; 8618c2ecf20Sopenharmony_ci struct batadv_orig_node_vlan *vlan; 8628c2ecf20Sopenharmony_ci struct batadv_orig_ifinfo *last_candidate; 8638c2ecf20Sopenharmony_ci 8648c2ecf20Sopenharmony_ci orig_node = container_of(ref, struct batadv_orig_node, refcount); 8658c2ecf20Sopenharmony_ci 8668c2ecf20Sopenharmony_ci spin_lock_bh(&orig_node->neigh_list_lock); 8678c2ecf20Sopenharmony_ci 8688c2ecf20Sopenharmony_ci /* for all neighbors towards this originator ... */ 8698c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(neigh_node, node_tmp, 8708c2ecf20Sopenharmony_ci &orig_node->neigh_list, list) { 8718c2ecf20Sopenharmony_ci hlist_del_rcu(&neigh_node->list); 8728c2ecf20Sopenharmony_ci batadv_neigh_node_put(neigh_node); 8738c2ecf20Sopenharmony_ci } 8748c2ecf20Sopenharmony_ci 8758c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(orig_ifinfo, node_tmp, 8768c2ecf20Sopenharmony_ci &orig_node->ifinfo_list, list) { 8778c2ecf20Sopenharmony_ci hlist_del_rcu(&orig_ifinfo->list); 8788c2ecf20Sopenharmony_ci batadv_orig_ifinfo_put(orig_ifinfo); 8798c2ecf20Sopenharmony_ci } 8808c2ecf20Sopenharmony_ci 8818c2ecf20Sopenharmony_ci last_candidate = orig_node->last_bonding_candidate; 8828c2ecf20Sopenharmony_ci orig_node->last_bonding_candidate = NULL; 8838c2ecf20Sopenharmony_ci spin_unlock_bh(&orig_node->neigh_list_lock); 8848c2ecf20Sopenharmony_ci 8858c2ecf20Sopenharmony_ci if (last_candidate) 8868c2ecf20Sopenharmony_ci batadv_orig_ifinfo_put(last_candidate); 8878c2ecf20Sopenharmony_ci 8888c2ecf20Sopenharmony_ci spin_lock_bh(&orig_node->vlan_list_lock); 8898c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(vlan, node_tmp, &orig_node->vlan_list, list) { 8908c2ecf20Sopenharmony_ci hlist_del_rcu(&vlan->list); 8918c2ecf20Sopenharmony_ci batadv_orig_node_vlan_put(vlan); 8928c2ecf20Sopenharmony_ci } 8938c2ecf20Sopenharmony_ci spin_unlock_bh(&orig_node->vlan_list_lock); 8948c2ecf20Sopenharmony_ci 8958c2ecf20Sopenharmony_ci /* Free nc_nodes */ 8968c2ecf20Sopenharmony_ci batadv_nc_purge_orig(orig_node->bat_priv, orig_node, NULL); 8978c2ecf20Sopenharmony_ci 8988c2ecf20Sopenharmony_ci call_rcu(&orig_node->rcu, batadv_orig_node_free_rcu); 8998c2ecf20Sopenharmony_ci} 9008c2ecf20Sopenharmony_ci 9018c2ecf20Sopenharmony_ci/** 9028c2ecf20Sopenharmony_ci * batadv_originator_free() - Free all originator structures 9038c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 9048c2ecf20Sopenharmony_ci */ 9058c2ecf20Sopenharmony_civoid batadv_originator_free(struct batadv_priv *bat_priv) 9068c2ecf20Sopenharmony_ci{ 9078c2ecf20Sopenharmony_ci struct batadv_hashtable *hash = bat_priv->orig_hash; 9088c2ecf20Sopenharmony_ci struct hlist_node *node_tmp; 9098c2ecf20Sopenharmony_ci struct hlist_head *head; 9108c2ecf20Sopenharmony_ci spinlock_t *list_lock; /* spinlock to protect write access */ 9118c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node; 9128c2ecf20Sopenharmony_ci u32 i; 9138c2ecf20Sopenharmony_ci 9148c2ecf20Sopenharmony_ci if (!hash) 9158c2ecf20Sopenharmony_ci return; 9168c2ecf20Sopenharmony_ci 9178c2ecf20Sopenharmony_ci cancel_delayed_work_sync(&bat_priv->orig_work); 9188c2ecf20Sopenharmony_ci 9198c2ecf20Sopenharmony_ci bat_priv->orig_hash = NULL; 9208c2ecf20Sopenharmony_ci 9218c2ecf20Sopenharmony_ci for (i = 0; i < hash->size; i++) { 9228c2ecf20Sopenharmony_ci head = &hash->table[i]; 9238c2ecf20Sopenharmony_ci list_lock = &hash->list_locks[i]; 9248c2ecf20Sopenharmony_ci 9258c2ecf20Sopenharmony_ci spin_lock_bh(list_lock); 9268c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(orig_node, node_tmp, 9278c2ecf20Sopenharmony_ci head, hash_entry) { 9288c2ecf20Sopenharmony_ci hlist_del_rcu(&orig_node->hash_entry); 9298c2ecf20Sopenharmony_ci batadv_orig_node_put(orig_node); 9308c2ecf20Sopenharmony_ci } 9318c2ecf20Sopenharmony_ci spin_unlock_bh(list_lock); 9328c2ecf20Sopenharmony_ci } 9338c2ecf20Sopenharmony_ci 9348c2ecf20Sopenharmony_ci batadv_hash_destroy(hash); 9358c2ecf20Sopenharmony_ci} 9368c2ecf20Sopenharmony_ci 9378c2ecf20Sopenharmony_ci/** 9388c2ecf20Sopenharmony_ci * batadv_orig_node_new() - creates a new orig_node 9398c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 9408c2ecf20Sopenharmony_ci * @addr: the mac address of the originator 9418c2ecf20Sopenharmony_ci * 9428c2ecf20Sopenharmony_ci * Creates a new originator object and initialises all the generic fields. 9438c2ecf20Sopenharmony_ci * The new object is not added to the originator list. 9448c2ecf20Sopenharmony_ci * 9458c2ecf20Sopenharmony_ci * Return: the newly created object or NULL on failure. 9468c2ecf20Sopenharmony_ci */ 9478c2ecf20Sopenharmony_cistruct batadv_orig_node *batadv_orig_node_new(struct batadv_priv *bat_priv, 9488c2ecf20Sopenharmony_ci const u8 *addr) 9498c2ecf20Sopenharmony_ci{ 9508c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node; 9518c2ecf20Sopenharmony_ci struct batadv_orig_node_vlan *vlan; 9528c2ecf20Sopenharmony_ci unsigned long reset_time; 9538c2ecf20Sopenharmony_ci int i; 9548c2ecf20Sopenharmony_ci 9558c2ecf20Sopenharmony_ci batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 9568c2ecf20Sopenharmony_ci "Creating new originator: %pM\n", addr); 9578c2ecf20Sopenharmony_ci 9588c2ecf20Sopenharmony_ci orig_node = kzalloc(sizeof(*orig_node), GFP_ATOMIC); 9598c2ecf20Sopenharmony_ci if (!orig_node) 9608c2ecf20Sopenharmony_ci return NULL; 9618c2ecf20Sopenharmony_ci 9628c2ecf20Sopenharmony_ci INIT_HLIST_HEAD(&orig_node->neigh_list); 9638c2ecf20Sopenharmony_ci INIT_HLIST_HEAD(&orig_node->vlan_list); 9648c2ecf20Sopenharmony_ci INIT_HLIST_HEAD(&orig_node->ifinfo_list); 9658c2ecf20Sopenharmony_ci spin_lock_init(&orig_node->bcast_seqno_lock); 9668c2ecf20Sopenharmony_ci spin_lock_init(&orig_node->neigh_list_lock); 9678c2ecf20Sopenharmony_ci spin_lock_init(&orig_node->tt_buff_lock); 9688c2ecf20Sopenharmony_ci spin_lock_init(&orig_node->tt_lock); 9698c2ecf20Sopenharmony_ci spin_lock_init(&orig_node->vlan_list_lock); 9708c2ecf20Sopenharmony_ci 9718c2ecf20Sopenharmony_ci batadv_nc_init_orig(orig_node); 9728c2ecf20Sopenharmony_ci 9738c2ecf20Sopenharmony_ci /* extra reference for return */ 9748c2ecf20Sopenharmony_ci kref_init(&orig_node->refcount); 9758c2ecf20Sopenharmony_ci 9768c2ecf20Sopenharmony_ci orig_node->bat_priv = bat_priv; 9778c2ecf20Sopenharmony_ci ether_addr_copy(orig_node->orig, addr); 9788c2ecf20Sopenharmony_ci batadv_dat_init_orig_node_addr(orig_node); 9798c2ecf20Sopenharmony_ci atomic_set(&orig_node->last_ttvn, 0); 9808c2ecf20Sopenharmony_ci orig_node->tt_buff = NULL; 9818c2ecf20Sopenharmony_ci orig_node->tt_buff_len = 0; 9828c2ecf20Sopenharmony_ci orig_node->last_seen = jiffies; 9838c2ecf20Sopenharmony_ci reset_time = jiffies - 1 - msecs_to_jiffies(BATADV_RESET_PROTECTION_MS); 9848c2ecf20Sopenharmony_ci orig_node->bcast_seqno_reset = reset_time; 9858c2ecf20Sopenharmony_ci 9868c2ecf20Sopenharmony_ci#ifdef CONFIG_BATMAN_ADV_MCAST 9878c2ecf20Sopenharmony_ci orig_node->mcast_flags = BATADV_MCAST_WANT_NO_RTR4; 9888c2ecf20Sopenharmony_ci orig_node->mcast_flags |= BATADV_MCAST_WANT_NO_RTR6; 9898c2ecf20Sopenharmony_ci INIT_HLIST_NODE(&orig_node->mcast_want_all_unsnoopables_node); 9908c2ecf20Sopenharmony_ci INIT_HLIST_NODE(&orig_node->mcast_want_all_ipv4_node); 9918c2ecf20Sopenharmony_ci INIT_HLIST_NODE(&orig_node->mcast_want_all_ipv6_node); 9928c2ecf20Sopenharmony_ci spin_lock_init(&orig_node->mcast_handler_lock); 9938c2ecf20Sopenharmony_ci#endif 9948c2ecf20Sopenharmony_ci 9958c2ecf20Sopenharmony_ci /* create a vlan object for the "untagged" LAN */ 9968c2ecf20Sopenharmony_ci vlan = batadv_orig_node_vlan_new(orig_node, BATADV_NO_FLAGS); 9978c2ecf20Sopenharmony_ci if (!vlan) 9988c2ecf20Sopenharmony_ci goto free_orig_node; 9998c2ecf20Sopenharmony_ci /* batadv_orig_node_vlan_new() increases the refcounter. 10008c2ecf20Sopenharmony_ci * Immediately release vlan since it is not needed anymore in this 10018c2ecf20Sopenharmony_ci * context 10028c2ecf20Sopenharmony_ci */ 10038c2ecf20Sopenharmony_ci batadv_orig_node_vlan_put(vlan); 10048c2ecf20Sopenharmony_ci 10058c2ecf20Sopenharmony_ci for (i = 0; i < BATADV_FRAG_BUFFER_COUNT; i++) { 10068c2ecf20Sopenharmony_ci INIT_HLIST_HEAD(&orig_node->fragments[i].fragment_list); 10078c2ecf20Sopenharmony_ci spin_lock_init(&orig_node->fragments[i].lock); 10088c2ecf20Sopenharmony_ci orig_node->fragments[i].size = 0; 10098c2ecf20Sopenharmony_ci } 10108c2ecf20Sopenharmony_ci 10118c2ecf20Sopenharmony_ci return orig_node; 10128c2ecf20Sopenharmony_cifree_orig_node: 10138c2ecf20Sopenharmony_ci kfree(orig_node); 10148c2ecf20Sopenharmony_ci return NULL; 10158c2ecf20Sopenharmony_ci} 10168c2ecf20Sopenharmony_ci 10178c2ecf20Sopenharmony_ci/** 10188c2ecf20Sopenharmony_ci * batadv_purge_neigh_ifinfo() - purge obsolete ifinfo entries from neighbor 10198c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 10208c2ecf20Sopenharmony_ci * @neigh: orig node which is to be checked 10218c2ecf20Sopenharmony_ci */ 10228c2ecf20Sopenharmony_cistatic void 10238c2ecf20Sopenharmony_cibatadv_purge_neigh_ifinfo(struct batadv_priv *bat_priv, 10248c2ecf20Sopenharmony_ci struct batadv_neigh_node *neigh) 10258c2ecf20Sopenharmony_ci{ 10268c2ecf20Sopenharmony_ci struct batadv_neigh_ifinfo *neigh_ifinfo; 10278c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_outgoing; 10288c2ecf20Sopenharmony_ci struct hlist_node *node_tmp; 10298c2ecf20Sopenharmony_ci 10308c2ecf20Sopenharmony_ci spin_lock_bh(&neigh->ifinfo_lock); 10318c2ecf20Sopenharmony_ci 10328c2ecf20Sopenharmony_ci /* for all ifinfo objects for this neighinator */ 10338c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(neigh_ifinfo, node_tmp, 10348c2ecf20Sopenharmony_ci &neigh->ifinfo_list, list) { 10358c2ecf20Sopenharmony_ci if_outgoing = neigh_ifinfo->if_outgoing; 10368c2ecf20Sopenharmony_ci 10378c2ecf20Sopenharmony_ci /* always keep the default interface */ 10388c2ecf20Sopenharmony_ci if (if_outgoing == BATADV_IF_DEFAULT) 10398c2ecf20Sopenharmony_ci continue; 10408c2ecf20Sopenharmony_ci 10418c2ecf20Sopenharmony_ci /* don't purge if the interface is not (going) down */ 10428c2ecf20Sopenharmony_ci if (if_outgoing->if_status != BATADV_IF_INACTIVE && 10438c2ecf20Sopenharmony_ci if_outgoing->if_status != BATADV_IF_NOT_IN_USE && 10448c2ecf20Sopenharmony_ci if_outgoing->if_status != BATADV_IF_TO_BE_REMOVED) 10458c2ecf20Sopenharmony_ci continue; 10468c2ecf20Sopenharmony_ci 10478c2ecf20Sopenharmony_ci batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 10488c2ecf20Sopenharmony_ci "neighbor/ifinfo purge: neighbor %pM, iface: %s\n", 10498c2ecf20Sopenharmony_ci neigh->addr, if_outgoing->net_dev->name); 10508c2ecf20Sopenharmony_ci 10518c2ecf20Sopenharmony_ci hlist_del_rcu(&neigh_ifinfo->list); 10528c2ecf20Sopenharmony_ci batadv_neigh_ifinfo_put(neigh_ifinfo); 10538c2ecf20Sopenharmony_ci } 10548c2ecf20Sopenharmony_ci 10558c2ecf20Sopenharmony_ci spin_unlock_bh(&neigh->ifinfo_lock); 10568c2ecf20Sopenharmony_ci} 10578c2ecf20Sopenharmony_ci 10588c2ecf20Sopenharmony_ci/** 10598c2ecf20Sopenharmony_ci * batadv_purge_orig_ifinfo() - purge obsolete ifinfo entries from originator 10608c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 10618c2ecf20Sopenharmony_ci * @orig_node: orig node which is to be checked 10628c2ecf20Sopenharmony_ci * 10638c2ecf20Sopenharmony_ci * Return: true if any ifinfo entry was purged, false otherwise. 10648c2ecf20Sopenharmony_ci */ 10658c2ecf20Sopenharmony_cistatic bool 10668c2ecf20Sopenharmony_cibatadv_purge_orig_ifinfo(struct batadv_priv *bat_priv, 10678c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node) 10688c2ecf20Sopenharmony_ci{ 10698c2ecf20Sopenharmony_ci struct batadv_orig_ifinfo *orig_ifinfo; 10708c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_outgoing; 10718c2ecf20Sopenharmony_ci struct hlist_node *node_tmp; 10728c2ecf20Sopenharmony_ci bool ifinfo_purged = false; 10738c2ecf20Sopenharmony_ci 10748c2ecf20Sopenharmony_ci spin_lock_bh(&orig_node->neigh_list_lock); 10758c2ecf20Sopenharmony_ci 10768c2ecf20Sopenharmony_ci /* for all ifinfo objects for this originator */ 10778c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(orig_ifinfo, node_tmp, 10788c2ecf20Sopenharmony_ci &orig_node->ifinfo_list, list) { 10798c2ecf20Sopenharmony_ci if_outgoing = orig_ifinfo->if_outgoing; 10808c2ecf20Sopenharmony_ci 10818c2ecf20Sopenharmony_ci /* always keep the default interface */ 10828c2ecf20Sopenharmony_ci if (if_outgoing == BATADV_IF_DEFAULT) 10838c2ecf20Sopenharmony_ci continue; 10848c2ecf20Sopenharmony_ci 10858c2ecf20Sopenharmony_ci /* don't purge if the interface is not (going) down */ 10868c2ecf20Sopenharmony_ci if (if_outgoing->if_status != BATADV_IF_INACTIVE && 10878c2ecf20Sopenharmony_ci if_outgoing->if_status != BATADV_IF_NOT_IN_USE && 10888c2ecf20Sopenharmony_ci if_outgoing->if_status != BATADV_IF_TO_BE_REMOVED) 10898c2ecf20Sopenharmony_ci continue; 10908c2ecf20Sopenharmony_ci 10918c2ecf20Sopenharmony_ci batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 10928c2ecf20Sopenharmony_ci "router/ifinfo purge: originator %pM, iface: %s\n", 10938c2ecf20Sopenharmony_ci orig_node->orig, if_outgoing->net_dev->name); 10948c2ecf20Sopenharmony_ci 10958c2ecf20Sopenharmony_ci ifinfo_purged = true; 10968c2ecf20Sopenharmony_ci 10978c2ecf20Sopenharmony_ci hlist_del_rcu(&orig_ifinfo->list); 10988c2ecf20Sopenharmony_ci batadv_orig_ifinfo_put(orig_ifinfo); 10998c2ecf20Sopenharmony_ci if (orig_node->last_bonding_candidate == orig_ifinfo) { 11008c2ecf20Sopenharmony_ci orig_node->last_bonding_candidate = NULL; 11018c2ecf20Sopenharmony_ci batadv_orig_ifinfo_put(orig_ifinfo); 11028c2ecf20Sopenharmony_ci } 11038c2ecf20Sopenharmony_ci } 11048c2ecf20Sopenharmony_ci 11058c2ecf20Sopenharmony_ci spin_unlock_bh(&orig_node->neigh_list_lock); 11068c2ecf20Sopenharmony_ci 11078c2ecf20Sopenharmony_ci return ifinfo_purged; 11088c2ecf20Sopenharmony_ci} 11098c2ecf20Sopenharmony_ci 11108c2ecf20Sopenharmony_ci/** 11118c2ecf20Sopenharmony_ci * batadv_purge_orig_neighbors() - purges neighbors from originator 11128c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 11138c2ecf20Sopenharmony_ci * @orig_node: orig node which is to be checked 11148c2ecf20Sopenharmony_ci * 11158c2ecf20Sopenharmony_ci * Return: true if any neighbor was purged, false otherwise 11168c2ecf20Sopenharmony_ci */ 11178c2ecf20Sopenharmony_cistatic bool 11188c2ecf20Sopenharmony_cibatadv_purge_orig_neighbors(struct batadv_priv *bat_priv, 11198c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node) 11208c2ecf20Sopenharmony_ci{ 11218c2ecf20Sopenharmony_ci struct hlist_node *node_tmp; 11228c2ecf20Sopenharmony_ci struct batadv_neigh_node *neigh_node; 11238c2ecf20Sopenharmony_ci bool neigh_purged = false; 11248c2ecf20Sopenharmony_ci unsigned long last_seen; 11258c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_incoming; 11268c2ecf20Sopenharmony_ci 11278c2ecf20Sopenharmony_ci spin_lock_bh(&orig_node->neigh_list_lock); 11288c2ecf20Sopenharmony_ci 11298c2ecf20Sopenharmony_ci /* for all neighbors towards this originator ... */ 11308c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(neigh_node, node_tmp, 11318c2ecf20Sopenharmony_ci &orig_node->neigh_list, list) { 11328c2ecf20Sopenharmony_ci last_seen = neigh_node->last_seen; 11338c2ecf20Sopenharmony_ci if_incoming = neigh_node->if_incoming; 11348c2ecf20Sopenharmony_ci 11358c2ecf20Sopenharmony_ci if (batadv_has_timed_out(last_seen, BATADV_PURGE_TIMEOUT) || 11368c2ecf20Sopenharmony_ci if_incoming->if_status == BATADV_IF_INACTIVE || 11378c2ecf20Sopenharmony_ci if_incoming->if_status == BATADV_IF_NOT_IN_USE || 11388c2ecf20Sopenharmony_ci if_incoming->if_status == BATADV_IF_TO_BE_REMOVED) { 11398c2ecf20Sopenharmony_ci if (if_incoming->if_status == BATADV_IF_INACTIVE || 11408c2ecf20Sopenharmony_ci if_incoming->if_status == BATADV_IF_NOT_IN_USE || 11418c2ecf20Sopenharmony_ci if_incoming->if_status == BATADV_IF_TO_BE_REMOVED) 11428c2ecf20Sopenharmony_ci batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 11438c2ecf20Sopenharmony_ci "neighbor purge: originator %pM, neighbor: %pM, iface: %s\n", 11448c2ecf20Sopenharmony_ci orig_node->orig, neigh_node->addr, 11458c2ecf20Sopenharmony_ci if_incoming->net_dev->name); 11468c2ecf20Sopenharmony_ci else 11478c2ecf20Sopenharmony_ci batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 11488c2ecf20Sopenharmony_ci "neighbor timeout: originator %pM, neighbor: %pM, last_seen: %u\n", 11498c2ecf20Sopenharmony_ci orig_node->orig, neigh_node->addr, 11508c2ecf20Sopenharmony_ci jiffies_to_msecs(last_seen)); 11518c2ecf20Sopenharmony_ci 11528c2ecf20Sopenharmony_ci neigh_purged = true; 11538c2ecf20Sopenharmony_ci 11548c2ecf20Sopenharmony_ci hlist_del_rcu(&neigh_node->list); 11558c2ecf20Sopenharmony_ci batadv_neigh_node_put(neigh_node); 11568c2ecf20Sopenharmony_ci } else { 11578c2ecf20Sopenharmony_ci /* only necessary if not the whole neighbor is to be 11588c2ecf20Sopenharmony_ci * deleted, but some interface has been removed. 11598c2ecf20Sopenharmony_ci */ 11608c2ecf20Sopenharmony_ci batadv_purge_neigh_ifinfo(bat_priv, neigh_node); 11618c2ecf20Sopenharmony_ci } 11628c2ecf20Sopenharmony_ci } 11638c2ecf20Sopenharmony_ci 11648c2ecf20Sopenharmony_ci spin_unlock_bh(&orig_node->neigh_list_lock); 11658c2ecf20Sopenharmony_ci return neigh_purged; 11668c2ecf20Sopenharmony_ci} 11678c2ecf20Sopenharmony_ci 11688c2ecf20Sopenharmony_ci/** 11698c2ecf20Sopenharmony_ci * batadv_find_best_neighbor() - finds the best neighbor after purging 11708c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 11718c2ecf20Sopenharmony_ci * @orig_node: orig node which is to be checked 11728c2ecf20Sopenharmony_ci * @if_outgoing: the interface for which the metric should be compared 11738c2ecf20Sopenharmony_ci * 11748c2ecf20Sopenharmony_ci * Return: the current best neighbor, with refcount increased. 11758c2ecf20Sopenharmony_ci */ 11768c2ecf20Sopenharmony_cistatic struct batadv_neigh_node * 11778c2ecf20Sopenharmony_cibatadv_find_best_neighbor(struct batadv_priv *bat_priv, 11788c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node, 11798c2ecf20Sopenharmony_ci struct batadv_hard_iface *if_outgoing) 11808c2ecf20Sopenharmony_ci{ 11818c2ecf20Sopenharmony_ci struct batadv_neigh_node *best = NULL, *neigh; 11828c2ecf20Sopenharmony_ci struct batadv_algo_ops *bao = bat_priv->algo_ops; 11838c2ecf20Sopenharmony_ci 11848c2ecf20Sopenharmony_ci rcu_read_lock(); 11858c2ecf20Sopenharmony_ci hlist_for_each_entry_rcu(neigh, &orig_node->neigh_list, list) { 11868c2ecf20Sopenharmony_ci if (best && (bao->neigh.cmp(neigh, if_outgoing, best, 11878c2ecf20Sopenharmony_ci if_outgoing) <= 0)) 11888c2ecf20Sopenharmony_ci continue; 11898c2ecf20Sopenharmony_ci 11908c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&neigh->refcount)) 11918c2ecf20Sopenharmony_ci continue; 11928c2ecf20Sopenharmony_ci 11938c2ecf20Sopenharmony_ci if (best) 11948c2ecf20Sopenharmony_ci batadv_neigh_node_put(best); 11958c2ecf20Sopenharmony_ci 11968c2ecf20Sopenharmony_ci best = neigh; 11978c2ecf20Sopenharmony_ci } 11988c2ecf20Sopenharmony_ci rcu_read_unlock(); 11998c2ecf20Sopenharmony_ci 12008c2ecf20Sopenharmony_ci return best; 12018c2ecf20Sopenharmony_ci} 12028c2ecf20Sopenharmony_ci 12038c2ecf20Sopenharmony_ci/** 12048c2ecf20Sopenharmony_ci * batadv_purge_orig_node() - purges obsolete information from an orig_node 12058c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 12068c2ecf20Sopenharmony_ci * @orig_node: orig node which is to be checked 12078c2ecf20Sopenharmony_ci * 12088c2ecf20Sopenharmony_ci * This function checks if the orig_node or substructures of it have become 12098c2ecf20Sopenharmony_ci * obsolete, and purges this information if that's the case. 12108c2ecf20Sopenharmony_ci * 12118c2ecf20Sopenharmony_ci * Return: true if the orig_node is to be removed, false otherwise. 12128c2ecf20Sopenharmony_ci */ 12138c2ecf20Sopenharmony_cistatic bool batadv_purge_orig_node(struct batadv_priv *bat_priv, 12148c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node) 12158c2ecf20Sopenharmony_ci{ 12168c2ecf20Sopenharmony_ci struct batadv_neigh_node *best_neigh_node; 12178c2ecf20Sopenharmony_ci struct batadv_hard_iface *hard_iface; 12188c2ecf20Sopenharmony_ci bool changed_ifinfo, changed_neigh; 12198c2ecf20Sopenharmony_ci 12208c2ecf20Sopenharmony_ci if (batadv_has_timed_out(orig_node->last_seen, 12218c2ecf20Sopenharmony_ci 2 * BATADV_PURGE_TIMEOUT)) { 12228c2ecf20Sopenharmony_ci batadv_dbg(BATADV_DBG_BATMAN, bat_priv, 12238c2ecf20Sopenharmony_ci "Originator timeout: originator %pM, last_seen %u\n", 12248c2ecf20Sopenharmony_ci orig_node->orig, 12258c2ecf20Sopenharmony_ci jiffies_to_msecs(orig_node->last_seen)); 12268c2ecf20Sopenharmony_ci return true; 12278c2ecf20Sopenharmony_ci } 12288c2ecf20Sopenharmony_ci changed_ifinfo = batadv_purge_orig_ifinfo(bat_priv, orig_node); 12298c2ecf20Sopenharmony_ci changed_neigh = batadv_purge_orig_neighbors(bat_priv, orig_node); 12308c2ecf20Sopenharmony_ci 12318c2ecf20Sopenharmony_ci if (!changed_ifinfo && !changed_neigh) 12328c2ecf20Sopenharmony_ci return false; 12338c2ecf20Sopenharmony_ci 12348c2ecf20Sopenharmony_ci /* first for NULL ... */ 12358c2ecf20Sopenharmony_ci best_neigh_node = batadv_find_best_neighbor(bat_priv, orig_node, 12368c2ecf20Sopenharmony_ci BATADV_IF_DEFAULT); 12378c2ecf20Sopenharmony_ci batadv_update_route(bat_priv, orig_node, BATADV_IF_DEFAULT, 12388c2ecf20Sopenharmony_ci best_neigh_node); 12398c2ecf20Sopenharmony_ci if (best_neigh_node) 12408c2ecf20Sopenharmony_ci batadv_neigh_node_put(best_neigh_node); 12418c2ecf20Sopenharmony_ci 12428c2ecf20Sopenharmony_ci /* ... then for all other interfaces. */ 12438c2ecf20Sopenharmony_ci rcu_read_lock(); 12448c2ecf20Sopenharmony_ci list_for_each_entry_rcu(hard_iface, &batadv_hardif_list, list) { 12458c2ecf20Sopenharmony_ci if (hard_iface->if_status != BATADV_IF_ACTIVE) 12468c2ecf20Sopenharmony_ci continue; 12478c2ecf20Sopenharmony_ci 12488c2ecf20Sopenharmony_ci if (hard_iface->soft_iface != bat_priv->soft_iface) 12498c2ecf20Sopenharmony_ci continue; 12508c2ecf20Sopenharmony_ci 12518c2ecf20Sopenharmony_ci if (!kref_get_unless_zero(&hard_iface->refcount)) 12528c2ecf20Sopenharmony_ci continue; 12538c2ecf20Sopenharmony_ci 12548c2ecf20Sopenharmony_ci best_neigh_node = batadv_find_best_neighbor(bat_priv, 12558c2ecf20Sopenharmony_ci orig_node, 12568c2ecf20Sopenharmony_ci hard_iface); 12578c2ecf20Sopenharmony_ci batadv_update_route(bat_priv, orig_node, hard_iface, 12588c2ecf20Sopenharmony_ci best_neigh_node); 12598c2ecf20Sopenharmony_ci if (best_neigh_node) 12608c2ecf20Sopenharmony_ci batadv_neigh_node_put(best_neigh_node); 12618c2ecf20Sopenharmony_ci 12628c2ecf20Sopenharmony_ci batadv_hardif_put(hard_iface); 12638c2ecf20Sopenharmony_ci } 12648c2ecf20Sopenharmony_ci rcu_read_unlock(); 12658c2ecf20Sopenharmony_ci 12668c2ecf20Sopenharmony_ci return false; 12678c2ecf20Sopenharmony_ci} 12688c2ecf20Sopenharmony_ci 12698c2ecf20Sopenharmony_ci/** 12708c2ecf20Sopenharmony_ci * batadv_purge_orig_ref() - Purge all outdated originators 12718c2ecf20Sopenharmony_ci * @bat_priv: the bat priv with all the soft interface information 12728c2ecf20Sopenharmony_ci */ 12738c2ecf20Sopenharmony_civoid batadv_purge_orig_ref(struct batadv_priv *bat_priv) 12748c2ecf20Sopenharmony_ci{ 12758c2ecf20Sopenharmony_ci struct batadv_hashtable *hash = bat_priv->orig_hash; 12768c2ecf20Sopenharmony_ci struct hlist_node *node_tmp; 12778c2ecf20Sopenharmony_ci struct hlist_head *head; 12788c2ecf20Sopenharmony_ci spinlock_t *list_lock; /* spinlock to protect write access */ 12798c2ecf20Sopenharmony_ci struct batadv_orig_node *orig_node; 12808c2ecf20Sopenharmony_ci u32 i; 12818c2ecf20Sopenharmony_ci 12828c2ecf20Sopenharmony_ci if (!hash) 12838c2ecf20Sopenharmony_ci return; 12848c2ecf20Sopenharmony_ci 12858c2ecf20Sopenharmony_ci /* for all origins... */ 12868c2ecf20Sopenharmony_ci for (i = 0; i < hash->size; i++) { 12878c2ecf20Sopenharmony_ci head = &hash->table[i]; 12888c2ecf20Sopenharmony_ci list_lock = &hash->list_locks[i]; 12898c2ecf20Sopenharmony_ci 12908c2ecf20Sopenharmony_ci spin_lock_bh(list_lock); 12918c2ecf20Sopenharmony_ci hlist_for_each_entry_safe(orig_node, node_tmp, 12928c2ecf20Sopenharmony_ci head, hash_entry) { 12938c2ecf20Sopenharmony_ci if (batadv_purge_orig_node(bat_priv, orig_node)) { 12948c2ecf20Sopenharmony_ci batadv_gw_node_delete(bat_priv, orig_node); 12958c2ecf20Sopenharmony_ci hlist_del_rcu(&orig_node->hash_entry); 12968c2ecf20Sopenharmony_ci batadv_tt_global_del_orig(orig_node->bat_priv, 12978c2ecf20Sopenharmony_ci orig_node, -1, 12988c2ecf20Sopenharmony_ci "originator timed out"); 12998c2ecf20Sopenharmony_ci batadv_orig_node_put(orig_node); 13008c2ecf20Sopenharmony_ci continue; 13018c2ecf20Sopenharmony_ci } 13028c2ecf20Sopenharmony_ci 13038c2ecf20Sopenharmony_ci batadv_frag_purge_orig(orig_node, 13048c2ecf20Sopenharmony_ci batadv_frag_check_entry); 13058c2ecf20Sopenharmony_ci } 13068c2ecf20Sopenharmony_ci spin_unlock_bh(list_lock); 13078c2ecf20Sopenharmony_ci } 13088c2ecf20Sopenharmony_ci 13098c2ecf20Sopenharmony_ci batadv_gw_election(bat_priv); 13108c2ecf20Sopenharmony_ci} 13118c2ecf20Sopenharmony_ci 13128c2ecf20Sopenharmony_cistatic void batadv_purge_orig(struct work_struct *work) 13138c2ecf20Sopenharmony_ci{ 13148c2ecf20Sopenharmony_ci struct delayed_work *delayed_work; 13158c2ecf20Sopenharmony_ci struct batadv_priv *bat_priv; 13168c2ecf20Sopenharmony_ci 13178c2ecf20Sopenharmony_ci delayed_work = to_delayed_work(work); 13188c2ecf20Sopenharmony_ci bat_priv = container_of(delayed_work, struct batadv_priv, orig_work); 13198c2ecf20Sopenharmony_ci batadv_purge_orig_ref(bat_priv); 13208c2ecf20Sopenharmony_ci queue_delayed_work(batadv_event_workqueue, 13218c2ecf20Sopenharmony_ci &bat_priv->orig_work, 13228c2ecf20Sopenharmony_ci msecs_to_jiffies(BATADV_ORIG_WORK_PERIOD)); 13238c2ecf20Sopenharmony_ci} 13248c2ecf20Sopenharmony_ci 13258c2ecf20Sopenharmony_ci#ifdef CONFIG_BATMAN_ADV_DEBUGFS 13268c2ecf20Sopenharmony_ci 13278c2ecf20Sopenharmony_ci/** 13288c2ecf20Sopenharmony_ci * batadv_orig_seq_print_text() - Print the originator table in a seq file 13298c2ecf20Sopenharmony_ci * @seq: seq file to print on 13308c2ecf20Sopenharmony_ci * @offset: not used 13318c2ecf20Sopenharmony_ci * 13328c2ecf20Sopenharmony_ci * Return: always 0 13338c2ecf20Sopenharmony_ci */ 13348c2ecf20Sopenharmony_ciint batadv_orig_seq_print_text(struct seq_file *seq, void *offset) 13358c2ecf20Sopenharmony_ci{ 13368c2ecf20Sopenharmony_ci struct net_device *net_dev = (struct net_device *)seq->private; 13378c2ecf20Sopenharmony_ci struct batadv_priv *bat_priv = netdev_priv(net_dev); 13388c2ecf20Sopenharmony_ci struct batadv_hard_iface *primary_if; 13398c2ecf20Sopenharmony_ci 13408c2ecf20Sopenharmony_ci primary_if = batadv_seq_print_text_primary_if_get(seq); 13418c2ecf20Sopenharmony_ci if (!primary_if) 13428c2ecf20Sopenharmony_ci return 0; 13438c2ecf20Sopenharmony_ci 13448c2ecf20Sopenharmony_ci seq_printf(seq, "[B.A.T.M.A.N. adv %s, MainIF/MAC: %s/%pM (%s %s)]\n", 13458c2ecf20Sopenharmony_ci BATADV_SOURCE_VERSION, primary_if->net_dev->name, 13468c2ecf20Sopenharmony_ci primary_if->net_dev->dev_addr, net_dev->name, 13478c2ecf20Sopenharmony_ci bat_priv->algo_ops->name); 13488c2ecf20Sopenharmony_ci 13498c2ecf20Sopenharmony_ci batadv_hardif_put(primary_if); 13508c2ecf20Sopenharmony_ci 13518c2ecf20Sopenharmony_ci if (!bat_priv->algo_ops->orig.print) { 13528c2ecf20Sopenharmony_ci seq_puts(seq, 13538c2ecf20Sopenharmony_ci "No printing function for this routing protocol\n"); 13548c2ecf20Sopenharmony_ci return 0; 13558c2ecf20Sopenharmony_ci } 13568c2ecf20Sopenharmony_ci 13578c2ecf20Sopenharmony_ci bat_priv->algo_ops->orig.print(bat_priv, seq, BATADV_IF_DEFAULT); 13588c2ecf20Sopenharmony_ci 13598c2ecf20Sopenharmony_ci return 0; 13608c2ecf20Sopenharmony_ci} 13618c2ecf20Sopenharmony_ci 13628c2ecf20Sopenharmony_ci/** 13638c2ecf20Sopenharmony_ci * batadv_orig_hardif_seq_print_text() - writes originator infos for a specific 13648c2ecf20Sopenharmony_ci * outgoing interface 13658c2ecf20Sopenharmony_ci * @seq: debugfs table seq_file struct 13668c2ecf20Sopenharmony_ci * @offset: not used 13678c2ecf20Sopenharmony_ci * 13688c2ecf20Sopenharmony_ci * Return: 0 13698c2ecf20Sopenharmony_ci */ 13708c2ecf20Sopenharmony_ciint batadv_orig_hardif_seq_print_text(struct seq_file *seq, void *offset) 13718c2ecf20Sopenharmony_ci{ 13728c2ecf20Sopenharmony_ci struct net_device *net_dev = (struct net_device *)seq->private; 13738c2ecf20Sopenharmony_ci struct batadv_hard_iface *hard_iface; 13748c2ecf20Sopenharmony_ci struct batadv_priv *bat_priv; 13758c2ecf20Sopenharmony_ci 13768c2ecf20Sopenharmony_ci hard_iface = batadv_hardif_get_by_netdev(net_dev); 13778c2ecf20Sopenharmony_ci 13788c2ecf20Sopenharmony_ci if (!hard_iface || !hard_iface->soft_iface) { 13798c2ecf20Sopenharmony_ci seq_puts(seq, "Interface not known to B.A.T.M.A.N.\n"); 13808c2ecf20Sopenharmony_ci goto out; 13818c2ecf20Sopenharmony_ci } 13828c2ecf20Sopenharmony_ci 13838c2ecf20Sopenharmony_ci bat_priv = netdev_priv(hard_iface->soft_iface); 13848c2ecf20Sopenharmony_ci if (!bat_priv->algo_ops->orig.print) { 13858c2ecf20Sopenharmony_ci seq_puts(seq, 13868c2ecf20Sopenharmony_ci "No printing function for this routing protocol\n"); 13878c2ecf20Sopenharmony_ci goto out; 13888c2ecf20Sopenharmony_ci } 13898c2ecf20Sopenharmony_ci 13908c2ecf20Sopenharmony_ci if (hard_iface->if_status != BATADV_IF_ACTIVE) { 13918c2ecf20Sopenharmony_ci seq_puts(seq, "Interface not active\n"); 13928c2ecf20Sopenharmony_ci goto out; 13938c2ecf20Sopenharmony_ci } 13948c2ecf20Sopenharmony_ci 13958c2ecf20Sopenharmony_ci seq_printf(seq, "[B.A.T.M.A.N. adv %s, IF/MAC: %s/%pM (%s %s)]\n", 13968c2ecf20Sopenharmony_ci BATADV_SOURCE_VERSION, hard_iface->net_dev->name, 13978c2ecf20Sopenharmony_ci hard_iface->net_dev->dev_addr, 13988c2ecf20Sopenharmony_ci hard_iface->soft_iface->name, bat_priv->algo_ops->name); 13998c2ecf20Sopenharmony_ci 14008c2ecf20Sopenharmony_ci bat_priv->algo_ops->orig.print(bat_priv, seq, hard_iface); 14018c2ecf20Sopenharmony_ci 14028c2ecf20Sopenharmony_ciout: 14038c2ecf20Sopenharmony_ci if (hard_iface) 14048c2ecf20Sopenharmony_ci batadv_hardif_put(hard_iface); 14058c2ecf20Sopenharmony_ci return 0; 14068c2ecf20Sopenharmony_ci} 14078c2ecf20Sopenharmony_ci#endif 14088c2ecf20Sopenharmony_ci 14098c2ecf20Sopenharmony_ci/** 14108c2ecf20Sopenharmony_ci * batadv_orig_dump() - Dump to netlink the originator infos for a specific 14118c2ecf20Sopenharmony_ci * outgoing interface 14128c2ecf20Sopenharmony_ci * @msg: message to dump into 14138c2ecf20Sopenharmony_ci * @cb: parameters for the dump 14148c2ecf20Sopenharmony_ci * 14158c2ecf20Sopenharmony_ci * Return: 0 or error value 14168c2ecf20Sopenharmony_ci */ 14178c2ecf20Sopenharmony_ciint batadv_orig_dump(struct sk_buff *msg, struct netlink_callback *cb) 14188c2ecf20Sopenharmony_ci{ 14198c2ecf20Sopenharmony_ci struct net *net = sock_net(cb->skb->sk); 14208c2ecf20Sopenharmony_ci struct net_device *soft_iface; 14218c2ecf20Sopenharmony_ci struct net_device *hard_iface = NULL; 14228c2ecf20Sopenharmony_ci struct batadv_hard_iface *hardif = BATADV_IF_DEFAULT; 14238c2ecf20Sopenharmony_ci struct batadv_priv *bat_priv; 14248c2ecf20Sopenharmony_ci struct batadv_hard_iface *primary_if = NULL; 14258c2ecf20Sopenharmony_ci int ret; 14268c2ecf20Sopenharmony_ci int ifindex, hard_ifindex; 14278c2ecf20Sopenharmony_ci 14288c2ecf20Sopenharmony_ci ifindex = batadv_netlink_get_ifindex(cb->nlh, BATADV_ATTR_MESH_IFINDEX); 14298c2ecf20Sopenharmony_ci if (!ifindex) 14308c2ecf20Sopenharmony_ci return -EINVAL; 14318c2ecf20Sopenharmony_ci 14328c2ecf20Sopenharmony_ci soft_iface = dev_get_by_index(net, ifindex); 14338c2ecf20Sopenharmony_ci if (!soft_iface || !batadv_softif_is_valid(soft_iface)) { 14348c2ecf20Sopenharmony_ci ret = -ENODEV; 14358c2ecf20Sopenharmony_ci goto out; 14368c2ecf20Sopenharmony_ci } 14378c2ecf20Sopenharmony_ci 14388c2ecf20Sopenharmony_ci bat_priv = netdev_priv(soft_iface); 14398c2ecf20Sopenharmony_ci 14408c2ecf20Sopenharmony_ci primary_if = batadv_primary_if_get_selected(bat_priv); 14418c2ecf20Sopenharmony_ci if (!primary_if || primary_if->if_status != BATADV_IF_ACTIVE) { 14428c2ecf20Sopenharmony_ci ret = -ENOENT; 14438c2ecf20Sopenharmony_ci goto out; 14448c2ecf20Sopenharmony_ci } 14458c2ecf20Sopenharmony_ci 14468c2ecf20Sopenharmony_ci hard_ifindex = batadv_netlink_get_ifindex(cb->nlh, 14478c2ecf20Sopenharmony_ci BATADV_ATTR_HARD_IFINDEX); 14488c2ecf20Sopenharmony_ci if (hard_ifindex) { 14498c2ecf20Sopenharmony_ci hard_iface = dev_get_by_index(net, hard_ifindex); 14508c2ecf20Sopenharmony_ci if (hard_iface) 14518c2ecf20Sopenharmony_ci hardif = batadv_hardif_get_by_netdev(hard_iface); 14528c2ecf20Sopenharmony_ci 14538c2ecf20Sopenharmony_ci if (!hardif) { 14548c2ecf20Sopenharmony_ci ret = -ENODEV; 14558c2ecf20Sopenharmony_ci goto out; 14568c2ecf20Sopenharmony_ci } 14578c2ecf20Sopenharmony_ci 14588c2ecf20Sopenharmony_ci if (hardif->soft_iface != soft_iface) { 14598c2ecf20Sopenharmony_ci ret = -ENOENT; 14608c2ecf20Sopenharmony_ci goto out; 14618c2ecf20Sopenharmony_ci } 14628c2ecf20Sopenharmony_ci } 14638c2ecf20Sopenharmony_ci 14648c2ecf20Sopenharmony_ci if (!bat_priv->algo_ops->orig.dump) { 14658c2ecf20Sopenharmony_ci ret = -EOPNOTSUPP; 14668c2ecf20Sopenharmony_ci goto out; 14678c2ecf20Sopenharmony_ci } 14688c2ecf20Sopenharmony_ci 14698c2ecf20Sopenharmony_ci bat_priv->algo_ops->orig.dump(msg, cb, bat_priv, hardif); 14708c2ecf20Sopenharmony_ci 14718c2ecf20Sopenharmony_ci ret = msg->len; 14728c2ecf20Sopenharmony_ci 14738c2ecf20Sopenharmony_ci out: 14748c2ecf20Sopenharmony_ci if (hardif) 14758c2ecf20Sopenharmony_ci batadv_hardif_put(hardif); 14768c2ecf20Sopenharmony_ci if (hard_iface) 14778c2ecf20Sopenharmony_ci dev_put(hard_iface); 14788c2ecf20Sopenharmony_ci if (primary_if) 14798c2ecf20Sopenharmony_ci batadv_hardif_put(primary_if); 14808c2ecf20Sopenharmony_ci if (soft_iface) 14818c2ecf20Sopenharmony_ci dev_put(soft_iface); 14828c2ecf20Sopenharmony_ci 14838c2ecf20Sopenharmony_ci return ret; 14848c2ecf20Sopenharmony_ci} 1485