dp_rx_mon_dest.c 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165
  1. /*
  2. * Copyright (c) 2017-2020 The Linux Foundation. All rights reserved.
  3. *
  4. * Permission to use, copy, modify, and/or distribute this software for
  5. * any purpose with or without fee is hereby granted, provided that the
  6. * above copyright notice and this permission notice appear in all
  7. * copies.
  8. *
  9. * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL
  10. * WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED
  11. * WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE
  12. * AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL
  13. * DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR
  14. * PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER
  15. * TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  16. * PERFORMANCE OF THIS SOFTWARE.
  17. */
  18. #include "hal_hw_headers.h"
  19. #include "dp_types.h"
  20. #include "dp_rx.h"
  21. #include "dp_peer.h"
  22. #include "hal_rx.h"
  23. #include "hal_api.h"
  24. #include "qdf_trace.h"
  25. #include "qdf_nbuf.h"
  26. #include "hal_api_mon.h"
  27. #include "dp_rx_mon.h"
  28. #include "wlan_cfg.h"
  29. #include "dp_internal.h"
  30. #include "dp_rx_buffer_pool.h"
  31. #ifdef WLAN_TX_PKT_CAPTURE_ENH
  32. #include "dp_rx_mon_feature.h"
  33. static inline void
  34. dp_handle_tx_capture(struct dp_soc *soc, struct dp_pdev *pdev,
  35. qdf_nbuf_t mon_mpdu)
  36. {
  37. struct hal_rx_ppdu_info *ppdu_info = &pdev->ppdu_info;
  38. if (pdev->tx_capture_enabled
  39. == CDP_TX_ENH_CAPTURE_DISABLED)
  40. return;
  41. if ((ppdu_info->sw_frame_group_id ==
  42. HAL_MPDU_SW_FRAME_GROUP_CTRL_NDPA) ||
  43. (ppdu_info->sw_frame_group_id ==
  44. HAL_MPDU_SW_FRAME_GROUP_CTRL_BAR))
  45. dp_handle_tx_capture_from_dest(soc, pdev, mon_mpdu);
  46. }
  47. static void
  48. dp_tx_capture_get_user_id(struct dp_pdev *dp_pdev, void *rx_desc_tlv)
  49. {
  50. if (dp_pdev->tx_capture_enabled
  51. != CDP_TX_ENH_CAPTURE_DISABLED)
  52. dp_pdev->ppdu_info.rx_info.user_id =
  53. HAL_RX_HW_DESC_MPDU_USER_ID(rx_desc_tlv);
  54. }
  55. #else
  56. static inline void
  57. dp_handle_tx_capture(struct dp_soc *soc, struct dp_pdev *pdev,
  58. qdf_nbuf_t mon_mpdu)
  59. {
  60. }
  61. static void
  62. dp_tx_capture_get_user_id(struct dp_pdev *dp_pdev, void *rx_desc_tlv)
  63. {
  64. }
  65. #endif
  66. /*
  67. * PPDU id is from 0 to 64k-1. PPDU id read from status ring and PPDU id
  68. * read from destination ring shall track each other. If the distance of
  69. * two ppdu id is less than 20000. It is assume no wrap around. Otherwise,
  70. * It is assume wrap around.
  71. */
  72. #define NOT_PPDU_ID_WRAP_AROUND 20000
  73. /*
  74. * The destination ring processing is stuck if the destrination is not
  75. * moving while status ring moves 16 ppdu. the destination ring processing
  76. * skips this destination ring ppdu as walkaround
  77. */
  78. #define MON_DEST_RING_STUCK_MAX_CNT 16
  79. /**
  80. * dp_rx_mon_link_desc_return() - Return a MPDU link descriptor to HW
  81. * (WBM), following error handling
  82. *
  83. * @dp_pdev: core txrx pdev context
  84. * @buf_addr_info: void pointer to monitor link descriptor buf addr info
  85. * Return: QDF_STATUS
  86. */
  87. QDF_STATUS
  88. dp_rx_mon_link_desc_return(struct dp_pdev *dp_pdev,
  89. hal_buff_addrinfo_t buf_addr_info, int mac_id)
  90. {
  91. struct dp_srng *dp_srng;
  92. hal_ring_handle_t hal_ring_hdl;
  93. hal_soc_handle_t hal_soc;
  94. QDF_STATUS status = QDF_STATUS_E_FAILURE;
  95. void *src_srng_desc;
  96. hal_soc = dp_pdev->soc->hal_soc;
  97. dp_srng = &dp_pdev->soc->rxdma_mon_desc_ring[mac_id];
  98. hal_ring_hdl = dp_srng->hal_srng;
  99. qdf_assert(hal_ring_hdl);
  100. if (qdf_unlikely(hal_srng_access_start(hal_soc, hal_ring_hdl))) {
  101. /* TODO */
  102. /*
  103. * Need API to convert from hal_ring pointer to
  104. * Ring Type / Ring Id combo
  105. */
  106. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  107. "%s %d : \
  108. HAL RING Access For WBM Release SRNG Failed -- %pK",
  109. __func__, __LINE__, hal_ring_hdl);
  110. goto done;
  111. }
  112. src_srng_desc = hal_srng_src_get_next(hal_soc, hal_ring_hdl);
  113. if (qdf_likely(src_srng_desc)) {
  114. /* Return link descriptor through WBM ring (SW2WBM)*/
  115. hal_rx_mon_msdu_link_desc_set(hal_soc,
  116. src_srng_desc, buf_addr_info);
  117. status = QDF_STATUS_SUCCESS;
  118. } else {
  119. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  120. "%s %d -- Monitor Link Desc WBM Release Ring Full",
  121. __func__, __LINE__);
  122. }
  123. done:
  124. hal_srng_access_end(hal_soc, hal_ring_hdl);
  125. return status;
  126. }
  127. /**
  128. * dp_rx_mon_mpdu_pop() - Return a MPDU link descriptor to HW
  129. * (WBM), following error handling
  130. *
  131. * @soc: core DP main context
  132. * @mac_id: mac id which is one of 3 mac_ids
  133. * @rxdma_dst_ring_desc: void pointer to monitor link descriptor buf addr info
  134. * @head_msdu: head of msdu to be popped
  135. * @tail_msdu: tail of msdu to be popped
  136. * @npackets: number of packet to be popped
  137. * @ppdu_id: ppdu id of processing ppdu
  138. * @head: head of descs list to be freed
  139. * @tail: tail of decs list to be freed
  140. *
  141. * Return: number of msdu in MPDU to be popped
  142. */
  143. static inline uint32_t
  144. dp_rx_mon_mpdu_pop(struct dp_soc *soc, uint32_t mac_id,
  145. hal_rxdma_desc_t rxdma_dst_ring_desc, qdf_nbuf_t *head_msdu,
  146. qdf_nbuf_t *tail_msdu, uint32_t *npackets, uint32_t *ppdu_id,
  147. union dp_rx_desc_list_elem_t **head,
  148. union dp_rx_desc_list_elem_t **tail)
  149. {
  150. struct dp_pdev *dp_pdev = dp_get_pdev_for_lmac_id(soc, mac_id);
  151. void *rx_desc_tlv;
  152. void *rx_msdu_link_desc;
  153. qdf_nbuf_t msdu;
  154. qdf_nbuf_t last;
  155. struct hal_rx_msdu_list msdu_list;
  156. uint16_t num_msdus;
  157. uint32_t rx_buf_size, rx_pkt_offset;
  158. struct hal_buf_info buf_info;
  159. uint32_t rx_bufs_used = 0;
  160. uint32_t msdu_ppdu_id, msdu_cnt;
  161. uint8_t *data = NULL;
  162. uint32_t i;
  163. uint32_t total_frag_len = 0, frag_len = 0;
  164. bool is_frag, is_first_msdu;
  165. bool drop_mpdu = false, is_frag_non_raw = false;
  166. uint8_t bm_action = HAL_BM_ACTION_PUT_IN_IDLE_LIST;
  167. qdf_dma_addr_t buf_paddr = 0;
  168. uint32_t rx_link_buf_info[HAL_RX_BUFFINFO_NUM_DWORDS];
  169. struct cdp_mon_status *rs;
  170. if (qdf_unlikely(!dp_pdev)) {
  171. dp_rx_mon_dest_debug("%pK: pdev is null for mac_id = %d", soc, mac_id);
  172. return rx_bufs_used;
  173. }
  174. msdu = 0;
  175. last = NULL;
  176. hal_rx_reo_ent_buf_paddr_get(rxdma_dst_ring_desc, &buf_info, &msdu_cnt);
  177. rs = &dp_pdev->rx_mon_recv_status;
  178. rs->cdp_rs_rxdma_err = false;
  179. if ((hal_rx_reo_ent_rxdma_push_reason_get(rxdma_dst_ring_desc) ==
  180. HAL_RX_WBM_RXDMA_PSH_RSN_ERROR)) {
  181. uint8_t rxdma_err =
  182. hal_rx_reo_ent_rxdma_error_code_get(
  183. rxdma_dst_ring_desc);
  184. if (qdf_unlikely((rxdma_err == HAL_RXDMA_ERR_FLUSH_REQUEST) ||
  185. (rxdma_err == HAL_RXDMA_ERR_MPDU_LENGTH) ||
  186. (rxdma_err == HAL_RXDMA_ERR_OVERFLOW) ||
  187. (rxdma_err == HAL_RXDMA_ERR_FCS && dp_pdev->mcopy_mode))) {
  188. drop_mpdu = true;
  189. dp_pdev->rx_mon_stats.dest_mpdu_drop++;
  190. }
  191. rs->cdp_rs_rxdma_err = true;
  192. }
  193. is_frag = false;
  194. is_first_msdu = true;
  195. do {
  196. /* WAR for duplicate link descriptors received from HW */
  197. if (qdf_unlikely(dp_pdev->mon_last_linkdesc_paddr ==
  198. buf_info.paddr)) {
  199. dp_pdev->rx_mon_stats.dup_mon_linkdesc_cnt++;
  200. return rx_bufs_used;
  201. }
  202. rx_msdu_link_desc =
  203. dp_rx_cookie_2_mon_link_desc(dp_pdev,
  204. buf_info, mac_id);
  205. qdf_assert_always(rx_msdu_link_desc);
  206. hal_rx_msdu_list_get(soc->hal_soc, rx_msdu_link_desc,
  207. &msdu_list, &num_msdus);
  208. for (i = 0; i < num_msdus; i++) {
  209. uint16_t l2_hdr_offset;
  210. struct dp_rx_desc *rx_desc = NULL;
  211. struct rx_desc_pool *rx_desc_pool;
  212. rx_desc = dp_rx_get_mon_desc(soc,
  213. msdu_list.sw_cookie[i]);
  214. qdf_assert_always(rx_desc);
  215. msdu = DP_RX_MON_GET_NBUF_FROM_DESC(rx_desc);
  216. buf_paddr = dp_rx_mon_get_paddr_from_desc(rx_desc);
  217. /* WAR for duplicate buffers received from HW */
  218. if (qdf_unlikely(dp_pdev->mon_last_buf_cookie ==
  219. msdu_list.sw_cookie[i] ||
  220. DP_RX_MON_IS_BUFFER_ADDR_NULL(rx_desc) ||
  221. msdu_list.paddr[i] != buf_paddr ||
  222. !rx_desc->in_use)) {
  223. /* Skip duplicate buffer and drop subsequent
  224. * buffers in this MPDU
  225. */
  226. drop_mpdu = true;
  227. dp_pdev->rx_mon_stats.dup_mon_buf_cnt++;
  228. dp_pdev->mon_last_linkdesc_paddr =
  229. buf_info.paddr;
  230. continue;
  231. }
  232. if (rx_desc->unmapped == 0) {
  233. rx_desc_pool = dp_rx_get_mon_desc_pool(soc,
  234. mac_id,
  235. dp_pdev->pdev_id);
  236. dp_rx_mon_buffer_unmap(soc, rx_desc,
  237. rx_desc_pool->buf_size);
  238. rx_desc->unmapped = 1;
  239. }
  240. if (dp_rx_buffer_pool_refill(soc, msdu,
  241. rx_desc->pool_id)) {
  242. drop_mpdu = true;
  243. msdu = NULL;
  244. dp_pdev->mon_last_linkdesc_paddr =
  245. buf_info.paddr;
  246. goto next_msdu;
  247. }
  248. if (drop_mpdu) {
  249. dp_pdev->mon_last_linkdesc_paddr =
  250. buf_info.paddr;
  251. dp_rx_mon_buffer_free(rx_desc);
  252. msdu = NULL;
  253. goto next_msdu;
  254. }
  255. data = dp_rx_mon_get_buffer_data(rx_desc);
  256. rx_desc_tlv = HAL_RX_MON_DEST_GET_DESC(data);
  257. dp_rx_mon_dest_debug("%pK: i=%d, ppdu_id=%x, num_msdus = %u",
  258. soc, i, *ppdu_id, num_msdus);
  259. if (is_first_msdu) {
  260. if (!hal_rx_mpdu_start_tlv_tag_valid(
  261. soc->hal_soc,
  262. rx_desc_tlv)) {
  263. drop_mpdu = true;
  264. dp_rx_mon_buffer_free(rx_desc);
  265. msdu = NULL;
  266. dp_pdev->mon_last_linkdesc_paddr =
  267. buf_info.paddr;
  268. goto next_msdu;
  269. }
  270. msdu_ppdu_id = hal_rx_hw_desc_get_ppduid_get(
  271. soc->hal_soc,
  272. rx_desc_tlv,
  273. rxdma_dst_ring_desc);
  274. is_first_msdu = false;
  275. dp_rx_mon_dest_debug("%pK: msdu_ppdu_id=%x",
  276. soc, msdu_ppdu_id);
  277. if (*ppdu_id > msdu_ppdu_id)
  278. dp_rx_mon_dest_debug("%pK: ppdu_id=%d "
  279. "msdu_ppdu_id=%d", soc,
  280. *ppdu_id, msdu_ppdu_id);
  281. if ((*ppdu_id < msdu_ppdu_id) && (
  282. (msdu_ppdu_id - *ppdu_id) <
  283. NOT_PPDU_ID_WRAP_AROUND)) {
  284. *ppdu_id = msdu_ppdu_id;
  285. return rx_bufs_used;
  286. } else if ((*ppdu_id > msdu_ppdu_id) && (
  287. (*ppdu_id - msdu_ppdu_id) >
  288. NOT_PPDU_ID_WRAP_AROUND)) {
  289. *ppdu_id = msdu_ppdu_id;
  290. return rx_bufs_used;
  291. }
  292. dp_tx_capture_get_user_id(dp_pdev,
  293. rx_desc_tlv);
  294. if (*ppdu_id == msdu_ppdu_id)
  295. dp_pdev->rx_mon_stats.ppdu_id_match++;
  296. else
  297. dp_pdev->rx_mon_stats.ppdu_id_mismatch
  298. ++;
  299. dp_pdev->mon_last_linkdesc_paddr =
  300. buf_info.paddr;
  301. if (dp_rx_mon_alloc_parent_buffer(head_msdu)
  302. != QDF_STATUS_SUCCESS) {
  303. DP_STATS_INC(dp_pdev,
  304. replenish.nbuf_alloc_fail,
  305. 1);
  306. qdf_frag_free(rx_desc_tlv);
  307. QDF_TRACE(QDF_MODULE_ID_DP,
  308. QDF_TRACE_LEVEL_DEBUG,
  309. "[%s] failed to allocate parent buffer to hold all frag",
  310. __func__);
  311. drop_mpdu = true;
  312. goto next_msdu;
  313. }
  314. }
  315. if (hal_rx_desc_is_first_msdu(soc->hal_soc,
  316. rx_desc_tlv))
  317. hal_rx_mon_hw_desc_get_mpdu_status(soc->hal_soc,
  318. rx_desc_tlv,
  319. &(dp_pdev->ppdu_info.rx_status));
  320. dp_rx_mon_parse_desc_buffer(soc,
  321. &(msdu_list.msdu_info[i]),
  322. &is_frag,
  323. &total_frag_len,
  324. &frag_len,
  325. &l2_hdr_offset,
  326. rx_desc_tlv,
  327. &is_frag_non_raw, data);
  328. if (!is_frag)
  329. msdu_cnt--;
  330. QDF_TRACE(QDF_MODULE_ID_DP, QDF_TRACE_LEVEL_DEBUG,
  331. "%s total_len %u frag_len %u flags %u",
  332. __func__, total_frag_len, frag_len,
  333. msdu_list.msdu_info[i].msdu_flags);
  334. rx_pkt_offset = SIZE_OF_MONITOR_TLV;
  335. rx_buf_size = rx_pkt_offset + l2_hdr_offset
  336. + frag_len;
  337. dp_rx_mon_buffer_set_pktlen(msdu, rx_buf_size);
  338. #if 0
  339. /* Disble it.see packet on msdu done set to 0 */
  340. /*
  341. * Check if DMA completed -- msdu_done is the
  342. * last bit to be written
  343. */
  344. if (!hal_rx_attn_msdu_done_get(rx_desc_tlv)) {
  345. QDF_TRACE(QDF_MODULE_ID_DP,
  346. QDF_TRACE_LEVEL_ERROR,
  347. "%s:%d: Pkt Desc",
  348. __func__, __LINE__);
  349. QDF_TRACE_HEX_DUMP(QDF_MODULE_ID_DP,
  350. QDF_TRACE_LEVEL_ERROR,
  351. rx_desc_tlv, 128);
  352. qdf_assert_always(0);
  353. }
  354. #endif
  355. dp_rx_mon_dest_debug("%pK: rx_pkt_offset=%d, l2_hdr_offset=%d, msdu_len=%d, frag_len %u",
  356. soc, rx_pkt_offset, l2_hdr_offset,
  357. msdu_list.msdu_info[i].msdu_len,
  358. frag_len);
  359. if (dp_rx_mon_add_msdu_to_list(head_msdu, msdu, &last,
  360. rx_desc_tlv, frag_len,
  361. l2_hdr_offset)
  362. != QDF_STATUS_SUCCESS) {
  363. dp_rx_mon_add_msdu_to_list_failure_handler(rx_desc_tlv,
  364. dp_pdev, &last, head_msdu,
  365. tail_msdu, __func__);
  366. drop_mpdu = true;
  367. goto next_msdu;
  368. }
  369. next_msdu:
  370. dp_pdev->mon_last_buf_cookie = msdu_list.sw_cookie[i];
  371. rx_bufs_used++;
  372. dp_rx_add_to_free_desc_list(head,
  373. tail, rx_desc);
  374. }
  375. /*
  376. * Store the current link buffer into to the local
  377. * structure to be used for release purpose.
  378. */
  379. hal_rxdma_buff_addr_info_set(rx_link_buf_info, buf_info.paddr,
  380. buf_info.sw_cookie, buf_info.rbm);
  381. hal_rx_mon_next_link_desc_get(rx_msdu_link_desc, &buf_info);
  382. if (dp_rx_monitor_link_desc_return(dp_pdev,
  383. (hal_buff_addrinfo_t)
  384. rx_link_buf_info,
  385. mac_id,
  386. bm_action)
  387. != QDF_STATUS_SUCCESS)
  388. dp_err_rl("monitor link desc return failed");
  389. } while (buf_info.paddr && msdu_cnt);
  390. dp_rx_mon_init_tail_msdu(head_msdu, msdu, last, tail_msdu);
  391. dp_rx_mon_remove_raw_frame_fcs_len(head_msdu, tail_msdu);
  392. return rx_bufs_used;
  393. }
  394. static inline
  395. void dp_rx_msdus_set_payload(struct dp_soc *soc, qdf_nbuf_t msdu)
  396. {
  397. uint8_t *data;
  398. uint32_t rx_pkt_offset, l2_hdr_offset;
  399. data = qdf_nbuf_data(msdu);
  400. rx_pkt_offset = SIZE_OF_MONITOR_TLV;
  401. l2_hdr_offset = hal_rx_msdu_end_l3_hdr_padding_get(soc->hal_soc, data);
  402. qdf_nbuf_pull_head(msdu, rx_pkt_offset + l2_hdr_offset);
  403. }
  404. #ifdef DP_RX_MON_MEM_FRAG
  405. /**
  406. * dp_rx_mon_fraglist_prepare() - Prepare nbuf fraglist from chained skb
  407. *
  408. * @head_msdu: Parent SKB
  409. * @tail_msdu: Last skb in the chained list
  410. *
  411. * Return: Void
  412. */
  413. void dp_rx_mon_fraglist_prepare(qdf_nbuf_t head_msdu, qdf_nbuf_t tail_msdu)
  414. {
  415. qdf_nbuf_t msdu, mpdu_buf, prev_buf, head_frag_list;
  416. uint32_t frag_list_sum_len;
  417. dp_err("[%s][%d] decap format raw head %pK head->next %pK last_msdu %pK last_msdu->next %pK",
  418. __func__, __LINE__, head_msdu, head_msdu->next,
  419. tail_msdu, tail_msdu->next);
  420. /* Single skb accommodating MPDU worth Data */
  421. if (tail_msdu == head_msdu)
  422. return;
  423. mpdu_buf = head_msdu;
  424. prev_buf = mpdu_buf;
  425. frag_list_sum_len = 0;
  426. msdu = qdf_nbuf_next(head_msdu);
  427. /* msdu can't be NULL here as it is multiple skb case here */
  428. /* Head frag list to point to second skb */
  429. head_frag_list = msdu;
  430. while (msdu) {
  431. frag_list_sum_len += qdf_nbuf_len(msdu);
  432. prev_buf = msdu;
  433. msdu = qdf_nbuf_next(msdu);
  434. }
  435. qdf_nbuf_append_ext_list(mpdu_buf, head_frag_list, frag_list_sum_len);
  436. /* Make Parent skb next to NULL */
  437. qdf_nbuf_set_next(mpdu_buf, NULL);
  438. }
  439. /**
  440. * dp_rx_mon_frag_restitch_mpdu_from_msdus() - Restitch logic to
  441. * convert to 802.3 header and adjust frag memory pointing to
  442. * dot3 header and payload in case of Non-Raw frame.
  443. *
  444. * @soc: struct dp_soc *
  445. * @mac_id: MAC id
  446. * @head_msdu: MPDU containing all MSDU as a frag
  447. * @tail_msdu: last skb which accommodate MPDU info
  448. * @rx_status: struct cdp_mon_status *
  449. *
  450. * Return: Adjusted nbuf containing MPDU worth info.
  451. */
  452. static inline
  453. qdf_nbuf_t dp_rx_mon_frag_restitch_mpdu_from_msdus(struct dp_soc *soc,
  454. uint32_t mac_id,
  455. qdf_nbuf_t head_msdu,
  456. qdf_nbuf_t tail_msdu,
  457. struct cdp_mon_status *rx_status)
  458. {
  459. uint32_t wifi_hdr_len, sec_hdr_len, msdu_llc_len,
  460. mpdu_buf_len, decap_hdr_pull_bytes, dir,
  461. is_amsdu, amsdu_pad, frag_size, tot_msdu_len;
  462. qdf_frag_t rx_desc, rx_src_desc, rx_dest_desc, frag_addr;
  463. char *hdr_desc;
  464. uint8_t num_frags, frags_iter, l2_hdr_offset;
  465. struct ieee80211_frame *wh;
  466. struct ieee80211_qoscntl *qos;
  467. struct dp_pdev *dp_pdev = dp_get_pdev_for_lmac_id(soc, mac_id);
  468. int16_t frag_page_offset = 0;
  469. struct hal_rx_mon_dest_buf_info buf_info;
  470. uint32_t pad_byte_pholder = 0;
  471. qdf_nbuf_t msdu_curr;
  472. if (qdf_unlikely(!dp_pdev)) {
  473. dp_rx_mon_dest_debug("%pK: pdev is null for mac_id = %d", soc, mac_id);
  474. return NULL;
  475. }
  476. qdf_mem_zero(&buf_info, sizeof(struct hal_rx_mon_dest_buf_info));
  477. if (!head_msdu || !tail_msdu)
  478. goto mpdu_stitch_fail;
  479. rx_desc = qdf_nbuf_get_frag_addr(head_msdu, 0) - SIZE_OF_MONITOR_TLV;
  480. if (HAL_RX_DESC_GET_MPDU_LENGTH_ERR(rx_desc)) {
  481. /* It looks like there is some issue on MPDU len err */
  482. /* Need further investigate if drop the packet */
  483. DP_STATS_INC(dp_pdev, dropped.mon_rx_drop, 1);
  484. return NULL;
  485. }
  486. /* Look for FCS error */
  487. num_frags = qdf_nbuf_get_nr_frags(tail_msdu);
  488. rx_desc =
  489. qdf_nbuf_get_frag_addr(tail_msdu,
  490. num_frags - 1) - SIZE_OF_MONITOR_TLV;
  491. rx_status->cdp_rs_fcs_err = HAL_RX_DESC_GET_MPDU_FCS_ERR(rx_desc);
  492. dp_pdev->ppdu_info.rx_status.rs_fcs_err =
  493. HAL_RX_DESC_GET_MPDU_FCS_ERR(rx_desc);
  494. rx_desc = qdf_nbuf_get_frag_addr(head_msdu, 0) - SIZE_OF_MONITOR_TLV;
  495. hal_rx_mon_dest_get_buffer_info_from_tlv(rx_desc, &buf_info);
  496. /* Easy case - The MSDU status indicates that this is a non-decapped
  497. * packet in RAW mode.
  498. */
  499. if (buf_info.is_decap_raw == 1) {
  500. dp_rx_mon_fraglist_prepare(head_msdu, tail_msdu);
  501. goto mpdu_stitch_done;
  502. }
  503. l2_hdr_offset = DP_RX_MON_NONRAW_L2_HDR_PAD_BYTE;
  504. /* Decap mode:
  505. * Calculate the amount of header in decapped packet to knock off based
  506. * on the decap type and the corresponding number of raw bytes to copy
  507. * status header
  508. */
  509. hdr_desc = HAL_RX_DESC_GET_80211_HDR(rx_desc);
  510. dp_rx_mon_dest_debug("%pK: decap format not raw", soc);
  511. /* Base size */
  512. wifi_hdr_len = sizeof(struct ieee80211_frame);
  513. wh = (struct ieee80211_frame *)hdr_desc;
  514. dir = wh->i_fc[1] & IEEE80211_FC1_DIR_MASK;
  515. if (dir == IEEE80211_FC1_DIR_DSTODS)
  516. wifi_hdr_len += 6;
  517. is_amsdu = 0;
  518. if (wh->i_fc[0] & QDF_IEEE80211_FC0_SUBTYPE_QOS) {
  519. qos = (struct ieee80211_qoscntl *)
  520. (hdr_desc + wifi_hdr_len);
  521. wifi_hdr_len += 2;
  522. is_amsdu = (qos->i_qos[0] & IEEE80211_QOS_AMSDU);
  523. }
  524. /*Calculate security header length based on 'Protected'
  525. * and 'EXT_IV' flag
  526. */
  527. if (wh->i_fc[1] & IEEE80211_FC1_WEP) {
  528. char *iv = (char *)wh + wifi_hdr_len;
  529. if (iv[3] & KEY_EXTIV)
  530. sec_hdr_len = 8;
  531. else
  532. sec_hdr_len = 4;
  533. } else {
  534. sec_hdr_len = 0;
  535. }
  536. wifi_hdr_len += sec_hdr_len;
  537. /* MSDU related stuff LLC - AMSDU subframe header etc */
  538. msdu_llc_len = is_amsdu ? (14 + 8) : 8;
  539. mpdu_buf_len = wifi_hdr_len + msdu_llc_len;
  540. /* "Decap" header to remove from MSDU buffer */
  541. decap_hdr_pull_bytes = 14;
  542. amsdu_pad = 0;
  543. tot_msdu_len = 0;
  544. /*
  545. * keeping first MSDU ops outside of loop to avoid multiple
  546. * check handling
  547. */
  548. /* Construct src header */
  549. rx_src_desc = hdr_desc;
  550. /*
  551. * Update protocol and flow tag for MSDU
  552. * update frag index in ctx_idx field.
  553. * Reset head pointer data of nbuf before updating.
  554. */
  555. QDF_NBUF_CB_RX_CTX_ID(head_msdu) = 0;
  556. dp_rx_mon_update_protocol_flow_tag(soc, dp_pdev, head_msdu, rx_desc);
  557. /* Construct destination address */
  558. frag_addr = qdf_nbuf_get_frag_addr(head_msdu, 0);
  559. frag_size = qdf_nbuf_get_frag_size_by_idx(head_msdu, 0);
  560. /* We will come here in 2 scenario:
  561. * 1. First MSDU of MPDU with single buffer
  562. * 2. First buffer of First MSDU of MPDU with continuation
  563. *
  564. * ------------------------------------------------------------
  565. * | SINGLE BUFFER (<= RX_MONITOR_BUFFER_SIZE - RX_PKT_TLVS_LEN)|
  566. * ------------------------------------------------------------
  567. *
  568. * ------------------------------------------------------------
  569. * | First BUFFER with Continuation | ... |
  570. * | (RX_MONITOR_BUFFER_SIZE - RX_PKT_TLVS_LEN) | |
  571. * ------------------------------------------------------------
  572. */
  573. pad_byte_pholder =
  574. (RX_MONITOR_BUFFER_SIZE - RX_PKT_TLVS_LEN) - frag_size;
  575. /* Construct destination address
  576. * --------------------------------------------------------------
  577. * | RX_PKT_TLV | L2_HDR_PAD | Decap HDR | Payload |
  578. * | | / |
  579. * | >Frag address points here / |
  580. * | \ / |
  581. * | \ This bytes needs to / |
  582. * | \ removed to frame pkt / |
  583. * | ----------------------- |
  584. * | | |
  585. * | | |
  586. * | WIFI +LLC HDR will be added here <-| |
  587. * | | | |
  588. * | >Dest addr will point | |
  589. * | somewhere in this area | |
  590. * --------------------------------------------------------------
  591. */
  592. rx_dest_desc =
  593. (frag_addr + decap_hdr_pull_bytes + l2_hdr_offset) -
  594. mpdu_buf_len;
  595. /* Add WIFI and LLC header for 1st MSDU of MPDU */
  596. qdf_mem_copy(rx_dest_desc, rx_src_desc, mpdu_buf_len);
  597. frag_page_offset =
  598. (decap_hdr_pull_bytes + l2_hdr_offset) - mpdu_buf_len;
  599. qdf_nbuf_move_frag_page_offset(head_msdu, 0, frag_page_offset);
  600. frag_size = qdf_nbuf_get_frag_size_by_idx(head_msdu, 0);
  601. if (buf_info.first_buffer && buf_info.last_buffer) {
  602. /* MSDU with single bufffer */
  603. amsdu_pad = frag_size & 0x3;
  604. amsdu_pad = amsdu_pad ? (4 - amsdu_pad) : 0;
  605. if (amsdu_pad && (amsdu_pad <= pad_byte_pholder)) {
  606. char *frag_addr_temp;
  607. qdf_nbuf_trim_add_frag_size(head_msdu, 0, amsdu_pad,
  608. 0);
  609. frag_addr_temp =
  610. (char *)qdf_nbuf_get_frag_addr(head_msdu, 0);
  611. frag_addr_temp = (frag_addr_temp +
  612. qdf_nbuf_get_frag_size_by_idx(head_msdu, 0)) -
  613. amsdu_pad;
  614. qdf_mem_zero(frag_addr_temp, amsdu_pad);
  615. amsdu_pad = 0;
  616. }
  617. } else {
  618. /*
  619. * First buffer of Continuation frame and hence
  620. * amsdu_padding doesn't need to be added
  621. * Increase tot_msdu_len so that amsdu_pad byte
  622. * will be calculated for last frame of MSDU
  623. */
  624. tot_msdu_len = frag_size;
  625. amsdu_pad = 0;
  626. }
  627. /* Here amsdu_pad byte will have some value if 1sf buffer was
  628. * Single buffer MSDU and dint had pholder to adjust amsdu padding
  629. * byte in the end
  630. * So dont initialize to ZERO here
  631. */
  632. pad_byte_pholder = 0;
  633. for (msdu_curr = head_msdu; msdu_curr;) {
  634. /* frag_iter will start from 0 for second skb onwards */
  635. if (msdu_curr == head_msdu)
  636. frags_iter = 1;
  637. else
  638. frags_iter = 0;
  639. num_frags = qdf_nbuf_get_nr_frags(msdu_curr);
  640. for (; frags_iter < num_frags; frags_iter++) {
  641. /* Construct destination address
  642. * ----------------------------------------------------------
  643. * | RX_PKT_TLV | L2_HDR_PAD | Decap HDR | Payload | Pad |
  644. * | | (First buffer) | | |
  645. * | | / / |
  646. * | >Frag address points here / / |
  647. * | \ / / |
  648. * | \ This bytes needs to / / |
  649. * | \ removed to frame pkt/ / |
  650. * | ---------------------- / |
  651. * | | / Add |
  652. * | | / amsdu pad |
  653. * | LLC HDR will be added here <-| | Byte for |
  654. * | | | | last frame |
  655. * | >Dest addr will point | | if space |
  656. * | somewhere in this area | | available |
  657. * | And amsdu_pad will be created if | | |
  658. * | dint get added in last buffer | | |
  659. * | (First Buffer) | | |
  660. * ----------------------------------------------------------
  661. */
  662. frag_addr =
  663. qdf_nbuf_get_frag_addr(msdu_curr, frags_iter);
  664. rx_desc = frag_addr - SIZE_OF_MONITOR_TLV;
  665. /*
  666. * Update protocol and flow tag for MSDU
  667. * update frag index in ctx_idx field
  668. */
  669. QDF_NBUF_CB_RX_CTX_ID(msdu_curr) = frags_iter;
  670. dp_rx_mon_update_protocol_flow_tag(soc, dp_pdev,
  671. msdu_curr, rx_desc);
  672. /* Read buffer info from stored data in tlvs */
  673. hal_rx_mon_dest_get_buffer_info_from_tlv(rx_desc,
  674. &buf_info);
  675. frag_size = qdf_nbuf_get_frag_size_by_idx(msdu_curr,
  676. frags_iter);
  677. /* If Middle buffer, dont add any header */
  678. if ((!buf_info.first_buffer) && (!buf_info.last_buffer)) {
  679. tot_msdu_len += frag_size;
  680. amsdu_pad = 0;
  681. pad_byte_pholder = 0;
  682. continue;
  683. }
  684. /* Calculate if current buffer has placeholder
  685. * to accommodate amsdu pad byte
  686. */
  687. pad_byte_pholder =
  688. (RX_MONITOR_BUFFER_SIZE - RX_PKT_TLVS_LEN) - frag_size;
  689. /*
  690. * We will come here only only three condition:
  691. * 1. Msdu with single Buffer
  692. * 2. First buffer in case MSDU is spread in multiple
  693. * buffer
  694. * 3. Last buffer in case MSDU is spread in multiple
  695. * buffer
  696. *
  697. * First buffER | Last buffer
  698. * Case 1: 1 | 1
  699. * Case 2: 1 | 0
  700. * Case 3: 0 | 1
  701. *
  702. * In 3rd case only l2_hdr_padding byte will be Zero and
  703. * in other case, It will be 2 Bytes.
  704. */
  705. if (buf_info.first_buffer)
  706. l2_hdr_offset = DP_RX_MON_NONRAW_L2_HDR_PAD_BYTE;
  707. else
  708. l2_hdr_offset = DP_RX_MON_RAW_L2_HDR_PAD_BYTE;
  709. if (buf_info.first_buffer) {
  710. /* Src addr from where llc header needs to be copied */
  711. rx_src_desc =
  712. HAL_RX_DESC_GET_80211_HDR(rx_desc);
  713. /* Size of buffer with llc header */
  714. frag_size = frag_size -
  715. (l2_hdr_offset + decap_hdr_pull_bytes);
  716. frag_size += msdu_llc_len;
  717. /* Construct destination address */
  718. rx_dest_desc = frag_addr +
  719. decap_hdr_pull_bytes + l2_hdr_offset;
  720. rx_dest_desc = rx_dest_desc - (msdu_llc_len);
  721. qdf_mem_copy(rx_dest_desc, rx_src_desc,
  722. msdu_llc_len);
  723. /*
  724. * Calculate new page offset and create hole
  725. * if amsdu_pad required.
  726. */
  727. frag_page_offset = l2_hdr_offset +
  728. decap_hdr_pull_bytes;
  729. frag_page_offset = frag_page_offset -
  730. (msdu_llc_len + amsdu_pad);
  731. qdf_nbuf_move_frag_page_offset(msdu_curr,
  732. frags_iter,
  733. frag_page_offset);
  734. tot_msdu_len = frag_size;
  735. /*
  736. * No amsdu padding required for first frame of
  737. * continuation buffer
  738. */
  739. if (!buf_info.last_buffer) {
  740. amsdu_pad = 0;
  741. continue;
  742. }
  743. } else {
  744. tot_msdu_len += frag_size;
  745. }
  746. /* Will reach to this place in only two case:
  747. * 1. Single buffer MSDU
  748. * 2. Last buffer of MSDU in case of multiple buf MSDU
  749. */
  750. /* Check size of buffer if amsdu padding required */
  751. amsdu_pad = tot_msdu_len & 0x3;
  752. amsdu_pad = amsdu_pad ? (4 - amsdu_pad) : 0;
  753. /* Create placeholder if current bufer can
  754. * accommodate padding.
  755. */
  756. if (amsdu_pad && (amsdu_pad <= pad_byte_pholder)) {
  757. char *frag_addr_temp;
  758. qdf_nbuf_trim_add_frag_size(msdu_curr,
  759. frags_iter,
  760. amsdu_pad, 0);
  761. frag_addr_temp = (char *)qdf_nbuf_get_frag_addr(msdu_curr, 0);
  762. frag_addr_temp = (frag_addr_temp +
  763. qdf_nbuf_get_frag_size_by_idx(msdu_curr, frags_iter)) -
  764. amsdu_pad;
  765. qdf_mem_zero(frag_addr_temp, amsdu_pad);
  766. amsdu_pad = 0;
  767. }
  768. /* reset tot_msdu_len */
  769. tot_msdu_len = 0;
  770. }
  771. msdu_curr = qdf_nbuf_next(msdu_curr);
  772. }
  773. dp_rx_mon_fraglist_prepare(head_msdu, tail_msdu);
  774. dp_rx_mon_dest_debug("%pK: head_msdu %pK head_msdu->len %u",
  775. soc, head_msdu, head_msdu->len);
  776. mpdu_stitch_done:
  777. return head_msdu;
  778. mpdu_stitch_fail:
  779. dp_rx_mon_dest_err("%pK: mpdu_stitch_fail head_msdu %pK",
  780. soc, head_msdu);
  781. return NULL;
  782. }
  783. #endif
  784. static inline
  785. qdf_nbuf_t dp_rx_mon_restitch_mpdu_from_msdus(struct dp_soc *soc,
  786. uint32_t mac_id, qdf_nbuf_t head_msdu, qdf_nbuf_t last_msdu,
  787. struct cdp_mon_status *rx_status)
  788. {
  789. qdf_nbuf_t msdu, mpdu_buf, prev_buf, msdu_orig, head_frag_list;
  790. uint32_t decap_format, wifi_hdr_len, sec_hdr_len, msdu_llc_len,
  791. mpdu_buf_len, decap_hdr_pull_bytes, frag_list_sum_len, dir,
  792. is_amsdu, is_first_frag, amsdu_pad;
  793. void *rx_desc;
  794. char *hdr_desc;
  795. unsigned char *dest;
  796. struct ieee80211_frame *wh;
  797. struct ieee80211_qoscntl *qos;
  798. struct dp_pdev *dp_pdev = dp_get_pdev_for_lmac_id(soc, mac_id);
  799. head_frag_list = NULL;
  800. mpdu_buf = NULL;
  801. if (qdf_unlikely(!dp_pdev)) {
  802. dp_rx_mon_dest_debug("%pK: pdev is null for mac_id = %d",
  803. soc, mac_id);
  804. return NULL;
  805. }
  806. /* The nbuf has been pulled just beyond the status and points to the
  807. * payload
  808. */
  809. if (!head_msdu)
  810. goto mpdu_stitch_fail;
  811. msdu_orig = head_msdu;
  812. rx_desc = qdf_nbuf_data(msdu_orig);
  813. if (HAL_RX_DESC_GET_MPDU_LENGTH_ERR(rx_desc)) {
  814. /* It looks like there is some issue on MPDU len err */
  815. /* Need further investigate if drop the packet */
  816. DP_STATS_INC(dp_pdev, dropped.mon_rx_drop, 1);
  817. return NULL;
  818. }
  819. rx_desc = qdf_nbuf_data(last_msdu);
  820. rx_status->cdp_rs_fcs_err = HAL_RX_DESC_GET_MPDU_FCS_ERR(rx_desc);
  821. dp_pdev->ppdu_info.rx_status.rs_fcs_err =
  822. HAL_RX_DESC_GET_MPDU_FCS_ERR(rx_desc);
  823. /* Fill out the rx_status from the PPDU start and end fields */
  824. /* HAL_RX_GET_PPDU_STATUS(soc, mac_id, rx_status); */
  825. rx_desc = qdf_nbuf_data(head_msdu);
  826. decap_format = HAL_RX_DESC_GET_DECAP_FORMAT(rx_desc);
  827. /* Easy case - The MSDU status indicates that this is a non-decapped
  828. * packet in RAW mode.
  829. */
  830. if (decap_format == HAL_HW_RX_DECAP_FORMAT_RAW) {
  831. /* Note that this path might suffer from headroom unavailabilty
  832. * - but the RX status is usually enough
  833. */
  834. dp_rx_msdus_set_payload(soc, head_msdu);
  835. dp_rx_mon_dest_debug("%pK: decap format raw head %pK head->next %pK last_msdu %pK last_msdu->next %pK",
  836. soc, head_msdu, head_msdu->next,
  837. last_msdu, last_msdu->next);
  838. mpdu_buf = head_msdu;
  839. prev_buf = mpdu_buf;
  840. frag_list_sum_len = 0;
  841. msdu = qdf_nbuf_next(head_msdu);
  842. is_first_frag = 1;
  843. while (msdu) {
  844. dp_rx_msdus_set_payload(soc, msdu);
  845. if (is_first_frag) {
  846. is_first_frag = 0;
  847. head_frag_list = msdu;
  848. }
  849. frag_list_sum_len += qdf_nbuf_len(msdu);
  850. /* Maintain the linking of the cloned MSDUS */
  851. qdf_nbuf_set_next_ext(prev_buf, msdu);
  852. /* Move to the next */
  853. prev_buf = msdu;
  854. msdu = qdf_nbuf_next(msdu);
  855. }
  856. qdf_nbuf_trim_tail(prev_buf, HAL_RX_FCS_LEN);
  857. /* If there were more fragments to this RAW frame */
  858. if (head_frag_list) {
  859. if (frag_list_sum_len <
  860. sizeof(struct ieee80211_frame_min_one)) {
  861. DP_STATS_INC(dp_pdev, dropped.mon_rx_drop, 1);
  862. return NULL;
  863. }
  864. frag_list_sum_len -= HAL_RX_FCS_LEN;
  865. qdf_nbuf_append_ext_list(mpdu_buf, head_frag_list,
  866. frag_list_sum_len);
  867. qdf_nbuf_set_next(mpdu_buf, NULL);
  868. }
  869. goto mpdu_stitch_done;
  870. }
  871. /* Decap mode:
  872. * Calculate the amount of header in decapped packet to knock off based
  873. * on the decap type and the corresponding number of raw bytes to copy
  874. * status header
  875. */
  876. rx_desc = qdf_nbuf_data(head_msdu);
  877. hdr_desc = HAL_RX_DESC_GET_80211_HDR(rx_desc);
  878. dp_rx_mon_dest_debug("%pK: decap format not raw", soc);
  879. /* Base size */
  880. wifi_hdr_len = sizeof(struct ieee80211_frame);
  881. wh = (struct ieee80211_frame *)hdr_desc;
  882. dir = wh->i_fc[1] & IEEE80211_FC1_DIR_MASK;
  883. if (dir == IEEE80211_FC1_DIR_DSTODS)
  884. wifi_hdr_len += 6;
  885. is_amsdu = 0;
  886. if (wh->i_fc[0] & QDF_IEEE80211_FC0_SUBTYPE_QOS) {
  887. qos = (struct ieee80211_qoscntl *)
  888. (hdr_desc + wifi_hdr_len);
  889. wifi_hdr_len += 2;
  890. is_amsdu = (qos->i_qos[0] & IEEE80211_QOS_AMSDU);
  891. }
  892. /*Calculate security header length based on 'Protected'
  893. * and 'EXT_IV' flag
  894. * */
  895. if (wh->i_fc[1] & IEEE80211_FC1_WEP) {
  896. char *iv = (char *)wh + wifi_hdr_len;
  897. if (iv[3] & KEY_EXTIV)
  898. sec_hdr_len = 8;
  899. else
  900. sec_hdr_len = 4;
  901. } else {
  902. sec_hdr_len = 0;
  903. }
  904. wifi_hdr_len += sec_hdr_len;
  905. /* MSDU related stuff LLC - AMSDU subframe header etc */
  906. msdu_llc_len = is_amsdu ? (14 + 8) : 8;
  907. mpdu_buf_len = wifi_hdr_len + msdu_llc_len;
  908. /* "Decap" header to remove from MSDU buffer */
  909. decap_hdr_pull_bytes = 14;
  910. /* Allocate a new nbuf for holding the 802.11 header retrieved from the
  911. * status of the now decapped first msdu. Leave enough headroom for
  912. * accomodating any radio-tap /prism like PHY header
  913. */
  914. mpdu_buf = qdf_nbuf_alloc(soc->osdev,
  915. MAX_MONITOR_HEADER + mpdu_buf_len,
  916. MAX_MONITOR_HEADER, 4, FALSE);
  917. if (!mpdu_buf)
  918. goto mpdu_stitch_done;
  919. /* Copy the MPDU related header and enc headers into the first buffer
  920. * - Note that there can be a 2 byte pad between heaader and enc header
  921. */
  922. prev_buf = mpdu_buf;
  923. dest = qdf_nbuf_put_tail(prev_buf, wifi_hdr_len);
  924. if (!dest)
  925. goto mpdu_stitch_fail;
  926. qdf_mem_copy(dest, hdr_desc, wifi_hdr_len);
  927. hdr_desc += wifi_hdr_len;
  928. #if 0
  929. dest = qdf_nbuf_put_tail(prev_buf, sec_hdr_len);
  930. adf_os_mem_copy(dest, hdr_desc, sec_hdr_len);
  931. hdr_desc += sec_hdr_len;
  932. #endif
  933. /* The first LLC len is copied into the MPDU buffer */
  934. frag_list_sum_len = 0;
  935. msdu_orig = head_msdu;
  936. is_first_frag = 1;
  937. amsdu_pad = 0;
  938. while (msdu_orig) {
  939. /* TODO: intra AMSDU padding - do we need it ??? */
  940. msdu = msdu_orig;
  941. if (is_first_frag) {
  942. head_frag_list = msdu;
  943. } else {
  944. /* Reload the hdr ptr only on non-first MSDUs */
  945. rx_desc = qdf_nbuf_data(msdu_orig);
  946. hdr_desc = HAL_RX_DESC_GET_80211_HDR(rx_desc);
  947. }
  948. /* Copy this buffers MSDU related status into the prev buffer */
  949. if (is_first_frag) {
  950. is_first_frag = 0;
  951. }
  952. /* Update protocol and flow tag for MSDU */
  953. dp_rx_mon_update_protocol_flow_tag(soc, dp_pdev,
  954. msdu_orig, rx_desc);
  955. dest = qdf_nbuf_put_tail(prev_buf,
  956. msdu_llc_len + amsdu_pad);
  957. if (!dest)
  958. goto mpdu_stitch_fail;
  959. dest += amsdu_pad;
  960. qdf_mem_copy(dest, hdr_desc, msdu_llc_len);
  961. dp_rx_msdus_set_payload(soc, msdu);
  962. /* Push the MSDU buffer beyond the decap header */
  963. qdf_nbuf_pull_head(msdu, decap_hdr_pull_bytes);
  964. frag_list_sum_len += msdu_llc_len + qdf_nbuf_len(msdu)
  965. + amsdu_pad;
  966. /* Set up intra-AMSDU pad to be added to start of next buffer -
  967. * AMSDU pad is 4 byte pad on AMSDU subframe */
  968. amsdu_pad = (msdu_llc_len + qdf_nbuf_len(msdu)) & 0x3;
  969. amsdu_pad = amsdu_pad ? (4 - amsdu_pad) : 0;
  970. /* TODO FIXME How do we handle MSDUs that have fraglist - Should
  971. * probably iterate all the frags cloning them along the way and
  972. * and also updating the prev_buf pointer
  973. */
  974. /* Move to the next */
  975. prev_buf = msdu;
  976. msdu_orig = qdf_nbuf_next(msdu_orig);
  977. }
  978. #if 0
  979. /* Add in the trailer section - encryption trailer + FCS */
  980. qdf_nbuf_put_tail(prev_buf, HAL_RX_FCS_LEN);
  981. frag_list_sum_len += HAL_RX_FCS_LEN;
  982. #endif
  983. frag_list_sum_len -= msdu_llc_len;
  984. /* TODO: Convert this to suitable adf routines */
  985. qdf_nbuf_append_ext_list(mpdu_buf, head_frag_list,
  986. frag_list_sum_len);
  987. dp_rx_mon_dest_debug("%pK: mpdu_buf %pK mpdu_buf->len %u",
  988. soc, mpdu_buf, mpdu_buf->len);
  989. mpdu_stitch_done:
  990. /* Check if this buffer contains the PPDU end status for TSF */
  991. /* Need revist this code to see where we can get tsf timestamp */
  992. #if 0
  993. /* PPDU end TLV will be retrieved from monitor status ring */
  994. last_mpdu =
  995. (*(((u_int32_t *)&rx_desc->attention)) &
  996. RX_ATTENTION_0_LAST_MPDU_MASK) >>
  997. RX_ATTENTION_0_LAST_MPDU_LSB;
  998. if (last_mpdu)
  999. rx_status->rs_tstamp.tsf = rx_desc->ppdu_end.tsf_timestamp;
  1000. #endif
  1001. return mpdu_buf;
  1002. mpdu_stitch_fail:
  1003. if ((mpdu_buf) && (decap_format != HAL_HW_RX_DECAP_FORMAT_RAW)) {
  1004. dp_rx_mon_dest_err("%pK: mpdu_stitch_fail mpdu_buf %pK",
  1005. soc, mpdu_buf);
  1006. /* Free the head buffer */
  1007. qdf_nbuf_free(mpdu_buf);
  1008. }
  1009. return NULL;
  1010. }
  1011. #ifdef DP_RX_MON_MEM_FRAG
  1012. #if defined(WLAN_SUPPORT_RX_PROTOCOL_TYPE_TAG) ||\
  1013. defined(WLAN_SUPPORT_RX_FLOW_TAG)
  1014. static inline
  1015. void dp_rx_mon_update_pf_tag_to_buf_headroom(struct dp_soc *soc,
  1016. qdf_nbuf_t nbuf)
  1017. {
  1018. qdf_nbuf_t ext_list;
  1019. if (qdf_unlikely(!soc)) {
  1020. dp_err("Soc[%pK] Null. Can't update pftag to nbuf headroom\n",
  1021. soc);
  1022. qdf_assert_always(0);
  1023. }
  1024. if (!wlan_cfg_is_rx_mon_protocol_flow_tag_enabled(soc->wlan_cfg_ctx))
  1025. return;
  1026. if (qdf_unlikely(!nbuf))
  1027. return;
  1028. /* Return if it dint came from mon Path */
  1029. if (!qdf_nbuf_get_nr_frags(nbuf))
  1030. return;
  1031. /* Headroom must be double of PF_TAG_SIZE as we copy it 1stly to head */
  1032. if (qdf_unlikely(qdf_nbuf_headroom(nbuf) < (DP_RX_MON_TOT_PF_TAG_LEN * 2))) {
  1033. dp_err("Nbuf avail Headroom[%d] < 2 * DP_RX_MON_PF_TAG_TOT_LEN[%d]",
  1034. qdf_nbuf_headroom(nbuf), DP_RX_MON_TOT_PF_TAG_LEN);
  1035. return;
  1036. }
  1037. qdf_nbuf_push_head(nbuf, DP_RX_MON_TOT_PF_TAG_LEN);
  1038. qdf_mem_copy(qdf_nbuf_data(nbuf), qdf_nbuf_head(nbuf),
  1039. DP_RX_MON_TOT_PF_TAG_LEN);
  1040. qdf_nbuf_pull_head(nbuf, DP_RX_MON_TOT_PF_TAG_LEN);
  1041. ext_list = qdf_nbuf_get_ext_list(nbuf);
  1042. while (ext_list) {
  1043. /* Headroom must be double of PF_TAG_SIZE as we copy it 1stly to head */
  1044. if (qdf_unlikely(qdf_nbuf_headroom(ext_list) < (DP_RX_MON_TOT_PF_TAG_LEN * 2))) {
  1045. dp_err("Fraglist Nbuf avail Headroom[%d] < 2 * DP_RX_MON_PF_TAG_TOT_LEN[%d]",
  1046. qdf_nbuf_headroom(ext_list), DP_RX_MON_TOT_PF_TAG_LEN);
  1047. ext_list = qdf_nbuf_queue_next(ext_list);
  1048. continue;
  1049. }
  1050. qdf_nbuf_push_head(ext_list, DP_RX_MON_TOT_PF_TAG_LEN);
  1051. qdf_mem_copy(qdf_nbuf_data(ext_list), qdf_nbuf_head(ext_list),
  1052. DP_RX_MON_TOT_PF_TAG_LEN);
  1053. qdf_nbuf_pull_head(ext_list, DP_RX_MON_TOT_PF_TAG_LEN);
  1054. ext_list = qdf_nbuf_queue_next(ext_list);
  1055. }
  1056. }
  1057. #else
  1058. static inline
  1059. void dp_rx_mon_update_pf_tag_to_buf_headroom(struct dp_soc *soc,
  1060. qdf_nbuf_t nbuf)
  1061. {
  1062. }
  1063. #endif
  1064. #else
  1065. static inline
  1066. void dp_rx_mon_update_pf_tag_to_buf_headroom(struct dp_soc *soc,
  1067. qdf_nbuf_t nbuf)
  1068. {
  1069. }
  1070. #endif
  1071. /**
  1072. * dp_send_mgmt_packet_to_stack(): send indicataion to upper layers
  1073. *
  1074. * @soc: soc handle
  1075. * @nbuf: Mgmt packet
  1076. * @pdev: pdev handle
  1077. *
  1078. * Return: QDF_STATUS_SUCCESS on success
  1079. * QDF_STATUS_E_INVAL in error
  1080. */
  1081. #ifdef FEATURE_PERPKT_INFO
  1082. static inline QDF_STATUS dp_send_mgmt_packet_to_stack(struct dp_soc *soc,
  1083. qdf_nbuf_t nbuf,
  1084. struct dp_pdev *pdev)
  1085. {
  1086. uint32_t *nbuf_data;
  1087. struct ieee80211_frame *wh;
  1088. qdf_frag_t addr;
  1089. if (!nbuf)
  1090. return QDF_STATUS_E_INVAL;
  1091. /* Get addr pointing to80211 header */
  1092. addr = dp_rx_mon_get_nbuf_80211_hdr(nbuf);
  1093. if (qdf_unlikely(!addr)) {
  1094. qdf_nbuf_free(nbuf);
  1095. return QDF_STATUS_E_INVAL;
  1096. }
  1097. /*check if this is not a mgmt packet*/
  1098. wh = (struct ieee80211_frame *)addr;
  1099. if (((wh->i_fc[0] & IEEE80211_FC0_TYPE_MASK) !=
  1100. IEEE80211_FC0_TYPE_MGT) &&
  1101. ((wh->i_fc[0] & IEEE80211_FC0_TYPE_MASK) !=
  1102. IEEE80211_FC0_TYPE_CTL)) {
  1103. qdf_nbuf_free(nbuf);
  1104. return QDF_STATUS_E_INVAL;
  1105. }
  1106. nbuf_data = (uint32_t *)qdf_nbuf_push_head(nbuf, 4);
  1107. if (!nbuf_data) {
  1108. QDF_TRACE(QDF_MODULE_ID_DP,
  1109. QDF_TRACE_LEVEL_ERROR,
  1110. FL("No headroom"));
  1111. qdf_nbuf_free(nbuf);
  1112. return QDF_STATUS_E_INVAL;
  1113. }
  1114. *nbuf_data = pdev->ppdu_info.com_info.ppdu_id;
  1115. dp_wdi_event_handler(WDI_EVENT_RX_MGMT_CTRL, soc, nbuf,
  1116. HTT_INVALID_PEER,
  1117. WDI_NO_VAL, pdev->pdev_id);
  1118. return QDF_STATUS_SUCCESS;
  1119. }
  1120. #else
  1121. static inline QDF_STATUS dp_send_mgmt_packet_to_stack(struct dp_soc *soc,
  1122. qdf_nbuf_t nbuf,
  1123. struct dp_pdev *pdev)
  1124. {
  1125. return QDF_STATUS_SUCCESS;
  1126. }
  1127. #endif
  1128. /**
  1129. * dp_rx_extract_radiotap_info(): Extract and populate information in
  1130. * struct mon_rx_status type
  1131. * @rx_status: Receive status
  1132. * @mon_rx_status: Monitor mode status
  1133. *
  1134. * Returns: None
  1135. */
  1136. static inline
  1137. void dp_rx_extract_radiotap_info(struct cdp_mon_status *rx_status,
  1138. struct mon_rx_status *rx_mon_status)
  1139. {
  1140. rx_mon_status->tsft = rx_status->cdp_rs_tstamp.cdp_tsf;
  1141. rx_mon_status->chan_freq = rx_status->rs_freq;
  1142. rx_mon_status->chan_num = rx_status->rs_channel;
  1143. rx_mon_status->chan_flags = rx_status->rs_flags;
  1144. rx_mon_status->rate = rx_status->rs_datarate;
  1145. /* TODO: rx_mon_status->ant_signal_db */
  1146. /* TODO: rx_mon_status->nr_ant */
  1147. rx_mon_status->mcs = rx_status->cdf_rs_rate_mcs;
  1148. rx_mon_status->is_stbc = rx_status->cdp_rs_stbc;
  1149. rx_mon_status->sgi = rx_status->cdp_rs_sgi;
  1150. /* TODO: rx_mon_status->ldpc */
  1151. /* TODO: rx_mon_status->beamformed */
  1152. /* TODO: rx_mon_status->vht_flags */
  1153. /* TODO: rx_mon_status->vht_flag_values1 */
  1154. }
  1155. #ifdef DP_RX_MON_MEM_FRAG
  1156. static inline
  1157. qdf_nbuf_t dp_rx_mon_restitch_mpdu(struct dp_soc *soc, uint32_t mac_id,
  1158. qdf_nbuf_t head_msdu, qdf_nbuf_t tail_msdu,
  1159. struct cdp_mon_status *rs)
  1160. {
  1161. if (qdf_nbuf_get_nr_frags(head_msdu))
  1162. return dp_rx_mon_frag_restitch_mpdu_from_msdus(soc, mac_id,
  1163. head_msdu,
  1164. tail_msdu, rs);
  1165. else
  1166. return dp_rx_mon_restitch_mpdu_from_msdus(soc, mac_id,
  1167. head_msdu,
  1168. tail_msdu, rs);
  1169. }
  1170. #else
  1171. static inline
  1172. qdf_nbuf_t dp_rx_mon_restitch_mpdu(struct dp_soc *soc, uint32_t mac_id,
  1173. qdf_nbuf_t head_msdu, qdf_nbuf_t tail_msdu,
  1174. struct cdp_mon_status *rs)
  1175. {
  1176. return dp_rx_mon_restitch_mpdu_from_msdus(soc, mac_id, head_msdu,
  1177. tail_msdu, rs);
  1178. }
  1179. #endif
  1180. /*
  1181. * dp_rx_mon_deliver(): function to deliver packets to stack
  1182. * @soc: DP soc
  1183. * @mac_id: MAC ID
  1184. * @head_msdu: head of msdu list
  1185. * @tail_msdu: tail of msdu list
  1186. *
  1187. * Return: status: 0 - Success, non-zero: Failure
  1188. */
  1189. QDF_STATUS dp_rx_mon_deliver(struct dp_soc *soc, uint32_t mac_id,
  1190. qdf_nbuf_t head_msdu, qdf_nbuf_t tail_msdu)
  1191. {
  1192. struct dp_pdev *pdev = dp_get_pdev_for_lmac_id(soc, mac_id);
  1193. struct cdp_mon_status *rs = &pdev->rx_mon_recv_status;
  1194. qdf_nbuf_t mon_skb, skb_next;
  1195. qdf_nbuf_t mon_mpdu = NULL;
  1196. if (!pdev || (!pdev->monitor_vdev && !pdev->mcopy_mode))
  1197. goto mon_deliver_fail;
  1198. /* restitch mon MPDU for delivery via monitor interface */
  1199. mon_mpdu = dp_rx_mon_restitch_mpdu(soc, mac_id, head_msdu,
  1200. tail_msdu, rs);
  1201. /* If MPDU restitch fails, free buffers*/
  1202. if (!mon_mpdu) {
  1203. dp_info("MPDU restitch failed, free buffers");
  1204. goto mon_deliver_fail;
  1205. }
  1206. /* monitor vap cannot be present when mcopy is enabled
  1207. * hence same skb can be consumed
  1208. */
  1209. if (pdev->mcopy_mode)
  1210. return dp_send_mgmt_packet_to_stack(soc, mon_mpdu, pdev);
  1211. if (mon_mpdu && pdev->monitor_vdev && pdev->monitor_vdev->osif_vdev &&
  1212. pdev->monitor_vdev->osif_rx_mon) {
  1213. pdev->ppdu_info.rx_status.ppdu_id =
  1214. pdev->ppdu_info.com_info.ppdu_id;
  1215. pdev->ppdu_info.rx_status.device_id = soc->device_id;
  1216. pdev->ppdu_info.rx_status.chan_noise_floor =
  1217. pdev->chan_noise_floor;
  1218. dp_handle_tx_capture(soc, pdev, mon_mpdu);
  1219. if (!qdf_nbuf_update_radiotap(&pdev->ppdu_info.rx_status,
  1220. mon_mpdu,
  1221. qdf_nbuf_headroom(mon_mpdu))) {
  1222. DP_STATS_INC(pdev, dropped.mon_radiotap_update_err, 1);
  1223. goto mon_deliver_fail;
  1224. }
  1225. dp_rx_mon_update_pf_tag_to_buf_headroom(soc, mon_mpdu);
  1226. pdev->monitor_vdev->osif_rx_mon(pdev->monitor_vdev->osif_vdev,
  1227. mon_mpdu,
  1228. &pdev->ppdu_info.rx_status);
  1229. } else {
  1230. dp_rx_mon_dest_debug("%pK: mon_mpdu=%pK monitor_vdev %pK osif_vdev %pK"
  1231. , soc, mon_mpdu, pdev->monitor_vdev,
  1232. (pdev->monitor_vdev ? pdev->monitor_vdev->osif_vdev
  1233. : NULL));
  1234. goto mon_deliver_fail;
  1235. }
  1236. return QDF_STATUS_SUCCESS;
  1237. mon_deliver_fail:
  1238. mon_skb = head_msdu;
  1239. while (mon_skb) {
  1240. skb_next = qdf_nbuf_next(mon_skb);
  1241. dp_rx_mon_dest_debug("%pK: [%s][%d] mon_skb=%pK len %u",
  1242. soc, __func__, __LINE__, mon_skb, mon_skb->len);
  1243. qdf_nbuf_free(mon_skb);
  1244. mon_skb = skb_next;
  1245. }
  1246. return QDF_STATUS_E_INVAL;
  1247. }
  1248. /**
  1249. * dp_rx_mon_deliver_non_std()
  1250. * @soc: core txrx main contex
  1251. * @mac_id: MAC ID
  1252. *
  1253. * This function delivers the radio tap and dummy MSDU
  1254. * into user layer application for preamble only PPDU.
  1255. *
  1256. * Return: QDF_STATUS
  1257. */
  1258. QDF_STATUS dp_rx_mon_deliver_non_std(struct dp_soc *soc,
  1259. uint32_t mac_id)
  1260. {
  1261. struct dp_pdev *pdev = dp_get_pdev_for_lmac_id(soc, mac_id);
  1262. ol_txrx_rx_mon_fp osif_rx_mon;
  1263. qdf_nbuf_t dummy_msdu;
  1264. /* Sanity checking */
  1265. if (!pdev || !pdev->monitor_vdev || !pdev->monitor_vdev->osif_rx_mon)
  1266. goto mon_deliver_non_std_fail;
  1267. /* Generate a dummy skb_buff */
  1268. osif_rx_mon = pdev->monitor_vdev->osif_rx_mon;
  1269. dummy_msdu = qdf_nbuf_alloc(soc->osdev, MAX_MONITOR_HEADER,
  1270. MAX_MONITOR_HEADER, 4, FALSE);
  1271. if (!dummy_msdu)
  1272. goto allocate_dummy_msdu_fail;
  1273. qdf_nbuf_set_pktlen(dummy_msdu, 0);
  1274. qdf_nbuf_set_next(dummy_msdu, NULL);
  1275. pdev->ppdu_info.rx_status.ppdu_id =
  1276. pdev->ppdu_info.com_info.ppdu_id;
  1277. /* Apply the radio header to this dummy skb */
  1278. if (!qdf_nbuf_update_radiotap(&pdev->ppdu_info.rx_status, dummy_msdu,
  1279. qdf_nbuf_headroom(dummy_msdu))) {
  1280. DP_STATS_INC(pdev, dropped.mon_radiotap_update_err, 1);
  1281. qdf_nbuf_free(dummy_msdu);
  1282. goto mon_deliver_non_std_fail;
  1283. }
  1284. /* deliver to the user layer application */
  1285. osif_rx_mon(pdev->monitor_vdev->osif_vdev,
  1286. dummy_msdu, NULL);
  1287. /* Clear rx_status*/
  1288. qdf_mem_zero(&pdev->ppdu_info.rx_status,
  1289. sizeof(pdev->ppdu_info.rx_status));
  1290. pdev->mon_ppdu_status = DP_PPDU_STATUS_START;
  1291. return QDF_STATUS_SUCCESS;
  1292. allocate_dummy_msdu_fail:
  1293. dp_rx_mon_dest_debug("%pK: mon_skb=%pK ",
  1294. soc, dummy_msdu);
  1295. mon_deliver_non_std_fail:
  1296. return QDF_STATUS_E_INVAL;
  1297. }
  1298. void dp_rx_mon_dest_process(struct dp_soc *soc, struct dp_intr *int_ctx,
  1299. uint32_t mac_id, uint32_t quota)
  1300. {
  1301. struct dp_pdev *pdev = dp_get_pdev_for_lmac_id(soc, mac_id);
  1302. uint8_t pdev_id;
  1303. hal_rxdma_desc_t rxdma_dst_ring_desc;
  1304. hal_soc_handle_t hal_soc;
  1305. void *mon_dst_srng;
  1306. union dp_rx_desc_list_elem_t *head = NULL;
  1307. union dp_rx_desc_list_elem_t *tail = NULL;
  1308. uint32_t ppdu_id;
  1309. uint32_t rx_bufs_used;
  1310. uint32_t mpdu_rx_bufs_used;
  1311. int mac_for_pdev = mac_id;
  1312. struct cdp_pdev_mon_stats *rx_mon_stats;
  1313. if (!pdev) {
  1314. dp_rx_mon_dest_debug("%pK: pdev is null for mac_id = %d", soc, mac_id);
  1315. return;
  1316. }
  1317. mon_dst_srng = dp_rxdma_get_mon_dst_ring(pdev, mac_for_pdev);
  1318. if (!mon_dst_srng || !hal_srng_initialized(mon_dst_srng)) {
  1319. dp_rx_mon_dest_err("%pK: : HAL Monitor Destination Ring Init Failed -- %pK",
  1320. soc, mon_dst_srng);
  1321. return;
  1322. }
  1323. hal_soc = soc->hal_soc;
  1324. qdf_assert((hal_soc && pdev));
  1325. qdf_spin_lock_bh(&pdev->mon_lock);
  1326. if (qdf_unlikely(dp_srng_access_start(int_ctx, soc, mon_dst_srng))) {
  1327. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  1328. "%s %d : HAL Monitor Destination Ring access Failed -- %pK",
  1329. __func__, __LINE__, mon_dst_srng);
  1330. return;
  1331. }
  1332. pdev_id = pdev->pdev_id;
  1333. ppdu_id = pdev->ppdu_info.com_info.ppdu_id;
  1334. rx_bufs_used = 0;
  1335. rx_mon_stats = &pdev->rx_mon_stats;
  1336. while (qdf_likely(rxdma_dst_ring_desc =
  1337. hal_srng_dst_peek(hal_soc, mon_dst_srng))) {
  1338. qdf_nbuf_t head_msdu, tail_msdu;
  1339. uint32_t npackets;
  1340. head_msdu = (qdf_nbuf_t) NULL;
  1341. tail_msdu = (qdf_nbuf_t) NULL;
  1342. mpdu_rx_bufs_used =
  1343. dp_rx_mon_mpdu_pop(soc, mac_id,
  1344. rxdma_dst_ring_desc,
  1345. &head_msdu, &tail_msdu,
  1346. &npackets, &ppdu_id,
  1347. &head, &tail);
  1348. rx_bufs_used += mpdu_rx_bufs_used;
  1349. if (mpdu_rx_bufs_used)
  1350. pdev->mon_dest_ring_stuck_cnt = 0;
  1351. else
  1352. pdev->mon_dest_ring_stuck_cnt++;
  1353. if (pdev->mon_dest_ring_stuck_cnt >
  1354. MON_DEST_RING_STUCK_MAX_CNT) {
  1355. dp_info("destination ring stuck");
  1356. dp_info("ppdu_id status=%d dest=%d",
  1357. pdev->ppdu_info.com_info.ppdu_id, ppdu_id);
  1358. rx_mon_stats->mon_rx_dest_stuck++;
  1359. pdev->ppdu_info.com_info.ppdu_id = ppdu_id;
  1360. continue;
  1361. }
  1362. if (ppdu_id != pdev->ppdu_info.com_info.ppdu_id) {
  1363. rx_mon_stats->stat_ring_ppdu_id_hist[
  1364. rx_mon_stats->ppdu_id_hist_idx] =
  1365. pdev->ppdu_info.com_info.ppdu_id;
  1366. rx_mon_stats->dest_ring_ppdu_id_hist[
  1367. rx_mon_stats->ppdu_id_hist_idx] = ppdu_id;
  1368. rx_mon_stats->ppdu_id_hist_idx =
  1369. (rx_mon_stats->ppdu_id_hist_idx + 1) &
  1370. (MAX_PPDU_ID_HIST - 1);
  1371. pdev->mon_ppdu_status = DP_PPDU_STATUS_START;
  1372. qdf_mem_zero(&(pdev->ppdu_info.rx_status),
  1373. sizeof(pdev->ppdu_info.rx_status));
  1374. dp_rx_mon_dest_debug("%pK: ppdu_id %x != ppdu_info.com_info.ppdu_id %x",
  1375. soc, ppdu_id, pdev->ppdu_info.com_info.ppdu_id);
  1376. break;
  1377. }
  1378. if (qdf_likely((head_msdu) && (tail_msdu))) {
  1379. rx_mon_stats->dest_mpdu_done++;
  1380. dp_rx_mon_deliver(soc, mac_id, head_msdu, tail_msdu);
  1381. }
  1382. rxdma_dst_ring_desc = hal_srng_dst_get_next(hal_soc,
  1383. mon_dst_srng);
  1384. }
  1385. dp_srng_access_end(int_ctx, soc, mon_dst_srng);
  1386. qdf_spin_unlock_bh(&pdev->mon_lock);
  1387. if (rx_bufs_used) {
  1388. rx_mon_stats->dest_ppdu_done++;
  1389. dp_rx_buffers_replenish(soc, mac_id,
  1390. dp_rxdma_get_mon_buf_ring(pdev,
  1391. mac_for_pdev),
  1392. dp_rx_get_mon_desc_pool(soc, mac_id,
  1393. pdev_id),
  1394. rx_bufs_used, &head, &tail);
  1395. }
  1396. }
  1397. QDF_STATUS
  1398. dp_rx_pdev_mon_buf_buffers_alloc(struct dp_pdev *pdev, uint32_t mac_id,
  1399. bool delayed_replenish)
  1400. {
  1401. uint8_t pdev_id = pdev->pdev_id;
  1402. struct dp_soc *soc = pdev->soc;
  1403. struct dp_srng *mon_buf_ring;
  1404. uint32_t num_entries;
  1405. struct rx_desc_pool *rx_desc_pool;
  1406. QDF_STATUS status = QDF_STATUS_SUCCESS;
  1407. struct wlan_cfg_dp_soc_ctxt *soc_cfg_ctx = soc->wlan_cfg_ctx;
  1408. mon_buf_ring = dp_rxdma_get_mon_buf_ring(pdev, mac_id);
  1409. num_entries = mon_buf_ring->num_entries;
  1410. rx_desc_pool = dp_rx_get_mon_desc_pool(soc, mac_id, pdev_id);
  1411. dp_debug("Mon RX Desc Pool[%d] entries=%u", pdev_id, num_entries);
  1412. /* Replenish RXDMA monitor buffer ring with 8 buffers only
  1413. * delayed_replenish_entries is actually 8 but when we call
  1414. * dp_pdev_rx_buffers_attach() we pass 1 less than 8, hence
  1415. * added 1 to delayed_replenish_entries to ensure we have 8
  1416. * entries. Once the monitor VAP is configured we replenish
  1417. * the complete RXDMA monitor buffer ring.
  1418. */
  1419. if (delayed_replenish) {
  1420. num_entries = soc_cfg_ctx->delayed_replenish_entries + 1;
  1421. status = dp_pdev_rx_buffers_attach(soc, mac_id, mon_buf_ring,
  1422. rx_desc_pool,
  1423. num_entries - 1);
  1424. } else {
  1425. union dp_rx_desc_list_elem_t *tail = NULL;
  1426. union dp_rx_desc_list_elem_t *desc_list = NULL;
  1427. status = dp_rx_buffers_replenish(soc, mac_id,
  1428. mon_buf_ring,
  1429. rx_desc_pool,
  1430. num_entries,
  1431. &desc_list,
  1432. &tail);
  1433. }
  1434. return status;
  1435. }
  1436. static QDF_STATUS
  1437. dp_rx_pdev_mon_cmn_buffers_alloc(struct dp_pdev *pdev, int mac_id)
  1438. {
  1439. struct dp_soc *soc = pdev->soc;
  1440. uint8_t pdev_id = pdev->pdev_id;
  1441. int mac_for_pdev;
  1442. bool delayed_replenish;
  1443. QDF_STATUS status = QDF_STATUS_SUCCESS;
  1444. struct wlan_cfg_dp_soc_ctxt *soc_cfg_ctx = soc->wlan_cfg_ctx;
  1445. delayed_replenish = soc_cfg_ctx->delayed_replenish_entries ? 1 : 0;
  1446. mac_for_pdev = dp_get_lmac_id_for_pdev_id(pdev->soc, mac_id, pdev_id);
  1447. status = dp_rx_pdev_mon_status_buffers_alloc(pdev, mac_for_pdev);
  1448. if (!QDF_IS_STATUS_SUCCESS(status)) {
  1449. dp_err("dp_rx_pdev_mon_status_desc_pool_alloc() failed");
  1450. goto fail;
  1451. }
  1452. if (!soc->wlan_cfg_ctx->rxdma1_enable)
  1453. return status;
  1454. status = dp_rx_pdev_mon_buf_buffers_alloc(pdev, mac_for_pdev,
  1455. delayed_replenish);
  1456. if (!QDF_IS_STATUS_SUCCESS(status)) {
  1457. dp_err("dp_rx_pdev_mon_buf_desc_pool_alloc() failed");
  1458. goto mon_stat_buf_dealloc;
  1459. }
  1460. return status;
  1461. mon_stat_buf_dealloc:
  1462. dp_rx_pdev_mon_status_buffers_free(pdev, mac_for_pdev);
  1463. fail:
  1464. return status;
  1465. }
  1466. static void
  1467. dp_rx_pdev_mon_buf_desc_pool_init(struct dp_pdev *pdev, uint32_t mac_id)
  1468. {
  1469. uint8_t pdev_id = pdev->pdev_id;
  1470. struct dp_soc *soc = pdev->soc;
  1471. struct dp_srng *mon_buf_ring;
  1472. uint32_t num_entries;
  1473. struct rx_desc_pool *rx_desc_pool;
  1474. uint32_t rx_desc_pool_size;
  1475. struct wlan_cfg_dp_soc_ctxt *soc_cfg_ctx = soc->wlan_cfg_ctx;
  1476. mon_buf_ring = &soc->rxdma_mon_buf_ring[mac_id];
  1477. num_entries = mon_buf_ring->num_entries;
  1478. rx_desc_pool = &soc->rx_desc_mon[mac_id];
  1479. dp_debug("Mon RX Desc buf Pool[%d] init entries=%u",
  1480. pdev_id, num_entries);
  1481. rx_desc_pool_size = wlan_cfg_get_dp_soc_rx_sw_desc_weight(soc_cfg_ctx) *
  1482. num_entries;
  1483. rx_desc_pool->owner = HAL_RX_BUF_RBM_SW3_BM;
  1484. rx_desc_pool->buf_size = RX_MONITOR_BUFFER_SIZE;
  1485. rx_desc_pool->buf_alignment = RX_MONITOR_BUFFER_ALIGNMENT;
  1486. /* Enable frag processing if feature is enabled */
  1487. dp_rx_enable_mon_dest_frag(rx_desc_pool, true);
  1488. dp_rx_desc_pool_init(soc, mac_id, rx_desc_pool_size, rx_desc_pool);
  1489. pdev->mon_last_linkdesc_paddr = 0;
  1490. pdev->mon_last_buf_cookie = DP_RX_DESC_COOKIE_MAX + 1;
  1491. /* Attach full monitor mode resources */
  1492. dp_full_mon_attach(pdev);
  1493. }
  1494. static void
  1495. dp_rx_pdev_mon_cmn_desc_pool_init(struct dp_pdev *pdev, int mac_id)
  1496. {
  1497. struct dp_soc *soc = pdev->soc;
  1498. uint32_t mac_for_pdev;
  1499. mac_for_pdev = dp_get_lmac_id_for_pdev_id(soc, mac_id, pdev->pdev_id);
  1500. dp_rx_pdev_mon_status_desc_pool_init(pdev, mac_for_pdev);
  1501. if (!soc->wlan_cfg_ctx->rxdma1_enable)
  1502. return;
  1503. dp_rx_pdev_mon_buf_desc_pool_init(pdev, mac_for_pdev);
  1504. dp_link_desc_ring_replenish(soc, mac_for_pdev);
  1505. }
  1506. static void
  1507. dp_rx_pdev_mon_buf_desc_pool_deinit(struct dp_pdev *pdev, uint32_t mac_id)
  1508. {
  1509. uint8_t pdev_id = pdev->pdev_id;
  1510. struct dp_soc *soc = pdev->soc;
  1511. struct rx_desc_pool *rx_desc_pool;
  1512. rx_desc_pool = &soc->rx_desc_mon[mac_id];
  1513. dp_debug("Mon RX Desc buf Pool[%d] deinit", pdev_id);
  1514. dp_rx_desc_pool_deinit(soc, rx_desc_pool);
  1515. /* Detach full monitor mode resources */
  1516. dp_full_mon_detach(pdev);
  1517. }
  1518. static void
  1519. dp_rx_pdev_mon_cmn_desc_pool_deinit(struct dp_pdev *pdev, int mac_id)
  1520. {
  1521. struct dp_soc *soc = pdev->soc;
  1522. uint8_t pdev_id = pdev->pdev_id;
  1523. int mac_for_pdev = dp_get_lmac_id_for_pdev_id(soc, mac_id, pdev_id);
  1524. dp_rx_pdev_mon_status_desc_pool_deinit(pdev, mac_for_pdev);
  1525. if (!soc->wlan_cfg_ctx->rxdma1_enable)
  1526. return;
  1527. dp_rx_pdev_mon_buf_desc_pool_deinit(pdev, mac_for_pdev);
  1528. }
  1529. static void
  1530. dp_rx_pdev_mon_buf_desc_pool_free(struct dp_pdev *pdev, uint32_t mac_id)
  1531. {
  1532. uint8_t pdev_id = pdev->pdev_id;
  1533. struct dp_soc *soc = pdev->soc;
  1534. struct rx_desc_pool *rx_desc_pool;
  1535. rx_desc_pool = &soc->rx_desc_mon[mac_id];
  1536. dp_debug("Mon RX Buf Desc Pool Free pdev[%d]", pdev_id);
  1537. dp_rx_desc_pool_free(soc, rx_desc_pool);
  1538. }
  1539. static void
  1540. dp_rx_pdev_mon_cmn_desc_pool_free(struct dp_pdev *pdev, int mac_id)
  1541. {
  1542. struct dp_soc *soc = pdev->soc;
  1543. uint8_t pdev_id = pdev->pdev_id;
  1544. int mac_for_pdev = dp_get_lmac_id_for_pdev_id(soc, mac_id, pdev_id);
  1545. dp_rx_pdev_mon_status_desc_pool_free(pdev, mac_for_pdev);
  1546. dp_rx_pdev_mon_buf_desc_pool_free(pdev, mac_for_pdev);
  1547. dp_hw_link_desc_pool_banks_free(soc, mac_for_pdev);
  1548. }
  1549. void dp_rx_pdev_mon_buf_buffers_free(struct dp_pdev *pdev, uint32_t mac_id)
  1550. {
  1551. uint8_t pdev_id = pdev->pdev_id;
  1552. struct dp_soc *soc = pdev->soc;
  1553. struct rx_desc_pool *rx_desc_pool;
  1554. rx_desc_pool = &soc->rx_desc_mon[mac_id];
  1555. dp_debug("Mon RX Buf buffers Free pdev[%d]", pdev_id);
  1556. if (rx_desc_pool->rx_mon_dest_frag_enable)
  1557. dp_rx_desc_frag_free(soc, rx_desc_pool);
  1558. else
  1559. dp_rx_desc_nbuf_free(soc, rx_desc_pool);
  1560. }
  1561. static QDF_STATUS
  1562. dp_rx_pdev_mon_buf_desc_pool_alloc(struct dp_pdev *pdev, uint32_t mac_id)
  1563. {
  1564. uint8_t pdev_id = pdev->pdev_id;
  1565. struct dp_soc *soc = pdev->soc;
  1566. struct dp_srng *mon_buf_ring;
  1567. uint32_t num_entries;
  1568. struct rx_desc_pool *rx_desc_pool;
  1569. uint32_t rx_desc_pool_size;
  1570. struct wlan_cfg_dp_soc_ctxt *soc_cfg_ctx = soc->wlan_cfg_ctx;
  1571. mon_buf_ring = &soc->rxdma_mon_buf_ring[mac_id];
  1572. num_entries = mon_buf_ring->num_entries;
  1573. rx_desc_pool = &soc->rx_desc_mon[mac_id];
  1574. dp_debug("Mon RX Desc Pool[%d] entries=%u",
  1575. pdev_id, num_entries);
  1576. rx_desc_pool_size = wlan_cfg_get_dp_soc_rx_sw_desc_weight(soc_cfg_ctx) *
  1577. num_entries;
  1578. return dp_rx_desc_pool_alloc(soc, rx_desc_pool_size, rx_desc_pool);
  1579. }
  1580. static QDF_STATUS
  1581. dp_rx_pdev_mon_cmn_desc_pool_alloc(struct dp_pdev *pdev, int mac_id)
  1582. {
  1583. struct dp_soc *soc = pdev->soc;
  1584. uint8_t pdev_id = pdev->pdev_id;
  1585. uint32_t mac_for_pdev;
  1586. QDF_STATUS status;
  1587. mac_for_pdev = dp_get_lmac_id_for_pdev_id(soc, mac_id, pdev_id);
  1588. /* Allocate sw rx descriptor pool for monitor status ring */
  1589. status = dp_rx_pdev_mon_status_desc_pool_alloc(pdev, mac_for_pdev);
  1590. if (!QDF_IS_STATUS_SUCCESS(status)) {
  1591. dp_err("dp_rx_pdev_mon_status_desc_pool_alloc() failed");
  1592. goto fail;
  1593. }
  1594. if (!soc->wlan_cfg_ctx->rxdma1_enable)
  1595. return status;
  1596. /* Allocate sw rx descriptor pool for monitor RxDMA buffer ring */
  1597. status = dp_rx_pdev_mon_buf_desc_pool_alloc(pdev, mac_for_pdev);
  1598. if (!QDF_IS_STATUS_SUCCESS(status)) {
  1599. dp_err("dp_rx_pdev_mon_buf_desc_pool_alloc() failed");
  1600. goto mon_status_dealloc;
  1601. }
  1602. /* Allocate link descriptors for the monitor link descriptor ring */
  1603. status = dp_hw_link_desc_pool_banks_alloc(soc, mac_for_pdev);
  1604. if (!QDF_IS_STATUS_SUCCESS(status)) {
  1605. dp_err("dp_hw_link_desc_pool_banks_alloc() failed");
  1606. goto mon_buf_dealloc;
  1607. }
  1608. return status;
  1609. mon_buf_dealloc:
  1610. dp_rx_pdev_mon_buf_desc_pool_free(pdev, mac_for_pdev);
  1611. mon_status_dealloc:
  1612. dp_rx_pdev_mon_status_desc_pool_free(pdev, mac_for_pdev);
  1613. fail:
  1614. return status;
  1615. }
  1616. static void
  1617. dp_rx_pdev_mon_cmn_buffers_free(struct dp_pdev *pdev, int mac_id)
  1618. {
  1619. uint8_t pdev_id = pdev->pdev_id;
  1620. struct dp_soc *soc = pdev->soc;
  1621. int mac_for_pdev;
  1622. mac_for_pdev = dp_get_lmac_id_for_pdev_id(pdev->soc, mac_id, pdev_id);
  1623. dp_rx_pdev_mon_status_buffers_free(pdev, mac_for_pdev);
  1624. if (!soc->wlan_cfg_ctx->rxdma1_enable)
  1625. return;
  1626. dp_rx_pdev_mon_buf_buffers_free(pdev, mac_for_pdev);
  1627. }
  1628. QDF_STATUS
  1629. dp_rx_pdev_mon_desc_pool_alloc(struct dp_pdev *pdev)
  1630. {
  1631. QDF_STATUS status;
  1632. int mac_id, count;
  1633. for (mac_id = 0; mac_id < NUM_RXDMA_RINGS_PER_PDEV; mac_id++) {
  1634. status = dp_rx_pdev_mon_cmn_desc_pool_alloc(pdev, mac_id);
  1635. if (!QDF_IS_STATUS_SUCCESS(status)) {
  1636. dp_rx_mon_dest_err("%pK: %d failed\n",
  1637. pdev->soc, mac_id);
  1638. for (count = 0; count < mac_id; count++)
  1639. dp_rx_pdev_mon_cmn_desc_pool_free(pdev, count);
  1640. return status;
  1641. }
  1642. }
  1643. return status;
  1644. }
  1645. void
  1646. dp_rx_pdev_mon_desc_pool_init(struct dp_pdev *pdev)
  1647. {
  1648. int mac_id;
  1649. for (mac_id = 0; mac_id < NUM_RXDMA_RINGS_PER_PDEV; mac_id++)
  1650. dp_rx_pdev_mon_cmn_desc_pool_init(pdev, mac_id);
  1651. qdf_spinlock_create(&pdev->mon_lock);
  1652. }
  1653. void
  1654. dp_rx_pdev_mon_desc_pool_deinit(struct dp_pdev *pdev)
  1655. {
  1656. int mac_id;
  1657. for (mac_id = 0; mac_id < NUM_RXDMA_RINGS_PER_PDEV; mac_id++)
  1658. dp_rx_pdev_mon_cmn_desc_pool_deinit(pdev, mac_id);
  1659. qdf_spinlock_destroy(&pdev->mon_lock);
  1660. }
  1661. void dp_rx_pdev_mon_desc_pool_free(struct dp_pdev *pdev)
  1662. {
  1663. int mac_id;
  1664. for (mac_id = 0; mac_id < NUM_RXDMA_RINGS_PER_PDEV; mac_id++)
  1665. dp_rx_pdev_mon_cmn_desc_pool_free(pdev, mac_id);
  1666. }
  1667. void
  1668. dp_rx_pdev_mon_buffers_free(struct dp_pdev *pdev)
  1669. {
  1670. int mac_id;
  1671. for (mac_id = 0; mac_id < NUM_RXDMA_RINGS_PER_PDEV; mac_id++)
  1672. dp_rx_pdev_mon_cmn_buffers_free(pdev, mac_id);
  1673. }
  1674. QDF_STATUS
  1675. dp_rx_pdev_mon_buffers_alloc(struct dp_pdev *pdev)
  1676. {
  1677. int mac_id;
  1678. QDF_STATUS status;
  1679. for (mac_id = 0; mac_id < NUM_RXDMA_RINGS_PER_PDEV; mac_id++) {
  1680. status = dp_rx_pdev_mon_cmn_buffers_alloc(pdev, mac_id);
  1681. if (!QDF_IS_STATUS_SUCCESS(status)) {
  1682. dp_rx_mon_dest_err("%pK: %d failed\n",
  1683. pdev->soc, mac_id);
  1684. return status;
  1685. }
  1686. }
  1687. return status;
  1688. }
  1689. #if !defined(DISABLE_MON_CONFIG) && defined(MON_ENABLE_DROP_FOR_MAC)
  1690. uint32_t
  1691. dp_mon_dest_srng_drop_for_mac(struct dp_pdev *pdev, uint32_t mac_id)
  1692. {
  1693. struct dp_soc *soc = pdev->soc;
  1694. hal_rxdma_desc_t rxdma_dst_ring_desc;
  1695. hal_soc_handle_t hal_soc;
  1696. void *mon_dst_srng;
  1697. union dp_rx_desc_list_elem_t *head = NULL;
  1698. union dp_rx_desc_list_elem_t *tail = NULL;
  1699. uint32_t rx_bufs_used = 0;
  1700. void *rx_msdu_link_desc;
  1701. uint32_t msdu_count = 0;
  1702. uint16 num_msdus;
  1703. struct hal_buf_info buf_info;
  1704. struct hal_rx_msdu_list msdu_list;
  1705. qdf_nbuf_t nbuf;
  1706. uint32_t i;
  1707. uint8_t bm_action = HAL_BM_ACTION_PUT_IN_IDLE_LIST;
  1708. uint32_t rx_link_buf_info[HAL_RX_BUFFINFO_NUM_DWORDS];
  1709. struct rx_desc_pool *rx_desc_pool;
  1710. uint32_t reap_cnt = 0;
  1711. if (qdf_unlikely(!soc || !soc->hal_soc))
  1712. return reap_cnt;
  1713. mon_dst_srng = dp_rxdma_get_mon_dst_ring(pdev, mac_id);
  1714. if (qdf_unlikely(!mon_dst_srng || !hal_srng_initialized(mon_dst_srng)))
  1715. return reap_cnt;
  1716. hal_soc = soc->hal_soc;
  1717. qdf_spin_lock_bh(&pdev->mon_lock);
  1718. if (qdf_unlikely(hal_srng_access_start(hal_soc, mon_dst_srng))) {
  1719. qdf_spin_unlock_bh(&pdev->mon_lock);
  1720. return reap_cnt;
  1721. }
  1722. rx_desc_pool = dp_rx_get_mon_desc_pool(soc, mac_id, pdev->pdev_id);
  1723. while ((rxdma_dst_ring_desc =
  1724. hal_srng_dst_peek(hal_soc, mon_dst_srng)) &&
  1725. reap_cnt < MON_DROP_REAP_LIMIT) {
  1726. hal_rx_reo_ent_buf_paddr_get(rxdma_dst_ring_desc,
  1727. &buf_info, &msdu_count);
  1728. do {
  1729. rx_msdu_link_desc = dp_rx_cookie_2_mon_link_desc(pdev,
  1730. buf_info, mac_id);
  1731. if (qdf_unlikely(!rx_msdu_link_desc)) {
  1732. pdev->rx_mon_stats.mon_link_desc_invalid++;
  1733. goto next_entry;
  1734. }
  1735. hal_rx_msdu_list_get(soc->hal_soc, rx_msdu_link_desc,
  1736. &msdu_list, &num_msdus);
  1737. for (i = 0; i < num_msdus; i++) {
  1738. struct dp_rx_desc *rx_desc;
  1739. qdf_dma_addr_t buf_paddr;
  1740. rx_desc = dp_rx_get_mon_desc(soc,
  1741. msdu_list.sw_cookie[i]);
  1742. if (qdf_unlikely(!rx_desc)) {
  1743. pdev->rx_mon_stats.
  1744. mon_rx_desc_invalid++;
  1745. continue;
  1746. }
  1747. nbuf = DP_RX_MON_GET_NBUF_FROM_DESC(rx_desc);
  1748. buf_paddr =
  1749. dp_rx_mon_get_paddr_from_desc(rx_desc);
  1750. if (qdf_unlikely(!rx_desc->in_use || !nbuf ||
  1751. msdu_list.paddr[i] !=
  1752. buf_paddr)) {
  1753. pdev->rx_mon_stats.
  1754. mon_nbuf_sanity_err++;
  1755. continue;
  1756. }
  1757. rx_bufs_used++;
  1758. if (!rx_desc->unmapped) {
  1759. dp_rx_mon_buffer_unmap(soc, rx_desc,
  1760. rx_desc_pool->buf_size);
  1761. rx_desc->unmapped = 1;
  1762. }
  1763. qdf_nbuf_free(nbuf);
  1764. dp_rx_add_to_free_desc_list(&head, &tail,
  1765. rx_desc);
  1766. if (!(msdu_list.msdu_info[i].msdu_flags &
  1767. HAL_MSDU_F_MSDU_CONTINUATION))
  1768. msdu_count--;
  1769. }
  1770. /*
  1771. * Store the current link buffer into to the local
  1772. * structure to be used for release purpose.
  1773. */
  1774. hal_rxdma_buff_addr_info_set(rx_link_buf_info,
  1775. buf_info.paddr,
  1776. buf_info.sw_cookie,
  1777. buf_info.rbm);
  1778. hal_rx_mon_next_link_desc_get(rx_msdu_link_desc,
  1779. &buf_info);
  1780. if (dp_rx_monitor_link_desc_return(pdev,
  1781. (hal_buff_addrinfo_t)
  1782. rx_link_buf_info,
  1783. mac_id, bm_action) !=
  1784. QDF_STATUS_SUCCESS)
  1785. dp_info_rl("monitor link desc return failed");
  1786. } while (buf_info.paddr && msdu_count);
  1787. next_entry:
  1788. reap_cnt++;
  1789. rxdma_dst_ring_desc = hal_srng_dst_get_next(hal_soc,
  1790. mon_dst_srng);
  1791. }
  1792. hal_srng_access_end(hal_soc, mon_dst_srng);
  1793. qdf_spin_unlock_bh(&pdev->mon_lock);
  1794. if (rx_bufs_used) {
  1795. dp_rx_buffers_replenish(soc, mac_id,
  1796. dp_rxdma_get_mon_buf_ring(pdev, mac_id),
  1797. rx_desc_pool,
  1798. rx_bufs_used, &head, &tail);
  1799. }
  1800. return reap_cnt;
  1801. }
  1802. #endif