diff options
Diffstat (limited to 'storage/ndb/src/kernel/vm/Pool.hpp')
| -rw-r--r-- | storage/ndb/src/kernel/vm/Pool.hpp | 341 |
1 files changed, 0 insertions, 341 deletions
diff --git a/storage/ndb/src/kernel/vm/Pool.hpp b/storage/ndb/src/kernel/vm/Pool.hpp deleted file mode 100644 index 47b2e0d8892..00000000000 --- a/storage/ndb/src/kernel/vm/Pool.hpp +++ /dev/null @@ -1,341 +0,0 @@ -/* Copyright (c) 2003, 2006, 2007 MySQL AB - Use is subject to license terms - - This program is free software; you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation; version 2 of the License. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - GNU General Public License for more details. - - You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA */ - -#ifndef NDB_POOL_HPP -#define NDB_POOL_HPP - -#include <ndb_global.h> -#include <kernel_types.h> - -/** - * Type bits - * - * Type id is 11 bits record type, and 5 bits resource id - * -> 2048 different kind of records and 32 different resource groups - * - * Resource id is used to handle configuration parameters - * - * see blocks/records_types.hpp - */ -#define RG_BITS 5 -#define RG_MASK ((1 << RG_BITS) - 1) -#define MAKE_TID(TID,RG) ((TID << RG_BITS) | RG) - -/** - * Page bits - */ -#define POOL_RECORD_BITS 13 -#define POOL_RECORD_MASK ((1 << POOL_RECORD_BITS) - 1) - -/** - * Record_info - * - */ -struct Record_info -{ - Uint16 m_size; - Uint16 m_type_id; - Uint16 m_offset_next_pool; - Uint16 m_offset_magic; -}; - -/** - * Resource_limit - */ -struct Resource_limit -{ - Uint32 m_min; - Uint32 m_max; - Uint32 m_curr; - Uint32 m_resource_id; -}; - -struct Pool_context -{ - Pool_context() {} - class SimulatedBlock* m_block; - - /** - * Get mem root - */ - void* get_memroot(); - - /** - * Alloc consekutive pages - * - * @param i : out : i value of first page - * @return : pointer to first page (NULL if failed) - * - * Will handle resource limit - */ - void* alloc_page(Uint32 type_id, Uint32 *i); - - /** - * Release pages - * - * @param i : in : i value of first page - * @param p : in : pointer to first page - */ - void release_page(Uint32 type_id, Uint32 i); - - /** - * Alloc consekutive pages - * - * @param cnt : in/out : no of requested pages, - * return no of allocated (undefined return NULL) - * out will never be > in - * @param i : out : i value of first page - * @param min : in : will never allocate less than min - * @return : pointer to first page (NULL if failed) - * - * Will handle resource limit - */ - void* alloc_pages(Uint32 type_id, Uint32 *i, Uint32 *cnt, Uint32 min =1); - - /** - * Release pages - * - * @param i : in : i value of first page - * @param p : in : pointer to first page - * @param cnt : in : no of pages to release - */ - void release_pages(Uint32 type_id, Uint32 i, Uint32 cnt); - - /** - * Abort - */ - void handleAbort(int code, const char* msg); -}; - -template <typename T> -struct Ptr -{ - T * p; - Uint32 i; - inline bool isNull() const { return i == RNIL; } - inline void setNull() { i = RNIL; } -}; - -template <typename T> -struct ConstPtr -{ - const T * p; - Uint32 i; - inline bool isNull() const { return i == RNIL; } - inline void setNull() { i = RNIL; } -}; - -#ifdef XX_DOCUMENTATION_XX -/** - * Any pool should implement the following - */ -struct PoolImpl -{ - Pool_context m_ctx; - Record_info m_record_info; - - void init(const Record_info& ri, const Pool_context& pc); - void init(const Record_info& ri, const Pool_context& pc); - - bool seize(Ptr<void>&); - void release(Ptr<void>); - void * getPtr(Uint32 i); -}; -#endif - -template <typename T, typename P> -class RecordPool { -public: - RecordPool(); - ~RecordPool(); - - void init(Uint32 type_id, const Pool_context& pc); - void wo_pool_init(Uint32 type_id, const Pool_context& pc); - - /** - * Update p value for ptr according to i value - */ - void getPtr(Ptr<T> &); - void getPtr(ConstPtr<T> &) const; - - /** - * Get pointer for i value - */ - T * getPtr(Uint32 i); - const T * getConstPtr(Uint32 i) const; - - /** - * Update p & i value for ptr according to <b>i</b> value - */ - void getPtr(Ptr<T> &, Uint32 i); - void getPtr(ConstPtr<T> &, Uint32 i) const; - - /** - * Allocate an object from pool - update Ptr - * - * Return i - */ - bool seize(Ptr<T> &); - - /** - * Return an object to pool - */ - void release(Uint32 i); - - /** - * Return an object to pool - */ - void release(Ptr<T>); -private: - P m_pool; -}; - -template <typename T, typename P> -inline -RecordPool<T, P>::RecordPool() -{ -} - -template <typename T, typename P> -inline -void -RecordPool<T, P>::init(Uint32 type_id, const Pool_context& pc) -{ - T tmp; - const char * off_base = (char*)&tmp; - const char * off_next = (char*)&tmp.nextPool; - const char * off_magic = (char*)&tmp.m_magic; - - Record_info ri; - ri.m_size = sizeof(T); - ri.m_offset_next_pool = Uint32(off_next - off_base); - ri.m_offset_magic = Uint32(off_magic - off_base); - ri.m_type_id = type_id; - m_pool.init(ri, pc); -} - -template <typename T, typename P> -inline -void -RecordPool<T, P>::wo_pool_init(Uint32 type_id, const Pool_context& pc) -{ - T tmp; - const char * off_base = (char*)&tmp; - const char * off_magic = (char*)&tmp.m_magic; - - Record_info ri; - ri.m_size = sizeof(T); - ri.m_offset_next_pool = 0; - ri.m_offset_magic = Uint32(off_magic - off_base); - ri.m_type_id = type_id; - m_pool.init(ri, pc); -} - -template <typename T, typename P> -inline -RecordPool<T, P>::~RecordPool() -{ -} - - -template <typename T, typename P> -inline -void -RecordPool<T, P>::getPtr(Ptr<T> & ptr) -{ - ptr.p = static_cast<T*>(m_pool.getPtr(ptr.i)); -} - -template <typename T, typename P> -inline -void -RecordPool<T, P>::getPtr(ConstPtr<T> & ptr) const -{ - ptr.p = static_cast<const T*>(m_pool.getPtr(ptr.i)); -} - -template <typename T, typename P> -inline -void -RecordPool<T, P>::getPtr(Ptr<T> & ptr, Uint32 i) -{ - ptr.i = i; - ptr.p = static_cast<T*>(m_pool.getPtr(ptr.i)); -} - -template <typename T, typename P> -inline -void -RecordPool<T, P>::getPtr(ConstPtr<T> & ptr, Uint32 i) const -{ - ptr.i = i; - ptr.p = static_cast<const T*>(m_pool.getPtr(ptr.i)); -} - -template <typename T, typename P> -inline -T * -RecordPool<T, P>::getPtr(Uint32 i) -{ - return static_cast<T*>(m_pool.getPtr(i)); -} - -template <typename T, typename P> -inline -const T * -RecordPool<T, P>::getConstPtr(Uint32 i) const -{ - return static_cast<const T*>(m_pool.getPtr(i)); -} - -template <typename T, typename P> -inline -bool -RecordPool<T, P>::seize(Ptr<T> & ptr) -{ - Ptr<void> tmp; - bool ret = m_pool.seize(tmp); - if(likely(ret)) - { - ptr.i = tmp.i; - ptr.p = static_cast<T*>(tmp.p); - } - return ret; -} - -template <typename T, typename P> -inline -void -RecordPool<T, P>::release(Uint32 i) -{ - Ptr<void> ptr; - ptr.i = i; - ptr.p = m_pool.getPtr(i); - m_pool.release(ptr); -} - -template <typename T, typename P> -inline -void -RecordPool<T, P>::release(Ptr<T> ptr) -{ - Ptr<void> tmp; - tmp.i = ptr.i; - tmp.p = ptr.p; - m_pool.release(tmp); -} - -#endif |