|
MySQL 5.6.14 Source Code Document
|
|
MySQL 5.6.14 Source Code Document
|
Public Types | |
| enum | AtrtCommandType { ATCT_CHANGE_VERSION = 1, ATCT_RESET_PROC = 2 } |
 Public Types inherited from DbUtil | |
| typedef DataBuffer< 11 > | KeyInfoBuffer |
|
typedef KeyInfoBuffer::ConstDataBufferIterator | KeyInfoIterator |
| typedef DataBuffer< 11 > | AttrInfoBuffer |
|
typedef AttrInfoBuffer::ConstDataBufferIterator | AttrInfoIterator |
| typedef DataBuffer< 11 > | ResultSetBuffer |
| typedef DataBuffer< 11 > | ResultSetInfoBuffer |
| typedef DataBuffer< 1 > | AttrMappingBuffer |
| typedef Ptr< Page32 > | Page32Ptr |
| typedef Ptr< Prepare > | PreparePtr |
| typedef Ptr< Transaction > | TransactionPtr |
| typedef Ptr< Operation > | OperationPtr |
| typedef Ptr< PreparedOperation > | PreparedOperationPtr |
| typedef Ptr< LockQueueInstance > | LockQueuePtr |
| Public Types inherited from SimulatedBlock | |
| typedef void(SimulatedBlock::* | CallbackFunction )(class Signal *, Uint32 callbackData, Uint32 returnCode) |
Public Member Functions | |
| AtrtClient (const char *_suffix=".1.atrt") | |
| AtrtClient (MYSQL *) | |
| bool | changeVersion (int process_id, const char *process_args) |
| bool | resetProc (int process_id) |
| bool | getConnectString (int cluster_id, SqlResultSet &result) |
| bool | getClusters (SqlResultSet &result) |
| bool | getMgmds (int cluster_id, SqlResultSet &result) |
| bool | getNdbds (int cluster_id, SqlResultSet &result) |
| int | getOwnProcessId () |
| Public Member Functions inherited from DbUtil | |
| DbUtil (Block_context &ctx) | |
| BLOCK_DEFINES (DbUtil) | |
| void | getTransId (Transaction *) |
| void | initResultSet (ResultSetBuffer &, const ResultSetInfoBuffer &) |
| void | runTransaction (Signal *signal, TransactionPtr) |
| void | runOperation (Signal *signal, TransactionPtr &, OperationPtr &, Uint32) |
| void | sendKeyInfo (Signal *signal, Uint32 ref, KeyInfo *keyInfo, const KeyInfoBuffer &keyBuf, KeyInfoIterator &kit) |
| void | sendAttrInfo (Signal *, Uint32 ref, AttrInfo *attrInfo, const AttrInfoBuffer &, AttrInfoIterator &ait) |
| int | getResultSet (Signal *signal, const Transaction *transP, struct LinearSectionPtr sectionsPtr[]) |
| void | finishTransaction (Signal *, TransactionPtr) |
| void | releaseTransaction (TransactionPtr transPtr) |
| void | get_systab_tableid (Signal *) |
| void | hardcodedPrepare (Signal *, Uint32 SYSTAB_0) |
| void | connectTc (Signal *signal) |
| void | reportSequence (Signal *, const Transaction *) |
| void | readPrepareProps (Signal *signal, SimpleProperties::Reader *reader, PreparePtr) |
| void | prepareOperation (Signal *, PreparePtr, SegmentedSectionPtr) |
| void | sendUtilPrepareRef (Signal *, UtilPrepareRef::ErrorCode, Uint32, Uint32, Uint32 extraError=0) |
| void | sendUtilExecuteRef (Signal *, UtilExecuteRef::ErrorCode, Uint32, Uint32, Uint32) |
| void | releasePrepare (PreparePtr) |
| void | releasePreparedOperation (PreparedOperationPtr) |
| void | execUTIL_CREATE_LOCK_REQ (Signal *signal) |
| void | execUTIL_DESTORY_LOCK_REQ (Signal *signal) |
| void | execUTIL_LOCK_REQ (Signal *signal) |
| void | execUTIL_UNLOCK_REQ (Signal *signal) |
| void | sendLOCK_REF (Signal *, const UtilLockReq *req, UtilLockRef::ErrorCode) |
| void | sendLOCK_CONF (Signal *, const UtilLockReq *req) |
| void | sendUNLOCK_REF (Signal *, const UtilUnlockReq *, UtilUnlockRef::ErrorCode) |
| void | mutex_created (Signal *signal, Uint32 mutexId, Uint32 retVal) |
| void | mutex_destroyed (Signal *signal, Uint32 mutexId, Uint32 retVal) |
| void | mutex_locked (Signal *signal, Uint32 mutexId, Uint32 retVal) |
| void | mutex_unlocked (Signal *signal, Uint32 mutexId, Uint32 retVal) |
| DbUtil (MYSQL *mysql) | |
| DbUtil (const char *dbname="mysql", const char *suffix=NULL) | |
| bool | doQuery (const char *query) |
| bool | doQuery (const char *query, SqlResultSet &result) |
| bool | doQuery (const char *query, const Properties &args, SqlResultSet &result) |
| bool | doQuery (const char *query, const Properties &args) |
| bool | doQuery (BaseString &str) |
| bool | doQuery (BaseString &str, SqlResultSet &result) |
| bool | doQuery (BaseString &str, const Properties &args, SqlResultSet &result) |
| bool | doQuery (BaseString &str, const Properties &args) |
| bool | waitConnected (int timeout=120) |
| bool | databaseLogin (const char *host, const char *user, const char *password, unsigned int portIn, const char *sockIn, bool transactional) |
| const char * | getDbName () |
| const char * | getUser () |
| const char * | getPassword () |
| const char * | getHost () |
| const char * | getSocket () |
| const char * | getServerType () |
| const char * | getError () |
| MYSQL * | getMysql () |
| MYSQL_STMT *STDCALL | mysqlSimplePrepare (const char *query) |
| void | databaseLogout () |
| void | mysqlCloseStmHandle (MYSQL_STMT *my_stmt) |
| bool | connect () |
| void | disconnect () |
| bool | selectDb () |
| bool | selectDb (const char *) |
| bool | createDb (BaseString &) |
| int | getErrorNumber () |
| const char * | last_error () const |
| int | last_errno () const |
| unsigned long long | selectCountTable (const char *table) |
| void | silent () |
| Public Member Functions inherited from SimulatedBlock | |
| void | executeFunction (GlobalSignalNumber gsn, Signal *signal) |
| Uint32 | instance () const |
| SimulatedBlock * | getInstance (Uint32 instanceNumber) |
| void | addInstance (SimulatedBlock *b, Uint32 theInstanceNo) |
| virtual void | loadWorkers () |
| void | assignToThread (ThreadContext ctx) |
| uint32 | getThreadId () const |
| void | assertOwnThread () |
| void | synchronize_threads_for_blocks (Signal *, const Uint32 blocks[], const Callback &, JobBufferLevel=JBB) |
| void | synchronize_path (Signal *, const Uint32 blocks[], const Callback &, JobBufferLevel=JBB) |
| virtual const char * | get_filename (Uint32 fd) const |
| EmulatedJamBuffer * | jamBuffer () const |
| void | ignoreMutexUnlockCallback (Signal *signal, Uint32 ptrI, Uint32 retVal) |
| virtual bool | getParam (const char *param, Uint32 *retVal) |
Additional Inherited Members | |
| Static Public Member Functions inherited from SimulatedBlock | |
| static bool | isMultiThreaded () |
| static bool | isNdbMt () |
| static bool | isNdbMtLqh () |
| static Uint32 | getLqhWorkers () |
| static Uint32 | getInstanceKey (Uint32 tabId, Uint32 fragId) |
| static Uint32 | getInstanceFromKey (Uint32 instanceKey) |
| Public Attributes inherited from DbUtil | |
| Uint32 | c_transId [2] |
| ArrayPool< Page32 > | c_pagePool |
| ArrayPool< Prepare > | c_preparePool |
| ArrayPool< Operation > | c_operationPool |
| ArrayPool< PreparedOperation > | c_preparedOperationPool |
| ArrayPool< Transaction > | c_transactionPool |
| DataBuffer< 1 >::DataBufferPool | c_attrMappingPool |
| DataBuffer< 11 >::DataBufferPool | c_dataBufPool |
| DLList< Prepare > | c_runningPrepares |
| DLList< Transaction > | c_seizingTransactions |
| DLList< Transaction > | c_runningTransactions |
| ArrayPool< LockQueueInstance > | c_lockQueuePool |
| KeyTable< LockQueueInstance > | c_lockQueues |
| LockQueue::Pool | c_lockElementPool |
| Protected Types inherited from SimulatedBlock | |
| enum | CallbackFlags { CALLBACK_DIRECT = 0x0001, CALLBACK_ACK = 0x0002 } |
| enum | { THE_NULL_CALLBACK = 0 } |
| typedef void(SimulatedBlock::* | ExecFunction )(Signal *signal) |
| Protected Member Functions inherited from DbUtil | |
| void | execREAD_CONFIG_REQ (Signal *signal) |
| void | execSTTOR (Signal *signal) |
| void | execNDB_STTOR (Signal *signal) |
| void | execDUMP_STATE_ORD (Signal *signal) |
| void | execDBINFO_SCANREQ (Signal *signal) |
| void | execCONTINUEB (Signal *signal) |
| void | execNODE_FAILREP (Signal *signal) |
| void | execUTIL_SEQUENCE_REQ (Signal *signal) |
| void | execUTIL_SEQUENCE_REF (Signal *signal) |
| void | execUTIL_SEQUENCE_CONF (Signal *signal) |
| void | execUTIL_PREPARE_REQ (Signal *signal) |
| void | execUTIL_PREPARE_CONF (Signal *signal) |
| void | execUTIL_PREPARE_REF (Signal *signal) |
| void | execUTIL_DELETE_REQ (Signal *signal) |
| void | execUTIL_DELETE_REF (Signal *signal) |
| void | execUTIL_DELETE_CONF (Signal *signal) |
| void | execUTIL_EXECUTE_REQ (Signal *signal) |
| void | execUTIL_EXECUTE_REF (Signal *signal) |
| void | execUTIL_EXECUTE_CONF (Signal *signal) |
| void | execUTIL_RELEASE_REQ (Signal *signal) |
| void | execUTIL_RELEASE_CONF (Signal *signal) |
| void | execUTIL_RELEASE_REF (Signal *signal) |
| void | execTCSEIZECONF (Signal *signal) |
| void | execTCKEYCONF (Signal *signal) |
| void | execTCKEYREF (Signal *signal) |
| void | execTCROLLBACKREP (Signal *signal) |
| void | execTCKEY_FAILCONF (Signal *signal) |
| void | execTCKEY_FAILREF (Signal *signal) |
| void | execTRANSID_AI (Signal *signal) |
| void | execGET_TABINFOREF (Signal *) |
| void | execGET_TABINFO_CONF (Signal *signal) |
| bool | runQuery (const char *query, const Properties &args, SqlResultSet &rows) |
| bool | isConnected () |
| Static Protected Member Functions inherited from SimulatedBlock | |
| static const NewVARIABLE * | getBat (BlockNumber blockNo, Uint32 instanceNo) |
| static Uint16 | getBatSize (BlockNumber blockNo, Uint32 instanceNo) |
| static BlockReference | calcTcBlockRef (NodeId aNode) |
| static BlockReference | calcLqhBlockRef (NodeId aNode) |
| static BlockReference | calcAccBlockRef (NodeId aNode) |
| static BlockReference | calcTupBlockRef (NodeId aNode) |
| static BlockReference | calcTuxBlockRef (NodeId aNode) |
| static BlockReference | calcDihBlockRef (NodeId aNode) |
| static BlockReference | calcQmgrBlockRef (NodeId aNode) |
| static BlockReference | calcDictBlockRef (NodeId aNode) |
| static BlockReference | calcNdbCntrBlockRef (NodeId aNode) |
| static BlockReference | calcTrixBlockRef (NodeId aNode) |
| static BlockReference | calcBackupBlockRef (NodeId aNode) |
| static BlockReference | calcSumaBlockRef (NodeId aNode) |
| static BlockReference | calcApiClusterMgrBlockRef (NodeId aNode) |
| static int | sortchunks (const void *, const void *) |
| Protected Attributes inherited from DbUtil | |
| MYSQL * | m_mysql |
| bool | m_free_mysql |
| Static Protected Attributes inherited from SimulatedBlock | |
| static Callback | TheEmptyCallback = {0, 0} |
| static Callback | TheNULLCallback |
Definition at line 24 of file AtrtClient.hpp.
| int AtrtClient::getOwnProcessId | ( | ) |
Put in env for simplicity
Definition at line 215 of file AtrtClient.cpp.
1.8.1.2 
