dp_rx.h 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714
  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. #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. if (!dp_peer_add_ast(soc, ta_peer, wds_src_mac,
  323. dp_ast_type_wds)) {
  324. ret = soc->cdp_soc.ol_ops->peer_add_wds_entry(
  325. ta_peer->vdev->osif_vdev,
  326. wds_src_mac,
  327. ta_peer->mac_addr.raw,
  328. flags);
  329. }
  330. } else {
  331. /*
  332. * Get the AST entry from HW SA index and mark it as active
  333. */
  334. struct dp_ast_entry *ast;
  335. uint16_t sa_idx = hal_rx_msdu_end_sa_idx_get(rx_tlv_hdr);
  336. ast = soc->ast_table[sa_idx];
  337. /*
  338. * Ensure we are updating the right AST entry by
  339. * validating ast_idx.
  340. * There is a possibility we might arrive here without
  341. * AST MAP event , so this check is mandatory
  342. */
  343. if (ast && (ast->ast_idx == sa_idx)) {
  344. ast->is_active = TRUE;
  345. }
  346. if (sa_sw_peer_id != ta_peer->peer_ids[0]) {
  347. ret = soc->cdp_soc.ol_ops->peer_update_wds_entry(
  348. ta_peer->vdev->osif_vdev,
  349. wds_src_mac,
  350. ta_peer->mac_addr.raw,
  351. flags);
  352. }
  353. }
  354. return;
  355. }
  356. #else
  357. static inline void
  358. dp_rx_wds_srcport_learn(struct dp_soc *soc,
  359. uint8_t *rx_tlv_hdr,
  360. struct dp_peer *ta_peer,
  361. qdf_nbuf_t nbuf)
  362. {
  363. }
  364. #endif
  365. uint8_t dp_rx_process_invalid_peer(struct dp_soc *soc, qdf_nbuf_t nbuf);
  366. void dp_rx_process_mic_error(struct dp_soc *soc, qdf_nbuf_t nbuf, uint8_t *rx_tlv_hdr);
  367. #define DP_RX_LIST_APPEND(head, tail, elem) \
  368. do { \
  369. if (!(head)) { \
  370. (head) = (elem); \
  371. } else { \
  372. qdf_nbuf_set_next((tail), (elem)); \
  373. } \
  374. (tail) = (elem); \
  375. qdf_nbuf_set_next((tail), NULL); \
  376. } while (0)
  377. #ifndef BUILD_X86
  378. static inline int check_x86_paddr(struct dp_soc *dp_soc, qdf_nbuf_t *rx_netbuf,
  379. qdf_dma_addr_t *paddr, struct dp_pdev *pdev)
  380. {
  381. return QDF_STATUS_SUCCESS;
  382. }
  383. #else
  384. #define MAX_RETRY 100
  385. static inline int check_x86_paddr(struct dp_soc *dp_soc, qdf_nbuf_t *rx_netbuf,
  386. qdf_dma_addr_t *paddr, struct dp_pdev *pdev)
  387. {
  388. uint32_t nbuf_retry = 0;
  389. int32_t ret;
  390. const uint32_t x86_phy_addr = 0x50000000;
  391. /*
  392. * in M2M emulation platforms (x86) the memory below 0x50000000
  393. * is reserved for target use, so any memory allocated in this
  394. * region should not be used by host
  395. */
  396. do {
  397. if (qdf_likely(*paddr > x86_phy_addr))
  398. return QDF_STATUS_SUCCESS;
  399. else {
  400. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_INFO,
  401. "phy addr %pK exceded 0x50000000 trying again\n",
  402. paddr);
  403. nbuf_retry++;
  404. if ((*rx_netbuf)) {
  405. qdf_nbuf_unmap_single(dp_soc->osdev, *rx_netbuf,
  406. QDF_DMA_BIDIRECTIONAL);
  407. /* Not freeing buffer intentionally.
  408. * Observed that same buffer is getting
  409. * re-allocated resulting in longer load time
  410. * WMI init timeout.
  411. * This buffer is anyway not useful so skip it.
  412. **/
  413. }
  414. *rx_netbuf = qdf_nbuf_alloc(dp_soc->osdev,
  415. RX_BUFFER_SIZE,
  416. RX_BUFFER_RESERVATION,
  417. RX_BUFFER_ALIGNMENT,
  418. FALSE);
  419. if (qdf_unlikely(!(*rx_netbuf)))
  420. return QDF_STATUS_E_FAILURE;
  421. ret = qdf_nbuf_map_single(dp_soc->osdev, *rx_netbuf,
  422. QDF_DMA_BIDIRECTIONAL);
  423. if (qdf_unlikely(ret == QDF_STATUS_E_FAILURE)) {
  424. qdf_nbuf_free(*rx_netbuf);
  425. *rx_netbuf = NULL;
  426. continue;
  427. }
  428. *paddr = qdf_nbuf_get_frag_paddr(*rx_netbuf, 0);
  429. }
  430. } while (nbuf_retry < MAX_RETRY);
  431. if ((*rx_netbuf)) {
  432. qdf_nbuf_unmap_single(dp_soc->osdev, *rx_netbuf,
  433. QDF_DMA_BIDIRECTIONAL);
  434. qdf_nbuf_free(*rx_netbuf);
  435. }
  436. return QDF_STATUS_E_FAILURE;
  437. }
  438. #endif
  439. /**
  440. * dp_rx_cookie_2_link_desc_va() - Converts cookie to a virtual address of
  441. * the MSDU Link Descriptor
  442. * @soc: core txrx main context
  443. * @buf_info: buf_info include cookie that used to lookup virtual address of
  444. * link descriptor Normally this is just an index into a per SOC array.
  445. *
  446. * This is the VA of the link descriptor, that HAL layer later uses to
  447. * retrieve the list of MSDU's for a given MPDU.
  448. *
  449. * Return: void *: Virtual Address of the Rx descriptor
  450. */
  451. static inline
  452. void *dp_rx_cookie_2_link_desc_va(struct dp_soc *soc,
  453. struct hal_buf_info *buf_info)
  454. {
  455. void *link_desc_va;
  456. uint32_t bank_id = LINK_DESC_COOKIE_BANK_ID(buf_info->sw_cookie);
  457. /* TODO */
  458. /* Add sanity for cookie */
  459. link_desc_va = soc->link_desc_banks[bank_id].base_vaddr +
  460. (buf_info->paddr -
  461. soc->link_desc_banks[bank_id].base_paddr);
  462. return link_desc_va;
  463. }
  464. /**
  465. * dp_rx_cookie_2_mon_link_desc_va() - Converts cookie to a virtual address of
  466. * the MSDU Link Descriptor
  467. * @pdev: core txrx pdev context
  468. * @buf_info: buf_info includes cookie that used to lookup virtual address of
  469. * link descriptor. Normally this is just an index into a per pdev array.
  470. *
  471. * This is the VA of the link descriptor in monitor mode destination ring,
  472. * that HAL layer later uses to retrieve the list of MSDU's for a given MPDU.
  473. *
  474. * Return: void *: Virtual Address of the Rx descriptor
  475. */
  476. static inline
  477. void *dp_rx_cookie_2_mon_link_desc_va(struct dp_pdev *pdev,
  478. struct hal_buf_info *buf_info)
  479. {
  480. void *link_desc_va;
  481. /* TODO */
  482. /* Add sanity for cookie */
  483. link_desc_va = pdev->link_desc_banks[buf_info->sw_cookie].base_vaddr +
  484. (buf_info->paddr -
  485. pdev->link_desc_banks[buf_info->sw_cookie].base_paddr);
  486. return link_desc_va;
  487. }
  488. /**
  489. * dp_rx_defrag_concat() - Concatenate the fragments
  490. *
  491. * @dst: destination pointer to the buffer
  492. * @src: source pointer from where the fragment payload is to be copied
  493. *
  494. * Return: QDF_STATUS
  495. */
  496. static inline QDF_STATUS dp_rx_defrag_concat(qdf_nbuf_t dst, qdf_nbuf_t src)
  497. {
  498. /*
  499. * Inside qdf_nbuf_cat, if it is necessary to reallocate dst
  500. * to provide space for src, the headroom portion is copied from
  501. * the original dst buffer to the larger new dst buffer.
  502. * (This is needed, because the headroom of the dst buffer
  503. * contains the rx desc.)
  504. */
  505. if (qdf_nbuf_cat(dst, src))
  506. return QDF_STATUS_E_DEFRAG_ERROR;
  507. return QDF_STATUS_SUCCESS;
  508. }
  509. /*
  510. * dp_rx_ast_set_active() - set the active flag of the astentry
  511. * corresponding to a hw index.
  512. * @soc: core txrx main context
  513. * @sa_idx: hw idx
  514. * @is_active: active flag
  515. *
  516. */
  517. #ifdef FEATURE_WDS
  518. static inline QDF_STATUS dp_rx_ast_set_active(struct dp_soc *soc, uint16_t sa_idx, bool is_active)
  519. {
  520. struct dp_ast_entry *ast;
  521. qdf_spin_lock_bh(&soc->ast_lock);
  522. ast = soc->ast_table[sa_idx];
  523. /*
  524. * Ensure we are updating the right AST entry by
  525. * validating ast_idx.
  526. * There is a possibility we might arrive here without
  527. * AST MAP event , so this check is mandatory
  528. */
  529. if (ast && (ast->ast_idx == sa_idx)) {
  530. ast->is_active = is_active;
  531. qdf_spin_unlock_bh(&soc->ast_lock);
  532. return QDF_STATUS_SUCCESS;
  533. }
  534. qdf_spin_unlock_bh(&soc->ast_lock);
  535. return QDF_STATUS_E_FAILURE;
  536. }
  537. #else
  538. static inline QDF_STATUS dp_rx_ast_set_active(struct dp_soc *soc, uint16_t sa_idx, bool is_active)
  539. {
  540. return QDF_STATUS_SUCCESS;
  541. }
  542. #endif
  543. /*
  544. * check_qwrap_multicast_loopback() - Check if rx packet is a loopback packet.
  545. * In qwrap mode, packets originated from
  546. * any vdev should not loopback and
  547. * should be dropped.
  548. * @vdev: vdev on which rx packet is received
  549. * @nbuf: rx pkt
  550. *
  551. */
  552. #if ATH_SUPPORT_WRAP
  553. static inline bool check_qwrap_multicast_loopback(struct dp_vdev *vdev,
  554. qdf_nbuf_t nbuf)
  555. {
  556. struct dp_vdev *psta_vdev;
  557. struct dp_pdev *pdev = vdev->pdev;
  558. uint8_t *data = qdf_nbuf_data(nbuf);
  559. if (qdf_unlikely(vdev->proxysta_vdev)) {
  560. /* In qwrap isolation mode, allow loopback packets as all
  561. * packets go to RootAP and Loopback on the mpsta.
  562. */
  563. if (vdev->isolation_vdev)
  564. return false;
  565. TAILQ_FOREACH(psta_vdev, &pdev->vdev_list, vdev_list_elem) {
  566. if (qdf_unlikely(psta_vdev->proxysta_vdev &&
  567. !qdf_mem_cmp(psta_vdev->mac_addr.raw,
  568. &data[DP_MAC_ADDR_LEN], DP_MAC_ADDR_LEN))) {
  569. /* Drop packet if source address is equal to
  570. * any of the vdev addresses.
  571. */
  572. return true;
  573. }
  574. }
  575. }
  576. return false;
  577. }
  578. #else
  579. static inline bool check_qwrap_multicast_loopback(struct dp_vdev *vdev,
  580. qdf_nbuf_t nbuf)
  581. {
  582. return false;
  583. }
  584. #endif
  585. /*
  586. * dp_rx_buffers_replenish() - replenish rxdma ring with rx nbufs
  587. * called during dp rx initialization
  588. * and at the end of dp_rx_process.
  589. *
  590. * @soc: core txrx main context
  591. * @mac_id: mac_id which is one of 3 mac_ids
  592. * @dp_rxdma_srng: dp rxdma circular ring
  593. * @rx_desc_pool: Poiter to free Rx descriptor pool
  594. * @num_req_buffers: number of buffer to be replenished
  595. * @desc_list: list of descs if called from dp_rx_process
  596. * or NULL during dp rx initialization or out of buffer
  597. * interrupt.
  598. * @tail: tail of descs list
  599. * @owner: who owns the nbuf (host, NSS etc...)
  600. * Return: return success or failure
  601. */
  602. QDF_STATUS dp_rx_buffers_replenish(struct dp_soc *dp_soc, uint32_t mac_id,
  603. struct dp_srng *dp_rxdma_srng,
  604. struct rx_desc_pool *rx_desc_pool,
  605. uint32_t num_req_buffers,
  606. union dp_rx_desc_list_elem_t **desc_list,
  607. union dp_rx_desc_list_elem_t **tail,
  608. uint8_t owner);
  609. /**
  610. * dp_rx_link_desc_return() - Return a MPDU link descriptor to HW
  611. * (WBM), following error handling
  612. *
  613. * @soc: core DP main context
  614. * @buf_addr_info: opaque pointer to the REO error ring descriptor
  615. * @buf_addr_info: void pointer to the buffer_addr_info
  616. * @bm_action: put to idle_list or release to msdu_list
  617. * Return: QDF_STATUS
  618. */
  619. QDF_STATUS
  620. dp_rx_link_desc_return(struct dp_soc *soc, void *ring_desc, uint8_t bm_action);
  621. QDF_STATUS
  622. dp_rx_link_desc_buf_return(struct dp_soc *soc, struct dp_srng *dp_rxdma_srng,
  623. void *buf_addr_info, uint8_t bm_action);
  624. uint32_t
  625. dp_rxdma_err_process(struct dp_soc *soc, uint32_t mac_id,
  626. uint32_t quota);
  627. void dp_rx_fill_mesh_stats(struct dp_vdev *vdev, qdf_nbuf_t nbuf,
  628. uint8_t *rx_tlv_hdr, struct dp_peer *peer);
  629. QDF_STATUS dp_rx_filter_mesh_packets(struct dp_vdev *vdev, qdf_nbuf_t nbuf,
  630. uint8_t *rx_tlv_hdr);
  631. int dp_wds_rx_policy_check(uint8_t *rx_tlv_hdr, struct dp_vdev *vdev,
  632. struct dp_peer *peer, int rx_mcast);
  633. #endif /* _DP_RX_H */