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
|
/*
* Copyright (C) 2018 Codership Oy <info@codership.com>
*
* This file is part of wsrep-lib.
*
* Wsrep-lib 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, either version 2 of the License, or
* (at your option) any later version.
*
* Wsrep-lib 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 wsrep-lib. If not, see <https://www.gnu.org/licenses/>.
*/
/** @file view.hpp
*
*
*/
#ifndef WSREP_VIEW_HPP
#define WSREP_VIEW_HPP
#include "id.hpp"
#include "seqno.hpp"
#include "gtid.hpp"
#include <vector>
#include <iostream>
namespace wsrep
{
class view
{
public:
enum status
{
primary,
non_primary,
disconnected
};
class member
{
public:
member(const wsrep::id& id,
const std::string& name,
const std::string& incoming)
: id_(id)
, name_(name)
, incoming_(incoming)
{
}
const wsrep::id& id() const { return id_; }
const std::string& name() const { return name_; }
const std::string& incoming() const { return incoming_; }
private:
wsrep::id id_;
std::string name_;
std::string incoming_;
};
view()
: state_id_()
, view_seqno_()
, status_(disconnected)
, capabilities_()
, own_index_(-1)
, protocol_version_(0)
, members_()
{ }
view(const wsrep::gtid& state_id,
wsrep::seqno view_seqno,
enum wsrep::view::status status,
int capabilities,
ssize_t own_index,
int protocol_version,
const std::vector<wsrep::view::member>& members)
: state_id_(state_id)
, view_seqno_(view_seqno)
, status_(status)
, capabilities_(capabilities)
, own_index_(own_index)
, protocol_version_(protocol_version)
, members_(members)
{ }
wsrep::gtid state_id() const
{ return state_id_; }
wsrep::seqno view_seqno() const
{ return view_seqno_; }
wsrep::view::status status() const
{ return status_; }
int capabilities() const
{ return capabilities_; }
ssize_t own_index() const
{ return own_index_; }
/**
* Return true if the two views have the same membership
*/
bool equal_membership(const wsrep::view& other) const;
int protocol_version() const
{ return protocol_version_; }
const std::vector<member>& members() const
{ return members_; }
/**
* Return true if the view is final
*/
bool final() const
{
return (members_.empty() && own_index_ == -1);
}
/**
* Return member index in the view.
*
* @return Member index if found, -1 if member is not present
* in the view.
*/
int member_index(const wsrep::id& member_id) const;
/**
* Return true if id is member of this view
*/
bool is_member(const wsrep::id& id) const
{
return member_index(id) != -1;
}
void print(std::ostream& os) const;
private:
wsrep::gtid state_id_;
wsrep::seqno view_seqno_;
enum wsrep::view::status status_;
int capabilities_;
ssize_t own_index_;
int protocol_version_;
std::vector<wsrep::view::member> members_;
};
static inline
std::ostream& operator<<(std::ostream& os, const wsrep::view& v)
{
v.print(os); return os;
}
static inline const char* to_c_string(enum wsrep::view::status status)
{
switch(status)
{
case wsrep::view::primary: return "primary";
case wsrep::view::non_primary: return "non-primary";
case wsrep::view::disconnected: return "disconnected";
}
return "invalid status";
}
}
#endif // WSREP_VIEW
|
