The world's most popular open source database

MySQL 5.1: mysql/src/5.1-dbg/storage/ndb/src/kernel/blocks/dbdict/Dbdict.cpp File Reference

mysql/src/5.1-dbg/storage/ndb/src/kernel/blocks/dbdict/Dbdict.cpp File Reference

#include <ndb_global.h>
#include <my_sys.h>
#include "Dbdict.hpp"
#include <ndb_limits.h>
#include <NdbOut.hpp>
#include <Properties.hpp>
#include <Configuration.hpp>
#include <SectionReader.hpp>
#include <SimpleProperties.hpp>
#include <AttributeHeader.hpp>
#include <KeyDescriptor.hpp>
#include <signaldata/DictSchemaInfo.hpp>
#include <signaldata/DictTabInfo.hpp>
#include <signaldata/DropTabFile.hpp>
#include <signaldata/EventReport.hpp>
#include <signaldata/FsCloseReq.hpp>
#include <signaldata/FsConf.hpp>
#include <signaldata/FsOpenReq.hpp>
#include <signaldata/FsReadWriteReq.hpp>
#include <signaldata/FsRef.hpp>
#include <signaldata/GetTabInfo.hpp>
#include <signaldata/GetTableId.hpp>
#include <signaldata/HotSpareRep.hpp>
#include <signaldata/NFCompleteRep.hpp>
#include <signaldata/NodeFailRep.hpp>
#include <signaldata/ReadNodesConf.hpp>
#include <signaldata/RelTabMem.hpp>
#include <signaldata/WaitGCP.hpp>
#include <signaldata/ListTables.hpp>
#include <signaldata/CreateTrig.hpp>
#include <signaldata/AlterTrig.hpp>
#include <signaldata/DropTrig.hpp>
#include <signaldata/CreateIndx.hpp>
#include <signaldata/DropIndx.hpp>
#include <signaldata/BuildIndx.hpp>
#include <signaldata/DropFilegroup.hpp>
#include <signaldata/CreateFilegroup.hpp>
#include <signaldata/CreateFilegroupImpl.hpp>
#include <signaldata/CreateEvnt.hpp>
#include <signaldata/UtilPrepare.hpp>
#include <signaldata/UtilExecute.hpp>
#include <signaldata/UtilRelease.hpp>
#include <signaldata/SumaImpl.hpp>
#include <signaldata/LqhFrag.hpp>
#include <signaldata/DiAddTab.hpp>
#include <signaldata/DihStartTab.hpp>
#include <signaldata/DropTable.hpp>
#include <signaldata/DropTab.hpp>
#include <signaldata/PrepDropTab.hpp>
#include <signaldata/CreateTable.hpp>
#include <signaldata/AlterTable.hpp>
#include <signaldata/AlterTab.hpp>
#include <signaldata/CreateFragmentation.hpp>
#include <signaldata/CreateTab.hpp>
#include <NdbSleep.h>
#include <signaldata/ApiBroadcast.hpp>
#include <signaldata/DropObj.hpp>
#include <signaldata/CreateObj.hpp>
#include <SLList.hpp>
#include <ndb_version.h>
#include <DebuggerNames.hpp>

Include dependency graph for Dbdict.cpp:

Go to the source code of this file.


Defines
#define	DBDICT_C
#define	ZNOT_FOUND 626
#define	ZALREADYEXIST 630
#define	EVENT_TRACE
#define	DIV(x, y) (((x)+(y)-1)/(y))
#define	WORDS2PAGES(x) DIV(x, (ZSIZE_OF_PAGES_IN_WORDS - ZPAGE_HEADER_SIZE))
#define	MEMINFO(x, y) infoEvent(x ": %d %d", y.getSize(), y.getNoOfFree())
#define	tabRequire(cond, error)
Functions
Uint32	alter_obj_inc_schema_version (Uint32 old)
static Uint32	alter_obj_dec_schema_version (Uint32 old)
static Uint32	create_obj_inc_schema_version (Uint32 old)
static bool	checkSchemaStatus (Uint32 tableType, Uint32 pass)
void	getSection (SegmentedSectionPtr &ptr, Uint32 i)
static void	calcLHbits (Uint32 lhPageBits, Uint32 lhDistrBits, Uint32 fid, Uint32 totalFragments)
void	interpretUtilPrepareErrorCode (UtilPrepareRef::ErrorCode errorCode, Uint32 &error, Uint32 &line)
Variables
static const char	EVENT_SYSTEM_TABLE_NAME [] = "sys/def/NDB$EVENTS_0"
struct {
Uint32 m_gsn_user_req
Uint32 m_gsn_req
Uint32 m_gsn_ref
Uint32 m_gsn_conf
void(Dbdict::* m_trans_commit_start )(Signal , Dbdict::SchemaTransaction )
void(Dbdict::* m_trans_commit_complete )(Signal , Dbdict::SchemaTransaction )
void(Dbdict::* m_trans_abort_start )(Signal , Dbdict::SchemaTransaction )
void(Dbdict::* m_trans_abort_complete )(Signal , Dbdict::SchemaTransaction )
void(Dbdict::* m_prepare_start )(Signal , Dbdict::SchemaOp )
void(Dbdict::* m_prepare_complete )(Signal , Dbdict::SchemaOp )
void(Dbdict::* m_commit )(Signal , Dbdict::SchemaOp )
void(Dbdict::* m_commit_start )(Signal , Dbdict::SchemaOp )
void(Dbdict::* m_commit_complete )(Signal , Dbdict::SchemaOp )
void(Dbdict::* m_abort )(Signal , Dbdict::SchemaOp )
void(Dbdict::* m_abort_start )(Signal , Dbdict::SchemaOp )
void(Dbdict::* m_abort_complete )(Signal , Dbdict::SchemaOp )
}	f_dict_op []

Define Documentation

#define DBDICT_C

Definition at line 20 of file Dbdict.cpp.

#define DIV	(	x,
		y		)	(((x)+(y)-1)/(y))

Definition at line 101 of file Dbdict.cpp.

#define EVENT_TRACE

Definition at line 98 of file Dbdict.cpp.

Referenced by Dbdict::createEvent_RT_USER_GET(), Dbdict::createEvent_sendReply(), Dbdict::createEventUTIL_EXECUTE(), Dbdict::createEventUTIL_PREPARE(), Dbdict::dropEvent_sendReply(), Dbdict::dropEventUTIL_EXECUTE_DELETE(), Dbdict::dropEventUTIL_EXECUTE_READ(), Dbdict::dropEventUTIL_PREPARE_DELETE(), Dbdict::dropEventUTIL_PREPARE_READ(), Dbdict::dropEventUtilExecuteRef(), Dbdict::dropEventUtilPrepareRef(), Dbdict::execCREATE_EVNT_CONF(), Dbdict::execCREATE_EVNT_REF(), Dbdict::execCREATE_EVNT_REQ(), Dbdict::execSUB_CREATE_CONF(), Dbdict::executeTransaction(), Dbdict::executeTransEventSysTable(), Dbdict::execUTIL_EXECUTE_CONF(), Dbdict::execUTIL_EXECUTE_REF(), Dbdict::execUTIL_PREPARE_CONF(), Dbdict::execUTIL_PREPARE_REF(), Dbdict::execUTIL_RELEASE_CONF(), Dbdict::execUTIL_RELEASE_REF(), Dbdict::prepareUtilTransaction(), Dbdict::recvSignalUtilReq(), and Dbdict::sendSignalUtilReq().

#define MEMINFO	(	x,
		y		)	infoEvent(x ": %d %d", y.getSize(), y.getNoOfFree())

Referenced by Dbdict::execDUMP_STATE_ORD().

#define tabRequire	(	cond,
		error		)

Value:

if (!(cond)) { \
    jam();    \
    parseP->errorCode = error; parseP->errorLine = __LINE__; \
    parseP->errorKey = it.getKey(); \
    return;   \
  }

Definition at line 5796 of file Dbdict.cpp.

Referenced by Dbdict::handleTabInfo(), and Dbdict::handleTabInfoInit().

#define WORDS2PAGES ( x ) DIV(x, (ZSIZE_OF_PAGES_IN_WORDS - ZPAGE_HEADER_SIZE))

Definition at line 102 of file Dbdict.cpp.

Referenced by Dbdict::packTableIntoPages(), Dbdict::readTableConf(), Dbdict::readTableFile(), and Dbdict::writeTableFile().

#define ZALREADYEXIST 630

Definition at line 90 of file Dbdict.cpp.

Referenced by Dbdict::createEventUTIL_EXECUTE(), and Dbtc::execLQHKEYREF().

#define ZNOT_FOUND 626

Definition at line 89 of file Dbdict.cpp.

Referenced by Dbdict::createEventUTIL_EXECUTE(), Dbdict::dropEventUtilExecuteRef(), Dbtc::execLQHKEYREF(), and Dblqh::findTransaction().

Function Documentation

static Uint32 alter_obj_dec_schema_version ( Uint32 old ) [static]

Definition at line 204 of file Dbdict.cpp.

Referenced by Dbdict::alterTab_writeTableConf(), and Dbdict::revertAlterTable().

00205 {
00206   return (old & 0x00FFFFFF) + ((old - 0x1000000) & 0xFF000000);
00207 }

Here is the caller graph for this function:

Uint32 alter_obj_inc_schema_version ( Uint32 old )

Definition at line 197 of file Dbdict.cpp.

Referenced by Dbdict::alterTable_backup_mutex_locked(), Dbdict::execALTER_TAB_REQ(), and Dbdict::updateSchemaState().

00198 {
00199    return (old & 0x00FFFFFF) + ((old + 0x1000000) & 0xFF000000);
00200 }

Here is the caller graph for this function:

static void calcLHbits	(	Uint32 *	lhPageBits,
		Uint32 *	lhDistrBits,
		Uint32	fid,
		Uint32	totalFragments
	)			`[static]`

Definition at line 5267 of file Dbdict.cpp.

References jam, and pageBits.

Referenced by Dbdict::execADD_FRAGREQ().

05269 {
05270   Uint32 distrBits = 0;
05271   Uint32 pageBits = 0;
05272   
05273   Uint32 tmp = 1;
05274   while (tmp < totalFragments) {
05275     jam();
05276     tmp <<= 1;
05277     distrBits++;
05278   }//while
05279 #ifdef ndb_classical_lhdistrbits
05280   if (tmp != totalFragments) {
05281     tmp >>= 1;
05282     if ((fid >= (totalFragments - tmp)) && (fid < (tmp - 1))) {
05283       distrBits--;
05284     }//if
05285   }//if
05286 #endif
05287   * lhPageBits = pageBits;
05288   * lhDistrBits = distrBits;
05289 
05290 }//calcLHbits()

Here is the caller graph for this function:

static bool checkSchemaStatus	(	Uint32	tableType,
		Uint32	pass
	)			`[static]`

Definition at line 2637 of file Dbdict.cpp.

References DictTabInfo::Datafile, DictTabInfo::HashIndex, DictTabInfo::HashIndexTrigger, DictTabInfo::IndexTrigger, DictTabInfo::LogfileGroup, DictTabInfo::OrderedIndex, DictTabInfo::ReadOnlyConstraint, DictTabInfo::SubscriptionTrigger, DictTabInfo::SystemTable, DictTabInfo::Tablespace, DictTabInfo::UndefTableType, DictTabInfo::Undofile, DictTabInfo::UniqueHashIndex, DictTabInfo::UniqueOrderedIndex, and DictTabInfo::UserTable.

02638 {
02639   switch(tableType){
02640   case DictTabInfo::UndefTableType:
02641     return true;
02642   case DictTabInfo::HashIndexTrigger:
02643   case DictTabInfo::SubscriptionTrigger:
02644   case DictTabInfo::ReadOnlyConstraint:
02645   case DictTabInfo::IndexTrigger:
02646     return false;
02647   case DictTabInfo::LogfileGroup:
02648     return pass == 0;
02649   case DictTabInfo::Tablespace:
02650     return pass == 1;
02651   case DictTabInfo::Datafile:
02652   case DictTabInfo::Undofile:
02653     return pass == 2;
02654   case DictTabInfo::SystemTable:
02655   case DictTabInfo::UserTable:
02656     return pass == 3;
02657   case DictTabInfo::UniqueHashIndex:
02658   case DictTabInfo::HashIndex:
02659   case DictTabInfo::UniqueOrderedIndex:
02660   case DictTabInfo::OrderedIndex:
02661     return pass == 4;
02662   }
02663   
02664   return false;
02665 }

static Uint32 create_obj_inc_schema_version ( Uint32 old ) [static]

Definition at line 211 of file Dbdict.cpp.

Referenced by Dbdict::execCREATE_FILE_REQ(), Dbdict::execCREATE_FILEGROUP_REQ(), Dbdict::execCREATE_FRAGMENTATION_CONF(), and Dbdict::updateSchemaState().

00212 {
00213   return (old + 0x00000001) & 0x00FFFFFF;
00214 }

Here is the caller graph for this function:

void getSection	(	SegmentedSectionPtr &	ptr,
		Uint32	i
	)

Definition at line 173 of file TransporterCallback.cpp.

Referenced by Dbdict::alterTab_writeSchemaConf(), Dbdict::alterTab_writeTableConf(), Dbdict::alterTable_backup_mutex_locked(), Dbdict::create_fg_prepare_start(), Dbdict::create_file_prepare_start(), Dbdict::createObj_prepare_start_done(), Dbdict::createObj_writeSchemaConf1(), Dbdict::createTab_alterComplete(), Dbdict::createTab_writeSchemaConf1(), Dbdict::createTab_writeTableConf(), Dbdict::releaseCreateTableOp(), Dbdict::restartCreateObj_prepare_start_done(), and Dbdict::restartCreateObj_write_complete().

00173                                                {
00174   ptr.i = i;
00175   SectionSegment * p = g_sectionSegmentPool.getPtr(i);
00176   ptr.p = p;
00177   ptr.sz = p->m_sz;
00178 }

Here is the caller graph for this function:

void interpretUtilPrepareErrorCode	(	UtilPrepareRef::ErrorCode	errorCode,
		Uint32 &	error,
		Uint32 &	line
	)

Definition at line 9098 of file Dbdict.cpp.

References DBUG_ENTER, DBUG_VOID_RETURN, UtilPrepareRef::DICT_TAB_INFO_ERROR, jam, UtilPrepareRef::MISSING_PROPERTIES_SECTION, UtilPrepareRef::NO_ERROR, UtilPrepareRef::PREPARE_PAGES_SEIZE_ERROR, UtilPrepareRef::PREPARE_SEIZE_ERROR, and UtilPrepareRef::PREPARED_OPERATION_SEIZE_ERROR.

Referenced by Dbdict::createEventUTIL_PREPARE(), and Dbdict::dropEventUtilPrepareRef().

09100 {
09101   DBUG_ENTER("interpretUtilPrepareErrorCode");
09102   switch (errorCode) {
09103   case UtilPrepareRef::NO_ERROR:
09104     jam();
09105     error = 1;
09106     line = __LINE__;
09107     DBUG_VOID_RETURN;
09108   case UtilPrepareRef::PREPARE_SEIZE_ERROR:
09109     jam();
09110     error = 748;
09111     line = __LINE__;
09112     DBUG_VOID_RETURN;
09113   case UtilPrepareRef::PREPARE_PAGES_SEIZE_ERROR:
09114     jam();
09115     error = 1;
09116     line = __LINE__;
09117     DBUG_VOID_RETURN;
09118   case UtilPrepareRef::PREPARED_OPERATION_SEIZE_ERROR:
09119     jam();
09120     error = 1;
09121     line = __LINE__;
09122     DBUG_VOID_RETURN;
09123   case UtilPrepareRef::DICT_TAB_INFO_ERROR:
09124     jam();
09125     error = 1;
09126     line = __LINE__;
09127     DBUG_VOID_RETURN;
09128   case UtilPrepareRef::MISSING_PROPERTIES_SECTION:
09129     jam();
09130     error = 1;
09131     line = __LINE__;
09132     DBUG_VOID_RETURN;
09133   default:
09134     jam();
09135     error = 1;
09136     line = __LINE__;
09137     DBUG_VOID_RETURN;
09138   }
09139   DBUG_VOID_RETURN;
09140 }