dp_be_rx.h 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899
  1. /*
  2. * Copyright (c) 2016-2021 The Linux Foundation. All rights reserved.
  3. * Copyright (c) 2021-2023 Qualcomm Innovation Center, Inc. All rights reserved.
  4. *
  5. * Permission to use, copy, modify, and/or distribute this software for
  6. * any purpose with or without fee is hereby granted, provided that the
  7. * above copyright notice and this permission notice appear in all
  8. * copies.
  9. *
  10. * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
  11. * WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
  12. * WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
  13. * AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL
  14. * DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
  15. * PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
  16. * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  17. * PERFORMANCE OF THIS SOFTWARE.
  18. */
  19. #ifndef _DP_BE_RX_H_
  20. #define _DP_BE_RX_H_
  21. #include <dp_types.h>
  22. #include "dp_be.h"
  23. #include "dp_peer.h"
  24. #include <dp_rx.h>
  25. #include "hal_be_rx.h"
  26. #include "hal_be_rx_tlv.h"
  27. /*
  28. * dp_be_intrabss_params
  29. *
  30. * @dest_soc: dest soc to forward the packet to
  31. * @tx_vdev_id: vdev id retrieved from dest peer
  32. */
  33. struct dp_be_intrabss_params {
  34. struct dp_soc *dest_soc;
  35. uint8_t tx_vdev_id;
  36. };
  37. #ifndef QCA_HOST_MODE_WIFI_DISABLED
  38. /**
  39. * dp_rx_intrabss_fwd_be() - API for intrabss fwd. For EAPOL
  40. * pkt with DA not equal to vdev mac addr, fwd is not allowed.
  41. * @soc: core txrx main context
  42. * @ta_txrx_peer: source peer entry
  43. * @rx_tlv_hdr: start address of rx tlvs
  44. * @nbuf: nbuf that has to be intrabss forwarded
  45. * @link_id: link id on which the packet is received
  46. *
  47. * Return: true if it is forwarded else false
  48. */
  49. bool dp_rx_intrabss_fwd_be(struct dp_soc *soc,
  50. struct dp_txrx_peer *ta_txrx_peer,
  51. uint8_t *rx_tlv_hdr,
  52. qdf_nbuf_t nbuf,
  53. uint8_t link_id);
  54. #endif
  55. /**
  56. * dp_rx_intrabss_mcast_handler_be() - intrabss mcast handler
  57. * @soc: core txrx main context
  58. * @ta_txrx_peer: source txrx_peer entry
  59. * @nbuf_copy: nbuf that has to be intrabss forwarded
  60. * @tid_stats: tid_stats structure
  61. * @link_id: link id on which the packet is received
  62. *
  63. * Return: true if it is forwarded else false
  64. */
  65. bool
  66. dp_rx_intrabss_mcast_handler_be(struct dp_soc *soc,
  67. struct dp_txrx_peer *ta_txrx_peer,
  68. qdf_nbuf_t nbuf_copy,
  69. struct cdp_tid_rx_stats *tid_stats,
  70. uint8_t link_id);
  71. void dp_rx_word_mask_subscribe_be(struct dp_soc *soc,
  72. uint32_t *msg_word,
  73. void *rx_filter);
  74. /**
  75. * dp_rx_process_be() - Brain of the Rx processing functionality
  76. * Called from the bottom half (tasklet/NET_RX_SOFTIRQ)
  77. * @int_ctx: per interrupt context
  78. * @hal_ring_hdl: opaque pointer to the HAL Rx Ring, which will be serviced
  79. * @reo_ring_num: ring number (0, 1, 2 or 3) of the reo ring.
  80. * @quota: No. of units (packets) that can be serviced in one shot.
  81. *
  82. * This function implements the core of Rx functionality. This is
  83. * expected to handle only non-error frames.
  84. *
  85. * Return: uint32_t: No. of elements processed
  86. */
  87. uint32_t dp_rx_process_be(struct dp_intr *int_ctx,
  88. hal_ring_handle_t hal_ring_hdl, uint8_t reo_ring_num,
  89. uint32_t quota);
  90. /**
  91. * dp_rx_desc_pool_init_be() - Initialize Rx Descriptor pool(s)
  92. * @soc: Handle to DP Soc structure
  93. * @rx_desc_pool: Rx descriptor pool handler
  94. * @pool_id: Rx descriptor pool ID
  95. *
  96. * Return: QDF_STATUS_SUCCESS - succeeded, others - failed
  97. */
  98. QDF_STATUS dp_rx_desc_pool_init_be(struct dp_soc *soc,
  99. struct rx_desc_pool *rx_desc_pool,
  100. uint32_t pool_id);
  101. /**
  102. * dp_rx_desc_pool_deinit_be() - De-initialize Rx Descriptor pool(s)
  103. * @soc: Handle to DP Soc structure
  104. * @rx_desc_pool: Rx descriptor pool handler
  105. * @pool_id: Rx descriptor pool ID
  106. *
  107. * Return: None
  108. */
  109. void dp_rx_desc_pool_deinit_be(struct dp_soc *soc,
  110. struct rx_desc_pool *rx_desc_pool,
  111. uint32_t pool_id);
  112. /**
  113. * dp_wbm_get_rx_desc_from_hal_desc_be() - Get corresponding Rx Desc
  114. * address from WBM ring Desc
  115. * @soc: Handle to DP Soc structure
  116. * @ring_desc: ring descriptor structure pointer
  117. * @r_rx_desc: pointer to a pointer of Rx Desc
  118. *
  119. * Return: QDF_STATUS_SUCCESS - succeeded, others - failed
  120. */
  121. QDF_STATUS dp_wbm_get_rx_desc_from_hal_desc_be(struct dp_soc *soc,
  122. void *ring_desc,
  123. struct dp_rx_desc **r_rx_desc);
  124. /**
  125. * dp_rx_desc_cookie_2_va_be() - Convert RX Desc cookie ID to VA
  126. * @soc:Handle to DP Soc structure
  127. * @cookie: cookie used to lookup virtual address
  128. *
  129. * Return: Rx descriptor virtual address
  130. */
  131. struct dp_rx_desc *dp_rx_desc_cookie_2_va_be(struct dp_soc *soc,
  132. uint32_t cookie);
  133. #if !defined(DP_FEATURE_HW_COOKIE_CONVERSION) || \
  134. defined(DP_HW_COOKIE_CONVERT_EXCEPTION)
  135. /**
  136. * dp_rx_desc_sw_cc_check() - check if RX desc VA is got correctly,
  137. * if not, do SW cookie conversion.
  138. * @soc:Handle to DP Soc structure
  139. * @rx_buf_cookie: RX desc cookie ID
  140. * @r_rx_desc: double pointer for RX desc
  141. *
  142. * Return: None
  143. */
  144. static inline void
  145. dp_rx_desc_sw_cc_check(struct dp_soc *soc,
  146. uint32_t rx_buf_cookie,
  147. struct dp_rx_desc **r_rx_desc)
  148. {
  149. if (qdf_unlikely(!(*r_rx_desc))) {
  150. *r_rx_desc = (struct dp_rx_desc *)
  151. dp_cc_desc_find(soc,
  152. rx_buf_cookie);
  153. }
  154. }
  155. #else
  156. static inline void
  157. dp_rx_desc_sw_cc_check(struct dp_soc *soc,
  158. uint32_t rx_buf_cookie,
  159. struct dp_rx_desc **r_rx_desc)
  160. {
  161. }
  162. #endif /* DP_FEATURE_HW_COOKIE_CONVERSION && DP_HW_COOKIE_CONVERT_EXCEPTION */
  163. struct dp_rx_desc *dp_rx_desc_ppeds_cookie_2_va(struct dp_soc *soc,
  164. unsigned long cookie);
  165. #define DP_PEER_METADATA_OFFLOAD_GET_BE(_peer_metadata) (0)
  166. #define HTT_RX_PEER_META_DATA_FIELD_GET(_var, _field_s, _field_m) \
  167. (((_var) & (_field_m)) >> (_field_s))
  168. #ifdef DP_USE_REDUCED_PEER_ID_FIELD_WIDTH
  169. static inline uint16_t
  170. dp_rx_peer_metadata_peer_id_get_be(struct dp_soc *soc, uint32_t peer_metadata)
  171. {
  172. uint8_t ml_peer_valid;
  173. uint16_t peer_id;
  174. peer_id = HTT_RX_PEER_META_DATA_FIELD_GET(peer_metadata,
  175. soc->htt_peer_id_s,
  176. soc->htt_peer_id_m);
  177. ml_peer_valid = HTT_RX_PEER_META_DATA_FIELD_GET(
  178. peer_metadata,
  179. soc->htt_mld_peer_valid_s,
  180. soc->htt_mld_peer_valid_m);
  181. return (peer_id | (ml_peer_valid << soc->peer_id_shift));
  182. }
  183. #else
  184. /* Combine ml_peer_valid and peer_id field */
  185. #define DP_BE_PEER_METADATA_PEER_ID_MASK 0x00003fff
  186. #define DP_BE_PEER_METADATA_PEER_ID_SHIFT 0
  187. static inline uint16_t
  188. dp_rx_peer_metadata_peer_id_get_be(struct dp_soc *soc, uint32_t peer_metadata)
  189. {
  190. return ((peer_metadata & DP_BE_PEER_METADATA_PEER_ID_MASK) >>
  191. DP_BE_PEER_METADATA_PEER_ID_SHIFT);
  192. }
  193. #endif
  194. static inline uint16_t
  195. dp_rx_peer_metadata_vdev_id_get_be(struct dp_soc *soc, uint32_t peer_metadata)
  196. {
  197. return HTT_RX_PEER_META_DATA_FIELD_GET(peer_metadata,
  198. soc->htt_vdev_id_s,
  199. soc->htt_vdev_id_m);
  200. }
  201. static inline uint8_t
  202. dp_rx_peer_metadata_lmac_id_get_be(uint32_t peer_metadata)
  203. {
  204. return HTT_RX_PEER_META_DATA_V1_LMAC_ID_GET(peer_metadata);
  205. }
  206. #ifdef WLAN_FEATURE_NEAR_FULL_IRQ
  207. /**
  208. * dp_rx_nf_process() - Near Full state handler for RX rings.
  209. * @int_ctx: interrupt context
  210. * @hal_ring_hdl: Rx ring handle
  211. * @reo_ring_num: RX ring number
  212. * @quota: Quota of work to be done
  213. *
  214. * Return: work done in the handler
  215. */
  216. uint32_t dp_rx_nf_process(struct dp_intr *int_ctx,
  217. hal_ring_handle_t hal_ring_hdl,
  218. uint8_t reo_ring_num,
  219. uint32_t quota);
  220. #else
  221. static inline
  222. uint32_t dp_rx_nf_process(struct dp_intr *int_ctx,
  223. hal_ring_handle_t hal_ring_hdl,
  224. uint8_t reo_ring_num,
  225. uint32_t quota)
  226. {
  227. return 0;
  228. }
  229. #endif /*WLAN_FEATURE_NEAR_FULL_IRQ */
  230. #if defined(WLAN_FEATURE_11BE_MLO) && defined(WLAN_MLO_MULTI_CHIP)
  231. struct dp_soc *
  232. dp_rx_replenish_soc_get(struct dp_soc *soc, uint8_t chip_id);
  233. struct dp_soc *
  234. dp_soc_get_by_idle_bm_id(struct dp_soc *soc, uint8_t idle_bm_id);
  235. uint8_t dp_soc_get_num_soc_be(struct dp_soc *soc);
  236. #else
  237. static inline struct dp_soc *
  238. dp_rx_replenish_soc_get(struct dp_soc *soc, uint8_t chip_id)
  239. {
  240. return soc;
  241. }
  242. static inline uint8_t
  243. dp_soc_get_num_soc_be(struct dp_soc *soc)
  244. {
  245. return 1;
  246. }
  247. #endif
  248. #ifdef WLAN_FEATURE_11BE_MLO
  249. /**
  250. * dp_rx_mlo_igmp_handler() - Rx handler for Mcast packets
  251. * @soc: Handle to DP Soc structure
  252. * @vdev: DP vdev handle
  253. * @peer: DP peer handle
  254. * @nbuf: nbuf to be enqueued
  255. * @link_id: link id on which the packet is received
  256. *
  257. * Return: true when packet sent to stack, false failure
  258. */
  259. bool dp_rx_mlo_igmp_handler(struct dp_soc *soc,
  260. struct dp_vdev *vdev,
  261. struct dp_txrx_peer *peer,
  262. qdf_nbuf_t nbuf,
  263. uint8_t link_id);
  264. /**
  265. * dp_peer_rx_reorder_queue_setup_be() - Send reo queue setup wmi cmd to FW
  266. * per peer type
  267. * @soc: DP Soc handle
  268. * @peer: dp peer to operate on
  269. * @tid: TID
  270. * @ba_window_size: BlockAck window size
  271. *
  272. * Return: 0 - success, others - failure
  273. */
  274. static inline
  275. QDF_STATUS dp_peer_rx_reorder_queue_setup_be(struct dp_soc *soc,
  276. struct dp_peer *peer,
  277. int tid,
  278. uint32_t ba_window_size)
  279. {
  280. uint8_t i;
  281. struct dp_mld_link_peers link_peers_info;
  282. struct dp_peer *link_peer;
  283. struct dp_rx_tid *rx_tid;
  284. struct dp_soc *link_peer_soc;
  285. rx_tid = &peer->rx_tid[tid];
  286. if (!rx_tid->hw_qdesc_paddr)
  287. return QDF_STATUS_E_INVAL;
  288. if (!hal_reo_shared_qaddr_is_enable(soc->hal_soc)) {
  289. if (IS_MLO_DP_MLD_PEER(peer)) {
  290. /* get link peers with reference */
  291. dp_get_link_peers_ref_from_mld_peer(soc, peer,
  292. &link_peers_info,
  293. DP_MOD_ID_CDP);
  294. /* send WMI cmd to each link peers */
  295. for (i = 0; i < link_peers_info.num_links; i++) {
  296. link_peer = link_peers_info.link_peers[i];
  297. link_peer_soc = link_peer->vdev->pdev->soc;
  298. if (link_peer_soc->cdp_soc.ol_ops->
  299. peer_rx_reorder_queue_setup) {
  300. if (link_peer_soc->cdp_soc.ol_ops->
  301. peer_rx_reorder_queue_setup(
  302. link_peer_soc->ctrl_psoc,
  303. link_peer->vdev->pdev->pdev_id,
  304. link_peer->vdev->vdev_id,
  305. link_peer->mac_addr.raw,
  306. rx_tid->hw_qdesc_paddr,
  307. tid, tid,
  308. 1, ba_window_size)) {
  309. dp_peer_err("%pK: Failed to send reo queue setup to FW - tid %d\n",
  310. link_peer_soc, tid);
  311. return QDF_STATUS_E_FAILURE;
  312. }
  313. }
  314. }
  315. /* release link peers reference */
  316. dp_release_link_peers_ref(&link_peers_info,
  317. DP_MOD_ID_CDP);
  318. } else if (peer->peer_type == CDP_LINK_PEER_TYPE) {
  319. if (soc->cdp_soc.ol_ops->peer_rx_reorder_queue_setup) {
  320. if (soc->cdp_soc.ol_ops->
  321. peer_rx_reorder_queue_setup(
  322. soc->ctrl_psoc,
  323. peer->vdev->pdev->pdev_id,
  324. peer->vdev->vdev_id,
  325. peer->mac_addr.raw,
  326. rx_tid->hw_qdesc_paddr,
  327. tid, tid,
  328. 1, ba_window_size)) {
  329. dp_peer_err("%pK: Failed to send reo queue setup to FW - tid %d\n",
  330. soc, tid);
  331. return QDF_STATUS_E_FAILURE;
  332. }
  333. }
  334. } else {
  335. dp_peer_err("invalid peer type %d", peer->peer_type);
  336. return QDF_STATUS_E_FAILURE;
  337. }
  338. } else {
  339. /* Some BE targets dont require WMI and use shared
  340. * table managed by host for storing Reo queue ref structs
  341. */
  342. if (IS_MLO_DP_LINK_PEER(peer) ||
  343. peer->peer_id == HTT_INVALID_PEER) {
  344. /* Return if this is for MLD link peer and table
  345. * is not used in MLD link peer case as MLD peer's
  346. * qref is written to LUT in peer setup or peer map.
  347. * At this point peer setup for link peer is called
  348. * before peer map, hence peer id is not assigned.
  349. * This could happen if peer_setup is called before
  350. * host receives HTT peer map. In this case return
  351. * success with no op and let peer map handle
  352. * writing the reo_qref to LUT.
  353. */
  354. dp_peer_debug("Invalid peer id for dp_peer:%pK", peer);
  355. return QDF_STATUS_SUCCESS;
  356. }
  357. hal_reo_shared_qaddr_write(soc->hal_soc,
  358. peer->peer_id,
  359. tid, peer->rx_tid[tid].hw_qdesc_paddr);
  360. }
  361. return QDF_STATUS_SUCCESS;
  362. }
  363. #else
  364. static inline
  365. QDF_STATUS dp_peer_rx_reorder_queue_setup_be(struct dp_soc *soc,
  366. struct dp_peer *peer,
  367. int tid,
  368. uint32_t ba_window_size)
  369. {
  370. struct dp_rx_tid *rx_tid = &peer->rx_tid[tid];
  371. if (!rx_tid->hw_qdesc_paddr)
  372. return QDF_STATUS_E_INVAL;
  373. if (soc->cdp_soc.ol_ops->peer_rx_reorder_queue_setup) {
  374. if (soc->cdp_soc.ol_ops->peer_rx_reorder_queue_setup(
  375. soc->ctrl_psoc,
  376. peer->vdev->pdev->pdev_id,
  377. peer->vdev->vdev_id,
  378. peer->mac_addr.raw, rx_tid->hw_qdesc_paddr, tid, tid,
  379. 1, ba_window_size)) {
  380. dp_peer_err("%pK: Failed to send reo queue setup to FW - tid %d\n",
  381. soc, tid);
  382. return QDF_STATUS_E_FAILURE;
  383. }
  384. }
  385. return QDF_STATUS_SUCCESS;
  386. }
  387. #endif /* WLAN_FEATURE_11BE_MLO */
  388. #ifdef QCA_DP_RX_NBUF_AND_NBUF_DATA_PREFETCH
  389. static inline
  390. void dp_rx_prefetch_nbuf_data_be(qdf_nbuf_t nbuf, qdf_nbuf_t next)
  391. {
  392. if (next) {
  393. /* prefetch skb->next and first few bytes of skb->cb */
  394. qdf_prefetch(next);
  395. /* skb->cb spread across 2 cache lines hence below prefetch */
  396. qdf_prefetch(&next->_skb_refdst);
  397. qdf_prefetch(&next->protocol);
  398. qdf_prefetch(&next->data);
  399. qdf_prefetch(next->data);
  400. qdf_prefetch(next->data + 64);
  401. }
  402. }
  403. #else
  404. static inline
  405. void dp_rx_prefetch_nbuf_data_be(qdf_nbuf_t nbuf, qdf_nbuf_t next)
  406. {
  407. }
  408. #endif
  409. #ifdef QCA_DP_RX_HW_SW_NBUF_DESC_PREFETCH
  410. /**
  411. * dp_rx_va_prefetch() - function to prefetch the SW desc
  412. * @last_prefetched_hw_desc: HW desc
  413. *
  414. * Return: prefetched Rx descriptor virtual address
  415. */
  416. static inline
  417. void *dp_rx_va_prefetch(void *last_prefetched_hw_desc)
  418. {
  419. void *prefetch_desc;
  420. prefetch_desc = (void *)hal_rx_get_reo_desc_va(last_prefetched_hw_desc);
  421. qdf_prefetch(prefetch_desc);
  422. return prefetch_desc;
  423. }
  424. /**
  425. * dp_rx_prefetch_hw_sw_nbuf_32_byte_desc() - function to prefetch HW and SW
  426. * descriptors
  427. * @soc: DP soc context
  428. * @hal_soc: Handle to HAL Soc structure
  429. * @num_entries: valid number of HW descriptors
  430. * @hal_ring_hdl: Destination ring pointer
  431. * @last_prefetched_hw_desc: pointer to the last prefetched HW descriptor
  432. * @last_prefetched_sw_desc: input & output param of last prefetch SW desc
  433. *
  434. * Return: None
  435. */
  436. static inline void
  437. dp_rx_prefetch_hw_sw_nbuf_32_byte_desc(struct dp_soc *soc,
  438. hal_soc_handle_t hal_soc,
  439. uint32_t num_entries,
  440. hal_ring_handle_t hal_ring_hdl,
  441. hal_ring_desc_t *last_prefetched_hw_desc,
  442. struct dp_rx_desc **last_prefetched_sw_desc)
  443. {
  444. if (*last_prefetched_sw_desc) {
  445. qdf_prefetch((uint8_t *)(*last_prefetched_sw_desc)->nbuf);
  446. qdf_prefetch((uint8_t *)(*last_prefetched_sw_desc)->nbuf + 64);
  447. }
  448. if (num_entries) {
  449. *last_prefetched_sw_desc =
  450. dp_rx_va_prefetch(*last_prefetched_hw_desc);
  451. if ((uintptr_t)*last_prefetched_hw_desc & 0x3f)
  452. *last_prefetched_hw_desc =
  453. hal_srng_dst_prefetch_next_cached_desc(hal_soc,
  454. hal_ring_hdl,
  455. (uint8_t *)*last_prefetched_hw_desc);
  456. else
  457. *last_prefetched_hw_desc =
  458. hal_srng_dst_get_next_32_byte_desc(hal_soc,
  459. hal_ring_hdl,
  460. (uint8_t *)*last_prefetched_hw_desc);
  461. }
  462. }
  463. #else
  464. static inline void
  465. dp_rx_prefetch_hw_sw_nbuf_32_byte_desc(struct dp_soc *soc,
  466. hal_soc_handle_t hal_soc,
  467. uint32_t num_entries,
  468. hal_ring_handle_t hal_ring_hdl,
  469. hal_ring_desc_t *last_prefetched_hw_desc,
  470. struct dp_rx_desc **last_prefetched_sw_desc)
  471. {
  472. }
  473. #endif
  474. #ifdef CONFIG_WORD_BASED_TLV
  475. /**
  476. * dp_rx_get_reo_qdesc_addr_be(): API to get qdesc address of reo
  477. * entrance ring desc
  478. *
  479. * @hal_soc: Handle to HAL Soc structure
  480. * @dst_ring_desc: reo dest ring descriptor (used for Lithium DP)
  481. * @buf: pointer to the start of RX PKT TLV headers
  482. * @txrx_peer: pointer to txrx_peer
  483. * @tid: tid value
  484. *
  485. * Return: qdesc address in reo destination ring buffer
  486. */
  487. static inline
  488. uint64_t dp_rx_get_reo_qdesc_addr_be(hal_soc_handle_t hal_soc,
  489. uint8_t *dst_ring_desc,
  490. uint8_t *buf,
  491. struct dp_txrx_peer *txrx_peer,
  492. unsigned int tid)
  493. {
  494. struct dp_peer *peer = NULL;
  495. uint64_t qdesc_addr = 0;
  496. if (hal_reo_shared_qaddr_is_enable(hal_soc)) {
  497. qdesc_addr = (uint64_t)txrx_peer->peer_id;
  498. } else {
  499. peer = dp_peer_get_ref_by_id(txrx_peer->vdev->pdev->soc,
  500. txrx_peer->peer_id,
  501. DP_MOD_ID_CONFIG);
  502. if (!peer)
  503. return 0;
  504. qdesc_addr = (uint64_t)peer->rx_tid[tid].hw_qdesc_paddr;
  505. dp_peer_unref_delete(peer, DP_MOD_ID_CONFIG);
  506. }
  507. return qdesc_addr;
  508. }
  509. #else
  510. static inline
  511. uint64_t dp_rx_get_reo_qdesc_addr_be(hal_soc_handle_t hal_soc,
  512. uint8_t *dst_ring_desc,
  513. uint8_t *buf,
  514. struct dp_txrx_peer *txrx_peer,
  515. unsigned int tid)
  516. {
  517. return hal_rx_get_qdesc_addr(hal_soc, dst_ring_desc, buf);
  518. }
  519. #endif
  520. /**
  521. * dp_rx_wbm_err_reap_desc_be() - Function to reap and replenish
  522. * WBM RX Error descriptors
  523. *
  524. * @int_ctx: pointer to DP interrupt context
  525. * @soc: core DP main context
  526. * @hal_ring_hdl: opaque pointer to the HAL Rx Error Ring, to be serviced
  527. * @quota: No. of units (packets) that can be serviced in one shot.
  528. * @rx_bufs_used: No. of descriptors reaped
  529. *
  530. * This function implements the core Rx functionality like reap and
  531. * replenish the RX error ring Descriptors, and create a nbuf list
  532. * out of it. It also reads wbm error information from descriptors
  533. * and update the nbuf tlv area.
  534. *
  535. * Return: qdf_nbuf_t: head pointer to the nbuf list created
  536. */
  537. qdf_nbuf_t
  538. dp_rx_wbm_err_reap_desc_be(struct dp_intr *int_ctx, struct dp_soc *soc,
  539. hal_ring_handle_t hal_ring_hdl, uint32_t quota,
  540. uint32_t *rx_bufs_used);
  541. /**
  542. * dp_rx_null_q_desc_handle_be() - Function to handle NULL Queue
  543. * descriptor violation on either a
  544. * REO or WBM ring
  545. *
  546. * @soc: core DP main context
  547. * @nbuf: buffer pointer
  548. * @rx_tlv_hdr: start of rx tlv header
  549. * @pool_id: mac id
  550. * @txrx_peer: txrx peer handle
  551. * @is_reo_exception: flag to check if the error is from REO or WBM
  552. * @link_id: link Id on which the packet is received
  553. *
  554. * This function handles NULL queue descriptor violations arising out
  555. * a missing REO queue for a given peer or a given TID. This typically
  556. * may happen if a packet is received on a QOS enabled TID before the
  557. * ADDBA negotiation for that TID, when the TID queue is setup. Or
  558. * it may also happen for MC/BC frames if they are not routed to the
  559. * non-QOS TID queue, in the absence of any other default TID queue.
  560. * This error can show up both in a REO destination or WBM release ring.
  561. *
  562. * Return: QDF_STATUS_SUCCESS, if nbuf handled successfully. QDF status code
  563. * if nbuf could not be handled or dropped.
  564. */
  565. QDF_STATUS
  566. dp_rx_null_q_desc_handle_be(struct dp_soc *soc, qdf_nbuf_t nbuf,
  567. uint8_t *rx_tlv_hdr, uint8_t pool_id,
  568. struct dp_txrx_peer *txrx_peer,
  569. bool is_reo_exception, uint8_t link_id);
  570. #if defined(DP_PKT_STATS_PER_LMAC) && defined(WLAN_FEATURE_11BE_MLO)
  571. static inline void
  572. dp_rx_set_msdu_lmac_id(qdf_nbuf_t nbuf, uint32_t peer_mdata)
  573. {
  574. uint8_t lmac_id;
  575. lmac_id = dp_rx_peer_metadata_lmac_id_get_be(peer_mdata);
  576. qdf_nbuf_set_lmac_id(nbuf, lmac_id);
  577. }
  578. #else
  579. static inline void
  580. dp_rx_set_msdu_lmac_id(qdf_nbuf_t nbuf, uint32_t peer_mdata)
  581. {
  582. }
  583. #endif
  584. #ifndef CONFIG_NBUF_AP_PLATFORM
  585. #if defined(WLAN_FEATURE_11BE_MLO) && defined(DP_MLO_LINK_STATS_SUPPORT)
  586. static inline uint8_t
  587. dp_rx_peer_mdata_link_id_get_be(uint32_t peer_mdata)
  588. {
  589. uint8_t link_id;
  590. link_id = HTT_RX_PEER_META_DATA_V1A_LOGICAL_LINK_ID_GET(peer_mdata) + 1;
  591. if (link_id > DP_MAX_MLO_LINKS)
  592. link_id = 0;
  593. return link_id;
  594. }
  595. #else
  596. static inline uint8_t
  597. dp_rx_peer_mdata_link_id_get_be(uint32_t peer_metadata)
  598. {
  599. return 0;
  600. }
  601. #endif /* DP_MLO_LINK_STATS_SUPPORT */
  602. static inline void
  603. dp_rx_set_mpdu_seq_number_be(qdf_nbuf_t nbuf, uint8_t *rx_tlv_hdr)
  604. {
  605. QDF_NBUF_CB_RX_MPDU_SEQ_NUM(nbuf) =
  606. hal_rx_mpdu_sequence_number_get_be(rx_tlv_hdr);
  607. }
  608. static inline void
  609. dp_rx_set_link_id_be(qdf_nbuf_t nbuf, uint32_t peer_mdata)
  610. {
  611. uint8_t logical_link_id;
  612. logical_link_id = dp_rx_peer_mdata_link_id_get_be(peer_mdata);
  613. QDF_NBUF_CB_RX_LOGICAL_LINK_ID(nbuf) = logical_link_id;
  614. }
  615. static inline uint16_t
  616. dp_rx_get_peer_id_be(qdf_nbuf_t nbuf)
  617. {
  618. return QDF_NBUF_CB_RX_PEER_ID(nbuf);
  619. }
  620. static inline void
  621. dp_rx_set_mpdu_msdu_desc_info_in_nbuf(qdf_nbuf_t nbuf,
  622. uint32_t mpdu_desc_info,
  623. uint32_t peer_mdata,
  624. uint32_t msdu_desc_info)
  625. {
  626. }
  627. static inline uint8_t dp_rx_copy_desc_info_in_nbuf_cb(struct dp_soc *soc,
  628. hal_ring_desc_t ring_desc,
  629. qdf_nbuf_t nbuf,
  630. uint8_t reo_ring_num)
  631. {
  632. struct hal_rx_mpdu_desc_info mpdu_desc_info;
  633. struct hal_rx_msdu_desc_info msdu_desc_info;
  634. uint8_t pkt_capture_offload = 0;
  635. uint32_t peer_mdata = 0;
  636. qdf_mem_zero(&mpdu_desc_info, sizeof(mpdu_desc_info));
  637. qdf_mem_zero(&msdu_desc_info, sizeof(msdu_desc_info));
  638. /* Get MPDU DESC info */
  639. hal_rx_mpdu_desc_info_get_be(ring_desc, &mpdu_desc_info);
  640. /* Get MSDU DESC info */
  641. hal_rx_msdu_desc_info_get_be(ring_desc, &msdu_desc_info);
  642. /* Set the end bit to identify the last buffer in MPDU */
  643. if (msdu_desc_info.msdu_flags & HAL_MSDU_F_LAST_MSDU_IN_MPDU)
  644. qdf_nbuf_set_rx_chfrag_end(nbuf, 1);
  645. if (mpdu_desc_info.mpdu_flags & HAL_MPDU_F_RETRY_BIT)
  646. qdf_nbuf_set_rx_retry_flag(nbuf, 1);
  647. if (qdf_unlikely(mpdu_desc_info.mpdu_flags & HAL_MPDU_F_RAW_AMPDU))
  648. qdf_nbuf_set_raw_frame(nbuf, 1);
  649. peer_mdata = mpdu_desc_info.peer_meta_data;
  650. QDF_NBUF_CB_RX_PEER_ID(nbuf) =
  651. dp_rx_peer_metadata_peer_id_get_be(soc, peer_mdata);
  652. QDF_NBUF_CB_RX_VDEV_ID(nbuf) =
  653. dp_rx_peer_metadata_vdev_id_get_be(soc, peer_mdata);
  654. dp_rx_set_msdu_lmac_id(nbuf, peer_mdata);
  655. dp_rx_set_link_id_be(nbuf, peer_mdata);
  656. /* to indicate whether this msdu is rx offload */
  657. pkt_capture_offload =
  658. DP_PEER_METADATA_OFFLOAD_GET_BE(peer_mdata);
  659. /*
  660. * save msdu flags first, last and continuation msdu in
  661. * nbuf->cb, also save mcbc, is_da_valid, is_sa_valid and
  662. * length to nbuf->cb. This ensures the info required for
  663. * per pkt processing is always in the same cache line.
  664. * This helps in improving throughput for smaller pkt
  665. * sizes.
  666. */
  667. if (msdu_desc_info.msdu_flags & HAL_MSDU_F_FIRST_MSDU_IN_MPDU)
  668. qdf_nbuf_set_rx_chfrag_start(nbuf, 1);
  669. if (msdu_desc_info.msdu_flags & HAL_MSDU_F_MSDU_CONTINUATION)
  670. qdf_nbuf_set_rx_chfrag_cont(nbuf, 1);
  671. if (msdu_desc_info.msdu_flags & HAL_MSDU_F_DA_IS_MCBC)
  672. qdf_nbuf_set_da_mcbc(nbuf, 1);
  673. if (msdu_desc_info.msdu_flags & HAL_MSDU_F_DA_IS_VALID)
  674. qdf_nbuf_set_da_valid(nbuf, 1);
  675. if (msdu_desc_info.msdu_flags & HAL_MSDU_F_SA_IS_VALID)
  676. qdf_nbuf_set_sa_valid(nbuf, 1);
  677. if (msdu_desc_info.msdu_flags & HAL_MSDU_F_INTRA_BSS)
  678. qdf_nbuf_set_intra_bss(nbuf, 1);
  679. if (qdf_likely(mpdu_desc_info.mpdu_flags &
  680. HAL_MPDU_F_QOS_CONTROL_VALID))
  681. qdf_nbuf_set_tid_val(nbuf, mpdu_desc_info.tid);
  682. /* set sw exception */
  683. qdf_nbuf_set_rx_reo_dest_ind_or_sw_excpt(
  684. nbuf,
  685. hal_rx_sw_exception_get_be(ring_desc));
  686. QDF_NBUF_CB_RX_PKT_LEN(nbuf) = msdu_desc_info.msdu_len;
  687. QDF_NBUF_CB_RX_CTX_ID(nbuf) = reo_ring_num;
  688. return pkt_capture_offload;
  689. }
  690. static inline uint8_t hal_rx_get_l3_pad_bytes_be(qdf_nbuf_t nbuf,
  691. uint8_t *rx_tlv_hdr)
  692. {
  693. return HAL_RX_TLV_L3_HEADER_PADDING_GET(rx_tlv_hdr);
  694. }
  695. static inline uint8_t
  696. dp_rx_wbm_err_msdu_continuation_get(struct dp_soc *soc,
  697. hal_ring_desc_t ring_desc,
  698. qdf_nbuf_t nbuf)
  699. {
  700. return hal_rx_wbm_err_msdu_continuation_get(soc->hal_soc,
  701. ring_desc);
  702. }
  703. #else
  704. static inline void
  705. dp_rx_set_link_id_be(qdf_nbuf_t nbuf, uint32_t peer_mdata)
  706. {
  707. }
  708. static inline void
  709. dp_rx_set_mpdu_seq_number_be(qdf_nbuf_t nbuf, uint8_t *rx_tlv_hdr)
  710. {
  711. }
  712. static inline uint16_t
  713. dp_rx_get_peer_id_be(qdf_nbuf_t nbuf)
  714. {
  715. uint32_t peer_metadata = QDF_NBUF_CB_RX_MPDU_DESC_INFO_2(nbuf);
  716. return ((peer_metadata & DP_BE_PEER_METADATA_PEER_ID_MASK) >>
  717. DP_BE_PEER_METADATA_PEER_ID_SHIFT);
  718. }
  719. static inline void
  720. dp_rx_set_mpdu_msdu_desc_info_in_nbuf(qdf_nbuf_t nbuf,
  721. uint32_t mpdu_desc_info,
  722. uint32_t peer_mdata,
  723. uint32_t msdu_desc_info)
  724. {
  725. QDF_NBUF_CB_RX_MPDU_DESC_INFO_1(nbuf) = mpdu_desc_info;
  726. QDF_NBUF_CB_RX_MPDU_DESC_INFO_2(nbuf) = peer_mdata;
  727. QDF_NBUF_CB_RX_MSDU_DESC_INFO(nbuf) = msdu_desc_info;
  728. }
  729. static inline uint8_t dp_rx_copy_desc_info_in_nbuf_cb(struct dp_soc *soc,
  730. hal_ring_desc_t ring_desc,
  731. qdf_nbuf_t nbuf,
  732. uint8_t reo_ring_num)
  733. {
  734. uint32_t mpdu_desc_info = 0;
  735. uint32_t msdu_desc_info = 0;
  736. uint32_t peer_mdata = 0;
  737. /* get REO mpdu & msdu desc info */
  738. hal_rx_get_mpdu_msdu_desc_info_be(ring_desc,
  739. &mpdu_desc_info,
  740. &peer_mdata,
  741. &msdu_desc_info);
  742. dp_rx_set_mpdu_msdu_desc_info_in_nbuf(nbuf,
  743. mpdu_desc_info,
  744. peer_mdata,
  745. msdu_desc_info);
  746. return 0;
  747. }
  748. static inline uint8_t hal_rx_get_l3_pad_bytes_be(qdf_nbuf_t nbuf,
  749. uint8_t *rx_tlv_hdr)
  750. {
  751. return QDF_NBUF_CB_RX_L3_PAD_MSB(nbuf) ? 2 : 0;
  752. }
  753. static inline uint8_t
  754. dp_rx_wbm_err_msdu_continuation_get(struct dp_soc *soc,
  755. hal_ring_desc_t ring_desc,
  756. qdf_nbuf_t nbuf)
  757. {
  758. return qdf_nbuf_is_rx_chfrag_cont(nbuf);
  759. }
  760. #endif /* CONFIG_NBUF_AP_PLATFORM */
  761. /**
  762. * dp_rx_wbm_err_copy_desc_info_in_nbuf(): API to copy WBM dest ring
  763. * descriptor information in nbuf CB/TLV
  764. *
  765. * @soc: pointer to Soc structure
  766. * @ring_desc: wbm dest ring descriptor
  767. * @nbuf: nbuf to save descriptor information
  768. * @pool_id: pool id part of wbm error info
  769. *
  770. * Return: wbm error information details
  771. */
  772. static inline uint32_t
  773. dp_rx_wbm_err_copy_desc_info_in_nbuf(struct dp_soc *soc,
  774. hal_ring_desc_t ring_desc,
  775. qdf_nbuf_t nbuf,
  776. uint8_t pool_id)
  777. {
  778. uint32_t mpdu_desc_info = 0;
  779. uint32_t msdu_desc_info = 0;
  780. uint32_t peer_mdata = 0;
  781. union hal_wbm_err_info_u wbm_err = { 0 };
  782. /* get WBM mpdu & msdu desc info */
  783. hal_rx_wbm_err_mpdu_msdu_info_get_be(ring_desc,
  784. &wbm_err.info,
  785. &mpdu_desc_info,
  786. &msdu_desc_info,
  787. &peer_mdata);
  788. wbm_err.info_bit.pool_id = pool_id;
  789. dp_rx_set_mpdu_msdu_desc_info_in_nbuf(nbuf,
  790. mpdu_desc_info,
  791. peer_mdata,
  792. msdu_desc_info);
  793. dp_rx_set_wbm_err_info_in_nbuf(soc, nbuf, wbm_err);
  794. return wbm_err.info;
  795. }
  796. #if defined(WLAN_FEATURE_11BE_MLO) && defined(WLAN_MLO_MULTI_CHIP)
  797. struct dp_soc *
  798. dp_get_soc_by_chip_id_be(struct dp_soc *soc, uint8_t chip_id);
  799. #else
  800. static inline struct dp_soc *
  801. dp_get_soc_by_chip_id_be(struct dp_soc *soc, uint8_t chip_id)
  802. {
  803. return soc;
  804. }
  805. #endif
  806. #endif