diff options
author | Mattes D <github@xoft.cz> | 2015-07-31 16:49:10 +0200 |
---|---|---|
committer | Mattes D <github@xoft.cz> | 2015-07-31 16:49:10 +0200 |
commit | 6e4122e551eeb41d3e950b363dd837d5586fe560 (patch) | |
tree | b5ee221d8a8e63c7d3b7868da1db19bf717a6ffd /src/AllocationPool.h | |
parent | Merge pull request #2400 from cuberite/OffloadBadChunks (diff) | |
download | cuberite-6e4122e551eeb41d3e950b363dd837d5586fe560.tar cuberite-6e4122e551eeb41d3e950b363dd837d5586fe560.tar.gz cuberite-6e4122e551eeb41d3e950b363dd837d5586fe560.tar.bz2 cuberite-6e4122e551eeb41d3e950b363dd837d5586fe560.tar.lz cuberite-6e4122e551eeb41d3e950b363dd837d5586fe560.tar.xz cuberite-6e4122e551eeb41d3e950b363dd837d5586fe560.tar.zst cuberite-6e4122e551eeb41d3e950b363dd837d5586fe560.zip |
Diffstat (limited to '')
-rw-r--r-- | src/AllocationPool.h | 129 |
1 files changed, 71 insertions, 58 deletions
diff --git a/src/AllocationPool.h b/src/AllocationPool.h index e82f9807e..4815ab414 100644 --- a/src/AllocationPool.h +++ b/src/AllocationPool.h @@ -3,6 +3,10 @@ #include <memory> + + + + template <class T> class cAllocationPool { @@ -12,100 +16,109 @@ public: public: virtual ~cStarvationCallbacks() {} - /** Is called when the reserve buffer starts to be used **/ + /** Is called when the reserve buffer starts to be used */ virtual void OnStartUsingReserve() = 0; - /** Is called once the reserve buffer has returned to normal size **/ + /** Is called once the reserve buffer has returned to normal size */ virtual void OnEndUsingReserve() = 0; /** Is called when the allocation pool is unable to allocate memory. Will be repeatedly - called if it does not free sufficient memory **/ + called if it does not free sufficient memory */ virtual void OnOutOfReserve() = 0; }; virtual ~cAllocationPool() {} - /** Allocates a pointer to T **/ + /** Allocates a pointer to T */ virtual T * Allocate() = 0; - /** Frees the pointer passed in a_ptr, invalidating it **/ + /** Frees the pointer passed in a_ptr, invalidating it */ virtual void Free(T * a_ptr) = 0; }; + + + + /** Allocates memory storing unused elements in a linked list. Keeps at least NumElementsInReserve -elements in the list unless malloc fails so that the program has a reserve to handle OOM.**/ +elements in the list unless malloc fails so that the program has a reserve to handle OOM. */ template <class T, size_t NumElementsInReserve> -class cListAllocationPool : public cAllocationPool<T> +class cListAllocationPool: + public cAllocationPool<T> { - public: +public: - cListAllocationPool(std::unique_ptr<typename cAllocationPool<T>::cStarvationCallbacks> a_Callbacks) : - m_Callbacks(std::move(a_Callbacks)) + cListAllocationPool(std::unique_ptr<typename cAllocationPool<T>::cStarvationCallbacks> a_Callbacks): + m_Callbacks(std::move(a_Callbacks)) + { + for (size_t i = 0; i < NumElementsInReserve; i++) { - for (size_t i = 0; i < NumElementsInReserve; i++) + void * space = malloc(sizeof(T)); + if (space == nullptr) { - void * space = malloc(sizeof(T)); - if (space == nullptr) - { - m_Callbacks->OnStartUsingReserve(); - break; - } - m_FreeList.push_front(space); + m_Callbacks->OnStartUsingReserve(); + break; } + m_FreeList.push_front(space); } + } - virtual ~cListAllocationPool() + + virtual ~cListAllocationPool() + { + while (!m_FreeList.empty()) { - while (!m_FreeList.empty()) - { - free (m_FreeList.front()); - m_FreeList.pop_front(); - } + free (m_FreeList.front()); + m_FreeList.pop_front(); } + } - virtual T * Allocate() override + + virtual T * Allocate() override + { + if (m_FreeList.size() <= NumElementsInReserve) { - if (m_FreeList.size() <= NumElementsInReserve) + void * space = malloc(sizeof(T)); + if (space != nullptr) { - void * space = malloc(sizeof(T)); - if (space != nullptr) - { - return new(space) T; - } - else if (m_FreeList.size() == NumElementsInReserve) - { - m_Callbacks->OnStartUsingReserve(); - } - else if (m_FreeList.empty()) - { - m_Callbacks->OnOutOfReserve(); - // Try again until the memory is avalable - return Allocate(); - } + return new(space) T; } - // placement new, used to initalize the object - T * ret = new (m_FreeList.front()) T; - m_FreeList.pop_front(); - return ret; - } - virtual void Free(T * a_ptr) override - { - if (a_ptr == nullptr) + else if (m_FreeList.size() == NumElementsInReserve) { - return; + m_Callbacks->OnStartUsingReserve(); } - // placement destruct. - a_ptr->~T(); - m_FreeList.push_front(a_ptr); - if (m_FreeList.size() == NumElementsInReserve) + else if (m_FreeList.empty()) { - m_Callbacks->OnEndUsingReserve(); + m_Callbacks->OnOutOfReserve(); + // Try again until the memory is avalable + return Allocate(); } } + // placement new, used to initalize the object + T * ret = new (m_FreeList.front()) T; + m_FreeList.pop_front(); + return ret; + } + + + virtual void Free(T * a_ptr) override + { + if (a_ptr == nullptr) + { + return; + } + // placement destruct. + a_ptr->~T(); + m_FreeList.push_front(a_ptr); + if (m_FreeList.size() == NumElementsInReserve) + { + m_Callbacks->OnEndUsingReserve(); + } + } - private: - std::list<void *> m_FreeList; - std::unique_ptr<typename cAllocationPool<T>::cStarvationCallbacks> m_Callbacks; +private: + std::list<void *> m_FreeList; + std::unique_ptr<typename cAllocationPool<T>::cStarvationCallbacks> m_Callbacks; }; |