Merge joreland@bk-internal.mysql.com:/home/bk/mysql-5.0-ndb

into mysql.com:/home/jonas/src/mysql-5.0-ndb
This commit is contained in:
joreland@mysql.com 2005-03-15 20:17:00 +01:00
commit 9ab5f5c0d9
4 changed files with 79 additions and 6 deletions

View file

@ -204,6 +204,81 @@ Dbacc::Dbacc(const class Configuration & conf):
addRecSignal(GSN_SET_VAR_REQ, &Dbacc::execSET_VAR_REQ);
initData();
#ifdef VM_TRACE
{
void* tmp[] = { &expDirRangePtr,
&gnsDirRangePtr,
&newDirRangePtr,
&rdDirRangePtr,
&nciOverflowrangeptr,
&expDirptr,
&rdDirptr,
&sdDirptr,
&nciOverflowDirptr,
&fragrecptr,
&fsConnectptr,
&fsOpptr,
&lcpConnectptr,
&operationRecPtr,
&idrOperationRecPtr,
&copyInOperPtr,
&copyOperPtr,
&mlpqOperPtr,
&queOperPtr,
&readWriteOpPtr,
&tgnptMainOpPtr,
&iopOverflowRecPtr,
&tfoOverflowRecPtr,
&porOverflowRecPtr,
&priOverflowRecPtr,
&rorOverflowRecPtr,
&sorOverflowRecPtr,
&troOverflowRecPtr,
&ancPageptr,
&colPageptr,
&ccoPageptr,
&datapageptr,
&delPageptr,
&excPageptr,
&expPageptr,
&gdiPageptr,
&gePageptr,
&gflPageptr,
&idrPageptr,
&ilcPageptr,
&inpPageptr,
&iopPageptr,
&lastPageptr,
&lastPrevpageptr,
&lcnPageptr,
&lcnCopyPageptr,
&lupPageptr,
&priPageptr,
&pwiPageptr,
&ciPageidptr,
&gsePageidptr,
&isoPageptr,
&nciPageidptr,
&rsbPageidptr,
&rscPageidptr,
&slPageidptr,
&sscPageidptr,
&rlPageptr,
&rlpPageptr,
&ropPageptr,
&rpPageptr,
&slPageptr,
&spPageptr,
&rootfragrecptr,
&scanPtr,
&srVersionPtr,
&tabptr,
&undopageptr
};
init_globals_list(tmp, sizeof(tmp)/sizeof(tmp[0]));
}
#endif
}//Dbacc::Dbacc()
Dbacc::~Dbacc()

View file

@ -2449,14 +2449,14 @@ void Dbacc::execACC_COMMITREQ(Signal* signal)
operationRecPtr.p->transactionstate = IDLE;
operationRecPtr.p->operation = ZUNDEFINED_OP;
if(Toperation != ZREAD){
rootfragrecptr.i = fragrecptr.p->myroot;
ptrCheckGuard(rootfragrecptr, crootfragmentsize, rootfragmentrec);
rootfragrecptr.p->m_commit_count++;
if (Toperation != ZINSERT) {
if (Toperation != ZDELETE) {
return;
} else {
jam();
rootfragrecptr.i = fragrecptr.p->myroot;
ptrCheckGuard(rootfragrecptr, crootfragmentsize, rootfragmentrec);
rootfragrecptr.p->noOfElements--;
fragrecptr.p->slack += operationRecPtr.p->insertDeleteLen;
if (fragrecptr.p->slack > fragrecptr.p->slackCheck) {
@ -2476,8 +2476,6 @@ void Dbacc::execACC_COMMITREQ(Signal* signal)
}//if
} else {
jam(); /* EXPAND PROCESS HANDLING */
rootfragrecptr.i = fragrecptr.p->myroot;
ptrCheckGuard(rootfragrecptr, crootfragmentsize, rootfragmentrec);
rootfragrecptr.p->noOfElements++;
fragrecptr.p->slack -= operationRecPtr.p->insertDeleteLen;
if (fragrecptr.p->slack >= (1u << 31)) {

View file

@ -5698,7 +5698,7 @@ extern "C" pthread_handler_decl(ndb_util_thread_func,
}
List<NDB_SHARE> util_open_tables;
set_timespec(abstime, ndb_cache_check_time);
set_timespec(abstime, 0);
for (;;)
{
@ -5716,6 +5716,7 @@ extern "C" pthread_handler_decl(ndb_util_thread_func,
if (ndb_cache_check_time == 0)
{
/* Wake up in 10 seconds to check if value has changed */
set_timespec(abstime, 10);
continue;
}

View file

@ -1150,7 +1150,6 @@ public:
table_map used_tables;
USER_CONN *user_connect;
CHARSET_INFO *db_charset;
List<TABLE> temporary_tables_should_be_free; // list of temporary tables
/*
FIXME: this, and some other variables like 'count_cuted_fields'
maybe should be statement/cursor local, that is, moved to Statement