mirror of
https://github.com/AuxXxilium/linux_dsm_epyc7002.git
synced 2024-12-21 21:29:49 +07:00
929e6edea5
Currently rs uses the info in mac80211 tx status which is a translation of the actual rate coming up from the FW in the tx response. This is matched up against the LQ table first rate to make sure this tx frame used the current LQ table. Instead of using the translated mac80211 info it's easier and cleaner to just pass the actual tx response rate in the driver private data and use that for matching. This becomes even more important once the FW begins to decide on its own whether to use STBC/BFER/SISO. Signed-off-by: Eyal Shapira <eyalx.shapira@intel.com> Signed-off-by: Emmanuel Grumbach <emmanuel.grumbach@intel.com>
1066 lines
32 KiB
C
1066 lines
32 KiB
C
/******************************************************************************
|
|
*
|
|
* This file is provided under a dual BSD/GPLv2 license. When using or
|
|
* redistributing this file, you may do so under either license.
|
|
*
|
|
* GPL LICENSE SUMMARY
|
|
*
|
|
* Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
|
|
* Copyright(c) 2013 - 2014 Intel Mobile Communications GmbH
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of version 2 of the GNU General Public License as
|
|
* published by the Free Software Foundation.
|
|
*
|
|
* This program is distributed in the hope that it will be useful, but
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110,
|
|
* USA
|
|
*
|
|
* The full GNU General Public License is included in this distribution
|
|
* in the file called COPYING.
|
|
*
|
|
* Contact Information:
|
|
* Intel Linux Wireless <ilw@linux.intel.com>
|
|
* Intel Corporation, 5200 N.E. Elam Young Parkway, Hillsboro, OR 97124-6497
|
|
*
|
|
* BSD LICENSE
|
|
*
|
|
* Copyright(c) 2012 - 2014 Intel Corporation. All rights reserved.
|
|
* Copyright(c) 2013 - 2014 Intel Mobile Communications GmbH
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
*
|
|
* * Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* * Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in
|
|
* the documentation and/or other materials provided with the
|
|
* distribution.
|
|
* * Neither the name Intel Corporation nor the names of its
|
|
* contributors may be used to endorse or promote products derived
|
|
* from this software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*
|
|
*****************************************************************************/
|
|
#include <linux/ieee80211.h>
|
|
#include <linux/etherdevice.h>
|
|
|
|
#include "iwl-trans.h"
|
|
#include "iwl-eeprom-parse.h"
|
|
#include "mvm.h"
|
|
#include "sta.h"
|
|
|
|
/*
|
|
* Sets most of the Tx cmd's fields
|
|
*/
|
|
void iwl_mvm_set_tx_cmd(struct iwl_mvm *mvm, struct sk_buff *skb,
|
|
struct iwl_tx_cmd *tx_cmd,
|
|
struct ieee80211_tx_info *info, u8 sta_id)
|
|
{
|
|
struct ieee80211_hdr *hdr = (void *)skb->data;
|
|
__le16 fc = hdr->frame_control;
|
|
u32 tx_flags = le32_to_cpu(tx_cmd->tx_flags);
|
|
u32 len = skb->len + FCS_LEN;
|
|
u8 ac;
|
|
|
|
if (!(info->flags & IEEE80211_TX_CTL_NO_ACK))
|
|
tx_flags |= TX_CMD_FLG_ACK;
|
|
else
|
|
tx_flags &= ~TX_CMD_FLG_ACK;
|
|
|
|
if (ieee80211_is_probe_resp(fc))
|
|
tx_flags |= TX_CMD_FLG_TSF;
|
|
|
|
if (ieee80211_has_morefrags(fc))
|
|
tx_flags |= TX_CMD_FLG_MORE_FRAG;
|
|
|
|
if (ieee80211_is_data_qos(fc)) {
|
|
u8 *qc = ieee80211_get_qos_ctl(hdr);
|
|
tx_cmd->tid_tspec = qc[0] & 0xf;
|
|
tx_flags &= ~TX_CMD_FLG_SEQ_CTL;
|
|
} else if (ieee80211_is_back_req(fc)) {
|
|
struct ieee80211_bar *bar = (void *)skb->data;
|
|
u16 control = le16_to_cpu(bar->control);
|
|
|
|
tx_flags |= TX_CMD_FLG_ACK | TX_CMD_FLG_BAR;
|
|
tx_cmd->tid_tspec = (control &
|
|
IEEE80211_BAR_CTRL_TID_INFO_MASK) >>
|
|
IEEE80211_BAR_CTRL_TID_INFO_SHIFT;
|
|
WARN_ON_ONCE(tx_cmd->tid_tspec >= IWL_MAX_TID_COUNT);
|
|
} else {
|
|
tx_cmd->tid_tspec = IWL_TID_NON_QOS;
|
|
if (info->flags & IEEE80211_TX_CTL_ASSIGN_SEQ)
|
|
tx_flags |= TX_CMD_FLG_SEQ_CTL;
|
|
else
|
|
tx_flags &= ~TX_CMD_FLG_SEQ_CTL;
|
|
}
|
|
|
|
/* Default to 0 (BE) when tid_spec is set to IWL_TID_NON_QOS */
|
|
if (tx_cmd->tid_tspec < IWL_MAX_TID_COUNT)
|
|
ac = tid_to_mac80211_ac[tx_cmd->tid_tspec];
|
|
else
|
|
ac = tid_to_mac80211_ac[0];
|
|
|
|
tx_flags |= iwl_mvm_bt_coex_tx_prio(mvm, hdr, info, ac) <<
|
|
TX_CMD_FLG_BT_PRIO_POS;
|
|
|
|
if (ieee80211_is_mgmt(fc)) {
|
|
if (ieee80211_is_assoc_req(fc) || ieee80211_is_reassoc_req(fc))
|
|
tx_cmd->pm_frame_timeout = cpu_to_le16(3);
|
|
else
|
|
tx_cmd->pm_frame_timeout = cpu_to_le16(2);
|
|
|
|
/* The spec allows Action frames in A-MPDU, we don't support
|
|
* it
|
|
*/
|
|
WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_AMPDU);
|
|
} else if (info->control.flags & IEEE80211_TX_CTRL_PORT_CTRL_PROTO) {
|
|
tx_cmd->pm_frame_timeout = cpu_to_le16(2);
|
|
} else {
|
|
tx_cmd->pm_frame_timeout = 0;
|
|
}
|
|
|
|
if (ieee80211_is_data(fc) && len > mvm->rts_threshold &&
|
|
!is_multicast_ether_addr(ieee80211_get_DA(hdr)))
|
|
tx_flags |= TX_CMD_FLG_PROT_REQUIRE;
|
|
|
|
if ((mvm->fw->ucode_capa.capa[0] &
|
|
IWL_UCODE_TLV_CAPA_TXPOWER_INSERTION_SUPPORT) &&
|
|
ieee80211_action_contains_tpc(skb))
|
|
tx_flags |= TX_CMD_FLG_WRITE_TX_POWER;
|
|
|
|
tx_cmd->tx_flags = cpu_to_le32(tx_flags);
|
|
/* Total # bytes to be transmitted */
|
|
tx_cmd->len = cpu_to_le16((u16)skb->len);
|
|
tx_cmd->next_frame_len = 0;
|
|
tx_cmd->life_time = cpu_to_le32(TX_CMD_LIFE_TIME_INFINITE);
|
|
tx_cmd->sta_id = sta_id;
|
|
}
|
|
|
|
/*
|
|
* Sets the fields in the Tx cmd that are rate related
|
|
*/
|
|
void iwl_mvm_set_tx_cmd_rate(struct iwl_mvm *mvm, struct iwl_tx_cmd *tx_cmd,
|
|
struct ieee80211_tx_info *info,
|
|
struct ieee80211_sta *sta, __le16 fc)
|
|
{
|
|
u32 rate_flags;
|
|
int rate_idx;
|
|
u8 rate_plcp;
|
|
|
|
/* Set retry limit on RTS packets */
|
|
tx_cmd->rts_retry_limit = IWL_RTS_DFAULT_RETRY_LIMIT;
|
|
|
|
/* Set retry limit on DATA packets and Probe Responses*/
|
|
if (ieee80211_is_probe_resp(fc)) {
|
|
tx_cmd->data_retry_limit = IWL_MGMT_DFAULT_RETRY_LIMIT;
|
|
tx_cmd->rts_retry_limit =
|
|
min(tx_cmd->data_retry_limit, tx_cmd->rts_retry_limit);
|
|
} else if (ieee80211_is_back_req(fc)) {
|
|
tx_cmd->data_retry_limit = IWL_BAR_DFAULT_RETRY_LIMIT;
|
|
} else {
|
|
tx_cmd->data_retry_limit = IWL_DEFAULT_TX_RETRY;
|
|
}
|
|
|
|
/*
|
|
* for data packets, rate info comes from the table inside the fw. This
|
|
* table is controlled by LINK_QUALITY commands
|
|
*/
|
|
|
|
if (ieee80211_is_data(fc) && sta) {
|
|
tx_cmd->initial_rate_index = 0;
|
|
tx_cmd->tx_flags |= cpu_to_le32(TX_CMD_FLG_STA_RATE);
|
|
return;
|
|
} else if (ieee80211_is_back_req(fc)) {
|
|
tx_cmd->tx_flags |=
|
|
cpu_to_le32(TX_CMD_FLG_ACK | TX_CMD_FLG_BAR);
|
|
}
|
|
|
|
/* HT rate doesn't make sense for a non data frame */
|
|
WARN_ONCE(info->control.rates[0].flags & IEEE80211_TX_RC_MCS,
|
|
"Got an HT rate (flags:0x%x/mcs:%d) for a non data frame (fc:0x%x)\n",
|
|
info->control.rates[0].flags,
|
|
info->control.rates[0].idx,
|
|
le16_to_cpu(fc));
|
|
|
|
rate_idx = info->control.rates[0].idx;
|
|
/* if the rate isn't a well known legacy rate, take the lowest one */
|
|
if (rate_idx < 0 || rate_idx > IWL_RATE_COUNT_LEGACY)
|
|
rate_idx = rate_lowest_index(
|
|
&mvm->nvm_data->bands[info->band], sta);
|
|
|
|
/* For 5 GHZ band, remap mac80211 rate indices into driver indices */
|
|
if (info->band == IEEE80211_BAND_5GHZ)
|
|
rate_idx += IWL_FIRST_OFDM_RATE;
|
|
|
|
/* For 2.4 GHZ band, check that there is no need to remap */
|
|
BUILD_BUG_ON(IWL_FIRST_CCK_RATE != 0);
|
|
|
|
/* Get PLCP rate for tx_cmd->rate_n_flags */
|
|
rate_plcp = iwl_mvm_mac80211_idx_to_hwrate(rate_idx);
|
|
|
|
mvm->mgmt_last_antenna_idx =
|
|
iwl_mvm_next_antenna(mvm, iwl_mvm_get_valid_tx_ant(mvm),
|
|
mvm->mgmt_last_antenna_idx);
|
|
|
|
if (info->band == IEEE80211_BAND_2GHZ &&
|
|
!iwl_mvm_bt_coex_is_shared_ant_avail(mvm))
|
|
rate_flags = BIT(mvm->cfg->non_shared_ant) << RATE_MCS_ANT_POS;
|
|
else
|
|
rate_flags =
|
|
BIT(mvm->mgmt_last_antenna_idx) << RATE_MCS_ANT_POS;
|
|
|
|
/* Set CCK flag as needed */
|
|
if ((rate_idx >= IWL_FIRST_CCK_RATE) && (rate_idx <= IWL_LAST_CCK_RATE))
|
|
rate_flags |= RATE_MCS_CCK_MSK;
|
|
|
|
/* Set the rate in the TX cmd */
|
|
tx_cmd->rate_n_flags = cpu_to_le32((u32)rate_plcp | rate_flags);
|
|
}
|
|
|
|
/*
|
|
* Sets the fields in the Tx cmd that are crypto related
|
|
*/
|
|
void iwl_mvm_set_tx_cmd_crypto(struct iwl_mvm *mvm,
|
|
struct ieee80211_tx_info *info,
|
|
struct iwl_tx_cmd *tx_cmd,
|
|
struct sk_buff *skb_frag)
|
|
{
|
|
struct ieee80211_key_conf *keyconf = info->control.hw_key;
|
|
|
|
switch (keyconf->cipher) {
|
|
case WLAN_CIPHER_SUITE_CCMP:
|
|
tx_cmd->sec_ctl = TX_CMD_SEC_CCM;
|
|
memcpy(tx_cmd->key, keyconf->key, keyconf->keylen);
|
|
if (info->flags & IEEE80211_TX_CTL_AMPDU)
|
|
tx_cmd->tx_flags |= cpu_to_le32(TX_CMD_FLG_CCMP_AGG);
|
|
break;
|
|
|
|
case WLAN_CIPHER_SUITE_TKIP:
|
|
tx_cmd->sec_ctl = TX_CMD_SEC_TKIP;
|
|
ieee80211_get_tkip_p2k(keyconf, skb_frag, tx_cmd->key);
|
|
break;
|
|
|
|
case WLAN_CIPHER_SUITE_WEP104:
|
|
tx_cmd->sec_ctl |= TX_CMD_SEC_KEY128;
|
|
/* fall through */
|
|
case WLAN_CIPHER_SUITE_WEP40:
|
|
tx_cmd->sec_ctl |= TX_CMD_SEC_WEP |
|
|
((keyconf->keyidx << TX_CMD_SEC_WEP_KEY_IDX_POS) &
|
|
TX_CMD_SEC_WEP_KEY_IDX_MSK);
|
|
|
|
memcpy(&tx_cmd->key[3], keyconf->key, keyconf->keylen);
|
|
break;
|
|
default:
|
|
tx_cmd->sec_ctl |= TX_CMD_SEC_EXT;
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Allocates and sets the Tx cmd the driver data pointers in the skb
|
|
*/
|
|
static struct iwl_device_cmd *
|
|
iwl_mvm_set_tx_params(struct iwl_mvm *mvm, struct sk_buff *skb,
|
|
struct ieee80211_sta *sta, u8 sta_id)
|
|
{
|
|
struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
|
|
struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
|
|
struct iwl_device_cmd *dev_cmd;
|
|
struct iwl_tx_cmd *tx_cmd;
|
|
|
|
dev_cmd = iwl_trans_alloc_tx_cmd(mvm->trans);
|
|
|
|
if (unlikely(!dev_cmd))
|
|
return NULL;
|
|
|
|
memset(dev_cmd, 0, sizeof(*dev_cmd));
|
|
dev_cmd->hdr.cmd = TX_CMD;
|
|
tx_cmd = (struct iwl_tx_cmd *)dev_cmd->payload;
|
|
|
|
if (info->control.hw_key)
|
|
iwl_mvm_set_tx_cmd_crypto(mvm, info, tx_cmd, skb);
|
|
|
|
iwl_mvm_set_tx_cmd(mvm, skb, tx_cmd, info, sta_id);
|
|
|
|
iwl_mvm_set_tx_cmd_rate(mvm, tx_cmd, info, sta, hdr->frame_control);
|
|
|
|
memset(&info->status, 0, sizeof(info->status));
|
|
|
|
info->driver_data[0] = NULL;
|
|
info->driver_data[1] = dev_cmd;
|
|
|
|
return dev_cmd;
|
|
}
|
|
|
|
int iwl_mvm_tx_skb_non_sta(struct iwl_mvm *mvm, struct sk_buff *skb)
|
|
{
|
|
struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
|
|
struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
|
|
struct iwl_device_cmd *dev_cmd;
|
|
struct iwl_tx_cmd *tx_cmd;
|
|
u8 sta_id;
|
|
|
|
if (WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_AMPDU))
|
|
return -1;
|
|
|
|
if (WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_SEND_AFTER_DTIM &&
|
|
(!info->control.vif ||
|
|
info->hw_queue != info->control.vif->cab_queue)))
|
|
return -1;
|
|
|
|
/*
|
|
* IWL_MVM_OFFCHANNEL_QUEUE is used for ROC packets that can be used
|
|
* in 2 different types of vifs, P2P & STATION. P2P uses the offchannel
|
|
* queue. STATION (HS2.0) uses the auxiliary context of the FW,
|
|
* and hence needs to be sent on the aux queue
|
|
*/
|
|
if (IEEE80211_SKB_CB(skb)->hw_queue == IWL_MVM_OFFCHANNEL_QUEUE &&
|
|
info->control.vif->type == NL80211_IFTYPE_STATION)
|
|
IEEE80211_SKB_CB(skb)->hw_queue = mvm->aux_queue;
|
|
|
|
/*
|
|
* If the interface on which frame is sent is the P2P_DEVICE
|
|
* or an AP/GO interface use the broadcast station associated
|
|
* with it; otherwise use the AUX station.
|
|
*/
|
|
if (info->control.vif &&
|
|
(info->control.vif->type == NL80211_IFTYPE_P2P_DEVICE ||
|
|
info->control.vif->type == NL80211_IFTYPE_AP)) {
|
|
struct iwl_mvm_vif *mvmvif =
|
|
iwl_mvm_vif_from_mac80211(info->control.vif);
|
|
sta_id = mvmvif->bcast_sta.sta_id;
|
|
} else {
|
|
sta_id = mvm->aux_sta.sta_id;
|
|
}
|
|
|
|
IWL_DEBUG_TX(mvm, "station Id %d, queue=%d\n", sta_id, info->hw_queue);
|
|
|
|
dev_cmd = iwl_mvm_set_tx_params(mvm, skb, NULL, sta_id);
|
|
if (!dev_cmd)
|
|
return -1;
|
|
|
|
/* From now on, we cannot access info->control */
|
|
tx_cmd = (struct iwl_tx_cmd *)dev_cmd->payload;
|
|
|
|
/* Copy MAC header from skb into command buffer */
|
|
memcpy(tx_cmd->hdr, hdr, ieee80211_hdrlen(hdr->frame_control));
|
|
|
|
if (iwl_trans_tx(mvm->trans, skb, dev_cmd, info->hw_queue)) {
|
|
iwl_trans_free_tx_cmd(mvm->trans, dev_cmd);
|
|
return -1;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
/*
|
|
* Sets the fields in the Tx cmd that are crypto related
|
|
*/
|
|
int iwl_mvm_tx_skb(struct iwl_mvm *mvm, struct sk_buff *skb,
|
|
struct ieee80211_sta *sta)
|
|
{
|
|
struct ieee80211_hdr *hdr = (struct ieee80211_hdr *)skb->data;
|
|
struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
|
|
struct iwl_mvm_sta *mvmsta;
|
|
struct iwl_device_cmd *dev_cmd;
|
|
struct iwl_tx_cmd *tx_cmd;
|
|
__le16 fc;
|
|
u16 seq_number = 0;
|
|
u8 tid = IWL_MAX_TID_COUNT;
|
|
u8 txq_id = info->hw_queue;
|
|
bool is_data_qos = false, is_ampdu = false;
|
|
|
|
mvmsta = iwl_mvm_sta_from_mac80211(sta);
|
|
fc = hdr->frame_control;
|
|
|
|
if (WARN_ON_ONCE(!mvmsta))
|
|
return -1;
|
|
|
|
if (WARN_ON_ONCE(mvmsta->sta_id == IWL_MVM_STATION_COUNT))
|
|
return -1;
|
|
|
|
dev_cmd = iwl_mvm_set_tx_params(mvm, skb, sta, mvmsta->sta_id);
|
|
if (!dev_cmd)
|
|
goto drop;
|
|
|
|
tx_cmd = (struct iwl_tx_cmd *)dev_cmd->payload;
|
|
/* From now on, we cannot access info->control */
|
|
|
|
/*
|
|
* we handle that entirely ourselves -- for uAPSD the firmware
|
|
* will always send a notification, and for PS-Poll responses
|
|
* we'll notify mac80211 when getting frame status
|
|
*/
|
|
info->flags &= ~IEEE80211_TX_STATUS_EOSP;
|
|
|
|
spin_lock(&mvmsta->lock);
|
|
|
|
if (ieee80211_is_data_qos(fc) && !ieee80211_is_qos_nullfunc(fc)) {
|
|
u8 *qc = NULL;
|
|
qc = ieee80211_get_qos_ctl(hdr);
|
|
tid = qc[0] & IEEE80211_QOS_CTL_TID_MASK;
|
|
if (WARN_ON_ONCE(tid >= IWL_MAX_TID_COUNT))
|
|
goto drop_unlock_sta;
|
|
|
|
seq_number = mvmsta->tid_data[tid].seq_number;
|
|
seq_number &= IEEE80211_SCTL_SEQ;
|
|
hdr->seq_ctrl &= cpu_to_le16(IEEE80211_SCTL_FRAG);
|
|
hdr->seq_ctrl |= cpu_to_le16(seq_number);
|
|
is_data_qos = true;
|
|
is_ampdu = info->flags & IEEE80211_TX_CTL_AMPDU;
|
|
}
|
|
|
|
/* Copy MAC header from skb into command buffer */
|
|
memcpy(tx_cmd->hdr, hdr, ieee80211_hdrlen(fc));
|
|
|
|
WARN_ON_ONCE(info->flags & IEEE80211_TX_CTL_SEND_AFTER_DTIM);
|
|
|
|
if (sta->tdls) {
|
|
/* default to TID 0 for non-QoS packets */
|
|
u8 tdls_tid = tid == IWL_MAX_TID_COUNT ? 0 : tid;
|
|
|
|
txq_id = mvmsta->hw_queue[tid_to_mac80211_ac[tdls_tid]];
|
|
}
|
|
|
|
if (is_ampdu) {
|
|
if (WARN_ON_ONCE(mvmsta->tid_data[tid].state != IWL_AGG_ON))
|
|
goto drop_unlock_sta;
|
|
txq_id = mvmsta->tid_data[tid].txq_id;
|
|
}
|
|
|
|
IWL_DEBUG_TX(mvm, "TX to [%d|%d] Q:%d - seq: 0x%x\n", mvmsta->sta_id,
|
|
tid, txq_id, IEEE80211_SEQ_TO_SN(seq_number));
|
|
|
|
if (iwl_trans_tx(mvm->trans, skb, dev_cmd, txq_id))
|
|
goto drop_unlock_sta;
|
|
|
|
if (is_data_qos && !ieee80211_has_morefrags(fc))
|
|
mvmsta->tid_data[tid].seq_number = seq_number + 0x10;
|
|
|
|
spin_unlock(&mvmsta->lock);
|
|
|
|
if (txq_id < mvm->first_agg_queue)
|
|
atomic_inc(&mvm->pending_frames[mvmsta->sta_id]);
|
|
|
|
return 0;
|
|
|
|
drop_unlock_sta:
|
|
iwl_trans_free_tx_cmd(mvm->trans, dev_cmd);
|
|
spin_unlock(&mvmsta->lock);
|
|
drop:
|
|
return -1;
|
|
}
|
|
|
|
static void iwl_mvm_check_ratid_empty(struct iwl_mvm *mvm,
|
|
struct ieee80211_sta *sta, u8 tid)
|
|
{
|
|
struct iwl_mvm_sta *mvmsta = iwl_mvm_sta_from_mac80211(sta);
|
|
struct iwl_mvm_tid_data *tid_data = &mvmsta->tid_data[tid];
|
|
struct ieee80211_vif *vif = mvmsta->vif;
|
|
|
|
lockdep_assert_held(&mvmsta->lock);
|
|
|
|
if ((tid_data->state == IWL_AGG_ON ||
|
|
tid_data->state == IWL_EMPTYING_HW_QUEUE_DELBA) &&
|
|
iwl_mvm_tid_queued(tid_data) == 0) {
|
|
/*
|
|
* Now that this aggregation queue is empty tell mac80211 so it
|
|
* knows we no longer have frames buffered for the station on
|
|
* this TID (for the TIM bitmap calculation.)
|
|
*/
|
|
ieee80211_sta_set_buffered(sta, tid, false);
|
|
}
|
|
|
|
if (tid_data->ssn != tid_data->next_reclaimed)
|
|
return;
|
|
|
|
switch (tid_data->state) {
|
|
case IWL_EMPTYING_HW_QUEUE_ADDBA:
|
|
IWL_DEBUG_TX_QUEUES(mvm,
|
|
"Can continue addBA flow ssn = next_recl = %d\n",
|
|
tid_data->next_reclaimed);
|
|
tid_data->state = IWL_AGG_STARTING;
|
|
ieee80211_start_tx_ba_cb_irqsafe(vif, sta->addr, tid);
|
|
break;
|
|
|
|
case IWL_EMPTYING_HW_QUEUE_DELBA:
|
|
IWL_DEBUG_TX_QUEUES(mvm,
|
|
"Can continue DELBA flow ssn = next_recl = %d\n",
|
|
tid_data->next_reclaimed);
|
|
iwl_mvm_disable_txq(mvm, tid_data->txq_id, CMD_ASYNC);
|
|
tid_data->state = IWL_AGG_OFF;
|
|
/*
|
|
* we can't hold the mutex - but since we are after a sequence
|
|
* point (call to iwl_mvm_disable_txq(), so we don't even need
|
|
* a memory barrier.
|
|
*/
|
|
mvm->queue_to_mac80211[tid_data->txq_id] =
|
|
IWL_INVALID_MAC80211_QUEUE;
|
|
ieee80211_stop_tx_ba_cb_irqsafe(vif, sta->addr, tid);
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
#ifdef CONFIG_IWLWIFI_DEBUG
|
|
const char *iwl_mvm_get_tx_fail_reason(u32 status)
|
|
{
|
|
#define TX_STATUS_FAIL(x) case TX_STATUS_FAIL_ ## x: return #x
|
|
#define TX_STATUS_POSTPONE(x) case TX_STATUS_POSTPONE_ ## x: return #x
|
|
|
|
switch (status & TX_STATUS_MSK) {
|
|
case TX_STATUS_SUCCESS:
|
|
return "SUCCESS";
|
|
TX_STATUS_POSTPONE(DELAY);
|
|
TX_STATUS_POSTPONE(FEW_BYTES);
|
|
TX_STATUS_POSTPONE(BT_PRIO);
|
|
TX_STATUS_POSTPONE(QUIET_PERIOD);
|
|
TX_STATUS_POSTPONE(CALC_TTAK);
|
|
TX_STATUS_FAIL(INTERNAL_CROSSED_RETRY);
|
|
TX_STATUS_FAIL(SHORT_LIMIT);
|
|
TX_STATUS_FAIL(LONG_LIMIT);
|
|
TX_STATUS_FAIL(UNDERRUN);
|
|
TX_STATUS_FAIL(DRAIN_FLOW);
|
|
TX_STATUS_FAIL(RFKILL_FLUSH);
|
|
TX_STATUS_FAIL(LIFE_EXPIRE);
|
|
TX_STATUS_FAIL(DEST_PS);
|
|
TX_STATUS_FAIL(HOST_ABORTED);
|
|
TX_STATUS_FAIL(BT_RETRY);
|
|
TX_STATUS_FAIL(STA_INVALID);
|
|
TX_STATUS_FAIL(FRAG_DROPPED);
|
|
TX_STATUS_FAIL(TID_DISABLE);
|
|
TX_STATUS_FAIL(FIFO_FLUSHED);
|
|
TX_STATUS_FAIL(SMALL_CF_POLL);
|
|
TX_STATUS_FAIL(FW_DROP);
|
|
TX_STATUS_FAIL(STA_COLOR_MISMATCH);
|
|
}
|
|
|
|
return "UNKNOWN";
|
|
|
|
#undef TX_STATUS_FAIL
|
|
#undef TX_STATUS_POSTPONE
|
|
}
|
|
#endif /* CONFIG_IWLWIFI_DEBUG */
|
|
|
|
void iwl_mvm_hwrate_to_tx_rate(u32 rate_n_flags,
|
|
enum ieee80211_band band,
|
|
struct ieee80211_tx_rate *r)
|
|
{
|
|
if (rate_n_flags & RATE_HT_MCS_GF_MSK)
|
|
r->flags |= IEEE80211_TX_RC_GREEN_FIELD;
|
|
switch (rate_n_flags & RATE_MCS_CHAN_WIDTH_MSK) {
|
|
case RATE_MCS_CHAN_WIDTH_20:
|
|
break;
|
|
case RATE_MCS_CHAN_WIDTH_40:
|
|
r->flags |= IEEE80211_TX_RC_40_MHZ_WIDTH;
|
|
break;
|
|
case RATE_MCS_CHAN_WIDTH_80:
|
|
r->flags |= IEEE80211_TX_RC_80_MHZ_WIDTH;
|
|
break;
|
|
case RATE_MCS_CHAN_WIDTH_160:
|
|
r->flags |= IEEE80211_TX_RC_160_MHZ_WIDTH;
|
|
break;
|
|
}
|
|
if (rate_n_flags & RATE_MCS_SGI_MSK)
|
|
r->flags |= IEEE80211_TX_RC_SHORT_GI;
|
|
if (rate_n_flags & RATE_MCS_HT_MSK) {
|
|
r->flags |= IEEE80211_TX_RC_MCS;
|
|
r->idx = rate_n_flags & RATE_HT_MCS_INDEX_MSK;
|
|
} else if (rate_n_flags & RATE_MCS_VHT_MSK) {
|
|
ieee80211_rate_set_vht(
|
|
r, rate_n_flags & RATE_VHT_MCS_RATE_CODE_MSK,
|
|
((rate_n_flags & RATE_VHT_MCS_NSS_MSK) >>
|
|
RATE_VHT_MCS_NSS_POS) + 1);
|
|
r->flags |= IEEE80211_TX_RC_VHT_MCS;
|
|
} else {
|
|
r->idx = iwl_mvm_legacy_rate_to_mac80211_idx(rate_n_flags,
|
|
band);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* translate ucode response to mac80211 tx status control values
|
|
*/
|
|
static void iwl_mvm_hwrate_to_tx_status(u32 rate_n_flags,
|
|
struct ieee80211_tx_info *info)
|
|
{
|
|
struct ieee80211_tx_rate *r = &info->status.rates[0];
|
|
|
|
info->status.antenna =
|
|
((rate_n_flags & RATE_MCS_ANT_ABC_MSK) >> RATE_MCS_ANT_POS);
|
|
iwl_mvm_hwrate_to_tx_rate(rate_n_flags, info->band, r);
|
|
}
|
|
|
|
static void iwl_mvm_rx_tx_cmd_single(struct iwl_mvm *mvm,
|
|
struct iwl_rx_packet *pkt)
|
|
{
|
|
struct ieee80211_sta *sta;
|
|
u16 sequence = le16_to_cpu(pkt->hdr.sequence);
|
|
int txq_id = SEQ_TO_QUEUE(sequence);
|
|
struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
|
|
int sta_id = IWL_MVM_TX_RES_GET_RA(tx_resp->ra_tid);
|
|
int tid = IWL_MVM_TX_RES_GET_TID(tx_resp->ra_tid);
|
|
u32 status = le16_to_cpu(tx_resp->status.status);
|
|
u16 ssn = iwl_mvm_get_scd_ssn(tx_resp);
|
|
struct iwl_mvm_sta *mvmsta;
|
|
struct sk_buff_head skbs;
|
|
u8 skb_freed = 0;
|
|
u16 next_reclaimed, seq_ctl;
|
|
|
|
__skb_queue_head_init(&skbs);
|
|
|
|
seq_ctl = le16_to_cpu(tx_resp->seq_ctl);
|
|
|
|
/* we can free until ssn % q.n_bd not inclusive */
|
|
iwl_trans_reclaim(mvm->trans, txq_id, ssn, &skbs);
|
|
|
|
while (!skb_queue_empty(&skbs)) {
|
|
struct sk_buff *skb = __skb_dequeue(&skbs);
|
|
struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
|
|
|
|
skb_freed++;
|
|
|
|
iwl_trans_free_tx_cmd(mvm->trans, info->driver_data[1]);
|
|
|
|
memset(&info->status, 0, sizeof(info->status));
|
|
|
|
info->flags &= ~IEEE80211_TX_CTL_AMPDU;
|
|
|
|
/* inform mac80211 about what happened with the frame */
|
|
switch (status & TX_STATUS_MSK) {
|
|
case TX_STATUS_SUCCESS:
|
|
case TX_STATUS_DIRECT_DONE:
|
|
info->flags |= IEEE80211_TX_STAT_ACK;
|
|
break;
|
|
case TX_STATUS_FAIL_DEST_PS:
|
|
info->flags |= IEEE80211_TX_STAT_TX_FILTERED;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
info->status.rates[0].count = tx_resp->failure_frame + 1;
|
|
iwl_mvm_hwrate_to_tx_status(le32_to_cpu(tx_resp->initial_rate),
|
|
info);
|
|
info->status.status_driver_data[1] =
|
|
(void *)(uintptr_t)le32_to_cpu(tx_resp->initial_rate);
|
|
|
|
/* Single frame failure in an AMPDU queue => send BAR */
|
|
if (txq_id >= mvm->first_agg_queue &&
|
|
!(info->flags & IEEE80211_TX_STAT_ACK) &&
|
|
!(info->flags & IEEE80211_TX_STAT_TX_FILTERED))
|
|
info->flags |= IEEE80211_TX_STAT_AMPDU_NO_BACK;
|
|
|
|
/* W/A FW bug: seq_ctl is wrong when the status isn't success */
|
|
if (status != TX_STATUS_SUCCESS) {
|
|
struct ieee80211_hdr *hdr = (void *)skb->data;
|
|
seq_ctl = le16_to_cpu(hdr->seq_ctrl);
|
|
}
|
|
|
|
/*
|
|
* TODO: this is not accurate if we are freeing more than one
|
|
* packet.
|
|
*/
|
|
info->status.tx_time =
|
|
le16_to_cpu(tx_resp->wireless_media_time);
|
|
BUILD_BUG_ON(ARRAY_SIZE(info->status.status_driver_data) < 1);
|
|
info->status.status_driver_data[0] =
|
|
(void *)(uintptr_t)tx_resp->reduced_tpc;
|
|
|
|
ieee80211_tx_status(mvm->hw, skb);
|
|
}
|
|
|
|
if (txq_id >= mvm->first_agg_queue) {
|
|
/* If this is an aggregation queue, we use the ssn since:
|
|
* ssn = wifi seq_num % 256.
|
|
* The seq_ctl is the sequence control of the packet to which
|
|
* this Tx response relates. But if there is a hole in the
|
|
* bitmap of the BA we received, this Tx response may allow to
|
|
* reclaim the hole and all the subsequent packets that were
|
|
* already acked. In that case, seq_ctl != ssn, and the next
|
|
* packet to be reclaimed will be ssn and not seq_ctl. In that
|
|
* case, several packets will be reclaimed even if
|
|
* frame_count = 1.
|
|
*
|
|
* The ssn is the index (% 256) of the latest packet that has
|
|
* treated (acked / dropped) + 1.
|
|
*/
|
|
next_reclaimed = ssn;
|
|
} else {
|
|
/* The next packet to be reclaimed is the one after this one */
|
|
next_reclaimed = IEEE80211_SEQ_TO_SN(seq_ctl + 0x10);
|
|
}
|
|
|
|
IWL_DEBUG_TX_REPLY(mvm,
|
|
"TXQ %d status %s (0x%08x)\n",
|
|
txq_id, iwl_mvm_get_tx_fail_reason(status), status);
|
|
|
|
IWL_DEBUG_TX_REPLY(mvm,
|
|
"\t\t\t\tinitial_rate 0x%x retries %d, idx=%d ssn=%d next_reclaimed=0x%x seq_ctl=0x%x\n",
|
|
le32_to_cpu(tx_resp->initial_rate),
|
|
tx_resp->failure_frame, SEQ_TO_INDEX(sequence),
|
|
ssn, next_reclaimed, seq_ctl);
|
|
|
|
rcu_read_lock();
|
|
|
|
sta = rcu_dereference(mvm->fw_id_to_mac_id[sta_id]);
|
|
/*
|
|
* sta can't be NULL otherwise it'd mean that the sta has been freed in
|
|
* the firmware while we still have packets for it in the Tx queues.
|
|
*/
|
|
if (WARN_ON_ONCE(!sta))
|
|
goto out;
|
|
|
|
if (!IS_ERR(sta)) {
|
|
mvmsta = iwl_mvm_sta_from_mac80211(sta);
|
|
|
|
if (tid != IWL_TID_NON_QOS) {
|
|
struct iwl_mvm_tid_data *tid_data =
|
|
&mvmsta->tid_data[tid];
|
|
|
|
spin_lock_bh(&mvmsta->lock);
|
|
tid_data->next_reclaimed = next_reclaimed;
|
|
IWL_DEBUG_TX_REPLY(mvm, "Next reclaimed packet:%d\n",
|
|
next_reclaimed);
|
|
iwl_mvm_check_ratid_empty(mvm, sta, tid);
|
|
spin_unlock_bh(&mvmsta->lock);
|
|
}
|
|
|
|
if (mvmsta->next_status_eosp) {
|
|
mvmsta->next_status_eosp = false;
|
|
ieee80211_sta_eosp(sta);
|
|
}
|
|
} else {
|
|
mvmsta = NULL;
|
|
}
|
|
|
|
/*
|
|
* If the txq is not an AMPDU queue, there is no chance we freed
|
|
* several skbs. Check that out...
|
|
*/
|
|
if (txq_id >= mvm->first_agg_queue)
|
|
goto out;
|
|
|
|
/* We can't free more than one frame at once on a shared queue */
|
|
WARN_ON(skb_freed > 1);
|
|
|
|
/* If we have still frames for this STA nothing to do here */
|
|
if (!atomic_sub_and_test(skb_freed, &mvm->pending_frames[sta_id]))
|
|
goto out;
|
|
|
|
if (mvmsta && mvmsta->vif->type == NL80211_IFTYPE_AP) {
|
|
|
|
/*
|
|
* If there are no pending frames for this STA and
|
|
* the tx to this station is not disabled, notify
|
|
* mac80211 that this station can now wake up in its
|
|
* STA table.
|
|
* If mvmsta is not NULL, sta is valid.
|
|
*/
|
|
|
|
spin_lock_bh(&mvmsta->lock);
|
|
|
|
if (!mvmsta->disable_tx)
|
|
ieee80211_sta_block_awake(mvm->hw, sta, false);
|
|
|
|
spin_unlock_bh(&mvmsta->lock);
|
|
}
|
|
|
|
if (PTR_ERR(sta) == -EBUSY || PTR_ERR(sta) == -ENOENT) {
|
|
/*
|
|
* We are draining and this was the last packet - pre_rcu_remove
|
|
* has been called already. We might be after the
|
|
* synchronize_net already.
|
|
* Don't rely on iwl_mvm_rm_sta to see the empty Tx queues.
|
|
*/
|
|
set_bit(sta_id, mvm->sta_drained);
|
|
schedule_work(&mvm->sta_drained_wk);
|
|
}
|
|
|
|
out:
|
|
rcu_read_unlock();
|
|
}
|
|
|
|
#ifdef CONFIG_IWLWIFI_DEBUG
|
|
#define AGG_TX_STATE_(x) case AGG_TX_STATE_ ## x: return #x
|
|
static const char *iwl_get_agg_tx_status(u16 status)
|
|
{
|
|
switch (status & AGG_TX_STATE_STATUS_MSK) {
|
|
AGG_TX_STATE_(TRANSMITTED);
|
|
AGG_TX_STATE_(UNDERRUN);
|
|
AGG_TX_STATE_(BT_PRIO);
|
|
AGG_TX_STATE_(FEW_BYTES);
|
|
AGG_TX_STATE_(ABORT);
|
|
AGG_TX_STATE_(LAST_SENT_TTL);
|
|
AGG_TX_STATE_(LAST_SENT_TRY_CNT);
|
|
AGG_TX_STATE_(LAST_SENT_BT_KILL);
|
|
AGG_TX_STATE_(SCD_QUERY);
|
|
AGG_TX_STATE_(TEST_BAD_CRC32);
|
|
AGG_TX_STATE_(RESPONSE);
|
|
AGG_TX_STATE_(DUMP_TX);
|
|
AGG_TX_STATE_(DELAY_TX);
|
|
}
|
|
|
|
return "UNKNOWN";
|
|
}
|
|
|
|
static void iwl_mvm_rx_tx_cmd_agg_dbg(struct iwl_mvm *mvm,
|
|
struct iwl_rx_packet *pkt)
|
|
{
|
|
struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
|
|
struct agg_tx_status *frame_status = &tx_resp->status;
|
|
int i;
|
|
|
|
for (i = 0; i < tx_resp->frame_count; i++) {
|
|
u16 fstatus = le16_to_cpu(frame_status[i].status);
|
|
|
|
IWL_DEBUG_TX_REPLY(mvm,
|
|
"status %s (0x%04x), try-count (%d) seq (0x%x)\n",
|
|
iwl_get_agg_tx_status(fstatus),
|
|
fstatus & AGG_TX_STATE_STATUS_MSK,
|
|
(fstatus & AGG_TX_STATE_TRY_CNT_MSK) >>
|
|
AGG_TX_STATE_TRY_CNT_POS,
|
|
le16_to_cpu(frame_status[i].sequence));
|
|
}
|
|
}
|
|
#else
|
|
static void iwl_mvm_rx_tx_cmd_agg_dbg(struct iwl_mvm *mvm,
|
|
struct iwl_rx_packet *pkt)
|
|
{}
|
|
#endif /* CONFIG_IWLWIFI_DEBUG */
|
|
|
|
static void iwl_mvm_rx_tx_cmd_agg(struct iwl_mvm *mvm,
|
|
struct iwl_rx_packet *pkt)
|
|
{
|
|
struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
|
|
int sta_id = IWL_MVM_TX_RES_GET_RA(tx_resp->ra_tid);
|
|
int tid = IWL_MVM_TX_RES_GET_TID(tx_resp->ra_tid);
|
|
u16 sequence = le16_to_cpu(pkt->hdr.sequence);
|
|
struct ieee80211_sta *sta;
|
|
|
|
if (WARN_ON_ONCE(SEQ_TO_QUEUE(sequence) < mvm->first_agg_queue))
|
|
return;
|
|
|
|
if (WARN_ON_ONCE(tid == IWL_TID_NON_QOS))
|
|
return;
|
|
|
|
iwl_mvm_rx_tx_cmd_agg_dbg(mvm, pkt);
|
|
|
|
rcu_read_lock();
|
|
|
|
sta = rcu_dereference(mvm->fw_id_to_mac_id[sta_id]);
|
|
|
|
if (!WARN_ON_ONCE(IS_ERR_OR_NULL(sta))) {
|
|
struct iwl_mvm_sta *mvmsta = iwl_mvm_sta_from_mac80211(sta);
|
|
mvmsta->tid_data[tid].rate_n_flags =
|
|
le32_to_cpu(tx_resp->initial_rate);
|
|
mvmsta->tid_data[tid].reduced_tpc = tx_resp->reduced_tpc;
|
|
mvmsta->tid_data[tid].tx_time =
|
|
le16_to_cpu(tx_resp->wireless_media_time);
|
|
}
|
|
|
|
rcu_read_unlock();
|
|
}
|
|
|
|
int iwl_mvm_rx_tx_cmd(struct iwl_mvm *mvm, struct iwl_rx_cmd_buffer *rxb,
|
|
struct iwl_device_cmd *cmd)
|
|
{
|
|
struct iwl_rx_packet *pkt = rxb_addr(rxb);
|
|
struct iwl_mvm_tx_resp *tx_resp = (void *)pkt->data;
|
|
|
|
if (tx_resp->frame_count == 1)
|
|
iwl_mvm_rx_tx_cmd_single(mvm, pkt);
|
|
else
|
|
iwl_mvm_rx_tx_cmd_agg(mvm, pkt);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static void iwl_mvm_tx_info_from_ba_notif(struct ieee80211_tx_info *info,
|
|
struct iwl_mvm_ba_notif *ba_notif,
|
|
struct iwl_mvm_tid_data *tid_data)
|
|
{
|
|
info->flags |= IEEE80211_TX_STAT_AMPDU;
|
|
info->status.ampdu_ack_len = ba_notif->txed_2_done;
|
|
info->status.ampdu_len = ba_notif->txed;
|
|
iwl_mvm_hwrate_to_tx_status(tid_data->rate_n_flags,
|
|
info);
|
|
/* TODO: not accounted if the whole A-MPDU failed */
|
|
info->status.tx_time = tid_data->tx_time;
|
|
info->status.status_driver_data[0] =
|
|
(void *)(uintptr_t)tid_data->reduced_tpc;
|
|
info->status.status_driver_data[1] =
|
|
(void *)(uintptr_t)tid_data->rate_n_flags;
|
|
}
|
|
|
|
int iwl_mvm_rx_ba_notif(struct iwl_mvm *mvm, struct iwl_rx_cmd_buffer *rxb,
|
|
struct iwl_device_cmd *cmd)
|
|
{
|
|
struct iwl_rx_packet *pkt = rxb_addr(rxb);
|
|
struct iwl_mvm_ba_notif *ba_notif = (void *)pkt->data;
|
|
struct sk_buff_head reclaimed_skbs;
|
|
struct iwl_mvm_tid_data *tid_data;
|
|
struct ieee80211_sta *sta;
|
|
struct iwl_mvm_sta *mvmsta;
|
|
struct sk_buff *skb;
|
|
int sta_id, tid, freed;
|
|
/* "flow" corresponds to Tx queue */
|
|
u16 scd_flow = le16_to_cpu(ba_notif->scd_flow);
|
|
/* "ssn" is start of block-ack Tx window, corresponds to index
|
|
* (in Tx queue's circular buffer) of first TFD/frame in window */
|
|
u16 ba_resp_scd_ssn = le16_to_cpu(ba_notif->scd_ssn);
|
|
|
|
sta_id = ba_notif->sta_id;
|
|
tid = ba_notif->tid;
|
|
|
|
if (WARN_ONCE(sta_id >= IWL_MVM_STATION_COUNT ||
|
|
tid >= IWL_MAX_TID_COUNT,
|
|
"sta_id %d tid %d", sta_id, tid))
|
|
return 0;
|
|
|
|
rcu_read_lock();
|
|
|
|
sta = rcu_dereference(mvm->fw_id_to_mac_id[sta_id]);
|
|
|
|
/* Reclaiming frames for a station that has been deleted ? */
|
|
if (WARN_ON_ONCE(IS_ERR_OR_NULL(sta))) {
|
|
rcu_read_unlock();
|
|
return 0;
|
|
}
|
|
|
|
mvmsta = iwl_mvm_sta_from_mac80211(sta);
|
|
tid_data = &mvmsta->tid_data[tid];
|
|
|
|
if (WARN_ONCE(tid_data->txq_id != scd_flow, "Q %d, tid %d, flow %d",
|
|
tid_data->txq_id, tid, scd_flow)) {
|
|
rcu_read_unlock();
|
|
return 0;
|
|
}
|
|
|
|
spin_lock_bh(&mvmsta->lock);
|
|
|
|
__skb_queue_head_init(&reclaimed_skbs);
|
|
|
|
/*
|
|
* Release all TFDs before the SSN, i.e. all TFDs in front of
|
|
* block-ack window (we assume that they've been successfully
|
|
* transmitted ... if not, it's too late anyway).
|
|
*/
|
|
iwl_trans_reclaim(mvm->trans, scd_flow, ba_resp_scd_ssn,
|
|
&reclaimed_skbs);
|
|
|
|
IWL_DEBUG_TX_REPLY(mvm,
|
|
"BA_NOTIFICATION Received from %pM, sta_id = %d\n",
|
|
(u8 *)&ba_notif->sta_addr_lo32,
|
|
ba_notif->sta_id);
|
|
IWL_DEBUG_TX_REPLY(mvm,
|
|
"TID = %d, SeqCtl = %d, bitmap = 0x%llx, scd_flow = %d, scd_ssn = %d sent:%d, acked:%d\n",
|
|
ba_notif->tid, le16_to_cpu(ba_notif->seq_ctl),
|
|
(unsigned long long)le64_to_cpu(ba_notif->bitmap),
|
|
scd_flow, ba_resp_scd_ssn, ba_notif->txed,
|
|
ba_notif->txed_2_done);
|
|
|
|
tid_data->next_reclaimed = ba_resp_scd_ssn;
|
|
|
|
iwl_mvm_check_ratid_empty(mvm, sta, tid);
|
|
|
|
freed = 0;
|
|
|
|
skb_queue_walk(&reclaimed_skbs, skb) {
|
|
struct ieee80211_hdr *hdr = (void *)skb->data;
|
|
struct ieee80211_tx_info *info = IEEE80211_SKB_CB(skb);
|
|
|
|
if (ieee80211_is_data_qos(hdr->frame_control))
|
|
freed++;
|
|
else
|
|
WARN_ON_ONCE(1);
|
|
|
|
iwl_trans_free_tx_cmd(mvm->trans, info->driver_data[1]);
|
|
|
|
memset(&info->status, 0, sizeof(info->status));
|
|
/* Packet was transmitted successfully, failures come as single
|
|
* frames because before failing a frame the firmware transmits
|
|
* it without aggregation at least once.
|
|
*/
|
|
info->flags |= IEEE80211_TX_STAT_ACK;
|
|
|
|
/* this is the first skb we deliver in this batch */
|
|
/* put the rate scaling data there */
|
|
if (freed == 1)
|
|
iwl_mvm_tx_info_from_ba_notif(info, ba_notif, tid_data);
|
|
}
|
|
|
|
spin_unlock_bh(&mvmsta->lock);
|
|
|
|
/* We got a BA notif with 0 acked or scd_ssn didn't progress which is
|
|
* possible (i.e. first MPDU in the aggregation wasn't acked)
|
|
* Still it's important to update RS about sent vs. acked.
|
|
*/
|
|
if (skb_queue_empty(&reclaimed_skbs)) {
|
|
struct ieee80211_tx_info ba_info = {};
|
|
struct ieee80211_chanctx_conf *chanctx_conf = NULL;
|
|
|
|
if (mvmsta->vif)
|
|
chanctx_conf =
|
|
rcu_dereference(mvmsta->vif->chanctx_conf);
|
|
|
|
if (WARN_ON_ONCE(!chanctx_conf))
|
|
goto out;
|
|
|
|
ba_info.band = chanctx_conf->def.chan->band;
|
|
iwl_mvm_tx_info_from_ba_notif(&ba_info, ba_notif, tid_data);
|
|
|
|
IWL_DEBUG_TX_REPLY(mvm, "No reclaim. Update rs directly\n");
|
|
iwl_mvm_rs_tx_status(mvm, sta, tid, &ba_info);
|
|
}
|
|
|
|
out:
|
|
rcu_read_unlock();
|
|
|
|
while (!skb_queue_empty(&reclaimed_skbs)) {
|
|
skb = __skb_dequeue(&reclaimed_skbs);
|
|
ieee80211_tx_status(mvm->hw, skb);
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
int iwl_mvm_flush_tx_path(struct iwl_mvm *mvm, u32 tfd_msk, bool sync)
|
|
{
|
|
int ret;
|
|
struct iwl_tx_path_flush_cmd flush_cmd = {
|
|
.queues_ctl = cpu_to_le32(tfd_msk),
|
|
.flush_ctl = cpu_to_le16(DUMP_TX_FIFO_FLUSH),
|
|
};
|
|
|
|
u32 flags = sync ? 0 : CMD_ASYNC;
|
|
|
|
ret = iwl_mvm_send_cmd_pdu(mvm, TXPATH_FLUSH, flags,
|
|
sizeof(flush_cmd), &flush_cmd);
|
|
if (ret)
|
|
IWL_ERR(mvm, "Failed to send flush command (%d)\n", ret);
|
|
return ret;
|
|
}
|