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
|
/*
* 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/>.
*/
#ifndef WSREP_GTID_HPP
#define WSREP_GTID_HPP
#include "id.hpp"
#include "seqno.hpp"
#include "compiler.hpp"
#include <iosfwd>
/**
* Minimum number of bytes guaratneed to store GTID string representation,
* terminating '\0' not included (36 + 1 + 20).
*/
#define WSREP_LIB_GTID_C_STR_LEN 57
namespace wsrep
{
class gtid
{
public:
gtid()
: id_()
, seqno_()
{ }
gtid(const wsrep::id& id, wsrep::seqno seqno)
: id_(id)
, seqno_(seqno)
{ }
const wsrep::id& id() const { return id_; }
wsrep::seqno seqno() const { return seqno_ ; }
bool is_undefined() const
{
return (seqno_.is_undefined() && id_.is_undefined());
}
static const wsrep::gtid& undefined()
{
return undefined_;
}
bool operator==(const gtid& other) const
{
return (
seqno_ == other.seqno_ &&
id_ == other.id_
);
}
private:
static const wsrep::gtid undefined_;
wsrep::id id_;
wsrep::seqno seqno_;
};
/**
* Scan a GTID from C string.
*
* @param buf Buffer containing the string
* @param len Length of buffer
* @param[out] gtid Gtid to be printed to
*
* @return Number of bytes scanned, negative value on error.
*/
ssize_t scan_from_c_str(const char* buf, size_t buf_len,
wsrep::gtid& gtid);
/*
* Deprecated version of the above for backwards compatibility.
* Will be removed when all the superprojects have been updated.
*/
static inline ssize_t gtid_scan_from_c_str(const char* buf, size_t buf_len,
wsrep::gtid& gtid)
{
return scan_from_c_str(buf, buf_len, gtid);
}
/**
* Print a GTID into character buffer.
*
* @param gtid GTID to be printed.
* @param buf Pointer to the beginning of the buffer
* @param buf_len Buffer length
*
* @return Number of characters printed or negative value for error
*/
ssize_t print_to_c_str(const wsrep::gtid& gtid, char* buf, size_t buf_len);
/*
* Deprecated version of the above for backwards compatibility.
* Will be removed when all the superprojects have been updated.
*/
static inline ssize_t gtid_print_to_c_str(const wsrep::gtid& gtid,
char* buf, size_t buf_len)
{
return print_to_c_str(gtid, buf, buf_len);
}
/**
* Return minimum number of chars required to store any GTID.
*/
static inline size_t gtid_c_str_len() { return WSREP_LIB_GTID_C_STR_LEN; }
/**
* Overload for ostream operator<<.
*/
std::ostream& operator<<(std::ostream&, const wsrep::gtid&);
/**
* Overload for istream operator>>.
*/
std::istream& operator>>(std::istream&, wsrep::gtid&);
}
#endif // WSREP_GTID_HPP
|
