Loading ndb/src/mgmclient/CommandInterpreter.cpp +12 −0 Original line number Diff line number Diff line Loading @@ -2120,6 +2120,18 @@ CommandInterpreter::executeStatus(int processId, ndbout << processId << ": Node not found" << endl; return -1; } if (cl->node_states[i].node_type != NDB_MGM_NODE_TYPE_NDB){ if (cl->node_states[i].version != 0){ ndbout << "Node "<< cl->node_states[i].node_id <<": connected" ; ndbout_c(" (Version %d.%d.%d)", getMajor(version) , getMinor(version), getBuild(version)); }else ndbout << "Node "<< cl->node_states[i].node_id <<": not connected" << endl; return 0; } status = cl->node_states[i].node_status; startPhase = cl->node_states[i].start_phase; version = cl->node_states[i].version; Loading ndb/src/ndbapi/Ndb.cpp +7 −0 Original line number Diff line number Diff line Loading @@ -983,6 +983,8 @@ Ndb::opTupleIdOnNdb(Ndb_local_table_info* info, Uint64 & opValue, Uint32 op) Uint64 tValue; NdbRecAttr* tRecAttrResult; NdbError savedError; CHECK_STATUS_MACRO_ZERO; BaseString currentDb(getDatabaseName()); Loading Loading @@ -1077,7 +1079,12 @@ Ndb::opTupleIdOnNdb(Ndb_local_table_info* info, Uint64 & opValue, Uint32 op) error_handler: theError.code = tConnection->theError.code; savedError = theError; this->closeTransaction(tConnection); theError = savedError; error_return: // Restore current name space setDatabaseName(currentDb.c_str()); Loading Loading
ndb/src/mgmclient/CommandInterpreter.cpp +12 −0 Original line number Diff line number Diff line Loading @@ -2120,6 +2120,18 @@ CommandInterpreter::executeStatus(int processId, ndbout << processId << ": Node not found" << endl; return -1; } if (cl->node_states[i].node_type != NDB_MGM_NODE_TYPE_NDB){ if (cl->node_states[i].version != 0){ ndbout << "Node "<< cl->node_states[i].node_id <<": connected" ; ndbout_c(" (Version %d.%d.%d)", getMajor(version) , getMinor(version), getBuild(version)); }else ndbout << "Node "<< cl->node_states[i].node_id <<": not connected" << endl; return 0; } status = cl->node_states[i].node_status; startPhase = cl->node_states[i].start_phase; version = cl->node_states[i].version; Loading
ndb/src/ndbapi/Ndb.cpp +7 −0 Original line number Diff line number Diff line Loading @@ -983,6 +983,8 @@ Ndb::opTupleIdOnNdb(Ndb_local_table_info* info, Uint64 & opValue, Uint32 op) Uint64 tValue; NdbRecAttr* tRecAttrResult; NdbError savedError; CHECK_STATUS_MACRO_ZERO; BaseString currentDb(getDatabaseName()); Loading Loading @@ -1077,7 +1079,12 @@ Ndb::opTupleIdOnNdb(Ndb_local_table_info* info, Uint64 & opValue, Uint32 op) error_handler: theError.code = tConnection->theError.code; savedError = theError; this->closeTransaction(tConnection); theError = savedError; error_return: // Restore current name space setDatabaseName(currentDb.c_str()); Loading