Lines Matching refs:bat_priv
74 static void batadv_nc_start_timer(struct batadv_priv *bat_priv) in batadv_nc_start_timer() argument
76 queue_delayed_work(batadv_event_workqueue, &bat_priv->nc.work, in batadv_nc_start_timer()
85 static void batadv_nc_tvlv_container_update(struct batadv_priv *bat_priv) in batadv_nc_tvlv_container_update() argument
89 nc_mode = atomic_read(&bat_priv->network_coding); in batadv_nc_tvlv_container_update()
93 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1); in batadv_nc_tvlv_container_update()
96 batadv_tvlv_container_register(bat_priv, BATADV_TVLV_NC, 1, in batadv_nc_tvlv_container_update()
109 struct batadv_priv *bat_priv = netdev_priv(net_dev); in batadv_nc_status_update() local
111 batadv_nc_tvlv_container_update(bat_priv); in batadv_nc_status_update()
122 static void batadv_nc_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv, in batadv_nc_tvlv_ogm_handler_v1() argument
139 int batadv_nc_mesh_init(struct batadv_priv *bat_priv) in batadv_nc_mesh_init() argument
141 bat_priv->nc.timestamp_fwd_flush = jiffies; in batadv_nc_mesh_init()
142 bat_priv->nc.timestamp_sniffed_purge = jiffies; in batadv_nc_mesh_init()
144 if (bat_priv->nc.coding_hash || bat_priv->nc.decoding_hash) in batadv_nc_mesh_init()
147 bat_priv->nc.coding_hash = batadv_hash_new(128); in batadv_nc_mesh_init()
148 if (!bat_priv->nc.coding_hash) in batadv_nc_mesh_init()
151 batadv_hash_set_lock_class(bat_priv->nc.coding_hash, in batadv_nc_mesh_init()
154 bat_priv->nc.decoding_hash = batadv_hash_new(128); in batadv_nc_mesh_init()
155 if (!bat_priv->nc.decoding_hash) { in batadv_nc_mesh_init()
156 batadv_hash_destroy(bat_priv->nc.coding_hash); in batadv_nc_mesh_init()
160 batadv_hash_set_lock_class(bat_priv->nc.decoding_hash, in batadv_nc_mesh_init()
163 INIT_DELAYED_WORK(&bat_priv->nc.work, batadv_nc_worker); in batadv_nc_mesh_init()
164 batadv_nc_start_timer(bat_priv); in batadv_nc_mesh_init()
166 batadv_tvlv_handler_register(bat_priv, batadv_nc_tvlv_ogm_handler_v1, in batadv_nc_mesh_init()
169 batadv_nc_tvlv_container_update(bat_priv); in batadv_nc_mesh_init()
180 void batadv_nc_init_bat_priv(struct batadv_priv *bat_priv) in batadv_nc_init_bat_priv() argument
182 atomic_set(&bat_priv->network_coding, 0); in batadv_nc_init_bat_priv()
183 bat_priv->nc.min_tq = 200; in batadv_nc_init_bat_priv()
184 bat_priv->nc.max_fwd_delay = 10; in batadv_nc_init_bat_priv()
185 bat_priv->nc.max_buffer_time = 200; in batadv_nc_init_bat_priv()
279 static bool batadv_nc_to_purge_nc_node(struct batadv_priv *bat_priv, in batadv_nc_to_purge_nc_node() argument
282 if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE) in batadv_nc_to_purge_nc_node()
295 static bool batadv_nc_to_purge_nc_path_coding(struct batadv_priv *bat_priv, in batadv_nc_to_purge_nc_path_coding() argument
298 if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE) in batadv_nc_to_purge_nc_path_coding()
305 bat_priv->nc.max_fwd_delay * 10); in batadv_nc_to_purge_nc_path_coding()
316 static bool batadv_nc_to_purge_nc_path_decoding(struct batadv_priv *bat_priv, in batadv_nc_to_purge_nc_path_decoding() argument
319 if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE) in batadv_nc_to_purge_nc_path_decoding()
326 bat_priv->nc.max_buffer_time * 10); in batadv_nc_to_purge_nc_path_decoding()
341 batadv_nc_purge_orig_nc_nodes(struct batadv_priv *bat_priv, in batadv_nc_purge_orig_nc_nodes() argument
355 if (to_purge && !to_purge(bat_priv, nc_node)) in batadv_nc_purge_orig_nc_nodes()
358 batadv_dbg(BATADV_DBG_NC, bat_priv, in batadv_nc_purge_orig_nc_nodes()
377 void batadv_nc_purge_orig(struct batadv_priv *bat_priv, in batadv_nc_purge_orig() argument
383 batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->in_coding_list, in batadv_nc_purge_orig()
388 batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->out_coding_list, in batadv_nc_purge_orig()
398 static void batadv_nc_purge_orig_hash(struct batadv_priv *bat_priv) in batadv_nc_purge_orig_hash() argument
400 struct batadv_hashtable *hash = bat_priv->orig_hash; in batadv_nc_purge_orig_hash()
414 batadv_nc_purge_orig(bat_priv, orig_node, in batadv_nc_purge_orig_hash()
430 static void batadv_nc_purge_paths(struct batadv_priv *bat_priv, in batadv_nc_purge_paths() argument
451 if (to_purge && !to_purge(bat_priv, nc_path)) in batadv_nc_purge_paths()
469 batadv_dbg(BATADV_DBG_NC, bat_priv, in batadv_nc_purge_paths()
597 static bool batadv_nc_sniffed_purge(struct batadv_priv *bat_priv, in batadv_nc_sniffed_purge() argument
601 unsigned long timeout = bat_priv->nc.max_buffer_time; in batadv_nc_sniffed_purge()
609 if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE && in batadv_nc_sniffed_purge()
636 static bool batadv_nc_fwd_flush(struct batadv_priv *bat_priv, in batadv_nc_fwd_flush() argument
640 unsigned long timeout = bat_priv->nc.max_fwd_delay; in batadv_nc_fwd_flush()
647 if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE && in batadv_nc_fwd_flush()
652 batadv_inc_counter(bat_priv, BATADV_CNT_FORWARD); in batadv_nc_fwd_flush()
653 batadv_add_counter(bat_priv, BATADV_CNT_FORWARD_BYTES, in batadv_nc_fwd_flush()
671 batadv_nc_process_nc_paths(struct batadv_priv *bat_priv, in batadv_nc_process_nc_paths() argument
697 ret = process_fn(bat_priv, nc_path, nc_packet); in batadv_nc_process_nc_paths()
716 struct batadv_priv *bat_priv; in batadv_nc_worker() local
721 bat_priv = container_of(priv_nc, struct batadv_priv, nc); in batadv_nc_worker()
723 batadv_nc_purge_orig_hash(bat_priv); in batadv_nc_worker()
724 batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash, in batadv_nc_worker()
726 batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash, in batadv_nc_worker()
729 timeout = bat_priv->nc.max_fwd_delay; in batadv_nc_worker()
731 if (batadv_has_timed_out(bat_priv->nc.timestamp_fwd_flush, timeout)) { in batadv_nc_worker()
732 batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.coding_hash, in batadv_nc_worker()
734 bat_priv->nc.timestamp_fwd_flush = jiffies; in batadv_nc_worker()
737 if (batadv_has_timed_out(bat_priv->nc.timestamp_sniffed_purge, in batadv_nc_worker()
738 bat_priv->nc.max_buffer_time)) { in batadv_nc_worker()
739 batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.decoding_hash, in batadv_nc_worker()
741 bat_priv->nc.timestamp_sniffed_purge = jiffies; in batadv_nc_worker()
745 batadv_nc_start_timer(bat_priv); in batadv_nc_worker()
761 static bool batadv_can_nc_with_orig(struct batadv_priv *bat_priv, in batadv_can_nc_with_orig() argument
783 if (ogm_packet->tq < bat_priv->nc.min_tq) in batadv_can_nc_with_orig()
841 batadv_nc_get_nc_node(struct batadv_priv *bat_priv, in batadv_nc_get_nc_node() argument
879 batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_node %pM -> %pM\n", in batadv_nc_get_nc_node()
902 void batadv_nc_update_nc_node(struct batadv_priv *bat_priv, in batadv_nc_update_nc_node() argument
912 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_update_nc_node()
920 if (!batadv_can_nc_with_orig(bat_priv, orig_node, ogm_packet) && in batadv_nc_update_nc_node()
925 in_nc_node = batadv_nc_get_nc_node(bat_priv, orig_node, in batadv_nc_update_nc_node()
933 out_nc_node = batadv_nc_get_nc_node(bat_priv, orig_neigh_node, in batadv_nc_update_nc_node()
955 static struct batadv_nc_path *batadv_nc_get_path(struct batadv_priv *bat_priv, in batadv_nc_get_path() argument
988 batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_path %pM -> %pM\n", in batadv_nc_get_path()
1047 static bool batadv_nc_code_packets(struct batadv_priv *bat_priv, in batadv_nc_code_packets() argument
1178 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE, 2); in batadv_nc_code_packets()
1179 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, count); in batadv_nc_code_packets()
1185 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE, 2); in batadv_nc_code_packets()
1186 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, count); in batadv_nc_code_packets()
1190 batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE); in batadv_nc_code_packets()
1191 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, in batadv_nc_code_packets()
1193 batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE); in batadv_nc_code_packets()
1194 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, in batadv_nc_code_packets()
1199 batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE); in batadv_nc_code_packets()
1200 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, in batadv_nc_code_packets()
1202 batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE); in batadv_nc_code_packets()
1203 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, in batadv_nc_code_packets()
1261 batadv_nc_path_search(struct batadv_priv *bat_priv, in batadv_nc_path_search() argument
1270 struct batadv_hashtable *hash = bat_priv->nc.coding_hash; in batadv_nc_path_search()
1329 batadv_nc_skb_src_search(struct batadv_priv *bat_priv, in batadv_nc_skb_src_search() argument
1339 orig_node = batadv_orig_hash_find(bat_priv, eth_src); in batadv_nc_skb_src_search()
1352 nc_packet = batadv_nc_path_search(bat_priv, in_nc_node, in batadv_nc_skb_src_search()
1370 static void batadv_nc_skb_store_before_coding(struct batadv_priv *bat_priv, in batadv_nc_skb_store_before_coding() argument
1390 batadv_nc_skb_store_for_decoding(bat_priv, skb); in batadv_nc_skb_store_before_coding()
1416 struct batadv_priv *bat_priv = netdev_priv(netdev); in batadv_nc_skb_dst_search() local
1424 nc_packet = batadv_nc_skb_src_search(bat_priv, skb, in batadv_nc_skb_dst_search()
1438 batadv_nc_skb_store_before_coding(bat_priv, skb, in batadv_nc_skb_dst_search()
1440 batadv_nc_skb_store_before_coding(bat_priv, nc_packet->skb, in batadv_nc_skb_dst_search()
1444 if (batadv_nc_code_packets(bat_priv, skb, ethhdr, nc_packet, in batadv_nc_skb_dst_search()
1503 struct batadv_priv *bat_priv = netdev_priv(netdev); in batadv_nc_skb_forward() local
1511 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_skb_forward()
1525 nc_path = batadv_nc_get_path(bat_priv, in batadv_nc_skb_forward()
1526 bat_priv->nc.coding_hash, in batadv_nc_skb_forward()
1554 void batadv_nc_skb_store_for_decoding(struct batadv_priv *bat_priv, in batadv_nc_skb_store_for_decoding() argument
1564 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_skb_store_for_decoding()
1574 nc_path = batadv_nc_get_path(bat_priv, in batadv_nc_skb_store_for_decoding()
1575 bat_priv->nc.decoding_hash, in batadv_nc_skb_store_for_decoding()
1598 batadv_inc_counter(bat_priv, BATADV_CNT_NC_BUFFER); in batadv_nc_skb_store_for_decoding()
1615 void batadv_nc_skb_store_sniffed_unicast(struct batadv_priv *bat_priv, in batadv_nc_skb_store_sniffed_unicast() argument
1620 if (batadv_is_my_mac(bat_priv, ethhdr->h_dest)) in batadv_nc_skb_store_sniffed_unicast()
1626 batadv_nc_skb_store_for_decoding(bat_priv, skb); in batadv_nc_skb_store_sniffed_unicast()
1640 batadv_nc_skb_decode_packet(struct batadv_priv *bat_priv, struct sk_buff *skb, in batadv_nc_skb_decode_packet() argument
1675 if (batadv_is_my_mac(bat_priv, coded_packet_tmp.second_dest)) { in batadv_nc_skb_decode_packet()
1733 batadv_nc_find_decoding_packet(struct batadv_priv *bat_priv, in batadv_nc_find_decoding_packet() argument
1737 struct batadv_hashtable *hash = bat_priv->nc.decoding_hash; in batadv_nc_find_decoding_packet()
1749 if (!batadv_is_my_mac(bat_priv, coded->second_dest)) { in batadv_nc_find_decoding_packet()
1782 batadv_dbg(BATADV_DBG_NC, bat_priv, in batadv_nc_find_decoding_packet()
1800 struct batadv_priv *bat_priv = netdev_priv(recv_if->soft_iface); in batadv_nc_recv_coded_packet() local
1808 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_recv_coded_packet()
1819 if (!batadv_is_my_mac(bat_priv, ethhdr->h_dest) && in batadv_nc_recv_coded_packet()
1820 !batadv_is_my_mac(bat_priv, coded_packet->second_dest)) in batadv_nc_recv_coded_packet()
1824 if (batadv_is_my_mac(bat_priv, coded_packet->second_dest)) in batadv_nc_recv_coded_packet()
1825 batadv_inc_counter(bat_priv, BATADV_CNT_NC_SNIFFED); in batadv_nc_recv_coded_packet()
1827 nc_packet = batadv_nc_find_decoding_packet(bat_priv, ethhdr, in batadv_nc_recv_coded_packet()
1830 batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED); in batadv_nc_recv_coded_packet()
1842 unicast_packet = batadv_nc_skb_decode_packet(bat_priv, skb, nc_packet); in batadv_nc_recv_coded_packet()
1844 batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED); in batadv_nc_recv_coded_packet()
1850 batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE); in batadv_nc_recv_coded_packet()
1851 batadv_add_counter(bat_priv, BATADV_CNT_NC_DECODE_BYTES, in batadv_nc_recv_coded_packet()
1867 void batadv_nc_mesh_free(struct batadv_priv *bat_priv) in batadv_nc_mesh_free() argument
1869 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1); in batadv_nc_mesh_free()
1870 batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_NC, 1); in batadv_nc_mesh_free()
1871 cancel_delayed_work_sync(&bat_priv->nc.work); in batadv_nc_mesh_free()
1873 batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash, NULL); in batadv_nc_mesh_free()
1874 batadv_hash_destroy(bat_priv->nc.coding_hash); in batadv_nc_mesh_free()
1875 batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash, NULL); in batadv_nc_mesh_free()
1876 batadv_hash_destroy(bat_priv->nc.decoding_hash); in batadv_nc_mesh_free()