Lines Matching +full:local +full:- +full:timer +full:- +full:stop
1 // SPDX-License-Identifier: GPL-2.0-only
6 * Copyright 2002-2005, Instant802 Networks, Inc.
7 * Copyright 2005-2006, Devicescape Software, Inc.
8 * Copyright 2006-2007 Jiri Benc <jbenc@suse.cz>
10 * Copyright 2007-2010, Intel Corporation
11 * Copyright(c) 2015-2017 Intel Deutschland GmbH
12 * Copyright (C) 2018-2024 Intel Corporation
16 * DOC: RX A-MPDU aggregation
19 * @ampdu_action callback that is invoked to start/stop any
20 * block-ack sessions for RX aggregation.
29 * to de-aggregate frames and pass them up one by one to mac80211,
43 #include "driver-ops.h"
51 for (i = 0; i < tid_rx->buf_size; i++) in ieee80211_free_tid_rx()
52 __skb_queue_purge(&tid_rx->reorder_buf[i]); in ieee80211_free_tid_rx()
53 kfree(tid_rx->reorder_buf); in ieee80211_free_tid_rx()
54 kfree(tid_rx->reorder_time); in ieee80211_free_tid_rx()
61 struct ieee80211_local *local = sta->local; in __ieee80211_stop_rx_ba_session() local
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()
84 "Rx BA session stop requested for %pM tid %u %s reason: %d\n", 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, ¶ms)) in __ieee80211_stop_rx_ba_session()
90 sdata_info(sta->sdata, in __ieee80211_stop_rx_ba_session()
91 "HW problem - can not stop rx aggregation for %pM tid %d\n", 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()
100 * return here in case tid_rx is not assigned - which will happen if in __ieee80211_stop_rx_ba_session()
106 timer_delete_sync(&tid_rx->session_timer); in __ieee80211_stop_rx_ba_session()
108 /* make sure ieee80211_sta_reorder_release() doesn't re-arm the timer */ in __ieee80211_stop_rx_ba_session()
109 spin_lock_bh(&tid_rx->reorder_lock); in __ieee80211_stop_rx_ba_session()
110 tid_rx->removed = true; in __ieee80211_stop_rx_ba_session()
111 spin_unlock_bh(&tid_rx->reorder_lock); in __ieee80211_stop_rx_ba_session()
112 timer_delete_sync(&tid_rx->reorder_timer); in __ieee80211_stop_rx_ba_session()
114 call_rcu(&tid_rx->rcu_head, ieee80211_free_tid_rx); 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()
141 * After accepting the AddBA Request we activated a timer,
147 struct sta_info *sta = tid_rx->sta; in sta_rx_agg_session_timer_expired()
148 u8 tid = tid_rx->tid; in sta_rx_agg_session_timer_expired()
151 timeout = tid_rx->last_rx + TU_TO_JIFFIES(tid_rx->timeout); in sta_rx_agg_session_timer_expired()
153 mod_timer(&tid_rx->session_timer, timeout); in sta_rx_agg_session_timer_expired()
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()
185 addba_ext->data = IEEE80211_ADDBA_EXT_NO_FRAG; in ieee80211_add_addbaext()
187 addba_ext->data &= req_addba_ext_data; in ieee80211_add_addbaext()
189 addba_ext->data |= in ieee80211_add_addbaext()
201 if (!sta->sta.deflink.he_cap.has_he) in ieee80211_retrieve_addba_ext_data()
209 if (!elems || elems->parse_error || !elems->addba_ext_ie) in ieee80211_retrieve_addba_ext_data()
212 data = elems->addba_ext_ie->data; in ieee80211_retrieve_addba_ext_data()
215 (sta->sta.valid_links || sta->sta.deflink.eht_cap.has_eht)) { in ieee80211_retrieve_addba_ext_data()
216 buf_size_1k = u8_get_bits(elems->addba_ext_ie->data, in ieee80211_retrieve_addba_ext_data()
233 struct ieee80211_sub_if_data *sdata = sta->sdata; in ieee80211_send_addba_resp()
234 struct ieee80211_local *local = sdata->local; in ieee80211_send_addba_resp() local
237 bool amsdu = ieee80211_hw_check(&local->hw, SUPPORTS_AMSDU_IN_AMPDU); in ieee80211_send_addba_resp()
242 local->hw.extra_tx_headroom); in ieee80211_send_addba_resp()
246 skb_reserve(skb, local->hw.extra_tx_headroom); in ieee80211_send_addba_resp()
249 skb_put(skb, 1 + sizeof(mgmt->u.action.u.addba_resp)); in ieee80211_send_addba_resp()
250 mgmt->u.action.category = WLAN_CATEGORY_BACK; in ieee80211_send_addba_resp()
251 mgmt->u.action.u.addba_resp.action_code = WLAN_ACTION_ADDBA_RESP; in ieee80211_send_addba_resp()
252 mgmt->u.action.u.addba_resp.dialog_token = dialog_token; in ieee80211_send_addba_resp()
259 mgmt->u.action.u.addba_resp.capab = cpu_to_le16(capab); in ieee80211_send_addba_resp()
260 mgmt->u.action.u.addba_resp.timeout = cpu_to_le16(timeout); in ieee80211_send_addba_resp()
261 mgmt->u.action.u.addba_resp.status = cpu_to_le16(status); in ieee80211_send_addba_resp()
263 if (sta->sta.valid_links || sta->sta.deflink.he_cap.has_he) in ieee80211_send_addba_resp()
275 struct ieee80211_local *local = sta->sdata->local; in __ieee80211_start_rx_ba_session() local
278 .sta = &sta->sta, in __ieee80211_start_rx_ba_session()
285 int i, ret = -EOPNOTSUPP; in __ieee80211_start_rx_ba_session()
289 lockdep_assert_wiphy(sta->local->hw.wiphy); in __ieee80211_start_rx_ba_session()
292 ht_dbg(sta->sdata, in __ieee80211_start_rx_ba_session()
294 sta->sta.addr, tid); in __ieee80211_start_rx_ba_session()
298 if (!sta->sta.valid_links && in __ieee80211_start_rx_ba_session()
299 !sta->sta.deflink.ht_cap.ht_supported && in __ieee80211_start_rx_ba_session()
300 !sta->sta.deflink.he_cap.has_he) { in __ieee80211_start_rx_ba_session()
301 ht_dbg(sta->sdata, in __ieee80211_start_rx_ba_session()
303 sta->sta.addr, tid); in __ieee80211_start_rx_ba_session()
309 ht_dbg(sta->sdata, in __ieee80211_start_rx_ba_session()
310 "Suspend in progress - Denying ADDBA request (%pM tid %d)\n", in __ieee80211_start_rx_ba_session()
311 sta->sta.addr, tid); in __ieee80211_start_rx_ba_session()
315 if (sta->sta.valid_links || sta->sta.deflink.eht_cap.has_eht) in __ieee80211_start_rx_ba_session()
317 else if (sta->sta.deflink.he_cap.has_he) in __ieee80211_start_rx_ba_session()
327 (sta->sta.valid_links || in __ieee80211_start_rx_ba_session()
328 !(sta->sta.deflink.ht_cap.cap & IEEE80211_HT_CAP_DELAY_BA))) || in __ieee80211_start_rx_ba_session()
331 ht_dbg_ratelimited(sta->sdata, in __ieee80211_start_rx_ba_session()
333 sta->sta.addr, tid, ba_policy, buf_size); in __ieee80211_start_rx_ba_session()
341 if (buf_size > sta->sta.max_rx_aggregation_subframes) in __ieee80211_start_rx_ba_session()
342 buf_size = sta->sta.max_rx_aggregation_subframes; in __ieee80211_start_rx_ba_session()
345 ht_dbg(sta->sdata, "AddBA Req buf_size=%d for %pM\n", in __ieee80211_start_rx_ba_session()
346 buf_size, sta->sta.addr); in __ieee80211_start_rx_ba_session()
348 if (test_bit(tid, sta->ampdu_mlme.agg_session_valid)) { in __ieee80211_start_rx_ba_session()
349 if (sta->ampdu_mlme.tid_rx_token[tid] == dialog_token) { in __ieee80211_start_rx_ba_session()
352 ht_dbg_ratelimited(sta->sdata, in __ieee80211_start_rx_ba_session()
354 sta->sta.addr, tid); in __ieee80211_start_rx_ba_session()
361 tid_rx = rcu_dereference(sta->ampdu_mlme.tid_rx[tid]); in __ieee80211_start_rx_ba_session()
362 if (tid_rx && tid_rx->timeout == timeout) in __ieee80211_start_rx_ba_session()
370 ht_dbg_ratelimited(sta->sdata, in __ieee80211_start_rx_ba_session()
372 sta->sta.addr, tid); in __ieee80211_start_rx_ba_session()
380 if (ieee80211_hw_check(&local->hw, SUPPORTS_REORDERING_BUFFER)) { in __ieee80211_start_rx_ba_session()
381 ret = drv_ampdu_action(local, sta->sdata, ¶ms); in __ieee80211_start_rx_ba_session()
382 ht_dbg(sta->sdata, in __ieee80211_start_rx_ba_session()
383 "Rx A-MPDU request on %pM tid %d result %d\n", in __ieee80211_start_rx_ba_session()
384 sta->sta.addr, tid, ret); in __ieee80211_start_rx_ba_session()
390 /* prepare A-MPDU MLME for Rx aggregation */ in __ieee80211_start_rx_ba_session()
395 spin_lock_init(&tid_agg_rx->reorder_lock); in __ieee80211_start_rx_ba_session()
397 /* rx timer */ in __ieee80211_start_rx_ba_session()
398 timer_setup(&tid_agg_rx->session_timer, in __ieee80211_start_rx_ba_session()
401 /* rx reorder timer */ in __ieee80211_start_rx_ba_session()
402 timer_setup(&tid_agg_rx->reorder_timer, in __ieee80211_start_rx_ba_session()
406 tid_agg_rx->reorder_buf = in __ieee80211_start_rx_ba_session()
408 tid_agg_rx->reorder_time = in __ieee80211_start_rx_ba_session()
410 if (!tid_agg_rx->reorder_buf || !tid_agg_rx->reorder_time) { in __ieee80211_start_rx_ba_session()
411 kfree(tid_agg_rx->reorder_buf); in __ieee80211_start_rx_ba_session()
412 kfree(tid_agg_rx->reorder_time); in __ieee80211_start_rx_ba_session()
418 __skb_queue_head_init(&tid_agg_rx->reorder_buf[i]); in __ieee80211_start_rx_ba_session()
420 ret = drv_ampdu_action(local, sta->sdata, ¶ms); in __ieee80211_start_rx_ba_session()
421 ht_dbg(sta->sdata, "Rx A-MPDU request on %pM tid %d result %d\n", in __ieee80211_start_rx_ba_session()
422 sta->sta.addr, tid, ret); in __ieee80211_start_rx_ba_session()
424 kfree(tid_agg_rx->reorder_buf); in __ieee80211_start_rx_ba_session()
425 kfree(tid_agg_rx->reorder_time); in __ieee80211_start_rx_ba_session()
431 tid_agg_rx->ssn = start_seq_num; in __ieee80211_start_rx_ba_session()
432 tid_agg_rx->head_seq_num = start_seq_num; in __ieee80211_start_rx_ba_session()
433 tid_agg_rx->buf_size = buf_size; in __ieee80211_start_rx_ba_session()
434 tid_agg_rx->timeout = timeout; in __ieee80211_start_rx_ba_session()
435 tid_agg_rx->stored_mpdu_num = 0; in __ieee80211_start_rx_ba_session()
436 tid_agg_rx->auto_seq = auto_seq; in __ieee80211_start_rx_ba_session()
437 tid_agg_rx->started = false; in __ieee80211_start_rx_ba_session()
438 tid_agg_rx->reorder_buf_filtered = 0; in __ieee80211_start_rx_ba_session()
439 tid_agg_rx->tid = tid; in __ieee80211_start_rx_ba_session()
440 tid_agg_rx->sta = sta; in __ieee80211_start_rx_ba_session()
444 rcu_assign_pointer(sta->ampdu_mlme.tid_rx[tid], tid_agg_rx); in __ieee80211_start_rx_ba_session()
447 mod_timer(&tid_agg_rx->session_timer, TU_TO_EXP_TIME(timeout)); in __ieee80211_start_rx_ba_session()
448 tid_agg_rx->last_rx = jiffies; in __ieee80211_start_rx_ba_session()
453 __set_bit(tid, sta->ampdu_mlme.agg_session_valid); in __ieee80211_start_rx_ba_session()
454 __clear_bit(tid, sta->ampdu_mlme.unexpected_agg); in __ieee80211_start_rx_ba_session()
455 sta->ampdu_mlme.tid_rx_token[tid] = dialog_token; in __ieee80211_start_rx_ba_session()
459 ieee80211_send_addba_resp(sta, sta->sta.addr, tid, in __ieee80211_start_rx_ba_session()
464 void ieee80211_process_addba_request(struct ieee80211_local *local, in ieee80211_process_addba_request() argument
473 dialog_token = mgmt->u.action.u.addba_req.dialog_token; in ieee80211_process_addba_request()
474 timeout = le16_to_cpu(mgmt->u.action.u.addba_req.timeout); in ieee80211_process_addba_request()
476 le16_to_cpu(mgmt->u.action.u.addba_req.start_seq_num) >> 4; in ieee80211_process_addba_request()
478 capab = le16_to_cpu(mgmt->u.action.u.addba_req.capab); in ieee80211_process_addba_request()
485 mgmt->u.action.u.addba_req.variable, in ieee80211_process_addba_request()
486 len - in ieee80211_process_addba_request()
507 set_bit(tid, sta->ampdu_mlme.tid_rx_manage_offl); in ieee80211_manage_rx_ba_offl()
508 wiphy_work_queue(sta->local->hw.wiphy, &sta->ampdu_mlme.work); in ieee80211_manage_rx_ba_offl()
525 set_bit(tid, sta->ampdu_mlme.tid_rx_timer_expired); in ieee80211_rx_ba_timer_expired()
526 wiphy_work_queue(sta->local->hw.wiphy, &sta->ampdu_mlme.work); in ieee80211_rx_ba_timer_expired()