dp_rx.h 20 KB

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