tx.c 31 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055
  1. /******************************************************************************
  2. *
  3. * This file is provided under a dual BSD/GPLv2 license. When using or
  4. * redistributing this file, you may do so under either license.
  5. *
  6. * GPL LICENSE SUMMARY
  7. *
  8. * Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
  9. * Copyright(c) 2013 - 2014 Intel Mobile Communications GmbH
  10. *
  11. * This program is free software; you can redistribute it and/or modify
  12. * it under the terms of version 2 of the GNU General Public License as
  13. * published by the Free Software Foundation.
  14. *
  15. * This program is distributed in the hope that it will be useful, but
  16. * WITHOUT ANY WARRANTY; without even the implied warranty of
  17. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  18. * General Public License for more details.
  19. *
  20. * You should have received a copy of the GNU General Public License
  21. * along with this program; if not, write to the Free Software
  22. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110,
  23. * USA
  24. *
  25. * The full GNU General Public License is included in this distribution
  26. * in the file called COPYING.
  27. *
  28. * Contact Information:
  29. * Intel Linux Wireless <ilw@linux.intel.com>
  30. * Intel Corporation, 5200 N.E. Elam Young Parkway, Hillsboro, OR 97124-6497
  31. *
  32. * BSD LICENSE
  33. *
  34. * Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
  35. * Copyright(c) 2013 - 2014 Intel Mobile Communications GmbH
  36. * All rights reserved.
  37. *
  38. * Redistribution and use in source and binary forms, with or without
  39. * modification, are permitted provided that the following conditions
  40. * are met:
  41. *
  42. * * Redistributions of source code must retain the above copyright
  43. * notice, this list of conditions and the following disclaimer.
  44. * * Redistributions in binary form must reproduce the above copyright
  45. * notice, this list of conditions and the following disclaimer in
  46. * the documentation and/or other materials provided with the
  47. * distribution.
  48. * * Neither the name Intel Corporation nor the names of its
  49. * contributors may be used to endorse or promote products derived
  50. * from this software without specific prior written permission.
  51. *
  52. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  53. * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  54. * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  55. * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  56. * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  57. * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  58. * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  59. * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  60. * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  61. * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  62. * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  63. *
  64. *****************************************************************************/
  65. #include <linux/ieee80211.h>
  66. #include <linux/etherdevice.h>
  67. #include "iwl-trans.h"
  68. #include "iwl-eeprom-parse.h"
  69. #include "mvm.h"
  70. #include "sta.h"
  71. /*
  72. * Sets most of the Tx cmd's fields
  73. */
  74. void iwl_mvm_set_tx_cmd(struct iwl_mvm *mvm, struct sk_buff *skb,
  75. struct iwl_tx_cmd *tx_cmd,
  76. struct ieee80211_tx_info *info, u8 sta_id)
  77. {
  78. struct ieee80211_hdr *hdr = (void *)skb->data;
  79. __le16 fc = hdr->frame_control;
  80. u32 tx_flags = le32_to_cpu(tx_cmd->tx_flags);
  81. u32 len = skb->len + FCS_LEN;
  82. u8 ac;
  83. if (!(info->flags & IEEE80211_TX_CTL_NO_ACK))
  84. tx_flags |= TX_CMD_FLG_ACK;
  85. else
  86. tx_flags &= ~TX_CMD_FLG_ACK;
  87. if (ieee80211_is_probe_resp(fc))
  88. tx_flags |= TX_CMD_FLG_TSF;
  89. if (ieee80211_has_morefrags(fc))
  90. tx_flags |= TX_CMD_FLG_MORE_FRAG;
  91. if (ieee80211_is_data_qos(fc)) {
  92. u8 *qc = ieee80211_get_qos_ctl(hdr);
  93. tx_cmd->tid_tspec = qc[0] & 0xf;
  94. tx_flags &= ~TX_CMD_FLG_SEQ_CTL;
  95. } else if (ieee80211_is_back_req(fc)) {
  96. struct ieee80211_bar *bar = (void *)skb->data;
  97. u16 control = le16_to_cpu(bar->control);
  98. tx_flags |= TX_CMD_FLG_ACK | TX_CMD_FLG_BAR;
  99. tx_cmd->tid_tspec = (control &
  100. IEEE80211_BAR_CTRL_TID_INFO_MASK) >>
  101. IEEE80211_BAR_CTRL_TID_INFO_SHIFT;
  102. WARN_ON_ONCE(tx_cmd->tid_tspec >= IWL_MAX_TID_COUNT);
  103. } else {
  104. tx_cmd->tid_tspec = IWL_TID_NON_QOS;
  105. if (info->flags & IEEE80211_TX_CTL_ASSIGN_SEQ)
  106. tx_flags |= TX_CMD_FLG_SEQ_CTL;
  107. else
  108. tx_flags &= ~TX_CMD_FLG_SEQ_CTL;
  109. }
  110. /* Default to 0 (BE) when tid_spec is set to IWL_TID_NON_QOS */
  111. if (tx_cmd->tid_tspec < IWL_MAX_TID_COUNT)
  112. ac = tid_to_mac80211_ac[tx_cmd->tid_tspec];
  113. else
  114. ac = tid_to_mac80211_ac[0];
  115. tx_flags |= iwl_mvm_bt_coex_tx_prio(mvm, hdr, info, ac) <<
  116. TX_CMD_FLG_BT_PRIO_POS;
  117. if (ieee80211_is_mgmt(fc)) {
  118. if (ieee80211_is_assoc_req(fc) || ieee80211_is_reassoc_req(fc))
  119. tx_cmd->pm_frame_timeout = cpu_to_le16(3);
  120. else
  121. tx_cmd->pm_frame_timeout = cpu_to_le16(2);
  122. /* The spec allows Action frames in A-MPDU, we don't support
  123. * it
  124. */
  125. WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_AMPDU);
  126. } else if (info->control.flags & IEEE80211_TX_CTRL_PORT_CTRL_PROTO) {
  127. tx_cmd->pm_frame_timeout = cpu_to_le16(2);
  128. } else {
  129. tx_cmd->pm_frame_timeout = 0;
  130. }
  131. if (ieee80211_is_data(fc) && len > mvm->rts_threshold &&
  132. !is_multicast_ether_addr(ieee80211_get_DA(hdr)))
  133. tx_flags |= TX_CMD_FLG_PROT_REQUIRE;
  134. if ((mvm->fw->ucode_capa.capa[0] &
  135. IWL_UCODE_TLV_CAPA_TXPOWER_INSERTION_SUPPORT) &&
  136. ieee80211_action_contains_tpc(skb))
  137. tx_flags |= TX_CMD_FLG_WRITE_TX_POWER;
  138. tx_cmd->tx_flags = cpu_to_le32(tx_flags);
  139. /* Total # bytes to be transmitted */
  140. tx_cmd->len = cpu_to_le16((u16)skb->len);
  141. tx_cmd->next_frame_len = 0;
  142. tx_cmd->life_time = cpu_to_le32(TX_CMD_LIFE_TIME_INFINITE);
  143. tx_cmd->sta_id = sta_id;
  144. }
  145. /*
  146. * Sets the fields in the Tx cmd that are rate related
  147. */
  148. void iwl_mvm_set_tx_cmd_rate(struct iwl_mvm *mvm, struct iwl_tx_cmd *tx_cmd,
  149. struct ieee80211_tx_info *info,
  150. struct ieee80211_sta *sta, __le16 fc)
  151. {
  152. u32 rate_flags;
  153. int rate_idx;
  154. u8 rate_plcp;
  155. /* Set retry limit on RTS packets */
  156. tx_cmd->rts_retry_limit = IWL_RTS_DFAULT_RETRY_LIMIT;
  157. /* Set retry limit on DATA packets and Probe Responses*/
  158. if (ieee80211_is_probe_resp(fc)) {
  159. tx_cmd->data_retry_limit = IWL_MGMT_DFAULT_RETRY_LIMIT;
  160. tx_cmd->rts_retry_limit =
  161. min(tx_cmd->data_retry_limit, tx_cmd->rts_retry_limit);
  162. } else if (ieee80211_is_back_req(fc)) {
  163. tx_cmd->data_retry_limit = IWL_BAR_DFAULT_RETRY_LIMIT;
  164. } else {
  165. tx_cmd->data_retry_limit = IWL_DEFAULT_TX_RETRY;
  166. }
  167. /*
  168. * for data packets, rate info comes from the table inside the fw. This
  169. * table is controlled by LINK_QUALITY commands
  170. */
  171. if (ieee80211_is_data(fc) && sta) {
  172. tx_cmd->initial_rate_index = 0;
  173. tx_cmd->tx_flags |= cpu_to_le32(TX_CMD_FLG_STA_RATE);
  174. return;
  175. } else if (ieee80211_is_back_req(fc)) {
  176. tx_cmd->tx_flags |=
  177. cpu_to_le32(TX_CMD_FLG_ACK | TX_CMD_FLG_BAR);
  178. }
  179. /* HT rate doesn't make sense for a non data frame */
  180. WARN_ONCE(info->control.rates[0].flags & IEEE80211_TX_RC_MCS,
  181. "Got an HT rate (flags:0x%x/mcs:%d) for a non data frame (fc:0x%x)\n",
  182. info->control.rates[0].flags,
  183. info->control.rates[0].idx,
  184. le16_to_cpu(fc));
  185. rate_idx = info->control.rates[0].idx;
  186. /* if the rate isn't a well known legacy rate, take the lowest one */
  187. if (rate_idx < 0 || rate_idx > IWL_RATE_COUNT_LEGACY)
  188. rate_idx = rate_lowest_index(
  189. &mvm->nvm_data->bands[info->band], sta);
  190. /* For 5 GHZ band, remap mac80211 rate indices into driver indices */
  191. if (info->band == IEEE80211_BAND_5GHZ)
  192. rate_idx += IWL_FIRST_OFDM_RATE;
  193. /* For 2.4 GHZ band, check that there is no need to remap */
  194. BUILD_BUG_ON(IWL_FIRST_CCK_RATE != 0);
  195. /* Get PLCP rate for tx_cmd->rate_n_flags */
  196. rate_plcp = iwl_mvm_mac80211_idx_to_hwrate(rate_idx);
  197. mvm->mgmt_last_antenna_idx =
  198. iwl_mvm_next_antenna(mvm, mvm->fw->valid_tx_ant,
  199. mvm->mgmt_last_antenna_idx);
  200. if (info->band == IEEE80211_BAND_2GHZ &&
  201. !iwl_mvm_bt_coex_is_shared_ant_avail(mvm))
  202. rate_flags = BIT(mvm->cfg->non_shared_ant) << RATE_MCS_ANT_POS;
  203. else
  204. rate_flags =
  205. BIT(mvm->mgmt_last_antenna_idx) << RATE_MCS_ANT_POS;
  206. /* Set CCK flag as needed */
  207. if ((rate_idx >= IWL_FIRST_CCK_RATE) && (rate_idx <= IWL_LAST_CCK_RATE))
  208. rate_flags |= RATE_MCS_CCK_MSK;
  209. /* Set the rate in the TX cmd */
  210. tx_cmd->rate_n_flags = cpu_to_le32((u32)rate_plcp | rate_flags);
  211. }
  212. /*
  213. * Sets the fields in the Tx cmd that are crypto related
  214. */
  215. void iwl_mvm_set_tx_cmd_crypto(struct iwl_mvm *mvm,
  216. struct ieee80211_tx_info *info,
  217. struct iwl_tx_cmd *tx_cmd,
  218. struct sk_buff *skb_frag)
  219. {
  220. struct ieee80211_key_conf *keyconf = info->control.hw_key;
  221. switch (keyconf->cipher) {
  222. case WLAN_CIPHER_SUITE_CCMP:
  223. tx_cmd->sec_ctl = TX_CMD_SEC_CCM;
  224. memcpy(tx_cmd->key, keyconf->key, keyconf->keylen);
  225. if (info->flags & IEEE80211_TX_CTL_AMPDU)
  226. tx_cmd->tx_flags |= cpu_to_le32(TX_CMD_FLG_CCMP_AGG);
  227. break;
  228. case WLAN_CIPHER_SUITE_TKIP:
  229. tx_cmd->sec_ctl = TX_CMD_SEC_TKIP;
  230. ieee80211_get_tkip_p2k(keyconf, skb_frag, tx_cmd->key);
  231. break;
  232. case WLAN_CIPHER_SUITE_WEP104:
  233. tx_cmd->sec_ctl |= TX_CMD_SEC_KEY128;
  234. /* fall through */
  235. case WLAN_CIPHER_SUITE_WEP40:
  236. tx_cmd->sec_ctl |= TX_CMD_SEC_WEP |
  237. ((keyconf->keyidx << TX_CMD_SEC_WEP_KEY_IDX_POS) &
  238. TX_CMD_SEC_WEP_KEY_IDX_MSK);
  239. memcpy(&tx_cmd->key[3], keyconf->key, keyconf->keylen);
  240. break;
  241. default:
  242. tx_cmd->sec_ctl |= TX_CMD_SEC_EXT;
  243. }
  244. }
  245. /*
  246. * Allocates and sets the Tx cmd the driver data pointers in the skb
  247. */
  248. static struct iwl_device_cmd *
  249. iwl_mvm_set_tx_params(struct iwl_mvm *mvm, struct sk_buff *skb,
  250. struct ieee80211_sta *sta, u8 sta_id)
  251. {
  252. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
  253. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  254. struct iwl_device_cmd *dev_cmd;
  255. struct iwl_tx_cmd *tx_cmd;
  256. dev_cmd = iwl_trans_alloc_tx_cmd(mvm->trans);
  257. if (unlikely(!dev_cmd))
  258. return NULL;
  259. memset(dev_cmd, 0, sizeof(*dev_cmd));
  260. dev_cmd->hdr.cmd = TX_CMD;
  261. tx_cmd = (struct iwl_tx_cmd *)dev_cmd->payload;
  262. if (info->control.hw_key)
  263. iwl_mvm_set_tx_cmd_crypto(mvm, info, tx_cmd, skb);
  264. iwl_mvm_set_tx_cmd(mvm, skb, tx_cmd, info, sta_id);
  265. iwl_mvm_set_tx_cmd_rate(mvm, tx_cmd, info, sta, hdr->frame_control);
  266. memset(&info->status, 0, sizeof(info->status));
  267. info->driver_data[0] = NULL;
  268. info->driver_data[1] = dev_cmd;
  269. return dev_cmd;
  270. }
  271. int iwl_mvm_tx_skb_non_sta(struct iwl_mvm *mvm, struct sk_buff *skb)
  272. {
  273. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
  274. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  275. struct iwl_device_cmd *dev_cmd;
  276. struct iwl_tx_cmd *tx_cmd;
  277. u8 sta_id;
  278. if (WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_AMPDU))
  279. return -1;
  280. if (WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_SEND_AFTER_DTIM &&
  281. (!info->control.vif ||
  282. info->hw_queue != info->control.vif->cab_queue)))
  283. return -1;
  284. /*
  285. * IWL_MVM_OFFCHANNEL_QUEUE is used for ROC packets that can be used
  286. * in 2 different types of vifs, P2P & STATION. P2P uses the offchannel
  287. * queue. STATION (HS2.0) uses the auxiliary context of the FW,
  288. * and hence needs to be sent on the aux queue
  289. */
  290. if (IEEE80211_SKB_CB(skb)->hw_queue == IWL_MVM_OFFCHANNEL_QUEUE &&
  291. info->control.vif->type == NL80211_IFTYPE_STATION)
  292. IEEE80211_SKB_CB(skb)->hw_queue = mvm->aux_queue;
  293. /*
  294. * If the interface on which frame is sent is the P2P_DEVICE
  295. * or an AP/GO interface use the broadcast station associated
  296. * with it; otherwise use the AUX station.
  297. */
  298. if (info->control.vif &&
  299. (info->control.vif->type == NL80211_IFTYPE_P2P_DEVICE ||
  300. info->control.vif->type == NL80211_IFTYPE_AP)) {
  301. struct iwl_mvm_vif *mvmvif =
  302. iwl_mvm_vif_from_mac80211(info->control.vif);
  303. sta_id = mvmvif->bcast_sta.sta_id;
  304. } else {
  305. sta_id = mvm->aux_sta.sta_id;
  306. }
  307. IWL_DEBUG_TX(mvm, "station Id %d, queue=%d\n", sta_id, info->hw_queue);
  308. dev_cmd = iwl_mvm_set_tx_params(mvm, skb, NULL, sta_id);
  309. if (!dev_cmd)
  310. return -1;
  311. /* From now on, we cannot access info->control */
  312. tx_cmd = (struct iwl_tx_cmd *)dev_cmd->payload;
  313. /* Copy MAC header from skb into command buffer */
  314. memcpy(tx_cmd->hdr, hdr, ieee80211_hdrlen(hdr->frame_control));
  315. if (iwl_trans_tx(mvm->trans, skb, dev_cmd, info->hw_queue)) {
  316. iwl_trans_free_tx_cmd(mvm->trans, dev_cmd);
  317. return -1;
  318. }
  319. return 0;
  320. }
  321. /*
  322. * Sets the fields in the Tx cmd that are crypto related
  323. */
  324. int iwl_mvm_tx_skb(struct iwl_mvm *mvm, struct sk_buff *skb,
  325. struct ieee80211_sta *sta)
  326. {
  327. struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
  328. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  329. struct iwl_mvm_sta *mvmsta;
  330. struct iwl_device_cmd *dev_cmd;
  331. struct iwl_tx_cmd *tx_cmd;
  332. __le16 fc;
  333. u16 seq_number = 0;
  334. u8 tid = IWL_MAX_TID_COUNT;
  335. u8 txq_id = info->hw_queue;
  336. bool is_data_qos = false, is_ampdu = false;
  337. mvmsta = iwl_mvm_sta_from_mac80211(sta);
  338. fc = hdr->frame_control;
  339. if (WARN_ON_ONCE(!mvmsta))
  340. return -1;
  341. if (WARN_ON_ONCE(mvmsta->sta_id == IWL_MVM_STATION_COUNT))
  342. return -1;
  343. dev_cmd = iwl_mvm_set_tx_params(mvm, skb, sta, mvmsta->sta_id);
  344. if (!dev_cmd)
  345. goto drop;
  346. tx_cmd = (struct iwl_tx_cmd *)dev_cmd->payload;
  347. /* From now on, we cannot access info->control */
  348. /*
  349. * we handle that entirely ourselves -- for uAPSD the firmware
  350. * will always send a notification, and for PS-Poll responses
  351. * we'll notify mac80211 when getting frame status
  352. */
  353. info->flags &= ~IEEE80211_TX_STATUS_EOSP;
  354. spin_lock(&mvmsta->lock);
  355. if (ieee80211_is_data_qos(fc) && !ieee80211_is_qos_nullfunc(fc)) {
  356. u8 *qc = NULL;
  357. qc = ieee80211_get_qos_ctl(hdr);
  358. tid = qc[0] & IEEE80211_QOS_CTL_TID_MASK;
  359. if (WARN_ON_ONCE(tid >= IWL_MAX_TID_COUNT))
  360. goto drop_unlock_sta;
  361. seq_number = mvmsta->tid_data[tid].seq_number;
  362. seq_number &= IEEE80211_SCTL_SEQ;
  363. hdr->seq_ctrl &= cpu_to_le16(IEEE80211_SCTL_FRAG);
  364. hdr->seq_ctrl |= cpu_to_le16(seq_number);
  365. is_data_qos = true;
  366. is_ampdu = info->flags & IEEE80211_TX_CTL_AMPDU;
  367. }
  368. /* Copy MAC header from skb into command buffer */
  369. memcpy(tx_cmd->hdr, hdr, ieee80211_hdrlen(fc));
  370. WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_SEND_AFTER_DTIM);
  371. if (sta->tdls) {
  372. /* default to TID 0 for non-QoS packets */
  373. u8 tdls_tid = tid == IWL_MAX_TID_COUNT ? 0 : tid;
  374. txq_id = mvmsta->hw_queue[tid_to_mac80211_ac[tdls_tid]];
  375. }
  376. if (is_ampdu) {
  377. if (WARN_ON_ONCE(mvmsta->tid_data[tid].state != IWL_AGG_ON))
  378. goto drop_unlock_sta;
  379. txq_id = mvmsta->tid_data[tid].txq_id;
  380. }
  381. IWL_DEBUG_TX(mvm, "TX to [%d|%d] Q:%d - seq: 0x%x\n", mvmsta->sta_id,
  382. tid, txq_id, IEEE80211_SEQ_TO_SN(seq_number));
  383. if (iwl_trans_tx(mvm->trans, skb, dev_cmd, txq_id))
  384. goto drop_unlock_sta;
  385. if (is_data_qos && !ieee80211_has_morefrags(fc))
  386. mvmsta->tid_data[tid].seq_number = seq_number + 0x10;
  387. spin_unlock(&mvmsta->lock);
  388. if (txq_id < mvm->first_agg_queue)
  389. atomic_inc(&mvm->pending_frames[mvmsta->sta_id]);
  390. return 0;
  391. drop_unlock_sta:
  392. iwl_trans_free_tx_cmd(mvm->trans, dev_cmd);
  393. spin_unlock(&mvmsta->lock);
  394. drop:
  395. return -1;
  396. }
  397. static void iwl_mvm_check_ratid_empty(struct iwl_mvm *mvm,
  398. struct ieee80211_sta *sta, u8 tid)
  399. {
  400. struct iwl_mvm_sta *mvmsta = iwl_mvm_sta_from_mac80211(sta);
  401. struct iwl_mvm_tid_data *tid_data = &mvmsta->tid_data[tid];
  402. struct ieee80211_vif *vif = mvmsta->vif;
  403. lockdep_assert_held(&mvmsta->lock);
  404. if ((tid_data->state == IWL_AGG_ON ||
  405. tid_data->state == IWL_EMPTYING_HW_QUEUE_DELBA) &&
  406. iwl_mvm_tid_queued(tid_data) == 0) {
  407. /*
  408. * Now that this aggregation queue is empty tell mac80211 so it
  409. * knows we no longer have frames buffered for the station on
  410. * this TID (for the TIM bitmap calculation.)
  411. */
  412. ieee80211_sta_set_buffered(sta, tid, false);
  413. }
  414. if (tid_data->ssn != tid_data->next_reclaimed)
  415. return;
  416. switch (tid_data->state) {
  417. case IWL_EMPTYING_HW_QUEUE_ADDBA:
  418. IWL_DEBUG_TX_QUEUES(mvm,
  419. "Can continue addBA flow ssn = next_recl = %d\n",
  420. tid_data->next_reclaimed);
  421. tid_data->state = IWL_AGG_STARTING;
  422. ieee80211_start_tx_ba_cb_irqsafe(vif, sta->addr, tid);
  423. break;
  424. case IWL_EMPTYING_HW_QUEUE_DELBA:
  425. IWL_DEBUG_TX_QUEUES(mvm,
  426. "Can continue DELBA flow ssn = next_recl = %d\n",
  427. tid_data->next_reclaimed);
  428. iwl_mvm_disable_txq(mvm, tid_data->txq_id);
  429. tid_data->state = IWL_AGG_OFF;
  430. /*
  431. * we can't hold the mutex - but since we are after a sequence
  432. * point (call to iwl_mvm_disable_txq(), so we don't even need
  433. * a memory barrier.
  434. */
  435. mvm->queue_to_mac80211[tid_data->txq_id] =
  436. IWL_INVALID_MAC80211_QUEUE;
  437. ieee80211_stop_tx_ba_cb_irqsafe(vif, sta->addr, tid);
  438. break;
  439. default:
  440. break;
  441. }
  442. }
  443. #ifdef CONFIG_IWLWIFI_DEBUG
  444. const char *iwl_mvm_get_tx_fail_reason(u32 status)
  445. {
  446. #define TX_STATUS_FAIL(x) case TX_STATUS_FAIL_ ## x: return #x
  447. #define TX_STATUS_POSTPONE(x) case TX_STATUS_POSTPONE_ ## x: return #x
  448. switch (status & TX_STATUS_MSK) {
  449. case TX_STATUS_SUCCESS:
  450. return "SUCCESS";
  451. TX_STATUS_POSTPONE(DELAY);
  452. TX_STATUS_POSTPONE(FEW_BYTES);
  453. TX_STATUS_POSTPONE(BT_PRIO);
  454. TX_STATUS_POSTPONE(QUIET_PERIOD);
  455. TX_STATUS_POSTPONE(CALC_TTAK);
  456. TX_STATUS_FAIL(INTERNAL_CROSSED_RETRY);
  457. TX_STATUS_FAIL(SHORT_LIMIT);
  458. TX_STATUS_FAIL(LONG_LIMIT);
  459. TX_STATUS_FAIL(UNDERRUN);
  460. TX_STATUS_FAIL(DRAIN_FLOW);
  461. TX_STATUS_FAIL(RFKILL_FLUSH);
  462. TX_STATUS_FAIL(LIFE_EXPIRE);
  463. TX_STATUS_FAIL(DEST_PS);
  464. TX_STATUS_FAIL(HOST_ABORTED);
  465. TX_STATUS_FAIL(BT_RETRY);
  466. TX_STATUS_FAIL(STA_INVALID);
  467. TX_STATUS_FAIL(FRAG_DROPPED);
  468. TX_STATUS_FAIL(TID_DISABLE);
  469. TX_STATUS_FAIL(FIFO_FLUSHED);
  470. TX_STATUS_FAIL(SMALL_CF_POLL);
  471. TX_STATUS_FAIL(FW_DROP);
  472. TX_STATUS_FAIL(STA_COLOR_MISMATCH);
  473. }
  474. return "UNKNOWN";
  475. #undef TX_STATUS_FAIL
  476. #undef TX_STATUS_POSTPONE
  477. }
  478. #endif /* CONFIG_IWLWIFI_DEBUG */
  479. void iwl_mvm_hwrate_to_tx_rate(u32 rate_n_flags,
  480. enum ieee80211_band band,
  481. struct ieee80211_tx_rate *r)
  482. {
  483. if (rate_n_flags & RATE_HT_MCS_GF_MSK)
  484. r->flags |= IEEE80211_TX_RC_GREEN_FIELD;
  485. switch (rate_n_flags & RATE_MCS_CHAN_WIDTH_MSK) {
  486. case RATE_MCS_CHAN_WIDTH_20:
  487. break;
  488. case RATE_MCS_CHAN_WIDTH_40:
  489. r->flags |= IEEE80211_TX_RC_40_MHZ_WIDTH;
  490. break;
  491. case RATE_MCS_CHAN_WIDTH_80:
  492. r->flags |= IEEE80211_TX_RC_80_MHZ_WIDTH;
  493. break;
  494. case RATE_MCS_CHAN_WIDTH_160:
  495. r->flags |= IEEE80211_TX_RC_160_MHZ_WIDTH;
  496. break;
  497. }
  498. if (rate_n_flags & RATE_MCS_SGI_MSK)
  499. r->flags |= IEEE80211_TX_RC_SHORT_GI;
  500. if (rate_n_flags & RATE_MCS_HT_MSK) {
  501. r->flags |= IEEE80211_TX_RC_MCS;
  502. r->idx = rate_n_flags & RATE_HT_MCS_INDEX_MSK;
  503. } else if (rate_n_flags & RATE_MCS_VHT_MSK) {
  504. ieee80211_rate_set_vht(
  505. r, rate_n_flags & RATE_VHT_MCS_RATE_CODE_MSK,
  506. ((rate_n_flags & RATE_VHT_MCS_NSS_MSK) >>
  507. RATE_VHT_MCS_NSS_POS) + 1);
  508. r->flags |= IEEE80211_TX_RC_VHT_MCS;
  509. } else {
  510. r->idx = iwl_mvm_legacy_rate_to_mac80211_idx(rate_n_flags,
  511. band);
  512. }
  513. }
  514. /**
  515. * translate ucode response to mac80211 tx status control values
  516. */
  517. static void iwl_mvm_hwrate_to_tx_status(u32 rate_n_flags,
  518. struct ieee80211_tx_info *info)
  519. {
  520. struct ieee80211_tx_rate *r = &info->status.rates[0];
  521. info->status.antenna =
  522. ((rate_n_flags & RATE_MCS_ANT_ABC_MSK) >> RATE_MCS_ANT_POS);
  523. iwl_mvm_hwrate_to_tx_rate(rate_n_flags, info->band, r);
  524. }
  525. static void iwl_mvm_rx_tx_cmd_single(struct iwl_mvm *mvm,
  526. struct iwl_rx_packet *pkt)
  527. {
  528. struct ieee80211_sta *sta;
  529. u16 sequence = le16_to_cpu(pkt->hdr.sequence);
  530. int txq_id = SEQ_TO_QUEUE(sequence);
  531. struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
  532. int sta_id = IWL_MVM_TX_RES_GET_RA(tx_resp->ra_tid);
  533. int tid = IWL_MVM_TX_RES_GET_TID(tx_resp->ra_tid);
  534. u32 status = le16_to_cpu(tx_resp->status.status);
  535. u16 ssn = iwl_mvm_get_scd_ssn(tx_resp);
  536. struct iwl_mvm_sta *mvmsta;
  537. struct sk_buff_head skbs;
  538. u8 skb_freed = 0;
  539. u16 next_reclaimed, seq_ctl;
  540. __skb_queue_head_init(&skbs);
  541. seq_ctl = le16_to_cpu(tx_resp->seq_ctl);
  542. /* we can free until ssn % q.n_bd not inclusive */
  543. iwl_trans_reclaim(mvm->trans, txq_id, ssn, &skbs);
  544. while (!skb_queue_empty(&skbs)) {
  545. struct sk_buff *skb = __skb_dequeue(&skbs);
  546. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  547. skb_freed++;
  548. iwl_trans_free_tx_cmd(mvm->trans, info->driver_data[1]);
  549. memset(&info->status, 0, sizeof(info->status));
  550. info->flags &= ~IEEE80211_TX_CTL_AMPDU;
  551. /* inform mac80211 about what happened with the frame */
  552. switch (status & TX_STATUS_MSK) {
  553. case TX_STATUS_SUCCESS:
  554. case TX_STATUS_DIRECT_DONE:
  555. info->flags |= IEEE80211_TX_STAT_ACK;
  556. break;
  557. case TX_STATUS_FAIL_DEST_PS:
  558. info->flags |= IEEE80211_TX_STAT_TX_FILTERED;
  559. break;
  560. default:
  561. break;
  562. }
  563. info->status.rates[0].count = tx_resp->failure_frame + 1;
  564. iwl_mvm_hwrate_to_tx_status(le32_to_cpu(tx_resp->initial_rate),
  565. info);
  566. /* Single frame failure in an AMPDU queue => send BAR */
  567. if (txq_id >= mvm->first_agg_queue &&
  568. !(info->flags & IEEE80211_TX_STAT_ACK))
  569. info->flags |= IEEE80211_TX_STAT_AMPDU_NO_BACK;
  570. /* W/A FW bug: seq_ctl is wrong when the status isn't success */
  571. if (status != TX_STATUS_SUCCESS) {
  572. struct ieee80211_hdr *hdr = (void *)skb->data;
  573. seq_ctl = le16_to_cpu(hdr->seq_ctrl);
  574. }
  575. /*
  576. * TODO: this is not accurate if we are freeing more than one
  577. * packet.
  578. */
  579. info->status.tx_time =
  580. le16_to_cpu(tx_resp->wireless_media_time);
  581. BUILD_BUG_ON(ARRAY_SIZE(info->status.status_driver_data) < 1);
  582. info->status.status_driver_data[0] =
  583. (void *)(uintptr_t)tx_resp->reduced_tpc;
  584. ieee80211_tx_status(mvm->hw, skb);
  585. }
  586. if (txq_id >= mvm->first_agg_queue) {
  587. /* If this is an aggregation queue, we use the ssn since:
  588. * ssn = wifi seq_num % 256.
  589. * The seq_ctl is the sequence control of the packet to which
  590. * this Tx response relates. But if there is a hole in the
  591. * bitmap of the BA we received, this Tx response may allow to
  592. * reclaim the hole and all the subsequent packets that were
  593. * already acked. In that case, seq_ctl != ssn, and the next
  594. * packet to be reclaimed will be ssn and not seq_ctl. In that
  595. * case, several packets will be reclaimed even if
  596. * frame_count = 1.
  597. *
  598. * The ssn is the index (% 256) of the latest packet that has
  599. * treated (acked / dropped) + 1.
  600. */
  601. next_reclaimed = ssn;
  602. } else {
  603. /* The next packet to be reclaimed is the one after this one */
  604. next_reclaimed = IEEE80211_SEQ_TO_SN(seq_ctl + 0x10);
  605. }
  606. IWL_DEBUG_TX_REPLY(mvm,
  607. "TXQ %d status %s (0x%08x)\n",
  608. txq_id, iwl_mvm_get_tx_fail_reason(status), status);
  609. IWL_DEBUG_TX_REPLY(mvm,
  610. "\t\t\t\tinitial_rate 0x%x retries %d, idx=%d ssn=%d next_reclaimed=0x%x seq_ctl=0x%x\n",
  611. le32_to_cpu(tx_resp->initial_rate),
  612. tx_resp->failure_frame, SEQ_TO_INDEX(sequence),
  613. ssn, next_reclaimed, seq_ctl);
  614. rcu_read_lock();
  615. sta = rcu_dereference(mvm->fw_id_to_mac_id[sta_id]);
  616. /*
  617. * sta can't be NULL otherwise it'd mean that the sta has been freed in
  618. * the firmware while we still have packets for it in the Tx queues.
  619. */
  620. if (WARN_ON_ONCE(!sta))
  621. goto out;
  622. if (!IS_ERR(sta)) {
  623. mvmsta = iwl_mvm_sta_from_mac80211(sta);
  624. if (tid != IWL_TID_NON_QOS) {
  625. struct iwl_mvm_tid_data *tid_data =
  626. &mvmsta->tid_data[tid];
  627. spin_lock_bh(&mvmsta->lock);
  628. tid_data->next_reclaimed = next_reclaimed;
  629. IWL_DEBUG_TX_REPLY(mvm, "Next reclaimed packet:%d\n",
  630. next_reclaimed);
  631. iwl_mvm_check_ratid_empty(mvm, sta, tid);
  632. spin_unlock_bh(&mvmsta->lock);
  633. }
  634. if (mvmsta->next_status_eosp) {
  635. mvmsta->next_status_eosp = false;
  636. ieee80211_sta_eosp(sta);
  637. }
  638. } else {
  639. mvmsta = NULL;
  640. }
  641. /*
  642. * If the txq is not an AMPDU queue, there is no chance we freed
  643. * several skbs. Check that out...
  644. */
  645. if (txq_id >= mvm->first_agg_queue)
  646. goto out;
  647. /* We can't free more than one frame at once on a shared queue */
  648. WARN_ON(skb_freed > 1);
  649. /* If we have still frames for this STA nothing to do here */
  650. if (!atomic_sub_and_test(skb_freed, &mvm->pending_frames[sta_id]))
  651. goto out;
  652. if (mvmsta && mvmsta->vif->type == NL80211_IFTYPE_AP) {
  653. /*
  654. * If there are no pending frames for this STA and
  655. * the tx to this station is not disabled, notify
  656. * mac80211 that this station can now wake up in its
  657. * STA table.
  658. * If mvmsta is not NULL, sta is valid.
  659. */
  660. spin_lock_bh(&mvmsta->lock);
  661. if (!mvmsta->disable_tx)
  662. ieee80211_sta_block_awake(mvm->hw, sta, false);
  663. spin_unlock_bh(&mvmsta->lock);
  664. }
  665. if (PTR_ERR(sta) == -EBUSY || PTR_ERR(sta) == -ENOENT) {
  666. /*
  667. * We are draining and this was the last packet - pre_rcu_remove
  668. * has been called already. We might be after the
  669. * synchronize_net already.
  670. * Don't rely on iwl_mvm_rm_sta to see the empty Tx queues.
  671. */
  672. set_bit(sta_id, mvm->sta_drained);
  673. schedule_work(&mvm->sta_drained_wk);
  674. }
  675. out:
  676. rcu_read_unlock();
  677. }
  678. #ifdef CONFIG_IWLWIFI_DEBUG
  679. #define AGG_TX_STATE_(x) case AGG_TX_STATE_ ## x: return #x
  680. static const char *iwl_get_agg_tx_status(u16 status)
  681. {
  682. switch (status & AGG_TX_STATE_STATUS_MSK) {
  683. AGG_TX_STATE_(TRANSMITTED);
  684. AGG_TX_STATE_(UNDERRUN);
  685. AGG_TX_STATE_(BT_PRIO);
  686. AGG_TX_STATE_(FEW_BYTES);
  687. AGG_TX_STATE_(ABORT);
  688. AGG_TX_STATE_(LAST_SENT_TTL);
  689. AGG_TX_STATE_(LAST_SENT_TRY_CNT);
  690. AGG_TX_STATE_(LAST_SENT_BT_KILL);
  691. AGG_TX_STATE_(SCD_QUERY);
  692. AGG_TX_STATE_(TEST_BAD_CRC32);
  693. AGG_TX_STATE_(RESPONSE);
  694. AGG_TX_STATE_(DUMP_TX);
  695. AGG_TX_STATE_(DELAY_TX);
  696. }
  697. return "UNKNOWN";
  698. }
  699. static void iwl_mvm_rx_tx_cmd_agg_dbg(struct iwl_mvm *mvm,
  700. struct iwl_rx_packet *pkt)
  701. {
  702. struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
  703. struct agg_tx_status *frame_status = &tx_resp->status;
  704. int i;
  705. for (i = 0; i < tx_resp->frame_count; i++) {
  706. u16 fstatus = le16_to_cpu(frame_status[i].status);
  707. IWL_DEBUG_TX_REPLY(mvm,
  708. "status %s (0x%04x), try-count (%d) seq (0x%x)\n",
  709. iwl_get_agg_tx_status(fstatus),
  710. fstatus & AGG_TX_STATE_STATUS_MSK,
  711. (fstatus & AGG_TX_STATE_TRY_CNT_MSK) >>
  712. AGG_TX_STATE_TRY_CNT_POS,
  713. le16_to_cpu(frame_status[i].sequence));
  714. }
  715. }
  716. #else
  717. static void iwl_mvm_rx_tx_cmd_agg_dbg(struct iwl_mvm *mvm,
  718. struct iwl_rx_packet *pkt)
  719. {}
  720. #endif /* CONFIG_IWLWIFI_DEBUG */
  721. static void iwl_mvm_rx_tx_cmd_agg(struct iwl_mvm *mvm,
  722. struct iwl_rx_packet *pkt)
  723. {
  724. struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
  725. int sta_id = IWL_MVM_TX_RES_GET_RA(tx_resp->ra_tid);
  726. int tid = IWL_MVM_TX_RES_GET_TID(tx_resp->ra_tid);
  727. u16 sequence = le16_to_cpu(pkt->hdr.sequence);
  728. struct ieee80211_sta *sta;
  729. if (WARN_ON_ONCE(SEQ_TO_QUEUE(sequence) < mvm->first_agg_queue))
  730. return;
  731. if (WARN_ON_ONCE(tid == IWL_TID_NON_QOS))
  732. return;
  733. iwl_mvm_rx_tx_cmd_agg_dbg(mvm, pkt);
  734. rcu_read_lock();
  735. sta = rcu_dereference(mvm->fw_id_to_mac_id[sta_id]);
  736. if (!WARN_ON_ONCE(IS_ERR_OR_NULL(sta))) {
  737. struct iwl_mvm_sta *mvmsta = iwl_mvm_sta_from_mac80211(sta);
  738. mvmsta->tid_data[tid].rate_n_flags =
  739. le32_to_cpu(tx_resp->initial_rate);
  740. mvmsta->tid_data[tid].reduced_tpc = tx_resp->reduced_tpc;
  741. mvmsta->tid_data[tid].tx_time =
  742. le16_to_cpu(tx_resp->wireless_media_time);
  743. }
  744. rcu_read_unlock();
  745. }
  746. int iwl_mvm_rx_tx_cmd(struct iwl_mvm *mvm, struct iwl_rx_cmd_buffer *rxb,
  747. struct iwl_device_cmd *cmd)
  748. {
  749. struct iwl_rx_packet *pkt = rxb_addr(rxb);
  750. struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
  751. if (tx_resp->frame_count == 1)
  752. iwl_mvm_rx_tx_cmd_single(mvm, pkt);
  753. else
  754. iwl_mvm_rx_tx_cmd_agg(mvm, pkt);
  755. return 0;
  756. }
  757. static void iwl_mvm_tx_info_from_ba_notif(struct ieee80211_tx_info *info,
  758. struct iwl_mvm_ba_notif *ba_notif,
  759. struct iwl_mvm_tid_data *tid_data)
  760. {
  761. info->flags |= IEEE80211_TX_STAT_AMPDU;
  762. info->status.ampdu_ack_len = ba_notif->txed_2_done;
  763. info->status.ampdu_len = ba_notif->txed;
  764. iwl_mvm_hwrate_to_tx_status(tid_data->rate_n_flags,
  765. info);
  766. /* TODO: not accounted if the whole A-MPDU failed */
  767. info->status.tx_time = tid_data->tx_time;
  768. info->status.status_driver_data[0] =
  769. (void *)(uintptr_t)tid_data->reduced_tpc;
  770. }
  771. int iwl_mvm_rx_ba_notif(struct iwl_mvm *mvm, struct iwl_rx_cmd_buffer *rxb,
  772. struct iwl_device_cmd *cmd)
  773. {
  774. struct iwl_rx_packet *pkt = rxb_addr(rxb);
  775. struct iwl_mvm_ba_notif *ba_notif = (void *)pkt->data;
  776. struct sk_buff_head reclaimed_skbs;
  777. struct iwl_mvm_tid_data *tid_data;
  778. struct ieee80211_sta *sta;
  779. struct iwl_mvm_sta *mvmsta;
  780. struct sk_buff *skb;
  781. int sta_id, tid, freed;
  782. /* "flow" corresponds to Tx queue */
  783. u16 scd_flow = le16_to_cpu(ba_notif->scd_flow);
  784. /* "ssn" is start of block-ack Tx window, corresponds to index
  785. * (in Tx queue's circular buffer) of first TFD/frame in window */
  786. u16 ba_resp_scd_ssn = le16_to_cpu(ba_notif->scd_ssn);
  787. sta_id = ba_notif->sta_id;
  788. tid = ba_notif->tid;
  789. rcu_read_lock();
  790. sta = rcu_dereference(mvm->fw_id_to_mac_id[sta_id]);
  791. /* Reclaiming frames for a station that has been deleted ? */
  792. if (WARN_ON_ONCE(IS_ERR_OR_NULL(sta))) {
  793. rcu_read_unlock();
  794. return 0;
  795. }
  796. mvmsta = iwl_mvm_sta_from_mac80211(sta);
  797. tid_data = &mvmsta->tid_data[tid];
  798. if (WARN_ONCE(tid_data->txq_id != scd_flow, "Q %d, tid %d, flow %d",
  799. tid_data->txq_id, tid, scd_flow)) {
  800. rcu_read_unlock();
  801. return 0;
  802. }
  803. spin_lock_bh(&mvmsta->lock);
  804. __skb_queue_head_init(&reclaimed_skbs);
  805. /*
  806. * Release all TFDs before the SSN, i.e. all TFDs in front of
  807. * block-ack window (we assume that they've been successfully
  808. * transmitted ... if not, it's too late anyway).
  809. */
  810. iwl_trans_reclaim(mvm->trans, scd_flow, ba_resp_scd_ssn,
  811. &reclaimed_skbs);
  812. IWL_DEBUG_TX_REPLY(mvm,
  813. "BA_NOTIFICATION Received from %pM, sta_id = %d\n",
  814. (u8 *)&ba_notif->sta_addr_lo32,
  815. ba_notif->sta_id);
  816. IWL_DEBUG_TX_REPLY(mvm,
  817. "TID = %d, SeqCtl = %d, bitmap = 0x%llx, scd_flow = %d, scd_ssn = %d sent:%d, acked:%d\n",
  818. ba_notif->tid, le16_to_cpu(ba_notif->seq_ctl),
  819. (unsigned long long)le64_to_cpu(ba_notif->bitmap),
  820. scd_flow, ba_resp_scd_ssn, ba_notif->txed,
  821. ba_notif->txed_2_done);
  822. tid_data->next_reclaimed = ba_resp_scd_ssn;
  823. iwl_mvm_check_ratid_empty(mvm, sta, tid);
  824. freed = 0;
  825. skb_queue_walk(&reclaimed_skbs, skb) {
  826. struct ieee80211_hdr *hdr = (void *)skb->data;
  827. struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
  828. if (ieee80211_is_data_qos(hdr->frame_control))
  829. freed++;
  830. else
  831. WARN_ON_ONCE(1);
  832. iwl_trans_free_tx_cmd(mvm->trans, info->driver_data[1]);
  833. memset(&info->status, 0, sizeof(info->status));
  834. /* Packet was transmitted successfully, failures come as single
  835. * frames because before failing a frame the firmware transmits
  836. * it without aggregation at least once.
  837. */
  838. info->flags |= IEEE80211_TX_STAT_ACK;
  839. /* this is the first skb we deliver in this batch */
  840. /* put the rate scaling data there */
  841. if (freed == 1)
  842. iwl_mvm_tx_info_from_ba_notif(info, ba_notif, tid_data);
  843. }
  844. spin_unlock_bh(&mvmsta->lock);
  845. /* We got a BA notif with 0 acked or scd_ssn didn't progress which is
  846. * possible (i.e. first MPDU in the aggregation wasn't acked)
  847. * Still it's important to update RS about sent vs. acked.
  848. */
  849. if (skb_queue_empty(&reclaimed_skbs)) {
  850. struct ieee80211_tx_info ba_info = {};
  851. struct ieee80211_chanctx_conf *chanctx_conf = NULL;
  852. if (mvmsta->vif)
  853. chanctx_conf =
  854. rcu_dereference(mvmsta->vif->chanctx_conf);
  855. if (WARN_ON_ONCE(!chanctx_conf))
  856. goto out;
  857. ba_info.band = chanctx_conf->def.chan->band;
  858. iwl_mvm_tx_info_from_ba_notif(&ba_info, ba_notif, tid_data);
  859. IWL_DEBUG_TX_REPLY(mvm, "No reclaim. Update rs directly\n");
  860. iwl_mvm_rs_tx_status(mvm, sta, tid, &ba_info);
  861. }
  862. out:
  863. rcu_read_unlock();
  864. while (!skb_queue_empty(&reclaimed_skbs)) {
  865. skb = __skb_dequeue(&reclaimed_skbs);
  866. ieee80211_tx_status(mvm->hw, skb);
  867. }
  868. return 0;
  869. }
  870. int iwl_mvm_flush_tx_path(struct iwl_mvm *mvm, u32 tfd_msk, bool sync)
  871. {
  872. int ret;
  873. struct iwl_tx_path_flush_cmd flush_cmd = {
  874. .queues_ctl = cpu_to_le32(tfd_msk),
  875. .flush_ctl = cpu_to_le16(DUMP_TX_FIFO_FLUSH),
  876. };
  877. u32 flags = sync ? 0 : CMD_ASYNC;
  878. ret = iwl_mvm_send_cmd_pdu(mvm, TXPATH_FLUSH, flags,
  879. sizeof(flush_cmd), &flush_cmd);
  880. if (ret)
  881. IWL_ERR(mvm, "Failed to send flush command (%d)\n", ret);
  882. return ret;
  883. }