Lines Matching refs:bat_priv
101 static void batadv_dat_start_timer(struct batadv_priv *bat_priv) in batadv_dat_start_timer() argument
103 queue_delayed_work(batadv_event_workqueue, &bat_priv->dat.work, in batadv_dat_start_timer()
157 static void __batadv_dat_purge(struct batadv_priv *bat_priv, in __batadv_dat_purge() argument
166 if (!bat_priv->dat.hash) in __batadv_dat_purge()
169 for (i = 0; i < bat_priv->dat.hash->size; i++) { in __batadv_dat_purge()
170 head = &bat_priv->dat.hash->table[i]; in __batadv_dat_purge()
171 list_lock = &bat_priv->dat.hash->list_locks[i]; in __batadv_dat_purge()
198 struct batadv_priv *bat_priv; in batadv_dat_purge() local
202 bat_priv = container_of(priv_dat, struct batadv_priv, dat); in batadv_dat_purge()
204 __batadv_dat_purge(bat_priv, batadv_dat_to_purge); in batadv_dat_purge()
205 batadv_dat_start_timer(bat_priv); in batadv_dat_purge()
325 batadv_dat_entry_hash_find(struct batadv_priv *bat_priv, __be32 ip, in batadv_dat_entry_hash_find() argument
330 struct batadv_hashtable *hash = bat_priv->dat.hash; in batadv_dat_entry_hash_find()
365 static void batadv_dat_entry_add(struct batadv_priv *bat_priv, __be32 ip, in batadv_dat_entry_add() argument
371 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip, vid); in batadv_dat_entry_add()
377 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_entry_add()
395 hash_added = batadv_hash_add(bat_priv->dat.hash, batadv_compare_dat, in batadv_dat_entry_add()
405 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()
605 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_choose_next_candidate()
627 batadv_dat_select_candidates(struct batadv_priv *bat_priv, __be32 ip_dst, in batadv_dat_select_candidates() argument
635 if (!bat_priv->orig_hash) in batadv_dat_select_candidates()
648 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_select_candidates()
653 batadv_choose_next_candidate(bat_priv, res, select, ip_key, in batadv_dat_select_candidates()
673 static bool batadv_dat_forward_data(struct batadv_priv *bat_priv, in batadv_dat_forward_data() argument
684 cand = batadv_dat_select_candidates(bat_priv, ip, vid); in batadv_dat_forward_data()
688 batadv_dbg(BATADV_DBG_DAT, bat_priv, "DHT_SEND for %pI4\n", &ip); in batadv_dat_forward_data()
700 if (!batadv_send_skb_prepare_unicast_4addr(bat_priv, tmp_skb, in batadv_dat_forward_data()
712 batadv_inc_counter(bat_priv, in batadv_dat_forward_data()
716 batadv_inc_counter(bat_priv, in batadv_dat_forward_data()
739 static void batadv_dat_tvlv_container_update(struct batadv_priv *bat_priv) in batadv_dat_tvlv_container_update() argument
743 dat_mode = atomic_read(&bat_priv->distributed_arp_table); in batadv_dat_tvlv_container_update()
747 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1); in batadv_dat_tvlv_container_update()
750 batadv_tvlv_container_register(bat_priv, BATADV_TVLV_DAT, 1, in batadv_dat_tvlv_container_update()
763 struct batadv_priv *bat_priv = netdev_priv(net_dev); in batadv_dat_status_update() local
765 batadv_dat_tvlv_container_update(bat_priv); in batadv_dat_status_update()
776 static void batadv_dat_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv, in batadv_dat_tvlv_ogm_handler_v1() argument
791 static void batadv_dat_hash_free(struct batadv_priv *bat_priv) in batadv_dat_hash_free() argument
793 if (!bat_priv->dat.hash) in batadv_dat_hash_free()
796 __batadv_dat_purge(bat_priv, NULL); in batadv_dat_hash_free()
798 batadv_hash_destroy(bat_priv->dat.hash); in batadv_dat_hash_free()
800 bat_priv->dat.hash = NULL; in batadv_dat_hash_free()
809 int batadv_dat_init(struct batadv_priv *bat_priv) in batadv_dat_init() argument
811 if (bat_priv->dat.hash) in batadv_dat_init()
814 bat_priv->dat.hash = batadv_hash_new(1024); in batadv_dat_init()
816 if (!bat_priv->dat.hash) in batadv_dat_init()
819 INIT_DELAYED_WORK(&bat_priv->dat.work, batadv_dat_purge); in batadv_dat_init()
820 batadv_dat_start_timer(bat_priv); in batadv_dat_init()
822 batadv_tvlv_handler_register(bat_priv, batadv_dat_tvlv_ogm_handler_v1, in batadv_dat_init()
825 batadv_dat_tvlv_container_update(bat_priv); in batadv_dat_init()
833 void batadv_dat_free(struct batadv_priv *bat_priv) in batadv_dat_free() argument
835 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_DAT, 1); in batadv_dat_free()
836 batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_DAT, 1); in batadv_dat_free()
838 cancel_delayed_work_sync(&bat_priv->dat.work); in batadv_dat_free()
840 batadv_dat_hash_free(bat_priv); in batadv_dat_free()
941 struct batadv_priv *bat_priv; in batadv_dat_cache_dump() local
950 bat_priv = netdev_priv(mesh_iface); in batadv_dat_cache_dump()
951 hash = bat_priv->dat.hash; in batadv_dat_cache_dump()
953 primary_if = batadv_primary_if_get_selected(bat_priv); in batadv_dat_cache_dump()
989 static u16 batadv_arp_get_type(struct batadv_priv *bat_priv, in batadv_arp_get_type() argument
1096 batadv_dat_arp_create_reply(struct batadv_priv *bat_priv, __be32 ip_src, in batadv_dat_arp_create_reply() argument
1102 skb = arp_create(ARPOP_REPLY, ETH_P_ARP, ip_dst, bat_priv->mesh_iface, in batadv_dat_arp_create_reply()
1126 bool batadv_dat_snoop_outgoing_arp_request(struct batadv_priv *bat_priv, in batadv_dat_snoop_outgoing_arp_request() argument
1135 struct net_device *mesh_iface = bat_priv->mesh_iface; in batadv_dat_snoop_outgoing_arp_request()
1139 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_outgoing_arp_request()
1144 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_outgoing_arp_request()
1151 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing outgoing ARP REQUEST"); in batadv_dat_snoop_outgoing_arp_request()
1157 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_outgoing_arp_request()
1159 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); in batadv_dat_snoop_outgoing_arp_request()
1169 if (batadv_is_my_client(bat_priv, dat_entry->mac_addr, vid)) { in batadv_dat_snoop_outgoing_arp_request()
1179 if (!batadv_bla_check_claim(bat_priv, in batadv_dat_snoop_outgoing_arp_request()
1181 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_outgoing_arp_request()
1188 skb_new = batadv_dat_arp_create_reply(bat_priv, ip_dst, ip_src, in batadv_dat_snoop_outgoing_arp_request()
1196 batadv_inc_counter(bat_priv, BATADV_CNT_RX); in batadv_dat_snoop_outgoing_arp_request()
1197 batadv_add_counter(bat_priv, BATADV_CNT_RX_BYTES, in batadv_dat_snoop_outgoing_arp_request()
1201 batadv_dbg(BATADV_DBG_DAT, bat_priv, "ARP request replied locally\n"); in batadv_dat_snoop_outgoing_arp_request()
1205 ret = batadv_dat_forward_data(bat_priv, skb, ip_dst, vid, in batadv_dat_snoop_outgoing_arp_request()
1222 bool batadv_dat_snoop_incoming_arp_request(struct batadv_priv *bat_priv, in batadv_dat_snoop_incoming_arp_request() argument
1234 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_incoming_arp_request()
1239 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_incoming_arp_request()
1247 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing incoming ARP REQUEST"); in batadv_dat_snoop_incoming_arp_request()
1249 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_incoming_arp_request()
1251 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); in batadv_dat_snoop_incoming_arp_request()
1255 skb_new = batadv_dat_arp_create_reply(bat_priv, ip_dst, ip_src, in batadv_dat_snoop_incoming_arp_request()
1265 err = batadv_send_skb_via_tt_4addr(bat_priv, skb_new, in batadv_dat_snoop_incoming_arp_request()
1269 err = batadv_send_skb_via_tt(bat_priv, skb_new, NULL, vid); in batadv_dat_snoop_incoming_arp_request()
1272 batadv_inc_counter(bat_priv, BATADV_CNT_DAT_CACHED_REPLY_TX); in batadv_dat_snoop_incoming_arp_request()
1287 void batadv_dat_snoop_outgoing_arp_reply(struct batadv_priv *bat_priv, in batadv_dat_snoop_outgoing_arp_reply() argument
1296 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_outgoing_arp_reply()
1301 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_outgoing_arp_reply()
1305 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing outgoing ARP REPLY"); in batadv_dat_snoop_outgoing_arp_reply()
1312 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_outgoing_arp_reply()
1313 batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); in batadv_dat_snoop_outgoing_arp_reply()
1318 batadv_dat_forward_data(bat_priv, skb, ip_src, vid, in batadv_dat_snoop_outgoing_arp_reply()
1320 batadv_dat_forward_data(bat_priv, skb, ip_dst, vid, in batadv_dat_snoop_outgoing_arp_reply()
1334 bool batadv_dat_snoop_incoming_arp_reply(struct batadv_priv *bat_priv, in batadv_dat_snoop_incoming_arp_reply() argument
1344 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_incoming_arp_reply()
1349 type = batadv_arp_get_type(bat_priv, skb, hdr_size); in batadv_dat_snoop_incoming_arp_reply()
1353 batadv_dbg_arp(bat_priv, skb, hdr_size, "Parsing incoming ARP REPLY"); in batadv_dat_snoop_incoming_arp_reply()
1366 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_src, vid); in batadv_dat_snoop_incoming_arp_reply()
1368 …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()
1377 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_incoming_arp_reply()
1378 batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); in batadv_dat_snoop_incoming_arp_reply()
1389 if (!batadv_bla_check_claim(bat_priv, hw_src, vid)) { in batadv_dat_snoop_incoming_arp_reply()
1390 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_incoming_arp_reply()
1400 dropped = !batadv_is_my_client(bat_priv, hw_dst, vid); in batadv_dat_snoop_incoming_arp_reply()
1405 dropped |= batadv_is_my_client(bat_priv, hw_src, vid); in batadv_dat_snoop_incoming_arp_reply()
1621 static void batadv_dat_put_dhcp(struct batadv_priv *bat_priv, u8 *chaddr, in batadv_dat_put_dhcp() argument
1627 skb = batadv_dat_arp_create_reply(bat_priv, yiaddr, ip_dst, chaddr, in batadv_dat_put_dhcp()
1634 batadv_dat_entry_add(bat_priv, yiaddr, chaddr, vid); in batadv_dat_put_dhcp()
1635 batadv_dat_entry_add(bat_priv, ip_dst, hw_dst, vid); in batadv_dat_put_dhcp()
1637 batadv_dat_forward_data(bat_priv, skb, yiaddr, vid, in batadv_dat_put_dhcp()
1639 batadv_dat_forward_data(bat_priv, skb, ip_dst, vid, in batadv_dat_put_dhcp()
1644 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_put_dhcp()
1647 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_put_dhcp()
1706 void batadv_dat_snoop_outgoing_dhcp_ack(struct batadv_priv *bat_priv, in batadv_dat_snoop_outgoing_dhcp_ack() argument
1714 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_outgoing_dhcp_ack()
1720 batadv_dat_put_dhcp(bat_priv, chaddr, yiaddr, eth_hdr(skb)->h_source, in batadv_dat_snoop_outgoing_dhcp_ack()
1734 void batadv_dat_snoop_incoming_dhcp_ack(struct batadv_priv *bat_priv, in batadv_dat_snoop_incoming_dhcp_ack() argument
1744 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_snoop_incoming_dhcp_ack()
1760 batadv_dat_entry_add(bat_priv, yiaddr, chaddr, vid); in batadv_dat_snoop_incoming_dhcp_ack()
1761 batadv_dat_entry_add(bat_priv, ip_src, hw_src, vid); in batadv_dat_snoop_incoming_dhcp_ack()
1763 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_incoming_dhcp_ack()
1766 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_snoop_incoming_dhcp_ack()
1779 bool batadv_dat_drop_broadcast_packet(struct batadv_priv *bat_priv, in batadv_dat_drop_broadcast_packet() argument
1789 if (!atomic_read(&bat_priv->distributed_arp_table)) in batadv_dat_drop_broadcast_packet()
1800 type = batadv_arp_get_type(bat_priv, forw_packet->skb, hdr_size); in batadv_dat_drop_broadcast_packet()
1805 dat_entry = batadv_dat_entry_hash_find(bat_priv, ip_dst, vid); in batadv_dat_drop_broadcast_packet()
1808 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_drop_broadcast_packet()
1813 batadv_dbg(BATADV_DBG_DAT, bat_priv, in batadv_dat_drop_broadcast_packet()