Lines Matching refs:forw_packet_aggr
545 struct batadv_forw_packet *forw_packet_aggr; in batadv_iv_ogm_aggregate_new() local
563 forw_packet_aggr = batadv_forw_packet_alloc(if_incoming, if_outgoing, in batadv_iv_ogm_aggregate_new()
565 if (!forw_packet_aggr) { in batadv_iv_ogm_aggregate_new()
570 forw_packet_aggr->skb->priority = TC_PRIO_CONTROL; in batadv_iv_ogm_aggregate_new()
571 skb_reserve(forw_packet_aggr->skb, ETH_HLEN); in batadv_iv_ogm_aggregate_new()
573 skb_buff = skb_put(forw_packet_aggr->skb, packet_len); in batadv_iv_ogm_aggregate_new()
574 forw_packet_aggr->packet_len = packet_len; in batadv_iv_ogm_aggregate_new()
577 forw_packet_aggr->own = own_packet; in batadv_iv_ogm_aggregate_new()
578 forw_packet_aggr->direct_link_flags = BATADV_NO_FLAGS; in batadv_iv_ogm_aggregate_new()
579 forw_packet_aggr->send_time = send_time; in batadv_iv_ogm_aggregate_new()
583 forw_packet_aggr->direct_link_flags |= 1; in batadv_iv_ogm_aggregate_new()
585 INIT_DELAYED_WORK(&forw_packet_aggr->delayed_work, in batadv_iv_ogm_aggregate_new()
588 batadv_forw_packet_ogmv1_queue(bat_priv, forw_packet_aggr, send_time); in batadv_iv_ogm_aggregate_new()
592 static void batadv_iv_ogm_aggregate(struct batadv_forw_packet *forw_packet_aggr, in batadv_iv_ogm_aggregate() argument
598 skb_put_data(forw_packet_aggr->skb, packet_buff, packet_len); in batadv_iv_ogm_aggregate()
599 forw_packet_aggr->packet_len += packet_len; in batadv_iv_ogm_aggregate()
600 forw_packet_aggr->num_packets++; in batadv_iv_ogm_aggregate()
604 new_direct_link_flag = BIT(forw_packet_aggr->num_packets); in batadv_iv_ogm_aggregate()
605 forw_packet_aggr->direct_link_flags |= new_direct_link_flag; in batadv_iv_ogm_aggregate()
629 struct batadv_forw_packet *forw_packet_aggr = NULL; in batadv_iv_ogm_queue_add() local
651 forw_packet_aggr = forw_packet_pos; in batadv_iv_ogm_queue_add()
660 if (!forw_packet_aggr) { in batadv_iv_ogm_queue_add()
676 batadv_iv_ogm_aggregate(forw_packet_aggr, packet_buff, in batadv_iv_ogm_queue_add()