diff options
Diffstat (limited to 'ndb/src/ndbapi/NdbImpl.hpp')
-rw-r--r-- | ndb/src/ndbapi/NdbImpl.hpp | 136 |
1 files changed, 0 insertions, 136 deletions
diff --git a/ndb/src/ndbapi/NdbImpl.hpp b/ndb/src/ndbapi/NdbImpl.hpp deleted file mode 100644 index d649b39c5eb..00000000000 --- a/ndb/src/ndbapi/NdbImpl.hpp +++ /dev/null @@ -1,136 +0,0 @@ -/* 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 NDB_IMPL_HPP -#define NDB_IMPL_HPP - -#include <ndb_global.h> -#include <Ndb.hpp> -#include <NdbOut.hpp> -#include <NdbError.hpp> -#include <NdbCondition.h> -#include <NdbReceiver.hpp> -#include <NdbOperation.hpp> -#include <kernel/ndb_limits.h> - -#include <NdbTick.h> - -#include "ndb_cluster_connection_impl.hpp" -#include "NdbDictionaryImpl.hpp" -#include "ObjectMap.hpp" - -/** - * Private parts of the Ndb object (corresponding to Ndb.hpp in public API) - */ -class NdbImpl { -public: - NdbImpl(Ndb_cluster_connection *, Ndb&); - ~NdbImpl(); - - Ndb_cluster_connection_impl &m_ndb_cluster_connection; - - NdbDictionaryImpl m_dictionary; - - // Ensure good distribution of connects - Uint32 theCurrentConnectIndex; - Ndb_cluster_connection_node_iter m_node_iter; - - NdbObjectIdMap theNdbObjectIdMap; - - Uint32 theNoOfDBnodes; // The number of DB nodes - Uint8 theDBnodes[MAX_NDB_NODES]; // The node number of the DB nodes - - // 1 indicates to release all connections to node - Uint32 the_release_ind[MAX_NDB_NODES]; - - NdbWaiter theWaiter; - - int m_optimized_node_selection; -}; - -#ifdef VM_TRACE -#define TRACE_DEBUG(x) ndbout << x << endl; -#else -#define TRACE_DEBUG(x) -#endif - -#define CHECK_STATUS_MACRO \ - {if (checkInitState() == -1) { theError.code = 4100; return -1;}} -#define CHECK_STATUS_MACRO_VOID \ - {if (checkInitState() == -1) { theError.code = 4100; return;}} -#define CHECK_STATUS_MACRO_ZERO \ - {if (checkInitState() == -1) { theError.code = 4100; return 0;}} -#define CHECK_STATUS_MACRO_NULL \ - {if (checkInitState() == -1) { theError.code = 4100; return NULL;}} - -inline -void * -Ndb::int2void(Uint32 val){ - return theImpl->theNdbObjectIdMap.getObject(val); -} - -inline -NdbReceiver * -Ndb::void2rec(void* val){ - return (NdbReceiver*)val; -} - -inline -NdbTransaction * -Ndb::void2con(void* val){ - return (NdbTransaction*)val; -} - -inline -NdbOperation* -Ndb::void2rec_op(void* val){ - return (NdbOperation*)(void2rec(val)->getOwner()); -} - -inline -NdbIndexOperation* -Ndb::void2rec_iop(void* val){ - return (NdbIndexOperation*)(void2rec(val)->getOwner()); -} - -inline -NdbTransaction * -NdbReceiver::getTransaction(){ - return ((NdbOperation*)m_owner)->theNdbCon; -} - - -inline -int -Ndb::checkInitState() -{ - theError.code = 0; - - if (theInitState != Initialised) - return -1; - return 0; -} - -Uint32 convertEndian(Uint32 Data); - -enum LockMode { - Read, - Update, - Insert, - Delete -}; - -#endif |