58 void __ieee80211_stop_rx_ba_session(struct sta_info *sta, u16 tid,  in __ieee80211_stop_rx_ba_session()  argument
61 	struct ieee80211_local *local = sta->local;  in __ieee80211_stop_rx_ba_session()
64 		.sta = &sta->sta,  in __ieee80211_stop_rx_ba_session()
72 	lockdep_assert_wiphy(sta->local->hw.wiphy);  in __ieee80211_stop_rx_ba_session()
74 	tid_rx = rcu_dereference_protected(sta->ampdu_mlme.tid_rx[tid],  in __ieee80211_stop_rx_ba_session()
75 					lockdep_is_held(&sta->local->hw.wiphy->mtx));  in __ieee80211_stop_rx_ba_session()
77 	if (!test_bit(tid, sta->ampdu_mlme.agg_session_valid))  in __ieee80211_stop_rx_ba_session()
80 	RCU_INIT_POINTER(sta->ampdu_mlme.tid_rx[tid], NULL);  in __ieee80211_stop_rx_ba_session()
81 	__clear_bit(tid, sta->ampdu_mlme.agg_session_valid);  in __ieee80211_stop_rx_ba_session()
83 	ht_dbg(sta->sdata,  in __ieee80211_stop_rx_ba_session()
85 	       sta->sta.addr, tid,  in __ieee80211_stop_rx_ba_session()
89 	if (drv_ampdu_action(local, sta->sdata, &params))  in __ieee80211_stop_rx_ba_session()
90 		sdata_info(sta->sdata,  in __ieee80211_stop_rx_ba_session()
92 			   sta->sta.addr, tid);  in __ieee80211_stop_rx_ba_session()
96 		ieee80211_send_delba(sta->sdata, sta->sta.addr,  in __ieee80211_stop_rx_ba_session()
121 	struct sta_info *sta;  in ieee80211_stop_rx_ba_session()  local
125 	sta = sta_info_get_bss(sdata, addr);  in ieee80211_stop_rx_ba_session()
126 	if (!sta) {  in ieee80211_stop_rx_ba_session()
133 			set_bit(i, sta->ampdu_mlme.tid_rx_stop_requested);  in ieee80211_stop_rx_ba_session()
135 	wiphy_work_queue(sta->local->hw.wiphy, &sta->ampdu_mlme.work);  in ieee80211_stop_rx_ba_session()
147 	struct sta_info *sta = tid_rx->sta;  in sta_rx_agg_session_timer_expired()  local
157 	ht_dbg(sta->sdata, "RX session timer expired on %pM tid %d\n",  in sta_rx_agg_session_timer_expired()
158 	       sta->sta.addr, tid);  in sta_rx_agg_session_timer_expired()
160 	set_bit(tid, sta->ampdu_mlme.tid_rx_timer_expired);  in sta_rx_agg_session_timer_expired()
161 	wiphy_work_queue(sta->local->hw.wiphy, &sta->ampdu_mlme.work);  in sta_rx_agg_session_timer_expired()
169 	ieee80211_release_reorder_timeout(tid_rx->sta, tid_rx->tid);  in sta_rx_agg_reorder_timer_expired()
191 static void ieee80211_send_addba_resp(struct sta_info *sta, u8 *da, u16 tid,  in ieee80211_send_addba_resp()  argument
196 	struct ieee80211_sub_if_data *sdata = sta->sdata;  in ieee80211_send_addba_resp()
226 	if (sta->sta.deflink.he_cap.has_he && addbaext)  in ieee80211_send_addba_resp()
232 void __ieee80211_start_rx_ba_session(struct sta_info *sta,  in __ieee80211_start_rx_ba_session()  argument
238 	struct ieee80211_local *local = sta->sdata->local;  in __ieee80211_start_rx_ba_session()
241 		.sta = &sta->sta,  in __ieee80211_start_rx_ba_session()
252 	lockdep_assert_wiphy(sta->local->hw.wiphy);  in __ieee80211_start_rx_ba_session()
255 		ht_dbg(sta->sdata,  in __ieee80211_start_rx_ba_session()
257 		       sta->sta.addr, tid);  in __ieee80211_start_rx_ba_session()
261 	if (!sta->sta.deflink.ht_cap.ht_supported &&  in __ieee80211_start_rx_ba_session()
262 	    !sta->sta.deflink.he_cap.has_he) {  in __ieee80211_start_rx_ba_session()
263 		ht_dbg(sta->sdata,  in __ieee80211_start_rx_ba_session()
265 		       sta->sta.addr, tid);  in __ieee80211_start_rx_ba_session()
270 	if (test_sta_flag(sta, WLAN_STA_BLOCK_BA)) {  in __ieee80211_start_rx_ba_session()
271 		ht_dbg(sta->sdata,  in __ieee80211_start_rx_ba_session()
273 		       sta->sta.addr, tid);  in __ieee80211_start_rx_ba_session()
277 	if (sta->sta.deflink.eht_cap.has_eht)  in __ieee80211_start_rx_ba_session()
279 	else if (sta->sta.deflink.he_cap.has_he)  in __ieee80211_start_rx_ba_session()
289 	     (!(sta->sta.deflink.ht_cap.cap & IEEE80211_HT_CAP_DELAY_BA))) ||  in __ieee80211_start_rx_ba_session()
292 		ht_dbg_ratelimited(sta->sdata,  in __ieee80211_start_rx_ba_session()
294 				   sta->sta.addr, tid, ba_policy, buf_size);  in __ieee80211_start_rx_ba_session()
302 	if (buf_size > sta->sta.max_rx_aggregation_subframes)  in __ieee80211_start_rx_ba_session()
303 		buf_size = sta->sta.max_rx_aggregation_subframes;  in __ieee80211_start_rx_ba_session()
306 	ht_dbg(sta->sdata, "AddBA Req buf_size=%d for %pM\n",  in __ieee80211_start_rx_ba_session()
307 	       buf_size, sta->sta.addr);  in __ieee80211_start_rx_ba_session()
309 	if (test_bit(tid, sta->ampdu_mlme.agg_session_valid)) {  in __ieee80211_start_rx_ba_session()
310 		if (sta->ampdu_mlme.tid_rx_token[tid] == dialog_token) {  in __ieee80211_start_rx_ba_session()
313 			ht_dbg_ratelimited(sta->sdata,  in __ieee80211_start_rx_ba_session()
315 					   sta->sta.addr, tid);  in __ieee80211_start_rx_ba_session()
322 			tid_rx = rcu_dereference(sta->ampdu_mlme.tid_rx[tid]);  in __ieee80211_start_rx_ba_session()
331 		ht_dbg_ratelimited(sta->sdata,  in __ieee80211_start_rx_ba_session()
333 				   sta->sta.addr, tid);  in __ieee80211_start_rx_ba_session()
336 		__ieee80211_stop_rx_ba_session(sta, tid, WLAN_BACK_RECIPIENT,  in __ieee80211_start_rx_ba_session()
342 		ret = drv_ampdu_action(local, sta->sdata, &params);  in __ieee80211_start_rx_ba_session()
343 		ht_dbg(sta->sdata,  in __ieee80211_start_rx_ba_session()
345 		       sta->sta.addr, tid, ret);  in __ieee80211_start_rx_ba_session()
381 	ret = drv_ampdu_action(local, sta->sdata, &params);  in __ieee80211_start_rx_ba_session()
382 	ht_dbg(sta->sdata, "Rx A-MPDU request on %pM tid %d result %d\n",  in __ieee80211_start_rx_ba_session()
383 	       sta->sta.addr, tid, ret);  in __ieee80211_start_rx_ba_session()
401 	tid_agg_rx->sta = sta;  in __ieee80211_start_rx_ba_session()
405 	rcu_assign_pointer(sta->ampdu_mlme.tid_rx[tid], tid_agg_rx);  in __ieee80211_start_rx_ba_session()
414 		__set_bit(tid, sta->ampdu_mlme.agg_session_valid);  in __ieee80211_start_rx_ba_session()
415 		__clear_bit(tid, sta->ampdu_mlme.unexpected_agg);  in __ieee80211_start_rx_ba_session()
416 		sta->ampdu_mlme.tid_rx_token[tid] = dialog_token;  in __ieee80211_start_rx_ba_session()
420 		ieee80211_send_addba_resp(sta, sta->sta.addr, tid,  in __ieee80211_start_rx_ba_session()
426 				     struct sta_info *sta,  in ieee80211_process_addba_request()  argument
455 	if (sta->sta.deflink.eht_cap.has_eht && elems && elems->addba_ext_ie) {  in ieee80211_process_addba_request()
462 	__ieee80211_start_rx_ba_session(sta, dialog_token, timeout,  in ieee80211_process_addba_request()
474 	struct sta_info *sta;  in ieee80211_manage_rx_ba_offl()  local
477 	sta = sta_info_get_bss(sdata, addr);  in ieee80211_manage_rx_ba_offl()
478 	if (!sta)  in ieee80211_manage_rx_ba_offl()
481 	set_bit(tid, sta->ampdu_mlme.tid_rx_manage_offl);  in ieee80211_manage_rx_ba_offl()
482 	wiphy_work_queue(sta->local->hw.wiphy, &sta->ampdu_mlme.work);  in ieee80211_manage_rx_ba_offl()
492 	struct sta_info *sta;  in ieee80211_rx_ba_timer_expired()  local
495 	sta = sta_info_get_bss(sdata, addr);  in ieee80211_rx_ba_timer_expired()
496 	if (!sta)  in ieee80211_rx_ba_timer_expired()
499 	set_bit(tid, sta->ampdu_mlme.tid_rx_timer_expired);  in ieee80211_rx_ba_timer_expired()
500 	wiphy_work_queue(sta->local->hw.wiphy, &sta->ampdu_mlme.work);  in ieee80211_rx_ba_timer_expired()