83 static void batadv_nc_start_timer(struct batadv_priv *bat_priv)  in batadv_nc_start_timer()  argument
85 	queue_delayed_work(batadv_event_workqueue, &bat_priv->nc.work,  in batadv_nc_start_timer()
94 static void batadv_nc_tvlv_container_update(struct batadv_priv *bat_priv)  in batadv_nc_tvlv_container_update()  argument
98 	nc_mode = atomic_read(&bat_priv->network_coding);  in batadv_nc_tvlv_container_update()
102 		batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_tvlv_container_update()
105 		batadv_tvlv_container_register(bat_priv, BATADV_TVLV_NC, 1,  in batadv_nc_tvlv_container_update()
118 	struct batadv_priv *bat_priv = netdev_priv(net_dev);  in batadv_nc_status_update()  local
120 	batadv_nc_tvlv_container_update(bat_priv);  in batadv_nc_status_update()
131 static void batadv_nc_tvlv_ogm_handler_v1(struct batadv_priv *bat_priv,  in batadv_nc_tvlv_ogm_handler_v1()  argument
146 int batadv_nc_mesh_init(struct batadv_priv *bat_priv)  in batadv_nc_mesh_init()  argument
148 	bat_priv->nc.timestamp_fwd_flush = jiffies;  in batadv_nc_mesh_init()
149 	bat_priv->nc.timestamp_sniffed_purge = jiffies;  in batadv_nc_mesh_init()
151 	if (bat_priv->nc.coding_hash || bat_priv->nc.decoding_hash)  in batadv_nc_mesh_init()
154 	bat_priv->nc.coding_hash = batadv_hash_new(128);  in batadv_nc_mesh_init()
155 	if (!bat_priv->nc.coding_hash)  in batadv_nc_mesh_init()
158 	batadv_hash_set_lock_class(bat_priv->nc.coding_hash,  in batadv_nc_mesh_init()
161 	bat_priv->nc.decoding_hash = batadv_hash_new(128);  in batadv_nc_mesh_init()
162 	if (!bat_priv->nc.decoding_hash)  in batadv_nc_mesh_init()
165 	batadv_hash_set_lock_class(bat_priv->nc.decoding_hash,  in batadv_nc_mesh_init()
168 	INIT_DELAYED_WORK(&bat_priv->nc.work, batadv_nc_worker);  in batadv_nc_mesh_init()
169 	batadv_nc_start_timer(bat_priv);  in batadv_nc_mesh_init()
171 	batadv_tvlv_handler_register(bat_priv, batadv_nc_tvlv_ogm_handler_v1,  in batadv_nc_mesh_init()
174 	batadv_nc_tvlv_container_update(bat_priv);  in batadv_nc_mesh_init()
185 void batadv_nc_init_bat_priv(struct batadv_priv *bat_priv)  in batadv_nc_init_bat_priv()  argument
187 	atomic_set(&bat_priv->network_coding, 0);  in batadv_nc_init_bat_priv()
188 	bat_priv->nc.min_tq = 200;  in batadv_nc_init_bat_priv()
189 	bat_priv->nc.max_fwd_delay = 10;  in batadv_nc_init_bat_priv()
190 	bat_priv->nc.max_buffer_time = 200;  in batadv_nc_init_bat_priv()
258 static bool batadv_nc_to_purge_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_node()  argument
261 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_node()
274 static bool batadv_nc_to_purge_nc_path_coding(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_path_coding()  argument
277 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_path_coding()
284 				    bat_priv->nc.max_fwd_delay * 10);  in batadv_nc_to_purge_nc_path_coding()
294 static bool batadv_nc_to_purge_nc_path_decoding(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_path_decoding()  argument
297 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_path_decoding()
304 				    bat_priv->nc.max_buffer_time * 10);  in batadv_nc_to_purge_nc_path_decoding()
319 batadv_nc_purge_orig_nc_nodes(struct batadv_priv *bat_priv,  in batadv_nc_purge_orig_nc_nodes()  argument
333 		if (to_purge && !to_purge(bat_priv, nc_node))  in batadv_nc_purge_orig_nc_nodes()
336 		batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_purge_orig_nc_nodes()
355 void batadv_nc_purge_orig(struct batadv_priv *bat_priv,  in batadv_nc_purge_orig()  argument
361 	batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->in_coding_list,  in batadv_nc_purge_orig()
366 	batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->out_coding_list,  in batadv_nc_purge_orig()
376 static void batadv_nc_purge_orig_hash(struct batadv_priv *bat_priv)  in batadv_nc_purge_orig_hash()  argument
378 	struct batadv_hashtable *hash = bat_priv->orig_hash;  in batadv_nc_purge_orig_hash()
392 			batadv_nc_purge_orig(bat_priv, orig_node,  in batadv_nc_purge_orig_hash()
408 static void batadv_nc_purge_paths(struct batadv_priv *bat_priv,  in batadv_nc_purge_paths()  argument
429 			if (to_purge && !to_purge(bat_priv, nc_path))  in batadv_nc_purge_paths()
447 			batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_purge_paths()
579 static bool batadv_nc_sniffed_purge(struct batadv_priv *bat_priv,  in batadv_nc_sniffed_purge()  argument
583 	unsigned long timeout = bat_priv->nc.max_buffer_time;  in batadv_nc_sniffed_purge()
591 	if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE &&  in batadv_nc_sniffed_purge()
618 static bool batadv_nc_fwd_flush(struct batadv_priv *bat_priv,  in batadv_nc_fwd_flush()  argument
622 	unsigned long timeout = bat_priv->nc.max_fwd_delay;  in batadv_nc_fwd_flush()
629 	if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE &&  in batadv_nc_fwd_flush()
634 	batadv_inc_counter(bat_priv, BATADV_CNT_FORWARD);  in batadv_nc_fwd_flush()
635 	batadv_add_counter(bat_priv, BATADV_CNT_FORWARD_BYTES,  in batadv_nc_fwd_flush()
653 batadv_nc_process_nc_paths(struct batadv_priv *bat_priv,  in batadv_nc_process_nc_paths()  argument
679 				ret = process_fn(bat_priv, nc_path, nc_packet);  in batadv_nc_process_nc_paths()
697 	struct batadv_priv *bat_priv;  in batadv_nc_worker()  local
702 	bat_priv = container_of(priv_nc, struct batadv_priv, nc);  in batadv_nc_worker()
704 	batadv_nc_purge_orig_hash(bat_priv);  in batadv_nc_worker()
705 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash,  in batadv_nc_worker()
707 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash,  in batadv_nc_worker()
710 	timeout = bat_priv->nc.max_fwd_delay;  in batadv_nc_worker()
712 	if (batadv_has_timed_out(bat_priv->nc.timestamp_fwd_flush, timeout)) {  in batadv_nc_worker()
713 		batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.coding_hash,  in batadv_nc_worker()
715 		bat_priv->nc.timestamp_fwd_flush = jiffies;  in batadv_nc_worker()
718 	if (batadv_has_timed_out(bat_priv->nc.timestamp_sniffed_purge,  in batadv_nc_worker()
719 				 bat_priv->nc.max_buffer_time)) {  in batadv_nc_worker()
720 		batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.decoding_hash,  in batadv_nc_worker()
722 		bat_priv->nc.timestamp_sniffed_purge = jiffies;  in batadv_nc_worker()
726 	batadv_nc_start_timer(bat_priv);  in batadv_nc_worker()
742 static bool batadv_can_nc_with_orig(struct batadv_priv *bat_priv,  in batadv_can_nc_with_orig()  argument
764 	if (ogm_packet->tq < bat_priv->nc.min_tq)  in batadv_can_nc_with_orig()
822 *batadv_nc_get_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_get_nc_node()  argument
860 	batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_node %pM -> %pM\n",  in batadv_nc_get_nc_node()
885 void batadv_nc_update_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_update_nc_node()  argument
895 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_update_nc_node()
903 	if (!batadv_can_nc_with_orig(bat_priv, orig_node, ogm_packet) &&  in batadv_nc_update_nc_node()
908 	in_nc_node = batadv_nc_get_nc_node(bat_priv, orig_node,  in batadv_nc_update_nc_node()
916 	out_nc_node = batadv_nc_get_nc_node(bat_priv, orig_neigh_node,  in batadv_nc_update_nc_node()
940 static struct batadv_nc_path *batadv_nc_get_path(struct batadv_priv *bat_priv,  in batadv_nc_get_path()  argument
973 	batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_path %pM -> %pM\n",  in batadv_nc_get_path()
1036 static bool batadv_nc_code_packets(struct batadv_priv *bat_priv,  in batadv_nc_code_packets()  argument
1167 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE, 2);  in batadv_nc_code_packets()
1168 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, count);  in batadv_nc_code_packets()
1174 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE, 2);  in batadv_nc_code_packets()
1175 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, count);  in batadv_nc_code_packets()
1179 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE);  in batadv_nc_code_packets()
1180 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES,  in batadv_nc_code_packets()
1182 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE);  in batadv_nc_code_packets()
1183 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES,  in batadv_nc_code_packets()
1188 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE);  in batadv_nc_code_packets()
1189 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES,  in batadv_nc_code_packets()
1191 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE);  in batadv_nc_code_packets()
1192 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES,  in batadv_nc_code_packets()
1254 batadv_nc_path_search(struct batadv_priv *bat_priv,  in batadv_nc_path_search()  argument
1263 	struct batadv_hashtable *hash = bat_priv->nc.coding_hash;  in batadv_nc_path_search()
1322 batadv_nc_skb_src_search(struct batadv_priv *bat_priv,  in batadv_nc_skb_src_search()  argument
1332 	orig_node = batadv_orig_hash_find(bat_priv, eth_src);  in batadv_nc_skb_src_search()
1345 		nc_packet = batadv_nc_path_search(bat_priv, in_nc_node,  in batadv_nc_skb_src_search()
1363 static void batadv_nc_skb_store_before_coding(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_before_coding()  argument
1383 	batadv_nc_skb_store_for_decoding(bat_priv, skb);  in batadv_nc_skb_store_before_coding()
1409 	struct batadv_priv *bat_priv = netdev_priv(netdev);  in batadv_nc_skb_dst_search()  local
1417 		nc_packet = batadv_nc_skb_src_search(bat_priv, skb,  in batadv_nc_skb_dst_search()
1431 	batadv_nc_skb_store_before_coding(bat_priv, skb,  in batadv_nc_skb_dst_search()
1433 	batadv_nc_skb_store_before_coding(bat_priv, nc_packet->skb,  in batadv_nc_skb_dst_search()
1437 	if (batadv_nc_code_packets(bat_priv, skb, ethhdr, nc_packet,  in batadv_nc_skb_dst_search()
1496 	struct batadv_priv *bat_priv = netdev_priv(netdev);  in batadv_nc_skb_forward()  local
1504 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_skb_forward()
1518 	nc_path = batadv_nc_get_path(bat_priv,  in batadv_nc_skb_forward()
1519 				     bat_priv->nc.coding_hash,  in batadv_nc_skb_forward()
1547 void batadv_nc_skb_store_for_decoding(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_for_decoding()  argument
1557 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_skb_store_for_decoding()
1567 	nc_path = batadv_nc_get_path(bat_priv,  in batadv_nc_skb_store_for_decoding()
1568 				     bat_priv->nc.decoding_hash,  in batadv_nc_skb_store_for_decoding()
1591 	batadv_inc_counter(bat_priv, BATADV_CNT_NC_BUFFER);  in batadv_nc_skb_store_for_decoding()
1608 void batadv_nc_skb_store_sniffed_unicast(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_sniffed_unicast()  argument
1613 	if (batadv_is_my_mac(bat_priv, ethhdr->h_dest))  in batadv_nc_skb_store_sniffed_unicast()
1619 	batadv_nc_skb_store_for_decoding(bat_priv, skb);  in batadv_nc_skb_store_sniffed_unicast()
1633 batadv_nc_skb_decode_packet(struct batadv_priv *bat_priv, struct sk_buff *skb,  in batadv_nc_skb_decode_packet()  argument
1668 	if (batadv_is_my_mac(bat_priv, coded_packet_tmp.second_dest)) {  in batadv_nc_skb_decode_packet()
1726 batadv_nc_find_decoding_packet(struct batadv_priv *bat_priv,  in batadv_nc_find_decoding_packet()  argument
1730 	struct batadv_hashtable *hash = bat_priv->nc.decoding_hash;  in batadv_nc_find_decoding_packet()
1742 	if (!batadv_is_my_mac(bat_priv, coded->second_dest)) {  in batadv_nc_find_decoding_packet()
1775 		batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_find_decoding_packet()
1790 	struct batadv_priv *bat_priv = netdev_priv(recv_if->soft_iface);  in batadv_nc_recv_coded_packet()  local
1798 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_recv_coded_packet()
1809 	if (!batadv_is_my_mac(bat_priv, ethhdr->h_dest) &&  in batadv_nc_recv_coded_packet()
1810 	    !batadv_is_my_mac(bat_priv, coded_packet->second_dest))  in batadv_nc_recv_coded_packet()
1814 	if (batadv_is_my_mac(bat_priv, coded_packet->second_dest))  in batadv_nc_recv_coded_packet()
1815 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_SNIFFED);  in batadv_nc_recv_coded_packet()
1817 	nc_packet = batadv_nc_find_decoding_packet(bat_priv, ethhdr,  in batadv_nc_recv_coded_packet()
1820 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED);  in batadv_nc_recv_coded_packet()
1832 	unicast_packet = batadv_nc_skb_decode_packet(bat_priv, skb, nc_packet);  in batadv_nc_recv_coded_packet()
1834 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED);  in batadv_nc_recv_coded_packet()
1840 	batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE);  in batadv_nc_recv_coded_packet()
1841 	batadv_add_counter(bat_priv, BATADV_CNT_NC_DECODE_BYTES,  in batadv_nc_recv_coded_packet()
1854 void batadv_nc_mesh_free(struct batadv_priv *bat_priv)  in batadv_nc_mesh_free()  argument
1856 	batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_mesh_free()
1857 	batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_mesh_free()
1858 	cancel_delayed_work_sync(&bat_priv->nc.work);  in batadv_nc_mesh_free()
1860 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash, NULL);  in batadv_nc_mesh_free()
1861 	batadv_hash_destroy(bat_priv->nc.coding_hash);  in batadv_nc_mesh_free()
1862 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash, NULL);  in batadv_nc_mesh_free()
1863 	batadv_hash_destroy(bat_priv->nc.decoding_hash);  in batadv_nc_mesh_free()
1874 	struct batadv_priv *bat_priv = netdev_priv(net_dev);  in batadv_nc_nodes_seq_print_text()  local
1875 	struct batadv_hashtable *hash = bat_priv->orig_hash;  in batadv_nc_nodes_seq_print_text()
1933 int batadv_nc_init_debugfs(struct batadv_priv *bat_priv)  in batadv_nc_init_debugfs()  argument
1937 	nc_dir = debugfs_create_dir("nc", bat_priv->debug_dir);  in batadv_nc_init_debugfs()
1942 				 &bat_priv->nc.min_tq);  in batadv_nc_init_debugfs()
1947 				  &bat_priv->nc.max_fwd_delay);  in batadv_nc_init_debugfs()
1952 				  &bat_priv->nc.max_buffer_time);  in batadv_nc_init_debugfs()