MySQL 5.6.14 Source Code Document
|
Classes | |
struct | ApiConnectRecord |
struct | ConnectRecord |
struct | CopyGCIMaster |
struct | CopyGCISlave |
struct | CopyTableNode |
struct | CreateReplicaRecord |
struct | DictLockSlaveRecord |
struct | DIVERIFY_queue |
struct | FileRecord |
struct | Fragmentstore |
struct | GcpMonitor |
struct | GcpSave |
struct | LcpState |
struct | LocalLCPState |
class | MasterTakeOverState |
struct | MicroGcp |
struct | NodeGroupRecord |
struct | NodeRecord |
struct | NodeStartMasterRecord |
struct | NodeStartSlaveRecord |
struct | PageRecord |
struct | ReplicaRecord |
struct | RWFragment |
struct | StopMeRecord |
struct | StopPermMasterRecord |
struct | StopPermProxyRecord |
struct | SwitchReplicaRecord |
struct | TabRecord |
struct | TakeOverRecord |
struct | WaitGCPMasterRecord |
struct | WaitGCPProxyRecord |
Public Types | |
enum | NodefailHandlingStep { NF_REMOVE_NODE_FROM_TABLE = 1, NF_GCP_TAKE_OVER = 2, NF_LCP_TAKE_OVER = 4 } |
enum | LcpStatus { LCP_STATUS_IDLE = 0, LCP_TCGET = 1, LCP_STATUS_ACTIVE = 2, LCP_CALCULATE_KEEP_GCI = 4, LCP_COPY_GCI = 5, LCP_INIT_TABLES = 6, LCP_TC_CLOPSIZE = 7, LCP_START_LCP_ROUND = 8, LCP_TAB_COMPLETED = 9, LCP_TAB_SAVED = 10 } |
enum | LcpMasterTakeOverState { LMTOS_IDLE = 0, LMTOS_WAIT_EMPTY_LCP = 1, LMTOS_WAIT_LCP_FRAG_REP = 2, LMTOS_INITIAL = 3, LMTOS_ALL_IDLE = 4, LMTOS_ALL_ACTIVE = 5, LMTOS_LCP_CONCLUDING = 6, LMTOS_COPY_ONGOING = 7 } |
typedef Ptr< ApiConnectRecord > | ApiConnectRecordPtr |
typedef Ptr< ConnectRecord > | ConnectRecordPtr |
typedef Ptr< CreateReplicaRecord > | CreateReplicaRecordPtr |
typedef Ptr< FileRecord > | FileRecordPtr |
typedef Ptr< Fragmentstore > | FragmentstorePtr |
typedef Ptr< NodeGroupRecord > | NodeGroupRecordPtr |
typedef Ptr< NodeRecord > | NodeRecordPtr |
typedef Ptr< PageRecord > | PageRecordPtr |
typedef Ptr< ReplicaRecord > | ReplicaRecordPtr |
typedef Ptr< TabRecord > | TabRecordPtr |
typedef Ptr< TakeOverRecord > | TakeOverRecordPtr |
Public Types inherited from SimulatedBlock | |
typedef void(SimulatedBlock::* | CallbackFunction )(class Signal *, Uint32 callbackData, Uint32 returnCode) |
Public Member Functions | |
virtual bool | getParam (const char *param, Uint32 *retVal) |
Dbdih (Block_context &ctx) | |
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) |
Friends | |
class | SimulatedBlock |
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 SimulatedBlock | |
MutexManager | c_mutexMgr |
SafeCounterManager | c_counterMgr |
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 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 ©FirstIVal, 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 | execNDB_TAMPER (Signal *signal) |
void | execNODE_STATE_REP (Signal *signal) |
void | execCHANGE_NODE_STATE_REQ (Signal *signal) |
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 |
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 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 | |
Static Protected Attributes inherited from SimulatedBlock | |
static Callback | TheEmptyCallback = {0, 0} |
static Callback | TheNULLCallback |