slab.c 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945
  1. /*
  2. * File : slab.c
  3. * This file is part of RT-Thread RTOS
  4. * COPYRIGHT (C) 2008 - 2012, RT-Thread Development Team
  5. *
  6. * The license and distribution terms for this file may be
  7. * found in the file LICENSE in this distribution or at
  8. * http://www.rt-thread.org/license/LICENSE
  9. *
  10. * Change Logs:
  11. * Date Author Notes
  12. * 2008-07-12 Bernard the first version
  13. * 2010-07-13 Bernard fix RT_ALIGN issue found by kuronca
  14. * 2010-10-23 yi.qiu add module memory allocator
  15. * 2010-12-18 yi.qiu fix zone release bug
  16. */
  17. /*
  18. * KERN_SLABALLOC.C - Kernel SLAB memory allocator
  19. *
  20. * Copyright (c) 2003,2004 The DragonFly Project. All rights reserved.
  21. *
  22. * This code is derived from software contributed to The DragonFly Project
  23. * by Matthew Dillon <dillon@backplane.com>
  24. *
  25. * Redistribution and use in source and binary forms, with or without
  26. * modification, are permitted provided that the following conditions
  27. * are met:
  28. *
  29. * 1. Redistributions of source code must retain the above copyright
  30. * notice, this list of conditions and the following disclaimer.
  31. * 2. Redistributions in binary form must reproduce the above copyright
  32. * notice, this list of conditions and the following disclaimer in
  33. * the documentation and/or other materials provided with the
  34. * distribution.
  35. * 3. Neither the name of The DragonFly Project nor the names of its
  36. * contributors may be used to endorse or promote products derived
  37. * from this software without specific, prior written permission.
  38. *
  39. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  40. * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  41. * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
  42. * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
  43. * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
  44. * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
  45. * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  46. * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
  47. * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
  48. * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
  49. * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  50. * SUCH DAMAGE.
  51. *
  52. */
  53. #include <rthw.h>
  54. #include <rtthread.h>
  55. #define RT_MEM_STATS
  56. #if defined (RT_USING_HEAP) && defined (RT_USING_SLAB)
  57. /* some statistical variable */
  58. #ifdef RT_MEM_STATS
  59. static rt_size_t used_mem, max_mem;
  60. #endif
  61. #ifdef RT_USING_HOOK
  62. static void (*rt_malloc_hook)(void *ptr, rt_size_t size);
  63. static void (*rt_free_hook)(void *ptr);
  64. /**
  65. * @addtogroup Hook
  66. */
  67. /*@{*/
  68. /**
  69. * This function will set a hook function, which will be invoked when a memory
  70. * block is allocated from heap memory.
  71. *
  72. * @param hook the hook function
  73. */
  74. void rt_malloc_sethook(void (*hook)(void *ptr, rt_size_t size))
  75. {
  76. rt_malloc_hook = hook;
  77. }
  78. RTM_EXPORT(rt_malloc_sethook);
  79. /**
  80. * This function will set a hook function, which will be invoked when a memory
  81. * block is released to heap memory.
  82. *
  83. * @param hook the hook function
  84. */
  85. void rt_free_sethook(void (*hook)(void *ptr))
  86. {
  87. rt_free_hook = hook;
  88. }
  89. RTM_EXPORT(rt_free_sethook);
  90. /*@}*/
  91. #endif
  92. /*
  93. * slab allocator implementation
  94. *
  95. * A slab allocator reserves a ZONE for each chunk size, then lays the
  96. * chunks out in an array within the zone. Allocation and deallocation
  97. * is nearly instantanious, and fragmentation/overhead losses are limited
  98. * to a fixed worst-case amount.
  99. *
  100. * The downside of this slab implementation is in the chunk size
  101. * multiplied by the number of zones. ~80 zones * 128K = 10MB of VM per cpu.
  102. * In a kernel implementation all this memory will be physical so
  103. * the zone size is adjusted downward on machines with less physical
  104. * memory. The upside is that overhead is bounded... this is the *worst*
  105. * case overhead.
  106. *
  107. * Slab management is done on a per-cpu basis and no locking or mutexes
  108. * are required, only a critical section. When one cpu frees memory
  109. * belonging to another cpu's slab manager an asynchronous IPI message
  110. * will be queued to execute the operation. In addition, both the
  111. * high level slab allocator and the low level zone allocator optimize
  112. * M_ZERO requests, and the slab allocator does not have to pre initialize
  113. * the linked list of chunks.
  114. *
  115. * XXX Balancing is needed between cpus. Balance will be handled through
  116. * asynchronous IPIs primarily by reassigning the z_Cpu ownership of chunks.
  117. *
  118. * XXX If we have to allocate a new zone and M_USE_RESERVE is set, use of
  119. * the new zone should be restricted to M_USE_RESERVE requests only.
  120. *
  121. * Alloc Size Chunking Number of zones
  122. * 0-127 8 16
  123. * 128-255 16 8
  124. * 256-511 32 8
  125. * 512-1023 64 8
  126. * 1024-2047 128 8
  127. * 2048-4095 256 8
  128. * 4096-8191 512 8
  129. * 8192-16383 1024 8
  130. * 16384-32767 2048 8
  131. * (if RT_MM_PAGE_SIZE is 4K the maximum zone allocation is 16383)
  132. *
  133. * Allocations >= zone_limit go directly to kmem.
  134. *
  135. * API REQUIREMENTS AND SIDE EFFECTS
  136. *
  137. * To operate as a drop-in replacement to the FreeBSD-4.x malloc() we
  138. * have remained compatible with the following API requirements:
  139. *
  140. * + small power-of-2 sized allocations are power-of-2 aligned (kern_tty)
  141. * + all power-of-2 sized allocations are power-of-2 aligned (twe)
  142. * + malloc(0) is allowed and returns non-RT_NULL (ahc driver)
  143. * + ability to allocate arbitrarily large chunks of memory
  144. */
  145. /*
  146. * Chunk structure for free elements
  147. */
  148. typedef struct slab_chunk
  149. {
  150. struct slab_chunk *c_next;
  151. } slab_chunk;
  152. /*
  153. * The IN-BAND zone header is placed at the beginning of each zone.
  154. */
  155. typedef struct slab_zone
  156. {
  157. rt_int32_t z_magic; /* magic number for sanity check */
  158. rt_int32_t z_nfree; /* total free chunks / ualloc space in zone */
  159. rt_int32_t z_nmax; /* maximum free chunks */
  160. struct slab_zone *z_next; /* zoneary[] link if z_nfree non-zero */
  161. rt_uint8_t *z_baseptr; /* pointer to start of chunk array */
  162. rt_int32_t z_uindex; /* current initial allocation index */
  163. rt_int32_t z_chunksize; /* chunk size for validation */
  164. rt_int32_t z_zoneindex; /* zone index */
  165. slab_chunk *z_freechunk; /* free chunk list */
  166. } slab_zone;
  167. #define ZALLOC_SLAB_MAGIC 0x51ab51ab
  168. #define ZALLOC_ZONE_LIMIT (16 * 1024) /* max slab-managed alloc */
  169. #define ZALLOC_MIN_ZONE_SIZE (32 * 1024) /* minimum zone size */
  170. #define ZALLOC_MAX_ZONE_SIZE (128 * 1024) /* maximum zone size */
  171. #define NZONES 72 /* number of zones */
  172. #define ZONE_RELEASE_THRESH 2 /* threshold number of zones */
  173. static slab_zone *zone_array[NZONES]; /* linked list of zones NFree > 0 */
  174. static slab_zone *zone_free; /* whole zones that have become free */
  175. static int zone_free_cnt;
  176. static int zone_size;
  177. static int zone_limit;
  178. static int zone_page_cnt;
  179. /*
  180. * Misc constants. Note that allocations that are exact multiples of
  181. * RT_MM_PAGE_SIZE, or exceed the zone limit, fall through to the kmem module.
  182. */
  183. #define MIN_CHUNK_SIZE 8 /* in bytes */
  184. #define MIN_CHUNK_MASK (MIN_CHUNK_SIZE - 1)
  185. /*
  186. * Array of descriptors that describe the contents of each page
  187. */
  188. #define PAGE_TYPE_FREE 0x00
  189. #define PAGE_TYPE_SMALL 0x01
  190. #define PAGE_TYPE_LARGE 0x02
  191. struct memusage
  192. {
  193. rt_uint32_t type:2 ; /* page type */
  194. rt_uint32_t size:30; /* pages allocated or offset from zone */
  195. };
  196. static struct memusage *memusage = RT_NULL;
  197. #define btokup(addr) (&memusage[((rt_uint32_t)(addr) - heap_start) >> RT_MM_PAGE_BITS])
  198. static rt_uint32_t heap_start, heap_end;
  199. /* page allocator */
  200. struct rt_page_head
  201. {
  202. struct rt_page_head *next; /* next valid page */
  203. rt_size_t page; /* number of page */
  204. /* dummy */
  205. char dummy[RT_MM_PAGE_SIZE - (sizeof(struct rt_page_head*) + sizeof (rt_size_t))];
  206. };
  207. static struct rt_page_head *rt_page_list;
  208. static struct rt_semaphore heap_sem;
  209. void *rt_page_alloc(rt_size_t npages)
  210. {
  211. struct rt_page_head *b, *n;
  212. struct rt_page_head **prev;
  213. if(npages == 0)
  214. return RT_NULL;
  215. /* lock heap */
  216. rt_sem_take(&heap_sem, RT_WAITING_FOREVER);
  217. for (prev = &rt_page_list; (b = *prev) != RT_NULL; prev = &(b->next))
  218. {
  219. if (b->page > npages)
  220. {
  221. /* splite pages */
  222. n = b + npages;
  223. n->next = b->next;
  224. n->page = b->page - npages;
  225. *prev = n;
  226. break;
  227. }
  228. if (b->page == npages)
  229. {
  230. /* this node fit, remove this node */
  231. *prev = b->next;
  232. break;
  233. }
  234. }
  235. /* unlock heap */
  236. rt_sem_release(&heap_sem);
  237. return b;
  238. }
  239. void rt_page_free(void *addr, rt_size_t npages)
  240. {
  241. struct rt_page_head *b, *n;
  242. struct rt_page_head **prev;
  243. RT_ASSERT(addr != RT_NULL);
  244. RT_ASSERT((rt_uint32_t)addr % RT_MM_PAGE_SIZE == 0);
  245. RT_ASSERT(npages != 0);
  246. n = (struct rt_page_head *)addr;
  247. /* lock heap */
  248. rt_sem_take(&heap_sem, RT_WAITING_FOREVER);
  249. for (prev = &rt_page_list; (b = *prev) != RT_NULL; prev = &(b->next))
  250. {
  251. RT_ASSERT(b->page > 0);
  252. RT_ASSERT(b > n || b + b->page <= n);
  253. if (b + b->page == n)
  254. {
  255. if (b + (b->page += npages) == b->next)
  256. {
  257. b->page += b->next->page;
  258. b->next = b->next->next;
  259. }
  260. goto _return;
  261. }
  262. if (b == n + npages)
  263. {
  264. n->page = b->page + npages;
  265. n->next = b->next;
  266. *prev = n;
  267. goto _return;
  268. }
  269. if (b > n + npages)
  270. break;
  271. }
  272. n->page = npages;
  273. n->next = b;
  274. *prev = n;
  275. _return:
  276. /* unlock heap */
  277. rt_sem_release(&heap_sem);
  278. }
  279. /*
  280. * Initialize the page allocator
  281. */
  282. static void rt_page_init(void *addr, rt_size_t npages)
  283. {
  284. RT_ASSERT(addr != RT_NULL);
  285. RT_ASSERT(npages != 0);
  286. rt_page_list = RT_NULL;
  287. rt_page_free(addr, npages);
  288. }
  289. /**
  290. * @ingroup SystemInit
  291. *
  292. * This function will init system heap
  293. *
  294. * @param begin_addr the beginning address of system page
  295. * @param end_addr the end address of system page
  296. */
  297. void rt_system_heap_init(void *begin_addr, void *end_addr)
  298. {
  299. rt_uint32_t limsize, npages;
  300. RT_DEBUG_NOT_IN_INTERRUPT;
  301. /* align begin and end addr to page */
  302. heap_start = RT_ALIGN((rt_uint32_t)begin_addr, RT_MM_PAGE_SIZE);
  303. heap_end = RT_ALIGN_DOWN((rt_uint32_t)end_addr, RT_MM_PAGE_SIZE);
  304. if (heap_start >= heap_end)
  305. {
  306. rt_kprintf("rt_system_heap_init, wrong address[0x%x - 0x%x]\n",
  307. (rt_uint32_t)begin_addr, (rt_uint32_t)end_addr);
  308. return;
  309. }
  310. limsize = heap_end - heap_start;
  311. npages = limsize / RT_MM_PAGE_SIZE;
  312. /* initialize heap semaphore */
  313. rt_sem_init(&heap_sem, "heap", 1, RT_IPC_FLAG_FIFO);
  314. RT_DEBUG_LOG(RT_DEBUG_SLAB,
  315. ("heap[0x%x - 0x%x], size 0x%x, 0x%x pages\n", heap_start, heap_end, limsize, npages));
  316. /* init pages */
  317. rt_page_init((void *)heap_start, npages);
  318. /* calculate zone size */
  319. zone_size = ZALLOC_MIN_ZONE_SIZE;
  320. while (zone_size < ZALLOC_MAX_ZONE_SIZE && (zone_size << 1) < (limsize/1024))
  321. zone_size <<= 1;
  322. zone_limit = zone_size / 4;
  323. if (zone_limit > ZALLOC_ZONE_LIMIT)
  324. zone_limit = ZALLOC_ZONE_LIMIT;
  325. zone_page_cnt = zone_size / RT_MM_PAGE_SIZE;
  326. RT_DEBUG_LOG(RT_DEBUG_SLAB,
  327. ("zone size 0x%x, zone page count 0x%x\n", zone_size, zone_page_cnt));
  328. /* allocate memusage array */
  329. limsize = npages * sizeof(struct memusage);
  330. limsize = RT_ALIGN(limsize, RT_MM_PAGE_SIZE);
  331. memusage = rt_page_alloc(limsize/RT_MM_PAGE_SIZE);
  332. RT_DEBUG_LOG(RT_DEBUG_SLAB,
  333. ("memusage 0x%x, size 0x%x\n", (rt_uint32_t)memusage, limsize));
  334. }
  335. /*
  336. * Calculate the zone index for the allocation request size and set the
  337. * allocation request size to that particular zone's chunk size.
  338. */
  339. rt_inline int zoneindex(rt_uint32_t *bytes)
  340. {
  341. rt_uint32_t n = (rt_uint32_t)*bytes; /* unsigned for shift opt */
  342. if (n < 128)
  343. {
  344. *bytes = n = (n + 7) & ~7;
  345. return(n / 8 - 1); /* 8 byte chunks, 16 zones */
  346. }
  347. if (n < 256)
  348. {
  349. *bytes = n = (n + 15) & ~15;
  350. return(n / 16 + 7);
  351. }
  352. if (n < 8192)
  353. {
  354. if (n < 512)
  355. {
  356. *bytes = n = (n + 31) & ~31;
  357. return(n / 32 + 15);
  358. }
  359. if (n < 1024)
  360. {
  361. *bytes = n = (n + 63) & ~63;
  362. return(n / 64 + 23);
  363. }
  364. if (n < 2048)
  365. {
  366. *bytes = n = (n + 127) & ~127;
  367. return(n / 128 + 31);
  368. }
  369. if (n < 4096)
  370. {
  371. *bytes = n = (n + 255) & ~255;
  372. return(n / 256 + 39);
  373. }
  374. *bytes = n = (n + 511) & ~511;
  375. return(n / 512 + 47);
  376. }
  377. if (n < 16384)
  378. {
  379. *bytes = n = (n + 1023) & ~1023;
  380. return(n / 1024 + 55);
  381. }
  382. rt_kprintf("Unexpected byte count %d", n);
  383. return 0;
  384. }
  385. /**
  386. * @addtogroup MM
  387. */
  388. /*@{*/
  389. /**
  390. * This function will allocate a block from system heap memory.
  391. * - If the nbytes is less than zero,
  392. * or
  393. * - If there is no nbytes sized memory valid in system,
  394. * the RT_NULL is returned.
  395. *
  396. * @param size the size of memory to be allocated
  397. *
  398. * @return the allocated memory
  399. */
  400. void *rt_malloc(rt_size_t size)
  401. {
  402. slab_zone *z;
  403. rt_int32_t zi;
  404. slab_chunk *chunk;
  405. struct memusage *kup;
  406. /* zero size, return RT_NULL */
  407. if (size == 0)
  408. return RT_NULL;
  409. #ifdef RT_USING_MODULE
  410. if (rt_module_self() != RT_NULL)
  411. return rt_module_malloc(size);
  412. #endif
  413. /*
  414. * Handle large allocations directly. There should not be very many of
  415. * these so performance is not a big issue.
  416. */
  417. if (size >= zone_limit)
  418. {
  419. size = RT_ALIGN(size, RT_MM_PAGE_SIZE);
  420. chunk = rt_page_alloc(size >> RT_MM_PAGE_BITS);
  421. if (chunk == RT_NULL)
  422. return RT_NULL;
  423. /* set kup */
  424. kup = btokup(chunk);
  425. kup->type = PAGE_TYPE_LARGE;
  426. kup->size = size >> RT_MM_PAGE_BITS;
  427. RT_DEBUG_LOG(RT_DEBUG_SLAB, ("malloc a large memory 0x%x, page cnt %d, kup %d\n",
  428. size,
  429. size >> RT_MM_PAGE_BITS,
  430. ((rt_uint32_t)chunk - heap_start) >> RT_MM_PAGE_BITS));
  431. /* lock heap */
  432. rt_sem_take(&heap_sem, RT_WAITING_FOREVER);
  433. #ifdef RT_MEM_STATS
  434. used_mem += size;
  435. if (used_mem > max_mem)
  436. max_mem = used_mem;
  437. #endif
  438. goto done;
  439. }
  440. /* lock heap */
  441. rt_sem_take(&heap_sem, RT_WAITING_FOREVER);
  442. /*
  443. * Attempt to allocate out of an existing zone. First try the free list,
  444. * then allocate out of unallocated space. If we find a good zone move
  445. * it to the head of the list so later allocations find it quickly
  446. * (we might have thousands of zones in the list).
  447. *
  448. * Note: zoneindex() will panic of size is too large.
  449. */
  450. zi = zoneindex(&size);
  451. RT_ASSERT(zi < NZONES);
  452. RT_DEBUG_LOG(RT_DEBUG_SLAB, ("try to malloc 0x%x on zone: %d\n", size, zi));
  453. if ((z = zone_array[zi]) != RT_NULL)
  454. {
  455. RT_ASSERT(z->z_nfree > 0);
  456. /* Remove us from the zone_array[] when we become empty */
  457. if (--z->z_nfree == 0)
  458. {
  459. zone_array[zi] = z->z_next;
  460. z->z_next = RT_NULL;
  461. }
  462. /*
  463. * No chunks are available but nfree said we had some memory, so
  464. * it must be available in the never-before-used-memory area
  465. * governed by uindex. The consequences are very serious if our zone
  466. * got corrupted so we use an explicit rt_kprintf rather then a KASSERT.
  467. */
  468. if (z->z_uindex + 1 != z->z_nmax)
  469. {
  470. z->z_uindex = z->z_uindex + 1;
  471. chunk = (slab_chunk *)(z->z_baseptr + z->z_uindex * size);
  472. }
  473. else
  474. {
  475. /* find on free chunk list */
  476. chunk = z->z_freechunk;
  477. /* remove this chunk from list */
  478. z->z_freechunk = z->z_freechunk->c_next;
  479. }
  480. #ifdef RT_MEM_STATS
  481. used_mem += z->z_chunksize;
  482. if (used_mem > max_mem)
  483. max_mem = used_mem;
  484. #endif
  485. goto done;
  486. }
  487. /*
  488. * If all zones are exhausted we need to allocate a new zone for this
  489. * index.
  490. *
  491. * At least one subsystem, the tty code (see CROUND) expects power-of-2
  492. * allocations to be power-of-2 aligned. We maintain compatibility by
  493. * adjusting the base offset below.
  494. */
  495. {
  496. rt_int32_t off;
  497. if ((z = zone_free) != RT_NULL)
  498. {
  499. /* remove zone from free zone list */
  500. zone_free = z->z_next;
  501. -- zone_free_cnt;
  502. }
  503. else
  504. {
  505. /* unlock heap, since page allocator will think about lock */
  506. rt_sem_release(&heap_sem);
  507. /* allocate a zone from page */
  508. z = rt_page_alloc(zone_size / RT_MM_PAGE_SIZE);
  509. if (z == RT_NULL)
  510. goto fail;
  511. /* lock heap */
  512. rt_sem_take(&heap_sem, RT_WAITING_FOREVER);
  513. RT_DEBUG_LOG(RT_DEBUG_SLAB, ("alloc a new zone: 0x%x\n", (rt_uint32_t)z));
  514. /* set message usage */
  515. for (off = 0, kup = btokup(z); off < zone_page_cnt; off ++)
  516. {
  517. kup->type = PAGE_TYPE_SMALL;
  518. kup->size = off;
  519. kup ++;
  520. }
  521. }
  522. /* clear to zero */
  523. rt_memset(z, 0, sizeof(slab_zone));
  524. /* offset of slab zone struct in zone */
  525. off = sizeof(slab_zone);
  526. /*
  527. * Guarentee power-of-2 alignment for power-of-2-sized chunks.
  528. * Otherwise just 8-byte align the data.
  529. */
  530. if ((size | (size - 1)) + 1 == (size << 1))
  531. off = (off + size - 1) & ~(size - 1);
  532. else
  533. off = (off + MIN_CHUNK_MASK) & ~MIN_CHUNK_MASK;
  534. z->z_magic = ZALLOC_SLAB_MAGIC;
  535. z->z_zoneindex = zi;
  536. z->z_nmax = (zone_size - off) / size;
  537. z->z_nfree = z->z_nmax - 1;
  538. z->z_baseptr = (rt_uint8_t *)z + off;
  539. z->z_uindex = 0;
  540. z->z_chunksize = size;
  541. chunk = (slab_chunk *)(z->z_baseptr + z->z_uindex * size);
  542. /* link to zone array */
  543. z->z_next = zone_array[zi];
  544. zone_array[zi] = z;
  545. #ifdef RT_MEM_STATS
  546. used_mem += z->z_chunksize;
  547. if (used_mem > max_mem)
  548. max_mem = used_mem;
  549. #endif
  550. }
  551. done:
  552. rt_sem_release(&heap_sem);
  553. RT_OBJECT_HOOK_CALL(rt_malloc_hook, ((char *)chunk, size));
  554. return chunk;
  555. fail:
  556. rt_sem_release(&heap_sem);
  557. return RT_NULL;
  558. }
  559. RTM_EXPORT(rt_malloc);
  560. /**
  561. * This function will change the size of previously allocated memory block.
  562. *
  563. * @param ptr the previously allocated memory block
  564. * @param size the new size of memory block
  565. *
  566. * @return the allocated memory
  567. */
  568. void *rt_realloc(void *ptr, rt_size_t size)
  569. {
  570. void *nptr;
  571. slab_zone *z;
  572. struct memusage *kup;
  573. if (ptr == RT_NULL)
  574. return rt_malloc(size);
  575. if (size == 0)
  576. {
  577. rt_free(ptr);
  578. return RT_NULL;
  579. }
  580. #ifdef RT_USING_MODULE
  581. if (rt_module_self() != RT_NULL)
  582. return rt_module_realloc(ptr, size);
  583. #endif
  584. /*
  585. * Get the original allocation's zone. If the new request winds up
  586. * using the same chunk size we do not have to do anything.
  587. */
  588. kup = btokup((rt_uint32_t)ptr & ~RT_MM_PAGE_MASK);
  589. if (kup->type == PAGE_TYPE_LARGE)
  590. {
  591. rt_size_t osize;
  592. osize = kup->size << RT_MM_PAGE_BITS;
  593. if ((nptr = rt_malloc(size)) == RT_NULL)
  594. return RT_NULL;
  595. rt_memcpy(nptr, ptr, size > osize ? osize : size);
  596. rt_free(ptr);
  597. return nptr;
  598. }
  599. else if (kup->type == PAGE_TYPE_SMALL)
  600. {
  601. z = (slab_zone *)(((rt_uint32_t)ptr & ~RT_MM_PAGE_MASK) - kup->size * RT_MM_PAGE_SIZE);
  602. RT_ASSERT(z->z_magic == ZALLOC_SLAB_MAGIC);
  603. zoneindex(&size);
  604. if (z->z_chunksize == size)
  605. return(ptr); /* same chunk */
  606. /*
  607. * Allocate memory for the new request size. Note that zoneindex has
  608. * already adjusted the request size to the appropriate chunk size, which
  609. * should optimize our bcopy(). Then copy and return the new pointer.
  610. */
  611. if ((nptr = rt_malloc(size)) == RT_NULL)
  612. return RT_NULL;
  613. rt_memcpy(nptr, ptr, size > z->z_chunksize ? z->z_chunksize : size);
  614. rt_free(ptr);
  615. return nptr;
  616. }
  617. return RT_NULL;
  618. }
  619. RTM_EXPORT(rt_realloc);
  620. /**
  621. * This function will contiguously allocate enough space for count objects
  622. * that are size bytes of memory each and returns a pointer to the allocated
  623. * memory.
  624. *
  625. * The allocated memory is filled with bytes of value zero.
  626. *
  627. * @param count number of objects to allocate
  628. * @param size size of the objects to allocate
  629. *
  630. * @return pointer to allocated memory / NULL pointer if there is an error
  631. */
  632. void *rt_calloc(rt_size_t count, rt_size_t size)
  633. {
  634. void *p;
  635. /* allocate 'count' objects of size 'size' */
  636. p = rt_malloc(count * size);
  637. /* zero the memory */
  638. if (p)
  639. rt_memset(p, 0, count * size);
  640. return p;
  641. }
  642. RTM_EXPORT(rt_calloc);
  643. /**
  644. * This function will release the previously allocated memory block by rt_malloc.
  645. * The released memory block is taken back to system heap.
  646. *
  647. * @param ptr the address of memory which will be released
  648. */
  649. void rt_free(void *ptr)
  650. {
  651. slab_zone *z;
  652. slab_chunk *chunk;
  653. struct memusage *kup;
  654. /* free a RT_NULL pointer */
  655. if (ptr == RT_NULL)
  656. return ;
  657. RT_OBJECT_HOOK_CALL(rt_free_hook, (ptr));
  658. #ifdef RT_USING_MODULE
  659. if(rt_module_self() != RT_NULL)
  660. {
  661. rt_module_free(rt_module_self(), ptr);
  662. return;
  663. }
  664. #endif
  665. /* get memory usage */
  666. #if RT_DEBUG_SLAB
  667. {
  668. rt_uint32_t addr = ((rt_uint32_t)ptr & ~RT_MM_PAGE_MASK);
  669. RT_DEBUG_LOG(RT_DEBUG_SLAB,
  670. ("free a memory 0x%x and align to 0x%x, kup index %d\n",
  671. (rt_uint32_t)ptr,
  672. (rt_uint32_t)addr,
  673. ((rt_uint32_t)(addr) - heap_start) >> RT_MM_PAGE_BITS));
  674. }
  675. #endif
  676. kup = btokup((rt_uint32_t)ptr & ~RT_MM_PAGE_MASK);
  677. /* release large allocation */
  678. if (kup->type == PAGE_TYPE_LARGE)
  679. {
  680. rt_uint32_t size;
  681. /* lock heap */
  682. rt_sem_take(&heap_sem, RT_WAITING_FOREVER);
  683. /* clear page counter */
  684. size = kup->size;
  685. kup->size = 0;
  686. #ifdef RT_MEM_STATS
  687. used_mem -= size * RT_MM_PAGE_SIZE;
  688. #endif
  689. rt_sem_release(&heap_sem);
  690. RT_DEBUG_LOG(RT_DEBUG_SLAB,
  691. ("free large memory block 0x%x, page count %d\n", (rt_uint32_t)ptr, size));
  692. /* free this page */
  693. rt_page_free(ptr, size);
  694. return;
  695. }
  696. /* lock heap */
  697. rt_sem_take(&heap_sem, RT_WAITING_FOREVER);
  698. /* zone case. get out zone. */
  699. z = (slab_zone *)(((rt_uint32_t)ptr & ~RT_MM_PAGE_MASK) - kup->size * RT_MM_PAGE_SIZE);
  700. RT_ASSERT(z->z_magic == ZALLOC_SLAB_MAGIC);
  701. chunk = (slab_chunk *)ptr;
  702. chunk->c_next = z->z_freechunk;
  703. z->z_freechunk = chunk;
  704. #ifdef RT_MEM_STATS
  705. used_mem -= z->z_chunksize;
  706. #endif
  707. /*
  708. * Bump the number of free chunks. If it becomes non-zero the zone
  709. * must be added back onto the appropriate list.
  710. */
  711. if (z->z_nfree++ == 0)
  712. {
  713. z->z_next = zone_array[z->z_zoneindex];
  714. zone_array[z->z_zoneindex] = z;
  715. }
  716. /*
  717. * If the zone becomes totally free, and there are other zones we
  718. * can allocate from, move this zone to the FreeZones list. Since
  719. * this code can be called from an IPI callback, do *NOT* try to mess
  720. * with kernel_map here. Hysteresis will be performed at malloc() time.
  721. */
  722. if (z->z_nfree == z->z_nmax && (z->z_next || zone_array[z->z_zoneindex] != z))
  723. {
  724. slab_zone **pz;
  725. RT_DEBUG_LOG(RT_DEBUG_SLAB, ("free zone 0x%x\n", (rt_uint32_t)z, z->z_zoneindex));
  726. /* remove zone from zone array list */
  727. for (pz = &zone_array[z->z_zoneindex]; z != *pz; pz = &(*pz)->z_next)
  728. ;
  729. *pz = z->z_next;
  730. /* reset zone */
  731. z->z_magic = -1;
  732. /* insert to free zone list */
  733. z->z_next = zone_free;
  734. zone_free = z;
  735. ++ zone_free_cnt;
  736. /* release zone to page allocator */
  737. if (zone_free_cnt > ZONE_RELEASE_THRESH)
  738. {
  739. register rt_base_t i;
  740. z = zone_free;
  741. zone_free = z->z_next;
  742. -- zone_free_cnt;
  743. /* set message usage */
  744. for (i = 0, kup = btokup(z); i < zone_page_cnt; i ++)
  745. {
  746. kup->type = PAGE_TYPE_FREE;
  747. kup->size = 0;
  748. kup ++;
  749. }
  750. /* unlock heap */
  751. rt_sem_release(&heap_sem);
  752. /* release pages */
  753. rt_page_free(z, zone_size / RT_MM_PAGE_SIZE);
  754. return;
  755. }
  756. }
  757. /* unlock heap */
  758. rt_sem_release(&heap_sem);
  759. }
  760. RTM_EXPORT(rt_free);
  761. #ifdef RT_MEM_STATS
  762. void rt_memory_info(rt_uint32_t *total, rt_uint32_t *used, rt_uint32_t *max_used)
  763. {
  764. if (total != RT_NULL)
  765. *total = heap_end - heap_start;
  766. if (used != RT_NULL)
  767. *used = used_mem;
  768. if (max_used != RT_NULL)
  769. *max_used = max_mem;
  770. }
  771. #ifdef RT_USING_FINSH
  772. #include <finsh.h>
  773. void list_mem(void)
  774. {
  775. rt_kprintf("total memory: %d\n", heap_end - heap_start);
  776. rt_kprintf("used memory : %d\n", used_mem);
  777. rt_kprintf("maximum allocated memory: %d\n", max_mem);
  778. }
  779. FINSH_FUNCTION_EXPORT(list_mem, list memory usage information)
  780. #endif
  781. #endif
  782. /*@}*/
  783. #endif