Category

Development Platform
Home > SourceCode/Document > Database system > MySQL > View Code
NdbRestarter.hpp
Package: mysql-4.1.16-win-src.zip　[view]
Upload User: romrleung
Upload Date: 2022-05-23
Package Size: 18897k
Code Size: 3k
Category:

MySQL

Development Platform:

Visual C++

NdbRestarter.hpp：Code Content
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. #ifndef NDBT_RESTARTER_HPP
  18. #define NDBT_RESTARTER_HPP
  20. #include <mgmapi.h>
  21. #include <Vector.hpp>
  22. #include <BaseString.hpp>
  24. class NdbRestarter {
  25. public:
  26.   NdbRestarter(const char* _addr = 0);
  27.   ~NdbRestarter();
  29.   int getDbNodeId(int _i);
  31.   int restartOneDbNode(int _nodeId, 
  32.        bool initial = false, 
  33.        bool nostart = false, 
  34.        bool abort = false);
  36.   int restartAll(bool initial = false, 
  37.  bool nostart = false, 
  38.  bool abort = false);
  39.   
  40.   int startAll();
  41.   int startNodes(int * _nodes, int _num_nodes);
  42.   int waitClusterStarted(unsigned int _timeout = 120);
  43.   int waitClusterSingleUser(unsigned int _timeout = 120);
  44.   int waitClusterStartPhase(int _startphase, unsigned int _timeout = 120);
  45.   int waitClusterNoStart(unsigned int _timeout = 120);  
  46.   int waitNodesStarted(int * _nodes, int _num_nodes,
  47.        unsigned int _timeout = 120);
  48.   int waitNodesStartPhase(int * _nodes, int _num_nodes, 
  49.   int _startphase, unsigned int _timeout = 120);
  50.   int waitNodesNoStart(int * _nodes, int _num_nodes,
  51.        unsigned int _timeout = 120); 
  54.   int getNumDbNodes();
  55.   int insertErrorInNode(int _nodeId, int error);
  56.   int insertErrorInAllNodes(int error);
  58.   int enterSingleUserMode(int _nodeId);
  59.   int exitSingleUserMode();
  61.   int dumpStateOneNode(int _nodeId, int * _args, int _num_args);
  62.   int dumpStateAllNodes(int * _args, int _num_args);
  64.   int getMasterNodeId();
  65.   int getRandomNodeOtherNodeGroup(int nodeId, int randomNumber);
  66.   int getRandomNotMasterNodeId(int randomNumber);
  67.   
  68. protected:
  70.   int waitClusterState(ndb_mgm_node_status _status,
  71.        unsigned int _timeout,
  72.        int _startphase = -1);  
  74.   int waitNodesState(int * _nodes, int _num_nodes,
  75.      ndb_mgm_node_status _status,
  76.      unsigned int _timeout,
  77.      int _startphase = -1);
  79.   bool isConnected();
  80.   int connect();
  81.   void disconnect();
  82.   int getStatus();
  83.   
  84.   Vector<ndb_mgm_node_state> ndbNodes;
  85.   Vector<ndb_mgm_node_state> mgmNodes;
  86.   Vector<ndb_mgm_node_state> apiNodes;
  87.   
  88.   bool connected;
  89.   BaseString addr;
  90.   NdbMgmHandle handle;
  91.   ndb_mgm_configuration * m_config;
  92. protected:
  93.   ndb_mgm_configuration * getConfig();
  94. };
  96. #endif