xref: /openbmc/linux/net/mac80211/sta_info.c (revision ef044763a3ca6b9e0bb65a9ce0cb38c0eca62756)
1f0706e82SJiri Benc /*
2f0706e82SJiri Benc  * Copyright 2002-2005, Instant802 Networks, Inc.
3f0706e82SJiri Benc  * Copyright 2006-2007	Jiri Benc <jbenc@suse.cz>
4d98ad83eSJohannes Berg  * Copyright 2013-2014  Intel Mobile Communications GmbH
50ead2510SEmmanuel Grumbach  * Copyright (C) 2015 Intel Deutschland GmbH
6f0706e82SJiri Benc  *
7f0706e82SJiri Benc  * This program is free software; you can redistribute it and/or modify
8f0706e82SJiri Benc  * it under the terms of the GNU General Public License version 2 as
9f0706e82SJiri Benc  * published by the Free Software Foundation.
10f0706e82SJiri Benc  */
11f0706e82SJiri Benc 
12f0706e82SJiri Benc #include <linux/module.h>
13f0706e82SJiri Benc #include <linux/init.h>
14888d04dfSFelix Fietkau #include <linux/etherdevice.h>
15f0706e82SJiri Benc #include <linux/netdevice.h>
16f0706e82SJiri Benc #include <linux/types.h>
17f0706e82SJiri Benc #include <linux/slab.h>
18f0706e82SJiri Benc #include <linux/skbuff.h>
19f0706e82SJiri Benc #include <linux/if_arp.h>
200d174406SJohannes Berg #include <linux/timer.h>
21d0709a65SJohannes Berg #include <linux/rtnetlink.h>
22f0706e82SJiri Benc 
23f0706e82SJiri Benc #include <net/mac80211.h>
24f0706e82SJiri Benc #include "ieee80211_i.h"
2524487981SJohannes Berg #include "driver-ops.h"
262c8dccc7SJohannes Berg #include "rate.h"
27f0706e82SJiri Benc #include "sta_info.h"
28e9f207f0SJiri Benc #include "debugfs_sta.h"
29ee385855SLuis Carlos Cobo #include "mesh.h"
30ce662b44SJohannes Berg #include "wme.h"
31f0706e82SJiri Benc 
32d0709a65SJohannes Berg /**
33d0709a65SJohannes Berg  * DOC: STA information lifetime rules
34d0709a65SJohannes Berg  *
35d0709a65SJohannes Berg  * STA info structures (&struct sta_info) are managed in a hash table
36d0709a65SJohannes Berg  * for faster lookup and a list for iteration. They are managed using
37d0709a65SJohannes Berg  * RCU, i.e. access to the list and hash table is protected by RCU.
38d0709a65SJohannes Berg  *
3934e89507SJohannes Berg  * Upon allocating a STA info structure with sta_info_alloc(), the caller
4034e89507SJohannes Berg  * owns that structure. It must then insert it into the hash table using
4134e89507SJohannes Berg  * either sta_info_insert() or sta_info_insert_rcu(); only in the latter
4234e89507SJohannes Berg  * case (which acquires an rcu read section but must not be called from
4334e89507SJohannes Berg  * within one) will the pointer still be valid after the call. Note that
4434e89507SJohannes Berg  * the caller may not do much with the STA info before inserting it, in
4534e89507SJohannes Berg  * particular, it may not start any mesh peer link management or add
4634e89507SJohannes Berg  * encryption keys.
4793e5deb1SJohannes Berg  *
4893e5deb1SJohannes Berg  * When the insertion fails (sta_info_insert()) returns non-zero), the
4993e5deb1SJohannes Berg  * structure will have been freed by sta_info_insert()!
50d0709a65SJohannes Berg  *
5134e89507SJohannes Berg  * Station entries are added by mac80211 when you establish a link with a
527e189a12SLuis R. Rodriguez  * peer. This means different things for the different type of interfaces
537e189a12SLuis R. Rodriguez  * we support. For a regular station this mean we add the AP sta when we
5425985edcSLucas De Marchi  * receive an association response from the AP. For IBSS this occurs when
5534e89507SJohannes Berg  * get to know about a peer on the same IBSS. For WDS we add the sta for
5625985edcSLucas De Marchi  * the peer immediately upon device open. When using AP mode we add stations
5734e89507SJohannes Berg  * for each respective station upon request from userspace through nl80211.
587e189a12SLuis R. Rodriguez  *
5934e89507SJohannes Berg  * In order to remove a STA info structure, various sta_info_destroy_*()
6034e89507SJohannes Berg  * calls are available.
61d0709a65SJohannes Berg  *
6234e89507SJohannes Berg  * There is no concept of ownership on a STA entry, each structure is
6334e89507SJohannes Berg  * owned by the global hash table/list until it is removed. All users of
6434e89507SJohannes Berg  * the structure need to be RCU protected so that the structure won't be
6534e89507SJohannes Berg  * freed before they are done using it.
66d0709a65SJohannes Berg  */
67f0706e82SJiri Benc 
687bedd0cfSJohannes Berg static const struct rhashtable_params sta_rht_params = {
697bedd0cfSJohannes Berg 	.nelem_hint = 3, /* start small */
70caf22d31SJohannes Berg 	.automatic_shrinking = true,
717bedd0cfSJohannes Berg 	.head_offset = offsetof(struct sta_info, hash_node),
72ac100ce5SJohannes Berg 	.key_offset = offsetof(struct sta_info, addr),
737bedd0cfSJohannes Berg 	.key_len = ETH_ALEN,
747bedd0cfSJohannes Berg 	.hashfn = sta_addr_hash,
75ebd82b39SJohannes Berg 	.max_size = CONFIG_MAC80211_STA_HASH_MAX_SIZE,
767bedd0cfSJohannes Berg };
777bedd0cfSJohannes Berg 
784d33960bSJohannes Berg /* Caller must hold local->sta_mtx */
79be8755e1SMichael Wu static int sta_info_hash_del(struct ieee80211_local *local,
80f0706e82SJiri Benc 			     struct sta_info *sta)
81f0706e82SJiri Benc {
827bedd0cfSJohannes Berg 	return rhashtable_remove_fast(&local->sta_hash, &sta->hash_node,
837bedd0cfSJohannes Berg 				      sta_rht_params);
84f0706e82SJiri Benc }
85f0706e82SJiri Benc 
865108ca82SJohannes Berg static void __cleanup_single_sta(struct sta_info *sta)
87b22cfcfcSEliad Peller {
88b22cfcfcSEliad Peller 	int ac, i;
89b22cfcfcSEliad Peller 	struct tid_ampdu_tx *tid_tx;
90b22cfcfcSEliad Peller 	struct ieee80211_sub_if_data *sdata = sta->sdata;
91b22cfcfcSEliad Peller 	struct ieee80211_local *local = sdata->local;
92d012a605SMarco Porsch 	struct ps_data *ps;
93b22cfcfcSEliad Peller 
94e3685e03SJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_PS_STA) ||
955ac2e350SJohannes Berg 	    test_sta_flag(sta, WLAN_STA_PS_DRIVER) ||
965ac2e350SJohannes Berg 	    test_sta_flag(sta, WLAN_STA_PS_DELIVER)) {
97d012a605SMarco Porsch 		if (sta->sdata->vif.type == NL80211_IFTYPE_AP ||
98d012a605SMarco Porsch 		    sta->sdata->vif.type == NL80211_IFTYPE_AP_VLAN)
99d012a605SMarco Porsch 			ps = &sdata->bss->ps;
1003f52b7e3SMarco Porsch 		else if (ieee80211_vif_is_mesh(&sdata->vif))
1013f52b7e3SMarco Porsch 			ps = &sdata->u.mesh.ps;
102d012a605SMarco Porsch 		else
103d012a605SMarco Porsch 			return;
104b22cfcfcSEliad Peller 
105b22cfcfcSEliad Peller 		clear_sta_flag(sta, WLAN_STA_PS_STA);
106e3685e03SJohannes Berg 		clear_sta_flag(sta, WLAN_STA_PS_DRIVER);
1075ac2e350SJohannes Berg 		clear_sta_flag(sta, WLAN_STA_PS_DELIVER);
108b22cfcfcSEliad Peller 
109d012a605SMarco Porsch 		atomic_dec(&ps->num_sta_ps);
110b22cfcfcSEliad Peller 	}
111b22cfcfcSEliad Peller 
112ba8c3d6fSFelix Fietkau 	if (sta->sta.txq[0]) {
113ba8c3d6fSFelix Fietkau 		for (i = 0; i < ARRAY_SIZE(sta->sta.txq); i++) {
114ba8c3d6fSFelix Fietkau 			struct txq_info *txqi = to_txq_info(sta->sta.txq[i]);
115ba8c3d6fSFelix Fietkau 			int n = skb_queue_len(&txqi->queue);
116ba8c3d6fSFelix Fietkau 
117ba8c3d6fSFelix Fietkau 			ieee80211_purge_tx_queue(&local->hw, &txqi->queue);
118ba8c3d6fSFelix Fietkau 			atomic_sub(n, &sdata->txqs_len[txqi->txq.ac]);
119ba8c3d6fSFelix Fietkau 		}
120ba8c3d6fSFelix Fietkau 	}
121ba8c3d6fSFelix Fietkau 
122b22cfcfcSEliad Peller 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
123b22cfcfcSEliad Peller 		local->total_ps_buffered -= skb_queue_len(&sta->ps_tx_buf[ac]);
1241f98ab7fSFelix Fietkau 		ieee80211_purge_tx_queue(&local->hw, &sta->ps_tx_buf[ac]);
1251f98ab7fSFelix Fietkau 		ieee80211_purge_tx_queue(&local->hw, &sta->tx_filtered[ac]);
126b22cfcfcSEliad Peller 	}
127b22cfcfcSEliad Peller 
12845b5028eSThomas Pedersen 	if (ieee80211_vif_is_mesh(&sdata->vif))
12945b5028eSThomas Pedersen 		mesh_sta_cleanup(sta);
130b22cfcfcSEliad Peller 
1315ac2e350SJohannes Berg 	cancel_work_sync(&sta->drv_deliver_wk);
132b22cfcfcSEliad Peller 
133b22cfcfcSEliad Peller 	/*
134b22cfcfcSEliad Peller 	 * Destroy aggregation state here. It would be nice to wait for the
135b22cfcfcSEliad Peller 	 * driver to finish aggregation stop and then clean up, but for now
136b22cfcfcSEliad Peller 	 * drivers have to handle aggregation stop being requested, followed
137b22cfcfcSEliad Peller 	 * directly by station destruction.
138b22cfcfcSEliad Peller 	 */
1395a306f58SJohannes Berg 	for (i = 0; i < IEEE80211_NUM_TIDS; i++) {
140661eb381SJohannes Berg 		kfree(sta->ampdu_mlme.tid_start_tx[i]);
141b22cfcfcSEliad Peller 		tid_tx = rcu_dereference_raw(sta->ampdu_mlme.tid_tx[i]);
142b22cfcfcSEliad Peller 		if (!tid_tx)
143b22cfcfcSEliad Peller 			continue;
1441f98ab7fSFelix Fietkau 		ieee80211_purge_tx_queue(&local->hw, &tid_tx->pending);
145b22cfcfcSEliad Peller 		kfree(tid_tx);
146b22cfcfcSEliad Peller 	}
1475108ca82SJohannes Berg }
148b22cfcfcSEliad Peller 
1495108ca82SJohannes Berg static void cleanup_single_sta(struct sta_info *sta)
1505108ca82SJohannes Berg {
1515108ca82SJohannes Berg 	struct ieee80211_sub_if_data *sdata = sta->sdata;
1525108ca82SJohannes Berg 	struct ieee80211_local *local = sdata->local;
1535108ca82SJohannes Berg 
1545108ca82SJohannes Berg 	__cleanup_single_sta(sta);
155b22cfcfcSEliad Peller 	sta_info_free(local, sta);
156b22cfcfcSEliad Peller }
157b22cfcfcSEliad Peller 
158d0709a65SJohannes Berg /* protected by RCU */
159abe60632SJohannes Berg struct sta_info *sta_info_get(struct ieee80211_sub_if_data *sdata,
160abe60632SJohannes Berg 			      const u8 *addr)
16143ba7e95SJohannes Berg {
162abe60632SJohannes Berg 	struct ieee80211_local *local = sdata->local;
16360f4b626SJohannes Berg 	struct sta_info *sta;
16460f4b626SJohannes Berg 	struct rhash_head *tmp;
16560f4b626SJohannes Berg 	const struct bucket_table *tbl;
16643ba7e95SJohannes Berg 
16760f4b626SJohannes Berg 	rcu_read_lock();
16860f4b626SJohannes Berg 	tbl = rht_dereference_rcu(local->sta_hash.tbl, &local->sta_hash);
16960f4b626SJohannes Berg 
17060f4b626SJohannes Berg 	for_each_sta_info(local, tbl, addr, sta, tmp) {
17160f4b626SJohannes Berg 		if (sta->sdata == sdata) {
17260f4b626SJohannes Berg 			rcu_read_unlock();
17360f4b626SJohannes Berg 			/* this is safe as the caller must already hold
17460f4b626SJohannes Berg 			 * another rcu read section or the mutex
17560f4b626SJohannes Berg 			 */
17660f4b626SJohannes Berg 			return sta;
17760f4b626SJohannes Berg 		}
17860f4b626SJohannes Berg 	}
17960f4b626SJohannes Berg 	rcu_read_unlock();
18060f4b626SJohannes Berg 	return NULL;
18143ba7e95SJohannes Berg }
18243ba7e95SJohannes Berg 
1830e5ded5aSFelix Fietkau /*
1840e5ded5aSFelix Fietkau  * Get sta info either from the specified interface
1850e5ded5aSFelix Fietkau  * or from one of its vlans
1860e5ded5aSFelix Fietkau  */
1870e5ded5aSFelix Fietkau struct sta_info *sta_info_get_bss(struct ieee80211_sub_if_data *sdata,
1880e5ded5aSFelix Fietkau 				  const u8 *addr)
1890e5ded5aSFelix Fietkau {
1900e5ded5aSFelix Fietkau 	struct ieee80211_local *local = sdata->local;
1910e5ded5aSFelix Fietkau 	struct sta_info *sta;
1927bedd0cfSJohannes Berg 	struct rhash_head *tmp;
1937bedd0cfSJohannes Berg 	const struct bucket_table *tbl;
1940e5ded5aSFelix Fietkau 
1957bedd0cfSJohannes Berg 	rcu_read_lock();
1967bedd0cfSJohannes Berg 	tbl = rht_dereference_rcu(local->sta_hash.tbl, &local->sta_hash);
1977bedd0cfSJohannes Berg 
1987bedd0cfSJohannes Berg 	for_each_sta_info(local, tbl, addr, sta, tmp) {
1997bedd0cfSJohannes Berg 		if (sta->sdata == sdata ||
2007bedd0cfSJohannes Berg 		    (sta->sdata->bss && sta->sdata->bss == sdata->bss)) {
2017bedd0cfSJohannes Berg 			rcu_read_unlock();
2027bedd0cfSJohannes Berg 			/* this is safe as the caller must already hold
2037bedd0cfSJohannes Berg 			 * another rcu read section or the mutex
2047bedd0cfSJohannes Berg 			 */
2050e5ded5aSFelix Fietkau 			return sta;
2060e5ded5aSFelix Fietkau 		}
2077bedd0cfSJohannes Berg 	}
2087bedd0cfSJohannes Berg 	rcu_read_unlock();
2097bedd0cfSJohannes Berg 	return NULL;
2107bedd0cfSJohannes Berg }
2110e5ded5aSFelix Fietkau 
2123b53fde8SJohannes Berg struct sta_info *sta_info_get_by_idx(struct ieee80211_sub_if_data *sdata,
2133b53fde8SJohannes Berg 				     int idx)
214ee385855SLuis Carlos Cobo {
2153b53fde8SJohannes Berg 	struct ieee80211_local *local = sdata->local;
216ee385855SLuis Carlos Cobo 	struct sta_info *sta;
217ee385855SLuis Carlos Cobo 	int i = 0;
218ee385855SLuis Carlos Cobo 
219d0709a65SJohannes Berg 	list_for_each_entry_rcu(sta, &local->sta_list, list) {
2203b53fde8SJohannes Berg 		if (sdata != sta->sdata)
2212a8ca29aSLuis Carlos Cobo 			continue;
222ee385855SLuis Carlos Cobo 		if (i < idx) {
223ee385855SLuis Carlos Cobo 			++i;
224ee385855SLuis Carlos Cobo 			continue;
225ee385855SLuis Carlos Cobo 		}
2262a8ca29aSLuis Carlos Cobo 		return sta;
227ee385855SLuis Carlos Cobo 	}
228ee385855SLuis Carlos Cobo 
229ee385855SLuis Carlos Cobo 	return NULL;
230ee385855SLuis Carlos Cobo }
231f0706e82SJiri Benc 
23293e5deb1SJohannes Berg /**
233d9a7ddb0SJohannes Berg  * sta_info_free - free STA
23493e5deb1SJohannes Berg  *
2356ef307bcSRandy Dunlap  * @local: pointer to the global information
23693e5deb1SJohannes Berg  * @sta: STA info to free
23793e5deb1SJohannes Berg  *
23893e5deb1SJohannes Berg  * This function must undo everything done by sta_info_alloc()
239d9a7ddb0SJohannes Berg  * that may happen before sta_info_insert(). It may only be
240d9a7ddb0SJohannes Berg  * called when sta_info_insert() has not been attempted (and
241d9a7ddb0SJohannes Berg  * if that fails, the station is freed anyway.)
24293e5deb1SJohannes Berg  */
243d9a7ddb0SJohannes Berg void sta_info_free(struct ieee80211_local *local, struct sta_info *sta)
24493e5deb1SJohannes Berg {
245889cbb91SJohannes Berg 	if (sta->rate_ctrl)
2464b7679a5SJohannes Berg 		rate_control_free_sta(sta);
24793e5deb1SJohannes Berg 
248bdcbd8e0SJohannes Berg 	sta_dbg(sta->sdata, "Destroyed STA %pM\n", sta->sta.addr);
24993e5deb1SJohannes Berg 
250ba8c3d6fSFelix Fietkau 	if (sta->sta.txq[0])
251ba8c3d6fSFelix Fietkau 		kfree(to_txq_info(sta->sta.txq[0]));
25253d04525SFelix Fietkau 	kfree(rcu_dereference_raw(sta->sta.rates));
253433f5bc1SJohannes Berg #ifdef CONFIG_MAC80211_MESH
254433f5bc1SJohannes Berg 	kfree(sta->mesh);
255433f5bc1SJohannes Berg #endif
25693e5deb1SJohannes Berg 	kfree(sta);
25793e5deb1SJohannes Berg }
25893e5deb1SJohannes Berg 
2594d33960bSJohannes Berg /* Caller must hold local->sta_mtx */
260d0709a65SJohannes Berg static void sta_info_hash_add(struct ieee80211_local *local,
261d0709a65SJohannes Berg 			      struct sta_info *sta)
262f0706e82SJiri Benc {
2637bedd0cfSJohannes Berg 	rhashtable_insert_fast(&local->sta_hash, &sta->hash_node,
2647bedd0cfSJohannes Berg 			       sta_rht_params);
265f0706e82SJiri Benc }
266f0706e82SJiri Benc 
2675ac2e350SJohannes Berg static void sta_deliver_ps_frames(struct work_struct *wk)
268af818581SJohannes Berg {
269af818581SJohannes Berg 	struct sta_info *sta;
270af818581SJohannes Berg 
2715ac2e350SJohannes Berg 	sta = container_of(wk, struct sta_info, drv_deliver_wk);
272af818581SJohannes Berg 
273af818581SJohannes Berg 	if (sta->dead)
274af818581SJohannes Berg 		return;
275af818581SJohannes Berg 
27654420473SHelmut Schaa 	local_bh_disable();
2775ac2e350SJohannes Berg 	if (!test_sta_flag(sta, WLAN_STA_PS_STA))
278af818581SJohannes Berg 		ieee80211_sta_ps_deliver_wakeup(sta);
2795ac2e350SJohannes Berg 	else if (test_and_clear_sta_flag(sta, WLAN_STA_PSPOLL))
280af818581SJohannes Berg 		ieee80211_sta_ps_deliver_poll_response(sta);
2815ac2e350SJohannes Berg 	else if (test_and_clear_sta_flag(sta, WLAN_STA_UAPSD))
28247086fc5SJohannes Berg 		ieee80211_sta_ps_deliver_uapsd(sta);
283ce662b44SJohannes Berg 	local_bh_enable();
284af818581SJohannes Berg }
285af818581SJohannes Berg 
286af65cd96SJohannes Berg static int sta_prepare_rate_control(struct ieee80211_local *local,
287af65cd96SJohannes Berg 				    struct sta_info *sta, gfp_t gfp)
288af65cd96SJohannes Berg {
28930686bf7SJohannes Berg 	if (ieee80211_hw_check(&local->hw, HAS_RATE_CONTROL))
290af65cd96SJohannes Berg 		return 0;
291af65cd96SJohannes Berg 
292889cbb91SJohannes Berg 	sta->rate_ctrl = local->rate_ctrl;
293af65cd96SJohannes Berg 	sta->rate_ctrl_priv = rate_control_alloc_sta(sta->rate_ctrl,
29435c347acSJohannes Berg 						     sta, gfp);
295889cbb91SJohannes Berg 	if (!sta->rate_ctrl_priv)
296af65cd96SJohannes Berg 		return -ENOMEM;
297af65cd96SJohannes Berg 
298af65cd96SJohannes Berg 	return 0;
299af65cd96SJohannes Berg }
300af65cd96SJohannes Berg 
30173651ee6SJohannes Berg struct sta_info *sta_info_alloc(struct ieee80211_sub_if_data *sdata,
30256544160SJohannes Berg 				const u8 *addr, gfp_t gfp)
303f0706e82SJiri Benc {
304d0709a65SJohannes Berg 	struct ieee80211_local *local = sdata->local;
305ba8c3d6fSFelix Fietkau 	struct ieee80211_hw *hw = &local->hw;
306f0706e82SJiri Benc 	struct sta_info *sta;
30716c5f15cSRon Rindjunsky 	int i;
308f0706e82SJiri Benc 
309ba8c3d6fSFelix Fietkau 	sta = kzalloc(sizeof(*sta) + hw->sta_data_size, gfp);
310f0706e82SJiri Benc 	if (!sta)
31173651ee6SJohannes Berg 		return NULL;
312f0706e82SJiri Benc 
31307346f81SJohannes Berg 	spin_lock_init(&sta->lock);
3141d147bfaSEmmanuel Grumbach 	spin_lock_init(&sta->ps_lock);
3155ac2e350SJohannes Berg 	INIT_WORK(&sta->drv_deliver_wk, sta_deliver_ps_frames);
31667c282c0SJohannes Berg 	INIT_WORK(&sta->ampdu_mlme.work, ieee80211_ba_session_work);
317a93e3644SJohannes Berg 	mutex_init(&sta->ampdu_mlme.mtx);
31887f59c70SThomas Pedersen #ifdef CONFIG_MAC80211_MESH
319433f5bc1SJohannes Berg 	if (ieee80211_vif_is_mesh(&sdata->vif)) {
320433f5bc1SJohannes Berg 		sta->mesh = kzalloc(sizeof(*sta->mesh), gfp);
321433f5bc1SJohannes Berg 		if (!sta->mesh)
322433f5bc1SJohannes Berg 			goto free;
323433f5bc1SJohannes Berg 		spin_lock_init(&sta->mesh->plink_lock);
32487f59c70SThomas Pedersen 		if (ieee80211_vif_is_mesh(&sdata->vif) &&
32587f59c70SThomas Pedersen 		    !sdata->u.mesh.user_mpm)
326433f5bc1SJohannes Berg 			init_timer(&sta->mesh->plink_timer);
327433f5bc1SJohannes Berg 		sta->mesh->nonpeer_pm = NL80211_MESH_POWER_ACTIVE;
328433f5bc1SJohannes Berg 	}
32987f59c70SThomas Pedersen #endif
33007346f81SJohannes Berg 
331ac100ce5SJohannes Berg 	memcpy(sta->addr, addr, ETH_ALEN);
33217741cdcSJohannes Berg 	memcpy(sta->sta.addr, addr, ETH_ALEN);
333d0709a65SJohannes Berg 	sta->local = local;
334d0709a65SJohannes Berg 	sta->sdata = sdata;
335e5a9f8d0SJohannes Berg 	sta->rx_stats.last_rx = jiffies;
336f0706e82SJiri Benc 
33771ec375cSJohannes Berg 	sta->sta_state = IEEE80211_STA_NONE;
33871ec375cSJohannes Berg 
339b6da911bSLiad Kaufman 	/* Mark TID as unreserved */
340b6da911bSLiad Kaufman 	sta->reserved_tid = IEEE80211_TID_UNRESERVED;
341b6da911bSLiad Kaufman 
34284b00607SArnd Bergmann 	sta->last_connected = ktime_get_seconds();
343e5a9f8d0SJohannes Berg 	ewma_signal_init(&sta->rx_stats.avg_signal);
344e5a9f8d0SJohannes Berg 	for (i = 0; i < ARRAY_SIZE(sta->rx_stats.chain_signal_avg); i++)
345e5a9f8d0SJohannes Berg 		ewma_signal_init(&sta->rx_stats.chain_signal_avg[i]);
346541a45a1SBruno Randolf 
347ba8c3d6fSFelix Fietkau 	if (local->ops->wake_tx_queue) {
348ba8c3d6fSFelix Fietkau 		void *txq_data;
349ba8c3d6fSFelix Fietkau 		int size = sizeof(struct txq_info) +
350ba8c3d6fSFelix Fietkau 			   ALIGN(hw->txq_data_size, sizeof(void *));
351ba8c3d6fSFelix Fietkau 
352ba8c3d6fSFelix Fietkau 		txq_data = kcalloc(ARRAY_SIZE(sta->sta.txq), size, gfp);
353ba8c3d6fSFelix Fietkau 		if (!txq_data)
354ba8c3d6fSFelix Fietkau 			goto free;
355ba8c3d6fSFelix Fietkau 
356ba8c3d6fSFelix Fietkau 		for (i = 0; i < ARRAY_SIZE(sta->sta.txq); i++) {
357ba8c3d6fSFelix Fietkau 			struct txq_info *txq = txq_data + i * size;
358ba8c3d6fSFelix Fietkau 
359ba8c3d6fSFelix Fietkau 			ieee80211_init_tx_queue(sdata, sta, txq, i);
360abfbc3afSJohannes Berg 		}
361ba8c3d6fSFelix Fietkau 	}
362ba8c3d6fSFelix Fietkau 
363ba8c3d6fSFelix Fietkau 	if (sta_prepare_rate_control(local, sta, gfp))
364ba8c3d6fSFelix Fietkau 		goto free_txq;
365f0706e82SJiri Benc 
3665a306f58SJohannes Berg 	for (i = 0; i < IEEE80211_NUM_TIDS; i++) {
367a622ab72SJohannes Berg 		/*
368a622ab72SJohannes Berg 		 * timer_to_tid must be initialized with identity mapping
369a622ab72SJohannes Berg 		 * to enable session_timer's data differentiation. See
370a622ab72SJohannes Berg 		 * sta_rx_agg_session_timer_expired for usage.
371a622ab72SJohannes Berg 		 */
37216c5f15cSRon Rindjunsky 		sta->timer_to_tid[i] = i;
37316c5f15cSRon Rindjunsky 	}
374948d887dSJohannes Berg 	for (i = 0; i < IEEE80211_NUM_ACS; i++) {
375948d887dSJohannes Berg 		skb_queue_head_init(&sta->ps_tx_buf[i]);
376948d887dSJohannes Berg 		skb_queue_head_init(&sta->tx_filtered[i]);
377948d887dSJohannes Berg 	}
37873651ee6SJohannes Berg 
3795a306f58SJohannes Berg 	for (i = 0; i < IEEE80211_NUM_TIDS; i++)
3804be929beSAlexey Dobriyan 		sta->last_seq_ctrl[i] = cpu_to_le16(USHRT_MAX);
381cccaec98SSenthil Balasubramanian 
382af0ed69bSJohannes Berg 	sta->sta.smps_mode = IEEE80211_SMPS_OFF;
383687da132SEmmanuel Grumbach 	if (sdata->vif.type == NL80211_IFTYPE_AP ||
384687da132SEmmanuel Grumbach 	    sdata->vif.type == NL80211_IFTYPE_AP_VLAN) {
385687da132SEmmanuel Grumbach 		struct ieee80211_supported_band *sband =
386ba8c3d6fSFelix Fietkau 			hw->wiphy->bands[ieee80211_get_sdata_band(sdata)];
387687da132SEmmanuel Grumbach 		u8 smps = (sband->ht_cap.cap & IEEE80211_HT_CAP_SM_PS) >>
388687da132SEmmanuel Grumbach 				IEEE80211_HT_CAP_SM_PS_SHIFT;
389687da132SEmmanuel Grumbach 		/*
390687da132SEmmanuel Grumbach 		 * Assume that hostapd advertises our caps in the beacon and
391687da132SEmmanuel Grumbach 		 * this is the known_smps_mode for a station that just assciated
392687da132SEmmanuel Grumbach 		 */
393687da132SEmmanuel Grumbach 		switch (smps) {
394687da132SEmmanuel Grumbach 		case WLAN_HT_SMPS_CONTROL_DISABLED:
395687da132SEmmanuel Grumbach 			sta->known_smps_mode = IEEE80211_SMPS_OFF;
396687da132SEmmanuel Grumbach 			break;
397687da132SEmmanuel Grumbach 		case WLAN_HT_SMPS_CONTROL_STATIC:
398687da132SEmmanuel Grumbach 			sta->known_smps_mode = IEEE80211_SMPS_STATIC;
399687da132SEmmanuel Grumbach 			break;
400687da132SEmmanuel Grumbach 		case WLAN_HT_SMPS_CONTROL_DYNAMIC:
401687da132SEmmanuel Grumbach 			sta->known_smps_mode = IEEE80211_SMPS_DYNAMIC;
402687da132SEmmanuel Grumbach 			break;
403687da132SEmmanuel Grumbach 		default:
404687da132SEmmanuel Grumbach 			WARN_ON(1);
405687da132SEmmanuel Grumbach 		}
406687da132SEmmanuel Grumbach 	}
407af0ed69bSJohannes Berg 
408bdcbd8e0SJohannes Berg 	sta_dbg(sdata, "Allocated STA %pM\n", sta->sta.addr);
409ef04a297SJohannes Berg 
410abfbc3afSJohannes Berg 	return sta;
411ba8c3d6fSFelix Fietkau 
412ba8c3d6fSFelix Fietkau free_txq:
413ba8c3d6fSFelix Fietkau 	if (sta->sta.txq[0])
414ba8c3d6fSFelix Fietkau 		kfree(to_txq_info(sta->sta.txq[0]));
415ba8c3d6fSFelix Fietkau free:
416433f5bc1SJohannes Berg #ifdef CONFIG_MAC80211_MESH
417433f5bc1SJohannes Berg 	kfree(sta->mesh);
418433f5bc1SJohannes Berg #endif
419ba8c3d6fSFelix Fietkau 	kfree(sta);
420ba8c3d6fSFelix Fietkau 	return NULL;
42173651ee6SJohannes Berg }
42273651ee6SJohannes Berg 
4238c71df7aSGuy Eilam static int sta_info_insert_check(struct sta_info *sta)
42434e89507SJohannes Berg {
42534e89507SJohannes Berg 	struct ieee80211_sub_if_data *sdata = sta->sdata;
42634e89507SJohannes Berg 
42703e4497eSJohannes Berg 	/*
42803e4497eSJohannes Berg 	 * Can't be a WARN_ON because it can be triggered through a race:
42903e4497eSJohannes Berg 	 * something inserts a STA (on one CPU) without holding the RTNL
43003e4497eSJohannes Berg 	 * and another CPU turns off the net device.
43103e4497eSJohannes Berg 	 */
4328c71df7aSGuy Eilam 	if (unlikely(!ieee80211_sdata_running(sdata)))
4338c71df7aSGuy Eilam 		return -ENETDOWN;
43403e4497eSJohannes Berg 
435b203ca39SJoe Perches 	if (WARN_ON(ether_addr_equal(sta->sta.addr, sdata->vif.addr) ||
4368c71df7aSGuy Eilam 		    is_multicast_ether_addr(sta->sta.addr)))
4378c71df7aSGuy Eilam 		return -EINVAL;
4388c71df7aSGuy Eilam 
43931104891SJohannes Berg 	/* Strictly speaking this isn't necessary as we hold the mutex, but
44031104891SJohannes Berg 	 * the rhashtable code can't really deal with that distinction. We
44131104891SJohannes Berg 	 * do require the mutex for correctness though.
44231104891SJohannes Berg 	 */
44331104891SJohannes Berg 	rcu_read_lock();
44431104891SJohannes Berg 	lockdep_assert_held(&sdata->local->sta_mtx);
44531104891SJohannes Berg 	if (ieee80211_hw_check(&sdata->local->hw, NEEDS_UNIQUE_STA_ADDR) &&
44631104891SJohannes Berg 	    ieee80211_find_sta_by_ifaddr(&sdata->local->hw, sta->addr, NULL)) {
44731104891SJohannes Berg 		rcu_read_unlock();
44831104891SJohannes Berg 		return -ENOTUNIQ;
44931104891SJohannes Berg 	}
45031104891SJohannes Berg 	rcu_read_unlock();
45131104891SJohannes Berg 
4528c71df7aSGuy Eilam 	return 0;
45393e5deb1SJohannes Berg }
45444213b5eSJohannes Berg 
455f09603a2SJohannes Berg static int sta_info_insert_drv_state(struct ieee80211_local *local,
456f09603a2SJohannes Berg 				     struct ieee80211_sub_if_data *sdata,
457f09603a2SJohannes Berg 				     struct sta_info *sta)
458f09603a2SJohannes Berg {
459f09603a2SJohannes Berg 	enum ieee80211_sta_state state;
460f09603a2SJohannes Berg 	int err = 0;
461f09603a2SJohannes Berg 
462f09603a2SJohannes Berg 	for (state = IEEE80211_STA_NOTEXIST; state < sta->sta_state; state++) {
463f09603a2SJohannes Berg 		err = drv_sta_state(local, sdata, sta, state, state + 1);
464f09603a2SJohannes Berg 		if (err)
465f09603a2SJohannes Berg 			break;
466f09603a2SJohannes Berg 	}
467f09603a2SJohannes Berg 
468f09603a2SJohannes Berg 	if (!err) {
469a4ec45a4SJohannes Berg 		/*
470a4ec45a4SJohannes Berg 		 * Drivers using legacy sta_add/sta_remove callbacks only
471a4ec45a4SJohannes Berg 		 * get uploaded set to true after sta_add is called.
472a4ec45a4SJohannes Berg 		 */
473a4ec45a4SJohannes Berg 		if (!local->ops->sta_add)
474f09603a2SJohannes Berg 			sta->uploaded = true;
475f09603a2SJohannes Berg 		return 0;
476f09603a2SJohannes Berg 	}
477f09603a2SJohannes Berg 
478f09603a2SJohannes Berg 	if (sdata->vif.type == NL80211_IFTYPE_ADHOC) {
479bdcbd8e0SJohannes Berg 		sdata_info(sdata,
480bdcbd8e0SJohannes Berg 			   "failed to move IBSS STA %pM to state %d (%d) - keeping it anyway\n",
481bdcbd8e0SJohannes Berg 			   sta->sta.addr, state + 1, err);
482f09603a2SJohannes Berg 		err = 0;
483f09603a2SJohannes Berg 	}
484f09603a2SJohannes Berg 
485f09603a2SJohannes Berg 	/* unwind on error */
486f09603a2SJohannes Berg 	for (; state > IEEE80211_STA_NOTEXIST; state--)
487f09603a2SJohannes Berg 		WARN_ON(drv_sta_state(local, sdata, sta, state, state - 1));
488f09603a2SJohannes Berg 
489f09603a2SJohannes Berg 	return err;
490f09603a2SJohannes Berg }
491f09603a2SJohannes Berg 
49234e89507SJohannes Berg /*
4938c71df7aSGuy Eilam  * should be called with sta_mtx locked
4948c71df7aSGuy Eilam  * this function replaces the mutex lock
4958c71df7aSGuy Eilam  * with a RCU lock
4968c71df7aSGuy Eilam  */
4974d33960bSJohannes Berg static int sta_info_insert_finish(struct sta_info *sta) __acquires(RCU)
4988c71df7aSGuy Eilam {
4998c71df7aSGuy Eilam 	struct ieee80211_local *local = sta->local;
5008c71df7aSGuy Eilam 	struct ieee80211_sub_if_data *sdata = sta->sdata;
5017852e361SJohannes Berg 	struct station_info sinfo;
5028c71df7aSGuy Eilam 	int err = 0;
5038c71df7aSGuy Eilam 
5048c71df7aSGuy Eilam 	lockdep_assert_held(&local->sta_mtx);
5058c71df7aSGuy Eilam 
5067852e361SJohannes Berg 	/* check if STA exists already */
5077852e361SJohannes Berg 	if (sta_info_get_bss(sdata, sta->sta.addr)) {
5084d33960bSJohannes Berg 		err = -EEXIST;
5094d33960bSJohannes Berg 		goto out_err;
51034e89507SJohannes Berg 	}
51134e89507SJohannes Berg 
5124d33960bSJohannes Berg 	local->num_sta++;
5134d33960bSJohannes Berg 	local->sta_generation++;
5144d33960bSJohannes Berg 	smp_mb();
5154d33960bSJohannes Berg 
5165108ca82SJohannes Berg 	/* simplify things and don't accept BA sessions yet */
5175108ca82SJohannes Berg 	set_sta_flag(sta, WLAN_STA_BLOCK_BA);
5185108ca82SJohannes Berg 
5194d33960bSJohannes Berg 	/* make the station visible */
5204d33960bSJohannes Berg 	sta_info_hash_add(local, sta);
5214d33960bSJohannes Berg 
5222bad7748SArik Nemtsov 	list_add_tail_rcu(&sta->list, &local->sta_list);
52383d5cc01SJohannes Berg 
5245108ca82SJohannes Berg 	/* notify driver */
5255108ca82SJohannes Berg 	err = sta_info_insert_drv_state(local, sdata, sta);
5265108ca82SJohannes Berg 	if (err)
5275108ca82SJohannes Berg 		goto out_remove;
5285108ca82SJohannes Berg 
52983d5cc01SJohannes Berg 	set_sta_flag(sta, WLAN_STA_INSERTED);
5305108ca82SJohannes Berg 	/* accept BA sessions now */
5315108ca82SJohannes Berg 	clear_sta_flag(sta, WLAN_STA_BLOCK_BA);
5324d33960bSJohannes Berg 
53321f659bfSEliad Peller 	ieee80211_recalc_min_chandef(sdata);
5344d33960bSJohannes Berg 	ieee80211_sta_debugfs_add(sta);
5354d33960bSJohannes Berg 	rate_control_add_sta_debugfs(sta);
5364d33960bSJohannes Berg 
5374d33960bSJohannes Berg 	memset(&sinfo, 0, sizeof(sinfo));
5384d33960bSJohannes Berg 	sinfo.filled = 0;
5394d33960bSJohannes Berg 	sinfo.generation = local->sta_generation;
5404d33960bSJohannes Berg 	cfg80211_new_sta(sdata->dev, sta->sta.addr, &sinfo, GFP_KERNEL);
541d0709a65SJohannes Berg 
542bdcbd8e0SJohannes Berg 	sta_dbg(sdata, "Inserted STA %pM\n", sta->sta.addr);
543f0706e82SJiri Benc 
54434e89507SJohannes Berg 	/* move reference to rcu-protected */
54534e89507SJohannes Berg 	rcu_read_lock();
54634e89507SJohannes Berg 	mutex_unlock(&local->sta_mtx);
547e9f207f0SJiri Benc 
54873651ee6SJohannes Berg 	if (ieee80211_vif_is_mesh(&sdata->vif))
54973651ee6SJohannes Berg 		mesh_accept_plinks_update(sdata);
55073651ee6SJohannes Berg 
55173651ee6SJohannes Berg 	return 0;
5525108ca82SJohannes Berg  out_remove:
5535108ca82SJohannes Berg 	sta_info_hash_del(local, sta);
5545108ca82SJohannes Berg 	list_del_rcu(&sta->list);
5555108ca82SJohannes Berg 	local->num_sta--;
5565108ca82SJohannes Berg 	synchronize_net();
5575108ca82SJohannes Berg 	__cleanup_single_sta(sta);
5584d33960bSJohannes Berg  out_err:
5594d33960bSJohannes Berg 	mutex_unlock(&local->sta_mtx);
5604d33960bSJohannes Berg 	rcu_read_lock();
5614d33960bSJohannes Berg 	return err;
5628c71df7aSGuy Eilam }
5638c71df7aSGuy Eilam 
5648c71df7aSGuy Eilam int sta_info_insert_rcu(struct sta_info *sta) __acquires(RCU)
5658c71df7aSGuy Eilam {
5668c71df7aSGuy Eilam 	struct ieee80211_local *local = sta->local;
567308f7fcfSZhao, Gang 	int err;
5688c71df7aSGuy Eilam 
5694d33960bSJohannes Berg 	might_sleep();
5704d33960bSJohannes Berg 
57131104891SJohannes Berg 	mutex_lock(&local->sta_mtx);
57231104891SJohannes Berg 
5738c71df7aSGuy Eilam 	err = sta_info_insert_check(sta);
5748c71df7aSGuy Eilam 	if (err) {
57531104891SJohannes Berg 		mutex_unlock(&local->sta_mtx);
5768c71df7aSGuy Eilam 		rcu_read_lock();
5778c71df7aSGuy Eilam 		goto out_free;
5788c71df7aSGuy Eilam 	}
5798c71df7aSGuy Eilam 
5804d33960bSJohannes Berg 	err = sta_info_insert_finish(sta);
5818c71df7aSGuy Eilam 	if (err)
582004c872eSJohannes Berg 		goto out_free;
583d0709a65SJohannes Berg 
584004c872eSJohannes Berg 	return 0;
58593e5deb1SJohannes Berg  out_free:
586d9a7ddb0SJohannes Berg 	sta_info_free(local, sta);
58793e5deb1SJohannes Berg 	return err;
588f0706e82SJiri Benc }
589f0706e82SJiri Benc 
59034e89507SJohannes Berg int sta_info_insert(struct sta_info *sta)
59134e89507SJohannes Berg {
59234e89507SJohannes Berg 	int err = sta_info_insert_rcu(sta);
59334e89507SJohannes Berg 
59434e89507SJohannes Berg 	rcu_read_unlock();
59534e89507SJohannes Berg 
59634e89507SJohannes Berg 	return err;
59734e89507SJohannes Berg }
59834e89507SJohannes Berg 
599d012a605SMarco Porsch static inline void __bss_tim_set(u8 *tim, u16 id)
600004c872eSJohannes Berg {
601004c872eSJohannes Berg 	/*
602004c872eSJohannes Berg 	 * This format has been mandated by the IEEE specifications,
603004c872eSJohannes Berg 	 * so this line may not be changed to use the __set_bit() format.
604004c872eSJohannes Berg 	 */
605d012a605SMarco Porsch 	tim[id / 8] |= (1 << (id % 8));
606004c872eSJohannes Berg }
607004c872eSJohannes Berg 
608d012a605SMarco Porsch static inline void __bss_tim_clear(u8 *tim, u16 id)
609004c872eSJohannes Berg {
610004c872eSJohannes Berg 	/*
611004c872eSJohannes Berg 	 * This format has been mandated by the IEEE specifications,
612004c872eSJohannes Berg 	 * so this line may not be changed to use the __clear_bit() format.
613004c872eSJohannes Berg 	 */
614d012a605SMarco Porsch 	tim[id / 8] &= ~(1 << (id % 8));
615004c872eSJohannes Berg }
616004c872eSJohannes Berg 
6173d5839b6SIlan Peer static inline bool __bss_tim_get(u8 *tim, u16 id)
6183d5839b6SIlan Peer {
6193d5839b6SIlan Peer 	/*
6203d5839b6SIlan Peer 	 * This format has been mandated by the IEEE specifications,
6213d5839b6SIlan Peer 	 * so this line may not be changed to use the test_bit() format.
6223d5839b6SIlan Peer 	 */
6233d5839b6SIlan Peer 	return tim[id / 8] & (1 << (id % 8));
6243d5839b6SIlan Peer }
6253d5839b6SIlan Peer 
626948d887dSJohannes Berg static unsigned long ieee80211_tids_for_ac(int ac)
627004c872eSJohannes Berg {
628948d887dSJohannes Berg 	/* If we ever support TIDs > 7, this obviously needs to be adjusted */
629948d887dSJohannes Berg 	switch (ac) {
630948d887dSJohannes Berg 	case IEEE80211_AC_VO:
631948d887dSJohannes Berg 		return BIT(6) | BIT(7);
632948d887dSJohannes Berg 	case IEEE80211_AC_VI:
633948d887dSJohannes Berg 		return BIT(4) | BIT(5);
634948d887dSJohannes Berg 	case IEEE80211_AC_BE:
635948d887dSJohannes Berg 		return BIT(0) | BIT(3);
636948d887dSJohannes Berg 	case IEEE80211_AC_BK:
637948d887dSJohannes Berg 		return BIT(1) | BIT(2);
638948d887dSJohannes Berg 	default:
639948d887dSJohannes Berg 		WARN_ON(1);
640948d887dSJohannes Berg 		return 0;
641d0709a65SJohannes Berg 	}
642004c872eSJohannes Berg }
643004c872eSJohannes Berg 
6449b7a86f3SJohannes Berg static void __sta_info_recalc_tim(struct sta_info *sta, bool ignore_pending)
645004c872eSJohannes Berg {
646c868cb35SJohannes Berg 	struct ieee80211_local *local = sta->local;
647d012a605SMarco Porsch 	struct ps_data *ps;
648948d887dSJohannes Berg 	bool indicate_tim = false;
649948d887dSJohannes Berg 	u8 ignore_for_tim = sta->sta.uapsd_queues;
650948d887dSJohannes Berg 	int ac;
651a69bd8e6SBob Copeland 	u16 id = sta->sta.aid;
652004c872eSJohannes Berg 
653d012a605SMarco Porsch 	if (sta->sdata->vif.type == NL80211_IFTYPE_AP ||
654d012a605SMarco Porsch 	    sta->sdata->vif.type == NL80211_IFTYPE_AP_VLAN) {
655c868cb35SJohannes Berg 		if (WARN_ON_ONCE(!sta->sdata->bss))
656c868cb35SJohannes Berg 			return;
6573e122be0SJohannes Berg 
658d012a605SMarco Porsch 		ps = &sta->sdata->bss->ps;
6593f52b7e3SMarco Porsch #ifdef CONFIG_MAC80211_MESH
6603f52b7e3SMarco Porsch 	} else if (ieee80211_vif_is_mesh(&sta->sdata->vif)) {
6613f52b7e3SMarco Porsch 		ps = &sta->sdata->u.mesh.ps;
6623f52b7e3SMarco Porsch #endif
663d012a605SMarco Porsch 	} else {
664d012a605SMarco Porsch 		return;
665d012a605SMarco Porsch 	}
666d012a605SMarco Porsch 
667c868cb35SJohannes Berg 	/* No need to do anything if the driver does all */
66830686bf7SJohannes Berg 	if (ieee80211_hw_check(&local->hw, AP_LINK_PS))
669c868cb35SJohannes Berg 		return;
670004c872eSJohannes Berg 
671c868cb35SJohannes Berg 	if (sta->dead)
672c868cb35SJohannes Berg 		goto done;
6733e122be0SJohannes Berg 
674948d887dSJohannes Berg 	/*
675948d887dSJohannes Berg 	 * If all ACs are delivery-enabled then we should build
676948d887dSJohannes Berg 	 * the TIM bit for all ACs anyway; if only some are then
677948d887dSJohannes Berg 	 * we ignore those and build the TIM bit using only the
678948d887dSJohannes Berg 	 * non-enabled ones.
679948d887dSJohannes Berg 	 */
680948d887dSJohannes Berg 	if (ignore_for_tim == BIT(IEEE80211_NUM_ACS) - 1)
681948d887dSJohannes Berg 		ignore_for_tim = 0;
682948d887dSJohannes Berg 
6839b7a86f3SJohannes Berg 	if (ignore_pending)
6849b7a86f3SJohannes Berg 		ignore_for_tim = BIT(IEEE80211_NUM_ACS) - 1;
6859b7a86f3SJohannes Berg 
686948d887dSJohannes Berg 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
687948d887dSJohannes Berg 		unsigned long tids;
688948d887dSJohannes Berg 
689948d887dSJohannes Berg 		if (ignore_for_tim & BIT(ac))
690948d887dSJohannes Berg 			continue;
691948d887dSJohannes Berg 
692948d887dSJohannes Berg 		indicate_tim |= !skb_queue_empty(&sta->tx_filtered[ac]) ||
693948d887dSJohannes Berg 				!skb_queue_empty(&sta->ps_tx_buf[ac]);
694948d887dSJohannes Berg 		if (indicate_tim)
695948d887dSJohannes Berg 			break;
696948d887dSJohannes Berg 
697948d887dSJohannes Berg 		tids = ieee80211_tids_for_ac(ac);
698948d887dSJohannes Berg 
699948d887dSJohannes Berg 		indicate_tim |=
700948d887dSJohannes Berg 			sta->driver_buffered_tids & tids;
701ba8c3d6fSFelix Fietkau 		indicate_tim |=
702ba8c3d6fSFelix Fietkau 			sta->txq_buffered_tids & tids;
703004c872eSJohannes Berg 	}
704004c872eSJohannes Berg 
705c868cb35SJohannes Berg  done:
70665f704a5SJohannes Berg 	spin_lock_bh(&local->tim_lock);
707004c872eSJohannes Berg 
7083d5839b6SIlan Peer 	if (indicate_tim == __bss_tim_get(ps->tim, id))
7093d5839b6SIlan Peer 		goto out_unlock;
7103d5839b6SIlan Peer 
711948d887dSJohannes Berg 	if (indicate_tim)
712d012a605SMarco Porsch 		__bss_tim_set(ps->tim, id);
713c868cb35SJohannes Berg 	else
714d012a605SMarco Porsch 		__bss_tim_clear(ps->tim, id);
7153e122be0SJohannes Berg 
7169b7a86f3SJohannes Berg 	if (local->ops->set_tim && !WARN_ON(sta->dead)) {
717c868cb35SJohannes Berg 		local->tim_in_locked_section = true;
718948d887dSJohannes Berg 		drv_set_tim(local, &sta->sta, indicate_tim);
719c868cb35SJohannes Berg 		local->tim_in_locked_section = false;
720004c872eSJohannes Berg 	}
721004c872eSJohannes Berg 
7223d5839b6SIlan Peer out_unlock:
72365f704a5SJohannes Berg 	spin_unlock_bh(&local->tim_lock);
724004c872eSJohannes Berg }
725004c872eSJohannes Berg 
7269b7a86f3SJohannes Berg void sta_info_recalc_tim(struct sta_info *sta)
7279b7a86f3SJohannes Berg {
7289b7a86f3SJohannes Berg 	__sta_info_recalc_tim(sta, false);
7299b7a86f3SJohannes Berg }
7309b7a86f3SJohannes Berg 
731cd0b8d89SJohannes Berg static bool sta_info_buffer_expired(struct sta_info *sta, struct sk_buff *skb)
732f0706e82SJiri Benc {
733e039fa4aSJohannes Berg 	struct ieee80211_tx_info *info;
734f0706e82SJiri Benc 	int timeout;
735f0706e82SJiri Benc 
736f0706e82SJiri Benc 	if (!skb)
737cd0b8d89SJohannes Berg 		return false;
738f0706e82SJiri Benc 
739e039fa4aSJohannes Berg 	info = IEEE80211_SKB_CB(skb);
740f0706e82SJiri Benc 
741f0706e82SJiri Benc 	/* Timeout: (2 * listen_interval * beacon_int * 1024 / 1000000) sec */
74257c4d7b4SJohannes Berg 	timeout = (sta->listen_interval *
74357c4d7b4SJohannes Berg 		   sta->sdata->vif.bss_conf.beacon_int *
74457c4d7b4SJohannes Berg 		   32 / 15625) * HZ;
745f0706e82SJiri Benc 	if (timeout < STA_TX_BUFFER_EXPIRE)
746f0706e82SJiri Benc 		timeout = STA_TX_BUFFER_EXPIRE;
747e039fa4aSJohannes Berg 	return time_after(jiffies, info->control.jiffies + timeout);
748f0706e82SJiri Benc }
749f0706e82SJiri Benc 
750f0706e82SJiri Benc 
751948d887dSJohannes Berg static bool sta_info_cleanup_expire_buffered_ac(struct ieee80211_local *local,
752948d887dSJohannes Berg 						struct sta_info *sta, int ac)
753f0706e82SJiri Benc {
754f0706e82SJiri Benc 	unsigned long flags;
755f0706e82SJiri Benc 	struct sk_buff *skb;
756f0706e82SJiri Benc 
75760750397SJohannes Berg 	/*
75860750397SJohannes Berg 	 * First check for frames that should expire on the filtered
75960750397SJohannes Berg 	 * queue. Frames here were rejected by the driver and are on
76060750397SJohannes Berg 	 * a separate queue to avoid reordering with normal PS-buffered
76160750397SJohannes Berg 	 * frames. They also aren't accounted for right now in the
76260750397SJohannes Berg 	 * total_ps_buffered counter.
76360750397SJohannes Berg 	 */
764f0706e82SJiri Benc 	for (;;) {
765948d887dSJohannes Berg 		spin_lock_irqsave(&sta->tx_filtered[ac].lock, flags);
766948d887dSJohannes Berg 		skb = skb_peek(&sta->tx_filtered[ac]);
76757c4d7b4SJohannes Berg 		if (sta_info_buffer_expired(sta, skb))
768948d887dSJohannes Berg 			skb = __skb_dequeue(&sta->tx_filtered[ac]);
769836341a7SJohannes Berg 		else
770f0706e82SJiri Benc 			skb = NULL;
771948d887dSJohannes Berg 		spin_unlock_irqrestore(&sta->tx_filtered[ac].lock, flags);
772f0706e82SJiri Benc 
77360750397SJohannes Berg 		/*
77460750397SJohannes Berg 		 * Frames are queued in order, so if this one
77560750397SJohannes Berg 		 * hasn't expired yet we can stop testing. If
77660750397SJohannes Berg 		 * we actually reached the end of the queue we
77760750397SJohannes Berg 		 * also need to stop, of course.
77860750397SJohannes Berg 		 */
77960750397SJohannes Berg 		if (!skb)
78060750397SJohannes Berg 			break;
781d4fa14cdSFelix Fietkau 		ieee80211_free_txskb(&local->hw, skb);
78260750397SJohannes Berg 	}
78360750397SJohannes Berg 
78460750397SJohannes Berg 	/*
78560750397SJohannes Berg 	 * Now also check the normal PS-buffered queue, this will
78660750397SJohannes Berg 	 * only find something if the filtered queue was emptied
78760750397SJohannes Berg 	 * since the filtered frames are all before the normal PS
78860750397SJohannes Berg 	 * buffered frames.
78960750397SJohannes Berg 	 */
790f0706e82SJiri Benc 	for (;;) {
791948d887dSJohannes Berg 		spin_lock_irqsave(&sta->ps_tx_buf[ac].lock, flags);
792948d887dSJohannes Berg 		skb = skb_peek(&sta->ps_tx_buf[ac]);
793f0706e82SJiri Benc 		if (sta_info_buffer_expired(sta, skb))
794948d887dSJohannes Berg 			skb = __skb_dequeue(&sta->ps_tx_buf[ac]);
795f0706e82SJiri Benc 		else
796f0706e82SJiri Benc 			skb = NULL;
797948d887dSJohannes Berg 		spin_unlock_irqrestore(&sta->ps_tx_buf[ac].lock, flags);
798f0706e82SJiri Benc 
79960750397SJohannes Berg 		/*
80060750397SJohannes Berg 		 * frames are queued in order, so if this one
80160750397SJohannes Berg 		 * hasn't expired yet (or we reached the end of
80260750397SJohannes Berg 		 * the queue) we can stop testing
80360750397SJohannes Berg 		 */
804836341a7SJohannes Berg 		if (!skb)
805836341a7SJohannes Berg 			break;
806836341a7SJohannes Berg 
807f0706e82SJiri Benc 		local->total_ps_buffered--;
808bdcbd8e0SJohannes Berg 		ps_dbg(sta->sdata, "Buffered frame expired (STA %pM)\n",
809bdcbd8e0SJohannes Berg 		       sta->sta.addr);
810d4fa14cdSFelix Fietkau 		ieee80211_free_txskb(&local->hw, skb);
811f0706e82SJiri Benc 	}
8123393a608SJuuso Oikarinen 
81360750397SJohannes Berg 	/*
81460750397SJohannes Berg 	 * Finally, recalculate the TIM bit for this station -- it might
81560750397SJohannes Berg 	 * now be clear because the station was too slow to retrieve its
81660750397SJohannes Berg 	 * frames.
81760750397SJohannes Berg 	 */
81860750397SJohannes Berg 	sta_info_recalc_tim(sta);
81960750397SJohannes Berg 
82060750397SJohannes Berg 	/*
82160750397SJohannes Berg 	 * Return whether there are any frames still buffered, this is
82260750397SJohannes Berg 	 * used to check whether the cleanup timer still needs to run,
82360750397SJohannes Berg 	 * if there are no frames we don't need to rearm the timer.
82460750397SJohannes Berg 	 */
825948d887dSJohannes Berg 	return !(skb_queue_empty(&sta->ps_tx_buf[ac]) &&
826948d887dSJohannes Berg 		 skb_queue_empty(&sta->tx_filtered[ac]));
827948d887dSJohannes Berg }
828948d887dSJohannes Berg 
829948d887dSJohannes Berg static bool sta_info_cleanup_expire_buffered(struct ieee80211_local *local,
830948d887dSJohannes Berg 					     struct sta_info *sta)
831948d887dSJohannes Berg {
832948d887dSJohannes Berg 	bool have_buffered = false;
833948d887dSJohannes Berg 	int ac;
834948d887dSJohannes Berg 
8353f52b7e3SMarco Porsch 	/* This is only necessary for stations on BSS/MBSS interfaces */
8363f52b7e3SMarco Porsch 	if (!sta->sdata->bss &&
8373f52b7e3SMarco Porsch 	    !ieee80211_vif_is_mesh(&sta->sdata->vif))
838948d887dSJohannes Berg 		return false;
839948d887dSJohannes Berg 
840948d887dSJohannes Berg 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
841948d887dSJohannes Berg 		have_buffered |=
842948d887dSJohannes Berg 			sta_info_cleanup_expire_buffered_ac(local, sta, ac);
843948d887dSJohannes Berg 
844948d887dSJohannes Berg 	return have_buffered;
845f0706e82SJiri Benc }
846f0706e82SJiri Benc 
847d778207bSJohannes Berg static int __must_check __sta_info_destroy_part1(struct sta_info *sta)
84834e89507SJohannes Berg {
84934e89507SJohannes Berg 	struct ieee80211_local *local;
85034e89507SJohannes Berg 	struct ieee80211_sub_if_data *sdata;
8516d10e46bSJohannes Berg 	int ret;
85234e89507SJohannes Berg 
85334e89507SJohannes Berg 	might_sleep();
85434e89507SJohannes Berg 
85534e89507SJohannes Berg 	if (!sta)
85634e89507SJohannes Berg 		return -ENOENT;
85734e89507SJohannes Berg 
85834e89507SJohannes Berg 	local = sta->local;
85934e89507SJohannes Berg 	sdata = sta->sdata;
86034e89507SJohannes Berg 
86183d5cc01SJohannes Berg 	lockdep_assert_held(&local->sta_mtx);
86283d5cc01SJohannes Berg 
863098a6070SJohannes Berg 	/*
864098a6070SJohannes Berg 	 * Before removing the station from the driver and
865098a6070SJohannes Berg 	 * rate control, it might still start new aggregation
866098a6070SJohannes Berg 	 * sessions -- block that to make sure the tear-down
867098a6070SJohannes Berg 	 * will be sufficient.
868098a6070SJohannes Berg 	 */
869c2c98fdeSJohannes Berg 	set_sta_flag(sta, WLAN_STA_BLOCK_BA);
870c82c4a80SJohannes Berg 	ieee80211_sta_tear_down_BA_sessions(sta, AGG_STOP_DESTROY_STA);
871098a6070SJohannes Berg 
87234e89507SJohannes Berg 	ret = sta_info_hash_del(local, sta);
873b01711beSJohannes Berg 	if (WARN_ON(ret))
87434e89507SJohannes Berg 		return ret;
87534e89507SJohannes Berg 
876a7a6bdd0SArik Nemtsov 	/*
877a7a6bdd0SArik Nemtsov 	 * for TDLS peers, make sure to return to the base channel before
878a7a6bdd0SArik Nemtsov 	 * removal.
879a7a6bdd0SArik Nemtsov 	 */
880a7a6bdd0SArik Nemtsov 	if (test_sta_flag(sta, WLAN_STA_TDLS_OFF_CHANNEL)) {
881a7a6bdd0SArik Nemtsov 		drv_tdls_cancel_channel_switch(local, sdata, &sta->sta);
882a7a6bdd0SArik Nemtsov 		clear_sta_flag(sta, WLAN_STA_TDLS_OFF_CHANNEL);
883a7a6bdd0SArik Nemtsov 	}
884a7a6bdd0SArik Nemtsov 
885794454ceSArik Nemtsov 	list_del_rcu(&sta->list);
886*ef044763SEliad Peller 	sta->removed = true;
8874d33960bSJohannes Berg 
8886a9d1b91SJohannes Berg 	drv_sta_pre_rcu_remove(local, sta->sdata, sta);
8896a9d1b91SJohannes Berg 
890a710c816SJohannes Berg 	if (sdata->vif.type == NL80211_IFTYPE_AP_VLAN &&
891a710c816SJohannes Berg 	    rcu_access_pointer(sdata->u.vlan.sta) == sta)
892a710c816SJohannes Berg 		RCU_INIT_POINTER(sdata->u.vlan.sta, NULL);
893a710c816SJohannes Berg 
894d778207bSJohannes Berg 	return 0;
895d778207bSJohannes Berg }
896d778207bSJohannes Berg 
897d778207bSJohannes Berg static void __sta_info_destroy_part2(struct sta_info *sta)
898d778207bSJohannes Berg {
899d778207bSJohannes Berg 	struct ieee80211_local *local = sta->local;
900d778207bSJohannes Berg 	struct ieee80211_sub_if_data *sdata = sta->sdata;
9016f7a8d26SJohannes Berg 	struct station_info sinfo = {};
902d778207bSJohannes Berg 	int ret;
903d778207bSJohannes Berg 
904d778207bSJohannes Berg 	/*
905d778207bSJohannes Berg 	 * NOTE: This assumes at least synchronize_net() was done
906d778207bSJohannes Berg 	 *	 after _part1 and before _part2!
907d778207bSJohannes Berg 	 */
908d778207bSJohannes Berg 
909d778207bSJohannes Berg 	might_sleep();
910d778207bSJohannes Berg 	lockdep_assert_held(&local->sta_mtx);
911d778207bSJohannes Berg 
912c8782078SJohannes Berg 	/* now keys can no longer be reached */
9136d10e46bSJohannes Berg 	ieee80211_free_sta_keys(local, sta);
91434e89507SJohannes Berg 
9159b7a86f3SJohannes Berg 	/* disable TIM bit - last chance to tell driver */
9169b7a86f3SJohannes Berg 	__sta_info_recalc_tim(sta, true);
9179b7a86f3SJohannes Berg 
91834e89507SJohannes Berg 	sta->dead = true;
91934e89507SJohannes Berg 
92034e89507SJohannes Berg 	local->num_sta--;
92134e89507SJohannes Berg 	local->sta_generation++;
92234e89507SJohannes Berg 
92383d5cc01SJohannes Berg 	while (sta->sta_state > IEEE80211_STA_NONE) {
924f09603a2SJohannes Berg 		ret = sta_info_move_state(sta, sta->sta_state - 1);
925f09603a2SJohannes Berg 		if (ret) {
92683d5cc01SJohannes Berg 			WARN_ON_ONCE(1);
92783d5cc01SJohannes Berg 			break;
92883d5cc01SJohannes Berg 		}
92983d5cc01SJohannes Berg 	}
930d9a7ddb0SJohannes Berg 
931f09603a2SJohannes Berg 	if (sta->uploaded) {
932f09603a2SJohannes Berg 		ret = drv_sta_state(local, sdata, sta, IEEE80211_STA_NONE,
933f09603a2SJohannes Berg 				    IEEE80211_STA_NOTEXIST);
934f09603a2SJohannes Berg 		WARN_ON_ONCE(ret != 0);
935f09603a2SJohannes Berg 	}
93634e89507SJohannes Berg 
937bdcbd8e0SJohannes Berg 	sta_dbg(sdata, "Removed STA %pM\n", sta->sta.addr);
938bdcbd8e0SJohannes Berg 
9396f7a8d26SJohannes Berg 	sta_set_sinfo(sta, &sinfo);
9406f7a8d26SJohannes Berg 	cfg80211_del_sta_sinfo(sdata->dev, sta->sta.addr, &sinfo, GFP_KERNEL);
941ec15e68bSJouni Malinen 
94234e89507SJohannes Berg 	rate_control_remove_sta_debugfs(sta);
94334e89507SJohannes Berg 	ieee80211_sta_debugfs_remove(sta);
94421f659bfSEliad Peller 	ieee80211_recalc_min_chandef(sdata);
94534e89507SJohannes Berg 
946d34ba216SJohannes Berg 	cleanup_single_sta(sta);
947d778207bSJohannes Berg }
948d778207bSJohannes Berg 
949d778207bSJohannes Berg int __must_check __sta_info_destroy(struct sta_info *sta)
950d778207bSJohannes Berg {
951d778207bSJohannes Berg 	int err = __sta_info_destroy_part1(sta);
952d778207bSJohannes Berg 
953d778207bSJohannes Berg 	if (err)
954d778207bSJohannes Berg 		return err;
955d778207bSJohannes Berg 
956d778207bSJohannes Berg 	synchronize_net();
957d778207bSJohannes Berg 
958d778207bSJohannes Berg 	__sta_info_destroy_part2(sta);
95934e89507SJohannes Berg 
96034e89507SJohannes Berg 	return 0;
96134e89507SJohannes Berg }
96234e89507SJohannes Berg 
96334e89507SJohannes Berg int sta_info_destroy_addr(struct ieee80211_sub_if_data *sdata, const u8 *addr)
96434e89507SJohannes Berg {
96534e89507SJohannes Berg 	struct sta_info *sta;
96634e89507SJohannes Berg 	int ret;
96734e89507SJohannes Berg 
96834e89507SJohannes Berg 	mutex_lock(&sdata->local->sta_mtx);
9697852e361SJohannes Berg 	sta = sta_info_get(sdata, addr);
97034e89507SJohannes Berg 	ret = __sta_info_destroy(sta);
97134e89507SJohannes Berg 	mutex_unlock(&sdata->local->sta_mtx);
97234e89507SJohannes Berg 
97334e89507SJohannes Berg 	return ret;
97434e89507SJohannes Berg }
97534e89507SJohannes Berg 
97634e89507SJohannes Berg int sta_info_destroy_addr_bss(struct ieee80211_sub_if_data *sdata,
97734e89507SJohannes Berg 			      const u8 *addr)
97834e89507SJohannes Berg {
97934e89507SJohannes Berg 	struct sta_info *sta;
98034e89507SJohannes Berg 	int ret;
98134e89507SJohannes Berg 
98234e89507SJohannes Berg 	mutex_lock(&sdata->local->sta_mtx);
9837852e361SJohannes Berg 	sta = sta_info_get_bss(sdata, addr);
98434e89507SJohannes Berg 	ret = __sta_info_destroy(sta);
98534e89507SJohannes Berg 	mutex_unlock(&sdata->local->sta_mtx);
98634e89507SJohannes Berg 
98734e89507SJohannes Berg 	return ret;
98834e89507SJohannes Berg }
989f0706e82SJiri Benc 
990f0706e82SJiri Benc static void sta_info_cleanup(unsigned long data)
991f0706e82SJiri Benc {
992f0706e82SJiri Benc 	struct ieee80211_local *local = (struct ieee80211_local *) data;
993f0706e82SJiri Benc 	struct sta_info *sta;
9943393a608SJuuso Oikarinen 	bool timer_needed = false;
995f0706e82SJiri Benc 
996d0709a65SJohannes Berg 	rcu_read_lock();
997d0709a65SJohannes Berg 	list_for_each_entry_rcu(sta, &local->sta_list, list)
9983393a608SJuuso Oikarinen 		if (sta_info_cleanup_expire_buffered(local, sta))
9993393a608SJuuso Oikarinen 			timer_needed = true;
1000d0709a65SJohannes Berg 	rcu_read_unlock();
1001f0706e82SJiri Benc 
10025bb644a0SJohannes Berg 	if (local->quiescing)
10035bb644a0SJohannes Berg 		return;
10045bb644a0SJohannes Berg 
10053393a608SJuuso Oikarinen 	if (!timer_needed)
10063393a608SJuuso Oikarinen 		return;
10073393a608SJuuso Oikarinen 
100826d59535SJohannes Berg 	mod_timer(&local->sta_cleanup,
100926d59535SJohannes Berg 		  round_jiffies(jiffies + STA_INFO_CLEANUP_INTERVAL));
1010f0706e82SJiri Benc }
1011f0706e82SJiri Benc 
10127bedd0cfSJohannes Berg u32 sta_addr_hash(const void *key, u32 length, u32 seed)
1013f0706e82SJiri Benc {
10147bedd0cfSJohannes Berg 	return jhash(key, ETH_ALEN, seed);
10157bedd0cfSJohannes Berg }
10167bedd0cfSJohannes Berg 
10177bedd0cfSJohannes Berg int sta_info_init(struct ieee80211_local *local)
10187bedd0cfSJohannes Berg {
10197bedd0cfSJohannes Berg 	int err;
10207bedd0cfSJohannes Berg 
10217bedd0cfSJohannes Berg 	err = rhashtable_init(&local->sta_hash, &sta_rht_params);
10227bedd0cfSJohannes Berg 	if (err)
10237bedd0cfSJohannes Berg 		return err;
10247bedd0cfSJohannes Berg 
10254d33960bSJohannes Berg 	spin_lock_init(&local->tim_lock);
102634e89507SJohannes Berg 	mutex_init(&local->sta_mtx);
1027f0706e82SJiri Benc 	INIT_LIST_HEAD(&local->sta_list);
1028f0706e82SJiri Benc 
1029b24b8a24SPavel Emelyanov 	setup_timer(&local->sta_cleanup, sta_info_cleanup,
1030b24b8a24SPavel Emelyanov 		    (unsigned long)local);
10317bedd0cfSJohannes Berg 	return 0;
1032f0706e82SJiri Benc }
1033f0706e82SJiri Benc 
1034f0706e82SJiri Benc void sta_info_stop(struct ieee80211_local *local)
1035f0706e82SJiri Benc {
1036a56f992cSJohannes Berg 	del_timer_sync(&local->sta_cleanup);
10377bedd0cfSJohannes Berg 	rhashtable_destroy(&local->sta_hash);
1038f0706e82SJiri Benc }
1039f0706e82SJiri Benc 
1040051007d9SJohannes Berg 
1041e716251dSJohannes Berg int __sta_info_flush(struct ieee80211_sub_if_data *sdata, bool vlans)
1042f0706e82SJiri Benc {
1043b998e8bbSJohannes Berg 	struct ieee80211_local *local = sdata->local;
1044f0706e82SJiri Benc 	struct sta_info *sta, *tmp;
1045d778207bSJohannes Berg 	LIST_HEAD(free_list);
104644213b5eSJohannes Berg 	int ret = 0;
1047f0706e82SJiri Benc 
1048d0709a65SJohannes Berg 	might_sleep();
1049d0709a65SJohannes Berg 
1050e716251dSJohannes Berg 	WARN_ON(vlans && sdata->vif.type != NL80211_IFTYPE_AP);
1051e716251dSJohannes Berg 	WARN_ON(vlans && !sdata->bss);
1052e716251dSJohannes Berg 
105334e89507SJohannes Berg 	mutex_lock(&local->sta_mtx);
105434e89507SJohannes Berg 	list_for_each_entry_safe(sta, tmp, &local->sta_list, list) {
1055e716251dSJohannes Berg 		if (sdata == sta->sdata ||
1056e716251dSJohannes Berg 		    (vlans && sdata->bss == sta->sdata->bss)) {
1057d778207bSJohannes Berg 			if (!WARN_ON(__sta_info_destroy_part1(sta)))
1058d778207bSJohannes Berg 				list_add(&sta->free_list, &free_list);
105934316837SJohannes Berg 			ret++;
106034316837SJohannes Berg 		}
106134e89507SJohannes Berg 	}
1062d778207bSJohannes Berg 
1063d778207bSJohannes Berg 	if (!list_empty(&free_list)) {
1064d778207bSJohannes Berg 		synchronize_net();
1065d778207bSJohannes Berg 		list_for_each_entry_safe(sta, tmp, &free_list, free_list)
1066d778207bSJohannes Berg 			__sta_info_destroy_part2(sta);
1067d778207bSJohannes Berg 	}
106834e89507SJohannes Berg 	mutex_unlock(&local->sta_mtx);
106944213b5eSJohannes Berg 
1070051007d9SJohannes Berg 	return ret;
1071051007d9SJohannes Berg }
1072051007d9SJohannes Berg 
107324723d1bSJohannes Berg void ieee80211_sta_expire(struct ieee80211_sub_if_data *sdata,
107424723d1bSJohannes Berg 			  unsigned long exp_time)
107524723d1bSJohannes Berg {
107624723d1bSJohannes Berg 	struct ieee80211_local *local = sdata->local;
107724723d1bSJohannes Berg 	struct sta_info *sta, *tmp;
107824723d1bSJohannes Berg 
107934e89507SJohannes Berg 	mutex_lock(&local->sta_mtx);
1080e46a2cf9SMohammed Shafi Shajakhan 
1081e46a2cf9SMohammed Shafi Shajakhan 	list_for_each_entry_safe(sta, tmp, &local->sta_list, list) {
1082ec2b774eSMarek Lindner 		if (sdata != sta->sdata)
1083ec2b774eSMarek Lindner 			continue;
1084ec2b774eSMarek Lindner 
1085e5a9f8d0SJohannes Berg 		if (time_after(jiffies, sta->rx_stats.last_rx + exp_time)) {
1086eea57d42SMohammed Shafi Shajakhan 			sta_dbg(sta->sdata, "expiring inactive STA %pM\n",
1087bdcbd8e0SJohannes Berg 				sta->sta.addr);
10883f52b7e3SMarco Porsch 
10893f52b7e3SMarco Porsch 			if (ieee80211_vif_is_mesh(&sdata->vif) &&
10903f52b7e3SMarco Porsch 			    test_sta_flag(sta, WLAN_STA_PS_STA))
10913f52b7e3SMarco Porsch 				atomic_dec(&sdata->u.mesh.ps.num_sta_ps);
10923f52b7e3SMarco Porsch 
109334e89507SJohannes Berg 			WARN_ON(__sta_info_destroy(sta));
109424723d1bSJohannes Berg 		}
1095e46a2cf9SMohammed Shafi Shajakhan 	}
1096e46a2cf9SMohammed Shafi Shajakhan 
109734e89507SJohannes Berg 	mutex_unlock(&local->sta_mtx);
109824723d1bSJohannes Berg }
109917741cdcSJohannes Berg 
1100686b9cb9SBen Greear struct ieee80211_sta *ieee80211_find_sta_by_ifaddr(struct ieee80211_hw *hw,
1101686b9cb9SBen Greear 						   const u8 *addr,
1102686b9cb9SBen Greear 						   const u8 *localaddr)
110317741cdcSJohannes Berg {
11047bedd0cfSJohannes Berg 	struct ieee80211_local *local = hw_to_local(hw);
11057bedd0cfSJohannes Berg 	struct sta_info *sta;
11067bedd0cfSJohannes Berg 	struct rhash_head *tmp;
11077bedd0cfSJohannes Berg 	const struct bucket_table *tbl;
11087bedd0cfSJohannes Berg 
11097bedd0cfSJohannes Berg 	tbl = rht_dereference_rcu(local->sta_hash.tbl, &local->sta_hash);
111017741cdcSJohannes Berg 
1111686b9cb9SBen Greear 	/*
1112686b9cb9SBen Greear 	 * Just return a random station if localaddr is NULL
1113686b9cb9SBen Greear 	 * ... first in list.
1114686b9cb9SBen Greear 	 */
11157bedd0cfSJohannes Berg 	for_each_sta_info(local, tbl, addr, sta, tmp) {
1116686b9cb9SBen Greear 		if (localaddr &&
1117b203ca39SJoe Perches 		    !ether_addr_equal(sta->sdata->vif.addr, localaddr))
1118686b9cb9SBen Greear 			continue;
1119f7c65594SJohannes Berg 		if (!sta->uploaded)
1120f7c65594SJohannes Berg 			return NULL;
112117741cdcSJohannes Berg 		return &sta->sta;
1122f7c65594SJohannes Berg 	}
1123f7c65594SJohannes Berg 
1124abe60632SJohannes Berg 	return NULL;
112517741cdcSJohannes Berg }
1126686b9cb9SBen Greear EXPORT_SYMBOL_GPL(ieee80211_find_sta_by_ifaddr);
11275ed176e1SJohannes Berg 
11285ed176e1SJohannes Berg struct ieee80211_sta *ieee80211_find_sta(struct ieee80211_vif *vif,
11295ed176e1SJohannes Berg 					 const u8 *addr)
11305ed176e1SJohannes Berg {
1131f7c65594SJohannes Berg 	struct sta_info *sta;
11325ed176e1SJohannes Berg 
11335ed176e1SJohannes Berg 	if (!vif)
11345ed176e1SJohannes Berg 		return NULL;
11355ed176e1SJohannes Berg 
1136f7c65594SJohannes Berg 	sta = sta_info_get_bss(vif_to_sdata(vif), addr);
1137f7c65594SJohannes Berg 	if (!sta)
1138f7c65594SJohannes Berg 		return NULL;
11395ed176e1SJohannes Berg 
1140f7c65594SJohannes Berg 	if (!sta->uploaded)
1141f7c65594SJohannes Berg 		return NULL;
1142f7c65594SJohannes Berg 
1143f7c65594SJohannes Berg 	return &sta->sta;
11445ed176e1SJohannes Berg }
114517741cdcSJohannes Berg EXPORT_SYMBOL(ieee80211_find_sta);
1146af818581SJohannes Berg 
1147e3685e03SJohannes Berg /* powersave support code */
1148e3685e03SJohannes Berg void ieee80211_sta_ps_deliver_wakeup(struct sta_info *sta)
114950a9432dSJohannes Berg {
1150608383bfSHelmut Schaa 	struct ieee80211_sub_if_data *sdata = sta->sdata;
1151e3685e03SJohannes Berg 	struct ieee80211_local *local = sdata->local;
1152e3685e03SJohannes Berg 	struct sk_buff_head pending;
1153ba8c3d6fSFelix Fietkau 	int filtered = 0, buffered = 0, ac, i;
1154e3685e03SJohannes Berg 	unsigned long flags;
1155d012a605SMarco Porsch 	struct ps_data *ps;
1156d012a605SMarco Porsch 
11573918edb0SFelix Fietkau 	if (sdata->vif.type == NL80211_IFTYPE_AP_VLAN)
11583918edb0SFelix Fietkau 		sdata = container_of(sdata->bss, struct ieee80211_sub_if_data,
11593918edb0SFelix Fietkau 				     u.ap);
11603918edb0SFelix Fietkau 
11613918edb0SFelix Fietkau 	if (sdata->vif.type == NL80211_IFTYPE_AP)
1162d012a605SMarco Porsch 		ps = &sdata->bss->ps;
11633f52b7e3SMarco Porsch 	else if (ieee80211_vif_is_mesh(&sdata->vif))
11643f52b7e3SMarco Porsch 		ps = &sdata->u.mesh.ps;
1165d012a605SMarco Porsch 	else
1166d012a605SMarco Porsch 		return;
116750a9432dSJohannes Berg 
1168c2c98fdeSJohannes Berg 	clear_sta_flag(sta, WLAN_STA_SP);
116947086fc5SJohannes Berg 
11705a306f58SJohannes Berg 	BUILD_BUG_ON(BITS_TO_LONGS(IEEE80211_NUM_TIDS) > 1);
1171948d887dSJohannes Berg 	sta->driver_buffered_tids = 0;
1172ba8c3d6fSFelix Fietkau 	sta->txq_buffered_tids = 0;
1173948d887dSJohannes Berg 
117430686bf7SJohannes Berg 	if (!ieee80211_hw_check(&local->hw, AP_LINK_PS))
117512375ef9SJohannes Berg 		drv_sta_notify(local, sdata, STA_NOTIFY_AWAKE, &sta->sta);
1176af818581SJohannes Berg 
1177ba8c3d6fSFelix Fietkau 	if (sta->sta.txq[0]) {
1178ba8c3d6fSFelix Fietkau 		for (i = 0; i < ARRAY_SIZE(sta->sta.txq); i++) {
1179ba8c3d6fSFelix Fietkau 			struct txq_info *txqi = to_txq_info(sta->sta.txq[i]);
1180ba8c3d6fSFelix Fietkau 
1181ba8c3d6fSFelix Fietkau 			if (!skb_queue_len(&txqi->queue))
1182ba8c3d6fSFelix Fietkau 				continue;
1183ba8c3d6fSFelix Fietkau 
1184ba8c3d6fSFelix Fietkau 			drv_wake_tx_queue(local, txqi);
1185ba8c3d6fSFelix Fietkau 		}
1186ba8c3d6fSFelix Fietkau 	}
1187ba8c3d6fSFelix Fietkau 
1188948d887dSJohannes Berg 	skb_queue_head_init(&pending);
1189af818581SJohannes Berg 
11901d147bfaSEmmanuel Grumbach 	/* sync with ieee80211_tx_h_unicast_ps_buf */
11911d147bfaSEmmanuel Grumbach 	spin_lock(&sta->ps_lock);
1192af818581SJohannes Berg 	/* Send all buffered frames to the station */
1193948d887dSJohannes Berg 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
1194948d887dSJohannes Berg 		int count = skb_queue_len(&pending), tmp;
1195948d887dSJohannes Berg 
1196987c285cSArik Nemtsov 		spin_lock_irqsave(&sta->tx_filtered[ac].lock, flags);
1197948d887dSJohannes Berg 		skb_queue_splice_tail_init(&sta->tx_filtered[ac], &pending);
1198987c285cSArik Nemtsov 		spin_unlock_irqrestore(&sta->tx_filtered[ac].lock, flags);
1199948d887dSJohannes Berg 		tmp = skb_queue_len(&pending);
1200948d887dSJohannes Berg 		filtered += tmp - count;
1201948d887dSJohannes Berg 		count = tmp;
1202948d887dSJohannes Berg 
1203987c285cSArik Nemtsov 		spin_lock_irqsave(&sta->ps_tx_buf[ac].lock, flags);
1204948d887dSJohannes Berg 		skb_queue_splice_tail_init(&sta->ps_tx_buf[ac], &pending);
1205987c285cSArik Nemtsov 		spin_unlock_irqrestore(&sta->ps_tx_buf[ac].lock, flags);
1206948d887dSJohannes Berg 		tmp = skb_queue_len(&pending);
1207948d887dSJohannes Berg 		buffered += tmp - count;
1208948d887dSJohannes Berg 	}
1209948d887dSJohannes Berg 
1210e3685e03SJohannes Berg 	ieee80211_add_pending_skbs(local, &pending);
12115ac2e350SJohannes Berg 
12125ac2e350SJohannes Berg 	/* now we're no longer in the deliver code */
12135ac2e350SJohannes Berg 	clear_sta_flag(sta, WLAN_STA_PS_DELIVER);
12145ac2e350SJohannes Berg 
12155ac2e350SJohannes Berg 	/* The station might have polled and then woken up before we responded,
12165ac2e350SJohannes Berg 	 * so clear these flags now to avoid them sticking around.
12175ac2e350SJohannes Berg 	 */
12185ac2e350SJohannes Berg 	clear_sta_flag(sta, WLAN_STA_PSPOLL);
12195ac2e350SJohannes Berg 	clear_sta_flag(sta, WLAN_STA_UAPSD);
12201d147bfaSEmmanuel Grumbach 	spin_unlock(&sta->ps_lock);
1221948d887dSJohannes Berg 
1222e3685e03SJohannes Berg 	atomic_dec(&ps->num_sta_ps);
1223e3685e03SJohannes Berg 
1224687da132SEmmanuel Grumbach 	/* This station just woke up and isn't aware of our SMPS state */
1225062f1d6dSChun-Yeow Yeoh 	if (!ieee80211_vif_is_mesh(&sdata->vif) &&
1226062f1d6dSChun-Yeow Yeoh 	    !ieee80211_smps_is_restrictive(sta->known_smps_mode,
1227687da132SEmmanuel Grumbach 					   sdata->smps_mode) &&
1228687da132SEmmanuel Grumbach 	    sta->known_smps_mode != sdata->bss->req_smps &&
1229687da132SEmmanuel Grumbach 	    sta_info_tx_streams(sta) != 1) {
1230687da132SEmmanuel Grumbach 		ht_dbg(sdata,
1231687da132SEmmanuel Grumbach 		       "%pM just woke up and MIMO capable - update SMPS\n",
1232687da132SEmmanuel Grumbach 		       sta->sta.addr);
1233687da132SEmmanuel Grumbach 		ieee80211_send_smps_action(sdata, sdata->bss->req_smps,
1234687da132SEmmanuel Grumbach 					   sta->sta.addr,
1235687da132SEmmanuel Grumbach 					   sdata->vif.bss_conf.bssid);
1236687da132SEmmanuel Grumbach 	}
1237687da132SEmmanuel Grumbach 
1238af818581SJohannes Berg 	local->total_ps_buffered -= buffered;
1239af818581SJohannes Berg 
1240c868cb35SJohannes Berg 	sta_info_recalc_tim(sta);
1241c868cb35SJohannes Berg 
1242bdcbd8e0SJohannes Berg 	ps_dbg(sdata,
1243bdcbd8e0SJohannes Berg 	       "STA %pM aid %d sending %d filtered/%d PS frames since STA not sleeping anymore\n",
1244bdcbd8e0SJohannes Berg 	       sta->sta.addr, sta->sta.aid, filtered, buffered);
124517c18bf8SJohannes Berg 
124617c18bf8SJohannes Berg 	ieee80211_check_fast_xmit(sta);
1247af818581SJohannes Berg }
1248af818581SJohannes Berg 
12490ead2510SEmmanuel Grumbach static void ieee80211_send_null_response(struct sta_info *sta, int tid,
1250b77cf4f8SJohannes Berg 					 enum ieee80211_frame_release_type reason,
12510ead2510SEmmanuel Grumbach 					 bool call_driver, bool more_data)
1252ce662b44SJohannes Berg {
12530ead2510SEmmanuel Grumbach 	struct ieee80211_sub_if_data *sdata = sta->sdata;
1254ce662b44SJohannes Berg 	struct ieee80211_local *local = sdata->local;
1255ce662b44SJohannes Berg 	struct ieee80211_qos_hdr *nullfunc;
1256ce662b44SJohannes Berg 	struct sk_buff *skb;
1257ce662b44SJohannes Berg 	int size = sizeof(*nullfunc);
1258ce662b44SJohannes Berg 	__le16 fc;
1259a74a8c84SJohannes Berg 	bool qos = sta->sta.wme;
1260ce662b44SJohannes Berg 	struct ieee80211_tx_info *info;
126155de908aSJohannes Berg 	struct ieee80211_chanctx_conf *chanctx_conf;
1262ce662b44SJohannes Berg 
1263ce662b44SJohannes Berg 	if (qos) {
1264ce662b44SJohannes Berg 		fc = cpu_to_le16(IEEE80211_FTYPE_DATA |
1265ce662b44SJohannes Berg 				 IEEE80211_STYPE_QOS_NULLFUNC |
1266ce662b44SJohannes Berg 				 IEEE80211_FCTL_FROMDS);
1267ce662b44SJohannes Berg 	} else {
1268ce662b44SJohannes Berg 		size -= 2;
1269ce662b44SJohannes Berg 		fc = cpu_to_le16(IEEE80211_FTYPE_DATA |
1270ce662b44SJohannes Berg 				 IEEE80211_STYPE_NULLFUNC |
1271ce662b44SJohannes Berg 				 IEEE80211_FCTL_FROMDS);
1272ce662b44SJohannes Berg 	}
1273ce662b44SJohannes Berg 
1274ce662b44SJohannes Berg 	skb = dev_alloc_skb(local->hw.extra_tx_headroom + size);
1275ce662b44SJohannes Berg 	if (!skb)
1276ce662b44SJohannes Berg 		return;
1277ce662b44SJohannes Berg 
1278ce662b44SJohannes Berg 	skb_reserve(skb, local->hw.extra_tx_headroom);
1279ce662b44SJohannes Berg 
1280ce662b44SJohannes Berg 	nullfunc = (void *) skb_put(skb, size);
1281ce662b44SJohannes Berg 	nullfunc->frame_control = fc;
1282ce662b44SJohannes Berg 	nullfunc->duration_id = 0;
1283ce662b44SJohannes Berg 	memcpy(nullfunc->addr1, sta->sta.addr, ETH_ALEN);
1284ce662b44SJohannes Berg 	memcpy(nullfunc->addr2, sdata->vif.addr, ETH_ALEN);
1285ce662b44SJohannes Berg 	memcpy(nullfunc->addr3, sdata->vif.addr, ETH_ALEN);
1286864a6040SJohannes Berg 	nullfunc->seq_ctrl = 0;
1287ce662b44SJohannes Berg 
1288ce662b44SJohannes Berg 	skb->priority = tid;
1289ce662b44SJohannes Berg 	skb_set_queue_mapping(skb, ieee802_1d_to_ac[tid]);
129059b66255SJohannes Berg 	if (qos) {
1291ce662b44SJohannes Berg 		nullfunc->qos_ctrl = cpu_to_le16(tid);
1292ce662b44SJohannes Berg 
12930ead2510SEmmanuel Grumbach 		if (reason == IEEE80211_FRAME_RELEASE_UAPSD) {
1294ce662b44SJohannes Berg 			nullfunc->qos_ctrl |=
1295ce662b44SJohannes Berg 				cpu_to_le16(IEEE80211_QOS_CTL_EOSP);
12960ead2510SEmmanuel Grumbach 			if (more_data)
12970ead2510SEmmanuel Grumbach 				nullfunc->frame_control |=
12980ead2510SEmmanuel Grumbach 					cpu_to_le16(IEEE80211_FCTL_MOREDATA);
12990ead2510SEmmanuel Grumbach 		}
1300ce662b44SJohannes Berg 	}
1301ce662b44SJohannes Berg 
1302ce662b44SJohannes Berg 	info = IEEE80211_SKB_CB(skb);
1303ce662b44SJohannes Berg 
1304ce662b44SJohannes Berg 	/*
1305ce662b44SJohannes Berg 	 * Tell TX path to send this frame even though the
1306ce662b44SJohannes Berg 	 * STA may still remain is PS mode after this frame
1307deeaee19SJohannes Berg 	 * exchange. Also set EOSP to indicate this packet
1308deeaee19SJohannes Berg 	 * ends the poll/service period.
1309ce662b44SJohannes Berg 	 */
131002f2f1a9SJohannes Berg 	info->flags |= IEEE80211_TX_CTL_NO_PS_BUFFER |
1311deeaee19SJohannes Berg 		       IEEE80211_TX_STATUS_EOSP |
1312ce662b44SJohannes Berg 		       IEEE80211_TX_CTL_REQ_TX_STATUS;
1313ce662b44SJohannes Berg 
13146b127c71SSujith Manoharan 	info->control.flags |= IEEE80211_TX_CTRL_PS_RESPONSE;
13156b127c71SSujith Manoharan 
1316b77cf4f8SJohannes Berg 	if (call_driver)
1317b77cf4f8SJohannes Berg 		drv_allow_buffered_frames(local, sta, BIT(tid), 1,
1318b77cf4f8SJohannes Berg 					  reason, false);
131940b96408SJohannes Berg 
132089afe614SJohannes Berg 	skb->dev = sdata->dev;
132189afe614SJohannes Berg 
132255de908aSJohannes Berg 	rcu_read_lock();
132355de908aSJohannes Berg 	chanctx_conf = rcu_dereference(sdata->vif.chanctx_conf);
132455de908aSJohannes Berg 	if (WARN_ON(!chanctx_conf)) {
132555de908aSJohannes Berg 		rcu_read_unlock();
132655de908aSJohannes Berg 		kfree_skb(skb);
132755de908aSJohannes Berg 		return;
132855de908aSJohannes Berg 	}
132955de908aSJohannes Berg 
133073c4e195SJohannes Berg 	info->band = chanctx_conf->def.chan->band;
13317c10770fSJohannes Berg 	ieee80211_xmit(sdata, sta, skb);
133255de908aSJohannes Berg 	rcu_read_unlock();
1333ce662b44SJohannes Berg }
1334ce662b44SJohannes Berg 
13350a1cb809SJohannes Berg static int find_highest_prio_tid(unsigned long tids)
13360a1cb809SJohannes Berg {
13370a1cb809SJohannes Berg 	/* lower 3 TIDs aren't ordered perfectly */
13380a1cb809SJohannes Berg 	if (tids & 0xF8)
13390a1cb809SJohannes Berg 		return fls(tids) - 1;
13400a1cb809SJohannes Berg 	/* TID 0 is BE just like TID 3 */
13410a1cb809SJohannes Berg 	if (tids & BIT(0))
13420a1cb809SJohannes Berg 		return 0;
13430a1cb809SJohannes Berg 	return fls(tids) - 1;
13440a1cb809SJohannes Berg }
13450a1cb809SJohannes Berg 
13460ead2510SEmmanuel Grumbach /* Indicates if the MORE_DATA bit should be set in the last
13470ead2510SEmmanuel Grumbach  * frame obtained by ieee80211_sta_ps_get_frames.
13480ead2510SEmmanuel Grumbach  * Note that driver_release_tids is relevant only if
13490ead2510SEmmanuel Grumbach  * reason = IEEE80211_FRAME_RELEASE_PSPOLL
13500ead2510SEmmanuel Grumbach  */
13510ead2510SEmmanuel Grumbach static bool
13520ead2510SEmmanuel Grumbach ieee80211_sta_ps_more_data(struct sta_info *sta, u8 ignored_acs,
13530ead2510SEmmanuel Grumbach 			   enum ieee80211_frame_release_type reason,
13540ead2510SEmmanuel Grumbach 			   unsigned long driver_release_tids)
13550ead2510SEmmanuel Grumbach {
13560ead2510SEmmanuel Grumbach 	int ac;
13570ead2510SEmmanuel Grumbach 
13580ead2510SEmmanuel Grumbach 	/* If the driver has data on more than one TID then
13590ead2510SEmmanuel Grumbach 	 * certainly there's more data if we release just a
13600ead2510SEmmanuel Grumbach 	 * single frame now (from a single TID). This will
13610ead2510SEmmanuel Grumbach 	 * only happen for PS-Poll.
13620ead2510SEmmanuel Grumbach 	 */
13630ead2510SEmmanuel Grumbach 	if (reason == IEEE80211_FRAME_RELEASE_PSPOLL &&
13640ead2510SEmmanuel Grumbach 	    hweight16(driver_release_tids) > 1)
13650ead2510SEmmanuel Grumbach 		return true;
13660ead2510SEmmanuel Grumbach 
13670ead2510SEmmanuel Grumbach 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
13680ead2510SEmmanuel Grumbach 		if (ignored_acs & BIT(ac))
13690ead2510SEmmanuel Grumbach 			continue;
13700ead2510SEmmanuel Grumbach 
13710ead2510SEmmanuel Grumbach 		if (!skb_queue_empty(&sta->tx_filtered[ac]) ||
13720ead2510SEmmanuel Grumbach 		    !skb_queue_empty(&sta->ps_tx_buf[ac]))
13730ead2510SEmmanuel Grumbach 			return true;
13740ead2510SEmmanuel Grumbach 	}
13750ead2510SEmmanuel Grumbach 
13760ead2510SEmmanuel Grumbach 	return false;
13770ead2510SEmmanuel Grumbach }
13780ead2510SEmmanuel Grumbach 
137947086fc5SJohannes Berg static void
13800ead2510SEmmanuel Grumbach ieee80211_sta_ps_get_frames(struct sta_info *sta, int n_frames, u8 ignored_acs,
13810ead2510SEmmanuel Grumbach 			    enum ieee80211_frame_release_type reason,
13820ead2510SEmmanuel Grumbach 			    struct sk_buff_head *frames,
13830ead2510SEmmanuel Grumbach 			    unsigned long *driver_release_tids)
1384af818581SJohannes Berg {
1385af818581SJohannes Berg 	struct ieee80211_sub_if_data *sdata = sta->sdata;
1386af818581SJohannes Berg 	struct ieee80211_local *local = sdata->local;
1387948d887dSJohannes Berg 	int ac;
1388af818581SJohannes Berg 
1389f9f760b4SJohannes Berg 	/* Get response frame(s) and more data bit for the last one. */
1390948d887dSJohannes Berg 	for (ac = 0; ac < IEEE80211_NUM_ACS; ac++) {
13914049e09aSJohannes Berg 		unsigned long tids;
13924049e09aSJohannes Berg 
139347086fc5SJohannes Berg 		if (ignored_acs & BIT(ac))
1394948d887dSJohannes Berg 			continue;
1395948d887dSJohannes Berg 
13964049e09aSJohannes Berg 		tids = ieee80211_tids_for_ac(ac);
13974049e09aSJohannes Berg 
1398f9f760b4SJohannes Berg 		/* if we already have frames from software, then we can't also
1399f9f760b4SJohannes Berg 		 * release from hardware queues
1400f9f760b4SJohannes Berg 		 */
14010ead2510SEmmanuel Grumbach 		if (skb_queue_empty(frames)) {
14020ead2510SEmmanuel Grumbach 			*driver_release_tids |=
14030ead2510SEmmanuel Grumbach 				sta->driver_buffered_tids & tids;
14040ead2510SEmmanuel Grumbach 			*driver_release_tids |= sta->txq_buffered_tids & tids;
1405ba8c3d6fSFelix Fietkau 		}
1406f9f760b4SJohannes Berg 
14070ead2510SEmmanuel Grumbach 		if (!*driver_release_tids) {
140847086fc5SJohannes Berg 			struct sk_buff *skb;
140947086fc5SJohannes Berg 
141047086fc5SJohannes Berg 			while (n_frames > 0) {
1411948d887dSJohannes Berg 				skb = skb_dequeue(&sta->tx_filtered[ac]);
1412948d887dSJohannes Berg 				if (!skb) {
141347086fc5SJohannes Berg 					skb = skb_dequeue(
141447086fc5SJohannes Berg 						&sta->ps_tx_buf[ac]);
1415af818581SJohannes Berg 					if (skb)
1416af818581SJohannes Berg 						local->total_ps_buffered--;
1417af818581SJohannes Berg 				}
141847086fc5SJohannes Berg 				if (!skb)
141947086fc5SJohannes Berg 					break;
142047086fc5SJohannes Berg 				n_frames--;
14210ead2510SEmmanuel Grumbach 				__skb_queue_tail(frames, skb);
142247086fc5SJohannes Berg 			}
1423948d887dSJohannes Berg 		}
1424948d887dSJohannes Berg 
14250ead2510SEmmanuel Grumbach 		/* If we have more frames buffered on this AC, then abort the
14260ead2510SEmmanuel Grumbach 		 * loop since we can't send more data from other ACs before
14270ead2510SEmmanuel Grumbach 		 * the buffered frames from this.
14284049e09aSJohannes Berg 		 */
1429948d887dSJohannes Berg 		if (!skb_queue_empty(&sta->tx_filtered[ac]) ||
14300ead2510SEmmanuel Grumbach 		    !skb_queue_empty(&sta->ps_tx_buf[ac]))
1431948d887dSJohannes Berg 			break;
1432948d887dSJohannes Berg 	}
1433948d887dSJohannes Berg }
1434af818581SJohannes Berg 
14350ead2510SEmmanuel Grumbach static void
14360ead2510SEmmanuel Grumbach ieee80211_sta_ps_deliver_response(struct sta_info *sta,
14370ead2510SEmmanuel Grumbach 				  int n_frames, u8 ignored_acs,
14380ead2510SEmmanuel Grumbach 				  enum ieee80211_frame_release_type reason)
14390ead2510SEmmanuel Grumbach {
14400ead2510SEmmanuel Grumbach 	struct ieee80211_sub_if_data *sdata = sta->sdata;
14410ead2510SEmmanuel Grumbach 	struct ieee80211_local *local = sdata->local;
14420ead2510SEmmanuel Grumbach 	unsigned long driver_release_tids = 0;
14430ead2510SEmmanuel Grumbach 	struct sk_buff_head frames;
14440ead2510SEmmanuel Grumbach 	bool more_data;
14450ead2510SEmmanuel Grumbach 
14460ead2510SEmmanuel Grumbach 	/* Service or PS-Poll period starts */
14470ead2510SEmmanuel Grumbach 	set_sta_flag(sta, WLAN_STA_SP);
14480ead2510SEmmanuel Grumbach 
14490ead2510SEmmanuel Grumbach 	__skb_queue_head_init(&frames);
14500ead2510SEmmanuel Grumbach 
14510ead2510SEmmanuel Grumbach 	ieee80211_sta_ps_get_frames(sta, n_frames, ignored_acs, reason,
14520ead2510SEmmanuel Grumbach 				    &frames, &driver_release_tids);
14530ead2510SEmmanuel Grumbach 
14540ead2510SEmmanuel Grumbach 	more_data = ieee80211_sta_ps_more_data(sta, ignored_acs, reason, driver_release_tids);
14550ead2510SEmmanuel Grumbach 
14560ead2510SEmmanuel Grumbach 	if (reason == IEEE80211_FRAME_RELEASE_PSPOLL)
14570ead2510SEmmanuel Grumbach 		driver_release_tids =
14580ead2510SEmmanuel Grumbach 			BIT(find_highest_prio_tid(driver_release_tids));
14590ead2510SEmmanuel Grumbach 
1460f9f760b4SJohannes Berg 	if (skb_queue_empty(&frames) && !driver_release_tids) {
1461ce662b44SJohannes Berg 		int tid;
14624049e09aSJohannes Berg 
1463ce662b44SJohannes Berg 		/*
1464ce662b44SJohannes Berg 		 * For PS-Poll, this can only happen due to a race condition
1465ce662b44SJohannes Berg 		 * when we set the TIM bit and the station notices it, but
1466ce662b44SJohannes Berg 		 * before it can poll for the frame we expire it.
1467ce662b44SJohannes Berg 		 *
1468ce662b44SJohannes Berg 		 * For uAPSD, this is said in the standard (11.2.1.5 h):
1469ce662b44SJohannes Berg 		 *	At each unscheduled SP for a non-AP STA, the AP shall
1470ce662b44SJohannes Berg 		 *	attempt to transmit at least one MSDU or MMPDU, but no
1471ce662b44SJohannes Berg 		 *	more than the value specified in the Max SP Length field
1472ce662b44SJohannes Berg 		 *	in the QoS Capability element from delivery-enabled ACs,
1473ce662b44SJohannes Berg 		 *	that are destined for the non-AP STA.
1474ce662b44SJohannes Berg 		 *
1475ce662b44SJohannes Berg 		 * Since we have no other MSDU/MMPDU, transmit a QoS null frame.
1476ce662b44SJohannes Berg 		 */
1477ce662b44SJohannes Berg 
1478ce662b44SJohannes Berg 		/* This will evaluate to 1, 3, 5 or 7. */
1479ce662b44SJohannes Berg 		tid = 7 - ((ffs(~ignored_acs) - 1) << 1);
1480ce662b44SJohannes Berg 
14810ead2510SEmmanuel Grumbach 		ieee80211_send_null_response(sta, tid, reason, true, false);
1482f9f760b4SJohannes Berg 	} else if (!driver_release_tids) {
148347086fc5SJohannes Berg 		struct sk_buff_head pending;
148447086fc5SJohannes Berg 		struct sk_buff *skb;
148540b96408SJohannes Berg 		int num = 0;
148640b96408SJohannes Berg 		u16 tids = 0;
1487b77cf4f8SJohannes Berg 		bool need_null = false;
148847086fc5SJohannes Berg 
148947086fc5SJohannes Berg 		skb_queue_head_init(&pending);
149047086fc5SJohannes Berg 
149147086fc5SJohannes Berg 		while ((skb = __skb_dequeue(&frames))) {
1492af818581SJohannes Berg 			struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
149347086fc5SJohannes Berg 			struct ieee80211_hdr *hdr = (void *) skb->data;
149440b96408SJohannes Berg 			u8 *qoshdr = NULL;
149540b96408SJohannes Berg 
149640b96408SJohannes Berg 			num++;
1497af818581SJohannes Berg 
1498af818581SJohannes Berg 			/*
149947086fc5SJohannes Berg 			 * Tell TX path to send this frame even though the
150047086fc5SJohannes Berg 			 * STA may still remain is PS mode after this frame
150147086fc5SJohannes Berg 			 * exchange.
1502af818581SJohannes Berg 			 */
15036b127c71SSujith Manoharan 			info->flags |= IEEE80211_TX_CTL_NO_PS_BUFFER;
15046b127c71SSujith Manoharan 			info->control.flags |= IEEE80211_TX_CTRL_PS_RESPONSE;
1505af818581SJohannes Berg 
150647086fc5SJohannes Berg 			/*
150747086fc5SJohannes Berg 			 * Use MoreData flag to indicate whether there are
150847086fc5SJohannes Berg 			 * more buffered frames for this STA
150947086fc5SJohannes Berg 			 */
151024b9c373SJanusz.Dziedzic@tieto.com 			if (more_data || !skb_queue_empty(&frames))
151147086fc5SJohannes Berg 				hdr->frame_control |=
151247086fc5SJohannes Berg 					cpu_to_le16(IEEE80211_FCTL_MOREDATA);
151324b9c373SJanusz.Dziedzic@tieto.com 			else
151424b9c373SJanusz.Dziedzic@tieto.com 				hdr->frame_control &=
151524b9c373SJanusz.Dziedzic@tieto.com 					cpu_to_le16(~IEEE80211_FCTL_MOREDATA);
1516af818581SJohannes Berg 
151740b96408SJohannes Berg 			if (ieee80211_is_data_qos(hdr->frame_control) ||
151840b96408SJohannes Berg 			    ieee80211_is_qos_nullfunc(hdr->frame_control))
151940b96408SJohannes Berg 				qoshdr = ieee80211_get_qos_ctl(hdr);
152040b96408SJohannes Berg 
1521b77cf4f8SJohannes Berg 			tids |= BIT(skb->priority);
1522b77cf4f8SJohannes Berg 
1523b77cf4f8SJohannes Berg 			__skb_queue_tail(&pending, skb);
1524b77cf4f8SJohannes Berg 
1525b77cf4f8SJohannes Berg 			/* end service period after last frame or add one */
1526b77cf4f8SJohannes Berg 			if (!skb_queue_empty(&frames))
1527b77cf4f8SJohannes Berg 				continue;
1528b77cf4f8SJohannes Berg 
1529b77cf4f8SJohannes Berg 			if (reason != IEEE80211_FRAME_RELEASE_UAPSD) {
1530b77cf4f8SJohannes Berg 				/* for PS-Poll, there's only one frame */
1531b77cf4f8SJohannes Berg 				info->flags |= IEEE80211_TX_STATUS_EOSP |
1532b77cf4f8SJohannes Berg 					       IEEE80211_TX_CTL_REQ_TX_STATUS;
1533b77cf4f8SJohannes Berg 				break;
1534b77cf4f8SJohannes Berg 			}
1535b77cf4f8SJohannes Berg 
1536b77cf4f8SJohannes Berg 			/* For uAPSD, things are a bit more complicated. If the
1537b77cf4f8SJohannes Berg 			 * last frame has a QoS header (i.e. is a QoS-data or
1538b77cf4f8SJohannes Berg 			 * QoS-nulldata frame) then just set the EOSP bit there
1539b77cf4f8SJohannes Berg 			 * and be done.
1540b77cf4f8SJohannes Berg 			 * If the frame doesn't have a QoS header (which means
1541b77cf4f8SJohannes Berg 			 * it should be a bufferable MMPDU) then we can't set
1542b77cf4f8SJohannes Berg 			 * the EOSP bit in the QoS header; add a QoS-nulldata
1543b77cf4f8SJohannes Berg 			 * frame to the list to send it after the MMPDU.
1544b77cf4f8SJohannes Berg 			 *
1545b77cf4f8SJohannes Berg 			 * Note that this code is only in the mac80211-release
1546b77cf4f8SJohannes Berg 			 * code path, we assume that the driver will not buffer
1547b77cf4f8SJohannes Berg 			 * anything but QoS-data frames, or if it does, will
1548b77cf4f8SJohannes Berg 			 * create the QoS-nulldata frame by itself if needed.
1549b77cf4f8SJohannes Berg 			 *
1550b77cf4f8SJohannes Berg 			 * Cf. 802.11-2012 10.2.1.10 (c).
1551b77cf4f8SJohannes Berg 			 */
1552b77cf4f8SJohannes Berg 			if (qoshdr) {
155340b96408SJohannes Berg 				*qoshdr |= IEEE80211_QOS_CTL_EOSP;
1554deeaee19SJohannes Berg 
155547086fc5SJohannes Berg 				info->flags |= IEEE80211_TX_STATUS_EOSP |
155647086fc5SJohannes Berg 					       IEEE80211_TX_CTL_REQ_TX_STATUS;
1557b77cf4f8SJohannes Berg 			} else {
1558b77cf4f8SJohannes Berg 				/* The standard isn't completely clear on this
1559b77cf4f8SJohannes Berg 				 * as it says the more-data bit should be set
1560b77cf4f8SJohannes Berg 				 * if there are more BUs. The QoS-Null frame
1561b77cf4f8SJohannes Berg 				 * we're about to send isn't buffered yet, we
1562b77cf4f8SJohannes Berg 				 * only create it below, but let's pretend it
1563b77cf4f8SJohannes Berg 				 * was buffered just in case some clients only
1564b77cf4f8SJohannes Berg 				 * expect more-data=0 when eosp=1.
1565b77cf4f8SJohannes Berg 				 */
1566b77cf4f8SJohannes Berg 				hdr->frame_control |=
1567b77cf4f8SJohannes Berg 					cpu_to_le16(IEEE80211_FCTL_MOREDATA);
1568b77cf4f8SJohannes Berg 				need_null = true;
1569b77cf4f8SJohannes Berg 				num++;
157052a3f20cSMarco Porsch 			}
1571b77cf4f8SJohannes Berg 			break;
157247086fc5SJohannes Berg 		}
157347086fc5SJohannes Berg 
157440b96408SJohannes Berg 		drv_allow_buffered_frames(local, sta, tids, num,
157540b96408SJohannes Berg 					  reason, more_data);
157640b96408SJohannes Berg 
157747086fc5SJohannes Berg 		ieee80211_add_pending_skbs(local, &pending);
1578af818581SJohannes Berg 
1579b77cf4f8SJohannes Berg 		if (need_null)
1580b77cf4f8SJohannes Berg 			ieee80211_send_null_response(
15810ead2510SEmmanuel Grumbach 				sta, find_highest_prio_tid(tids),
15820ead2510SEmmanuel Grumbach 				reason, false, false);
1583b77cf4f8SJohannes Berg 
1584c868cb35SJohannes Berg 		sta_info_recalc_tim(sta);
1585af818581SJohannes Berg 	} else {
1586ba8c3d6fSFelix Fietkau 		unsigned long tids = sta->txq_buffered_tids & driver_release_tids;
1587ba8c3d6fSFelix Fietkau 		int tid;
1588ba8c3d6fSFelix Fietkau 
1589af818581SJohannes Berg 		/*
15904049e09aSJohannes Berg 		 * We need to release a frame that is buffered somewhere in the
15914049e09aSJohannes Berg 		 * driver ... it'll have to handle that.
1592f9f760b4SJohannes Berg 		 * Note that the driver also has to check the number of frames
1593f9f760b4SJohannes Berg 		 * on the TIDs we're releasing from - if there are more than
1594f9f760b4SJohannes Berg 		 * n_frames it has to set the more-data bit (if we didn't ask
1595f9f760b4SJohannes Berg 		 * it to set it anyway due to other buffered frames); if there
1596f9f760b4SJohannes Berg 		 * are fewer than n_frames it has to make sure to adjust that
1597f9f760b4SJohannes Berg 		 * to allow the service period to end properly.
1598af818581SJohannes Berg 		 */
15994049e09aSJohannes Berg 		drv_release_buffered_frames(local, sta, driver_release_tids,
160047086fc5SJohannes Berg 					    n_frames, reason, more_data);
16014049e09aSJohannes Berg 
16024049e09aSJohannes Berg 		/*
16034049e09aSJohannes Berg 		 * Note that we don't recalculate the TIM bit here as it would
16044049e09aSJohannes Berg 		 * most likely have no effect at all unless the driver told us
1605f9f760b4SJohannes Berg 		 * that the TID(s) became empty before returning here from the
16064049e09aSJohannes Berg 		 * release function.
1607f9f760b4SJohannes Berg 		 * Either way, however, when the driver tells us that the TID(s)
1608ba8c3d6fSFelix Fietkau 		 * became empty or we find that a txq became empty, we'll do the
1609ba8c3d6fSFelix Fietkau 		 * TIM recalculation.
16104049e09aSJohannes Berg 		 */
1611ba8c3d6fSFelix Fietkau 
1612ba8c3d6fSFelix Fietkau 		if (!sta->sta.txq[0])
1613ba8c3d6fSFelix Fietkau 			return;
1614ba8c3d6fSFelix Fietkau 
1615ba8c3d6fSFelix Fietkau 		for (tid = 0; tid < ARRAY_SIZE(sta->sta.txq); tid++) {
1616ba8c3d6fSFelix Fietkau 			struct txq_info *txqi = to_txq_info(sta->sta.txq[tid]);
1617ba8c3d6fSFelix Fietkau 
1618ba8c3d6fSFelix Fietkau 			if (!(tids & BIT(tid)) || skb_queue_len(&txqi->queue))
1619ba8c3d6fSFelix Fietkau 				continue;
1620ba8c3d6fSFelix Fietkau 
1621ba8c3d6fSFelix Fietkau 			sta_info_recalc_tim(sta);
1622ba8c3d6fSFelix Fietkau 			break;
1623ba8c3d6fSFelix Fietkau 		}
1624af818581SJohannes Berg 	}
1625af818581SJohannes Berg }
1626af818581SJohannes Berg 
1627af818581SJohannes Berg void ieee80211_sta_ps_deliver_poll_response(struct sta_info *sta)
1628af818581SJohannes Berg {
162947086fc5SJohannes Berg 	u8 ignore_for_response = sta->sta.uapsd_queues;
1630af818581SJohannes Berg 
1631af818581SJohannes Berg 	/*
163247086fc5SJohannes Berg 	 * If all ACs are delivery-enabled then we should reply
163347086fc5SJohannes Berg 	 * from any of them, if only some are enabled we reply
163447086fc5SJohannes Berg 	 * only from the non-enabled ones.
1635af818581SJohannes Berg 	 */
163647086fc5SJohannes Berg 	if (ignore_for_response == BIT(IEEE80211_NUM_ACS) - 1)
163747086fc5SJohannes Berg 		ignore_for_response = 0;
1638af818581SJohannes Berg 
163947086fc5SJohannes Berg 	ieee80211_sta_ps_deliver_response(sta, 1, ignore_for_response,
164047086fc5SJohannes Berg 					  IEEE80211_FRAME_RELEASE_PSPOLL);
1641af818581SJohannes Berg }
164247086fc5SJohannes Berg 
164347086fc5SJohannes Berg void ieee80211_sta_ps_deliver_uapsd(struct sta_info *sta)
164447086fc5SJohannes Berg {
164547086fc5SJohannes Berg 	int n_frames = sta->sta.max_sp;
164647086fc5SJohannes Berg 	u8 delivery_enabled = sta->sta.uapsd_queues;
164747086fc5SJohannes Berg 
164847086fc5SJohannes Berg 	/*
164947086fc5SJohannes Berg 	 * If we ever grow support for TSPEC this might happen if
165047086fc5SJohannes Berg 	 * the TSPEC update from hostapd comes in between a trigger
165147086fc5SJohannes Berg 	 * frame setting WLAN_STA_UAPSD in the RX path and this
165247086fc5SJohannes Berg 	 * actually getting called.
165347086fc5SJohannes Berg 	 */
165447086fc5SJohannes Berg 	if (!delivery_enabled)
165547086fc5SJohannes Berg 		return;
165647086fc5SJohannes Berg 
165747086fc5SJohannes Berg 	switch (sta->sta.max_sp) {
165847086fc5SJohannes Berg 	case 1:
165947086fc5SJohannes Berg 		n_frames = 2;
166047086fc5SJohannes Berg 		break;
166147086fc5SJohannes Berg 	case 2:
166247086fc5SJohannes Berg 		n_frames = 4;
166347086fc5SJohannes Berg 		break;
166447086fc5SJohannes Berg 	case 3:
166547086fc5SJohannes Berg 		n_frames = 6;
166647086fc5SJohannes Berg 		break;
166747086fc5SJohannes Berg 	case 0:
166847086fc5SJohannes Berg 		/* XXX: what is a good value? */
166913a8098aSAndrei Otcheretianski 		n_frames = 128;
167047086fc5SJohannes Berg 		break;
167147086fc5SJohannes Berg 	}
167247086fc5SJohannes Berg 
167347086fc5SJohannes Berg 	ieee80211_sta_ps_deliver_response(sta, n_frames, ~delivery_enabled,
167447086fc5SJohannes Berg 					  IEEE80211_FRAME_RELEASE_UAPSD);
1675af818581SJohannes Berg }
1676af818581SJohannes Berg 
1677af818581SJohannes Berg void ieee80211_sta_block_awake(struct ieee80211_hw *hw,
1678af818581SJohannes Berg 			       struct ieee80211_sta *pubsta, bool block)
1679af818581SJohannes Berg {
1680af818581SJohannes Berg 	struct sta_info *sta = container_of(pubsta, struct sta_info, sta);
1681af818581SJohannes Berg 
1682b5878a2dSJohannes Berg 	trace_api_sta_block_awake(sta->local, pubsta, block);
1683b5878a2dSJohannes Berg 
16845ac2e350SJohannes Berg 	if (block) {
1685c2c98fdeSJohannes Berg 		set_sta_flag(sta, WLAN_STA_PS_DRIVER);
168617c18bf8SJohannes Berg 		ieee80211_clear_fast_xmit(sta);
16875ac2e350SJohannes Berg 		return;
16885ac2e350SJohannes Berg 	}
16895ac2e350SJohannes Berg 
16905ac2e350SJohannes Berg 	if (!test_sta_flag(sta, WLAN_STA_PS_DRIVER))
16915ac2e350SJohannes Berg 		return;
16925ac2e350SJohannes Berg 
16935ac2e350SJohannes Berg 	if (!test_sta_flag(sta, WLAN_STA_PS_STA)) {
16945ac2e350SJohannes Berg 		set_sta_flag(sta, WLAN_STA_PS_DELIVER);
16955ac2e350SJohannes Berg 		clear_sta_flag(sta, WLAN_STA_PS_DRIVER);
16965ac2e350SJohannes Berg 		ieee80211_queue_work(hw, &sta->drv_deliver_wk);
16975ac2e350SJohannes Berg 	} else if (test_sta_flag(sta, WLAN_STA_PSPOLL) ||
16985ac2e350SJohannes Berg 		   test_sta_flag(sta, WLAN_STA_UAPSD)) {
16995ac2e350SJohannes Berg 		/* must be asleep in this case */
17005ac2e350SJohannes Berg 		clear_sta_flag(sta, WLAN_STA_PS_DRIVER);
17015ac2e350SJohannes Berg 		ieee80211_queue_work(hw, &sta->drv_deliver_wk);
17025ac2e350SJohannes Berg 	} else {
17035ac2e350SJohannes Berg 		clear_sta_flag(sta, WLAN_STA_PS_DRIVER);
170417c18bf8SJohannes Berg 		ieee80211_check_fast_xmit(sta);
17055ac2e350SJohannes Berg 	}
1706af818581SJohannes Berg }
1707af818581SJohannes Berg EXPORT_SYMBOL(ieee80211_sta_block_awake);
1708dcf55fb5SFelix Fietkau 
1709e943789eSJohannes Berg void ieee80211_sta_eosp(struct ieee80211_sta *pubsta)
171037fbd908SJohannes Berg {
171137fbd908SJohannes Berg 	struct sta_info *sta = container_of(pubsta, struct sta_info, sta);
171237fbd908SJohannes Berg 	struct ieee80211_local *local = sta->local;
171337fbd908SJohannes Berg 
171437fbd908SJohannes Berg 	trace_api_eosp(local, pubsta);
171537fbd908SJohannes Berg 
171637fbd908SJohannes Berg 	clear_sta_flag(sta, WLAN_STA_SP);
171737fbd908SJohannes Berg }
1718e943789eSJohannes Berg EXPORT_SYMBOL(ieee80211_sta_eosp);
171937fbd908SJohannes Berg 
17200ead2510SEmmanuel Grumbach void ieee80211_send_eosp_nullfunc(struct ieee80211_sta *pubsta, int tid)
17210ead2510SEmmanuel Grumbach {
17220ead2510SEmmanuel Grumbach 	struct sta_info *sta = container_of(pubsta, struct sta_info, sta);
17230ead2510SEmmanuel Grumbach 	enum ieee80211_frame_release_type reason;
17240ead2510SEmmanuel Grumbach 	bool more_data;
17250ead2510SEmmanuel Grumbach 
17260ead2510SEmmanuel Grumbach 	trace_api_send_eosp_nullfunc(sta->local, pubsta, tid);
17270ead2510SEmmanuel Grumbach 
17280ead2510SEmmanuel Grumbach 	reason = IEEE80211_FRAME_RELEASE_UAPSD;
17290ead2510SEmmanuel Grumbach 	more_data = ieee80211_sta_ps_more_data(sta, ~sta->sta.uapsd_queues,
17300ead2510SEmmanuel Grumbach 					       reason, 0);
17310ead2510SEmmanuel Grumbach 
17320ead2510SEmmanuel Grumbach 	ieee80211_send_null_response(sta, tid, reason, false, more_data);
17330ead2510SEmmanuel Grumbach }
17340ead2510SEmmanuel Grumbach EXPORT_SYMBOL(ieee80211_send_eosp_nullfunc);
17350ead2510SEmmanuel Grumbach 
1736042ec453SJohannes Berg void ieee80211_sta_set_buffered(struct ieee80211_sta *pubsta,
1737042ec453SJohannes Berg 				u8 tid, bool buffered)
1738dcf55fb5SFelix Fietkau {
1739dcf55fb5SFelix Fietkau 	struct sta_info *sta = container_of(pubsta, struct sta_info, sta);
1740dcf55fb5SFelix Fietkau 
17415a306f58SJohannes Berg 	if (WARN_ON(tid >= IEEE80211_NUM_TIDS))
1742042ec453SJohannes Berg 		return;
1743042ec453SJohannes Berg 
17441b000789SJohannes Berg 	trace_api_sta_set_buffered(sta->local, pubsta, tid, buffered);
17451b000789SJohannes Berg 
1746948d887dSJohannes Berg 	if (buffered)
1747948d887dSJohannes Berg 		set_bit(tid, &sta->driver_buffered_tids);
1748948d887dSJohannes Berg 	else
1749948d887dSJohannes Berg 		clear_bit(tid, &sta->driver_buffered_tids);
1750948d887dSJohannes Berg 
1751c868cb35SJohannes Berg 	sta_info_recalc_tim(sta);
1752dcf55fb5SFelix Fietkau }
1753042ec453SJohannes Berg EXPORT_SYMBOL(ieee80211_sta_set_buffered);
1754d9a7ddb0SJohannes Berg 
175583d5cc01SJohannes Berg int sta_info_move_state(struct sta_info *sta,
1756d9a7ddb0SJohannes Berg 			enum ieee80211_sta_state new_state)
1757d9a7ddb0SJohannes Berg {
17588bf11d8dSJohannes Berg 	might_sleep();
1759d9a7ddb0SJohannes Berg 
1760d9a7ddb0SJohannes Berg 	if (sta->sta_state == new_state)
1761d9a7ddb0SJohannes Berg 		return 0;
1762d9a7ddb0SJohannes Berg 
1763f09603a2SJohannes Berg 	/* check allowed transitions first */
1764f09603a2SJohannes Berg 
1765d9a7ddb0SJohannes Berg 	switch (new_state) {
1766d9a7ddb0SJohannes Berg 	case IEEE80211_STA_NONE:
1767f09603a2SJohannes Berg 		if (sta->sta_state != IEEE80211_STA_AUTH)
1768d9a7ddb0SJohannes Berg 			return -EINVAL;
1769d9a7ddb0SJohannes Berg 		break;
1770d9a7ddb0SJohannes Berg 	case IEEE80211_STA_AUTH:
1771f09603a2SJohannes Berg 		if (sta->sta_state != IEEE80211_STA_NONE &&
1772f09603a2SJohannes Berg 		    sta->sta_state != IEEE80211_STA_ASSOC)
1773d9a7ddb0SJohannes Berg 			return -EINVAL;
1774d9a7ddb0SJohannes Berg 		break;
1775d9a7ddb0SJohannes Berg 	case IEEE80211_STA_ASSOC:
1776f09603a2SJohannes Berg 		if (sta->sta_state != IEEE80211_STA_AUTH &&
1777f09603a2SJohannes Berg 		    sta->sta_state != IEEE80211_STA_AUTHORIZED)
1778d9a7ddb0SJohannes Berg 			return -EINVAL;
1779d9a7ddb0SJohannes Berg 		break;
1780d9a7ddb0SJohannes Berg 	case IEEE80211_STA_AUTHORIZED:
1781f09603a2SJohannes Berg 		if (sta->sta_state != IEEE80211_STA_ASSOC)
1782d9a7ddb0SJohannes Berg 			return -EINVAL;
1783d9a7ddb0SJohannes Berg 		break;
1784d9a7ddb0SJohannes Berg 	default:
1785d9a7ddb0SJohannes Berg 		WARN(1, "invalid state %d", new_state);
1786d9a7ddb0SJohannes Berg 		return -EINVAL;
1787d9a7ddb0SJohannes Berg 	}
1788d9a7ddb0SJohannes Berg 
1789bdcbd8e0SJohannes Berg 	sta_dbg(sta->sdata, "moving STA %pM to state %d\n",
1790bdcbd8e0SJohannes Berg 		sta->sta.addr, new_state);
1791f09603a2SJohannes Berg 
1792f09603a2SJohannes Berg 	/*
1793f09603a2SJohannes Berg 	 * notify the driver before the actual changes so it can
1794f09603a2SJohannes Berg 	 * fail the transition
1795f09603a2SJohannes Berg 	 */
1796f09603a2SJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_INSERTED)) {
1797f09603a2SJohannes Berg 		int err = drv_sta_state(sta->local, sta->sdata, sta,
1798f09603a2SJohannes Berg 					sta->sta_state, new_state);
1799f09603a2SJohannes Berg 		if (err)
1800f09603a2SJohannes Berg 			return err;
1801f09603a2SJohannes Berg 	}
1802f09603a2SJohannes Berg 
1803f09603a2SJohannes Berg 	/* reflect the change in all state variables */
1804f09603a2SJohannes Berg 
1805f09603a2SJohannes Berg 	switch (new_state) {
1806f09603a2SJohannes Berg 	case IEEE80211_STA_NONE:
1807f09603a2SJohannes Berg 		if (sta->sta_state == IEEE80211_STA_AUTH)
1808f09603a2SJohannes Berg 			clear_bit(WLAN_STA_AUTH, &sta->_flags);
1809f09603a2SJohannes Berg 		break;
1810f09603a2SJohannes Berg 	case IEEE80211_STA_AUTH:
1811f09603a2SJohannes Berg 		if (sta->sta_state == IEEE80211_STA_NONE)
1812f09603a2SJohannes Berg 			set_bit(WLAN_STA_AUTH, &sta->_flags);
1813f09603a2SJohannes Berg 		else if (sta->sta_state == IEEE80211_STA_ASSOC)
1814f09603a2SJohannes Berg 			clear_bit(WLAN_STA_ASSOC, &sta->_flags);
1815f09603a2SJohannes Berg 		break;
1816f09603a2SJohannes Berg 	case IEEE80211_STA_ASSOC:
1817f09603a2SJohannes Berg 		if (sta->sta_state == IEEE80211_STA_AUTH) {
1818f09603a2SJohannes Berg 			set_bit(WLAN_STA_ASSOC, &sta->_flags);
1819f09603a2SJohannes Berg 		} else if (sta->sta_state == IEEE80211_STA_AUTHORIZED) {
18207e3ed02cSFelix Fietkau 			if (sta->sdata->vif.type == NL80211_IFTYPE_AP ||
18217e3ed02cSFelix Fietkau 			    (sta->sdata->vif.type == NL80211_IFTYPE_AP_VLAN &&
18227e3ed02cSFelix Fietkau 			     !sta->sdata->u.vlan.sta))
18237e3ed02cSFelix Fietkau 				atomic_dec(&sta->sdata->bss->num_mcast_sta);
1824f09603a2SJohannes Berg 			clear_bit(WLAN_STA_AUTHORIZED, &sta->_flags);
182517c18bf8SJohannes Berg 			ieee80211_clear_fast_xmit(sta);
1826f09603a2SJohannes Berg 		}
1827f09603a2SJohannes Berg 		break;
1828f09603a2SJohannes Berg 	case IEEE80211_STA_AUTHORIZED:
1829f09603a2SJohannes Berg 		if (sta->sta_state == IEEE80211_STA_ASSOC) {
18307e3ed02cSFelix Fietkau 			if (sta->sdata->vif.type == NL80211_IFTYPE_AP ||
18317e3ed02cSFelix Fietkau 			    (sta->sdata->vif.type == NL80211_IFTYPE_AP_VLAN &&
18327e3ed02cSFelix Fietkau 			     !sta->sdata->u.vlan.sta))
18337e3ed02cSFelix Fietkau 				atomic_inc(&sta->sdata->bss->num_mcast_sta);
1834f09603a2SJohannes Berg 			set_bit(WLAN_STA_AUTHORIZED, &sta->_flags);
183517c18bf8SJohannes Berg 			ieee80211_check_fast_xmit(sta);
1836f09603a2SJohannes Berg 		}
1837f09603a2SJohannes Berg 		break;
1838f09603a2SJohannes Berg 	default:
1839f09603a2SJohannes Berg 		break;
1840f09603a2SJohannes Berg 	}
1841f09603a2SJohannes Berg 
1842d9a7ddb0SJohannes Berg 	sta->sta_state = new_state;
1843d9a7ddb0SJohannes Berg 
1844d9a7ddb0SJohannes Berg 	return 0;
1845d9a7ddb0SJohannes Berg }
1846687da132SEmmanuel Grumbach 
1847687da132SEmmanuel Grumbach u8 sta_info_tx_streams(struct sta_info *sta)
1848687da132SEmmanuel Grumbach {
1849687da132SEmmanuel Grumbach 	struct ieee80211_sta_ht_cap *ht_cap = &sta->sta.ht_cap;
1850687da132SEmmanuel Grumbach 	u8 rx_streams;
1851687da132SEmmanuel Grumbach 
1852687da132SEmmanuel Grumbach 	if (!sta->sta.ht_cap.ht_supported)
1853687da132SEmmanuel Grumbach 		return 1;
1854687da132SEmmanuel Grumbach 
1855687da132SEmmanuel Grumbach 	if (sta->sta.vht_cap.vht_supported) {
1856687da132SEmmanuel Grumbach 		int i;
1857687da132SEmmanuel Grumbach 		u16 tx_mcs_map =
1858687da132SEmmanuel Grumbach 			le16_to_cpu(sta->sta.vht_cap.vht_mcs.tx_mcs_map);
1859687da132SEmmanuel Grumbach 
1860687da132SEmmanuel Grumbach 		for (i = 7; i >= 0; i--)
1861687da132SEmmanuel Grumbach 			if ((tx_mcs_map & (0x3 << (i * 2))) !=
1862687da132SEmmanuel Grumbach 			    IEEE80211_VHT_MCS_NOT_SUPPORTED)
1863687da132SEmmanuel Grumbach 				return i + 1;
1864687da132SEmmanuel Grumbach 	}
1865687da132SEmmanuel Grumbach 
1866687da132SEmmanuel Grumbach 	if (ht_cap->mcs.rx_mask[3])
1867687da132SEmmanuel Grumbach 		rx_streams = 4;
1868687da132SEmmanuel Grumbach 	else if (ht_cap->mcs.rx_mask[2])
1869687da132SEmmanuel Grumbach 		rx_streams = 3;
1870687da132SEmmanuel Grumbach 	else if (ht_cap->mcs.rx_mask[1])
1871687da132SEmmanuel Grumbach 		rx_streams = 2;
1872687da132SEmmanuel Grumbach 	else
1873687da132SEmmanuel Grumbach 		rx_streams = 1;
1874687da132SEmmanuel Grumbach 
1875687da132SEmmanuel Grumbach 	if (!(ht_cap->mcs.tx_params & IEEE80211_HT_MCS_TX_RX_DIFF))
1876687da132SEmmanuel Grumbach 		return rx_streams;
1877687da132SEmmanuel Grumbach 
1878687da132SEmmanuel Grumbach 	return ((ht_cap->mcs.tx_params & IEEE80211_HT_MCS_TX_MAX_STREAMS_MASK)
1879687da132SEmmanuel Grumbach 			>> IEEE80211_HT_MCS_TX_MAX_STREAMS_SHIFT) + 1;
1880687da132SEmmanuel Grumbach }
1881b7ffbd7eSJohannes Berg 
1882fbd6ff5cSJohannes Berg static void sta_set_rate_info_rx(struct sta_info *sta, struct rate_info *rinfo)
1883fbd6ff5cSJohannes Berg {
1884fbd6ff5cSJohannes Berg 	rinfo->flags = 0;
1885fbd6ff5cSJohannes Berg 
1886e5a9f8d0SJohannes Berg 	if (sta->rx_stats.last_rate_flag & RX_FLAG_HT) {
1887fbd6ff5cSJohannes Berg 		rinfo->flags |= RATE_INFO_FLAGS_MCS;
1888e5a9f8d0SJohannes Berg 		rinfo->mcs = sta->rx_stats.last_rate_idx;
1889e5a9f8d0SJohannes Berg 	} else if (sta->rx_stats.last_rate_flag & RX_FLAG_VHT) {
1890fbd6ff5cSJohannes Berg 		rinfo->flags |= RATE_INFO_FLAGS_VHT_MCS;
1891e5a9f8d0SJohannes Berg 		rinfo->nss = sta->rx_stats.last_rate_vht_nss;
1892e5a9f8d0SJohannes Berg 		rinfo->mcs = sta->rx_stats.last_rate_idx;
1893fbd6ff5cSJohannes Berg 	} else {
1894fbd6ff5cSJohannes Berg 		struct ieee80211_supported_band *sband;
1895fbd6ff5cSJohannes Berg 		int shift = ieee80211_vif_get_shift(&sta->sdata->vif);
1896fbd6ff5cSJohannes Berg 		u16 brate;
1897fbd6ff5cSJohannes Berg 
1898fbd6ff5cSJohannes Berg 		sband = sta->local->hw.wiphy->bands[
1899fbd6ff5cSJohannes Berg 				ieee80211_get_sdata_band(sta->sdata)];
1900e5a9f8d0SJohannes Berg 		brate = sband->bitrates[sta->rx_stats.last_rate_idx].bitrate;
1901fbd6ff5cSJohannes Berg 		rinfo->legacy = DIV_ROUND_UP(brate, 1 << shift);
1902fbd6ff5cSJohannes Berg 	}
1903fbd6ff5cSJohannes Berg 
1904e5a9f8d0SJohannes Berg 	if (sta->rx_stats.last_rate_flag & RX_FLAG_SHORT_GI)
1905fbd6ff5cSJohannes Berg 		rinfo->flags |= RATE_INFO_FLAGS_SHORT_GI;
1906fbd6ff5cSJohannes Berg 
1907e5a9f8d0SJohannes Berg 	if (sta->rx_stats.last_rate_flag & RX_FLAG_5MHZ)
1908fbd6ff5cSJohannes Berg 		rinfo->bw = RATE_INFO_BW_5;
1909e5a9f8d0SJohannes Berg 	else if (sta->rx_stats.last_rate_flag & RX_FLAG_10MHZ)
1910fbd6ff5cSJohannes Berg 		rinfo->bw = RATE_INFO_BW_10;
1911e5a9f8d0SJohannes Berg 	else if (sta->rx_stats.last_rate_flag & RX_FLAG_40MHZ)
1912fbd6ff5cSJohannes Berg 		rinfo->bw = RATE_INFO_BW_40;
1913e5a9f8d0SJohannes Berg 	else if (sta->rx_stats.last_rate_vht_flag & RX_VHT_FLAG_80MHZ)
1914fbd6ff5cSJohannes Berg 		rinfo->bw = RATE_INFO_BW_80;
1915e5a9f8d0SJohannes Berg 	else if (sta->rx_stats.last_rate_vht_flag & RX_VHT_FLAG_160MHZ)
1916fbd6ff5cSJohannes Berg 		rinfo->bw = RATE_INFO_BW_160;
1917fbd6ff5cSJohannes Berg 	else
1918fbd6ff5cSJohannes Berg 		rinfo->bw = RATE_INFO_BW_20;
1919fbd6ff5cSJohannes Berg }
1920fbd6ff5cSJohannes Berg 
1921b7ffbd7eSJohannes Berg void sta_set_sinfo(struct sta_info *sta, struct station_info *sinfo)
1922b7ffbd7eSJohannes Berg {
1923b7ffbd7eSJohannes Berg 	struct ieee80211_sub_if_data *sdata = sta->sdata;
1924b7ffbd7eSJohannes Berg 	struct ieee80211_local *local = sdata->local;
19259a244409SJohn W. Linville 	struct rate_control_ref *ref = NULL;
1926b7ffbd7eSJohannes Berg 	u32 thr = 0;
1927b7ffbd7eSJohannes Berg 	int i, ac;
1928b7ffbd7eSJohannes Berg 
19299a244409SJohn W. Linville 	if (test_sta_flag(sta, WLAN_STA_RATE_CONTROL))
19309a244409SJohn W. Linville 		ref = local->rate_ctrl;
19319a244409SJohn W. Linville 
1932b7ffbd7eSJohannes Berg 	sinfo->generation = sdata->local->sta_generation;
1933b7ffbd7eSJohannes Berg 
1934225b8189SJohannes Berg 	/* do before driver, so beacon filtering drivers have a
1935225b8189SJohannes Berg 	 * chance to e.g. just add the number of filtered beacons
1936225b8189SJohannes Berg 	 * (or just modify the value entirely, of course)
1937225b8189SJohannes Berg 	 */
1938225b8189SJohannes Berg 	if (sdata->vif.type == NL80211_IFTYPE_STATION)
1939225b8189SJohannes Berg 		sinfo->rx_beacon = sdata->u.mgd.count_beacon_signal;
1940225b8189SJohannes Berg 
19412b9a7e1bSJohannes Berg 	drv_sta_statistics(local, sdata, &sta->sta, sinfo);
19422b9a7e1bSJohannes Berg 
1943319090bfSJohannes Berg 	sinfo->filled |= BIT(NL80211_STA_INFO_INACTIVE_TIME) |
1944319090bfSJohannes Berg 			 BIT(NL80211_STA_INFO_STA_FLAGS) |
1945319090bfSJohannes Berg 			 BIT(NL80211_STA_INFO_BSS_PARAM) |
1946319090bfSJohannes Berg 			 BIT(NL80211_STA_INFO_CONNECTED_TIME) |
1947976bd9efSJohannes Berg 			 BIT(NL80211_STA_INFO_RX_DROP_MISC);
1948976bd9efSJohannes Berg 
1949976bd9efSJohannes Berg 	if (sdata->vif.type == NL80211_IFTYPE_STATION) {
1950976bd9efSJohannes Berg 		sinfo->beacon_loss_count = sdata->u.mgd.beacon_loss_count;
1951976bd9efSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_BEACON_LOSS);
1952976bd9efSJohannes Berg 	}
1953b7ffbd7eSJohannes Berg 
195484b00607SArnd Bergmann 	sinfo->connected_time = ktime_get_seconds() - sta->last_connected;
1955e5a9f8d0SJohannes Berg 	sinfo->inactive_time =
1956e5a9f8d0SJohannes Berg 		jiffies_to_msecs(jiffies - sta->rx_stats.last_rx);
19572b9a7e1bSJohannes Berg 
1958319090bfSJohannes Berg 	if (!(sinfo->filled & (BIT(NL80211_STA_INFO_TX_BYTES64) |
1959319090bfSJohannes Berg 			       BIT(NL80211_STA_INFO_TX_BYTES)))) {
1960b7ffbd7eSJohannes Berg 		sinfo->tx_bytes = 0;
19612b9a7e1bSJohannes Berg 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
1962e5a9f8d0SJohannes Berg 			sinfo->tx_bytes += sta->tx_stats.bytes[ac];
1963319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_TX_BYTES64);
1964b7ffbd7eSJohannes Berg 	}
19652b9a7e1bSJohannes Berg 
1966319090bfSJohannes Berg 	if (!(sinfo->filled & BIT(NL80211_STA_INFO_TX_PACKETS))) {
19672b9a7e1bSJohannes Berg 		sinfo->tx_packets = 0;
19682b9a7e1bSJohannes Berg 		for (ac = 0; ac < IEEE80211_NUM_ACS; ac++)
1969e5a9f8d0SJohannes Berg 			sinfo->tx_packets += sta->tx_stats.packets[ac];
1970319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_TX_PACKETS);
19712b9a7e1bSJohannes Berg 	}
19722b9a7e1bSJohannes Berg 
1973319090bfSJohannes Berg 	if (!(sinfo->filled & (BIT(NL80211_STA_INFO_RX_BYTES64) |
1974319090bfSJohannes Berg 			       BIT(NL80211_STA_INFO_RX_BYTES)))) {
1975e5a9f8d0SJohannes Berg 		sinfo->rx_bytes = sta->rx_stats.bytes;
1976319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_RX_BYTES64);
19772b9a7e1bSJohannes Berg 	}
19782b9a7e1bSJohannes Berg 
1979319090bfSJohannes Berg 	if (!(sinfo->filled & BIT(NL80211_STA_INFO_RX_PACKETS))) {
1980e5a9f8d0SJohannes Berg 		sinfo->rx_packets = sta->rx_stats.packets;
1981319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_RX_PACKETS);
19822b9a7e1bSJohannes Berg 	}
19832b9a7e1bSJohannes Berg 
1984319090bfSJohannes Berg 	if (!(sinfo->filled & BIT(NL80211_STA_INFO_TX_RETRIES))) {
1985e5a9f8d0SJohannes Berg 		sinfo->tx_retries = sta->status_stats.retry_count;
1986319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_TX_RETRIES);
19872b9a7e1bSJohannes Berg 	}
19882b9a7e1bSJohannes Berg 
1989319090bfSJohannes Berg 	if (!(sinfo->filled & BIT(NL80211_STA_INFO_TX_FAILED))) {
1990e5a9f8d0SJohannes Berg 		sinfo->tx_failed = sta->status_stats.retry_failed;
1991319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_TX_FAILED);
19922b9a7e1bSJohannes Berg 	}
19932b9a7e1bSJohannes Berg 
1994e5a9f8d0SJohannes Berg 	sinfo->rx_dropped_misc = sta->rx_stats.dropped;
1995b7ffbd7eSJohannes Berg 
1996225b8189SJohannes Berg 	if (sdata->vif.type == NL80211_IFTYPE_STATION &&
1997225b8189SJohannes Berg 	    !(sdata->vif.driver_flags & IEEE80211_VIF_BEACON_FILTER)) {
1998225b8189SJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_BEACON_RX) |
1999225b8189SJohannes Berg 				 BIT(NL80211_STA_INFO_BEACON_SIGNAL_AVG);
2000225b8189SJohannes Berg 		sinfo->rx_beacon_signal_avg = ieee80211_ave_rssi(&sdata->vif);
2001225b8189SJohannes Berg 	}
2002225b8189SJohannes Berg 
200330686bf7SJohannes Berg 	if (ieee80211_hw_check(&sta->local->hw, SIGNAL_DBM) ||
200430686bf7SJohannes Berg 	    ieee80211_hw_check(&sta->local->hw, SIGNAL_UNSPEC)) {
2005319090bfSJohannes Berg 		if (!(sinfo->filled & BIT(NL80211_STA_INFO_SIGNAL))) {
2006e5a9f8d0SJohannes Berg 			sinfo->signal = (s8)sta->rx_stats.last_signal;
2007319090bfSJohannes Berg 			sinfo->filled |= BIT(NL80211_STA_INFO_SIGNAL);
2008b7ffbd7eSJohannes Berg 		}
20092b9a7e1bSJohannes Berg 
2010319090bfSJohannes Berg 		if (!(sinfo->filled & BIT(NL80211_STA_INFO_SIGNAL_AVG))) {
201140d9a38aSJohannes Berg 			sinfo->signal_avg =
2012e5a9f8d0SJohannes Berg 				-ewma_signal_read(&sta->rx_stats.avg_signal);
2013319090bfSJohannes Berg 			sinfo->filled |= BIT(NL80211_STA_INFO_SIGNAL_AVG);
20142b9a7e1bSJohannes Berg 		}
20152b9a7e1bSJohannes Berg 	}
20162b9a7e1bSJohannes Berg 
2017e5a9f8d0SJohannes Berg 	if (sta->rx_stats.chains &&
2018319090bfSJohannes Berg 	    !(sinfo->filled & (BIT(NL80211_STA_INFO_CHAIN_SIGNAL) |
2019319090bfSJohannes Berg 			       BIT(NL80211_STA_INFO_CHAIN_SIGNAL_AVG)))) {
2020319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_CHAIN_SIGNAL) |
2021319090bfSJohannes Berg 				 BIT(NL80211_STA_INFO_CHAIN_SIGNAL_AVG);
2022b7ffbd7eSJohannes Berg 
2023e5a9f8d0SJohannes Berg 		sinfo->chains = sta->rx_stats.chains;
2024b7ffbd7eSJohannes Berg 		for (i = 0; i < ARRAY_SIZE(sinfo->chain_signal); i++) {
2025e5a9f8d0SJohannes Berg 			sinfo->chain_signal[i] =
2026e5a9f8d0SJohannes Berg 				sta->rx_stats.chain_signal_last[i];
2027b7ffbd7eSJohannes Berg 			sinfo->chain_signal_avg[i] =
2028e5a9f8d0SJohannes Berg 				-ewma_signal_read(&sta->rx_stats.chain_signal_avg[i]);
2029b7ffbd7eSJohannes Berg 		}
2030b7ffbd7eSJohannes Berg 	}
2031b7ffbd7eSJohannes Berg 
2032319090bfSJohannes Berg 	if (!(sinfo->filled & BIT(NL80211_STA_INFO_TX_BITRATE))) {
2033e5a9f8d0SJohannes Berg 		sta_set_rate_info_tx(sta, &sta->tx_stats.last_rate,
2034e5a9f8d0SJohannes Berg 				     &sinfo->txrate);
2035319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_TX_BITRATE);
20362b9a7e1bSJohannes Berg 	}
20372b9a7e1bSJohannes Berg 
2038319090bfSJohannes Berg 	if (!(sinfo->filled & BIT(NL80211_STA_INFO_RX_BITRATE))) {
2039b7ffbd7eSJohannes Berg 		sta_set_rate_info_rx(sta, &sinfo->rxrate);
2040319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_RX_BITRATE);
20412b9a7e1bSJohannes Berg 	}
2042b7ffbd7eSJohannes Berg 
204379c892b8SJohannes Berg 	sinfo->filled |= BIT(NL80211_STA_INFO_TID_STATS);
204479c892b8SJohannes Berg 	for (i = 0; i < IEEE80211_NUM_TIDS + 1; i++) {
204579c892b8SJohannes Berg 		struct cfg80211_tid_stats *tidstats = &sinfo->pertid[i];
204679c892b8SJohannes Berg 
204779c892b8SJohannes Berg 		if (!(tidstats->filled & BIT(NL80211_TID_STATS_RX_MSDU))) {
204879c892b8SJohannes Berg 			tidstats->filled |= BIT(NL80211_TID_STATS_RX_MSDU);
2049e5a9f8d0SJohannes Berg 			tidstats->rx_msdu = sta->rx_stats.msdu[i];
205079c892b8SJohannes Berg 		}
205179c892b8SJohannes Berg 
205279c892b8SJohannes Berg 		if (!(tidstats->filled & BIT(NL80211_TID_STATS_TX_MSDU))) {
205379c892b8SJohannes Berg 			tidstats->filled |= BIT(NL80211_TID_STATS_TX_MSDU);
2054e5a9f8d0SJohannes Berg 			tidstats->tx_msdu = sta->tx_stats.msdu[i];
205579c892b8SJohannes Berg 		}
205679c892b8SJohannes Berg 
205779c892b8SJohannes Berg 		if (!(tidstats->filled &
205879c892b8SJohannes Berg 				BIT(NL80211_TID_STATS_TX_MSDU_RETRIES)) &&
205930686bf7SJohannes Berg 		    ieee80211_hw_check(&local->hw, REPORTS_TX_ACK_STATUS)) {
206079c892b8SJohannes Berg 			tidstats->filled |=
206179c892b8SJohannes Berg 				BIT(NL80211_TID_STATS_TX_MSDU_RETRIES);
2062e5a9f8d0SJohannes Berg 			tidstats->tx_msdu_retries =
2063e5a9f8d0SJohannes Berg 				sta->status_stats.msdu_retries[i];
206479c892b8SJohannes Berg 		}
206579c892b8SJohannes Berg 
206679c892b8SJohannes Berg 		if (!(tidstats->filled &
206779c892b8SJohannes Berg 				BIT(NL80211_TID_STATS_TX_MSDU_FAILED)) &&
206830686bf7SJohannes Berg 		    ieee80211_hw_check(&local->hw, REPORTS_TX_ACK_STATUS)) {
206979c892b8SJohannes Berg 			tidstats->filled |=
207079c892b8SJohannes Berg 				BIT(NL80211_TID_STATS_TX_MSDU_FAILED);
2071e5a9f8d0SJohannes Berg 			tidstats->tx_msdu_failed =
2072e5a9f8d0SJohannes Berg 				sta->status_stats.msdu_failed[i];
207379c892b8SJohannes Berg 		}
207479c892b8SJohannes Berg 	}
207579c892b8SJohannes Berg 
2076b7ffbd7eSJohannes Berg 	if (ieee80211_vif_is_mesh(&sdata->vif)) {
2077b7ffbd7eSJohannes Berg #ifdef CONFIG_MAC80211_MESH
2078319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_LLID) |
2079319090bfSJohannes Berg 				 BIT(NL80211_STA_INFO_PLID) |
2080319090bfSJohannes Berg 				 BIT(NL80211_STA_INFO_PLINK_STATE) |
2081319090bfSJohannes Berg 				 BIT(NL80211_STA_INFO_LOCAL_PM) |
2082319090bfSJohannes Berg 				 BIT(NL80211_STA_INFO_PEER_PM) |
2083319090bfSJohannes Berg 				 BIT(NL80211_STA_INFO_NONPEER_PM);
2084b7ffbd7eSJohannes Berg 
2085433f5bc1SJohannes Berg 		sinfo->llid = sta->mesh->llid;
2086433f5bc1SJohannes Berg 		sinfo->plid = sta->mesh->plid;
2087433f5bc1SJohannes Berg 		sinfo->plink_state = sta->mesh->plink_state;
2088b7ffbd7eSJohannes Berg 		if (test_sta_flag(sta, WLAN_STA_TOFFSET_KNOWN)) {
2089319090bfSJohannes Berg 			sinfo->filled |= BIT(NL80211_STA_INFO_T_OFFSET);
2090433f5bc1SJohannes Berg 			sinfo->t_offset = sta->mesh->t_offset;
2091b7ffbd7eSJohannes Berg 		}
2092433f5bc1SJohannes Berg 		sinfo->local_pm = sta->mesh->local_pm;
2093433f5bc1SJohannes Berg 		sinfo->peer_pm = sta->mesh->peer_pm;
2094433f5bc1SJohannes Berg 		sinfo->nonpeer_pm = sta->mesh->nonpeer_pm;
2095b7ffbd7eSJohannes Berg #endif
2096b7ffbd7eSJohannes Berg 	}
2097b7ffbd7eSJohannes Berg 
2098b7ffbd7eSJohannes Berg 	sinfo->bss_param.flags = 0;
2099b7ffbd7eSJohannes Berg 	if (sdata->vif.bss_conf.use_cts_prot)
2100b7ffbd7eSJohannes Berg 		sinfo->bss_param.flags |= BSS_PARAM_FLAGS_CTS_PROT;
2101b7ffbd7eSJohannes Berg 	if (sdata->vif.bss_conf.use_short_preamble)
2102b7ffbd7eSJohannes Berg 		sinfo->bss_param.flags |= BSS_PARAM_FLAGS_SHORT_PREAMBLE;
2103b7ffbd7eSJohannes Berg 	if (sdata->vif.bss_conf.use_short_slot)
2104b7ffbd7eSJohannes Berg 		sinfo->bss_param.flags |= BSS_PARAM_FLAGS_SHORT_SLOT_TIME;
2105785e21a8SEmmanuel Grumbach 	sinfo->bss_param.dtim_period = sdata->vif.bss_conf.dtim_period;
2106b7ffbd7eSJohannes Berg 	sinfo->bss_param.beacon_interval = sdata->vif.bss_conf.beacon_int;
2107b7ffbd7eSJohannes Berg 
2108b7ffbd7eSJohannes Berg 	sinfo->sta_flags.set = 0;
2109b7ffbd7eSJohannes Berg 	sinfo->sta_flags.mask = BIT(NL80211_STA_FLAG_AUTHORIZED) |
2110b7ffbd7eSJohannes Berg 				BIT(NL80211_STA_FLAG_SHORT_PREAMBLE) |
2111b7ffbd7eSJohannes Berg 				BIT(NL80211_STA_FLAG_WME) |
2112b7ffbd7eSJohannes Berg 				BIT(NL80211_STA_FLAG_MFP) |
2113b7ffbd7eSJohannes Berg 				BIT(NL80211_STA_FLAG_AUTHENTICATED) |
2114b7ffbd7eSJohannes Berg 				BIT(NL80211_STA_FLAG_ASSOCIATED) |
2115b7ffbd7eSJohannes Berg 				BIT(NL80211_STA_FLAG_TDLS_PEER);
2116b7ffbd7eSJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_AUTHORIZED))
2117b7ffbd7eSJohannes Berg 		sinfo->sta_flags.set |= BIT(NL80211_STA_FLAG_AUTHORIZED);
2118b7ffbd7eSJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_SHORT_PREAMBLE))
2119b7ffbd7eSJohannes Berg 		sinfo->sta_flags.set |= BIT(NL80211_STA_FLAG_SHORT_PREAMBLE);
2120a74a8c84SJohannes Berg 	if (sta->sta.wme)
2121b7ffbd7eSJohannes Berg 		sinfo->sta_flags.set |= BIT(NL80211_STA_FLAG_WME);
2122b7ffbd7eSJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_MFP))
2123b7ffbd7eSJohannes Berg 		sinfo->sta_flags.set |= BIT(NL80211_STA_FLAG_MFP);
2124b7ffbd7eSJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_AUTH))
2125b7ffbd7eSJohannes Berg 		sinfo->sta_flags.set |= BIT(NL80211_STA_FLAG_AUTHENTICATED);
2126b7ffbd7eSJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_ASSOC))
2127b7ffbd7eSJohannes Berg 		sinfo->sta_flags.set |= BIT(NL80211_STA_FLAG_ASSOCIATED);
2128b7ffbd7eSJohannes Berg 	if (test_sta_flag(sta, WLAN_STA_TDLS_PEER))
2129b7ffbd7eSJohannes Berg 		sinfo->sta_flags.set |= BIT(NL80211_STA_FLAG_TDLS_PEER);
2130b7ffbd7eSJohannes Berg 
2131b7ffbd7eSJohannes Berg 	/* check if the driver has a SW RC implementation */
2132b7ffbd7eSJohannes Berg 	if (ref && ref->ops->get_expected_throughput)
2133b7ffbd7eSJohannes Berg 		thr = ref->ops->get_expected_throughput(sta->rate_ctrl_priv);
2134b7ffbd7eSJohannes Berg 	else
2135b7ffbd7eSJohannes Berg 		thr = drv_get_expected_throughput(local, &sta->sta);
2136b7ffbd7eSJohannes Berg 
2137b7ffbd7eSJohannes Berg 	if (thr != 0) {
2138319090bfSJohannes Berg 		sinfo->filled |= BIT(NL80211_STA_INFO_EXPECTED_THROUGHPUT);
2139b7ffbd7eSJohannes Berg 		sinfo->expected_throughput = thr;
2140b7ffbd7eSJohannes Berg 	}
2141b7ffbd7eSJohannes Berg }
2142