Commit 50e3a9cd authored by stewart@mysql.com's avatar stewart@mysql.com

Merge mysql.com:/home/stewart/Documents/MySQL/5.0/main

into  mysql.com:/home/stewart/Documents/MySQL/5.0/cleanup
parents f2b1e403 cd8b89d3
...@@ -3871,7 +3871,7 @@ Backup::checkFile(Signal* signal, BackupFilePtr filePtr) ...@@ -3871,7 +3871,7 @@ Backup::checkFile(Signal* signal, BackupFilePtr filePtr)
req->userReference = reference(); req->userReference = reference();
req->varIndex = 0; req->varIndex = 0;
req->offset = tmp - c_startOfPages; req->offset = tmp - c_startOfPages;
req->size = sz; // Avrunda uppot req->size = sz; // Round up
sendSignal(NDBFS_REF, GSN_FSAPPENDREQ, signal, sendSignal(NDBFS_REF, GSN_FSAPPENDREQ, signal,
FsAppendReq::SignalLength, JBA); FsAppendReq::SignalLength, JBA);
......
...@@ -11135,7 +11135,11 @@ void Dbdih::initCommonData() ...@@ -11135,7 +11135,11 @@ void Dbdih::initCommonData()
cnoReplicas = 1; cnoReplicas = 1;
ndb_mgm_get_int_parameter(p, CFG_DB_NO_REPLICAS, &cnoReplicas); ndb_mgm_get_int_parameter(p, CFG_DB_NO_REPLICAS, &cnoReplicas);
cnoReplicas = cnoReplicas > 4 ? 4 : cnoReplicas; if (cnoReplicas > 4)
{
progError(__LINE__, NDBD_EXIT_INVALID_CONFIG,
"Only up to four replicas are supported. Check NoOfReplicas.");
}
cgcpDelay = 2000; cgcpDelay = 2000;
ndb_mgm_get_int_parameter(p, CFG_DB_GCP_INTERVAL, &cgcpDelay); ndb_mgm_get_int_parameter(p, CFG_DB_GCP_INTERVAL, &cgcpDelay);
...@@ -11723,14 +11727,14 @@ void Dbdih::execCHECKNODEGROUPSREQ(Signal* signal) ...@@ -11723,14 +11727,14 @@ void Dbdih::execCHECKNODEGROUPSREQ(Signal* signal)
break; break;
case CheckNodeGroups::GetNodeGroupMembers: { case CheckNodeGroups::GetNodeGroupMembers: {
ok = true; ok = true;
Uint32 ownNodeGoup = Uint32 ownNodeGroup =
Sysfile::getNodeGroup(sd->nodeId, SYSFILE->nodeGroups); Sysfile::getNodeGroup(sd->nodeId, SYSFILE->nodeGroups);
sd->output = ownNodeGoup; sd->output = ownNodeGroup;
sd->mask.clear(); sd->mask.clear();
NodeGroupRecordPtr ngPtr; NodeGroupRecordPtr ngPtr;
ngPtr.i = ownNodeGoup; ngPtr.i = ownNodeGroup;
ptrAss(ngPtr, nodeGroupRecord); ptrAss(ngPtr, nodeGroupRecord);
for (Uint32 j = 0; j < ngPtr.p->nodeCount; j++) { for (Uint32 j = 0; j < ngPtr.p->nodeCount; j++) {
jam(); jam();
...@@ -11738,7 +11742,7 @@ void Dbdih::execCHECKNODEGROUPSREQ(Signal* signal) ...@@ -11738,7 +11742,7 @@ void Dbdih::execCHECKNODEGROUPSREQ(Signal* signal)
} }
#if 0 #if 0
for (int i = 0; i < MAX_NDB_NODES; i++) { for (int i = 0; i < MAX_NDB_NODES; i++) {
if (ownNodeGoup == if (ownNodeGroup ==
Sysfile::getNodeGroup(i, SYSFILE->nodeGroups)) { Sysfile::getNodeGroup(i, SYSFILE->nodeGroups)) {
sd->mask.set(i); sd->mask.set(i);
} }
......
...@@ -18578,60 +18578,54 @@ void ...@@ -18578,60 +18578,54 @@ void
Dblqh::execCREATE_TRIG_REQ(Signal* signal) Dblqh::execCREATE_TRIG_REQ(Signal* signal)
{ {
jamEntry(); jamEntry();
NodeId myNodeId = getOwnNodeId();
BlockReference tupref = calcTupBlockRef(myNodeId);
sendSignal(tupref, GSN_CREATE_TRIG_REQ, signal, CreateTrigReq::SignalLength, JBB); sendSignal(DBTUP_REF, GSN_CREATE_TRIG_REQ, signal,
CreateTrigReq::SignalLength, JBB);
} }
void void
Dblqh::execCREATE_TRIG_CONF(Signal* signal) Dblqh::execCREATE_TRIG_CONF(Signal* signal)
{ {
jamEntry(); jamEntry();
NodeId myNodeId = getOwnNodeId();
BlockReference dictref = calcDictBlockRef(myNodeId);
sendSignal(dictref, GSN_CREATE_TRIG_CONF, signal, CreateTrigConf::SignalLength, JBB); sendSignal(DBDICT_REF, GSN_CREATE_TRIG_CONF, signal,
CreateTrigConf::SignalLength, JBB);
} }
void void
Dblqh::execCREATE_TRIG_REF(Signal* signal) Dblqh::execCREATE_TRIG_REF(Signal* signal)
{ {
jamEntry(); jamEntry();
NodeId myNodeId = getOwnNodeId();
BlockReference dictref = calcDictBlockRef(myNodeId);
sendSignal(dictref, GSN_CREATE_TRIG_REF, signal, CreateTrigRef::SignalLength, JBB); sendSignal(DBDICT_REF, GSN_CREATE_TRIG_REF, signal,
CreateTrigRef::SignalLength, JBB);
} }
void void
Dblqh::execDROP_TRIG_REQ(Signal* signal) Dblqh::execDROP_TRIG_REQ(Signal* signal)
{ {
jamEntry(); jamEntry();
NodeId myNodeId = getOwnNodeId();
BlockReference tupref = calcTupBlockRef(myNodeId);
sendSignal(tupref, GSN_DROP_TRIG_REQ, signal, DropTrigReq::SignalLength, JBB); sendSignal(DBTUP_REF, GSN_DROP_TRIG_REQ, signal,
DropTrigReq::SignalLength, JBB);
} }
void void
Dblqh::execDROP_TRIG_CONF(Signal* signal) Dblqh::execDROP_TRIG_CONF(Signal* signal)
{ {
jamEntry(); jamEntry();
NodeId myNodeId = getOwnNodeId();
BlockReference dictref = calcDictBlockRef(myNodeId);
sendSignal(dictref, GSN_DROP_TRIG_CONF, signal, DropTrigConf::SignalLength, JBB); sendSignal(DBDICT_REF, GSN_DROP_TRIG_CONF, signal,
DropTrigConf::SignalLength, JBB);
} }
void void
Dblqh::execDROP_TRIG_REF(Signal* signal) Dblqh::execDROP_TRIG_REF(Signal* signal)
{ {
jamEntry(); jamEntry();
NodeId myNodeId = getOwnNodeId();
BlockReference dictref = calcDictBlockRef(myNodeId);
sendSignal(dictref, GSN_DROP_TRIG_REF, signal, DropTrigRef::SignalLength, JBB); sendSignal(DBDICT_REF, GSN_DROP_TRIG_REF, signal,
DropTrigRef::SignalLength, JBB);
} }
Uint32 Dblqh::calcPageCheckSum(LogPageRecordPtr logP){ Uint32 Dblqh::calcPageCheckSum(LogPageRecordPtr logP){
......
...@@ -146,9 +146,9 @@ foreach(@{$tables}) ...@@ -146,9 +146,9 @@ foreach(@{$tables})
elsif($type =~ /varchar/ || $type =~ /varbinary/) elsif($type =~ /varchar/ || $type =~ /varbinary/)
{ {
my $fixed= 1+$size; my $fixed= 1+$size;
my @dynamic=$dbh->selectrow_array("select avg(length(" my @dynamic=$dbh->selectrow_array("select avg(length(`"
.$dbh->quote($name) .$name.
.")) from `".$table.'`'); ."`)) from `".$table.'`');
$dynamic[0]=0 if !$dynamic[0]; $dynamic[0]=0 if !$dynamic[0];
@realsize= ($fixed,$fixed,ceil($dynamic[0])); @realsize= ($fixed,$fixed,ceil($dynamic[0]));
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment