diff options
| author | unknown <stewart@mysql.com> | 2005-07-12 15:51:31 +1000 |
|---|---|---|
| committer | unknown <stewart@mysql.com> | 2005-07-12 15:51:31 +1000 |
| commit | 2508b29e7c0833316934ed3bbecd74c5983bf388 (patch) | |
| tree | 0069c066a951ce37a859739a9fd523559f46885f | |
| parent | ed244881494fc8f086850e26c3fb09bdec7f83d8 (diff) | |
| parent | 6951bad6f28777894618b51e94c6ba6e77cebe4e (diff) | |
| download | mariadb-git-2508b29e7c0833316934ed3bbecd74c5983bf388.tar.gz | |
Merge ssmith@bk-internal.mysql.com:/home/bk/mysql-5.0
into mysql.com:/home/stewart/Documents/MySQL/5.0/main
| -rw-r--r-- | ndb/include/mgmcommon/ConfigRetriever.hpp | 1 | ||||
| -rw-r--r-- | ndb/src/common/mgmcommon/ConfigRetriever.cpp | 6 | ||||
| -rw-r--r-- | ndb/src/mgmsrv/main.cpp | 3 |
3 files changed, 9 insertions, 1 deletions
diff --git a/ndb/include/mgmcommon/ConfigRetriever.hpp b/ndb/include/mgmcommon/ConfigRetriever.hpp index 95d257dea23..c0b877af07d 100644 --- a/ndb/include/mgmcommon/ConfigRetriever.hpp +++ b/ndb/include/mgmcommon/ConfigRetriever.hpp @@ -32,6 +32,7 @@ public: ~ConfigRetriever(); int do_connect(int no_retries, int retry_delay_in_seconds, int verbose); + int disconnect(); /** * Get configuration for current node. diff --git a/ndb/src/common/mgmcommon/ConfigRetriever.cpp b/ndb/src/common/mgmcommon/ConfigRetriever.cpp index eca886c8586..0e9b2a83e2f 100644 --- a/ndb/src/common/mgmcommon/ConfigRetriever.cpp +++ b/ndb/src/common/mgmcommon/ConfigRetriever.cpp @@ -107,6 +107,12 @@ ConfigRetriever::do_connect(int no_retries, 0 : -1; } +int +ConfigRetriever::disconnect() +{ + return ndb_mgm_disconnect(m_handle); +} + //**************************************************************************** //**************************************************************************** //**************************************************************************** diff --git a/ndb/src/mgmsrv/main.cpp b/ndb/src/mgmsrv/main.cpp index 3335fdc827c..c7315c61ba1 100644 --- a/ndb/src/mgmsrv/main.cpp +++ b/ndb/src/mgmsrv/main.cpp @@ -353,7 +353,8 @@ int main(int argc, char** argv) g_eventLogger.info("Shutting down server..."); glob.socketServer->stopServer(); - glob.socketServer->stopSessions(); + glob.mgmObject->get_config_retriever()->disconnect(); + glob.socketServer->stopSessions(true); g_eventLogger.info("Shutdown complete"); return 0; error_end: |