samsung-sm8650/android_kernel_samsung_sm8650-modules
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

qca-wifi: add module id for dp peer reference

Browse Source 
Use appropriate module id while taking peer
reference

Change-Id: Ifd4c80ff304f599700192a340e60c7f65214f2b7
This commit is contained in:
Chaithanya Garrepalli
2020-08-06 12:02:22 +05:30
parent 78363d7d9c
commit 243000f513
2 changed files with 90 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

100
dp/wifi3.0/dp_tx_capture.c
View File

@@ -2675,10 +2675,11 @@ QDF_STATUS dp_send_dummy_mpdu_info_to_stack(struct dp_pdev *pdev,
qdf_nbuf_set_pktlen(tx_capture_info.mpdu_nbuf, qdf_nbuf_set_pktlen(tx_capture_info.mpdu_nbuf,
sizeof(struct ieee80211_frame_min_one)); sizeof(struct ieee80211_frame_min_one));
else { else {
peer = dp_peer_find_by_id(pdev->soc, user->peer_id); peer = dp_peer_get_ref_by_id(pdev->soc, user->peer_id,
DP_MOD_ID_TX_CAPTURE);
if (peer) { if (peer) {
vdev = peer->vdev; vdev = peer->vdev;
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
} else { } else {
vdev = vdev =
dp_get_vdev_from_soc_vdev_id_wifi3(pdev->soc, dp_get_vdev_from_soc_vdev_id_wifi3(pdev->soc,
@@ -2783,10 +2784,11 @@ void dp_send_dummy_rts_cts_frame(struct dp_pdev *pdev,
ppdu_desc->tx_duration = cur_ppdu_desc->tx_duration - ppdu_desc->tx_duration = cur_ppdu_desc->tx_duration -
(RTS_INTERVAL + SIFS_INTERVAL); (RTS_INTERVAL + SIFS_INTERVAL);
ppdu_desc->user[usr_idx].peer_id = peer_id; ppdu_desc->user[usr_idx].peer_id = peer_id;
peer = dp_peer_find_by_id(pdev->soc, peer_id); peer = dp_peer_get_ref_by_id(pdev->soc, peer_id,
DP_MOD_ID_TX_CAPTURE);
if (peer) { if (peer) {
vdev = peer->vdev; vdev = peer->vdev;
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
} else { } else {
uint8_t vdev_id; uint8_t vdev_id;
@@ -2828,8 +2830,9 @@ static void dp_gen_ack_rx_frame(struct dp_pdev *pdev,
tx_capture_info->ppdu_desc->ppdu_end_timestamp; tx_capture_info->ppdu_desc->ppdu_end_timestamp;
ppdu_desc->user[0].peer_id = ppdu_desc->user[0].peer_id =
tx_capture_info->ppdu_desc->user[0].peer_id; tx_capture_info->ppdu_desc->user[0].peer_id;
peer = dp_peer_find_by_id(pdev->soc, peer = dp_peer_get_ref_by_id
tx_capture_info->ppdu_desc->user[0].peer_id); (pdev->soc, tx_capture_info->ppdu_desc->user[0].peer_id,
DP_MOD_ID_TX_CAPTURE);
if (peer) { if (peer) {
struct dp_vdev *vdev = NULL; struct dp_vdev *vdev = NULL;
@@ -2838,7 +2841,7 @@ static void dp_gen_ack_rx_frame(struct dp_pdev *pdev,
qdf_mem_copy(&ppdu_desc->user[0].mac_addr, qdf_mem_copy(&ppdu_desc->user[0].mac_addr,
vdev->mac_addr.raw, vdev->mac_addr.raw,
QDF_MAC_ADDR_SIZE); QDF_MAC_ADDR_SIZE);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
} }
dp_send_dummy_mpdu_info_to_stack(pdev, ppdu_desc, 0); dp_send_dummy_mpdu_info_to_stack(pdev, ppdu_desc, 0);
@@ -2874,7 +2877,8 @@ void dp_send_data_to_stack(struct dp_pdev *pdev,
ppdu_id = ppdu_desc->ppdu_id; ppdu_id = ppdu_desc->ppdu_id;
user = &ppdu_desc->user[usr_idx]; user = &ppdu_desc->user[usr_idx];
peer = dp_peer_find_by_id(pdev->soc, user->peer_id); peer = dp_peer_get_ref_by_id(pdev->soc, user->peer_id,
DP_MOD_ID_TX_CAPTURE);
if (!peer) { if (!peer) {
return; return;
} }
@@ -2961,7 +2965,7 @@ void dp_send_data_to_stack(struct dp_pdev *pdev,
dp_gen_ack_rx_frame(pdev, &tx_capture_info); dp_gen_ack_rx_frame(pdev, &tx_capture_info);
return_send_to_stack: return_send_to_stack:
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return; return;
} }
@@ -3473,12 +3477,14 @@ dp_tx_mon_proc_pending_ppdus(struct dp_pdev *pdev, struct dp_tx_tid *tx_tid,
qdf_nbuf_copy_expand_fraglist( qdf_nbuf_copy_expand_fraglist(
mpdu_nbuf, MAX_MONITOR_HEADER, 0); mpdu_nbuf, MAX_MONITOR_HEADER, 0);
peer = dp_peer_find_by_id(pdev->soc, peer = dp_peer_get_ref_by_id
user->peer_id); (pdev->soc, user->peer_id,
DP_MOD_ID_TX_CAPTURE);
if (peer) { if (peer) {
dp_tx_cap_stats_mpdu_update(peer, dp_tx_cap_stats_mpdu_update(peer,
PEER_MPDU_CLONE, 1); PEER_MPDU_CLONE, 1);
dp_peer_unref_delete(peer); dp_peer_unref_delete
(peer, DP_MOD_ID_TX_CAPTURE);
} }
user->failed_bitmap[k] |= user->failed_bitmap[k] |=
SEQ_SEG_MSK(user->failed_bitmap[k], i); SEQ_SEG_MSK(user->failed_bitmap[k], i);
@@ -3761,20 +3767,21 @@ dp_check_mgmt_ctrl_ppdu(struct dp_pdev *pdev,
subtype = 0; subtype = 0;
} }
peer = dp_peer_find_by_id(pdev->soc, ppdu_desc->user[0].peer_id); peer = dp_peer_get_ref_by_id(pdev->soc, ppdu_desc->user[0].peer_id,
DP_MOD_ID_TX_CAPTURE);
if (peer && !peer->bss_peer) { if (peer && !peer->bss_peer) {
if (!dp_peer_or_pdev_tx_cap_enabled(pdev, peer, if (!dp_peer_or_pdev_tx_cap_enabled(pdev, peer,
ppdu_desc->user[0].mac_addr ppdu_desc->user[0].mac_addr
)) { )) {
qdf_nbuf_free(nbuf_ppdu_desc); qdf_nbuf_free(nbuf_ppdu_desc);
status = 0; status = 0;
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
goto free_ppdu_desc; goto free_ppdu_desc;
} }
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
} else { } else {
if (peer) if (peer)
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
if (!(type == IEEE80211_FC0_TYPE_MGT && if (!(type == IEEE80211_FC0_TYPE_MGT &&
(subtype == MGMT_SUBTYPE_PROBE_RESP >> 4 || (subtype == MGMT_SUBTYPE_PROBE_RESP >> 4 ||
subtype == MGMT_SUBTYPE_DISASSOC >> 4 || subtype == MGMT_SUBTYPE_DISASSOC >> 4 ||
@@ -4235,14 +4242,15 @@ dp_tx_ppdu_stats_flush(struct dp_pdev *pdev,
struct cdp_tx_completion_ppdu_user *user; struct cdp_tx_completion_ppdu_user *user;
user = &ppdu_desc->user[usr_idx]; user = &ppdu_desc->user[usr_idx];
peer = dp_peer_find_by_id(pdev->soc, user->peer_id); peer = dp_peer_get_ref_by_id(pdev->soc, user->peer_id,
DP_MOD_ID_TX_CAPTURE);
if (!peer) if (!peer)
return; return;
dp_peer_tx_cap_tid_queue_flush_tlv(pdev, peer, ppdu_desc, usr_idx); dp_peer_tx_cap_tid_queue_flush_tlv(pdev, peer, ppdu_desc, usr_idx);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return; return;
} }
@@ -4382,7 +4390,9 @@ dp_check_ppdu_and_deliver(struct dp_pdev *pdev,
if (user->delayed_ba || user->skip == 1) if (user->delayed_ba || user->skip == 1)
continue; continue;
peer = dp_peer_find_by_id(pdev->soc, user->peer_id); peer = dp_peer_get_ref_by_id(pdev->soc,
user->peer_id,
DP_MOD_ID_TX_CAPTURE);
if (!peer) { if (!peer) {
dp_ppdu_desc_free(ptr_nbuf_list, usr_idx); dp_ppdu_desc_free(ptr_nbuf_list, usr_idx);
user->skip = 1; user->skip = 1;
@@ -4418,7 +4428,8 @@ dp_check_ppdu_and_deliver(struct dp_pdev *pdev,
"%s: ppdu_desc->mpdus allocation failed", "%s: ppdu_desc->mpdus allocation failed",
__func__); __func__);
dp_ppdu_desc_free_all(ptr_nbuf_list, num_users); dp_ppdu_desc_free_all(ptr_nbuf_list, num_users);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer,
DP_MOD_ID_TX_CAPTURE);
dp_print_pdev_tx_capture_stats(pdev); dp_print_pdev_tx_capture_stats(pdev);
qdf_assert_always(0); qdf_assert_always(0);
return; return;
@@ -4427,7 +4438,8 @@ dp_check_ppdu_and_deliver(struct dp_pdev *pdev,
if (qdf_unlikely(user->ba_size > if (qdf_unlikely(user->ba_size >
CDP_BA_256_BIT_MAP_SIZE_DWORDS * CDP_BA_256_BIT_MAP_SIZE_DWORDS *
SEQ_SEG_SZ_BITS(user->failed_bitmap))) { SEQ_SEG_SZ_BITS(user->failed_bitmap))) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer,
DP_MOD_ID_TX_CAPTURE);
qdf_assert_always(0); qdf_assert_always(0);
return; return;
} }
@@ -4523,7 +4535,7 @@ dp_check_ppdu_and_deliver(struct dp_pdev *pdev,
user->ba_size = seq_no - start_seq + 1; user->ba_size = seq_no - start_seq + 1;
} }
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
} }
} }
@@ -4558,7 +4570,8 @@ dp_check_ppdu_and_deliver(struct dp_pdev *pdev,
continue; continue;
peer_id = cur_ppdu_desc->user[usr_idx].peer_id; peer_id = cur_ppdu_desc->user[usr_idx].peer_id;
peer = dp_peer_find_by_id(pdev->soc, peer_id); peer = dp_peer_get_ref_by_id(pdev->soc, peer_id,
DP_MOD_ID_TX_CAPTURE);
if (!peer) { if (!peer) {
dp_ppdu_desc_free(ptr_nbuf_list, usr_idx); dp_ppdu_desc_free(ptr_nbuf_list, usr_idx);
continue; continue;
@@ -4611,7 +4624,8 @@ dp_check_ppdu_and_deliver(struct dp_pdev *pdev,
tmp_ppdu_q = &tx_tid->pending_ppdu_q; tmp_ppdu_q = &tx_tid->pending_ppdu_q;
tmp_nbuf = qdf_nbuf_queue_remove(tmp_ppdu_q); tmp_nbuf = qdf_nbuf_queue_remove(tmp_ppdu_q);
if (qdf_unlikely(!tmp_nbuf)) { if (qdf_unlikely(!tmp_nbuf)) {
dp_peer_unref_delete(peer); dp_peer_unref_delete
(peer, DP_MOD_ID_TX_CAPTURE);
qdf_assert_always(0); qdf_assert_always(0);
return; return;
} }
@@ -4627,7 +4641,7 @@ dp_check_ppdu_and_deliver(struct dp_pdev *pdev,
qdf_nbuf_free(tmp_nbuf); qdf_nbuf_free(tmp_nbuf);
pdev->tx_capture.pend_ppdu_dropped++; pdev->tx_capture.pend_ppdu_dropped++;
} }
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
} }
} }
} }
@@ -4724,8 +4738,9 @@ dp_tx_cap_proc_per_ppdu_info(struct dp_pdev *pdev, qdf_nbuf_t nbuf_ppdu,
} }
peer_id = user->peer_id; peer_id = user->peer_id;
peer = dp_peer_find_by_id(pdev->soc, peer = dp_peer_get_ref_by_id(pdev->soc,
peer_id); peer_id,
DP_MOD_ID_TX_CAPTURE);
/** /**
* peer can be NULL * peer can be NULL
*/ */
@@ -4884,7 +4899,7 @@ dequeue_msdu_again:
mpdu_suc); mpdu_suc);
dp_tx_cap_stats_mpdu_update(peer, PEER_MPDU_TRI, dp_tx_cap_stats_mpdu_update(peer, PEER_MPDU_TRI,
mpdu_tri); mpdu_tri);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
/* get reference count */ /* get reference count */
ref_cnt = qdf_nbuf_get_users(nbuf_ppdu); ref_cnt = qdf_nbuf_get_users(nbuf_ppdu);
continue; continue;
@@ -4894,7 +4909,8 @@ free_nbuf_dec_ref:
qdf_nbuf_free(nbuf_ppdu); qdf_nbuf_free(nbuf_ppdu);
ref_cnt--; ref_cnt--;
if (peer) if (peer)
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer,
DP_MOD_ID_TX_CAPTURE);
continue; continue;
} }
@@ -5447,12 +5463,12 @@ QDF_STATUS dp_send_cts_frame_to_stack(struct dp_soc *soc,
peer_id = peer->peer_id; peer_id = peer->peer_id;
qdf_spin_unlock_bh(&soc->ast_lock); qdf_spin_unlock_bh(&soc->ast_lock);
peer = dp_peer_find_by_id(soc, peer_id); peer = dp_peer_get_ref_by_id(soc, peer_id, DP_MOD_ID_TX_CAPTURE);
if (!peer) if (!peer)
return QDF_STATUS_E_FAILURE; return QDF_STATUS_E_FAILURE;
if (!dp_peer_or_pdev_tx_cap_enabled(pdev, NULL, peer->mac_addr.raw)) { if (!dp_peer_or_pdev_tx_cap_enabled(pdev, NULL, peer->mac_addr.raw)) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return QDF_STATUS_E_FAILURE; return QDF_STATUS_E_FAILURE;
} }
@@ -5468,7 +5484,7 @@ QDF_STATUS dp_send_cts_frame_to_stack(struct dp_soc *soc,
} }
} }
if (!match) { if (!match) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return QDF_STATUS_E_FAILURE; return QDF_STATUS_E_FAILURE;
} }
} }
@@ -5486,13 +5502,13 @@ QDF_STATUS dp_send_cts_frame_to_stack(struct dp_soc *soc,
4, FALSE); 4, FALSE);
if (!tx_capture_info.mpdu_nbuf) { if (!tx_capture_info.mpdu_nbuf) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return QDF_STATUS_E_NOMEM; return QDF_STATUS_E_NOMEM;
} }
dp_gen_cts_frame(ppdu_info, peer, dp_gen_cts_frame(ppdu_info, peer,
tx_capture_info.mpdu_nbuf); tx_capture_info.mpdu_nbuf);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
dp_wdi_event_handler(WDI_EVENT_TX_DATA, pdev->soc, dp_wdi_event_handler(WDI_EVENT_TX_DATA, pdev->soc,
&tx_capture_info, HTT_INVALID_PEER, &tx_capture_info, HTT_INVALID_PEER,
WDI_NO_VAL, pdev->pdev_id); WDI_NO_VAL, pdev->pdev_id);
@@ -5588,13 +5604,13 @@ void dp_send_usr_ack_frm_to_stack(struct dp_soc *soc,
peer_id = peer->peer_id; peer_id = peer->peer_id;
qdf_spin_unlock_bh(&soc->ast_lock); qdf_spin_unlock_bh(&soc->ast_lock);
peer = dp_peer_find_by_id(soc, peer_id); peer = dp_peer_get_ref_by_id(soc, peer_id, DP_MOD_ID_TX_CAPTURE);
if (!peer) if (!peer)
return; return;
if (!dp_peer_or_pdev_tx_cap_enabled(pdev, peer, if (!dp_peer_or_pdev_tx_cap_enabled(pdev, peer,
peer->mac_addr.raw)) { peer->mac_addr.raw)) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return; return;
} }
@@ -5609,7 +5625,7 @@ void dp_send_usr_ack_frm_to_stack(struct dp_soc *soc,
4, FALSE); 4, FALSE);
if (!tx_capture_info.mpdu_nbuf) { if (!tx_capture_info.mpdu_nbuf) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return; return;
} }
@@ -5627,7 +5643,7 @@ void dp_send_usr_ack_frm_to_stack(struct dp_soc *soc,
tx_capture_info.mpdu_nbuf); tx_capture_info.mpdu_nbuf);
} }
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
dp_wdi_event_handler(WDI_EVENT_TX_DATA, pdev->soc, dp_wdi_event_handler(WDI_EVENT_TX_DATA, pdev->soc,
&tx_capture_info, HTT_INVALID_PEER, &tx_capture_info, HTT_INVALID_PEER,
WDI_NO_VAL, pdev->pdev_id); WDI_NO_VAL, pdev->pdev_id);
@@ -5856,13 +5872,13 @@ QDF_STATUS dp_send_noack_frame_to_stack(struct dp_soc *soc,
peer_id = peer->peer_id; peer_id = peer->peer_id;
qdf_spin_unlock_bh(&soc->ast_lock); qdf_spin_unlock_bh(&soc->ast_lock);
peer = dp_peer_find_by_id(soc, peer_id); peer = dp_peer_get_ref_by_id(soc, peer_id, DP_MOD_ID_TX_CAPTURE);
if (!peer) { if (!peer) {
return QDF_STATUS_E_FAILURE; return QDF_STATUS_E_FAILURE;
} }
if (!dp_peer_or_pdev_tx_cap_enabled(pdev, peer, peer->mac_addr.raw)) { if (!dp_peer_or_pdev_tx_cap_enabled(pdev, peer, peer->mac_addr.raw)) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return QDF_STATUS_E_FAILURE; return QDF_STATUS_E_FAILURE;
} }
@@ -5883,14 +5899,14 @@ QDF_STATUS dp_send_noack_frame_to_stack(struct dp_soc *soc,
4, FALSE); 4, FALSE);
if (!tx_capture_info.mpdu_nbuf) { if (!tx_capture_info.mpdu_nbuf) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
return QDF_STATUS_E_NOMEM; return QDF_STATUS_E_NOMEM;
} }
dp_gen_noack_frame(ppdu_info, peer, dp_gen_noack_frame(ppdu_info, peer,
tx_capture_info.mpdu_nbuf, mon_mpdu); tx_capture_info.mpdu_nbuf, mon_mpdu);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_CAPTURE);
dp_wdi_event_handler(WDI_EVENT_TX_DATA, pdev->soc, dp_wdi_event_handler(WDI_EVENT_TX_DATA, pdev->soc,
&tx_capture_info, HTT_INVALID_PEER, &tx_capture_info, HTT_INVALID_PEER,
WDI_NO_VAL, pdev->pdev_id); WDI_NO_VAL, pdev->pdev_id);

62
dp/wifi3.0/dp_txrx_wds.c
View File

@@ -209,7 +209,8 @@ void dp_tx_mec_handler(struct dp_vdev *vdev, uint8_t *status)
return; return;
soc = vdev->pdev->soc; soc = vdev->pdev->soc;
peer = dp_vdev_bss_peer_ref_n_get(soc, vdev); peer = dp_vdev_bss_peer_ref_n_get(soc, vdev,
DP_MOD_ID_AST);
if (!peer) { if (!peer) {
QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_DEBUG, QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_DEBUG,
@@ -231,7 +232,7 @@ void dp_tx_mec_handler(struct dp_vdev *vdev, uint8_t *status)
mac_addr, mac_addr,
CDP_TXRX_AST_TYPE_MEC, CDP_TXRX_AST_TYPE_MEC,
flags); flags);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
} }
/** /**
@@ -257,7 +258,7 @@ dp_txrx_set_wds_rx_policy(struct cdp_soc_t *soc, uint8_t vdev_id, u_int32_t val)
return QDF_STATUS_E_INVAL; return QDF_STATUS_E_INVAL;
} }
peer = dp_vdev_bss_peer_ref_n_get(vdev); peer = dp_vdev_bss_peer_ref_n_get(vdev, DP_MOD_ID_AST);
if (peer) { if (peer) {
peer->wds_ecm.wds_rx_filter = 1; peer->wds_ecm.wds_rx_filter = 1;
@@ -265,7 +266,7 @@ dp_txrx_set_wds_rx_policy(struct cdp_soc_t *soc, uint8_t vdev_id, u_int32_t val)
(val & WDS_POLICY_RX_UCAST_4ADDR) ? 1 : 0; (val & WDS_POLICY_RX_UCAST_4ADDR) ? 1 : 0;
peer->wds_ecm.wds_rx_mcast_4addr = peer->wds_ecm.wds_rx_mcast_4addr =
(val & WDS_POLICY_RX_MCAST_4ADDR) ? 1 : 0; (val & WDS_POLICY_RX_MCAST_4ADDR) ? 1 : 0;
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
} }
return QDF_STATUS_SUCCESS; return QDF_STATUS_SUCCESS;
@@ -289,7 +290,8 @@ dp_txrx_peer_wds_tx_policy_update(struct cdp_soc_t *soc, uint8_t vdev_id,
{ {
struct dp_peer *peer = dp_peer_find_hash_find((struct dp_soc *)soc, struct dp_peer *peer = dp_peer_find_hash_find((struct dp_soc *)soc,
peer_mac, 0, peer_mac, 0,
vdev_id); vdev_id,
DP_MOD_ID_AST);
if (!peer) { if (!peer) {
QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
FL("peer is NULL for mac %pM vdev_id %d"), FL("peer is NULL for mac %pM vdev_id %d"),
@@ -318,7 +320,7 @@ dp_txrx_peer_wds_tx_policy_update(struct cdp_soc_t *soc, uint8_t vdev_id,
"peer->wds_ecm.wds_tx_mcast_4addr %d\n", "peer->wds_ecm.wds_tx_mcast_4addr %d\n",
peer->wds_ecm.wds_tx_mcast_4addr); peer->wds_ecm.wds_tx_mcast_4addr);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
return QDF_STATUS_SUCCESS; return QDF_STATUS_SUCCESS;
} }
@@ -333,15 +335,15 @@ int dp_wds_rx_policy_check(uint8_t *rx_tlv_hdr,
int rx_mcast = hal_rx_msdu_end_da_is_mcbc_get(hal_soc, rx_tlv_hdr); int rx_mcast = hal_rx_msdu_end_da_is_mcbc_get(hal_soc, rx_tlv_hdr);
if (vdev->opmode == wlan_op_mode_ap) { if (vdev->opmode == wlan_op_mode_ap) {
bss_peer = dp_vdev_bss_peer_ref_n_get(vdev); bss_peer = dp_vdev_bss_peer_ref_n_get(vdev, DP_MOD_ID_AST);
/* if wds policy check is not enabled on this vdev, accept all frames */ /* if wds policy check is not enabled on this vdev, accept all frames */
if (bss_peer && !bss_peer->wds_ecm.wds_rx_filter) { if (bss_peer && !bss_peer->wds_ecm.wds_rx_filter) {
dp_peer_unref_delete(bss_peer); dp_peer_unref_delete(bss_peer, DP_MOD_ID_AST);
return 1; return 1;
} }
rx_policy_ucast = bss_peer->wds_ecm.wds_rx_ucast_4addr; rx_policy_ucast = bss_peer->wds_ecm.wds_rx_ucast_4addr;
rx_policy_mcast = bss_peer->wds_ecm.wds_rx_mcast_4addr; rx_policy_mcast = bss_peer->wds_ecm.wds_rx_mcast_4addr;
dp_peer_unref_delete(bss_peer); dp_peer_unref_delete(bss_peer, DP_MOD_ID_AST);
} else { /* sta mode */ } else { /* sta mode */
if (!peer->wds_ecm.wds_rx_filter) { if (!peer->wds_ecm.wds_rx_filter) {
return 1; return 1;
@@ -491,7 +493,8 @@ uint8_t dp_tx_need_multipass_process(struct dp_soc *soc, struct dp_vdev *vdev,
return DP_VLAN_UNTAGGED; return DP_VLAN_UNTAGGED;
} }
peer = dp_peer_find_hash_find(soc, eh->ether_dhost, 0, DP_VDEV_ALL); peer = dp_peer_find_hash_find(soc, eh->ether_dhost, 0, DP_VDEV_ALL,
DP_MOD_ID_TX_MULTIPASS);
if (qdf_unlikely(peer == NULL)) if (qdf_unlikely(peer == NULL))
return DP_VLAN_UNTAGGED; return DP_VLAN_UNTAGGED;
@@ -501,11 +504,11 @@ uint8_t dp_tx_need_multipass_process(struct dp_soc *soc, struct dp_vdev *vdev,
* Send the frame as it is. * Send the frame as it is.
*/ */
if (*vlan_id == peer->vlan_id) { if (*vlan_id == peer->vlan_id) {
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_MULTIPASS);
return DP_VLAN_TAGGED_UNICAST; return DP_VLAN_TAGGED_UNICAST;
} }
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_MULTIPASS);
return DP_VLAN_UNTAGGED; return DP_VLAN_UNTAGGED;
} }
@@ -647,7 +650,7 @@ void dp_peer_multipass_list_remove(struct dp_peer *peer)
qdf_spin_unlock_bh(&vdev->mpass_peer_mutex); qdf_spin_unlock_bh(&vdev->mpass_peer_mutex);
if (found) if (found)
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_MULTIPASS);
} }
/** /**
@@ -663,7 +666,8 @@ static void dp_peer_multipass_list_add(struct dp_soc *soc, uint8_t *peer_mac,
uint8_t vdev_id, uint16_t vlan_id) uint8_t vdev_id, uint16_t vlan_id)
{ {
struct dp_peer *peer = struct dp_peer *peer =
dp_peer_find_hash_find(soc, peer_mac, 0, vdev_id); dp_peer_find_hash_find(soc, peer_mac, 0, vdev_id,
DP_MOD_ID_TX_MULTIPASS);
if (qdf_unlikely(!peer)) { if (qdf_unlikely(!peer)) {
qdf_err("NULL peer"); qdf_err("NULL peer");
@@ -678,7 +682,7 @@ static void dp_peer_multipass_list_add(struct dp_soc *soc, uint8_t *peer_mac,
dp_debug("peer already added to vdev multipass list" dp_debug("peer already added to vdev multipass list"
"MAC: "QDF_MAC_ADDR_STR" vlan: %d ", "MAC: "QDF_MAC_ADDR_STR" vlan: %d ",
QDF_MAC_ADDR_ARRAY(peer->mac_addr.raw), peer->vlan_id); QDF_MAC_ADDR_ARRAY(peer->mac_addr.raw), peer->vlan_id);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_TX_MULTIPASS);
return; return;
} }
@@ -889,7 +893,7 @@ void dp_peer_ast_index_flow_queue_map_create(void *soc_hdl,
if (is_wds) if (is_wds)
return; return;
peer = dp_peer_find_by_id(soc, peer_id); peer = dp_peer_get_ref_by_id(soc, peer_id, DP_MOD_ID_AST);
if (!peer) { if (!peer) {
QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
"%s: Invalid peer\n", __func__); "%s: Invalid peer\n", __func__);
@@ -900,9 +904,7 @@ void dp_peer_ast_index_flow_queue_map_create(void *soc_hdl,
if (peer->vdev->opmode != wlan_op_mode_ap) { if (peer->vdev->opmode != wlan_op_mode_ap) {
QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
"%s: Peer ast flow map not in STA mode\n", __func__); "%s: Peer ast flow map not in STA mode\n", __func__);
/* Release peer reference */ goto end;
dp_peer_unref_delete(peer);
return;
} }
/* Making sure the peer is for this mac address */ /* Making sure the peer is for this mac address */
@@ -910,8 +912,7 @@ void dp_peer_ast_index_flow_queue_map_create(void *soc_hdl,
(struct qdf_mac_addr *)peer->mac_addr.raw)) { (struct qdf_mac_addr *)peer->mac_addr.raw)) {
QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
"%s: Peer mac address mismatch\n", __func__); "%s: Peer mac address mismatch\n", __func__);
dp_peer_unref_delete(peer); goto end;
return;
} }
/* Ast entry flow mapping not valid for self peer map */ /* Ast entry flow mapping not valid for self peer map */
@@ -919,8 +920,7 @@ void dp_peer_ast_index_flow_queue_map_create(void *soc_hdl,
(struct qdf_mac_addr *)peer->vdev->mac_addr.raw)) { (struct qdf_mac_addr *)peer->vdev->mac_addr.raw)) {
QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
"%s: Ast flow mapping not valid for self peer \n", __func__); "%s: Ast flow mapping not valid for self peer \n", __func__);
dp_peer_unref_delete(peer); goto end;
return;
} }
/* Fill up ast index <---> flow id mapping table for this peer */ /* Fill up ast index <---> flow id mapping table for this peer */
@@ -960,8 +960,9 @@ void dp_peer_ast_index_flow_queue_map_create(void *soc_hdl,
peer->vdev->vdev_id, peer_mac_addr); peer->vdev->vdev_id, peer_mac_addr);
} }
end:
/* Release peer reference */ /* Release peer reference */
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
} }
/** /**
@@ -987,7 +988,8 @@ int dp_peer_find_ast_index_by_flowq_id(struct cdp_soc_t *soc,
} }
peer = dp_peer_find_hash_find((struct dp_soc *)soc, peer = dp_peer_find_hash_find((struct dp_soc *)soc,
peer_mac_addr, 0, vdev_id); peer_mac_addr, 0, vdev_id,
DP_MOD_ID_AST);
if (!peer) { if (!peer) {
QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
"%s: Invalid peer\n", __func__); "%s: Invalid peer\n", __func__);
@@ -1012,7 +1014,7 @@ int dp_peer_find_ast_index_by_flowq_id(struct cdp_soc_t *soc,
if (i == DP_PEER_AST_FLOWQ_MAX) { if (i == DP_PEER_AST_FLOWQ_MAX) {
QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
"%s: ast index not found for flow %d\n", __func__, flow_id); "%s: ast index not found for flow %d\n", __func__, flow_id);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
return -1; return -1;
} }
@@ -1020,7 +1022,7 @@ int dp_peer_find_ast_index_by_flowq_id(struct cdp_soc_t *soc,
if (!peer->peer_ast_flowq_idx[i].is_valid) { if (!peer->peer_ast_flowq_idx[i].is_valid) {
QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
"%s: ast index is invalid for flow %d\n", __func__, flow_id); "%s: ast index is invalid for flow %d\n", __func__, flow_id);
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
return -1; return -1;
} }
@@ -1034,7 +1036,7 @@ int dp_peer_find_ast_index_by_flowq_id(struct cdp_soc_t *soc,
& (1 << tid))) { & (1 << tid))) {
/* Release peer reference */ /* Release peer reference */
ast_index = peer->peer_ast_flowq_idx[i].ast_idx; ast_index = peer->peer_ast_flowq_idx[i].ast_idx;
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
return ast_index; return ast_index;
} else { } else {
QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR, QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
@@ -1044,7 +1046,7 @@ int dp_peer_find_ast_index_by_flowq_id(struct cdp_soc_t *soc,
* TID is not valid for this flow * TID is not valid for this flow
* Return -1 * Return -1
*/ */
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
return -1; return -1;
} }
} }
@@ -1054,7 +1056,7 @@ int dp_peer_find_ast_index_by_flowq_id(struct cdp_soc_t *soc,
* UDP/NON UDP flow id * UDP/NON UDP flow id
*/ */
ast_index = peer->peer_ast_flowq_idx[i].ast_idx; ast_index = peer->peer_ast_flowq_idx[i].ast_idx;
dp_peer_unref_delete(peer); dp_peer_unref_delete(peer, DP_MOD_ID_AST);
return ast_index; return ast_index;
} }
#endif #endif