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()
158 	batadv_hash_set_lock_class(bat_priv->nc.decoding_hash,  in batadv_nc_mesh_init()
161 	INIT_DELAYED_WORK(&bat_priv->nc.work, batadv_nc_worker);  in batadv_nc_mesh_init()
162 	batadv_nc_start_timer(bat_priv);  in batadv_nc_mesh_init()
164 	batadv_tvlv_handler_register(bat_priv, batadv_nc_tvlv_ogm_handler_v1,  in batadv_nc_mesh_init()
167 	batadv_nc_tvlv_container_update(bat_priv);  in batadv_nc_mesh_init()
178 void batadv_nc_init_bat_priv(struct batadv_priv *bat_priv)  in batadv_nc_init_bat_priv()  argument
180 	atomic_set(&bat_priv->network_coding, 0);  in batadv_nc_init_bat_priv()
181 	bat_priv->nc.min_tq = 200;  in batadv_nc_init_bat_priv()
182 	bat_priv->nc.max_fwd_delay = 10;  in batadv_nc_init_bat_priv()
183 	bat_priv->nc.max_buffer_time = 200;  in batadv_nc_init_bat_priv()
271 static bool batadv_nc_to_purge_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_node()  argument
274 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_node()
287 static bool batadv_nc_to_purge_nc_path_coding(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_path_coding()  argument
290 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_path_coding()
297 				    bat_priv->nc.max_fwd_delay * 10);  in batadv_nc_to_purge_nc_path_coding()
308 static bool batadv_nc_to_purge_nc_path_decoding(struct batadv_priv *bat_priv,  in batadv_nc_to_purge_nc_path_decoding()  argument
311 	if (atomic_read(&bat_priv->mesh_state) != BATADV_MESH_ACTIVE)  in batadv_nc_to_purge_nc_path_decoding()
318 				    bat_priv->nc.max_buffer_time * 10);  in batadv_nc_to_purge_nc_path_decoding()
333 batadv_nc_purge_orig_nc_nodes(struct batadv_priv *bat_priv,  in batadv_nc_purge_orig_nc_nodes()  argument
347 		if (to_purge && !to_purge(bat_priv, nc_node))  in batadv_nc_purge_orig_nc_nodes()
350 		batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_purge_orig_nc_nodes()
369 void batadv_nc_purge_orig(struct batadv_priv *bat_priv,  in batadv_nc_purge_orig()  argument
375 	batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->in_coding_list,  in batadv_nc_purge_orig()
380 	batadv_nc_purge_orig_nc_nodes(bat_priv, &orig_node->out_coding_list,  in batadv_nc_purge_orig()
390 static void batadv_nc_purge_orig_hash(struct batadv_priv *bat_priv)  in batadv_nc_purge_orig_hash()  argument
392 	struct batadv_hashtable *hash = bat_priv->orig_hash;  in batadv_nc_purge_orig_hash()
406 			batadv_nc_purge_orig(bat_priv, orig_node,  in batadv_nc_purge_orig_hash()
422 static void batadv_nc_purge_paths(struct batadv_priv *bat_priv,  in batadv_nc_purge_paths()  argument
443 			if (to_purge && !to_purge(bat_priv, nc_path))  in batadv_nc_purge_paths()
461 			batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_purge_paths()
589 static bool batadv_nc_sniffed_purge(struct batadv_priv *bat_priv,  in batadv_nc_sniffed_purge()  argument
593 	unsigned long timeout = bat_priv->nc.max_buffer_time;  in batadv_nc_sniffed_purge()
601 	if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE &&  in batadv_nc_sniffed_purge()
628 static bool batadv_nc_fwd_flush(struct batadv_priv *bat_priv,  in batadv_nc_fwd_flush()  argument
632 	unsigned long timeout = bat_priv->nc.max_fwd_delay;  in batadv_nc_fwd_flush()
639 	if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_ACTIVE &&  in batadv_nc_fwd_flush()
644 	batadv_inc_counter(bat_priv, BATADV_CNT_FORWARD);  in batadv_nc_fwd_flush()
645 	batadv_add_counter(bat_priv, BATADV_CNT_FORWARD_BYTES,  in batadv_nc_fwd_flush()
663 batadv_nc_process_nc_paths(struct batadv_priv *bat_priv,  in batadv_nc_process_nc_paths()  argument
689 				ret = process_fn(bat_priv, nc_path, nc_packet);  in batadv_nc_process_nc_paths()
708 	struct batadv_priv *bat_priv;  in batadv_nc_worker()  local
713 	bat_priv = container_of(priv_nc, struct batadv_priv, nc);  in batadv_nc_worker()
715 	batadv_nc_purge_orig_hash(bat_priv);  in batadv_nc_worker()
716 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash,  in batadv_nc_worker()
718 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash,  in batadv_nc_worker()
721 	timeout = bat_priv->nc.max_fwd_delay;  in batadv_nc_worker()
723 	if (batadv_has_timed_out(bat_priv->nc.timestamp_fwd_flush, timeout)) {  in batadv_nc_worker()
724 		batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.coding_hash,  in batadv_nc_worker()
726 		bat_priv->nc.timestamp_fwd_flush = jiffies;  in batadv_nc_worker()
729 	if (batadv_has_timed_out(bat_priv->nc.timestamp_sniffed_purge,  in batadv_nc_worker()
730 				 bat_priv->nc.max_buffer_time)) {  in batadv_nc_worker()
731 		batadv_nc_process_nc_paths(bat_priv, bat_priv->nc.decoding_hash,  in batadv_nc_worker()
733 		bat_priv->nc.timestamp_sniffed_purge = jiffies;  in batadv_nc_worker()
737 	batadv_nc_start_timer(bat_priv);  in batadv_nc_worker()
753 static bool batadv_can_nc_with_orig(struct batadv_priv *bat_priv,  in batadv_can_nc_with_orig()  argument
775 	if (ogm_packet->tq < bat_priv->nc.min_tq)  in batadv_can_nc_with_orig()
833 batadv_nc_get_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_get_nc_node()  argument
871 	batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_node %pM -> %pM\n",  in batadv_nc_get_nc_node()
894 void batadv_nc_update_nc_node(struct batadv_priv *bat_priv,  in batadv_nc_update_nc_node()  argument
904 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_update_nc_node()
912 	if (!batadv_can_nc_with_orig(bat_priv, orig_node, ogm_packet) &&  in batadv_nc_update_nc_node()
917 	in_nc_node = batadv_nc_get_nc_node(bat_priv, orig_node,  in batadv_nc_update_nc_node()
925 	out_nc_node = batadv_nc_get_nc_node(bat_priv, orig_neigh_node,  in batadv_nc_update_nc_node()
949 static struct batadv_nc_path *batadv_nc_get_path(struct batadv_priv *bat_priv,  in batadv_nc_get_path()  argument
982 	batadv_dbg(BATADV_DBG_NC, bat_priv, "Adding nc_path %pM -> %pM\n",  in batadv_nc_get_path()
1041 static bool batadv_nc_code_packets(struct batadv_priv *bat_priv,  in batadv_nc_code_packets()  argument
1172 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE, 2);  in batadv_nc_code_packets()
1173 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES, count);  in batadv_nc_code_packets()
1179 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE, 2);  in batadv_nc_code_packets()
1180 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_BYTES, count);  in batadv_nc_code_packets()
1184 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE);  in batadv_nc_code_packets()
1185 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES,  in batadv_nc_code_packets()
1187 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_CODE);  in batadv_nc_code_packets()
1188 		batadv_add_counter(bat_priv, BATADV_CNT_NC_CODE_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()
1196 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_RECODE);  in batadv_nc_code_packets()
1197 		batadv_add_counter(bat_priv, BATADV_CNT_NC_RECODE_BYTES,  in batadv_nc_code_packets()
1259 batadv_nc_path_search(struct batadv_priv *bat_priv,  in batadv_nc_path_search()  argument
1268 	struct batadv_hashtable *hash = bat_priv->nc.coding_hash;  in batadv_nc_path_search()
1327 batadv_nc_skb_src_search(struct batadv_priv *bat_priv,  in batadv_nc_skb_src_search()  argument
1337 	orig_node = batadv_orig_hash_find(bat_priv, eth_src);  in batadv_nc_skb_src_search()
1350 		nc_packet = batadv_nc_path_search(bat_priv, in_nc_node,  in batadv_nc_skb_src_search()
1368 static void batadv_nc_skb_store_before_coding(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_before_coding()  argument
1388 	batadv_nc_skb_store_for_decoding(bat_priv, skb);  in batadv_nc_skb_store_before_coding()
1414 	struct batadv_priv *bat_priv = netdev_priv(netdev);  in batadv_nc_skb_dst_search()  local
1422 		nc_packet = batadv_nc_skb_src_search(bat_priv, skb,  in batadv_nc_skb_dst_search()
1436 	batadv_nc_skb_store_before_coding(bat_priv, skb,  in batadv_nc_skb_dst_search()
1438 	batadv_nc_skb_store_before_coding(bat_priv, nc_packet->skb,  in batadv_nc_skb_dst_search()
1442 	if (batadv_nc_code_packets(bat_priv, skb, ethhdr, nc_packet,  in batadv_nc_skb_dst_search()
1501 	struct batadv_priv *bat_priv = netdev_priv(netdev);  in batadv_nc_skb_forward()  local
1509 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_skb_forward()
1523 	nc_path = batadv_nc_get_path(bat_priv,  in batadv_nc_skb_forward()
1524 				     bat_priv->nc.coding_hash,  in batadv_nc_skb_forward()
1552 void batadv_nc_skb_store_for_decoding(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_for_decoding()  argument
1562 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_skb_store_for_decoding()
1572 	nc_path = batadv_nc_get_path(bat_priv,  in batadv_nc_skb_store_for_decoding()
1573 				     bat_priv->nc.decoding_hash,  in batadv_nc_skb_store_for_decoding()
1596 	batadv_inc_counter(bat_priv, BATADV_CNT_NC_BUFFER);  in batadv_nc_skb_store_for_decoding()
1613 void batadv_nc_skb_store_sniffed_unicast(struct batadv_priv *bat_priv,  in batadv_nc_skb_store_sniffed_unicast()  argument
1618 	if (batadv_is_my_mac(bat_priv, ethhdr->h_dest))  in batadv_nc_skb_store_sniffed_unicast()
1624 	batadv_nc_skb_store_for_decoding(bat_priv, skb);  in batadv_nc_skb_store_sniffed_unicast()
1638 batadv_nc_skb_decode_packet(struct batadv_priv *bat_priv, struct sk_buff *skb,  in batadv_nc_skb_decode_packet()  argument
1673 	if (batadv_is_my_mac(bat_priv, coded_packet_tmp.second_dest)) {  in batadv_nc_skb_decode_packet()
1731 batadv_nc_find_decoding_packet(struct batadv_priv *bat_priv,  in batadv_nc_find_decoding_packet()  argument
1735 	struct batadv_hashtable *hash = bat_priv->nc.decoding_hash;  in batadv_nc_find_decoding_packet()
1747 	if (!batadv_is_my_mac(bat_priv, coded->second_dest)) {  in batadv_nc_find_decoding_packet()
1780 		batadv_dbg(BATADV_DBG_NC, bat_priv,  in batadv_nc_find_decoding_packet()
1798 	struct batadv_priv *bat_priv = netdev_priv(recv_if->soft_iface);  in batadv_nc_recv_coded_packet()  local
1806 	if (!atomic_read(&bat_priv->network_coding))  in batadv_nc_recv_coded_packet()
1817 	if (!batadv_is_my_mac(bat_priv, ethhdr->h_dest) &&  in batadv_nc_recv_coded_packet()
1818 	    !batadv_is_my_mac(bat_priv, coded_packet->second_dest))  in batadv_nc_recv_coded_packet()
1822 	if (batadv_is_my_mac(bat_priv, coded_packet->second_dest))  in batadv_nc_recv_coded_packet()
1823 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_SNIFFED);  in batadv_nc_recv_coded_packet()
1825 	nc_packet = batadv_nc_find_decoding_packet(bat_priv, ethhdr,  in batadv_nc_recv_coded_packet()
1828 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED);  in batadv_nc_recv_coded_packet()
1840 	unicast_packet = batadv_nc_skb_decode_packet(bat_priv, skb, nc_packet);  in batadv_nc_recv_coded_packet()
1842 		batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE_FAILED);  in batadv_nc_recv_coded_packet()
1848 	batadv_inc_counter(bat_priv, BATADV_CNT_NC_DECODE);  in batadv_nc_recv_coded_packet()
1849 	batadv_add_counter(bat_priv, BATADV_CNT_NC_DECODE_BYTES,  in batadv_nc_recv_coded_packet()
1865 void batadv_nc_mesh_free(struct batadv_priv *bat_priv)  in batadv_nc_mesh_free()  argument
1867 	batadv_tvlv_container_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_mesh_free()
1868 	batadv_tvlv_handler_unregister(bat_priv, BATADV_TVLV_NC, 1);  in batadv_nc_mesh_free()
1869 	cancel_delayed_work_sync(&bat_priv->nc.work);  in batadv_nc_mesh_free()
1871 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.coding_hash, NULL);  in batadv_nc_mesh_free()
1872 	batadv_hash_destroy(bat_priv->nc.coding_hash);  in batadv_nc_mesh_free()
1873 	batadv_nc_purge_paths(bat_priv, bat_priv->nc.decoding_hash, NULL);  in batadv_nc_mesh_free()
1874 	batadv_hash_destroy(bat_priv->nc.decoding_hash);  in batadv_nc_mesh_free()