Lines Matching refs:sta
146 void ieee80211_assign_tid_tx(struct sta_info *sta, int tid, in ieee80211_assign_tid_tx() argument
149 lockdep_assert_held(&sta->ampdu_mlme.mtx); in ieee80211_assign_tid_tx()
150 lockdep_assert_held(&sta->lock); in ieee80211_assign_tid_tx()
151 rcu_assign_pointer(sta->ampdu_mlme.tid_tx[tid], tid_tx); in ieee80211_assign_tid_tx()
194 ieee80211_agg_stop_txq(struct sta_info *sta, int tid) in ieee80211_agg_stop_txq() argument
196 struct ieee80211_txq *txq = sta->sta.txq[tid]; in ieee80211_agg_stop_txq()
215 ieee80211_agg_start_txq(struct sta_info *sta, int tid, bool enable) in ieee80211_agg_start_txq() argument
217 struct ieee80211_txq *txq = sta->sta.txq[tid]; in ieee80211_agg_start_txq()
231 drv_wake_tx_queue(sta->sdata->local, txqi); in ieee80211_agg_start_txq()
268 static void ieee80211_remove_tid_tx(struct sta_info *sta, int tid) in ieee80211_remove_tid_tx() argument
272 lockdep_assert_held(&sta->ampdu_mlme.mtx); in ieee80211_remove_tid_tx()
273 lockdep_assert_held(&sta->lock); in ieee80211_remove_tid_tx()
275 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_remove_tid_tx()
287 ieee80211_agg_splice_packets(sta->sdata, tid_tx, tid); in ieee80211_remove_tid_tx()
290 ieee80211_assign_tid_tx(sta, tid, NULL); in ieee80211_remove_tid_tx()
292 ieee80211_agg_splice_finish(sta->sdata, tid); in ieee80211_remove_tid_tx()
293 ieee80211_agg_start_txq(sta, tid, false); in ieee80211_remove_tid_tx()
298 int ___ieee80211_stop_tx_ba_session(struct sta_info *sta, u16 tid, in ___ieee80211_stop_tx_ba_session() argument
301 struct ieee80211_local *local = sta->local; in ___ieee80211_stop_tx_ba_session()
304 .sta = &sta->sta, in ___ieee80211_stop_tx_ba_session()
313 lockdep_assert_held(&sta->ampdu_mlme.mtx); in ___ieee80211_stop_tx_ba_session()
329 spin_lock_bh(&sta->lock); in ___ieee80211_stop_tx_ba_session()
331 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ___ieee80211_stop_tx_ba_session()
333 spin_unlock_bh(&sta->lock); in ___ieee80211_stop_tx_ba_session()
342 spin_unlock_bh(&sta->lock); in ___ieee80211_stop_tx_ba_session()
346 ret = drv_ampdu_action(local, sta->sdata, ¶ms); in ___ieee80211_stop_tx_ba_session()
353 ieee80211_assign_tid_tx(sta, tid, NULL); in ___ieee80211_stop_tx_ba_session()
354 spin_unlock_bh(&sta->lock); in ___ieee80211_stop_tx_ba_session()
361 spin_unlock_bh(&sta->lock); in ___ieee80211_stop_tx_ba_session()
363 ht_dbg(sta->sdata, "Tx BA session stop requested for %pM tid %u\n", in ___ieee80211_stop_tx_ba_session()
364 sta->sta.addr, tid); in ___ieee80211_stop_tx_ba_session()
395 ret = drv_ampdu_action(local, sta->sdata, ¶ms); in ___ieee80211_stop_tx_ba_session()
430 struct sta_info *sta = container_of((void *)data, in sta_addba_resp_timer_expired() local
436 tid_tx = rcu_dereference(sta->ampdu_mlme.tid_tx[tid]); in sta_addba_resp_timer_expired()
440 ht_dbg(sta->sdata, in sta_addba_resp_timer_expired()
442 sta->sta.addr, tid); in sta_addba_resp_timer_expired()
446 ht_dbg(sta->sdata, "addBA response timer expired on %pM tid %d\n", in sta_addba_resp_timer_expired()
447 sta->sta.addr, tid); in sta_addba_resp_timer_expired()
449 ieee80211_stop_tx_ba_session(&sta->sta, tid); in sta_addba_resp_timer_expired()
453 void ieee80211_tx_ba_session_handle_start(struct sta_info *sta, int tid) in ieee80211_tx_ba_session_handle_start() argument
456 struct ieee80211_local *local = sta->local; in ieee80211_tx_ba_session_handle_start()
457 struct ieee80211_sub_if_data *sdata = sta->sdata; in ieee80211_tx_ba_session_handle_start()
459 .sta = &sta->sta, in ieee80211_tx_ba_session_handle_start()
468 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_tx_ba_session_handle_start()
477 ieee80211_agg_stop_txq(sta, tid); in ieee80211_tx_ba_session_handle_start()
487 params.ssn = sta->tid_seq[tid] >> 4; in ieee80211_tx_ba_session_handle_start()
492 sta->sta.addr, tid); in ieee80211_tx_ba_session_handle_start()
493 spin_lock_bh(&sta->lock); in ieee80211_tx_ba_session_handle_start()
495 ieee80211_assign_tid_tx(sta, tid, NULL); in ieee80211_tx_ba_session_handle_start()
497 spin_unlock_bh(&sta->lock); in ieee80211_tx_ba_session_handle_start()
499 ieee80211_agg_start_txq(sta, tid, false); in ieee80211_tx_ba_session_handle_start()
508 sta->sta.addr, tid); in ieee80211_tx_ba_session_handle_start()
510 spin_lock_bh(&sta->lock); in ieee80211_tx_ba_session_handle_start()
511 sta->ampdu_mlme.last_addba_req_time[tid] = jiffies; in ieee80211_tx_ba_session_handle_start()
512 sta->ampdu_mlme.addba_req_num[tid]++; in ieee80211_tx_ba_session_handle_start()
513 spin_unlock_bh(&sta->lock); in ieee80211_tx_ba_session_handle_start()
516 ieee80211_send_addba_request(sdata, sta->sta.addr, tid, in ieee80211_tx_ba_session_handle_start()
534 struct sta_info *sta = container_of(timer_to_id, struct sta_info, in sta_tx_agg_session_timer_expired() local
540 tid_tx = rcu_dereference(sta->ampdu_mlme.tid_tx[*ptid]); in sta_tx_agg_session_timer_expired()
555 ht_dbg(sta->sdata, "tx session timer expired on %pM tid %d\n", in sta_tx_agg_session_timer_expired()
556 sta->sta.addr, (u16)*ptid); in sta_tx_agg_session_timer_expired()
558 ieee80211_stop_tx_ba_session(&sta->sta, *ptid); in sta_tx_agg_session_timer_expired()
564 struct sta_info *sta = container_of(pubsta, struct sta_info, sta); in ieee80211_start_tx_ba_session() local
565 struct ieee80211_sub_if_data *sdata = sta->sdata; in ieee80211_start_tx_ba_session()
572 if (WARN(sta->reserved_tid == tid, in ieee80211_start_tx_ba_session()
600 if (test_sta_flag(sta, WLAN_STA_BLOCK_BA)) { in ieee80211_start_tx_ba_session()
603 sta->sta.addr, tid); in ieee80211_start_tx_ba_session()
619 if (sta->sdata->vif.type == NL80211_IFTYPE_ADHOC && in ieee80211_start_tx_ba_session()
620 !sta->sta.ht_cap.ht_supported) { in ieee80211_start_tx_ba_session()
627 spin_lock_bh(&sta->lock); in ieee80211_start_tx_ba_session()
630 if (sta->ampdu_mlme.addba_req_num[tid] > HT_AGG_MAX_RETRIES) { in ieee80211_start_tx_ba_session()
640 if (sta->ampdu_mlme.addba_req_num[tid] > HT_AGG_BURST_RETRIES && in ieee80211_start_tx_ba_session()
641 time_before(jiffies, sta->ampdu_mlme.last_addba_req_time[tid] + in ieee80211_start_tx_ba_session()
645 sta->ampdu_mlme.addba_req_num[tid], sta->sta.addr, tid); in ieee80211_start_tx_ba_session()
650 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_start_tx_ba_session()
652 if (tid_tx || sta->ampdu_mlme.tid_start_tx[tid]) { in ieee80211_start_tx_ba_session()
655 sta->sta.addr, tid); in ieee80211_start_tx_ba_session()
674 tid_tx->addba_resp_timer.data = (unsigned long)&sta->timer_to_tid[tid]; in ieee80211_start_tx_ba_session()
679 tid_tx->session_timer.data = (unsigned long)&sta->timer_to_tid[tid]; in ieee80211_start_tx_ba_session()
683 sta->ampdu_mlme.dialog_token_allocator++; in ieee80211_start_tx_ba_session()
684 tid_tx->dialog_token = sta->ampdu_mlme.dialog_token_allocator; in ieee80211_start_tx_ba_session()
690 sta->ampdu_mlme.tid_start_tx[tid] = tid_tx; in ieee80211_start_tx_ba_session()
692 ieee80211_queue_work(&local->hw, &sta->ampdu_mlme.work); in ieee80211_start_tx_ba_session()
696 spin_unlock_bh(&sta->lock); in ieee80211_start_tx_ba_session()
702 struct sta_info *sta, u16 tid) in ieee80211_agg_tx_operational() argument
706 .sta = &sta->sta, in ieee80211_agg_tx_operational()
713 lockdep_assert_held(&sta->ampdu_mlme.mtx); in ieee80211_agg_tx_operational()
715 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_agg_tx_operational()
719 ht_dbg(sta->sdata, "Aggregation is on for %pM tid %d\n", in ieee80211_agg_tx_operational()
720 sta->sta.addr, tid); in ieee80211_agg_tx_operational()
722 drv_ampdu_action(local, sta->sdata, ¶ms); in ieee80211_agg_tx_operational()
728 spin_lock_bh(&sta->lock); in ieee80211_agg_tx_operational()
730 ieee80211_agg_splice_packets(sta->sdata, tid_tx, tid); in ieee80211_agg_tx_operational()
737 ieee80211_agg_splice_finish(sta->sdata, tid); in ieee80211_agg_tx_operational()
739 spin_unlock_bh(&sta->lock); in ieee80211_agg_tx_operational()
741 ieee80211_agg_start_txq(sta, tid, true); in ieee80211_agg_tx_operational()
748 struct sta_info *sta; in ieee80211_start_tx_ba_cb() local
760 sta = sta_info_get_bss(sdata, ra); in ieee80211_start_tx_ba_cb()
761 if (!sta) { in ieee80211_start_tx_ba_cb()
767 mutex_lock(&sta->ampdu_mlme.mtx); in ieee80211_start_tx_ba_cb()
768 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_start_tx_ba_cb()
779 ieee80211_agg_tx_operational(local, sta, tid); in ieee80211_start_tx_ba_cb()
782 mutex_unlock(&sta->ampdu_mlme.mtx); in ieee80211_start_tx_ba_cb()
807 int __ieee80211_stop_tx_ba_session(struct sta_info *sta, u16 tid, in __ieee80211_stop_tx_ba_session() argument
812 mutex_lock(&sta->ampdu_mlme.mtx); in __ieee80211_stop_tx_ba_session()
814 ret = ___ieee80211_stop_tx_ba_session(sta, tid, reason); in __ieee80211_stop_tx_ba_session()
816 mutex_unlock(&sta->ampdu_mlme.mtx); in __ieee80211_stop_tx_ba_session()
823 struct sta_info *sta = container_of(pubsta, struct sta_info, sta); in ieee80211_stop_tx_ba_session() local
824 struct ieee80211_sub_if_data *sdata = sta->sdata; in ieee80211_stop_tx_ba_session()
837 spin_lock_bh(&sta->lock); in ieee80211_stop_tx_ba_session()
838 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_stop_tx_ba_session()
845 WARN(sta->reserved_tid == tid, in ieee80211_stop_tx_ba_session()
855 ieee80211_queue_work(&local->hw, &sta->ampdu_mlme.work); in ieee80211_stop_tx_ba_session()
858 spin_unlock_bh(&sta->lock); in ieee80211_stop_tx_ba_session()
867 struct sta_info *sta; in ieee80211_stop_tx_ba_cb() local
883 sta = sta_info_get_bss(sdata, ra); in ieee80211_stop_tx_ba_cb()
884 if (!sta) { in ieee80211_stop_tx_ba_cb()
889 mutex_lock(&sta->ampdu_mlme.mtx); in ieee80211_stop_tx_ba_cb()
890 spin_lock_bh(&sta->lock); in ieee80211_stop_tx_ba_cb()
891 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_stop_tx_ba_cb()
896 sta->sta.addr, tid); in ieee80211_stop_tx_ba_cb()
903 ieee80211_remove_tid_tx(sta, tid); in ieee80211_stop_tx_ba_cb()
906 spin_unlock_bh(&sta->lock); in ieee80211_stop_tx_ba_cb()
912 mutex_unlock(&sta->ampdu_mlme.mtx); in ieee80211_stop_tx_ba_cb()
940 struct sta_info *sta, in ieee80211_process_addba_resp() argument
956 txq = sta->sta.txq[tid]; in ieee80211_process_addba_resp()
960 mutex_lock(&sta->ampdu_mlme.mtx); in ieee80211_process_addba_resp()
962 tid_tx = rcu_dereference_protected_tid_tx(sta, tid); in ieee80211_process_addba_resp()
967 ht_dbg(sta->sdata, "wrong addBA response token, %pM tid %d\n", in ieee80211_process_addba_resp()
968 sta->sta.addr, tid); in ieee80211_process_addba_resp()
974 ht_dbg(sta->sdata, "switched off addBA timer for %pM tid %d\n", in ieee80211_process_addba_resp()
975 sta->sta.addr, tid); in ieee80211_process_addba_resp()
984 ht_dbg(sta->sdata, in ieee80211_process_addba_resp()
986 sta->sta.addr, tid); in ieee80211_process_addba_resp()
1008 ieee80211_agg_tx_operational(local, sta, tid); in ieee80211_process_addba_resp()
1010 sta->ampdu_mlme.addba_req_num[tid] = 0; in ieee80211_process_addba_resp()
1019 ___ieee80211_stop_tx_ba_session(sta, tid, AGG_STOP_DECLINED); in ieee80211_process_addba_resp()
1023 mutex_unlock(&sta->ampdu_mlme.mtx); in ieee80211_process_addba_resp()