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 | Static Protected Member Functions | Protected Attributes | Friends | List of all members
PgmanProxy Class Reference
Inheritance diagram for PgmanProxy:
Inheritance graph
[legend]
Collaboration diagram for PgmanProxy:
Collaboration graph
[legend]

Classes

struct  Ss_END_LCP_REQ
struct  Ss_LCP_FRAG_ORD

Public Member Functions

 PgmanProxy (Block_context &ctx)
 BLOCK_DEFINES (PgmanProxy)
- 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)
void execLCP_FRAG_ORD (Signal *)
void sendLCP_FRAG_ORD (Signal *, Uint32 ssId, SectionHandle *)
void execEND_LCP_REQ (Signal *)
void sendEND_LCP_REQ (Signal *, Uint32 ssId, SectionHandle *)
void execEND_LCP_CONF (Signal *)
void sendEND_LCP_CONF (Signal *, Uint32 ssId)
void execRELEASE_PAGES_CONF (Signal *)
int get_page (Page_cache_client &caller, Signal *, Page_cache_client::Request &req, Uint32 flags)
void update_lsn (Page_cache_client &caller, Local_key key, Uint64 lsn)
int drop_page (Page_cache_client &caller, Local_key key, Uint32 page_id)
Uint32 create_data_file (Signal *)
Uint32 alloc_data_file (Signal *, Uint32 file_no)
void map_file_no (Signal *, Uint32 file_no, Uint32 fd)
void free_data_file (Signal *, Uint32 file_no, Uint32 fd)
void send_data_file_ord (Signal *, Uint32 i, Uint32 ret, Uint32 cmd, Uint32 file_no=RNIL, Uint32 fd=RNIL)
- 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 *)
virtual void callREAD_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 *)
virtual void callSTTOR (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

Static Protected Member Functions

static Uint32 getSsId (const LcpFragOrd *req)
static Uint32 getSsId (const EndLcpReq *req)
static Uint32 getSsId (const EndLcpConf *conf)
static Uint32 getSsId (const ReleasePagesConf *conf)

Protected Attributes

SsPool< Ss_LCP_FRAG_ORD > c_ss_LCP_FRAG_ORD
SsPool< Ss_END_LCP_REQ > c_ss_END_LCP_REQ
- 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 Page_cache_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 Attributes inherited from SimulatedBlock
static Callback TheEmptyCallback = {0, 0}
static Callback TheNULLCallback

Detailed Description

Definition at line 24 of file PgmanProxy.hpp.

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