Lines Matching +full:local +full:- +full:timer +full:- +full:stop
5 * Copyright 2002-2005, Instant802 Networks, Inc.
6 * Copyright 2005-2006, Devicescape Software, Inc.
7 * Copyright 2006-2007 Jiri Benc <jbenc@suse.cz>
9 * Copyright 2007-2010, Intel Corporation
10 * Copyright(c) 2015-2017 Intel Deutschland GmbH
19 * DOC: RX A-MPDU aggregation
22 * @ampdu_action callback that is invoked to start/stop any
23 * block-ack sessions for RX aggregation.
32 * to de-aggregate frames and pass them up one by one to mac80211,
46 #include "driver-ops.h"
54 for (i = 0; i < tid_rx->buf_size; i++) in ieee80211_free_tid_rx()
55 __skb_queue_purge(&tid_rx->reorder_buf[i]); in ieee80211_free_tid_rx()
56 kfree(tid_rx->reorder_buf); in ieee80211_free_tid_rx()
57 kfree(tid_rx->reorder_time); in ieee80211_free_tid_rx()
64 struct ieee80211_local *local = sta->local; in ___ieee80211_stop_rx_ba_session() local
67 .sta = &sta->sta, in ___ieee80211_stop_rx_ba_session()
75 lockdep_assert_held(&sta->ampdu_mlme.mtx); in ___ieee80211_stop_rx_ba_session()
77 tid_rx = rcu_dereference_protected(sta->ampdu_mlme.tid_rx[tid], in ___ieee80211_stop_rx_ba_session()
78 lockdep_is_held(&sta->ampdu_mlme.mtx)); in ___ieee80211_stop_rx_ba_session()
80 if (!test_bit(tid, sta->ampdu_mlme.agg_session_valid)) in ___ieee80211_stop_rx_ba_session()
83 RCU_INIT_POINTER(sta->ampdu_mlme.tid_rx[tid], NULL); in ___ieee80211_stop_rx_ba_session()
84 __clear_bit(tid, sta->ampdu_mlme.agg_session_valid); in ___ieee80211_stop_rx_ba_session()
86 ht_dbg(sta->sdata, in ___ieee80211_stop_rx_ba_session()
87 "Rx BA session stop requested for %pM tid %u %s reason: %d\n", in ___ieee80211_stop_rx_ba_session()
88 sta->sta.addr, tid, in ___ieee80211_stop_rx_ba_session()
92 if (drv_ampdu_action(local, sta->sdata, ¶ms)) in ___ieee80211_stop_rx_ba_session()
93 sdata_info(sta->sdata, in ___ieee80211_stop_rx_ba_session()
94 "HW problem - can not stop rx aggregation for %pM tid %d\n", in ___ieee80211_stop_rx_ba_session()
95 sta->sta.addr, tid); in ___ieee80211_stop_rx_ba_session()
99 ieee80211_send_delba(sta->sdata, sta->sta.addr, in ___ieee80211_stop_rx_ba_session()
103 * return here in case tid_rx is not assigned - which will happen if in ___ieee80211_stop_rx_ba_session()
109 del_timer_sync(&tid_rx->session_timer); in ___ieee80211_stop_rx_ba_session()
111 /* make sure ieee80211_sta_reorder_release() doesn't re-arm the timer */ in ___ieee80211_stop_rx_ba_session()
112 spin_lock_bh(&tid_rx->reorder_lock); in ___ieee80211_stop_rx_ba_session()
113 tid_rx->removed = true; in ___ieee80211_stop_rx_ba_session()
114 spin_unlock_bh(&tid_rx->reorder_lock); in ___ieee80211_stop_rx_ba_session()
115 del_timer_sync(&tid_rx->reorder_timer); in ___ieee80211_stop_rx_ba_session()
117 call_rcu(&tid_rx->rcu_head, ieee80211_free_tid_rx); in ___ieee80211_stop_rx_ba_session()
123 mutex_lock(&sta->ampdu_mlme.mtx); in __ieee80211_stop_rx_ba_session()
125 mutex_unlock(&sta->ampdu_mlme.mtx); in __ieee80211_stop_rx_ba_session()
144 set_bit(i, sta->ampdu_mlme.tid_rx_stop_requested); in ieee80211_stop_rx_ba_session()
146 ieee80211_queue_work(&sta->local->hw, &sta->ampdu_mlme.work); in ieee80211_stop_rx_ba_session()
152 * After accepting the AddBA Request we activated a timer,
158 struct sta_info *sta = tid_rx->sta; in sta_rx_agg_session_timer_expired()
159 u8 tid = tid_rx->tid; in sta_rx_agg_session_timer_expired()
162 timeout = tid_rx->last_rx + TU_TO_JIFFIES(tid_rx->timeout); in sta_rx_agg_session_timer_expired()
164 mod_timer(&tid_rx->session_timer, timeout); in sta_rx_agg_session_timer_expired()
168 ht_dbg(sta->sdata, "RX session timer expired on %pM tid %d\n", in sta_rx_agg_session_timer_expired()
169 sta->sta.addr, tid); in sta_rx_agg_session_timer_expired()
171 set_bit(tid, sta->ampdu_mlme.tid_rx_timer_expired); in sta_rx_agg_session_timer_expired()
172 ieee80211_queue_work(&sta->local->hw, &sta->ampdu_mlme.work); in sta_rx_agg_session_timer_expired()
180 ieee80211_release_reorder_timeout(tid_rx->sta, tid_rx->tid); in sta_rx_agg_reorder_timer_expired()
188 struct ieee80211_local *local = sdata->local; in ieee80211_send_addba_resp() local
191 bool amsdu = ieee80211_hw_check(&local->hw, SUPPORTS_AMSDU_IN_AMPDU); in ieee80211_send_addba_resp()
194 skb = dev_alloc_skb(sizeof(*mgmt) + local->hw.extra_tx_headroom); in ieee80211_send_addba_resp()
198 skb_reserve(skb, local->hw.extra_tx_headroom); in ieee80211_send_addba_resp()
200 memcpy(mgmt->da, da, ETH_ALEN); in ieee80211_send_addba_resp()
201 memcpy(mgmt->sa, sdata->vif.addr, ETH_ALEN); in ieee80211_send_addba_resp()
202 if (sdata->vif.type == NL80211_IFTYPE_AP || in ieee80211_send_addba_resp()
203 sdata->vif.type == NL80211_IFTYPE_AP_VLAN || in ieee80211_send_addba_resp()
204 sdata->vif.type == NL80211_IFTYPE_MESH_POINT) in ieee80211_send_addba_resp()
205 memcpy(mgmt->bssid, sdata->vif.addr, ETH_ALEN); in ieee80211_send_addba_resp()
206 else if (sdata->vif.type == NL80211_IFTYPE_STATION) in ieee80211_send_addba_resp()
207 memcpy(mgmt->bssid, sdata->u.mgd.bssid, ETH_ALEN); in ieee80211_send_addba_resp()
208 else if (sdata->vif.type == NL80211_IFTYPE_ADHOC) in ieee80211_send_addba_resp()
209 memcpy(mgmt->bssid, sdata->u.ibss.bssid, ETH_ALEN); in ieee80211_send_addba_resp()
211 mgmt->frame_control = cpu_to_le16(IEEE80211_FTYPE_MGMT | in ieee80211_send_addba_resp()
214 skb_put(skb, 1 + sizeof(mgmt->u.action.u.addba_resp)); in ieee80211_send_addba_resp()
215 mgmt->u.action.category = WLAN_CATEGORY_BACK; in ieee80211_send_addba_resp()
216 mgmt->u.action.u.addba_resp.action_code = WLAN_ACTION_ADDBA_RESP; in ieee80211_send_addba_resp()
217 mgmt->u.action.u.addba_resp.dialog_token = dialog_token; in ieee80211_send_addba_resp()
219 capab = (u16)(amsdu << 0); /* bit 0 A-MSDU support */ in ieee80211_send_addba_resp()
224 mgmt->u.action.u.addba_resp.capab = cpu_to_le16(capab); in ieee80211_send_addba_resp()
225 mgmt->u.action.u.addba_resp.timeout = cpu_to_le16(timeout); in ieee80211_send_addba_resp()
226 mgmt->u.action.u.addba_resp.status = cpu_to_le16(status); in ieee80211_send_addba_resp()
236 struct ieee80211_local *local = sta->sdata->local; in ___ieee80211_start_rx_ba_session() local
239 .sta = &sta->sta, in ___ieee80211_start_rx_ba_session()
246 int i, ret = -EOPNOTSUPP; in ___ieee80211_start_rx_ba_session()
251 ht_dbg(sta->sdata, in ___ieee80211_start_rx_ba_session()
253 sta->sta.addr, tid); in ___ieee80211_start_rx_ba_session()
257 if (!sta->sta.ht_cap.ht_supported) { in ___ieee80211_start_rx_ba_session()
258 ht_dbg(sta->sdata, in ___ieee80211_start_rx_ba_session()
260 sta->sta.addr, tid); in ___ieee80211_start_rx_ba_session()
266 ht_dbg(sta->sdata, in ___ieee80211_start_rx_ba_session()
267 "Suspend in progress - Denying ADDBA request (%pM tid %d)\n", in ___ieee80211_start_rx_ba_session()
268 sta->sta.addr, tid); in ___ieee80211_start_rx_ba_session()
272 if (sta->sta.he_cap.has_he) in ___ieee80211_start_rx_ba_session()
282 (!(sta->sta.ht_cap.cap & IEEE80211_HT_CAP_DELAY_BA))) || in ___ieee80211_start_rx_ba_session()
285 ht_dbg_ratelimited(sta->sdata, in ___ieee80211_start_rx_ba_session()
287 sta->sta.addr, tid, ba_policy, buf_size); in ___ieee80211_start_rx_ba_session()
295 if (buf_size > sta->sta.max_rx_aggregation_subframes) in ___ieee80211_start_rx_ba_session()
296 buf_size = sta->sta.max_rx_aggregation_subframes; in ___ieee80211_start_rx_ba_session()
299 ht_dbg(sta->sdata, "AddBA Req buf_size=%d for %pM\n", in ___ieee80211_start_rx_ba_session()
300 buf_size, sta->sta.addr); in ___ieee80211_start_rx_ba_session()
303 lockdep_assert_held(&sta->ampdu_mlme.mtx); in ___ieee80211_start_rx_ba_session()
305 if (test_bit(tid, sta->ampdu_mlme.agg_session_valid)) { in ___ieee80211_start_rx_ba_session()
306 if (sta->ampdu_mlme.tid_rx_token[tid] == dialog_token) { in ___ieee80211_start_rx_ba_session()
309 ht_dbg_ratelimited(sta->sdata, in ___ieee80211_start_rx_ba_session()
311 sta->sta.addr, tid); in ___ieee80211_start_rx_ba_session()
318 tid_rx = rcu_dereference(sta->ampdu_mlme.tid_rx[tid]); in ___ieee80211_start_rx_ba_session()
319 if (tid_rx && tid_rx->timeout == timeout) in ___ieee80211_start_rx_ba_session()
327 ht_dbg_ratelimited(sta->sdata, in ___ieee80211_start_rx_ba_session()
329 sta->sta.addr, tid); in ___ieee80211_start_rx_ba_session()
337 if (ieee80211_hw_check(&local->hw, SUPPORTS_REORDERING_BUFFER)) { in ___ieee80211_start_rx_ba_session()
338 ret = drv_ampdu_action(local, sta->sdata, ¶ms); in ___ieee80211_start_rx_ba_session()
339 ht_dbg(sta->sdata, in ___ieee80211_start_rx_ba_session()
340 "Rx A-MPDU request on %pM tid %d result %d\n", in ___ieee80211_start_rx_ba_session()
341 sta->sta.addr, tid, ret); in ___ieee80211_start_rx_ba_session()
347 /* prepare A-MPDU MLME for Rx aggregation */ in ___ieee80211_start_rx_ba_session()
352 spin_lock_init(&tid_agg_rx->reorder_lock); in ___ieee80211_start_rx_ba_session()
354 /* rx timer */ in ___ieee80211_start_rx_ba_session()
355 timer_setup(&tid_agg_rx->session_timer, in ___ieee80211_start_rx_ba_session()
358 /* rx reorder timer */ in ___ieee80211_start_rx_ba_session()
359 timer_setup(&tid_agg_rx->reorder_timer, in ___ieee80211_start_rx_ba_session()
363 tid_agg_rx->reorder_buf = in ___ieee80211_start_rx_ba_session()
365 tid_agg_rx->reorder_time = in ___ieee80211_start_rx_ba_session()
367 if (!tid_agg_rx->reorder_buf || !tid_agg_rx->reorder_time) { in ___ieee80211_start_rx_ba_session()
368 kfree(tid_agg_rx->reorder_buf); in ___ieee80211_start_rx_ba_session()
369 kfree(tid_agg_rx->reorder_time); in ___ieee80211_start_rx_ba_session()
375 __skb_queue_head_init(&tid_agg_rx->reorder_buf[i]); in ___ieee80211_start_rx_ba_session()
377 ret = drv_ampdu_action(local, sta->sdata, ¶ms); in ___ieee80211_start_rx_ba_session()
378 ht_dbg(sta->sdata, "Rx A-MPDU request on %pM tid %d result %d\n", in ___ieee80211_start_rx_ba_session()
379 sta->sta.addr, tid, ret); in ___ieee80211_start_rx_ba_session()
381 kfree(tid_agg_rx->reorder_buf); in ___ieee80211_start_rx_ba_session()
382 kfree(tid_agg_rx->reorder_time); in ___ieee80211_start_rx_ba_session()
388 tid_agg_rx->ssn = start_seq_num; in ___ieee80211_start_rx_ba_session()
389 tid_agg_rx->head_seq_num = start_seq_num; in ___ieee80211_start_rx_ba_session()
390 tid_agg_rx->buf_size = buf_size; in ___ieee80211_start_rx_ba_session()
391 tid_agg_rx->timeout = timeout; in ___ieee80211_start_rx_ba_session()
392 tid_agg_rx->stored_mpdu_num = 0; in ___ieee80211_start_rx_ba_session()
393 tid_agg_rx->auto_seq = auto_seq; in ___ieee80211_start_rx_ba_session()
394 tid_agg_rx->started = false; in ___ieee80211_start_rx_ba_session()
395 tid_agg_rx->reorder_buf_filtered = 0; in ___ieee80211_start_rx_ba_session()
396 tid_agg_rx->tid = tid; in ___ieee80211_start_rx_ba_session()
397 tid_agg_rx->sta = sta; in ___ieee80211_start_rx_ba_session()
401 rcu_assign_pointer(sta->ampdu_mlme.tid_rx[tid], tid_agg_rx); in ___ieee80211_start_rx_ba_session()
404 mod_timer(&tid_agg_rx->session_timer, TU_TO_EXP_TIME(timeout)); in ___ieee80211_start_rx_ba_session()
405 tid_agg_rx->last_rx = jiffies; in ___ieee80211_start_rx_ba_session()
410 __set_bit(tid, sta->ampdu_mlme.agg_session_valid); in ___ieee80211_start_rx_ba_session()
411 __clear_bit(tid, sta->ampdu_mlme.unexpected_agg); in ___ieee80211_start_rx_ba_session()
412 sta->ampdu_mlme.tid_rx_token[tid] = dialog_token; in ___ieee80211_start_rx_ba_session()
416 ieee80211_send_addba_resp(sta->sdata, sta->sta.addr, tid, in ___ieee80211_start_rx_ba_session()
427 mutex_lock(&sta->ampdu_mlme.mtx); in __ieee80211_start_rx_ba_session()
431 mutex_unlock(&sta->ampdu_mlme.mtx); in __ieee80211_start_rx_ba_session()
434 void ieee80211_process_addba_request(struct ieee80211_local *local, in ieee80211_process_addba_request() argument
443 dialog_token = mgmt->u.action.u.addba_req.dialog_token; in ieee80211_process_addba_request()
444 timeout = le16_to_cpu(mgmt->u.action.u.addba_req.timeout); in ieee80211_process_addba_request()
446 le16_to_cpu(mgmt->u.action.u.addba_req.start_seq_num) >> 4; in ieee80211_process_addba_request()
448 capab = le16_to_cpu(mgmt->u.action.u.addba_req.capab); in ieee80211_process_addba_request()
462 struct ieee80211_local *local = sdata->local; in ieee80211_manage_rx_ba_offl() local
470 set_bit(tid, sta->ampdu_mlme.tid_rx_manage_offl); in ieee80211_manage_rx_ba_offl()
471 ieee80211_queue_work(&local->hw, &sta->ampdu_mlme.work); in ieee80211_manage_rx_ba_offl()
481 struct ieee80211_local *local = sdata->local; in ieee80211_rx_ba_timer_expired() local
489 set_bit(tid, sta->ampdu_mlme.tid_rx_timer_expired); in ieee80211_rx_ba_timer_expired()
490 ieee80211_queue_work(&local->hw, &sta->ampdu_mlme.work); in ieee80211_rx_ba_timer_expired()