Commit 954542b0 authored by joreland@mysql.com's avatar joreland@mysql.com

more 4.1 to irix merge

parent 20c86363
...@@ -175,11 +175,15 @@ NDB_MAIN(ndb_kernel){ ...@@ -175,11 +175,15 @@ NDB_MAIN(ndb_kernel){
globalTransporterRegistry.startSending(); globalTransporterRegistry.startSending();
globalTransporterRegistry.startReceiving(); globalTransporterRegistry.startReceiving();
if (!globalTransporterRegistry.start_service(socket_server)) if (!globalTransporterRegistry.start_service(socket_server)){
NDB_ASSERT(0, "globalTransporterRegistry.start_service() failed"); ndbout_c("globalTransporterRegistry.start_service() failed");
exit(-1);
}
if (!globalTransporterRegistry.start_clients()) if (!globalTransporterRegistry.start_clients()){
NDB_ASSERT(0, "globalTransporterRegistry.start_clients() failed"); ndbout_c("globalTransporterRegistry.start_clients() failed");
exit(-1);
}
globalEmulatorData.theWatchDog->doStart(); globalEmulatorData.theWatchDog->doStart();
......
...@@ -587,8 +587,10 @@ MgmtSrvr::MgmtSrvr(NodeId nodeId, ...@@ -587,8 +587,10 @@ MgmtSrvr::MgmtSrvr(NodeId nodeId,
_ownNodeId= 0; // did not get nodeid requested _ownNodeId= 0; // did not get nodeid requested
} }
m_allocated_resources.reserve_node(_ownNodeId); m_allocated_resources.reserve_node(_ownNodeId);
} else } else {
NDB_ASSERT(0, "Unable to retrieve own node id"); ndbout_c("Unable to retrieve own node id");
exit(-1);
}
} }
......
...@@ -463,11 +463,15 @@ void TransporterFacade::threadMainSend(void) ...@@ -463,11 +463,15 @@ void TransporterFacade::threadMainSend(void)
SocketServer socket_server; SocketServer socket_server;
theTransporterRegistry->startSending(); theTransporterRegistry->startSending();
if (!theTransporterRegistry->start_service(socket_server)) if (!theTransporterRegistry->start_service(socket_server)){
NDB_ASSERT(0, "Unable to start theTransporterRegistry->start_service"); ndbout_c("Unable to start theTransporterRegistry->start_service");
exit(0);
}
if (!theTransporterRegistry->start_clients()) if (!theTransporterRegistry->start_clients()){
NDB_ASSERT(0, "Unable to start theTransporterRegistry->start_clients"); ndbout_c("Unable to start theTransporterRegistry->start_clients");
exit(0);
}
socket_server.startServer(); socket_server.startServer();
......
...@@ -703,5 +703,3 @@ HugoOperations::indexUpdateRecord(Ndb*, ...@@ -703,5 +703,3 @@ HugoOperations::indexUpdateRecord(Ndb*,
} }
return NDBT_OK; return NDBT_OK;
} }
template class Vector<HugoOperations::ScanTmp>;
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