diff options
author | unknown <tomas@poseidon.ndb.mysql.com> | 2005-03-04 12:19:53 +0100 |
---|---|---|
committer | unknown <tomas@poseidon.ndb.mysql.com> | 2005-03-04 12:19:53 +0100 |
commit | db86cb81aae20fa8cdd594f3f6ec28d262db9c60 (patch) | |
tree | 673cbd228141967b37fef01c277ca420f97f9643 | |
parent | 9cc85f40af7eebee4884d916a549303e17d44c82 (diff) | |
download | mariadb-git-db86cb81aae20fa8cdd594f3f6ec28d262db9c60.tar.gz |
changed order of transporter_connect and closing the mgmapisession
ndb/src/mgmsrv/MgmtSrvr.cpp:
removed the extra setting of connected node, not needed
-rw-r--r-- | ndb/src/mgmsrv/MgmtSrvr.cpp | 7 | ||||
-rw-r--r-- | ndb/src/mgmsrv/Services.cpp | 10 |
2 files changed, 6 insertions, 11 deletions
diff --git a/ndb/src/mgmsrv/MgmtSrvr.cpp b/ndb/src/mgmsrv/MgmtSrvr.cpp index 28b53acf9c3..21c3c4d614d 100644 --- a/ndb/src/mgmsrv/MgmtSrvr.cpp +++ b/ndb/src/mgmsrv/MgmtSrvr.cpp @@ -55,7 +55,6 @@ #include <mgmapi_configuration.hpp> #include <mgmapi_config_parameters.h> #include <m_string.h> -#include <Transporter.hpp> //#define MGM_SRV_DEBUG #ifdef MGM_SRV_DEBUG @@ -2139,11 +2138,7 @@ MgmtSrvr::get_connected_nodes(NodeBitmask &connected_nodes) const if (getNodeType(i) == NDB_MGM_NODE_TYPE_NDB) { const ClusterMgr::Node &node= theFacade->theClusterMgr->getNodeInfo(i); - if (theFacade->get_registry()->get_transporter(i)->isConnected()) - { - connected_nodes.bitOR(node.m_state.m_connected_nodes); - connected_nodes.set(i); - } + connected_nodes.bitOR(node.m_state.m_connected_nodes); } } } diff --git a/ndb/src/mgmsrv/Services.cpp b/ndb/src/mgmsrv/Services.cpp index cbed7998e29..bbd3db1e734 100644 --- a/ndb/src/mgmsrv/Services.cpp +++ b/ndb/src/mgmsrv/Services.cpp @@ -1546,19 +1546,19 @@ MgmApiSession::check_connection(Parser_t::Context &ctx, void MgmApiSession::transporter_connect(Parser_t::Context &ctx, - Properties const &args) { - NDB_SOCKET_TYPE s= m_socket; + Properties const &args) +{ + m_mgmsrv.transporter_connect(m_socket); m_stop= true; m_stopped= true; // force a stop (no closing socket) m_socket= NDB_INVALID_SOCKET; // so nobody closes it - - m_mgmsrv.transporter_connect(s); } void MgmApiSession::get_mgmd_nodeid(Parser_t::Context &ctx, - Properties const &args) { + Properties const &args) +{ m_output->println("get mgmd nodeid reply"); m_output->println("nodeid:%u",m_mgmsrv.getOwnNodeId()); m_output->println(""); |