Put the custom allocator in its own lib, as to lessen the difficulty to switch between libc's allocator and a custom one (#7)
This commit is contained in:
parent
713f0f0302
commit
cb7f3c3fdf
85 changed files with 1121 additions and 877 deletions
362
allocator/src/get_arena.c
Normal file
362
allocator/src/get_arena.c
Normal file
|
|
@ -0,0 +1,362 @@
|
|||
/* ************************************************************************** */
|
||||
/* */
|
||||
/* ::: :::::::: */
|
||||
/* get_arena.c :+: :+: :+: */
|
||||
/* +:+ +:+ +:+ */
|
||||
/* By: maiboyer <maiboyer@student.42.fr> +#+ +:+ +#+ */
|
||||
/* +#+#+#+#+#+ +#+ */
|
||||
/* Created: 2024/05/07 09:47:50 by maiboyer #+# #+# */
|
||||
/* Updated: 2024/05/14 16:52:37 by maiboyer ### ########.fr */
|
||||
/* */
|
||||
/* ************************************************************************** */
|
||||
|
||||
#include "aq/alloc.h"
|
||||
#include "aq/alloc_internal.h"
|
||||
#include "aq/internal_vg_funcs.h"
|
||||
#include "me/fs/putendl_fd.h"
|
||||
#include "me/fs/putnbr_fd.h"
|
||||
#include "me/fs/putstr_fd.h"
|
||||
#include "me/mem/mem_compare.h"
|
||||
#include "me/mem/mem_copy.h"
|
||||
#include "me/mem/mem_set_zero.h"
|
||||
#include "me/num/usize.h"
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
/*
|
||||
|
||||
void *__libc_malloc(size_t size);
|
||||
void __libc_free(void *ptr);
|
||||
|
||||
t_mpage *alloc_page(t_usize size)
|
||||
{
|
||||
t_mpage *val;
|
||||
|
||||
size = usize_round_up_to(size + sizeof(t_mpage), PAGE_SIZE_DEFAULT);
|
||||
val = __libc_malloc(size);
|
||||
if (val == NULL)
|
||||
return (NULL);
|
||||
mem_set_zero(val, size);
|
||||
val->next = NULL;
|
||||
val->page_size = size - sizeof(*val);
|
||||
val->first = (t_mblock *)(((t_usize)val) + sizeof(t_mpage));
|
||||
val->first->page = val;
|
||||
val->first->next = NULL;
|
||||
val->first->used = false;
|
||||
val->first->size = size - sizeof(t_mpage) - sizeof(t_mblock) * 2;
|
||||
mem_copy(val->first->padding, BLOCK_PADDING, 7);
|
||||
vg_mem_no_access(val, size);
|
||||
return (val);
|
||||
}
|
||||
|
||||
t_mpage *get_head_arena(void)
|
||||
{
|
||||
static t_mpage *val = NULL;
|
||||
|
||||
if (val == NULL &&
|
||||
PAGE_SIZE_DEFAULT > sizeof(t_mpage) + sizeof(t_mblock) * 2 + 16)
|
||||
{
|
||||
vg_mempool_create(POOL_ADDR);
|
||||
val = alloc_page(PAGE_SIZE_DEFAULT - sizeof(t_mpage));
|
||||
}
|
||||
if (val == NULL)
|
||||
(me_putstr_fd("Failed to alloc first page", 2), exit(1));
|
||||
return (val);
|
||||
}
|
||||
|
||||
t_mblock *split_block(t_mblock *self, t_usize min_size)
|
||||
{
|
||||
t_usize remaining;
|
||||
t_mblock *old_next;
|
||||
|
||||
vg_mem_defined(self, sizeof(*self));
|
||||
min_size = usize_round_up_to(min_size, 16);
|
||||
if (self->size > (min_size + sizeof(t_mblock) + 16))
|
||||
{
|
||||
remaining = self->size - min_size - sizeof(t_mblock);
|
||||
printf("splitting %zu into %zu and %zu\n", self->size, min_size,
|
||||
remaining);
|
||||
self->size = min_size;
|
||||
old_next = self->next;
|
||||
self->next = (t_mblock *)(((t_usize)self) + sizeof(*self) + self->size);
|
||||
vg_mem_defined(self->next, sizeof(*self->next));
|
||||
self->next->page = self->page;
|
||||
self->next->next = old_next;
|
||||
self->next->used = false;
|
||||
self->next->size = remaining;
|
||||
mem_copy(self->next->padding, BLOCK_PADDING, 7);
|
||||
vg_mem_no_access(self->next, sizeof(*self->next));
|
||||
}
|
||||
vg_mem_no_access(self, sizeof(*self));
|
||||
return (self);
|
||||
}
|
||||
|
||||
t_mblock *get_block_for_size(t_usize size)
|
||||
{
|
||||
t_mblock *last;
|
||||
t_mblock *cur;
|
||||
t_mpage *head;
|
||||
|
||||
last = NULL;
|
||||
head = get_head_arena();
|
||||
vg_mem_defined(head, sizeof(*head));
|
||||
cur = head->first;
|
||||
vg_mem_no_access(head, sizeof(*head));
|
||||
while (cur)
|
||||
{
|
||||
vg_mem_defined(cur, sizeof(*cur));
|
||||
if (!cur->used && cur->size >= size)
|
||||
return (split_block(cur, size));
|
||||
last = cur;
|
||||
cur = cur->next;
|
||||
vg_mem_no_access(last, sizeof(*last));
|
||||
}
|
||||
if (last == NULL)
|
||||
return (NULL);
|
||||
vg_mem_defined(last, sizeof(*last));
|
||||
vg_mem_defined(last->page, sizeof(*last->page));
|
||||
last->page->next = alloc_page(size + sizeof(t_mblock));
|
||||
if (last->page->next == NULL)
|
||||
me_abort("Failed to alloc page!");
|
||||
vg_mem_defined(last->page->next, sizeof(*last->page->next));
|
||||
last->next = last->page->next->first;
|
||||
cur = last->page->next->first;
|
||||
vg_mem_no_access(last->page->next, sizeof(*last->page->next));
|
||||
vg_mem_no_access(last->page, sizeof(*last->page));
|
||||
vg_mem_no_access(last, sizeof(*last));
|
||||
return (split_block(cur, size));
|
||||
}
|
||||
|
||||
void print_pages_info(void)
|
||||
{
|
||||
t_mpage *page;
|
||||
t_mpage *old;
|
||||
t_i32 page_nb;
|
||||
|
||||
page = get_head_arena();
|
||||
page_nb = 0;
|
||||
while (page != NULL)
|
||||
{
|
||||
vg_mem_defined(page, sizeof(*page));
|
||||
me_putstr_fd("Page ", 2);
|
||||
me_putnbr_fd(page_nb++, 2);
|
||||
me_putstr_fd(" with size ", 2);
|
||||
me_putnbr_fd((t_i32)page->page_size, 2);
|
||||
me_putstr_fd("\n", 2);
|
||||
old = page;
|
||||
page = page->next;
|
||||
vg_mem_no_access(old, sizeof(*old));
|
||||
}
|
||||
}
|
||||
|
||||
bool merge_block(t_mblock *self, t_usize min_size)
|
||||
{
|
||||
t_mblock *old_next;
|
||||
|
||||
vg_mem_defined(self, sizeof(*self));
|
||||
vg_mem_defined(self->next, sizeof(*self->next));
|
||||
if (!(self->next && !self->next->used && self->next->page == self->page &&
|
||||
self->size + self->next->size + sizeof(t_mblock) >= min_size))
|
||||
return (vg_mem_no_access(self->next, sizeof(*self->next)),
|
||||
vg_mem_no_access(self, sizeof(*self)), false);
|
||||
old_next = self->next;
|
||||
self->size += sizeof(*self) + self->next->size;
|
||||
self->next = self->next->next;
|
||||
vg_mem_no_access(self, sizeof(*self));
|
||||
vg_mem_no_access(old_next, sizeof(*old_next));
|
||||
return (true);
|
||||
}
|
||||
|
||||
void uninit_allocator(void)
|
||||
{
|
||||
t_mpage *page;
|
||||
void *tmp;
|
||||
t_mblock *block;
|
||||
t_usize count_block;
|
||||
|
||||
page = get_head_arena();
|
||||
count_block = 0;
|
||||
vg_mem_defined(page, sizeof(*page));
|
||||
block = page->first;
|
||||
while (block)
|
||||
{
|
||||
vg_mem_defined(block, sizeof(*block));
|
||||
if (block->used)
|
||||
count_block += 1;
|
||||
block = block->next;
|
||||
}
|
||||
while (page)
|
||||
{
|
||||
vg_mem_defined(page, sizeof(*page));
|
||||
tmp = page->next;
|
||||
__libc_free(page);
|
||||
page = tmp;
|
||||
}
|
||||
if (count_block != 0)
|
||||
(me_putnbr_fd(count_block, 2),
|
||||
me_putendl_fd(" Blocks weren't freed when exiting !", 2));
|
||||
}*/
|
||||
|
||||
//
|
||||
// void free_ifn(void *ptr)
|
||||
// {
|
||||
// if (ptr != NULL)
|
||||
// __libc_free(ptr);
|
||||
// }
|
||||
//
|
||||
// t_mpage *alloc_page(t_usize size)
|
||||
// {
|
||||
// t_mpage *page;
|
||||
// void *data;
|
||||
// t_mblock *block;
|
||||
//
|
||||
// size = usize_round_up_to(size, PAGE_SIZE_DEFAULT);
|
||||
// page = __libc_malloc(sizeof(t_mpage));
|
||||
// block = __libc_malloc(sizeof(t_mblock));
|
||||
// data = __libc_malloc(size);
|
||||
// if (page == NULL || data == NULL || block == NULL ||
|
||||
// PAGE_SIZE_DEFAULT <= (t_usize)0)
|
||||
// return (free_ifn(page), free_ifn(data), free_ifn(block), NULL);
|
||||
// page->data = data;
|
||||
// page->next = NULL;
|
||||
// page->page_size = size;
|
||||
// page->first = block;
|
||||
// block->offset = 0;
|
||||
// block->page = page;
|
||||
// block->next = NULL;
|
||||
// block->used = false;
|
||||
// block->size = size;
|
||||
// mem_copy(block->padding, BLOCK_PADDING, 7);
|
||||
// return (page);
|
||||
// }
|
||||
//
|
||||
// t_mpage *get_head_arena(void)
|
||||
// {
|
||||
// static t_mpage *val = NULL;
|
||||
//
|
||||
// if (val == NULL)
|
||||
// {
|
||||
// val = alloc_page(PAGE_SIZE_DEFAULT);
|
||||
// if (val == NULL)
|
||||
// (me_putstr_fd("Failed to alloc first page", 2), exit(1));
|
||||
// }
|
||||
// return (val);
|
||||
// }
|
||||
//
|
||||
// t_mblock *split_block(t_mblock *self, t_usize min_size)
|
||||
// {
|
||||
// t_usize remaining;
|
||||
// t_mblock *new_next;
|
||||
//
|
||||
// min_size = usize_round_up_to(min_size, 16);
|
||||
// if (self->size > min_size)
|
||||
// {
|
||||
// remaining = self->size - min_size - 1;
|
||||
// new_next = __libc_malloc(sizeof(t_mblock));
|
||||
// if (new_next == NULL)
|
||||
// return (me_abort("Failed to alloc block"), NULL);
|
||||
// printf("splitting %zu into %zu and %zu\n", self->size, min_size,
|
||||
// remaining);
|
||||
// self->size = min_size;
|
||||
// new_next->page = self->page;
|
||||
// new_next->next = self->next;
|
||||
// new_next->offset = self->offset + self->size + 1;
|
||||
// new_next->used = false;
|
||||
// new_next->size = remaining;
|
||||
// mem_copy(new_next->padding, BLOCK_PADDING, 7);
|
||||
// self->next = new_next;
|
||||
// }
|
||||
// return (self);
|
||||
// }
|
||||
//
|
||||
// t_mblock *get_block_for_size(t_usize size)
|
||||
// {
|
||||
// t_mblock *last;
|
||||
// t_mblock *cur;
|
||||
//
|
||||
// last = NULL;
|
||||
// cur = get_head_arena()->first;
|
||||
// while (cur)
|
||||
// {
|
||||
// if (cur->page == NULL)
|
||||
// me_abort("block doesn't have a page ?????");
|
||||
// if (!cur->used && cur->size >= size)
|
||||
// return (split_block(cur, size));
|
||||
// last = cur;
|
||||
// cur = cur->next;
|
||||
// }
|
||||
// if (last == NULL)
|
||||
// return (NULL);
|
||||
// last->page->next = alloc_page(size);
|
||||
// if (last->page->next == NULL)
|
||||
// me_abort("Failed to alloc page!");
|
||||
// last->next = last->page->next->first;
|
||||
// return (split_block(last->page->next->first, size));
|
||||
// }
|
||||
//
|
||||
// t_mblock *get_block_from_ptr(void *ptr)
|
||||
// {
|
||||
// t_mpage *page;
|
||||
// t_mblock *block;
|
||||
//
|
||||
// page = get_page_from_ptr(ptr);
|
||||
// if (page == NULL)
|
||||
// return (NULL);
|
||||
// block = page->first;
|
||||
// while (block && block->page == page)
|
||||
// {
|
||||
// if (((t_u8 *)page->data) + block->offset == (t_u8 *)ptr)
|
||||
// return (block);
|
||||
// block = block->next;
|
||||
// }
|
||||
// return (NULL);
|
||||
// }
|
||||
//
|
||||
// t_mpage *get_page_from_ptr(void *ptr)
|
||||
// {
|
||||
// t_mpage *page;
|
||||
//
|
||||
// page = get_head_arena();
|
||||
// while (page)
|
||||
// {
|
||||
// if ((t_u8 *)page->data <= (t_u8 *)ptr &&
|
||||
// (t_u8 *)ptr < (((t_u8 *)page->data) + page->page_size))
|
||||
// return (page);
|
||||
// page = page->next;
|
||||
// }
|
||||
// return (NULL);
|
||||
// }
|
||||
//
|
||||
// void print_pages_info(void)
|
||||
// {
|
||||
// t_mpage *page;
|
||||
// t_i32 page_nb;
|
||||
//
|
||||
// page = get_head_arena();
|
||||
// page_nb = 0;
|
||||
// while (page != NULL)
|
||||
// {
|
||||
// me_putstr_fd("Page ", 2);
|
||||
// me_putnbr_fd(page_nb++, 2);
|
||||
// me_putstr_fd(" with size ", 2);
|
||||
// me_putnbr_fd((t_i32)page->page_size, 2);
|
||||
// me_putstr_fd("\n", 2);
|
||||
// page = page->next;
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// bool merge_next_block(t_mblock *cur, t_usize min_size)
|
||||
// {
|
||||
// t_mblock *next;
|
||||
//
|
||||
// if (cur->next != NULL && cur->page == cur->next->page && !cur->next->used &&
|
||||
// cur->size + cur->next->size >= min_size)
|
||||
// {
|
||||
// cur->size += cur->next->size;
|
||||
// next = cur->next;
|
||||
// cur->next = cur->next->next;
|
||||
// printf("merging two blocks %p and %p\n", cur, cur->next);
|
||||
// __libc_free(next);
|
||||
// return (NO_ERROR);
|
||||
// }
|
||||
// return (ERROR);
|
||||
// }
|
||||
Loading…
Add table
Add a link
Reference in a new issue