Lines Matching refs:bat_priv
54 struct batadv_orig_node *batadv_v_ogm_orig_get(struct batadv_priv *bat_priv, in batadv_v_ogm_orig_get() argument
60 orig_node = batadv_orig_hash_find(bat_priv, addr); in batadv_v_ogm_orig_get()
64 orig_node = batadv_orig_node_new(bat_priv, addr); in batadv_v_ogm_orig_get()
69 hash_added = batadv_hash_add(bat_priv->orig_hash, batadv_compare_orig, in batadv_v_ogm_orig_get()
100 static void batadv_v_ogm_start_timer(struct batadv_priv *bat_priv) in batadv_v_ogm_start_timer() argument
106 if (delayed_work_pending(&bat_priv->bat_v.ogm_wq)) in batadv_v_ogm_start_timer()
109 msecs = atomic_read(&bat_priv->orig_interval) - BATADV_JITTER; in batadv_v_ogm_start_timer()
111 queue_delayed_work(batadv_event_workqueue, &bat_priv->bat_v.ogm_wq, in batadv_v_ogm_start_timer()
123 struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); in batadv_v_ogm_send_to_if() local
128 batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_TX); in batadv_v_ogm_send_to_if()
129 batadv_add_counter(bat_priv, BATADV_CNT_MGMT_TX_BYTES, in batadv_v_ogm_send_to_if()
243 struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); in batadv_v_ogm_queue_on_if() local
245 if (!atomic_read(&bat_priv->aggregated_ogms)) { in batadv_v_ogm_queue_on_if()
263 static void batadv_v_ogm_send_softif(struct batadv_priv *bat_priv) in batadv_v_ogm_send_softif() argument
273 lockdep_assert_held(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_send_softif()
275 if (atomic_read(&bat_priv->mesh_state) == BATADV_MESH_DEACTIVATING) in batadv_v_ogm_send_softif()
278 ogm_buff = bat_priv->bat_v.ogm_buff; in batadv_v_ogm_send_softif()
279 ogm_buff_len = bat_priv->bat_v.ogm_buff_len; in batadv_v_ogm_send_softif()
283 batadv_tt_local_commit_changes(bat_priv); in batadv_v_ogm_send_softif()
284 tvlv_len = batadv_tvlv_container_ogm_append(bat_priv, &ogm_buff, in batadv_v_ogm_send_softif()
288 bat_priv->bat_v.ogm_buff = ogm_buff; in batadv_v_ogm_send_softif()
289 bat_priv->bat_v.ogm_buff_len = ogm_buff_len; in batadv_v_ogm_send_softif()
299 ogm_packet->seqno = htonl(atomic_read(&bat_priv->bat_v.ogm_seqno)); in batadv_v_ogm_send_softif()
300 atomic_inc(&bat_priv->bat_v.ogm_seqno); in batadv_v_ogm_send_softif()
306 if (hard_iface->soft_iface != bat_priv->soft_iface) in batadv_v_ogm_send_softif()
330 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 from ourselves on %s suppressed: %s\n", in batadv_v_ogm_send_softif()
337 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_send_softif()
359 batadv_v_ogm_start_timer(bat_priv); in batadv_v_ogm_send_softif()
371 struct batadv_priv *bat_priv; in batadv_v_ogm_send() local
374 bat_priv = container_of(bat_v, struct batadv_priv, bat_v); in batadv_v_ogm_send()
376 mutex_lock(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_send()
377 batadv_v_ogm_send_softif(bat_priv); in batadv_v_ogm_send()
378 mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_send()
412 struct batadv_priv *bat_priv = netdev_priv(hard_iface->soft_iface); in batadv_v_ogm_iface_enable() local
415 batadv_v_ogm_start_timer(bat_priv); in batadv_v_ogm_iface_enable()
439 struct batadv_priv *bat_priv = netdev_priv(primary_iface->soft_iface); in batadv_v_ogm_primary_iface_set() local
442 mutex_lock(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_primary_iface_set()
443 if (!bat_priv->bat_v.ogm_buff) in batadv_v_ogm_primary_iface_set()
446 ogm_packet = (struct batadv_ogm2_packet *)bat_priv->bat_v.ogm_buff; in batadv_v_ogm_primary_iface_set()
450 mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_primary_iface_set()
474 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()
512 static void batadv_v_ogm_forward(struct batadv_priv *bat_priv, in batadv_v_ogm_forward() argument
550 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "ttl exceeded\n"); in batadv_v_ogm_forward()
574 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_forward()
604 static int batadv_v_ogm_metric_update(struct batadv_priv *bat_priv, in batadv_v_ogm_metric_update() argument
625 batadv_window_protected(bat_priv, seq_diff, in batadv_v_ogm_metric_update()
629 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_metric_update()
632 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_metric_update()
655 path_throughput = batadv_v_forward_penalty(bat_priv, if_incoming, in batadv_v_ogm_metric_update()
687 static bool batadv_v_ogm_route_update(struct batadv_priv *bat_priv, in batadv_v_ogm_route_update() argument
705 orig_neigh_node = batadv_v_ogm_orig_get(bat_priv, ethhdr->h_source); in batadv_v_ogm_route_update()
717 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_route_update()
727 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_route_update()
759 batadv_update_route(bat_priv, orig_node, if_outgoing, neigh_node); in batadv_v_ogm_route_update()
786 batadv_v_ogm_process_per_outif(struct batadv_priv *bat_priv, in batadv_v_ogm_process_per_outif() argument
798 seqno_age = batadv_v_ogm_metric_update(bat_priv, ogm2, orig_node, in batadv_v_ogm_process_per_outif()
808 batadv_tvlv_containers_process(bat_priv, true, orig_node, in batadv_v_ogm_process_per_outif()
814 forward = batadv_v_ogm_route_update(bat_priv, ethhdr, ogm2, orig_node, in batadv_v_ogm_process_per_outif()
820 batadv_v_ogm_forward(bat_priv, ogm2, orig_node, neigh_node, in batadv_v_ogm_process_per_outif()
859 struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface); in batadv_v_ogm_process() local
874 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_process()
885 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_process()
893 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, in batadv_v_ogm_process()
898 orig_node = batadv_v_ogm_orig_get(bat_priv, ogm_packet->orig); in batadv_v_ogm_process()
918 batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet, orig_node, in batadv_v_ogm_process()
927 if (hard_iface->soft_iface != bat_priv->soft_iface) in batadv_v_ogm_process()
954 batadv_dbg(BATADV_DBG_BATMAN, bat_priv, "OGM2 packet from %pM on %s suppressed: %s\n", in batadv_v_ogm_process()
962 batadv_v_ogm_process_per_outif(bat_priv, ethhdr, ogm_packet, in batadv_v_ogm_process()
989 struct batadv_priv *bat_priv = netdev_priv(if_incoming->soft_iface); in batadv_v_ogm_packet_recv() local
999 if (strcmp(bat_priv->algo_ops->name, "BATMAN_V") != 0) in batadv_v_ogm_packet_recv()
1005 if (batadv_is_my_mac(bat_priv, ethhdr->h_source)) in batadv_v_ogm_packet_recv()
1010 if (batadv_is_my_mac(bat_priv, ogm_packet->orig)) in batadv_v_ogm_packet_recv()
1013 batadv_inc_counter(bat_priv, BATADV_CNT_MGMT_RX); in batadv_v_ogm_packet_recv()
1014 batadv_add_counter(bat_priv, BATADV_CNT_MGMT_RX_BYTES, in batadv_v_ogm_packet_recv()
1048 int batadv_v_ogm_init(struct batadv_priv *bat_priv) in batadv_v_ogm_init() argument
1054 bat_priv->bat_v.ogm_buff_len = BATADV_OGM2_HLEN; in batadv_v_ogm_init()
1055 ogm_buff = kzalloc(bat_priv->bat_v.ogm_buff_len, GFP_ATOMIC); in batadv_v_ogm_init()
1059 bat_priv->bat_v.ogm_buff = ogm_buff; in batadv_v_ogm_init()
1069 atomic_set(&bat_priv->bat_v.ogm_seqno, random_seqno); in batadv_v_ogm_init()
1070 INIT_DELAYED_WORK(&bat_priv->bat_v.ogm_wq, batadv_v_ogm_send); in batadv_v_ogm_init()
1072 mutex_init(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_init()
1081 void batadv_v_ogm_free(struct batadv_priv *bat_priv) in batadv_v_ogm_free() argument
1083 cancel_delayed_work_sync(&bat_priv->bat_v.ogm_wq); in batadv_v_ogm_free()
1085 mutex_lock(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_free()
1087 kfree(bat_priv->bat_v.ogm_buff); in batadv_v_ogm_free()
1088 bat_priv->bat_v.ogm_buff = NULL; in batadv_v_ogm_free()
1089 bat_priv->bat_v.ogm_buff_len = 0; in batadv_v_ogm_free()
1091 mutex_unlock(&bat_priv->bat_v.ogm_buff_mutex); in batadv_v_ogm_free()