diff options
author | tomas@poseidon.ndb.mysql.com <> | 2005-03-04 12:19:53 +0100 |
---|---|---|
committer | tomas@poseidon.ndb.mysql.com <> | 2005-03-04 12:19:53 +0100 |
commit | eb41f3f74fb26d2ea592a7b7b2b00adc4214a1f9 (patch) | |
tree | 673cbd228141967b37fef01c277ca420f97f9643 /ndb | |
parent | d360786e454fdf57b6b44ba31eb05a7732ee657b (diff) | |
download | mariadb-git-eb41f3f74fb26d2ea592a7b7b2b00adc4214a1f9.tar.gz |
changed order of transporter_connect and closing the mgmapisession
Diffstat (limited to 'ndb')
-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(""); |