55 struct batadv_orig_node *batadv_v_ogm_orig_get(struct batadv_priv *bat_priv,  in batadv_v_ogm_orig_get()  argument
61 	orig_node = batadv_orig_hash_find(bat_priv, addr);  in batadv_v_ogm_orig_get()
65 	orig_node = batadv_orig_node_new(bat_priv, addr);  in batadv_v_ogm_orig_get()
70 	hash_added = batadv_hash_add(bat_priv->orig_hash, batadv_compare_orig,  in batadv_v_ogm_orig_get()
101 static void batadv_v_ogm_start_timer(struct batadv_priv *bat_priv)  in batadv_v_ogm_start_timer()  argument
107 	if (delayed_work_pending(&bat_priv->bat_v.ogm_wq))  in batadv_v_ogm_start_timer()
110 	msecs = atomic_read(&bat_priv->orig_interval) - BATADV_JITTER;  in batadv_v_ogm_start_timer()
112 	queue_delayed_work(batadv_event_workqueue, &bat_priv->bat_v.ogm_wq,  in batadv_v_ogm_start_timer()
124 	struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);  in batadv_v_ogm_send_to_if()  local
129 	batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_TX);  in batadv_v_ogm_send_to_if()
130 	batadv_add_counter(bat_priv, BATADV_CNT_MGMT_TX_BYTES,  in batadv_v_ogm_send_to_if()
240 	struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);  in batadv_v_ogm_queue_on_if()  local
242 	if (!atomic_read(&bat_priv->aggregated_ogms)) {  in batadv_v_ogm_queue_on_if()
260 static void batadv_v_ogm_send_softif(struct batadv_priv *bat_priv)  in batadv_v_ogm_send_softif()  argument
270 	lockdep_assert_held(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_send_softif()
272 	if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_DEACTIVATING)  in batadv_v_ogm_send_softif()
275 	ogm_buff = bat_priv->bat_v.ogm_buff;  in batadv_v_ogm_send_softif()
276 	ogm_buff_len = bat_priv->bat_v.ogm_buff_len;  in batadv_v_ogm_send_softif()
280 	batadv_tt_local_commit_changes(bat_priv);  in batadv_v_ogm_send_softif()
281 	tvlv_len = batadv_tvlv_container_ogm_append(bat_priv, &ogm_buff,  in batadv_v_ogm_send_softif()
285 	bat_priv->bat_v.ogm_buff = ogm_buff;  in batadv_v_ogm_send_softif()
286 	bat_priv->bat_v.ogm_buff_len = ogm_buff_len;  in batadv_v_ogm_send_softif()
296 	ogm_packet->seqno = htonl(atomic_read(&bat_priv->bat_v.ogm_seqno));  in batadv_v_ogm_send_softif()
297 	atomic_inc(&bat_priv->bat_v.ogm_seqno);  in batadv_v_ogm_send_softif()
303 		if (hard_iface->soft_iface != bat_priv->soft_iface)  in batadv_v_ogm_send_softif()
327 			batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 from ourselves on %s suppressed: %s\n",  in batadv_v_ogm_send_softif()
334 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_send_softif()
356 	batadv_v_ogm_start_timer(bat_priv);  in batadv_v_ogm_send_softif()
368 	struct batadv_priv *bat_priv;  in batadv_v_ogm_send()  local
371 	bat_priv = container_of(bat_v, struct batadv_priv, bat_v);  in batadv_v_ogm_send()
373 	mutex_lock(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_send()
374 	batadv_v_ogm_send_softif(bat_priv);  in batadv_v_ogm_send()
375 	mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_send()
409 	struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface);  in batadv_v_ogm_iface_enable()  local
412 	batadv_v_ogm_start_timer(bat_priv);  in batadv_v_ogm_iface_enable()
436 	struct batadv_priv *bat_priv = netdev_priv(primary_iface->soft_iface);  in batadv_v_ogm_primary_iface_set()  local
439 	mutex_lock(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_primary_iface_set()
440 	if (!bat_priv->bat_v.ogm_buff)  in batadv_v_ogm_primary_iface_set()
443 	ogm_packet = (struct batadv_ogm2_packet *)bat_priv->bat_v.ogm_buff;  in batadv_v_ogm_primary_iface_set()
447 	mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_primary_iface_set()
473 static u32 batadv_v_forward_penalty(struct batadv_priv *bat_priv,  in batadv_v_forward_penalty()  argument
479 	int hop_penalty = atomic_read(&bat_priv->hop_penalty);  in batadv_v_forward_penalty()
516 static void batadv_v_ogm_forward(struct batadv_priv *bat_priv,  in batadv_v_ogm_forward()  argument
554 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "ttl exceeded\n");  in batadv_v_ogm_forward()
578 	batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_forward()
608 static int batadv_v_ogm_metric_update(struct batadv_priv *bat_priv,  in batadv_v_ogm_metric_update()  argument
629 	    batadv_window_protected(bat_priv, seq_diff,  in batadv_v_ogm_metric_update()
633 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_metric_update()
636 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_metric_update()
659 	path_throughput = batadv_v_forward_penalty(bat_priv, if_incoming,  in batadv_v_ogm_metric_update()
691 static bool batadv_v_ogm_route_update(struct batadv_priv *bat_priv,  in batadv_v_ogm_route_update()  argument
709 	orig_neigh_node = batadv_v_ogm_orig_get(bat_priv, ethhdr->h_source);  in batadv_v_ogm_route_update()
721 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_route_update()
731 	batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_route_update()
763 	batadv_update_route(bat_priv, orig_node, if_outgoing, neigh_node);  in batadv_v_ogm_route_update()
790 batadv_v_ogm_process_per_outif(struct batadv_priv *bat_priv,  in batadv_v_ogm_process_per_outif()  argument
802 	seqno_age = batadv_v_ogm_metric_update(bat_priv, ogm2, orig_node,  in batadv_v_ogm_process_per_outif()
812 		batadv_tvlv_containers_process(bat_priv, true, orig_node,  in batadv_v_ogm_process_per_outif()
818 	forward = batadv_v_ogm_route_update(bat_priv, ethhdr, ogm2, orig_node,  in batadv_v_ogm_process_per_outif()
824 		batadv_v_ogm_forward(bat_priv, ogm2, orig_node, neigh_node,  in batadv_v_ogm_process_per_outif()
863 	struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface);  in batadv_v_ogm_process()  local
878 	batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_process()
885 	if (batadv_is_my_mac(bat_priv, ogm_packet->orig)) {  in batadv_v_ogm_process()
886 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_process()
895 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_process()
903 		batadv_dbg(BATADV_DBG_BATMAN, bat_priv,  in batadv_v_ogm_process()
908 	orig_node = batadv_v_ogm_orig_get(bat_priv, ogm_packet->orig);  in batadv_v_ogm_process()
928 	batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet, orig_node,  in batadv_v_ogm_process()
937 		if (hard_iface->soft_iface != bat_priv->soft_iface)  in batadv_v_ogm_process()
964 			batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 packet from %pM on %s suppressed: %s\n",  in batadv_v_ogm_process()
972 		batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet,  in batadv_v_ogm_process()
999 	struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface);  in batadv_v_ogm_packet_recv()  local
1009 	if (strcmp(bat_priv->algo_ops->name, "BATMAN_V") != 0)  in batadv_v_ogm_packet_recv()
1015 	if (batadv_is_my_mac(bat_priv, ethhdr->h_source))  in batadv_v_ogm_packet_recv()
1018 	batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_RX);  in batadv_v_ogm_packet_recv()
1019 	batadv_add_counter(bat_priv, BATADV_CNT_MGMT_RX_BYTES,  in batadv_v_ogm_packet_recv()
1053 int batadv_v_ogm_init(struct batadv_priv *bat_priv)  in batadv_v_ogm_init()  argument
1059 	bat_priv->bat_v.ogm_buff_len = BATADV_OGM2_HLEN;  in batadv_v_ogm_init()
1060 	ogm_buff = kzalloc(bat_priv->bat_v.ogm_buff_len, GFP_ATOMIC);  in batadv_v_ogm_init()
1064 	bat_priv->bat_v.ogm_buff = ogm_buff;  in batadv_v_ogm_init()
1074 	atomic_set(&bat_priv->bat_v.ogm_seqno, random_seqno);  in batadv_v_ogm_init()
1075 	INIT_DELAYED_WORK(&bat_priv->bat_v.ogm_wq, batadv_v_ogm_send);  in batadv_v_ogm_init()
1077 	mutex_init(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_init()
1086 void batadv_v_ogm_free(struct batadv_priv *bat_priv)  in batadv_v_ogm_free()  argument
1088 	cancel_delayed_work_sync(&bat_priv->bat_v.ogm_wq);  in batadv_v_ogm_free()
1090 	mutex_lock(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_free()
1092 	kfree(bat_priv->bat_v.ogm_buff);  in batadv_v_ogm_free()
1093 	bat_priv->bat_v.ogm_buff = NULL;  in batadv_v_ogm_free()
1094 	bat_priv->bat_v.ogm_buff_len = 0;  in batadv_v_ogm_free()
1096 	mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex);  in batadv_v_ogm_free()