MySQL 5.6.14 Source Code Document
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Classes | Public Member Functions | Protected Member Functions | Protected Attributes | Friends | List of all members
DbtupProxy Class Reference
Inheritance diagram for DbtupProxy:
Inheritance graph
[legend]
Collaboration diagram for DbtupProxy:
Collaboration graph
[legend]

Classes

struct  Proxy_undo
struct  Ss_BUILD_INDX_IMPL_REQ

Public Member Functions

 DbtupProxy (Block_context &ctx)
 BLOCK_DEFINES (DbtupProxy)
- Public Member Functions inherited from LocalProxy
 LocalProxy (BlockNumber blockNumber, Block_context &ctx)
 BLOCK_DEFINES (LocalProxy)
- 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)
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)

Protected Member Functions

virtual SimulatedBlock * newWorker (Uint32 instanceNo)
virtual void callREAD_CONFIG_REQ (Signal *)
virtual void callSTTOR (Signal *)
void execCREATE_TAB_REQ (Signal *)
void execDROP_TAB_REQ (Signal *)
void execBUILD_INDX_IMPL_REQ (Signal *)
void sendBUILD_INDX_IMPL_REQ (Signal *, Uint32 ssId, SectionHandle *)
void execBUILD_INDX_IMPL_CONF (Signal *)
void execBUILD_INDX_IMPL_REF (Signal *)
void sendBUILD_INDX_IMPL_CONF (Signal *, Uint32 ssId)
void disk_restart_undo (Signal *, Uint64 lsn, Uint32 type, const Uint32 *ptr, Uint32 len)
void disk_restart_undo_callback (Signal *, Uint32, Uint32 page_id)
void disk_restart_undo_finish (Signal *)
void disk_restart_undo_send (Signal *, Uint32 i)
int disk_restart_alloc_extent (Uint32 tableId, Uint32 fragId, const Local_key *key, Uint32 pages)
void disk_restart_page_bits (Uint32 tableId, Uint32 fragId, const Local_key *key, Uint32 bits)
- Protected Member Functions inherited from LocalProxy
virtual void loadWorkers ()
SimulatedBlock * workerBlock (Uint32 i)
SimulatedBlock * extraWorkerBlock ()
BlockReference workerRef (Uint32 i)
BlockReference extraWorkerRef ()
Uint32 workerInstance (Uint32 i) const
Uint32 workerIndex (Uint32 ino) const
void sendREQ (Signal *, SsSequential &ss)
void recvCONF (Signal *, SsSequential &ss)
void recvREF (Signal *, SsSequential &ss, Uint32 error)
void skipReq (SsSequential &ss)
void skipConf (SsSequential &ss)
bool firstReply (const SsSequential &ss)
bool lastReply (const SsSequential &ss)
void saveSections (SsCommon &ss, SectionHandle &)
void restoreHandle (SectionHandle &, SsCommon &)
void sendREQ (Signal *, SsParallel &ss)
void recvCONF (Signal *, SsParallel &ss)
void recvREF (Signal *, SsParallel &ss, Uint32 error)
void skipReq (SsParallel &ss)
void skipConf (SsParallel &ss)
bool firstReply (const SsParallel &ss)
bool lastReply (const SsParallel &ss)
bool lastExtra (Signal *signal, SsParallel &ss)
void setMask (SsParallel &ss)
void setMask (SsParallel &ss, const WorkerMask &mask)
template<class Ss >
Ss * ssSearch (Uint32 ssId)
template<class Ss >
Ss & ssSeize ()
template<class Ss >
Ss & ssSeize (Uint32 ssId)
template<class Ss >
Ss & ssFind (Uint32 ssId)
template<class Ss >
Ss & ssFindSeize (Uint32 ssId, bool *found)
template<class Ss >
void ssRelease (Uint32 ssId)
template<class Ss >
void ssRelease (Ss &ss)
template<class Ss >
bool ssQueue (Signal *signal)
void execREAD_CONFIG_REQ (Signal *)
void backREAD_CONFIG_REQ (Signal *)
void sendREAD_CONFIG_REQ (Signal *, Uint32 ssId, SectionHandle *)
void execREAD_CONFIG_CONF (Signal *)
void sendREAD_CONFIG_CONF (Signal *, Uint32 ssId)
void execSTTOR (Signal *)
void backSTTOR (Signal *)
void sendSTTOR (Signal *, Uint32 ssId, SectionHandle *)
void execSTTORRY (Signal *)
void sendSTTORRY (Signal *, Uint32 ssId)
void execNDB_STTOR (Signal *)
virtual void callNDB_STTOR (Signal *)
void backNDB_STTOR (Signal *)
void sendNDB_STTOR (Signal *, Uint32 ssId, SectionHandle *)
void execNDB_STTORRY (Signal *)
void sendNDB_STTORRY (Signal *, Uint32 ssId)
void sendREAD_NODESREQ (Signal *)
void execREAD_NODESCONF (Signal *)
void execREAD_NODESREF (Signal *)
void execNODE_FAILREP (Signal *)
void sendNODE_FAILREP (Signal *, Uint32 ssId, SectionHandle *)
void execNF_COMPLETEREP (Signal *)
void sendNF_COMPLETEREP (Signal *, Uint32 ssId)
void execINCL_NODEREQ (Signal *)
void sendINCL_NODEREQ (Signal *, Uint32 ssId, SectionHandle *)
void execINCL_NODECONF (Signal *)
void sendINCL_NODECONF (Signal *, Uint32 ssId)
void execNODE_STATE_REP (Signal *)
void sendNODE_STATE_REP (Signal *, Uint32 ssId, SectionHandle *)
void execCHANGE_NODE_STATE_REQ (Signal *)
void sendCHANGE_NODE_STATE_REQ (Signal *, Uint32 ssId, SectionHandle *)
void execCHANGE_NODE_STATE_CONF (Signal *)
void sendCHANGE_NODE_STATE_CONF (Signal *, Uint32 ssId)
void execDUMP_STATE_ORD (Signal *)
void sendDUMP_STATE_ORD (Signal *, Uint32 ssId, SectionHandle *)
void execNDB_TAMPER (Signal *)
void sendNDB_TAMPER (Signal *, Uint32 ssId, SectionHandle *)
void execTIME_SIGNAL (Signal *)
void sendTIME_SIGNAL (Signal *, Uint32 ssId, SectionHandle *)
void execCREATE_TRIG_IMPL_REQ (Signal *)
void sendCREATE_TRIG_IMPL_REQ (Signal *, Uint32 ssId, SectionHandle *)
void execCREATE_TRIG_IMPL_CONF (Signal *)
void execCREATE_TRIG_IMPL_REF (Signal *)
void sendCREATE_TRIG_IMPL_CONF (Signal *, Uint32 ssId)
void execDROP_TRIG_IMPL_REQ (Signal *)
void sendDROP_TRIG_IMPL_REQ (Signal *, Uint32 ssId, SectionHandle *)
void execDROP_TRIG_IMPL_CONF (Signal *)
void execDROP_TRIG_IMPL_REF (Signal *)
void sendDROP_TRIG_IMPL_CONF (Signal *, Uint32 ssId)
bool find_next (Ndbinfo::ScanCursor *cursor) const
void execDBINFO_SCANREQ (Signal *)
void execDBINFO_SCANCONF (Signal *)
void execSYNC_REQ (Signal *)
void execSYNC_REF (Signal *)
void execSYNC_CONF (Signal *)
void sendSYNC_REQ (Signal *, Uint32 ssId, SectionHandle *)
void sendSYNC_CONF (Signal *, Uint32 ssId)
void execSYNC_PATH_REQ (Signal *)
- Protected Member Functions inherited from SimulatedBlock
 SimulatedBlock (BlockNumber blockNumber, struct Block_context &ctx, Uint32 instanceNumber=0)
void addRecSignalImpl (GlobalSignalNumber g, ExecFunction fun, bool f=false)
void installSimulatedBlockFunctions ()
void initCommon ()
void TheNULLCallbackFunction (class Signal *, Uint32, Uint32)
void execute (Signal *signal, Callback &c, Uint32 returnCode)
void sendSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf) const
void sendSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf) const
void sendSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, SectionHandle *sections) const
void sendSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, SectionHandle *sections) const
void sendSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections) const
void sendSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections) const
void sendSignalNoRelease (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, SectionHandle *sections) const
void sendSignalNoRelease (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, SectionHandle *sections) const
void sendSignalWithDelay (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 delayInMilliSeconds, Uint32 length) const
void sendSignalWithDelay (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 delayInMilliSeconds, Uint32 length, SectionHandle *sections) const
void EXECUTE_DIRECT (Uint32 block, Uint32 gsn, Signal *signal, Uint32 len, Uint32 givenInstanceNo=ZNIL)
class SectionSegmentPool & getSectionSegmentPool ()
void release (SegmentedSectionPtr &ptr)
void release (SegmentedSectionPtrPOD &ptr)
void releaseSection (Uint32 firstSegmentIVal)
void releaseSections (struct SectionHandle &)
bool import (Ptr< SectionSegment > &first, const Uint32 *src, Uint32 len)
bool import (SegmentedSectionPtr &ptr, const Uint32 *src, Uint32 len)
bool appendToSection (Uint32 &firstSegmentIVal, const Uint32 *src, Uint32 len)
bool dupSection (Uint32 &copyFirstIVal, Uint32 srcFirstIVal)
bool writeToSection (Uint32 firstSegmentIVal, Uint32 offset, const Uint32 *src, Uint32 len)
void handle_invalid_sections_in_send_signal (Signal *) const
void handle_lingering_sections_after_execute (Signal *) const
void handle_lingering_sections_after_execute (SectionHandle *) const
void handle_invalid_fragmentInfo (Signal *) const
void handle_send_failed (SendStatus, Signal *) const
void handle_out_of_longsignal_memory (Signal *) const
void sendRoutedSignal (RoutePath path[], Uint32 pathcnt, Uint32 dst[], Uint32 dstcnt, Uint32 gsn, Signal *, Uint32 len, JobBufferLevel prio, SectionHandle *handle=0)
bool checkNodeFailSequence (Signal *)
bool assembleFragments (Signal *signal)
bool assembleDroppedFragments (Signal *signal)
 STATIC_CONST (FRAGMENT_WORD_SIZE=240)
void sendFragmentedSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, SectionHandle *sections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void sendFragmentedSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, SectionHandle *sections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void sendFragmentedSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void sendFragmentedSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
Uint32 simBlockNodeFailure (Signal *signal, Uint32 failedNodeId, Callback &cb=TheEmptyCallback)
bool sendFirstFragment (FragmentSendInfo &info, NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, SectionHandle *sections, bool noRelease, Uint32 messageSize=FRAGMENT_WORD_SIZE)
bool sendFirstFragment (FragmentSendInfo &info, NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void sendNextSegmentedFragment (Signal *signal, FragmentSendInfo &info)
void sendNextLinearFragment (Signal *signal, FragmentSendInfo &info)
BlockNumber number () const
BlockReference reference () const
NodeId getOwnNodeId () const
void refresh_watch_dog (Uint32 place=1)
void update_watch_dog_timer (Uint32 interval)
void progError (int line, int err_code, const char *extradata=NULL) const ATTRIBUTE_NORETURN
NewVARIABLE * allocateBat (int batSize)
void freeBat ()
BlockReference calcInstanceBlockRef (BlockNumber aBlock)
BlockReference calcInstanceBlockRef (BlockNumber aBlock, NodeId aNode)
void * allocRecord (const char *type, size_t s, size_t n, bool clear=true, Uint32 paramId=0)
void * allocRecordAligned (const char *type, size_t s, size_t n, void **unaligned_buffer, Uint32 align=NDB_O_DIRECT_WRITE_ALIGNMENT, bool clear=true, Uint32 paramId=0)
void deallocRecord (void **, const char *type, size_t s, size_t n)
Uint32 allocChunks (AllocChunk dst[], Uint32arraysize, Uint32rg, Uint32pages, Uint32 paramId)
void infoEvent (const char *msg,...) const ATTRIBUTE_FORMAT(printf
void void warningEvent (const char *msg,...) const ATTRIBUTE_FORMAT(printf
void void const NodeState & getNodeState () const
const NodeInfo & getNodeInfo (NodeId nodeId) const
NodeInfo & setNodeInfo (NodeId)
const NodeVersionInfo & getNodeVersionInfo () const
NodeVersionInfo & setNodeVersionInfo ()
Uint32 xfrm_key (Uint32 tab, const Uint32 *src, Uint32 *dst, Uint32 dstSize, Uint32 keyPartLen[MAX_ATTRIBUTES_IN_INDEX]) const
Uint32 xfrm_attr (Uint32 attrDesc, CHARSET_INFO *cs, const Uint32 *src, Uint32 &srcPos, Uint32 *dst, Uint32 &dstPos, Uint32 dstSize) const
Uint32 create_distr_key (Uint32 tableId, const Uint32 *src, Uint32 *dst, const Uint32 keyPaLen[MAX_ATTRIBUTES_IN_INDEX]) const
void wakeup ()
void setup_wakeup ()
void execSIGNAL_DROPPED_REP (Signal *signal)
void execCONTINUE_FRAGMENTED (Signal *signal)
void execSTOP_FOR_CRASH (Signal *signal)
void execAPI_START_REP (Signal *signal)
void execNODE_START_REP (Signal *signal)
void execSEND_PACKED (Signal *signal)
void execLOCAL_ROUTE_ORD (Signal *)
Uint32 debugPrintFragmentCounts ()
void fsRefError (Signal *signal, Uint32 line, const char *msg)
void execFSWRITEREF (Signal *signal)
void execFSREADREF (Signal *signal)
void execFSOPENREF (Signal *signal)
void execFSCLOSEREF (Signal *signal)
void execFSREMOVEREF (Signal *signal)
void execFSSYNCREF (Signal *signal)
void execFSAPPENDREF (Signal *signal)
void execute (Signal *signal, CallbackPtr &cptr, Uint32 returnCode)
const CallbackEntry & getCallbackEntry (Uint32 ci)
void sendCallbackConf (Signal *signal, Uint32 fullBlockNo, CallbackPtr &cptr, Uint32 returnCode)
void execCALLBACK_CONF (Signal *signal)
void ndbinfo_send_row (Signal *signal, const DbinfoScanReq &req, const Ndbinfo::Row &row, Ndbinfo::Ratelimit &rl) const
void ndbinfo_send_scan_break (Signal *signal, DbinfoScanReq &req, const Ndbinfo::Ratelimit &rl, Uint32 data1, Uint32 data2=0, Uint32 data3=0, Uint32 data4=0) const
void ndbinfo_send_scan_conf (Signal *signal, DbinfoScanReq &req, const Ndbinfo::Ratelimit &rl) const

Protected Attributes

class Pgman * c_pgman
Uint32 c_tableRecSize
Uint8 * c_tableRec
SsPool< Ss_BUILD_INDX_IMPL_REQ > c_ss_BUILD_INDX_IMPL_REQ
Proxy_undo c_proxy_undo
- Protected Attributes inherited from LocalProxy
Uint32 c_lqhWorkers
Uint32 c_extraWorkers
Uint32 c_workers
SimulatedBlock * c_worker [MaxWorkers]
Uint32 c_ssIdSeq
Uint32 c_typeOfStart
Uint32 c_masterNodeId
SsPool< Ss_READ_CONFIG_REQ > c_ss_READ_CONFIG_REQ
SsPool< Ss_STTOR > c_ss_STTOR
SsPool< Ss_NDB_STTOR > c_ss_NDB_STTOR
Ss_READ_NODES_REQ c_ss_READ_NODESREQ
SsPool< Ss_NODE_FAILREP > c_ss_NODE_FAILREP
SsPool< Ss_INCL_NODEREQ > c_ss_INCL_NODEREQ
SsPool< Ss_NODE_STATE_REP > c_ss_NODE_STATE_REP
SsPool< Ss_CHANGE_NODE_STATE_REQ > c_ss_CHANGE_NODE_STATE_REQ
SsPool< Ss_DUMP_STATE_ORD > c_ss_DUMP_STATE_ORD
SsPool< Ss_NDB_TAMPER > c_ss_NDB_TAMPER
SsPool< Ss_TIME_SIGNAL > c_ss_TIME_SIGNAL
SsPool< Ss_CREATE_TRIG_IMPL_REQ > c_ss_CREATE_TRIG_IMPL_REQ
SsPool< Ss_DROP_TRIG_IMPL_REQ > c_ss_DROP_TRIG_IMPL_REQ
SsPool< Ss_SYNC_REQ > c_ss_SYNC_REQ
- Protected Attributes inherited from SimulatedBlock
ExecFunction theExecArray [MAX_GSN+1]
Block_context m_ctx
SafeArrayPool< GlobalPage > & m_global_page_pool
ArrayPool< GlobalPage > & m_shared_page_pool
CallbackTable * m_callbackTableAddr
 ERROR_INSERT_VARIABLE

Friends

class Dbtup_client

Additional Inherited Members

- Public Types inherited from SimulatedBlock
typedef void(SimulatedBlock::* CallbackFunction )(class Signal *, Uint32 callbackData, Uint32 returnCode)
- 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 SimulatedBlock
MutexManager c_mutexMgr
SafeCounterManager c_counterMgr
- Protected Types inherited from LocalProxy
enum  { MaxLqhWorkers = MAX_NDBMT_LQH_WORKERS }
enum  { MaxExtraWorkers = 1 }
enum  { MaxWorkers = MaxLqhWorkers + MaxExtraWorkers }
enum  { SsIdBase = (1u << 31) }
typedef Bitmask<(MaxWorkers+31)/32 > WorkerMask
typedef void(LocalProxy::* SsFUNCREQ )(Signal *, Uint32 ssId, SectionHandle *)
typedef void(LocalProxy::* SsFUNCREP )(Signal *, Uint32 ssId)
- 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 *)
- Static Protected Attributes inherited from SimulatedBlock
static Callback TheEmptyCallback = {0, 0}
static Callback TheNULLCallback

Detailed Description

Definition at line 24 of file DbtupProxy.hpp.

The documentation for this class was generated from the following files: