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
|
/* Copyright (c) 2019, 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 GROUP_SERVICE_MESSAGE_H
#define GROUP_SERVICE_MESSAGE_H
#include <string>
#include <vector>
#include "plugin/group_replication/include/gcs_plugin_messages.h"
#include "plugin/group_replication/include/plugin_psi.h"
#include "sql/malloc_allocator.h"
class Group_service_message : public Plugin_gcs_message {
public:
enum enum_payload_item_type {
// This type should not be used anywhere.
PIT_UNKNOWN = 0,
// Length of the payload item: variable
PIT_TAG = 1,
// Length of the payload item: variable
PIT_DATA = 2,
// No valid type codes can appear after this one.
PIT_MAX = 3
};
/**
Group service message constructor.
*/
Group_service_message();
/**
Group service message constructor for raw data.
@param[in] buf raw data
@param[in] len raw length
*/
Group_service_message(const uchar *buf, size_t len);
/**
Group service message destructor
*/
~Group_service_message() override;
/**
Set data to message that will be transmitted to group members.
Memory ownership belongs to the message creator.
@param[in] data where the data will be read
@param[in] data_length the length of the data to write
@return returns false if succeeds, otherwise true is returned.
*/
bool set_data(const uchar *data, const size_t data_length);
/**
Return data on message
@return content of the message
*/
const uchar *get_data();
/**
Return the length of the data on message
@return length of the content of the message
*/
size_t get_data_length();
/**
Set the tag that identifies the message
@param[in] tag tag name identify message
@return returns false if succeeds, otherwise tag is invalid and true
shall returned
*/
bool set_tag(const char *tag);
/**
Return the tag that identifies the message
@return const string that identifies content of message
*/
const std::string &get_tag() { return m_tag; }
/**
Return the length of the tag that identifies the message
@return length of the string that identifies content of message
*/
size_t get_tag_length() { return m_tag.length(); }
protected:
/**
Encodes the group service message contents for transmission.
@param[out] buffer the message buffer to be written
*/
void encode_payload(std::vector<unsigned char> *buffer) const override;
/**
Group service message decoding method
@param[in] buffer the received data
*/
void decode_payload(const unsigned char *buffer,
const unsigned char *) override;
private:
/**The message identifier*/
std::string m_tag;
/**The message data*/
std::vector<uchar, Malloc_allocator<uchar>> m_data;
/**
A pointer to the message data, memory ownership belongs to the
message creator.
*/
const unsigned char *m_data_pointer;
size_t m_data_pointer_length;
};
#endif /* GROUP_SERVICE_MESSAGE_H */
|
