Lines Matching refs:forw_packet_aggr
694 struct batadv_forw_packet *forw_packet_aggr; in batadv_iv_ogm_aggregate_new() local
712 forw_packet_aggr = batadv_forw_packet_alloc(if_incoming, if_outgoing, in batadv_iv_ogm_aggregate_new()
714 if (!forw_packet_aggr) { in batadv_iv_ogm_aggregate_new()
719 forw_packet_aggr->skb->priority = TC_PRIO_CONTROL; in batadv_iv_ogm_aggregate_new()
720 skb_reserve(forw_packet_aggr->skb, ETH_HLEN); in batadv_iv_ogm_aggregate_new()
722 skb_buff = skb_put(forw_packet_aggr->skb, packet_len); in batadv_iv_ogm_aggregate_new()
723 forw_packet_aggr->packet_len = packet_len; in batadv_iv_ogm_aggregate_new()
726 forw_packet_aggr->own = own_packet; in batadv_iv_ogm_aggregate_new()
727 forw_packet_aggr->direct_link_flags = BATADV_NO_FLAGS; in batadv_iv_ogm_aggregate_new()
728 forw_packet_aggr->send_time = send_time; in batadv_iv_ogm_aggregate_new()
732 forw_packet_aggr->direct_link_flags |= 1; in batadv_iv_ogm_aggregate_new()
734 INIT_DELAYED_WORK(&forw_packet_aggr->delayed_work, in batadv_iv_ogm_aggregate_new()
737 batadv_forw_packet_ogmv1_queue(bat_priv, forw_packet_aggr, send_time); in batadv_iv_ogm_aggregate_new()
741 static void batadv_iv_ogm_aggregate(struct batadv_forw_packet *forw_packet_aggr, in batadv_iv_ogm_aggregate() argument
747 skb_put_data(forw_packet_aggr->skb, packet_buff, packet_len); in batadv_iv_ogm_aggregate()
748 forw_packet_aggr->packet_len += packet_len; in batadv_iv_ogm_aggregate()
749 forw_packet_aggr->num_packets++; in batadv_iv_ogm_aggregate()
753 new_direct_link_flag = BIT(forw_packet_aggr->num_packets); in batadv_iv_ogm_aggregate()
754 forw_packet_aggr->direct_link_flags |= new_direct_link_flag; in batadv_iv_ogm_aggregate()
778 struct batadv_forw_packet *forw_packet_aggr = NULL; in batadv_iv_ogm_queue_add() local
800 forw_packet_aggr = forw_packet_pos; in batadv_iv_ogm_queue_add()
809 if (!forw_packet_aggr) { in batadv_iv_ogm_queue_add()
825 batadv_iv_ogm_aggregate(forw_packet_aggr, packet_buff, in batadv_iv_ogm_queue_add()