Commit b52ed0d6 authored by joreland@mysql.com's avatar joreland@mysql.com

Merge mysql.com:/home/jonas/src/fix

into mysql.com:/home/jonas/src/mysql-4.1
parents c25ce0e3 72127b52
...@@ -201,8 +201,10 @@ private: ...@@ -201,8 +201,10 @@ private:
//Uint32 m_indexVersion; //Uint32 m_indexVersion;
Uint32 m_errorCode; Uint32 m_errorCode;
Uint32 m_errorLine; Uint32 m_errorLine;
Uint32 m_errorNode; union {
Uint32 m_errorNode;
Uint32 masterNodeId; // if NotMaster
};
public: public:
AlterIndxConf* getConf() { AlterIndxConf* getConf() {
return &m_conf; return &m_conf;
......
...@@ -242,9 +242,8 @@ public: ...@@ -242,9 +242,8 @@ public:
AllocationFailure = 4252, AllocationFailure = 4252,
InternalError = 4346 InternalError = 4346
}; };
STATIC_CONST( SignalLength = BuildIndxConf::SignalLength + 1 ); STATIC_CONST( SignalLength = BuildIndxConf::SignalLength + 2 );
private:
//Uint32 m_userRef; //Uint32 m_userRef;
//Uint32 m_connectionPtr; //Uint32 m_connectionPtr;
//Uint32 m_requestInfo; //Uint32 m_requestInfo;
...@@ -253,6 +252,7 @@ private: ...@@ -253,6 +252,7 @@ private:
//Uint32 m_indexId; //Uint32 m_indexId;
BuildIndxConf m_conf; BuildIndxConf m_conf;
Uint32 m_errorCode; Uint32 m_errorCode;
Uint32 masterNodeId;
public: public:
BuildIndxConf* getConf() { BuildIndxConf* getConf() {
......
...@@ -220,8 +220,10 @@ public: ...@@ -220,8 +220,10 @@ public:
//Uint32 m_indexVersion; //Uint32 m_indexVersion;
Uint32 m_errorCode; Uint32 m_errorCode;
Uint32 m_errorLine; Uint32 m_errorLine;
Uint32 m_errorNode; union {
Uint32 m_errorNode;
Uint32 masterNodeId; // If NotMaster
};
public: public:
CreateIndxConf* getConf() { CreateIndxConf* getConf() {
return &m_conf; return &m_conf;
......
...@@ -311,8 +311,10 @@ private: ...@@ -311,8 +311,10 @@ private:
//Uint32 m_triggerInfo; //Uint32 m_triggerInfo;
Uint32 m_errorCode; Uint32 m_errorCode;
Uint32 m_errorLine; Uint32 m_errorLine;
Uint32 m_errorNode; union {
Uint32 m_errorNode;
Uint32 masterNodeId; // When NotMaster
};
public: public:
CreateTrigConf* getConf() { CreateTrigConf* getConf() {
return &m_conf; return &m_conf;
......
...@@ -185,8 +185,10 @@ public: ...@@ -185,8 +185,10 @@ public:
//Uint32 m_indexVersion; //Uint32 m_indexVersion;
Uint32 m_errorCode; Uint32 m_errorCode;
Uint32 m_errorLine; Uint32 m_errorLine;
Uint32 m_errorNode; union {
Uint32 m_errorNode;
Uint32 masterNodeId;
};
public: public:
DropIndxConf* getConf() { DropIndxConf* getConf() {
return &m_conf; return &m_conf;
......
...@@ -10237,6 +10237,7 @@ Dbdict::buildIndex_sendReply(Signal* signal, OpBuildIndexPtr opPtr, ...@@ -10237,6 +10237,7 @@ Dbdict::buildIndex_sendReply(Signal* signal, OpBuildIndexPtr opPtr,
rep->setIndexId(opPtr.p->m_request.getIndexId()); rep->setIndexId(opPtr.p->m_request.getIndexId());
if (sendRef) { if (sendRef) {
rep->setErrorCode(opPtr.p->m_errorCode); rep->setErrorCode(opPtr.p->m_errorCode);
rep->masterNodeId = opPtr.p->m_errorNode;
gsn = GSN_BUILDINDXREF; gsn = GSN_BUILDINDXREF;
length = BuildIndxRef::SignalLength; length = BuildIndxRef::SignalLength;
} }
......
...@@ -2125,7 +2125,7 @@ NdbDictInterface::execCREATE_INDX_REF(NdbApiSignal * signal, ...@@ -2125,7 +2125,7 @@ NdbDictInterface::execCREATE_INDX_REF(NdbApiSignal * signal,
const CreateIndxRef* const ref = CAST_CONSTPTR(CreateIndxRef, signal->getDataPtr()); const CreateIndxRef* const ref = CAST_CONSTPTR(CreateIndxRef, signal->getDataPtr());
m_error.code = ref->getErrorCode(); m_error.code = ref->getErrorCode();
if(m_error.code == ref->NotMaster) if(m_error.code == ref->NotMaster)
m_masterNodeId= ref->m_errorNode; m_masterNodeId= ref->masterNodeId;
m_waiter.signal(NO_WAIT); m_waiter.signal(NO_WAIT);
} }
...@@ -2251,7 +2251,7 @@ NdbDictInterface::execDROP_INDX_REF(NdbApiSignal * signal, ...@@ -2251,7 +2251,7 @@ NdbDictInterface::execDROP_INDX_REF(NdbApiSignal * signal,
const DropIndxRef* const ref = CAST_CONSTPTR(DropIndxRef, signal->getDataPtr()); const DropIndxRef* const ref = CAST_CONSTPTR(DropIndxRef, signal->getDataPtr());
m_error.code = ref->getErrorCode(); m_error.code = ref->getErrorCode();
if(m_error.code == ref->NotMaster) if(m_error.code == ref->NotMaster)
m_masterNodeId= ref->m_errorNode; m_masterNodeId= ref->masterNodeId;
m_waiter.signal(NO_WAIT); m_waiter.signal(NO_WAIT);
} }
......
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