1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
/* Copyright (C) 2003 MySQL AB
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; version 2 of the License.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
#ifndef NDBT_RESTARTER_HPP
#define NDBT_RESTARTER_HPP
#include <mgmapi.h>
#include <Vector.hpp>
#include <BaseString.hpp>
class NdbRestarter {
public:
NdbRestarter(const char* _addr = 0);
~NdbRestarter();
int getDbNodeId(int _i);
enum RestartFlags {
NRRF_INITIAL = 0x1,
NRRF_NOSTART = 0x2,
NRRF_ABORT = 0x4
};
int restartOneDbNode(int _nodeId,
bool initial = false,
bool nostart = false,
bool abort = false);
int restartOneDbNode2(int _nodeId, Uint32 flags){
return restartOneDbNode(_nodeId,
flags & NRRF_INITIAL,
flags & NRRF_NOSTART,
flags & NRRF_ABORT);
}
int restartAll(bool initial = false,
bool nostart = false,
bool abort = false);
int restartAll2(Uint32 flags){
return restartAll(flags & NRRF_INITIAL,
flags & NRRF_NOSTART,
flags & NRRF_ABORT);
}
int startAll();
int startNodes(const int * _nodes, int _num_nodes);
int waitClusterStarted(unsigned int _timeout = 120);
int waitClusterSingleUser(unsigned int _timeout = 120);
int waitClusterStartPhase(int _startphase, unsigned int _timeout = 120);
int waitClusterNoStart(unsigned int _timeout = 120);
int waitNodesStarted(const int * _nodes, int _num_nodes,
unsigned int _timeout = 120);
int waitNodesStartPhase(const int * _nodes, int _num_nodes,
int _startphase, unsigned int _timeout = 120);
int waitNodesNoStart(const int * _nodes, int _num_nodes,
unsigned int _timeout = 120);
int getNumDbNodes();
int insertErrorInNode(int _nodeId, int error);
int insertErrorInAllNodes(int error);
int enterSingleUserMode(int _nodeId);
int exitSingleUserMode();
int dumpStateOneNode(int _nodeId, const int * _args, int _num_args);
int dumpStateAllNodes(const int * _args, int _num_args);
int getMasterNodeId();
int getNextMasterNodeId(int nodeId);
int getNodeGroup(int nodeId);
int getRandomNodeSameNodeGroup(int nodeId, int randomNumber);
int getRandomNodeOtherNodeGroup(int nodeId, int randomNumber);
int getRandomNotMasterNodeId(int randomNumber);
NdbMgmHandle handle;
protected:
int waitClusterState(ndb_mgm_node_status _status,
unsigned int _timeout,
int _startphase = -1);
int waitNodesState(const int * _nodes, int _num_nodes,
ndb_mgm_node_status _status,
unsigned int _timeout,
int _startphase = -1);
bool isConnected();
int connect();
void disconnect();
int getStatus();
Vector<ndb_mgm_node_state> mgmNodes;
Vector<ndb_mgm_node_state> apiNodes;
bool connected;
BaseString addr;
ndb_mgm_configuration * m_config;
protected:
ndb_mgm_configuration * getConfig();
public:
Vector<ndb_mgm_node_state> ndbNodes;
};
#endif
|
