23#ifndef RPL_GTID_H_INCLUDED
24#define RPL_GTID_H_INCLUDED
59#define BINLOG_ERROR(MYSQLBINLOG_ERROR, SERVER_ERROR) error MYSQLBINLOG_ERROR
61#define BINLOG_ERROR(MYSQLBINLOG_ERROR, SERVER_ERROR) my_error SERVER_ERROR
75#define SKIP_WHITESPACE() \
76 while (my_isspace(&my_charset_utf8mb3_general_ci, *s)) s++
83#undef NON_DISABLED_GTID
149#define __CHECK_RETURN_STATUS(STATUS, ACTION, STATUS_NAME, ALLOW_UNREPORTED)
152 const char *status_name,
int allow_unreported);
153#define __CHECK_RETURN_STATUS(STATUS, ACTION, STATUS_NAME, ALLOW_UNREPORTED) \
154 check_return_status(STATUS, ACTION, STATUS_NAME, ALLOW_UNREPORTED);
161#define __PROPAGATE_ERROR(STATUS, RETURN_VALUE, ALLOW_UNREPORTED) \
163 enum_return_status __propagate_error_status = STATUS; \
164 if (__propagate_error_status != RETURN_STATUS_OK) { \
165 __CHECK_RETURN_STATUS(__propagate_error_status, "Propagating", #STATUS, \
167 return RETURN_VALUE; \
171#define __RETURN_STATUS(STATUS, ALLOW_UNREPORTED) \
173 enum_return_status __return_status_status = STATUS; \
174 __CHECK_RETURN_STATUS(__return_status_status, "Returning", #STATUS, \
176 return __return_status_status; \
182#define PROPAGATE_ERROR(STATUS) \
183 __PROPAGATE_ERROR(STATUS, __propagate_error_status, true)
189#define PROPAGATE_REPORTED_ERROR(STATUS) \
190 __PROPAGATE_ERROR(STATUS, __propagate_error_status, false)
196#define PROPAGATE_REPORTED_ERROR_INT(STATUS) __PROPAGATE_ERROR(STATUS, 1, false)
201#define RETURN_STATUS(STATUS) __RETURN_STATUS(STATUS, true)
207#define RETURN_REPORTED_STATUS(STATUS) __RETURN_STATUS(STATUS, false)
209#define RETURN_OK return RETURN_STATUS_OK
211#define RETURN_REPORTED_ERROR RETURN_STATUS(RETURN_STATUS_REPORTED_ERROR)
213#define RETURN_UNREPORTED_ERROR RETURN_STATUS(RETURN_STATUS_UNREPORTED_ERROR)
320 m_is_write_lock =
false;
322#if defined(HAVE_PSI_INTERFACE)
366 std::adopt_lock_t t [[maybe_unused]])
371 lock.assert_some_rdlock();
374 lock.assert_some_wrlock();
475 m_is_write_lock =
true;
491 m_is_write_lock =
false;
504 return m_is_write_lock;
520 m_is_write_lock =
true;
576 bool m_is_write_lock;
683 static std::pair<bool, value_type>
from_string(std::string s);
768 return it->second->sidno;
850 const Node *node = pointer_cast<const Node *>(ptr);
974 inline bool wait(
const THD *thd,
int sidno,
struct timespec *abstime)
const {
981 if (abstime !=
nullptr)
995 inline int get_max_index() const {
997 return static_cast<int>(
m_array.size() - 1);
1019 bool is_thd_killed(
const THD *thd)
const;
1028 assert(
n <= get_max_index());
1078 assert(sidno_arg > 0);
1079 assert(gno_arg > 0);
1106 static bool is_valid(
const char *text);
1125 bool need_lock =
false)
const;
1144 printf(
"%s\n",
buf);
1149 const char *text [[maybe_unused]] =
"",
1150 bool need_lock [[maybe_unused]] =
false)
const {
1154 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
buf));
1263 Sid_map *sid_map,
char *gtid_arg,
uint *gtid_length_arg,
1266 char *last_transient_errmsg_arg,
uint *last_transient_errmsg_length_arg,
1267 ulonglong *last_transient_timestamp_arg, ulong *retries_count_arg)
const;
1299 uint *last_transient_errno_arg,
1300 char *last_transient_errmsg_arg,
1301 uint *last_transient_errmsg_length_arg,
1302 ulonglong *last_transient_timestamp_arg,
1303 ulong *retries_count_arg)
const;
1388 ulonglong immediate_ts_arg,
bool skipped_arg =
false);
1391 size_t uncompressed_size);
1429 const char *transient_err_message_arg,
1430 ulong trans_retries_arg);
1626 bool *starts_with_plus =
nullptr);
1639 size_t *actual_length =
nullptr);
1729 while (ivit.
get() !=
nullptr) {
1750 return ivit.
get() !=
nullptr;
1756 static bool is_valid(
const char *text);
1834 printf(
"%s\n",
str ?
str :
"out of memory in Gtid_set::print");
1852 bool need_lock [[maybe_unused]] =
false,
1854 [[maybe_unused]] =
nullptr)
const {
1858 DBUG_PRINT(
"info", (
"%s%s'%s'", text, *text ?
": " :
"",
1859 str ?
str :
"out of memory in Gtid_set::dbug_print"));
1931 template <
typename Gt
id_set_p,
typename Interval_p>
1942 init(gtid_set, sidno);
1946 p =
const_cast<Interval_p *
>(>id_set->free_intervals);
1950 p =
const_cast<Interval_p *
>(>id_set->m_intervals[sidno - 1]);
1954 assert(*
p !=
nullptr);
1955 p =
const_cast<Interval_p *
>(&(*p)->next);
1958 inline Interval_p
get()
const {
return *
p; }
2012 assert(
get() !=
nullptr);
2047 if (iv ==
nullptr) {
2050 if (
sidno == 0)
return;
2075 }
while (iv ==
nullptr);
2137 while (ivit.
get() !=
nullptr) {
2148 for (
rpl_sidno sidno = 1; sidno < max_sidno; sidno++)
2250 Free_intervals_lock *
lock);
2273 Free_intervals_lock *
lock);
2290 Free_intervals_lock *
lock);
2307 Free_intervals_lock *
lock);
2312 Const_interval_iterator *super);
2315 Const_interval_iterator *ivit2);
2342#ifdef FRIEND_OF_GTID_SET
2343 friend FRIEND_OF_GTID_SET;
2488 for (
rpl_sidno sid_i = 0; sid_i < sid_map_max_sidno; sid_i++) {
2490 if (sidno > max_sidno)
continue;
2491 bool printed_sid =
false;
2492 for (
const auto &key_and_value : *
get_hash(sidno)) {
2493 Node *node = key_and_value.second.get();
2494 assert(node !=
nullptr);
2499 p += sprintf(
p,
":%" PRId64
"#%u", node->
gno, node->
owner);
2503 return (
int)(
p - out);
2514 for (
rpl_sidno sidno = 1; sidno <= max_sidno; sidno++) {
2515 size_t records =
get_hash(sidno)->size();
2530 while (node !=
nullptr) {
2531 if (node->
owner == thd_id)
return true;
2546 assert(
str !=
nullptr);
2553 printf(
"%s\n",
str);
2564 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
str));
2623 assert(
hash !=
nullptr);
2626 assert(
node !=
nullptr);
2843 (
"atomic_anonymous_gtid_count increased to %d", new_value));
2844 assert(new_value >= 1);
2858 (
"atomic_anonymous_gtid_count decreased to %d", new_value));
2859 assert(new_value >= 0);
2880 (
"ongoing_automatic_gtid_violating_transaction_count increased to %d",
2882 assert(new_value >= 1);
2902 (
"ongoing_automatic_gtid_violating_transaction_count decreased to %d",
2904 assert(new_value >= 0);
2928 DBUG_PRINT(
"info", (
"atomic_anonymous_gtid_violation_count increased to %d",
2930 assert(new_value >= 1);
2950 (
"ongoing_anonymous_gtid_violating_transaction_count decreased to %d",
2952 assert(new_value >= 0);
2977 DBUG_PRINT(
"info", (
"atomic_gtid_wait_count changed from %d to %d",
2978 new_value - 1, new_value));
2979 assert(new_value >= 1);
2994 DBUG_PRINT(
"info", (
"atomic_gtid_wait_count changed from %d to %d",
2995 new_value + 1, new_value));
2996 assert(new_value >= 0);
3110 bool update_thd_status =
true);
3117 struct timespec *abstime =
nullptr);
3133 bool update_thd_status =
true);
3232 p += sprintf(
p,
"Executed GTIDs:\n");
3234 p += sprintf(
p,
"\nOwned GTIDs:\n");
3236 p += sprintf(
p,
"\nLost GTIDs:\n");
3238 p += sprintf(
p,
"\nGTIDs only_in_table:\n");
3240 return (
int)(
p -
buf);
3264 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
str));
3364#ifdef HAVE_GTID_NEXT_LIST
3366 void lock_owned_sidnos(
const THD *thd);
3411#ifdef FRIEND_OF_GTID_STATE
3412 friend FRIEND_OF_GTID_STATE;
3839 static bool is_valid(
const char *text);
3854 bool need_lock =
false)
const;
3870 printf(
"%s\n",
buf);
3878 bool need_lock [[maybe_unused]] =
false)
const {
3882 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
buf));
3992#ifdef HAVE_GTID_NEXT_LIST
3993int gtid_acquire_ownership_multiple(
THD *thd);
RAII class to acquire a lock for the duration of a block.
Definition: rpl_gtid.h:336
void unlock_if_locked()
Unlock the lock, if it was acquired by this guard.
Definition: rpl_gtid.h:440
Guard(Checkable_rwlock &lock, enum_lock_type lock_type)
Create a guard, and optionally acquire a lock on it.
Definition: rpl_gtid.h:344
Checkable_rwlock & m_lock
Definition: rpl_gtid.h:337
Guard(Checkable_rwlock &lock, enum_lock_type lock_type, std::adopt_lock_t t)
Create a guard, assuming the caller already holds a lock on it.
Definition: rpl_gtid.h:365
bool is_locked() const
Return true if this object is either read locked or write locked.
Definition: rpl_gtid.h:455
bool is_wrlocked() const
Return true if this object is write locked.
Definition: rpl_gtid.h:452
int tryrdlock()
Try to acquire a read lock, and fail if it cannot be immediately granted.
Definition: rpl_gtid.h:424
enum_lock_type m_lock_type
Definition: rpl_gtid.h:338
Guard(Guard const ©)=delete
Objects of this class should not be copied or moved.
void unlock()
Unlock the lock.
Definition: rpl_gtid.h:433
void rdlock()
Acquire the read lock.
Definition: rpl_gtid.h:393
Guard(Guard const &©)=delete
bool is_rdlocked() const
Return true if this object is read locked.
Definition: rpl_gtid.h:449
~Guard()
Unlock on destruct.
Definition: rpl_gtid.h:387
Checkable_rwlock & get_lock() const
Return the underlying Checkable_rwlock object.
Definition: rpl_gtid.h:446
int trywrlock()
Try to acquire the write lock, and fail if it cannot be immediately granted.
Definition: rpl_gtid.h:412
void wrlock()
Acquire the write lock.
Definition: rpl_gtid.h:401
This has the functionality of mysql_rwlock_t, with two differences:
Definition: rpl_gtid.h:308
int32 get_state() const
Read lock_state atomically and return the value.
Definition: rpl_gtid.h:571
void assert_no_rdlock() const
Assert that no thread holds the read lock.
Definition: rpl_gtid.h:553
int trywrlock()
Return 0 if the write lock is held, otherwise an error will be returned.
Definition: rpl_gtid.h:511
enum_lock_type
Definition: rpl_gtid.h:331
@ TRY_READ_LOCK
Definition: rpl_gtid.h:331
@ WRITE_LOCK
Definition: rpl_gtid.h:331
@ READ_LOCK
Definition: rpl_gtid.h:331
@ NO_LOCK
Definition: rpl_gtid.h:331
void rdlock()
Acquire the read lock.
Definition: rpl_gtid.h:459
void wrlock()
Acquire the write lock.
Definition: rpl_gtid.h:468
std::atomic< int32 > m_lock_state
The state of the lock: 0 - not locked -1 - write locked >0 - read locked by that many threads.
Definition: rpl_gtid.h:569
void assert_no_lock() const
Assert that no thread holds read or write lock.
Definition: rpl_gtid.h:555
int tryrdlock()
Return 0 if the read lock is held, otherwise an error will be returned.
Definition: rpl_gtid.h:530
~Checkable_rwlock()
Destroy this Checkable_lock.
Definition: rpl_gtid.h:329
void assert_no_wrlock() const
Assert that no thread holds the write lock.
Definition: rpl_gtid.h:551
void assert_some_lock() const
Assert that some thread holds either the read or the write lock.
Definition: rpl_gtid.h:545
Checkable_rwlock(PSI_rwlock_key psi_key=0)
Initialize this Checkable_rwlock.
Definition: rpl_gtid.h:311
void assert_some_rdlock() const
Assert that some thread holds the read lock.
Definition: rpl_gtid.h:547
void unlock()
Release the lock (whether it is a write or read lock).
Definition: rpl_gtid.h:479
bool m_dbug_trace
If enabled, print any lock/unlock operations to the DBUG trace.
Definition: rpl_gtid.h:560
bool is_wrlock()
Return true if the write lock is held.
Definition: rpl_gtid.h:499
void assert_some_wrlock() const
Assert that some thread holds the write lock.
Definition: rpl_gtid.h:549
mysql_rwlock_t m_rwlock
The rwlock.
Definition: rpl_gtid.h:580
Class to access the value of @global.gtid_mode in an efficient and thread-safe manner.
Definition: rpl_gtid.h:590
static std::pair< bool, value_type > from_string(std::string s)
Return the given string gtid_mode as an enumeration value.
Definition: rpl_gtid_mode.cc:54
static ulong sysvar_mode
The sys_var framework needs a variable of type ulong to store the value in.
Definition: rpl_gtid.h:603
std::atomic< int > m_atomic_mode
Definition: rpl_gtid.h:592
const char * get_string() const
Return the current gtid_mode as a string.
Definition: rpl_gtid_mode.cc:51
Gtid_mode()
Definition: rpl_gtid.h:595
static const char * names[]
Strings holding the enumeration values for gtid_mode.
Definition: rpl_gtid.h:635
void set(value_type value)
Set a new value for @global.gtid_mode.
Definition: rpl_gtid_mode.cc:42
value_type get() const
Return the current gtid_mode as an enumeration value.
Definition: rpl_gtid_mode.cc:46
static const char * to_string(value_type value)
Return the given gtid_mode as a string.
Definition: rpl_gtid_mode.cc:66
static Checkable_rwlock lock
Protects updates to @global.gtid_mode.
Definition: rpl_gtid.h:646
value_type
Possible values for @global.gtid_mode.
Definition: rpl_gtid.h:606
@ ON_PERMISSIVE
New transactions are GTID-transactions.
Definition: rpl_gtid.h:622
@ OFF
New transactions are anonymous.
Definition: rpl_gtid.h:611
@ OFF_PERMISSIVE
New transactions are anonyomus.
Definition: rpl_gtid.h:617
@ ON
New transactions are GTID-transactions.
Definition: rpl_gtid.h:628
@ DEFAULT
Definition: rpl_gtid.h:612
Stores information to monitor a transaction during the different replication stages.
Definition: rpl_gtid.h:1310
Trx_monitoring_info * last_processed_trx
Holds information about the last processed transaction.
Definition: rpl_gtid.h:1330
const Gtid * get_processing_trx_gtid()
Returns the GTID of the processing_trx.
Definition: rpl_gtid_misc.cc:525
void clear()
Clear all monitoring information.
Definition: rpl_gtid_misc.cc:419
void finish()
Sets the final information, copy processing info to last_processed and clears processing info.
Definition: rpl_gtid_misc.cc:486
void start(Gtid gtid_arg, ulonglong original_ts_arg, ulonglong immediate_ts_arg, bool skipped_arg=false)
Sets the initial monitoring information.
Definition: rpl_gtid_misc.cc:446
void update(binary_log::transaction::compression::type t, size_t payload_size, size_t uncompressed_size)
Definition: rpl_gtid_misc.cc:438
~Gtid_monitoring_info()
Destroy this GTID monitoring info object.
Definition: rpl_gtid_misc.cc:378
Trx_monitoring_info * processing_trx
Holds information about transaction being processed.
Definition: rpl_gtid.h:1328
void atomic_lock()
Lock this object when no thread mutex is used to arbitrate the access.
Definition: rpl_gtid_misc.cc:383
void atomic_unlock()
Unlock this object when no thread mutex is used to arbitrate the access.
Definition: rpl_gtid_misc.cc:408
mysql_mutex_t * atomic_mutex
Mutex arbitrating the atomic access to the object.
Definition: rpl_gtid.h:1347
void copy_info_to(Trx_monitoring_info *processing_dest, Trx_monitoring_info *last_processed_dest)
Copies both processing_trx and last_processed_trx info to other Trx_monitoring_info structures.
Definition: rpl_gtid_misc.cc:503
std::atomic< bool > atomic_locked
The atomic locked flag.
Definition: rpl_gtid.h:1350
bool is_processing_trx_set()
Returns true if the processing_trx is set, false otherwise.
Definition: rpl_gtid_misc.cc:516
bool is_locked
Flag to assert the atomic lock behavior.
Definition: rpl_gtid.h:1353
void store_transient_error(uint transient_errno_arg, const char *transient_err_message_arg, ulong trans_retries_arg)
Stores the information about the last transient error in the current transaction, namely: the error n...
Definition: rpl_gtid_misc.cc:534
Gtid_monitoring_info(mysql_mutex_t *atomic_mutex_arg=nullptr)
Create this GTID monitoring info object.
Definition: rpl_gtid_misc.cc:372
void clear_last_processed_trx()
Clear only the last_processed_trx monitoring info.
Definition: rpl_gtid_misc.cc:432
void clear_processing_trx()
Clear only the processing_trx monitoring info.
Definition: rpl_gtid_misc.cc:426
Iterator over intervals of a const Gtid_set.
Definition: rpl_gtid.h:1973
Const_interval_iterator(const Gtid_set *gtid_set)
Create this Const_interval_iterator.
Definition: rpl_gtid.h:1980
Const_interval_iterator(const Gtid_set *gtid_set, rpl_sidno sidno)
Create this Const_interval_iterator.
Definition: rpl_gtid.h:1976
Class representing a lock on free_intervals_mutex.
Definition: rpl_gtid.h:2201
bool locked
Definition: rpl_gtid.h:2225
void unlock_if_locked()
Lock the lock if it is locked.
Definition: rpl_gtid.h:2214
Free_intervals_lock(Gtid_set *_gtid_set)
Create a new lock, but do not acquire it.
Definition: rpl_gtid.h:2204
~Free_intervals_lock()
Destroy this object and unlock the lock if it is locked.
Definition: rpl_gtid.h:2221
void lock_if_not_locked()
Lock the lock if it is not already locked.
Definition: rpl_gtid.h:2207
Gtid_set * gtid_set
Definition: rpl_gtid.h:2224
Iterator over all gtids in a Gtid_set.
Definition: rpl_gtid.h:2031
Gtid get() const
Return next gtid, or {0,0} if we reached the end.
Definition: rpl_gtid.h:2057
rpl_sidno sidno
The SIDNO of the current element, or 0 if the iterator is past the last element.
Definition: rpl_gtid.h:2084
const Gtid_set * gtid_set
The Gtid_set we iterate over.
Definition: rpl_gtid.h:2079
void next()
Advance to next gtid.
Definition: rpl_gtid.h:2038
rpl_gno gno
The GNO of the current element, or 0 if the iterator is past the last element.
Definition: rpl_gtid.h:2089
Const_interval_iterator ivit
Iterator over the intervals for the current SIDNO.
Definition: rpl_gtid.h:2091
Gtid_iterator(const Gtid_set *gs)
Definition: rpl_gtid.h:2033
void next_sidno()
Find the next sidno that has one or more intervals.
Definition: rpl_gtid.h:2064
Iterator over intervals for a given SIDNO.
Definition: rpl_gtid.h:1932
Interval_p get() const
Return current_elem.
Definition: rpl_gtid.h:1958
void init(Gtid_set_p gtid_set, rpl_sidno sidno)
Reset this iterator.
Definition: rpl_gtid.h:1949
Interval_iterator_base(Gtid_set_p gtid_set, rpl_sidno sidno)
Construct a new iterator over the GNO intervals for a given Gtid_set.
Definition: rpl_gtid.h:1940
Interval_p * p
Holds the address of the 'next' pointer of the previous element, or the address of the initial pointe...
Definition: rpl_gtid.h:1966
Interval_iterator_base(Gtid_set_p gtid_set)
Construct a new iterator over the free intervals of a Gtid_set.
Definition: rpl_gtid.h:1945
void next()
Advance current_elem one step.
Definition: rpl_gtid.h:1953
Iterator over intervals of a non-const Gtid_set, with additional methods to modify the Gtid_set.
Definition: rpl_gtid.h:1990
Interval_iterator(Gtid_set *gtid_set)
Destroy this Interval_iterator.
Definition: rpl_gtid.h:1996
void set(Interval *iv)
Set current_elem to the given Interval but do not touch the next pointer of the given Interval.
Definition: rpl_gtid.h:2004
void insert(Interval *iv)
Insert the given element before current_elem.
Definition: rpl_gtid.h:2006
void remove(Gtid_set *gtid_set)
Remove current_elem.
Definition: rpl_gtid.h:2011
Interval_iterator(Gtid_set *gtid_set, rpl_sidno sidno)
Create this Interval_iterator.
Definition: rpl_gtid.h:1993
Represents a set of GTIDs.
Definition: rpl_gtid.h:1454
void encode(uchar *buf) const
Encodes this Gtid_set as a binary string.
Definition: rpl_gtid_set.cc:1236
void put_free_interval(Interval *iv)
Puts the given interval in the list of free intervals.
Definition: rpl_gtid_set.cc:254
rpl_gno get_last_gno(rpl_sidno sidno) const
Definition: rpl_gtid_set.cc:723
bool is_size_greater_than_or_equal(ulonglong num) const
Return true if the size of the set is greater than or equal to the given number.
Definition: rpl_gtid_set.cc:1225
bool is_intersection_nonempty(const Gtid_set *other) const
Returns true if there is a least one element of this Gtid_set in the other Gtid_set.
Definition: rpl_gtid_set.cc:1146
bool is_subset(const Gtid_set *super) const
Returns true if this Gtid_set is a subset of the other Gtid_set.
Definition: rpl_gtid_set.cc:1067
void add_interval_memory(int n_intervals, Interval *intervals_param)
Provides an array of Intervals that this Gtid_set can use when gtids are subsequently added.
Definition: rpl_gtid.h:1915
bool contains_sidno(rpl_sidno sidno) const
Returns true if this Gtid_set contains at least one GTID with the given SIDNO.
Definition: rpl_gtid.h:1746
int get_n_intervals() const
Return the number of intervals in this Gtid_set.
Definition: rpl_gtid.h:2144
bool sidno_equals(rpl_sidno sidno, const Gtid_set *other, rpl_sidno other_sidno) const
Return true if the given sidno of this Gtid_set contains the same intervals as the given sidno of the...
Definition: rpl_gtid_set.cc:912
Sid_map * sid_map
Sid_map associated with this Gtid_set.
Definition: rpl_gtid.h:2318
friend std::ostream & operator<<(std::ostream &os, const Gtid_set &in)
For use with C++ std::ostream
Definition: rpl_gtid.h:1839
void add_gno_intervals(rpl_sidno sidno, Const_interval_iterator ivit, Free_intervals_lock *lock)
Adds a list of intervals to the given SIDNO.
Definition: rpl_gtid_set.cc:610
Checkable_rwlock * sid_lock
Read-write lock that protects updates to the number of SIDs.
Definition: rpl_gtid.h:2182
static bool is_interval_subset(Const_interval_iterator *sub, Const_interval_iterator *super)
Returns true if every interval of sub is a subset of some interval of super.
Definition: rpl_gtid_set.cc:988
void init()
Worker for the constructor.
Definition: rpl_gtid_set.cc:101
static const int CHUNK_GROW_SIZE
The default number of intervals in an Interval_chunk.
Definition: rpl_gtid.h:2117
Interval_chunk * chunks
Linked list of chunks.
Definition: rpl_gtid.h:2327
static const String_format commented_string_format
String_format for printing the Gtid_set commented: the string is not quote-wrapped,...
Definition: rpl_gtid.h:1883
bool contains_gtid(rpl_sidno sidno, rpl_gno gno) const
Return true iff the given GTID exists in this set.
Definition: rpl_gtid_set.cc:705
enum_return_status ensure_sidno(rpl_sidno sidno)
Allocates space for all sidnos up to the given sidno in the array of intervals.
Definition: rpl_gtid_set.cc:131
int get_n_intervals(rpl_sidno sidno) const
Return the number of intervals for the given sidno.
Definition: rpl_gtid.h:2134
enum_return_status add_gtid_set(const Gtid_set *other)
Adds all gtids from the given Gtid_set to this Gtid_set.
Definition: rpl_gtid_set.cc:646
Gtid_set(Sid_map *sid_map, Checkable_rwlock *sid_lock=nullptr)
Constructs a new, empty Gtid_set.
Definition: rpl_gtid_set.cc:84
Interval * free_intervals
Linked list of free intervals.
Definition: rpl_gtid.h:2325
bool contains_gtid(const Gtid >id) const
Return true iff the given GTID exists in this set.
Definition: rpl_gtid.h:1643
static const String_format default_string_format
The default String_format: the format understood by add_gtid_text(const char *).
Definition: rpl_gtid.h:1873
void clear_set_and_sid_map()
Removes all gtids from this Gtid_set and clear all the sidnos used by the Gtid_set and it's SID map.
Definition: rpl_gtid_set.cc:287
void add_interval_memory_lock_taken(int n_ivs, Interval *ivs)
Like add_interval_memory, but does not acquire free_intervals_mutex.
Definition: rpl_gtid_set.cc:179
void remove_gtid_set(const Gtid_set *other)
Removes all gtids in the given Gtid_set from this Gtid_set.
Definition: rpl_gtid_set.cc:678
void print(bool need_lock=false, const Gtid_set::String_format *sf=nullptr) const
Debug only: Print this Gtid_set to stdout.
Definition: rpl_gtid.h:1830
Prealloced_array< Interval *, 8 > m_intervals
Array where the N'th element contains the head pointer to the intervals of SIDNO N+1.
Definition: rpl_gtid.h:2323
mysql_mutex_t free_intervals_mutex
Lock protecting the list of free intervals.
Definition: rpl_gtid.h:2187
void dbug_print(const char *text="", bool need_lock=false, const Gtid_set::String_format *sf=nullptr) const
Print this Gtid_set to the trace file if debug is enabled; no-op otherwise.
Definition: rpl_gtid.h:1851
bool is_subset_for_sid(const Gtid_set *super, rpl_sidno superset_sidno, rpl_sidno subset_sidno) const
Returns true if this Gtid_set is a subset of the given gtid_set on the given superset_sidno and subse...
Definition: rpl_gtid_set.cc:1029
int n_chunks
The number of chunks.
Definition: rpl_gtid.h:2339
void remove_gno_intervals(rpl_sidno sidno, Const_interval_iterator ivit, Free_intervals_lock *lock)
Removes a list of intervals from the given SIDNO.
Definition: rpl_gtid_set.cc:623
static bool is_valid(const char *text)
Returns true if the given string is a valid specification of a Gtid_set, false otherwise.
Definition: rpl_gtid_set.cc:567
void clear()
Removes all gtids from this Gtid_set.
Definition: rpl_gtid_set.cc:262
static bool is_interval_intersection_nonempty(Const_interval_iterator *ivit1, Const_interval_iterator *ivit2)
Returns true if at least one sidno in ivit1 is also in ivit2.
Definition: rpl_gtid_set.cc:1109
enum_return_status intersection(const Gtid_set *other, Gtid_set *result)
Add the intersection of this Gtid_set and the other Gtid_set to result.
Definition: rpl_gtid_set.cc:1199
void remove_gno_interval(Interval_iterator *ivitp, rpl_gno start, rpl_gno end, Free_intervals_lock *lock)
Removes the interval (start, end) from the given Interval_iterator.
Definition: rpl_gtid_set.cc:349
void get_gtid_intervals(std::list< Gtid_interval > *gtid_intervals) const
Gets all gtid intervals from this Gtid_set.
Definition: rpl_gtid_set.cc:826
bool is_subset_not_equals(const Gtid_set *super) const
Returns true if this Gtid_set is a non equal subset of the other Gtid_set.
Definition: rpl_gtid.h:1670
size_t get_string_length(const String_format *string_format=nullptr) const
Returns the length of the output from to_string.
Definition: rpl_gtid_set.cc:868
size_t cached_string_length
The string length.
Definition: rpl_gtid.h:2331
enum_return_status add_gtid_text(const char *text, bool *anonymous=nullptr, bool *starts_with_plus=nullptr)
Adds the set of GTIDs represented by the given string to this Gtid_set.
Definition: rpl_gtid_set.cc:423
void add_gno_interval(Interval_iterator *ivitp, rpl_gno start, rpl_gno end, Free_intervals_lock *lock)
Adds the interval (start, end) to the given Interval_iterator.
Definition: rpl_gtid_set.cc:300
void _add_gtid(rpl_sidno sidno, rpl_gno gno)
Adds the given GTID to this Gtid_set.
Definition: rpl_gtid.h:1516
bool is_empty() const
Returns true if this Gtid_set is empty.
Definition: rpl_gtid.h:1703
static PSI_mutex_key key_gtid_executed_free_intervals_mutex
Definition: rpl_gtid.h:1456
static const String_format sql_string_format
String_format useful to generate an SQL string: the string is wrapped in single quotes and there is a...
Definition: rpl_gtid.h:1878
bool equals(const Gtid_set *other) const
Returns true if this Gtid_set is equal to the other Gtid_set.
Definition: rpl_gtid_set.cc:930
enum_return_status add_gtid_encoding(const uchar *encoded, size_t length, size_t *actual_length=nullptr)
Decodes a Gtid_set from the given string.
Definition: rpl_gtid_set.cc:1284
void remove_intervals_for_sidno(Gtid_set *other, rpl_sidno sidno)
Removes all intervals of 'other' for a given SIDNO, from 'this'.
Definition: rpl_gtid_set.cc:637
size_t get_encoded_length() const
Returns the length of this Gtid_set when encoded using the encode() function.
Definition: rpl_gtid_set.cc:1369
~Gtid_set()
Destroy this Gtid_set.
Definition: rpl_gtid_set.cc:116
bool has_cached_string_length
If the string is cached.
Definition: rpl_gtid.h:2329
const String_format * cached_string_format
The String_format that was used when cached_string_length was computed.
Definition: rpl_gtid.h:2333
void get_free_interval(Interval **out)
Returns a fresh new Interval object.
Definition: rpl_gtid_set.cc:241
size_t to_string(char *buf, bool need_lock=false, const String_format *string_format=nullptr) const
Formats this Gtid_set as a string and saves in a given buffer.
Definition: rpl_gtid_set.cc:760
void _remove_gtid(const Gtid >id)
Removes the given GTID from this Gtid_set.
Definition: rpl_gtid.h:1554
Sid_map * get_sid_map() const
Return the Sid_map associated with this Gtid_set.
Definition: rpl_gtid.h:1886
void _remove_gtid(rpl_sidno sidno, rpl_gno gno)
Removes the given GTID from this Gtid_set.
Definition: rpl_gtid.h:1532
void create_new_chunk(int size)
Allocates a new chunk of Intervals and adds them to the list of unused intervals.
Definition: rpl_gtid_set.cc:190
void _add_gtid(const Gtid >id)
Adds the given GTID to this Gtid_set.
Definition: rpl_gtid.h:1548
rpl_sidno get_max_sidno() const
Returns the maximal sidno that this Gtid_set currently has space for.
Definition: rpl_gtid.h:1649
void assert_free_intervals_locked()
Definition: rpl_gtid.h:2227
ulonglong get_gtid_count(rpl_sidno sidno) const
What is the count of all the GTIDs in all intervals for a sidno.
Definition: rpl_gtid.h:1726
Represents the server's GTID state: the set of committed GTIDs, the set of lost gtids,...
Definition: rpl_gtid.h:2701
bool update_gtids_impl_check_skip_gtid_rollback(THD *thd)
Used by unit tests that need to access private members.
Definition: rpl_gtid_state.cc:767
int init()
Add @GLOBAL.SERVER_UUID to this binlog's Sid_map.
Definition: rpl_gtid_state.cc:659
bool update_gtids_impl_do_nothing(THD *thd)
This is a sub task of update_gtids_impl responsible only to handle the case of a thread that owns not...
Definition: rpl_gtid_state.cc:776
void end_automatic_gtid_violating_transaction()
Decrease the global counter when ending a GTID-violating transaction having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2890
void broadcast_owned_sidnos(const THD *thd)
Broadcast the condition for all SIDNOs owned by the given THD.
Definition: rpl_gtid_state.cc:142
const Gtid_set * get_executed_gtids() const
Definition: rpl_gtid.h:3194
void unlock_sidnos(const Gtid_set *set)
Unlocks the mutex for each SIDNO where the given Gtid_set has at least one GTID.
Definition: rpl_gtid_state.cc:555
void print() const
Debug only: print this Gtid_state to stdout.
Definition: rpl_gtid.h:3250
const Gtid_set * get_lost_gtids() const
Return a pointer to the Gtid_set that contains the lost gtids.
Definition: rpl_gtid.h:3189
enum_return_status ensure_sidno()
Ensure that owned_gtids, executed_gtids, lost_gtids, gtids_only_in_table, previous_gtids_logged and s...
Definition: rpl_gtid_state.cc:569
void begin_anonymous_gtid_violating_transaction()
Increase the global counter when starting a GTID-violating transaction having GTID_NEXT=ANONYMOUS.
Definition: rpl_gtid.h:2920
rpl_sidno server_sidno
The SIDNO for this server.
Definition: rpl_gtid.h:3398
bool wait_for_gtid_set(THD *thd, Gtid_set *gtid_set, double timeout, bool update_thd_status=true)
Wait until the given Gtid_set is included in @GLOBAL.GTID_EXECUTED.
Definition: rpl_gtid_state.cc:300
enum_return_status acquire_ownership(THD *thd, const Gtid >id)
Acquires ownership of the given GTID, on behalf of the given thread.
Definition: rpl_gtid_state.cc:77
void update_gtids_impl_own_nothing(THD *thd)
Handle the case that the thread owns nothing.
Definition: rpl_gtid_state.cc:946
void update_gtids_impl_lock_sidno(rpl_sidno sidno)
Lock a given sidno of a transaction being updated.
Definition: rpl_gtid_state.cc:827
rpl_gno next_free_gno
The next_free_gno variable will be set with the supposed next free GNO every time a new GNO is delive...
Definition: rpl_gtid.h:3039
Sid_map * sid_map
The Sid_map used by this Gtid_state.
Definition: rpl_gtid.h:3375
std::atomic< int32 > atomic_anonymous_gtid_count
The number of anonymous transactions owned by any client.
Definition: rpl_gtid.h:3401
int save_gtids_of_last_binlog_into_table()
Save the set of gtids logged in the last binlog into gtid_executed table.
Definition: rpl_gtid_state.cc:701
void end_gtid_wait()
Decrease the global counter when ending a call to WAIT_FOR_EXECUTED_GTID_SET or WAIT_UNTIL_SQL_THREAD...
Definition: rpl_gtid.h:2987
Gtid_state(Checkable_rwlock *_sid_lock, Sid_map *_sid_map)
Constructs a new Gtid_state object.
Definition: rpl_gtid.h:2710
Gtid_set lost_gtids
The set of GTIDs that existed in some previously purged binary log.
Definition: rpl_gtid.h:3382
const Owned_gtids * get_owned_gtids() const
Return a pointer to the Owned_gtids that contains the owned gtids.
Definition: rpl_gtid.h:3210
void unlock_owned_sidnos(const THD *thd)
Unlock all SIDNOs owned by the given THD.
Definition: rpl_gtid_state.cc:130
const rpl_sid & get_server_sid() const
Return the server's SID.
Definition: rpl_gtid.h:3214
Owned_gtids owned_gtids
The set of GTIDs that are owned by some thread.
Definition: rpl_gtid.h:3396
enum_return_status generate_automatic_gtid(THD *thd, rpl_sidno specified_sidno=0, rpl_gno specified_gno=0, rpl_sidno *locked_sidno=nullptr)
Generates the GTID (or ANONYMOUS, if GTID_MODE = OFF or OFF_PERMISSIVE) for the THD,...
Definition: rpl_gtid_state.cc:472
rpl_sidno get_server_sidno() const
Return the server's SID's SIDNO.
Definition: rpl_gtid.h:3212
const Gtid_set * get_previous_gtids_logged() const
Definition: rpl_gtid.h:3206
void update_gtids_impl_broadcast_and_unlock_sidno(rpl_sidno sidno)
Unlock a given sidno after broadcasting its changes.
Definition: rpl_gtid_state.cc:908
int32 get_gtid_wait_count()
Return the number of clients that have an ongoing call to WAIT_FOR_EXECUTED_GTID_SET or WAIT_UNTIL_SQ...
Definition: rpl_gtid.h:3004
Mutex_cond_array sid_locks
Contains one mutex/cond pair for every SIDNO.
Definition: rpl_gtid.h:3377
char * to_string() const
Debug only: return a newly allocated string, or NULL on out-of-memory.
Definition: rpl_gtid.h:3243
int read_gtid_executed_from_table()
Fetch gtids from gtid_executed table and store them into gtid_executed set.
Definition: rpl_gtid_state.cc:752
Gtid_set previous_gtids_logged
Definition: rpl_gtid.h:3394
enum_return_status add_lost_gtids(Gtid_set *gtid_set, bool starts_with_plus)
Adds the given Gtid_set to lost_gtids and executed_gtids.
Definition: rpl_gtid_state.cc:615
bool wait_for_sidno(THD *thd, rpl_sidno sidno, struct timespec *abstime, bool update_thd_status=true)
Wait for a signal on the given SIDNO.
Definition: rpl_gtid_state.cc:265
const Gtid_set * get_gtids_only_in_table() const
Definition: rpl_gtid.h:3199
int compress(THD *thd)
Compress the gtid_executed table, read each row by the PK(sid, gno_start) in increasing order,...
Definition: rpl_gtid_state.cc:756
int32 get_anonymous_gtid_violating_transaction_count()
Return the number of ongoing GTID-violating transactions having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2962
void lock_sidnos(const Gtid_set *set)
Locks one mutex for each SIDNO where the given Gtid_set has at least one GTID.
Definition: rpl_gtid_state.cc:548
void assert_sidno_lock_owner(rpl_sidno sidno) const
Assert that we own the given SIDNO.
Definition: rpl_gtid.h:3084
enum_return_status ensure_commit_group_sidnos(rpl_sidno sidno)
Ensure that commit_group_sidnos have room for the SIDNO passed as parameter.
Definition: rpl_gtid_state.cc:956
void update_gtids_impl_own_anonymous(THD *thd, bool *more_trx)
Handle the case that the thread owns ANONYMOUS GTID.
Definition: rpl_gtid_state.cc:922
bool wait_for_gtid(THD *thd, const Gtid >id, struct timespec *abstime=nullptr)
This is only a shorthand for wait_for_sidno, which contains additional debug printouts and assertions...
Definition: rpl_gtid_state.cc:288
void acquire_anonymous_ownership()
Acquire anonymous ownership.
Definition: rpl_gtid.h:2834
int warn_or_err_on_modify_gtid_table(THD *thd, Table_ref *table)
Push a warning to client if user is modifying the gtid_executed table explicitly by a non-XA transact...
Definition: rpl_gtid_state.cc:760
void update_on_rollback(THD *thd)
Update the state after the given thread has rollbacked.
Definition: rpl_gtid_state.cc:209
Gtid_set gtids_only_in_table
Definition: rpl_gtid.h:3392
rpl_gno get_automatic_gno(rpl_sidno sidno) const
Computes the next available GNO.
Definition: rpl_gtid_state.cc:411
Gtid_set executed_gtids
Definition: rpl_gtid.h:3387
void update_gtids_impl_own_gtid(THD *thd, bool is_commit)
Handle the case that the thread own a single non-anonymous GTID.
Definition: rpl_gtid_state.cc:854
int32 get_automatic_gtid_violating_transaction_count()
Return the number of ongoing GTID-violating transactions having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2912
void dbug_print(const char *text="") const
Print this Gtid_state to the trace file if debug is enabled; no-op otherwise.
Definition: rpl_gtid.h:3260
void update_commit_group(THD *first_thd)
This function updates both the THD and the Gtid_state to reflect that the transaction set of transact...
Definition: rpl_gtid_state.cc:154
void unlock_sidno(rpl_sidno sidno)
Unlocks a mutex for the given SIDNO.
Definition: rpl_gtid.h:3080
bool is_owned(const Gtid >id) const
Returns true if GTID is owned, otherwise returns 0.
Definition: rpl_gtid.h:2767
int to_string(char *buf) const
Debug only: Generate a string in the given buffer and return the length.
Definition: rpl_gtid.h:3230
bool is_executed(const Gtid >id) const
Returns true if the given GTID is logged.
Definition: rpl_gtid.h:2754
Prealloced_array< bool, 8 > commit_group_sidnos
This array is used by Gtid_state_update_gtids_impl* functions.
Definition: rpl_gtid.h:3648
void update_prev_gtids(Gtid_set *write_gtid_set)
Updates previously logged GTID set before writing to table.
Definition: rpl_gtid_state.cc:596
Checkable_rwlock * sid_lock
Read-write lock that protects updates to the number of SIDs.
Definition: rpl_gtid.h:3373
void end_gtid_violating_transaction(THD *thd)
Definition: rpl_gtid_state.cc:252
void begin_automatic_gtid_violating_transaction()
Increase the global counter when starting a GTID-violating transaction having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2870
void update_gtids_impl_broadcast_and_unlock_sidnos()
Unlocks all locked sidnos after broadcasting their changes.
Definition: rpl_gtid_state.cc:914
void lock_sidno(rpl_sidno sidno)
Locks a mutex for the given SIDNO.
Definition: rpl_gtid.h:3078
void update_gtids_impl_own_gtid_set(THD *thd, bool is_commit)
Handle the case that the thread own a set of GTIDs.
Definition: rpl_gtid_state.cc:799
void broadcast_sidnos(const Gtid_set *set)
Broadcasts the condition variable for each SIDNO where the given Gtid_set has at least one GTID.
Definition: rpl_gtid_state.cc:562
size_t get_max_string_length() const
Debug only: Returns an upper bound on the length of the string generated by to_string(),...
Definition: rpl_gtid.h:3223
std::atomic< int32 > atomic_automatic_gtid_violation_count
The number of GTID-violating transactions that use GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:3403
std::atomic< int32 > atomic_gtid_wait_count
The number of clients that are executing WAIT_FOR_EXECUTED_GTID_SET or WAIT_UNTIL_SQL_THREAD_AFTER_GT...
Definition: rpl_gtid.h:3408
void end_anonymous_gtid_violating_transaction()
Decrease the global counter when ending a GTID-violating transaction having GTID_NEXT=ANONYMOUS.
Definition: rpl_gtid.h:2938
rpl_gno get_last_executed_gno(rpl_sidno sidno) const
Return the last executed GNO for a given SIDNO, e.g.
Definition: rpl_gtid_state.cc:461
int clear(THD *thd)
Reset the state and persistor after RESET MASTER: remove all logged and lost gtids,...
Definition: rpl_gtid_state.cc:55
std::atomic< int32 > atomic_anonymous_gtid_violation_count
The number of GTID-violating transactions that use GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:3405
void update_on_commit(THD *thd)
Remove the GTID owned by thread from owned GTIDs, stating that thd->owned_gtid was committed.
Definition: rpl_gtid_state.cc:202
void update_gtids_impl_lock_sidnos(THD *thd)
Locks the sidnos of all the GTIDs of the commit group starting on the transaction passed as parameter...
Definition: rpl_gtid_state.cc:833
int32 get_anonymous_ownership_count()
Return the number of clients that hold anonymous ownership.
Definition: rpl_gtid.h:2864
void update_gtids_impl_end(THD *thd, bool more_trx)
Handle the final part of update_gtids_impl.
Definition: rpl_gtid_state.cc:952
int save(THD *thd)
Save gtid owned by the thd into executed_gtids variable and gtid_executed table.
Definition: rpl_gtid_state.cc:674
bool update_gtids_impl_begin(THD *thd)
This is a sub task of update_gtids_impl responsible only to evaluate if the thread is committing in t...
Definition: rpl_gtid_state.cc:789
void broadcast_sidno(rpl_sidno sidno)
Broadcasts updates for the given SIDNO.
Definition: rpl_gtid.h:3082
void release_anonymous_ownership()
Release anonymous ownership.
Definition: rpl_gtid.h:2849
void begin_gtid_wait()
Increase the global counter when starting a call to WAIT_FOR_EXECUTED_GTID_SET or WAIT_UNTIL_SQL_THRE...
Definition: rpl_gtid.h:2970
void update_gtids_impl(THD *thd, bool is_commit)
Remove the GTID owned by thread from owned GTIDs.
Definition: rpl_gtid_state.cc:216
Represents a growable array where each element contains a mutex and a condition variable.
Definition: rpl_gtid.h:912
Prealloced_array< Mutex_cond *, 8 > m_array
Definition: rpl_gtid.h:1035
bool is_thd_killed(const THD *thd) const
Return true if the given THD is killed.
Definition: rpl_gtid_mutex_cond_array.cc:95
void enter_cond(THD *thd, int n, PSI_stage_info *stage, PSI_stage_info *old_stage) const
Execute THD::enter_cond for the n'th condition variable.
Definition: rpl_gtid_mutex_cond_array.cc:65
Checkable_rwlock * global_lock
Read-write lock that protects updates to the number of elements.
Definition: rpl_gtid.h:1034
bool wait(const THD *thd, int sidno, struct timespec *abstime) const
Wait for signal on the n'th condition variable.
Definition: rpl_gtid.h:974
Mutex_cond_array(Checkable_rwlock *global_lock)
Create a new Mutex_cond_array.
Definition: rpl_gtid_mutex_cond_array.cc:41
void broadcast(int n) const
Broadcast the n'th condition.
Definition: rpl_gtid.h:934
void assert_not_owner(int n) const
Assert that this thread does not own the n'th mutex.
Definition: rpl_gtid.h:950
~Mutex_cond_array()
Destroy this object.
Definition: rpl_gtid_mutex_cond_array.cc:47
void assert_owner(int n) const
Assert that this thread owns the n'th mutex.
Definition: rpl_gtid.h:941
void unlock(int n) const
Unlock the n'th mutex.
Definition: rpl_gtid.h:929
void lock(int n) const
Lock the n'th mutex.
Definition: rpl_gtid.h:924
Mutex_cond * get_mutex_cond(int n) const
Return the Nth Mutex_cond object.
Definition: rpl_gtid.h:1026
Iterator over all gtids in a Owned_gtids set.
Definition: rpl_gtid.h:2605
rpl_sidno max_sidno
Max SIDNO of the current iterator.
Definition: rpl_gtid.h:2660
Node * node
Current node on current SIDNO hash.
Definition: rpl_gtid.h:2667
malloc_unordered_multimap< rpl_gno, unique_ptr_my_free< Node > >::const_iterator node_it
Current node iterator on current SIDNO hash.
Definition: rpl_gtid.h:2665
const Owned_gtids * owned_gtids
The Owned_gtids set we iterate over.
Definition: rpl_gtid.h:2656
Node * get_node() const
Return the current GTID Node, or NULL if we reached the end.
Definition: rpl_gtid.h:2652
Gtid_iterator(const Owned_gtids *og)
Definition: rpl_gtid.h:2607
Gtid get() const
Return next GTID, or {0,0} if we reached the end.
Definition: rpl_gtid.h:2643
void next()
Advance to next GTID.
Definition: rpl_gtid.h:2617
rpl_sidno sidno
The SIDNO of the current element, or 1 in the initial iteration.
Definition: rpl_gtid.h:2658
malloc_unordered_multimap< rpl_gno, unique_ptr_my_free< Node > > * hash
Current SIDNO hash.
Definition: rpl_gtid.h:2662
Represents the set of GTIDs that are owned by some thread.
Definition: rpl_gtid.h:2416
size_t get_max_string_length() const
Return an upper bound on the length of the string representation of this Owned_gtids.
Definition: rpl_gtid.h:2511
char * to_string() const
Debug only: return a newly allocated string representation of this Owned_gtids.
Definition: rpl_gtid.h:2543
bool thread_owns_anything(my_thread_id thd_id) const
Return true if the given thread is the owner of any gtids.
Definition: rpl_gtid.h:2527
enum_return_status add_gtid_owner(const Gtid >id, my_thread_id owner)
Add a GTID to this Owned_gtids.
Definition: rpl_gtid_owned.cc:69
bool is_intersection_nonempty(const Gtid_set *other) const
Returns true if there is a least one element of this Owned_gtids set in the other Gtid_set.
Definition: rpl_gtid_owned.cc:103
bool is_owned_by(const Gtid >id, const my_thread_id thd_id) const
If thd_id==0, returns true when gtid is not owned by any thread.
Definition: rpl_gtid_owned.cc:137
bool is_empty() const
Returns true if this Owned_gtids is empty.
Definition: rpl_gtid.h:2468
int to_string(char *out) const
Write a string representation of this Owned_gtids to the given buffer.
Definition: rpl_gtid.h:2484
Owned_gtids(Checkable_rwlock *sid_lock)
Constructs a new, empty Owned_gtids object.
Definition: rpl_gtid_owned.cc:38
rpl_sidno get_max_sidno() const
Returns the maximal sidno that this Owned_gtids currently has space for.
Definition: rpl_gtid.h:2473
malloc_unordered_multimap< rpl_gno, unique_ptr_my_free< Node > > * get_hash(rpl_sidno sidno) const
Returns the hash for the given SIDNO.
Definition: rpl_gtid.h:2586
Prealloced_array< malloc_unordered_multimap< rpl_gno, unique_ptr_my_free< Node > > *, 8 > sidno_to_hash
Growable array of hashes.
Definition: rpl_gtid.h:2598
void dbug_print(const char *text="") const
Print this Owned_gtids to the trace file if debug is enabled; no-op otherwise.
Definition: rpl_gtid.h:2561
void get_gtids(Gtid_set >id_set) const
Definition: rpl_gtid_owned.cc:116
bool contains_gtid(const Gtid >id) const
Return true iff this Owned_gtids object contains the given gtid.
Definition: rpl_gtid_owned.cc:130
Checkable_rwlock * sid_lock
Read-write lock that protects updates to the number of SIDs.
Definition: rpl_gtid.h:2584
~Owned_gtids()
Destroys this Owned_gtids.
Definition: rpl_gtid_owned.cc:42
void print() const
Debug only: print this Owned_gtids to stdout.
Definition: rpl_gtid.h:2551
enum_return_status ensure_sidno(rpl_sidno sidno)
Ensures that this Owned_gtids object can accommodate SIDNOs up to the given SIDNO.
Definition: rpl_gtid_owned.cc:55
void remove_gtid(const Gtid >id, const my_thread_id owner)
Removes the given GTID.
Definition: rpl_gtid_owned.cc:88
A typesafe replacement for DYNAMIC_ARRAY.
Definition: prealloced_array.h:70
Represents a bidirectional map between SID and SIDNO.
Definition: rpl_gtid.h:723
~Sid_map()
Destroy this Sid_map.
Definition: rpl_gtid_sid_map.cc:52
malloc_unordered_map< rpl_sid, unique_ptr_my_free< Node >, binary_log::Hash_Uuid > _sid_to_sidno
Hash that maps SID to SIDNO.
Definition: rpl_gtid.h:880
Checkable_rwlock * sid_lock
Read-write lock that protects updates to the number of SIDNOs.
Definition: rpl_gtid.h:869
rpl_sidno get_sorted_sidno(rpl_sidno n) const
Return the n'th smallest sidno, in the order of the SID's UUID.
Definition: rpl_gtid.h:810
rpl_sidno sid_to_sidno(const rpl_sid &sid) const
Get the SIDNO for a given SID.
Definition: rpl_gtid.h:764
rpl_sidno add_sid(const rpl_sid &sid)
Add the given SID to this map if it does not already exist.
Definition: rpl_gtid_sid_map.cc:62
enum_return_status add_node(rpl_sidno sidno, const rpl_sid &sid)
Create a Node from the given SIDNO and SID and add it to _sidno_to_sid, _sid_to_sidno,...
Definition: rpl_gtid_sid_map.cc:103
static const uchar * sid_map_get_key(const uchar *ptr, size_t *length)
Definition: rpl_gtid.h:849
rpl_sidno get_max_sidno() const
Return the biggest sidno in this Sid_map.
Definition: rpl_gtid.h:820
Prealloced_array< Node *, 8 > _sidno_to_sid
Array that maps SIDNO to SID; the element at index N points to a Node with SIDNO N-1.
Definition: rpl_gtid.h:875
Prealloced_array< rpl_sidno, 8 > _sorted
Array that maps numbers in the interval [0, get_max_sidno()-1] to SIDNOs, in order of increasing SID.
Definition: rpl_gtid.h:887
Checkable_rwlock * get_sid_lock() const
Return the sid_lock.
Definition: rpl_gtid.h:826
enum_return_status copy(Sid_map *dest)
Deep copy this Sid_map to dest.
Definition: rpl_gtid_sid_map.cc:152
enum_return_status clear()
Clears this Sid_map (for RESET SLAVE)
Definition: rpl_gtid_sid_map.cc:54
const rpl_sid & sidno_to_sid(rpl_sidno sidno, bool need_lock=false) const
Get the SID for a given SIDNO.
Definition: rpl_gtid.h:790
Sid_map(Checkable_rwlock *sid_lock)
Create this Sid_map.
Definition: rpl_gtid_sid_map.cc:45
Using this class is fraught with peril, and you need to be very careful when doing so.
Definition: sql_string.h:166
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:33
std::unordered_map, but with my_malloc, so that you can track the memory used using PSI memory keys.
Definition: map_helpers.h:147
std::unordered_multimap, but with my_malloc, so that you can track the memory used using PSI memory k...
Definition: map_helpers.h:188
#define mysql_cond_wait(C, M)
Definition: mysql_cond.h:47
#define mysql_cond_timedwait(C, M, T)
Definition: mysql_cond.h:50
#define mysql_mutex_lock(M)
Definition: mysql_mutex.h:49
#define mysql_mutex_unlock(M)
Definition: mysql_mutex.h:56
#define mysql_rwlock_rdlock(T)
Definition: mysql_rwlock.h:60
#define mysql_rwlock_unlock(T)
Definition: mysql_rwlock.h:90
#define mysql_rwlock_init(K, T)
Definition: mysql_rwlock.h:40
#define mysql_rwlock_tryrdlock(T)
Definition: mysql_rwlock.h:80
#define mysql_rwlock_destroy(T)
Definition: mysql_rwlock.h:50
#define mysql_rwlock_trywrlock(T)
Definition: mysql_rwlock.h:85
#define mysql_rwlock_wrlock(T)
Definition: mysql_rwlock.h:70
const char * p
Definition: ctype-mb.cc:1236
Fido Client Authentication nullptr
Definition: fido_client_plugin.cc:221
#define MY_WME
Definition: my_sys.h:122
unsigned int PSI_memory_key
Instrumented memory key.
Definition: psi_memory_bits.h:48
unsigned int PSI_mutex_key
Instrumented mutex key.
Definition: psi_mutex_bits.h:51
unsigned int PSI_rwlock_key
Instrumented rwlock key.
Definition: psi_rwlock_bits.h:43
#define mysql_mutex_assert_not_owner(M)
Wrapper, to use safe_mutex_assert_not_owner with instrumented mutexes.
Definition: mysql_mutex.h:125
#define mysql_mutex_assert_owner(M)
Wrapper, to use safe_mutex_assert_owner with instrumented mutexes.
Definition: mysql_mutex.h:111
static void start(mysql_harness::PluginFuncEnv *env)
Definition: http_auth_backend_plugin.cc:176
#define DBUG_PRINT(keyword, arglist)
Definition: my_dbug.h:180
#define DBUG_TRACE
Definition: my_dbug.h:145
unsigned long long int ulonglong
Definition: my_inttypes.h:55
unsigned char uchar
Definition: my_inttypes.h:51
int64_t int64
Definition: my_inttypes.h:67
#define MYF(v)
Definition: my_inttypes.h:96
int32_t int32
Definition: my_inttypes.h:65
void * my_malloc(PSI_memory_key key, size_t size, int flags)
Allocates size bytes of memory.
Definition: my_memory.cc:56
void my_free(void *ptr)
Frees the memory pointed by the ptr.
Definition: my_memory.cc:80
#define HAVE_PSI_INTERFACE
Definition: my_psi_config.h:38
static int is_timeout(int e)
Definition: my_thread.h:56
uint32 my_thread_id
Definition: my_thread_local.h:33
int(* mysql_cond_broadcast)(mysql_cond_t *that, const char *src_file, unsigned int src_line)
Definition: mysql_cond_service.h:51
void copy(Shards< COUNT > &dst, const Shards< COUNT > &src) noexcept
Copy the counters, overwrite destination.
Definition: ut0counter.h:353
Type sub(Shards< COUNT > &shards, size_t id, size_t n)
Decrement the counter for a shard by n.
Definition: ut0counter.h:279
std::string str(const mysqlrouter::ConfigGenerator::Options::Endpoint &ep)
Definition: config_generator.cc:1054
std::int64_t gno_t
Definition: global.h:33
type
Definition: base.h:36
Definition: buf0block_hint.cc:29
bool length(const dd::Spatial_reference_system *srs, const Geometry *g1, double *length, bool *null) noexcept
Computes the length of linestrings and multilinestrings.
Definition: length.cc:75
Provides atomic access in shared-exclusive modes.
Definition: shared_spin_lock.h:78
static bool timeout(bool(*wait_condition)())
Timeout function.
Definition: log0meb.cc:495
HARNESS_EXPORT std::string string_format(const char *format,...)
Definition: utilities.cc:63
static mysql_service_status_t flush(reference_caching_cache cache) noexcept
Definition: component.cc:121
Cursor end()
A past-the-end Cursor.
Definition: rules_table_service.cc:191
mode
Definition: file_handle.h:59
std::set< Key, Compare, ut::allocator< Key > > set
Specialization of set which uses ut_allocator.
Definition: ut0new.h:2880
static std::mutex lock
Definition: net_ns.cc:55
Instrumentation helpers for conditions.
Instrumentation helpers for rwlock.
PSI_memory_key key_memory_Sid_map_Node
Definition: rpl_gtid_sid_map.cc:43
required uint32 status
Definition: replication_asynchronous_connection_failover.proto:60
repeated Action action
Definition: replication_group_member_actions.proto:42
Sid_map * global_sid_map
Definition: mysqld.cc:1822
rpl_gno get_last_executed_gno(rpl_sidno sidno)
Return last gno for a given sidno, see Gtid_state::get_last_executed_gno() for details.
Definition: rpl_gtid_misc.cc:226
const int MAX_THREAD_ID_TEXT_LENGTH
The maximal possible length of thread_id when printed in decimal.
Definition: rpl_gtid.h:272
const rpl_gno GNO_WARNING_THRESHOLD
If the GNO goes above the number, generate a warning.
Definition: rpl_gtid.h:268
ulong _gtid_consistency_mode
Current value for ENFORCE_GTID_CONSISTENCY.
Definition: rpl_gtid_misc.cc:39
const rpl_gno GNO_END
One-past-the-max value of GNO.
Definition: rpl_gtid.h:266
enum_return_status map_macro_enum(int status)
enum to map the result of Uuid::parse to the above Macros
Definition: rpl_gtid.h:218
enum_gtid_consistency_mode get_gtid_consistency_mode()
Return the current value of ENFORCE_GTID_CONSISTENCY.
Definition: rpl_gtid_misc.cc:63
void gtid_state_commit_or_rollback(THD *thd, bool needs_to, bool do_commit)
The function commits or rolls back the gtid state if it needs to.
Definition: rpl_gtid.h:4034
PSI_memory_key key_memory_Gtid_cache_to_string
enum_return_status
Generic return type for many functions that can succeed or fail.
Definition: rpl_gtid.h:121
@ RETURN_STATUS_OK
The function completed successfully.
Definition: rpl_gtid.h:123
@ RETURN_STATUS_UNREPORTED_ERROR
The function completed with error but did not report it.
Definition: rpl_gtid.h:125
@ RETURN_STATUS_REPORTED_ERROR
The function completed with error and has called my_error.
Definition: rpl_gtid.h:127
bool set_gtid_next(THD *thd, const Gtid_specification &spec)
Acquire ownership of the given Gtid_specification.
Definition: rpl_gtid_execution.cc:45
const char * gtid_consistency_mode_names[]
Strings holding the enumeration values for gtid_consistency_mode_names.
Definition: rpl_gtid_misc.cc:57
int rpl_sidno
Type of SIDNO (source ID number, first component of GTID)
Definition: rpl_gtid.h:95
int format_gno(char *s, rpl_gno gno)
Formats a GNO as a string.
Definition: rpl_gtid_set.cc:419
Gtid_mode global_gtid_mode
The one and only instance of Gtid_mode.
Definition: rpl_gtid_mode.cc:29
const int MAX_GNO_TEXT_LENGTH
The length of MAX_GNO when printed in decimal.
Definition: rpl_gtid.h:270
PSI_memory_key key_memory_Gtid_state_group_commit_sidno
Definition: rpl_gtid_state.cc:51
bool is_already_logged_transaction(const THD *thd)
Check if current transaction should be skipped, that is, if GTID_NEXT was already logged.
Definition: rpl_gtid_execution.cc:305
void gtid_set_performance_schema_values(const THD *thd)
Definition: rpl_gtid_execution.cc:580
bool gtid_reacquire_ownership_if_anonymous(THD *thd)
If gtid_next=ANONYMOUS or NOT_YET_DETERMINED, but the thread does not hold anonymous ownership,...
Definition: rpl_gtid_execution.cc:364
enum_gtid_statement_status
Indicates if a statement should be skipped or not.
Definition: rpl_gtid.h:3891
@ GTID_STATEMENT_CANCEL
Statement should be cancelled.
Definition: rpl_gtid.h:3895
@ GTID_STATEMENT_EXECUTE
Statement can execute.
Definition: rpl_gtid.h:3893
@ GTID_STATEMENT_SKIP
Statement should be skipped, but there may be an implicit commit after the statement if gtid_commit i...
Definition: rpl_gtid.h:3900
bool gtid_pre_statement_post_implicit_commit_checks(THD *thd)
Perform GTID-related checks before executing a statement, but after executing an implicit commit befo...
Definition: rpl_gtid_execution.cc:550
int64 rpl_binlog_pos
Definition: rpl_gtid.h:103
binary_log::gtids::gno_t rpl_gno
GNO, the second (numeric) component of a GTID, is an alias of binary_log::gtids::gno_t.
Definition: rpl_gtid.h:102
rpl_gno parse_gno(const char **s)
Parse a GNO from a string.
Definition: rpl_gtid_set.cc:411
PSI_memory_key key_memory_Gtid_set_Interval_chunk
Definition: rpl_gtid_set.cc:65
const char * get_gtid_consistency_mode_string(enum_gtid_consistency_mode mode)
Return the given GTID_CONSISTENCY_MODE as a string.
Definition: rpl_gtid.h:252
Gtid_state * gtid_state
Global state of GTIDs.
Definition: mysqld.cc:1823
rpl_sidno get_sidno_from_global_sid_map(rpl_sid sid)
Return sidno for a given sid, see Sid_map::add_sid() for details.
Definition: rpl_gtid_misc.cc:216
Checkable_rwlock * global_sid_lock
Protects Gtid_state. See comment above gtid_state for details.
Definition: mysqld.cc:1821
PSI_memory_key key_memory_Gtid_set_to_string
Definition: rpl_gtid_set.cc:64
#define RETURN_OK
Returns RETURN_STATUS_OK.
Definition: rpl_gtid.h:209
std::ostream & operator<<(std::ostream &oss, Gtid_mode::value_type const &mode)
Definition: rpl_gtid_mode.cc:70
enum_gtid_consistency_mode
Possible values for ENFORCE_GTID_CONSISTENCY.
Definition: rpl_gtid.h:229
@ GTID_CONSISTENCY_MODE_ON
Definition: rpl_gtid.h:231
@ GTID_CONSISTENCY_MODE_WARN
Definition: rpl_gtid.h:232
@ GTID_CONSISTENCY_MODE_OFF
Definition: rpl_gtid.h:230
PSI_memory_key key_memory_Owned_gtids_to_string
Definition: psi_memory_key.cc:66
enum_gtid_type
Enumeration of different types of values for Gtid_specification, i.e, the different internal states t...
Definition: rpl_gtid.h:3676
@ UNDEFINED_GTID
GTID_NEXT is set to this state after a transaction with GTID_NEXT=='UUID:NUMBER' is committed.
Definition: rpl_gtid.h:3742
@ ANONYMOUS_GTID
Specifies that the transaction is anonymous, i.e., it does not have a GTID and will never be assigned...
Definition: rpl_gtid.h:3708
@ ASSIGNED_GTID
Specifies that the transaction has been assigned a GTID (UUID:NUMBER).
Definition: rpl_gtid.h:3698
@ PRE_GENERATE_GTID
The applier sets GTID_NEXT this state internally, when it processes an Anonymous_gtid_log_event on a ...
Definition: rpl_gtid.h:3779
@ NOT_YET_DETERMINED_GTID
Definition: rpl_gtid.h:3769
@ AUTOMATIC_GTID
Specifies that the GTID has not been generated yet; it will be generated on commit.
Definition: rpl_gtid.h:3690
void check_return_status(enum_return_status status, const char *action, const char *status_name, int allow_unreported)
Definition: rpl_gtid_misc.cc:190
binary_log::Uuid rpl_sid
Definition: rpl_gtid.h:292
enum_gtid_statement_status gtid_pre_statement_checks(THD *thd)
Perform GTID-related checks before executing a statement:
Definition: rpl_gtid_execution.cc:442
#define RETURN_UNREPORTED_ERROR
Does a DBUG_PRINT and returns RETURN_STATUS_UNREPORTED_ERROR.
Definition: rpl_gtid.h:213
PSI_memory_key key_memory_Gtid_state_to_string
Definition: psi_memory_key.cc:49
#define MAX_SLAVE_ERRMSG
Maximum size of an error message from a slave thread.
Definition: rpl_reporting.h:41
Holds information about a GTID interval: the sidno, the first gno and the last gno of this interval.
Definition: rpl_gtid.h:1042
rpl_gno gno_start
Definition: rpl_gtid.h:1046
rpl_gno gno_end
Definition: rpl_gtid.h:1048
void set(rpl_sidno sid_no, rpl_gno start, rpl_gno end)
Definition: rpl_gtid.h:1049
rpl_sidno sidno
Definition: rpl_gtid.h:1044
Contains a list of intervals allocated by this Gtid_set.
Definition: rpl_gtid.h:2112
Interval intervals[1]
Definition: rpl_gtid.h:2114
Interval_chunk * next
Definition: rpl_gtid.h:2113
Represents one element in the linked list of intervals associated with a SIDNO.
Definition: rpl_gtid.h:1892
rpl_gno start
The first GNO of this interval.
Definition: rpl_gtid.h:1895
rpl_gno end
The first GNO after this interval.
Definition: rpl_gtid.h:1897
bool equals(const Interval &other) const
Return true iff this interval is equal to the given interval.
Definition: rpl_gtid.h:1899
Interval * next
Pointer to next interval in list.
Definition: rpl_gtid.h:1903
Holds information about a Gtid_set.
Definition: rpl_gtid.h:2369
Gtid_set * gtid_set
Pointer to the Gtid_set.
Definition: rpl_gtid.h:2371
Gtid_set * set_non_null(Sid_map *sm)
Do nothing if this object is non-null; set to empty set otherwise.
Definition: rpl_gtid.h:2384
Gtid_set * get_gtid_set() const
Return NULL if this is NULL, otherwise return the Gtid_set.
Definition: rpl_gtid.h:2375
void set_null()
Set this Gtid_set to NULL.
Definition: rpl_gtid.h:2395
bool is_non_null
True if this Gtid_set is NULL.
Definition: rpl_gtid.h:2373
This struct represents a specification of a GTID for a statement to be executed: either "AUTOMATIC",...
Definition: rpl_gtid.h:3790
void set_not_yet_determined()
Set the type to NOT_YET_DETERMINED_GTID.
Definition: rpl_gtid.h:3811
enum_gtid_type type
The type of this GTID.
Definition: rpl_gtid.h:3792
static bool is_valid(const char *text)
Returns true if the given string is a valid Gtid_specification.
Definition: rpl_gtid_specification.cc:52
Gtid gtid
The GTID: { SIDNO, GNO } if type == GTID; { 0, 0 } if type == AUTOMATIC or ANONYMOUS.
Definition: rpl_gtid.h:3798
bool equals(const Gtid_specification &other) const
Return true if this Gtid_specification is equal to 'other'.
Definition: rpl_gtid.h:3818
int to_string(const Sid_map *sid_map, char *buf, bool need_lock=false) const
Writes this Gtid_specification to the given string buffer.
Definition: rpl_gtid_specification.cc:97
void set(const Gtid >id_param)
Set the type to ASSIGNED_GTID and SID, GNO to the given Gtid.
Definition: rpl_gtid.h:3805
static const int MAX_TEXT_LENGTH
Definition: rpl_gtid.h:3841
void dbug_print(const char *text="", bool need_lock=false) const
Print this Gtid_specification to the trace file if debug is enabled; no-op otherwise.
Definition: rpl_gtid.h:3877
enum_return_status parse(Sid_map *sid_map, const char *text)
Parses the given string and stores in this Gtid_specification.
Definition: rpl_gtid_specification.cc:33
void set_anonymous()
Set the type to ANONYMOUS_GTID.
Definition: rpl_gtid.h:3809
void set_undefined()
Set to undefined. Must only be called if the type is ASSIGNED_GTID.
Definition: rpl_gtid.h:3813
void set_automatic()
Set the type to AUTOMATIC_GTID.
Definition: rpl_gtid.h:3807
void set(rpl_sidno sidno, rpl_gno gno)
Set the type to ASSIGNED_GTID and SID, GNO to the given values.
Definition: rpl_gtid.h:3800
bool equals(const Gtid &other_gtid) const
Return true if this Gtid_specification is a ASSIGNED_GTID with the same SID, GNO as 'other_gtid'.
Definition: rpl_gtid.h:3826
void print() const
Debug only: print this Gtid_specification to stdout.
Definition: rpl_gtid.h:3867
TODO: Move this structure to libbinlogevents/include/control_events.h when we start using C++11.
Definition: rpl_gtid.h:1065
static const int MAX_TEXT_LENGTH
The maximal length of the textual representation of a SID, not including the terminating '\0'.
Definition: rpl_gtid.h:1100
void print(const Sid_map *sid_map) const
Debug only: print this Gtid to stdout.
Definition: rpl_gtid.h:1141
bool is_empty() const
Return true if sidno is zero (and assert that gno is zero too in this case).
Definition: rpl_gtid.h:1088
void dbug_print(const Sid_map *sid_map, const char *text="", bool need_lock=false) const
Print this Gtid to the trace file if debug is enabled; no-op otherwise.
Definition: rpl_gtid.h:1148
void set(rpl_sidno sidno_arg, rpl_gno gno_arg)
Set both components to the given, positive values.
Definition: rpl_gtid.h:1077
void clear()
Set both components to 0.
Definition: rpl_gtid.h:1072
rpl_gno gno
GNO of this Gtid.
Definition: rpl_gtid.h:1069
enum_return_status parse(Sid_map *sid_map, const char *text)
Parses the given string and stores in this Gtid.
Definition: rpl_gtid_misc.cc:69
rpl_sidno sidno
SIDNO of this Gtid.
Definition: rpl_gtid.h:1067
bool equals(const Gtid &other) const
Returns true if this Gtid has the same sid and gno as 'other'.
Definition: rpl_gtid.h:1127
static bool is_valid(const char *text)
Return true if parse() would succeed, but don't store the result anywhere.
Definition: rpl_gtid_misc.cc:156
int to_string(const rpl_sid &sid, char *buf) const
Convert a Gtid to a string.
Definition: rpl_gtid_misc.cc:117
Struct representing a duration.
Definition: my_time.h:227
A mutex/cond pair.
Definition: rpl_gtid.h:1021
mysql_mutex_t mutex
Definition: rpl_gtid.h:1022
mysql_cond_t cond
Definition: rpl_gtid.h:1023
Represents one owned GTID.
Definition: rpl_gtid.h:2577