Commit 4438b27d authored by unknown's avatar unknown

Merge pilot.mysql.com:/data/msvensson/mysql/mysql-5.0-maint

into  pilot.mysql.com:/data/msvensson/mysql/mysql-5.1-new-maint


storage/ndb/src/ndbapi/ClusterMgr.cpp:
  Auto merged
storage/ndb/src/mgmsrv/Services.cpp:
  SCCS merged
parents 93fdb082 1976540e
...@@ -968,7 +968,6 @@ printNodeStatus(OutputStream *output, ...@@ -968,7 +968,6 @@ printNodeStatus(OutputStream *output,
MgmtSrvr &mgmsrv, MgmtSrvr &mgmsrv,
enum ndb_mgm_node_type type) { enum ndb_mgm_node_type type) {
NodeId nodeId = 0; NodeId nodeId = 0;
mgmsrv.updateStatus();
while(mgmsrv.getNextNodeId(&nodeId, type)) { while(mgmsrv.getNextNodeId(&nodeId, type)) {
enum ndb_mgm_node_status status; enum ndb_mgm_node_status status;
Uint32 startPhase = 0, Uint32 startPhase = 0,
...@@ -1018,6 +1017,7 @@ MgmApiSession::getStatus(Parser<MgmApiSession>::Context &, ...@@ -1018,6 +1017,7 @@ MgmApiSession::getStatus(Parser<MgmApiSession>::Context &,
m_output->println("node status"); m_output->println("node status");
SLEEP_ERROR_INSERTED(6); SLEEP_ERROR_INSERTED(6);
m_output->println("nodes: %d", noOfNodes); m_output->println("nodes: %d", noOfNodes);
m_mgmsrv.updateStatus();
SLEEP_ERROR_INSERTED(7); SLEEP_ERROR_INSERTED(7);
printNodeStatus(m_output, m_mgmsrv, NDB_MGM_NODE_TYPE_NDB); printNodeStatus(m_output, m_mgmsrv, NDB_MGM_NODE_TYPE_NDB);
printNodeStatus(m_output, m_mgmsrv, NDB_MGM_NODE_TYPE_MGM); printNodeStatus(m_output, m_mgmsrv, NDB_MGM_NODE_TYPE_MGM);
......
...@@ -204,7 +204,10 @@ ClusterMgr::forceHB() ...@@ -204,7 +204,10 @@ ClusterMgr::forceHB()
theFacade.sendSignalUnCond(&signal, nodeId); theFacade.sendSignalUnCond(&signal, nodeId);
} }
NdbCondition_WaitTimeout(waitForHBCond, theFacade.theMutexPtr, 1000); /* Wait for nodes to reply - if any heartbeats was sent */
if (!waitForHBFromNodes.isclear())
NdbCondition_WaitTimeout(waitForHBCond, theFacade.theMutexPtr, 1000);
waitingForHB= false; waitingForHB= false;
#ifdef DEBUG_REG #ifdef DEBUG_REG
ndbout << "Still waiting for HB from " << waitForHBFromNodes.getText(buf) << endl; ndbout << "Still waiting for HB from " << waitForHBFromNodes.getText(buf) << endl;
......
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