39 static void batadv_dat_start_timer(struct batadv_priv *bat_priv)  in batadv_dat_start_timer()  argument
41 	INIT_DELAYED_WORK(&bat_priv->dat.work, batadv_dat_purge);  in batadv_dat_start_timer()
42 	queue_delayed_work(batadv_event_workqueue, &bat_priv->dat.work,  in batadv_dat_start_timer()
80 static void __batadv_dat_purge(struct batadv_priv *bat_priv,  in __batadv_dat_purge()  argument
89 	if (!bat_priv->dat.hash)  in __batadv_dat_purge()
92 	for (i = 0; i < bat_priv->dat.hash->size; i++) {  in __batadv_dat_purge()
93 		head = &bat_priv->dat.hash->table[i];  in __batadv_dat_purge()
94 		list_lock = &bat_priv->dat.hash->list_locks[i];  in __batadv_dat_purge()
121 	struct batadv_priv *bat_priv;  in batadv_dat_purge()  local
125 	bat_priv = container_of(priv_dat, struct batadv_priv, dat);  in batadv_dat_purge()
127 	__batadv_dat_purge(bat_priv, batadv_dat_to_purge);  in batadv_dat_purge()
128 	batadv_dat_start_timer(bat_priv);  in batadv_dat_purge()
231 batadv_dat_entry_hash_find(struct batadv_priv *bat_priv, __be32 ip,  in batadv_dat_entry_hash_find()  argument
236 	struct batadv_hashtable *hash = bat_priv->dat.hash;  in batadv_dat_entry_hash_find()
271 static void batadv_dat_entry_add(struct batadv_priv *bat_priv, __be32 ip,  in batadv_dat_entry_add()  argument
277 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip, vid);  in batadv_dat_entry_add()
283 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_entry_add()
300 	hash_added = batadv_hash_add(bat_priv->dat.hash, batadv_compare_dat,  in batadv_dat_entry_add()
310 	batadv_dbg(BATADV_DBG_DAT, bat_priv, "New entry added: %pI4 %pM (vid: %d)\n",  in batadv_dat_entry_add()
328 static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb,  in batadv_dbg_arp()  argument
337 		batadv_dbg(BATADV_DBG_DAT, bat_priv, "%s\n", msg);  in batadv_dbg_arp()
341 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
353 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
357 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
362 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_PUT\n");  in batadv_dbg_arp()
365 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_GET\n");  in batadv_dbg_arp()
368 			batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
372 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DATA\n");  in batadv_dbg_arp()
375 			batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: Unknown (%u)!\n",  in batadv_dbg_arp()
382 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
387 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dbg_arp()
395 static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb,  in batadv_dbg_arp()  argument
464 static void batadv_choose_next_candidate(struct batadv_priv *bat_priv,  in batadv_choose_next_candidate()  argument
471 	struct batadv_hashtable *hash = bat_priv->orig_hash;  in batadv_choose_next_candidate()
511 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_choose_next_candidate()
532 batadv_dat_select_candidates(struct batadv_priv *bat_priv, __be32 ip_dst)  in batadv_dat_select_candidates()  argument
538 	if (!bat_priv->orig_hash)  in batadv_dat_select_candidates()
549 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_select_candidates()
554 		batadv_choose_next_candidate(bat_priv, res, select, ip_key,  in batadv_dat_select_candidates()
573 static bool batadv_dat_send_data(struct batadv_priv *bat_priv,  in batadv_dat_send_data()  argument
584 	cand = batadv_dat_select_candidates(bat_priv, ip);  in batadv_dat_send_data()
588 	batadv_dbg(BATADV_DBG_DAT, bat_priv, "DHT_SEND for %pI4\n", &ip);  in batadv_dat_send_data()
600 		if (!batadv_send_skb_prepare_unicast_4addr(bat_priv, tmp_skb,  in batadv_dat_send_data()
614 				batadv_inc_counter(bat_priv,  in batadv_dat_send_data()
618 				batadv_inc_counter(bat_priv,  in batadv_dat_send_data()
642 static void batadv_dat_tvlv_container_update(struct batadv_priv *bat_priv)  in batadv_dat_tvlv_container_update()  argument
646 	dat_mode = atomic_read(&bat_priv->distributed_arp_table);  in batadv_dat_tvlv_container_update()
650 		batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1);  in batadv_dat_tvlv_container_update()
653 		batadv_tvlv_container_register(bat_priv, BATADV_TVLV_DAT, 1,  in batadv_dat_tvlv_container_update()
666 	struct batadv_priv *bat_priv = netdev_priv(net_dev);  in batadv_dat_status_update()  local
668 	batadv_dat_tvlv_container_update(bat_priv);  in batadv_dat_status_update()
679 static void batadv_dat_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv,  in batadv_dat_tvlv_ogm_handler_v1()  argument
695 static void batadv_dat_hash_free(struct batadv_priv *bat_priv)  in batadv_dat_hash_free()  argument
697 	if (!bat_priv->dat.hash)  in batadv_dat_hash_free()
700 	__batadv_dat_purge(bat_priv, NULL);  in batadv_dat_hash_free()
702 	batadv_hash_destroy(bat_priv->dat.hash);  in batadv_dat_hash_free()
704 	bat_priv->dat.hash = NULL;  in batadv_dat_hash_free()
711 int batadv_dat_init(struct batadv_priv *bat_priv)  in batadv_dat_init()  argument
713 	if (bat_priv->dat.hash)  in batadv_dat_init()
716 	bat_priv->dat.hash = batadv_hash_new(1024);  in batadv_dat_init()
718 	if (!bat_priv->dat.hash)  in batadv_dat_init()
721 	batadv_dat_start_timer(bat_priv);  in batadv_dat_init()
723 	batadv_tvlv_handler_register(bat_priv, batadv_dat_tvlv_ogm_handler_v1,  in batadv_dat_init()
726 	batadv_dat_tvlv_container_update(bat_priv);  in batadv_dat_init()
734 void batadv_dat_free(struct batadv_priv *bat_priv)  in batadv_dat_free()  argument
736 	batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1);  in batadv_dat_free()
737 	batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_DAT, 1);  in batadv_dat_free()
739 	cancel_delayed_work_sync(&bat_priv->dat.work);  in batadv_dat_free()
741 	batadv_dat_hash_free(bat_priv);  in batadv_dat_free()
752 	struct batadv_priv *bat_priv = netdev_priv(net_dev);  in batadv_dat_cache_seq_print_text()  local
753 	struct batadv_hashtable *hash = bat_priv->dat.hash;  in batadv_dat_cache_seq_print_text()
802 static uint16_t batadv_arp_get_type(struct batadv_priv *bat_priv,  in batadv_arp_get_type()  argument
903 bool batadv_dat_snoop_outgoing_arp_request(struct batadv_priv *bat_priv,  in batadv_dat_snoop_outgoing_arp_request()  argument
915 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_outgoing_arp_request()
920 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_outgoing_arp_request()
927 	batadv_dbg_arp(bat_priv, skb, type, hdr_size,  in batadv_dat_snoop_outgoing_arp_request()
934 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_outgoing_arp_request()
936 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);  in batadv_dat_snoop_outgoing_arp_request()
946 		if (batadv_is_my_client(bat_priv, dat_entry->mac_addr, vid)) {  in batadv_dat_snoop_outgoing_arp_request()
952 				     bat_priv->soft_iface, ip_dst, hw_src,  in batadv_dat_snoop_outgoing_arp_request()
963 						   bat_priv->soft_iface);  in batadv_dat_snoop_outgoing_arp_request()
964 		bat_priv->stats.rx_packets++;  in batadv_dat_snoop_outgoing_arp_request()
965 		bat_priv->stats.rx_bytes += skb->len + ETH_HLEN + hdr_size;  in batadv_dat_snoop_outgoing_arp_request()
966 		bat_priv->soft_iface->last_rx = jiffies;  in batadv_dat_snoop_outgoing_arp_request()
969 		batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP request replied locally\n");  in batadv_dat_snoop_outgoing_arp_request()
973 		ret = batadv_dat_send_data(bat_priv, skb, ip_dst,  in batadv_dat_snoop_outgoing_arp_request()
991 bool batadv_dat_snoop_incoming_arp_request(struct batadv_priv *bat_priv,  in batadv_dat_snoop_incoming_arp_request()  argument
1003 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_incoming_arp_request()
1008 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_incoming_arp_request()
1016 	batadv_dbg_arp(bat_priv, skb, type, hdr_size,  in batadv_dat_snoop_incoming_arp_request()
1019 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_incoming_arp_request()
1021 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);  in batadv_dat_snoop_incoming_arp_request()
1026 			     bat_priv->soft_iface, ip_dst, hw_src,  in batadv_dat_snoop_incoming_arp_request()
1046 		err = batadv_send_skb_via_tt_4addr(bat_priv, skb_new,  in batadv_dat_snoop_incoming_arp_request()
1050 		err = batadv_send_skb_via_tt(bat_priv, skb_new, NULL, vid);  in batadv_dat_snoop_incoming_arp_request()
1053 		batadv_inc_counter(bat_priv, BATADV_CNT_DAT_CACHED_REPLY_TX);  in batadv_dat_snoop_incoming_arp_request()
1069 void batadv_dat_snoop_outgoing_arp_reply(struct batadv_priv *bat_priv,  in batadv_dat_snoop_outgoing_arp_reply()  argument
1078 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_outgoing_arp_reply()
1083 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_outgoing_arp_reply()
1087 	batadv_dbg_arp(bat_priv, skb, type, hdr_size,  in batadv_dat_snoop_outgoing_arp_reply()
1095 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_outgoing_arp_reply()
1096 	batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid);  in batadv_dat_snoop_outgoing_arp_reply()
1101 	batadv_dat_send_data(bat_priv, skb, ip_src, BATADV_P_DAT_DHT_PUT);  in batadv_dat_snoop_outgoing_arp_reply()
1102 	batadv_dat_send_data(bat_priv, skb, ip_dst, BATADV_P_DAT_DHT_PUT);  in batadv_dat_snoop_outgoing_arp_reply()
1112 bool batadv_dat_snoop_incoming_arp_reply(struct batadv_priv *bat_priv,  in batadv_dat_snoop_incoming_arp_reply()  argument
1121 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_snoop_incoming_arp_reply()
1126 	type = batadv_arp_get_type(bat_priv, skb, hdr_size);  in batadv_dat_snoop_incoming_arp_reply()
1130 	batadv_dbg_arp(bat_priv, skb, type, hdr_size,  in batadv_dat_snoop_incoming_arp_reply()
1141 	batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid);  in batadv_dat_snoop_incoming_arp_reply()
1142 	batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid);  in batadv_dat_snoop_incoming_arp_reply()
1147 	ret = !batadv_is_my_client(bat_priv, hw_dst, vid);  in batadv_dat_snoop_incoming_arp_reply()
1163 bool batadv_dat_drop_broadcast_packet(struct batadv_priv *bat_priv,  in batadv_dat_drop_broadcast_packet()  argument
1173 	if (!atomic_read(&bat_priv->distributed_arp_table))  in batadv_dat_drop_broadcast_packet()
1184 	type = batadv_arp_get_type(bat_priv, forw_packet->skb, hdr_size);  in batadv_dat_drop_broadcast_packet()
1189 	dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid);  in batadv_dat_drop_broadcast_packet()
1192 		batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_drop_broadcast_packet()
1197 	batadv_dbg(BATADV_DBG_DAT, bat_priv,  in batadv_dat_drop_broadcast_packet()