Blame view
net/batman-adv/distributed-arp-table.c
33.9 KB
0b8739314 batman-adv: updat... |
1 |
/* Copyright (C) 2011-2013 B.A.T.M.A.N. contributors: |
785ea1144 batman-adv: Distr... |
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
* * Antonio Quartulli * * This program is free software; you can redistribute it and/or * modify it under the terms of version 2 of the GNU General Public * License as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA * 02110-1301, USA */ #include <linux/if_ether.h> #include <linux/if_arp.h> |
be1db4f66 batman-adv: make ... |
22 |
#include <linux/if_vlan.h> |
c384ea3ec batman-adv: Distr... |
23 |
#include <net/arp.h> |
785ea1144 batman-adv: Distr... |
24 25 |
#include "main.h" |
5c3a0e553 batman-adv: Distr... |
26 |
#include "hash.h" |
785ea1144 batman-adv: Distr... |
27 28 29 30 31 |
#include "distributed-arp-table.h" #include "hard-interface.h" #include "originator.h" #include "send.h" #include "types.h" |
c384ea3ec batman-adv: Distr... |
32 |
#include "translation-table.h" |
785ea1144 batman-adv: Distr... |
33 |
|
2f1dfbe18 batman-adv: Distr... |
34 35 36 37 38 39 40 41 42 43 44 45 46 47 |
static void batadv_dat_purge(struct work_struct *work); /** * batadv_dat_start_timer - initialise the DAT periodic worker * @bat_priv: the bat priv with all the soft interface information */ static void batadv_dat_start_timer(struct batadv_priv *bat_priv) { INIT_DELAYED_WORK(&bat_priv->dat.work, batadv_dat_purge); queue_delayed_work(batadv_event_workqueue, &bat_priv->dat.work, msecs_to_jiffies(10000)); } /** |
93178018e batman-adv: fix t... |
48 |
* batadv_dat_entry_free_ref - decrement the dat_entry refcounter and possibly |
2f1dfbe18 batman-adv: Distr... |
49 |
* free it |
93178018e batman-adv: fix t... |
50 |
* @dat_entry: the entry to free |
2f1dfbe18 batman-adv: Distr... |
51 52 53 54 55 56 57 58 |
*/ static void batadv_dat_entry_free_ref(struct batadv_dat_entry *dat_entry) { if (atomic_dec_and_test(&dat_entry->refcount)) kfree_rcu(dat_entry, rcu); } /** |
93178018e batman-adv: fix t... |
59 |
* batadv_dat_to_purge - check whether a dat_entry has to be purged or not |
2f1dfbe18 batman-adv: Distr... |
60 61 |
* @dat_entry: the entry to check * |
93178018e batman-adv: fix t... |
62 |
* Returns true if the entry has to be purged now, false otherwise. |
2f1dfbe18 batman-adv: Distr... |
63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 |
*/ static bool batadv_dat_to_purge(struct batadv_dat_entry *dat_entry) { return batadv_has_timed_out(dat_entry->last_update, BATADV_DAT_ENTRY_TIMEOUT); } /** * __batadv_dat_purge - delete entries from the DAT local storage * @bat_priv: the bat priv with all the soft interface information * @to_purge: function in charge to decide whether an entry has to be purged or * not. This function takes the dat_entry as argument and has to * returns a boolean value: true is the entry has to be deleted, * false otherwise * |
93178018e batman-adv: fix t... |
78 79 |
* Loops over each entry in the DAT local storage and deletes it if and only if * the to_purge function passed as argument returns true. |
2f1dfbe18 batman-adv: Distr... |
80 81 82 83 84 85 |
*/ static void __batadv_dat_purge(struct batadv_priv *bat_priv, bool (*to_purge)(struct batadv_dat_entry *)) { spinlock_t *list_lock; /* protects write access to the hash lists */ struct batadv_dat_entry *dat_entry; |
b67bfe0d4 hlist: drop the n... |
86 |
struct hlist_node *node_tmp; |
2f1dfbe18 batman-adv: Distr... |
87 88 89 90 91 92 93 94 95 96 97 |
struct hlist_head *head; uint32_t i; if (!bat_priv->dat.hash) return; for (i = 0; i < bat_priv->dat.hash->size; i++) { head = &bat_priv->dat.hash->table[i]; list_lock = &bat_priv->dat.hash->list_locks[i]; spin_lock_bh(list_lock); |
b67bfe0d4 hlist: drop the n... |
98 |
hlist_for_each_entry_safe(dat_entry, node_tmp, head, |
2f1dfbe18 batman-adv: Distr... |
99 |
hash_entry) { |
93178018e batman-adv: fix t... |
100 |
/* if a helper function has been passed as parameter, |
2f1dfbe18 batman-adv: Distr... |
101 102 103 104 |
* ask it if the entry has to be purged or not */ if (to_purge && !to_purge(dat_entry)) continue; |
b67bfe0d4 hlist: drop the n... |
105 |
hlist_del_rcu(&dat_entry->hash_entry); |
2f1dfbe18 batman-adv: Distr... |
106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 |
batadv_dat_entry_free_ref(dat_entry); } spin_unlock_bh(list_lock); } } /** * batadv_dat_purge - periodic task that deletes old entries from the local DAT * hash table * @work: kernel work struct */ static void batadv_dat_purge(struct work_struct *work) { struct delayed_work *delayed_work; struct batadv_priv_dat *priv_dat; struct batadv_priv *bat_priv; delayed_work = container_of(work, struct delayed_work, work); priv_dat = container_of(delayed_work, struct batadv_priv_dat, work); bat_priv = container_of(priv_dat, struct batadv_priv, dat); __batadv_dat_purge(bat_priv, batadv_dat_to_purge); batadv_dat_start_timer(bat_priv); } /** * batadv_compare_dat - comparing function used in the local DAT hash table * @node: node in the local table * @data2: second object to compare the node to * |
93178018e batman-adv: fix t... |
136 |
* Returns 1 if the two entries are the same, 0 otherwise. |
2f1dfbe18 batman-adv: Distr... |
137 138 139 140 141 142 143 144 |
*/ static int batadv_compare_dat(const struct hlist_node *node, const void *data2) { const void *data1 = container_of(node, struct batadv_dat_entry, hash_entry); return (memcmp(data1, data2, sizeof(__be32)) == 0 ? 1 : 0); } |
785ea1144 batman-adv: Distr... |
145 |
/** |
5c3a0e553 batman-adv: Distr... |
146 147 148 149 |
* batadv_arp_hw_src - extract the hw_src field from an ARP packet * @skb: ARP packet * @hdr_size: size of the possible header before the ARP packet * |
93178018e batman-adv: fix t... |
150 |
* Returns the value of the hw_src field in the ARP packet. |
5c3a0e553 batman-adv: Distr... |
151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 |
*/ static uint8_t *batadv_arp_hw_src(struct sk_buff *skb, int hdr_size) { uint8_t *addr; addr = (uint8_t *)(skb->data + hdr_size); addr += ETH_HLEN + sizeof(struct arphdr); return addr; } /** * batadv_arp_ip_src - extract the ip_src field from an ARP packet * @skb: ARP packet * @hdr_size: size of the possible header before the ARP packet * |
93178018e batman-adv: fix t... |
167 |
* Returns the value of the ip_src field in the ARP packet. |
5c3a0e553 batman-adv: Distr... |
168 169 170 171 172 173 174 175 176 177 178 |
*/ static __be32 batadv_arp_ip_src(struct sk_buff *skb, int hdr_size) { return *(__be32 *)(batadv_arp_hw_src(skb, hdr_size) + ETH_ALEN); } /** * batadv_arp_hw_dst - extract the hw_dst field from an ARP packet * @skb: ARP packet * @hdr_size: size of the possible header before the ARP packet * |
93178018e batman-adv: fix t... |
179 |
* Returns the value of the hw_dst field in the ARP packet. |
5c3a0e553 batman-adv: Distr... |
180 181 182 183 184 185 186 187 188 189 190 |
*/ static uint8_t *batadv_arp_hw_dst(struct sk_buff *skb, int hdr_size) { return batadv_arp_hw_src(skb, hdr_size) + ETH_ALEN + 4; } /** * batadv_arp_ip_dst - extract the ip_dst field from an ARP packet * @skb: ARP packet * @hdr_size: size of the possible header before the ARP packet * |
93178018e batman-adv: fix t... |
191 |
* Returns the value of the ip_dst field in the ARP packet. |
5c3a0e553 batman-adv: Distr... |
192 193 194 195 196 197 198 |
*/ static __be32 batadv_arp_ip_dst(struct sk_buff *skb, int hdr_size) { return *(__be32 *)(batadv_arp_hw_src(skb, hdr_size) + ETH_ALEN * 2 + 4); } /** |
785ea1144 batman-adv: Distr... |
199 200 201 202 |
* batadv_hash_dat - compute the hash value for an IP address * @data: data to hash * @size: size of the hash table * |
93178018e batman-adv: fix t... |
203 |
* Returns the selected index in the hash table for the given data. |
785ea1144 batman-adv: Distr... |
204 205 206 |
*/ static uint32_t batadv_hash_dat(const void *data, uint32_t size) { |
785ea1144 batman-adv: Distr... |
207 |
uint32_t hash = 0; |
be1db4f66 batman-adv: make ... |
208 |
const struct batadv_dat_entry *dat = data; |
785ea1144 batman-adv: Distr... |
209 |
|
be1db4f66 batman-adv: make ... |
210 211 |
hash = batadv_hash_bytes(hash, &dat->ip, sizeof(dat->ip)); hash = batadv_hash_bytes(hash, &dat->vid, sizeof(dat->vid)); |
785ea1144 batman-adv: Distr... |
212 213 214 215 216 217 218 219 220 |
hash += (hash << 3); hash ^= (hash >> 11); hash += (hash << 15); return hash % size; } /** |
93178018e batman-adv: fix t... |
221 |
* batadv_dat_entry_hash_find - look for a given dat_entry in the local hash |
2f1dfbe18 batman-adv: Distr... |
222 223 224 |
* table * @bat_priv: the bat priv with all the soft interface information * @ip: search key |
be1db4f66 batman-adv: make ... |
225 |
* @vid: VLAN identifier |
2f1dfbe18 batman-adv: Distr... |
226 |
* |
93178018e batman-adv: fix t... |
227 |
* Returns the dat_entry if found, NULL otherwise. |
2f1dfbe18 batman-adv: Distr... |
228 229 |
*/ static struct batadv_dat_entry * |
be1db4f66 batman-adv: make ... |
230 231 |
batadv_dat_entry_hash_find(struct batadv_priv *bat_priv, __be32 ip, unsigned short vid) |
2f1dfbe18 batman-adv: Distr... |
232 233 |
{ struct hlist_head *head; |
be1db4f66 batman-adv: make ... |
234 |
struct batadv_dat_entry to_find, *dat_entry, *dat_entry_tmp = NULL; |
2f1dfbe18 batman-adv: Distr... |
235 236 237 238 239 |
struct batadv_hashtable *hash = bat_priv->dat.hash; uint32_t index; if (!hash) return NULL; |
be1db4f66 batman-adv: make ... |
240 241 242 243 |
to_find.ip = ip; to_find.vid = vid; index = batadv_hash_dat(&to_find, hash->size); |
2f1dfbe18 batman-adv: Distr... |
244 245 246 |
head = &hash->table[index]; rcu_read_lock(); |
b67bfe0d4 hlist: drop the n... |
247 |
hlist_for_each_entry_rcu(dat_entry, head, hash_entry) { |
2f1dfbe18 batman-adv: Distr... |
248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 |
if (dat_entry->ip != ip) continue; if (!atomic_inc_not_zero(&dat_entry->refcount)) continue; dat_entry_tmp = dat_entry; break; } rcu_read_unlock(); return dat_entry_tmp; } /** * batadv_dat_entry_add - add a new dat entry or update it if already exists * @bat_priv: the bat priv with all the soft interface information * @ip: ipv4 to add/edit * @mac_addr: mac address to assign to the given ipv4 |
be1db4f66 batman-adv: make ... |
267 |
* @vid: VLAN identifier |
2f1dfbe18 batman-adv: Distr... |
268 269 |
*/ static void batadv_dat_entry_add(struct batadv_priv *bat_priv, __be32 ip, |
be1db4f66 batman-adv: make ... |
270 |
uint8_t *mac_addr, unsigned short vid) |
2f1dfbe18 batman-adv: Distr... |
271 272 273 |
{ struct batadv_dat_entry *dat_entry; int hash_added; |
be1db4f66 batman-adv: make ... |
274 |
dat_entry = batadv_dat_entry_hash_find(bat_priv, ip, vid); |
2f1dfbe18 batman-adv: Distr... |
275 276 277 278 279 280 |
/* if this entry is already known, just update it */ if (dat_entry) { if (!batadv_compare_eth(dat_entry->mac_addr, mac_addr)) memcpy(dat_entry->mac_addr, mac_addr, ETH_ALEN); dat_entry->last_update = jiffies; batadv_dbg(BATADV_DBG_DAT, bat_priv, |
be1db4f66 batman-adv: make ... |
281 282 283 284 |
"Entry updated: %pI4 %pM (vid: %d) ", &dat_entry->ip, dat_entry->mac_addr, BATADV_PRINT_VID(vid)); |
2f1dfbe18 batman-adv: Distr... |
285 286 287 288 289 290 291 292 |
goto out; } dat_entry = kmalloc(sizeof(*dat_entry), GFP_ATOMIC); if (!dat_entry) goto out; dat_entry->ip = ip; |
be1db4f66 batman-adv: make ... |
293 |
dat_entry->vid = vid; |
2f1dfbe18 batman-adv: Distr... |
294 295 296 297 298 |
memcpy(dat_entry->mac_addr, mac_addr, ETH_ALEN); dat_entry->last_update = jiffies; atomic_set(&dat_entry->refcount, 2); hash_added = batadv_hash_add(bat_priv->dat.hash, batadv_compare_dat, |
be1db4f66 batman-adv: make ... |
299 |
batadv_hash_dat, dat_entry, |
2f1dfbe18 batman-adv: Distr... |
300 301 302 303 304 305 306 |
&dat_entry->hash_entry); if (unlikely(hash_added != 0)) { /* remove the reference for the hash */ batadv_dat_entry_free_ref(dat_entry); goto out; } |
be1db4f66 batman-adv: make ... |
307 308 309 |
batadv_dbg(BATADV_DBG_DAT, bat_priv, "New entry added: %pI4 %pM (vid: %d) ", &dat_entry->ip, dat_entry->mac_addr, BATADV_PRINT_VID(vid)); |
2f1dfbe18 batman-adv: Distr... |
310 311 312 313 314 |
out: if (dat_entry) batadv_dat_entry_free_ref(dat_entry); } |
5c3a0e553 batman-adv: Distr... |
315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 |
#ifdef CONFIG_BATMAN_ADV_DEBUG /** * batadv_dbg_arp - print a debug message containing all the ARP packet details * @bat_priv: the bat priv with all the soft interface information * @skb: ARP packet * @type: ARP type * @hdr_size: size of the possible header before the ARP packet * @msg: message to print together with the debugging information */ static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb, uint16_t type, int hdr_size, char *msg) { struct batadv_unicast_4addr_packet *unicast_4addr_packet; struct batadv_bcast_packet *bcast_pkt; uint8_t *orig_addr; __be32 ip_src, ip_dst; if (msg) batadv_dbg(BATADV_DBG_DAT, bat_priv, "%s ", msg); ip_src = batadv_arp_ip_src(skb, hdr_size); ip_dst = batadv_arp_ip_dst(skb, hdr_size); batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP MSG = [src: %pM-%pI4 dst: %pM-%pI4] ", batadv_arp_hw_src(skb, hdr_size), &ip_src, batadv_arp_hw_dst(skb, hdr_size), &ip_dst); if (hdr_size == 0) return; |
5c3a0e553 batman-adv: Distr... |
347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 |
unicast_4addr_packet = (struct batadv_unicast_4addr_packet *)skb->data; switch (unicast_4addr_packet->u.header.packet_type) { case BATADV_UNICAST: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* encapsulated within a UNICAST packet "); break; case BATADV_UNICAST_4ADDR: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* encapsulated within a UNICAST_4ADDR packet (src: %pM) ", unicast_4addr_packet->src); switch (unicast_4addr_packet->subtype) { case BATADV_P_DAT_DHT_PUT: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_PUT "); break; case BATADV_P_DAT_DHT_GET: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_GET "); break; case BATADV_P_DAT_CACHE_REPLY: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_CACHE_REPLY "); break; case BATADV_P_DATA: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DATA "); break; default: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: Unknown (%u)! ", unicast_4addr_packet->u.header.packet_type); } break; case BATADV_BCAST: bcast_pkt = (struct batadv_bcast_packet *)unicast_4addr_packet; orig_addr = bcast_pkt->orig; batadv_dbg(BATADV_DBG_DAT, bat_priv, "* encapsulated within a BCAST packet (src: %pM) ", orig_addr); break; default: batadv_dbg(BATADV_DBG_DAT, bat_priv, "* encapsulated within an unknown packet type (0x%x) ", unicast_4addr_packet->u.header.packet_type); } } #else static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb, uint16_t type, int hdr_size, char *msg) { } #endif /* CONFIG_BATMAN_ADV_DEBUG */ |
2f1dfbe18 batman-adv: Distr... |
408 |
/** |
785ea1144 batman-adv: Distr... |
409 410 411 412 413 414 415 416 417 |
* batadv_is_orig_node_eligible - check whether a node can be a DHT candidate * @res: the array with the already selected candidates * @select: number of already selected candidates * @tmp_max: address of the currently evaluated node * @max: current round max address * @last_max: address of the last selected candidate * @candidate: orig_node under evaluation * @max_orig_node: last selected candidate * |
93178018e batman-adv: fix t... |
418 419 |
* Returns true if the node has been elected as next candidate or false * otherwise. |
785ea1144 batman-adv: Distr... |
420 421 422 423 424 425 426 427 428 429 |
*/ static bool batadv_is_orig_node_eligible(struct batadv_dat_candidate *res, int select, batadv_dat_addr_t tmp_max, batadv_dat_addr_t max, batadv_dat_addr_t last_max, struct batadv_orig_node *candidate, struct batadv_orig_node *max_orig_node) { bool ret = false; int j; |
17cf0ea45 batman-adv: tvlv ... |
430 431 432 |
/* check if orig node candidate is running DAT */ if (!(candidate->capabilities & BATADV_ORIG_CAPA_HAS_DAT)) goto out; |
785ea1144 batman-adv: Distr... |
433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 |
/* Check if this node has already been selected... */ for (j = 0; j < select; j++) if (res[j].orig_node == candidate) break; /* ..and possibly skip it */ if (j < select) goto out; /* sanity check: has it already been selected? This should not happen */ if (tmp_max > last_max) goto out; /* check if during this iteration an originator with a closer dht * address has already been found */ if (tmp_max < max) goto out; /* this is an hash collision with the temporary selected node. Choose * the one with the lowest address */ |
816cd5b83 batman-adv: Fix N... |
451 |
if ((tmp_max == max) && max_orig_node && |
785ea1144 batman-adv: Distr... |
452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 |
(batadv_compare_eth(candidate->orig, max_orig_node->orig) > 0)) goto out; ret = true; out: return ret; } /** * batadv_choose_next_candidate - select the next DHT candidate * @bat_priv: the bat priv with all the soft interface information * @cands: candidates array * @select: number of candidates already present in the array * @ip_key: key to look up in the DHT * @last_max: pointer where the address of the selected candidate will be saved */ static void batadv_choose_next_candidate(struct batadv_priv *bat_priv, struct batadv_dat_candidate *cands, int select, batadv_dat_addr_t ip_key, batadv_dat_addr_t *last_max) { batadv_dat_addr_t max = 0, tmp_max = 0; struct batadv_orig_node *orig_node, *max_orig_node = NULL; struct batadv_hashtable *hash = bat_priv->orig_hash; |
785ea1144 batman-adv: Distr... |
476 477 478 479 480 481 482 |
struct hlist_head *head; int i; /* if no node is eligible as candidate, leave the candidate type as * NOT_FOUND */ cands[select].type = BATADV_DAT_CANDIDATE_NOT_FOUND; |
93178018e batman-adv: fix t... |
483 |
/* iterate over the originator list and find the node with the closest |
785ea1144 batman-adv: Distr... |
484 485 486 487 488 489 |
* dat_address which has not been selected yet */ for (i = 0; i < hash->size; i++) { head = &hash->table[i]; rcu_read_lock(); |
b67bfe0d4 hlist: drop the n... |
490 |
hlist_for_each_entry_rcu(orig_node, head, hash_entry) { |
93178018e batman-adv: fix t... |
491 |
/* the dht space is a ring using unsigned addresses */ |
785ea1144 batman-adv: Distr... |
492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 |
tmp_max = BATADV_DAT_ADDR_MAX - orig_node->dat_addr + ip_key; if (!batadv_is_orig_node_eligible(cands, select, tmp_max, max, *last_max, orig_node, max_orig_node)) continue; if (!atomic_inc_not_zero(&orig_node->refcount)) continue; max = tmp_max; if (max_orig_node) batadv_orig_node_free_ref(max_orig_node); max_orig_node = orig_node; } rcu_read_unlock(); } if (max_orig_node) { cands[select].type = BATADV_DAT_CANDIDATE_ORIG; cands[select].orig_node = max_orig_node; batadv_dbg(BATADV_DBG_DAT, bat_priv, "dat_select_candidates() %d: selected %pM addr=%u dist=%u ", select, max_orig_node->orig, max_orig_node->dat_addr, max); } *last_max = max; } /** |
93178018e batman-adv: fix t... |
524 |
* batadv_dat_select_candidates - select the nodes which the DHT message has to |
785ea1144 batman-adv: Distr... |
525 526 527 528 529 530 531 532 |
* be sent to * @bat_priv: the bat priv with all the soft interface information * @ip_dst: ipv4 to look up in the DHT * * An originator O is selected if and only if its DHT_ID value is one of three * closest values (from the LEFT, with wrap around if needed) then the hash * value of the key. ip_dst is the key. * |
93178018e batman-adv: fix t... |
533 |
* Returns the candidate array of size BATADV_DAT_CANDIDATE_NUM. |
785ea1144 batman-adv: Distr... |
534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 |
*/ static struct batadv_dat_candidate * batadv_dat_select_candidates(struct batadv_priv *bat_priv, __be32 ip_dst) { int select; batadv_dat_addr_t last_max = BATADV_DAT_ADDR_MAX, ip_key; struct batadv_dat_candidate *res; if (!bat_priv->orig_hash) return NULL; res = kmalloc(BATADV_DAT_CANDIDATES_NUM * sizeof(*res), GFP_ATOMIC); if (!res) return NULL; ip_key = (batadv_dat_addr_t)batadv_hash_dat(&ip_dst, BATADV_DAT_ADDR_MAX); batadv_dbg(BATADV_DBG_DAT, bat_priv, "dat_select_candidates(): IP=%pI4 hash(IP)=%u ", &ip_dst, ip_key); for (select = 0; select < BATADV_DAT_CANDIDATES_NUM; select++) batadv_choose_next_candidate(bat_priv, res, select, ip_key, &last_max); return res; } /** * batadv_dat_send_data - send a payload to the selected candidates * @bat_priv: the bat priv with all the soft interface information * @skb: payload to send * @ip: the DHT key * @packet_subtype: unicast4addr packet subtype to use * |
93178018e batman-adv: fix t... |
571 572 |
* This function copies the skb with pskb_copy() and is sent as unicast packet * to each of the selected candidates. |
785ea1144 batman-adv: Distr... |
573 |
* |
93178018e batman-adv: fix t... |
574 575 |
* Returns true if the packet is sent to at least one candidate, false * otherwise. |
785ea1144 batman-adv: Distr... |
576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 |
*/ static bool batadv_dat_send_data(struct batadv_priv *bat_priv, struct sk_buff *skb, __be32 ip, int packet_subtype) { int i; bool ret = false; int send_status; struct batadv_neigh_node *neigh_node = NULL; struct sk_buff *tmp_skb; struct batadv_dat_candidate *cand; cand = batadv_dat_select_candidates(bat_priv, ip); if (!cand) goto out; batadv_dbg(BATADV_DBG_DAT, bat_priv, "DHT_SEND for %pI4 ", &ip); for (i = 0; i < BATADV_DAT_CANDIDATES_NUM; i++) { if (cand[i].type == BATADV_DAT_CANDIDATE_NOT_FOUND) continue; neigh_node = batadv_orig_node_get_router(cand[i].orig_node); if (!neigh_node) goto free_orig; tmp_skb = pskb_copy(skb, GFP_ATOMIC); |
f097e25db batman-adv: Remov... |
604 605 606 |
if (!batadv_send_skb_prepare_unicast_4addr(bat_priv, tmp_skb, cand[i].orig_node, packet_subtype)) { |
785ea1144 batman-adv: Distr... |
607 608 609 610 611 612 613 |
kfree_skb(tmp_skb); goto free_neigh; } send_status = batadv_send_skb_packet(tmp_skb, neigh_node->if_incoming, neigh_node->addr); |
4046b24af batman-adv: Add g... |
614 615 616 617 618 619 620 621 622 623 624 625 |
if (send_status == NET_XMIT_SUCCESS) { /* count the sent packet */ switch (packet_subtype) { case BATADV_P_DAT_DHT_GET: batadv_inc_counter(bat_priv, BATADV_CNT_DAT_GET_TX); break; case BATADV_P_DAT_DHT_PUT: batadv_inc_counter(bat_priv, BATADV_CNT_DAT_PUT_TX); break; } |
785ea1144 batman-adv: Distr... |
626 627 |
/* packet sent to a candidate: return true */ ret = true; |
4046b24af batman-adv: Add g... |
628 |
} |
785ea1144 batman-adv: Distr... |
629 630 631 632 633 634 635 636 637 638 |
free_neigh: batadv_neigh_node_free_ref(neigh_node); free_orig: batadv_orig_node_free_ref(cand[i].orig_node); } out: kfree(cand); return ret; } |
2f1dfbe18 batman-adv: Distr... |
639 640 |
/** |
17cf0ea45 batman-adv: tvlv ... |
641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 |
* batadv_dat_tvlv_container_update - update the dat tvlv container after dat * setting change * @bat_priv: the bat priv with all the soft interface information */ static void batadv_dat_tvlv_container_update(struct batadv_priv *bat_priv) { char dat_mode; dat_mode = atomic_read(&bat_priv->distributed_arp_table); switch (dat_mode) { case 0: batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1); break; case 1: batadv_tvlv_container_register(bat_priv, BATADV_TVLV_DAT, 1, NULL, 0); break; } } /** * batadv_dat_status_update - update the dat tvlv container after dat * setting change * @net_dev: the soft interface net device */ void batadv_dat_status_update(struct net_device *net_dev) { struct batadv_priv *bat_priv = netdev_priv(net_dev); batadv_dat_tvlv_container_update(bat_priv); } /** * batadv_gw_tvlv_ogm_handler_v1 - process incoming dat tvlv container * @bat_priv: the bat priv with all the soft interface information * @orig: the orig_node of the ogm * @flags: flags indicating the tvlv state (see batadv_tvlv_handler_flags) * @tvlv_value: tvlv buffer containing the gateway data * @tvlv_value_len: tvlv buffer length */ static void batadv_dat_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv, struct batadv_orig_node *orig, uint8_t flags, void *tvlv_value, uint16_t tvlv_value_len) { if (flags & BATADV_TVLV_HANDLER_OGM_CIFNOTFND) orig->capabilities &= ~BATADV_ORIG_CAPA_HAS_DAT; else orig->capabilities |= BATADV_ORIG_CAPA_HAS_DAT; } /** |
2f1dfbe18 batman-adv: Distr... |
694 695 696 697 698 |
* batadv_dat_hash_free - free the local DAT hash table * @bat_priv: the bat priv with all the soft interface information */ static void batadv_dat_hash_free(struct batadv_priv *bat_priv) { |
33af49ad8 batman-adv: Distr... |
699 700 |
if (!bat_priv->dat.hash) return; |
2f1dfbe18 batman-adv: Distr... |
701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 |
__batadv_dat_purge(bat_priv, NULL); batadv_hash_destroy(bat_priv->dat.hash); bat_priv->dat.hash = NULL; } /** * batadv_dat_init - initialise the DAT internals * @bat_priv: the bat priv with all the soft interface information */ int batadv_dat_init(struct batadv_priv *bat_priv) { if (bat_priv->dat.hash) return 0; bat_priv->dat.hash = batadv_hash_new(1024); if (!bat_priv->dat.hash) return -ENOMEM; batadv_dat_start_timer(bat_priv); |
17cf0ea45 batman-adv: tvlv ... |
723 724 725 726 |
batadv_tvlv_handler_register(bat_priv, batadv_dat_tvlv_ogm_handler_v1, NULL, BATADV_TVLV_DAT, 1, BATADV_TVLV_HANDLER_OGM_CIFNOTFND); batadv_dat_tvlv_container_update(bat_priv); |
2f1dfbe18 batman-adv: Distr... |
727 728 729 730 731 732 733 734 735 |
return 0; } /** * batadv_dat_free - free the DAT internals * @bat_priv: the bat priv with all the soft interface information */ void batadv_dat_free(struct batadv_priv *bat_priv) { |
17cf0ea45 batman-adv: tvlv ... |
736 737 |
batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1); batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_DAT, 1); |
2f1dfbe18 batman-adv: Distr... |
738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 |
cancel_delayed_work_sync(&bat_priv->dat.work); batadv_dat_hash_free(bat_priv); } /** * batadv_dat_cache_seq_print_text - print the local DAT hash table * @seq: seq file to print on * @offset: not used */ int batadv_dat_cache_seq_print_text(struct seq_file *seq, void *offset) { struct net_device *net_dev = (struct net_device *)seq->private; struct batadv_priv *bat_priv = netdev_priv(net_dev); struct batadv_hashtable *hash = bat_priv->dat.hash; struct batadv_dat_entry *dat_entry; struct batadv_hard_iface *primary_if; |
2f1dfbe18 batman-adv: Distr... |
755 756 757 758 759 760 761 762 763 764 765 |
struct hlist_head *head; unsigned long last_seen_jiffies; int last_seen_msecs, last_seen_secs, last_seen_mins; uint32_t i; primary_if = batadv_seq_print_text_primary_if_get(seq); if (!primary_if) goto out; seq_printf(seq, "Distributed ARP Table (%s): ", net_dev->name); |
be1db4f66 batman-adv: make ... |
766 767 768 |
seq_printf(seq, " %-7s %-9s %4s %11s ", "IPv4", "MAC", "VID", "last-seen"); |
2f1dfbe18 batman-adv: Distr... |
769 770 771 772 773 |
for (i = 0; i < hash->size; i++) { head = &hash->table[i]; rcu_read_lock(); |
b67bfe0d4 hlist: drop the n... |
774 |
hlist_for_each_entry_rcu(dat_entry, head, hash_entry) { |
2f1dfbe18 batman-adv: Distr... |
775 776 777 778 779 |
last_seen_jiffies = jiffies - dat_entry->last_update; last_seen_msecs = jiffies_to_msecs(last_seen_jiffies); last_seen_mins = last_seen_msecs / 60000; last_seen_msecs = last_seen_msecs % 60000; last_seen_secs = last_seen_msecs / 1000; |
be1db4f66 batman-adv: make ... |
780 781 |
seq_printf(seq, " * %15pI4 %14pM %4i %6i:%02i ", |
2f1dfbe18 batman-adv: Distr... |
782 |
&dat_entry->ip, dat_entry->mac_addr, |
be1db4f66 batman-adv: make ... |
783 |
BATADV_PRINT_VID(dat_entry->vid), |
2f1dfbe18 batman-adv: Distr... |
784 785 786 787 788 789 790 791 792 793 |
last_seen_mins, last_seen_secs); } rcu_read_unlock(); } out: if (primary_if) batadv_hardif_free_ref(primary_if); return 0; } |
5c3a0e553 batman-adv: Distr... |
794 795 796 797 798 799 800 |
/** * batadv_arp_get_type - parse an ARP packet and gets the type * @bat_priv: the bat priv with all the soft interface information * @skb: packet to analyse * @hdr_size: size of the possible header before the ARP packet in the skb * |
93178018e batman-adv: fix t... |
801 |
* Returns the ARP type if the skb contains a valid ARP packet, 0 otherwise. |
5c3a0e553 batman-adv: Distr... |
802 803 804 805 806 807 808 |
*/ static uint16_t batadv_arp_get_type(struct batadv_priv *bat_priv, struct sk_buff *skb, int hdr_size) { struct arphdr *arphdr; struct ethhdr *ethhdr; __be32 ip_src, ip_dst; |
b618ad110 batman-adv: filte... |
809 |
uint8_t *hw_src, *hw_dst; |
5c3a0e553 batman-adv: Distr... |
810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 |
uint16_t type = 0; /* pull the ethernet header */ if (unlikely(!pskb_may_pull(skb, hdr_size + ETH_HLEN))) goto out; ethhdr = (struct ethhdr *)(skb->data + hdr_size); if (ethhdr->h_proto != htons(ETH_P_ARP)) goto out; /* pull the ARP payload */ if (unlikely(!pskb_may_pull(skb, hdr_size + ETH_HLEN + arp_hdr_len(skb->dev)))) goto out; arphdr = (struct arphdr *)(skb->data + hdr_size + ETH_HLEN); |
93178018e batman-adv: fix t... |
827 |
/* check whether the ARP packet carries a valid IP information */ |
5c3a0e553 batman-adv: Distr... |
828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 |
if (arphdr->ar_hrd != htons(ARPHRD_ETHER)) goto out; if (arphdr->ar_pro != htons(ETH_P_IP)) goto out; if (arphdr->ar_hln != ETH_ALEN) goto out; if (arphdr->ar_pln != 4) goto out; /* Check for bad reply/request. If the ARP message is not sane, DAT * will simply ignore it */ ip_src = batadv_arp_ip_src(skb, hdr_size); ip_dst = batadv_arp_ip_dst(skb, hdr_size); if (ipv4_is_loopback(ip_src) || ipv4_is_multicast(ip_src) || |
757dd82ea batman-adv: check... |
846 847 848 |
ipv4_is_loopback(ip_dst) || ipv4_is_multicast(ip_dst) || ipv4_is_zeronet(ip_src) || ipv4_is_lbcast(ip_src) || ipv4_is_zeronet(ip_dst) || ipv4_is_lbcast(ip_dst)) |
5c3a0e553 batman-adv: Distr... |
849 |
goto out; |
b618ad110 batman-adv: filte... |
850 851 852 |
hw_src = batadv_arp_hw_src(skb, hdr_size); if (is_zero_ether_addr(hw_src) || is_multicast_ether_addr(hw_src)) goto out; |
93178018e batman-adv: fix t... |
853 |
/* don't care about the destination MAC address in ARP requests */ |
b618ad110 batman-adv: filte... |
854 855 856 857 858 859 |
if (arphdr->ar_op != htons(ARPOP_REQUEST)) { hw_dst = batadv_arp_hw_dst(skb, hdr_size); if (is_zero_ether_addr(hw_dst) || is_multicast_ether_addr(hw_dst)) goto out; } |
5c3a0e553 batman-adv: Distr... |
860 861 862 863 |
type = ntohs(arphdr->ar_op); out: return type; } |
c384ea3ec batman-adv: Distr... |
864 865 |
/** |
be1db4f66 batman-adv: make ... |
866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 |
* batadv_dat_get_vid - extract the VLAN identifier from skb if any * @skb: the buffer containing the packet to extract the VID from * @hdr_size: the size of the batman-adv header encapsulating the packet * * If the packet embedded in the skb is vlan tagged this function returns the * VID with the BATADV_VLAN_HAS_TAG flag. Otherwise BATADV_NO_FLAGS is returned. */ static unsigned short batadv_dat_get_vid(struct sk_buff *skb, int *hdr_size) { unsigned short vid; vid = batadv_get_vid(skb, *hdr_size); /* ARP parsing functions jump forward of hdr_size + ETH_HLEN. * If the header contained in the packet is a VLAN one (which is longer) * hdr_size is updated so that the functions will still skip the * correct amount of bytes. */ if (vid & BATADV_VLAN_HAS_TAG) *hdr_size += VLAN_HLEN; return vid; } /** |
c384ea3ec batman-adv: Distr... |
891 892 893 894 895 896 |
* batadv_dat_snoop_outgoing_arp_request - snoop the ARP request and try to * answer using DAT * @bat_priv: the bat priv with all the soft interface information * @skb: packet to check * * Returns true if the message has been sent to the dht candidates, false |
93178018e batman-adv: fix t... |
897 898 |
* otherwise. In case of a positive return value the message has to be enqueued * to permit the fallback. |
c384ea3ec batman-adv: Distr... |
899 900 901 902 903 904 905 906 907 908 |
*/ bool batadv_dat_snoop_outgoing_arp_request(struct batadv_priv *bat_priv, struct sk_buff *skb) { uint16_t type = 0; __be32 ip_dst, ip_src; uint8_t *hw_src; bool ret = false; struct batadv_dat_entry *dat_entry = NULL; struct sk_buff *skb_new; |
be1db4f66 batman-adv: make ... |
909 910 |
int hdr_size = 0; unsigned short vid; |
c384ea3ec batman-adv: Distr... |
911 |
|
33af49ad8 batman-adv: Distr... |
912 913 |
if (!atomic_read(&bat_priv->distributed_arp_table)) goto out; |
be1db4f66 batman-adv: make ... |
914 915 916 |
vid = batadv_dat_get_vid(skb, &hdr_size); type = batadv_arp_get_type(bat_priv, skb, hdr_size); |
c384ea3ec batman-adv: Distr... |
917 918 919 920 921 |
/* If the node gets an ARP_REQUEST it has to send a DHT_GET unicast * message to the selected DHT candidates */ if (type != ARPOP_REQUEST) goto out; |
be1db4f66 batman-adv: make ... |
922 923 |
batadv_dbg_arp(bat_priv, skb, type, hdr_size, "Parsing outgoing ARP REQUEST"); |
c384ea3ec batman-adv: Distr... |
924 |
|
be1db4f66 batman-adv: make ... |
925 926 927 |
ip_src = batadv_arp_ip_src(skb, hdr_size); hw_src = batadv_arp_hw_src(skb, hdr_size); ip_dst = batadv_arp_ip_dst(skb, hdr_size); |
c384ea3ec batman-adv: Distr... |
928 |
|
be1db4f66 batman-adv: make ... |
929 |
batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); |
c384ea3ec batman-adv: Distr... |
930 |
|
be1db4f66 batman-adv: make ... |
931 |
dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); |
c384ea3ec batman-adv: Distr... |
932 |
if (dat_entry) { |
88e48d7b3 batman-adv: make ... |
933 934 935 936 937 938 939 940 |
/* If the ARP request is destined for a local client the local * client will answer itself. DAT would only generate a * duplicate packet. * * Moreover, if the soft-interface is enslaved into a bridge, an * additional DAT answer may trigger kernel warnings about * a packet coming from the wrong port. */ |
c018ad3de batman-adv: add t... |
941 942 |
if (batadv_is_my_client(bat_priv, dat_entry->mac_addr, BATADV_NO_FLAGS)) { |
88e48d7b3 batman-adv: make ... |
943 944 945 |
ret = true; goto out; } |
c384ea3ec batman-adv: Distr... |
946 |
skb_new = arp_create(ARPOP_REPLY, ETH_P_ARP, ip_src, |
736292c2e batman-adv: repla... |
947 |
bat_priv->soft_iface, ip_dst, hw_src, |
c384ea3ec batman-adv: Distr... |
948 949 950 |
dat_entry->mac_addr, hw_src); if (!skb_new) goto out; |
be1db4f66 batman-adv: make ... |
951 952 953 |
if (vid & BATADV_VLAN_HAS_TAG) skb_new = vlan_insert_tag(skb_new, htons(ETH_P_8021Q), vid & VLAN_VID_MASK); |
c384ea3ec batman-adv: Distr... |
954 955 |
skb_reset_mac_header(skb_new); skb_new->protocol = eth_type_trans(skb_new, |
736292c2e batman-adv: repla... |
956 |
bat_priv->soft_iface); |
c384ea3ec batman-adv: Distr... |
957 |
bat_priv->stats.rx_packets++; |
be1db4f66 batman-adv: make ... |
958 |
bat_priv->stats.rx_bytes += skb->len + ETH_HLEN + hdr_size; |
736292c2e batman-adv: repla... |
959 |
bat_priv->soft_iface->last_rx = jiffies; |
c384ea3ec batman-adv: Distr... |
960 961 962 963 964 965 |
netif_rx(skb_new); batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP request replied locally "); ret = true; } else { |
93178018e batman-adv: fix t... |
966 |
/* Send the request to the DHT */ |
c384ea3ec batman-adv: Distr... |
967 968 969 970 971 972 |
ret = batadv_dat_send_data(bat_priv, skb, ip_dst, BATADV_P_DAT_DHT_GET); } out: if (dat_entry) batadv_dat_entry_free_ref(dat_entry); |
c384ea3ec batman-adv: Distr... |
973 974 975 976 977 978 979 980 981 982 |
return ret; } /** * batadv_dat_snoop_incoming_arp_request - snoop the ARP request and try to * answer using the local DAT storage * @bat_priv: the bat priv with all the soft interface information * @skb: packet to check * @hdr_size: size of the encapsulation header * |
93178018e batman-adv: fix t... |
983 |
* Returns true if the request has been answered, false otherwise. |
c384ea3ec batman-adv: Distr... |
984 985 986 987 988 989 990 991 |
*/ bool batadv_dat_snoop_incoming_arp_request(struct batadv_priv *bat_priv, struct sk_buff *skb, int hdr_size) { uint16_t type; __be32 ip_src, ip_dst; uint8_t *hw_src; struct sk_buff *skb_new; |
c384ea3ec batman-adv: Distr... |
992 993 |
struct batadv_dat_entry *dat_entry = NULL; bool ret = false; |
be1db4f66 batman-adv: make ... |
994 |
unsigned short vid; |
c384ea3ec batman-adv: Distr... |
995 |
int err; |
33af49ad8 batman-adv: Distr... |
996 997 |
if (!atomic_read(&bat_priv->distributed_arp_table)) goto out; |
be1db4f66 batman-adv: make ... |
998 |
vid = batadv_dat_get_vid(skb, &hdr_size); |
c384ea3ec batman-adv: Distr... |
999 1000 1001 1002 1003 1004 1005 1006 1007 1008 |
type = batadv_arp_get_type(bat_priv, skb, hdr_size); if (type != ARPOP_REQUEST) goto out; hw_src = batadv_arp_hw_src(skb, hdr_size); ip_src = batadv_arp_ip_src(skb, hdr_size); ip_dst = batadv_arp_ip_dst(skb, hdr_size); batadv_dbg_arp(bat_priv, skb, type, hdr_size, "Parsing incoming ARP REQUEST"); |
be1db4f66 batman-adv: make ... |
1009 |
batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); |
c384ea3ec batman-adv: Distr... |
1010 |
|
be1db4f66 batman-adv: make ... |
1011 |
dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); |
c384ea3ec batman-adv: Distr... |
1012 1013 |
if (!dat_entry) goto out; |
c384ea3ec batman-adv: Distr... |
1014 |
skb_new = arp_create(ARPOP_REPLY, ETH_P_ARP, ip_src, |
736292c2e batman-adv: repla... |
1015 |
bat_priv->soft_iface, ip_dst, hw_src, |
c384ea3ec batman-adv: Distr... |
1016 1017 1018 1019 |
dat_entry->mac_addr, hw_src); if (!skb_new) goto out; |
be1db4f66 batman-adv: make ... |
1020 1021 1022 |
if (vid & BATADV_VLAN_HAS_TAG) skb_new = vlan_insert_tag(skb_new, htons(ETH_P_8021Q), vid & VLAN_VID_MASK); |
93178018e batman-adv: fix t... |
1023 1024 1025 |
/* To preserve backwards compatibility, the node has choose the outgoing * format based on the incoming request packet type. The assumption is * that a node not using the 4addr packet format doesn't support it. |
c384ea3ec batman-adv: Distr... |
1026 1027 |
*/ if (hdr_size == sizeof(struct batadv_unicast_4addr_packet)) |
e300d3146 batman-adv: refin... |
1028 1029 1030 |
err = batadv_send_skb_via_tt_4addr(bat_priv, skb_new, BATADV_P_DAT_CACHE_REPLY, vid); |
c384ea3ec batman-adv: Distr... |
1031 |
else |
e300d3146 batman-adv: refin... |
1032 |
err = batadv_send_skb_via_tt(bat_priv, skb_new, vid); |
c384ea3ec batman-adv: Distr... |
1033 |
|
e300d3146 batman-adv: refin... |
1034 |
if (err != NET_XMIT_DROP) { |
4046b24af batman-adv: Add g... |
1035 |
batadv_inc_counter(bat_priv, BATADV_CNT_DAT_CACHED_REPLY_TX); |
c384ea3ec batman-adv: Distr... |
1036 |
ret = true; |
4046b24af batman-adv: Add g... |
1037 |
} |
c384ea3ec batman-adv: Distr... |
1038 1039 1040 |
out: if (dat_entry) batadv_dat_entry_free_ref(dat_entry); |
c384ea3ec batman-adv: Distr... |
1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 |
if (ret) kfree_skb(skb); return ret; } /** * batadv_dat_snoop_outgoing_arp_reply - snoop the ARP reply and fill the DHT * @bat_priv: the bat priv with all the soft interface information * @skb: packet to check */ void batadv_dat_snoop_outgoing_arp_reply(struct batadv_priv *bat_priv, struct sk_buff *skb) { uint16_t type; __be32 ip_src, ip_dst; uint8_t *hw_src, *hw_dst; |
be1db4f66 batman-adv: make ... |
1057 1058 |
int hdr_size = 0; unsigned short vid; |
c384ea3ec batman-adv: Distr... |
1059 |
|
33af49ad8 batman-adv: Distr... |
1060 1061 |
if (!atomic_read(&bat_priv->distributed_arp_table)) return; |
be1db4f66 batman-adv: make ... |
1062 1063 1064 |
vid = batadv_dat_get_vid(skb, &hdr_size); type = batadv_arp_get_type(bat_priv, skb, hdr_size); |
c384ea3ec batman-adv: Distr... |
1065 1066 |
if (type != ARPOP_REPLY) return; |
be1db4f66 batman-adv: make ... |
1067 1068 |
batadv_dbg_arp(bat_priv, skb, type, hdr_size, "Parsing outgoing ARP REPLY"); |
c384ea3ec batman-adv: Distr... |
1069 |
|
be1db4f66 batman-adv: make ... |
1070 1071 1072 1073 |
hw_src = batadv_arp_hw_src(skb, hdr_size); ip_src = batadv_arp_ip_src(skb, hdr_size); hw_dst = batadv_arp_hw_dst(skb, hdr_size); ip_dst = batadv_arp_ip_dst(skb, hdr_size); |
c384ea3ec batman-adv: Distr... |
1074 |
|
be1db4f66 batman-adv: make ... |
1075 1076 |
batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); |
c384ea3ec batman-adv: Distr... |
1077 1078 |
/* Send the ARP reply to the candidates for both the IP addresses that |
93178018e batman-adv: fix t... |
1079 |
* the node obtained from the ARP reply |
c384ea3ec batman-adv: Distr... |
1080 1081 1082 1083 1084 1085 1086 1087 1088 |
*/ batadv_dat_send_data(bat_priv, skb, ip_src, BATADV_P_DAT_DHT_PUT); batadv_dat_send_data(bat_priv, skb, ip_dst, BATADV_P_DAT_DHT_PUT); } /** * batadv_dat_snoop_incoming_arp_reply - snoop the ARP reply and fill the local * DAT storage only * @bat_priv: the bat priv with all the soft interface information * @skb: packet to check |
93178018e batman-adv: fix t... |
1089 |
* @hdr_size: size of the encapsulation header |
c384ea3ec batman-adv: Distr... |
1090 1091 1092 1093 1094 1095 1096 1097 |
*/ bool batadv_dat_snoop_incoming_arp_reply(struct batadv_priv *bat_priv, struct sk_buff *skb, int hdr_size) { uint16_t type; __be32 ip_src, ip_dst; uint8_t *hw_src, *hw_dst; bool ret = false; |
be1db4f66 batman-adv: make ... |
1098 |
unsigned short vid; |
c384ea3ec batman-adv: Distr... |
1099 |
|
33af49ad8 batman-adv: Distr... |
1100 1101 |
if (!atomic_read(&bat_priv->distributed_arp_table)) goto out; |
be1db4f66 batman-adv: make ... |
1102 |
vid = batadv_dat_get_vid(skb, &hdr_size); |
c384ea3ec batman-adv: Distr... |
1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 |
type = batadv_arp_get_type(bat_priv, skb, hdr_size); if (type != ARPOP_REPLY) goto out; batadv_dbg_arp(bat_priv, skb, type, hdr_size, "Parsing incoming ARP REPLY"); hw_src = batadv_arp_hw_src(skb, hdr_size); ip_src = batadv_arp_ip_src(skb, hdr_size); hw_dst = batadv_arp_hw_dst(skb, hdr_size); ip_dst = batadv_arp_ip_dst(skb, hdr_size); /* Update our internal cache with both the IP addresses the node got * within the ARP reply */ |
be1db4f66 batman-adv: make ... |
1118 1119 |
batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); |
c384ea3ec batman-adv: Distr... |
1120 1121 1122 1123 |
/* if this REPLY is directed to a client of mine, let's deliver the * packet to the interface */ |
be1db4f66 batman-adv: make ... |
1124 |
ret = !batadv_is_my_client(bat_priv, hw_dst, vid); |
c384ea3ec batman-adv: Distr... |
1125 |
out: |
0d15becee batman-adv: fix s... |
1126 1127 |
if (ret) kfree_skb(skb); |
c384ea3ec batman-adv: Distr... |
1128 1129 1130 1131 1132 1133 |
/* if ret == false -> packet has to be delivered to the interface */ return ret; } /** * batadv_dat_drop_broadcast_packet - check if an ARP request has to be dropped |
93178018e batman-adv: fix t... |
1134 |
* (because the node has already obtained the reply via DAT) or not |
c384ea3ec batman-adv: Distr... |
1135 1136 1137 |
* @bat_priv: the bat priv with all the soft interface information * @forw_packet: the broadcast packet * |
93178018e batman-adv: fix t... |
1138 |
* Returns true if the node can drop the packet, false otherwise. |
c384ea3ec batman-adv: Distr... |
1139 1140 1141 1142 1143 1144 1145 1146 |
*/ bool batadv_dat_drop_broadcast_packet(struct batadv_priv *bat_priv, struct batadv_forw_packet *forw_packet) { uint16_t type; __be32 ip_dst; struct batadv_dat_entry *dat_entry = NULL; bool ret = false; |
be1db4f66 batman-adv: make ... |
1147 1148 |
int hdr_size = sizeof(struct batadv_bcast_packet); unsigned short vid; |
c384ea3ec batman-adv: Distr... |
1149 |
|
33af49ad8 batman-adv: Distr... |
1150 1151 |
if (!atomic_read(&bat_priv->distributed_arp_table)) goto out; |
c384ea3ec batman-adv: Distr... |
1152 1153 1154 1155 1156 |
/* If this packet is an ARP_REQUEST and the node already has the * information that it is going to ask, then the packet can be dropped */ if (forw_packet->num_packets) goto out; |
be1db4f66 batman-adv: make ... |
1157 1158 1159 |
vid = batadv_dat_get_vid(forw_packet->skb, &hdr_size); type = batadv_arp_get_type(bat_priv, forw_packet->skb, hdr_size); |
c384ea3ec batman-adv: Distr... |
1160 1161 |
if (type != ARPOP_REQUEST) goto out; |
be1db4f66 batman-adv: make ... |
1162 1163 |
ip_dst = batadv_arp_ip_dst(forw_packet->skb, hdr_size); dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); |
c384ea3ec batman-adv: Distr... |
1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 |
/* check if the node already got this entry */ if (!dat_entry) { batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP Request for %pI4: fallback ", &ip_dst); goto out; } batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP Request for %pI4: fallback prevented ", &ip_dst); ret = true; out: if (dat_entry) batadv_dat_entry_free_ref(dat_entry); return ret; } |