osdep_service.c 62 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162
  1. /******************************************************************************
  2. *
  3. * Copyright(c) 2007 - 2017 Realtek Corporation.
  4. *
  5. * This program is free software; you can redistribute it and/or modify it
  6. * under the terms of version 2 of the GNU General Public License as
  7. * published by the Free Software Foundation.
  8. *
  9. * This program is distributed in the hope that it will be useful, but WITHOUT
  10. * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  11. * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
  12. * more details.
  13. *
  14. *****************************************************************************/
  15. #define _OSDEP_SERVICE_C_
  16. #include <drv_types.h>
  17. #define RT_TAG '1178'
  18. #ifdef DBG_MEMORY_LEAK
  19. #ifdef PLATFORM_LINUX
  20. atomic_t _malloc_cnt = ATOMIC_INIT(0);
  21. atomic_t _malloc_size = ATOMIC_INIT(0);
  22. #endif
  23. #endif /* DBG_MEMORY_LEAK */
  24. #if defined(PLATFORM_LINUX)
  25. /*
  26. * Translate the OS dependent @param error_code to OS independent RTW_STATUS_CODE
  27. * @return: one of RTW_STATUS_CODE
  28. */
  29. inline int RTW_STATUS_CODE(int error_code)
  30. {
  31. if (error_code >= 0)
  32. return _SUCCESS;
  33. switch (error_code) {
  34. /* case -ETIMEDOUT: */
  35. /* return RTW_STATUS_TIMEDOUT; */
  36. default:
  37. return _FAIL;
  38. }
  39. }
  40. #else
  41. inline int RTW_STATUS_CODE(int error_code)
  42. {
  43. return error_code;
  44. }
  45. #endif
  46. u32 rtw_atoi(u8 *s)
  47. {
  48. int num = 0, flag = 0;
  49. int i;
  50. for (i = 0; i <= strlen(s); i++) {
  51. if (s[i] >= '0' && s[i] <= '9')
  52. num = num * 10 + s[i] - '0';
  53. else if (s[0] == '-' && i == 0)
  54. flag = 1;
  55. else
  56. break;
  57. }
  58. if (flag == 1)
  59. num = num * -1;
  60. return num;
  61. }
  62. inline void *_rtw_vmalloc(u32 sz)
  63. {
  64. void *pbuf;
  65. #ifdef PLATFORM_LINUX
  66. pbuf = vmalloc(sz);
  67. #endif
  68. #ifdef PLATFORM_FREEBSD
  69. pbuf = malloc(sz, M_DEVBUF, M_NOWAIT);
  70. #endif
  71. #ifdef PLATFORM_WINDOWS
  72. NdisAllocateMemoryWithTag(&pbuf, sz, RT_TAG);
  73. #endif
  74. #ifdef DBG_MEMORY_LEAK
  75. #ifdef PLATFORM_LINUX
  76. if (pbuf != NULL) {
  77. atomic_inc(&_malloc_cnt);
  78. atomic_add(sz, &_malloc_size);
  79. }
  80. #endif
  81. #endif /* DBG_MEMORY_LEAK */
  82. return pbuf;
  83. }
  84. inline void *_rtw_zvmalloc(u32 sz)
  85. {
  86. void *pbuf;
  87. #ifdef PLATFORM_LINUX
  88. pbuf = _rtw_vmalloc(sz);
  89. if (pbuf != NULL)
  90. memset(pbuf, 0, sz);
  91. #endif
  92. #ifdef PLATFORM_FREEBSD
  93. pbuf = malloc(sz, M_DEVBUF, M_ZERO | M_NOWAIT);
  94. #endif
  95. #ifdef PLATFORM_WINDOWS
  96. NdisAllocateMemoryWithTag(&pbuf, sz, RT_TAG);
  97. if (pbuf != NULL)
  98. NdisFillMemory(pbuf, sz, 0);
  99. #endif
  100. return pbuf;
  101. }
  102. inline void _rtw_vmfree(void *pbuf, u32 sz)
  103. {
  104. #ifdef PLATFORM_LINUX
  105. vfree(pbuf);
  106. #endif
  107. #ifdef PLATFORM_FREEBSD
  108. free(pbuf, M_DEVBUF);
  109. #endif
  110. #ifdef PLATFORM_WINDOWS
  111. NdisFreeMemory(pbuf, sz, 0);
  112. #endif
  113. #ifdef DBG_MEMORY_LEAK
  114. #ifdef PLATFORM_LINUX
  115. atomic_dec(&_malloc_cnt);
  116. atomic_sub(sz, &_malloc_size);
  117. #endif
  118. #endif /* DBG_MEMORY_LEAK */
  119. }
  120. void *_rtw_malloc(u32 sz)
  121. {
  122. void *pbuf = NULL;
  123. #ifdef PLATFORM_LINUX
  124. #ifdef RTK_DMP_PLATFORM
  125. if (sz > 0x4000)
  126. pbuf = dvr_malloc(sz);
  127. else
  128. #endif
  129. pbuf = kmalloc(sz, in_interrupt() ? GFP_ATOMIC : GFP_KERNEL);
  130. #endif
  131. #ifdef PLATFORM_FREEBSD
  132. pbuf = malloc(sz, M_DEVBUF, M_NOWAIT);
  133. #endif
  134. #ifdef PLATFORM_WINDOWS
  135. NdisAllocateMemoryWithTag(&pbuf, sz, RT_TAG);
  136. #endif
  137. #ifdef DBG_MEMORY_LEAK
  138. #ifdef PLATFORM_LINUX
  139. if (pbuf != NULL) {
  140. atomic_inc(&_malloc_cnt);
  141. atomic_add(sz, &_malloc_size);
  142. }
  143. #endif
  144. #endif /* DBG_MEMORY_LEAK */
  145. return pbuf;
  146. }
  147. void *_rtw_zmalloc(u32 sz)
  148. {
  149. #ifdef PLATFORM_FREEBSD
  150. return malloc(sz, M_DEVBUF, M_ZERO | M_NOWAIT);
  151. #else /* PLATFORM_FREEBSD */
  152. void *pbuf = _rtw_malloc(sz);
  153. if (pbuf != NULL) {
  154. #ifdef PLATFORM_LINUX
  155. memset(pbuf, 0, sz);
  156. #endif
  157. #ifdef PLATFORM_WINDOWS
  158. NdisFillMemory(pbuf, sz, 0);
  159. #endif
  160. }
  161. return pbuf;
  162. #endif /* PLATFORM_FREEBSD */
  163. }
  164. void _rtw_mfree(void *pbuf, u32 sz)
  165. {
  166. #ifdef PLATFORM_LINUX
  167. #ifdef RTK_DMP_PLATFORM
  168. if (sz > 0x4000)
  169. dvr_free(pbuf);
  170. else
  171. #endif
  172. kfree(pbuf);
  173. #endif
  174. #ifdef PLATFORM_FREEBSD
  175. free(pbuf, M_DEVBUF);
  176. #endif
  177. #ifdef PLATFORM_WINDOWS
  178. NdisFreeMemory(pbuf, sz, 0);
  179. #endif
  180. #ifdef DBG_MEMORY_LEAK
  181. #ifdef PLATFORM_LINUX
  182. atomic_dec(&_malloc_cnt);
  183. atomic_sub(sz, &_malloc_size);
  184. #endif
  185. #endif /* DBG_MEMORY_LEAK */
  186. }
  187. #ifdef PLATFORM_FREEBSD
  188. /* review again */
  189. struct sk_buff *dev_alloc_skb(unsigned int size)
  190. {
  191. struct sk_buff *skb = NULL;
  192. u8 *data = NULL;
  193. /* skb = _rtw_zmalloc(sizeof(struct sk_buff)); */ /* for skb->len, etc. */
  194. skb = _rtw_malloc(sizeof(struct sk_buff));
  195. if (!skb)
  196. goto out;
  197. data = _rtw_malloc(size);
  198. if (!data)
  199. goto nodata;
  200. skb->head = (unsigned char *)data;
  201. skb->data = (unsigned char *)data;
  202. skb->tail = (unsigned char *)data;
  203. skb->end = (unsigned char *)data + size;
  204. skb->len = 0;
  205. /* printf("%s()-%d: skb=%p, skb->head = %p\n", __FUNCTION__, __LINE__, skb, skb->head); */
  206. out:
  207. return skb;
  208. nodata:
  209. _rtw_mfree(skb, sizeof(struct sk_buff));
  210. skb = NULL;
  211. goto out;
  212. }
  213. void dev_kfree_skb_any(struct sk_buff *skb)
  214. {
  215. /* printf("%s()-%d: skb->head = %p\n", __FUNCTION__, __LINE__, skb->head); */
  216. if (skb->head)
  217. _rtw_mfree(skb->head, 0);
  218. /* printf("%s()-%d: skb = %p\n", __FUNCTION__, __LINE__, skb); */
  219. if (skb)
  220. _rtw_mfree(skb, 0);
  221. }
  222. struct sk_buff *skb_clone(const struct sk_buff *skb)
  223. {
  224. return NULL;
  225. }
  226. #endif /* PLATFORM_FREEBSD */
  227. inline struct sk_buff *_rtw_skb_alloc(u32 sz)
  228. {
  229. #ifdef PLATFORM_LINUX
  230. return __dev_alloc_skb(sz, in_interrupt() ? GFP_ATOMIC : GFP_KERNEL);
  231. #endif /* PLATFORM_LINUX */
  232. #ifdef PLATFORM_FREEBSD
  233. return dev_alloc_skb(sz);
  234. #endif /* PLATFORM_FREEBSD */
  235. }
  236. inline void _rtw_skb_free(struct sk_buff *skb)
  237. {
  238. dev_kfree_skb_any(skb);
  239. }
  240. inline struct sk_buff *_rtw_skb_copy(const struct sk_buff *skb)
  241. {
  242. #ifdef PLATFORM_LINUX
  243. return skb_copy(skb, in_interrupt() ? GFP_ATOMIC : GFP_KERNEL);
  244. #endif /* PLATFORM_LINUX */
  245. #ifdef PLATFORM_FREEBSD
  246. return NULL;
  247. #endif /* PLATFORM_FREEBSD */
  248. }
  249. inline struct sk_buff *_rtw_skb_clone(struct sk_buff *skb)
  250. {
  251. #ifdef PLATFORM_LINUX
  252. return skb_clone(skb, in_interrupt() ? GFP_ATOMIC : GFP_KERNEL);
  253. #endif /* PLATFORM_LINUX */
  254. #ifdef PLATFORM_FREEBSD
  255. return skb_clone(skb);
  256. #endif /* PLATFORM_FREEBSD */
  257. }
  258. inline struct sk_buff *_rtw_pskb_copy(struct sk_buff *skb)
  259. {
  260. #ifdef PLATFORM_LINUX
  261. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 36))
  262. return pskb_copy(skb, in_interrupt() ? GFP_ATOMIC : GFP_KERNEL);
  263. #else
  264. return skb_clone(skb, in_interrupt() ? GFP_ATOMIC : GFP_KERNEL);
  265. #endif
  266. #endif /* PLATFORM_LINUX */
  267. #ifdef PLATFORM_FREEBSD
  268. return NULL;
  269. #endif /* PLATFORM_FREEBSD */
  270. }
  271. inline int _rtw_netif_rx(_nic_hdl ndev, struct sk_buff *skb)
  272. {
  273. #if defined(PLATFORM_LINUX)
  274. skb->dev = ndev;
  275. return netif_rx(skb);
  276. #elif defined(PLATFORM_FREEBSD)
  277. return (*ndev->if_input)(ndev, skb);
  278. #else
  279. rtw_warn_on(1);
  280. return -1;
  281. #endif
  282. }
  283. #ifdef CONFIG_RTW_NAPI
  284. inline int _rtw_netif_receive_skb(_nic_hdl ndev, struct sk_buff *skb)
  285. {
  286. #if defined(PLATFORM_LINUX)
  287. skb->dev = ndev;
  288. return netif_receive_skb(skb);
  289. #else
  290. rtw_warn_on(1);
  291. return -1;
  292. #endif
  293. }
  294. #ifdef CONFIG_RTW_GRO
  295. inline gro_result_t _rtw_napi_gro_receive(struct napi_struct *napi, struct sk_buff *skb)
  296. {
  297. #if defined(PLATFORM_LINUX)
  298. return napi_gro_receive(napi, skb);
  299. #else
  300. rtw_warn_on(1);
  301. return -1;
  302. #endif
  303. }
  304. #endif /* CONFIG_RTW_GRO */
  305. #endif /* CONFIG_RTW_NAPI */
  306. void _rtw_skb_queue_purge(struct sk_buff_head *list)
  307. {
  308. struct sk_buff *skb;
  309. while ((skb = skb_dequeue(list)) != NULL)
  310. _rtw_skb_free(skb);
  311. }
  312. #ifdef CONFIG_USB_HCI
  313. inline void *_rtw_usb_buffer_alloc(struct usb_device *dev, size_t size, dma_addr_t *dma)
  314. {
  315. #ifdef PLATFORM_LINUX
  316. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 35))
  317. return usb_alloc_coherent(dev, size, (in_interrupt() ? GFP_ATOMIC : GFP_KERNEL), dma);
  318. #else
  319. return usb_buffer_alloc(dev, size, (in_interrupt() ? GFP_ATOMIC : GFP_KERNEL), dma);
  320. #endif
  321. #endif /* PLATFORM_LINUX */
  322. #ifdef PLATFORM_FREEBSD
  323. return malloc(size, M_USBDEV, M_NOWAIT | M_ZERO);
  324. #endif /* PLATFORM_FREEBSD */
  325. }
  326. inline void _rtw_usb_buffer_free(struct usb_device *dev, size_t size, void *addr, dma_addr_t dma)
  327. {
  328. #ifdef PLATFORM_LINUX
  329. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 35))
  330. usb_free_coherent(dev, size, addr, dma);
  331. #else
  332. usb_buffer_free(dev, size, addr, dma);
  333. #endif
  334. #endif /* PLATFORM_LINUX */
  335. #ifdef PLATFORM_FREEBSD
  336. free(addr, M_USBDEV);
  337. #endif /* PLATFORM_FREEBSD */
  338. }
  339. #endif /* CONFIG_USB_HCI */
  340. #if defined(DBG_MEM_ALLOC)
  341. struct rtw_mem_stat {
  342. ATOMIC_T alloc; /* the memory bytes we allocate currently */
  343. ATOMIC_T peak; /* the peak memory bytes we allocate */
  344. ATOMIC_T alloc_cnt; /* the alloc count for alloc currently */
  345. ATOMIC_T alloc_err_cnt; /* the error times we fail to allocate memory */
  346. };
  347. struct rtw_mem_stat rtw_mem_type_stat[mstat_tf_idx(MSTAT_TYPE_MAX)];
  348. #ifdef RTW_MEM_FUNC_STAT
  349. struct rtw_mem_stat rtw_mem_func_stat[mstat_ff_idx(MSTAT_FUNC_MAX)];
  350. #endif
  351. char *MSTAT_TYPE_str[] = {
  352. "VIR",
  353. "PHY",
  354. "SKB",
  355. "USB",
  356. };
  357. #ifdef RTW_MEM_FUNC_STAT
  358. char *MSTAT_FUNC_str[] = {
  359. "UNSP",
  360. "IO",
  361. "TXIO",
  362. "RXIO",
  363. "TX",
  364. "RX",
  365. };
  366. #endif
  367. void rtw_mstat_dump(void *sel)
  368. {
  369. int i;
  370. int value_t[4][mstat_tf_idx(MSTAT_TYPE_MAX)];
  371. #ifdef RTW_MEM_FUNC_STAT
  372. int value_f[4][mstat_ff_idx(MSTAT_FUNC_MAX)];
  373. #endif
  374. int vir_alloc, vir_peak, vir_alloc_err, phy_alloc, phy_peak, phy_alloc_err;
  375. int tx_alloc, tx_peak, tx_alloc_err, rx_alloc, rx_peak, rx_alloc_err;
  376. for (i = 0; i < mstat_tf_idx(MSTAT_TYPE_MAX); i++) {
  377. value_t[0][i] = ATOMIC_READ(&(rtw_mem_type_stat[i].alloc));
  378. value_t[1][i] = ATOMIC_READ(&(rtw_mem_type_stat[i].peak));
  379. value_t[2][i] = ATOMIC_READ(&(rtw_mem_type_stat[i].alloc_cnt));
  380. value_t[3][i] = ATOMIC_READ(&(rtw_mem_type_stat[i].alloc_err_cnt));
  381. }
  382. #ifdef RTW_MEM_FUNC_STAT
  383. for (i = 0; i < mstat_ff_idx(MSTAT_FUNC_MAX); i++) {
  384. value_f[0][i] = ATOMIC_READ(&(rtw_mem_func_stat[i].alloc));
  385. value_f[1][i] = ATOMIC_READ(&(rtw_mem_func_stat[i].peak));
  386. value_f[2][i] = ATOMIC_READ(&(rtw_mem_func_stat[i].alloc_cnt));
  387. value_f[3][i] = ATOMIC_READ(&(rtw_mem_func_stat[i].alloc_err_cnt));
  388. }
  389. #endif
  390. RTW_PRINT_SEL(sel, "===================== MSTAT =====================\n");
  391. RTW_PRINT_SEL(sel, "%4s %10s %10s %10s %10s\n", "TAG", "alloc", "peak", "aloc_cnt", "err_cnt");
  392. RTW_PRINT_SEL(sel, "-------------------------------------------------\n");
  393. for (i = 0; i < mstat_tf_idx(MSTAT_TYPE_MAX); i++)
  394. RTW_PRINT_SEL(sel, "%4s %10d %10d %10d %10d\n", MSTAT_TYPE_str[i], value_t[0][i], value_t[1][i], value_t[2][i], value_t[3][i]);
  395. #ifdef RTW_MEM_FUNC_STAT
  396. RTW_PRINT_SEL(sel, "-------------------------------------------------\n");
  397. for (i = 0; i < mstat_ff_idx(MSTAT_FUNC_MAX); i++)
  398. RTW_PRINT_SEL(sel, "%4s %10d %10d %10d %10d\n", MSTAT_FUNC_str[i], value_f[0][i], value_f[1][i], value_f[2][i], value_f[3][i]);
  399. #endif
  400. }
  401. void rtw_mstat_update(const enum mstat_f flags, const MSTAT_STATUS status, u32 sz)
  402. {
  403. static systime update_time = 0;
  404. int peak, alloc;
  405. int i;
  406. /* initialization */
  407. if (!update_time) {
  408. for (i = 0; i < mstat_tf_idx(MSTAT_TYPE_MAX); i++) {
  409. ATOMIC_SET(&(rtw_mem_type_stat[i].alloc), 0);
  410. ATOMIC_SET(&(rtw_mem_type_stat[i].peak), 0);
  411. ATOMIC_SET(&(rtw_mem_type_stat[i].alloc_cnt), 0);
  412. ATOMIC_SET(&(rtw_mem_type_stat[i].alloc_err_cnt), 0);
  413. }
  414. #ifdef RTW_MEM_FUNC_STAT
  415. for (i = 0; i < mstat_ff_idx(MSTAT_FUNC_MAX); i++) {
  416. ATOMIC_SET(&(rtw_mem_func_stat[i].alloc), 0);
  417. ATOMIC_SET(&(rtw_mem_func_stat[i].peak), 0);
  418. ATOMIC_SET(&(rtw_mem_func_stat[i].alloc_cnt), 0);
  419. ATOMIC_SET(&(rtw_mem_func_stat[i].alloc_err_cnt), 0);
  420. }
  421. #endif
  422. }
  423. switch (status) {
  424. case MSTAT_ALLOC_SUCCESS:
  425. ATOMIC_INC(&(rtw_mem_type_stat[mstat_tf_idx(flags)].alloc_cnt));
  426. alloc = ATOMIC_ADD_RETURN(&(rtw_mem_type_stat[mstat_tf_idx(flags)].alloc), sz);
  427. peak = ATOMIC_READ(&(rtw_mem_type_stat[mstat_tf_idx(flags)].peak));
  428. if (peak < alloc)
  429. ATOMIC_SET(&(rtw_mem_type_stat[mstat_tf_idx(flags)].peak), alloc);
  430. #ifdef RTW_MEM_FUNC_STAT
  431. ATOMIC_INC(&(rtw_mem_func_stat[mstat_ff_idx(flags)].alloc_cnt));
  432. alloc = ATOMIC_ADD_RETURN(&(rtw_mem_func_stat[mstat_ff_idx(flags)].alloc), sz);
  433. peak = ATOMIC_READ(&(rtw_mem_func_stat[mstat_ff_idx(flags)].peak));
  434. if (peak < alloc)
  435. ATOMIC_SET(&(rtw_mem_func_stat[mstat_ff_idx(flags)].peak), alloc);
  436. #endif
  437. break;
  438. case MSTAT_ALLOC_FAIL:
  439. ATOMIC_INC(&(rtw_mem_type_stat[mstat_tf_idx(flags)].alloc_err_cnt));
  440. #ifdef RTW_MEM_FUNC_STAT
  441. ATOMIC_INC(&(rtw_mem_func_stat[mstat_ff_idx(flags)].alloc_err_cnt));
  442. #endif
  443. break;
  444. case MSTAT_FREE:
  445. ATOMIC_DEC(&(rtw_mem_type_stat[mstat_tf_idx(flags)].alloc_cnt));
  446. ATOMIC_SUB(&(rtw_mem_type_stat[mstat_tf_idx(flags)].alloc), sz);
  447. #ifdef RTW_MEM_FUNC_STAT
  448. ATOMIC_DEC(&(rtw_mem_func_stat[mstat_ff_idx(flags)].alloc_cnt));
  449. ATOMIC_SUB(&(rtw_mem_func_stat[mstat_ff_idx(flags)].alloc), sz);
  450. #endif
  451. break;
  452. };
  453. /* if (rtw_get_passing_time_ms(update_time) > 5000) { */
  454. /* rtw_mstat_dump(RTW_DBGDUMP); */
  455. update_time = rtw_get_current_time();
  456. /* } */
  457. }
  458. #ifndef SIZE_MAX
  459. #define SIZE_MAX (~(size_t)0)
  460. #endif
  461. struct mstat_sniff_rule {
  462. enum mstat_f flags;
  463. size_t lb;
  464. size_t hb;
  465. };
  466. struct mstat_sniff_rule mstat_sniff_rules[] = {
  467. {MSTAT_TYPE_PHY, 4097, SIZE_MAX},
  468. };
  469. int mstat_sniff_rule_num = sizeof(mstat_sniff_rules) / sizeof(struct mstat_sniff_rule);
  470. bool match_mstat_sniff_rules(const enum mstat_f flags, const size_t size)
  471. {
  472. int i;
  473. for (i = 0; i < mstat_sniff_rule_num; i++) {
  474. if (mstat_sniff_rules[i].flags == flags
  475. && mstat_sniff_rules[i].lb <= size
  476. && mstat_sniff_rules[i].hb >= size)
  477. return _TRUE;
  478. }
  479. return _FALSE;
  480. }
  481. inline void *dbg_rtw_vmalloc(u32 sz, const enum mstat_f flags, const char *func, const int line)
  482. {
  483. void *p;
  484. if (match_mstat_sniff_rules(flags, sz))
  485. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%d)\n", func, line, __FUNCTION__, (sz));
  486. p = _rtw_vmalloc((sz));
  487. rtw_mstat_update(
  488. flags
  489. , p ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  490. , sz
  491. );
  492. return p;
  493. }
  494. inline void *dbg_rtw_zvmalloc(u32 sz, const enum mstat_f flags, const char *func, const int line)
  495. {
  496. void *p;
  497. if (match_mstat_sniff_rules(flags, sz))
  498. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%d)\n", func, line, __FUNCTION__, (sz));
  499. p = _rtw_zvmalloc((sz));
  500. rtw_mstat_update(
  501. flags
  502. , p ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  503. , sz
  504. );
  505. return p;
  506. }
  507. inline void dbg_rtw_vmfree(void *pbuf, u32 sz, const enum mstat_f flags, const char *func, const int line)
  508. {
  509. if (match_mstat_sniff_rules(flags, sz))
  510. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%d)\n", func, line, __FUNCTION__, (sz));
  511. _rtw_vmfree((pbuf), (sz));
  512. rtw_mstat_update(
  513. flags
  514. , MSTAT_FREE
  515. , sz
  516. );
  517. }
  518. inline void *dbg_rtw_malloc(u32 sz, const enum mstat_f flags, const char *func, const int line)
  519. {
  520. void *p;
  521. if (match_mstat_sniff_rules(flags, sz))
  522. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%d)\n", func, line, __FUNCTION__, (sz));
  523. p = _rtw_malloc((sz));
  524. rtw_mstat_update(
  525. flags
  526. , p ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  527. , sz
  528. );
  529. return p;
  530. }
  531. inline void *dbg_rtw_zmalloc(u32 sz, const enum mstat_f flags, const char *func, const int line)
  532. {
  533. void *p;
  534. if (match_mstat_sniff_rules(flags, sz))
  535. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%d)\n", func, line, __FUNCTION__, (sz));
  536. p = _rtw_zmalloc((sz));
  537. rtw_mstat_update(
  538. flags
  539. , p ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  540. , sz
  541. );
  542. return p;
  543. }
  544. inline void dbg_rtw_mfree(void *pbuf, u32 sz, const enum mstat_f flags, const char *func, const int line)
  545. {
  546. if (match_mstat_sniff_rules(flags, sz))
  547. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%d)\n", func, line, __FUNCTION__, (sz));
  548. _rtw_mfree((pbuf), (sz));
  549. rtw_mstat_update(
  550. flags
  551. , MSTAT_FREE
  552. , sz
  553. );
  554. }
  555. inline struct sk_buff *dbg_rtw_skb_alloc(unsigned int size, const enum mstat_f flags, const char *func, int line)
  556. {
  557. struct sk_buff *skb;
  558. unsigned int truesize = 0;
  559. skb = _rtw_skb_alloc(size);
  560. if (skb)
  561. truesize = skb->truesize;
  562. if (!skb || truesize < size || match_mstat_sniff_rules(flags, truesize))
  563. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%d), skb:%p, truesize=%u\n", func, line, __FUNCTION__, size, skb, truesize);
  564. rtw_mstat_update(
  565. flags
  566. , skb ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  567. , truesize
  568. );
  569. return skb;
  570. }
  571. inline void dbg_rtw_skb_free(struct sk_buff *skb, const enum mstat_f flags, const char *func, int line)
  572. {
  573. unsigned int truesize = skb->truesize;
  574. if (match_mstat_sniff_rules(flags, truesize))
  575. RTW_INFO("DBG_MEM_ALLOC %s:%d %s, truesize=%u\n", func, line, __FUNCTION__, truesize);
  576. _rtw_skb_free(skb);
  577. rtw_mstat_update(
  578. flags
  579. , MSTAT_FREE
  580. , truesize
  581. );
  582. }
  583. inline struct sk_buff *dbg_rtw_skb_copy(const struct sk_buff *skb, const enum mstat_f flags, const char *func, const int line)
  584. {
  585. struct sk_buff *skb_cp;
  586. unsigned int truesize = skb->truesize;
  587. unsigned int cp_truesize = 0;
  588. skb_cp = _rtw_skb_copy(skb);
  589. if (skb_cp)
  590. cp_truesize = skb_cp->truesize;
  591. if (!skb_cp || cp_truesize < truesize || match_mstat_sniff_rules(flags, cp_truesize))
  592. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%u), skb_cp:%p, cp_truesize=%u\n", func, line, __FUNCTION__, truesize, skb_cp, cp_truesize);
  593. rtw_mstat_update(
  594. flags
  595. , skb_cp ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  596. , cp_truesize
  597. );
  598. return skb_cp;
  599. }
  600. inline struct sk_buff *dbg_rtw_skb_clone(struct sk_buff *skb, const enum mstat_f flags, const char *func, const int line)
  601. {
  602. struct sk_buff *skb_cl;
  603. unsigned int truesize = skb->truesize;
  604. unsigned int cl_truesize = 0;
  605. skb_cl = _rtw_skb_clone(skb);
  606. if (skb_cl)
  607. cl_truesize = skb_cl->truesize;
  608. if (!skb_cl || cl_truesize < truesize || match_mstat_sniff_rules(flags, cl_truesize))
  609. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%u), skb_cl:%p, cl_truesize=%u\n", func, line, __FUNCTION__, truesize, skb_cl, cl_truesize);
  610. rtw_mstat_update(
  611. flags
  612. , skb_cl ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  613. , cl_truesize
  614. );
  615. return skb_cl;
  616. }
  617. inline int dbg_rtw_netif_rx(_nic_hdl ndev, struct sk_buff *skb, const enum mstat_f flags, const char *func, int line)
  618. {
  619. int ret;
  620. unsigned int truesize = skb->truesize;
  621. if (match_mstat_sniff_rules(flags, truesize))
  622. RTW_INFO("DBG_MEM_ALLOC %s:%d %s, truesize=%u\n", func, line, __FUNCTION__, truesize);
  623. ret = _rtw_netif_rx(ndev, skb);
  624. rtw_mstat_update(
  625. flags
  626. , MSTAT_FREE
  627. , truesize
  628. );
  629. return ret;
  630. }
  631. #ifdef CONFIG_RTW_NAPI
  632. inline int dbg_rtw_netif_receive_skb(_nic_hdl ndev, struct sk_buff *skb, const enum mstat_f flags, const char *func, int line)
  633. {
  634. int ret;
  635. unsigned int truesize = skb->truesize;
  636. if (match_mstat_sniff_rules(flags, truesize))
  637. RTW_INFO("DBG_MEM_ALLOC %s:%d %s, truesize=%u\n", func, line, __FUNCTION__, truesize);
  638. ret = _rtw_netif_receive_skb(ndev, skb);
  639. rtw_mstat_update(
  640. flags
  641. , MSTAT_FREE
  642. , truesize
  643. );
  644. return ret;
  645. }
  646. #ifdef CONFIG_RTW_GRO
  647. inline gro_result_t dbg_rtw_napi_gro_receive(struct napi_struct *napi, struct sk_buff *skb, const enum mstat_f flags, const char *func, int line)
  648. {
  649. int ret;
  650. unsigned int truesize = skb->truesize;
  651. if (match_mstat_sniff_rules(flags, truesize))
  652. RTW_INFO("DBG_MEM_ALLOC %s:%d %s, truesize=%u\n", func, line, __FUNCTION__, truesize);
  653. ret = _rtw_napi_gro_receive(napi, skb);
  654. rtw_mstat_update(
  655. flags
  656. , MSTAT_FREE
  657. , truesize
  658. );
  659. return ret;
  660. }
  661. #endif /* CONFIG_RTW_GRO */
  662. #endif /* CONFIG_RTW_NAPI */
  663. inline void dbg_rtw_skb_queue_purge(struct sk_buff_head *list, enum mstat_f flags, const char *func, int line)
  664. {
  665. struct sk_buff *skb;
  666. while ((skb = skb_dequeue(list)) != NULL)
  667. dbg_rtw_skb_free(skb, flags, func, line);
  668. }
  669. #ifdef CONFIG_USB_HCI
  670. inline void *dbg_rtw_usb_buffer_alloc(struct usb_device *dev, size_t size, dma_addr_t *dma, const enum mstat_f flags, const char *func, int line)
  671. {
  672. void *p;
  673. if (match_mstat_sniff_rules(flags, size))
  674. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%zu)\n", func, line, __FUNCTION__, size);
  675. p = _rtw_usb_buffer_alloc(dev, size, dma);
  676. rtw_mstat_update(
  677. flags
  678. , p ? MSTAT_ALLOC_SUCCESS : MSTAT_ALLOC_FAIL
  679. , size
  680. );
  681. return p;
  682. }
  683. inline void dbg_rtw_usb_buffer_free(struct usb_device *dev, size_t size, void *addr, dma_addr_t dma, const enum mstat_f flags, const char *func, int line)
  684. {
  685. if (match_mstat_sniff_rules(flags, size))
  686. RTW_INFO("DBG_MEM_ALLOC %s:%d %s(%zu)\n", func, line, __FUNCTION__, size);
  687. _rtw_usb_buffer_free(dev, size, addr, dma);
  688. rtw_mstat_update(
  689. flags
  690. , MSTAT_FREE
  691. , size
  692. );
  693. }
  694. #endif /* CONFIG_USB_HCI */
  695. #endif /* defined(DBG_MEM_ALLOC) */
  696. void *rtw_malloc2d(int h, int w, size_t size)
  697. {
  698. int j;
  699. void **a = (void **) rtw_zmalloc(h * sizeof(void *) + h * w * size);
  700. if (a == NULL) {
  701. RTW_INFO("%s: alloc memory fail!\n", __FUNCTION__);
  702. return NULL;
  703. }
  704. for (j = 0; j < h; j++)
  705. a[j] = ((char *)(a + h)) + j * w * size;
  706. return a;
  707. }
  708. void rtw_mfree2d(void *pbuf, int h, int w, int size)
  709. {
  710. rtw_mfree((u8 *)pbuf, h * sizeof(void *) + w * h * size);
  711. }
  712. inline void rtw_os_pkt_free(_pkt *pkt)
  713. {
  714. #if defined(PLATFORM_LINUX)
  715. rtw_skb_free(pkt);
  716. #elif defined(PLATFORM_FREEBSD)
  717. m_freem(pkt);
  718. #else
  719. #error "TBD\n"
  720. #endif
  721. }
  722. inline _pkt *rtw_os_pkt_copy(_pkt *pkt)
  723. {
  724. #if defined(PLATFORM_LINUX)
  725. return rtw_skb_copy(pkt);
  726. #elif defined(PLATFORM_FREEBSD)
  727. return m_dup(pkt, M_NOWAIT);
  728. #else
  729. #error "TBD\n"
  730. #endif
  731. }
  732. inline void *rtw_os_pkt_data(_pkt *pkt)
  733. {
  734. #if defined(PLATFORM_LINUX)
  735. return pkt->data;
  736. #elif defined(PLATFORM_FREEBSD)
  737. return pkt->m_data;
  738. #else
  739. #error "TBD\n"
  740. #endif
  741. }
  742. inline u32 rtw_os_pkt_len(_pkt *pkt)
  743. {
  744. #if defined(PLATFORM_LINUX)
  745. return pkt->len;
  746. #elif defined(PLATFORM_FREEBSD)
  747. return pkt->m_pkthdr.len;
  748. #else
  749. #error "TBD\n"
  750. #endif
  751. }
  752. void _rtw_memcpy(void *dst, const void *src, u32 sz)
  753. {
  754. #if defined(PLATFORM_LINUX) || defined (PLATFORM_FREEBSD)
  755. memcpy(dst, src, sz);
  756. #endif
  757. #ifdef PLATFORM_WINDOWS
  758. NdisMoveMemory(dst, src, sz);
  759. #endif
  760. }
  761. inline void _rtw_memmove(void *dst, const void *src, u32 sz)
  762. {
  763. #if defined(PLATFORM_LINUX)
  764. memmove(dst, src, sz);
  765. #else
  766. #error "TBD\n"
  767. #endif
  768. }
  769. int _rtw_memcmp(const void *dst, const void *src, u32 sz)
  770. {
  771. #if defined(PLATFORM_LINUX) || defined (PLATFORM_FREEBSD)
  772. /* under Linux/GNU/GLibc, the return value of memcmp for two same mem. chunk is 0 */
  773. if (!(memcmp(dst, src, sz)))
  774. return _TRUE;
  775. else
  776. return _FALSE;
  777. #endif
  778. #ifdef PLATFORM_WINDOWS
  779. /* under Windows, the return value of NdisEqualMemory for two same mem. chunk is 1 */
  780. if (NdisEqualMemory(dst, src, sz))
  781. return _TRUE;
  782. else
  783. return _FALSE;
  784. #endif
  785. }
  786. void _rtw_memset(void *pbuf, int c, u32 sz)
  787. {
  788. #if defined(PLATFORM_LINUX) || defined (PLATFORM_FREEBSD)
  789. memset(pbuf, c, sz);
  790. #endif
  791. #ifdef PLATFORM_WINDOWS
  792. #if 0
  793. NdisZeroMemory(pbuf, sz);
  794. if (c != 0)
  795. memset(pbuf, c, sz);
  796. #else
  797. NdisFillMemory(pbuf, sz, c);
  798. #endif
  799. #endif
  800. }
  801. #ifdef PLATFORM_FREEBSD
  802. static inline void __list_add(_list *pnew, _list *pprev, _list *pnext)
  803. {
  804. pnext->prev = pnew;
  805. pnew->next = pnext;
  806. pnew->prev = pprev;
  807. pprev->next = pnew;
  808. }
  809. #endif /* PLATFORM_FREEBSD */
  810. void _rtw_init_listhead(_list *list)
  811. {
  812. #ifdef PLATFORM_LINUX
  813. INIT_LIST_HEAD(list);
  814. #endif
  815. #ifdef PLATFORM_FREEBSD
  816. list->next = list;
  817. list->prev = list;
  818. #endif
  819. #ifdef PLATFORM_WINDOWS
  820. NdisInitializeListHead(list);
  821. #endif
  822. }
  823. /*
  824. For the following list_xxx operations,
  825. caller must guarantee the atomic context.
  826. Otherwise, there will be racing condition.
  827. */
  828. u32 rtw_is_list_empty(_list *phead)
  829. {
  830. #ifdef PLATFORM_LINUX
  831. if (list_empty(phead))
  832. return _TRUE;
  833. else
  834. return _FALSE;
  835. #endif
  836. #ifdef PLATFORM_FREEBSD
  837. if (phead->next == phead)
  838. return _TRUE;
  839. else
  840. return _FALSE;
  841. #endif
  842. #ifdef PLATFORM_WINDOWS
  843. if (IsListEmpty(phead))
  844. return _TRUE;
  845. else
  846. return _FALSE;
  847. #endif
  848. }
  849. void rtw_list_insert_head(_list *plist, _list *phead)
  850. {
  851. #ifdef PLATFORM_LINUX
  852. list_add(plist, phead);
  853. #endif
  854. #ifdef PLATFORM_FREEBSD
  855. __list_add(plist, phead, phead->next);
  856. #endif
  857. #ifdef PLATFORM_WINDOWS
  858. InsertHeadList(phead, plist);
  859. #endif
  860. }
  861. void rtw_list_insert_tail(_list *plist, _list *phead)
  862. {
  863. #ifdef PLATFORM_LINUX
  864. list_add_tail(plist, phead);
  865. #endif
  866. #ifdef PLATFORM_FREEBSD
  867. __list_add(plist, phead->prev, phead);
  868. #endif
  869. #ifdef PLATFORM_WINDOWS
  870. InsertTailList(phead, plist);
  871. #endif
  872. }
  873. inline void rtw_list_splice(_list *list, _list *head)
  874. {
  875. #ifdef PLATFORM_LINUX
  876. list_splice(list, head);
  877. #else
  878. #error "TBD\n"
  879. #endif
  880. }
  881. inline void rtw_list_splice_init(_list *list, _list *head)
  882. {
  883. #ifdef PLATFORM_LINUX
  884. list_splice_init(list, head);
  885. #else
  886. #error "TBD\n"
  887. #endif
  888. }
  889. inline void rtw_list_splice_tail(_list *list, _list *head)
  890. {
  891. #ifdef PLATFORM_LINUX
  892. #if (LINUX_VERSION_CODE < KERNEL_VERSION(2, 6, 27))
  893. if (!list_empty(list))
  894. __list_splice(list, head);
  895. #else
  896. list_splice_tail(list, head);
  897. #endif
  898. #else
  899. #error "TBD\n"
  900. #endif
  901. }
  902. inline void rtw_hlist_head_init(rtw_hlist_head *h)
  903. {
  904. #ifdef PLATFORM_LINUX
  905. INIT_HLIST_HEAD(h);
  906. #else
  907. #error "TBD\n"
  908. #endif
  909. }
  910. inline void rtw_hlist_add_head(rtw_hlist_node *n, rtw_hlist_head *h)
  911. {
  912. #ifdef PLATFORM_LINUX
  913. hlist_add_head(n, h);
  914. #else
  915. #error "TBD\n"
  916. #endif
  917. }
  918. inline void rtw_hlist_del(rtw_hlist_node *n)
  919. {
  920. #ifdef PLATFORM_LINUX
  921. hlist_del(n);
  922. #else
  923. #error "TBD\n"
  924. #endif
  925. }
  926. inline void rtw_hlist_add_head_rcu(rtw_hlist_node *n, rtw_hlist_head *h)
  927. {
  928. #ifdef PLATFORM_LINUX
  929. hlist_add_head_rcu(n, h);
  930. #else
  931. #error "TBD\n"
  932. #endif
  933. }
  934. inline void rtw_hlist_del_rcu(rtw_hlist_node *n)
  935. {
  936. #ifdef PLATFORM_LINUX
  937. hlist_del_rcu(n);
  938. #else
  939. #error "TBD\n"
  940. #endif
  941. }
  942. void rtw_init_timer(_timer *ptimer, void *padapter, void *pfunc, void *ctx)
  943. {
  944. _adapter *adapter = (_adapter *)padapter;
  945. #ifdef PLATFORM_LINUX
  946. _init_timer(ptimer, adapter->pnetdev, pfunc, ctx);
  947. #endif
  948. #ifdef PLATFORM_FREEBSD
  949. _init_timer(ptimer, adapter->pifp, pfunc, ctx);
  950. #endif
  951. #ifdef PLATFORM_WINDOWS
  952. _init_timer(ptimer, adapter->hndis_adapter, pfunc, ctx);
  953. #endif
  954. }
  955. /*
  956. Caller must check if the list is empty before calling rtw_list_delete
  957. */
  958. void _rtw_init_sema(_sema *sema, int init_val)
  959. {
  960. #ifdef PLATFORM_LINUX
  961. sema_init(sema, init_val);
  962. #endif
  963. #ifdef PLATFORM_FREEBSD
  964. sema_init(sema, init_val, "rtw_drv");
  965. #endif
  966. #ifdef PLATFORM_OS_XP
  967. KeInitializeSemaphore(sema, init_val, SEMA_UPBND); /* count=0; */
  968. #endif
  969. #ifdef PLATFORM_OS_CE
  970. if (*sema == NULL)
  971. *sema = CreateSemaphore(NULL, init_val, SEMA_UPBND, NULL);
  972. #endif
  973. }
  974. void _rtw_free_sema(_sema *sema)
  975. {
  976. #ifdef PLATFORM_FREEBSD
  977. sema_destroy(sema);
  978. #endif
  979. #ifdef PLATFORM_OS_CE
  980. CloseHandle(*sema);
  981. #endif
  982. }
  983. void _rtw_up_sema(_sema *sema)
  984. {
  985. #ifdef PLATFORM_LINUX
  986. up(sema);
  987. #endif
  988. #ifdef PLATFORM_FREEBSD
  989. sema_post(sema);
  990. #endif
  991. #ifdef PLATFORM_OS_XP
  992. KeReleaseSemaphore(sema, IO_NETWORK_INCREMENT, 1, FALSE);
  993. #endif
  994. #ifdef PLATFORM_OS_CE
  995. ReleaseSemaphore(*sema, 1, NULL);
  996. #endif
  997. }
  998. u32 _rtw_down_sema(_sema *sema)
  999. {
  1000. #ifdef PLATFORM_LINUX
  1001. if (down_interruptible(sema))
  1002. return _FAIL;
  1003. else
  1004. return _SUCCESS;
  1005. #endif
  1006. #ifdef PLATFORM_FREEBSD
  1007. sema_wait(sema);
  1008. return _SUCCESS;
  1009. #endif
  1010. #ifdef PLATFORM_OS_XP
  1011. if (STATUS_SUCCESS == KeWaitForSingleObject(sema, Executive, KernelMode, TRUE, NULL))
  1012. return _SUCCESS;
  1013. else
  1014. return _FAIL;
  1015. #endif
  1016. #ifdef PLATFORM_OS_CE
  1017. if (WAIT_OBJECT_0 == WaitForSingleObject(*sema, INFINITE))
  1018. return _SUCCESS;
  1019. else
  1020. return _FAIL;
  1021. #endif
  1022. }
  1023. inline void thread_exit(_completion *comp)
  1024. {
  1025. #ifdef PLATFORM_LINUX
  1026. complete_and_exit(comp, 0);
  1027. #endif
  1028. #ifdef PLATFORM_FREEBSD
  1029. printf("%s", "RTKTHREAD_exit");
  1030. #endif
  1031. #ifdef PLATFORM_OS_CE
  1032. ExitThread(STATUS_SUCCESS);
  1033. #endif
  1034. #ifdef PLATFORM_OS_XP
  1035. PsTerminateSystemThread(STATUS_SUCCESS);
  1036. #endif
  1037. }
  1038. inline void _rtw_init_completion(_completion *comp)
  1039. {
  1040. #ifdef PLATFORM_LINUX
  1041. init_completion(comp);
  1042. #endif
  1043. }
  1044. inline void _rtw_wait_for_comp_timeout(_completion *comp)
  1045. {
  1046. #ifdef PLATFORM_LINUX
  1047. wait_for_completion_timeout(comp, msecs_to_jiffies(3000));
  1048. #endif
  1049. }
  1050. inline void _rtw_wait_for_comp(_completion *comp)
  1051. {
  1052. #ifdef PLATFORM_LINUX
  1053. wait_for_completion(comp);
  1054. #endif
  1055. }
  1056. void _rtw_mutex_init(_mutex *pmutex)
  1057. {
  1058. #ifdef PLATFORM_LINUX
  1059. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 37))
  1060. mutex_init(pmutex);
  1061. #else
  1062. init_MUTEX(pmutex);
  1063. #endif
  1064. #endif
  1065. #ifdef PLATFORM_FREEBSD
  1066. mtx_init(pmutex, "", NULL, MTX_DEF | MTX_RECURSE);
  1067. #endif
  1068. #ifdef PLATFORM_OS_XP
  1069. KeInitializeMutex(pmutex, 0);
  1070. #endif
  1071. #ifdef PLATFORM_OS_CE
  1072. *pmutex = CreateMutex(NULL, _FALSE, NULL);
  1073. #endif
  1074. }
  1075. void _rtw_mutex_free(_mutex *pmutex);
  1076. void _rtw_mutex_free(_mutex *pmutex)
  1077. {
  1078. #ifdef PLATFORM_LINUX
  1079. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 37))
  1080. mutex_destroy(pmutex);
  1081. #else
  1082. #endif
  1083. #ifdef PLATFORM_FREEBSD
  1084. sema_destroy(pmutex);
  1085. #endif
  1086. #endif
  1087. #ifdef PLATFORM_OS_XP
  1088. #endif
  1089. #ifdef PLATFORM_OS_CE
  1090. #endif
  1091. }
  1092. void _rtw_spinlock_init(_lock *plock)
  1093. {
  1094. #ifdef PLATFORM_LINUX
  1095. spin_lock_init(plock);
  1096. #endif
  1097. #ifdef PLATFORM_FREEBSD
  1098. mtx_init(plock, "", NULL, MTX_DEF | MTX_RECURSE);
  1099. #endif
  1100. #ifdef PLATFORM_WINDOWS
  1101. NdisAllocateSpinLock(plock);
  1102. #endif
  1103. }
  1104. void _rtw_spinlock_free(_lock *plock)
  1105. {
  1106. #ifdef PLATFORM_FREEBSD
  1107. mtx_destroy(plock);
  1108. #endif
  1109. #ifdef PLATFORM_WINDOWS
  1110. NdisFreeSpinLock(plock);
  1111. #endif
  1112. }
  1113. #ifdef PLATFORM_FREEBSD
  1114. extern PADAPTER prtw_lock;
  1115. void rtw_mtx_lock(_lock *plock)
  1116. {
  1117. if (prtw_lock)
  1118. mtx_lock(&prtw_lock->glock);
  1119. else
  1120. printf("%s prtw_lock==NULL", __FUNCTION__);
  1121. }
  1122. void rtw_mtx_unlock(_lock *plock)
  1123. {
  1124. if (prtw_lock)
  1125. mtx_unlock(&prtw_lock->glock);
  1126. else
  1127. printf("%s prtw_lock==NULL", __FUNCTION__);
  1128. }
  1129. #endif /* PLATFORM_FREEBSD */
  1130. void _rtw_spinlock(_lock *plock)
  1131. {
  1132. #ifdef PLATFORM_LINUX
  1133. spin_lock(plock);
  1134. #endif
  1135. #ifdef PLATFORM_FREEBSD
  1136. mtx_lock(plock);
  1137. #endif
  1138. #ifdef PLATFORM_WINDOWS
  1139. NdisAcquireSpinLock(plock);
  1140. #endif
  1141. }
  1142. void _rtw_spinunlock(_lock *plock)
  1143. {
  1144. #ifdef PLATFORM_LINUX
  1145. spin_unlock(plock);
  1146. #endif
  1147. #ifdef PLATFORM_FREEBSD
  1148. mtx_unlock(plock);
  1149. #endif
  1150. #ifdef PLATFORM_WINDOWS
  1151. NdisReleaseSpinLock(plock);
  1152. #endif
  1153. }
  1154. void _rtw_spinlock_ex(_lock *plock)
  1155. {
  1156. #ifdef PLATFORM_LINUX
  1157. spin_lock(plock);
  1158. #endif
  1159. #ifdef PLATFORM_FREEBSD
  1160. mtx_lock(plock);
  1161. #endif
  1162. #ifdef PLATFORM_WINDOWS
  1163. NdisDprAcquireSpinLock(plock);
  1164. #endif
  1165. }
  1166. void _rtw_spinunlock_ex(_lock *plock)
  1167. {
  1168. #ifdef PLATFORM_LINUX
  1169. spin_unlock(plock);
  1170. #endif
  1171. #ifdef PLATFORM_FREEBSD
  1172. mtx_unlock(plock);
  1173. #endif
  1174. #ifdef PLATFORM_WINDOWS
  1175. NdisDprReleaseSpinLock(plock);
  1176. #endif
  1177. }
  1178. void _rtw_init_queue(_queue *pqueue)
  1179. {
  1180. _rtw_init_listhead(&(pqueue->queue));
  1181. _rtw_spinlock_init(&(pqueue->lock));
  1182. }
  1183. void _rtw_deinit_queue(_queue *pqueue)
  1184. {
  1185. _rtw_spinlock_free(&(pqueue->lock));
  1186. }
  1187. u32 _rtw_queue_empty(_queue *pqueue)
  1188. {
  1189. return rtw_is_list_empty(&(pqueue->queue));
  1190. }
  1191. u32 rtw_end_of_queue_search(_list *head, _list *plist)
  1192. {
  1193. if (head == plist)
  1194. return _TRUE;
  1195. else
  1196. return _FALSE;
  1197. }
  1198. systime _rtw_get_current_time(void)
  1199. {
  1200. #ifdef PLATFORM_LINUX
  1201. return jiffies;
  1202. #endif
  1203. #ifdef PLATFORM_FREEBSD
  1204. struct timeval tvp;
  1205. getmicrotime(&tvp);
  1206. return tvp.tv_sec;
  1207. #endif
  1208. #ifdef PLATFORM_WINDOWS
  1209. LARGE_INTEGER SystemTime;
  1210. NdisGetCurrentSystemTime(&SystemTime);
  1211. return SystemTime.LowPart;/* count of 100-nanosecond intervals */
  1212. #endif
  1213. }
  1214. inline u32 _rtw_systime_to_ms(systime stime)
  1215. {
  1216. #ifdef PLATFORM_LINUX
  1217. return jiffies_to_msecs(stime);
  1218. #endif
  1219. #ifdef PLATFORM_FREEBSD
  1220. return stime * 1000;
  1221. #endif
  1222. #ifdef PLATFORM_WINDOWS
  1223. return stime / 10000 ;
  1224. #endif
  1225. }
  1226. inline systime _rtw_ms_to_systime(u32 ms)
  1227. {
  1228. #ifdef PLATFORM_LINUX
  1229. return msecs_to_jiffies(ms);
  1230. #endif
  1231. #ifdef PLATFORM_FREEBSD
  1232. return ms / 1000;
  1233. #endif
  1234. #ifdef PLATFORM_WINDOWS
  1235. return ms * 10000 ;
  1236. #endif
  1237. }
  1238. inline systime _rtw_us_to_systime(u32 us)
  1239. {
  1240. #ifdef PLATFORM_LINUX
  1241. return usecs_to_jiffies(us);
  1242. #else
  1243. #error "TBD\n"
  1244. #endif
  1245. }
  1246. /* the input parameter start use the same unit as returned by rtw_get_current_time */
  1247. inline s32 _rtw_get_passing_time_ms(systime start)
  1248. {
  1249. return _rtw_systime_to_ms(_rtw_get_current_time() - start);
  1250. }
  1251. inline s32 _rtw_get_remaining_time_ms(systime end)
  1252. {
  1253. return _rtw_systime_to_ms(end - _rtw_get_current_time());
  1254. }
  1255. inline s32 _rtw_get_time_interval_ms(systime start, systime end)
  1256. {
  1257. return _rtw_systime_to_ms(end - start);
  1258. }
  1259. inline bool _rtw_time_after(systime a, systime b)
  1260. {
  1261. #ifdef PLATFORM_LINUX
  1262. return time_after(a, b);
  1263. #else
  1264. #error "TBD\n"
  1265. #endif
  1266. }
  1267. void rtw_sleep_schedulable(int ms)
  1268. {
  1269. #ifdef PLATFORM_LINUX
  1270. u32 delta;
  1271. delta = (ms * HZ) / 1000; /* (ms) */
  1272. if (delta == 0) {
  1273. delta = 1;/* 1 ms */
  1274. }
  1275. set_current_state(TASK_INTERRUPTIBLE);
  1276. if (schedule_timeout(delta) != 0)
  1277. return ;
  1278. return;
  1279. #endif
  1280. #ifdef PLATFORM_FREEBSD
  1281. DELAY(ms * 1000);
  1282. return ;
  1283. #endif
  1284. #ifdef PLATFORM_WINDOWS
  1285. NdisMSleep(ms * 1000); /* (us)*1000=(ms) */
  1286. #endif
  1287. }
  1288. void rtw_msleep_os(int ms)
  1289. {
  1290. #ifdef PLATFORM_LINUX
  1291. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 36))
  1292. if (ms < 20) {
  1293. unsigned long us = ms * 1000UL;
  1294. usleep_range(us, us + 1000UL);
  1295. } else
  1296. #endif
  1297. msleep((unsigned int)ms);
  1298. #endif
  1299. #ifdef PLATFORM_FREEBSD
  1300. /* Delay for delay microseconds */
  1301. DELAY(ms * 1000);
  1302. return ;
  1303. #endif
  1304. #ifdef PLATFORM_WINDOWS
  1305. NdisMSleep(ms * 1000); /* (us)*1000=(ms) */
  1306. #endif
  1307. }
  1308. void rtw_usleep_os(int us)
  1309. {
  1310. #ifdef PLATFORM_LINUX
  1311. /* msleep((unsigned int)us); */
  1312. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 36))
  1313. usleep_range(us, us + 1);
  1314. #else
  1315. if (1 < (us / 1000))
  1316. msleep(1);
  1317. else
  1318. msleep((us / 1000) + 1);
  1319. #endif
  1320. #endif
  1321. #ifdef PLATFORM_FREEBSD
  1322. /* Delay for delay microseconds */
  1323. DELAY(us);
  1324. return ;
  1325. #endif
  1326. #ifdef PLATFORM_WINDOWS
  1327. NdisMSleep(us); /* (us) */
  1328. #endif
  1329. }
  1330. #ifdef DBG_DELAY_OS
  1331. void _rtw_mdelay_os(int ms, const char *func, const int line)
  1332. {
  1333. #if 0
  1334. if (ms > 10)
  1335. RTW_INFO("%s:%d %s(%d)\n", func, line, __FUNCTION__, ms);
  1336. rtw_msleep_os(ms);
  1337. return;
  1338. #endif
  1339. RTW_INFO("%s:%d %s(%d)\n", func, line, __FUNCTION__, ms);
  1340. #if defined(PLATFORM_LINUX)
  1341. mdelay((unsigned long)ms);
  1342. #elif defined(PLATFORM_WINDOWS)
  1343. NdisStallExecution(ms * 1000); /* (us)*1000=(ms) */
  1344. #endif
  1345. }
  1346. void _rtw_udelay_os(int us, const char *func, const int line)
  1347. {
  1348. #if 0
  1349. if (us > 1000) {
  1350. RTW_INFO("%s:%d %s(%d)\n", func, line, __FUNCTION__, us);
  1351. rtw_usleep_os(us);
  1352. return;
  1353. }
  1354. #endif
  1355. RTW_INFO("%s:%d %s(%d)\n", func, line, __FUNCTION__, us);
  1356. #if defined(PLATFORM_LINUX)
  1357. udelay((unsigned long)us);
  1358. #elif defined(PLATFORM_WINDOWS)
  1359. NdisStallExecution(us); /* (us) */
  1360. #endif
  1361. }
  1362. #else
  1363. void rtw_mdelay_os(int ms)
  1364. {
  1365. #ifdef PLATFORM_LINUX
  1366. mdelay((unsigned long)ms);
  1367. #endif
  1368. #ifdef PLATFORM_FREEBSD
  1369. DELAY(ms * 1000);
  1370. return ;
  1371. #endif
  1372. #ifdef PLATFORM_WINDOWS
  1373. NdisStallExecution(ms * 1000); /* (us)*1000=(ms) */
  1374. #endif
  1375. }
  1376. void rtw_udelay_os(int us)
  1377. {
  1378. #ifdef PLATFORM_LINUX
  1379. udelay((unsigned long)us);
  1380. #endif
  1381. #ifdef PLATFORM_FREEBSD
  1382. /* Delay for delay microseconds */
  1383. DELAY(us);
  1384. return ;
  1385. #endif
  1386. #ifdef PLATFORM_WINDOWS
  1387. NdisStallExecution(us); /* (us) */
  1388. #endif
  1389. }
  1390. #endif
  1391. void rtw_yield_os(void)
  1392. {
  1393. #ifdef PLATFORM_LINUX
  1394. yield();
  1395. #endif
  1396. #ifdef PLATFORM_FREEBSD
  1397. yield();
  1398. #endif
  1399. #ifdef PLATFORM_WINDOWS
  1400. SwitchToThread();
  1401. #endif
  1402. }
  1403. bool rtw_macaddr_is_larger(const u8 *a, const u8 *b)
  1404. {
  1405. u32 va, vb;
  1406. va = be32_to_cpu(*((u32 *)a));
  1407. vb = be32_to_cpu(*((u32 *)b));
  1408. if (va > vb)
  1409. return 1;
  1410. else if (va < vb)
  1411. return 0;
  1412. return be16_to_cpu(*((u16 *)(a + 4))) > be16_to_cpu(*((u16 *)(b + 4)));
  1413. }
  1414. #define RTW_SUSPEND_LOCK_NAME "rtw_wifi"
  1415. #define RTW_SUSPEND_TRAFFIC_LOCK_NAME "rtw_wifi_traffic"
  1416. #define RTW_SUSPEND_RESUME_LOCK_NAME "rtw_wifi_resume"
  1417. #ifdef CONFIG_WAKELOCK
  1418. static struct wake_lock rtw_suspend_lock;
  1419. static struct wake_lock rtw_suspend_traffic_lock;
  1420. static struct wake_lock rtw_suspend_resume_lock;
  1421. #elif defined(CONFIG_ANDROID_POWER)
  1422. static android_suspend_lock_t rtw_suspend_lock = {
  1423. .name = RTW_SUSPEND_LOCK_NAME
  1424. };
  1425. static android_suspend_lock_t rtw_suspend_traffic_lock = {
  1426. .name = RTW_SUSPEND_TRAFFIC_LOCK_NAME
  1427. };
  1428. static android_suspend_lock_t rtw_suspend_resume_lock = {
  1429. .name = RTW_SUSPEND_RESUME_LOCK_NAME
  1430. };
  1431. #endif
  1432. inline void rtw_suspend_lock_init(void)
  1433. {
  1434. #ifdef CONFIG_WAKELOCK
  1435. wake_lock_init(&rtw_suspend_lock, WAKE_LOCK_SUSPEND, RTW_SUSPEND_LOCK_NAME);
  1436. wake_lock_init(&rtw_suspend_traffic_lock, WAKE_LOCK_SUSPEND, RTW_SUSPEND_TRAFFIC_LOCK_NAME);
  1437. wake_lock_init(&rtw_suspend_resume_lock, WAKE_LOCK_SUSPEND, RTW_SUSPEND_RESUME_LOCK_NAME);
  1438. #elif defined(CONFIG_ANDROID_POWER)
  1439. android_init_suspend_lock(&rtw_suspend_lock);
  1440. android_init_suspend_lock(&rtw_suspend_traffic_lock);
  1441. android_init_suspend_lock(&rtw_suspend_resume_lock);
  1442. #endif
  1443. }
  1444. inline void rtw_suspend_lock_uninit(void)
  1445. {
  1446. #ifdef CONFIG_WAKELOCK
  1447. wake_lock_destroy(&rtw_suspend_lock);
  1448. wake_lock_destroy(&rtw_suspend_traffic_lock);
  1449. wake_lock_destroy(&rtw_suspend_resume_lock);
  1450. #elif defined(CONFIG_ANDROID_POWER)
  1451. android_uninit_suspend_lock(&rtw_suspend_lock);
  1452. android_uninit_suspend_lock(&rtw_suspend_traffic_lock);
  1453. android_uninit_suspend_lock(&rtw_suspend_resume_lock);
  1454. #endif
  1455. }
  1456. inline void rtw_lock_suspend(void)
  1457. {
  1458. #ifdef CONFIG_WAKELOCK
  1459. wake_lock(&rtw_suspend_lock);
  1460. #elif defined(CONFIG_ANDROID_POWER)
  1461. android_lock_suspend(&rtw_suspend_lock);
  1462. #endif
  1463. #if defined(CONFIG_WAKELOCK) || defined(CONFIG_ANDROID_POWER)
  1464. /* RTW_INFO("####%s: suspend_lock_count:%d####\n", __FUNCTION__, rtw_suspend_lock.stat.count); */
  1465. #endif
  1466. }
  1467. inline void rtw_unlock_suspend(void)
  1468. {
  1469. #ifdef CONFIG_WAKELOCK
  1470. wake_unlock(&rtw_suspend_lock);
  1471. #elif defined(CONFIG_ANDROID_POWER)
  1472. android_unlock_suspend(&rtw_suspend_lock);
  1473. #endif
  1474. #if defined(CONFIG_WAKELOCK) || defined(CONFIG_ANDROID_POWER)
  1475. /* RTW_INFO("####%s: suspend_lock_count:%d####\n", __FUNCTION__, rtw_suspend_lock.stat.count); */
  1476. #endif
  1477. }
  1478. inline void rtw_resume_lock_suspend(void)
  1479. {
  1480. #ifdef CONFIG_WAKELOCK
  1481. wake_lock(&rtw_suspend_resume_lock);
  1482. #elif defined(CONFIG_ANDROID_POWER)
  1483. android_lock_suspend(&rtw_suspend_resume_lock);
  1484. #endif
  1485. #if defined(CONFIG_WAKELOCK) || defined(CONFIG_ANDROID_POWER)
  1486. /* RTW_INFO("####%s: suspend_lock_count:%d####\n", __FUNCTION__, rtw_suspend_lock.stat.count); */
  1487. #endif
  1488. }
  1489. inline void rtw_resume_unlock_suspend(void)
  1490. {
  1491. #ifdef CONFIG_WAKELOCK
  1492. wake_unlock(&rtw_suspend_resume_lock);
  1493. #elif defined(CONFIG_ANDROID_POWER)
  1494. android_unlock_suspend(&rtw_suspend_resume_lock);
  1495. #endif
  1496. #if defined(CONFIG_WAKELOCK) || defined(CONFIG_ANDROID_POWER)
  1497. /* RTW_INFO("####%s: suspend_lock_count:%d####\n", __FUNCTION__, rtw_suspend_lock.stat.count); */
  1498. #endif
  1499. }
  1500. inline void rtw_lock_suspend_timeout(u32 timeout_ms)
  1501. {
  1502. #ifdef CONFIG_WAKELOCK
  1503. wake_lock_timeout(&rtw_suspend_lock, rtw_ms_to_systime(timeout_ms));
  1504. #elif defined(CONFIG_ANDROID_POWER)
  1505. android_lock_suspend_auto_expire(&rtw_suspend_lock, rtw_ms_to_systime(timeout_ms));
  1506. #endif
  1507. }
  1508. inline void rtw_lock_traffic_suspend_timeout(u32 timeout_ms)
  1509. {
  1510. #ifdef CONFIG_WAKELOCK
  1511. wake_lock_timeout(&rtw_suspend_traffic_lock, rtw_ms_to_systime(timeout_ms));
  1512. #elif defined(CONFIG_ANDROID_POWER)
  1513. android_lock_suspend_auto_expire(&rtw_suspend_traffic_lock, rtw_ms_to_systime(timeout_ms));
  1514. #endif
  1515. /* RTW_INFO("traffic lock timeout:%d\n", timeout_ms); */
  1516. }
  1517. inline void rtw_set_bit(int nr, unsigned long *addr)
  1518. {
  1519. #ifdef PLATFORM_LINUX
  1520. set_bit(nr, addr);
  1521. #else
  1522. #error "TBD\n";
  1523. #endif
  1524. }
  1525. inline void rtw_clear_bit(int nr, unsigned long *addr)
  1526. {
  1527. #ifdef PLATFORM_LINUX
  1528. clear_bit(nr, addr);
  1529. #else
  1530. #error "TBD\n";
  1531. #endif
  1532. }
  1533. inline int rtw_test_and_clear_bit(int nr, unsigned long *addr)
  1534. {
  1535. #ifdef PLATFORM_LINUX
  1536. return test_and_clear_bit(nr, addr);
  1537. #else
  1538. #error "TBD\n";
  1539. #endif
  1540. }
  1541. inline void ATOMIC_SET(ATOMIC_T *v, int i)
  1542. {
  1543. #ifdef PLATFORM_LINUX
  1544. atomic_set(v, i);
  1545. #elif defined(PLATFORM_WINDOWS)
  1546. *v = i; /* other choice???? */
  1547. #elif defined(PLATFORM_FREEBSD)
  1548. atomic_set_int(v, i);
  1549. #endif
  1550. }
  1551. inline int ATOMIC_READ(ATOMIC_T *v)
  1552. {
  1553. #ifdef PLATFORM_LINUX
  1554. return atomic_read(v);
  1555. #elif defined(PLATFORM_WINDOWS)
  1556. return *v; /* other choice???? */
  1557. #elif defined(PLATFORM_FREEBSD)
  1558. return atomic_load_acq_32(v);
  1559. #endif
  1560. }
  1561. inline void ATOMIC_ADD(ATOMIC_T *v, int i)
  1562. {
  1563. #ifdef PLATFORM_LINUX
  1564. atomic_add(i, v);
  1565. #elif defined(PLATFORM_WINDOWS)
  1566. InterlockedAdd(v, i);
  1567. #elif defined(PLATFORM_FREEBSD)
  1568. atomic_add_int(v, i);
  1569. #endif
  1570. }
  1571. inline void ATOMIC_SUB(ATOMIC_T *v, int i)
  1572. {
  1573. #ifdef PLATFORM_LINUX
  1574. atomic_sub(i, v);
  1575. #elif defined(PLATFORM_WINDOWS)
  1576. InterlockedAdd(v, -i);
  1577. #elif defined(PLATFORM_FREEBSD)
  1578. atomic_subtract_int(v, i);
  1579. #endif
  1580. }
  1581. inline void ATOMIC_INC(ATOMIC_T *v)
  1582. {
  1583. #ifdef PLATFORM_LINUX
  1584. atomic_inc(v);
  1585. #elif defined(PLATFORM_WINDOWS)
  1586. InterlockedIncrement(v);
  1587. #elif defined(PLATFORM_FREEBSD)
  1588. atomic_add_int(v, 1);
  1589. #endif
  1590. }
  1591. inline void ATOMIC_DEC(ATOMIC_T *v)
  1592. {
  1593. #ifdef PLATFORM_LINUX
  1594. atomic_dec(v);
  1595. #elif defined(PLATFORM_WINDOWS)
  1596. InterlockedDecrement(v);
  1597. #elif defined(PLATFORM_FREEBSD)
  1598. atomic_subtract_int(v, 1);
  1599. #endif
  1600. }
  1601. inline int ATOMIC_ADD_RETURN(ATOMIC_T *v, int i)
  1602. {
  1603. #ifdef PLATFORM_LINUX
  1604. return atomic_add_return(i, v);
  1605. #elif defined(PLATFORM_WINDOWS)
  1606. return InterlockedAdd(v, i);
  1607. #elif defined(PLATFORM_FREEBSD)
  1608. atomic_add_int(v, i);
  1609. return atomic_load_acq_32(v);
  1610. #endif
  1611. }
  1612. inline int ATOMIC_SUB_RETURN(ATOMIC_T *v, int i)
  1613. {
  1614. #ifdef PLATFORM_LINUX
  1615. return atomic_sub_return(i, v);
  1616. #elif defined(PLATFORM_WINDOWS)
  1617. return InterlockedAdd(v, -i);
  1618. #elif defined(PLATFORM_FREEBSD)
  1619. atomic_subtract_int(v, i);
  1620. return atomic_load_acq_32(v);
  1621. #endif
  1622. }
  1623. inline int ATOMIC_INC_RETURN(ATOMIC_T *v)
  1624. {
  1625. #ifdef PLATFORM_LINUX
  1626. return atomic_inc_return(v);
  1627. #elif defined(PLATFORM_WINDOWS)
  1628. return InterlockedIncrement(v);
  1629. #elif defined(PLATFORM_FREEBSD)
  1630. atomic_add_int(v, 1);
  1631. return atomic_load_acq_32(v);
  1632. #endif
  1633. }
  1634. inline int ATOMIC_DEC_RETURN(ATOMIC_T *v)
  1635. {
  1636. #ifdef PLATFORM_LINUX
  1637. return atomic_dec_return(v);
  1638. #elif defined(PLATFORM_WINDOWS)
  1639. return InterlockedDecrement(v);
  1640. #elif defined(PLATFORM_FREEBSD)
  1641. atomic_subtract_int(v, 1);
  1642. return atomic_load_acq_32(v);
  1643. #endif
  1644. }
  1645. inline bool ATOMIC_INC_UNLESS(ATOMIC_T *v, int u)
  1646. {
  1647. #ifdef PLATFORM_LINUX
  1648. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 15))
  1649. return atomic_add_unless(v, 1, u);
  1650. #else
  1651. /* only make sure not exceed after this function */
  1652. if (ATOMIC_INC_RETURN(v) > u) {
  1653. ATOMIC_DEC(v);
  1654. return 0;
  1655. }
  1656. return 1;
  1657. #endif
  1658. #else
  1659. #error "TBD\n"
  1660. #endif
  1661. }
  1662. #ifdef PLATFORM_LINUX
  1663. /*
  1664. * Open a file with the specific @param path, @param flag, @param mode
  1665. * @param fpp the pointer of struct file pointer to get struct file pointer while file opening is success
  1666. * @param path the path of the file to open
  1667. * @param flag file operation flags, please refer to linux document
  1668. * @param mode please refer to linux document
  1669. * @return Linux specific error code
  1670. */
  1671. static int openFile(struct file **fpp, const char *path, int flag, int mode)
  1672. {
  1673. struct file *fp;
  1674. fp = filp_open(path, flag, mode);
  1675. if (IS_ERR(fp)) {
  1676. *fpp = NULL;
  1677. return PTR_ERR(fp);
  1678. } else {
  1679. *fpp = fp;
  1680. return 0;
  1681. }
  1682. }
  1683. /*
  1684. * Close the file with the specific @param fp
  1685. * @param fp the pointer of struct file to close
  1686. * @return always 0
  1687. */
  1688. static int closeFile(struct file *fp)
  1689. {
  1690. filp_close(fp, NULL);
  1691. return 0;
  1692. }
  1693. static int readFile(struct file *fp, char *buf, int len)
  1694. {
  1695. int rlen = 0, sum = 0;
  1696. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(4, 1, 0))
  1697. if (!(fp->f_mode & FMODE_CAN_READ))
  1698. #else
  1699. if (!fp->f_op || !fp->f_op->read)
  1700. #endif
  1701. return -EPERM;
  1702. while (sum < len) {
  1703. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(4, 14, 0))
  1704. rlen = kernel_read(fp, buf + sum, len - sum, &fp->f_pos);
  1705. #elif (LINUX_VERSION_CODE >= KERNEL_VERSION(4, 1, 0))
  1706. rlen = __vfs_read(fp, buf + sum, len - sum, &fp->f_pos);
  1707. #else
  1708. rlen = fp->f_op->read(fp, buf + sum, len - sum, &fp->f_pos);
  1709. #endif
  1710. if (rlen > 0)
  1711. sum += rlen;
  1712. else if (0 != rlen)
  1713. return rlen;
  1714. else
  1715. break;
  1716. }
  1717. return sum;
  1718. }
  1719. static int writeFile(struct file *fp, char *buf, int len)
  1720. {
  1721. int wlen = 0, sum = 0;
  1722. if (!fp->f_op || !fp->f_op->write)
  1723. return -EPERM;
  1724. while (sum < len) {
  1725. wlen = fp->f_op->write(fp, buf + sum, len - sum, &fp->f_pos);
  1726. if (wlen > 0)
  1727. sum += wlen;
  1728. else if (0 != wlen)
  1729. return wlen;
  1730. else
  1731. break;
  1732. }
  1733. return sum;
  1734. }
  1735. /*
  1736. * Test if the specifi @param path is a file and readable
  1737. * If readable, @param sz is got
  1738. * @param path the path of the file to test
  1739. * @return Linux specific error code
  1740. */
  1741. static int isFileReadable(const char *path, u32 *sz)
  1742. {
  1743. struct file *fp;
  1744. int ret = 0;
  1745. mm_segment_t oldfs;
  1746. char buf;
  1747. fp = filp_open(path, O_RDONLY, 0);
  1748. if (IS_ERR(fp))
  1749. ret = PTR_ERR(fp);
  1750. else {
  1751. #if (LINUX_VERSION_CODE < KERNEL_VERSION(5, 10, 0))
  1752. oldfs = get_fs();
  1753. set_fs(KERNEL_DS);
  1754. #else
  1755. oldfs = force_uaccess_begin();;
  1756. #endif
  1757. if (1 != readFile(fp, &buf, 1))
  1758. ret = PTR_ERR(fp);
  1759. if (ret == 0 && sz) {
  1760. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(3, 19, 0))
  1761. *sz = i_size_read(fp->f_path.dentry->d_inode);
  1762. #else
  1763. *sz = i_size_read(fp->f_dentry->d_inode);
  1764. #endif
  1765. }
  1766. #if (LINUX_VERSION_CODE < KERNEL_VERSION(5, 10, 0))
  1767. set_fs(oldfs);
  1768. #else
  1769. force_uaccess_end(oldfs);
  1770. #endif
  1771. filp_close(fp, NULL);
  1772. }
  1773. return ret;
  1774. }
  1775. /*
  1776. * Open the file with @param path and retrive the file content into memory starting from @param buf for @param sz at most
  1777. * @param path the path of the file to open and read
  1778. * @param buf the starting address of the buffer to store file content
  1779. * @param sz how many bytes to read at most
  1780. * @return the byte we've read, or Linux specific error code
  1781. */
  1782. static int retriveFromFile(const char *path, u8 *buf, u32 sz)
  1783. {
  1784. int ret = -1;
  1785. mm_segment_t oldfs;
  1786. struct file *fp;
  1787. if (path && buf) {
  1788. ret = openFile(&fp, path, O_RDONLY, 0);
  1789. if (0 == ret) {
  1790. RTW_INFO("%s openFile path:%s fp=%p\n", __FUNCTION__, path , fp);
  1791. #if (LINUX_VERSION_CODE < KERNEL_VERSION(5, 10, 0))
  1792. oldfs = get_fs();
  1793. set_fs(KERNEL_DS);
  1794. #else
  1795. oldfs = force_uaccess_begin();
  1796. #endif
  1797. ret = readFile(fp, buf, sz);
  1798. #if (LINUX_VERSION_CODE < KERNEL_VERSION(5, 10, 0))
  1799. set_fs(oldfs);
  1800. #else
  1801. force_uaccess_end(oldfs);
  1802. #endif
  1803. closeFile(fp);
  1804. RTW_INFO("%s readFile, ret:%d\n", __FUNCTION__, ret);
  1805. } else
  1806. RTW_INFO("%s openFile path:%s Fail, ret:%d\n", __FUNCTION__, path, ret);
  1807. } else {
  1808. RTW_INFO("%s NULL pointer\n", __FUNCTION__);
  1809. ret = -EINVAL;
  1810. }
  1811. return ret;
  1812. }
  1813. /*
  1814. * Open the file with @param path and wirte @param sz byte of data starting from @param buf into the file
  1815. * @param path the path of the file to open and write
  1816. * @param buf the starting address of the data to write into file
  1817. * @param sz how many bytes to write at most
  1818. * @return the byte we've written, or Linux specific error code
  1819. */
  1820. static int storeToFile(const char *path, u8 *buf, u32 sz)
  1821. {
  1822. int ret = 0;
  1823. mm_segment_t oldfs;
  1824. struct file *fp;
  1825. if (path && buf) {
  1826. ret = openFile(&fp, path, O_CREAT | O_WRONLY, 0666);
  1827. if (0 == ret) {
  1828. RTW_INFO("%s openFile path:%s fp=%p\n", __FUNCTION__, path , fp);
  1829. #if (LINUX_VERSION_CODE < KERNEL_VERSION(5, 10, 0))
  1830. oldfs = get_fs();
  1831. set_fs(KERNEL_DS);
  1832. #else
  1833. oldfs = force_uaccess_begin();
  1834. #endif
  1835. ret = writeFile(fp, buf, sz);
  1836. #if (LINUX_VERSION_CODE < KERNEL_VERSION(5, 10, 0))
  1837. set_fs(oldfs);
  1838. #else
  1839. force_uaccess_end(oldfs);
  1840. #endif
  1841. closeFile(fp);
  1842. RTW_INFO("%s writeFile, ret:%d\n", __FUNCTION__, ret);
  1843. } else
  1844. RTW_INFO("%s openFile path:%s Fail, ret:%d\n", __FUNCTION__, path, ret);
  1845. } else {
  1846. RTW_INFO("%s NULL pointer\n", __FUNCTION__);
  1847. ret = -EINVAL;
  1848. }
  1849. return ret;
  1850. }
  1851. #endif /* PLATFORM_LINUX */
  1852. /*
  1853. * Test if the specifi @param path is a file and readable
  1854. * @param path the path of the file to test
  1855. * @return _TRUE or _FALSE
  1856. */
  1857. int rtw_is_file_readable(const char *path)
  1858. {
  1859. #ifdef PLATFORM_LINUX
  1860. if (isFileReadable(path, NULL) == 0)
  1861. return _TRUE;
  1862. else
  1863. return _FALSE;
  1864. #else
  1865. /* Todo... */
  1866. return _FALSE;
  1867. #endif
  1868. }
  1869. /*
  1870. * Test if the specifi @param path is a file and readable.
  1871. * If readable, @param sz is got
  1872. * @param path the path of the file to test
  1873. * @return _TRUE or _FALSE
  1874. */
  1875. int rtw_is_file_readable_with_size(const char *path, u32 *sz)
  1876. {
  1877. #ifdef PLATFORM_LINUX
  1878. if (isFileReadable(path, sz) == 0)
  1879. return _TRUE;
  1880. else
  1881. return _FALSE;
  1882. #else
  1883. /* Todo... */
  1884. return _FALSE;
  1885. #endif
  1886. }
  1887. /*
  1888. * Open the file with @param path and retrive the file content into memory starting from @param buf for @param sz at most
  1889. * @param path the path of the file to open and read
  1890. * @param buf the starting address of the buffer to store file content
  1891. * @param sz how many bytes to read at most
  1892. * @return the byte we've read
  1893. */
  1894. int rtw_retrieve_from_file(const char *path, u8 *buf, u32 sz)
  1895. {
  1896. #ifdef PLATFORM_LINUX
  1897. int ret = retriveFromFile(path, buf, sz);
  1898. return ret >= 0 ? ret : 0;
  1899. #else
  1900. /* Todo... */
  1901. return 0;
  1902. #endif
  1903. }
  1904. /*
  1905. * Open the file with @param path and wirte @param sz byte of data starting from @param buf into the file
  1906. * @param path the path of the file to open and write
  1907. * @param buf the starting address of the data to write into file
  1908. * @param sz how many bytes to write at most
  1909. * @return the byte we've written
  1910. */
  1911. int rtw_store_to_file(const char *path, u8 *buf, u32 sz)
  1912. {
  1913. #ifdef PLATFORM_LINUX
  1914. int ret = storeToFile(path, buf, sz);
  1915. return ret >= 0 ? ret : 0;
  1916. #else
  1917. /* Todo... */
  1918. return 0;
  1919. #endif
  1920. }
  1921. #ifdef PLATFORM_LINUX
  1922. struct net_device *rtw_alloc_etherdev_with_old_priv(int sizeof_priv, void *old_priv)
  1923. {
  1924. struct net_device *pnetdev;
  1925. struct rtw_netdev_priv_indicator *pnpi;
  1926. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 35))
  1927. pnetdev = alloc_etherdev_mq(sizeof(struct rtw_netdev_priv_indicator), 4);
  1928. #else
  1929. pnetdev = alloc_etherdev(sizeof(struct rtw_netdev_priv_indicator));
  1930. #endif
  1931. if (!pnetdev)
  1932. goto RETURN;
  1933. pnpi = netdev_priv(pnetdev);
  1934. pnpi->priv = old_priv;
  1935. pnpi->sizeof_priv = sizeof_priv;
  1936. RETURN:
  1937. return pnetdev;
  1938. }
  1939. struct net_device *rtw_alloc_etherdev(int sizeof_priv)
  1940. {
  1941. struct net_device *pnetdev;
  1942. struct rtw_netdev_priv_indicator *pnpi;
  1943. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 35))
  1944. pnetdev = alloc_etherdev_mq(sizeof(struct rtw_netdev_priv_indicator), 4);
  1945. #else
  1946. pnetdev = alloc_etherdev(sizeof(struct rtw_netdev_priv_indicator));
  1947. #endif
  1948. if (!pnetdev)
  1949. goto RETURN;
  1950. pnpi = netdev_priv(pnetdev);
  1951. pnpi->priv = rtw_zvmalloc(sizeof_priv);
  1952. if (!pnpi->priv) {
  1953. free_netdev(pnetdev);
  1954. pnetdev = NULL;
  1955. goto RETURN;
  1956. }
  1957. pnpi->sizeof_priv = sizeof_priv;
  1958. RETURN:
  1959. return pnetdev;
  1960. }
  1961. void rtw_free_netdev(struct net_device *netdev)
  1962. {
  1963. struct rtw_netdev_priv_indicator *pnpi;
  1964. if (!netdev)
  1965. goto RETURN;
  1966. pnpi = netdev_priv(netdev);
  1967. if (!pnpi->priv)
  1968. goto RETURN;
  1969. free_netdev(netdev);
  1970. RETURN:
  1971. return;
  1972. }
  1973. int rtw_change_ifname(_adapter *padapter, const char *ifname)
  1974. {
  1975. struct dvobj_priv *dvobj;
  1976. struct net_device *pnetdev;
  1977. struct net_device *cur_pnetdev;
  1978. struct rereg_nd_name_data *rereg_priv;
  1979. int ret;
  1980. u8 rtnl_lock_needed;
  1981. if (!padapter)
  1982. goto error;
  1983. dvobj = adapter_to_dvobj(padapter);
  1984. cur_pnetdev = padapter->pnetdev;
  1985. rereg_priv = &padapter->rereg_nd_name_priv;
  1986. /* free the old_pnetdev */
  1987. if (rereg_priv->old_pnetdev) {
  1988. free_netdev(rereg_priv->old_pnetdev);
  1989. rereg_priv->old_pnetdev = NULL;
  1990. }
  1991. rtnl_lock_needed = rtw_rtnl_lock_needed(dvobj);
  1992. if (rtnl_lock_needed)
  1993. unregister_netdev(cur_pnetdev);
  1994. else
  1995. unregister_netdevice(cur_pnetdev);
  1996. rereg_priv->old_pnetdev = cur_pnetdev;
  1997. pnetdev = rtw_init_netdev(padapter);
  1998. if (!pnetdev) {
  1999. ret = -1;
  2000. goto error;
  2001. }
  2002. SET_NETDEV_DEV(pnetdev, dvobj_to_dev(adapter_to_dvobj(padapter)));
  2003. rtw_init_netdev_name(pnetdev, ifname);
  2004. _rtw_memcpy(pnetdev->dev_addr, adapter_mac_addr(padapter), ETH_ALEN);
  2005. if (rtnl_lock_needed)
  2006. ret = register_netdev(pnetdev);
  2007. else
  2008. ret = register_netdevice(pnetdev);
  2009. if (ret != 0) {
  2010. goto error;
  2011. }
  2012. return 0;
  2013. error:
  2014. return -1;
  2015. }
  2016. #endif
  2017. #ifdef PLATFORM_FREEBSD
  2018. /*
  2019. * Copy a buffer from userspace and write into kernel address
  2020. * space.
  2021. *
  2022. * This emulation just calls the FreeBSD copyin function (to
  2023. * copy data from user space buffer into a kernel space buffer)
  2024. * and is designed to be used with the above io_write_wrapper.
  2025. *
  2026. * This function should return the number of bytes not copied.
  2027. * I.e. success results in a zero value.
  2028. * Negative error values are not returned.
  2029. */
  2030. unsigned long
  2031. copy_from_user(void *to, const void *from, unsigned long n)
  2032. {
  2033. if (copyin(from, to, n) != 0) {
  2034. /* Any errors will be treated as a failure
  2035. to copy any of the requested bytes */
  2036. return n;
  2037. }
  2038. return 0;
  2039. }
  2040. unsigned long
  2041. copy_to_user(void *to, const void *from, unsigned long n)
  2042. {
  2043. if (copyout(from, to, n) != 0) {
  2044. /* Any errors will be treated as a failure
  2045. to copy any of the requested bytes */
  2046. return n;
  2047. }
  2048. return 0;
  2049. }
  2050. /*
  2051. * The usb_register and usb_deregister functions are used to register
  2052. * usb drivers with the usb subsystem. In this compatibility layer
  2053. * emulation a list of drivers (struct usb_driver) is maintained
  2054. * and is used for probing/attaching etc.
  2055. *
  2056. * usb_register and usb_deregister simply call these functions.
  2057. */
  2058. int
  2059. usb_register(struct usb_driver *driver)
  2060. {
  2061. rtw_usb_linux_register(driver);
  2062. return 0;
  2063. }
  2064. int
  2065. usb_deregister(struct usb_driver *driver)
  2066. {
  2067. rtw_usb_linux_deregister(driver);
  2068. return 0;
  2069. }
  2070. void module_init_exit_wrapper(void *arg)
  2071. {
  2072. int (*func)(void) = arg;
  2073. func();
  2074. return;
  2075. }
  2076. #endif /* PLATFORM_FREEBSD */
  2077. #ifdef CONFIG_PLATFORM_SPRD
  2078. #ifdef do_div
  2079. #undef do_div
  2080. #endif
  2081. #include <asm-generic/div64.h>
  2082. #endif
  2083. u64 rtw_modular64(u64 x, u64 y)
  2084. {
  2085. #ifdef PLATFORM_LINUX
  2086. return do_div(x, y);
  2087. #elif defined(PLATFORM_WINDOWS)
  2088. return x % y;
  2089. #elif defined(PLATFORM_FREEBSD)
  2090. return x % y;
  2091. #endif
  2092. }
  2093. u64 rtw_division64(u64 x, u64 y)
  2094. {
  2095. #ifdef PLATFORM_LINUX
  2096. do_div(x, y);
  2097. return x;
  2098. #elif defined(PLATFORM_WINDOWS)
  2099. return x / y;
  2100. #elif defined(PLATFORM_FREEBSD)
  2101. return x / y;
  2102. #endif
  2103. }
  2104. inline u32 rtw_random32(void)
  2105. {
  2106. #ifdef PLATFORM_LINUX
  2107. #if (LINUX_VERSION_CODE >= KERNEL_VERSION(3, 8, 0))
  2108. return prandom_u32();
  2109. #elif (LINUX_VERSION_CODE <= KERNEL_VERSION(2, 6, 18))
  2110. u32 random_int;
  2111. get_random_bytes(&random_int , 4);
  2112. return random_int;
  2113. #else
  2114. return random32();
  2115. #endif
  2116. #elif defined(PLATFORM_WINDOWS)
  2117. #error "to be implemented\n"
  2118. #elif defined(PLATFORM_FREEBSD)
  2119. #error "to be implemented\n"
  2120. #endif
  2121. }
  2122. void rtw_buf_free(u8 **buf, u32 *buf_len)
  2123. {
  2124. u32 ori_len;
  2125. if (!buf || !buf_len)
  2126. return;
  2127. ori_len = *buf_len;
  2128. if (*buf) {
  2129. u32 tmp_buf_len = *buf_len;
  2130. *buf_len = 0;
  2131. rtw_mfree(*buf, tmp_buf_len);
  2132. *buf = NULL;
  2133. }
  2134. }
  2135. void rtw_buf_update(u8 **buf, u32 *buf_len, u8 *src, u32 src_len)
  2136. {
  2137. u32 ori_len = 0, dup_len = 0;
  2138. u8 *ori = NULL;
  2139. u8 *dup = NULL;
  2140. if (!buf || !buf_len)
  2141. return;
  2142. if (!src || !src_len)
  2143. goto keep_ori;
  2144. /* duplicate src */
  2145. dup = rtw_malloc(src_len);
  2146. if (dup) {
  2147. dup_len = src_len;
  2148. _rtw_memcpy(dup, src, dup_len);
  2149. }
  2150. keep_ori:
  2151. ori = *buf;
  2152. ori_len = *buf_len;
  2153. /* replace buf with dup */
  2154. *buf_len = 0;
  2155. *buf = dup;
  2156. *buf_len = dup_len;
  2157. /* free ori */
  2158. if (ori && ori_len > 0)
  2159. rtw_mfree(ori, ori_len);
  2160. }
  2161. /**
  2162. * rtw_cbuf_full - test if cbuf is full
  2163. * @cbuf: pointer of struct rtw_cbuf
  2164. *
  2165. * Returns: _TRUE if cbuf is full
  2166. */
  2167. inline bool rtw_cbuf_full(struct rtw_cbuf *cbuf)
  2168. {
  2169. return (cbuf->write == cbuf->read - 1) ? _TRUE : _FALSE;
  2170. }
  2171. /**
  2172. * rtw_cbuf_empty - test if cbuf is empty
  2173. * @cbuf: pointer of struct rtw_cbuf
  2174. *
  2175. * Returns: _TRUE if cbuf is empty
  2176. */
  2177. inline bool rtw_cbuf_empty(struct rtw_cbuf *cbuf)
  2178. {
  2179. return (cbuf->write == cbuf->read) ? _TRUE : _FALSE;
  2180. }
  2181. /**
  2182. * rtw_cbuf_push - push a pointer into cbuf
  2183. * @cbuf: pointer of struct rtw_cbuf
  2184. * @buf: pointer to push in
  2185. *
  2186. * Lock free operation, be careful of the use scheme
  2187. * Returns: _TRUE push success
  2188. */
  2189. bool rtw_cbuf_push(struct rtw_cbuf *cbuf, void *buf)
  2190. {
  2191. if (rtw_cbuf_full(cbuf))
  2192. return _FAIL;
  2193. if (0)
  2194. RTW_INFO("%s on %u\n", __func__, cbuf->write);
  2195. cbuf->bufs[cbuf->write] = buf;
  2196. cbuf->write = (cbuf->write + 1) % cbuf->size;
  2197. return _SUCCESS;
  2198. }
  2199. /**
  2200. * rtw_cbuf_pop - pop a pointer from cbuf
  2201. * @cbuf: pointer of struct rtw_cbuf
  2202. *
  2203. * Lock free operation, be careful of the use scheme
  2204. * Returns: pointer popped out
  2205. */
  2206. void *rtw_cbuf_pop(struct rtw_cbuf *cbuf)
  2207. {
  2208. void *buf;
  2209. if (rtw_cbuf_empty(cbuf))
  2210. return NULL;
  2211. if (0)
  2212. RTW_INFO("%s on %u\n", __func__, cbuf->read);
  2213. buf = cbuf->bufs[cbuf->read];
  2214. cbuf->read = (cbuf->read + 1) % cbuf->size;
  2215. return buf;
  2216. }
  2217. /**
  2218. * rtw_cbuf_alloc - allocte a rtw_cbuf with given size and do initialization
  2219. * @size: size of pointer
  2220. *
  2221. * Returns: pointer of srtuct rtw_cbuf, NULL for allocation failure
  2222. */
  2223. struct rtw_cbuf *rtw_cbuf_alloc(u32 size)
  2224. {
  2225. struct rtw_cbuf *cbuf;
  2226. cbuf = (struct rtw_cbuf *)rtw_malloc(sizeof(*cbuf) + sizeof(void *) * size);
  2227. if (cbuf) {
  2228. cbuf->write = cbuf->read = 0;
  2229. cbuf->size = size;
  2230. }
  2231. return cbuf;
  2232. }
  2233. /**
  2234. * rtw_cbuf_free - free the given rtw_cbuf
  2235. * @cbuf: pointer of struct rtw_cbuf to free
  2236. */
  2237. void rtw_cbuf_free(struct rtw_cbuf *cbuf)
  2238. {
  2239. rtw_mfree((u8 *)cbuf, sizeof(*cbuf) + sizeof(void *) * cbuf->size);
  2240. }
  2241. /**
  2242. * map_readN - read a range of map data
  2243. * @map: map to read
  2244. * @offset: start address to read
  2245. * @len: length to read
  2246. * @buf: pointer of buffer to store data read
  2247. *
  2248. * Returns: _SUCCESS or _FAIL
  2249. */
  2250. int map_readN(const struct map_t *map, u16 offset, u16 len, u8 *buf)
  2251. {
  2252. const struct map_seg_t *seg;
  2253. int ret = _FAIL;
  2254. int i;
  2255. if (len == 0) {
  2256. rtw_warn_on(1);
  2257. goto exit;
  2258. }
  2259. if (offset + len > map->len) {
  2260. rtw_warn_on(1);
  2261. goto exit;
  2262. }
  2263. _rtw_memset(buf, map->init_value, len);
  2264. for (i = 0; i < map->seg_num; i++) {
  2265. u8 *c_dst, *c_src;
  2266. u16 c_len;
  2267. seg = map->segs + i;
  2268. if (seg->sa + seg->len <= offset || seg->sa >= offset + len)
  2269. continue;
  2270. if (seg->sa >= offset) {
  2271. c_dst = buf + (seg->sa - offset);
  2272. c_src = seg->c;
  2273. if (seg->sa + seg->len <= offset + len)
  2274. c_len = seg->len;
  2275. else
  2276. c_len = offset + len - seg->sa;
  2277. } else {
  2278. c_dst = buf;
  2279. c_src = seg->c + (offset - seg->sa);
  2280. if (seg->sa + seg->len >= offset + len)
  2281. c_len = len;
  2282. else
  2283. c_len = seg->sa + seg->len - offset;
  2284. }
  2285. _rtw_memcpy(c_dst, c_src, c_len);
  2286. }
  2287. exit:
  2288. return ret;
  2289. }
  2290. /**
  2291. * map_read8 - read 1 byte of map data
  2292. * @map: map to read
  2293. * @offset: address to read
  2294. *
  2295. * Returns: value of data of specified offset. map.init_value if offset is out of range
  2296. */
  2297. u8 map_read8(const struct map_t *map, u16 offset)
  2298. {
  2299. const struct map_seg_t *seg;
  2300. u8 val = map->init_value;
  2301. int i;
  2302. if (offset + 1 > map->len) {
  2303. rtw_warn_on(1);
  2304. goto exit;
  2305. }
  2306. for (i = 0; i < map->seg_num; i++) {
  2307. seg = map->segs + i;
  2308. if (seg->sa + seg->len <= offset || seg->sa >= offset + 1)
  2309. continue;
  2310. val = *(seg->c + offset - seg->sa);
  2311. break;
  2312. }
  2313. exit:
  2314. return val;
  2315. }
  2316. int rtw_blacklist_add(_queue *blist, const u8 *addr, u32 timeout_ms)
  2317. {
  2318. struct blacklist_ent *ent;
  2319. _list *list, *head;
  2320. u8 exist = _FALSE, timeout = _FALSE;
  2321. enter_critical_bh(&blist->lock);
  2322. head = &blist->queue;
  2323. list = get_next(head);
  2324. while (rtw_end_of_queue_search(head, list) == _FALSE) {
  2325. ent = LIST_CONTAINOR(list, struct blacklist_ent, list);
  2326. list = get_next(list);
  2327. if (_rtw_memcmp(ent->addr, addr, ETH_ALEN) == _TRUE) {
  2328. exist = _TRUE;
  2329. if (rtw_time_after(rtw_get_current_time(), ent->exp_time))
  2330. timeout = _TRUE;
  2331. ent->exp_time = rtw_get_current_time()
  2332. + rtw_ms_to_systime(timeout_ms);
  2333. break;
  2334. }
  2335. if (rtw_time_after(rtw_get_current_time(), ent->exp_time)) {
  2336. rtw_list_delete(&ent->list);
  2337. rtw_mfree(ent, sizeof(struct blacklist_ent));
  2338. }
  2339. }
  2340. if (exist == _FALSE) {
  2341. ent = rtw_malloc(sizeof(struct blacklist_ent));
  2342. if (ent) {
  2343. _rtw_memcpy(ent->addr, addr, ETH_ALEN);
  2344. ent->exp_time = rtw_get_current_time()
  2345. + rtw_ms_to_systime(timeout_ms);
  2346. rtw_list_insert_tail(&ent->list, head);
  2347. }
  2348. }
  2349. exit_critical_bh(&blist->lock);
  2350. exit:
  2351. return (exist == _TRUE && timeout == _FALSE) ? RTW_ALREADY : (ent ? _SUCCESS : _FAIL);
  2352. }
  2353. int rtw_blacklist_del(_queue *blist, const u8 *addr)
  2354. {
  2355. struct blacklist_ent *ent = NULL;
  2356. _list *list, *head;
  2357. u8 exist = _FALSE;
  2358. enter_critical_bh(&blist->lock);
  2359. head = &blist->queue;
  2360. list = get_next(head);
  2361. while (rtw_end_of_queue_search(head, list) == _FALSE) {
  2362. ent = LIST_CONTAINOR(list, struct blacklist_ent, list);
  2363. list = get_next(list);
  2364. if (_rtw_memcmp(ent->addr, addr, ETH_ALEN) == _TRUE) {
  2365. rtw_list_delete(&ent->list);
  2366. rtw_mfree(ent, sizeof(struct blacklist_ent));
  2367. exist = _TRUE;
  2368. break;
  2369. }
  2370. if (rtw_time_after(rtw_get_current_time(), ent->exp_time)) {
  2371. rtw_list_delete(&ent->list);
  2372. rtw_mfree(ent, sizeof(struct blacklist_ent));
  2373. }
  2374. }
  2375. exit_critical_bh(&blist->lock);
  2376. exit:
  2377. return exist == _TRUE ? _SUCCESS : RTW_ALREADY;
  2378. }
  2379. int rtw_blacklist_search(_queue *blist, const u8 *addr)
  2380. {
  2381. struct blacklist_ent *ent = NULL;
  2382. _list *list, *head;
  2383. u8 exist = _FALSE;
  2384. enter_critical_bh(&blist->lock);
  2385. head = &blist->queue;
  2386. list = get_next(head);
  2387. while (rtw_end_of_queue_search(head, list) == _FALSE) {
  2388. ent = LIST_CONTAINOR(list, struct blacklist_ent, list);
  2389. list = get_next(list);
  2390. if (_rtw_memcmp(ent->addr, addr, ETH_ALEN) == _TRUE) {
  2391. if (rtw_time_after(rtw_get_current_time(), ent->exp_time)) {
  2392. rtw_list_delete(&ent->list);
  2393. rtw_mfree(ent, sizeof(struct blacklist_ent));
  2394. } else
  2395. exist = _TRUE;
  2396. break;
  2397. }
  2398. if (rtw_time_after(rtw_get_current_time(), ent->exp_time)) {
  2399. rtw_list_delete(&ent->list);
  2400. rtw_mfree(ent, sizeof(struct blacklist_ent));
  2401. }
  2402. }
  2403. exit_critical_bh(&blist->lock);
  2404. exit:
  2405. return exist;
  2406. }
  2407. void rtw_blacklist_flush(_queue *blist)
  2408. {
  2409. struct blacklist_ent *ent;
  2410. _list *list, *head;
  2411. _list tmp;
  2412. _rtw_init_listhead(&tmp);
  2413. enter_critical_bh(&blist->lock);
  2414. rtw_list_splice_init(&blist->queue, &tmp);
  2415. exit_critical_bh(&blist->lock);
  2416. head = &tmp;
  2417. list = get_next(head);
  2418. while (rtw_end_of_queue_search(head, list) == _FALSE) {
  2419. ent = LIST_CONTAINOR(list, struct blacklist_ent, list);
  2420. list = get_next(list);
  2421. rtw_list_delete(&ent->list);
  2422. rtw_mfree(ent, sizeof(struct blacklist_ent));
  2423. }
  2424. }
  2425. void dump_blacklist(void *sel, _queue *blist, const char *title)
  2426. {
  2427. struct blacklist_ent *ent = NULL;
  2428. _list *list, *head;
  2429. enter_critical_bh(&blist->lock);
  2430. head = &blist->queue;
  2431. list = get_next(head);
  2432. if (rtw_end_of_queue_search(head, list) == _FALSE) {
  2433. if (title)
  2434. RTW_PRINT_SEL(sel, "%s:\n", title);
  2435. while (rtw_end_of_queue_search(head, list) == _FALSE) {
  2436. ent = LIST_CONTAINOR(list, struct blacklist_ent, list);
  2437. list = get_next(list);
  2438. if (rtw_time_after(rtw_get_current_time(), ent->exp_time))
  2439. RTW_PRINT_SEL(sel, MAC_FMT" expired\n", MAC_ARG(ent->addr));
  2440. else
  2441. RTW_PRINT_SEL(sel, MAC_FMT" %u\n", MAC_ARG(ent->addr)
  2442. , rtw_get_remaining_time_ms(ent->exp_time));
  2443. }
  2444. }
  2445. exit_critical_bh(&blist->lock);
  2446. }
  2447. /**
  2448. * is_null -
  2449. *
  2450. * Return TRUE if c is null character
  2451. * FALSE otherwise.
  2452. */
  2453. inline BOOLEAN is_null(char c)
  2454. {
  2455. if (c == '\0')
  2456. return _TRUE;
  2457. else
  2458. return _FALSE;
  2459. }
  2460. inline BOOLEAN is_all_null(char *c, int len)
  2461. {
  2462. for (; len > 0; len--)
  2463. if (c[len - 1] != '\0')
  2464. return _FALSE;
  2465. return _TRUE;
  2466. }
  2467. /**
  2468. * is_eol -
  2469. *
  2470. * Return TRUE if c is represent for EOL (end of line)
  2471. * FALSE otherwise.
  2472. */
  2473. inline BOOLEAN is_eol(char c)
  2474. {
  2475. if (c == '\r' || c == '\n')
  2476. return _TRUE;
  2477. else
  2478. return _FALSE;
  2479. }
  2480. /**
  2481. * is_space -
  2482. *
  2483. * Return TRUE if c is represent for space
  2484. * FALSE otherwise.
  2485. */
  2486. inline BOOLEAN is_space(char c)
  2487. {
  2488. if (c == ' ' || c == '\t')
  2489. return _TRUE;
  2490. else
  2491. return _FALSE;
  2492. }
  2493. /**
  2494. * IsHexDigit -
  2495. *
  2496. * Return TRUE if chTmp is represent for hex digit
  2497. * FALSE otherwise.
  2498. */
  2499. inline BOOLEAN IsHexDigit(char chTmp)
  2500. {
  2501. if ((chTmp >= '0' && chTmp <= '9') ||
  2502. (chTmp >= 'a' && chTmp <= 'f') ||
  2503. (chTmp >= 'A' && chTmp <= 'F'))
  2504. return _TRUE;
  2505. else
  2506. return _FALSE;
  2507. }
  2508. /**
  2509. * is_alpha -
  2510. *
  2511. * Return TRUE if chTmp is represent for alphabet
  2512. * FALSE otherwise.
  2513. */
  2514. inline BOOLEAN is_alpha(char chTmp)
  2515. {
  2516. if ((chTmp >= 'a' && chTmp <= 'z') ||
  2517. (chTmp >= 'A' && chTmp <= 'Z'))
  2518. return _TRUE;
  2519. else
  2520. return _FALSE;
  2521. }
  2522. inline char alpha_to_upper(char c)
  2523. {
  2524. if ((c >= 'a' && c <= 'z'))
  2525. c = 'A' + (c - 'a');
  2526. return c;
  2527. }
  2528. int hex2num_i(char c)
  2529. {
  2530. if (c >= '0' && c <= '9')
  2531. return c - '0';
  2532. if (c >= 'a' && c <= 'f')
  2533. return c - 'a' + 10;
  2534. if (c >= 'A' && c <= 'F')
  2535. return c - 'A' + 10;
  2536. return -1;
  2537. }
  2538. int hex2byte_i(const char *hex)
  2539. {
  2540. int a, b;
  2541. a = hex2num_i(*hex++);
  2542. if (a < 0)
  2543. return -1;
  2544. b = hex2num_i(*hex++);
  2545. if (b < 0)
  2546. return -1;
  2547. return (a << 4) | b;
  2548. }
  2549. int hexstr2bin(const char *hex, u8 *buf, size_t len)
  2550. {
  2551. size_t i;
  2552. int a;
  2553. const char *ipos = hex;
  2554. u8 *opos = buf;
  2555. for (i = 0; i < len; i++) {
  2556. a = hex2byte_i(ipos);
  2557. if (a < 0)
  2558. return -1;
  2559. *opos++ = a;
  2560. ipos += 2;
  2561. }
  2562. return 0;
  2563. }