Lines Matching refs:bat_priv
77 static void batadv_nc_start_timer(struct batadv_priv *bat_priv) in batadv_nc_start_timer() argument
79 queue_delayed_work(batadv_event_workqueue, &bat_priv->nc.work, in batadv_nc_start_timer()
88 static void batadv_nc_tvlv_container_update(struct batadv_priv *bat_priv) in batadv_nc_tvlv_container_update() argument
92 nc_mode = atomic_read(&bat_priv->network_coding); in batadv_nc_tvlv_container_update()
96 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1); in batadv_nc_tvlv_container_update()
99 batadv_tvlv_container_register(bat_priv, BATADV_TVLV_NC, 1, in batadv_nc_tvlv_container_update()
112 struct batadv_priv *bat_priv = netdev_priv(net_dev); in batadv_nc_status_update() local
114 batadv_nc_tvlv_container_update(bat_priv); in batadv_nc_status_update()
125 static void batadv_nc_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv, in batadv_nc_tvlv_ogm_handler_v1() argument
142 int batadv_nc_mesh_init(struct batadv_priv *bat_priv) in batadv_nc_mesh_init() argument
144 bat_priv->nc.timestamp_fwd_flush = jiffies; in batadv_nc_mesh_init()
145 bat_priv->nc.timestamp_sniffed_purge = jiffies; in batadv_nc_mesh_init()
147 if (bat_priv->nc.coding_hash || bat_priv->nc.decoding_hash) in batadv_nc_mesh_init()
150 bat_priv->nc.coding_hash = batadv_hash_new(128); in batadv_nc_mesh_init()
151 if (!bat_priv->nc.coding_hash) in batadv_nc_mesh_init()
154 batadv_hash_set_lock_class(bat_priv->nc.coding_hash, in batadv_nc_mesh_init()
157 bat_priv->nc.decoding_hash = batadv_hash_new(128); in batadv_nc_mesh_init()
158 if (!bat_priv->nc.decoding_hash) in batadv_nc_mesh_init()
161 batadv_hash_set_lock_class(bat_priv->nc.decoding_hash, in batadv_nc_mesh_init()
164 INIT_DELAYED_WORK(&bat_priv->nc.work, batadv_nc_worker); in batadv_nc_mesh_init()
165 batadv_nc_start_timer(bat_priv); in batadv_nc_mesh_init()
167 batadv_tvlv_handler_register(bat_priv, batadv_nc_tvlv_ogm_handler_v1, in batadv_nc_mesh_init()
170 batadv_nc_tvlv_container_update(bat_priv); in batadv_nc_mesh_init()
181 void batadv_nc_init_bat_priv(struct batadv_priv *bat_priv) in batadv_nc_init_bat_priv() argument
183 atomic_set(&bat_priv->network_coding, 0); in batadv_nc_init_bat_priv()
184 bat_priv->nc.min_tq = 200; in batadv_nc_init_bat_priv()
185 bat_priv->nc.max_fwd_delay = 10; in batadv_nc_init_bat_priv()
186 bat_priv->nc.max_buffer_time = 200; in batadv_nc_init_bat_priv()
274 static bool batadv_nc_to_purge_nc_node(struct batadv_priv *bat_priv, in batadv_nc_to_purge_nc_node() argument
277 if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE) in batadv_nc_to_purge_nc_node()
290 static bool batadv_nc_to_purge_nc_path_coding(struct batadv_priv *bat_priv, in batadv_nc_to_purge_nc_path_coding() argument
293 if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE) in batadv_nc_to_purge_nc_path_coding()
300 bat_priv->nc.max_fwd_delay * 10); in batadv_nc_to_purge_nc_path_coding()
311 static bool batadv_nc_to_purge_nc_path_decoding(struct batadv_priv *bat_priv, in batadv_nc_to_purge_nc_path_decoding() argument
314 if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE) in batadv_nc_to_purge_nc_path_decoding()
321 bat_priv->nc.max_buffer_time * 10); in batadv_nc_to_purge_nc_path_decoding()
336 batadv_nc_purge_orig_nc_nodes(struct batadv_priv *bat_priv, in batadv_nc_purge_orig_nc_nodes() argument
350 if (to_purge && !to_purge(bat_priv, nc_node)) in batadv_nc_purge_orig_nc_nodes()
353 batadv_dbg(BATADV_DBG_NC, bat_priv, in batadv_nc_purge_orig_nc_nodes()
372 void batadv_nc_purge_orig(struct batadv_priv *bat_priv, in batadv_nc_purge_orig() argument
378 batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->in_coding_list, in batadv_nc_purge_orig()
383 batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->out_coding_list, in batadv_nc_purge_orig()
393 static void batadv_nc_purge_orig_hash(struct batadv_priv *bat_priv) in batadv_nc_purge_orig_hash() argument
395 struct batadv_hashtable *hash = bat_priv->orig_hash; in batadv_nc_purge_orig_hash()
409 batadv_nc_purge_orig(bat_priv, orig_node, in batadv_nc_purge_orig_hash()
425 static void batadv_nc_purge_paths(struct batadv_priv *bat_priv, in batadv_nc_purge_paths() argument
446 if (to_purge && !to_purge(bat_priv, nc_path)) in batadv_nc_purge_paths()
464 batadv_dbg(BATADV_DBG_NC, bat_priv, in batadv_nc_purge_paths()
592 static bool batadv_nc_sniffed_purge(struct batadv_priv *bat_priv, in batadv_nc_sniffed_purge() argument
596 unsigned long timeout = bat_priv->nc.max_buffer_time; in batadv_nc_sniffed_purge()
604 if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE && in batadv_nc_sniffed_purge()
631 static bool batadv_nc_fwd_flush(struct batadv_priv *bat_priv, in batadv_nc_fwd_flush() argument
635 unsigned long timeout = bat_priv->nc.max_fwd_delay; in batadv_nc_fwd_flush()
642 if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE && in batadv_nc_fwd_flush()
647 batadv_inc_counter(bat_priv, BATADV_CNT_FORWARD); in batadv_nc_fwd_flush()
648 batadv_add_counter(bat_priv, BATADV_CNT_FORWARD_BYTES, in batadv_nc_fwd_flush()
666 batadv_nc_process_nc_paths(struct batadv_priv *bat_priv, in batadv_nc_process_nc_paths() argument
692 ret = process_fn(bat_priv, nc_path, nc_packet); in batadv_nc_process_nc_paths()
711 struct batadv_priv *bat_priv; in batadv_nc_worker() local
716 bat_priv = container_of(priv_nc, struct batadv_priv, nc); in batadv_nc_worker()
718 batadv_nc_purge_orig_hash(bat_priv); in batadv_nc_worker()
719 batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash, in batadv_nc_worker()
721 batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash, in batadv_nc_worker()
724 timeout = bat_priv->nc.max_fwd_delay; in batadv_nc_worker()
726 if (batadv_has_timed_out(bat_priv->nc.timestamp_fwd_flush, timeout)) { in batadv_nc_worker()
727 batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.coding_hash, in batadv_nc_worker()
729 bat_priv->nc.timestamp_fwd_flush = jiffies; in batadv_nc_worker()
732 if (batadv_has_timed_out(bat_priv->nc.timestamp_sniffed_purge, in batadv_nc_worker()
733 bat_priv->nc.max_buffer_time)) { in batadv_nc_worker()
734 batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.decoding_hash, in batadv_nc_worker()
736 bat_priv->nc.timestamp_sniffed_purge = jiffies; in batadv_nc_worker()
740 batadv_nc_start_timer(bat_priv); in batadv_nc_worker()
756 static bool batadv_can_nc_with_orig(struct batadv_priv *bat_priv, in batadv_can_nc_with_orig() argument
778 if (ogm_packet->tq < bat_priv->nc.min_tq) in batadv_can_nc_with_orig()
836 batadv_nc_get_nc_node(struct batadv_priv *bat_priv, in batadv_nc_get_nc_node() argument
874 batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_node %pM -> %pM\n", in batadv_nc_get_nc_node()
897 void batadv_nc_update_nc_node(struct batadv_priv *bat_priv, in batadv_nc_update_nc_node() argument
907 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_update_nc_node()
915 if (!batadv_can_nc_with_orig(bat_priv, orig_node, ogm_packet) && in batadv_nc_update_nc_node()
920 in_nc_node = batadv_nc_get_nc_node(bat_priv, orig_node, in batadv_nc_update_nc_node()
928 out_nc_node = batadv_nc_get_nc_node(bat_priv, orig_neigh_node, in batadv_nc_update_nc_node()
952 static struct batadv_nc_path *batadv_nc_get_path(struct batadv_priv *bat_priv, in batadv_nc_get_path() argument
985 batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_path %pM -> %pM\n", in batadv_nc_get_path()
1051 static bool batadv_nc_code_packets(struct batadv_priv *bat_priv, in batadv_nc_code_packets() argument
1182 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE, 2); in batadv_nc_code_packets()
1183 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, count); in batadv_nc_code_packets()
1189 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE, 2); in batadv_nc_code_packets()
1190 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, count); in batadv_nc_code_packets()
1194 batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE); in batadv_nc_code_packets()
1195 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, in batadv_nc_code_packets()
1197 batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE); in batadv_nc_code_packets()
1198 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, in batadv_nc_code_packets()
1203 batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE); in batadv_nc_code_packets()
1204 batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, in batadv_nc_code_packets()
1206 batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE); in batadv_nc_code_packets()
1207 batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, in batadv_nc_code_packets()
1269 batadv_nc_path_search(struct batadv_priv *bat_priv, in batadv_nc_path_search() argument
1278 struct batadv_hashtable *hash = bat_priv->nc.coding_hash; in batadv_nc_path_search()
1337 batadv_nc_skb_src_search(struct batadv_priv *bat_priv, in batadv_nc_skb_src_search() argument
1347 orig_node = batadv_orig_hash_find(bat_priv, eth_src); in batadv_nc_skb_src_search()
1360 nc_packet = batadv_nc_path_search(bat_priv, in_nc_node, in batadv_nc_skb_src_search()
1378 static void batadv_nc_skb_store_before_coding(struct batadv_priv *bat_priv, in batadv_nc_skb_store_before_coding() argument
1398 batadv_nc_skb_store_for_decoding(bat_priv, skb); in batadv_nc_skb_store_before_coding()
1424 struct batadv_priv *bat_priv = netdev_priv(netdev); in batadv_nc_skb_dst_search() local
1432 nc_packet = batadv_nc_skb_src_search(bat_priv, skb, in batadv_nc_skb_dst_search()
1446 batadv_nc_skb_store_before_coding(bat_priv, skb, in batadv_nc_skb_dst_search()
1448 batadv_nc_skb_store_before_coding(bat_priv, nc_packet->skb, in batadv_nc_skb_dst_search()
1452 if (batadv_nc_code_packets(bat_priv, skb, ethhdr, nc_packet, in batadv_nc_skb_dst_search()
1511 struct batadv_priv *bat_priv = netdev_priv(netdev); in batadv_nc_skb_forward() local
1519 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_skb_forward()
1533 nc_path = batadv_nc_get_path(bat_priv, in batadv_nc_skb_forward()
1534 bat_priv->nc.coding_hash, in batadv_nc_skb_forward()
1562 void batadv_nc_skb_store_for_decoding(struct batadv_priv *bat_priv, in batadv_nc_skb_store_for_decoding() argument
1572 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_skb_store_for_decoding()
1582 nc_path = batadv_nc_get_path(bat_priv, in batadv_nc_skb_store_for_decoding()
1583 bat_priv->nc.decoding_hash, in batadv_nc_skb_store_for_decoding()
1606 batadv_inc_counter(bat_priv, BATADV_CNT_NC_BUFFER); in batadv_nc_skb_store_for_decoding()
1623 void batadv_nc_skb_store_sniffed_unicast(struct batadv_priv *bat_priv, in batadv_nc_skb_store_sniffed_unicast() argument
1628 if (batadv_is_my_mac(bat_priv, ethhdr->h_dest)) in batadv_nc_skb_store_sniffed_unicast()
1634 batadv_nc_skb_store_for_decoding(bat_priv, skb); in batadv_nc_skb_store_sniffed_unicast()
1648 batadv_nc_skb_decode_packet(struct batadv_priv *bat_priv, struct sk_buff *skb, in batadv_nc_skb_decode_packet() argument
1683 if (batadv_is_my_mac(bat_priv, coded_packet_tmp.second_dest)) { in batadv_nc_skb_decode_packet()
1741 batadv_nc_find_decoding_packet(struct batadv_priv *bat_priv, in batadv_nc_find_decoding_packet() argument
1745 struct batadv_hashtable *hash = bat_priv->nc.decoding_hash; in batadv_nc_find_decoding_packet()
1757 if (!batadv_is_my_mac(bat_priv, coded->second_dest)) { in batadv_nc_find_decoding_packet()
1790 batadv_dbg(BATADV_DBG_NC, bat_priv, in batadv_nc_find_decoding_packet()
1808 struct batadv_priv *bat_priv = netdev_priv(recv_if->soft_iface); in batadv_nc_recv_coded_packet() local
1816 if (!atomic_read(&bat_priv->network_coding)) in batadv_nc_recv_coded_packet()
1827 if (!batadv_is_my_mac(bat_priv, ethhdr->h_dest) && in batadv_nc_recv_coded_packet()
1828 !batadv_is_my_mac(bat_priv, coded_packet->second_dest)) in batadv_nc_recv_coded_packet()
1832 if (batadv_is_my_mac(bat_priv, coded_packet->second_dest)) in batadv_nc_recv_coded_packet()
1833 batadv_inc_counter(bat_priv, BATADV_CNT_NC_SNIFFED); in batadv_nc_recv_coded_packet()
1835 nc_packet = batadv_nc_find_decoding_packet(bat_priv, ethhdr, in batadv_nc_recv_coded_packet()
1838 batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED); in batadv_nc_recv_coded_packet()
1850 unicast_packet = batadv_nc_skb_decode_packet(bat_priv, skb, nc_packet); in batadv_nc_recv_coded_packet()
1852 batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED); in batadv_nc_recv_coded_packet()
1858 batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE); in batadv_nc_recv_coded_packet()
1859 batadv_add_counter(bat_priv, BATADV_CNT_NC_DECODE_BYTES, in batadv_nc_recv_coded_packet()
1875 void batadv_nc_mesh_free(struct batadv_priv *bat_priv) in batadv_nc_mesh_free() argument
1877 batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1); in batadv_nc_mesh_free()
1878 batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_NC, 1); in batadv_nc_mesh_free()
1879 cancel_delayed_work_sync(&bat_priv->nc.work); in batadv_nc_mesh_free()
1881 batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash, NULL); in batadv_nc_mesh_free()
1882 batadv_hash_destroy(bat_priv->nc.coding_hash); in batadv_nc_mesh_free()
1883 batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash, NULL); in batadv_nc_mesh_free()
1884 batadv_hash_destroy(bat_priv->nc.decoding_hash); in batadv_nc_mesh_free()
1898 struct batadv_priv *bat_priv = netdev_priv(net_dev); in batadv_nc_nodes_seq_print_text() local
1899 struct batadv_hashtable *hash = bat_priv->orig_hash; in batadv_nc_nodes_seq_print_text()
1955 void batadv_nc_init_debugfs(struct batadv_priv *bat_priv) in batadv_nc_init_debugfs() argument
1959 nc_dir = debugfs_create_dir("nc", bat_priv->debug_dir); in batadv_nc_init_debugfs()
1961 debugfs_create_u8("min_tq", 0644, nc_dir, &bat_priv->nc.min_tq); in batadv_nc_init_debugfs()
1964 &bat_priv->nc.max_fwd_delay); in batadv_nc_init_debugfs()
1967 &bat_priv->nc.max_buffer_time); in batadv_nc_init_debugfs()