ForwardAllocator.hxx

Go to the documentation of this file.

 
#ifndef _UTILS_FORWARDALLOCATOR_HXX_
#define _UTILS_FORWARDALLOCATOR_HXX_
 
#include <cstdint>
 
#include "os/OS.hxx"
#include "utils/Buffer.hxx"
#include "utils/SimpleQueue.hxx"
 
class DynamicPool;
 
class ForwardAllocator
{
public:
    static constexpr size_t BLOCK_BYTE_SIZE = 1024;
 
    void *allocate(size_t size, size_t align);
 
    ForwardAllocator();
    ~ForwardAllocator();
 
#ifdef GTEST
    static void TEST_recreate_pool();
#endif
 
private:
    typedef uint64_t primitive_t;
    typedef primitive_t AlignedPayload[BLOCK_BYTE_SIZE / sizeof(primitive_t)];
    static_assert(sizeof(AlignedPayload) == BLOCK_BYTE_SIZE,
        "aligned payload size mismatch");
    typedef Buffer<AlignedPayload> BufferType;
 
    uint8_t *head_ptr()
    {
        if (allocatedBlocks_.empty())
        {
            return nullptr;
        }
        return (uint8_t *)allocatedBlocks_.front()->data();
    }
 
    TypedQueue<BufferType> allocatedBlocks_;
    size_t offsetInLast_ {BLOCK_BYTE_SIZE + 1};
 
public:
    size_t allocSize_ {0};
    size_t allocWasted_ {0};
 
private:
    OSMutex lock_;
    static DynamicPool *kbytePool_;
};
 
#endif // _UTILS_FORWARDALLOCATOR_HXX_