Add MAP_NORESERVE support.

Add MAP_NORESERVE to the chunk_mmap() case being used by
chunk_swap_enable(), if the system supports it.
This commit is contained in:
Jordan DeLong 2010-05-10 14:17:00 -07:00 committed by Jason Evans
parent ecea0f6125
commit 2206e1acc1
3 changed files with 32 additions and 14 deletions

View File

@ -10,6 +10,7 @@
#ifdef JEMALLOC_H_EXTERNS #ifdef JEMALLOC_H_EXTERNS
void *chunk_alloc_mmap(size_t size); void *chunk_alloc_mmap(size_t size);
void *chunk_alloc_mmap_noreserve(size_t size);
void chunk_dealloc_mmap(void *chunk, size_t size); void chunk_dealloc_mmap(void *chunk, size_t size);
#endif /* JEMALLOC_H_EXTERNS */ #endif /* JEMALLOC_H_EXTERNS */

View File

@ -23,14 +23,15 @@ static
/******************************************************************************/ /******************************************************************************/
/* Function prototypes for non-inline static functions. */ /* Function prototypes for non-inline static functions. */
static void *pages_map(void *addr, size_t size); static void *pages_map(void *addr, size_t size, bool noreserve);
static void pages_unmap(void *addr, size_t size); static void pages_unmap(void *addr, size_t size);
static void *chunk_alloc_mmap_slow(size_t size, bool unaligned); static void *chunk_alloc_mmap_slow(size_t size, bool unaligned, bool noreserve);
static void *chunk_alloc_mmap_internal(size_t size, bool noreserve);
/******************************************************************************/ /******************************************************************************/
static void * static void *
pages_map(void *addr, size_t size) pages_map(void *addr, size_t size, bool noreserve)
{ {
void *ret; void *ret;
@ -38,8 +39,12 @@ pages_map(void *addr, size_t size)
* We don't use MAP_FIXED here, because it can cause the *replacement* * We don't use MAP_FIXED here, because it can cause the *replacement*
* of existing mappings, and we only want to create new mappings. * of existing mappings, and we only want to create new mappings.
*/ */
ret = mmap(addr, size, PROT_READ | PROT_WRITE, MAP_PRIVATE | MAP_ANON, int flags = MAP_PRIVATE | MAP_ANON;
-1, 0); #ifdef MAP_NORESERVE
if (noreserve)
flags |= MAP_NORESERVE;
#endif
ret = mmap(addr, size, PROT_READ | PROT_WRITE, flags, -1, 0);
assert(ret != NULL); assert(ret != NULL);
if (ret == MAP_FAILED) if (ret == MAP_FAILED)
@ -83,7 +88,7 @@ pages_unmap(void *addr, size_t size)
} }
static void * static void *
chunk_alloc_mmap_slow(size_t size, bool unaligned) chunk_alloc_mmap_slow(size_t size, bool unaligned, bool noreserve)
{ {
void *ret; void *ret;
size_t offset; size_t offset;
@ -92,7 +97,7 @@ chunk_alloc_mmap_slow(size_t size, bool unaligned)
if (size + chunksize <= size) if (size + chunksize <= size)
return (NULL); return (NULL);
ret = pages_map(NULL, size + chunksize); ret = pages_map(NULL, size + chunksize, noreserve);
if (ret == NULL) if (ret == NULL)
return (NULL); return (NULL);
@ -128,8 +133,8 @@ chunk_alloc_mmap_slow(size_t size, bool unaligned)
return (ret); return (ret);
} }
void * static void *
chunk_alloc_mmap(size_t size) chunk_alloc_mmap_internal(size_t size, bool noreserve)
{ {
void *ret; void *ret;
@ -164,7 +169,7 @@ chunk_alloc_mmap(size_t size)
if (mmap_unaligned == false) { if (mmap_unaligned == false) {
size_t offset; size_t offset;
ret = pages_map(NULL, size); ret = pages_map(NULL, size, noreserve);
if (ret == NULL) if (ret == NULL)
return (NULL); return (NULL);
@ -173,13 +178,13 @@ chunk_alloc_mmap(size_t size)
mmap_unaligned = true; mmap_unaligned = true;
/* Try to extend chunk boundary. */ /* Try to extend chunk boundary. */
if (pages_map((void *)((uintptr_t)ret + size), if (pages_map((void *)((uintptr_t)ret + size),
chunksize - offset) == NULL) { chunksize - offset, noreserve) == NULL) {
/* /*
* Extension failed. Clean up, then revert to * Extension failed. Clean up, then revert to
* the reliable-but-expensive method. * the reliable-but-expensive method.
*/ */
pages_unmap(ret, size); pages_unmap(ret, size);
ret = chunk_alloc_mmap_slow(size, true); ret = chunk_alloc_mmap_slow(size, true, noreserve);
} else { } else {
/* Clean up unneeded leading space. */ /* Clean up unneeded leading space. */
pages_unmap(ret, chunksize - offset); pages_unmap(ret, chunksize - offset);
@ -188,11 +193,23 @@ chunk_alloc_mmap(size_t size)
} }
} }
} else } else
ret = chunk_alloc_mmap_slow(size, false); ret = chunk_alloc_mmap_slow(size, false, noreserve);
return (ret); return (ret);
} }
void *
chunk_alloc_mmap(size_t size)
{
return chunk_alloc_mmap_internal(size, false);
}
void *
chunk_alloc_mmap_noreserve(size_t size)
{
return chunk_alloc_mmap_internal(size, true);
}
void void
chunk_dealloc_mmap(void *chunk, size_t size) chunk_dealloc_mmap(void *chunk, size_t size)
{ {

View File

@ -283,7 +283,7 @@ chunk_swap_enable(const int *fds, unsigned nfds, bool prezeroed)
* Allocate a chunk-aligned region of anonymous memory, which will * Allocate a chunk-aligned region of anonymous memory, which will
* be the final location for the memory-mapped files. * be the final location for the memory-mapped files.
*/ */
vaddr = chunk_alloc_mmap(cumsize); vaddr = chunk_alloc_mmap_noreserve(cumsize);
if (vaddr == NULL) { if (vaddr == NULL) {
ret = true; ret = true;
goto RETURN; goto RETURN;