diff options
Diffstat (limited to 'storage/ndb/src/ndbapi/DictCache.hpp')
-rw-r--r-- | storage/ndb/src/ndbapi/DictCache.hpp | 92 |
1 files changed, 92 insertions, 0 deletions
diff --git a/storage/ndb/src/ndbapi/DictCache.hpp b/storage/ndb/src/ndbapi/DictCache.hpp new file mode 100644 index 00000000000..58c08a93e61 --- /dev/null +++ b/storage/ndb/src/ndbapi/DictCache.hpp @@ -0,0 +1,92 @@ +/* Copyright (C) 2003 MySQL AB + + 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; either version 2 of the License, or + (at your option) any later version. + + 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ + +#ifndef DictCache_H +#define DictCache_H + +#include <ndb_types.h> +#include <kernel_types.h> +#include <NdbError.hpp> +#include <BaseString.hpp> +#include <Vector.hpp> +#include <UtilBuffer.hpp> +#include <NdbDictionary.hpp> +#include <Ndb.hpp> +#include <NdbCondition.h> +#include "NdbLinHash.hpp" + +class Ndb_local_table_info { +public: + static Ndb_local_table_info *create(NdbTableImpl *table_impl, Uint32 sz=0); + static void destroy(Ndb_local_table_info *); + NdbTableImpl *m_table_impl; + Uint64 m_local_data[1]; +private: + Ndb_local_table_info(NdbTableImpl *table_impl); + ~Ndb_local_table_info(); +}; + +/** + * A non thread safe dict cache + */ +class LocalDictCache { +public: + LocalDictCache(); + ~LocalDictCache(); + + Ndb_local_table_info * get(const char * name); + + void put(const char * name, Ndb_local_table_info *); + void drop(const char * name); + + NdbLinHash<Ndb_local_table_info> m_tableHash; // On name +}; + +/** + * A thread safe dict cache + */ +class GlobalDictCache : public NdbLockable { +public: + GlobalDictCache(); + ~GlobalDictCache(); + + NdbTableImpl * get(const char * name); + + NdbTableImpl* put(const char * name, NdbTableImpl *); + void drop(NdbTableImpl *); + void release(NdbTableImpl *); +public: + enum Status { + OK = 0, + DROPPED = 1, + RETREIVING = 2 + }; + +private: + struct TableVersion { + Uint32 m_version; + Uint32 m_refCount; + NdbTableImpl * m_impl; + Status m_status; + }; + + NdbLinHash<Vector<TableVersion> > m_tableHash; + NdbCondition * m_waitForTableCondition; +}; + +#endif + + |