DblqhProxy Class Reference

Inheritance diagram for DblqhProxy:

Collaboration diagram for DblqhProxy:

Classes
struct	LcpRecord
struct	Ss_ALTER_TAB_REQ
struct	Ss_CREATE_TAB_REQ
struct	Ss_DROP_FRAG_REQ
struct	Ss_DROP_TAB_REQ
struct	Ss_EXEC_SR_1
struct	Ss_EXEC_SR_2
struct	Ss_GCP_SAVEREQ
struct	Ss_LQH_TRANSREQ
struct	Ss_LQHADDATTREQ
struct	Ss_PREP_DROP_TAB_REQ
struct	Ss_START_RECREQ
struct	Ss_START_RECREQ_2
struct	Ss_TAB_COMMITREQ

Public Member Functions
	DblqhProxy (Block_context &ctx)
	BLOCK_DEFINES (DblqhProxy)
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	callNDB_STTOR (Signal *)
virtual void	callREAD_CONFIG_REQ (Signal *)
void	execCREATE_TAB_REQ (Signal *)
void	sendCREATE_TAB_REQ (Signal *, Uint32 ssId, SectionHandle *)
void	execCREATE_TAB_CONF (Signal *)
void	execCREATE_TAB_REF (Signal *)
void	sendCREATE_TAB_CONF (Signal *, Uint32 ssId)
void	execLQHADDATTREQ (Signal *)
void	sendLQHADDATTREQ (Signal *, Uint32 ssId, SectionHandle *)
void	execLQHADDATTCONF (Signal *)
void	execLQHADDATTREF (Signal *)
void	sendLQHADDATTCONF (Signal *, Uint32 ssId)
void	execLQHFRAGREQ (Signal *)
void	execTAB_COMMITREQ (Signal *)
void	sendTAB_COMMITREQ (Signal *, Uint32 ssId, SectionHandle *)
void	execTAB_COMMITCONF (Signal *)
void	execTAB_COMMITREF (Signal *)
void	sendTAB_COMMITCONF (Signal *, Uint32 ssId)
Uint32	getSsId (const GCPSaveReq *req)
Uint32	getSsId (const GCPSaveConf *conf)
Uint32	getSsId (const GCPSaveRef *ref)
void	execGCP_SAVEREQ (Signal *)
void	sendGCP_SAVEREQ (Signal *, Uint32 ssId, SectionHandle *)
void	execGCP_SAVECONF (Signal *)
void	execGCP_SAVEREF (Signal *)
void	sendGCP_SAVECONF (Signal *, Uint32 ssId)
void	execSUB_GCP_COMPLETE_REP (Signal *)
Uint32	getSsId (const PrepDropTabReq *req)
Uint32	getSsId (const PrepDropTabConf *conf)
Uint32	getSsId (const PrepDropTabRef *ref)
void	execPREP_DROP_TAB_REQ (Signal *)
void	sendPREP_DROP_TAB_REQ (Signal *, Uint32 ssId, SectionHandle *)
void	execPREP_DROP_TAB_CONF (Signal *)
void	execPREP_DROP_TAB_REF (Signal *)
void	sendPREP_DROP_TAB_CONF (Signal *, Uint32 ssId)
Uint32	getSsId (const DropTabReq *req)
Uint32	getSsId (const DropTabConf *conf)
Uint32	getSsId (const DropTabRef *ref)
void	execDROP_TAB_REQ (Signal *)
void	sendDROP_TAB_REQ (Signal *, Uint32 ssId, SectionHandle *)
void	execDROP_TAB_CONF (Signal *)
void	execDROP_TAB_REF (Signal *)
void	sendDROP_TAB_CONF (Signal *, Uint32 ssId)
Uint32	getSsId (const AlterTabReq *req)
Uint32	getSsId (const AlterTabConf *conf)
Uint32	getSsId (const AlterTabRef *ref)
void	execALTER_TAB_REQ (Signal *)
void	sendALTER_TAB_REQ (Signal *, Uint32 ssId, SectionHandle *)
void	execALTER_TAB_CONF (Signal *)
void	execALTER_TAB_REF (Signal *)
void	sendALTER_TAB_CONF (Signal *, Uint32 ssId)
void	execSTART_FRAGREQ (Signal *)
void	execSTART_RECREQ (Signal *)
void	sendSTART_RECREQ (Signal *, Uint32 ssId, SectionHandle *)
void	execSTART_RECCONF (Signal *)
void	sendSTART_RECCONF (Signal *, Uint32 ssId)
Uint32	getSsId (const Ss_START_RECREQ_2::Req *req)
Uint32	getSsId (const Ss_START_RECREQ_2::Conf *conf)
void	execSTART_RECREQ_2 (Signal *)
void	sendSTART_RECREQ_2 (Signal *, Uint32 ssId)
void	execSTART_RECCONF_2 (Signal *)
void	sendSTART_RECCONF_2 (Signal *, Uint32 ssId, SectionHandle *)
void	execLQH_TRANSREQ (Signal *)
void	sendLQH_TRANSREQ (Signal *, Uint32 ssId, SectionHandle *)
void	execLQH_TRANSCONF (Signal *)
void	sendLQH_TRANSCONF (Signal *, Uint32 ssId)
Uint32	getSsId (const Ss_EXEC_SR_1::Sig *sig)
void	execEXEC_SRREQ (Signal *)
void	execEXEC_SRCONF (Signal *)
void	execEXEC_SR_1 (Signal *, GlobalSignalNumber gsn)
void	sendEXEC_SR_1 (Signal *, Uint32 ssId, SectionHandle *)
Uint32	getSsId (const Ss_EXEC_SR_2::Sig *sig)
void	execEXEC_SR_2 (Signal *, GlobalSignalNumber gsn)
void	sendEXEC_SR_2 (Signal *, Uint32 ssId)
void	execEXEC_FRAGREQ (Signal *)
void	execEXEC_FRAGCONF (Signal *)
Uint32	getSsId (const DropFragReq *req)
Uint32	getSsId (const DropFragConf *conf)
Uint32	getSsId (const DropFragRef *ref)
void	execDROP_FRAG_REQ (Signal *)
void	sendDROP_FRAG_REQ (Signal *, Uint32 ssId, SectionHandle *)
void	execDROP_FRAG_CONF (Signal *)
void	execDROP_FRAG_REF (Signal *)
void	sendDROP_FRAG_CONF (Signal *, Uint32 ssId)
void	execEMPTY_LCP_REQ (Signal *)
void	execLCP_FRAG_ORD (Signal *)
void	execLCP_FRAG_REP (Signal *)
void	execEND_LCP_CONF (Signal *)
void	execLCP_COMPLETE_REP (Signal *)
Uint32	getNoOfOutstanding (const LcpRecord &) const
void	completeLCP_1 (Signal *signal)
void	completeLCP_2 (Signal *signal)
void	completeLCP_3 (Signal *signal)
void	sendLCP_COMPLETE_REP (Signal *)
void	checkSendEMPTY_LCP_CONF_impl (Signal *signal)
void	checkSendEMPTY_LCP_CONF (Signal *signal)
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 *)
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 *)
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
Uint32	c_tableRecSize
Uint8 *	c_tableRec
SsPool< Ss_CREATE_TAB_REQ >	c_ss_CREATE_TAB_REQ
SsPool< Ss_LQHADDATTREQ >	c_ss_LQHADDATTREQ
SsPool< Ss_TAB_COMMITREQ >	c_ss_TAB_COMMITREQ
SsPool< Ss_GCP_SAVEREQ >	c_ss_GCP_SAVEREQ
SsPool< Ss_PREP_DROP_TAB_REQ >	c_ss_PREP_DROP_TAB_REQ
SsPool< Ss_DROP_TAB_REQ >	c_ss_DROP_TAB_REQ
SsPool< Ss_ALTER_TAB_REQ >	c_ss_ALTER_TAB_REQ
SsPool< Ss_START_RECREQ >	c_ss_START_RECREQ
SsPool< Ss_START_RECREQ_2 >	c_ss_START_RECREQ_2
SsPool< Ss_LQH_TRANSREQ >	c_ss_LQH_TRANSREQ
SsPool< Ss_EXEC_SR_1 >	c_ss_EXEC_SR_1
SsPool< Ss_EXEC_SR_2 >	c_ss_EXEC_SR_2
SsPool< Ss_DROP_FRAG_REQ >	c_ss_DROP_FRAG_REQ
LcpRecord	c_lcpRecord
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

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 33 of file DblqhProxy.hpp.

Member Function Documentation

void DblqhProxy::checkSendEMPTY_LCP_CONF_impl ( Signal *  signal )

protected

Given that we wait for all ongoing... we can simply return last LCP_FRAG_ORD sent to us

Definition at line 770 of file DblqhProxy.cpp.

void DblqhProxy::completeLCP_1 ( Signal *  signal )

protected

send LCP_FRAG_ORD (lastFragmentFlag = true) to all LQH instances... they will reply with LCP_COMPLETE_REP

send END_LCP_REQ to all pgman instances (except "extra" pgman) they will reply with END_LCP_CONF

Definition at line 583 of file DblqhProxy.cpp.

void DblqhProxy::completeLCP_2 ( Signal *  signal )

protected

send to "extra" instance that will checkpoint extent-pages

Definition at line 675 of file DblqhProxy.cpp.

void DblqhProxy::completeLCP_3 ( Signal *  signal )

protected

And finally also checkpoint UNDO LOG and inform TSMAN that checkpoint is "complete"

lgman does currently not like 0 fragments, cause then it does not get a LCP_FRAG_ORD

this should change so that it gets this first (style)

Definition at line 700 of file DblqhProxy.cpp.

void DblqhProxy::execEXEC_FRAGREQ ( Signal *  signal )

protected

GSN_EXEC_FRAGREQ & GSN_EXEC_FRAGCONF needs to be passed via proxy for correct serialization wrt to GSN_EXEC_SRREQ & GSN_EXEC_SRCONF

Definition at line 1616 of file DblqhProxy.cpp.

Here is the call graph for this function:

void DblqhProxy::execLCP_FRAG_ORD ( Signal *  signal )

protected

Wait for all LCP_FRAG_ORD/REP to complete

Send to lqh-0...that will handle it...

Definition at line 459 of file DblqhProxy.cpp.

Here is the call graph for this function:

void DblqhProxy::execLCP_FRAG_REP ( Signal *  signal )

protected

But instead of broadcasting to all DIH's send to local that will do the broadcast

lastFragmentFlag has arrived...

Definition at line 542 of file DblqhProxy.cpp.

void DblqhProxy::execLQH_TRANSCONF ( Signal *  signal )

protected

This is an in-flight signal to an old take-over "session"

When completing(LqhTransConf::LastTransConf) a LQH_TRANSREQ also check if one can release obsoleteded records

This could have been done on each LQH_TRANSCONF, but there is no urgency, so it's ok todo only on LastTransConf

Definition at line 1401 of file DblqhProxy.cpp.

void DblqhProxy::execLQH_TRANSREQ ( Signal *  signal )

protected

See if this is a "resend" (i.e multi TC failure) and if so, mark "old" record as invalid

Definition at line 1354 of file DblqhProxy.cpp.

Here is the call graph for this function:

void DblqhProxy::execLQHADDATTREQ ( Signal *  signal )

protected

Count LQHFRAGREQ, so that I can release CREATE_TAB_REQ after last attribute has been processed

Definition at line 250 of file DblqhProxy.cpp.

void DblqhProxy::execSTART_FRAGREQ ( Signal *  signal )

protected

GSN_START_FRAGREQ needs to be serialized wrt START_RECREQ so send it via proxy, even if DIH knows where to send it...

Definition at line 1159 of file DblqhProxy.cpp.

void DblqhProxy::sendLQHADDATTCONF ( Signal *  signal, Uint32  ssId  )

protected

All the attributes has been processed release create_table object

Definition at line 317 of file DblqhProxy.cpp.

void DblqhProxy::sendSTART_RECCONF ( Signal *  signal, Uint32  ssId  )

protected

There should be no disk-ops in flight here...check it

Definition at line 1232 of file DblqhProxy.cpp.

---

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

• storage/ndb/src/kernel/blocks/dblqh/DblqhProxy.hpp
• storage/ndb/src/kernel/blocks/dblqh/DblqhProxy.cpp