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
|
/* Copyright (c) 2018, 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 PRIMARY_ELECTION_UTILS_INCLUDED
#define PRIMARY_ELECTION_UTILS_INCLUDED
#include <string>
#include "plugin/group_replication/include/member_version.h"
class Plugin_gcs_message;
class Election_member_info {
public:
Election_member_info(const std::string uuid, const Member_version &version,
bool is_primary);
/**
@return The member uuid
*/
std::string &get_uuid();
/**
@return The member version
*/
Member_version &get_member_version();
/**
@note This only returns true for single primary mode
@return Is this member a primary?
*/
bool is_primary();
/**
@return Did the member left the group
*/
bool member_left();
/**
@return this member has channels?
*/
bool has_channels();
/**
@return was this member information updated
*/
bool is_information_set();
/**
Set the flag that tells if the member has channels
@param running_channels the member has channels?
*/
void set_has_running_channels(bool running_channels);
/**
Set the flag that tells if this class was updated
@param set was the info updated?
*/
void set_information_set(bool set);
/**
Did the member left the group
@param left did the member left the group
*/
void set_member_left(bool left);
private:
/** The member uuid */
std::string member_uuid;
/** This member version*/
Member_version member_version;
/** Is this member the primary*/
bool is_member_primary;
/** Does the member has running channels*/
bool has_running_channels;
/** Did the member leave?*/
bool has_member_left;
/** Was the info for this member set*/
bool info_is_set;
};
bool send_message(Plugin_gcs_message *message);
/**
Kill transactions and enable super_read_only mode
@param err_msg the sql error message
*/
void kill_transactions_and_leave_on_election_error(std::string &err_msg);
#endif /* PRIMARY_ELECTION_UTILS_INCLUDED */
|
