osdep_service.c 56 KB

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