1 // 2 // Copyright (c) 2002-2010 The ANGLE Project Authors. All rights reserved. 3 // Use of this source code is governed by a BSD-style license that can be 4 // found in the LICENSE file. 5 // 6 7 #ifndef _POOLALLOC_INCLUDED_ 8 #define _POOLALLOC_INCLUDED_ 9 10 #ifdef _DEBUG 11 #define GUARD_BLOCKS // define to enable guard block sanity checking 12 #endif 13 14 // 15 // This header defines an allocator that can be used to efficiently 16 // allocate a large number of small requests for heap memory, with the 17 // intention that they are not individually deallocated, but rather 18 // collectively deallocated at one time. 19 // 20 // This simultaneously 21 // 22 // * Makes each individual allocation much more efficient; the 23 // typical allocation is trivial. 24 // * Completely avoids the cost of doing individual deallocation. 25 // * Saves the trouble of tracking down and plugging a large class of leaks. 26 // 27 // Individual classes can use this allocator by supplying their own 28 // new and delete methods. 29 // 30 // STL containers can use this allocator by using the pool_allocator 31 // class as the allocator (second) template argument. 32 // 33 34 #include <stddef.h> 35 #include <string.h> 36 #include <vector> 37 38 // If we are using guard blocks, we must track each indivual 39 // allocation. If we aren't using guard blocks, these 40 // never get instantiated, so won't have any impact. 41 // 42 43 class TAllocation { 44 public: 45 TAllocation(size_t size, unsigned char* mem, TAllocation* prev = 0) : size(size)46 size(size), mem(mem), prevAlloc(prev) { 47 // Allocations are bracketed: 48 // [allocationHeader][initialGuardBlock][userData][finalGuardBlock] 49 // This would be cleaner with if (guardBlockSize)..., but that 50 // makes the compiler print warnings about 0 length memsets, 51 // even with the if() protecting them. 52 #ifdef GUARD_BLOCKS 53 memset(preGuard(), guardBlockBeginVal, guardBlockSize); 54 memset(data(), userDataFill, size); 55 memset(postGuard(), guardBlockEndVal, guardBlockSize); 56 #endif 57 } 58 check()59 void check() const { 60 checkGuardBlock(preGuard(), guardBlockBeginVal, "before"); 61 checkGuardBlock(postGuard(), guardBlockEndVal, "after"); 62 } 63 64 void checkAllocList() const; 65 66 // Return total size needed to accomodate user buffer of 'size', 67 // plus our tracking data. allocationSize(size_t size)68 inline static size_t allocationSize(size_t size) { 69 return size + 2 * guardBlockSize + headerSize(); 70 } 71 72 // Offset from surrounding buffer to get to user data buffer. offsetAllocation(unsigned char * m)73 inline static unsigned char* offsetAllocation(unsigned char* m) { 74 return m + guardBlockSize + headerSize(); 75 } 76 77 private: 78 void checkGuardBlock(unsigned char* blockMem, unsigned char val, const char* locText) const; 79 80 // Find offsets to pre and post guard blocks, and user data buffer preGuard()81 unsigned char* preGuard() const { return mem + headerSize(); } data()82 unsigned char* data() const { return preGuard() + guardBlockSize; } postGuard()83 unsigned char* postGuard() const { return data() + size; } 84 85 size_t size; // size of the user data area 86 unsigned char* mem; // beginning of our allocation (pts to header) 87 TAllocation* prevAlloc; // prior allocation in the chain 88 89 // Support MSVC++ 6.0 90 const static unsigned char guardBlockBeginVal; 91 const static unsigned char guardBlockEndVal; 92 const static unsigned char userDataFill; 93 94 const static size_t guardBlockSize; 95 #ifdef GUARD_BLOCKS headerSize()96 inline static size_t headerSize() { return sizeof(TAllocation); } 97 #else headerSize()98 inline static size_t headerSize() { return 0; } 99 #endif 100 }; 101 102 // 103 // There are several stacks. One is to track the pushing and popping 104 // of the user, and not yet implemented. The others are simply a 105 // repositories of free pages or used pages. 106 // 107 // Page stacks are linked together with a simple header at the beginning 108 // of each allocation obtained from the underlying OS. Multi-page allocations 109 // are returned to the OS. Individual page allocations are kept for future 110 // re-use. 111 // 112 // The "page size" used is not, nor must it match, the underlying OS 113 // page size. But, having it be about that size or equal to a set of 114 // pages is likely most optimal. 115 // 116 class TPoolAllocator { 117 public: 118 TPoolAllocator(int growthIncrement = 8*1024, int allocationAlignment = 16); 119 120 // 121 // Don't call the destructor just to free up the memory, call pop() 122 // 123 ~TPoolAllocator(); 124 125 // 126 // Call push() to establish a new place to pop memory too. Does not 127 // have to be called to get things started. 128 // 129 void push(); 130 131 // 132 // Call pop() to free all memory allocated since the last call to push(), 133 // or if no last call to push, frees all memory since first allocation. 134 // 135 void pop(); 136 137 // 138 // Call popAll() to free all memory allocated. 139 // 140 void popAll(); 141 142 // 143 // Call allocate() to actually acquire memory. Returns 0 if no memory 144 // available, otherwise a properly aligned pointer to 'numBytes' of memory. 145 // 146 void* allocate(size_t numBytes); 147 148 // 149 // There is no deallocate. The point of this class is that 150 // deallocation can be skipped by the user of it, as the model 151 // of use is to simultaneously deallocate everything at once 152 // by calling pop(), and to not have to solve memory leak problems. 153 // 154 155 protected: 156 friend struct tHeader; 157 158 struct tHeader { tHeadertHeader159 tHeader(tHeader* nextPage, size_t pageCount) : 160 nextPage(nextPage), 161 pageCount(pageCount) 162 #ifdef GUARD_BLOCKS 163 , lastAllocation(0) 164 #endif 165 { } 166 ~tHeadertHeader167 ~tHeader() { 168 #ifdef GUARD_BLOCKS 169 if (lastAllocation) 170 lastAllocation->checkAllocList(); 171 #endif 172 } 173 174 tHeader* nextPage; 175 size_t pageCount; 176 #ifdef GUARD_BLOCKS 177 TAllocation* lastAllocation; 178 #endif 179 }; 180 181 struct tAllocState { 182 size_t offset; 183 tHeader* page; 184 }; 185 typedef std::vector<tAllocState> tAllocStack; 186 187 // Track allocations if and only if we're using guard blocks initializeAllocation(tHeader * block,unsigned char * memory,size_t numBytes)188 void* initializeAllocation(tHeader* block, unsigned char* memory, size_t numBytes) { 189 #ifdef GUARD_BLOCKS 190 new(memory) TAllocation(numBytes, memory, block->lastAllocation); 191 block->lastAllocation = reinterpret_cast<TAllocation*>(memory); 192 #endif 193 // This is optimized entirely away if GUARD_BLOCKS is not defined. 194 return TAllocation::offsetAllocation(memory); 195 } 196 197 size_t pageSize; // granularity of allocation from the OS 198 size_t alignment; // all returned allocations will be aligned at 199 // this granularity, which will be a power of 2 200 size_t alignmentMask; 201 size_t headerSkip; // amount of memory to skip to make room for the 202 // header (basically, size of header, rounded 203 // up to make it aligned 204 size_t currentPageOffset; // next offset in top of inUseList to allocate from 205 tHeader* freeList; // list of popped memory 206 tHeader* inUseList; // list of all memory currently being used 207 tAllocStack stack; // stack of where to allocate from, to partition pool 208 209 int numCalls; // just an interesting statistic 210 size_t totalBytes; // just an interesting statistic 211 private: 212 TPoolAllocator& operator=(const TPoolAllocator&); // dont allow assignment operator 213 TPoolAllocator(const TPoolAllocator&); // dont allow default copy constructor 214 }; 215 216 217 // 218 // There could potentially be many pools with pops happening at 219 // different times. But a simple use is to have a global pop 220 // with everyone using the same global allocator. 221 // 222 extern TPoolAllocator& GetGlobalPoolAllocator(); 223 extern void SetGlobalPoolAllocator(TPoolAllocator* poolAllocator); 224 #define GlobalPoolAllocator GetGlobalPoolAllocator() 225 226 struct TThreadGlobalPools 227 { 228 TPoolAllocator* globalPoolAllocator; 229 }; 230 231 // 232 // This STL compatible allocator is intended to be used as the allocator 233 // parameter to templatized STL containers, like vector and map. 234 // 235 // It will use the pools for allocation, and not 236 // do any deallocation, but will still do destruction. 237 // 238 template<class T> 239 class pool_allocator { 240 public: 241 typedef size_t size_type; 242 typedef ptrdiff_t difference_type; 243 typedef T* pointer; 244 typedef const T* const_pointer; 245 typedef T& reference; 246 typedef const T& const_reference; 247 typedef T value_type; 248 249 template<class Other> 250 struct rebind { 251 typedef pool_allocator<Other> other; 252 }; address(reference x)253 pointer address(reference x) const { return &x; } address(const_reference x)254 const_pointer address(const_reference x) const { return &x; } 255 pool_allocator()256 pool_allocator() : allocator(GlobalPoolAllocator) { } pool_allocator(TPoolAllocator & a)257 pool_allocator(TPoolAllocator& a) : allocator(a) { } pool_allocator(const pool_allocator<T> & p)258 pool_allocator(const pool_allocator<T>& p) : allocator(p.allocator) { } 259 260 template<class Other> pool_allocator(const pool_allocator<Other> & p)261 pool_allocator(const pool_allocator<Other>& p) : allocator(p.getAllocator()) { } 262 263 #if defined(__SUNPRO_CC) && !defined(_RWSTD_ALLOCATOR) 264 // libCStd on some platforms have a different allocate/deallocate interface. 265 // Caller pre-bakes sizeof(T) into 'n' which is the number of bytes to be 266 // allocated, not the number of elements. allocate(size_type n)267 void* allocate(size_type n) { 268 return getAllocator().allocate(n); 269 } allocate(size_type n,const void *)270 void* allocate(size_type n, const void*) { 271 return getAllocator().allocate(n); 272 } deallocate(void *,size_type)273 void deallocate(void*, size_type) {} 274 #else allocate(size_type n)275 pointer allocate(size_type n) { 276 return reinterpret_cast<pointer>(getAllocator().allocate(n * sizeof(T))); 277 } allocate(size_type n,const void *)278 pointer allocate(size_type n, const void*) { 279 return reinterpret_cast<pointer>(getAllocator().allocate(n * sizeof(T))); 280 } deallocate(pointer,size_type)281 void deallocate(pointer, size_type) {} 282 #endif // _RWSTD_ALLOCATOR 283 construct(pointer p,const T & val)284 void construct(pointer p, const T& val) { new ((void *)p) T(val); } destroy(pointer p)285 void destroy(pointer p) { p->T::~T(); } 286 287 bool operator==(const pool_allocator& rhs) const { return &getAllocator() == &rhs.getAllocator(); } 288 bool operator!=(const pool_allocator& rhs) const { return &getAllocator() != &rhs.getAllocator(); } 289 max_size()290 size_type max_size() const { return static_cast<size_type>(-1) / sizeof(T); } max_size(int size)291 size_type max_size(int size) const { return static_cast<size_type>(-1) / size; } 292 setAllocator(TPoolAllocator * a)293 void setAllocator(TPoolAllocator* a) { allocator = *a; } getAllocator()294 TPoolAllocator& getAllocator() const { return allocator; } 295 296 protected: 297 TPoolAllocator& allocator; 298 }; 299 300 #endif // _POOLALLOC_INCLUDED_