Commit 23a467af authored by unknown's avatar unknown

Small fix


ndb/src/common/transporter/Transporter.hpp:
  Add get_r_port()
ndb/src/common/transporter/TransporterRegistry.cpp:
  compile fix: use t->get_r_port()
parent 0388a3f4
...@@ -69,6 +69,11 @@ public: ...@@ -69,6 +69,11 @@ public:
*/ */
NodeId getLocalNodeId() const; NodeId getLocalNodeId() const;
/**
* Get r_port we're connecting to
*/
unsigned int get_r_port() { return m_r_port; };
/** /**
* Set r_port to connect to * Set r_port to connect to
*/ */
......
...@@ -1141,7 +1141,7 @@ TransporterRegistry::start_clients_thread() ...@@ -1141,7 +1141,7 @@ TransporterRegistry::start_clients_thread()
switch(performStates[nodeId]){ switch(performStates[nodeId]){
case CONNECTING: case CONNECTING:
if(!t->isConnected() && !t->isServer) { if(!t->isConnected() && !t->isServer) {
if(server_port <= 0) { // Port is dynamic if(t->get_r_port() <= 0) { // Port is dynamic
Uint32 server_port=0; Uint32 server_port=0;
struct ndb_mgm_reply mgm_reply; struct ndb_mgm_reply mgm_reply;
int res; int res;
......
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