ndb - bug#16447

  correct return value in check_cm_cmregreq
parent aa43e56b
...@@ -848,10 +848,12 @@ Qmgr::check_cmregreq_reply(Signal* signal, Uint32 nodeId, Uint32 gsn) ...@@ -848,10 +848,12 @@ Qmgr::check_cmregreq_reply(Signal* signal, Uint32 nodeId, Uint32 gsn)
goto die_direct; goto die_direct;
} }
return false; return true;
die_direct: die_direct:
ndbout_c(buf); ndbout_c(buf);
CRASH_INSERTION(932);
progError(__LINE__, progError(__LINE__,
ERR_ARBIT_SHUTDOWN, ERR_ARBIT_SHUTDOWN,
buf); buf);
...@@ -2082,9 +2084,13 @@ void Qmgr::execDISCONNECT_REP(Signal* signal) ...@@ -2082,9 +2084,13 @@ void Qmgr::execDISCONNECT_REP(Signal* signal)
case ZFAIL_CLOSING: case ZFAIL_CLOSING:
case ZAPI_ACTIVE: case ZAPI_ACTIVE:
case ZAPI_INACTIVE: case ZAPI_INACTIVE:
{
char buf[100];
BaseString::snprintf(buf, 100, "Node %u disconected", nodeId);
progError(__LINE__, ERR_SR_OTHERNODEFAILED, buf);
ndbrequire(false); ndbrequire(false);
} }
}
node_failed(signal, nodeId); node_failed(signal, nodeId);
}//DISCONNECT_REP }//DISCONNECT_REP
......
...@@ -445,8 +445,7 @@ int twoNodeFailure(NdbRestarter& _restarter, ...@@ -445,8 +445,7 @@ int twoNodeFailure(NdbRestarter& _restarter,
<< ") secs " << endl; << ") secs " << endl;
NdbSleep_SecSleep(seconds); NdbSleep_SecSleep(seconds);
randomId = (rand() % _restarter.getNumDbNodes()); nodeId = _restarter.getRandomNodeOtherNodeGroup(nodeId, rand());
nodeId = _restarter.getDbNodeId(randomId);
g_info << _restart->m_name << ": node = "<< nodeId << endl; g_info << _restart->m_name << ": node = "<< nodeId << endl;
CHECK(_restarter.insertErrorInNode(nodeId, 9999) == 0, CHECK(_restarter.insertErrorInNode(nodeId, 9999) == 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