102 static void batadv_dat_start_timer(struct batadv_priv *bat_priv)  in batadv_dat_start_timer()  argument
104 	INIT_DELAYED_WORK(&bat_priv->dat.work, batadv_dat_purge);  in batadv_dat_start_timer()
105 	queue_delayed_work(batadv_event_workqueue, &bat_priv->dat.work,  in batadv_dat_start_timer()
156 static void __batadv_dat_purge(struct batadv_priv *bat_priv,  in __batadv_dat_purge()  argument
165 	if (!bat_priv->dat.hash)  in __batadv_dat_purge()
168 	for (i = 0; i < bat_priv->dat.hash->size; i++) {  in __batadv_dat_purge()
169 		head = &bat_priv->dat.hash->table[i];  in __batadv_dat_purge()
170 		list_lock = &bat_priv->dat.hash->list_locks[i];  in __batadv_dat_purge()
197 	struct batadv_priv *bat_priv;  in batadv_dat_purge()  local
201 	bat_priv = container_of(priv_dat, struct batadv_priv, dat);  in batadv_dat_purge()
203 	__batadv_dat_purge(bat_priv, batadv_dat_to_purge);  in batadv_dat_purge()
204 	batadv_dat_start_timer(bat_priv);  in batadv_dat_purge()
324 batadv_dat_entry_hash_find(struct batadv_priv *bat_priv, __be32 ip,  in batadv_dat_entry_hash_find()  argument
329 	struct batadv_hashtable *hash = bat_priv->dat.hash;  in batadv_dat_entry_hash_find()
364 static void batadv_dat_entry_add(struct batadv_priv *bat_priv, __be32 ip,  in batadv_dat_entry_add()  argument
370 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip, vid);  in batadv_dat_entry_add()
376 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_entry_add()
394 	hash_added = batadv_hash_add(bat_priv->dat.hash, batadv_compare_dat,  in batadv_dat_entry_add()
404 	batadv_dbg(BATADV_DBG_DAT, bat_priv, "New entry added: %pI4 %pM (vid: %d)\n",  in batadv_dat_entry_add()
422 static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb,  in batadv_dbg_arp()  argument
431 		batadv_dbg(BATADV_DBG_DAT, bat_priv, "%s\n", msg);  in batadv_dbg_arp()
435 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
447 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
451 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
456 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_PUT\n");  in batadv_dbg_arp()
459 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_GET\n");  in batadv_dbg_arp()
462 			batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
466 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DATA\n");  in batadv_dbg_arp()
469 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: Unknown (%u)!\n",  in batadv_dbg_arp()
476 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
481 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
489 static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb,  in batadv_dbg_arp()  argument
558 static void batadv_choose_next_candidate(struct batadv_priv *bat_priv,  in batadv_choose_next_candidate()  argument
566 	struct batadv_hashtable *hash = bat_priv->orig_hash;  in batadv_choose_next_candidate()
606 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_choose_next_candidate()
628 batadv_dat_select_candidates(struct batadv_priv *bat_priv, __be32 ip_dst,  in batadv_dat_select_candidates()  argument
636 	if (!bat_priv->orig_hash)  in batadv_dat_select_candidates()
649 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_select_candidates()
654 		batadv_choose_next_candidate(bat_priv, res, select, ip_key,  in batadv_dat_select_candidates()
674 static bool batadv_dat_forward_data(struct batadv_priv *bat_priv,  in batadv_dat_forward_data()  argument
685 	cand = batadv_dat_select_candidates(bat_priv, ip, vid);  in batadv_dat_forward_data()
689 	batadv_dbg(BATADV_DBG_DAT, bat_priv, "DHT_SEND for %pI4\n", &ip);  in batadv_dat_forward_data()
701 		if (!batadv_send_skb_prepare_unicast_4addr(bat_priv, tmp_skb,  in batadv_dat_forward_data()
713 				batadv_inc_counter(bat_priv,  in batadv_dat_forward_data()
717 				batadv_inc_counter(bat_priv,  in batadv_dat_forward_data()
741 static void batadv_dat_tvlv_container_update(struct batadv_priv *bat_priv)  in batadv_dat_tvlv_container_update()  argument
745 	dat_mode = atomic_read(&bat_priv->distributed_arp_table);  in batadv_dat_tvlv_container_update()
749 		batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1);  in batadv_dat_tvlv_container_update()
752 		batadv_tvlv_container_register(bat_priv, BATADV_TVLV_DAT, 1,  in batadv_dat_tvlv_container_update()
765 	struct batadv_priv *bat_priv = netdev_priv(net_dev);  in batadv_dat_status_update()  local
767 	batadv_dat_tvlv_container_update(bat_priv);  in batadv_dat_status_update()
778 static void batadv_dat_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv,  in batadv_dat_tvlv_ogm_handler_v1()  argument
793 static void batadv_dat_hash_free(struct batadv_priv *bat_priv)  in batadv_dat_hash_free()  argument
795 	if (!bat_priv->dat.hash)  in batadv_dat_hash_free()
798 	__batadv_dat_purge(bat_priv, NULL);  in batadv_dat_hash_free()
800 	batadv_hash_destroy(bat_priv->dat.hash);  in batadv_dat_hash_free()
802 	bat_priv->dat.hash = NULL;  in batadv_dat_hash_free()
811 int batadv_dat_init(struct batadv_priv *bat_priv)  in batadv_dat_init()  argument
813 	if (bat_priv->dat.hash)  in batadv_dat_init()
816 	bat_priv->dat.hash = batadv_hash_new(1024);  in batadv_dat_init()
818 	if (!bat_priv->dat.hash)  in batadv_dat_init()
821 	batadv_dat_start_timer(bat_priv);  in batadv_dat_init()
823 	batadv_tvlv_handler_register(bat_priv, batadv_dat_tvlv_ogm_handler_v1,  in batadv_dat_init()
826 	batadv_dat_tvlv_container_update(bat_priv);  in batadv_dat_init()
834 void batadv_dat_free(struct batadv_priv *bat_priv)  in batadv_dat_free()  argument
836 	batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1);  in batadv_dat_free()
837 	batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_DAT, 1);  in batadv_dat_free()
839 	cancel_delayed_work_sync(&bat_priv->dat.work);  in batadv_dat_free()
841 	batadv_dat_hash_free(bat_priv);  in batadv_dat_free()
943 	struct batadv_priv *bat_priv;  in batadv_dat_cache_dump()  local
960 	bat_priv = netdev_priv(soft_iface);  in batadv_dat_cache_dump()
961 	hash = bat_priv->dat.hash;  in batadv_dat_cache_dump()
963 	primary_if = batadv_primary_if_get_selected(bat_priv);  in batadv_dat_cache_dump()
1001 static u16 batadv_arp_get_type(struct batadv_priv *bat_priv,  in batadv_arp_get_type()  argument
1108 batadv_dat_arp_create_reply(struct batadv_priv *bat_priv, __be32 ip_src,  in batadv_dat_arp_create_reply()  argument
1114 	skb = arp_create(ARPOP_REPLY, ETH_P_ARP, ip_dst, bat_priv->soft_iface,  in batadv_dat_arp_create_reply()
1138 bool batadv_dat_snoop_outgoing_arp_request(struct batadv_priv *bat_priv,  in batadv_dat_snoop_outgoing_arp_request()  argument
1147 	struct net_device *soft_iface = bat_priv->soft_iface;  in batadv_dat_snoop_outgoing_arp_request()
1151 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_outgoing_arp_request()
1156 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_outgoing_arp_request()
1163 	batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing outgoing ARP REQUEST");  in batadv_dat_snoop_outgoing_arp_request()
1169 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_outgoing_arp_request()
1171 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);  in batadv_dat_snoop_outgoing_arp_request()
1181 		if (batadv_is_my_client(bat_priv, dat_entry->mac_addr, vid)) {  in batadv_dat_snoop_outgoing_arp_request()
1191 		if (!batadv_bla_check_claim(bat_priv,  in batadv_dat_snoop_outgoing_arp_request()
1193 			batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_snoop_outgoing_arp_request()
1200 		skb_new = batadv_dat_arp_create_reply(bat_priv, ip_dst, ip_src,  in batadv_dat_snoop_outgoing_arp_request()
1208 		batadv_inc_counter(bat_priv, BATADV_CNT_RX);  in batadv_dat_snoop_outgoing_arp_request()
1209 		batadv_add_counter(bat_priv, BATADV_CNT_RX_BYTES,  in batadv_dat_snoop_outgoing_arp_request()
1213 		batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP request replied locally\n");  in batadv_dat_snoop_outgoing_arp_request()
1217 		ret = batadv_dat_forward_data(bat_priv, skb, ip_dst, vid,  in batadv_dat_snoop_outgoing_arp_request()
1235 bool batadv_dat_snoop_incoming_arp_request(struct batadv_priv *bat_priv,  in batadv_dat_snoop_incoming_arp_request()  argument
1247 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_incoming_arp_request()
1252 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_incoming_arp_request()
1260 	batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing incoming ARP REQUEST");  in batadv_dat_snoop_incoming_arp_request()
1262 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_incoming_arp_request()
1264 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);  in batadv_dat_snoop_incoming_arp_request()
1268 	skb_new = batadv_dat_arp_create_reply(bat_priv, ip_dst, ip_src,  in batadv_dat_snoop_incoming_arp_request()
1278 		err = batadv_send_skb_via_tt_4addr(bat_priv, skb_new,  in batadv_dat_snoop_incoming_arp_request()
1282 		err = batadv_send_skb_via_tt(bat_priv, skb_new, NULL, vid);  in batadv_dat_snoop_incoming_arp_request()
1285 		batadv_inc_counter(bat_priv, BATADV_CNT_DAT_CACHED_REPLY_TX);  in batadv_dat_snoop_incoming_arp_request()
1301 void batadv_dat_snoop_outgoing_arp_reply(struct batadv_priv *bat_priv,  in batadv_dat_snoop_outgoing_arp_reply()  argument
1310 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_outgoing_arp_reply()
1315 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_outgoing_arp_reply()
1319 	batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing outgoing ARP REPLY");  in batadv_dat_snoop_outgoing_arp_reply()
1326 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_outgoing_arp_reply()
1327 	batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid);  in batadv_dat_snoop_outgoing_arp_reply()
1332 	batadv_dat_forward_data(bat_priv, skb, ip_src, vid,  in batadv_dat_snoop_outgoing_arp_reply()
1334 	batadv_dat_forward_data(bat_priv, skb, ip_dst, vid,  in batadv_dat_snoop_outgoing_arp_reply()
1348 bool batadv_dat_snoop_incoming_arp_reply(struct batadv_priv *bat_priv,  in batadv_dat_snoop_incoming_arp_reply()  argument
1358 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_incoming_arp_reply()
1363 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_incoming_arp_reply()
1367 	batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing incoming ARP REPLY");  in batadv_dat_snoop_incoming_arp_reply()
1380 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_src, vid);  in batadv_dat_snoop_incoming_arp_reply()
1382 …batadv_dbg(BATADV_DBG_DAT, bat_priv, "Doubled ARP reply removed: ARP MSG = [src: %pM-%pI4 dst: %pM…  in batadv_dat_snoop_incoming_arp_reply()
1391 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_incoming_arp_reply()
1392 	batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid);  in batadv_dat_snoop_incoming_arp_reply()
1403 	if (!batadv_bla_check_claim(bat_priv, hw_src, vid)) {  in batadv_dat_snoop_incoming_arp_reply()
1404 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_snoop_incoming_arp_reply()
1414 	dropped = !batadv_is_my_client(bat_priv, hw_dst, vid);  in batadv_dat_snoop_incoming_arp_reply()
1419 	dropped |= batadv_is_my_client(bat_priv, hw_src, vid);  in batadv_dat_snoop_incoming_arp_reply()
1636 static void batadv_dat_put_dhcp(struct batadv_priv *bat_priv, u8 *chaddr,  in batadv_dat_put_dhcp()  argument
1642 	skb = batadv_dat_arp_create_reply(bat_priv, yiaddr, ip_dst, chaddr,  in batadv_dat_put_dhcp()
1649 	batadv_dat_entry_add(bat_priv, yiaddr, chaddr, vid);  in batadv_dat_put_dhcp()
1650 	batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid);  in batadv_dat_put_dhcp()
1652 	batadv_dat_forward_data(bat_priv, skb, yiaddr, vid,  in batadv_dat_put_dhcp()
1654 	batadv_dat_forward_data(bat_priv, skb, ip_dst, vid,  in batadv_dat_put_dhcp()
1659 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_put_dhcp()
1662 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_put_dhcp()
1721 void batadv_dat_snoop_outgoing_dhcp_ack(struct batadv_priv *bat_priv,  in batadv_dat_snoop_outgoing_dhcp_ack()  argument
1729 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_outgoing_dhcp_ack()
1735 	batadv_dat_put_dhcp(bat_priv, chaddr, yiaddr, eth_hdr(skb)->h_source,  in batadv_dat_snoop_outgoing_dhcp_ack()
1749 void batadv_dat_snoop_incoming_dhcp_ack(struct batadv_priv *bat_priv,  in batadv_dat_snoop_incoming_dhcp_ack()  argument
1759 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_incoming_dhcp_ack()
1775 	batadv_dat_entry_add(bat_priv, yiaddr, chaddr, vid);  in batadv_dat_snoop_incoming_dhcp_ack()
1776 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_incoming_dhcp_ack()
1778 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_snoop_incoming_dhcp_ack()
1781 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_snoop_incoming_dhcp_ack()
1794 bool batadv_dat_drop_broadcast_packet(struct batadv_priv *bat_priv,  in batadv_dat_drop_broadcast_packet()  argument
1804 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_drop_broadcast_packet()
1815 	type = batadv_arp_get_type(bat_priv, forw_packet->skb, hdr_size);  in batadv_dat_drop_broadcast_packet()
1820 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);  in batadv_dat_drop_broadcast_packet()
1823 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_drop_broadcast_packet()
1828 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_drop_broadcast_packet()