Lines Matching refs:m_mgmsrv

334   : SocketServer::Session(sock), m_mgmsrv(mgm),  in MgmApiSession()
557 if (!m_mgmsrv.alloc_node_id(tmp, in get_nodeid()
602 m_mgmsrv.get_packed_config_from_node(from_node, in getConfig()
604 m_mgmsrv.get_packed_config((ndb_mgm_node_type)nodetype, in getConfig()
647 if(node==m_mgmsrv.getOwnNodeId() in insertError()
656 result= m_mgmsrv.insertError(node, error, extraptr); in insertError()
675 int result = m_mgmsrv.setTraceNo(node, trace); in setTrace()
693 m_output->println("string: %s", m_mgmsrv.get_version_string()); in getVersion()
717 result = m_mgmsrv.startBackup(backupId, completed, input_backupId, backuppoint); in startBackup()
740 int result = m_mgmsrv.abortBackup(id); in abortBackup()
761 int result = m_mgmsrv.dumpState(node, args_str.c_str()); in dumpState()
808 …m_output->println("%s: %d", names[i], m_mgmsrv.m_event_listner[0].m_logLevel.getLogLevel(category)… in getClusterLogLevel()
836 m_mgmsrv.m_event_listner.lock(); in setClusterLogLevel()
837 if (m_mgmsrv.m_event_listner[0].m_logLevel.setLogLevel(category,level)) in setClusterLogLevel()
841 m_mgmsrv.m_event_listner.unlock(); in setClusterLogLevel()
844 m_mgmsrv.m_event_listner.unlock(); in setClusterLogLevel()
848 m_mgmsrv.m_event_listner.update_max_log_level(tmp); in setClusterLogLevel()
880 m_mgmsrv.m_event_listner.update_max_log_level(ll); in setLogLevel()
895 int result = m_mgmsrv.stopSignalTracing(node); in stopSignalLog()
940 int result= m_mgmsrv.restartNodes(nodes, in restart()
955 result= m_mgmsrv.restartNodes(nodes, in restart()
969 result = m_mgmsrv.restartDB(nostart, initialstart, false, &restarted); in restart()
996 int result = m_mgmsrv.restartDB(nostart, initialstart, abort, &count); in restartAll()
1073 while(m_mgmsrv.getNextNodeId(&nodeId, types[i])) in getStatus()
1084 printNodeStatus(m_output, m_mgmsrv, types[i]); in getStatus()
1156 result= m_mgmsrv.stopNodes(nodes, &stopped, abort != 0, force != 0, in stop()
1166 result= m_mgmsrv.stopNodes(nodes, &stopped, abort != 0, force != 0, in stop()
1175 result = m_mgmsrv.shutdownDB(&stopped, false); in stop()
1208 result= m_mgmsrv.shutdownDB(&stopped[0], abort != 0); in stopAll()
1210 result= m_mgmsrv.shutdownMGM(&stopped[1], abort!=0, &m_stopSelf); in stopAll()
1231 result = m_mgmsrv.enterSingleUser(&stopped, nodeId); in enterSingleUser()
1246 int result = m_mgmsrv.exitSingleUser(&stopped, false); in exitSingleUser()
1263 int result = m_mgmsrv.startSignalTracing(node); in startSignalLog()
1308 int result = m_mgmsrv.setSignalLoggingMode(node, mode, blocks); in logSignals()
1325 int result = m_mgmsrv.sendSTART_ORD(node); in start()
1341 while(m_mgmsrv.getNextNodeId(&node, NDB_MGM_NODE_TYPE_NDB)) in startAll()
1342 if(m_mgmsrv.sendSTART_ORD(node) == 0) in startAll()
1548 m_mgmsrv->m_log_level_requests.push_back(req); in update_log_level()
1625 int ret = m_mgmsrv.setDbParameter(node, in setParameter()
1647 int ret = m_mgmsrv.setConnectionDbParameter(node1, in setConnectionParameter()
1671 int ret = m_mgmsrv.getConnectionDbParameter(node1, in getConnectionParameter()
1761 m_mgmsrv.m_event_listner.add_listener(le); in listen_event()
1772 m_mgmsrv.get_socket_server()->checkSessions(); in purge_stale_sessions()
1797 if (!m_mgmsrv.transporter_connect(m_socket, errormsg, close_with_reset)) in transporter_connect()
1827 m_output->println("nodeid:%u",m_mgmsrv.getOwnNodeId()); in get_mgmd_nodeid()
1852 m_mgmsrv.eventReport(data, length); in report_event()
1885 res = m_mgmsrv.createNodegroup(nodes.getBase(), nodes.size(), &ng); in create_nodegroup()
1911 if((res = m_mgmsrv.dropNodegroup(ng)) != 0) in drop_nodegroup()
1966 m_mgmsrv.get_socket_server()->foreachSession(list_session,(void*)this); in listSessions()
2029 m_mgmsrv.get_socket_server()->foreachSession(get_session,(void*)&p); in getSession()
2143 (void)m_mgmsrv.change_config(new_config, result); in setConfig()
2166 m_mgmsrv.print_config(section, nodeid, name, in showConfig()
2189 if (!m_mgmsrv.reload_config(config_filename, (mycnf != 0), msg)) in reloadConfig()
2204 m_mgmsrv.show_variables(socket_out); in show_variables()
2291 if (!m_mgmsrv.request_events(nodes, in dump_events()
2510 if (!m_mgmsrv.setDynamicPorts(node, ports, num_ports, msg)) in set_ports()