#include <Ndb.hpp>
Classes | |
| struct | Key_part_ptr |
| struct | PartitionSpec |
| struct | PartitionSpec_v1 |
Public Member Functions | |
| Uint32 | get_cond_wait_index () |
| void | set_cond_wait_index (Uint32 index) |
General | |
| Ndb (Ndb_cluster_connection *ndb_cluster_connection, const char *aCatalogName="", const char *aSchemaName="def") | |
| ~Ndb () | |
| const char * | getDatabaseName () const |
| int | setDatabaseName (const char *aDatabaseName) |
| const char * | getDatabaseSchemaName () const |
| int | setDatabaseSchemaName (const char *aDatabaseSchemaName) |
| int | init (int maxNoOfTransactions=4) |
| int | waitUntilReady (int timeout=60) |
Meta Information | |
| class NdbDictionary::Dictionary * | getDictionary () const |
Event subscriptions | |
| NdbEventOperation * | createEventOperation (const char *eventName) |
| int | dropEventOperation (NdbEventOperation *eventOp) |
| int | pollEvents (int aMillisecondNumber, Uint64 *latestGCI=0) |
| NdbEventOperation * | nextEvent () |
| bool | isConsistent (Uint64 &gci) |
| bool | isConsistentGCI (Uint64 gci) |
| const NdbEventOperation * | getGCIEventOperations (Uint32 *iter, Uint32 *event_types) |
Error Handling | |
| const NdbError & | getNdbError () const |
| const NdbError & | getNdbError (int errorCode) |
Private Types | |
| enum | InitType { NotConstructed, NotInitialised, StartingInit, Initialised, InitConfigError } |
Private Member Functions | |
| void | cond_signal () |
| void | setup (Ndb_cluster_connection *ndb_cluster_connection, const char *aCatalogName, const char *aSchemaName) |
| void | connected (Uint32 block_reference) |
| void | report_node_connected (Uint32 nodeId) |
| NdbTransaction * | startTransactionLocal (Uint32 aPrio, Uint32 aFragmentId) |
| int | NDB_connect (Uint32 tNode) |
| NdbTransaction * | doConnect (Uint32 nodeId) |
| void | doDisconnect () |
| NdbReceiver * | getNdbScanRec () |
| NdbLabel * | getNdbLabel () |
| NdbBranch * | getNdbBranch () |
| NdbSubroutine * | getNdbSubroutine () |
| NdbCall * | getNdbCall () |
| NdbApiSignal * | getSignal () |
| NdbRecAttr * | getRecAttr () |
| NdbOperation * | getOperation () |
| NdbIndexScanOperation * | getScanOperation () |
| NdbIndexOperation * | getIndexOperation () |
| NdbBlob * | getNdbBlob () |
| void | releaseSignal (NdbApiSignal *anApiSignal) |
| void | releaseSignals (Uint32, NdbApiSignal *, NdbApiSignal *) |
| void | releaseSignalsInList (NdbApiSignal **pList) |
| void | releaseNdbScanRec (NdbReceiver *aNdbScanRec) |
| void | releaseNdbLabel (NdbLabel *anNdbLabel) |
| void | releaseNdbBranch (NdbBranch *anNdbBranch) |
| void | releaseNdbSubroutine (NdbSubroutine *anNdbSubroutine) |
| void | releaseNdbCall (NdbCall *anNdbCall) |
| void | releaseRecAttr (NdbRecAttr *aRecAttr) |
| void | releaseOperation (NdbOperation *anOperation) |
| void | releaseScanOperation (NdbIndexScanOperation *) |
| void | releaseNdbBlob (NdbBlob *aBlob) |
| void | check_send_timeout () |
| void | remove_sent_list (Uint32) |
| Uint32 | insert_completed_list (NdbTransaction *) |
| Uint32 | insert_sent_list (NdbTransaction *) |
| void | handleReceivedSignal (NdbApiSignal *anApiSignal, struct LinearSectionPtr ptr[3]) |
| int | sendRecSignal (Uint16 aNodeId, Uint32 aWaitState, NdbApiSignal *aSignal, Uint32 nodeSequence, Uint32 *ret_conn_seq=0) |
| void | RestartGCI (int aRestartGCI) |
| int | getBlockNumber () |
| int | createConIdleList (int aNrOfCon) |
| int | createOpIdleList (int nrOfOp) |
| void | freeOperation () |
| void | freeScanOperation () |
| void | freeIndexOperation () |
| void | freeNdbCon () |
| void | freeSignal () |
| void | freeRecAttr () |
| void | freeNdbLabel () |
| void | freeNdbBranch () |
| void | freeNdbSubroutine () |
| void | freeNdbCall () |
| void | freeNdbScanRec () |
| void | freeNdbBlob () |
| NdbTransaction * | getNdbCon () |
| NdbTransaction * | getConnectedNdbTransaction (Uint32 nodeId) |
| void | releaseConnectToNdb (NdbTransaction *) |
| void | releaseNdbCon (NdbTransaction *) |
| int | checkInitState () |
| void | report_node_failure (Uint32 node_id) |
| void | report_node_failure_completed (Uint32 node_id) |
| void | checkFailedNode () |
| int | NDB_connect () |
| void | releaseTransactionArrays () |
| Uint32 | pollCompleted (NdbTransaction **aCopyArray) |
| void | sendPrepTrans (int forceSend) |
| void | reportCallback (NdbTransaction **aCopyArray, Uint32 aNoOfComplTrans) |
| int | poll_trans (int milliSecs, int noOfEventsToWaitFor, PollGuard *pg) |
| void | waitCompletedTransactions (int milliSecs, int noOfEventsToWaitFor, PollGuard *pg) |
| void | completedTransaction (NdbTransaction *aTransaction) |
| void | completedScanTransaction (NdbTransaction *aTransaction) |
| void | abortTransactionsAfterNodeFailure (Uint16 aNodeId) |
| const char * | externalizeTableName (const char *internalTableName) |
| const BaseString | internalize_table_name (const char *external_name) const |
| const char * | externalizeIndexName (const char *internalIndexName) |
| const BaseString | old_internalize_index_name (const NdbTableImpl *table, const char *external_name) const |
| const BaseString | internalize_index_name (const NdbTableImpl *table, const char *external_name) const |
| void * | int2void (Uint32 val) |
| NdbReceiver * | void2rec (void *val) |
| NdbTransaction * | void2con (void *val) |
| NdbOperation * | void2rec_op (void *val) |
| NdbIndexOperation * | void2rec_iop (void *val) |
| Uint64 | allocate_transaction_id () |
Static Private Member Functions | |
| static const char * | externalizeTableName (const char *internalTableName, bool fullyQualifiedNames) |
| static const char * | externalizeIndexName (const char *internalIndexName, bool fullyQualifiedNames) |
| static const BaseString | getDatabaseFromInternalName (const char *internalName) |
| static const BaseString | getSchemaFromInternalName (const char *internalName) |
| static void | executeMessage (void *, NdbApiSignal *, struct LinearSectionPtr ptr[3]) |
| static void | statusMessage (void *, Uint32, bool, bool) |
Private Attributes | |
| Uint32 | cond_wait_index |
| Ndb * | cond_signal_ndb |
| NdbTransaction ** | thePreparedTransactionsArray |
| NdbTransaction ** | theSentTransactionsArray |
| NdbTransaction ** | theCompletedTransactionsArray |
| Uint32 | theNoOfPreparedTransactions |
| Uint32 | theNoOfSentTransactions |
| Uint32 | theNoOfCompletedTransactions |
| Uint32 | theRemainingStartTransactions |
| Uint32 | theMaxNoOfTransactions |
| Uint32 | theMinNoOfEventsToWakeUp |
| Uint32 | theNextConnectNode |
| bool | fullyQualifiedNames |
| class NdbImpl * | theImpl |
| class NdbDictionaryImpl * | theDictionary |
| class NdbEventBuffer * | theEventBuffer |
| NdbTransaction * | theTransactionList |
| NdbTransaction ** | theConnectionArray |
| Uint32 | theMyRef |
| Uint32 | theNode |
| Uint64 | the_last_check_time |
| Uint64 | theFirstTransId |
| const NdbDictionary::Table * | m_sys_tab_0 |
| Uint32 | theRestartGCI |
| NdbError | theError |
| Int32 | theNdbBlockNumber |
| enum Ndb::InitType | theInitState |
| NdbApiSignal * | theCommitAckSignal |
Starting and Closing Transactions | |
| NdbTransaction * | startTransaction (const NdbDictionary::Table *table=0, const char *keyData=0, Uint32 keyLen=0) |
| NdbTransaction * | startTransaction (const NdbDictionary::Table *table, const struct Key_part_ptr *keyData, void *xfrmbuf=0, Uint32 xfrmbuflen=0) |
| NdbTransaction * | startTransaction (const NdbDictionary::Table *table, Uint32 partitionId) |
| void | closeTransaction (NdbTransaction *) |
| static int | computeHash (Uint32 *hashvalueptr, const NdbDictionary::Table *, const struct Key_part_ptr *keyData, void *xfrmbuf=0, Uint32 xfrmbuflen=0) |
Always start your application program by creating an Ndb object. By using several Ndb objects it is possible to design a multi-threaded application, but note that Ndb objects cannot be shared by several threads. Different threads should use different Ndb objects. A thread might however use multiple Ndb objects. Currently there is a limit of maximum 128 Ndb objects per application process.
The Ndb object is multi-thread safe in the following manner. Each Ndb object can ONLY be handled in one thread. If an Ndb object is handed over to another thread then the application must ensure that a memory barrier is used to ensure that the new thread see all updates performed by the previous thread. Semaphores, mutexes and so forth are easy ways of issuing memory barriers without having to bother about the memory barrier concept.
enum Ndb::InitType [private] |
| Ndb::Ndb | ( | Ndb_cluster_connection * | ndb_cluster_connection, | |
| const char * | aCatalogName = "", |
|||
| const char * | aSchemaName = "def" | |||
| ) |
The Ndb object represents a connection to a database.
| ndb_cluster_connection | is a connection to the cluster containing the database to be used | |
| aCatalogName | is the name of the catalog to be used. |
| aSchemaName | is the name of the schema you want to use. |
| Ndb::~Ndb | ( | ) |
| void Ndb::abortTransactionsAfterNodeFailure | ( | Uint16 | aNodeId | ) | [private] |
| Uint64 Ndb::allocate_transaction_id | ( | ) | [private] |
| void Ndb::check_send_timeout | ( | ) | [private] |
| void Ndb::checkFailedNode | ( | ) | [private] |
| int Ndb::checkInitState | ( | ) | [private] |
| void Ndb::closeTransaction | ( | NdbTransaction * | ) |
Close a transaction.
| void Ndb::completedScanTransaction | ( | NdbTransaction * | aTransaction | ) | [private] |
| void Ndb::completedTransaction | ( | NdbTransaction * | aTransaction | ) | [private] |
| static int Ndb::computeHash | ( | Uint32 * | hashvalueptr, | |
| const NdbDictionary::Table * | , | |||
| const struct Key_part_ptr * | keyData, | |||
| void * | xfrmbuf = 0, |
|||
| Uint32 | xfrmbuflen = 0 | |||
| ) | [static] |
Compute distribution hash value given table/keys
| hashvalueptr | - OUT, is set to hashvalue if return value is 0 | |
| table | Pointer to table object | |
| keyData | Null-terminated array of pointers to keyParts that is part of distribution key. Length of resp. keyPart will be read from metadata and checked against passed value | |
| xfrmbuf | Pointer to temporary buffer that will be used to calculate hashvalue | |
| xfrmbuflen | Lengh of buffer |
| void Ndb::cond_signal | ( | ) | [private] |
| void Ndb::connected | ( | Uint32 | block_reference | ) | [private] |
| int Ndb::createConIdleList | ( | int | aNrOfCon | ) | [private] |
| NdbEventOperation* Ndb::createEventOperation | ( | const char * | eventName | ) |
Create a subcription to an event defined in the database
| eventName | unique identifier of the event |
| int Ndb::createOpIdleList | ( | int | nrOfOp | ) | [private] |
| NdbTransaction* Ndb::doConnect | ( | Uint32 | nodeId | ) | [private] |
| void Ndb::doDisconnect | ( | ) | [private] |
| int Ndb::dropEventOperation | ( | NdbEventOperation * | eventOp | ) |
Drop a subscription to an event
| eventOp | Event operation |
| static void Ndb::executeMessage | ( | void * | , | |
| NdbApiSignal * | , | |||
| struct LinearSectionPtr | ptr[3] | |||
| ) | [static, private] |
| const char* Ndb::externalizeIndexName | ( | const char * | internalIndexName | ) | [private] |
| static const char* Ndb::externalizeIndexName | ( | const char * | internalIndexName, | |
| bool | fullyQualifiedNames | |||
| ) | [static, private] |
| const char* Ndb::externalizeTableName | ( | const char * | internalTableName | ) | [private] |
| static const char* Ndb::externalizeTableName | ( | const char * | internalTableName, | |
| bool | fullyQualifiedNames | |||
| ) | [static, private] |
| void Ndb::freeIndexOperation | ( | ) | [private] |
| void Ndb::freeNdbBlob | ( | ) | [private] |
| void Ndb::freeNdbBranch | ( | ) | [private] |
| void Ndb::freeNdbCall | ( | ) | [private] |
| void Ndb::freeNdbCon | ( | ) | [private] |
| void Ndb::freeNdbLabel | ( | ) | [private] |
| void Ndb::freeNdbScanRec | ( | ) | [private] |
| void Ndb::freeNdbSubroutine | ( | ) | [private] |
| void Ndb::freeOperation | ( | ) | [private] |
| void Ndb::freeRecAttr | ( | ) | [private] |
| void Ndb::freeScanOperation | ( | ) | [private] |
| void Ndb::freeSignal | ( | ) | [private] |
| Uint32 Ndb::get_cond_wait_index | ( | ) | [inline] |
| int Ndb::getBlockNumber | ( | ) | [private] |
| NdbTransaction* Ndb::getConnectedNdbTransaction | ( | Uint32 | nodeId | ) | [private] |
Get a connected NdbTransaction to nodeId Returns NULL if none found
| static const BaseString Ndb::getDatabaseFromInternalName | ( | const char * | internalName | ) | [static, private] |
| const char* Ndb::getDatabaseName | ( | ) | const |
The current database name can be fetched by getDatabaseName.
| const char* Ndb::getDatabaseSchemaName | ( | ) | const |
The current database schema name can be fetched by getDatabaseSchemaName.
| class NdbDictionary::Dictionary* Ndb::getDictionary | ( | ) | const |
Get an object for retrieving or manipulating database schema information
| const NdbEventOperation* Ndb::getGCIEventOperations | ( | Uint32 * | iter, | |
| Uint32 * | event_types | |||
| ) |
Iterate over distinct event operations which are part of current GCI. Valid after nextEvent. Used to get summary information for the epoch (e.g. list of all tables) before processing event data.
Set *iter=0 to start. Returns NULL when no more. If event_types is not NULL, it returns bitmask of received event types.
| NdbIndexOperation* Ndb::getIndexOperation | ( | ) | [private] |
| NdbBlob* Ndb::getNdbBlob | ( | ) | [private] |
| NdbBranch* Ndb::getNdbBranch | ( | ) | [private] |
| NdbCall* Ndb::getNdbCall | ( | ) | [private] |
| NdbTransaction* Ndb::getNdbCon | ( | ) | [private] |
| const NdbError& Ndb::getNdbError | ( | int | errorCode | ) |
| const NdbError& Ndb::getNdbError | ( | ) | const |
| NdbLabel* Ndb::getNdbLabel | ( | ) | [private] |
| NdbReceiver* Ndb::getNdbScanRec | ( | ) | [private] |
| NdbSubroutine* Ndb::getNdbSubroutine | ( | ) | [private] |
| NdbOperation* Ndb::getOperation | ( | ) | [private] |
| NdbRecAttr* Ndb::getRecAttr | ( | ) | [private] |
| NdbIndexScanOperation* Ndb::getScanOperation | ( | ) | [private] |
| static const BaseString Ndb::getSchemaFromInternalName | ( | const char * | internalName | ) | [static, private] |
| NdbApiSignal* Ndb::getSignal | ( | ) | [private] |
| void Ndb::handleReceivedSignal | ( | NdbApiSignal * | anApiSignal, | |
| struct LinearSectionPtr | ptr[3] | |||
| ) | [private] |
| int Ndb::init | ( | int | maxNoOfTransactions = 4 |
) |
Initializes the Ndb object
| maxNoOfTransactions | Maximum number of parallel NdbTransaction objects that can be handled by the Ndb object. Maximum value is 1024. |
| Uint32 Ndb::insert_completed_list | ( | NdbTransaction * | ) | [private] |
| Uint32 Ndb::insert_sent_list | ( | NdbTransaction * | ) | [private] |
| void* Ndb::int2void | ( | Uint32 | val | ) | [private] |
| const BaseString Ndb::internalize_index_name | ( | const NdbTableImpl * | table, | |
| const char * | external_name | |||
| ) | const [private] |
| const BaseString Ndb::internalize_table_name | ( | const char * | external_name | ) | const [private] |
| bool Ndb::isConsistent | ( | Uint64 & | gci | ) |
Check if all events are consistent If node failure occurs during resource exaustion events may be lost and the delivered event data might thus be incomplete.
| OUT | aGCI any inconsistent GCI found |
| bool Ndb::isConsistentGCI | ( | Uint64 | gci | ) |
Check if all events in a GCI are consistent If node failure occurs during resource exaustion events may be lost and the delivered event data might thus be incomplete.
| aGCI | the GCI to check |
| int Ndb::NDB_connect | ( | ) | [private] |
| int Ndb::NDB_connect | ( | Uint32 | tNode | ) | [private] |
| NdbEventOperation* Ndb::nextEvent | ( | ) |
Returns an event operation that has data after a pollEvents
| const BaseString Ndb::old_internalize_index_name | ( | const NdbTableImpl * | table, | |
| const char * | external_name | |||
| ) | const [private] |
| int Ndb::poll_trans | ( | int | milliSecs, | |
| int | noOfEventsToWaitFor, | |||
| PollGuard * | pg | |||
| ) | [private] |
| Uint32 Ndb::pollCompleted | ( | NdbTransaction ** | aCopyArray | ) | [private] |
| int Ndb::pollEvents | ( | int | aMillisecondNumber, | |
| Uint64 * | latestGCI = 0 | |||
| ) |
Wait for an event to occur. Will return as soon as an event is detected on any of the created events.
| aMillisecondNumber | maximum time to wait |
| void Ndb::releaseConnectToNdb | ( | NdbTransaction * | ) | [private] |
| void Ndb::releaseNdbBlob | ( | NdbBlob * | aBlob | ) | [private] |
| void Ndb::releaseNdbBranch | ( | NdbBranch * | anNdbBranch | ) | [private] |
| void Ndb::releaseNdbCall | ( | NdbCall * | anNdbCall | ) | [private] |
| void Ndb::releaseNdbCon | ( | NdbTransaction * | ) | [private] |
| void Ndb::releaseNdbLabel | ( | NdbLabel * | anNdbLabel | ) | [private] |
| void Ndb::releaseNdbScanRec | ( | NdbReceiver * | aNdbScanRec | ) | [private] |
| void Ndb::releaseNdbSubroutine | ( | NdbSubroutine * | anNdbSubroutine | ) | [private] |
| void Ndb::releaseOperation | ( | NdbOperation * | anOperation | ) | [private] |
| void Ndb::releaseRecAttr | ( | NdbRecAttr * | aRecAttr | ) | [private] |
| void Ndb::releaseScanOperation | ( | NdbIndexScanOperation * | ) | [private] |
| void Ndb::releaseSignal | ( | NdbApiSignal * | anApiSignal | ) | [private] |
| void Ndb::releaseSignals | ( | Uint32 | , | |
| NdbApiSignal * | , | |||
| NdbApiSignal * | ||||
| ) | [private] |
| void Ndb::releaseSignalsInList | ( | NdbApiSignal ** | pList | ) | [private] |
| void Ndb::releaseTransactionArrays | ( | ) | [private] |
| void Ndb::remove_sent_list | ( | Uint32 | ) | [private] |
| void Ndb::report_node_connected | ( | Uint32 | nodeId | ) | [private] |
| void Ndb::report_node_failure | ( | Uint32 | node_id | ) | [private] |
| void Ndb::report_node_failure_completed | ( | Uint32 | node_id | ) | [private] |
| void Ndb::reportCallback | ( | NdbTransaction ** | aCopyArray, | |
| Uint32 | aNoOfComplTrans | |||
| ) | [private] |
| void Ndb::RestartGCI | ( | int | aRestartGCI | ) | [private] |
| void Ndb::sendPrepTrans | ( | int | forceSend | ) | [private] |
| int Ndb::sendRecSignal | ( | Uint16 | aNodeId, | |
| Uint32 | aWaitState, | |||
| NdbApiSignal * | aSignal, | |||
| Uint32 | nodeSequence, | |||
| Uint32 * | ret_conn_seq = 0 | |||
| ) | [private] |
| void Ndb::set_cond_wait_index | ( | Uint32 | index | ) | [inline] |
| int Ndb::setDatabaseName | ( | const char * | aDatabaseName | ) |
The current database name can be set by setDatabaseName.
| aDatabaseName | is the new name of the current database |
| int Ndb::setDatabaseSchemaName | ( | const char * | aDatabaseSchemaName | ) |
The current database schema name can be set by setDatabaseSchemaName.
| aDatabaseSchemaName | is the new name of the current database schema |
| void Ndb::setup | ( | Ndb_cluster_connection * | ndb_cluster_connection, | |
| const char * | aCatalogName, | |||
| const char * | aSchemaName | |||
| ) | [private] |
| NdbTransaction* Ndb::startTransaction | ( | const NdbDictionary::Table * | table, | |
| Uint32 | partitionId | |||
| ) |
Start a transaction, specifying table+partition as hint for TC-selection
| NdbTransaction* Ndb::startTransaction | ( | const NdbDictionary::Table * | table, | |
| const struct Key_part_ptr * | keyData, | |||
| void * | xfrmbuf = 0, |
|||
| Uint32 | xfrmbuflen = 0 | |||
| ) |
Start a transaction
| table | Pointer to table object used for deciding which node to run the Transaction Coordinator on | |
| keyData | Null-terminated array of pointers to keyParts that is part of distribution key. Length of resp. keyPart will be read from metadata and checked against passed value | |
| xfrmbuf | Pointer to temporary buffer that will be used to calculate hashvalue | |
| xfrmbuflen | Lengh of buffer |
| NdbTransaction* Ndb::startTransaction | ( | const NdbDictionary::Table * | table = 0, |
|
| const char * | keyData = 0, |
|||
| Uint32 | keyLen = 0 | |||
| ) |
Start a transaction
| table | Pointer to table object used for deciding which node to run the Transaction Coordinator on | |
| keyData | Pointer to partition key corresponding to table | |
| keyLen | Length of partition key expressed in bytes |
| NdbTransaction* Ndb::startTransactionLocal | ( | Uint32 | aPrio, | |
| Uint32 | aFragmentId | |||
| ) | [private] |
| static void Ndb::statusMessage | ( | void * | , | |
| Uint32 | , | |||
| bool | , | |||
| bool | ||||
| ) | [static, private] |
| NdbTransaction* Ndb::void2con | ( | void * | val | ) | [private] |
| NdbReceiver* Ndb::void2rec | ( | void * | val | ) | [private] |
| NdbIndexOperation* Ndb::void2rec_iop | ( | void * | val | ) | [private] |
| NdbOperation* Ndb::void2rec_op | ( | void * | val | ) | [private] |
| void Ndb::waitCompletedTransactions | ( | int | milliSecs, | |
| int | noOfEventsToWaitFor, | |||
| PollGuard * | pg | |||
| ) | [private] |
| int Ndb::waitUntilReady | ( | int | timeout = 60 |
) |
Wait for Ndb object to successfully set-up connections to the NDB kernel. Starting to use the Ndb object without using this method gives unspecified behavior.
| timeout | The maximum time we will wait for the initiation process to finish. Timeout is expressed in seconds. |
Ndb* Ndb::cond_signal_ndb [private] |
Uint32 Ndb::cond_wait_index [private] |
bool Ndb::fullyQualifiedNames [private] |
const NdbDictionary::Table* Ndb::m_sys_tab_0 [private] |
Uint64 Ndb::the_last_check_time [private] |
NdbApiSignal* Ndb::theCommitAckSignal [private] |
NdbTransaction** Ndb::theCompletedTransactionsArray [private] |
NdbTransaction** Ndb::theConnectionArray [private] |
class NdbDictionaryImpl* Ndb::theDictionary [private] |
NdbError Ndb::theError [private] |
class NdbEventBuffer* Ndb::theEventBuffer [private] |
Uint64 Ndb::theFirstTransId [private] |
class NdbImpl* Ndb::theImpl [private] |
enum Ndb::InitType Ndb::theInitState [private] |
Uint32 Ndb::theMaxNoOfTransactions [private] |
Uint32 Ndb::theMinNoOfEventsToWakeUp [private] |
Uint32 Ndb::theMyRef [private] |
Int32 Ndb::theNdbBlockNumber [private] |
Uint32 Ndb::theNextConnectNode [private] |
Uint32 Ndb::theNode [private] |
Uint32 Ndb::theNoOfCompletedTransactions [private] |
Uint32 Ndb::theNoOfPreparedTransactions [private] |
Uint32 Ndb::theNoOfSentTransactions [private] |
NdbTransaction** Ndb::thePreparedTransactionsArray [private] |
Uint32 Ndb::theRemainingStartTransactions [private] |
Uint32 Ndb::theRestartGCI [private] |
NdbTransaction** Ndb::theSentTransactionsArray [private] |
NdbTransaction* Ndb::theTransactionList [private] |
Based on MySQL Cluster 7.0.6.
This page is for information only and is not maintained by MySQL or Sun Microsystems - use at your own risk. For an upto date view of the API refer to the header files included with your MySQL Cluster distribution or check the MySQL Cluster API Developer Guide.