Lgman Class Reference

Inheritance diagram for Lgman:

Collaboration diagram for Lgman:

Classes
struct	Buffer_idx
struct	Log_waiter
struct	Logfile_group
struct	Undofile

Public Types
enum	CallbackIndex { ENDLCP_CALLBACK = 1, COUNT_CALLBACKS = 2 }
typedef RecordPool< Log_waiter, WOPool >	Log_waiter_pool
typedef SLFifoListImpl < Log_waiter_pool, Log_waiter >	Log_waiter_list
typedef LocalSLFifoListImpl < Log_waiter_pool, Log_waiter >	Local_log_waiter_list
typedef RecordPool< Undofile, RWPool >	Undofile_pool
typedef DLFifoListImpl < Undofile_pool, Undofile >	Undofile_list
typedef LocalDLFifoListImpl < Undofile_pool, Undofile >	Local_undofile_list
typedef LocalDataBuffer< 15 >	Page_map
typedef RecordPool < Logfile_group, RWPool >	Logfile_group_pool
typedef DLFifoListImpl < Logfile_group_pool, Logfile_group >	Logfile_group_list
typedef LocalDLFifoListImpl < Logfile_group_pool, Logfile_group >	Local_logfile_group_list
typedef KeyTableImpl < Logfile_group_pool, Logfile_group >	Logfile_group_hash
typedef KeyTableImpl < Logfile_group_pool, Logfile_group >::Iterator	Logfile_group_hash_iterator
Public Types inherited from SimulatedBlock
typedef void(SimulatedBlock::*	CallbackFunction )(class Signal *, Uint32 callbackData, Uint32 returnCode)

Public Member Functions
	Lgman (Block_context &ctx)
	BLOCK_DEFINES (Lgman)
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)

Public Attributes
CallbackEntry	m_callbackEntry [COUNT_CALLBACKS]
CallbackTable	m_callbackTable
Public Attributes inherited from SimulatedBlock
MutexManager	c_mutexMgr
SafeCounterManager	c_counterMgr

Protected Member Functions
void	execSTTOR (Signal *signal)
void	sendSTTORRY (Signal *)
void	execREAD_CONFIG_REQ (Signal *signal)
void	execDUMP_STATE_ORD (Signal *signal)
void	execDBINFO_SCANREQ (Signal *signal)
void	execCONTINUEB (Signal *signal)
void	execNODE_FAILREP (Signal *signal)
void	execCREATE_FILE_IMPL_REQ (Signal *signal)
void	execCREATE_FILEGROUP_IMPL_REQ (Signal *signal)
void	execDROP_FILE_IMPL_REQ (Signal *signal)
void	execDROP_FILEGROUP_IMPL_REQ (Signal *signal)
void	execFSWRITEREQ (Signal *)
void	execFSWRITEREF (Signal *)
void	execFSWRITECONF (Signal *)
void	execFSOPENREF (Signal *)
void	execFSOPENCONF (Signal *)
void	execFSCLOSEREF (Signal *)
void	execFSCLOSECONF (Signal *)
void	execFSREADREF (Signal *)
void	execFSREADCONF (Signal *)
void	execLCP_FRAG_ORD (Signal *)
void	execEND_LCP_REQ (Signal *)
void	execSUB_GCP_COMPLETE_REP (Signal *)
void	execSTART_RECREQ (Signal *)
void	execEND_LCP_CONF (Signal *)
void	execGET_TABINFOREQ (Signal *)
void	sendGET_TABINFOREF (Signal *signal, GetTabInfoReq *req, GetTabInfoRef::ErrorCode errorCode)
void	exec_lcp_frag_ord (Signal *, SimulatedBlock *client_block)
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	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	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

Friends
class	Logfile_client

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)
Protected Types inherited from SimulatedBlock
enum	CallbackFlags { CALLBACK_DIRECT = 0x0001, CALLBACK_ACK = 0x0002 }
enum	{ THE_NULL_CALLBACK = 0 }
typedef void(SimulatedBlock::*	ExecFunction )(Signal *signal)
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

Detailed Description

Definition at line 37 of file lgman.hpp.

Member Function Documentation

void Lgman::exec_lcp_frag_ord ( Signal *  signal, SimulatedBlock *  client_block  )

protected

First LCP_FRAGORD for each LCP, sets tail pos

Definition at line 2132 of file lgman.cpp.

void Lgman::execEND_LCP_CONF ( Signal *  signal )

protected

pgman has completed flushing all pages

insert "fake" LCP record preventing undo to be "rerun"

Definition at line 3472 of file lgman.cpp.

Here is the call graph for this function:

void Lgman::execFSREADCONF ( Signal *  signal )

protected

Prepare for execution

Insert into m_files

File has highest lsn, add last

Insert file in correct position in file list

Definition at line 2584 of file lgman.cpp.

Here is the call graph for this function:

void Lgman::execSUB_GCP_COMPLETE_REP ( Signal *  signal )

protected

Filter all logfile groups in parallell

Definition at line 2337 of file lgman.cpp.

void Lgman::sendGET_TABINFOREF ( Signal *  signal, GetTabInfoReq *  req, GetTabInfoRef::ErrorCode  errorCode  )

protected

The format of GetTabInfo Req/Ref is the same

Definition at line 3614 of file lgman.cpp.

Here is the call graph for this function:

---

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

• storage/ndb/src/kernel/blocks/lgman.hpp
• storage/ndb/src/kernel/blocks/lgman.cpp