89 static void batadv_nc_start_timer(struct batadv_priv *bat_priv)  in batadv_nc_start_timer()  argument
91 	queue_delayed_work(batadv_event_workqueue, &bat_priv->nc.work,  in batadv_nc_start_timer()
100 static void batadv_nc_tvlv_container_update(struct batadv_priv *bat_priv)  in batadv_nc_tvlv_container_update()  argument
104 	nc_mode = atomic_read(&bat_priv->network_coding);  in batadv_nc_tvlv_container_update()
108 		batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_tvlv_container_update()
111 		batadv_tvlv_container_register(bat_priv, BATADV_TVLV_NC, 1,  in batadv_nc_tvlv_container_update()
124 	struct batadv_priv *bat_priv = netdev_priv(net_dev);  in batadv_nc_status_update()  local
126 	batadv_nc_tvlv_container_update(bat_priv);  in batadv_nc_status_update()
137 static void batadv_nc_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv,  in batadv_nc_tvlv_ogm_handler_v1()  argument
154 int batadv_nc_mesh_init(struct batadv_priv *bat_priv)  in batadv_nc_mesh_init()  argument
156 	bat_priv->nc.timestamp_fwd_flush = jiffies;  in batadv_nc_mesh_init()
157 	bat_priv->nc.timestamp_sniffed_purge = jiffies;  in batadv_nc_mesh_init()
159 	if (bat_priv->nc.coding_hash || bat_priv->nc.decoding_hash)  in batadv_nc_mesh_init()
162 	bat_priv->nc.coding_hash = batadv_hash_new(128);  in batadv_nc_mesh_init()
163 	if (!bat_priv->nc.coding_hash)  in batadv_nc_mesh_init()
166 	batadv_hash_set_lock_class(bat_priv->nc.coding_hash,  in batadv_nc_mesh_init()
169 	bat_priv->nc.decoding_hash = batadv_hash_new(128);  in batadv_nc_mesh_init()
170 	if (!bat_priv->nc.decoding_hash)  in batadv_nc_mesh_init()
173 	batadv_hash_set_lock_class(bat_priv->nc.decoding_hash,  in batadv_nc_mesh_init()
176 	INIT_DELAYED_WORK(&bat_priv->nc.work, batadv_nc_worker);  in batadv_nc_mesh_init()
177 	batadv_nc_start_timer(bat_priv);  in batadv_nc_mesh_init()
179 	batadv_tvlv_handler_register(bat_priv, batadv_nc_tvlv_ogm_handler_v1,  in batadv_nc_mesh_init()
182 	batadv_nc_tvlv_container_update(bat_priv);  in batadv_nc_mesh_init()
193 void batadv_nc_init_bat_priv(struct batadv_priv *bat_priv)  in batadv_nc_init_bat_priv()  argument
195 	atomic_set(&bat_priv->network_coding, 0);  in batadv_nc_init_bat_priv()
196 	bat_priv->nc.min_tq = 200;  in batadv_nc_init_bat_priv()
197 	bat_priv->nc.max_fwd_delay = 10;  in batadv_nc_init_bat_priv()
198 	bat_priv->nc.max_buffer_time = 200;  in batadv_nc_init_bat_priv()
286 static bool batadv_nc_to_purge_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_node()  argument
289 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_node()
302 static bool batadv_nc_to_purge_nc_path_coding(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_path_coding()  argument
305 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_path_coding()
312 				    bat_priv->nc.max_fwd_delay * 10);  in batadv_nc_to_purge_nc_path_coding()
323 static bool batadv_nc_to_purge_nc_path_decoding(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_path_decoding()  argument
326 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_path_decoding()
333 				    bat_priv->nc.max_buffer_time * 10);  in batadv_nc_to_purge_nc_path_decoding()
348 batadv_nc_purge_orig_nc_nodes(struct batadv_priv *bat_priv,  in batadv_nc_purge_orig_nc_nodes()  argument
362 		if (to_purge && !to_purge(bat_priv, nc_node))  in batadv_nc_purge_orig_nc_nodes()
365 		batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_purge_orig_nc_nodes()
384 void batadv_nc_purge_orig(struct batadv_priv *bat_priv,  in batadv_nc_purge_orig()  argument
390 	batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->in_coding_list,  in batadv_nc_purge_orig()
395 	batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->out_coding_list,  in batadv_nc_purge_orig()
405 static void batadv_nc_purge_orig_hash(struct batadv_priv *bat_priv)  in batadv_nc_purge_orig_hash()  argument
407 	struct batadv_hashtable *hash = bat_priv->orig_hash;  in batadv_nc_purge_orig_hash()
421 			batadv_nc_purge_orig(bat_priv, orig_node,  in batadv_nc_purge_orig_hash()
437 static void batadv_nc_purge_paths(struct batadv_priv *bat_priv,  in batadv_nc_purge_paths()  argument
458 			if (to_purge && !to_purge(bat_priv, nc_path))  in batadv_nc_purge_paths()
476 			batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_purge_paths()
604 static bool batadv_nc_sniffed_purge(struct batadv_priv *bat_priv,  in batadv_nc_sniffed_purge()  argument
608 	unsigned long timeout = bat_priv->nc.max_buffer_time;  in batadv_nc_sniffed_purge()
616 	if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE &&  in batadv_nc_sniffed_purge()
643 static bool batadv_nc_fwd_flush(struct batadv_priv *bat_priv,  in batadv_nc_fwd_flush()  argument
647 	unsigned long timeout = bat_priv->nc.max_fwd_delay;  in batadv_nc_fwd_flush()
654 	if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE &&  in batadv_nc_fwd_flush()
659 	batadv_inc_counter(bat_priv, BATADV_CNT_FORWARD);  in batadv_nc_fwd_flush()
660 	batadv_add_counter(bat_priv, BATADV_CNT_FORWARD_BYTES,  in batadv_nc_fwd_flush()
678 batadv_nc_process_nc_paths(struct batadv_priv *bat_priv,  in batadv_nc_process_nc_paths()  argument
704 				ret = process_fn(bat_priv, nc_path, nc_packet);  in batadv_nc_process_nc_paths()
723 	struct batadv_priv *bat_priv;  in batadv_nc_worker()  local
728 	bat_priv = container_of(priv_nc, struct batadv_priv, nc);  in batadv_nc_worker()
730 	batadv_nc_purge_orig_hash(bat_priv);  in batadv_nc_worker()
731 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash,  in batadv_nc_worker()
733 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash,  in batadv_nc_worker()
736 	timeout = bat_priv->nc.max_fwd_delay;  in batadv_nc_worker()
738 	if (batadv_has_timed_out(bat_priv->nc.timestamp_fwd_flush, timeout)) {  in batadv_nc_worker()
739 		batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.coding_hash,  in batadv_nc_worker()
741 		bat_priv->nc.timestamp_fwd_flush = jiffies;  in batadv_nc_worker()
744 	if (batadv_has_timed_out(bat_priv->nc.timestamp_sniffed_purge,  in batadv_nc_worker()
745 				 bat_priv->nc.max_buffer_time)) {  in batadv_nc_worker()
746 		batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.decoding_hash,  in batadv_nc_worker()
748 		bat_priv->nc.timestamp_sniffed_purge = jiffies;  in batadv_nc_worker()
752 	batadv_nc_start_timer(bat_priv);  in batadv_nc_worker()
768 static bool batadv_can_nc_with_orig(struct batadv_priv *bat_priv,  in batadv_can_nc_with_orig()  argument
790 	if (ogm_packet->tq < bat_priv->nc.min_tq)  in batadv_can_nc_with_orig()
848 batadv_nc_get_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_get_nc_node()  argument
886 	batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_node %pM -> %pM\n",  in batadv_nc_get_nc_node()
909 void batadv_nc_update_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_update_nc_node()  argument
919 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_update_nc_node()
927 	if (!batadv_can_nc_with_orig(bat_priv, orig_node, ogm_packet) &&  in batadv_nc_update_nc_node()
932 	in_nc_node = batadv_nc_get_nc_node(bat_priv, orig_node,  in batadv_nc_update_nc_node()
940 	out_nc_node = batadv_nc_get_nc_node(bat_priv, orig_neigh_node,  in batadv_nc_update_nc_node()
964 static struct batadv_nc_path *batadv_nc_get_path(struct batadv_priv *bat_priv,  in batadv_nc_get_path()  argument
997 	batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_path %pM -> %pM\n",  in batadv_nc_get_path()
1063 static bool batadv_nc_code_packets(struct batadv_priv *bat_priv,  in batadv_nc_code_packets()  argument
1194 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE, 2);  in batadv_nc_code_packets()
1195 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, count);  in batadv_nc_code_packets()
1201 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE, 2);  in batadv_nc_code_packets()
1202 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, count);  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()
1209 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE);  in batadv_nc_code_packets()
1210 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES,  in batadv_nc_code_packets()
1215 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE);  in batadv_nc_code_packets()
1216 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES,  in batadv_nc_code_packets()
1218 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE);  in batadv_nc_code_packets()
1219 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES,  in batadv_nc_code_packets()
1281 batadv_nc_path_search(struct batadv_priv *bat_priv,  in batadv_nc_path_search()  argument
1290 	struct batadv_hashtable *hash = bat_priv->nc.coding_hash;  in batadv_nc_path_search()
1349 batadv_nc_skb_src_search(struct batadv_priv *bat_priv,  in batadv_nc_skb_src_search()  argument
1359 	orig_node = batadv_orig_hash_find(bat_priv, eth_src);  in batadv_nc_skb_src_search()
1372 		nc_packet = batadv_nc_path_search(bat_priv, in_nc_node,  in batadv_nc_skb_src_search()
1390 static void batadv_nc_skb_store_before_coding(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_before_coding()  argument
1410 	batadv_nc_skb_store_for_decoding(bat_priv, skb);  in batadv_nc_skb_store_before_coding()
1436 	struct batadv_priv *bat_priv = netdev_priv(netdev);  in batadv_nc_skb_dst_search()  local
1444 		nc_packet = batadv_nc_skb_src_search(bat_priv, skb,  in batadv_nc_skb_dst_search()
1458 	batadv_nc_skb_store_before_coding(bat_priv, skb,  in batadv_nc_skb_dst_search()
1460 	batadv_nc_skb_store_before_coding(bat_priv, nc_packet->skb,  in batadv_nc_skb_dst_search()
1464 	if (batadv_nc_code_packets(bat_priv, skb, ethhdr, nc_packet,  in batadv_nc_skb_dst_search()
1523 	struct batadv_priv *bat_priv = netdev_priv(netdev);  in batadv_nc_skb_forward()  local
1531 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_skb_forward()
1545 	nc_path = batadv_nc_get_path(bat_priv,  in batadv_nc_skb_forward()
1546 				     bat_priv->nc.coding_hash,  in batadv_nc_skb_forward()
1574 void batadv_nc_skb_store_for_decoding(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_for_decoding()  argument
1584 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_skb_store_for_decoding()
1594 	nc_path = batadv_nc_get_path(bat_priv,  in batadv_nc_skb_store_for_decoding()
1595 				     bat_priv->nc.decoding_hash,  in batadv_nc_skb_store_for_decoding()
1618 	batadv_inc_counter(bat_priv, BATADV_CNT_NC_BUFFER);  in batadv_nc_skb_store_for_decoding()
1635 void batadv_nc_skb_store_sniffed_unicast(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_sniffed_unicast()  argument
1640 	if (batadv_is_my_mac(bat_priv, ethhdr->h_dest))  in batadv_nc_skb_store_sniffed_unicast()
1646 	batadv_nc_skb_store_for_decoding(bat_priv, skb);  in batadv_nc_skb_store_sniffed_unicast()
1660 batadv_nc_skb_decode_packet(struct batadv_priv *bat_priv, struct sk_buff *skb,  in batadv_nc_skb_decode_packet()  argument
1695 	if (batadv_is_my_mac(bat_priv, coded_packet_tmp.second_dest)) {  in batadv_nc_skb_decode_packet()
1753 batadv_nc_find_decoding_packet(struct batadv_priv *bat_priv,  in batadv_nc_find_decoding_packet()  argument
1757 	struct batadv_hashtable *hash = bat_priv->nc.decoding_hash;  in batadv_nc_find_decoding_packet()
1769 	if (!batadv_is_my_mac(bat_priv, coded->second_dest)) {  in batadv_nc_find_decoding_packet()
1802 		batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_find_decoding_packet()
1820 	struct batadv_priv *bat_priv = netdev_priv(recv_if->soft_iface);  in batadv_nc_recv_coded_packet()  local
1828 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_recv_coded_packet()
1839 	if (!batadv_is_my_mac(bat_priv, ethhdr->h_dest) &&  in batadv_nc_recv_coded_packet()
1840 	    !batadv_is_my_mac(bat_priv, coded_packet->second_dest))  in batadv_nc_recv_coded_packet()
1844 	if (batadv_is_my_mac(bat_priv, coded_packet->second_dest))  in batadv_nc_recv_coded_packet()
1845 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_SNIFFED);  in batadv_nc_recv_coded_packet()
1847 	nc_packet = batadv_nc_find_decoding_packet(bat_priv, ethhdr,  in batadv_nc_recv_coded_packet()
1850 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED);  in batadv_nc_recv_coded_packet()
1862 	unicast_packet = batadv_nc_skb_decode_packet(bat_priv, skb, nc_packet);  in batadv_nc_recv_coded_packet()
1864 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED);  in batadv_nc_recv_coded_packet()
1870 	batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE);  in batadv_nc_recv_coded_packet()
1871 	batadv_add_counter(bat_priv, BATADV_CNT_NC_DECODE_BYTES,  in batadv_nc_recv_coded_packet()
1887 void batadv_nc_mesh_free(struct batadv_priv *bat_priv)  in batadv_nc_mesh_free()  argument
1889 	batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_mesh_free()
1890 	batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_mesh_free()
1891 	cancel_delayed_work_sync(&bat_priv->nc.work);  in batadv_nc_mesh_free()
1893 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash, NULL);  in batadv_nc_mesh_free()
1894 	batadv_hash_destroy(bat_priv->nc.coding_hash);  in batadv_nc_mesh_free()
1895 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash, NULL);  in batadv_nc_mesh_free()
1896 	batadv_hash_destroy(bat_priv->nc.decoding_hash);  in batadv_nc_mesh_free()
1910 	struct batadv_priv *bat_priv = netdev_priv(net_dev);  in batadv_nc_nodes_seq_print_text()  local
1911 	struct batadv_hashtable *hash = bat_priv->orig_hash;  in batadv_nc_nodes_seq_print_text()
1969 int batadv_nc_init_debugfs(struct batadv_priv *bat_priv)  in batadv_nc_init_debugfs()  argument
1973 	nc_dir = debugfs_create_dir("nc", bat_priv->debug_dir);  in batadv_nc_init_debugfs()
1977 	file = debugfs_create_u8("min_tq", 0644, nc_dir, &bat_priv->nc.min_tq);  in batadv_nc_init_debugfs()
1982 				  &bat_priv->nc.max_fwd_delay);  in batadv_nc_init_debugfs()
1987 				  &bat_priv->nc.max_buffer_time);  in batadv_nc_init_debugfs()