summaryrefslogtreecommitdiff
path: root/ndb
diff options
context:
space:
mode:
authortomas@poseidon.ndb.mysql.com <>2005-03-04 12:19:53 +0100
committertomas@poseidon.ndb.mysql.com <>2005-03-04 12:19:53 +0100
commiteb41f3f74fb26d2ea592a7b7b2b00adc4214a1f9 (patch)
tree673cbd228141967b37fef01c277ca420f97f9643 /ndb
parentd360786e454fdf57b6b44ba31eb05a7732ee657b (diff)
downloadmariadb-git-eb41f3f74fb26d2ea592a7b7b2b00adc4214a1f9.tar.gz
changed order of transporter_connect and closing the mgmapisession
Diffstat (limited to 'ndb')
-rw-r--r--ndb/src/mgmsrv/MgmtSrvr.cpp7
-rw-r--r--ndb/src/mgmsrv/Services.cpp10
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("");