#include "postgres.h"
#include "lib/ilist.h"
#include "port/pg_bitutils.h"
#include "utils/memdebug.h"
#include "utils/memutils.h"
#include "utils/memutils_internal.h"
#include "utils/memutils_memorychunk.h"
#define Generation_BLOCKHDRSZ MAXALIGN(sizeof(GenerationBlock))
#define Generation_CHUNKHDRSZ sizeof(MemoryChunk)
#define Generation_CHUNK_FRACTION 8
typedef struct GenerationBlock GenerationBlock;
typedef void *GenerationPointer;
typedef struct GenerationContext
{
MemoryContextData header;
uint32 initBlockSize;
uint32 maxBlockSize;
uint32 nextBlockSize;
uint32 allocChunkLimit;
GenerationBlock *block;
GenerationBlock *freeblock;
dlist_head blocks;
} GenerationContext;
struct GenerationBlock
{
dlist_node node;
GenerationContext *context;
Size blksize;
int nchunks;
int nfree;
char *freeptr;
char *endptr;
};
#define GenerationIsValid(set) \
(PointerIsValid(set) && IsA(set, GenerationContext))
#define GenerationBlockIsValid(block) \
(PointerIsValid(block) && GenerationIsValid((block)->context))
#define GenerationBlockIsEmpty(b) ((b)->nchunks == 0)
#define ExternalChunkGetBlock(chunk) \
(GenerationBlock *) ((char *) chunk - Generation_BLOCKHDRSZ)
#define KeeperBlock(set) \
((GenerationBlock *) (((char *) set) + \
MAXALIGN(sizeof(GenerationContext))))
#define IsKeeperBlock(set, block) ((block) == (KeeperBlock(set)))
static inline void GenerationBlockInit(GenerationContext *context,
GenerationBlock *block,
Size blksize);
static inline void GenerationBlockMarkEmpty(GenerationBlock *block);
static inline Size GenerationBlockFreeBytes(GenerationBlock *block);
static inline void GenerationBlockFree(GenerationContext *set,
GenerationBlock *block);
void
GenerationReset(MemoryContext context)
{
GenerationContext *set = (GenerationContext *) context;
dlist_mutable_iter miter;
Assert(GenerationIsValid(set));
#ifdef MEMORY_CONTEXT_CHECKING
GenerationCheck(context);
#endif
set->freeblock = NULL;
dlist_foreach_modify(miter, &set->blocks)
{
GenerationBlock *block = dlist_container(GenerationBlock, node, miter.cur);
if (IsKeeperBlock(set, block))
GenerationBlockMarkEmpty(block);
else
GenerationBlockFree(set, block);
}
set->block = KeeperBlock(set);
set->nextBlockSize = set->initBlockSize;
Assert(!dlist_is_empty(&set->blocks));
Assert(!dlist_has_next(&set->blocks, dlist_head_node(&set->blocks)));
}
void
GenerationDelete(MemoryContext context)
{
GenerationReset(context);
free(context);
}
pg_noinline
static void *
GenerationAllocLarge(MemoryContext context, Size size, int flags)
{
GenerationContext *set = (GenerationContext *) context;
GenerationBlock *block;
MemoryChunk *chunk;
Size chunk_size;
Size required_size;
Size blksize;
MemoryContextCheckSize(context, size, flags);
#ifdef MEMORY_CONTEXT_CHECKING
chunk_size = MAXALIGN(size + 1);
#else
chunk_size = MAXALIGN(size);
#endif
required_size = chunk_size + Generation_CHUNKHDRSZ;
blksize = required_size + Generation_BLOCKHDRSZ;
block = (GenerationBlock *) malloc(blksize);
if (block == NULL)
return MemoryContextAllocationFailure(context, size, flags);
context->mem_allocated += blksize;
block->context = set;
block->blksize = blksize;
block->nchunks = 1;
block->nfree = 0;
block->freeptr = block->endptr = ((char *) block) + blksize;
chunk = (MemoryChunk *) (((char *) block) + Generation_BLOCKHDRSZ);
MemoryChunkSetHdrMaskExternal(chunk, MCTX_GENERATION_ID);
#ifdef MEMORY_CONTEXT_CHECKING
chunk->requested_size = size;
Assert(size < chunk_size);
set_sentinel(MemoryChunkGetPointer(chunk), size);
#endif
#ifdef RANDOMIZE_ALLOCATED_MEMORY
randomize_mem((char *) MemoryChunkGetPointer(chunk), size);
#endif
dlist_push_head(&set->blocks, &block->node);
VALGRIND_MAKE_MEM_NOACCESS((char *) MemoryChunkGetPointer(chunk) + size,
chunk_size - size);
VALGRIND_MAKE_MEM_NOACCESS(chunk, Generation_CHUNKHDRSZ);
return MemoryChunkGetPointer(chunk);
}
static inline void *
GenerationAllocChunkFromBlock(MemoryContext context, GenerationBlock *block,
Size size, Size chunk_size)
{
MemoryChunk *chunk = (MemoryChunk *) (block->freeptr);
Assert(block != NULL);
Assert((block->endptr - block->freeptr) >=
Generation_CHUNKHDRSZ + chunk_size);
VALGRIND_MAKE_MEM_UNDEFINED(chunk, Generation_CHUNKHDRSZ);
block->nchunks += 1;
block->freeptr += (Generation_CHUNKHDRSZ + chunk_size);
Assert(block->freeptr <= block->endptr);
MemoryChunkSetHdrMask(chunk, block, chunk_size, MCTX_GENERATION_ID);
#ifdef MEMORY_CONTEXT_CHECKING
chunk->requested_size = size;
Assert(size < chunk_size);
set_sentinel(MemoryChunkGetPointer(chunk), size);
#endif
#ifdef RANDOMIZE_ALLOCATED_MEMORY
randomize_mem((char *) MemoryChunkGetPointer(chunk), size);
#endif
VALGRIND_MAKE_MEM_NOACCESS((char *) MemoryChunkGetPointer(chunk) + size,
chunk_size - size);
VALGRIND_MAKE_MEM_NOACCESS(chunk, Generation_CHUNKHDRSZ);
return MemoryChunkGetPointer(chunk);
}
pg_noinline
static void *
GenerationAllocFromNewBlock(MemoryContext context, Size size, int flags,
Size chunk_size)
{
GenerationContext *set = (GenerationContext *) context;
GenerationBlock *block;
Size blksize;
Size required_size;
blksize = set->nextBlockSize;
set->nextBlockSize <<= 1;
if (set->nextBlockSize > set->maxBlockSize)
set->nextBlockSize = set->maxBlockSize;
required_size = chunk_size + Generation_CHUNKHDRSZ + Generation_BLOCKHDRSZ;
if (blksize < required_size)
blksize = pg_nextpower2_size_t(required_size);
block = (GenerationBlock *) malloc(blksize);
if (block == NULL)
return MemoryContextAllocationFailure(context, size, flags);
context->mem_allocated += blksize;
GenerationBlockInit(set, block, blksize);
dlist_push_head(&set->blocks, &block->node);
set->block = block;
return GenerationAllocChunkFromBlock(context, block, size, chunk_size);
}
void *
GenerationAlloc(MemoryContext context, Size size, int flags)
{
GenerationContext *set = (GenerationContext *) context;
GenerationBlock *block;
Size chunk_size;
Size required_size;
Assert(GenerationIsValid(set));
#ifdef MEMORY_CONTEXT_CHECKING
chunk_size = MAXALIGN(size + 1);
#else
chunk_size = MAXALIGN(size);
#endif
if (chunk_size > set->allocChunkLimit)
return GenerationAllocLarge(context, size, flags);
required_size = chunk_size + Generation_CHUNKHDRSZ;
block = set->block;
if (unlikely(GenerationBlockFreeBytes(block) < required_size))
{
GenerationBlock *freeblock = set->freeblock;
Assert(freeblock == NULL || GenerationBlockIsEmpty(freeblock));
if (freeblock != NULL &&
GenerationBlockFreeBytes(freeblock) >= required_size)
{
set->freeblock = NULL;
set->block = freeblock;
return GenerationAllocChunkFromBlock(context,
freeblock,
size,
chunk_size);
}
else
{
return GenerationAllocFromNewBlock(context, size, flags, chunk_size);
}
}
return GenerationAllocChunkFromBlock(context, block, size, chunk_size);
}
static inline void
GenerationBlockInit(GenerationContext *context, GenerationBlock *block,
Size blksize)
{
block->context = context;
block->blksize = blksize;
block->nchunks = 0;
block->nfree = 0;
block->freeptr = ((char *) block) + Generation_BLOCKHDRSZ;
block->endptr = ((char *) block) + blksize;
VALGRIND_MAKE_MEM_NOACCESS(block->freeptr,
blksize - Generation_BLOCKHDRSZ);
}
static inline void
GenerationBlockMarkEmpty(GenerationBlock *block)
{
#if defined(USE_VALGRIND) || defined(CLOBBER_FREED_MEMORY)
char *datastart = ((char *) block) + Generation_BLOCKHDRSZ;
#endif
#ifdef CLOBBER_FREED_MEMORY
wipe_mem(datastart, block->freeptr - datastart);
#else
VALGRIND_MAKE_MEM_NOACCESS(datastart, block->freeptr - datastart);
#endif
block->nchunks = 0;
block->nfree = 0;
block->freeptr = ((char *) block) + Generation_BLOCKHDRSZ;
}
static inline Size
GenerationBlockFreeBytes(GenerationBlock *block)
{
return (block->endptr - block->freeptr);
}
static inline void
GenerationBlockFree(GenerationContext *set, GenerationBlock *block)
{
Assert(!IsKeeperBlock(set, block));
Assert(block != set->freeblock);
dlist_delete(&block->node);
((MemoryContext) set)->mem_allocated -= block->blksize;
#ifdef CLOBBER_FREED_MEMORY
wipe_mem(block, block->blksize);
#endif
free(block);
}
void
GenerationFree(void *pointer)
{
MemoryChunk *chunk = PointerGetMemoryChunk(pointer);
GenerationBlock *block;
GenerationContext *set;
#if (defined(MEMORY_CONTEXT_CHECKING) && defined(USE_ASSERT_CHECKING)) \
|| defined(CLOBBER_FREED_MEMORY)
Size chunksize;
#endif
VALGRIND_MAKE_MEM_DEFINED(chunk, Generation_CHUNKHDRSZ);
if (MemoryChunkIsExternal(chunk))
{
block = ExternalChunkGetBlock(chunk);
if (!GenerationBlockIsValid(block))
elog(ERROR, "could not find block containing chunk %p", chunk);
#if (defined(MEMORY_CONTEXT_CHECKING) && defined(USE_ASSERT_CHECKING)) \
|| defined(CLOBBER_FREED_MEMORY)
chunksize = block->endptr - (char *) pointer;
#endif
}
else
{
block = MemoryChunkGetBlock(chunk);
Assert(GenerationBlockIsValid(block));
#if (defined(MEMORY_CONTEXT_CHECKING) && defined(USE_ASSERT_CHECKING)) \
|| defined(CLOBBER_FREED_MEMORY)
chunksize = MemoryChunkGetValue(chunk);
#endif
}
#ifdef MEMORY_CONTEXT_CHECKING
Assert(chunk->requested_size < chunksize);
if (!sentinel_ok(pointer, chunk->requested_size))
elog(WARNING, "detected write past chunk end in %s %p",
((MemoryContext) block->context)->name, chunk);
#endif
#ifdef CLOBBER_FREED_MEMORY
wipe_mem(pointer, chunksize);
#endif
#ifdef MEMORY_CONTEXT_CHECKING
chunk->requested_size = InvalidAllocSize;
#endif
block->nfree += 1;
Assert(block->nchunks > 0);
Assert(block->nfree <= block->nchunks);
Assert(block != block->context->freeblock);
if (likely(block->nfree < block->nchunks))
return;
set = block->context;
if (IsKeeperBlock(set, block) || set->block == block)
GenerationBlockMarkEmpty(block);
else if (set->freeblock == NULL)
{
GenerationBlockMarkEmpty(block);
set->freeblock = block;
}
else
GenerationBlockFree(set, block);
}
void *
GenerationRealloc(void *pointer, Size size, int flags)
{
MemoryChunk *chunk = PointerGetMemoryChunk(pointer);
GenerationContext *set;
GenerationBlock *block;
GenerationPointer newPointer;
Size oldsize;
VALGRIND_MAKE_MEM_DEFINED(chunk, Generation_CHUNKHDRSZ);
if (MemoryChunkIsExternal(chunk))
{
block = ExternalChunkGetBlock(chunk);
if (!GenerationBlockIsValid(block))
elog(ERROR, "could not find block containing chunk %p", chunk);
oldsize = block->endptr - (char *) pointer;
}
else
{
block = MemoryChunkGetBlock(chunk);
Assert(GenerationBlockIsValid(block));
oldsize = MemoryChunkGetValue(chunk);
}
set = block->context;
#ifdef MEMORY_CONTEXT_CHECKING
Assert(chunk->requested_size < oldsize);
if (!sentinel_ok(pointer, chunk->requested_size))
elog(WARNING, "detected write past chunk end in %s %p",
((MemoryContext) set)->name, chunk);
#endif
#ifdef MEMORY_CONTEXT_CHECKING
if (oldsize > size)
#else
if (oldsize >= size)
#endif
{
#ifdef MEMORY_CONTEXT_CHECKING
Size oldrequest = chunk->requested_size;
#ifdef RANDOMIZE_ALLOCATED_MEMORY
if (size > oldrequest)
randomize_mem((char *) pointer + oldrequest,
size - oldrequest);
#endif
chunk->requested_size = size;
if (size > oldrequest)
VALGRIND_MAKE_MEM_UNDEFINED((char *) pointer + oldrequest,
size - oldrequest);
else
VALGRIND_MAKE_MEM_NOACCESS((char *) pointer + size,
oldsize - size);
set_sentinel(pointer, size);
#else
VALGRIND_MAKE_MEM_NOACCESS(pointer, oldsize);
VALGRIND_MAKE_MEM_DEFINED(pointer, size);
#endif
VALGRIND_MAKE_MEM_NOACCESS(chunk, Generation_CHUNKHDRSZ);
return pointer;
}
newPointer = GenerationAlloc((MemoryContext) set, size, flags);
if (newPointer == NULL)
{
VALGRIND_MAKE_MEM_NOACCESS(chunk, Generation_CHUNKHDRSZ);
return MemoryContextAllocationFailure((MemoryContext) set, size, flags);
}
VALGRIND_MAKE_MEM_UNDEFINED(newPointer, size);
#ifdef MEMORY_CONTEXT_CHECKING
oldsize = chunk->requested_size;
#else
VALGRIND_MAKE_MEM_DEFINED(pointer, oldsize);
#endif
memcpy(newPointer, pointer, oldsize);
GenerationFree(pointer);
return newPointer;
}
MemoryContext
GenerationGetChunkContext(void *pointer)
{
MemoryChunk *chunk = PointerGetMemoryChunk(pointer);
GenerationBlock *block;
VALGRIND_MAKE_MEM_DEFINED(chunk, Generation_CHUNKHDRSZ);
if (MemoryChunkIsExternal(chunk))
block = ExternalChunkGetBlock(chunk);
else
block = (GenerationBlock *) MemoryChunkGetBlock(chunk);
VALGRIND_MAKE_MEM_NOACCESS(chunk, Generation_CHUNKHDRSZ);
Assert(GenerationBlockIsValid(block));
return &block->context->header;
}
Size
GenerationGetChunkSpace(void *pointer)
{
MemoryChunk *chunk = PointerGetMemoryChunk(pointer);
Size chunksize;
VALGRIND_MAKE_MEM_DEFINED(chunk, Generation_CHUNKHDRSZ);
if (MemoryChunkIsExternal(chunk))
{
GenerationBlock *block = ExternalChunkGetBlock(chunk);
Assert(GenerationBlockIsValid(block));
chunksize = block->endptr - (char *) pointer;
}
else
chunksize = MemoryChunkGetValue(chunk);
VALGRIND_MAKE_MEM_NOACCESS(chunk, Generation_CHUNKHDRSZ);
return Generation_CHUNKHDRSZ + chunksize;
}
bool
GenerationIsEmpty(MemoryContext context)
{
GenerationContext *set = (GenerationContext *) context;
dlist_iter iter;
Assert(GenerationIsValid(set));
dlist_foreach(iter, &set->blocks)
{
GenerationBlock *block = dlist_container(GenerationBlock, node, iter.cur);
if (block->nchunks > 0)
return false;
}
return true;
}
void
GenerationStats(MemoryContext context,
MemoryStatsPrintFunc printfunc, void *passthru,
MemoryContextCounters *totals, bool print_to_stderr)
{
GenerationContext *set = (GenerationContext *) context;
Size nblocks = 0;
Size nchunks = 0;
Size nfreechunks = 0;
Size totalspace;
Size freespace = 0;
dlist_iter iter;
Assert(GenerationIsValid(set));
totalspace = MAXALIGN(sizeof(GenerationContext));
dlist_foreach(iter, &set->blocks)
{
GenerationBlock *block = dlist_container(GenerationBlock, node, iter.cur);
nblocks++;
nchunks += block->nchunks;
nfreechunks += block->nfree;
totalspace += block->blksize;
freespace += (block->endptr - block->freeptr);
}
if (printfunc)
{
char stats_string[200];
snprintf(stats_string, sizeof(stats_string),
"%zu total in %zu blocks (%zu chunks); %zu free (%zu chunks); %zu used",
totalspace, nblocks, nchunks, freespace,
nfreechunks, totalspace - freespace);
printfunc(context, passthru, stats_string, print_to_stderr);
}
if (totals)
{
totals->nblocks += nblocks;
totals->freechunks += nfreechunks;
totals->totalspace += totalspace;
totals->freespace += freespace;
}
}
#ifdef MEMORY_CONTEXT_CHECKING
void
GenerationCheck(MemoryContext context)
{
GenerationContext *gen = (GenerationContext *) context;
const char *name = context->name;
dlist_iter iter;
Size total_allocated = 0;
dlist_foreach(iter, &gen->blocks)
{
GenerationBlock *block = dlist_container(GenerationBlock, node, iter.cur);
int nfree,
nchunks;
char *ptr;
bool has_external_chunk = false;
total_allocated += block->blksize;
if (block->nfree > block->nchunks)
elog(WARNING, "problem in Generation %s: number of free chunks %d in block %p exceeds %d allocated",
name, block->nfree, block, block->nchunks);
if (block->context != gen)
elog(WARNING, "problem in Generation %s: bogus context link in block %p",
name, block);
nfree = 0;
nchunks = 0;
ptr = ((char *) block) + Generation_BLOCKHDRSZ;
while (ptr < block->freeptr)
{
MemoryChunk *chunk = (MemoryChunk *) ptr;
GenerationBlock *chunkblock;
Size chunksize;
VALGRIND_MAKE_MEM_DEFINED(chunk, Generation_CHUNKHDRSZ);
if (MemoryChunkIsExternal(chunk))
{
chunkblock = ExternalChunkGetBlock(chunk);
chunksize = block->endptr - (char *) MemoryChunkGetPointer(chunk);
has_external_chunk = true;
}
else
{
chunkblock = MemoryChunkGetBlock(chunk);
chunksize = MemoryChunkGetValue(chunk);
}
ptr += (chunksize + Generation_CHUNKHDRSZ);
nchunks += 1;
if (chunkblock != block)
elog(WARNING, "problem in Generation %s: bogus block link in block %p, chunk %p",
name, block, chunk);
if (chunk->requested_size != InvalidAllocSize)
{
if (chunksize < chunk->requested_size ||
chunksize != MAXALIGN(chunksize))
elog(WARNING, "problem in Generation %s: bogus chunk size in block %p, chunk %p",
name, block, chunk);
Assert(chunk->requested_size < chunksize);
if (!sentinel_ok(chunk, Generation_CHUNKHDRSZ + chunk->requested_size))
elog(WARNING, "problem in Generation %s: detected write past chunk end in block %p, chunk %p",
name, block, chunk);
}
else
nfree += 1;
if (chunk->requested_size != InvalidAllocSize)
VALGRIND_MAKE_MEM_NOACCESS(chunk, Generation_CHUNKHDRSZ);
}
if (nchunks != block->nchunks)
elog(WARNING, "problem in Generation %s: number of allocated chunks %d in block %p does not match header %d",
name, nchunks, block, block->nchunks);
if (nfree != block->nfree)
elog(WARNING, "problem in Generation %s: number of free chunks %d in block %p does not match header %d",
name, nfree, block, block->nfree);
if (has_external_chunk && nchunks > 1)
elog(WARNING, "problem in Generation %s: external chunk on non-dedicated block %p",
name, block);
}
Assert(total_allocated == context->mem_allocated);
}
#endif