Lines Matching refs:bat_priv
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()
159 static void __batadv_dat_purge(struct batadv_priv *bat_priv, in __batadv_dat_purge() argument
168 if (!bat_priv->dat.hash) in __batadv_dat_purge()
171 for (i = 0; i < bat_priv->dat.hash->size; i++) { in __batadv_dat_purge()
172 head = &bat_priv->dat.hash->table[i]; in __batadv_dat_purge()
173 list_lock = &bat_priv->dat.hash->list_locks[i]; in __batadv_dat_purge()
200 struct batadv_priv *bat_priv; in batadv_dat_purge() local
204 bat_priv = container_of(priv_dat, struct batadv_priv, dat); in batadv_dat_purge()
206 __batadv_dat_purge(bat_priv, batadv_dat_to_purge); in batadv_dat_purge()
207 batadv_dat_start_timer(bat_priv); in batadv_dat_purge()
327 batadv_dat_entry_hash_find(struct batadv_priv *bat_priv, __be32 ip, in batadv_dat_entry_hash_find() argument
332 struct batadv_hashtable *hash = bat_priv->dat.hash; in batadv_dat_entry_hash_find()
367 static void batadv_dat_entry_add(struct batadv_priv *bat_priv, __be32 ip, in batadv_dat_entry_add() argument
373 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip, vid); in batadv_dat_entry_add()
379 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_entry_add()
397 hash_added = batadv_hash_add(bat_priv->dat.hash, batadv_compare_dat, in batadv_dat_entry_add()
407 batadv_dbg(BATADV_DBG_DAT, bat_priv, "New entry added: %pI4 %pM (vid: %d)\n", in batadv_dat_entry_add()
424 static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb, in batadv_dbg_arp() argument
433 batadv_dbg(BATADV_DBG_DAT, bat_priv, "%s\n", msg); in batadv_dbg_arp()
437 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dbg_arp()
449 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dbg_arp()
453 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dbg_arp()
458 batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_PUT\n"); in batadv_dbg_arp()
461 batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DAT_DHT_GET\n"); in batadv_dbg_arp()
464 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dbg_arp()
468 batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: DATA\n"); in batadv_dbg_arp()
471 batadv_dbg(BATADV_DBG_DAT, bat_priv, "* type: Unknown (%u)!\n", in batadv_dbg_arp()
478 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dbg_arp()
483 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dbg_arp()
491 static void batadv_dbg_arp(struct batadv_priv *bat_priv, struct sk_buff *skb, in batadv_dbg_arp() argument
560 static void batadv_choose_next_candidate(struct batadv_priv *bat_priv, in batadv_choose_next_candidate() argument
568 struct batadv_hashtable *hash = bat_priv->orig_hash; in batadv_choose_next_candidate()
607 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_choose_next_candidate()
629 batadv_dat_select_candidates(struct batadv_priv *bat_priv, __be32 ip_dst, in batadv_dat_select_candidates() argument
637 if (!bat_priv->orig_hash) in batadv_dat_select_candidates()
650 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_select_candidates()
655 batadv_choose_next_candidate(bat_priv, res, select, ip_key, in batadv_dat_select_candidates()
675 static bool batadv_dat_forward_data(struct batadv_priv *bat_priv, in batadv_dat_forward_data() argument
686 cand = batadv_dat_select_candidates(bat_priv, ip, vid); in batadv_dat_forward_data()
690 batadv_dbg(BATADV_DBG_DAT, bat_priv, "DHT_SEND for %pI4\n", &ip); in batadv_dat_forward_data()
702 if (!batadv_send_skb_prepare_unicast_4addr(bat_priv, tmp_skb, in batadv_dat_forward_data()
714 batadv_inc_counter(bat_priv, in batadv_dat_forward_data()
718 batadv_inc_counter(bat_priv, in batadv_dat_forward_data()
742 static void batadv_dat_tvlv_container_update(struct batadv_priv *bat_priv) in batadv_dat_tvlv_container_update() argument
746 dat_mode = atomic_read(&bat_priv->distributed_arp_table); in batadv_dat_tvlv_container_update()
750 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1); in batadv_dat_tvlv_container_update()
753 batadv_tvlv_container_register(bat_priv, BATADV_TVLV_DAT, 1, in batadv_dat_tvlv_container_update()
766 struct batadv_priv *bat_priv = netdev_priv(net_dev); in batadv_dat_status_update() local
768 batadv_dat_tvlv_container_update(bat_priv); in batadv_dat_status_update()
779 static void batadv_dat_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv, in batadv_dat_tvlv_ogm_handler_v1() argument
794 static void batadv_dat_hash_free(struct batadv_priv *bat_priv) in batadv_dat_hash_free() argument
796 if (!bat_priv->dat.hash) in batadv_dat_hash_free()
799 __batadv_dat_purge(bat_priv, NULL); in batadv_dat_hash_free()
801 batadv_hash_destroy(bat_priv->dat.hash); in batadv_dat_hash_free()
803 bat_priv->dat.hash = NULL; in batadv_dat_hash_free()
812 int batadv_dat_init(struct batadv_priv *bat_priv) in batadv_dat_init() argument
814 if (bat_priv->dat.hash) in batadv_dat_init()
817 bat_priv->dat.hash = batadv_hash_new(1024); in batadv_dat_init()
819 if (!bat_priv->dat.hash) in batadv_dat_init()
822 batadv_dat_start_timer(bat_priv); in batadv_dat_init()
824 batadv_tvlv_handler_register(bat_priv, batadv_dat_tvlv_ogm_handler_v1, in batadv_dat_init()
827 batadv_dat_tvlv_container_update(bat_priv); in batadv_dat_init()
835 void batadv_dat_free(struct batadv_priv *bat_priv) in batadv_dat_free() argument
837 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1); in batadv_dat_free()
838 batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_DAT, 1); in batadv_dat_free()
840 cancel_delayed_work_sync(&bat_priv->dat.work); in batadv_dat_free()
842 batadv_dat_hash_free(bat_priv); in batadv_dat_free()
944 struct batadv_priv *bat_priv; in batadv_dat_cache_dump() local
961 bat_priv = netdev_priv(soft_iface); in batadv_dat_cache_dump()
962 hash = bat_priv->dat.hash; in batadv_dat_cache_dump()
964 primary_if = batadv_primary_if_get_selected(bat_priv); in batadv_dat_cache_dump()
1000 static u16 batadv_arp_get_type(struct batadv_priv *bat_priv, in batadv_arp_get_type() argument
1107 batadv_dat_arp_create_reply(struct batadv_priv *bat_priv, __be32 ip_src, in batadv_dat_arp_create_reply() argument
1113 skb = arp_create(ARPOP_REPLY, ETH_P_ARP, ip_dst, bat_priv->soft_iface, in batadv_dat_arp_create_reply()
1137 bool batadv_dat_snoop_outgoing_arp_request(struct batadv_priv *bat_priv, in batadv_dat_snoop_outgoing_arp_request() argument
1146 struct net_device *soft_iface = bat_priv->soft_iface; in batadv_dat_snoop_outgoing_arp_request()
1150 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_outgoing_arp_request()
1155 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_outgoing_arp_request()
1162 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing outgoing ARP REQUEST"); in batadv_dat_snoop_outgoing_arp_request()
1168 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_outgoing_arp_request()
1170 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); in batadv_dat_snoop_outgoing_arp_request()
1180 if (batadv_is_my_client(bat_priv, dat_entry->mac_addr, vid)) { in batadv_dat_snoop_outgoing_arp_request()
1190 if (!batadv_bla_check_claim(bat_priv, in batadv_dat_snoop_outgoing_arp_request()
1192 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_outgoing_arp_request()
1199 skb_new = batadv_dat_arp_create_reply(bat_priv, ip_dst, ip_src, in batadv_dat_snoop_outgoing_arp_request()
1207 batadv_inc_counter(bat_priv, BATADV_CNT_RX); in batadv_dat_snoop_outgoing_arp_request()
1208 batadv_add_counter(bat_priv, BATADV_CNT_RX_BYTES, in batadv_dat_snoop_outgoing_arp_request()
1212 batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP request replied locally\n"); in batadv_dat_snoop_outgoing_arp_request()
1216 ret = batadv_dat_forward_data(bat_priv, skb, ip_dst, vid, in batadv_dat_snoop_outgoing_arp_request()
1233 bool batadv_dat_snoop_incoming_arp_request(struct batadv_priv *bat_priv, in batadv_dat_snoop_incoming_arp_request() argument
1245 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_incoming_arp_request()
1250 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_incoming_arp_request()
1258 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing incoming ARP REQUEST"); in batadv_dat_snoop_incoming_arp_request()
1260 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_incoming_arp_request()
1262 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); in batadv_dat_snoop_incoming_arp_request()
1266 skb_new = batadv_dat_arp_create_reply(bat_priv, ip_dst, ip_src, in batadv_dat_snoop_incoming_arp_request()
1276 err = batadv_send_skb_via_tt_4addr(bat_priv, skb_new, in batadv_dat_snoop_incoming_arp_request()
1280 err = batadv_send_skb_via_tt(bat_priv, skb_new, NULL, vid); in batadv_dat_snoop_incoming_arp_request()
1283 batadv_inc_counter(bat_priv, BATADV_CNT_DAT_CACHED_REPLY_TX); in batadv_dat_snoop_incoming_arp_request()
1298 void batadv_dat_snoop_outgoing_arp_reply(struct batadv_priv *bat_priv, in batadv_dat_snoop_outgoing_arp_reply() argument
1307 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_outgoing_arp_reply()
1312 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_outgoing_arp_reply()
1316 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing outgoing ARP REPLY"); in batadv_dat_snoop_outgoing_arp_reply()
1323 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_outgoing_arp_reply()
1324 batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); in batadv_dat_snoop_outgoing_arp_reply()
1329 batadv_dat_forward_data(bat_priv, skb, ip_src, vid, in batadv_dat_snoop_outgoing_arp_reply()
1331 batadv_dat_forward_data(bat_priv, skb, ip_dst, vid, in batadv_dat_snoop_outgoing_arp_reply()
1345 bool batadv_dat_snoop_incoming_arp_reply(struct batadv_priv *bat_priv, in batadv_dat_snoop_incoming_arp_reply() argument
1355 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_incoming_arp_reply()
1360 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_incoming_arp_reply()
1364 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing incoming ARP REPLY"); in batadv_dat_snoop_incoming_arp_reply()
1377 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_src, vid); in batadv_dat_snoop_incoming_arp_reply()
1379 …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()
1388 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_incoming_arp_reply()
1389 batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); in batadv_dat_snoop_incoming_arp_reply()
1400 if (!batadv_bla_check_claim(bat_priv, hw_src, vid)) { in batadv_dat_snoop_incoming_arp_reply()
1401 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_incoming_arp_reply()
1411 dropped = !batadv_is_my_client(bat_priv, hw_dst, vid); in batadv_dat_snoop_incoming_arp_reply()
1416 dropped |= batadv_is_my_client(bat_priv, hw_src, vid); in batadv_dat_snoop_incoming_arp_reply()
1632 static void batadv_dat_put_dhcp(struct batadv_priv *bat_priv, u8 *chaddr, in batadv_dat_put_dhcp() argument
1638 skb = batadv_dat_arp_create_reply(bat_priv, yiaddr, ip_dst, chaddr, in batadv_dat_put_dhcp()
1645 batadv_dat_entry_add(bat_priv, yiaddr, chaddr, vid); in batadv_dat_put_dhcp()
1646 batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); in batadv_dat_put_dhcp()
1648 batadv_dat_forward_data(bat_priv, skb, yiaddr, vid, in batadv_dat_put_dhcp()
1650 batadv_dat_forward_data(bat_priv, skb, ip_dst, vid, in batadv_dat_put_dhcp()
1655 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_put_dhcp()
1658 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_put_dhcp()
1717 void batadv_dat_snoop_outgoing_dhcp_ack(struct batadv_priv *bat_priv, in batadv_dat_snoop_outgoing_dhcp_ack() argument
1725 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_outgoing_dhcp_ack()
1731 batadv_dat_put_dhcp(bat_priv, chaddr, yiaddr, eth_hdr(skb)->h_source, in batadv_dat_snoop_outgoing_dhcp_ack()
1745 void batadv_dat_snoop_incoming_dhcp_ack(struct batadv_priv *bat_priv, in batadv_dat_snoop_incoming_dhcp_ack() argument
1755 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_incoming_dhcp_ack()
1771 batadv_dat_entry_add(bat_priv, yiaddr, chaddr, vid); in batadv_dat_snoop_incoming_dhcp_ack()
1772 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_incoming_dhcp_ack()
1774 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_incoming_dhcp_ack()
1777 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_incoming_dhcp_ack()
1790 bool batadv_dat_drop_broadcast_packet(struct batadv_priv *bat_priv, in batadv_dat_drop_broadcast_packet() argument
1800 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_drop_broadcast_packet()
1811 type = batadv_arp_get_type(bat_priv, forw_packet->skb, hdr_size); in batadv_dat_drop_broadcast_packet()
1816 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); in batadv_dat_drop_broadcast_packet()
1819 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_drop_broadcast_packet()
1824 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_drop_broadcast_packet()