net/mac80211/sta_info.c

134 	int ac, i;
160 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
161 		local->total_ps_buffered -= skb_queue_len(&sta->ps_tx_buf[ac]);
162 		ieee80211_purge_tx_queue(&local->hw, &sta->ps_tx_buf[ac]);
163 		ieee80211_purge_tx_queue(&local->hw, &sta->tx_filtered[ac]);
363 	int ac, tid;
366 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
368 			link_sta->tx_stats.packets[ac];
369 		sta->rem_link_stats.tx_bytes += link_sta->tx_stats.bytes[ac];
1048 static unsigned long ieee80211_tids_for_ac(int ac)
1051 	switch (ac) {
1072 	int ac;
1108 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
1111 		if (ignore_for_tim & ieee80211_ac_to_qos_mask[ac])
1114 		indicate_tim |= !skb_queue_empty(&sta->tx_filtered[ac]) ||
1115 				!skb_queue_empty(&sta->ps_tx_buf[ac]);
1119 		tids = ieee80211_tids_for_ac(ac);
1174 						struct sta_info *sta, int ac)
1187 		spin_lock_irqsave(&sta->tx_filtered[ac].lock, flags);
1188 		skb = skb_peek(&sta->tx_filtered[ac]);
1190 			skb = __skb_dequeue(&sta->tx_filtered[ac]);
1193 		spin_unlock_irqrestore(&sta->tx_filtered[ac].lock, flags);
1213 		spin_lock_irqsave(&sta->ps_tx_buf[ac].lock, flags);
1214 		skb = skb_peek(&sta->ps_tx_buf[ac]);
1216 			skb = __skb_dequeue(&sta->ps_tx_buf[ac]);
1219 		spin_unlock_irqrestore(&sta->ps_tx_buf[ac].lock, flags);
1247 	return !(skb_queue_empty(&sta->ps_tx_buf[ac]) &&
1248 		 skb_queue_empty(&sta->tx_filtered[ac]));
1255 	int ac;
1262 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
1264 			sta_info_cleanup_expire_buffered_ac(local, sta, ac);
1771 	int filtered = 0, buffered = 0, ac, i;
1807 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
1810 		spin_lock_irqsave(&sta->tx_filtered[ac].lock, flags);
1811 		skb_queue_splice_tail_init(&sta->tx_filtered[ac], &pending);
1812 		spin_unlock_irqrestore(&sta->tx_filtered[ac].lock, flags);
1817 		spin_lock_irqsave(&sta->ps_tx_buf[ac].lock, flags);
1818 		skb_queue_splice_tail_init(&sta->ps_tx_buf[ac], &pending);
1819 		spin_unlock_irqrestore(&sta->ps_tx_buf[ac].lock, flags);
1956 	int ac;
1967 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
1968 		if (ignored_acs & ieee80211_ac_to_qos_mask[ac])
1971 		if (!skb_queue_empty(&sta->tx_filtered[ac]) ||
1972 		    !skb_queue_empty(&sta->ps_tx_buf[ac]))
1987 	int ac;
1990 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
1993 		if (ignored_acs & ieee80211_ac_to_qos_mask[ac])
1996 		tids = ieee80211_tids_for_ac(ac);
2011 				skb = skb_dequeue(&sta->tx_filtered[ac]);
2014 						&sta->ps_tx_buf[ac]);
2029 		if (!skb_queue_empty(&sta->tx_filtered[ac]) ||
2030 		    !skb_queue_empty(&sta->ps_tx_buf[ac]))
2061 		int tid, ac;
2079 		for (ac = IEEE80211_AC_VO; ac < IEEE80211_NUM_ACS; ac++)
2080 			if (!(ignored_acs & ieee80211_ac_to_qos_mask[ac]))
2082 		tid = 7 - 2 * ac;
2359 	u8 ac = ieee80211_ac_from_tid(tid);
2367 	spin_lock_bh(&local->active_txq_lock[ac]);
2368 	sta->airtime[ac].tx_airtime += tx_airtime;
2369 	sta->airtime[ac].rx_airtime += rx_airtime;
2371 	if (ieee80211_sta_keep_active(sta, ac))
2372 		sta->airtime[ac].deficit -= airtime;
2374 	spin_unlock_bh(&local->active_txq_lock[ac]);
2432 					  struct sta_info *sta, u8 ac,
2443 				   &sta->airtime[ac].aql_tx_pending);
2446 		atomic_add(tx_airtime, &local->aql_ac_pending_airtime[ac]);
2452 					       &sta->airtime[ac].aql_tx_pending);
2454 			atomic_cmpxchg(&sta->airtime[ac].aql_tx_pending,
2460 				       &local->aql_ac_pending_airtime[ac]);
2463 		      wiphy_name(local->hw.wiphy), ac, tx_pending,
2465 		atomic_cmpxchg(&local->aql_ac_pending_airtime[ac],
2730 	int i, ac, cpu, link_id = link->link_id;
2768 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
2770 				link_sta_info->tx_stats.bytes[ac];
2776 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
2778 				link_sta_info->tx_stats.packets[ac];
2828 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
2829 			link_sinfo->rx_duration += sta->airtime[ac].rx_airtime;
2834 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
2835 			link_sinfo->tx_duration += sta->airtime[ac].tx_airtime;
2965 	int i, ac, cpu, link_id;
3001 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
3002 			sinfo->tx_bytes += sta->deflink.tx_stats.bytes[ac];
3008 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
3009 			sinfo->tx_packets += sta->deflink.tx_stats.packets[ac];
3055 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
3056 			sinfo->rx_duration += sta->airtime[ac].rx_airtime;
3061 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
3062 			sinfo->tx_duration += sta->airtime[ac].tx_airtime;