Lines Matching refs:dat_entry
109 * batadv_dat_entry_release() - release dat_entry from lists and queue for free
111 * @ref: kref pointer of the dat_entry
115 struct batadv_dat_entry *dat_entry;
117 dat_entry = container_of(ref, struct batadv_dat_entry, refcount);
119 kfree_rcu(dat_entry, rcu);
123 * batadv_dat_entry_put() - decrement the dat_entry refcounter and possibly
125 * @dat_entry: dat_entry to be free'd
127 static void batadv_dat_entry_put(struct batadv_dat_entry *dat_entry)
129 if (!dat_entry)
132 kref_put(&dat_entry->refcount, batadv_dat_entry_release);
136 * batadv_dat_to_purge() - check whether a dat_entry has to be purged or not
137 * @dat_entry: the entry to check
141 static bool batadv_dat_to_purge(struct batadv_dat_entry *dat_entry)
143 return batadv_has_timed_out(dat_entry->last_update,
151 * not. This function takes the dat_entry as argument and has to
162 struct batadv_dat_entry *dat_entry;
175 hlist_for_each_entry_safe(dat_entry, node_tmp, head,
180 if (to_purge && !to_purge(dat_entry))
183 hlist_del_rcu(&dat_entry->hash_entry);
184 batadv_dat_entry_put(dat_entry);
317 * batadv_dat_entry_hash_find() - look for a given dat_entry in the local hash
323 * Return: the dat_entry if found, NULL otherwise.
330 struct batadv_dat_entry to_find, *dat_entry, *dat_entry_tmp = NULL;
344 hlist_for_each_entry_rcu(dat_entry, head, hash_entry) {
345 if (dat_entry->ip != ip)
348 if (!kref_get_unless_zero(&dat_entry->refcount))
351 dat_entry_tmp = dat_entry;
369 struct batadv_dat_entry *dat_entry;
372 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip, vid);
374 if (dat_entry) {
375 if (!batadv_compare_eth(dat_entry->mac_addr, mac_addr))
376 ether_addr_copy(dat_entry->mac_addr, mac_addr);
377 dat_entry->last_update = jiffies;
380 &dat_entry->ip, dat_entry->mac_addr,
385 dat_entry = kmalloc(sizeof(*dat_entry), GFP_ATOMIC);
386 if (!dat_entry)
389 dat_entry->ip = ip;
390 dat_entry->vid = vid;
391 ether_addr_copy(dat_entry->mac_addr, mac_addr);
392 dat_entry->last_update = jiffies;
393 kref_init(&dat_entry->refcount);
395 kref_get(&dat_entry->refcount);
397 batadv_hash_dat, dat_entry,
398 &dat_entry->hash_entry);
402 batadv_dat_entry_put(dat_entry);
407 &dat_entry->ip, dat_entry->mac_addr, batadv_print_vid(vid));
410 batadv_dat_entry_put(dat_entry);
851 * @dat_entry: entry to dump
858 struct batadv_dat_entry *dat_entry)
871 msecs = jiffies_to_msecs(jiffies - dat_entry->last_update);
874 dat_entry->ip) ||
876 dat_entry->mac_addr) ||
877 nla_put_u16(msg, BATADV_ATTR_DAT_CACHE_VID, dat_entry->vid) ||
905 struct batadv_dat_entry *dat_entry;
911 hlist_for_each_entry(dat_entry, &hash->table[bucket], hash_entry) {
915 if (batadv_dat_cache_dump_entry(msg, portid, cb, dat_entry)) {
1144 struct batadv_dat_entry *dat_entry = NULL;
1170 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);
1171 if (dat_entry) {
1180 if (batadv_is_my_client(bat_priv, dat_entry->mac_addr, vid)) {
1191 dat_entry->mac_addr, vid)) {
1194 dat_entry->mac_addr);
1200 dat_entry->mac_addr,
1220 batadv_dat_entry_put(dat_entry);
1240 struct batadv_dat_entry *dat_entry = NULL;
1262 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);
1263 if (!dat_entry)
1267 dat_entry->mac_addr, hw_src, vid);
1287 batadv_dat_entry_put(dat_entry);
1348 struct batadv_dat_entry *dat_entry = NULL;
1377 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_src, vid);
1378 if (dat_entry && batadv_compare_eth(hw_src, dat_entry->mac_addr)) {
1379 batadv_dbg(BATADV_DBG_DAT, bat_priv, "Doubled ARP reply removed: ARP MSG = [src: %pM-%pI4 dst: %pM-%pI4]; dat_entry: %pM-%pI4\n",
1381 dat_entry->mac_addr, &dat_entry->ip);
1420 batadv_dat_entry_put(dat_entry);
1795 struct batadv_dat_entry *dat_entry = NULL;
1816 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);
1818 if (!dat_entry) {
1829 batadv_dat_entry_put(dat_entry);