dp_htt.c 108 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858
  1. /*
  2. * Copyright (c) 2016-2021 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 <htt.h>
  19. #include <hal_hw_headers.h>
  20. #include <hal_api.h>
  21. #include "dp_peer.h"
  22. #include "dp_types.h"
  23. #include "dp_internal.h"
  24. #include "dp_rx.h"
  25. #include "htt_stats.h"
  26. #include "htt_ppdu_stats.h"
  27. #include "dp_htt.h"
  28. #ifdef WIFI_MONITOR_SUPPORT
  29. #include <dp_mon.h>
  30. #endif
  31. #include "qdf_mem.h" /* qdf_mem_malloc,free */
  32. #include "cdp_txrx_cmn_struct.h"
  33. #ifdef FEATURE_PERPKT_INFO
  34. #include "dp_ratetable.h"
  35. #endif
  36. #include <qdf_module.h>
  37. #define HTT_TLV_HDR_LEN HTT_T2H_EXT_STATS_CONF_TLV_HDR_SIZE
  38. #define HTT_HTC_PKT_POOL_INIT_SIZE 64
  39. #define HTT_MSG_BUF_SIZE(msg_bytes) \
  40. ((msg_bytes) + HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING)
  41. #define HTT_PID_BIT_MASK 0x3
  42. #define DP_EXT_MSG_LENGTH 2048
  43. #define HTT_HEADER_LEN 16
  44. #define HTT_MGMT_CTRL_TLV_HDR_RESERVERD_LEN 16
  45. #define HTT_SHIFT_UPPER_TIMESTAMP 32
  46. #define HTT_MASK_UPPER_TIMESTAMP 0xFFFFFFFF00000000
  47. #define HTT_HTC_PKT_STATUS_SUCCESS \
  48. ((pkt->htc_pkt.Status != QDF_STATUS_E_CANCELED) && \
  49. (pkt->htc_pkt.Status != QDF_STATUS_E_RESOURCES))
  50. /*
  51. * htt_htc_pkt_alloc() - Allocate HTC packet buffer
  52. * @htt_soc: HTT SOC handle
  53. *
  54. * Return: Pointer to htc packet buffer
  55. */
  56. static struct dp_htt_htc_pkt *
  57. htt_htc_pkt_alloc(struct htt_soc *soc)
  58. {
  59. struct dp_htt_htc_pkt_union *pkt = NULL;
  60. HTT_TX_MUTEX_ACQUIRE(&soc->htt_tx_mutex);
  61. if (soc->htt_htc_pkt_freelist) {
  62. pkt = soc->htt_htc_pkt_freelist;
  63. soc->htt_htc_pkt_freelist = soc->htt_htc_pkt_freelist->u.next;
  64. }
  65. HTT_TX_MUTEX_RELEASE(&soc->htt_tx_mutex);
  66. if (!pkt)
  67. pkt = qdf_mem_malloc(sizeof(*pkt));
  68. if (!pkt)
  69. return NULL;
  70. htc_packet_set_magic_cookie(&(pkt->u.pkt.htc_pkt), 0);
  71. return &pkt->u.pkt; /* not actually a dereference */
  72. }
  73. /*
  74. * htt_htc_pkt_free() - Free HTC packet buffer
  75. * @htt_soc: HTT SOC handle
  76. */
  77. static void
  78. htt_htc_pkt_free(struct htt_soc *soc, struct dp_htt_htc_pkt *pkt)
  79. {
  80. struct dp_htt_htc_pkt_union *u_pkt =
  81. (struct dp_htt_htc_pkt_union *)pkt;
  82. HTT_TX_MUTEX_ACQUIRE(&soc->htt_tx_mutex);
  83. htc_packet_set_magic_cookie(&(u_pkt->u.pkt.htc_pkt), 0);
  84. u_pkt->u.next = soc->htt_htc_pkt_freelist;
  85. soc->htt_htc_pkt_freelist = u_pkt;
  86. HTT_TX_MUTEX_RELEASE(&soc->htt_tx_mutex);
  87. }
  88. /*
  89. * htt_htc_pkt_pool_free() - Free HTC packet pool
  90. * @htt_soc: HTT SOC handle
  91. */
  92. void
  93. htt_htc_pkt_pool_free(struct htt_soc *soc)
  94. {
  95. struct dp_htt_htc_pkt_union *pkt, *next;
  96. pkt = soc->htt_htc_pkt_freelist;
  97. while (pkt) {
  98. next = pkt->u.next;
  99. qdf_mem_free(pkt);
  100. pkt = next;
  101. }
  102. soc->htt_htc_pkt_freelist = NULL;
  103. }
  104. #ifdef ENABLE_CE4_COMP_DISABLE_HTT_HTC_MISC_LIST
  105. static void
  106. htt_htc_misc_pkt_list_add(struct htt_soc *soc, struct dp_htt_htc_pkt *pkt)
  107. {
  108. }
  109. #else /* ENABLE_CE4_COMP_DISABLE_HTT_HTC_MISC_LIST */
  110. /*
  111. * htt_htc_misc_pkt_list_trim() - trim misc list
  112. * @htt_soc: HTT SOC handle
  113. * @level: max no. of pkts in list
  114. */
  115. static void
  116. htt_htc_misc_pkt_list_trim(struct htt_soc *soc, int level)
  117. {
  118. struct dp_htt_htc_pkt_union *pkt, *next, *prev = NULL;
  119. int i = 0;
  120. qdf_nbuf_t netbuf;
  121. HTT_TX_MUTEX_ACQUIRE(&soc->htt_tx_mutex);
  122. pkt = soc->htt_htc_pkt_misclist;
  123. while (pkt) {
  124. next = pkt->u.next;
  125. /* trim the out grown list*/
  126. if (++i > level) {
  127. netbuf =
  128. (qdf_nbuf_t)(pkt->u.pkt.htc_pkt.pNetBufContext);
  129. qdf_nbuf_unmap(soc->osdev, netbuf, QDF_DMA_TO_DEVICE);
  130. qdf_nbuf_free(netbuf);
  131. qdf_mem_free(pkt);
  132. pkt = NULL;
  133. if (prev)
  134. prev->u.next = NULL;
  135. }
  136. prev = pkt;
  137. pkt = next;
  138. }
  139. HTT_TX_MUTEX_RELEASE(&soc->htt_tx_mutex);
  140. }
  141. /*
  142. * htt_htc_misc_pkt_list_add() - Add pkt to misc list
  143. * @htt_soc: HTT SOC handle
  144. * @dp_htt_htc_pkt: pkt to be added to list
  145. */
  146. static void
  147. htt_htc_misc_pkt_list_add(struct htt_soc *soc, struct dp_htt_htc_pkt *pkt)
  148. {
  149. struct dp_htt_htc_pkt_union *u_pkt =
  150. (struct dp_htt_htc_pkt_union *)pkt;
  151. int misclist_trim_level = htc_get_tx_queue_depth(soc->htc_soc,
  152. pkt->htc_pkt.Endpoint)
  153. + DP_HTT_HTC_PKT_MISCLIST_SIZE;
  154. HTT_TX_MUTEX_ACQUIRE(&soc->htt_tx_mutex);
  155. if (soc->htt_htc_pkt_misclist) {
  156. u_pkt->u.next = soc->htt_htc_pkt_misclist;
  157. soc->htt_htc_pkt_misclist = u_pkt;
  158. } else {
  159. soc->htt_htc_pkt_misclist = u_pkt;
  160. }
  161. HTT_TX_MUTEX_RELEASE(&soc->htt_tx_mutex);
  162. /* only ce pipe size + tx_queue_depth could possibly be in use
  163. * free older packets in the misclist
  164. */
  165. htt_htc_misc_pkt_list_trim(soc, misclist_trim_level);
  166. }
  167. #endif /* ENABLE_CE4_COMP_DISABLE_HTT_HTC_MISC_LIST */
  168. /**
  169. * DP_HTT_SEND_HTC_PKT() - Send htt packet from host
  170. * @soc : HTT SOC handle
  171. * @pkt: pkt to be send
  172. * @cmd : command to be recorded in dp htt logger
  173. * @buf : Pointer to buffer needs to be recored for above cmd
  174. *
  175. * Return: None
  176. */
  177. static inline QDF_STATUS DP_HTT_SEND_HTC_PKT(struct htt_soc *soc,
  178. struct dp_htt_htc_pkt *pkt,
  179. uint8_t cmd, uint8_t *buf)
  180. {
  181. QDF_STATUS status;
  182. htt_command_record(soc->htt_logger_handle, cmd, buf);
  183. status = htc_send_pkt(soc->htc_soc, &pkt->htc_pkt);
  184. if (status == QDF_STATUS_SUCCESS && HTT_HTC_PKT_STATUS_SUCCESS)
  185. htt_htc_misc_pkt_list_add(soc, pkt);
  186. else
  187. soc->stats.fail_count++;
  188. return status;
  189. }
  190. /*
  191. * htt_htc_misc_pkt_pool_free() - free pkts in misc list
  192. * @htt_soc: HTT SOC handle
  193. */
  194. static void
  195. htt_htc_misc_pkt_pool_free(struct htt_soc *soc)
  196. {
  197. struct dp_htt_htc_pkt_union *pkt, *next;
  198. qdf_nbuf_t netbuf;
  199. HTT_TX_MUTEX_ACQUIRE(&soc->htt_tx_mutex);
  200. pkt = soc->htt_htc_pkt_misclist;
  201. while (pkt) {
  202. next = pkt->u.next;
  203. if (htc_packet_get_magic_cookie(&(pkt->u.pkt.htc_pkt)) !=
  204. HTC_PACKET_MAGIC_COOKIE) {
  205. pkt = next;
  206. soc->stats.skip_count++;
  207. continue;
  208. }
  209. netbuf = (qdf_nbuf_t) (pkt->u.pkt.htc_pkt.pNetBufContext);
  210. qdf_nbuf_unmap(soc->osdev, netbuf, QDF_DMA_TO_DEVICE);
  211. soc->stats.htc_pkt_free++;
  212. dp_htt_info("%pK: Pkt free count %d",
  213. soc->dp_soc, soc->stats.htc_pkt_free);
  214. qdf_nbuf_free(netbuf);
  215. qdf_mem_free(pkt);
  216. pkt = next;
  217. }
  218. soc->htt_htc_pkt_misclist = NULL;
  219. HTT_TX_MUTEX_RELEASE(&soc->htt_tx_mutex);
  220. dp_info("HTC Packets, fail count = %d, skip count = %d",
  221. soc->stats.fail_count, soc->stats.skip_count);
  222. }
  223. /*
  224. * htt_t2h_mac_addr_deswizzle() - Swap MAC addr bytes if FW endianness differ
  225. * @tgt_mac_addr: Target MAC
  226. * @buffer: Output buffer
  227. */
  228. static u_int8_t *
  229. htt_t2h_mac_addr_deswizzle(u_int8_t *tgt_mac_addr, u_int8_t *buffer)
  230. {
  231. #ifdef BIG_ENDIAN_HOST
  232. /*
  233. * The host endianness is opposite of the target endianness.
  234. * To make u_int32_t elements come out correctly, the target->host
  235. * upload has swizzled the bytes in each u_int32_t element of the
  236. * message.
  237. * For byte-array message fields like the MAC address, this
  238. * upload swizzling puts the bytes in the wrong order, and needs
  239. * to be undone.
  240. */
  241. buffer[0] = tgt_mac_addr[3];
  242. buffer[1] = tgt_mac_addr[2];
  243. buffer[2] = tgt_mac_addr[1];
  244. buffer[3] = tgt_mac_addr[0];
  245. buffer[4] = tgt_mac_addr[7];
  246. buffer[5] = tgt_mac_addr[6];
  247. return buffer;
  248. #else
  249. /*
  250. * The host endianness matches the target endianness -
  251. * we can use the mac addr directly from the message buffer.
  252. */
  253. return tgt_mac_addr;
  254. #endif
  255. }
  256. /*
  257. * dp_htt_h2t_send_complete_free_netbuf() - Free completed buffer
  258. * @soc: SOC handle
  259. * @status: Completion status
  260. * @netbuf: HTT buffer
  261. */
  262. static void
  263. dp_htt_h2t_send_complete_free_netbuf(
  264. void *soc, A_STATUS status, qdf_nbuf_t netbuf)
  265. {
  266. qdf_nbuf_free(netbuf);
  267. }
  268. #ifdef ENABLE_CE4_COMP_DISABLE_HTT_HTC_MISC_LIST
  269. /*
  270. * dp_htt_h2t_send_complete() - H2T completion handler
  271. * @context: Opaque context (HTT SOC handle)
  272. * @htc_pkt: HTC packet
  273. */
  274. static void
  275. dp_htt_h2t_send_complete(void *context, HTC_PACKET *htc_pkt)
  276. {
  277. struct htt_soc *soc = (struct htt_soc *) context;
  278. struct dp_htt_htc_pkt *htt_pkt;
  279. qdf_nbuf_t netbuf;
  280. htt_pkt = container_of(htc_pkt, struct dp_htt_htc_pkt, htc_pkt);
  281. /* process (free or keep) the netbuf that held the message */
  282. netbuf = (qdf_nbuf_t) htc_pkt->pNetBufContext;
  283. /*
  284. * adf sendcomplete is required for windows only
  285. */
  286. /* qdf_nbuf_set_sendcompleteflag(netbuf, TRUE); */
  287. /* free the htt_htc_pkt / HTC_PACKET object */
  288. qdf_nbuf_free(netbuf);
  289. htt_htc_pkt_free(soc, htt_pkt);
  290. }
  291. #else /* ENABLE_CE4_COMP_DISABLE_HTT_HTC_MISC_LIST */
  292. /*
  293. * * dp_htt_h2t_send_complete() - H2T completion handler
  294. * * @context: Opaque context (HTT SOC handle)
  295. * * @htc_pkt: HTC packet
  296. * */
  297. static void
  298. dp_htt_h2t_send_complete(void *context, HTC_PACKET *htc_pkt)
  299. {
  300. void (*send_complete_part2)(
  301. void *soc, QDF_STATUS status, qdf_nbuf_t msdu);
  302. struct htt_soc *soc = (struct htt_soc *) context;
  303. struct dp_htt_htc_pkt *htt_pkt;
  304. qdf_nbuf_t netbuf;
  305. send_complete_part2 = htc_pkt->pPktContext;
  306. htt_pkt = container_of(htc_pkt, struct dp_htt_htc_pkt, htc_pkt);
  307. /* process (free or keep) the netbuf that held the message */
  308. netbuf = (qdf_nbuf_t) htc_pkt->pNetBufContext;
  309. /*
  310. * adf sendcomplete is required for windows only
  311. */
  312. /* qdf_nbuf_set_sendcompleteflag(netbuf, TRUE); */
  313. if (send_complete_part2){
  314. send_complete_part2(
  315. htt_pkt->soc_ctxt, htc_pkt->Status, netbuf);
  316. }
  317. /* free the htt_htc_pkt / HTC_PACKET object */
  318. htt_htc_pkt_free(soc, htt_pkt);
  319. }
  320. #endif /* ENABLE_CE4_COMP_DISABLE_HTT_HTC_MISC_LIST */
  321. /*
  322. * htt_h2t_ver_req_msg() - Send HTT version request message to target
  323. * @htt_soc: HTT SOC handle
  324. *
  325. * Return: 0 on success; error code on failure
  326. */
  327. static int htt_h2t_ver_req_msg(struct htt_soc *soc)
  328. {
  329. struct dp_htt_htc_pkt *pkt;
  330. qdf_nbuf_t msg;
  331. uint32_t *msg_word;
  332. QDF_STATUS status;
  333. msg = qdf_nbuf_alloc(
  334. soc->osdev,
  335. HTT_MSG_BUF_SIZE(HTT_VER_REQ_BYTES),
  336. /* reserve room for the HTC header */
  337. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, TRUE);
  338. if (!msg)
  339. return QDF_STATUS_E_NOMEM;
  340. /*
  341. * Set the length of the message.
  342. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  343. * separately during the below call to qdf_nbuf_push_head.
  344. * The contribution from the HTC header is added separately inside HTC.
  345. */
  346. if (qdf_nbuf_put_tail(msg, HTT_VER_REQ_BYTES) == NULL) {
  347. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  348. "%s: Failed to expand head for HTT_H2T_MSG_TYPE_VERSION_REQ msg",
  349. __func__);
  350. return QDF_STATUS_E_FAILURE;
  351. }
  352. /* fill in the message contents */
  353. msg_word = (u_int32_t *) qdf_nbuf_data(msg);
  354. /* rewind beyond alignment pad to get to the HTC header reserved area */
  355. qdf_nbuf_push_head(msg, HTC_HDR_ALIGNMENT_PADDING);
  356. *msg_word = 0;
  357. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_VERSION_REQ);
  358. pkt = htt_htc_pkt_alloc(soc);
  359. if (!pkt) {
  360. qdf_nbuf_free(msg);
  361. return QDF_STATUS_E_FAILURE;
  362. }
  363. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  364. SET_HTC_PACKET_INFO_TX(&pkt->htc_pkt,
  365. dp_htt_h2t_send_complete_free_netbuf, qdf_nbuf_data(msg),
  366. qdf_nbuf_len(msg), soc->htc_endpoint,
  367. HTC_TX_PACKET_TAG_RTPM_PUT_RC);
  368. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, msg);
  369. status = DP_HTT_SEND_HTC_PKT(soc, pkt, HTT_H2T_MSG_TYPE_VERSION_REQ,
  370. NULL);
  371. if (status != QDF_STATUS_SUCCESS) {
  372. qdf_nbuf_free(msg);
  373. htt_htc_pkt_free(soc, pkt);
  374. }
  375. return status;
  376. }
  377. /*
  378. * htt_srng_setup() - Send SRNG setup message to target
  379. * @htt_soc: HTT SOC handle
  380. * @mac_id: MAC Id
  381. * @hal_srng: Opaque HAL SRNG pointer
  382. * @hal_ring_type: SRNG ring type
  383. *
  384. * Return: 0 on success; error code on failure
  385. */
  386. int htt_srng_setup(struct htt_soc *soc, int mac_id,
  387. hal_ring_handle_t hal_ring_hdl,
  388. int hal_ring_type)
  389. {
  390. struct dp_htt_htc_pkt *pkt;
  391. qdf_nbuf_t htt_msg;
  392. uint32_t *msg_word;
  393. struct hal_srng_params srng_params;
  394. qdf_dma_addr_t hp_addr, tp_addr;
  395. uint32_t ring_entry_size =
  396. hal_srng_get_entrysize(soc->hal_soc, hal_ring_type);
  397. int htt_ring_type, htt_ring_id;
  398. uint8_t *htt_logger_bufp;
  399. int target_pdev_id;
  400. int lmac_id = dp_get_lmac_id_for_pdev_id(soc->dp_soc, 0, mac_id);
  401. QDF_STATUS status;
  402. /* Sizes should be set in 4-byte words */
  403. ring_entry_size = ring_entry_size >> 2;
  404. htt_msg = qdf_nbuf_alloc(soc->osdev,
  405. HTT_MSG_BUF_SIZE(HTT_SRING_SETUP_SZ),
  406. /* reserve room for the HTC header */
  407. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, TRUE);
  408. if (!htt_msg)
  409. goto fail0;
  410. hal_get_srng_params(soc->hal_soc, hal_ring_hdl, &srng_params);
  411. hp_addr = hal_srng_get_hp_addr(soc->hal_soc, hal_ring_hdl);
  412. tp_addr = hal_srng_get_tp_addr(soc->hal_soc, hal_ring_hdl);
  413. switch (hal_ring_type) {
  414. case RXDMA_BUF:
  415. #ifdef QCA_HOST2FW_RXBUF_RING
  416. if (srng_params.ring_id ==
  417. (HAL_SRNG_WMAC1_SW2RXDMA0_BUF0)) {
  418. htt_ring_id = HTT_HOST1_TO_FW_RXBUF_RING;
  419. htt_ring_type = HTT_SW_TO_SW_RING;
  420. #ifdef IPA_OFFLOAD
  421. } else if (srng_params.ring_id ==
  422. (HAL_SRNG_WMAC1_SW2RXDMA0_BUF2)) {
  423. htt_ring_id = HTT_HOST2_TO_FW_RXBUF_RING;
  424. htt_ring_type = HTT_SW_TO_SW_RING;
  425. #endif
  426. #else
  427. if (srng_params.ring_id ==
  428. (HAL_SRNG_WMAC1_SW2RXDMA0_BUF0 +
  429. (lmac_id * HAL_MAX_RINGS_PER_LMAC))) {
  430. htt_ring_id = HTT_RXDMA_HOST_BUF_RING;
  431. htt_ring_type = HTT_SW_TO_HW_RING;
  432. #endif
  433. } else if (srng_params.ring_id ==
  434. #ifdef IPA_OFFLOAD
  435. (HAL_SRNG_WMAC1_SW2RXDMA0_BUF1 +
  436. #else
  437. (HAL_SRNG_WMAC1_SW2RXDMA1_BUF +
  438. #endif
  439. (lmac_id * HAL_MAX_RINGS_PER_LMAC))) {
  440. htt_ring_id = HTT_RXDMA_HOST_BUF_RING;
  441. htt_ring_type = HTT_SW_TO_HW_RING;
  442. } else {
  443. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  444. "%s: Ring %d currently not supported",
  445. __func__, srng_params.ring_id);
  446. goto fail1;
  447. }
  448. dp_info("ring_type %d ring_id %d htt_ring_id %d hp_addr 0x%llx tp_addr 0x%llx",
  449. hal_ring_type, srng_params.ring_id, htt_ring_id,
  450. (uint64_t)hp_addr,
  451. (uint64_t)tp_addr);
  452. break;
  453. case RXDMA_MONITOR_BUF:
  454. htt_ring_id = HTT_RXDMA_MONITOR_BUF_RING;
  455. htt_ring_type = HTT_SW_TO_HW_RING;
  456. break;
  457. case RXDMA_MONITOR_STATUS:
  458. htt_ring_id = HTT_RXDMA_MONITOR_STATUS_RING;
  459. htt_ring_type = HTT_SW_TO_HW_RING;
  460. break;
  461. case RXDMA_MONITOR_DST:
  462. htt_ring_id = HTT_RXDMA_MONITOR_DEST_RING;
  463. htt_ring_type = HTT_HW_TO_SW_RING;
  464. break;
  465. case RXDMA_MONITOR_DESC:
  466. htt_ring_id = HTT_RXDMA_MONITOR_DESC_RING;
  467. htt_ring_type = HTT_SW_TO_HW_RING;
  468. break;
  469. case RXDMA_DST:
  470. htt_ring_id = HTT_RXDMA_NON_MONITOR_DEST_RING;
  471. htt_ring_type = HTT_HW_TO_SW_RING;
  472. break;
  473. default:
  474. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  475. "%s: Ring currently not supported", __func__);
  476. goto fail1;
  477. }
  478. /*
  479. * Set the length of the message.
  480. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  481. * separately during the below call to qdf_nbuf_push_head.
  482. * The contribution from the HTC header is added separately inside HTC.
  483. */
  484. if (qdf_nbuf_put_tail(htt_msg, HTT_SRING_SETUP_SZ) == NULL) {
  485. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  486. "%s: Failed to expand head for SRING_SETUP msg",
  487. __func__);
  488. return QDF_STATUS_E_FAILURE;
  489. }
  490. msg_word = (uint32_t *)qdf_nbuf_data(htt_msg);
  491. /* rewind beyond alignment pad to get to the HTC header reserved area */
  492. qdf_nbuf_push_head(htt_msg, HTC_HDR_ALIGNMENT_PADDING);
  493. /* word 0 */
  494. *msg_word = 0;
  495. htt_logger_bufp = (uint8_t *)msg_word;
  496. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_SRING_SETUP);
  497. target_pdev_id =
  498. dp_get_target_pdev_id_for_host_pdev_id(soc->dp_soc, mac_id);
  499. if ((htt_ring_type == HTT_SW_TO_HW_RING) ||
  500. (htt_ring_type == HTT_HW_TO_SW_RING))
  501. HTT_SRING_SETUP_PDEV_ID_SET(*msg_word, target_pdev_id);
  502. else
  503. HTT_SRING_SETUP_PDEV_ID_SET(*msg_word, mac_id);
  504. dp_info("mac_id %d", mac_id);
  505. HTT_SRING_SETUP_RING_TYPE_SET(*msg_word, htt_ring_type);
  506. /* TODO: Discuss with FW on changing this to unique ID and using
  507. * htt_ring_type to send the type of ring
  508. */
  509. HTT_SRING_SETUP_RING_ID_SET(*msg_word, htt_ring_id);
  510. /* word 1 */
  511. msg_word++;
  512. *msg_word = 0;
  513. HTT_SRING_SETUP_RING_BASE_ADDR_LO_SET(*msg_word,
  514. srng_params.ring_base_paddr & 0xffffffff);
  515. /* word 2 */
  516. msg_word++;
  517. *msg_word = 0;
  518. HTT_SRING_SETUP_RING_BASE_ADDR_HI_SET(*msg_word,
  519. (uint64_t)srng_params.ring_base_paddr >> 32);
  520. /* word 3 */
  521. msg_word++;
  522. *msg_word = 0;
  523. HTT_SRING_SETUP_ENTRY_SIZE_SET(*msg_word, ring_entry_size);
  524. HTT_SRING_SETUP_RING_SIZE_SET(*msg_word,
  525. (ring_entry_size * srng_params.num_entries));
  526. dp_info("entry_size %d", ring_entry_size);
  527. dp_info("num_entries %d", srng_params.num_entries);
  528. dp_info("ring_size %d", (ring_entry_size * srng_params.num_entries));
  529. if (htt_ring_type == HTT_SW_TO_HW_RING)
  530. HTT_SRING_SETUP_RING_MISC_CFG_FLAG_LOOPCOUNT_DISABLE_SET(
  531. *msg_word, 1);
  532. HTT_SRING_SETUP_RING_MISC_CFG_FLAG_MSI_SWAP_SET(*msg_word,
  533. !!(srng_params.flags & HAL_SRNG_MSI_SWAP));
  534. HTT_SRING_SETUP_RING_MISC_CFG_FLAG_TLV_SWAP_SET(*msg_word,
  535. !!(srng_params.flags & HAL_SRNG_DATA_TLV_SWAP));
  536. HTT_SRING_SETUP_RING_MISC_CFG_FLAG_HOST_FW_SWAP_SET(*msg_word,
  537. !!(srng_params.flags & HAL_SRNG_RING_PTR_SWAP));
  538. /* word 4 */
  539. msg_word++;
  540. *msg_word = 0;
  541. HTT_SRING_SETUP_HEAD_OFFSET32_REMOTE_BASE_ADDR_LO_SET(*msg_word,
  542. hp_addr & 0xffffffff);
  543. /* word 5 */
  544. msg_word++;
  545. *msg_word = 0;
  546. HTT_SRING_SETUP_HEAD_OFFSET32_REMOTE_BASE_ADDR_HI_SET(*msg_word,
  547. (uint64_t)hp_addr >> 32);
  548. /* word 6 */
  549. msg_word++;
  550. *msg_word = 0;
  551. HTT_SRING_SETUP_TAIL_OFFSET32_REMOTE_BASE_ADDR_LO_SET(*msg_word,
  552. tp_addr & 0xffffffff);
  553. /* word 7 */
  554. msg_word++;
  555. *msg_word = 0;
  556. HTT_SRING_SETUP_TAIL_OFFSET32_REMOTE_BASE_ADDR_HI_SET(*msg_word,
  557. (uint64_t)tp_addr >> 32);
  558. /* word 8 */
  559. msg_word++;
  560. *msg_word = 0;
  561. HTT_SRING_SETUP_RING_MSI_ADDR_LO_SET(*msg_word,
  562. srng_params.msi_addr & 0xffffffff);
  563. /* word 9 */
  564. msg_word++;
  565. *msg_word = 0;
  566. HTT_SRING_SETUP_RING_MSI_ADDR_HI_SET(*msg_word,
  567. (uint64_t)(srng_params.msi_addr) >> 32);
  568. /* word 10 */
  569. msg_word++;
  570. *msg_word = 0;
  571. HTT_SRING_SETUP_RING_MSI_DATA_SET(*msg_word,
  572. qdf_cpu_to_le32(srng_params.msi_data));
  573. /* word 11 */
  574. msg_word++;
  575. *msg_word = 0;
  576. HTT_SRING_SETUP_INTR_BATCH_COUNTER_TH_SET(*msg_word,
  577. srng_params.intr_batch_cntr_thres_entries *
  578. ring_entry_size);
  579. HTT_SRING_SETUP_INTR_TIMER_TH_SET(*msg_word,
  580. srng_params.intr_timer_thres_us >> 3);
  581. /* word 12 */
  582. msg_word++;
  583. *msg_word = 0;
  584. if (srng_params.flags & HAL_SRNG_LOW_THRES_INTR_ENABLE) {
  585. /* TODO: Setting low threshold to 1/8th of ring size - see
  586. * if this needs to be configurable
  587. */
  588. HTT_SRING_SETUP_INTR_LOW_TH_SET(*msg_word,
  589. srng_params.low_threshold);
  590. }
  591. /* "response_required" field should be set if a HTT response message is
  592. * required after setting up the ring.
  593. */
  594. pkt = htt_htc_pkt_alloc(soc);
  595. if (!pkt)
  596. goto fail1;
  597. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  598. SET_HTC_PACKET_INFO_TX(
  599. &pkt->htc_pkt,
  600. dp_htt_h2t_send_complete_free_netbuf,
  601. qdf_nbuf_data(htt_msg),
  602. qdf_nbuf_len(htt_msg),
  603. soc->htc_endpoint,
  604. HTC_TX_PACKET_TAG_RUNTIME_PUT); /* tag for no FW response msg */
  605. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, htt_msg);
  606. status = DP_HTT_SEND_HTC_PKT(soc, pkt, HTT_H2T_MSG_TYPE_SRING_SETUP,
  607. htt_logger_bufp);
  608. if (status != QDF_STATUS_SUCCESS) {
  609. qdf_nbuf_free(htt_msg);
  610. htt_htc_pkt_free(soc, pkt);
  611. }
  612. return status;
  613. fail1:
  614. qdf_nbuf_free(htt_msg);
  615. fail0:
  616. return QDF_STATUS_E_FAILURE;
  617. }
  618. qdf_export_symbol(htt_srng_setup);
  619. #ifdef QCA_SUPPORT_FULL_MON
  620. /**
  621. * htt_h2t_full_mon_cfg() - Send full monitor configuarion msg to FW
  622. *
  623. * @htt_soc: HTT Soc handle
  624. * @pdev_id: Radio id
  625. * @dp_full_mon_config: enabled/disable configuration
  626. *
  627. * Return: Success when HTT message is sent, error on failure
  628. */
  629. int htt_h2t_full_mon_cfg(struct htt_soc *htt_soc,
  630. uint8_t pdev_id,
  631. enum dp_full_mon_config config)
  632. {
  633. struct htt_soc *soc = (struct htt_soc *)htt_soc;
  634. struct dp_htt_htc_pkt *pkt;
  635. qdf_nbuf_t htt_msg;
  636. uint32_t *msg_word;
  637. uint8_t *htt_logger_bufp;
  638. htt_msg = qdf_nbuf_alloc(soc->osdev,
  639. HTT_MSG_BUF_SIZE(
  640. HTT_RX_FULL_MONITOR_MODE_SETUP_SZ),
  641. /* reserve room for the HTC header */
  642. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING,
  643. 4,
  644. TRUE);
  645. if (!htt_msg)
  646. return QDF_STATUS_E_FAILURE;
  647. /*
  648. * Set the length of the message.
  649. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  650. * separately during the below call to qdf_nbuf_push_head.
  651. * The contribution from the HTC header is added separately inside HTC.
  652. */
  653. if (!qdf_nbuf_put_tail(htt_msg, HTT_RX_RING_SELECTION_CFG_SZ)) {
  654. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  655. "%s: Failed to expand head for RX Ring Cfg msg",
  656. __func__);
  657. goto fail1;
  658. }
  659. msg_word = (uint32_t *)qdf_nbuf_data(htt_msg);
  660. /* rewind beyond alignment pad to get to the HTC header reserved area */
  661. qdf_nbuf_push_head(htt_msg, HTC_HDR_ALIGNMENT_PADDING);
  662. /* word 0 */
  663. *msg_word = 0;
  664. htt_logger_bufp = (uint8_t *)msg_word;
  665. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_RX_FULL_MONITOR_MODE);
  666. HTT_RX_FULL_MONITOR_MODE_OPERATION_PDEV_ID_SET(
  667. *msg_word, DP_SW2HW_MACID(pdev_id));
  668. msg_word++;
  669. *msg_word = 0;
  670. /* word 1 */
  671. if (config == DP_FULL_MON_ENABLE) {
  672. HTT_RX_FULL_MONITOR_MODE_ENABLE_SET(*msg_word, true);
  673. HTT_RX_FULL_MONITOR_MODE_ZERO_MPDU_SET(*msg_word, true);
  674. HTT_RX_FULL_MONITOR_MODE_NON_ZERO_MPDU_SET(*msg_word, true);
  675. HTT_RX_FULL_MONITOR_MODE_RELEASE_RINGS_SET(*msg_word, 0x2);
  676. } else if (config == DP_FULL_MON_DISABLE) {
  677. /* As per MAC team's suggestion, While disbaling full monitor
  678. * mode, Set 'en' bit to true in full monitor mode register.
  679. */
  680. HTT_RX_FULL_MONITOR_MODE_ENABLE_SET(*msg_word, true);
  681. HTT_RX_FULL_MONITOR_MODE_ZERO_MPDU_SET(*msg_word, false);
  682. HTT_RX_FULL_MONITOR_MODE_NON_ZERO_MPDU_SET(*msg_word, false);
  683. HTT_RX_FULL_MONITOR_MODE_RELEASE_RINGS_SET(*msg_word, 0x2);
  684. }
  685. pkt = htt_htc_pkt_alloc(soc);
  686. if (!pkt) {
  687. qdf_err("HTC packet allocation failed");
  688. goto fail1;
  689. }
  690. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  691. SET_HTC_PACKET_INFO_TX(
  692. &pkt->htc_pkt,
  693. dp_htt_h2t_send_complete_free_netbuf,
  694. qdf_nbuf_data(htt_msg),
  695. qdf_nbuf_len(htt_msg),
  696. soc->htc_endpoint,
  697. HTC_TX_PACKET_TAG_RUNTIME_PUT); /* tag for no FW response msg */
  698. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, htt_msg);
  699. qdf_debug("config: %d", config);
  700. DP_HTT_SEND_HTC_PKT(soc, pkt, HTT_H2T_MSG_TYPE_SRING_SETUP,
  701. htt_logger_bufp);
  702. return QDF_STATUS_SUCCESS;
  703. fail1:
  704. qdf_nbuf_free(htt_msg);
  705. return QDF_STATUS_E_FAILURE;
  706. }
  707. qdf_export_symbol(htt_h2t_full_mon_cfg);
  708. #else
  709. int htt_h2t_full_mon_cfg(struct htt_soc *htt_soc,
  710. uint8_t pdev_id,
  711. enum dp_full_mon_config config)
  712. {
  713. return 0;
  714. }
  715. qdf_export_symbol(htt_h2t_full_mon_cfg);
  716. #endif
  717. /*
  718. * htt_h2t_rx_ring_cfg() - Send SRNG packet and TLV filter
  719. * config message to target
  720. * @htt_soc: HTT SOC handle
  721. * @pdev_id: WIN- PDEV Id, MCL- mac id
  722. * @hal_srng: Opaque HAL SRNG pointer
  723. * @hal_ring_type: SRNG ring type
  724. * @ring_buf_size: SRNG buffer size
  725. * @htt_tlv_filter: Rx SRNG TLV and filter setting
  726. * Return: 0 on success; error code on failure
  727. */
  728. int htt_h2t_rx_ring_cfg(struct htt_soc *htt_soc, int pdev_id,
  729. hal_ring_handle_t hal_ring_hdl,
  730. int hal_ring_type, int ring_buf_size,
  731. struct htt_rx_ring_tlv_filter *htt_tlv_filter)
  732. {
  733. struct htt_soc *soc = (struct htt_soc *)htt_soc;
  734. struct dp_htt_htc_pkt *pkt;
  735. qdf_nbuf_t htt_msg;
  736. uint32_t *msg_word;
  737. struct hal_srng_params srng_params;
  738. uint32_t htt_ring_type, htt_ring_id;
  739. uint32_t tlv_filter;
  740. uint8_t *htt_logger_bufp;
  741. struct wlan_cfg_dp_soc_ctxt *wlan_cfg_ctx = soc->dp_soc->wlan_cfg_ctx;
  742. uint32_t mon_drop_th = wlan_cfg_get_mon_drop_thresh(wlan_cfg_ctx);
  743. int target_pdev_id;
  744. QDF_STATUS status;
  745. htt_msg = qdf_nbuf_alloc(soc->osdev,
  746. HTT_MSG_BUF_SIZE(HTT_RX_RING_SELECTION_CFG_SZ),
  747. /* reserve room for the HTC header */
  748. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, TRUE);
  749. if (!htt_msg)
  750. goto fail0;
  751. hal_get_srng_params(soc->hal_soc, hal_ring_hdl, &srng_params);
  752. switch (hal_ring_type) {
  753. case RXDMA_BUF:
  754. htt_ring_id = HTT_RXDMA_HOST_BUF_RING;
  755. htt_ring_type = HTT_SW_TO_HW_RING;
  756. break;
  757. case RXDMA_MONITOR_BUF:
  758. htt_ring_id = HTT_RXDMA_MONITOR_BUF_RING;
  759. htt_ring_type = HTT_SW_TO_HW_RING;
  760. break;
  761. case RXDMA_MONITOR_STATUS:
  762. htt_ring_id = HTT_RXDMA_MONITOR_STATUS_RING;
  763. htt_ring_type = HTT_SW_TO_HW_RING;
  764. break;
  765. case RXDMA_MONITOR_DST:
  766. htt_ring_id = HTT_RXDMA_MONITOR_DEST_RING;
  767. htt_ring_type = HTT_HW_TO_SW_RING;
  768. break;
  769. case RXDMA_MONITOR_DESC:
  770. htt_ring_id = HTT_RXDMA_MONITOR_DESC_RING;
  771. htt_ring_type = HTT_SW_TO_HW_RING;
  772. break;
  773. case RXDMA_DST:
  774. htt_ring_id = HTT_RXDMA_NON_MONITOR_DEST_RING;
  775. htt_ring_type = HTT_HW_TO_SW_RING;
  776. break;
  777. default:
  778. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  779. "%s: Ring currently not supported", __func__);
  780. goto fail1;
  781. }
  782. /*
  783. * Set the length of the message.
  784. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  785. * separately during the below call to qdf_nbuf_push_head.
  786. * The contribution from the HTC header is added separately inside HTC.
  787. */
  788. if (qdf_nbuf_put_tail(htt_msg, HTT_RX_RING_SELECTION_CFG_SZ) == NULL) {
  789. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  790. "%s: Failed to expand head for RX Ring Cfg msg",
  791. __func__);
  792. goto fail1; /* failure */
  793. }
  794. msg_word = (uint32_t *)qdf_nbuf_data(htt_msg);
  795. /* rewind beyond alignment pad to get to the HTC header reserved area */
  796. qdf_nbuf_push_head(htt_msg, HTC_HDR_ALIGNMENT_PADDING);
  797. /* word 0 */
  798. htt_logger_bufp = (uint8_t *)msg_word;
  799. *msg_word = 0;
  800. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_RX_RING_SELECTION_CFG);
  801. /*
  802. * pdev_id is indexed from 0 whereas mac_id is indexed from 1
  803. * SW_TO_SW and SW_TO_HW rings are unaffected by this
  804. */
  805. target_pdev_id =
  806. dp_get_target_pdev_id_for_host_pdev_id(soc->dp_soc, pdev_id);
  807. if (htt_ring_type == HTT_SW_TO_SW_RING ||
  808. htt_ring_type == HTT_SW_TO_HW_RING)
  809. HTT_RX_RING_SELECTION_CFG_PDEV_ID_SET(*msg_word,
  810. target_pdev_id);
  811. /* TODO: Discuss with FW on changing this to unique ID and using
  812. * htt_ring_type to send the type of ring
  813. */
  814. HTT_RX_RING_SELECTION_CFG_RING_ID_SET(*msg_word, htt_ring_id);
  815. HTT_RX_RING_SELECTION_CFG_STATUS_TLV_SET(*msg_word,
  816. !!(srng_params.flags & HAL_SRNG_MSI_SWAP));
  817. HTT_RX_RING_SELECTION_CFG_RX_OFFSETS_VALID_SET(*msg_word,
  818. htt_tlv_filter->offset_valid);
  819. if (mon_drop_th > 0)
  820. HTT_RX_RING_SELECTION_CFG_DROP_THRESHOLD_VALID_SET(*msg_word,
  821. 1);
  822. else
  823. HTT_RX_RING_SELECTION_CFG_DROP_THRESHOLD_VALID_SET(*msg_word,
  824. 0);
  825. /* word 1 */
  826. msg_word++;
  827. *msg_word = 0;
  828. HTT_RX_RING_SELECTION_CFG_RING_BUFFER_SIZE_SET(*msg_word,
  829. ring_buf_size);
  830. /* word 2 */
  831. msg_word++;
  832. *msg_word = 0;
  833. if (htt_tlv_filter->enable_fp) {
  834. /* TYPE: MGMT */
  835. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  836. FP, MGMT, 0000,
  837. (htt_tlv_filter->fp_mgmt_filter &
  838. FILTER_MGMT_ASSOC_REQ) ? 1 : 0);
  839. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  840. FP, MGMT, 0001,
  841. (htt_tlv_filter->fp_mgmt_filter &
  842. FILTER_MGMT_ASSOC_RES) ? 1 : 0);
  843. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  844. FP, MGMT, 0010,
  845. (htt_tlv_filter->fp_mgmt_filter &
  846. FILTER_MGMT_REASSOC_REQ) ? 1 : 0);
  847. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  848. FP, MGMT, 0011,
  849. (htt_tlv_filter->fp_mgmt_filter &
  850. FILTER_MGMT_REASSOC_RES) ? 1 : 0);
  851. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  852. FP, MGMT, 0100,
  853. (htt_tlv_filter->fp_mgmt_filter &
  854. FILTER_MGMT_PROBE_REQ) ? 1 : 0);
  855. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  856. FP, MGMT, 0101,
  857. (htt_tlv_filter->fp_mgmt_filter &
  858. FILTER_MGMT_PROBE_RES) ? 1 : 0);
  859. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  860. FP, MGMT, 0110,
  861. (htt_tlv_filter->fp_mgmt_filter &
  862. FILTER_MGMT_TIM_ADVT) ? 1 : 0);
  863. /* reserved */
  864. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0, FP,
  865. MGMT, 0111,
  866. (htt_tlv_filter->fp_mgmt_filter &
  867. FILTER_MGMT_RESERVED_7) ? 1 : 0);
  868. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  869. FP, MGMT, 1000,
  870. (htt_tlv_filter->fp_mgmt_filter &
  871. FILTER_MGMT_BEACON) ? 1 : 0);
  872. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  873. FP, MGMT, 1001,
  874. (htt_tlv_filter->fp_mgmt_filter &
  875. FILTER_MGMT_ATIM) ? 1 : 0);
  876. }
  877. if (htt_tlv_filter->enable_md) {
  878. /* TYPE: MGMT */
  879. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  880. MD, MGMT, 0000,
  881. (htt_tlv_filter->md_mgmt_filter &
  882. FILTER_MGMT_ASSOC_REQ) ? 1 : 0);
  883. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  884. MD, MGMT, 0001,
  885. (htt_tlv_filter->md_mgmt_filter &
  886. FILTER_MGMT_ASSOC_RES) ? 1 : 0);
  887. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  888. MD, MGMT, 0010,
  889. (htt_tlv_filter->md_mgmt_filter &
  890. FILTER_MGMT_REASSOC_REQ) ? 1 : 0);
  891. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  892. MD, MGMT, 0011,
  893. (htt_tlv_filter->md_mgmt_filter &
  894. FILTER_MGMT_REASSOC_RES) ? 1 : 0);
  895. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  896. MD, MGMT, 0100,
  897. (htt_tlv_filter->md_mgmt_filter &
  898. FILTER_MGMT_PROBE_REQ) ? 1 : 0);
  899. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  900. MD, MGMT, 0101,
  901. (htt_tlv_filter->md_mgmt_filter &
  902. FILTER_MGMT_PROBE_RES) ? 1 : 0);
  903. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  904. MD, MGMT, 0110,
  905. (htt_tlv_filter->md_mgmt_filter &
  906. FILTER_MGMT_TIM_ADVT) ? 1 : 0);
  907. /* reserved */
  908. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0, MD,
  909. MGMT, 0111,
  910. (htt_tlv_filter->md_mgmt_filter &
  911. FILTER_MGMT_RESERVED_7) ? 1 : 0);
  912. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  913. MD, MGMT, 1000,
  914. (htt_tlv_filter->md_mgmt_filter &
  915. FILTER_MGMT_BEACON) ? 1 : 0);
  916. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  917. MD, MGMT, 1001,
  918. (htt_tlv_filter->md_mgmt_filter &
  919. FILTER_MGMT_ATIM) ? 1 : 0);
  920. }
  921. if (htt_tlv_filter->enable_mo) {
  922. /* TYPE: MGMT */
  923. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  924. MO, MGMT, 0000,
  925. (htt_tlv_filter->mo_mgmt_filter &
  926. FILTER_MGMT_ASSOC_REQ) ? 1 : 0);
  927. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  928. MO, MGMT, 0001,
  929. (htt_tlv_filter->mo_mgmt_filter &
  930. FILTER_MGMT_ASSOC_RES) ? 1 : 0);
  931. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  932. MO, MGMT, 0010,
  933. (htt_tlv_filter->mo_mgmt_filter &
  934. FILTER_MGMT_REASSOC_REQ) ? 1 : 0);
  935. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  936. MO, MGMT, 0011,
  937. (htt_tlv_filter->mo_mgmt_filter &
  938. FILTER_MGMT_REASSOC_RES) ? 1 : 0);
  939. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  940. MO, MGMT, 0100,
  941. (htt_tlv_filter->mo_mgmt_filter &
  942. FILTER_MGMT_PROBE_REQ) ? 1 : 0);
  943. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  944. MO, MGMT, 0101,
  945. (htt_tlv_filter->mo_mgmt_filter &
  946. FILTER_MGMT_PROBE_RES) ? 1 : 0);
  947. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  948. MO, MGMT, 0110,
  949. (htt_tlv_filter->mo_mgmt_filter &
  950. FILTER_MGMT_TIM_ADVT) ? 1 : 0);
  951. /* reserved */
  952. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0, MO,
  953. MGMT, 0111,
  954. (htt_tlv_filter->mo_mgmt_filter &
  955. FILTER_MGMT_RESERVED_7) ? 1 : 0);
  956. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  957. MO, MGMT, 1000,
  958. (htt_tlv_filter->mo_mgmt_filter &
  959. FILTER_MGMT_BEACON) ? 1 : 0);
  960. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG0,
  961. MO, MGMT, 1001,
  962. (htt_tlv_filter->mo_mgmt_filter &
  963. FILTER_MGMT_ATIM) ? 1 : 0);
  964. }
  965. /* word 3 */
  966. msg_word++;
  967. *msg_word = 0;
  968. if (htt_tlv_filter->enable_fp) {
  969. /* TYPE: MGMT */
  970. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  971. FP, MGMT, 1010,
  972. (htt_tlv_filter->fp_mgmt_filter &
  973. FILTER_MGMT_DISASSOC) ? 1 : 0);
  974. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  975. FP, MGMT, 1011,
  976. (htt_tlv_filter->fp_mgmt_filter &
  977. FILTER_MGMT_AUTH) ? 1 : 0);
  978. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  979. FP, MGMT, 1100,
  980. (htt_tlv_filter->fp_mgmt_filter &
  981. FILTER_MGMT_DEAUTH) ? 1 : 0);
  982. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  983. FP, MGMT, 1101,
  984. (htt_tlv_filter->fp_mgmt_filter &
  985. FILTER_MGMT_ACTION) ? 1 : 0);
  986. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  987. FP, MGMT, 1110,
  988. (htt_tlv_filter->fp_mgmt_filter &
  989. FILTER_MGMT_ACT_NO_ACK) ? 1 : 0);
  990. /* reserved*/
  991. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1, FP,
  992. MGMT, 1111,
  993. (htt_tlv_filter->fp_mgmt_filter &
  994. FILTER_MGMT_RESERVED_15) ? 1 : 0);
  995. }
  996. if (htt_tlv_filter->enable_md) {
  997. /* TYPE: MGMT */
  998. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  999. MD, MGMT, 1010,
  1000. (htt_tlv_filter->md_mgmt_filter &
  1001. FILTER_MGMT_DISASSOC) ? 1 : 0);
  1002. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1003. MD, MGMT, 1011,
  1004. (htt_tlv_filter->md_mgmt_filter &
  1005. FILTER_MGMT_AUTH) ? 1 : 0);
  1006. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1007. MD, MGMT, 1100,
  1008. (htt_tlv_filter->md_mgmt_filter &
  1009. FILTER_MGMT_DEAUTH) ? 1 : 0);
  1010. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1011. MD, MGMT, 1101,
  1012. (htt_tlv_filter->md_mgmt_filter &
  1013. FILTER_MGMT_ACTION) ? 1 : 0);
  1014. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1015. MD, MGMT, 1110,
  1016. (htt_tlv_filter->md_mgmt_filter &
  1017. FILTER_MGMT_ACT_NO_ACK) ? 1 : 0);
  1018. }
  1019. if (htt_tlv_filter->enable_mo) {
  1020. /* TYPE: MGMT */
  1021. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1022. MO, MGMT, 1010,
  1023. (htt_tlv_filter->mo_mgmt_filter &
  1024. FILTER_MGMT_DISASSOC) ? 1 : 0);
  1025. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1026. MO, MGMT, 1011,
  1027. (htt_tlv_filter->mo_mgmt_filter &
  1028. FILTER_MGMT_AUTH) ? 1 : 0);
  1029. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1030. MO, MGMT, 1100,
  1031. (htt_tlv_filter->mo_mgmt_filter &
  1032. FILTER_MGMT_DEAUTH) ? 1 : 0);
  1033. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1034. MO, MGMT, 1101,
  1035. (htt_tlv_filter->mo_mgmt_filter &
  1036. FILTER_MGMT_ACTION) ? 1 : 0);
  1037. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1,
  1038. MO, MGMT, 1110,
  1039. (htt_tlv_filter->mo_mgmt_filter &
  1040. FILTER_MGMT_ACT_NO_ACK) ? 1 : 0);
  1041. /* reserved*/
  1042. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG1, MO,
  1043. MGMT, 1111,
  1044. (htt_tlv_filter->mo_mgmt_filter &
  1045. FILTER_MGMT_RESERVED_15) ? 1 : 0);
  1046. }
  1047. /* word 4 */
  1048. msg_word++;
  1049. *msg_word = 0;
  1050. if (htt_tlv_filter->enable_fp) {
  1051. /* TYPE: CTRL */
  1052. /* reserved */
  1053. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1054. CTRL, 0000,
  1055. (htt_tlv_filter->fp_ctrl_filter &
  1056. FILTER_CTRL_RESERVED_1) ? 1 : 0);
  1057. /* reserved */
  1058. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1059. CTRL, 0001,
  1060. (htt_tlv_filter->fp_ctrl_filter &
  1061. FILTER_CTRL_RESERVED_2) ? 1 : 0);
  1062. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1063. CTRL, 0010,
  1064. (htt_tlv_filter->fp_ctrl_filter &
  1065. FILTER_CTRL_TRIGGER) ? 1 : 0);
  1066. /* reserved */
  1067. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1068. CTRL, 0011,
  1069. (htt_tlv_filter->fp_ctrl_filter &
  1070. FILTER_CTRL_RESERVED_4) ? 1 : 0);
  1071. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1072. CTRL, 0100,
  1073. (htt_tlv_filter->fp_ctrl_filter &
  1074. FILTER_CTRL_BF_REP_POLL) ? 1 : 0);
  1075. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1076. CTRL, 0101,
  1077. (htt_tlv_filter->fp_ctrl_filter &
  1078. FILTER_CTRL_VHT_NDP) ? 1 : 0);
  1079. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1080. CTRL, 0110,
  1081. (htt_tlv_filter->fp_ctrl_filter &
  1082. FILTER_CTRL_FRAME_EXT) ? 1 : 0);
  1083. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1084. CTRL, 0111,
  1085. (htt_tlv_filter->fp_ctrl_filter &
  1086. FILTER_CTRL_CTRLWRAP) ? 1 : 0);
  1087. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1088. CTRL, 1000,
  1089. (htt_tlv_filter->fp_ctrl_filter &
  1090. FILTER_CTRL_BA_REQ) ? 1 : 0);
  1091. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, FP,
  1092. CTRL, 1001,
  1093. (htt_tlv_filter->fp_ctrl_filter &
  1094. FILTER_CTRL_BA) ? 1 : 0);
  1095. }
  1096. if (htt_tlv_filter->enable_md) {
  1097. /* TYPE: CTRL */
  1098. /* reserved */
  1099. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1100. CTRL, 0000,
  1101. (htt_tlv_filter->md_ctrl_filter &
  1102. FILTER_CTRL_RESERVED_1) ? 1 : 0);
  1103. /* reserved */
  1104. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1105. CTRL, 0001,
  1106. (htt_tlv_filter->md_ctrl_filter &
  1107. FILTER_CTRL_RESERVED_2) ? 1 : 0);
  1108. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1109. CTRL, 0010,
  1110. (htt_tlv_filter->md_ctrl_filter &
  1111. FILTER_CTRL_TRIGGER) ? 1 : 0);
  1112. /* reserved */
  1113. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1114. CTRL, 0011,
  1115. (htt_tlv_filter->md_ctrl_filter &
  1116. FILTER_CTRL_RESERVED_4) ? 1 : 0);
  1117. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1118. CTRL, 0100,
  1119. (htt_tlv_filter->md_ctrl_filter &
  1120. FILTER_CTRL_BF_REP_POLL) ? 1 : 0);
  1121. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1122. CTRL, 0101,
  1123. (htt_tlv_filter->md_ctrl_filter &
  1124. FILTER_CTRL_VHT_NDP) ? 1 : 0);
  1125. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1126. CTRL, 0110,
  1127. (htt_tlv_filter->md_ctrl_filter &
  1128. FILTER_CTRL_FRAME_EXT) ? 1 : 0);
  1129. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1130. CTRL, 0111,
  1131. (htt_tlv_filter->md_ctrl_filter &
  1132. FILTER_CTRL_CTRLWRAP) ? 1 : 0);
  1133. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1134. CTRL, 1000,
  1135. (htt_tlv_filter->md_ctrl_filter &
  1136. FILTER_CTRL_BA_REQ) ? 1 : 0);
  1137. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MD,
  1138. CTRL, 1001,
  1139. (htt_tlv_filter->md_ctrl_filter &
  1140. FILTER_CTRL_BA) ? 1 : 0);
  1141. }
  1142. if (htt_tlv_filter->enable_mo) {
  1143. /* TYPE: CTRL */
  1144. /* reserved */
  1145. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1146. CTRL, 0000,
  1147. (htt_tlv_filter->mo_ctrl_filter &
  1148. FILTER_CTRL_RESERVED_1) ? 1 : 0);
  1149. /* reserved */
  1150. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1151. CTRL, 0001,
  1152. (htt_tlv_filter->mo_ctrl_filter &
  1153. FILTER_CTRL_RESERVED_2) ? 1 : 0);
  1154. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1155. CTRL, 0010,
  1156. (htt_tlv_filter->mo_ctrl_filter &
  1157. FILTER_CTRL_TRIGGER) ? 1 : 0);
  1158. /* reserved */
  1159. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1160. CTRL, 0011,
  1161. (htt_tlv_filter->mo_ctrl_filter &
  1162. FILTER_CTRL_RESERVED_4) ? 1 : 0);
  1163. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1164. CTRL, 0100,
  1165. (htt_tlv_filter->mo_ctrl_filter &
  1166. FILTER_CTRL_BF_REP_POLL) ? 1 : 0);
  1167. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1168. CTRL, 0101,
  1169. (htt_tlv_filter->mo_ctrl_filter &
  1170. FILTER_CTRL_VHT_NDP) ? 1 : 0);
  1171. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1172. CTRL, 0110,
  1173. (htt_tlv_filter->mo_ctrl_filter &
  1174. FILTER_CTRL_FRAME_EXT) ? 1 : 0);
  1175. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1176. CTRL, 0111,
  1177. (htt_tlv_filter->mo_ctrl_filter &
  1178. FILTER_CTRL_CTRLWRAP) ? 1 : 0);
  1179. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1180. CTRL, 1000,
  1181. (htt_tlv_filter->mo_ctrl_filter &
  1182. FILTER_CTRL_BA_REQ) ? 1 : 0);
  1183. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG2, MO,
  1184. CTRL, 1001,
  1185. (htt_tlv_filter->mo_ctrl_filter &
  1186. FILTER_CTRL_BA) ? 1 : 0);
  1187. }
  1188. /* word 5 */
  1189. msg_word++;
  1190. *msg_word = 0;
  1191. if (htt_tlv_filter->enable_fp) {
  1192. /* TYPE: CTRL */
  1193. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1194. CTRL, 1010,
  1195. (htt_tlv_filter->fp_ctrl_filter &
  1196. FILTER_CTRL_PSPOLL) ? 1 : 0);
  1197. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1198. CTRL, 1011,
  1199. (htt_tlv_filter->fp_ctrl_filter &
  1200. FILTER_CTRL_RTS) ? 1 : 0);
  1201. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1202. CTRL, 1100,
  1203. (htt_tlv_filter->fp_ctrl_filter &
  1204. FILTER_CTRL_CTS) ? 1 : 0);
  1205. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1206. CTRL, 1101,
  1207. (htt_tlv_filter->fp_ctrl_filter &
  1208. FILTER_CTRL_ACK) ? 1 : 0);
  1209. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1210. CTRL, 1110,
  1211. (htt_tlv_filter->fp_ctrl_filter &
  1212. FILTER_CTRL_CFEND) ? 1 : 0);
  1213. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1214. CTRL, 1111,
  1215. (htt_tlv_filter->fp_ctrl_filter &
  1216. FILTER_CTRL_CFEND_CFACK) ? 1 : 0);
  1217. /* TYPE: DATA */
  1218. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1219. DATA, MCAST,
  1220. (htt_tlv_filter->fp_data_filter &
  1221. FILTER_DATA_MCAST) ? 1 : 0);
  1222. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1223. DATA, UCAST,
  1224. (htt_tlv_filter->fp_data_filter &
  1225. FILTER_DATA_UCAST) ? 1 : 0);
  1226. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, FP,
  1227. DATA, NULL,
  1228. (htt_tlv_filter->fp_data_filter &
  1229. FILTER_DATA_NULL) ? 1 : 0);
  1230. }
  1231. if (htt_tlv_filter->enable_md) {
  1232. /* TYPE: CTRL */
  1233. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1234. CTRL, 1010,
  1235. (htt_tlv_filter->md_ctrl_filter &
  1236. FILTER_CTRL_PSPOLL) ? 1 : 0);
  1237. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1238. CTRL, 1011,
  1239. (htt_tlv_filter->md_ctrl_filter &
  1240. FILTER_CTRL_RTS) ? 1 : 0);
  1241. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1242. CTRL, 1100,
  1243. (htt_tlv_filter->md_ctrl_filter &
  1244. FILTER_CTRL_CTS) ? 1 : 0);
  1245. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1246. CTRL, 1101,
  1247. (htt_tlv_filter->md_ctrl_filter &
  1248. FILTER_CTRL_ACK) ? 1 : 0);
  1249. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1250. CTRL, 1110,
  1251. (htt_tlv_filter->md_ctrl_filter &
  1252. FILTER_CTRL_CFEND) ? 1 : 0);
  1253. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1254. CTRL, 1111,
  1255. (htt_tlv_filter->md_ctrl_filter &
  1256. FILTER_CTRL_CFEND_CFACK) ? 1 : 0);
  1257. /* TYPE: DATA */
  1258. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1259. DATA, MCAST,
  1260. (htt_tlv_filter->md_data_filter &
  1261. FILTER_DATA_MCAST) ? 1 : 0);
  1262. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1263. DATA, UCAST,
  1264. (htt_tlv_filter->md_data_filter &
  1265. FILTER_DATA_UCAST) ? 1 : 0);
  1266. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MD,
  1267. DATA, NULL,
  1268. (htt_tlv_filter->md_data_filter &
  1269. FILTER_DATA_NULL) ? 1 : 0);
  1270. }
  1271. if (htt_tlv_filter->enable_mo) {
  1272. /* TYPE: CTRL */
  1273. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1274. CTRL, 1010,
  1275. (htt_tlv_filter->mo_ctrl_filter &
  1276. FILTER_CTRL_PSPOLL) ? 1 : 0);
  1277. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1278. CTRL, 1011,
  1279. (htt_tlv_filter->mo_ctrl_filter &
  1280. FILTER_CTRL_RTS) ? 1 : 0);
  1281. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1282. CTRL, 1100,
  1283. (htt_tlv_filter->mo_ctrl_filter &
  1284. FILTER_CTRL_CTS) ? 1 : 0);
  1285. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1286. CTRL, 1101,
  1287. (htt_tlv_filter->mo_ctrl_filter &
  1288. FILTER_CTRL_ACK) ? 1 : 0);
  1289. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1290. CTRL, 1110,
  1291. (htt_tlv_filter->mo_ctrl_filter &
  1292. FILTER_CTRL_CFEND) ? 1 : 0);
  1293. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1294. CTRL, 1111,
  1295. (htt_tlv_filter->mo_ctrl_filter &
  1296. FILTER_CTRL_CFEND_CFACK) ? 1 : 0);
  1297. /* TYPE: DATA */
  1298. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1299. DATA, MCAST,
  1300. (htt_tlv_filter->mo_data_filter &
  1301. FILTER_DATA_MCAST) ? 1 : 0);
  1302. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1303. DATA, UCAST,
  1304. (htt_tlv_filter->mo_data_filter &
  1305. FILTER_DATA_UCAST) ? 1 : 0);
  1306. htt_rx_ring_pkt_enable_subtype_set(*msg_word, FLAG3, MO,
  1307. DATA, NULL,
  1308. (htt_tlv_filter->mo_data_filter &
  1309. FILTER_DATA_NULL) ? 1 : 0);
  1310. }
  1311. /* word 6 */
  1312. msg_word++;
  1313. *msg_word = 0;
  1314. tlv_filter = 0;
  1315. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, MPDU_START,
  1316. htt_tlv_filter->mpdu_start);
  1317. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, MSDU_START,
  1318. htt_tlv_filter->msdu_start);
  1319. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, PACKET,
  1320. htt_tlv_filter->packet);
  1321. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, MSDU_END,
  1322. htt_tlv_filter->msdu_end);
  1323. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, MPDU_END,
  1324. htt_tlv_filter->mpdu_end);
  1325. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, PACKET_HEADER,
  1326. htt_tlv_filter->packet_header);
  1327. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, ATTENTION,
  1328. htt_tlv_filter->attention);
  1329. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, PPDU_START,
  1330. htt_tlv_filter->ppdu_start);
  1331. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, PPDU_END,
  1332. htt_tlv_filter->ppdu_end);
  1333. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, PPDU_END_USER_STATS,
  1334. htt_tlv_filter->ppdu_end_user_stats);
  1335. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter,
  1336. PPDU_END_USER_STATS_EXT,
  1337. htt_tlv_filter->ppdu_end_user_stats_ext);
  1338. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, PPDU_END_STATUS_DONE,
  1339. htt_tlv_filter->ppdu_end_status_done);
  1340. /* RESERVED bit maps to header_per_msdu in htt_tlv_filter*/
  1341. htt_rx_ring_tlv_filter_in_enable_set(tlv_filter, RESERVED,
  1342. htt_tlv_filter->header_per_msdu);
  1343. HTT_RX_RING_SELECTION_CFG_TLV_FILTER_IN_FLAG_SET(*msg_word, tlv_filter);
  1344. msg_word++;
  1345. *msg_word = 0;
  1346. if (htt_tlv_filter->offset_valid) {
  1347. HTT_RX_RING_SELECTION_CFG_RX_PACKET_OFFSET_SET(*msg_word,
  1348. htt_tlv_filter->rx_packet_offset);
  1349. HTT_RX_RING_SELECTION_CFG_RX_HEADER_OFFSET_SET(*msg_word,
  1350. htt_tlv_filter->rx_header_offset);
  1351. msg_word++;
  1352. *msg_word = 0;
  1353. HTT_RX_RING_SELECTION_CFG_RX_MPDU_END_OFFSET_SET(*msg_word,
  1354. htt_tlv_filter->rx_mpdu_end_offset);
  1355. HTT_RX_RING_SELECTION_CFG_RX_MPDU_START_OFFSET_SET(*msg_word,
  1356. htt_tlv_filter->rx_mpdu_start_offset);
  1357. msg_word++;
  1358. *msg_word = 0;
  1359. HTT_RX_RING_SELECTION_CFG_RX_MSDU_END_OFFSET_SET(*msg_word,
  1360. htt_tlv_filter->rx_msdu_end_offset);
  1361. HTT_RX_RING_SELECTION_CFG_RX_MSDU_START_OFFSET_SET(*msg_word,
  1362. htt_tlv_filter->rx_msdu_start_offset);
  1363. msg_word++;
  1364. *msg_word = 0;
  1365. HTT_RX_RING_SELECTION_CFG_RX_ATTENTION_OFFSET_SET(*msg_word,
  1366. htt_tlv_filter->rx_attn_offset);
  1367. msg_word++;
  1368. *msg_word = 0;
  1369. } else {
  1370. msg_word += 4;
  1371. *msg_word = 0;
  1372. }
  1373. if (mon_drop_th > 0)
  1374. HTT_RX_RING_SELECTION_CFG_RX_DROP_THRESHOLD_SET(*msg_word,
  1375. mon_drop_th);
  1376. /* "response_required" field should be set if a HTT response message is
  1377. * required after setting up the ring.
  1378. */
  1379. pkt = htt_htc_pkt_alloc(soc);
  1380. if (!pkt)
  1381. goto fail1;
  1382. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  1383. SET_HTC_PACKET_INFO_TX(
  1384. &pkt->htc_pkt,
  1385. dp_htt_h2t_send_complete_free_netbuf,
  1386. qdf_nbuf_data(htt_msg),
  1387. qdf_nbuf_len(htt_msg),
  1388. soc->htc_endpoint,
  1389. HTC_TX_PACKET_TAG_RUNTIME_PUT); /* tag for no FW response msg */
  1390. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, htt_msg);
  1391. status = DP_HTT_SEND_HTC_PKT(soc, pkt,
  1392. HTT_H2T_MSG_TYPE_RX_RING_SELECTION_CFG,
  1393. htt_logger_bufp);
  1394. if (status != QDF_STATUS_SUCCESS) {
  1395. qdf_nbuf_free(htt_msg);
  1396. htt_htc_pkt_free(soc, pkt);
  1397. }
  1398. return status;
  1399. fail1:
  1400. qdf_nbuf_free(htt_msg);
  1401. fail0:
  1402. return QDF_STATUS_E_FAILURE;
  1403. }
  1404. qdf_export_symbol(htt_h2t_rx_ring_cfg);
  1405. #if defined(HTT_STATS_ENABLE)
  1406. static inline QDF_STATUS dp_send_htt_stat_resp(struct htt_stats_context *htt_stats,
  1407. struct dp_soc *soc, qdf_nbuf_t htt_msg)
  1408. {
  1409. uint32_t pdev_id;
  1410. uint32_t *msg_word = NULL;
  1411. uint32_t msg_remain_len = 0;
  1412. msg_word = (uint32_t *) qdf_nbuf_data(htt_msg);
  1413. /*COOKIE MSB*/
  1414. pdev_id = *(msg_word + 2) & HTT_PID_BIT_MASK;
  1415. /* stats message length + 16 size of HTT header*/
  1416. msg_remain_len = qdf_min(htt_stats->msg_len + 16,
  1417. (uint32_t)DP_EXT_MSG_LENGTH);
  1418. dp_wdi_event_handler(WDI_EVENT_HTT_STATS, soc,
  1419. msg_word, msg_remain_len,
  1420. WDI_NO_VAL, pdev_id);
  1421. if (htt_stats->msg_len >= DP_EXT_MSG_LENGTH) {
  1422. htt_stats->msg_len -= DP_EXT_MSG_LENGTH;
  1423. }
  1424. /* Need to be freed here as WDI handler will
  1425. * make a copy of pkt to send data to application
  1426. */
  1427. qdf_nbuf_free(htt_msg);
  1428. return QDF_STATUS_SUCCESS;
  1429. }
  1430. #else
  1431. static inline QDF_STATUS
  1432. dp_send_htt_stat_resp(struct htt_stats_context *htt_stats,
  1433. struct dp_soc *soc, qdf_nbuf_t htt_msg)
  1434. {
  1435. return QDF_STATUS_E_NOSUPPORT;
  1436. }
  1437. #endif
  1438. #ifdef HTT_STATS_DEBUGFS_SUPPORT
  1439. /* dp_send_htt_stats_dbgfs_msg() - Function to send htt data to upper layer
  1440. * @pdev: dp pdev handle
  1441. * @msg_word: HTT msg
  1442. * @msg_len: Length of HTT msg sent
  1443. *
  1444. * Return: none
  1445. */
  1446. static inline void
  1447. dp_htt_stats_dbgfs_send_msg(struct dp_pdev *pdev, uint32_t *msg_word,
  1448. uint32_t msg_len)
  1449. {
  1450. struct htt_dbgfs_cfg dbgfs_cfg;
  1451. int done = 0;
  1452. /* send 5th word of HTT msg to upper layer */
  1453. dbgfs_cfg.msg_word = (msg_word + 4);
  1454. dbgfs_cfg.m = pdev->dbgfs_cfg->m;
  1455. /* stats message length + 16 size of HTT header*/
  1456. msg_len = qdf_min(msg_len + HTT_HEADER_LEN, (uint32_t)DP_EXT_MSG_LENGTH);
  1457. if (pdev->dbgfs_cfg->htt_stats_dbgfs_msg_process)
  1458. pdev->dbgfs_cfg->htt_stats_dbgfs_msg_process(&dbgfs_cfg,
  1459. (msg_len - HTT_HEADER_LEN));
  1460. /* Get TLV Done bit from 4th msg word */
  1461. done = HTT_T2H_EXT_STATS_CONF_TLV_DONE_GET(*(msg_word + 3));
  1462. if (done) {
  1463. if (qdf_event_set(&pdev->dbgfs_cfg->htt_stats_dbgfs_event))
  1464. dp_htt_err("%pK: Failed to set event for debugfs htt stats"
  1465. , pdev->soc);
  1466. }
  1467. }
  1468. #else
  1469. static inline void
  1470. dp_htt_stats_dbgfs_send_msg(struct dp_pdev *pdev, uint32_t *msg_word,
  1471. uint32_t msg_len)
  1472. {
  1473. }
  1474. #endif /* HTT_STATS_DEBUGFS_SUPPORT */
  1475. /**
  1476. * dp_process_htt_stat_msg(): Process the list of buffers of HTT EXT stats
  1477. * @htt_stats: htt stats info
  1478. *
  1479. * The FW sends the HTT EXT STATS as a stream of T2H messages. Each T2H message
  1480. * contains sub messages which are identified by a TLV header.
  1481. * In this function we will process the stream of T2H messages and read all the
  1482. * TLV contained in the message.
  1483. *
  1484. * THe following cases have been taken care of
  1485. * Case 1: When the tlv_remain_length <= msg_remain_length of HTT MSG buffer
  1486. * In this case the buffer will contain multiple tlvs.
  1487. * Case 2: When the tlv_remain_length > msg_remain_length of HTT MSG buffer.
  1488. * Only one tlv will be contained in the HTT message and this tag
  1489. * will extend onto the next buffer.
  1490. * Case 3: When the buffer is the continuation of the previous message
  1491. * Case 4: tlv length is 0. which will indicate the end of message
  1492. *
  1493. * return: void
  1494. */
  1495. static inline void dp_process_htt_stat_msg(struct htt_stats_context *htt_stats,
  1496. struct dp_soc *soc)
  1497. {
  1498. htt_tlv_tag_t tlv_type = 0xff;
  1499. qdf_nbuf_t htt_msg = NULL;
  1500. uint32_t *msg_word;
  1501. uint8_t *tlv_buf_head = NULL;
  1502. uint8_t *tlv_buf_tail = NULL;
  1503. uint32_t msg_remain_len = 0;
  1504. uint32_t tlv_remain_len = 0;
  1505. uint32_t *tlv_start;
  1506. int cookie_val = 0;
  1507. int cookie_msb = 0;
  1508. int pdev_id;
  1509. bool copy_stats = false;
  1510. struct dp_pdev *pdev;
  1511. /* Process node in the HTT message queue */
  1512. while ((htt_msg = qdf_nbuf_queue_remove(&htt_stats->msg))
  1513. != NULL) {
  1514. msg_word = (uint32_t *) qdf_nbuf_data(htt_msg);
  1515. cookie_val = *(msg_word + 1);
  1516. htt_stats->msg_len = HTT_T2H_EXT_STATS_CONF_TLV_LENGTH_GET(
  1517. *(msg_word +
  1518. HTT_T2H_EXT_STATS_TLV_START_OFFSET));
  1519. if (cookie_val) {
  1520. if (dp_send_htt_stat_resp(htt_stats, soc, htt_msg)
  1521. == QDF_STATUS_SUCCESS) {
  1522. continue;
  1523. }
  1524. }
  1525. cookie_msb = *(msg_word + 2);
  1526. pdev_id = *(msg_word + 2) & HTT_PID_BIT_MASK;
  1527. pdev = soc->pdev_list[pdev_id];
  1528. if (!cookie_val && (cookie_msb & DBG_STATS_COOKIE_HTT_DBGFS)) {
  1529. dp_htt_stats_dbgfs_send_msg(pdev, msg_word,
  1530. htt_stats->msg_len);
  1531. qdf_nbuf_free(htt_msg);
  1532. continue;
  1533. }
  1534. if (cookie_msb & DBG_STATS_COOKIE_DP_STATS)
  1535. copy_stats = true;
  1536. /* read 5th word */
  1537. msg_word = msg_word + 4;
  1538. msg_remain_len = qdf_min(htt_stats->msg_len,
  1539. (uint32_t) DP_EXT_MSG_LENGTH);
  1540. /* Keep processing the node till node length is 0 */
  1541. while (msg_remain_len) {
  1542. /*
  1543. * if message is not a continuation of previous message
  1544. * read the tlv type and tlv length
  1545. */
  1546. if (!tlv_buf_head) {
  1547. tlv_type = HTT_STATS_TLV_TAG_GET(
  1548. *msg_word);
  1549. tlv_remain_len = HTT_STATS_TLV_LENGTH_GET(
  1550. *msg_word);
  1551. }
  1552. if (tlv_remain_len == 0) {
  1553. msg_remain_len = 0;
  1554. if (tlv_buf_head) {
  1555. qdf_mem_free(tlv_buf_head);
  1556. tlv_buf_head = NULL;
  1557. tlv_buf_tail = NULL;
  1558. }
  1559. goto error;
  1560. }
  1561. if (!tlv_buf_head)
  1562. tlv_remain_len += HTT_TLV_HDR_LEN;
  1563. if ((tlv_remain_len <= msg_remain_len)) {
  1564. /* Case 3 */
  1565. if (tlv_buf_head) {
  1566. qdf_mem_copy(tlv_buf_tail,
  1567. (uint8_t *)msg_word,
  1568. tlv_remain_len);
  1569. tlv_start = (uint32_t *)tlv_buf_head;
  1570. } else {
  1571. /* Case 1 */
  1572. tlv_start = msg_word;
  1573. }
  1574. if (copy_stats)
  1575. dp_htt_stats_copy_tag(pdev,
  1576. tlv_type,
  1577. tlv_start);
  1578. else
  1579. dp_htt_stats_print_tag(pdev,
  1580. tlv_type,
  1581. tlv_start);
  1582. if (tlv_type == HTT_STATS_PEER_DETAILS_TAG ||
  1583. tlv_type == HTT_STATS_PEER_STATS_CMN_TAG)
  1584. dp_peer_update_inactive_time(pdev,
  1585. tlv_type,
  1586. tlv_start);
  1587. msg_remain_len -= tlv_remain_len;
  1588. msg_word = (uint32_t *)
  1589. (((uint8_t *)msg_word) +
  1590. tlv_remain_len);
  1591. tlv_remain_len = 0;
  1592. if (tlv_buf_head) {
  1593. qdf_mem_free(tlv_buf_head);
  1594. tlv_buf_head = NULL;
  1595. tlv_buf_tail = NULL;
  1596. }
  1597. } else { /* tlv_remain_len > msg_remain_len */
  1598. /* Case 2 & 3 */
  1599. if (!tlv_buf_head) {
  1600. tlv_buf_head = qdf_mem_malloc(
  1601. tlv_remain_len);
  1602. if (!tlv_buf_head) {
  1603. QDF_TRACE(QDF_MODULE_ID_TXRX,
  1604. QDF_TRACE_LEVEL_ERROR,
  1605. "Alloc failed");
  1606. goto error;
  1607. }
  1608. tlv_buf_tail = tlv_buf_head;
  1609. }
  1610. qdf_mem_copy(tlv_buf_tail, (uint8_t *)msg_word,
  1611. msg_remain_len);
  1612. tlv_remain_len -= msg_remain_len;
  1613. tlv_buf_tail += msg_remain_len;
  1614. }
  1615. }
  1616. if (htt_stats->msg_len >= DP_EXT_MSG_LENGTH) {
  1617. htt_stats->msg_len -= DP_EXT_MSG_LENGTH;
  1618. }
  1619. qdf_nbuf_free(htt_msg);
  1620. }
  1621. return;
  1622. error:
  1623. qdf_nbuf_free(htt_msg);
  1624. while ((htt_msg = qdf_nbuf_queue_remove(&htt_stats->msg))
  1625. != NULL)
  1626. qdf_nbuf_free(htt_msg);
  1627. }
  1628. void htt_t2h_stats_handler(void *context)
  1629. {
  1630. struct dp_soc *soc = (struct dp_soc *)context;
  1631. struct htt_stats_context htt_stats;
  1632. uint32_t *msg_word;
  1633. qdf_nbuf_t htt_msg = NULL;
  1634. uint8_t done;
  1635. uint32_t rem_stats;
  1636. if (!soc) {
  1637. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  1638. "soc is NULL");
  1639. return;
  1640. }
  1641. if (!qdf_atomic_read(&soc->cmn_init_done)) {
  1642. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  1643. "soc: 0x%pK, init_done: %d", soc,
  1644. qdf_atomic_read(&soc->cmn_init_done));
  1645. return;
  1646. }
  1647. qdf_mem_zero(&htt_stats, sizeof(htt_stats));
  1648. qdf_nbuf_queue_init(&htt_stats.msg);
  1649. /* pull one completed stats from soc->htt_stats_msg and process */
  1650. qdf_spin_lock_bh(&soc->htt_stats.lock);
  1651. if (!soc->htt_stats.num_stats) {
  1652. qdf_spin_unlock_bh(&soc->htt_stats.lock);
  1653. return;
  1654. }
  1655. while ((htt_msg = qdf_nbuf_queue_remove(&soc->htt_stats.msg)) != NULL) {
  1656. msg_word = (uint32_t *) qdf_nbuf_data(htt_msg);
  1657. msg_word = msg_word + HTT_T2H_EXT_STATS_TLV_START_OFFSET;
  1658. done = HTT_T2H_EXT_STATS_CONF_TLV_DONE_GET(*msg_word);
  1659. qdf_nbuf_queue_add(&htt_stats.msg, htt_msg);
  1660. /*
  1661. * Done bit signifies that this is the last T2H buffer in the
  1662. * stream of HTT EXT STATS message
  1663. */
  1664. if (done)
  1665. break;
  1666. }
  1667. rem_stats = --soc->htt_stats.num_stats;
  1668. qdf_spin_unlock_bh(&soc->htt_stats.lock);
  1669. /* If there are more stats to process, schedule stats work again.
  1670. * Scheduling prior to processing ht_stats to queue with early
  1671. * index
  1672. */
  1673. if (rem_stats)
  1674. qdf_sched_work(0, &soc->htt_stats.work);
  1675. dp_process_htt_stat_msg(&htt_stats, soc);
  1676. }
  1677. /**
  1678. * dp_txrx_fw_stats_handler() - Function to process HTT EXT stats
  1679. * @soc: DP SOC handle
  1680. * @htt_t2h_msg: HTT message nbuf
  1681. *
  1682. * return:void
  1683. */
  1684. static inline void dp_txrx_fw_stats_handler(struct dp_soc *soc,
  1685. qdf_nbuf_t htt_t2h_msg)
  1686. {
  1687. uint8_t done;
  1688. qdf_nbuf_t msg_copy;
  1689. uint32_t *msg_word;
  1690. msg_word = (uint32_t *)qdf_nbuf_data(htt_t2h_msg);
  1691. msg_word = msg_word + 3;
  1692. done = HTT_T2H_EXT_STATS_CONF_TLV_DONE_GET(*msg_word);
  1693. /*
  1694. * HTT EXT stats response comes as stream of TLVs which span over
  1695. * multiple T2H messages.
  1696. * The first message will carry length of the response.
  1697. * For rest of the messages length will be zero.
  1698. *
  1699. * Clone the T2H message buffer and store it in a list to process
  1700. * it later.
  1701. *
  1702. * The original T2H message buffers gets freed in the T2H HTT event
  1703. * handler
  1704. */
  1705. msg_copy = qdf_nbuf_clone(htt_t2h_msg);
  1706. if (!msg_copy) {
  1707. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO,
  1708. "T2H messge clone failed for HTT EXT STATS");
  1709. goto error;
  1710. }
  1711. qdf_spin_lock_bh(&soc->htt_stats.lock);
  1712. qdf_nbuf_queue_add(&soc->htt_stats.msg, msg_copy);
  1713. /*
  1714. * Done bit signifies that this is the last T2H buffer in the stream of
  1715. * HTT EXT STATS message
  1716. */
  1717. if (done) {
  1718. soc->htt_stats.num_stats++;
  1719. qdf_sched_work(0, &soc->htt_stats.work);
  1720. }
  1721. qdf_spin_unlock_bh(&soc->htt_stats.lock);
  1722. return;
  1723. error:
  1724. qdf_spin_lock_bh(&soc->htt_stats.lock);
  1725. while ((msg_copy = qdf_nbuf_queue_remove(&soc->htt_stats.msg))
  1726. != NULL) {
  1727. qdf_nbuf_free(msg_copy);
  1728. }
  1729. soc->htt_stats.num_stats = 0;
  1730. qdf_spin_unlock_bh(&soc->htt_stats.lock);
  1731. return;
  1732. }
  1733. /*
  1734. * htt_soc_attach_target() - SOC level HTT setup
  1735. * @htt_soc: HTT SOC handle
  1736. *
  1737. * Return: 0 on success; error code on failure
  1738. */
  1739. int htt_soc_attach_target(struct htt_soc *htt_soc)
  1740. {
  1741. struct htt_soc *soc = (struct htt_soc *)htt_soc;
  1742. return htt_h2t_ver_req_msg(soc);
  1743. }
  1744. void htt_set_htc_handle(struct htt_soc *htt_soc, HTC_HANDLE htc_soc)
  1745. {
  1746. htt_soc->htc_soc = htc_soc;
  1747. }
  1748. HTC_HANDLE htt_get_htc_handle(struct htt_soc *htt_soc)
  1749. {
  1750. return htt_soc->htc_soc;
  1751. }
  1752. struct htt_soc *htt_soc_attach(struct dp_soc *soc, HTC_HANDLE htc_handle)
  1753. {
  1754. int i;
  1755. int j;
  1756. int alloc_size = HTT_SW_UMAC_RING_IDX_MAX * sizeof(unsigned long);
  1757. struct htt_soc *htt_soc = NULL;
  1758. htt_soc = qdf_mem_malloc(sizeof(*htt_soc));
  1759. if (!htt_soc) {
  1760. dp_err("HTT attach failed");
  1761. return NULL;
  1762. }
  1763. for (i = 0; i < MAX_PDEV_CNT; i++) {
  1764. htt_soc->pdevid_tt[i].umac_ttt = qdf_mem_malloc(alloc_size);
  1765. if (!htt_soc->pdevid_tt[i].umac_ttt)
  1766. break;
  1767. qdf_mem_set(htt_soc->pdevid_tt[i].umac_ttt, alloc_size, -1);
  1768. htt_soc->pdevid_tt[i].lmac_ttt = qdf_mem_malloc(alloc_size);
  1769. if (!htt_soc->pdevid_tt[i].lmac_ttt) {
  1770. qdf_mem_free(htt_soc->pdevid_tt[i].umac_ttt);
  1771. break;
  1772. }
  1773. qdf_mem_set(htt_soc->pdevid_tt[i].lmac_ttt, alloc_size, -1);
  1774. }
  1775. if (i != MAX_PDEV_CNT) {
  1776. for (j = 0; j < i; j++) {
  1777. qdf_mem_free(htt_soc->pdevid_tt[j].umac_ttt);
  1778. qdf_mem_free(htt_soc->pdevid_tt[j].lmac_ttt);
  1779. }
  1780. qdf_mem_free(htt_soc);
  1781. return NULL;
  1782. }
  1783. htt_soc->dp_soc = soc;
  1784. htt_soc->htc_soc = htc_handle;
  1785. HTT_TX_MUTEX_INIT(&htt_soc->htt_tx_mutex);
  1786. return htt_soc;
  1787. }
  1788. #if defined(WDI_EVENT_ENABLE) && \
  1789. !defined(REMOVE_PKT_LOG)
  1790. /*
  1791. * dp_pktlog_msg_handler() - Pktlog msg handler
  1792. * @htt_soc: HTT SOC handle
  1793. * @msg_word: Pointer to payload
  1794. *
  1795. * Return: None
  1796. */
  1797. static void
  1798. dp_pktlog_msg_handler(struct htt_soc *soc,
  1799. uint32_t *msg_word)
  1800. {
  1801. uint8_t pdev_id;
  1802. uint8_t target_pdev_id;
  1803. uint32_t *pl_hdr;
  1804. target_pdev_id = HTT_T2H_PKTLOG_PDEV_ID_GET(*msg_word);
  1805. pdev_id = dp_get_host_pdev_id_for_target_pdev_id(soc->dp_soc,
  1806. target_pdev_id);
  1807. pl_hdr = (msg_word + 1);
  1808. dp_wdi_event_handler(WDI_EVENT_OFFLOAD_ALL, soc->dp_soc,
  1809. pl_hdr, HTT_INVALID_PEER, WDI_NO_VAL,
  1810. pdev_id);
  1811. }
  1812. #else
  1813. static void
  1814. dp_pktlog_msg_handler(struct htt_soc *soc,
  1815. uint32_t *msg_word)
  1816. {
  1817. }
  1818. #endif
  1819. /*
  1820. * time_allow_print() - time allow print
  1821. * @htt_ring_tt: ringi_id array of timestamps
  1822. * @ring_id: ring_id (index)
  1823. *
  1824. * Return: 1 for successfully saving timestamp in array
  1825. * and 0 for timestamp falling within 2 seconds after last one
  1826. */
  1827. static bool time_allow_print(unsigned long *htt_ring_tt, u_int8_t ring_id)
  1828. {
  1829. unsigned long tstamp;
  1830. unsigned long delta;
  1831. tstamp = qdf_get_system_timestamp();
  1832. if (!htt_ring_tt)
  1833. return 0; //unable to print backpressure messages
  1834. if (htt_ring_tt[ring_id] == -1) {
  1835. htt_ring_tt[ring_id] = tstamp;
  1836. return 1;
  1837. }
  1838. delta = tstamp - htt_ring_tt[ring_id];
  1839. if (delta >= 2000) {
  1840. htt_ring_tt[ring_id] = tstamp;
  1841. return 1;
  1842. }
  1843. return 0;
  1844. }
  1845. static void dp_htt_alert_print(enum htt_t2h_msg_type msg_type,
  1846. struct dp_pdev *pdev, u_int8_t ring_id,
  1847. u_int16_t hp_idx, u_int16_t tp_idx,
  1848. u_int32_t bkp_time, char *ring_stype)
  1849. {
  1850. dp_alert("seq_num %u msg_type: %d pdev_id: %d ring_type: %s ",
  1851. pdev->bkp_stats.seq_num, msg_type, pdev->pdev_id, ring_stype);
  1852. dp_alert("ring_id: %d hp_idx: %d tp_idx: %d bkpressure_time_ms: %d ",
  1853. ring_id, hp_idx, tp_idx, bkp_time);
  1854. }
  1855. /**
  1856. * dp_get_srng_ring_state_from_hal(): Get hal level ring stats
  1857. * @soc: DP_SOC handle
  1858. * @srng: DP_SRNG handle
  1859. * @ring_type: srng src/dst ring
  1860. *
  1861. * Return: void
  1862. */
  1863. static QDF_STATUS
  1864. dp_get_srng_ring_state_from_hal(struct dp_soc *soc,
  1865. struct dp_pdev *pdev,
  1866. struct dp_srng *srng,
  1867. enum hal_ring_type ring_type,
  1868. struct dp_srng_ring_state *state)
  1869. {
  1870. struct hal_soc *hal_soc;
  1871. if (!soc || !srng || !srng->hal_srng || !state)
  1872. return QDF_STATUS_E_INVAL;
  1873. hal_soc = (struct hal_soc *)soc->hal_soc;
  1874. hal_get_sw_hptp(soc->hal_soc, srng->hal_srng, &state->sw_tail,
  1875. &state->sw_head);
  1876. hal_get_hw_hptp(soc->hal_soc, srng->hal_srng, &state->hw_head,
  1877. &state->hw_tail, ring_type);
  1878. state->ring_type = ring_type;
  1879. return QDF_STATUS_SUCCESS;
  1880. }
  1881. #ifdef QCA_MONITOR_PKT_SUPPORT
  1882. static void
  1883. dp_queue_mon_ring_stats(struct dp_pdev *pdev,
  1884. int lmac_id, uint32_t *num_srng,
  1885. struct dp_soc_srngs_state *soc_srngs_state)
  1886. {
  1887. QDF_STATUS status;
  1888. if (pdev->soc->wlan_cfg_ctx->rxdma1_enable) {
  1889. status = dp_get_srng_ring_state_from_hal
  1890. (pdev->soc, pdev,
  1891. &pdev->soc->rxdma_mon_buf_ring[lmac_id],
  1892. RXDMA_MONITOR_BUF,
  1893. &soc_srngs_state->ring_state[*num_srng]);
  1894. if (status == QDF_STATUS_SUCCESS)
  1895. qdf_assert_always(++(*num_srng) < DP_MAX_SRNGS);
  1896. status = dp_get_srng_ring_state_from_hal
  1897. (pdev->soc, pdev,
  1898. &pdev->soc->rxdma_mon_dst_ring[lmac_id],
  1899. RXDMA_MONITOR_DST,
  1900. &soc_srngs_state->ring_state[*num_srng]);
  1901. if (status == QDF_STATUS_SUCCESS)
  1902. qdf_assert_always(++(*num_srng) < DP_MAX_SRNGS);
  1903. status = dp_get_srng_ring_state_from_hal
  1904. (pdev->soc, pdev,
  1905. &pdev->soc->rxdma_mon_desc_ring[lmac_id],
  1906. RXDMA_MONITOR_DESC,
  1907. &soc_srngs_state->ring_state[*num_srng]);
  1908. if (status == QDF_STATUS_SUCCESS)
  1909. qdf_assert_always(++(*num_srng) < DP_MAX_SRNGS);
  1910. }
  1911. }
  1912. #else
  1913. static void
  1914. dp_queue_mon_ring_stats(struct dp_pdev *pdev,
  1915. int lmac_id, uint32_t *num_srng,
  1916. struct dp_soc_srngs_state *soc_srngs_state)
  1917. {
  1918. }
  1919. #endif
  1920. /**
  1921. * dp_queue_srng_ring_stats(): Print pdev hal level ring stats
  1922. * @pdev: DP_pdev handle
  1923. *
  1924. * Return: void
  1925. */
  1926. static void dp_queue_ring_stats(struct dp_pdev *pdev)
  1927. {
  1928. uint32_t i;
  1929. int mac_id;
  1930. int lmac_id;
  1931. uint32_t j = 0;
  1932. struct dp_soc_srngs_state * soc_srngs_state = NULL;
  1933. QDF_STATUS status;
  1934. soc_srngs_state = qdf_mem_malloc(sizeof(struct dp_soc_srngs_state));
  1935. if (!soc_srngs_state) {
  1936. dp_htt_alert("Memory alloc failed for back pressure event");
  1937. return;
  1938. }
  1939. status = dp_get_srng_ring_state_from_hal
  1940. (pdev->soc, pdev,
  1941. &pdev->soc->reo_exception_ring,
  1942. REO_EXCEPTION,
  1943. &soc_srngs_state->ring_state[j]);
  1944. if (status == QDF_STATUS_SUCCESS)
  1945. qdf_assert_always(++j < DP_MAX_SRNGS);
  1946. status = dp_get_srng_ring_state_from_hal
  1947. (pdev->soc, pdev,
  1948. &pdev->soc->reo_reinject_ring,
  1949. REO_REINJECT,
  1950. &soc_srngs_state->ring_state[j]);
  1951. if (status == QDF_STATUS_SUCCESS)
  1952. qdf_assert_always(++j < DP_MAX_SRNGS);
  1953. status = dp_get_srng_ring_state_from_hal
  1954. (pdev->soc, pdev,
  1955. &pdev->soc->reo_cmd_ring,
  1956. REO_CMD,
  1957. &soc_srngs_state->ring_state[j]);
  1958. if (status == QDF_STATUS_SUCCESS)
  1959. qdf_assert_always(++j < DP_MAX_SRNGS);
  1960. status = dp_get_srng_ring_state_from_hal
  1961. (pdev->soc, pdev,
  1962. &pdev->soc->reo_status_ring,
  1963. REO_STATUS,
  1964. &soc_srngs_state->ring_state[j]);
  1965. if (status == QDF_STATUS_SUCCESS)
  1966. qdf_assert_always(++j < DP_MAX_SRNGS);
  1967. status = dp_get_srng_ring_state_from_hal
  1968. (pdev->soc, pdev,
  1969. &pdev->soc->rx_rel_ring,
  1970. WBM2SW_RELEASE,
  1971. &soc_srngs_state->ring_state[j]);
  1972. if (status == QDF_STATUS_SUCCESS)
  1973. qdf_assert_always(++j < DP_MAX_SRNGS);
  1974. status = dp_get_srng_ring_state_from_hal
  1975. (pdev->soc, pdev,
  1976. &pdev->soc->tcl_cmd_credit_ring,
  1977. TCL_CMD_CREDIT,
  1978. &soc_srngs_state->ring_state[j]);
  1979. if (status == QDF_STATUS_SUCCESS)
  1980. qdf_assert_always(++j < DP_MAX_SRNGS);
  1981. status = dp_get_srng_ring_state_from_hal
  1982. (pdev->soc, pdev,
  1983. &pdev->soc->tcl_status_ring,
  1984. TCL_STATUS,
  1985. &soc_srngs_state->ring_state[j]);
  1986. if (status == QDF_STATUS_SUCCESS)
  1987. qdf_assert_always(++j < DP_MAX_SRNGS);
  1988. status = dp_get_srng_ring_state_from_hal
  1989. (pdev->soc, pdev,
  1990. &pdev->soc->wbm_desc_rel_ring,
  1991. SW2WBM_RELEASE,
  1992. &soc_srngs_state->ring_state[j]);
  1993. if (status == QDF_STATUS_SUCCESS)
  1994. qdf_assert_always(++j < DP_MAX_SRNGS);
  1995. for (i = 0; i < MAX_REO_DEST_RINGS; i++) {
  1996. status = dp_get_srng_ring_state_from_hal
  1997. (pdev->soc, pdev,
  1998. &pdev->soc->reo_dest_ring[i],
  1999. REO_DST,
  2000. &soc_srngs_state->ring_state[j]);
  2001. if (status == QDF_STATUS_SUCCESS)
  2002. qdf_assert_always(++j < DP_MAX_SRNGS);
  2003. }
  2004. for (i = 0; i < pdev->soc->num_tcl_data_rings; i++) {
  2005. status = dp_get_srng_ring_state_from_hal
  2006. (pdev->soc, pdev,
  2007. &pdev->soc->tcl_data_ring[i],
  2008. TCL_DATA,
  2009. &soc_srngs_state->ring_state[j]);
  2010. if (status == QDF_STATUS_SUCCESS)
  2011. qdf_assert_always(++j < DP_MAX_SRNGS);
  2012. }
  2013. for (i = 0; i < MAX_TCL_DATA_RINGS; i++) {
  2014. status = dp_get_srng_ring_state_from_hal
  2015. (pdev->soc, pdev,
  2016. &pdev->soc->tx_comp_ring[i],
  2017. WBM2SW_RELEASE,
  2018. &soc_srngs_state->ring_state[j]);
  2019. if (status == QDF_STATUS_SUCCESS)
  2020. qdf_assert_always(++j < DP_MAX_SRNGS);
  2021. }
  2022. lmac_id = dp_get_lmac_id_for_pdev_id(pdev->soc, 0, pdev->pdev_id);
  2023. status = dp_get_srng_ring_state_from_hal
  2024. (pdev->soc, pdev,
  2025. &pdev->soc->rx_refill_buf_ring
  2026. [lmac_id],
  2027. RXDMA_BUF,
  2028. &soc_srngs_state->ring_state[j]);
  2029. if (status == QDF_STATUS_SUCCESS)
  2030. qdf_assert_always(++j < DP_MAX_SRNGS);
  2031. status = dp_get_srng_ring_state_from_hal
  2032. (pdev->soc, pdev,
  2033. &pdev->rx_refill_buf_ring2,
  2034. RXDMA_BUF,
  2035. &soc_srngs_state->ring_state[j]);
  2036. if (status == QDF_STATUS_SUCCESS)
  2037. qdf_assert_always(++j < DP_MAX_SRNGS);
  2038. for (i = 0; i < MAX_RX_MAC_RINGS; i++) {
  2039. dp_get_srng_ring_state_from_hal
  2040. (pdev->soc, pdev,
  2041. &pdev->rx_mac_buf_ring[i],
  2042. RXDMA_BUF,
  2043. &soc_srngs_state->ring_state[j]);
  2044. if (status == QDF_STATUS_SUCCESS)
  2045. qdf_assert_always(++j < DP_MAX_SRNGS);
  2046. }
  2047. for (mac_id = 0; mac_id < NUM_RXDMA_RINGS_PER_PDEV; mac_id++) {
  2048. lmac_id = dp_get_lmac_id_for_pdev_id(pdev->soc,
  2049. mac_id, pdev->pdev_id);
  2050. dp_queue_mon_ring_stats(pdev, lmac_id, &j,
  2051. soc_srngs_state);
  2052. status = dp_get_srng_ring_state_from_hal
  2053. (pdev->soc, pdev,
  2054. &pdev->soc->rxdma_mon_status_ring[lmac_id],
  2055. RXDMA_MONITOR_STATUS,
  2056. &soc_srngs_state->ring_state[j]);
  2057. if (status == QDF_STATUS_SUCCESS)
  2058. qdf_assert_always(++j < DP_MAX_SRNGS);
  2059. }
  2060. for (i = 0; i < NUM_RXDMA_RINGS_PER_PDEV; i++) {
  2061. lmac_id = dp_get_lmac_id_for_pdev_id(pdev->soc,
  2062. i, pdev->pdev_id);
  2063. status = dp_get_srng_ring_state_from_hal
  2064. (pdev->soc, pdev,
  2065. &pdev->soc->rxdma_err_dst_ring
  2066. [lmac_id],
  2067. RXDMA_DST,
  2068. &soc_srngs_state->ring_state[j]);
  2069. if (status == QDF_STATUS_SUCCESS)
  2070. qdf_assert_always(++j < DP_MAX_SRNGS);
  2071. }
  2072. soc_srngs_state->max_ring_id = j;
  2073. qdf_spin_lock_bh(&pdev->bkp_stats.list_lock);
  2074. soc_srngs_state->seq_num = pdev->bkp_stats.seq_num;
  2075. TAILQ_INSERT_TAIL(&pdev->bkp_stats.list, soc_srngs_state,
  2076. list_elem);
  2077. pdev->bkp_stats.seq_num++;
  2078. qdf_spin_unlock_bh(&pdev->bkp_stats.list_lock);
  2079. qdf_queue_work(0, pdev->bkp_stats.work_queue,
  2080. &pdev->bkp_stats.work);
  2081. }
  2082. /*
  2083. * dp_htt_bkp_event_alert() - htt backpressure event alert
  2084. * @msg_word: htt packet context
  2085. * @htt_soc: HTT SOC handle
  2086. *
  2087. * Return: after attempting to print stats
  2088. */
  2089. static void dp_htt_bkp_event_alert(u_int32_t *msg_word, struct htt_soc *soc)
  2090. {
  2091. u_int8_t ring_type;
  2092. u_int8_t pdev_id;
  2093. uint8_t target_pdev_id;
  2094. u_int8_t ring_id;
  2095. u_int16_t hp_idx;
  2096. u_int16_t tp_idx;
  2097. u_int32_t bkp_time;
  2098. enum htt_t2h_msg_type msg_type;
  2099. struct dp_soc *dpsoc;
  2100. struct dp_pdev *pdev;
  2101. struct dp_htt_timestamp *radio_tt;
  2102. if (!soc)
  2103. return;
  2104. dpsoc = (struct dp_soc *)soc->dp_soc;
  2105. msg_type = HTT_T2H_MSG_TYPE_GET(*msg_word);
  2106. ring_type = HTT_T2H_RX_BKPRESSURE_RING_TYPE_GET(*msg_word);
  2107. target_pdev_id = HTT_T2H_RX_BKPRESSURE_PDEV_ID_GET(*msg_word);
  2108. pdev_id = dp_get_host_pdev_id_for_target_pdev_id(soc->dp_soc,
  2109. target_pdev_id);
  2110. if (pdev_id >= MAX_PDEV_CNT) {
  2111. dp_htt_debug("%pK: pdev id %d is invalid", soc, pdev_id);
  2112. return;
  2113. }
  2114. pdev = (struct dp_pdev *)dpsoc->pdev_list[pdev_id];
  2115. ring_id = HTT_T2H_RX_BKPRESSURE_RINGID_GET(*msg_word);
  2116. hp_idx = HTT_T2H_RX_BKPRESSURE_HEAD_IDX_GET(*(msg_word + 1));
  2117. tp_idx = HTT_T2H_RX_BKPRESSURE_TAIL_IDX_GET(*(msg_word + 1));
  2118. bkp_time = HTT_T2H_RX_BKPRESSURE_TIME_MS_GET(*(msg_word + 2));
  2119. radio_tt = &soc->pdevid_tt[pdev_id];
  2120. switch (ring_type) {
  2121. case HTT_SW_RING_TYPE_UMAC:
  2122. if (!time_allow_print(radio_tt->umac_ttt, ring_id))
  2123. return;
  2124. dp_htt_alert_print(msg_type, pdev, ring_id, hp_idx, tp_idx,
  2125. bkp_time, "HTT_SW_RING_TYPE_UMAC");
  2126. break;
  2127. case HTT_SW_RING_TYPE_LMAC:
  2128. if (!time_allow_print(radio_tt->lmac_ttt, ring_id))
  2129. return;
  2130. dp_htt_alert_print(msg_type, pdev, ring_id, hp_idx, tp_idx,
  2131. bkp_time, "HTT_SW_RING_TYPE_LMAC");
  2132. break;
  2133. default:
  2134. dp_htt_alert_print(msg_type, pdev, ring_id, hp_idx, tp_idx,
  2135. bkp_time, "UNKNOWN");
  2136. break;
  2137. }
  2138. dp_queue_ring_stats(pdev);
  2139. }
  2140. #ifdef WLAN_FEATURE_PKT_CAPTURE_V2
  2141. /*
  2142. * dp_offload_ind_handler() - offload msg handler
  2143. * @htt_soc: HTT SOC handle
  2144. * @msg_word: Pointer to payload
  2145. *
  2146. * Return: None
  2147. */
  2148. static void
  2149. dp_offload_ind_handler(struct htt_soc *soc, uint32_t *msg_word)
  2150. {
  2151. u_int8_t pdev_id;
  2152. u_int8_t target_pdev_id;
  2153. target_pdev_id = HTT_T2H_PPDU_STATS_PDEV_ID_GET(*msg_word);
  2154. pdev_id = dp_get_host_pdev_id_for_target_pdev_id(soc->dp_soc,
  2155. target_pdev_id);
  2156. dp_wdi_event_handler(WDI_EVENT_PKT_CAPTURE_OFFLOAD_TX_DATA, soc->dp_soc,
  2157. msg_word, HTT_INVALID_VDEV, WDI_NO_VAL,
  2158. pdev_id);
  2159. }
  2160. #else
  2161. static void
  2162. dp_offload_ind_handler(struct htt_soc *soc, uint32_t *msg_word)
  2163. {
  2164. }
  2165. #endif
  2166. /*
  2167. * dp_htt_t2h_msg_handler() - Generic Target to host Msg/event handler
  2168. * @context: Opaque context (HTT SOC handle)
  2169. * @pkt: HTC packet
  2170. */
  2171. static void dp_htt_t2h_msg_handler(void *context, HTC_PACKET *pkt)
  2172. {
  2173. struct htt_soc *soc = (struct htt_soc *) context;
  2174. qdf_nbuf_t htt_t2h_msg = (qdf_nbuf_t) pkt->pPktContext;
  2175. u_int32_t *msg_word;
  2176. enum htt_t2h_msg_type msg_type;
  2177. bool free_buf = true;
  2178. /* check for successful message reception */
  2179. if (pkt->Status != QDF_STATUS_SUCCESS) {
  2180. if (pkt->Status != QDF_STATUS_E_CANCELED)
  2181. soc->stats.htc_err_cnt++;
  2182. qdf_nbuf_free(htt_t2h_msg);
  2183. return;
  2184. }
  2185. /* TODO: Check if we should pop the HTC/HTT header alignment padding */
  2186. msg_word = (u_int32_t *) qdf_nbuf_data(htt_t2h_msg);
  2187. msg_type = HTT_T2H_MSG_TYPE_GET(*msg_word);
  2188. htt_event_record(soc->htt_logger_handle,
  2189. msg_type, (uint8_t *)msg_word);
  2190. switch (msg_type) {
  2191. case HTT_T2H_MSG_TYPE_BKPRESSURE_EVENT_IND:
  2192. {
  2193. dp_htt_bkp_event_alert(msg_word, soc);
  2194. break;
  2195. }
  2196. case HTT_T2H_MSG_TYPE_PEER_MAP:
  2197. {
  2198. u_int8_t mac_addr_deswizzle_buf[QDF_MAC_ADDR_SIZE];
  2199. u_int8_t *peer_mac_addr;
  2200. u_int16_t peer_id;
  2201. u_int16_t hw_peer_id;
  2202. u_int8_t vdev_id;
  2203. u_int8_t is_wds;
  2204. struct dp_soc *dpsoc = (struct dp_soc *)soc->dp_soc;
  2205. peer_id = HTT_RX_PEER_MAP_PEER_ID_GET(*msg_word);
  2206. hw_peer_id =
  2207. HTT_RX_PEER_MAP_HW_PEER_ID_GET(*(msg_word+2));
  2208. vdev_id = HTT_RX_PEER_MAP_VDEV_ID_GET(*msg_word);
  2209. peer_mac_addr = htt_t2h_mac_addr_deswizzle(
  2210. (u_int8_t *) (msg_word+1),
  2211. &mac_addr_deswizzle_buf[0]);
  2212. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2213. QDF_TRACE_LEVEL_INFO,
  2214. "HTT_T2H_MSG_TYPE_PEER_MAP msg for peer id %d vdev id %d n",
  2215. peer_id, vdev_id);
  2216. /*
  2217. * check if peer already exists for this peer_id, if so
  2218. * this peer map event is in response for a wds peer add
  2219. * wmi command sent during wds source port learning.
  2220. * in this case just add the ast entry to the existing
  2221. * peer ast_list.
  2222. */
  2223. is_wds = !!(dpsoc->peer_id_to_obj_map[peer_id]);
  2224. dp_rx_peer_map_handler(soc->dp_soc, peer_id, hw_peer_id,
  2225. vdev_id, peer_mac_addr, 0,
  2226. is_wds);
  2227. break;
  2228. }
  2229. case HTT_T2H_MSG_TYPE_PEER_UNMAP:
  2230. {
  2231. u_int16_t peer_id;
  2232. u_int8_t vdev_id;
  2233. u_int8_t mac_addr[QDF_MAC_ADDR_SIZE] = {0};
  2234. peer_id = HTT_RX_PEER_UNMAP_PEER_ID_GET(*msg_word);
  2235. vdev_id = HTT_RX_PEER_UNMAP_VDEV_ID_GET(*msg_word);
  2236. dp_rx_peer_unmap_handler(soc->dp_soc, peer_id,
  2237. vdev_id, mac_addr, 0,
  2238. DP_PEER_WDS_COUNT_INVALID);
  2239. break;
  2240. }
  2241. case HTT_T2H_MSG_TYPE_SEC_IND:
  2242. {
  2243. u_int16_t peer_id;
  2244. enum cdp_sec_type sec_type;
  2245. int is_unicast;
  2246. peer_id = HTT_SEC_IND_PEER_ID_GET(*msg_word);
  2247. sec_type = HTT_SEC_IND_SEC_TYPE_GET(*msg_word);
  2248. is_unicast = HTT_SEC_IND_UNICAST_GET(*msg_word);
  2249. /* point to the first part of the Michael key */
  2250. msg_word++;
  2251. dp_rx_sec_ind_handler(
  2252. soc->dp_soc, peer_id, sec_type, is_unicast,
  2253. msg_word, msg_word + 2);
  2254. break;
  2255. }
  2256. case HTT_T2H_MSG_TYPE_PPDU_STATS_IND:
  2257. {
  2258. free_buf =
  2259. dp_monitor_ppdu_stats_ind_handler(soc,
  2260. msg_word,
  2261. htt_t2h_msg);
  2262. break;
  2263. }
  2264. case HTT_T2H_MSG_TYPE_PKTLOG:
  2265. {
  2266. dp_pktlog_msg_handler(soc, msg_word);
  2267. break;
  2268. }
  2269. case HTT_T2H_MSG_TYPE_VERSION_CONF:
  2270. {
  2271. /*
  2272. * HTC maintains runtime pm count for H2T messages that
  2273. * have a response msg from FW. This count ensures that
  2274. * in the case FW does not sent out the response or host
  2275. * did not process this indication runtime_put happens
  2276. * properly in the cleanup path.
  2277. */
  2278. if (htc_dec_return_runtime_cnt(soc->htc_soc) >= 0)
  2279. htc_pm_runtime_put(soc->htc_soc);
  2280. else
  2281. soc->stats.htt_ver_req_put_skip++;
  2282. soc->tgt_ver.major = HTT_VER_CONF_MAJOR_GET(*msg_word);
  2283. soc->tgt_ver.minor = HTT_VER_CONF_MINOR_GET(*msg_word);
  2284. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO_LOW,
  2285. "target uses HTT version %d.%d; host uses %d.%d",
  2286. soc->tgt_ver.major, soc->tgt_ver.minor,
  2287. HTT_CURRENT_VERSION_MAJOR,
  2288. HTT_CURRENT_VERSION_MINOR);
  2289. if (soc->tgt_ver.major != HTT_CURRENT_VERSION_MAJOR) {
  2290. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2291. QDF_TRACE_LEVEL_WARN,
  2292. "*** Incompatible host/target HTT versions!");
  2293. }
  2294. /* abort if the target is incompatible with the host */
  2295. qdf_assert(soc->tgt_ver.major ==
  2296. HTT_CURRENT_VERSION_MAJOR);
  2297. if (soc->tgt_ver.minor != HTT_CURRENT_VERSION_MINOR) {
  2298. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2299. QDF_TRACE_LEVEL_INFO_LOW,
  2300. "*** Warning: host/target HTT versions"
  2301. " are different, though compatible!");
  2302. }
  2303. break;
  2304. }
  2305. case HTT_T2H_MSG_TYPE_RX_ADDBA:
  2306. {
  2307. uint16_t peer_id;
  2308. uint8_t tid;
  2309. uint8_t win_sz;
  2310. uint16_t status;
  2311. struct dp_peer *peer;
  2312. /*
  2313. * Update REO Queue Desc with new values
  2314. */
  2315. peer_id = HTT_RX_ADDBA_PEER_ID_GET(*msg_word);
  2316. tid = HTT_RX_ADDBA_TID_GET(*msg_word);
  2317. win_sz = HTT_RX_ADDBA_WIN_SIZE_GET(*msg_word);
  2318. peer = dp_peer_get_ref_by_id(soc->dp_soc, peer_id,
  2319. DP_MOD_ID_HTT);
  2320. /*
  2321. * Window size needs to be incremented by 1
  2322. * since fw needs to represent a value of 256
  2323. * using just 8 bits
  2324. */
  2325. if (peer) {
  2326. status = dp_addba_requestprocess_wifi3(
  2327. (struct cdp_soc_t *)soc->dp_soc,
  2328. peer->mac_addr.raw, peer->vdev->vdev_id,
  2329. 0, tid, 0, win_sz + 1, 0xffff);
  2330. /*
  2331. * If PEER_LOCK_REF_PROTECT enbled dec ref
  2332. * which is inc by dp_peer_get_ref_by_id
  2333. */
  2334. dp_peer_unref_delete(peer, DP_MOD_ID_HTT);
  2335. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2336. QDF_TRACE_LEVEL_INFO,
  2337. FL("PeerID %d BAW %d TID %d stat %d"),
  2338. peer_id, win_sz, tid, status);
  2339. } else {
  2340. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2341. QDF_TRACE_LEVEL_ERROR,
  2342. FL("Peer not found peer id %d"),
  2343. peer_id);
  2344. }
  2345. break;
  2346. }
  2347. case HTT_T2H_MSG_TYPE_EXT_STATS_CONF:
  2348. {
  2349. dp_txrx_fw_stats_handler(soc->dp_soc, htt_t2h_msg);
  2350. break;
  2351. }
  2352. case HTT_T2H_MSG_TYPE_PEER_MAP_V2:
  2353. {
  2354. u_int8_t mac_addr_deswizzle_buf[QDF_MAC_ADDR_SIZE];
  2355. u_int8_t *peer_mac_addr;
  2356. u_int16_t peer_id;
  2357. u_int16_t hw_peer_id;
  2358. u_int8_t vdev_id;
  2359. bool is_wds;
  2360. u_int16_t ast_hash;
  2361. struct dp_ast_flow_override_info ast_flow_info;
  2362. qdf_mem_set(&ast_flow_info, 0,
  2363. sizeof(struct dp_ast_flow_override_info));
  2364. peer_id = HTT_RX_PEER_MAP_V2_SW_PEER_ID_GET(*msg_word);
  2365. hw_peer_id =
  2366. HTT_RX_PEER_MAP_V2_HW_PEER_ID_GET(*(msg_word + 2));
  2367. vdev_id = HTT_RX_PEER_MAP_V2_VDEV_ID_GET(*msg_word);
  2368. peer_mac_addr =
  2369. htt_t2h_mac_addr_deswizzle((u_int8_t *)(msg_word + 1),
  2370. &mac_addr_deswizzle_buf[0]);
  2371. is_wds =
  2372. HTT_RX_PEER_MAP_V2_NEXT_HOP_GET(*(msg_word + 3));
  2373. ast_hash =
  2374. HTT_RX_PEER_MAP_V2_AST_HASH_VALUE_GET(*(msg_word + 3));
  2375. /*
  2376. * Update 4 ast_index per peer, ast valid mask
  2377. * and TID flow valid mask.
  2378. * AST valid mask is 3 bit field corresponds to
  2379. * ast_index[3:1]. ast_index 0 is always valid.
  2380. */
  2381. ast_flow_info.ast_valid_mask =
  2382. HTT_RX_PEER_MAP_V2_AST_VALID_MASK_GET(*(msg_word + 3));
  2383. ast_flow_info.ast_idx[0] = hw_peer_id;
  2384. ast_flow_info.ast_flow_mask[0] =
  2385. HTT_RX_PEER_MAP_V2_AST_0_FLOW_MASK_GET(*(msg_word + 4));
  2386. ast_flow_info.ast_idx[1] =
  2387. HTT_RX_PEER_MAP_V2_AST_INDEX_1_GET(*(msg_word + 4));
  2388. ast_flow_info.ast_flow_mask[1] =
  2389. HTT_RX_PEER_MAP_V2_AST_1_FLOW_MASK_GET(*(msg_word + 4));
  2390. ast_flow_info.ast_idx[2] =
  2391. HTT_RX_PEER_MAP_V2_AST_INDEX_2_GET(*(msg_word + 5));
  2392. ast_flow_info.ast_flow_mask[2] =
  2393. HTT_RX_PEER_MAP_V2_AST_2_FLOW_MASK_GET(*(msg_word + 4));
  2394. ast_flow_info.ast_idx[3] =
  2395. HTT_RX_PEER_MAP_V2_AST_INDEX_3_GET(*(msg_word + 6));
  2396. ast_flow_info.ast_flow_mask[3] =
  2397. HTT_RX_PEER_MAP_V2_AST_3_FLOW_MASK_GET(*(msg_word + 4));
  2398. /*
  2399. * TID valid mask is applicable only
  2400. * for HI and LOW priority flows.
  2401. * tid_valid_mas is 8 bit field corresponds
  2402. * to TID[7:0]
  2403. */
  2404. ast_flow_info.tid_valid_low_pri_mask =
  2405. HTT_RX_PEER_MAP_V2_TID_VALID_LOW_PRI_GET(*(msg_word + 5));
  2406. ast_flow_info.tid_valid_hi_pri_mask =
  2407. HTT_RX_PEER_MAP_V2_TID_VALID_HI_PRI_GET(*(msg_word + 5));
  2408. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2409. QDF_TRACE_LEVEL_INFO,
  2410. "HTT_T2H_MSG_TYPE_PEER_MAP msg for peer id %d vdev id %d n",
  2411. peer_id, vdev_id);
  2412. dp_rx_peer_map_handler(soc->dp_soc, peer_id,
  2413. hw_peer_id, vdev_id,
  2414. peer_mac_addr, ast_hash,
  2415. is_wds);
  2416. /*
  2417. * Update ast indexes for flow override support
  2418. * Applicable only for non wds peers
  2419. */
  2420. dp_peer_ast_index_flow_queue_map_create(
  2421. soc->dp_soc, is_wds,
  2422. peer_id, peer_mac_addr,
  2423. &ast_flow_info);
  2424. break;
  2425. }
  2426. case HTT_T2H_MSG_TYPE_PEER_UNMAP_V2:
  2427. {
  2428. u_int8_t mac_addr_deswizzle_buf[QDF_MAC_ADDR_SIZE];
  2429. u_int8_t *mac_addr;
  2430. u_int16_t peer_id;
  2431. u_int8_t vdev_id;
  2432. u_int8_t is_wds;
  2433. u_int32_t free_wds_count;
  2434. peer_id =
  2435. HTT_RX_PEER_UNMAP_V2_SW_PEER_ID_GET(*msg_word);
  2436. vdev_id = HTT_RX_PEER_UNMAP_V2_VDEV_ID_GET(*msg_word);
  2437. mac_addr =
  2438. htt_t2h_mac_addr_deswizzle((u_int8_t *)(msg_word + 1),
  2439. &mac_addr_deswizzle_buf[0]);
  2440. is_wds =
  2441. HTT_RX_PEER_UNMAP_V2_NEXT_HOP_GET(*(msg_word + 2));
  2442. free_wds_count =
  2443. HTT_RX_PEER_UNMAP_V2_PEER_WDS_FREE_COUNT_GET(*(msg_word + 4));
  2444. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2445. QDF_TRACE_LEVEL_INFO,
  2446. "HTT_T2H_MSG_TYPE_PEER_UNMAP msg for peer id %d vdev id %d n",
  2447. peer_id, vdev_id);
  2448. dp_rx_peer_unmap_handler(soc->dp_soc, peer_id,
  2449. vdev_id, mac_addr,
  2450. is_wds, free_wds_count);
  2451. break;
  2452. }
  2453. case HTT_T2H_MSG_TYPE_RX_DELBA:
  2454. {
  2455. uint16_t peer_id;
  2456. uint8_t tid;
  2457. uint8_t win_sz;
  2458. QDF_STATUS status;
  2459. peer_id = HTT_RX_DELBA_PEER_ID_GET(*msg_word);
  2460. tid = HTT_RX_DELBA_TID_GET(*msg_word);
  2461. win_sz = HTT_RX_DELBA_WIN_SIZE_GET(*msg_word);
  2462. status = dp_rx_delba_ind_handler(
  2463. soc->dp_soc,
  2464. peer_id, tid, win_sz);
  2465. QDF_TRACE(QDF_MODULE_ID_TXRX,
  2466. QDF_TRACE_LEVEL_INFO,
  2467. FL("DELBA PeerID %d BAW %d TID %d stat %d"),
  2468. peer_id, win_sz, tid, status);
  2469. break;
  2470. }
  2471. case HTT_T2H_MSG_TYPE_FSE_CMEM_BASE_SEND:
  2472. {
  2473. uint16_t num_entries;
  2474. uint32_t cmem_ba_lo;
  2475. uint32_t cmem_ba_hi;
  2476. num_entries = HTT_CMEM_BASE_SEND_NUM_ENTRIES_GET(*msg_word);
  2477. cmem_ba_lo = *(msg_word + 1);
  2478. cmem_ba_hi = *(msg_word + 2);
  2479. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_INFO,
  2480. FL("CMEM FSE num_entries %u CMEM BA LO %x HI %x"),
  2481. num_entries, cmem_ba_lo, cmem_ba_hi);
  2482. dp_rx_fst_update_cmem_params(soc->dp_soc, num_entries,
  2483. cmem_ba_lo, cmem_ba_hi);
  2484. break;
  2485. }
  2486. case HTT_T2H_MSG_TYPE_TX_OFFLOAD_DELIVER_IND:
  2487. {
  2488. dp_offload_ind_handler(soc, msg_word);
  2489. break;
  2490. }
  2491. default:
  2492. break;
  2493. };
  2494. /* Free the indication buffer */
  2495. if (free_buf)
  2496. qdf_nbuf_free(htt_t2h_msg);
  2497. }
  2498. /*
  2499. * dp_htt_h2t_full() - Send full handler (called from HTC)
  2500. * @context: Opaque context (HTT SOC handle)
  2501. * @pkt: HTC packet
  2502. *
  2503. * Return: enum htc_send_full_action
  2504. */
  2505. static enum htc_send_full_action
  2506. dp_htt_h2t_full(void *context, HTC_PACKET *pkt)
  2507. {
  2508. return HTC_SEND_FULL_KEEP;
  2509. }
  2510. /*
  2511. * dp_htt_hif_t2h_hp_callback() - HIF callback for high priority T2H messages
  2512. * @context: Opaque context (HTT SOC handle)
  2513. * @nbuf: nbuf containing T2H message
  2514. * @pipe_id: HIF pipe ID
  2515. *
  2516. * Return: QDF_STATUS
  2517. *
  2518. * TODO: Temporary change to bypass HTC connection for this new HIF pipe, which
  2519. * will be used for packet log and other high-priority HTT messages. Proper
  2520. * HTC connection to be added later once required FW changes are available
  2521. */
  2522. static QDF_STATUS
  2523. dp_htt_hif_t2h_hp_callback (void *context, qdf_nbuf_t nbuf, uint8_t pipe_id)
  2524. {
  2525. QDF_STATUS rc = QDF_STATUS_SUCCESS;
  2526. HTC_PACKET htc_pkt;
  2527. qdf_assert_always(pipe_id == DP_HTT_T2H_HP_PIPE);
  2528. qdf_mem_zero(&htc_pkt, sizeof(htc_pkt));
  2529. htc_pkt.Status = QDF_STATUS_SUCCESS;
  2530. htc_pkt.pPktContext = (void *)nbuf;
  2531. dp_htt_t2h_msg_handler(context, &htc_pkt);
  2532. return rc;
  2533. }
  2534. /*
  2535. * htt_htc_soc_attach() - Register SOC level HTT instance with HTC
  2536. * @htt_soc: HTT SOC handle
  2537. *
  2538. * Return: QDF_STATUS
  2539. */
  2540. static QDF_STATUS
  2541. htt_htc_soc_attach(struct htt_soc *soc)
  2542. {
  2543. struct htc_service_connect_req connect;
  2544. struct htc_service_connect_resp response;
  2545. QDF_STATUS status;
  2546. struct dp_soc *dpsoc = soc->dp_soc;
  2547. qdf_mem_zero(&connect, sizeof(connect));
  2548. qdf_mem_zero(&response, sizeof(response));
  2549. connect.pMetaData = NULL;
  2550. connect.MetaDataLength = 0;
  2551. connect.EpCallbacks.pContext = soc;
  2552. connect.EpCallbacks.EpTxComplete = dp_htt_h2t_send_complete;
  2553. connect.EpCallbacks.EpTxCompleteMultiple = NULL;
  2554. connect.EpCallbacks.EpRecv = dp_htt_t2h_msg_handler;
  2555. /* rx buffers currently are provided by HIF, not by EpRecvRefill */
  2556. connect.EpCallbacks.EpRecvRefill = NULL;
  2557. /* N/A, fill is done by HIF */
  2558. connect.EpCallbacks.RecvRefillWaterMark = 1;
  2559. connect.EpCallbacks.EpSendFull = dp_htt_h2t_full;
  2560. /*
  2561. * Specify how deep to let a queue get before htc_send_pkt will
  2562. * call the EpSendFull function due to excessive send queue depth.
  2563. */
  2564. connect.MaxSendQueueDepth = DP_HTT_MAX_SEND_QUEUE_DEPTH;
  2565. /* disable flow control for HTT data message service */
  2566. connect.ConnectionFlags |= HTC_CONNECT_FLAGS_DISABLE_CREDIT_FLOW_CTRL;
  2567. /* connect to control service */
  2568. connect.service_id = HTT_DATA_MSG_SVC;
  2569. status = htc_connect_service(soc->htc_soc, &connect, &response);
  2570. if (status != QDF_STATUS_SUCCESS)
  2571. return status;
  2572. soc->htc_endpoint = response.Endpoint;
  2573. hif_save_htc_htt_config_endpoint(dpsoc->hif_handle, soc->htc_endpoint);
  2574. htt_interface_logging_init(&soc->htt_logger_handle, soc->ctrl_psoc);
  2575. dp_hif_update_pipe_callback(soc->dp_soc, (void *)soc,
  2576. dp_htt_hif_t2h_hp_callback, DP_HTT_T2H_HP_PIPE);
  2577. return QDF_STATUS_SUCCESS; /* success */
  2578. }
  2579. /*
  2580. * htt_soc_initialize() - SOC level HTT initialization
  2581. * @htt_soc: Opaque htt SOC handle
  2582. * @ctrl_psoc: Opaque ctrl SOC handle
  2583. * @htc_soc: SOC level HTC handle
  2584. * @hal_soc: Opaque HAL SOC handle
  2585. * @osdev: QDF device
  2586. *
  2587. * Return: HTT handle on success; NULL on failure
  2588. */
  2589. void *
  2590. htt_soc_initialize(struct htt_soc *htt_soc,
  2591. struct cdp_ctrl_objmgr_psoc *ctrl_psoc,
  2592. HTC_HANDLE htc_soc,
  2593. hal_soc_handle_t hal_soc_hdl, qdf_device_t osdev)
  2594. {
  2595. struct htt_soc *soc = (struct htt_soc *)htt_soc;
  2596. soc->osdev = osdev;
  2597. soc->ctrl_psoc = ctrl_psoc;
  2598. soc->htc_soc = htc_soc;
  2599. soc->hal_soc = hal_soc_hdl;
  2600. if (htt_htc_soc_attach(soc))
  2601. goto fail2;
  2602. return soc;
  2603. fail2:
  2604. return NULL;
  2605. }
  2606. void htt_soc_htc_dealloc(struct htt_soc *htt_handle)
  2607. {
  2608. htt_interface_logging_deinit(htt_handle->htt_logger_handle);
  2609. htt_htc_misc_pkt_pool_free(htt_handle);
  2610. htt_htc_pkt_pool_free(htt_handle);
  2611. }
  2612. /*
  2613. * htt_soc_htc_prealloc() - HTC memory prealloc
  2614. * @htt_soc: SOC level HTT handle
  2615. *
  2616. * Return: QDF_STATUS_SUCCESS on Success or
  2617. * QDF_STATUS_E_NOMEM on allocation failure
  2618. */
  2619. QDF_STATUS htt_soc_htc_prealloc(struct htt_soc *soc)
  2620. {
  2621. int i;
  2622. soc->htt_htc_pkt_freelist = NULL;
  2623. /* pre-allocate some HTC_PACKET objects */
  2624. for (i = 0; i < HTT_HTC_PKT_POOL_INIT_SIZE; i++) {
  2625. struct dp_htt_htc_pkt_union *pkt;
  2626. pkt = qdf_mem_malloc(sizeof(*pkt));
  2627. if (!pkt)
  2628. return QDF_STATUS_E_NOMEM;
  2629. htt_htc_pkt_free(soc, &pkt->u.pkt);
  2630. }
  2631. return QDF_STATUS_SUCCESS;
  2632. }
  2633. /*
  2634. * htt_soc_detach() - Free SOC level HTT handle
  2635. * @htt_hdl: HTT SOC handle
  2636. */
  2637. void htt_soc_detach(struct htt_soc *htt_hdl)
  2638. {
  2639. int i;
  2640. struct htt_soc *htt_handle = (struct htt_soc *)htt_hdl;
  2641. for (i = 0; i < MAX_PDEV_CNT; i++) {
  2642. qdf_mem_free(htt_handle->pdevid_tt[i].umac_ttt);
  2643. qdf_mem_free(htt_handle->pdevid_tt[i].lmac_ttt);
  2644. }
  2645. HTT_TX_MUTEX_DESTROY(&htt_handle->htt_tx_mutex);
  2646. qdf_mem_free(htt_handle);
  2647. }
  2648. /**
  2649. * dp_h2t_ext_stats_msg_send(): function to contruct HTT message to pass to FW
  2650. * @pdev: DP PDEV handle
  2651. * @stats_type_upload_mask: stats type requested by user
  2652. * @config_param_0: extra configuration parameters
  2653. * @config_param_1: extra configuration parameters
  2654. * @config_param_2: extra configuration parameters
  2655. * @config_param_3: extra configuration parameters
  2656. * @mac_id: mac number
  2657. *
  2658. * return: QDF STATUS
  2659. */
  2660. QDF_STATUS dp_h2t_ext_stats_msg_send(struct dp_pdev *pdev,
  2661. uint32_t stats_type_upload_mask, uint32_t config_param_0,
  2662. uint32_t config_param_1, uint32_t config_param_2,
  2663. uint32_t config_param_3, int cookie_val, int cookie_msb,
  2664. uint8_t mac_id)
  2665. {
  2666. struct htt_soc *soc = pdev->soc->htt_handle;
  2667. struct dp_htt_htc_pkt *pkt;
  2668. qdf_nbuf_t msg;
  2669. uint32_t *msg_word;
  2670. uint8_t pdev_mask = 0;
  2671. uint8_t *htt_logger_bufp;
  2672. int mac_for_pdev;
  2673. int target_pdev_id;
  2674. QDF_STATUS status;
  2675. msg = qdf_nbuf_alloc(
  2676. soc->osdev,
  2677. HTT_MSG_BUF_SIZE(HTT_H2T_EXT_STATS_REQ_MSG_SZ),
  2678. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, TRUE);
  2679. if (!msg)
  2680. return QDF_STATUS_E_NOMEM;
  2681. /*TODO:Add support for SOC stats
  2682. * Bit 0: SOC Stats
  2683. * Bit 1: Pdev stats for pdev id 0
  2684. * Bit 2: Pdev stats for pdev id 1
  2685. * Bit 3: Pdev stats for pdev id 2
  2686. */
  2687. mac_for_pdev = dp_get_mac_id_for_pdev(mac_id, pdev->pdev_id);
  2688. target_pdev_id =
  2689. dp_get_target_pdev_id_for_host_pdev_id(pdev->soc, mac_for_pdev);
  2690. pdev_mask = 1 << target_pdev_id;
  2691. /*
  2692. * Set the length of the message.
  2693. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  2694. * separately during the below call to qdf_nbuf_push_head.
  2695. * The contribution from the HTC header is added separately inside HTC.
  2696. */
  2697. if (qdf_nbuf_put_tail(msg, HTT_H2T_EXT_STATS_REQ_MSG_SZ) == NULL) {
  2698. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  2699. "Failed to expand head for HTT_EXT_STATS");
  2700. qdf_nbuf_free(msg);
  2701. return QDF_STATUS_E_FAILURE;
  2702. }
  2703. dp_htt_tx_stats_info("%pK: cookie <-> %d\n config_param_0 %u\n"
  2704. "config_param_1 %u\n config_param_2 %u\n"
  2705. "config_param_4 %u\n -------------",
  2706. pdev->soc, cookie_val,
  2707. config_param_0,
  2708. config_param_1, config_param_2, config_param_3);
  2709. msg_word = (uint32_t *) qdf_nbuf_data(msg);
  2710. qdf_nbuf_push_head(msg, HTC_HDR_ALIGNMENT_PADDING);
  2711. htt_logger_bufp = (uint8_t *)msg_word;
  2712. *msg_word = 0;
  2713. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_EXT_STATS_REQ);
  2714. HTT_H2T_EXT_STATS_REQ_PDEV_MASK_SET(*msg_word, pdev_mask);
  2715. HTT_H2T_EXT_STATS_REQ_STATS_TYPE_SET(*msg_word, stats_type_upload_mask);
  2716. /* word 1 */
  2717. msg_word++;
  2718. *msg_word = 0;
  2719. HTT_H2T_EXT_STATS_REQ_CONFIG_PARAM_SET(*msg_word, config_param_0);
  2720. /* word 2 */
  2721. msg_word++;
  2722. *msg_word = 0;
  2723. HTT_H2T_EXT_STATS_REQ_CONFIG_PARAM_SET(*msg_word, config_param_1);
  2724. /* word 3 */
  2725. msg_word++;
  2726. *msg_word = 0;
  2727. HTT_H2T_EXT_STATS_REQ_CONFIG_PARAM_SET(*msg_word, config_param_2);
  2728. /* word 4 */
  2729. msg_word++;
  2730. *msg_word = 0;
  2731. HTT_H2T_EXT_STATS_REQ_CONFIG_PARAM_SET(*msg_word, config_param_3);
  2732. HTT_H2T_EXT_STATS_REQ_CONFIG_PARAM_SET(*msg_word, 0);
  2733. /* word 5 */
  2734. msg_word++;
  2735. /* word 6 */
  2736. msg_word++;
  2737. *msg_word = 0;
  2738. HTT_H2T_EXT_STATS_REQ_CONFIG_PARAM_SET(*msg_word, cookie_val);
  2739. /* word 7 */
  2740. msg_word++;
  2741. *msg_word = 0;
  2742. /* Currently Using last 2 bits for pdev_id
  2743. * For future reference, reserving 3 bits in cookie_msb for pdev_id
  2744. */
  2745. cookie_msb = (cookie_msb | pdev->pdev_id);
  2746. HTT_H2T_EXT_STATS_REQ_CONFIG_PARAM_SET(*msg_word, cookie_msb);
  2747. pkt = htt_htc_pkt_alloc(soc);
  2748. if (!pkt) {
  2749. qdf_nbuf_free(msg);
  2750. return QDF_STATUS_E_NOMEM;
  2751. }
  2752. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  2753. SET_HTC_PACKET_INFO_TX(&pkt->htc_pkt,
  2754. dp_htt_h2t_send_complete_free_netbuf,
  2755. qdf_nbuf_data(msg), qdf_nbuf_len(msg),
  2756. soc->htc_endpoint,
  2757. /* tag for FW response msg not guaranteed */
  2758. HTC_TX_PACKET_TAG_RUNTIME_PUT);
  2759. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, msg);
  2760. status = DP_HTT_SEND_HTC_PKT(soc, pkt, HTT_H2T_MSG_TYPE_EXT_STATS_REQ,
  2761. htt_logger_bufp);
  2762. if (status != QDF_STATUS_SUCCESS) {
  2763. qdf_nbuf_free(msg);
  2764. htt_htc_pkt_free(soc, pkt);
  2765. }
  2766. return status;
  2767. }
  2768. /**
  2769. * dp_h2t_3tuple_config_send(): function to contruct 3 tuple configuration
  2770. * HTT message to pass to FW
  2771. * @pdev: DP PDEV handle
  2772. * @tuple_mask: tuple configuration to report 3 tuple hash value in either
  2773. * toeplitz_2_or_4 or flow_id_toeplitz in MSDU START TLV.
  2774. *
  2775. * tuple_mask[1:0]:
  2776. * 00 - Do not report 3 tuple hash value
  2777. * 10 - Report 3 tuple hash value in toeplitz_2_or_4
  2778. * 01 - Report 3 tuple hash value in flow_id_toeplitz
  2779. * 11 - Report 3 tuple hash value in both toeplitz_2_or_4 & flow_id_toeplitz
  2780. *
  2781. * return: QDF STATUS
  2782. */
  2783. QDF_STATUS dp_h2t_3tuple_config_send(struct dp_pdev *pdev,
  2784. uint32_t tuple_mask, uint8_t mac_id)
  2785. {
  2786. struct htt_soc *soc = pdev->soc->htt_handle;
  2787. struct dp_htt_htc_pkt *pkt;
  2788. qdf_nbuf_t msg;
  2789. uint32_t *msg_word;
  2790. uint8_t *htt_logger_bufp;
  2791. int mac_for_pdev;
  2792. int target_pdev_id;
  2793. msg = qdf_nbuf_alloc(
  2794. soc->osdev,
  2795. HTT_MSG_BUF_SIZE(HTT_3_TUPLE_HASH_CFG_REQ_BYTES),
  2796. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, TRUE);
  2797. if (!msg)
  2798. return QDF_STATUS_E_NOMEM;
  2799. mac_for_pdev = dp_get_mac_id_for_pdev(mac_id, pdev->pdev_id);
  2800. target_pdev_id =
  2801. dp_get_target_pdev_id_for_host_pdev_id(pdev->soc, mac_for_pdev);
  2802. /*
  2803. * Set the length of the message.
  2804. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  2805. * separately during the below call to qdf_nbuf_push_head.
  2806. * The contribution from the HTC header is added separately inside HTC.
  2807. */
  2808. if (!qdf_nbuf_put_tail(msg, HTT_3_TUPLE_HASH_CFG_REQ_BYTES)) {
  2809. QDF_TRACE(QDF_MODULE_ID_TXRX, QDF_TRACE_LEVEL_ERROR,
  2810. "Failed to expand head for HTT_3TUPLE_CONFIG");
  2811. qdf_nbuf_free(msg);
  2812. return QDF_STATUS_E_FAILURE;
  2813. }
  2814. dp_htt_info("%pK: config_param_sent 0x%x for target_pdev %d\n -------------",
  2815. pdev->soc, tuple_mask, target_pdev_id);
  2816. msg_word = (uint32_t *)qdf_nbuf_data(msg);
  2817. qdf_nbuf_push_head(msg, HTC_HDR_ALIGNMENT_PADDING);
  2818. htt_logger_bufp = (uint8_t *)msg_word;
  2819. *msg_word = 0;
  2820. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_3_TUPLE_HASH_CFG);
  2821. HTT_RX_3_TUPLE_HASH_PDEV_ID_SET(*msg_word, target_pdev_id);
  2822. msg_word++;
  2823. *msg_word = 0;
  2824. HTT_H2T_FLOW_ID_TOEPLITZ_FIELD_CONFIG_SET(*msg_word, tuple_mask);
  2825. HTT_H2T_TOEPLITZ_2_OR_4_FIELD_CONFIG_SET(*msg_word, tuple_mask);
  2826. pkt = htt_htc_pkt_alloc(soc);
  2827. if (!pkt) {
  2828. qdf_nbuf_free(msg);
  2829. return QDF_STATUS_E_NOMEM;
  2830. }
  2831. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  2832. SET_HTC_PACKET_INFO_TX(
  2833. &pkt->htc_pkt,
  2834. dp_htt_h2t_send_complete_free_netbuf,
  2835. qdf_nbuf_data(msg),
  2836. qdf_nbuf_len(msg),
  2837. soc->htc_endpoint,
  2838. /* tag for no FW response msg */
  2839. HTC_TX_PACKET_TAG_RUNTIME_PUT);
  2840. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, msg);
  2841. DP_HTT_SEND_HTC_PKT(soc, pkt, HTT_H2T_MSG_TYPE_3_TUPLE_HASH_CFG,
  2842. htt_logger_bufp);
  2843. return QDF_STATUS_SUCCESS;
  2844. }
  2845. /* This macro will revert once proper HTT header will define for
  2846. * HTT_H2T_MSG_TYPE_PPDU_STATS_CFG in htt.h file
  2847. * */
  2848. #if defined(WDI_EVENT_ENABLE)
  2849. /**
  2850. * dp_h2t_cfg_stats_msg_send(): function to construct HTT message to pass to FW
  2851. * @pdev: DP PDEV handle
  2852. * @stats_type_upload_mask: stats type requested by user
  2853. * @mac_id: Mac id number
  2854. *
  2855. * return: QDF STATUS
  2856. */
  2857. QDF_STATUS dp_h2t_cfg_stats_msg_send(struct dp_pdev *pdev,
  2858. uint32_t stats_type_upload_mask, uint8_t mac_id)
  2859. {
  2860. struct htt_soc *soc = pdev->soc->htt_handle;
  2861. struct dp_htt_htc_pkt *pkt;
  2862. qdf_nbuf_t msg;
  2863. uint32_t *msg_word;
  2864. uint8_t pdev_mask;
  2865. QDF_STATUS status;
  2866. msg = qdf_nbuf_alloc(
  2867. soc->osdev,
  2868. HTT_MSG_BUF_SIZE(HTT_H2T_PPDU_STATS_CFG_MSG_SZ),
  2869. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, true);
  2870. if (!msg) {
  2871. dp_htt_err("%pK: Fail to allocate HTT_H2T_PPDU_STATS_CFG_MSG_SZ msg buffer"
  2872. , pdev->soc);
  2873. qdf_assert(0);
  2874. return QDF_STATUS_E_NOMEM;
  2875. }
  2876. /*TODO:Add support for SOC stats
  2877. * Bit 0: SOC Stats
  2878. * Bit 1: Pdev stats for pdev id 0
  2879. * Bit 2: Pdev stats for pdev id 1
  2880. * Bit 3: Pdev stats for pdev id 2
  2881. */
  2882. pdev_mask = 1 << dp_get_target_pdev_id_for_host_pdev_id(pdev->soc,
  2883. mac_id);
  2884. /*
  2885. * Set the length of the message.
  2886. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  2887. * separately during the below call to qdf_nbuf_push_head.
  2888. * The contribution from the HTC header is added separately inside HTC.
  2889. */
  2890. if (qdf_nbuf_put_tail(msg, HTT_H2T_PPDU_STATS_CFG_MSG_SZ) == NULL) {
  2891. dp_htt_err("%pK: Failed to expand head for HTT_CFG_STATS"
  2892. , pdev->soc);
  2893. qdf_nbuf_free(msg);
  2894. return QDF_STATUS_E_FAILURE;
  2895. }
  2896. msg_word = (uint32_t *) qdf_nbuf_data(msg);
  2897. qdf_nbuf_push_head(msg, HTC_HDR_ALIGNMENT_PADDING);
  2898. *msg_word = 0;
  2899. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_PPDU_STATS_CFG);
  2900. HTT_H2T_PPDU_STATS_CFG_PDEV_MASK_SET(*msg_word, pdev_mask);
  2901. HTT_H2T_PPDU_STATS_CFG_TLV_BITMASK_SET(*msg_word,
  2902. stats_type_upload_mask);
  2903. pkt = htt_htc_pkt_alloc(soc);
  2904. if (!pkt) {
  2905. dp_htt_err("%pK: Fail to allocate dp_htt_htc_pkt buffer", pdev->soc);
  2906. qdf_assert(0);
  2907. qdf_nbuf_free(msg);
  2908. return QDF_STATUS_E_NOMEM;
  2909. }
  2910. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  2911. SET_HTC_PACKET_INFO_TX(&pkt->htc_pkt,
  2912. dp_htt_h2t_send_complete_free_netbuf,
  2913. qdf_nbuf_data(msg), qdf_nbuf_len(msg),
  2914. soc->htc_endpoint,
  2915. /* tag for no FW response msg */
  2916. HTC_TX_PACKET_TAG_RUNTIME_PUT);
  2917. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, msg);
  2918. status = DP_HTT_SEND_HTC_PKT(soc, pkt, HTT_H2T_MSG_TYPE_PPDU_STATS_CFG,
  2919. (uint8_t *)msg_word);
  2920. if (status != QDF_STATUS_SUCCESS) {
  2921. qdf_nbuf_free(msg);
  2922. htt_htc_pkt_free(soc, pkt);
  2923. }
  2924. return status;
  2925. }
  2926. qdf_export_symbol(dp_h2t_cfg_stats_msg_send);
  2927. #endif
  2928. void
  2929. dp_peer_update_inactive_time(struct dp_pdev *pdev, uint32_t tag_type,
  2930. uint32_t *tag_buf)
  2931. {
  2932. struct dp_peer *peer = NULL;
  2933. switch (tag_type) {
  2934. case HTT_STATS_PEER_DETAILS_TAG:
  2935. {
  2936. htt_peer_details_tlv *dp_stats_buf =
  2937. (htt_peer_details_tlv *)tag_buf;
  2938. pdev->fw_stats_peer_id = dp_stats_buf->sw_peer_id;
  2939. }
  2940. break;
  2941. case HTT_STATS_PEER_STATS_CMN_TAG:
  2942. {
  2943. htt_peer_stats_cmn_tlv *dp_stats_buf =
  2944. (htt_peer_stats_cmn_tlv *)tag_buf;
  2945. peer = dp_peer_get_ref_by_id(pdev->soc, pdev->fw_stats_peer_id,
  2946. DP_MOD_ID_HTT);
  2947. if (peer && !peer->bss_peer) {
  2948. peer->stats.tx.inactive_time =
  2949. dp_stats_buf->inactive_time;
  2950. qdf_event_set(&pdev->fw_peer_stats_event);
  2951. }
  2952. if (peer)
  2953. dp_peer_unref_delete(peer, DP_MOD_ID_HTT);
  2954. }
  2955. break;
  2956. default:
  2957. qdf_err("Invalid tag_type");
  2958. }
  2959. }
  2960. /**
  2961. * dp_htt_rx_flow_fst_setup(): Send HTT Rx FST setup message to FW
  2962. * @pdev: DP pdev handle
  2963. * @fse_setup_info: FST setup parameters
  2964. *
  2965. * Return: Success when HTT message is sent, error on failure
  2966. */
  2967. QDF_STATUS
  2968. dp_htt_rx_flow_fst_setup(struct dp_pdev *pdev,
  2969. struct dp_htt_rx_flow_fst_setup *fse_setup_info)
  2970. {
  2971. struct htt_soc *soc = pdev->soc->htt_handle;
  2972. struct dp_htt_htc_pkt *pkt;
  2973. qdf_nbuf_t msg;
  2974. u_int32_t *msg_word;
  2975. struct htt_h2t_msg_rx_fse_setup_t *fse_setup;
  2976. uint8_t *htt_logger_bufp;
  2977. u_int32_t *key;
  2978. QDF_STATUS status;
  2979. msg = qdf_nbuf_alloc(
  2980. soc->osdev,
  2981. HTT_MSG_BUF_SIZE(sizeof(struct htt_h2t_msg_rx_fse_setup_t)),
  2982. /* reserve room for the HTC header */
  2983. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, TRUE);
  2984. if (!msg)
  2985. return QDF_STATUS_E_NOMEM;
  2986. /*
  2987. * Set the length of the message.
  2988. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  2989. * separately during the below call to qdf_nbuf_push_head.
  2990. * The contribution from the HTC header is added separately inside HTC.
  2991. */
  2992. if (!qdf_nbuf_put_tail(msg,
  2993. sizeof(struct htt_h2t_msg_rx_fse_setup_t))) {
  2994. qdf_err("Failed to expand head for HTT RX_FSE_SETUP msg");
  2995. return QDF_STATUS_E_FAILURE;
  2996. }
  2997. /* fill in the message contents */
  2998. msg_word = (u_int32_t *)qdf_nbuf_data(msg);
  2999. memset(msg_word, 0, sizeof(struct htt_h2t_msg_rx_fse_setup_t));
  3000. /* rewind beyond alignment pad to get to the HTC header reserved area */
  3001. qdf_nbuf_push_head(msg, HTC_HDR_ALIGNMENT_PADDING);
  3002. htt_logger_bufp = (uint8_t *)msg_word;
  3003. *msg_word = 0;
  3004. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_RX_FSE_SETUP_CFG);
  3005. fse_setup = (struct htt_h2t_msg_rx_fse_setup_t *)msg_word;
  3006. HTT_RX_FSE_SETUP_PDEV_ID_SET(*msg_word, fse_setup_info->pdev_id);
  3007. msg_word++;
  3008. HTT_RX_FSE_SETUP_NUM_REC_SET(*msg_word, fse_setup_info->max_entries);
  3009. HTT_RX_FSE_SETUP_MAX_SEARCH_SET(*msg_word, fse_setup_info->max_search);
  3010. HTT_RX_FSE_SETUP_IP_DA_SA_PREFIX_SET(*msg_word,
  3011. fse_setup_info->ip_da_sa_prefix);
  3012. msg_word++;
  3013. HTT_RX_FSE_SETUP_BASE_ADDR_LO_SET(*msg_word,
  3014. fse_setup_info->base_addr_lo);
  3015. msg_word++;
  3016. HTT_RX_FSE_SETUP_BASE_ADDR_HI_SET(*msg_word,
  3017. fse_setup_info->base_addr_hi);
  3018. key = (u_int32_t *)fse_setup_info->hash_key;
  3019. fse_setup->toeplitz31_0 = *key++;
  3020. fse_setup->toeplitz63_32 = *key++;
  3021. fse_setup->toeplitz95_64 = *key++;
  3022. fse_setup->toeplitz127_96 = *key++;
  3023. fse_setup->toeplitz159_128 = *key++;
  3024. fse_setup->toeplitz191_160 = *key++;
  3025. fse_setup->toeplitz223_192 = *key++;
  3026. fse_setup->toeplitz255_224 = *key++;
  3027. fse_setup->toeplitz287_256 = *key++;
  3028. fse_setup->toeplitz314_288 = *key;
  3029. msg_word++;
  3030. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz31_0);
  3031. msg_word++;
  3032. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz63_32);
  3033. msg_word++;
  3034. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz95_64);
  3035. msg_word++;
  3036. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz127_96);
  3037. msg_word++;
  3038. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz159_128);
  3039. msg_word++;
  3040. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz191_160);
  3041. msg_word++;
  3042. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz223_192);
  3043. msg_word++;
  3044. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz255_224);
  3045. msg_word++;
  3046. HTT_RX_FSE_SETUP_HASH_VALUE_SET(*msg_word, fse_setup->toeplitz287_256);
  3047. msg_word++;
  3048. HTT_RX_FSE_SETUP_HASH_314_288_SET(*msg_word,
  3049. fse_setup->toeplitz314_288);
  3050. pkt = htt_htc_pkt_alloc(soc);
  3051. if (!pkt) {
  3052. qdf_err("Fail to allocate dp_htt_htc_pkt buffer");
  3053. qdf_assert(0);
  3054. qdf_nbuf_free(msg);
  3055. return QDF_STATUS_E_RESOURCES; /* failure */
  3056. }
  3057. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  3058. SET_HTC_PACKET_INFO_TX(
  3059. &pkt->htc_pkt,
  3060. dp_htt_h2t_send_complete_free_netbuf,
  3061. qdf_nbuf_data(msg),
  3062. qdf_nbuf_len(msg),
  3063. soc->htc_endpoint,
  3064. /* tag for no FW response msg */
  3065. HTC_TX_PACKET_TAG_RUNTIME_PUT);
  3066. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, msg);
  3067. status = DP_HTT_SEND_HTC_PKT(soc, pkt,
  3068. HTT_H2T_MSG_TYPE_RX_FSE_SETUP_CFG,
  3069. htt_logger_bufp);
  3070. if (status == QDF_STATUS_SUCCESS) {
  3071. dp_info("HTT_H2T RX_FSE_SETUP sent to FW for pdev = %u",
  3072. fse_setup_info->pdev_id);
  3073. QDF_TRACE_HEX_DUMP(QDF_MODULE_ID_ANY, QDF_TRACE_LEVEL_DEBUG,
  3074. (void *)fse_setup_info->hash_key,
  3075. fse_setup_info->hash_key_len);
  3076. } else {
  3077. qdf_nbuf_free(msg);
  3078. htt_htc_pkt_free(soc, pkt);
  3079. }
  3080. return status;
  3081. }
  3082. /**
  3083. * dp_htt_rx_flow_fse_operation(): Send HTT Flow Search Entry msg to
  3084. * add/del a flow in HW
  3085. * @pdev: DP pdev handle
  3086. * @fse_op_info: Flow entry parameters
  3087. *
  3088. * Return: Success when HTT message is sent, error on failure
  3089. */
  3090. QDF_STATUS
  3091. dp_htt_rx_flow_fse_operation(struct dp_pdev *pdev,
  3092. struct dp_htt_rx_flow_fst_operation *fse_op_info)
  3093. {
  3094. struct htt_soc *soc = pdev->soc->htt_handle;
  3095. struct dp_htt_htc_pkt *pkt;
  3096. qdf_nbuf_t msg;
  3097. u_int32_t *msg_word;
  3098. struct htt_h2t_msg_rx_fse_operation_t *fse_operation;
  3099. uint8_t *htt_logger_bufp;
  3100. QDF_STATUS status;
  3101. msg = qdf_nbuf_alloc(
  3102. soc->osdev,
  3103. HTT_MSG_BUF_SIZE(sizeof(struct htt_h2t_msg_rx_fse_operation_t)),
  3104. /* reserve room for the HTC header */
  3105. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING, 4, TRUE);
  3106. if (!msg)
  3107. return QDF_STATUS_E_NOMEM;
  3108. /*
  3109. * Set the length of the message.
  3110. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  3111. * separately during the below call to qdf_nbuf_push_head.
  3112. * The contribution from the HTC header is added separately inside HTC.
  3113. */
  3114. if (!qdf_nbuf_put_tail(msg,
  3115. sizeof(struct htt_h2t_msg_rx_fse_operation_t))) {
  3116. qdf_err("Failed to expand head for HTT_RX_FSE_OPERATION msg");
  3117. qdf_nbuf_free(msg);
  3118. return QDF_STATUS_E_FAILURE;
  3119. }
  3120. /* fill in the message contents */
  3121. msg_word = (u_int32_t *)qdf_nbuf_data(msg);
  3122. memset(msg_word, 0, sizeof(struct htt_h2t_msg_rx_fse_operation_t));
  3123. /* rewind beyond alignment pad to get to the HTC header reserved area */
  3124. qdf_nbuf_push_head(msg, HTC_HDR_ALIGNMENT_PADDING);
  3125. htt_logger_bufp = (uint8_t *)msg_word;
  3126. *msg_word = 0;
  3127. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_RX_FSE_OPERATION_CFG);
  3128. fse_operation = (struct htt_h2t_msg_rx_fse_operation_t *)msg_word;
  3129. HTT_RX_FSE_OPERATION_PDEV_ID_SET(*msg_word, fse_op_info->pdev_id);
  3130. msg_word++;
  3131. HTT_RX_FSE_IPSEC_VALID_SET(*msg_word, false);
  3132. if (fse_op_info->op_code == DP_HTT_FST_CACHE_INVALIDATE_ENTRY) {
  3133. HTT_RX_FSE_OPERATION_SET(*msg_word,
  3134. HTT_RX_FSE_CACHE_INVALIDATE_ENTRY);
  3135. msg_word++;
  3136. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3137. *msg_word,
  3138. qdf_htonl(fse_op_info->rx_flow->flow_tuple_info.src_ip_31_0));
  3139. msg_word++;
  3140. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3141. *msg_word,
  3142. qdf_htonl(fse_op_info->rx_flow->flow_tuple_info.src_ip_63_32));
  3143. msg_word++;
  3144. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3145. *msg_word,
  3146. qdf_htonl(fse_op_info->rx_flow->flow_tuple_info.src_ip_95_64));
  3147. msg_word++;
  3148. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3149. *msg_word,
  3150. qdf_htonl(fse_op_info->rx_flow->flow_tuple_info.src_ip_127_96));
  3151. msg_word++;
  3152. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3153. *msg_word,
  3154. qdf_htonl(fse_op_info->rx_flow->flow_tuple_info.dest_ip_31_0));
  3155. msg_word++;
  3156. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3157. *msg_word,
  3158. qdf_htonl(fse_op_info->rx_flow->flow_tuple_info.dest_ip_63_32));
  3159. msg_word++;
  3160. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3161. *msg_word,
  3162. qdf_htonl(fse_op_info->rx_flow->flow_tuple_info.dest_ip_95_64));
  3163. msg_word++;
  3164. HTT_RX_FSE_OPERATION_IP_ADDR_SET(
  3165. *msg_word,
  3166. qdf_htonl(
  3167. fse_op_info->rx_flow->flow_tuple_info.dest_ip_127_96));
  3168. msg_word++;
  3169. HTT_RX_FSE_SOURCEPORT_SET(
  3170. *msg_word,
  3171. fse_op_info->rx_flow->flow_tuple_info.src_port);
  3172. HTT_RX_FSE_DESTPORT_SET(
  3173. *msg_word,
  3174. fse_op_info->rx_flow->flow_tuple_info.dest_port);
  3175. msg_word++;
  3176. HTT_RX_FSE_L4_PROTO_SET(
  3177. *msg_word,
  3178. fse_op_info->rx_flow->flow_tuple_info.l4_protocol);
  3179. } else if (fse_op_info->op_code == DP_HTT_FST_CACHE_INVALIDATE_FULL) {
  3180. HTT_RX_FSE_OPERATION_SET(*msg_word,
  3181. HTT_RX_FSE_CACHE_INVALIDATE_FULL);
  3182. } else if (fse_op_info->op_code == DP_HTT_FST_DISABLE) {
  3183. HTT_RX_FSE_OPERATION_SET(*msg_word, HTT_RX_FSE_DISABLE);
  3184. } else if (fse_op_info->op_code == DP_HTT_FST_ENABLE) {
  3185. HTT_RX_FSE_OPERATION_SET(*msg_word, HTT_RX_FSE_ENABLE);
  3186. }
  3187. pkt = htt_htc_pkt_alloc(soc);
  3188. if (!pkt) {
  3189. qdf_err("Fail to allocate dp_htt_htc_pkt buffer");
  3190. qdf_assert(0);
  3191. qdf_nbuf_free(msg);
  3192. return QDF_STATUS_E_RESOURCES; /* failure */
  3193. }
  3194. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  3195. SET_HTC_PACKET_INFO_TX(
  3196. &pkt->htc_pkt,
  3197. dp_htt_h2t_send_complete_free_netbuf,
  3198. qdf_nbuf_data(msg),
  3199. qdf_nbuf_len(msg),
  3200. soc->htc_endpoint,
  3201. /* tag for no FW response msg */
  3202. HTC_TX_PACKET_TAG_RUNTIME_PUT);
  3203. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, msg);
  3204. status = DP_HTT_SEND_HTC_PKT(soc, pkt,
  3205. HTT_H2T_MSG_TYPE_RX_FSE_OPERATION_CFG,
  3206. htt_logger_bufp);
  3207. if (status == QDF_STATUS_SUCCESS) {
  3208. dp_info("HTT_H2T RX_FSE_OPERATION_CFG sent to FW for pdev = %u",
  3209. fse_op_info->pdev_id);
  3210. } else {
  3211. qdf_nbuf_free(msg);
  3212. htt_htc_pkt_free(soc, pkt);
  3213. }
  3214. return status;
  3215. }
  3216. /**
  3217. * dp_htt_rx_fisa_config(): Send HTT msg to configure FISA
  3218. * @pdev: DP pdev handle
  3219. * @fse_op_info: Flow entry parameters
  3220. *
  3221. * Return: Success when HTT message is sent, error on failure
  3222. */
  3223. QDF_STATUS
  3224. dp_htt_rx_fisa_config(struct dp_pdev *pdev,
  3225. struct dp_htt_rx_fisa_cfg *fisa_config)
  3226. {
  3227. struct htt_soc *soc = pdev->soc->htt_handle;
  3228. struct dp_htt_htc_pkt *pkt;
  3229. qdf_nbuf_t msg;
  3230. u_int32_t *msg_word;
  3231. struct htt_h2t_msg_type_fisa_config_t *htt_fisa_config;
  3232. uint8_t *htt_logger_bufp;
  3233. uint32_t len;
  3234. QDF_STATUS status;
  3235. len = HTT_MSG_BUF_SIZE(sizeof(struct htt_h2t_msg_type_fisa_config_t));
  3236. msg = qdf_nbuf_alloc(soc->osdev,
  3237. len,
  3238. /* reserve room for the HTC header */
  3239. HTC_HEADER_LEN + HTC_HDR_ALIGNMENT_PADDING,
  3240. 4,
  3241. TRUE);
  3242. if (!msg)
  3243. return QDF_STATUS_E_NOMEM;
  3244. /*
  3245. * Set the length of the message.
  3246. * The contribution from the HTC_HDR_ALIGNMENT_PADDING is added
  3247. * separately during the below call to qdf_nbuf_push_head.
  3248. * The contribution from the HTC header is added separately inside HTC.
  3249. */
  3250. if (!qdf_nbuf_put_tail(msg,
  3251. sizeof(struct htt_h2t_msg_type_fisa_config_t))) {
  3252. qdf_err("Failed to expand head for HTT_RX_FSE_OPERATION msg");
  3253. qdf_nbuf_free(msg);
  3254. return QDF_STATUS_E_FAILURE;
  3255. }
  3256. /* fill in the message contents */
  3257. msg_word = (u_int32_t *)qdf_nbuf_data(msg);
  3258. memset(msg_word, 0, sizeof(struct htt_h2t_msg_type_fisa_config_t));
  3259. /* rewind beyond alignment pad to get to the HTC header reserved area */
  3260. qdf_nbuf_push_head(msg, HTC_HDR_ALIGNMENT_PADDING);
  3261. htt_logger_bufp = (uint8_t *)msg_word;
  3262. *msg_word = 0;
  3263. HTT_H2T_MSG_TYPE_SET(*msg_word, HTT_H2T_MSG_TYPE_RX_FISA_CFG);
  3264. htt_fisa_config = (struct htt_h2t_msg_type_fisa_config_t *)msg_word;
  3265. HTT_RX_FSE_OPERATION_PDEV_ID_SET(*msg_word, htt_fisa_config->pdev_id);
  3266. msg_word++;
  3267. HTT_RX_FISA_CONFIG_FISA_V2_ENABLE_SET(*msg_word, 1);
  3268. HTT_RX_FISA_CONFIG_FISA_V2_AGGR_LIMIT_SET(*msg_word, 0xf);
  3269. msg_word++;
  3270. htt_fisa_config->fisa_timeout_threshold = fisa_config->fisa_timeout;
  3271. pkt = htt_htc_pkt_alloc(soc);
  3272. if (!pkt) {
  3273. qdf_err("Fail to allocate dp_htt_htc_pkt buffer");
  3274. qdf_assert(0);
  3275. qdf_nbuf_free(msg);
  3276. return QDF_STATUS_E_RESOURCES; /* failure */
  3277. }
  3278. pkt->soc_ctxt = NULL; /* not used during send-done callback */
  3279. SET_HTC_PACKET_INFO_TX(&pkt->htc_pkt,
  3280. dp_htt_h2t_send_complete_free_netbuf,
  3281. qdf_nbuf_data(msg),
  3282. qdf_nbuf_len(msg),
  3283. soc->htc_endpoint,
  3284. /* tag for no FW response msg */
  3285. HTC_TX_PACKET_TAG_RUNTIME_PUT);
  3286. SET_HTC_PACKET_NET_BUF_CONTEXT(&pkt->htc_pkt, msg);
  3287. status = DP_HTT_SEND_HTC_PKT(soc, pkt, HTT_H2T_MSG_TYPE_RX_FISA_CFG,
  3288. htt_logger_bufp);
  3289. if (status == QDF_STATUS_SUCCESS) {
  3290. dp_info("HTT_H2T_MSG_TYPE_RX_FISA_CFG sent to FW for pdev = %u",
  3291. fisa_config->pdev_id);
  3292. } else {
  3293. qdf_nbuf_free(msg);
  3294. htt_htc_pkt_free(soc, pkt);
  3295. }
  3296. return status;
  3297. }
  3298. /**
  3299. * dp_bk_pressure_stats_handler(): worker function to print back pressure
  3300. * stats
  3301. *
  3302. * @context : argument to work function
  3303. */
  3304. static void dp_bk_pressure_stats_handler(void *context)
  3305. {
  3306. struct dp_pdev *pdev = (struct dp_pdev *)context;
  3307. struct dp_soc_srngs_state *soc_srngs_state, *soc_srngs_state_next;
  3308. const char *ring_name;
  3309. int i;
  3310. struct dp_srng_ring_state *ring_state;
  3311. TAILQ_HEAD(, dp_soc_srngs_state) soc_srngs_state_list;
  3312. TAILQ_INIT(&soc_srngs_state_list);
  3313. qdf_spin_lock_bh(&pdev->bkp_stats.list_lock);
  3314. TAILQ_CONCAT(&soc_srngs_state_list, &pdev->bkp_stats.list,
  3315. list_elem);
  3316. qdf_spin_unlock_bh(&pdev->bkp_stats.list_lock);
  3317. TAILQ_FOREACH_SAFE(soc_srngs_state, &soc_srngs_state_list,
  3318. list_elem, soc_srngs_state_next) {
  3319. TAILQ_REMOVE(&soc_srngs_state_list, soc_srngs_state,
  3320. list_elem);
  3321. DP_PRINT_STATS("### START BKP stats for seq_num %u ###",
  3322. soc_srngs_state->seq_num);
  3323. for (i = 0; i < soc_srngs_state->max_ring_id; i++) {
  3324. ring_state = &soc_srngs_state->ring_state[i];
  3325. ring_name = dp_srng_get_str_from_hal_ring_type
  3326. (ring_state->ring_type);
  3327. DP_PRINT_STATS("%s: SW:Head pointer = %d Tail Pointer = %d\n",
  3328. ring_name,
  3329. ring_state->sw_head,
  3330. ring_state->sw_tail);
  3331. DP_PRINT_STATS("%s: HW:Head pointer = %d Tail Pointer = %d\n",
  3332. ring_name,
  3333. ring_state->hw_head,
  3334. ring_state->hw_tail);
  3335. }
  3336. DP_PRINT_STATS("### BKP stats for seq_num %u COMPLETE ###",
  3337. soc_srngs_state->seq_num);
  3338. qdf_mem_free(soc_srngs_state);
  3339. }
  3340. dp_print_napi_stats(pdev->soc);
  3341. }
  3342. /*
  3343. * dp_pdev_bkp_stats_detach() - detach resources for back pressure stats
  3344. * processing
  3345. * @pdev: Datapath PDEV handle
  3346. *
  3347. */
  3348. void dp_pdev_bkp_stats_detach(struct dp_pdev *pdev)
  3349. {
  3350. struct dp_soc_srngs_state *ring_state, *ring_state_next;
  3351. if (!pdev->bkp_stats.work_queue)
  3352. return;
  3353. qdf_flush_workqueue(0, pdev->bkp_stats.work_queue);
  3354. qdf_destroy_workqueue(0, pdev->bkp_stats.work_queue);
  3355. qdf_flush_work(&pdev->bkp_stats.work);
  3356. qdf_disable_work(&pdev->bkp_stats.work);
  3357. qdf_spin_lock_bh(&pdev->bkp_stats.list_lock);
  3358. TAILQ_FOREACH_SAFE(ring_state, &pdev->bkp_stats.list,
  3359. list_elem, ring_state_next) {
  3360. TAILQ_REMOVE(&pdev->bkp_stats.list, ring_state,
  3361. list_elem);
  3362. qdf_mem_free(ring_state);
  3363. }
  3364. qdf_spin_unlock_bh(&pdev->bkp_stats.list_lock);
  3365. qdf_spinlock_destroy(&pdev->bkp_stats.list_lock);
  3366. }
  3367. /*
  3368. * dp_pdev_bkp_stats_attach() - attach resources for back pressure stats
  3369. * processing
  3370. * @pdev: Datapath PDEV handle
  3371. *
  3372. * Return: QDF_STATUS_SUCCESS: Success
  3373. * QDF_STATUS_E_NOMEM: Error
  3374. */
  3375. QDF_STATUS dp_pdev_bkp_stats_attach(struct dp_pdev *pdev)
  3376. {
  3377. TAILQ_INIT(&pdev->bkp_stats.list);
  3378. pdev->bkp_stats.seq_num = 0;
  3379. qdf_create_work(0, &pdev->bkp_stats.work,
  3380. dp_bk_pressure_stats_handler, pdev);
  3381. pdev->bkp_stats.work_queue =
  3382. qdf_alloc_unbound_workqueue("dp_bkp_work_queue");
  3383. if (!pdev->bkp_stats.work_queue)
  3384. goto fail;
  3385. qdf_spinlock_create(&pdev->bkp_stats.list_lock);
  3386. return QDF_STATUS_SUCCESS;
  3387. fail:
  3388. dp_htt_alert("BKP stats attach failed");
  3389. qdf_flush_work(&pdev->bkp_stats.work);
  3390. qdf_disable_work(&pdev->bkp_stats.work);
  3391. return QDF_STATUS_E_FAILURE;
  3392. }