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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
|
/* Copyright (c) 2020, 2025, Oracle and/or its affiliates.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 2.0,
as published by the Free Software Foundation.
This program is designed to work with certain software (including
but not limited to OpenSSL) that is licensed under separate terms,
as designated in a particular file or component or in included license
documentation. The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have either included with
the program or referenced in the documentation.
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, version 2.0, 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
#ifndef RECOVERY_ENDPOINTS_INCLUDE
#define RECOVERY_ENDPOINTS_INCLUDE
#include <set>
#include <string>
#include <vector>
#include <include/my_inttypes.h>
#include "plugin/group_replication/include/member_info.h"
/**
@class Recovery_endpoints
Validate recovery endpoints
*/
class Recovery_endpoints {
protected:
/**
@enum enum_status
This enumeration describes error status
*/
enum class enum_status { OK = 0, INVALID, BADFORMAT, ERROR };
/**
Recovery_endpoints constructor
*/
Recovery_endpoints();
/**
Recovery_endpoints destructor
*/
virtual ~Recovery_endpoints();
/**
Validate recovery endpoints and log errors if it fails.
@param endpoints advertised recovery endpoints
@return the operation status
@retval false OK
@retval true Error
*/
std::pair<enum_status, std::string> check(const char *endpoints);
/**
Return recovery endpoints
@return list with recovery endpoints
*/
std::vector<std::pair<std::string, uint>> get_endpoints();
/**
Set ports allowed on advertised recovery endpoints
It shall be called when validating local recovery endpoints.
@param mysqld_port mysqld port allowed on advertised recovery endpoints
@param admin_port mysqld admin port allowed on advertised recovery
endpoints
*/
void set_port_settings(uint mysqld_port, uint admin_port);
private:
/**
Validate if recovery endpoint is a host name.
@param host hostname to be checked
@param host_ips list of host IPs
@return the operation status
@retval 0 OK
@retval !=0 Error
*/
int hostname_check_and_log(std::string host, std::set<std::string> host_ips);
/**
Retrieve from host all ip address
@param[out] local_ips list of IPs present on host
@return the operation status
@retval 0 OK
@retval !=0 Error
*/
int local_interfaces_ips(std::set<std::string> &local_ips);
/**
Mysql bind port
*/
uint m_mysqld_port;
/**
Mysql bind admin port
*/
uint m_mysqld_admin_port;
/**
Advertised recovery valid endpoints
*/
std::vector<std::pair<std::string, uint>> m_endpoints;
/**
Recovery endpoints are from donor
*/
bool m_remote;
};
/**
@class Advertised_recovery_endpoints
Validate advertised recovery endpoints
*/
class Advertised_recovery_endpoints : Recovery_endpoints {
public:
/**
@enum enum_log_context
This enumeration describes which log context is being used.
*/
enum class enum_log_context { ON_BOOT, ON_START, ON_SET };
/**
Advertised_recovery_endpoints constructor
*/
Advertised_recovery_endpoints();
/**
Advertised_recovery_endpoints destructor
*/
~Advertised_recovery_endpoints() override;
/**
Validate recovery endpoints and log errors if it fails.
@param endpoints advertised recovery endpoints
@param where context where being executed
@return the operation status
@retval false OK
@retval true Error
*/
bool check(const char *endpoints, enum_log_context where);
};
/**
@class Donor_recovery_endpoints
Validate donor recovery endpoints
*/
class Donor_recovery_endpoints : Recovery_endpoints {
public:
/**
Donor_recovery_endpoints constructor
*/
Donor_recovery_endpoints();
/**
Donor_recovery_endpoints destructor
*/
~Donor_recovery_endpoints() override;
/**
Get recovery endpoints
@param donor group member info from donor
@return endpoints
*/
std::vector<std::pair<std::string, uint>> get_endpoints(
Group_member_info *donor);
};
#endif /* RECOVERY_ENDPOINTS_INCLUDE */
|
