aboutsummaryrefslogtreecommitdiffstats
path: root/net/mac80211/agg-tx.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/mac80211/agg-tx.c')
-rw-r--r--net/mac80211/agg-tx.c96
1 files changed, 38 insertions, 58 deletions
diff --git a/net/mac80211/agg-tx.c b/net/mac80211/agg-tx.c
index b09948ceec4a..6ddd11466df2 100644
--- a/net/mac80211/agg-tx.c
+++ b/net/mac80211/agg-tx.c
@@ -138,7 +138,8 @@ static int ___ieee80211_stop_tx_ba_session(struct sta_info *sta, u16 tid,
138 *state = HT_AGG_STATE_REQ_STOP_BA_MSK | 138 *state = HT_AGG_STATE_REQ_STOP_BA_MSK |
139 (initiator << HT_AGG_STATE_INITIATOR_SHIFT); 139 (initiator << HT_AGG_STATE_INITIATOR_SHIFT);
140 140
141 ret = drv_ampdu_action(local, IEEE80211_AMPDU_TX_STOP, 141 ret = drv_ampdu_action(local, &sta->sdata->vif,
142 IEEE80211_AMPDU_TX_STOP,
142 &sta->sta, tid, NULL); 143 &sta->sta, tid, NULL);
143 144
144 /* HW shall not deny going back to legacy */ 145 /* HW shall not deny going back to legacy */
@@ -196,11 +197,11 @@ static inline int ieee80211_ac_from_tid(int tid)
196 return ieee802_1d_to_ac[tid & 7]; 197 return ieee802_1d_to_ac[tid & 7];
197} 198}
198 199
199int ieee80211_start_tx_ba_session(struct ieee80211_hw *hw, u8 *ra, u16 tid) 200int ieee80211_start_tx_ba_session(struct ieee80211_sta *pubsta, u16 tid)
200{ 201{
201 struct ieee80211_local *local = hw_to_local(hw); 202 struct sta_info *sta = container_of(pubsta, struct sta_info, sta);
202 struct sta_info *sta; 203 struct ieee80211_sub_if_data *sdata = sta->sdata;
203 struct ieee80211_sub_if_data *sdata; 204 struct ieee80211_local *local = sdata->local;
204 u8 *state; 205 u8 *state;
205 int ret = 0; 206 int ret = 0;
206 u16 start_seq_num; 207 u16 start_seq_num;
@@ -208,52 +209,37 @@ int ieee80211_start_tx_ba_session(struct ieee80211_hw *hw, u8 *ra, u16 tid)
208 if (WARN_ON(!local->ops->ampdu_action)) 209 if (WARN_ON(!local->ops->ampdu_action))
209 return -EINVAL; 210 return -EINVAL;
210 211
211 if ((tid >= STA_TID_NUM) || !(hw->flags & IEEE80211_HW_AMPDU_AGGREGATION)) 212 if ((tid >= STA_TID_NUM) ||
213 !(local->hw.flags & IEEE80211_HW_AMPDU_AGGREGATION))
212 return -EINVAL; 214 return -EINVAL;
213 215
214#ifdef CONFIG_MAC80211_HT_DEBUG 216#ifdef CONFIG_MAC80211_HT_DEBUG
215 printk(KERN_DEBUG "Open BA session requested for %pM tid %u\n", 217 printk(KERN_DEBUG "Open BA session requested for %pM tid %u\n",
216 ra, tid); 218 pubsta->addr, tid);
217#endif /* CONFIG_MAC80211_HT_DEBUG */ 219#endif /* CONFIG_MAC80211_HT_DEBUG */
218 220
219 rcu_read_lock();
220
221 sta = sta_info_get(local, ra);
222 if (!sta) {
223#ifdef CONFIG_MAC80211_HT_DEBUG
224 printk(KERN_DEBUG "Could not find the station\n");
225#endif
226 ret = -ENOENT;
227 goto unlock;
228 }
229
230 /* 221 /*
231 * The aggregation code is not prepared to handle 222 * The aggregation code is not prepared to handle
232 * anything but STA/AP due to the BSSID handling. 223 * anything but STA/AP due to the BSSID handling.
233 * IBSS could work in the code but isn't supported 224 * IBSS could work in the code but isn't supported
234 * by drivers or the standard. 225 * by drivers or the standard.
235 */ 226 */
236 if (sta->sdata->vif.type != NL80211_IFTYPE_STATION && 227 if (sdata->vif.type != NL80211_IFTYPE_STATION &&
237 sta->sdata->vif.type != NL80211_IFTYPE_AP_VLAN && 228 sdata->vif.type != NL80211_IFTYPE_AP_VLAN &&
238 sta->sdata->vif.type != NL80211_IFTYPE_AP) { 229 sdata->vif.type != NL80211_IFTYPE_AP)
239 ret = -EINVAL; 230 return -EINVAL;
240 goto unlock;
241 }
242 231
243 if (test_sta_flags(sta, WLAN_STA_SUSPEND)) { 232 if (test_sta_flags(sta, WLAN_STA_SUSPEND)) {
244#ifdef CONFIG_MAC80211_HT_DEBUG 233#ifdef CONFIG_MAC80211_HT_DEBUG
245 printk(KERN_DEBUG "Suspend in progress. " 234 printk(KERN_DEBUG "Suspend in progress. "
246 "Denying BA session request\n"); 235 "Denying BA session request\n");
247#endif 236#endif
248 ret = -EINVAL; 237 return -EINVAL;
249 goto unlock;
250 } 238 }
251 239
252 spin_lock_bh(&sta->lock); 240 spin_lock_bh(&sta->lock);
253 spin_lock(&local->ampdu_lock); 241 spin_lock(&local->ampdu_lock);
254 242
255 sdata = sta->sdata;
256
257 /* we have tried too many times, receiver does not want A-MPDU */ 243 /* we have tried too many times, receiver does not want A-MPDU */
258 if (sta->ampdu_mlme.addba_req_num[tid] > HT_AGG_MAX_RETRIES) { 244 if (sta->ampdu_mlme.addba_req_num[tid] > HT_AGG_MAX_RETRIES) {
259 ret = -EBUSY; 245 ret = -EBUSY;
@@ -310,8 +296,9 @@ int ieee80211_start_tx_ba_session(struct ieee80211_hw *hw, u8 *ra, u16 tid)
310 296
311 start_seq_num = sta->tid_seq[tid]; 297 start_seq_num = sta->tid_seq[tid];
312 298
313 ret = drv_ampdu_action(local, IEEE80211_AMPDU_TX_START, 299 ret = drv_ampdu_action(local, &sdata->vif,
314 &sta->sta, tid, &start_seq_num); 300 IEEE80211_AMPDU_TX_START,
301 pubsta, tid, &start_seq_num);
315 302
316 if (ret) { 303 if (ret) {
317#ifdef CONFIG_MAC80211_HT_DEBUG 304#ifdef CONFIG_MAC80211_HT_DEBUG
@@ -336,7 +323,7 @@ int ieee80211_start_tx_ba_session(struct ieee80211_hw *hw, u8 *ra, u16 tid)
336 sta->ampdu_mlme.dialog_token_allocator; 323 sta->ampdu_mlme.dialog_token_allocator;
337 sta->ampdu_mlme.tid_tx[tid]->ssn = start_seq_num; 324 sta->ampdu_mlme.tid_tx[tid]->ssn = start_seq_num;
338 325
339 ieee80211_send_addba_request(sta->sdata, ra, tid, 326 ieee80211_send_addba_request(sdata, pubsta->addr, tid,
340 sta->ampdu_mlme.tid_tx[tid]->dialog_token, 327 sta->ampdu_mlme.tid_tx[tid]->dialog_token,
341 sta->ampdu_mlme.tid_tx[tid]->ssn, 328 sta->ampdu_mlme.tid_tx[tid]->ssn,
342 0x40, 5000); 329 0x40, 5000);
@@ -348,7 +335,7 @@ int ieee80211_start_tx_ba_session(struct ieee80211_hw *hw, u8 *ra, u16 tid)
348#ifdef CONFIG_MAC80211_HT_DEBUG 335#ifdef CONFIG_MAC80211_HT_DEBUG
349 printk(KERN_DEBUG "activated addBA response timer on tid %d\n", tid); 336 printk(KERN_DEBUG "activated addBA response timer on tid %d\n", tid);
350#endif 337#endif
351 goto unlock; 338 return 0;
352 339
353 err_free: 340 err_free:
354 kfree(sta->ampdu_mlme.tid_tx[tid]); 341 kfree(sta->ampdu_mlme.tid_tx[tid]);
@@ -360,8 +347,6 @@ int ieee80211_start_tx_ba_session(struct ieee80211_hw *hw, u8 *ra, u16 tid)
360 err_unlock_sta: 347 err_unlock_sta:
361 spin_unlock(&local->ampdu_lock); 348 spin_unlock(&local->ampdu_lock);
362 spin_unlock_bh(&sta->lock); 349 spin_unlock_bh(&sta->lock);
363 unlock:
364 rcu_read_unlock();
365 return ret; 350 return ret;
366} 351}
367EXPORT_SYMBOL(ieee80211_start_tx_ba_session); 352EXPORT_SYMBOL(ieee80211_start_tx_ba_session);
@@ -428,13 +413,15 @@ static void ieee80211_agg_tx_operational(struct ieee80211_local *local,
428 ieee80211_agg_splice_finish(local, sta, tid); 413 ieee80211_agg_splice_finish(local, sta, tid);
429 spin_unlock(&local->ampdu_lock); 414 spin_unlock(&local->ampdu_lock);
430 415
431 drv_ampdu_action(local, IEEE80211_AMPDU_TX_OPERATIONAL, 416 drv_ampdu_action(local, &sta->sdata->vif,
417 IEEE80211_AMPDU_TX_OPERATIONAL,
432 &sta->sta, tid, NULL); 418 &sta->sta, tid, NULL);
433} 419}
434 420
435void ieee80211_start_tx_ba_cb(struct ieee80211_hw *hw, u8 *ra, u16 tid) 421void ieee80211_start_tx_ba_cb(struct ieee80211_vif *vif, u8 *ra, u16 tid)
436{ 422{
437 struct ieee80211_local *local = hw_to_local(hw); 423 struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
424 struct ieee80211_local *local = sdata->local;
438 struct sta_info *sta; 425 struct sta_info *sta;
439 u8 *state; 426 u8 *state;
440 427
@@ -483,10 +470,11 @@ void ieee80211_start_tx_ba_cb(struct ieee80211_hw *hw, u8 *ra, u16 tid)
483} 470}
484EXPORT_SYMBOL(ieee80211_start_tx_ba_cb); 471EXPORT_SYMBOL(ieee80211_start_tx_ba_cb);
485 472
486void ieee80211_start_tx_ba_cb_irqsafe(struct ieee80211_hw *hw, 473void ieee80211_start_tx_ba_cb_irqsafe(struct ieee80211_vif *vif,
487 const u8 *ra, u16 tid) 474 const u8 *ra, u16 tid)
488{ 475{
489 struct ieee80211_local *local = hw_to_local(hw); 476 struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
477 struct ieee80211_local *local = sdata->local;
490 struct ieee80211_ra_tid *ra_tid; 478 struct ieee80211_ra_tid *ra_tid;
491 struct sk_buff *skb = dev_alloc_skb(0); 479 struct sk_buff *skb = dev_alloc_skb(0);
492 480
@@ -535,13 +523,12 @@ int __ieee80211_stop_tx_ba_session(struct sta_info *sta, u16 tid,
535 return ret; 523 return ret;
536} 524}
537 525
538int ieee80211_stop_tx_ba_session(struct ieee80211_hw *hw, 526int ieee80211_stop_tx_ba_session(struct ieee80211_sta *pubsta, u16 tid,
539 u8 *ra, u16 tid,
540 enum ieee80211_back_parties initiator) 527 enum ieee80211_back_parties initiator)
541{ 528{
542 struct ieee80211_local *local = hw_to_local(hw); 529 struct sta_info *sta = container_of(pubsta, struct sta_info, sta);
543 struct sta_info *sta; 530 struct ieee80211_sub_if_data *sdata = sta->sdata;
544 int ret = 0; 531 struct ieee80211_local *local = sdata->local;
545 532
546 if (WARN_ON(!local->ops->ampdu_action)) 533 if (WARN_ON(!local->ops->ampdu_action))
547 return -EINVAL; 534 return -EINVAL;
@@ -549,22 +536,14 @@ int ieee80211_stop_tx_ba_session(struct ieee80211_hw *hw,
549 if (tid >= STA_TID_NUM) 536 if (tid >= STA_TID_NUM)
550 return -EINVAL; 537 return -EINVAL;
551 538
552 rcu_read_lock(); 539 return __ieee80211_stop_tx_ba_session(sta, tid, initiator);
553 sta = sta_info_get(local, ra);
554 if (!sta) {
555 rcu_read_unlock();
556 return -ENOENT;
557 }
558
559 ret = __ieee80211_stop_tx_ba_session(sta, tid, initiator);
560 rcu_read_unlock();
561 return ret;
562} 540}
563EXPORT_SYMBOL(ieee80211_stop_tx_ba_session); 541EXPORT_SYMBOL(ieee80211_stop_tx_ba_session);
564 542
565void ieee80211_stop_tx_ba_cb(struct ieee80211_hw *hw, u8 *ra, u8 tid) 543void ieee80211_stop_tx_ba_cb(struct ieee80211_vif *vif, u8 *ra, u8 tid)
566{ 544{
567 struct ieee80211_local *local = hw_to_local(hw); 545 struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
546 struct ieee80211_local *local = sdata->local;
568 struct sta_info *sta; 547 struct sta_info *sta;
569 u8 *state; 548 u8 *state;
570 549
@@ -627,10 +606,11 @@ void ieee80211_stop_tx_ba_cb(struct ieee80211_hw *hw, u8 *ra, u8 tid)
627} 606}
628EXPORT_SYMBOL(ieee80211_stop_tx_ba_cb); 607EXPORT_SYMBOL(ieee80211_stop_tx_ba_cb);
629 608
630void ieee80211_stop_tx_ba_cb_irqsafe(struct ieee80211_hw *hw, 609void ieee80211_stop_tx_ba_cb_irqsafe(struct ieee80211_vif *vif,
631 const u8 *ra, u16 tid) 610 const u8 *ra, u16 tid)
632{ 611{
633 struct ieee80211_local *local = hw_to_local(hw); 612 struct ieee80211_sub_if_data *sdata = vif_to_sdata(vif);
613 struct ieee80211_local *local = sdata->local;
634 struct ieee80211_ra_tid *ra_tid; 614 struct ieee80211_ra_tid *ra_tid;
635 struct sk_buff *skb = dev_alloc_skb(0); 615 struct sk_buff *skb = dev_alloc_skb(0);
636 616