rsi: aggregation parameters frame for AP mode

TX command frame ampdu aggregation parameters is updated to
include sta_id for AP mode.

Signed-off-by: Prameela Rani Garnepudi <prameela.j04cs@gmail.com>
Signed-off-by: Amitkumar Karwar <amit.karwar@redpinesignals.com>
Signed-off-by: Kalle Valo <kvalo@codeaurora.org>
This commit is contained in:
Prameela Rani Garnepudi 2017-08-16 18:43:17 +05:30 committed by Kalle Valo
parent 8a1ff83f2b
commit 32be57a666
3 changed files with 39 additions and 13 deletions

View file

@ -866,9 +866,11 @@ static int rsi_mac80211_ampdu_action(struct ieee80211_hw *hw,
int status = -EOPNOTSUPP; int status = -EOPNOTSUPP;
struct rsi_hw *adapter = hw->priv; struct rsi_hw *adapter = hw->priv;
struct rsi_common *common = adapter->priv; struct rsi_common *common = adapter->priv;
u16 seq_no = 0; struct rsi_sta *rsta = NULL;
u16 seq_no = 0, seq_start = 0;
u8 ii = 0; u8 ii = 0;
struct ieee80211_sta *sta = params->sta; struct ieee80211_sta *sta = params->sta;
u8 sta_id = 0;
enum ieee80211_ampdu_mlme_action action = params->action; enum ieee80211_ampdu_mlme_action action = params->action;
u16 tid = params->tid; u16 tid = params->tid;
u16 *ssn = &params->ssn; u16 *ssn = &params->ssn;
@ -880,17 +882,31 @@ static int rsi_mac80211_ampdu_action(struct ieee80211_hw *hw,
} }
mutex_lock(&common->mutex); mutex_lock(&common->mutex);
rsi_dbg(INFO_ZONE, "%s: AMPDU action %d called\n", __func__, action);
if (ssn != NULL) if (ssn != NULL)
seq_no = *ssn; seq_no = *ssn;
if (vif->type == NL80211_IFTYPE_AP) {
rsta = rsi_find_sta(common, sta->addr);
if (!rsta) {
rsi_dbg(ERR_ZONE, "No station mapped\n");
return 0;
}
sta_id = rsta->sta_id;
}
rsi_dbg(INFO_ZONE,
"%s: AMPDU action tid=%d ssn=0x%x, buf_size=%d sta_id=%d\n",
__func__, tid, seq_no, buf_size, sta_id);
switch (action) { switch (action) {
case IEEE80211_AMPDU_RX_START: case IEEE80211_AMPDU_RX_START:
status = rsi_send_aggregation_params_frame(common, status = rsi_send_aggregation_params_frame(common,
tid, tid,
seq_no, seq_no,
buf_size, buf_size,
STA_RX_ADDBA_DONE); STA_RX_ADDBA_DONE,
sta_id);
break; break;
case IEEE80211_AMPDU_RX_STOP: case IEEE80211_AMPDU_RX_STOP:
@ -898,11 +914,15 @@ static int rsi_mac80211_ampdu_action(struct ieee80211_hw *hw,
tid, tid,
0, 0,
buf_size, buf_size,
STA_RX_DELBA); STA_RX_DELBA,
sta_id);
break; break;
case IEEE80211_AMPDU_TX_START: case IEEE80211_AMPDU_TX_START:
common->vif_info[ii].seq_start = seq_no; if (vif->type == NL80211_IFTYPE_STATION)
common->vif_info[ii].seq_start = seq_no;
else if (vif->type == NL80211_IFTYPE_AP)
rsta->seq_start[tid] = seq_no;
ieee80211_start_tx_ba_cb_irqsafe(vif, sta->addr, tid); ieee80211_start_tx_ba_cb_irqsafe(vif, sta->addr, tid);
status = 0; status = 0;
break; break;
@ -914,18 +934,23 @@ static int rsi_mac80211_ampdu_action(struct ieee80211_hw *hw,
tid, tid,
seq_no, seq_no,
buf_size, buf_size,
STA_TX_DELBA); STA_TX_DELBA,
sta_id);
if (!status) if (!status)
ieee80211_stop_tx_ba_cb_irqsafe(vif, sta->addr, tid); ieee80211_stop_tx_ba_cb_irqsafe(vif, sta->addr, tid);
break; break;
case IEEE80211_AMPDU_TX_OPERATIONAL: case IEEE80211_AMPDU_TX_OPERATIONAL:
if (vif->type == NL80211_IFTYPE_STATION)
seq_start = common->vif_info[ii].seq_start;
else if (vif->type == NL80211_IFTYPE_AP)
seq_start = rsta->seq_start[tid];
status = rsi_send_aggregation_params_frame(common, status = rsi_send_aggregation_params_frame(common,
tid, tid,
common->vif_info[ii] seq_start,
.seq_start,
buf_size, buf_size,
STA_TX_ADDBA_DONE); STA_TX_ADDBA_DONE,
sta_id);
break; break;
default: default:

View file

@ -537,11 +537,11 @@ int rsi_send_aggregation_params_frame(struct rsi_common *common,
u16 tid, u16 tid,
u16 ssn, u16 ssn,
u8 buf_size, u8 buf_size,
u8 event) u8 event,
u8 sta_id)
{ {
struct sk_buff *skb = NULL; struct sk_buff *skb = NULL;
struct rsi_aggr_params *aggr_params; struct rsi_aggr_params *aggr_params;
u8 peer_id = 0;
u16 frame_len = sizeof(struct rsi_aggr_params); u16 frame_len = sizeof(struct rsi_aggr_params);
skb = dev_alloc_skb(frame_len); skb = dev_alloc_skb(frame_len);
@ -561,7 +561,7 @@ int rsi_send_aggregation_params_frame(struct rsi_common *common,
aggr_params->desc_dword0.frame_type = AMPDU_IND; aggr_params->desc_dword0.frame_type = AMPDU_IND;
aggr_params->aggr_params = tid & RSI_AGGR_PARAMS_TID_MASK; aggr_params->aggr_params = tid & RSI_AGGR_PARAMS_TID_MASK;
aggr_params->peer_id = peer_id; aggr_params->peer_id = sta_id;
if (event == STA_TX_ADDBA_DONE) { if (event == STA_TX_ADDBA_DONE) {
aggr_params->seq_start = cpu_to_le16(ssn); aggr_params->seq_start = cpu_to_le16(ssn);
aggr_params->baw_size = cpu_to_le16(buf_size); aggr_params->baw_size = cpu_to_le16(buf_size);

View file

@ -609,7 +609,8 @@ int rsi_mgmt_pkt_recv(struct rsi_common *common, u8 *msg);
int rsi_set_vap_capabilities(struct rsi_common *common, enum opmode mode, int rsi_set_vap_capabilities(struct rsi_common *common, enum opmode mode,
u8 *mac_addr, u8 vap_id, u8 vap_status); u8 *mac_addr, u8 vap_id, u8 vap_status);
int rsi_send_aggregation_params_frame(struct rsi_common *common, u16 tid, int rsi_send_aggregation_params_frame(struct rsi_common *common, u16 tid,
u16 ssn, u8 buf_size, u8 event); u16 ssn, u8 buf_size, u8 event,
u8 sta_id);
int rsi_hal_load_key(struct rsi_common *common, u8 *data, u16 key_len, int rsi_hal_load_key(struct rsi_common *common, u8 *data, u16 key_len,
u8 key_type, u8 key_id, u32 cipher); u8 key_type, u8 key_id, u32 cipher);
int rsi_set_channel(struct rsi_common *common, int rsi_set_channel(struct rsi_common *common,