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

Classes

struct  AlterTabOperation
struct  Apply_undo
struct  BuildIndexRec
struct  ChangeMask
struct  Disk_alloc_info
struct  Disk_part_ref
struct  Disk_undo
struct  Extent_info
struct  Extent_list_t
struct  Fragoperrec
struct  Fragrecord
struct  HostBuffer
struct  KeyReqStruct
struct  Operationrec
struct  Page_request
struct  ScanLock
struct  ScanOp
struct  ScanPos
struct  storedProc
struct  SumaTriggerBuffer
struct  TableDescriptor
struct  Tablerec
struct  Tuple_header
struct  TupTriggerData
struct  Var_part_ref
struct  Varpart_copy

Public Types

enum  CallbackIndex {
  UNDO_CREATETABLE_LOGSYNC_CALLBACK = 1, DROP_TABLE_LOGSYNC_CALLBACK = 2, UNDO_CREATETABLE_CALLBACK = 3, DROP_TABLE_LOG_BUFFER_CALLBACK = 4,
  DROP_FRAGMENT_FREE_EXTENT_LOG_BUFFER_CALLBACK = 5, NR_DELETE_LOG_BUFFER_CALLBACK = 6, DISK_PAGE_LOG_BUFFER_CALLBACK = 7, COUNT_CALLBACKS = 8
}
enum  TransState {
  TRANS_IDLE = 0, TRANS_STARTED = 1, TRANS_NOT_USED_STATE = 2, TRANS_ERROR_WAIT_STORED_PROCREQ = 3,
  TRANS_ERROR_WAIT_TUPKEYREQ = 4, TRANS_TOO_MUCH_AI = 5, TRANS_DISCONNECTED = 6
}
enum  TupleState { TUPLE_PREPARED = 1, TUPLE_ALREADY_ABORTED = 2, TUPLE_TO_BE_COMMITTED = 3 }
enum  State {
  NOT_INITIALIZED = 0, IDLE = 17, ACTIVE = 18, SYSTEM_RESTART = 19,
  DEFINED = 34, NOT_DEFINED = 37, NORMAL_PAGE = 40, DEFINING = 65,
  DROPPING = 68
}
enum  When { KRS_PREPARE = 0, KRS_COMMIT = 1, KRS_PRE_COMMIT0 = 2, KRS_PRE_COMMIT1 = 3 }
typedef bool(Dbtup::* ReadFunction )(Uint8 *, KeyReqStruct *, AttributeHeader *, Uint32)
typedef bool(Dbtup::* UpdateFunction )(Uint32 *, KeyReqStruct *, Uint32)
typedef Ptr< Fragoperrec > FragoperrecPtr
typedef Ptr< AlterTabOperation > AlterTabOperationPtr
typedef Tup_page Page
typedef Ptr< Page > PagePtr
typedef Ptr< ScanLock > ScanLockPtr
typedef Ptr< ScanOp > ScanOpPtr
typedef RecordPool
< Page_request, WOPool > 		Page_request_pool
typedef DLFifoListImpl
< Page_request_pool,
Page_request > 		Page_request_list
typedef LocalDLFifoListImpl
< Page_request_pool,
Page_request > 		Local_page_request_list
typedef RecordPool
< Extent_info, RWPool > 		Extent_info_pool
typedef DLListImpl
< Extent_info_pool,
Extent_info > 		Extent_info_list
typedef LocalDLListImpl
< Extent_info_pool,
Extent_info > 		Local_extent_info_list
typedef DLHashTableImpl
< Extent_info_pool,
Extent_info > 		Extent_info_hash
typedef SLListImpl
< Extent_info_pool,
Extent_info, Extent_list_t > 		Fragment_extent_list
typedef LocalSLListImpl
< Extent_info_pool,
Extent_info, Extent_list_t > 		Local_fragment_extent_list
typedef Ptr< Fragrecord > FragrecordPtr
typedef Ptr< Operationrec > OperationrecPtr
typedef Ptr< TupTriggerData > TriggerPtr
typedef Ptr< Tablerec > TablerecPtr
typedef Ptr< storedProc > StoredProcPtr
typedef Ptr< TableDescriptor > TableDescriptorPtr
typedef Ptr< HostBuffer > HostBufferPtr
typedef Ptr< BuildIndexRec > BuildIndexPtr
- Public Types inherited from SimulatedBlock
typedef void(SimulatedBlock::* CallbackFunction )(class Signal *, Uint32 callbackData, Uint32 returnCode)

Public Member Functions

void scanReply (Signal *, ScanOpPtr scanPtr)
void scanFirst (Signal *, ScanOpPtr scanPtr)
bool scanNext (Signal *, ScanOpPtr scanPtr)
void scanCont (Signal *, ScanOpPtr scanPtr)
void disk_page_tup_scan_callback (Signal *, Uint32 scanPtrI, Uint32 page_i)
void scanClose (Signal *, ScanOpPtr scanPtr)
void addAccLockOp (ScanOp &scan, Uint32 accLockOp)
void removeAccLockOp (ScanOp &scan, Uint32 accLockOp)
void releaseScanOp (ScanOpPtr &scanPtr)
 STATIC_CONST (EXTENT_SEARCH_MATRIX_COLS=4)
 STATIC_CONST (EXTENT_SEARCH_MATRIX_ROWS=5)
 STATIC_CONST (EXTENT_SEARCH_MATRIX_SIZE=20)
void dump_disk_alloc (Disk_alloc_info &)
 STATIC_CONST (FREE_PAGE_BIT=0x80000000)
 STATIC_CONST (FREE_PAGE_RNIL=RNIL+1)
 STATIC_CONST (MM=0)
 STATIC_CONST (DD=1)
 STATIC_CONST (DYN_BM_LEN_BITS=8)
 STATIC_CONST (DYN_BM_LEN_MASK=((1<< DYN_BM_LEN_BITS)-1))
 STATIC_CONST (NO_DYNAMICS=2)
 STATIC_CONST (InternalMaxDynFix=16)
 RSS_AP_SNAPSHOT (c_storedProcPool)
void storedProcCountNonAPI (BlockReference apiBlockref, int add_del)
int mt_scan_init (Uint32 tableId, Uint32 fragId, Local_key *pos, Uint32 *fragPtrI)
int mt_scan_next (Uint32 tableId, Uint32 fragPtrI, Local_key *pos, bool moveNext)
 Dbtup (Block_context &, Uint32 instanceNumber=0)
void tuxGetTupAddr (Uint32 fragPtrI, Uint32 pageId, Uint32 pageOffset, Uint32 &lkey1, Uint32 &lkey2)
int tuxAllocNode (EmulatedJamBuffer *, Uint32 fragPtrI, Uint32 &pageId, Uint32 &pageOffset, Uint32 *&node)
void tuxFreeNode (Uint32 fragPtrI, Uint32 pageId, Uint32 pageOffset, Uint32 *node)
void tuxGetNode (Uint32 fragPtrI, Uint32 pageId, Uint32 pageOffset, Uint32 *&node)
int tuxReadAttrs (EmulatedJamBuffer *, Uint32 fragPtrI, Uint32 pageId, Uint32 pageOffset, Uint32 tupVersion, const Uint32 *attrIds, Uint32 numAttrs, Uint32 *dataOut, bool xfrmFlag)
int tuxReadPk (Uint32 fragPtrI, Uint32 pageId, Uint32 pageOffset, Uint32 *dataOut, bool xfrmFlag)
int accReadPk (Uint32 tableId, Uint32 fragId, Uint32 fragPageId, Uint32 pageIndex, Uint32 *dataOut, bool xfrmFlag)
bool tuxQueryTh (Uint32 fragPtrI, Uint32 pageId, Uint32 pageIndex, Uint32 tupVersion, Uint32 transId1, Uint32 transId2, bool dirty, Uint32 savepointId)
int load_diskpage (Signal *, Uint32 opRec, Uint32 fragPtrI, Uint32 lkey1, Uint32 lkey2, Uint32 flags)
int load_diskpage_scan (Signal *, Uint32 opRec, Uint32 fragPtrI, Uint32 lkey1, Uint32 lkey2, Uint32 flags)
void start_restore_lcp (Uint32 tableId, Uint32 fragmentId)
void complete_restore_lcp (Signal *, Uint32 ref, Uint32 data, Uint32 tableId, Uint32 fragmentId)
Uint32 get_max_lcp_record_size (Uint32 tableId)
int nr_read_pk (Uint32 fragPtr, const Local_key *, Uint32 *dataOut, bool &copy)
int nr_update_gci (Uint32 fragPtr, const Local_key *, Uint32 gci)
int nr_delete (Signal *, Uint32, Uint32 fragPtr, const Local_key *, Uint32 gci)
void nr_delete_page_callback (Signal *, Uint32 op, Uint32 page)
void nr_delete_log_buffer_callback (Signal *, Uint32 op, Uint32 page)
bool get_frag_info (Uint32 tableId, Uint32 fragId, Uint32 *maxPage)
Uint32 read_lcp_keys (Uint32, const Uint32 *src, Uint32 len, Uint32 *dst)
int disk_page_load_hook (Uint32 page_id)
void disk_page_unmap_callback (Uint32 when, Uint32 page, Uint32 dirty_count)
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 *, Uint32 bits)
void disk_restart_undo (Signal *signal, Uint64 lsn, Uint32 type, const Uint32 *ptr, Uint32 len)
void disk_restart_lcp_id (Uint32 table, Uint32 frag, Uint32 lcpId)
- 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

class Dblqh * c_lqh
Tsman * c_tsman
Lgman * c_lgman
Pgman * c_pgman
Ptr< GlobalPage > m_pgman_ptr
CallbackEntry m_callbackEntry [COUNT_CALLBACKS]
CallbackTable m_callbackTable
ArrayPool< ScanLock > c_scanLockPool
ArrayPool< ScanOp > c_scanOpPool
Uint64 c_dataBuffer [ZWORDS_ON_PAGE/2+1]
ArrayPool< TupTriggerData > c_triggerPool
Extent_info_pool c_extent_pool
Extent_info_hash c_extent_hash
Page_request_pool c_page_request_pool
ArrayPool< storedProc > c_storedProcPool
Uint32 c_storedProcCountNonAPI
ArrayPool< BuildIndexRec > c_buildIndexPool
DLList< BuildIndexRec > c_buildIndexList
Uint32 c_noOfBuildIndexRec
Undo_buffer c_undo_buffer
Uint32 terrorCode
- Public Attributes inherited from SimulatedBlock
MutexManager c_mutexMgr
SafeCounterManager c_counterMgr

Friends

class DbtupProxy
class Suma
struct KeyReqStruct
struct Undo_buffer

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)
- 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 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

Detailed Description

Definition at line 344 of file Dbtup.hpp.

Member Function Documentation

void Dbtup::complete_restore_lcp ( Signal *  signal,
Uint32  ref,
Uint32  data,
Uint32  tableId,
Uint32  fragmentId 
)

Rebuild free page list

Definition at line 2610 of file DbtupMeta.cpp.

Here is the call graph for this function:

int Dbtup::disk_page_load_hook ( Uint32  page_id)

Disk restart code

void Dbtup::disk_page_unmap_callback ( Uint32  when,
Uint32  page,
Uint32  dirty_count 
)

Before pageout

After page out

Definition at line 1030 of file DbtupDiskAlloc.cpp.

Here is the call graph for this function:

void Dbtup::disk_restart_undo ( Signal *  signal,
Uint64  lsn,
Uint32  type,
const Uint32 *  ptr,
Uint32  len 
)

Definition at line 1483 of file DbtupDiskAlloc.cpp.

Here is the call graph for this function:

int Dbtup::nr_delete ( Signal *  signal,
Uint32  senderData,
Uint32  fragPtr,
const Local_key *  key,
Uint32  gci 
)

1) alloc log buffer 2) get page 3) get log buffer 4) delete tuple

Definition at line 4252 of file DbtupExecQuery.cpp.

Here is the call graph for this function:

void Dbtup::nr_delete_log_buffer_callback ( Signal *  signal,
Uint32  op,
Uint32  page 
)

reset page no

Definition at line 4436 of file DbtupExecQuery.cpp.

Here is the call graph for this function:

Uint32 Dbtup::read_lcp_keys ( Uint32  tableId,
const Uint32 *  src,
Uint32  len,
Uint32 *  dst 
)

Used by Restore...

This is a "special" prepare_read

prepare_read...

Definition at line 3459 of file DbtupRoutines.cpp.

bool Dbtup::scanNext ( Signal *  signal,
ScanOpPtr  scanPtr 
)

Handle lcp keep list here to, due to scanCont

We need to refetch page after timeslice

Definition at line 669 of file DbtupScan.cpp.

Here is the call graph for this function:

Member Data Documentation

ArrayPool<TupTriggerData> Dbtup::c_triggerPool

Pool of trigger data record

Definition at line 953 of file Dbtup.hpp.

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