1 /* Copyright (c) 2014, 2019, Oracle and/or its affiliates. All rights reserved.
2
3 This program is free software; you can redistribute it and/or modify
4 it under the terms of the GNU General Public License, version 2.0,
5 as published by the Free Software Foundation.
6
7 This program is also distributed with certain software (including
8 but not limited to OpenSSL) that is licensed under separate terms,
9 as designated in a particular file or component or in included license
10 documentation. The authors of MySQL hereby grant you an additional
11 permission to link the program and your derivative works with the
12 separately licensed software that they have included with MySQL.
13
14 This program is distributed in the hope that it will be useful,
15 but WITHOUT ANY WARRANTY; without even the implied warranty of
16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 GNU General Public License, version 2.0, for more details.
18
19 You should have received a copy of the GNU General Public License
20 along with this program; if not, write to the Free Software
21 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
22
23 #include "plugin/group_replication/libmysqlgcs/include/mysql/gcs/gcs_view.h"
24
25 #include <stddef.h>
26 #include <iostream>
27
Gcs_view(const std::vector<Gcs_member_identifier> & members,const Gcs_view_identifier & view_id,const std::vector<Gcs_member_identifier> & leaving,const std::vector<Gcs_member_identifier> & joined,const Gcs_group_identifier & group_id)28 Gcs_view::Gcs_view(const std::vector<Gcs_member_identifier> &members,
29 const Gcs_view_identifier &view_id,
30 const std::vector<Gcs_member_identifier> &leaving,
31 const std::vector<Gcs_member_identifier> &joined,
32 const Gcs_group_identifier &group_id)
33 : m_members(nullptr),
34 m_view_id(nullptr),
35 m_leaving(nullptr),
36 m_joined(nullptr),
37 m_group_id(nullptr),
38 m_error_code(Gcs_view::OK) {
39 clone(members, view_id, leaving, joined, group_id, m_error_code);
40 }
41
Gcs_view(const std::vector<Gcs_member_identifier> & members,const Gcs_view_identifier & view_id,const std::vector<Gcs_member_identifier> & leaving,const std::vector<Gcs_member_identifier> & joined,const Gcs_group_identifier & group_id,Gcs_view::Gcs_view_error_code error_code)42 Gcs_view::Gcs_view(const std::vector<Gcs_member_identifier> &members,
43 const Gcs_view_identifier &view_id,
44 const std::vector<Gcs_member_identifier> &leaving,
45 const std::vector<Gcs_member_identifier> &joined,
46 const Gcs_group_identifier &group_id,
47 Gcs_view::Gcs_view_error_code error_code)
48 : m_members(nullptr),
49 m_view_id(nullptr),
50 m_leaving(nullptr),
51 m_joined(nullptr),
52 m_group_id(nullptr),
53 m_error_code(Gcs_view::OK) {
54 clone(members, view_id, leaving, joined, group_id, error_code);
55 }
56
Gcs_view(Gcs_view const & view)57 Gcs_view::Gcs_view(Gcs_view const &view)
58 : m_members(nullptr),
59 m_view_id(nullptr),
60 m_leaving(nullptr),
61 m_joined(nullptr),
62 m_group_id(nullptr),
63 m_error_code(Gcs_view::OK) {
64 clone(view.get_members(), view.get_view_id(), view.get_leaving_members(),
65 view.get_joined_members(), view.get_group_id(), view.get_error_code());
66 }
67
clone(const std::vector<Gcs_member_identifier> & members,const Gcs_view_identifier & view_id,const std::vector<Gcs_member_identifier> & leaving,const std::vector<Gcs_member_identifier> & joined,const Gcs_group_identifier & group_id,Gcs_view::Gcs_view_error_code error_code)68 void Gcs_view::clone(const std::vector<Gcs_member_identifier> &members,
69 const Gcs_view_identifier &view_id,
70 const std::vector<Gcs_member_identifier> &leaving,
71 const std::vector<Gcs_member_identifier> &joined,
72 const Gcs_group_identifier &group_id,
73 Gcs_view::Gcs_view_error_code error_code) {
74 m_members = new std::vector<Gcs_member_identifier>();
75 std::vector<Gcs_member_identifier>::const_iterator members_it;
76 for (members_it = members.begin(); members_it != members.end();
77 ++members_it) {
78 m_members->push_back(Gcs_member_identifier(*members_it));
79 }
80
81 m_leaving = new std::vector<Gcs_member_identifier>();
82 std::vector<Gcs_member_identifier>::const_iterator leaving_it;
83 for (leaving_it = leaving.begin(); leaving_it != leaving.end();
84 ++leaving_it) {
85 m_leaving->push_back(Gcs_member_identifier(*leaving_it));
86 }
87
88 m_joined = new std::vector<Gcs_member_identifier>();
89 std::vector<Gcs_member_identifier>::const_iterator joined_it;
90 for (joined_it = joined.begin(); joined_it != joined.end(); ++joined_it) {
91 m_joined->push_back(Gcs_member_identifier(*joined_it));
92 }
93
94 m_group_id = new Gcs_group_identifier(group_id);
95
96 m_view_id = view_id.clone();
97
98 m_error_code = error_code;
99 }
100
~Gcs_view()101 Gcs_view::~Gcs_view() {
102 delete m_members;
103 delete m_leaving;
104 delete m_joined;
105 delete m_group_id;
106 delete m_view_id;
107 }
108
get_view_id() const109 const Gcs_view_identifier &Gcs_view::get_view_id() const { return *m_view_id; }
110
get_group_id() const111 const Gcs_group_identifier &Gcs_view::get_group_id() const {
112 return *m_group_id;
113 }
114
get_members() const115 const std::vector<Gcs_member_identifier> &Gcs_view::get_members() const {
116 return *m_members;
117 }
118
get_leaving_members() const119 const std::vector<Gcs_member_identifier> &Gcs_view::get_leaving_members()
120 const {
121 return *m_leaving;
122 }
123
get_joined_members() const124 const std::vector<Gcs_member_identifier> &Gcs_view::get_joined_members() const {
125 return *m_joined;
126 }
127
get_error_code() const128 Gcs_view::Gcs_view_error_code Gcs_view::get_error_code() const {
129 return m_error_code;
130 }
131
get_member(const std::string & member_id) const132 const Gcs_member_identifier *Gcs_view::get_member(
133 const std::string &member_id) const {
134 std::vector<Gcs_member_identifier>::const_iterator members_it;
135 for (members_it = m_members->begin(); members_it != m_members->end();
136 ++members_it) {
137 if ((*members_it).get_member_id() == member_id) {
138 return &(*members_it);
139 }
140 }
141
142 return nullptr;
143 }
144
has_member(const std::string & member_id) const145 bool Gcs_view::has_member(const std::string &member_id) const {
146 return get_member(member_id) != nullptr;
147 }
148