source: mainline/uspace/lib/c/generic/malloc.c@ 1be7bee

Last change on this file since 1be7bee was 25f6bddb, checked in by Jakub Jermar <jakub@…>, 7 years ago

Deallocate waitq's used by the loader

  • Property mode set to 100644
File size: 25.7 KB
RevLine 
[6db6fd1]1/*
2 * Copyright (c) 2009 Martin Decky
3 * Copyright (c) 2009 Petr Tuma
4 * All rights reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
8 * are met:
9 *
10 * - Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * - Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 * - The name of the author may not be used to endorse or promote products
16 * derived from this software without specific prior written permission.
17 *
18 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
23 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
24 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
27 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28 */
29
30/** @addtogroup libc
31 * @{
32 */
33/** @file
34 */
35
36#include <malloc.h>
[3e6a98c5]37#include <stdbool.h>
[582a0b8]38#include <stddef.h>
[6db6fd1]39#include <as.h>
40#include <align.h>
41#include <macros.h>
42#include <assert.h>
43#include <errno.h>
44#include <bitops.h>
45#include <mem.h>
[d161715]46#include <stdlib.h>
[6db6fd1]47#include <adt/gcdlcm.h>
[f787c8e]48
[47b7006]49#include "private/malloc.h"
[f787c8e]50#include "private/fibril.h"
[6db6fd1]51
[0b37882]52/** Magic used in heap headers. */
53#define HEAP_BLOCK_HEAD_MAGIC UINT32_C(0xBEEF0101)
[6db6fd1]54
[0b37882]55/** Magic used in heap footers. */
56#define HEAP_BLOCK_FOOT_MAGIC UINT32_C(0xBEEF0202)
[6db6fd1]57
[0b37882]58/** Magic used in heap descriptor. */
59#define HEAP_AREA_MAGIC UINT32_C(0xBEEFCAFE)
60
61/** Allocation alignment.
62 *
63 * This also covers the alignment of fields
64 * in the heap header and footer.
65 *
66 */
[6db6fd1]67#define BASE_ALIGN 16
68
[013a5d7]69/** Heap shrink granularity
70 *
[21799398]71 * Try not to pump and stress the heap too much
[013a5d7]72 * by shrinking and enlarging it too often.
[21799398]73 * A heap area won't shrink if the released
[013a5d7]74 * free block is smaller than this constant.
75 *
76 */
77#define SHRINK_GRANULARITY (64 * PAGE_SIZE)
78
[0b37882]79/** Overhead of each heap block. */
80#define STRUCT_OVERHEAD \
81 (sizeof(heap_block_head_t) + sizeof(heap_block_foot_t))
82
[207533f]83/** Overhead of each area. */
84#define AREA_OVERHEAD(size) \
85 (ALIGN_UP(size + sizeof(heap_area_t), BASE_ALIGN))
86
[0b37882]87/** Calculate real size of a heap block.
88 *
89 * Add header and footer size.
90 *
[6db6fd1]91 */
[0b37882]92#define GROSS_SIZE(size) ((size) + STRUCT_OVERHEAD)
[6db6fd1]93
[0b37882]94/** Calculate net size of a heap block.
95 *
96 * Subtract header and footer size.
[6db6fd1]97 *
98 */
[0b37882]99#define NET_SIZE(size) ((size) - STRUCT_OVERHEAD)
[6db6fd1]100
[0b37882]101/** Get first block in heap area.
102 *
[6db6fd1]103 */
[013a5d7]104#define AREA_FIRST_BLOCK_HEAD(area) \
[0b37882]105 (ALIGN_UP(((uintptr_t) (area)) + sizeof(heap_area_t), BASE_ALIGN))
[6db6fd1]106
[013a5d7]107/** Get last block in heap area.
108 *
109 */
110#define AREA_LAST_BLOCK_FOOT(area) \
111 (((uintptr_t) (area)->end) - sizeof(heap_block_foot_t))
112
[7aafdb86]113#define AREA_LAST_BLOCK_HEAD(area) \
[da287d1]114 ((uintptr_t) BLOCK_HEAD(((heap_block_foot_t *) AREA_LAST_BLOCK_FOOT(area))))
[7aafdb86]115
[013a5d7]116/** Get header in heap block.
117 *
118 */
119#define BLOCK_HEAD(foot) \
120 ((heap_block_head_t *) \
121 (((uintptr_t) (foot)) + sizeof(heap_block_foot_t) - (foot)->size))
122
[0b37882]123/** Get footer in heap block.
124 *
[6db6fd1]125 */
[0b37882]126#define BLOCK_FOOT(head) \
127 ((heap_block_foot_t *) \
[013a5d7]128 (((uintptr_t) (head)) + (head)->size - sizeof(heap_block_foot_t)))
[0b37882]129
130/** Heap area.
131 *
132 * The memory managed by the heap allocator is divided into
133 * multiple discontinuous heaps. Each heap is represented
134 * by a separate address space area which has this structure
135 * at its very beginning.
136 *
137 */
138typedef struct heap_area {
139 /** Start of the heap area (including this structure)
140 *
141 * Aligned on page boundary.
142 *
143 */
144 void *start;
[a35b458]145
[0b37882]146 /** End of the heap area (aligned on page boundary) */
147 void *end;
[a35b458]148
[013a5d7]149 /** Previous heap area */
150 struct heap_area *prev;
[a35b458]151
[0b37882]152 /** Next heap area */
153 struct heap_area *next;
[a35b458]154
[0b37882]155 /** A magic value */
156 uint32_t magic;
157} heap_area_t;
[6db6fd1]158
159/** Header of a heap block
160 *
161 */
162typedef struct {
163 /* Size of the block (including header and footer) */
164 size_t size;
[a35b458]165
[6db6fd1]166 /* Indication of a free block */
167 bool free;
[a35b458]168
[0b37882]169 /** Heap area this block belongs to */
170 heap_area_t *area;
[a35b458]171
[6db6fd1]172 /* A magic value to detect overwrite of heap header */
173 uint32_t magic;
174} heap_block_head_t;
175
176/** Footer of a heap block
177 *
178 */
179typedef struct {
180 /* Size of the block (including header and footer) */
181 size_t size;
[a35b458]182
[6db6fd1]183 /* A magic value to detect overwrite of heap footer */
184 uint32_t magic;
185} heap_block_foot_t;
186
[0b37882]187/** First heap area */
188static heap_area_t *first_heap_area = NULL;
[6db6fd1]189
[0b37882]190/** Last heap area */
191static heap_area_t *last_heap_area = NULL;
[6db6fd1]192
[0b37882]193/** Next heap block to examine (next fit algorithm) */
[207533f]194static heap_block_head_t *next_fit = NULL;
[6db6fd1]195
[0b37882]196/** Futex for thread-safe heap manipulation */
[45c8eea]197static fibril_rmutex_t malloc_mutex;
[6db6fd1]198
[e8d3c6f5]199#define malloc_assert(expr) safe_assert(expr)
[af5dfa5b]200
201/** Serializes access to the heap from multiple threads. */
202static inline void heap_lock(void)
203{
[9bde0d5]204 fibril_rmutex_lock(&malloc_mutex);
[af5dfa5b]205}
206
207/** Serializes access to the heap from multiple threads. */
208static inline void heap_unlock(void)
209{
[9bde0d5]210 fibril_rmutex_unlock(&malloc_mutex);
[af5dfa5b]211}
212
[6db6fd1]213/** Initialize a heap block
214 *
[0b37882]215 * Fill in the structures related to a heap block.
[3292623]216 * Should be called only inside the critical section.
[6db6fd1]217 *
218 * @param addr Address of the block.
219 * @param size Size of the block including the header and the footer.
220 * @param free Indication of a free block.
[0b37882]221 * @param area Heap area the block belongs to.
[6db6fd1]222 *
223 */
[0b37882]224static void block_init(void *addr, size_t size, bool free, heap_area_t *area)
[6db6fd1]225{
226 /* Calculate the position of the header and the footer */
227 heap_block_head_t *head = (heap_block_head_t *) addr;
[a35b458]228
[6db6fd1]229 head->size = size;
230 head->free = free;
[0b37882]231 head->area = area;
[6db6fd1]232 head->magic = HEAP_BLOCK_HEAD_MAGIC;
[a35b458]233
[0b37882]234 heap_block_foot_t *foot = BLOCK_FOOT(head);
[a35b458]235
[6db6fd1]236 foot->size = size;
237 foot->magic = HEAP_BLOCK_FOOT_MAGIC;
238}
239
240/** Check a heap block
241 *
242 * Verifies that the structures related to a heap block still contain
243 * the magic constants. This helps detect heap corruption early on.
[3292623]244 * Should be called only inside the critical section.
[6db6fd1]245 *
246 * @param addr Address of the block.
247 *
248 */
249static void block_check(void *addr)
250{
251 heap_block_head_t *head = (heap_block_head_t *) addr;
[a35b458]252
[13f2461]253 malloc_assert(head->magic == HEAP_BLOCK_HEAD_MAGIC);
[a35b458]254
[0b37882]255 heap_block_foot_t *foot = BLOCK_FOOT(head);
[a35b458]256
[13f2461]257 malloc_assert(foot->magic == HEAP_BLOCK_FOOT_MAGIC);
258 malloc_assert(head->size == foot->size);
[6db6fd1]259}
260
[0b37882]261/** Check a heap area structure
[013a5d7]262 *
263 * Should be called only inside the critical section.
[3292623]264 *
[0b37882]265 * @param addr Address of the heap area.
[3292623]266 *
[0b37882]267 */
268static void area_check(void *addr)
269{
270 heap_area_t *area = (heap_area_t *) addr;
[a35b458]271
[13f2461]272 malloc_assert(area->magic == HEAP_AREA_MAGIC);
273 malloc_assert(addr == area->start);
274 malloc_assert(area->start < area->end);
275 malloc_assert(((uintptr_t) area->start % PAGE_SIZE) == 0);
276 malloc_assert(((uintptr_t) area->end % PAGE_SIZE) == 0);
[0b37882]277}
278
279/** Create new heap area
280 *
[013a5d7]281 * Should be called only inside the critical section.
282 *
283 * @param size Size of the area.
[3292623]284 *
285 */
[0b37882]286static bool area_create(size_t size)
[6db6fd1]287{
[fbcdeb8]288 /* Align the heap area size on page boundary */
[0b37882]289 size_t asize = ALIGN_UP(size, PAGE_SIZE);
[faba839]290 void *astart = as_area_create(AS_AREA_ANY, asize,
[6aeca0d]291 AS_AREA_WRITE | AS_AREA_READ | AS_AREA_CACHEABLE, AS_AREA_UNPAGED);
[faba839]292 if (astart == AS_MAP_FAILED)
[e70edd1]293 return false;
[a35b458]294
[0b37882]295 heap_area_t *area = (heap_area_t *) astart;
[a35b458]296
[0b37882]297 area->start = astart;
[013a5d7]298 area->end = (void *) ((uintptr_t) astart + asize);
299 area->prev = NULL;
[0b37882]300 area->next = NULL;
301 area->magic = HEAP_AREA_MAGIC;
[a35b458]302
[013a5d7]303 void *block = (void *) AREA_FIRST_BLOCK_HEAD(area);
[0b37882]304 size_t bsize = (size_t) (area->end - block);
[a35b458]305
[0b37882]306 block_init(block, bsize, true, area);
[a35b458]307
[0b37882]308 if (last_heap_area == NULL) {
309 first_heap_area = area;
310 last_heap_area = area;
311 } else {
[013a5d7]312 area->prev = last_heap_area;
[0b37882]313 last_heap_area->next = area;
314 last_heap_area = area;
315 }
[a35b458]316
[0b37882]317 return true;
318}
319
320/** Try to enlarge a heap area
[013a5d7]321 *
322 * Should be called only inside the critical section.
[0b37882]323 *
324 * @param area Heap area to grow.
[013a5d7]325 * @param size Gross size to grow (bytes).
326 *
327 * @return True if successful.
[0b37882]328 *
329 */
330static bool area_grow(heap_area_t *area, size_t size)
331{
332 if (size == 0)
333 return true;
[a35b458]334
[0b37882]335 area_check(area);
[a35b458]336
[0b37882]337 /* New heap area size */
[013a5d7]338 size_t gross_size = (size_t) (area->end - area->start) + size;
339 size_t asize = ALIGN_UP(gross_size, PAGE_SIZE);
340 void *end = (void *) ((uintptr_t) area->start + asize);
[a35b458]341
[0b37882]342 /* Check for overflow */
343 if (end < area->start)
344 return false;
[a35b458]345
[0b37882]346 /* Resize the address space area */
[b7fd2a0]347 errno_t ret = as_area_resize(area->start, asize, 0);
[0b37882]348 if (ret != EOK)
[6db6fd1]349 return false;
[a35b458]350
[da287d1]351 heap_block_head_t *last_head =
352 (heap_block_head_t *) AREA_LAST_BLOCK_HEAD(area);
[a35b458]353
[7aafdb86]354 if (last_head->free) {
355 /* Add the new space to the last block. */
356 size_t net_size = (size_t) (end - area->end) + last_head->size;
357 malloc_assert(net_size > 0);
358 block_init(last_head, net_size, true, area);
359 } else {
360 /* Add new free block */
361 size_t net_size = (size_t) (end - area->end);
362 if (net_size > 0)
363 block_init(area->end, net_size, true, area);
364 }
[a35b458]365
[0b37882]366 /* Update heap area parameters */
367 area->end = end;
[a35b458]368
[0b37882]369 return true;
370}
371
[013a5d7]372/** Try to shrink heap
[3292623]373 *
[013a5d7]374 * Should be called only inside the critical section.
[0b37882]375 * In all cases the next pointer is reset.
[3292623]376 *
[013a5d7]377 * @param area Last modified heap area.
378 *
[3292623]379 */
[013a5d7]380static void heap_shrink(heap_area_t *area)
[6db6fd1]381{
[013a5d7]382 area_check(area);
[a35b458]383
[013a5d7]384 heap_block_foot_t *last_foot =
385 (heap_block_foot_t *) AREA_LAST_BLOCK_FOOT(area);
386 heap_block_head_t *last_head = BLOCK_HEAD(last_foot);
[a35b458]387
[013a5d7]388 block_check((void *) last_head);
[13f2461]389 malloc_assert(last_head->area == area);
[a35b458]390
[013a5d7]391 if (last_head->free) {
392 /*
393 * The last block of the heap area is
394 * unused. The area might be potentially
395 * shrunk.
396 */
[a35b458]397
[013a5d7]398 heap_block_head_t *first_head =
399 (heap_block_head_t *) AREA_FIRST_BLOCK_HEAD(area);
[a35b458]400
[013a5d7]401 block_check((void *) first_head);
[13f2461]402 malloc_assert(first_head->area == area);
[a35b458]403
[e6eee2b]404 size_t shrink_size = ALIGN_DOWN(last_head->size, PAGE_SIZE);
[a35b458]405
[013a5d7]406 if (first_head == last_head) {
407 /*
408 * The entire heap area consists of a single
409 * free heap block. This means we can get rid
410 * of it entirely.
411 */
[a35b458]412
[013a5d7]413 heap_area_t *prev = area->prev;
414 heap_area_t *next = area->next;
[a35b458]415
[013a5d7]416 if (prev != NULL) {
417 area_check(prev);
418 prev->next = next;
419 } else
420 first_heap_area = next;
[a35b458]421
[013a5d7]422 if (next != NULL) {
423 area_check(next);
424 next->prev = prev;
425 } else
426 last_heap_area = prev;
[a35b458]427
[013a5d7]428 as_area_destroy(area->start);
[e6eee2b]429 } else if (shrink_size >= SHRINK_GRANULARITY) {
[013a5d7]430 /*
431 * Make sure that we always shrink the area
432 * by a multiple of page size and update
433 * the block layout accordingly.
434 */
[a35b458]435
[013a5d7]436 size_t asize = (size_t) (area->end - area->start) - shrink_size;
437 void *end = (void *) ((uintptr_t) area->start + asize);
[a35b458]438
[013a5d7]439 /* Resize the address space area */
[b7fd2a0]440 errno_t ret = as_area_resize(area->start, asize, 0);
[013a5d7]441 if (ret != EOK)
442 abort();
[a35b458]443
[013a5d7]444 /* Update heap area parameters */
445 area->end = end;
[207533f]446 size_t excess = ((size_t) area->end) - ((size_t) last_head);
[a35b458]447
[013a5d7]448 if (excess > 0) {
449 if (excess >= STRUCT_OVERHEAD) {
450 /*
451 * The previous block cannot be free and there
452 * is enough free space left in the area to
453 * create a new free block.
454 */
[207533f]455 block_init((void *) last_head, excess, true, area);
[013a5d7]456 } else {
457 /*
458 * The excess is small. Therefore just enlarge
459 * the previous block.
460 */
461 heap_block_foot_t *prev_foot = (heap_block_foot_t *)
462 (((uintptr_t) last_head) - sizeof(heap_block_foot_t));
463 heap_block_head_t *prev_head = BLOCK_HEAD(prev_foot);
[a35b458]464
[013a5d7]465 block_check((void *) prev_head);
[a35b458]466
[013a5d7]467 block_init(prev_head, prev_head->size + excess,
468 prev_head->free, area);
469 }
470 }
471 }
472 }
[a35b458]473
[207533f]474 next_fit = NULL;
[6db6fd1]475}
476
477/** Initialize the heap allocator
478 *
[47b7006]479 * Create initial heap memory area. This routine is
480 * only called from libc initialization, thus we do not
481 * take any locks.
[6db6fd1]482 *
483 */
[47b7006]484void __malloc_init(void)
[6db6fd1]485{
[45c8eea]486 if (fibril_rmutex_initialize(&malloc_mutex) != EOK)
487 abort();
488
[0b37882]489 if (!area_create(PAGE_SIZE))
[47b7006]490 abort();
[6db6fd1]491}
492
[25f6bddb]493void __malloc_fini(void)
494{
495 fibril_rmutex_destroy(&malloc_mutex);
496}
497
[3292623]498/** Split heap block and mark it as used.
499 *
500 * Should be called only inside the critical section.
501 *
502 * @param cur Heap block to split.
503 * @param size Number of bytes to split and mark from the beginning
504 * of the block.
505 *
506 */
[6db6fd1]507static void split_mark(heap_block_head_t *cur, const size_t size)
508{
[13f2461]509 malloc_assert(cur->size >= size);
[a35b458]510
[6db6fd1]511 /* See if we should split the block. */
512 size_t split_limit = GROSS_SIZE(size);
[a35b458]513
[6db6fd1]514 if (cur->size > split_limit) {
515 /* Block big enough -> split. */
516 void *next = ((void *) cur) + size;
[0b37882]517 block_init(next, cur->size - size, true, cur->area);
518 block_init(cur, size, false, cur->area);
[6db6fd1]519 } else {
520 /* Block too small -> use as is. */
521 cur->free = false;
522 }
523}
524
[0b37882]525/** Allocate memory from heap area starting from given block
[3292623]526 *
527 * Should be called only inside the critical section.
[0b37882]528 * As a side effect this function also sets the current
529 * pointer on successful allocation.
[6db6fd1]530 *
[0b37882]531 * @param area Heap area where to allocate from.
532 * @param first_block Starting heap block.
533 * @param final_block Heap block where to finish the search
534 * (may be NULL).
535 * @param real_size Gross number of bytes to allocate.
536 * @param falign Physical alignment of the block.
[6db6fd1]537 *
[0b37882]538 * @return Address of the allocated block or NULL on not enough memory.
[6db6fd1]539 *
540 */
[0b37882]541static void *malloc_area(heap_area_t *area, heap_block_head_t *first_block,
542 heap_block_head_t *final_block, size_t real_size, size_t falign)
[6db6fd1]543{
[0b37882]544 area_check((void *) area);
[13f2461]545 malloc_assert((void *) first_block >= (void *) AREA_FIRST_BLOCK_HEAD(area));
546 malloc_assert((void *) first_block < area->end);
[a35b458]547
[013a5d7]548 for (heap_block_head_t *cur = first_block; (void *) cur < area->end;
[0b37882]549 cur = (heap_block_head_t *) (((void *) cur) + cur->size)) {
[6db6fd1]550 block_check(cur);
[a35b458]551
[0b37882]552 /* Finish searching on the final block */
553 if ((final_block != NULL) && (cur == final_block))
554 break;
[a35b458]555
[6db6fd1]556 /* Try to find a block that is free and large enough. */
557 if ((cur->free) && (cur->size >= real_size)) {
[0b37882]558 /*
559 * We have found a suitable block.
560 * Check for alignment properties.
561 */
562 void *addr = (void *)
563 ((uintptr_t) cur + sizeof(heap_block_head_t));
564 void *aligned = (void *)
565 ALIGN_UP((uintptr_t) addr, falign);
[a35b458]566
[6db6fd1]567 if (addr == aligned) {
568 /* Exact block start including alignment. */
569 split_mark(cur, real_size);
[a35b458]570
[207533f]571 next_fit = cur;
[0b37882]572 return addr;
[6db6fd1]573 } else {
[d851f597]574 /* Block start has to be aligned */
[6db6fd1]575 size_t excess = (size_t) (aligned - addr);
[a35b458]576
[6db6fd1]577 if (cur->size >= real_size + excess) {
[0b37882]578 /*
579 * The current block is large enough to fit
580 * data in (including alignment).
581 */
[013a5d7]582 if ((void *) cur > (void *) AREA_FIRST_BLOCK_HEAD(area)) {
[0b37882]583 /*
584 * There is a block before the current block.
585 * This previous block can be enlarged to
586 * compensate for the alignment excess.
587 */
588 heap_block_foot_t *prev_foot = (heap_block_foot_t *)
589 ((void *) cur - sizeof(heap_block_foot_t));
[a35b458]590
[0b37882]591 heap_block_head_t *prev_head = (heap_block_head_t *)
592 ((void *) cur - prev_foot->size);
[a35b458]593
[6db6fd1]594 block_check(prev_head);
[a35b458]595
[6db6fd1]596 size_t reduced_size = cur->size - excess;
[d851f597]597 heap_block_head_t *next_head = ((void *) cur) + excess;
[a35b458]598
[0b37882]599 if ((!prev_head->free) &&
600 (excess >= STRUCT_OVERHEAD)) {
601 /*
602 * The previous block is not free and there
603 * is enough free space left to fill in
604 * a new free block between the previous
605 * and current block.
606 */
607 block_init(cur, excess, true, area);
[d851f597]608 } else {
[0b37882]609 /*
610 * The previous block is free (thus there
611 * is no need to induce additional
612 * fragmentation to the heap) or the
613 * excess is small. Therefore just enlarge
614 * the previous block.
615 */
616 block_init(prev_head, prev_head->size + excess,
617 prev_head->free, area);
[d851f597]618 }
[a35b458]619
[0b37882]620 block_init(next_head, reduced_size, true, area);
[d851f597]621 split_mark(next_head, real_size);
[a35b458]622
[207533f]623 next_fit = next_head;
[0b37882]624 return aligned;
[6db6fd1]625 } else {
[0b37882]626 /*
627 * The current block is the first block
628 * in the heap area. We have to make sure
629 * that the alignment excess is large enough
630 * to fit a new free block just before the
631 * current block.
632 */
[6db6fd1]633 while (excess < STRUCT_OVERHEAD) {
634 aligned += falign;
635 excess += falign;
636 }
[a35b458]637
[d851f597]638 /* Check for current block size again */
[6db6fd1]639 if (cur->size >= real_size + excess) {
640 size_t reduced_size = cur->size - excess;
[0b37882]641 cur = (heap_block_head_t *)
[013a5d7]642 (AREA_FIRST_BLOCK_HEAD(area) + excess);
[a35b458]643
[013a5d7]644 block_init((void *) AREA_FIRST_BLOCK_HEAD(area),
645 excess, true, area);
[0b37882]646 block_init(cur, reduced_size, true, area);
[6db6fd1]647 split_mark(cur, real_size);
[a35b458]648
[207533f]649 next_fit = cur;
[0b37882]650 return aligned;
[6db6fd1]651 }
652 }
653 }
654 }
655 }
[0b37882]656 }
[a35b458]657
[0b37882]658 return NULL;
659}
660
[7aafdb86]661/** Try to enlarge any of the heap areas.
662 *
[da287d1]663 * If successful, allocate block of the given size in the area.
[7aafdb86]664 * Should be called only inside the critical section.
665 *
[da287d1]666 * @param size Gross size of item to allocate (bytes).
[7aafdb86]667 * @param align Memory address alignment.
668 *
[da287d1]669 * @return Allocated block.
670 * @return NULL on failure.
671 *
[7aafdb86]672 */
673static void *heap_grow_and_alloc(size_t size, size_t align)
674{
675 if (size == 0)
676 return NULL;
[a35b458]677
[7aafdb86]678 /* First try to enlarge some existing area */
679 for (heap_area_t *area = first_heap_area; area != NULL;
680 area = area->next) {
[a35b458]681
[7aafdb86]682 if (area_grow(area, size + align)) {
[da287d1]683 heap_block_head_t *first =
684 (heap_block_head_t *) AREA_LAST_BLOCK_HEAD(area);
[a35b458]685
[da287d1]686 void *addr =
687 malloc_area(area, first, NULL, size, align);
[7aafdb86]688 malloc_assert(addr != NULL);
689 return addr;
690 }
691 }
[a35b458]692
[7aafdb86]693 /* Eventually try to create a new area */
694 if (area_create(AREA_OVERHEAD(size + align))) {
[da287d1]695 heap_block_head_t *first =
696 (heap_block_head_t *) AREA_FIRST_BLOCK_HEAD(last_heap_area);
[a35b458]697
[da287d1]698 void *addr =
699 malloc_area(last_heap_area, first, NULL, size, align);
[7aafdb86]700 malloc_assert(addr != NULL);
701 return addr;
702 }
[a35b458]703
[7aafdb86]704 return NULL;
705}
706
[0b37882]707/** Allocate a memory block
708 *
709 * Should be called only inside the critical section.
710 *
711 * @param size The size of the block to allocate.
712 * @param align Memory address alignment.
713 *
714 * @return Address of the allocated block or NULL on not enough memory.
715 *
716 */
717static void *malloc_internal(const size_t size, const size_t align)
718{
[13f2461]719 malloc_assert(first_heap_area != NULL);
[a35b458]720
[0b37882]721 if (align == 0)
722 return NULL;
[a35b458]723
[0b37882]724 size_t falign = lcm(align, BASE_ALIGN);
[a35b458]725
[e7c3fa0]726 /* Check for integer overflow. */
727 if (falign < align)
728 return NULL;
[a35b458]729
[c828803]730 /*
731 * The size of the allocated block needs to be naturally
732 * aligned, because the footer structure also needs to reside
733 * on a naturally aligned address in order to avoid unaligned
734 * memory accesses.
735 */
[da287d1]736 size_t gross_size = GROSS_SIZE(ALIGN_UP(size, BASE_ALIGN));
[a35b458]737
[0b37882]738 /* Try the next fit approach */
[da287d1]739 heap_block_head_t *split = next_fit;
[a35b458]740
[0b37882]741 if (split != NULL) {
[7aafdb86]742 void *addr = malloc_area(split->area, split, NULL, gross_size,
[0b37882]743 falign);
[a35b458]744
[0b37882]745 if (addr != NULL)
746 return addr;
[6db6fd1]747 }
[a35b458]748
[0b37882]749 /* Search the entire heap */
[013a5d7]750 for (heap_area_t *area = first_heap_area; area != NULL;
751 area = area->next) {
[0b37882]752 heap_block_head_t *first = (heap_block_head_t *)
[013a5d7]753 AREA_FIRST_BLOCK_HEAD(area);
[a35b458]754
[7aafdb86]755 void *addr = malloc_area(area, first, split, gross_size,
[0b37882]756 falign);
[a35b458]757
[0b37882]758 if (addr != NULL)
759 return addr;
760 }
[a35b458]761
[7aafdb86]762 /* Finally, try to grow heap space and allocate in the new area. */
763 return heap_grow_and_alloc(gross_size, falign);
[6db6fd1]764}
765
[3292623]766/** Allocate memory by number of elements
767 *
768 * @param nmemb Number of members to allocate.
769 * @param size Size of one member in bytes.
770 *
771 * @return Allocated memory or NULL.
772 *
773 */
[15b8e495]774void *calloc(const size_t nmemb, const size_t size)
775{
[c828803]776 // FIXME: Check for overflow
[a35b458]777
[e6b73ad0]778 void *block = malloc(nmemb * size);
779 if (block == NULL)
780 return NULL;
[a35b458]781
[e6b73ad0]782 memset(block, 0, nmemb * size);
783 return block;
[15b8e495]784}
785
[3292623]786/** Allocate memory
787 *
788 * @param size Number of bytes to allocate.
789 *
790 * @return Allocated memory or NULL.
791 *
792 */
[6db6fd1]793void *malloc(const size_t size)
794{
[af5dfa5b]795 heap_lock();
[3292623]796 void *block = malloc_internal(size, BASE_ALIGN);
[af5dfa5b]797 heap_unlock();
[d54b303]798
[3292623]799 return block;
[6db6fd1]800}
801
[3292623]802/** Allocate memory with specified alignment
803 *
804 * @param align Alignment in byes.
805 * @param size Number of bytes to allocate.
806 *
807 * @return Allocated memory or NULL.
808 *
809 */
[6db6fd1]810void *memalign(const size_t align, const size_t size)
811{
812 if (align == 0)
813 return NULL;
[a35b458]814
[6db6fd1]815 size_t palign =
816 1 << (fnzb(max(sizeof(void *), align) - 1) + 1);
[9a3b469]817
[af5dfa5b]818 heap_lock();
[3292623]819 void *block = malloc_internal(size, palign);
[af5dfa5b]820 heap_unlock();
[9a3b469]821
[3292623]822 return block;
[6db6fd1]823}
824
[3292623]825/** Reallocate memory block
826 *
827 * @param addr Already allocated memory or NULL.
828 * @param size New size of the memory block.
829 *
830 * @return Reallocated memory or NULL.
831 *
832 */
[8ebe212]833void *realloc(void *const addr, const size_t size)
[6db6fd1]834{
[d8023313]835 if (size == 0) {
836 free(addr);
837 return NULL;
838 }
839
[6db6fd1]840 if (addr == NULL)
841 return malloc(size);
[a35b458]842
[af5dfa5b]843 heap_lock();
[a35b458]844
[6db6fd1]845 /* Calculate the position of the header. */
846 heap_block_head_t *head =
847 (heap_block_head_t *) (addr - sizeof(heap_block_head_t));
[a35b458]848
[6db6fd1]849 block_check(head);
[13f2461]850 malloc_assert(!head->free);
[a35b458]851
[0b37882]852 heap_area_t *area = head->area;
[a35b458]853
[0b37882]854 area_check(area);
[13f2461]855 malloc_assert((void *) head >= (void *) AREA_FIRST_BLOCK_HEAD(area));
856 malloc_assert((void *) head < area->end);
[a35b458]857
[6db6fd1]858 void *ptr = NULL;
[3292623]859 bool reloc = false;
[f450280]860 size_t real_size = GROSS_SIZE(ALIGN_UP(size, BASE_ALIGN));
[6db6fd1]861 size_t orig_size = head->size;
[a35b458]862
[6db6fd1]863 if (orig_size > real_size) {
864 /* Shrink */
865 if (orig_size - real_size >= STRUCT_OVERHEAD) {
[0b37882]866 /*
867 * Split the original block to a full block
868 * and a trailing free block.
869 */
870 block_init((void *) head, real_size, false, area);
[6db6fd1]871 block_init((void *) head + real_size,
[0b37882]872 orig_size - real_size, true, area);
[013a5d7]873 heap_shrink(area);
[6db6fd1]874 }
[a35b458]875
[6db6fd1]876 ptr = ((void *) head) + sizeof(heap_block_head_t);
877 } else {
878 heap_block_head_t *next_head =
879 (heap_block_head_t *) (((void *) head) + head->size);
[5b46ec8]880 bool have_next = ((void *) next_head < area->end);
881
882 if (((void *) head) + real_size > area->end) {
883 /*
884 * The current area is too small to hold the resized
885 * block. Make sure there are no used blocks standing
886 * in our way and try to grow the area using real_size
887 * as a safe upper bound.
888 */
889
890 bool have_next_next;
891
892 if (have_next) {
893 have_next_next = (((void *) next_head) +
894 next_head->size < area->end);
895 }
896 if (!have_next || (next_head->free && !have_next_next)) {
897 /*
898 * There is no next block in this area or
899 * it is a free block and there is no used
900 * block following it. There can't be any
901 * free block following it either as
902 * two free blocks would be merged.
903 */
904 (void) area_grow(area, real_size);
905 }
906 }
[a35b458]907
[5b46ec8]908 /*
909 * Look at the next block. If it is free and the size is
910 * sufficient then merge the two. Otherwise just allocate a new
911 * block, copy the original data into it and free the original
912 * block.
913 */
914
915 if (have_next && (head->size + next_head->size >= real_size) &&
916 next_head->free) {
[6db6fd1]917 block_check(next_head);
[5b46ec8]918 block_init(head, head->size + next_head->size, false,
919 area);
[ba0aa6f]920 split_mark(head, real_size);
[a35b458]921
[6db6fd1]922 ptr = ((void *) head) + sizeof(heap_block_head_t);
[207533f]923 next_fit = NULL;
[5b46ec8]924 } else {
[3292623]925 reloc = true;
[5b46ec8]926 }
[3292623]927 }
[a35b458]928
[af5dfa5b]929 heap_unlock();
[a35b458]930
[3292623]931 if (reloc) {
932 ptr = malloc(size);
933 if (ptr != NULL) {
934 memcpy(ptr, addr, NET_SIZE(orig_size));
935 free(addr);
[6db6fd1]936 }
937 }
[a35b458]938
[6db6fd1]939 return ptr;
940}
941
942/** Free a memory block
943 *
944 * @param addr The address of the block.
[3292623]945 *
[6db6fd1]946 */
[8ebe212]947void free(void *const addr)
[6db6fd1]948{
[3019612]949 if (addr == NULL)
950 return;
[a35b458]951
[af5dfa5b]952 heap_lock();
[a35b458]953
[6db6fd1]954 /* Calculate the position of the header. */
[8ebe212]955 heap_block_head_t *head =
956 (heap_block_head_t *) (addr - sizeof(heap_block_head_t));
[a35b458]957
[6db6fd1]958 block_check(head);
[13f2461]959 malloc_assert(!head->free);
[a35b458]960
[0b37882]961 heap_area_t *area = head->area;
[a35b458]962
[0b37882]963 area_check(area);
[13f2461]964 malloc_assert((void *) head >= (void *) AREA_FIRST_BLOCK_HEAD(area));
965 malloc_assert((void *) head < area->end);
[a35b458]966
[6db6fd1]967 /* Mark the block itself as free. */
968 head->free = true;
[a35b458]969
[6db6fd1]970 /* Look at the next block. If it is free, merge the two. */
[8ebe212]971 heap_block_head_t *next_head =
972 (heap_block_head_t *) (((void *) head) + head->size);
[a35b458]973
[0b37882]974 if ((void *) next_head < area->end) {
[6db6fd1]975 block_check(next_head);
976 if (next_head->free)
[0b37882]977 block_init(head, head->size + next_head->size, true, area);
[6db6fd1]978 }
[a35b458]979
[6db6fd1]980 /* Look at the previous block. If it is free, merge the two. */
[013a5d7]981 if ((void *) head > (void *) AREA_FIRST_BLOCK_HEAD(area)) {
[6db6fd1]982 heap_block_foot_t *prev_foot =
983 (heap_block_foot_t *) (((void *) head) - sizeof(heap_block_foot_t));
[a35b458]984
[6db6fd1]985 heap_block_head_t *prev_head =
986 (heap_block_head_t *) (((void *) head) - prev_foot->size);
[a35b458]987
[6db6fd1]988 block_check(prev_head);
[a35b458]989
[6db6fd1]990 if (prev_head->free)
[0b37882]991 block_init(prev_head, prev_head->size + head->size, true,
992 area);
[6db6fd1]993 }
[a35b458]994
[013a5d7]995 heap_shrink(area);
[a35b458]996
[af5dfa5b]997 heap_unlock();
[6db6fd1]998}
999
[1b3e854]1000void *heap_check(void)
1001{
[af5dfa5b]1002 heap_lock();
[a35b458]1003
[1b3e854]1004 if (first_heap_area == NULL) {
[af5dfa5b]1005 heap_unlock();
[1b3e854]1006 return (void *) -1;
1007 }
[a35b458]1008
[1b3e854]1009 /* Walk all heap areas */
1010 for (heap_area_t *area = first_heap_area; area != NULL;
1011 area = area->next) {
[a35b458]1012
[1b3e854]1013 /* Check heap area consistency */
1014 if ((area->magic != HEAP_AREA_MAGIC) ||
1015 ((void *) area != area->start) ||
1016 (area->start >= area->end) ||
1017 (((uintptr_t) area->start % PAGE_SIZE) != 0) ||
1018 (((uintptr_t) area->end % PAGE_SIZE) != 0)) {
[af5dfa5b]1019 heap_unlock();
[1b3e854]1020 return (void *) area;
1021 }
[a35b458]1022
[1b3e854]1023 /* Walk all heap blocks */
1024 for (heap_block_head_t *head = (heap_block_head_t *)
1025 AREA_FIRST_BLOCK_HEAD(area); (void *) head < area->end;
1026 head = (heap_block_head_t *) (((void *) head) + head->size)) {
[a35b458]1027
[1b3e854]1028 /* Check heap block consistency */
1029 if (head->magic != HEAP_BLOCK_HEAD_MAGIC) {
[af5dfa5b]1030 heap_unlock();
[1b3e854]1031 return (void *) head;
1032 }
[a35b458]1033
[1b3e854]1034 heap_block_foot_t *foot = BLOCK_FOOT(head);
[a35b458]1035
[1b3e854]1036 if ((foot->magic != HEAP_BLOCK_FOOT_MAGIC) ||
1037 (head->size != foot->size)) {
[af5dfa5b]1038 heap_unlock();
[1b3e854]1039 return (void *) foot;
1040 }
1041 }
1042 }
[a35b458]1043
[af5dfa5b]1044 heap_unlock();
[a35b458]1045
[1b3e854]1046 return NULL;
1047}
1048
[6db6fd1]1049/** @}
1050 */
Note: See TracBrowser for help on using the repository browser.