#include "Python.h"

#include "pycore_interp.h" // _PyInterpreterState_HasFeature

#include "pycore_mmap.h" // _PyAnnotateMemoryMap()

#include "pycore_object.h" // _PyDebugAllocatorStats() definition

#include "pycore_obmalloc.h"

#include "pycore_obmalloc_init.h"

#include "pycore_pyerrors.h" // _Py_FatalErrorFormat()

#include "pycore_pymem.h"

#include "pycore_pystate.h" // _PyInterpreterState_GET

#include "pycore_stats.h" // OBJECT_STAT_INC_COND()

#include <stdlib.h> // malloc()

#include <stdbool.h>

#include <stdio.h> // fopen(), fgets(), sscanf()

#include <errno.h> // errno

#ifdef WITH_MIMALLOC

static void _PyMem_mi_page_clear_qsbr(mi_page_t *page);

static bool _PyMem_mi_page_is_safe_to_free(mi_page_t *page);

static bool _PyMem_mi_page_maybe_free(mi_page_t *page, mi_page_queue_t *pq, bool force);

static void _PyMem_mi_page_reclaimed(mi_page_t *page);

static void _PyMem_mi_heap_collect_qsbr(mi_heap_t *heap);

# include "pycore_mimalloc.h"

# include "mimalloc/static.c"

# include "mimalloc/internal.h" // for stats

#if defined(Py_GIL_DISABLED) && !defined(WITH_MIMALLOC)

# error "Py_GIL_DISABLED requires WITH_MIMALLOC"

#undef uint

#define uint pymem_uint

extern void _PyMem_DumpTraceback(int fd, const void *ptr);

static void _PyObject_DebugDumpAddress(const void *p);

static void _PyMem_DebugCheckAddress(const char *func, char api_id, const void *p);

static void set_up_debug_hooks_domain_unlocked(PyMemAllocatorDomain domain);

static void set_up_debug_hooks_unlocked(void);

static void get_allocator_unlocked(PyMemAllocatorDomain, PyMemAllocatorEx *);

static void set_allocator_unlocked(PyMemAllocatorDomain, PyMemAllocatorEx *);

void *

_PyMem_RawMalloc(void *Py_UNUSED(ctx), size_t size)

{

/* PyMem_RawMalloc(0) means malloc(1). Some systems would return NULL

if (size == 0)

size = 1;

return malloc(size);

}

void *

_PyMem_RawCalloc(void *Py_UNUSED(ctx), size_t nelem, size_t elsize)

{

/* PyMem_RawCalloc(0, 0) means calloc(1, 1). Some systems would return NULL

if (nelem == 0 || elsize == 0) {

nelem = 1;

elsize = 1;

}

return calloc(nelem, elsize);

}

void *

_PyMem_RawRealloc(void *Py_UNUSED(ctx), void *ptr, size_t size)

{

if (size == 0)

size = 1;

return realloc(ptr, size);

}

_PyMem_RawFree(void *Py_UNUSED(ctx), void *ptr)

{

free(ptr);

}

#ifdef WITH_MIMALLOC

static void

_PyMem_mi_page_clear_qsbr(mi_page_t *page)

{

#ifdef Py_GIL_DISABLED

// Clear the QSBR goal and remove the page from the QSBR linked list.

page->qsbr_goal = 0;

if (page->qsbr_node.next != NULL) {

llist_remove(&page->qsbr_node);

}

}

static bool

_PyMem_mi_page_is_safe_to_free(mi_page_t *page)

{

assert(mi_page_all_free(page));

#ifdef Py_GIL_DISABLED

assert(page->qsbr_node.next == NULL);

if (page->use_qsbr && page->qsbr_goal != 0) {

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

if (tstate == NULL) {

return false;

}

return _Py_qbsr_goal_reached(tstate->qsbr, page->qsbr_goal);

}

return true;

}

#ifdef Py_GIL_DISABLED

#define QSBR_PAGE_MEM_LIMIT 4096*20

static bool

should_advance_qsbr_for_page(struct _qsbr_thread_state *qsbr, mi_page_t *page)

{

size_t bsize = mi_page_block_size(page);

size_t page_size = page->capacity*bsize;

if (page_size > QSBR_PAGE_MEM_LIMIT) {

qsbr->deferred_page_memory = 0;

return true;

}

qsbr->deferred_page_memory += page_size;

if (qsbr->deferred_page_memory > QSBR_PAGE_MEM_LIMIT) {

qsbr->deferred_page_memory = 0;

return true;

}

return false;

}

static _PyThreadStateImpl *

tstate_from_heap(mi_heap_t *heap)

{

return _Py_CONTAINER_OF(heap->tld, _PyThreadStateImpl, mimalloc.tld);

}

static bool

_PyMem_mi_page_maybe_free(mi_page_t *page, mi_page_queue_t *pq, bool force)

{

#ifdef Py_GIL_DISABLED

assert(mi_page_all_free(page));

if (page->use_qsbr) {

struct _qsbr_thread_state *qsbr = ((_PyThreadStateImpl *)PyThreadState_GET())->qsbr;

if (page->qsbr_goal != 0 && _Py_qbsr_goal_reached(qsbr, page->qsbr_goal)) {

_PyMem_mi_page_clear_qsbr(page);

_mi_page_free(page, pq, force);

return true;

}

// gh-145615: since we are not freeing this page yet, we want to

// make it available for allocations. Note that the QSBR goal and

// linked list node remain set even if the page is later used for

// an allocation. We only detect and clear the QSBR goal when the

// page becomes empty again (used == 0).

if (mi_page_is_in_full(page)) {

_mi_page_unfull(page);

}

_PyMem_mi_page_clear_qsbr(page);

page->retire_expire = 0;

if (should_advance_qsbr_for_page(qsbr, page)) {

page->qsbr_goal = _Py_qsbr_advance(qsbr->shared);

}

else {

page->qsbr_goal = _Py_qsbr_shared_next(qsbr->shared);

}

// We may be freeing a page belonging to a different thread during a

// stop-the-world event. Find the _PyThreadStateImpl for the page.

_PyThreadStateImpl *tstate = tstate_from_heap(mi_page_heap(page));

llist_insert_tail(&tstate->mimalloc.page_list, &page->qsbr_node);

return false;

}

_mi_page_free(page, pq, force);

return true;

}

static void

_PyMem_mi_page_reclaimed(mi_page_t *page)

{

#ifdef Py_GIL_DISABLED

assert(page->qsbr_node.next == NULL);

if (page->qsbr_goal != 0) {

if (mi_page_all_free(page)) {

assert(page->qsbr_node.next == NULL);

_PyThreadStateImpl *tstate = tstate_from_heap(mi_page_heap(page));

assert(tstate == (_PyThreadStateImpl *)_PyThreadState_GET());

page->retire_expire = 0;

llist_insert_tail(&tstate->mimalloc.page_list, &page->qsbr_node);

}

else {

page->qsbr_goal = 0;

}

}

}

static void

_PyMem_mi_heap_collect_qsbr(mi_heap_t *heap)

{

#ifdef Py_GIL_DISABLED

if (!heap->page_use_qsbr) {

return;

}

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

struct llist_node *head = &tstate->mimalloc.page_list;

if (llist_empty(head)) {

return;

}

struct llist_node *node;

llist_for_each_safe(node, head) {

mi_page_t *page = llist_data(node, mi_page_t, qsbr_node);

if (!mi_page_all_free(page)) {

// We allocated from this page some point after the delayed free

_PyMem_mi_page_clear_qsbr(page);

continue;

}

if (!_Py_qsbr_poll(tstate->qsbr, page->qsbr_goal)) {

return;

}

_PyMem_mi_page_clear_qsbr(page);

_mi_page_free(page, mi_page_queue_of(page), false);

}

}

void *

_PyMem_MiMalloc(void *ctx, size_t size)

{

#ifdef Py_GIL_DISABLED

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

mi_heap_t *heap = &tstate->mimalloc.heaps[_Py_MIMALLOC_HEAP_MEM];

return mi_heap_malloc(heap, size);

return mi_malloc(size);

}

void *

_PyMem_MiCalloc(void *ctx, size_t nelem, size_t elsize)

{

#ifdef Py_GIL_DISABLED

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

mi_heap_t *heap = &tstate->mimalloc.heaps[_Py_MIMALLOC_HEAP_MEM];

return mi_heap_calloc(heap, nelem, elsize);

return mi_calloc(nelem, elsize);

}

void *

_PyMem_MiRealloc(void *ctx, void *ptr, size_t size)

{

#ifdef Py_GIL_DISABLED

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

mi_heap_t *heap = &tstate->mimalloc.heaps[_Py_MIMALLOC_HEAP_MEM];

return mi_heap_realloc(heap, ptr, size);

return mi_realloc(ptr, size);

}

_PyMem_MiFree(void *ctx, void *ptr)

{

mi_free(ptr);

}

void *

_PyObject_MiMalloc(void *ctx, size_t nbytes)

{

#ifdef Py_GIL_DISABLED

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

mi_heap_t *heap = tstate->mimalloc.current_object_heap;

return mi_heap_malloc(heap, nbytes);

return mi_malloc(nbytes);

}

void *

_PyObject_MiCalloc(void *ctx, size_t nelem, size_t elsize)

{

#ifdef Py_GIL_DISABLED

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

mi_heap_t *heap = tstate->mimalloc.current_object_heap;

return mi_heap_calloc(heap, nelem, elsize);

return mi_calloc(nelem, elsize);

}

void *

_PyObject_MiRealloc(void *ctx, void *ptr, size_t nbytes)

{

#ifdef Py_GIL_DISABLED

_PyThreadStateImpl *tstate = (_PyThreadStateImpl *)_PyThreadState_GET();

// Implement our own realloc logic so that we can copy PyObject header

// in a thread-safe way.

size_t size = mi_usable_size(ptr);

if (nbytes <= size && nbytes >= (size / 2) && nbytes > 0) {

return ptr;

}

mi_heap_t *heap = tstate->mimalloc.current_object_heap;

void* newp = mi_heap_malloc(heap, nbytes);

if (newp == NULL) {

return NULL;

}

// Free threaded Python allows access from other threads to the PyObject reference count

// fields for a period of time after the object is freed (see InternalDocs/qsbr.md).

// These fields are typically initialized by PyObject_Init() using relaxed

// atomic stores. We need to copy these fields in a thread-safe way here.

// We use the "debug_offset" to determine how many bytes to copy -- it

// includes the PyObject header and plus any extra pre-headers.

size_t offset = heap->debug_offset;

assert(offset % sizeof(void*) == 0);

size_t copy_size = (size < nbytes ? size : nbytes);

if (copy_size >= offset) {

for (size_t i = 0; i != offset; i += sizeof(void*)) {

// Use memcpy to avoid strict-aliasing issues. However, we probably

// still have unavoidable strict-aliasing issues with

// _Py_atomic_store_ptr_relaxed here.

void *word;

memcpy(&word, (char*)ptr + i, sizeof(void*));

_Py_atomic_store_ptr_relaxed((void**)((char*)newp + i), word);

}

_mi_memcpy((char*)newp + offset, (char*)ptr + offset, copy_size - offset);

}

else {

_mi_memcpy(newp, ptr, copy_size);

}

mi_free(ptr);

return newp;

return mi_realloc(ptr, nbytes);

}

_PyObject_MiFree(void *ctx, void *ptr)

{

mi_free(ptr);

}

void *

_PyMem_MiRawMalloc(void *ctx, size_t size)

{

return mi_malloc(size);

}

void *

_PyMem_MiRawCalloc(void *ctx, size_t nelem, size_t elsize)

{

return mi_calloc(nelem, elsize);

}

void *

_PyMem_MiRawRealloc(void *ctx, void *ptr, size_t size)

{

return mi_realloc(ptr, size);

}

_PyMem_MiRawFree(void *ctx, void *ptr)

{

mi_free(ptr);

}

#endif // WITH_MIMALLOC

#define MALLOC_ALLOC {NULL, _PyMem_RawMalloc, _PyMem_RawCalloc, _PyMem_RawRealloc, _PyMem_RawFree}

#ifdef WITH_MIMALLOC

# define MIMALLOC_ALLOC {NULL, _PyMem_MiMalloc, _PyMem_MiCalloc, _PyMem_MiRealloc, _PyMem_MiFree}

# define MIMALLOC_RAWALLOC {NULL, _PyMem_MiRawMalloc, _PyMem_MiRawCalloc, _PyMem_MiRawRealloc, _PyMem_MiRawFree}

# define MIMALLOC_OBJALLOC {NULL, _PyObject_MiMalloc, _PyObject_MiCalloc, _PyObject_MiRealloc, _PyObject_MiFree}

#if defined(WITH_PYMALLOC)

void* _PyObject_Malloc(void *ctx, size_t size);

void* _PyObject_Calloc(void *ctx, size_t nelem, size_t elsize);

void _PyObject_Free(void *ctx, void *p);

void* _PyObject_Realloc(void *ctx, void *ptr, size_t size);

# define PYMALLOC_ALLOC {NULL, _PyObject_Malloc, _PyObject_Calloc, _PyObject_Realloc, _PyObject_Free}

#endif // WITH_PYMALLOC

#if defined(Py_GIL_DISABLED)

# define PYRAW_ALLOC MIMALLOC_RAWALLOC

# define PYMEM_ALLOC MIMALLOC_ALLOC

# define PYOBJ_ALLOC MIMALLOC_OBJALLOC

#elif defined(WITH_PYMALLOC)

# define PYRAW_ALLOC MALLOC_ALLOC

# define PYMEM_ALLOC PYMALLOC_ALLOC

# define PYOBJ_ALLOC PYMALLOC_ALLOC

# define PYRAW_ALLOC MALLOC_ALLOC

# define PYMEM_ALLOC MALLOC_ALLOC

# define PYOBJ_ALLOC MALLOC_ALLOC

void* _PyMem_DebugRawMalloc(void *ctx, size_t size);

void* _PyMem_DebugRawCalloc(void *ctx, size_t nelem, size_t elsize);

void* _PyMem_DebugRawRealloc(void *ctx, void *ptr, size_t size);

void _PyMem_DebugRawFree(void *ctx, void *ptr);

void* _PyMem_DebugMalloc(void *ctx, size_t size);

void* _PyMem_DebugCalloc(void *ctx, size_t nelem, size_t elsize);

void* _PyMem_DebugRealloc(void *ctx, void *ptr, size_t size);

void _PyMem_DebugFree(void *ctx, void *p);

#define PYDBGRAW_ALLOC \

{&_PyRuntime.allocators.debug.raw, _PyMem_DebugRawMalloc, _PyMem_DebugRawCalloc, _PyMem_DebugRawRealloc, _PyMem_DebugRawFree}

#define PYDBGMEM_ALLOC \

{&_PyRuntime.allocators.debug.mem, _PyMem_DebugMalloc, _PyMem_DebugCalloc, _PyMem_DebugRealloc, _PyMem_DebugFree}

#define PYDBGOBJ_ALLOC \

{&_PyRuntime.allocators.debug.obj, _PyMem_DebugMalloc, _PyMem_DebugCalloc, _PyMem_DebugRealloc, _PyMem_DebugFree}

void *

_PyMem_DefaultRawMalloc(size_t size)

{

#ifdef Py_DEBUG

return _PyMem_DebugRawMalloc(&_PyRuntime.allocators.debug.raw, size);

return _PyMem_RawMalloc(NULL, size);

}

void *

_PyMem_DefaultRawCalloc(size_t nelem, size_t elsize)

{

#ifdef Py_DEBUG

return _PyMem_DebugRawCalloc(&_PyRuntime.allocators.debug.raw, nelem, elsize);

return _PyMem_RawCalloc(NULL, nelem, elsize);

}

void *

_PyMem_DefaultRawRealloc(void *ptr, size_t size)

{

#ifdef Py_DEBUG

return _PyMem_DebugRawRealloc(&_PyRuntime.allocators.debug.raw, ptr, size);

return _PyMem_RawRealloc(NULL, ptr, size);

}

_PyMem_DefaultRawFree(void *ptr)

{

#ifdef Py_DEBUG

_PyMem_DebugRawFree(&_PyRuntime.allocators.debug.raw, ptr);

_PyMem_RawFree(NULL, ptr);

}

_PyMem_DefaultRawWcsdup(const wchar_t *str)

{

assert(str != NULL);

size_t len = wcslen(str);

if (len > (size_t)PY_SSIZE_T_MAX / sizeof(wchar_t) - 1) {

return NULL;

}

size_t size = (len + 1) * sizeof(wchar_t);

wchar_t *str2 = _PyMem_DefaultRawMalloc(size);

if (str2 == NULL) {

return NULL;

}

memcpy(str2, str, size);

return str2;

}

#ifdef WITH_PYMALLOC

# ifdef MS_WINDOWS

# include <windows.h>

# elif defined(HAVE_MMAP)

# include <sys/mman.h>

# ifdef MAP_ANONYMOUS

# define ARENAS_USE_MMAP

#if defined(PYMALLOC_USE_HUGEPAGES) && defined(ARENAS_USE_MMAP) && defined(MAP_HUGETLB)

static size_t

_pymalloc_system_hugepage_size(void)

{

static size_t hp_size = 0;

static int initialized = 0;

if (initialized) {

return hp_size;

}

#ifdef __linux__

FILE *f = fopen("/proc/meminfo", "r");

if (f != NULL) {

char line[256];

while (fgets(line, sizeof(line), f)) {

unsigned long size_kb;

if (sscanf(line, "Hugepagesize: %lu kB", &size_kb) == 1) {

hp_size = (size_t)size_kb * 1024;

break;

}

}

fclose(f);

}

initialized = 1;

return hp_size;

}

#if (defined(MS_WINDOWS) && defined(PYMALLOC_USE_HUGEPAGES)) || \

(defined(PYMALLOC_USE_HUGEPAGES) && defined(ARENAS_USE_MMAP) && defined(MAP_HUGETLB))

static size_t

_pymalloc_round_up_to_multiple(size_t size, size_t multiple)

{

if (multiple == 0 || size == 0) {

return size;

}

size_t remainder = size % multiple;

if (remainder == 0) {

return size;

}

size_t padding = multiple - remainder;

if (size > SIZE_MAX - padding) {

return 0;

}

return size + padding;

}

static size_t

_pymalloc_virtual_alloc_size(size_t size)

{

#if defined(MS_WINDOWS) && defined(PYMALLOC_USE_HUGEPAGES)

if (_PyRuntime.allocators.use_hugepages) {

SIZE_T large_page_size = GetLargePageMinimum();

if (large_page_size > 0) {

return _pymalloc_round_up_to_multiple(size, (size_t)large_page_size);

}

}

#elif defined(PYMALLOC_USE_HUGEPAGES) && defined(ARENAS_USE_MMAP) && defined(MAP_HUGETLB)

if (_PyRuntime.allocators.use_hugepages) {

size_t hp_size = _pymalloc_system_hugepage_size();

if (hp_size > 0) {

return _pymalloc_round_up_to_multiple(size, hp_size);

}

}

return size;

}

void *

_PyMem_ArenaAlloc(void *Py_UNUSED(ctx), size_t size)

{

#ifdef MS_WINDOWS

# ifdef PYMALLOC_USE_HUGEPAGES

if (_PyRuntime.allocators.use_hugepages) {

SIZE_T lp_size = GetLargePageMinimum();

if (lp_size > 0 && size % lp_size == 0) {

void *ptr = VirtualAlloc(NULL, size,

MEM_COMMIT | MEM_RESERVE | MEM_LARGE_PAGES,

PAGE_READWRITE);

if (ptr != NULL)

return ptr;

}

}

/* Fall back to regular pages */

return VirtualAlloc(NULL, size,

MEM_COMMIT | MEM_RESERVE, PAGE_READWRITE);

#elif defined(ARENAS_USE_MMAP)

void *ptr;

# ifdef PYMALLOC_USE_HUGEPAGES

# ifdef MAP_HUGETLB

if (_PyRuntime.allocators.use_hugepages) {

size_t hp_size = _pymalloc_system_hugepage_size();

/* Only use huge pages if the arena size is a multiple of the

if (hp_size > 0 && size % hp_size == 0) {

ptr = mmap(NULL, size, PROT_READ|PROT_WRITE,

MAP_PRIVATE|MAP_ANONYMOUS|MAP_HUGETLB, -1, 0);

if (ptr != MAP_FAILED) {

assert(ptr != NULL);

(void)_PyAnnotateMemoryMap(ptr, size, "cpython:pymalloc:hugepage");

return ptr;

}

}

}

/* Fall back to regular pages */

ptr = mmap(NULL, size, PROT_READ|PROT_WRITE,

MAP_PRIVATE|MAP_ANONYMOUS, -1, 0);

if (ptr == MAP_FAILED)

return NULL;

assert(ptr != NULL);

(void)_PyAnnotateMemoryMap(ptr, size, "cpython:pymalloc");

return ptr;

return malloc(size);

}

_PyMem_ArenaFree(void *Py_UNUSED(ctx), void *ptr,

size_t Py_UNUSED(size)

)

{

#ifdef MS_WINDOWS

/* Unlike free(), VirtualFree() does not special-case NULL to noop. */

if (ptr == NULL) {

return;

}

VirtualFree(ptr, 0, MEM_RELEASE);

#elif defined(ARENAS_USE_MMAP)

/* Unlike free(), munmap() does not special-case NULL to noop. */

if (ptr == NULL) {

return;

}

if (munmap(ptr, size) < 0) {

_Py_FatalErrorFormat(__func__,

"munmap(%p, %zu) failed with errno %d",

ptr, size, errno);

}

free(ptr);

}

#define ALLOCATORS_MUTEX (_PyRuntime.allocators.mutex)

#define _PyMem_Raw (_PyRuntime.allocators.standard.raw)

#define _PyMem (_PyRuntime.allocators.standard.mem)

#define _PyObject (_PyRuntime.allocators.standard.obj)

#define _PyMem_Debug (_PyRuntime.allocators.debug)

#define _PyObject_Arena (_PyRuntime.allocators.obj_arena)

static int

set_default_allocator_unlocked(PyMemAllocatorDomain domain, int debug,

PyMemAllocatorEx *old_alloc)

{

if (old_alloc != NULL) {

get_allocator_unlocked(domain, old_alloc);

}

PyMemAllocatorEx new_alloc;

switch(domain)

{

case PYMEM_DOMAIN_RAW:

new_alloc = (PyMemAllocatorEx)PYRAW_ALLOC;

break;

case PYMEM_DOMAIN_MEM:

new_alloc = (PyMemAllocatorEx)PYMEM_ALLOC;

break;

case PYMEM_DOMAIN_OBJ:

new_alloc = (PyMemAllocatorEx)PYOBJ_ALLOC;

break;

default:

/* unknown domain */

return -1;

}

set_allocator_unlocked(domain, &new_alloc);

if (debug) {

set_up_debug_hooks_domain_unlocked(domain);

}

return 0;

}

#ifdef Py_DEBUG

static const int pydebug = 1;

static const int pydebug = 0;

_PyMem_GetAllocatorName(const char *name, PyMemAllocatorName *allocator)

{

if (name == NULL || *name == '\0') {

/* PYTHONMALLOC is empty or is not set or ignored (-E/-I command line

*allocator = PYMEM_ALLOCATOR_DEFAULT;

}

else if (strcmp(name, "default") == 0) {

*allocator = PYMEM_ALLOCATOR_DEFAULT;

}

else if (strcmp(name, "debug") == 0) {

*allocator = PYMEM_ALLOCATOR_DEBUG;

}

#if defined(WITH_PYMALLOC) && !defined(Py_GIL_DISABLED)

else if (strcmp(name, "pymalloc") == 0) {

*allocator = PYMEM_ALLOCATOR_PYMALLOC;

}

else if (strcmp(name, "pymalloc_debug") == 0) {

*allocator = PYMEM_ALLOCATOR_PYMALLOC_DEBUG;

}

#ifdef WITH_MIMALLOC

else if (strcmp(name, "mimalloc") == 0) {

*allocator = PYMEM_ALLOCATOR_MIMALLOC;

}

else if (strcmp(name, "mimalloc_debug") == 0) {

*allocator = PYMEM_ALLOCATOR_MIMALLOC_DEBUG;

}

#ifndef Py_GIL_DISABLED

else if (strcmp(name, "malloc") == 0) {

*allocator = PYMEM_ALLOCATOR_MALLOC;

}

else if (strcmp(name, "malloc_debug") == 0) {

*allocator = PYMEM_ALLOCATOR_MALLOC_DEBUG;

}

else {

/* unknown allocator */

return -1;

}

return 0;

}

static int

set_up_allocators_unlocked(PyMemAllocatorName allocator)

{

switch (allocator) {

case PYMEM_ALLOCATOR_NOT_SET:

/* do nothing */

break;

case PYMEM_ALLOCATOR_DEFAULT:

(void)set_default_allocator_unlocked(PYMEM_DOMAIN_RAW, pydebug, NULL);

(void)set_default_allocator_unlocked(PYMEM_DOMAIN_MEM, pydebug, NULL);

(void)set_default_allocator_unlocked(PYMEM_DOMAIN_OBJ, pydebug, NULL);

_PyRuntime.allocators.is_debug_enabled = pydebug;

break;

case PYMEM_ALLOCATOR_DEBUG:

(void)set_default_allocator_unlocked(PYMEM_DOMAIN_RAW, 1, NULL);

(void)set_default_allocator_unlocked(PYMEM_DOMAIN_MEM, 1, NULL);

(void)set_default_allocator_unlocked(PYMEM_DOMAIN_OBJ, 1, NULL);

_PyRuntime.allocators.is_debug_enabled = 1;

break;

#ifdef WITH_PYMALLOC

case PYMEM_ALLOCATOR_PYMALLOC:

case PYMEM_ALLOCATOR_PYMALLOC_DEBUG:

{

PyMemAllocatorEx malloc_alloc = MALLOC_ALLOC;

set_allocator_unlocked(PYMEM_DOMAIN_RAW, &malloc_alloc);

PyMemAllocatorEx pymalloc = PYMALLOC_ALLOC;

set_allocator_unlocked(PYMEM_DOMAIN_MEM, &pymalloc);

set_allocator_unlocked(PYMEM_DOMAIN_OBJ, &pymalloc);

int is_debug = (allocator == PYMEM_ALLOCATOR_PYMALLOC_DEBUG);

_PyRuntime.allocators.is_debug_enabled = is_debug;

if (is_debug) {

set_up_debug_hooks_unlocked();

}

break;

}

#ifdef WITH_MIMALLOC

case PYMEM_ALLOCATOR_MIMALLOC:

case PYMEM_ALLOCATOR_MIMALLOC_DEBUG:

{

PyMemAllocatorEx malloc_alloc = MIMALLOC_RAWALLOC;

set_allocator_unlocked(PYMEM_DOMAIN_RAW, &malloc_alloc);

PyMemAllocatorEx pymalloc = MIMALLOC_ALLOC;

set_allocator_unlocked(PYMEM_DOMAIN_MEM, &pymalloc);

PyMemAllocatorEx objmalloc = MIMALLOC_OBJALLOC;

set_allocator_unlocked(PYMEM_DOMAIN_OBJ, &objmalloc);

int is_debug = (allocator == PYMEM_ALLOCATOR_MIMALLOC_DEBUG);

_PyRuntime.allocators.is_debug_enabled = is_debug;

if (is_debug) {

set_up_debug_hooks_unlocked();

}

break;

}

case PYMEM_ALLOCATOR_MALLOC:

case PYMEM_ALLOCATOR_MALLOC_DEBUG:

{

PyMemAllocatorEx malloc_alloc = MALLOC_ALLOC;

set_allocator_unlocked(PYMEM_DOMAIN_RAW, &malloc_alloc);

set_allocator_unlocked(PYMEM_DOMAIN_MEM, &malloc_alloc);

set_allocator_unlocked(PYMEM_DOMAIN_OBJ, &malloc_alloc);

int is_debug = (allocator == PYMEM_ALLOCATOR_MALLOC_DEBUG);

_PyRuntime.allocators.is_debug_enabled = is_debug;

if (is_debug) {

set_up_debug_hooks_unlocked();

}

break;

}

default:

/* unknown allocator */

return -1;

}

return 0;

}

_PyMem_SetupAllocators(PyMemAllocatorName allocator)

{

PyMutex_Lock(&ALLOCATORS_MUTEX);

int res = set_up_allocators_unlocked(allocator);

PyMutex_Unlock(&ALLOCATORS_MUTEX);

return res;

}

static int

pymemallocator_eq(PyMemAllocatorEx *a, PyMemAllocatorEx *b)

{

return (memcmp(a, b, sizeof(PyMemAllocatorEx)) == 0);

}

static const char*

get_current_allocator_name_unlocked(void)

{

PyMemAllocatorEx malloc_alloc = MALLOC_ALLOC;

#ifdef WITH_PYMALLOC

PyMemAllocatorEx pymalloc = PYMALLOC_ALLOC;

#ifdef WITH_MIMALLOC

PyMemAllocatorEx mimalloc = MIMALLOC_ALLOC;

PyMemAllocatorEx mimalloc_obj = MIMALLOC_OBJALLOC;

PyMemAllocatorEx mimalloc_raw = MIMALLOC_RAWALLOC;

if (pymemallocator_eq(&_PyMem_Raw, &malloc_alloc) &&

pymemallocator_eq(&_PyMem, &malloc_alloc) &&

pymemallocator_eq(&_PyObject, &malloc_alloc))

{

return "malloc";

}

#ifdef WITH_PYMALLOC

if (pymemallocator_eq(&_PyMem_Raw, &malloc_alloc) &&

pymemallocator_eq(&_PyMem, &pymalloc) &&

pymemallocator_eq(&_PyObject, &pymalloc))

{

return "pymalloc";

}

#ifdef WITH_MIMALLOC

if (pymemallocator_eq(&_PyMem_Raw, &mimalloc_raw) &&

pymemallocator_eq(&_PyMem, &mimalloc) &&

pymemallocator_eq(&_PyObject, &mimalloc_obj))

{

return "mimalloc";

}

PyMemAllocatorEx dbg_raw = PYDBGRAW_ALLOC;

PyMemAllocatorEx dbg_mem = PYDBGMEM_ALLOC;

PyMemAllocatorEx dbg_obj = PYDBGOBJ_ALLOC;

if (pymemallocator_eq(&_PyMem_Raw, &dbg_raw) &&

pymemallocator_eq(&_PyMem, &dbg_mem) &&

pymemallocator_eq(&_PyObject, &dbg_obj))

{

/* Debug hooks installed */

if (pymemallocator_eq(&_PyMem_Debug.raw.alloc, &malloc_alloc) &&

pymemallocator_eq(&_PyMem_Debug.mem.alloc, &malloc_alloc) &&

pymemallocator_eq(&_PyMem_Debug.obj.alloc, &malloc_alloc))

{

return "malloc_debug";

}

#ifdef WITH_PYMALLOC

if (pymemallocator_eq(&_PyMem_Debug.raw.alloc, &malloc_alloc) &&

pymemallocator_eq(&_PyMem_Debug.mem.alloc, &pymalloc) &&

pymemallocator_eq(&_PyMem_Debug.obj.alloc, &pymalloc))

{

return "pymalloc_debug";

}

#ifdef WITH_MIMALLOC

if (pymemallocator_eq(&_PyMem_Debug.raw.alloc, &mimalloc_raw) &&

pymemallocator_eq(&_PyMem_Debug.mem.alloc, &mimalloc) &&

pymemallocator_eq(&_PyMem_Debug.obj.alloc, &mimalloc_obj))

{

return "mimalloc_debug";

}

}

return NULL;

}

const char*

_PyMem_GetCurrentAllocatorName(void)

{

PyMutex_Lock(&ALLOCATORS_MUTEX);

const char *name = get_current_allocator_name_unlocked();

PyMutex_Unlock(&ALLOCATORS_MUTEX);

return name;

}

_PyMem_DebugEnabled(void)

{

return _PyRuntime.allocators.is_debug_enabled;

}

#ifdef WITH_PYMALLOC

static int