dp_rx.h 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752
  1. /*
  2. * Copyright (c) 2016-2018 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. #ifndef _DP_RX_H
  19. #define _DP_RX_H
  20. #include "hal_rx.h"
  21. #include "dp_tx.h"
  22. #include "dp_peer.h"
  23. #include "dp_internal.h"
  24. #ifdef RXDMA_OPTIMIZATION
  25. #define RX_BUFFER_ALIGNMENT 128
  26. #else /* RXDMA_OPTIMIZATION */
  27. #define RX_BUFFER_ALIGNMENT 4
  28. #endif /* RXDMA_OPTIMIZATION */
  29. #ifdef QCA_HOST2FW_RXBUF_RING
  30. #define DP_WBM2SW_RBM HAL_RX_BUF_RBM_SW1_BM
  31. #else
  32. #define DP_WBM2SW_RBM HAL_RX_BUF_RBM_SW3_BM
  33. #endif
  34. #define RX_BUFFER_SIZE 2048
  35. #define RX_BUFFER_RESERVATION 0
  36. #define DP_PEER_METADATA_PEER_ID_MASK 0x0000ffff
  37. #define DP_PEER_METADATA_PEER_ID_SHIFT 0
  38. #define DP_PEER_METADATA_VDEV_ID_MASK 0x00070000
  39. #define DP_PEER_METADATA_VDEV_ID_SHIFT 16
  40. #define DP_PEER_METADATA_PEER_ID_GET(_peer_metadata) \
  41. (((_peer_metadata) & DP_PEER_METADATA_PEER_ID_MASK) \
  42. >> DP_PEER_METADATA_PEER_ID_SHIFT)
  43. #define DP_PEER_METADATA_ID_GET(_peer_metadata) \
  44. (((_peer_metadata) & DP_PEER_METADATA_VDEV_ID_MASK) \
  45. >> DP_PEER_METADATA_VDEV_ID_SHIFT)
  46. #define DP_RX_DESC_MAGIC 0xdec0de
  47. /**
  48. * struct dp_rx_desc
  49. *
  50. * @nbuf : VA of the "skb" posted
  51. * @rx_buf_start : VA of the original Rx buffer, before
  52. * movement of any skb->data pointer
  53. * @cookie : index into the sw array which holds
  54. * the sw Rx descriptors
  55. * Cookie space is 21 bits:
  56. * lower 18 bits -- index
  57. * upper 3 bits -- pool_id
  58. * @pool_id : pool Id for which this allocated.
  59. * Can only be used if there is no flow
  60. * steering
  61. * @in_use rx_desc is in use
  62. * @unmapped used to mark rx_desc an unmapped if the corresponding
  63. * nbuf is already unmapped
  64. */
  65. struct dp_rx_desc {
  66. qdf_nbuf_t nbuf;
  67. uint8_t *rx_buf_start;
  68. uint32_t cookie;
  69. uint8_t pool_id;
  70. #ifdef RX_DESC_DEBUG_CHECK
  71. uint32_t magic;
  72. #endif
  73. uint8_t in_use:1,
  74. unmapped:1;
  75. };
  76. #define RX_DESC_COOKIE_INDEX_SHIFT 0
  77. #define RX_DESC_COOKIE_INDEX_MASK 0x3ffff /* 18 bits */
  78. #define RX_DESC_COOKIE_POOL_ID_SHIFT 18
  79. #define RX_DESC_COOKIE_POOL_ID_MASK 0x1c0000
  80. #define DP_RX_DESC_COOKIE_POOL_ID_GET(_cookie) \
  81. (((_cookie) & RX_DESC_COOKIE_POOL_ID_MASK) >> \
  82. RX_DESC_COOKIE_POOL_ID_SHIFT)
  83. #define DP_RX_DESC_COOKIE_INDEX_GET(_cookie) \
  84. (((_cookie) & RX_DESC_COOKIE_INDEX_MASK) >> \
  85. RX_DESC_COOKIE_INDEX_SHIFT)
  86. /*
  87. *dp_rx_xor_block() - xor block of data
  88. *@b: destination data block
  89. *@a: source data block
  90. *@len: length of the data to process
  91. *
  92. *Returns: None
  93. */
  94. static inline void dp_rx_xor_block(uint8_t *b, const uint8_t *a, qdf_size_t len)
  95. {
  96. qdf_size_t i;
  97. for (i = 0; i < len; i++)
  98. b[i] ^= a[i];
  99. }
  100. /*
  101. *dp_rx_rotl() - rotate the bits left
  102. *@val: unsigned integer input value
  103. *@bits: number of bits
  104. *
  105. *Returns: Integer with left rotated by number of 'bits'
  106. */
  107. static inline uint32_t dp_rx_rotl(uint32_t val, int bits)
  108. {
  109. return (val << bits) | (val >> (32 - bits));
  110. }
  111. /*
  112. *dp_rx_rotr() - rotate the bits right
  113. *@val: unsigned integer input value
  114. *@bits: number of bits
  115. *
  116. *Returns: Integer with right rotated by number of 'bits'
  117. */
  118. static inline uint32_t dp_rx_rotr(uint32_t val, int bits)
  119. {
  120. return (val >> bits) | (val << (32 - bits));
  121. }
  122. /*
  123. *dp_rx_xswap() - swap the bits left
  124. *@val: unsigned integer input value
  125. *
  126. *Returns: Integer with bits swapped
  127. */
  128. static inline uint32_t dp_rx_xswap(uint32_t val)
  129. {
  130. return ((val & 0x00ff00ff) << 8) | ((val & 0xff00ff00) >> 8);
  131. }
  132. /*
  133. *dp_rx_get_le32_split() - get little endian 32 bits split
  134. *@b0: byte 0
  135. *@b1: byte 1
  136. *@b2: byte 2
  137. *@b3: byte 3
  138. *
  139. *Returns: Integer with split little endian 32 bits
  140. */
  141. static inline uint32_t dp_rx_get_le32_split(uint8_t b0, uint8_t b1, uint8_t b2,
  142. uint8_t b3)
  143. {
  144. return b0 | (b1 << 8) | (b2 << 16) | (b3 << 24);
  145. }
  146. /*
  147. *dp_rx_get_le32() - get little endian 32 bits
  148. *@b0: byte 0
  149. *@b1: byte 1
  150. *@b2: byte 2
  151. *@b3: byte 3
  152. *
  153. *Returns: Integer with little endian 32 bits
  154. */
  155. static inline uint32_t dp_rx_get_le32(const uint8_t *p)
  156. {
  157. return dp_rx_get_le32_split(p[0], p[1], p[2], p[3]);
  158. }
  159. /*
  160. * dp_rx_put_le32() - put little endian 32 bits
  161. * @p: destination char array
  162. * @v: source 32-bit integer
  163. *
  164. * Returns: None
  165. */
  166. static inline void dp_rx_put_le32(uint8_t *p, uint32_t v)
  167. {
  168. p[0] = (v) & 0xff;
  169. p[1] = (v >> 8) & 0xff;
  170. p[2] = (v >> 16) & 0xff;
  171. p[3] = (v >> 24) & 0xff;
  172. }
  173. /* Extract michal mic block of data */
  174. #define dp_rx_michael_block(l, r) \
  175. do { \
  176. r ^= dp_rx_rotl(l, 17); \
  177. l += r; \
  178. r ^= dp_rx_xswap(l); \
  179. l += r; \
  180. r ^= dp_rx_rotl(l, 3); \
  181. l += r; \
  182. r ^= dp_rx_rotr(l, 2); \
  183. l += r; \
  184. } while (0)
  185. /**
  186. * struct dp_rx_desc_list_elem_t
  187. *
  188. * @next : Next pointer to form free list
  189. * @rx_desc : DP Rx descriptor
  190. */
  191. union dp_rx_desc_list_elem_t {
  192. union dp_rx_desc_list_elem_t *next;
  193. struct dp_rx_desc rx_desc;
  194. };
  195. /**
  196. * dp_rx_cookie_2_va_rxdma_buf() - Converts cookie to a virtual address of
  197. * the Rx descriptor on Rx DMA source ring buffer
  198. * @soc: core txrx main context
  199. * @cookie: cookie used to lookup virtual address
  200. *
  201. * Return: void *: Virtual Address of the Rx descriptor
  202. */
  203. static inline
  204. void *dp_rx_cookie_2_va_rxdma_buf(struct dp_soc *soc, uint32_t cookie)
  205. {
  206. uint8_t pool_id = DP_RX_DESC_COOKIE_POOL_ID_GET(cookie);
  207. uint16_t index = DP_RX_DESC_COOKIE_INDEX_GET(cookie);
  208. /* TODO */
  209. /* Add sanity for pool_id & index */
  210. return &(soc->rx_desc_buf[pool_id].array[index].rx_desc);
  211. }
  212. /**
  213. * dp_rx_cookie_2_va_mon_buf() - Converts cookie to a virtual address of
  214. * the Rx descriptor on monitor ring buffer
  215. * @soc: core txrx main context
  216. * @cookie: cookie used to lookup virtual address
  217. *
  218. * Return: void *: Virtual Address of the Rx descriptor
  219. */
  220. static inline
  221. void *dp_rx_cookie_2_va_mon_buf(struct dp_soc *soc, uint32_t cookie)
  222. {
  223. uint8_t pool_id = DP_RX_DESC_COOKIE_POOL_ID_GET(cookie);
  224. uint16_t index = DP_RX_DESC_COOKIE_INDEX_GET(cookie);
  225. /* TODO */
  226. /* Add sanity for pool_id & index */
  227. return &(soc->rx_desc_mon[pool_id].array[index].rx_desc);
  228. }
  229. /**
  230. * dp_rx_cookie_2_va_mon_status() - Converts cookie to a virtual address of
  231. * the Rx descriptor on monitor status ring buffer
  232. * @soc: core txrx main context
  233. * @cookie: cookie used to lookup virtual address
  234. *
  235. * Return: void *: Virtual Address of the Rx descriptor
  236. */
  237. static inline
  238. void *dp_rx_cookie_2_va_mon_status(struct dp_soc *soc, uint32_t cookie)
  239. {
  240. uint8_t pool_id = DP_RX_DESC_COOKIE_POOL_ID_GET(cookie);
  241. uint16_t index = DP_RX_DESC_COOKIE_INDEX_GET(cookie);
  242. /* TODO */
  243. /* Add sanity for pool_id & index */
  244. return &(soc->rx_desc_status[pool_id].array[index].rx_desc);
  245. }
  246. void dp_rx_add_desc_list_to_free_list(struct dp_soc *soc,
  247. union dp_rx_desc_list_elem_t **local_desc_list,
  248. union dp_rx_desc_list_elem_t **tail,
  249. uint16_t pool_id,
  250. struct rx_desc_pool *rx_desc_pool);
  251. uint16_t dp_rx_get_free_desc_list(struct dp_soc *soc, uint32_t pool_id,
  252. struct rx_desc_pool *rx_desc_pool,
  253. uint16_t num_descs,
  254. union dp_rx_desc_list_elem_t **desc_list,
  255. union dp_rx_desc_list_elem_t **tail);
  256. QDF_STATUS dp_rx_pdev_attach(struct dp_pdev *pdev);
  257. void dp_rx_pdev_detach(struct dp_pdev *pdev);
  258. uint32_t
  259. dp_rx_process(struct dp_intr *int_ctx, void *hal_ring, uint32_t quota);
  260. uint32_t dp_rx_err_process(struct dp_soc *soc, void *hal_ring, uint32_t quota);
  261. uint32_t
  262. dp_rx_wbm_err_process(struct dp_soc *soc, void *hal_ring, uint32_t quota);
  263. /**
  264. * dp_rx_sg_create() - create a frag_list for MSDUs which are spread across
  265. * multiple nbufs.
  266. * @nbuf: pointer to the first msdu of an amsdu.
  267. * @rx_tlv_hdr: pointer to the start of RX TLV headers.
  268. *
  269. * This function implements the creation of RX frag_list for cases
  270. * where an MSDU is spread across multiple nbufs.
  271. *
  272. * Return: returns the head nbuf which contains complete frag_list.
  273. */
  274. qdf_nbuf_t dp_rx_sg_create(qdf_nbuf_t nbuf, uint8_t *rx_tlv_hdr);
  275. QDF_STATUS dp_rx_desc_pool_alloc(struct dp_soc *soc,
  276. uint32_t pool_id,
  277. uint32_t pool_size,
  278. struct rx_desc_pool *rx_desc_pool);
  279. void dp_rx_desc_pool_free(struct dp_soc *soc,
  280. uint32_t pool_id,
  281. struct rx_desc_pool *rx_desc_pool);
  282. void dp_rx_deliver_raw(struct dp_vdev *vdev, qdf_nbuf_t nbuf_list,
  283. struct dp_peer *peer);
  284. /**
  285. * dp_rx_add_to_free_desc_list() - Adds to a local free descriptor list
  286. *
  287. * @head: pointer to the head of local free list
  288. * @tail: pointer to the tail of local free list
  289. * @new: new descriptor that is added to the free list
  290. *
  291. * Return: void:
  292. */
  293. static inline
  294. void dp_rx_add_to_free_desc_list(union dp_rx_desc_list_elem_t **head,
  295. union dp_rx_desc_list_elem_t **tail,
  296. struct dp_rx_desc *new)
  297. {
  298. qdf_assert(head && new);
  299. new->nbuf = NULL;
  300. new->in_use = 0;
  301. new->unmapped = 0;
  302. ((union dp_rx_desc_list_elem_t *)new)->next = *head;
  303. *head = (union dp_rx_desc_list_elem_t *)new;
  304. if (*tail == NULL)
  305. *tail = *head;
  306. }
  307. /**
  308. * dp_rx_wds_srcport_learn() - Add or update the STA PEER which
  309. * is behind the WDS repeater.
  310. *
  311. * @soc: core txrx main context
  312. * @rx_tlv_hdr: base address of RX TLV header
  313. * @ta_peer: WDS repeater peer
  314. * @nbuf: rx pkt
  315. *
  316. * Return: void:
  317. */
  318. #ifdef FEATURE_WDS
  319. static inline void
  320. dp_rx_wds_srcport_learn(struct dp_soc *soc,
  321. uint8_t *rx_tlv_hdr,
  322. struct dp_peer *ta_peer,
  323. qdf_nbuf_t nbuf)
  324. {
  325. uint16_t sa_sw_peer_id = hal_rx_msdu_end_sa_sw_peer_id_get(rx_tlv_hdr);
  326. uint32_t flags = IEEE80211_NODE_F_WDS_HM;
  327. uint32_t ret = 0;
  328. uint8_t wds_src_mac[IEEE80211_ADDR_LEN];
  329. struct dp_ast_entry *ast;
  330. uint16_t sa_idx;
  331. /* Do wds source port learning only if it is a 4-address mpdu */
  332. if (!(qdf_nbuf_is_rx_chfrag_start(nbuf) &&
  333. hal_rx_get_mpdu_mac_ad4_valid(rx_tlv_hdr)))
  334. return;
  335. memcpy(wds_src_mac, (qdf_nbuf_data(nbuf) + IEEE80211_ADDR_LEN),
  336. IEEE80211_ADDR_LEN);
  337. if (qdf_unlikely(!hal_rx_msdu_end_sa_is_valid_get(rx_tlv_hdr))) {
  338. ret = dp_peer_add_ast(soc,
  339. ta_peer,
  340. wds_src_mac,
  341. CDP_TXRX_AST_TYPE_WDS,
  342. flags);
  343. return;
  344. }
  345. /*
  346. * Get the AST entry from HW SA index and mark it as active
  347. */
  348. sa_idx = hal_rx_msdu_end_sa_idx_get(rx_tlv_hdr);
  349. qdf_spin_lock_bh(&soc->ast_lock);
  350. ast = soc->ast_table[sa_idx];
  351. if (!ast) {
  352. qdf_spin_unlock_bh(&soc->ast_lock);
  353. return;
  354. }
  355. /*
  356. * Ensure we are updating the right AST entry by
  357. * validating ast_idx.
  358. * There is a possibility we might arrive here without
  359. * AST MAP event , so this check is mandatory
  360. */
  361. if (ast->ast_idx == sa_idx)
  362. ast->is_active = TRUE;
  363. /* Handle client roaming */
  364. if (sa_sw_peer_id != ta_peer->peer_ids[0])
  365. dp_peer_update_ast(soc, ta_peer, ast, flags);
  366. qdf_spin_unlock_bh(&soc->ast_lock);
  367. return;
  368. }
  369. #else
  370. static inline void
  371. dp_rx_wds_srcport_learn(struct dp_soc *soc,
  372. uint8_t *rx_tlv_hdr,
  373. struct dp_peer *ta_peer,
  374. qdf_nbuf_t nbuf)
  375. {
  376. }
  377. #endif
  378. uint8_t dp_rx_process_invalid_peer(struct dp_soc *soc, qdf_nbuf_t nbuf);
  379. void dp_rx_process_invalid_peer_wrapper(struct dp_soc *soc,
  380. qdf_nbuf_t mpdu, bool mpdu_done);
  381. void dp_rx_process_mic_error(struct dp_soc *soc, qdf_nbuf_t nbuf, uint8_t *rx_tlv_hdr);
  382. #define DP_RX_LIST_APPEND(head, tail, elem) \
  383. do { \
  384. if (!(head)) { \
  385. (head) = (elem); \
  386. } else { \
  387. qdf_nbuf_set_next((tail), (elem)); \
  388. } \
  389. (tail) = (elem); \
  390. qdf_nbuf_set_next((tail), NULL); \
  391. } while (0)
  392. #ifndef BUILD_X86
  393. static inline int check_x86_paddr(struct dp_soc *dp_soc, qdf_nbuf_t *rx_netbuf,
  394. qdf_dma_addr_t *paddr, struct dp_pdev *pdev)
  395. {
  396. return QDF_STATUS_SUCCESS;
  397. }
  398. #else
  399. #define MAX_RETRY 100
  400. static inline int check_x86_paddr(struct dp_soc *dp_soc, qdf_nbuf_t *rx_netbuf,
  401. qdf_dma_addr_t *paddr, struct dp_pdev *pdev)
  402. {
  403. uint32_t nbuf_retry = 0;
  404. int32_t ret;
  405. const uint32_t x86_phy_addr = 0x50000000;
  406. /*
  407. * in M2M emulation platforms (x86) the memory below 0x50000000
  408. * is reserved for target use, so any memory allocated in this
  409. * region should not be used by host
  410. */
  411. do {
  412. if (qdf_likely(*paddr > x86_phy_addr))
  413. return QDF_STATUS_SUCCESS;
  414. else {
  415. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO,
  416. "phy addr %pK exceded 0x50000000 trying again\n",
  417. paddr);
  418. nbuf_retry++;
  419. if ((*rx_netbuf)) {
  420. qdf_nbuf_unmap_single(dp_soc->osdev, *rx_netbuf,
  421. QDF_DMA_BIDIRECTIONAL);
  422. /* Not freeing buffer intentionally.
  423. * Observed that same buffer is getting
  424. * re-allocated resulting in longer load time
  425. * WMI init timeout.
  426. * This buffer is anyway not useful so skip it.
  427. **/
  428. }
  429. *rx_netbuf = qdf_nbuf_alloc(dp_soc->osdev,
  430. RX_BUFFER_SIZE,
  431. RX_BUFFER_RESERVATION,
  432. RX_BUFFER_ALIGNMENT,
  433. FALSE);
  434. if (qdf_unlikely(!(*rx_netbuf)))
  435. return QDF_STATUS_E_FAILURE;
  436. ret = qdf_nbuf_map_single(dp_soc->osdev, *rx_netbuf,
  437. QDF_DMA_BIDIRECTIONAL);
  438. if (qdf_unlikely(ret == QDF_STATUS_E_FAILURE)) {
  439. qdf_nbuf_free(*rx_netbuf);
  440. *rx_netbuf = NULL;
  441. continue;
  442. }
  443. *paddr = qdf_nbuf_get_frag_paddr(*rx_netbuf, 0);
  444. }
  445. } while (nbuf_retry < MAX_RETRY);
  446. if ((*rx_netbuf)) {
  447. qdf_nbuf_unmap_single(dp_soc->osdev, *rx_netbuf,
  448. QDF_DMA_BIDIRECTIONAL);
  449. qdf_nbuf_free(*rx_netbuf);
  450. }
  451. return QDF_STATUS_E_FAILURE;
  452. }
  453. #endif
  454. /**
  455. * dp_rx_cookie_2_link_desc_va() - Converts cookie to a virtual address of
  456. * the MSDU Link Descriptor
  457. * @soc: core txrx main context
  458. * @buf_info: buf_info include cookie that used to lookup virtual address of
  459. * link descriptor Normally this is just an index into a per SOC array.
  460. *
  461. * This is the VA of the link descriptor, that HAL layer later uses to
  462. * retrieve the list of MSDU's for a given MPDU.
  463. *
  464. * Return: void *: Virtual Address of the Rx descriptor
  465. */
  466. static inline
  467. void *dp_rx_cookie_2_link_desc_va(struct dp_soc *soc,
  468. struct hal_buf_info *buf_info)
  469. {
  470. void *link_desc_va;
  471. uint32_t bank_id = LINK_DESC_COOKIE_BANK_ID(buf_info->sw_cookie);
  472. /* TODO */
  473. /* Add sanity for cookie */
  474. link_desc_va = soc->link_desc_banks[bank_id].base_vaddr +
  475. (buf_info->paddr -
  476. soc->link_desc_banks[bank_id].base_paddr);
  477. return link_desc_va;
  478. }
  479. /**
  480. * dp_rx_cookie_2_mon_link_desc_va() - Converts cookie to a virtual address of
  481. * the MSDU Link Descriptor
  482. * @pdev: core txrx pdev context
  483. * @buf_info: buf_info includes cookie that used to lookup virtual address of
  484. * link descriptor. Normally this is just an index into a per pdev array.
  485. *
  486. * This is the VA of the link descriptor in monitor mode destination ring,
  487. * that HAL layer later uses to retrieve the list of MSDU's for a given MPDU.
  488. *
  489. * Return: void *: Virtual Address of the Rx descriptor
  490. */
  491. static inline
  492. void *dp_rx_cookie_2_mon_link_desc_va(struct dp_pdev *pdev,
  493. struct hal_buf_info *buf_info,
  494. int mac_id)
  495. {
  496. void *link_desc_va;
  497. int mac_for_pdev = dp_get_mac_id_for_mac(pdev->soc, mac_id);
  498. /* TODO */
  499. /* Add sanity for cookie */
  500. link_desc_va =
  501. pdev->link_desc_banks[mac_for_pdev][buf_info->sw_cookie].base_vaddr +
  502. (buf_info->paddr -
  503. pdev->link_desc_banks[mac_for_pdev][buf_info->sw_cookie].base_paddr);
  504. return link_desc_va;
  505. }
  506. /**
  507. * dp_rx_defrag_concat() - Concatenate the fragments
  508. *
  509. * @dst: destination pointer to the buffer
  510. * @src: source pointer from where the fragment payload is to be copied
  511. *
  512. * Return: QDF_STATUS
  513. */
  514. static inline QDF_STATUS dp_rx_defrag_concat(qdf_nbuf_t dst, qdf_nbuf_t src)
  515. {
  516. /*
  517. * Inside qdf_nbuf_cat, if it is necessary to reallocate dst
  518. * to provide space for src, the headroom portion is copied from
  519. * the original dst buffer to the larger new dst buffer.
  520. * (This is needed, because the headroom of the dst buffer
  521. * contains the rx desc.)
  522. */
  523. if (qdf_nbuf_cat(dst, src))
  524. return QDF_STATUS_E_DEFRAG_ERROR;
  525. return QDF_STATUS_SUCCESS;
  526. }
  527. /*
  528. * dp_rx_ast_set_active() - set the active flag of the astentry
  529. * corresponding to a hw index.
  530. * @soc: core txrx main context
  531. * @sa_idx: hw idx
  532. * @is_active: active flag
  533. *
  534. */
  535. #ifdef FEATURE_WDS
  536. static inline QDF_STATUS dp_rx_ast_set_active(struct dp_soc *soc, uint16_t sa_idx, bool is_active)
  537. {
  538. struct dp_ast_entry *ast;
  539. qdf_spin_lock_bh(&soc->ast_lock);
  540. ast = soc->ast_table[sa_idx];
  541. /*
  542. * Ensure we are updating the right AST entry by
  543. * validating ast_idx.
  544. * There is a possibility we might arrive here without
  545. * AST MAP event , so this check is mandatory
  546. */
  547. if (ast && (ast->ast_idx == sa_idx)) {
  548. ast->is_active = is_active;
  549. qdf_spin_unlock_bh(&soc->ast_lock);
  550. return QDF_STATUS_SUCCESS;
  551. }
  552. qdf_spin_unlock_bh(&soc->ast_lock);
  553. return QDF_STATUS_E_FAILURE;
  554. }
  555. #else
  556. static inline QDF_STATUS dp_rx_ast_set_active(struct dp_soc *soc, uint16_t sa_idx, bool is_active)
  557. {
  558. return QDF_STATUS_SUCCESS;
  559. }
  560. #endif
  561. /*
  562. * check_qwrap_multicast_loopback() - Check if rx packet is a loopback packet.
  563. * In qwrap mode, packets originated from
  564. * any vdev should not loopback and
  565. * should be dropped.
  566. * @vdev: vdev on which rx packet is received
  567. * @nbuf: rx pkt
  568. *
  569. */
  570. #if ATH_SUPPORT_WRAP
  571. static inline bool check_qwrap_multicast_loopback(struct dp_vdev *vdev,
  572. qdf_nbuf_t nbuf)
  573. {
  574. struct dp_vdev *psta_vdev;
  575. struct dp_pdev *pdev = vdev->pdev;
  576. uint8_t *data = qdf_nbuf_data(nbuf);
  577. if (qdf_unlikely(vdev->proxysta_vdev)) {
  578. /* In qwrap isolation mode, allow loopback packets as all
  579. * packets go to RootAP and Loopback on the mpsta.
  580. */
  581. if (vdev->isolation_vdev)
  582. return false;
  583. TAILQ_FOREACH(psta_vdev, &pdev->vdev_list, vdev_list_elem) {
  584. if (qdf_unlikely(psta_vdev->proxysta_vdev &&
  585. !qdf_mem_cmp(psta_vdev->mac_addr.raw,
  586. &data[DP_MAC_ADDR_LEN], DP_MAC_ADDR_LEN))) {
  587. /* Drop packet if source address is equal to
  588. * any of the vdev addresses.
  589. */
  590. return true;
  591. }
  592. }
  593. }
  594. return false;
  595. }
  596. #else
  597. static inline bool check_qwrap_multicast_loopback(struct dp_vdev *vdev,
  598. qdf_nbuf_t nbuf)
  599. {
  600. return false;
  601. }
  602. #endif
  603. /*
  604. * dp_rx_buffers_replenish() - replenish rxdma ring with rx nbufs
  605. * called during dp rx initialization
  606. * and at the end of dp_rx_process.
  607. *
  608. * @soc: core txrx main context
  609. * @mac_id: mac_id which is one of 3 mac_ids
  610. * @dp_rxdma_srng: dp rxdma circular ring
  611. * @rx_desc_pool: Poiter to free Rx descriptor pool
  612. * @num_req_buffers: number of buffer to be replenished
  613. * @desc_list: list of descs if called from dp_rx_process
  614. * or NULL during dp rx initialization or out of buffer
  615. * interrupt.
  616. * @tail: tail of descs list
  617. * Return: return success or failure
  618. */
  619. QDF_STATUS dp_rx_buffers_replenish(struct dp_soc *dp_soc, uint32_t mac_id,
  620. struct dp_srng *dp_rxdma_srng,
  621. struct rx_desc_pool *rx_desc_pool,
  622. uint32_t num_req_buffers,
  623. union dp_rx_desc_list_elem_t **desc_list,
  624. union dp_rx_desc_list_elem_t **tail);
  625. /**
  626. * dp_rx_link_desc_return() - Return a MPDU link descriptor to HW
  627. * (WBM), following error handling
  628. *
  629. * @soc: core DP main context
  630. * @buf_addr_info: opaque pointer to the REO error ring descriptor
  631. * @buf_addr_info: void pointer to the buffer_addr_info
  632. * @bm_action: put to idle_list or release to msdu_list
  633. * Return: QDF_STATUS
  634. */
  635. QDF_STATUS
  636. dp_rx_link_desc_return(struct dp_soc *soc, void *ring_desc, uint8_t bm_action);
  637. QDF_STATUS
  638. dp_rx_link_desc_buf_return(struct dp_soc *soc, struct dp_srng *dp_rxdma_srng,
  639. void *buf_addr_info, uint8_t bm_action);
  640. /**
  641. * dp_rx_link_desc_return_by_addr - Return a MPDU link descriptor to
  642. * (WBM) by address
  643. *
  644. * @soc: core DP main context
  645. * @link_desc_addr: link descriptor addr
  646. *
  647. * Return: QDF_STATUS
  648. */
  649. QDF_STATUS
  650. dp_rx_link_desc_return_by_addr(struct dp_soc *soc, void *link_desc_addr,
  651. uint8_t bm_action);
  652. uint32_t
  653. dp_rxdma_err_process(struct dp_soc *soc, uint32_t mac_id,
  654. uint32_t quota);
  655. void dp_rx_fill_mesh_stats(struct dp_vdev *vdev, qdf_nbuf_t nbuf,
  656. uint8_t *rx_tlv_hdr, struct dp_peer *peer);
  657. QDF_STATUS dp_rx_filter_mesh_packets(struct dp_vdev *vdev, qdf_nbuf_t nbuf,
  658. uint8_t *rx_tlv_hdr);
  659. int dp_wds_rx_policy_check(uint8_t *rx_tlv_hdr, struct dp_vdev *vdev,
  660. struct dp_peer *peer, int rx_mcast);
  661. qdf_nbuf_t
  662. dp_rx_nbuf_prepare(struct dp_soc *soc, struct dp_pdev *pdev);
  663. #endif /* _DP_RX_H */