dp_rx_err.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686
  1. /*
  2. * Copyright (c) 2016-2017 The Linux Foundation. All rights reserved.
  3. *
  4. * Permission to use, copy, modify, and/or distribute this software for
  5. * any purpose with or without fee is hereby granted, provided that the
  6. * above copyright notice and this permission notice appear in all
  7. * copies.
  8. *
  9. * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
  10. * WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
  11. * WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
  12. * AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL
  13. * DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
  14. * PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
  15. * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  16. * PERFORMANCE OF THIS SOFTWARE.
  17. */
  18. #include "dp_types.h"
  19. #include "dp_rx.h"
  20. #include "dp_peer.h"
  21. #include "dp_internal.h"
  22. #include "hal_api.h"
  23. #include "qdf_trace.h"
  24. #include "qdf_nbuf.h"
  25. #ifdef CONFIG_MCL
  26. #include <cds_ieee80211_common.h>
  27. #else
  28. #include <ieee80211.h>
  29. #endif
  30. /**
  31. * dp_rx_cookie_2_link_desc_va() - Converts cookie to a virtual address of
  32. * the MSDU Link Descriptor
  33. * @soc: core txrx main context
  34. * @cookie: cookie used to lookup virtual address of link descriptor
  35. * Normally this is just an index into a per SOC array.
  36. *
  37. * This is the VA of the link descriptor, that HAL layer later uses to
  38. * retrieve the list of MSDU's for a given .
  39. *
  40. * Return: void *: Virtual Address of the Rx descriptor
  41. */
  42. static inline
  43. void *dp_rx_cookie_2_link_desc_va(struct dp_soc *soc,
  44. struct hal_buf_info *buf_info)
  45. {
  46. void *link_desc_va;
  47. /* TODO */
  48. /* Add sanity for cookie */
  49. link_desc_va = soc->link_desc_banks[buf_info->sw_cookie].base_vaddr +
  50. (buf_info->paddr -
  51. soc->link_desc_banks[buf_info->sw_cookie].base_paddr);
  52. return link_desc_va;
  53. }
  54. /**
  55. * dp_rx_frag_handle() - Handles fragmented Rx frames
  56. *
  57. * @soc: core txrx main context
  58. * @ring_desc: opaque pointer to the REO error ring descriptor
  59. * @mpdu_desc_info: MPDU descriptor information from ring descriptor
  60. * @head: head of the local descriptor free-list
  61. * @tail: tail of the local descriptor free-list
  62. * @quota: No. of units (packets) that can be serviced in one shot.
  63. *
  64. * This function implements RX 802.11 fragmentation handling
  65. * The handling is mostly same as legacy fragmentation handling.
  66. * If required, this function can re-inject the frames back to
  67. * REO ring (with proper setting to by-pass fragmentation check
  68. * but use duplicate detection / re-ordering and routing these frames
  69. * to a different core.
  70. *
  71. * Return: uint32_t: No. of elements processed
  72. */
  73. static uint32_t
  74. dp_rx_frag_handle(struct dp_soc *soc, void *ring_desc,
  75. struct hal_rx_mpdu_desc_info *mpdu_desc_info,
  76. union dp_rx_desc_list_elem_t **head,
  77. union dp_rx_desc_list_elem_t **tail,
  78. uint32_t quota)
  79. {
  80. uint32_t rx_bufs_used = 0;
  81. return rx_bufs_used;
  82. }
  83. /**
  84. * dp_rx_msdus_drop() - Drops all MSDU's per MPDU
  85. *
  86. * @soc: core txrx main context
  87. * @ring_desc: opaque pointer to the REO error ring descriptor
  88. * @mpdu_desc_info: MPDU descriptor information from ring descriptor
  89. * @head: head of the local descriptor free-list
  90. * @tail: tail of the local descriptor free-list
  91. * @quota: No. of units (packets) that can be serviced in one shot.
  92. *
  93. * This function is used to drop all MSDU in an MPDU
  94. *
  95. * Return: uint32_t: No. of elements processed
  96. */
  97. static uint32_t
  98. dp_rx_msdus_drop(struct dp_soc *soc, void *ring_desc,
  99. struct hal_rx_mpdu_desc_info *mpdu_desc_info,
  100. union dp_rx_desc_list_elem_t **head,
  101. union dp_rx_desc_list_elem_t **tail,
  102. uint32_t quota)
  103. {
  104. uint8_t num_msdus;
  105. uint32_t rx_bufs_used = 0;
  106. void *link_desc_va;
  107. struct hal_buf_info buf_info;
  108. struct hal_rx_msdu_list msdu_list; /* MSDU's per MPDU */
  109. int i;
  110. hal_rx_reo_buf_paddr_get(ring_desc, &buf_info);
  111. link_desc_va = dp_rx_cookie_2_link_desc_va(soc, &buf_info);
  112. qdf_assert(rx_msdu_link_desc);
  113. /* No UNMAP required -- this is "malloc_consistent" memory */
  114. hal_rx_msdu_list_get(link_desc_va, &msdu_list, &num_msdus);
  115. for (i = 0; (i < HAL_RX_NUM_MSDU_DESC) && quota--; i++) {
  116. struct dp_rx_desc *rx_desc =
  117. dp_rx_cookie_2_va(soc, msdu_list.sw_cookie[i]);
  118. qdf_assert(rx_desc);
  119. rx_bufs_used++;
  120. /* Just free the buffers */
  121. qdf_nbuf_free(rx_desc->nbuf);
  122. dp_rx_add_to_free_desc_list(head, tail, rx_desc);
  123. }
  124. return rx_bufs_used;
  125. }
  126. /**
  127. * dp_rx_pn_error_handle() - Handles PN check errors
  128. *
  129. * @soc: core txrx main context
  130. * @ring_desc: opaque pointer to the REO error ring descriptor
  131. * @mpdu_desc_info: MPDU descriptor information from ring descriptor
  132. * @head: head of the local descriptor free-list
  133. * @tail: tail of the local descriptor free-list
  134. * @quota: No. of units (packets) that can be serviced in one shot.
  135. *
  136. * This function implements PN error handling
  137. * If the peer is configured to ignore the PN check errors
  138. * or if DP feels, that this frame is still OK, the frame can be
  139. * re-injected back to REO to use some of the other features
  140. * of REO e.g. duplicate detection/routing to other cores
  141. *
  142. * Return: uint32_t: No. of elements processed
  143. */
  144. static uint32_t
  145. dp_rx_pn_error_handle(struct dp_soc *soc, void *ring_desc,
  146. struct hal_rx_mpdu_desc_info *mpdu_desc_info,
  147. union dp_rx_desc_list_elem_t **head,
  148. union dp_rx_desc_list_elem_t **tail,
  149. uint32_t quota)
  150. {
  151. uint16_t peer_id;
  152. uint32_t rx_bufs_used = 0;
  153. struct dp_peer *peer;
  154. bool peer_pn_policy = false;
  155. peer_id = DP_PEER_METADATA_PEER_ID_GET(
  156. mpdu_desc_info->peer_meta_data);
  157. peer = dp_peer_find_by_id(soc, peer_id);
  158. if (qdf_likely(peer)) {
  159. /*
  160. * TODO: Check for peer specific policies & set peer_pn_policy
  161. */
  162. }
  163. /* No peer PN policy -- definitely drop */
  164. if (!peer_pn_policy)
  165. rx_bufs_used = dp_rx_msdus_drop(soc, ring_desc,
  166. mpdu_desc_info,
  167. head, tail, quota);
  168. return rx_bufs_used;
  169. }
  170. /**
  171. * dp_rx_2k_jump_handle() - Handles Sequence Number Jump by 2K
  172. *
  173. * @soc: core txrx main context
  174. * @ring_desc: opaque pointer to the REO error ring descriptor
  175. * @mpdu_desc_info: MPDU descriptor information from ring descriptor
  176. * @head: head of the local descriptor free-list
  177. * @tail: tail of the local descriptor free-list
  178. * @quota: No. of units (packets) that can be serviced in one shot.
  179. *
  180. * This function implements the error handling when sequence number
  181. * of the MPDU jumps suddenly by 2K.Today there are 2 cases that
  182. * need to be handled:
  183. * A) CSN (Current Sequence Number) = Last Valid SN (LSN) + 2K
  184. * B) CSN = LSN + 2K, but falls within a "BA sized window" of the SSN
  185. * For case A) the protocol stack is invoked to generate DELBA/DEAUTH frame
  186. * For case B), the frame is normally dropped, no more action is taken
  187. *
  188. * Return: uint32_t: No. of elements processed
  189. */
  190. static uint32_t
  191. dp_rx_2k_jump_handle(struct dp_soc *soc, void *ring_desc,
  192. struct hal_rx_mpdu_desc_info *mpdu_desc_info,
  193. union dp_rx_desc_list_elem_t **head,
  194. union dp_rx_desc_list_elem_t **tail,
  195. uint32_t quota)
  196. {
  197. return dp_rx_msdus_drop(soc, ring_desc, mpdu_desc_info,
  198. head, tail, quota);
  199. }
  200. /**
  201. * dp_rx_null_q_desc_handle() - Function to handle NULL Queue
  202. * descriptor violation on either a
  203. * REO or WBM ring
  204. *
  205. * @soc: core DP main context
  206. * @ring_desc: opaque pointer to the REO error ring descriptor
  207. * @head: pointer to head of rx descriptors to be added to free list
  208. * @tail: pointer to tail of rx descriptors to be added to free list
  209. * quota: upper limit of descriptors that can be reaped
  210. *
  211. * This function handles NULL queue descriptor violations arising out
  212. * a missing REO queue for a given peer or a given TID. This typically
  213. * may happen if a packet is received on a QOS enabled TID before the
  214. * ADDBA negotiation for that TID, when the TID queue is setup. Or
  215. * it may also happen for MC/BC frames if they are not routed to the
  216. * non-QOS TID queue, in the absence of any other default TID queue.
  217. * This error can show up both in a REO destination or WBM release ring.
  218. *
  219. * Return: uint32_t: No. of Rx buffers reaped
  220. */
  221. static uint32_t
  222. dp_rx_null_q_desc_handle(struct dp_soc *soc, void *ring_desc,
  223. union dp_rx_desc_list_elem_t **head,
  224. union dp_rx_desc_list_elem_t **tail,
  225. uint32_t quota)
  226. {
  227. uint32_t rx_buf_cookie;
  228. struct dp_rx_desc *rx_desc;
  229. uint32_t rx_bufs_used = 0;
  230. uint32_t pkt_len, l2_hdr_offset;
  231. uint16_t msdu_len;
  232. qdf_nbuf_t nbuf;
  233. struct dp_pdev *pdev0;
  234. struct dp_vdev *vdev0;
  235. uint32_t tid = 0;
  236. uint16_t peer_id;
  237. struct dp_peer *peer = NULL;
  238. rx_buf_cookie = HAL_RX_WBM_BUF_COOKIE_GET(ring_desc);
  239. rx_desc = dp_rx_cookie_2_va(soc, rx_buf_cookie);
  240. qdf_assert(rx_desc);
  241. rx_bufs_used++;
  242. nbuf = rx_desc->nbuf;
  243. qdf_nbuf_unmap_single(soc->osdev, nbuf,
  244. QDF_DMA_BIDIRECTIONAL);
  245. rx_desc->rx_buf_start = qdf_nbuf_data(nbuf);
  246. l2_hdr_offset =
  247. hal_rx_msdu_end_l3_hdr_padding_get(rx_desc->rx_buf_start);
  248. msdu_len = hal_rx_msdu_start_msdu_len_get(rx_desc->rx_buf_start);
  249. pkt_len = msdu_len + l2_hdr_offset + RX_PKT_TLVS_LEN;
  250. /* Set length in nbuf */
  251. qdf_nbuf_set_pktlen(nbuf, pkt_len);
  252. /*
  253. * Check if DMA completed -- msdu_done is the last bit
  254. * to be written
  255. */
  256. if (!hal_rx_attn_msdu_done_get(rx_desc->rx_buf_start)) {
  257. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  258. FL("nbuf->data 0x%p"), rx_desc->rx_buf_start);
  259. qdf_assert(0);
  260. }
  261. /*
  262. * Advance the packet start pointer by total size of
  263. * pre-header TLV's
  264. */
  265. qdf_nbuf_pull_head(nbuf, RX_PKT_TLVS_LEN);
  266. if (l2_hdr_offset)
  267. qdf_nbuf_pull_head(nbuf, l2_hdr_offset);
  268. if (hal_rx_mpdu_start_mpdu_qos_control_valid_get(
  269. rx_desc->rx_buf_start)) {
  270. /* TODO: Assuming that qos_control_valid also indicates
  271. * unicast. Should we check this?
  272. */
  273. tid = hal_rx_mpdu_start_tid_get(rx_desc->rx_buf_start);
  274. peer_id = hal_rx_mpdu_start_sw_peer_id_get(
  275. rx_desc->rx_buf_start);
  276. peer = dp_peer_find_by_id(soc, peer_id);
  277. if (peer &&
  278. peer->rx_tid[tid].hw_qdesc_vaddr_unaligned == NULL) {
  279. /* IEEE80211_SEQ_MAX indicates invalid start_seq */
  280. dp_rx_tid_setup_wifi3(peer, tid, 1, IEEE80211_SEQ_MAX);
  281. }
  282. }
  283. pdev0 = soc->pdev_list[0];/* Hard code 0th elem */
  284. if (pdev0) {
  285. vdev0 = (struct dp_vdev *)TAILQ_FIRST(&pdev0->vdev_list);
  286. if (vdev0 && vdev0->osif_rx) {
  287. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO,
  288. FL("pdev0 %p vdev0 %p osif_rx %p"), pdev0, vdev0,
  289. vdev0->osif_rx);
  290. vdev0->osif_rx(vdev0->osif_vdev, nbuf);
  291. } else {
  292. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  293. FL("INVALID vdev0 %p OR osif_rx"), vdev0);
  294. }
  295. } else {
  296. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  297. FL("INVALID pdev %p"), pdev0);
  298. }
  299. dp_rx_add_to_free_desc_list(head, tail, rx_desc);
  300. return rx_bufs_used;
  301. }
  302. /**
  303. * dp_rx_link_desc_return() - Return a MPDU link descriptor to HW
  304. * (WBM), following error handling
  305. *
  306. * @soc: core DP main context
  307. * @ring_desc: opaque pointer to the REO error ring descriptor
  308. *
  309. * Return: QDF_STATUS
  310. */
  311. static QDF_STATUS
  312. dp_rx_link_desc_return(struct dp_soc *soc, void *ring_desc)
  313. {
  314. void *buf_addr_info = HAL_RX_REO_BUF_ADDR_INFO_GET(ring_desc);
  315. struct dp_srng *wbm_desc_rel_ring = &soc->wbm_desc_rel_ring;
  316. void *wbm_rel_srng = wbm_desc_rel_ring->hal_srng;
  317. void *hal_soc = soc->hal_soc;
  318. QDF_STATUS status = QDF_STATUS_E_FAILURE;
  319. void *src_srng_desc;
  320. if (!wbm_rel_srng) {
  321. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  322. "WBM RELEASE RING not initialized");
  323. return status;
  324. }
  325. if (qdf_unlikely(hal_srng_access_start(hal_soc, wbm_rel_srng))) {
  326. /* TODO */
  327. /*
  328. * Need API to convert from hal_ring pointer to
  329. * Ring Type / Ring Id combo
  330. */
  331. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  332. FL("HAL RING Access For WBM Release SRNG Failed - %p"),
  333. wbm_rel_srng);
  334. goto done;
  335. }
  336. src_srng_desc = hal_srng_src_get_next(hal_soc, wbm_rel_srng);
  337. if (qdf_likely(src_srng_desc)) {
  338. /* Return link descriptor through WBM ring (SW2WBM)*/
  339. hal_rx_msdu_link_desc_set(hal_soc,
  340. src_srng_desc, buf_addr_info);
  341. status = QDF_STATUS_SUCCESS;
  342. } else {
  343. struct hal_srng *srng = (struct hal_srng *)wbm_rel_srng;
  344. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  345. FL("WBM Release Ring (Id %d) Full"), srng->ring_id);
  346. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  347. "HP 0x%x Reap HP 0x%x TP 0x%x Cached TP 0x%x",
  348. *srng->u.src_ring.hp_addr, srng->u.src_ring.reap_hp,
  349. *srng->u.src_ring.tp_addr, srng->u.src_ring.cached_tp);
  350. }
  351. done:
  352. hal_srng_access_end(hal_soc, wbm_rel_srng);
  353. return status;
  354. }
  355. /**
  356. * dp_rx_err_process() - Processes error frames routed to REO error ring
  357. *
  358. * @soc: core txrx main context
  359. * @hal_ring: opaque pointer to the HAL Rx Error Ring, which will be serviced
  360. * @quota: No. of units (packets) that can be serviced in one shot.
  361. *
  362. * This function implements error processing and top level demultiplexer
  363. * for all the frames routed to REO error ring.
  364. *
  365. * Return: uint32_t: No. of elements processed
  366. */
  367. uint32_t
  368. dp_rx_err_process(struct dp_soc *soc, void *hal_ring, uint32_t quota)
  369. {
  370. void *hal_soc;
  371. void *ring_desc;
  372. union dp_rx_desc_list_elem_t *head = NULL;
  373. union dp_rx_desc_list_elem_t *tail = NULL;
  374. uint32_t rx_bufs_used = 0;
  375. uint8_t buf_type;
  376. uint8_t error, rbm;
  377. struct hal_rx_mpdu_desc_info mpdu_desc_info;
  378. struct hal_buf_info hbi;
  379. /* Debug -- Remove later */
  380. qdf_assert(soc && hal_ring);
  381. hal_soc = soc->hal_soc;
  382. /* Debug -- Remove later */
  383. qdf_assert(hal_soc);
  384. if (qdf_unlikely(hal_srng_access_start(hal_soc, hal_ring))) {
  385. /* TODO */
  386. /*
  387. * Need API to convert from hal_ring pointer to
  388. * Ring Type / Ring Id combo
  389. */
  390. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  391. FL("HAL RING Access Failed -- %p"), hal_ring);
  392. goto done;
  393. }
  394. while (qdf_likely((ring_desc =
  395. hal_srng_dst_get_next(hal_soc, hal_ring))
  396. && quota--)) {
  397. error = HAL_RX_ERROR_STATUS_GET(ring_desc);
  398. qdf_assert(error == HAL_REO_ERROR_DETECTED);
  399. /*
  400. * Check if the buffer is to be processed on this processor
  401. */
  402. rbm = hal_rx_ret_buf_manager_get(ring_desc);
  403. if (qdf_unlikely(rbm != HAL_RX_BUF_RBM_SW3_BM)) {
  404. /* TODO */
  405. /* Call appropriate handler */
  406. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  407. FL("Invalid RBM %d"), rbm);
  408. continue;
  409. }
  410. buf_type = HAL_RX_REO_BUF_TYPE_GET(ring_desc);
  411. /*
  412. * For REO error ring, expect only MSDU LINK DESC
  413. */
  414. qdf_assert(buf_type == HAL_RX_REO_MSDU_LINK_DESC_TYPE);
  415. hal_rx_reo_buf_paddr_get(ring_desc, &hbi);
  416. /* Get the MPDU DESC info */
  417. hal_rx_mpdu_desc_info_get(ring_desc, &mpdu_desc_info);
  418. if (mpdu_desc_info.mpdu_flags & HAL_MPDU_F_FRAGMENT) {
  419. /* TODO */
  420. rx_bufs_used += dp_rx_frag_handle(soc,
  421. ring_desc, &mpdu_desc_info,
  422. &head, &tail, quota);
  423. continue;
  424. }
  425. if (hal_rx_reo_is_pn_error(ring_desc)) {
  426. /* TOD0 */
  427. rx_bufs_used += dp_rx_pn_error_handle(soc,
  428. ring_desc, &mpdu_desc_info,
  429. &head, &tail, quota);
  430. continue;
  431. }
  432. if (hal_rx_reo_is_2k_jump(ring_desc)) {
  433. /* TOD0 */
  434. rx_bufs_used += dp_rx_2k_jump_handle(soc,
  435. ring_desc, &mpdu_desc_info,
  436. &head, &tail, quota);
  437. continue;
  438. }
  439. /* Return link descriptor through WBM ring (SW2WBM)*/
  440. dp_rx_link_desc_return(soc, ring_desc);
  441. }
  442. done:
  443. hal_srng_access_end(hal_soc, hal_ring);
  444. /* Assume MAC id = 0, owner = 0 */
  445. if (rx_bufs_used)
  446. dp_rx_buffers_replenish(soc, 0, rx_bufs_used, &head, &tail,
  447. HAL_RX_BUF_RBM_SW3_BM);
  448. return rx_bufs_used; /* Assume no scale factor for now */
  449. }
  450. /**
  451. * dp_rx_wbm_err_process() - Processes error frames routed to WBM release ring
  452. *
  453. * @soc: core txrx main context
  454. * @hal_ring: opaque pointer to the HAL Rx Error Ring, which will be serviced
  455. * @quota: No. of units (packets) that can be serviced in one shot.
  456. *
  457. * This function implements error processing and top level demultiplexer
  458. * for all the frames routed to WBM2HOST sw release ring.
  459. *
  460. * Return: uint32_t: No. of elements processed
  461. */
  462. uint32_t
  463. dp_rx_wbm_err_process(struct dp_soc *soc, void *hal_ring, uint32_t quota)
  464. {
  465. void *hal_soc;
  466. void *ring_desc;
  467. struct dp_rx_desc *rx_desc;
  468. union dp_rx_desc_list_elem_t *head = NULL;
  469. union dp_rx_desc_list_elem_t *tail = NULL;
  470. uint32_t rx_bufs_used = 0;
  471. uint8_t buf_type, rbm;
  472. uint8_t wbm_err_src;
  473. uint32_t rx_buf_cookie;
  474. /* Debug -- Remove later */
  475. qdf_assert(soc && hal_ring);
  476. hal_soc = soc->hal_soc;
  477. /* Debug -- Remove later */
  478. qdf_assert(hal_soc);
  479. if (qdf_unlikely(hal_srng_access_start(hal_soc, hal_ring))) {
  480. /* TODO */
  481. /*
  482. * Need API to convert from hal_ring pointer to
  483. * Ring Type / Ring Id combo
  484. */
  485. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  486. FL("HAL RING Access Failed -- %p"), hal_ring);
  487. goto done;
  488. }
  489. while (qdf_likely((ring_desc =
  490. hal_srng_dst_get_next(hal_soc, hal_ring))
  491. && quota--)) {
  492. /* XXX */
  493. wbm_err_src = HAL_RX_WBM_ERR_SRC_GET(ring_desc);
  494. qdf_assert((wbm_err_src == HAL_RX_WBM_ERR_SRC_RXDMA) ||
  495. (wbm_err_src == HAL_RX_WBM_ERR_SRC_REO));
  496. /*
  497. * Check if the buffer is to be processed on this processor
  498. */
  499. rbm = hal_rx_ret_buf_manager_get(ring_desc);
  500. if (qdf_unlikely(rbm != HAL_RX_BUF_RBM_SW3_BM)) {
  501. /* TODO */
  502. /* Call appropriate handler */
  503. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_ERROR,
  504. FL("Invalid RBM %d"), rbm);
  505. continue;
  506. }
  507. /* XXX */
  508. buf_type = HAL_RX_WBM_BUF_TYPE_GET(ring_desc);
  509. /*
  510. * For WBM ring, expect only MSDU buffers
  511. */
  512. qdf_assert(buf_type == HAL_RX_WBM_BUF_TYPE_REL_BUF);
  513. if (wbm_err_src == HAL_RX_WBM_ERR_SRC_REO) {
  514. uint8_t push_reason =
  515. HAL_RX_WBM_REO_PUSH_REASON_GET(ring_desc);
  516. if (push_reason == HAL_RX_WBM_REO_PSH_RSN_ERROR) {
  517. uint8_t reo_error_code =
  518. HAL_RX_WBM_REO_ERROR_CODE_GET(ring_desc);
  519. switch (reo_error_code) {
  520. /*
  521. * Handling for packets which have NULL REO
  522. * queue descriptor
  523. */
  524. case HAL_REO_ERR_QUEUE_DESC_ADDR_0:
  525. QDF_TRACE(QDF_MODULE_ID_DP,
  526. QDF_TRACE_LEVEL_WARN,
  527. "Got pkt with REO ERROR: %d",
  528. reo_error_code);
  529. rx_bufs_used +=
  530. dp_rx_null_q_desc_handle(soc,
  531. ring_desc, &head, &tail, quota);
  532. continue;
  533. /* TODO */
  534. /* Add per error code accounting */
  535. default:
  536. QDF_TRACE(QDF_MODULE_ID_DP,
  537. QDF_TRACE_LEVEL_ERROR,
  538. "REO error %d detected",
  539. reo_error_code);
  540. }
  541. }
  542. } else if (wbm_err_src == HAL_RX_WBM_ERR_SRC_RXDMA) {
  543. uint8_t push_reason =
  544. HAL_RX_WBM_RXDMA_PUSH_REASON_GET(ring_desc);
  545. if (push_reason == HAL_RX_WBM_RXDMA_PSH_RSN_ERROR) {
  546. uint8_t rxdma_error_code =
  547. HAL_RX_WBM_RXDMA_ERROR_CODE_GET(ring_desc);
  548. switch (rxdma_error_code) {
  549. /* TODO */
  550. /* Add per error code accounting */
  551. default:
  552. QDF_TRACE(QDF_MODULE_ID_DP,
  553. QDF_TRACE_LEVEL_ERROR,
  554. "RXDMA error %d detected",
  555. rxdma_error_code);
  556. }
  557. }
  558. } else {
  559. /* Should not come here */
  560. qdf_assert(0);
  561. }
  562. rx_buf_cookie = HAL_RX_WBM_BUF_COOKIE_GET(ring_desc);
  563. rx_desc = dp_rx_cookie_2_va(soc, rx_buf_cookie);
  564. qdf_assert(rx_desc);
  565. rx_bufs_used++;
  566. qdf_nbuf_unmap_single(soc->osdev, rx_desc->nbuf,
  567. QDF_DMA_BIDIRECTIONAL);
  568. qdf_nbuf_free(rx_desc->nbuf);
  569. dp_rx_add_to_free_desc_list(&head, &tail, rx_desc);
  570. }
  571. done:
  572. hal_srng_access_end(hal_soc, hal_ring);
  573. /* Assume MAC id = 0, owner = 0 */
  574. if (rx_bufs_used)
  575. dp_rx_buffers_replenish(soc, 0, rx_bufs_used, &head, &tail,
  576. HAL_RX_BUF_RBM_SW3_BM);
  577. return rx_bufs_used; /* Assume no scale factor for now */
  578. }