Commit 1c2fba1a authored by unknown's avatar unknown

removed printout "- Repeated 1 times"

   make sure transporter connections are close early in shutdown


ndb/src/common/logger/LogHandler.cpp:
  removed printout "- Repeated 1 times"
ndb/src/kernel/main.cpp:
  make sure transporter connections are close early in shutdown
ndb/src/kernel/vm/Emulator.cpp:
  make sure transporter connections are close early in shutdown
ndb/src/kernel/vm/Emulator.hpp:
  make sure transporter connections are close early in shutdown
parent 846944a2
...@@ -76,15 +76,15 @@ LogHandler::append_impl(const char* pCategory, Logger::LoggerLevel level, ...@@ -76,15 +76,15 @@ LogHandler::append_impl(const char* pCategory, Logger::LoggerLevel level,
const char* pMsg) const char* pMsg)
{ {
writeHeader(pCategory, level); writeHeader(pCategory, level);
if (m_count_repeated_messages == 0) if (m_count_repeated_messages <= 1)
writeMessage(pMsg); writeMessage(pMsg);
else else
{ {
BaseString str(pMsg); BaseString str(pMsg);
str.appfmt(" - Repeated %d times", m_count_repeated_messages); str.appfmt(" - Repeated %d times", m_count_repeated_messages);
writeMessage(str.c_str()); writeMessage(str.c_str());
m_count_repeated_messages= 0;
} }
m_count_repeated_messages= 0;
writeFooter(); writeFooter();
} }
......
...@@ -180,11 +180,9 @@ int main(int argc, char** argv) ...@@ -180,11 +180,9 @@ int main(int argc, char** argv)
assert("Illegal state globalData.theRestartFlag" == 0); assert("Illegal state globalData.theRestartFlag" == 0);
} }
SocketServer socket_server;
globalTransporterRegistry.startSending(); globalTransporterRegistry.startSending();
globalTransporterRegistry.startReceiving(); globalTransporterRegistry.startReceiving();
if (!globalTransporterRegistry.start_service(socket_server)){ if (!globalTransporterRegistry.start_service(*globalEmulatorData.m_socket_server)){
ndbout_c("globalTransporterRegistry.start_service() failed"); ndbout_c("globalTransporterRegistry.start_service() failed");
exit(-1); exit(-1);
} }
...@@ -196,7 +194,7 @@ int main(int argc, char** argv) ...@@ -196,7 +194,7 @@ int main(int argc, char** argv)
globalEmulatorData.theWatchDog->doStart(); globalEmulatorData.theWatchDog->doStart();
socket_server.startServer(); globalEmulatorData.m_socket_server->startServer();
// theConfig->closeConfiguration(); // theConfig->closeConfiguration();
...@@ -204,11 +202,6 @@ int main(int argc, char** argv) ...@@ -204,11 +202,6 @@ int main(int argc, char** argv)
NdbShutdown(NST_Normal); NdbShutdown(NST_Normal);
socket_server.stopServer();
socket_server.stopSessions();
globalTransporterRegistry.stop_clients();
return NRT_Default; return NRT_Default;
} }
......
...@@ -68,6 +68,7 @@ EmulatorData::EmulatorData(){ ...@@ -68,6 +68,7 @@ EmulatorData::EmulatorData(){
theThreadConfig = 0; theThreadConfig = 0;
theSimBlockList = 0; theSimBlockList = 0;
theShutdownMutex = 0; theShutdownMutex = 0;
m_socket_server = 0;
} }
void void
...@@ -83,6 +84,7 @@ EmulatorData::create(){ ...@@ -83,6 +84,7 @@ EmulatorData::create(){
theWatchDog = new WatchDog(); theWatchDog = new WatchDog();
theThreadConfig = new ThreadConfig(); theThreadConfig = new ThreadConfig();
theSimBlockList = new SimBlockList(); theSimBlockList = new SimBlockList();
m_socket_server = new SocketServer();
theShutdownMutex = NdbMutex_Create(); theShutdownMutex = NdbMutex_Create();
...@@ -99,7 +101,8 @@ EmulatorData::destroy(){ ...@@ -99,7 +101,8 @@ EmulatorData::destroy(){
delete theThreadConfig; theThreadConfig = 0; delete theThreadConfig; theThreadConfig = 0;
if(theSimBlockList) if(theSimBlockList)
delete theSimBlockList; theSimBlockList = 0; delete theSimBlockList; theSimBlockList = 0;
if(m_socket_server)
delete m_socket_server; m_socket_server = 0;
NdbMem_Destroy(); NdbMem_Destroy();
} }
...@@ -195,9 +198,22 @@ NdbShutdown(NdbShutdownType type, ...@@ -195,9 +198,22 @@ NdbShutdown(NdbShutdownType type,
fclose(outputStream); fclose(outputStream);
#endif #endif
/**
* Stop all transporter connection attempts and accepts
*/
globalEmulatorData.m_socket_server->stopServer();
globalEmulatorData.m_socket_server->stopSessions();
globalTransporterRegistry.stop_clients();
/**
* Stop transporter communication with other nodes
*/
globalTransporterRegistry.stopSending(); globalTransporterRegistry.stopSending();
globalTransporterRegistry.stopReceiving(); globalTransporterRegistry.stopReceiving();
/**
* Remove all transporters
*/
globalTransporterRegistry.removeAll(); globalTransporterRegistry.removeAll();
#ifdef VM_TRACE #ifdef VM_TRACE
......
...@@ -55,7 +55,8 @@ struct EmulatorData { ...@@ -55,7 +55,8 @@ struct EmulatorData {
class WatchDog * theWatchDog; class WatchDog * theWatchDog;
class ThreadConfig * theThreadConfig; class ThreadConfig * theThreadConfig;
class SimBlockList * theSimBlockList; class SimBlockList * theSimBlockList;
class SocketServer * m_socket_server;
/** /**
* Constructor * Constructor
* *
......
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