23#ifndef RPL_GTID_H_INCLUDED
24#define RPL_GTID_H_INCLUDED
60#define BINLOG_ERROR(MYSQLBINLOG_ERROR, SERVER_ERROR) error MYSQLBINLOG_ERROR
62#define BINLOG_ERROR(MYSQLBINLOG_ERROR, SERVER_ERROR) my_error SERVER_ERROR
76#define SKIP_WHITESPACE() \
77 while (my_isspace(&my_charset_utf8mb3_general_ci, *s)) s++
84#undef NON_DISABLED_GTID
150#define __CHECK_RETURN_STATUS(STATUS, ACTION, STATUS_NAME, ALLOW_UNREPORTED)
153 const char *status_name,
int allow_unreported);
154#define __CHECK_RETURN_STATUS(STATUS, ACTION, STATUS_NAME, ALLOW_UNREPORTED) \
155 check_return_status(STATUS, ACTION, STATUS_NAME, ALLOW_UNREPORTED);
162#define __PROPAGATE_ERROR(STATUS, RETURN_VALUE, ALLOW_UNREPORTED) \
164 enum_return_status __propagate_error_status = STATUS; \
165 if (__propagate_error_status != RETURN_STATUS_OK) { \
166 __CHECK_RETURN_STATUS(__propagate_error_status, "Propagating", #STATUS, \
168 return RETURN_VALUE; \
172#define __RETURN_STATUS(STATUS, ALLOW_UNREPORTED) \
174 enum_return_status __return_status_status = STATUS; \
175 __CHECK_RETURN_STATUS(__return_status_status, "Returning", #STATUS, \
177 return __return_status_status; \
183#define PROPAGATE_ERROR(STATUS) \
184 __PROPAGATE_ERROR(STATUS, __propagate_error_status, true)
190#define PROPAGATE_REPORTED_ERROR(STATUS) \
191 __PROPAGATE_ERROR(STATUS, __propagate_error_status, false)
197#define PROPAGATE_REPORTED_ERROR_INT(STATUS) __PROPAGATE_ERROR(STATUS, 1, false)
202#define RETURN_STATUS(STATUS) __RETURN_STATUS(STATUS, true)
208#define RETURN_REPORTED_STATUS(STATUS) __RETURN_STATUS(STATUS, false)
210#define RETURN_OK return RETURN_STATUS_OK
212#define RETURN_REPORTED_ERROR RETURN_STATUS(RETURN_STATUS_REPORTED_ERROR)
214#define RETURN_UNREPORTED_ERROR RETURN_STATUS(RETURN_STATUS_UNREPORTED_ERROR)
321 m_is_write_lock =
false;
323#if defined(HAVE_PSI_INTERFACE)
376 std::adopt_lock_t t [[maybe_unused]])
381 lock.assert_some_rdlock();
384 lock.assert_some_wrlock();
486 m_is_write_lock =
true;
502 m_is_write_lock =
false;
515 return m_is_write_lock;
531 m_is_write_lock =
true;
587 bool m_is_write_lock;
694 static std::pair<bool, value_type>
from_string(std::string s);
779 return it->second->sidno;
861 const Node *node = pointer_cast<const Node *>(ptr);
986 inline bool wait(
const THD *thd,
int sidno,
struct timespec *abstime)
const {
993 if (abstime !=
nullptr)
1007 inline int get_max_index() const {
1009 return static_cast<int>(
m_array.size() - 1);
1031 bool is_thd_killed(
const THD *thd)
const;
1040 assert(
n <= get_max_index());
1090 assert(sidno_arg > 0);
1091 assert(gno_arg > 0);
1118 static bool is_valid(
const char *text);
1137 bool need_lock =
false)
const;
1156 printf(
"%s\n",
buf);
1161 const char *text [[maybe_unused]] =
"",
1162 bool need_lock [[maybe_unused]] =
false)
const {
1166 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
buf));
1275 Sid_map *sid_map,
char *gtid_arg, uint *gtid_length_arg,
1277 ulonglong *start_time_arg, uint *last_transient_errno_arg,
1278 char *last_transient_errmsg_arg, uint *last_transient_errmsg_length_arg,
1279 ulonglong *last_transient_timestamp_arg, ulong *retries_count_arg)
const;
1311 uint *last_transient_errno_arg,
1312 char *last_transient_errmsg_arg,
1313 uint *last_transient_errmsg_length_arg,
1314 ulonglong *last_transient_timestamp_arg,
1315 ulong *retries_count_arg)
const;
1400 ulonglong immediate_ts_arg,
bool skipped_arg =
false);
1403 size_t uncompressed_size);
1441 const char *transient_err_message_arg,
1442 ulong trans_retries_arg);
1638 bool *starts_with_plus =
nullptr);
1651 size_t *actual_length =
nullptr);
1741 while (ivit.
get() !=
nullptr) {
1762 return ivit.
get() !=
nullptr;
1768 static bool is_valid(
const char *text);
1846 printf(
"%s\n",
str ?
str :
"out of memory in Gtid_set::print");
1864 bool need_lock [[maybe_unused]] =
false,
1866 [[maybe_unused]] =
nullptr)
const {
1870 DBUG_PRINT(
"info", (
"%s%s'%s'", text, *text ?
": " :
"",
1871 str ?
str :
"out of memory in Gtid_set::dbug_print"));
1943 template <
typename Gt
id_set_p,
typename Interval_p>
1954 init(gtid_set, sidno);
1958 p =
const_cast<Interval_p *
>(>id_set->free_intervals);
1962 p =
const_cast<Interval_p *
>(>id_set->m_intervals[sidno - 1]);
1966 assert(*
p !=
nullptr);
1967 p =
const_cast<Interval_p *
>(&(*p)->next);
1970 inline Interval_p
get()
const {
return *
p; }
2024 assert(
get() !=
nullptr);
2059 if (iv ==
nullptr) {
2062 if (
sidno == 0)
return;
2087 }
while (iv ==
nullptr);
2149 while (ivit.
get() !=
nullptr) {
2160 for (
rpl_sidno sidno = 1; sidno < max_sidno; sidno++)
2262 Free_intervals_lock *
lock);
2285 Free_intervals_lock *
lock);
2302 Free_intervals_lock *
lock);
2319 Free_intervals_lock *
lock);
2324 Const_interval_iterator *super);
2327 Const_interval_iterator *ivit2);
2354#ifdef FRIEND_OF_GTID_SET
2355 friend FRIEND_OF_GTID_SET;
2500 for (
rpl_sidno sid_i = 0; sid_i < sid_map_max_sidno; sid_i++) {
2502 if (sidno > max_sidno)
continue;
2503 bool printed_sid =
false;
2504 for (
const auto &key_and_value : *
get_hash(sidno)) {
2505 Node *node = key_and_value.second.get();
2506 assert(node !=
nullptr);
2511 p += sprintf(
p,
":%" PRId64
"#%u", node->
gno, node->
owner);
2515 return (
int)(
p - out);
2526 for (
rpl_sidno sidno = 1; sidno <= max_sidno; sidno++) {
2527 size_t records =
get_hash(sidno)->size();
2542 while (node !=
nullptr) {
2543 if (node->
owner == thd_id)
return true;
2558 assert(
str !=
nullptr);
2565 printf(
"%s\n",
str);
2576 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
str));
2635 assert(
hash !=
nullptr);
2638 assert(
node !=
nullptr);
2855 (
"atomic_anonymous_gtid_count increased to %d", new_value));
2856 assert(new_value >= 1);
2870 (
"atomic_anonymous_gtid_count decreased to %d", new_value));
2871 assert(new_value >= 0);
2892 (
"ongoing_automatic_gtid_violating_transaction_count increased to %d",
2894 assert(new_value >= 1);
2914 (
"ongoing_automatic_gtid_violating_transaction_count decreased to %d",
2916 assert(new_value >= 0);
2940 DBUG_PRINT(
"info", (
"atomic_anonymous_gtid_violation_count increased to %d",
2942 assert(new_value >= 1);
2962 (
"ongoing_anonymous_gtid_violating_transaction_count decreased to %d",
2964 assert(new_value >= 0);
2989 DBUG_PRINT(
"info", (
"atomic_gtid_wait_count changed from %d to %d",
2990 new_value - 1, new_value));
2991 assert(new_value >= 1);
3006 DBUG_PRINT(
"info", (
"atomic_gtid_wait_count changed from %d to %d",
3007 new_value + 1, new_value));
3008 assert(new_value >= 0);
3123 bool update_thd_status =
true);
3130 struct timespec *abstime =
nullptr);
3146 bool update_thd_status =
true);
3245 p += sprintf(
p,
"Executed GTIDs:\n");
3247 p += sprintf(
p,
"\nOwned GTIDs:\n");
3249 p += sprintf(
p,
"\nLost GTIDs:\n");
3251 p += sprintf(
p,
"\nGTIDs only_in_table:\n");
3253 return (
int)(
p -
buf);
3277 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
str));
3377#ifdef HAVE_GTID_NEXT_LIST
3379 void lock_owned_sidnos(
const THD *thd);
3424#ifdef FRIEND_OF_GTID_STATE
3425 friend FRIEND_OF_GTID_STATE;
3852 static bool is_valid(
const char *text);
3867 bool need_lock =
false)
const;
3883 printf(
"%s\n",
buf);
3891 bool need_lock [[maybe_unused]] =
false)
const {
3895 DBUG_PRINT(
"info", (
"%s%s%s", text, *text ?
": " :
"",
buf));
4005#ifdef HAVE_GTID_NEXT_LIST
4006int gtid_acquire_ownership_multiple(
THD *thd);
Kerberos Client Authentication nullptr
Definition: auth_kerberos_client_plugin.cc:250
RAII class to acquire a lock for the duration of a block.
Definition: rpl_gtid.h:343
void unlock_if_locked()
Unlock the lock, if it was acquired by this guard.
Definition: rpl_gtid.h:451
Guard(Checkable_rwlock &lock, enum_lock_type lock_type)
Create a guard, and optionally acquire a lock on it.
Definition: rpl_gtid.h:351
Checkable_rwlock & m_lock
Definition: rpl_gtid.h:344
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:375
bool is_locked() const
Return true if this object is either read locked or write locked.
Definition: rpl_gtid.h:466
bool is_wrlocked() const
Return true if this object is write locked.
Definition: rpl_gtid.h:463
int tryrdlock()
Try to acquire a read lock, and fail if it cannot be immediately granted.
Definition: rpl_gtid.h:435
enum_lock_type m_lock_type
Definition: rpl_gtid.h:345
Guard(Guard const ©)=delete
Objects of this class should not be copied or moved.
void unlock()
Unlock the lock.
Definition: rpl_gtid.h:444
void rdlock()
Acquire the read lock.
Definition: rpl_gtid.h:404
Guard(Guard const &©)=delete
bool is_rdlocked() const
Return true if this object is read locked.
Definition: rpl_gtid.h:460
~Guard()
Unlock on destruct.
Definition: rpl_gtid.h:398
Checkable_rwlock & get_lock() const
Return the underlying Checkable_rwlock object.
Definition: rpl_gtid.h:457
int trywrlock()
Try to acquire the write lock, and fail if it cannot be immediately granted.
Definition: rpl_gtid.h:423
void wrlock()
Acquire the write lock.
Definition: rpl_gtid.h:412
This has the functionality of mysql_rwlock_t, with two differences:
Definition: rpl_gtid.h:309
int32 get_state() const
Read lock_state atomically and return the value.
Definition: rpl_gtid.h:582
void assert_no_rdlock() const
Assert that no thread holds the read lock.
Definition: rpl_gtid.h:564
int trywrlock()
Return 0 if the write lock is held, otherwise an error will be returned.
Definition: rpl_gtid.h:522
enum_lock_type
Definition: rpl_gtid.h:332
@ TRY_READ_LOCK
Definition: rpl_gtid.h:336
@ TRY_WRITE_LOCK
Definition: rpl_gtid.h:337
@ WRITE_LOCK
Definition: rpl_gtid.h:335
@ READ_LOCK
Definition: rpl_gtid.h:334
@ NO_LOCK
Definition: rpl_gtid.h:333
void rdlock()
Acquire the read lock.
Definition: rpl_gtid.h:470
void wrlock()
Acquire the write lock.
Definition: rpl_gtid.h:479
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:580
void assert_no_lock() const
Assert that no thread holds read or write lock.
Definition: rpl_gtid.h:566
int tryrdlock()
Return 0 if the read lock is held, otherwise an error will be returned.
Definition: rpl_gtid.h:541
~Checkable_rwlock()
Destroy this Checkable_lock.
Definition: rpl_gtid.h:330
void assert_no_wrlock() const
Assert that no thread holds the write lock.
Definition: rpl_gtid.h:562
void assert_some_lock() const
Assert that some thread holds either the read or the write lock.
Definition: rpl_gtid.h:556
Checkable_rwlock(PSI_rwlock_key psi_key=0)
Initialize this Checkable_rwlock.
Definition: rpl_gtid.h:312
void assert_some_rdlock() const
Assert that some thread holds the read lock.
Definition: rpl_gtid.h:558
void unlock()
Release the lock (whether it is a write or read lock).
Definition: rpl_gtid.h:490
bool m_dbug_trace
If enabled, print any lock/unlock operations to the DBUG trace.
Definition: rpl_gtid.h:571
bool is_wrlock()
Return true if the write lock is held.
Definition: rpl_gtid.h:510
void assert_some_wrlock() const
Assert that some thread holds the write lock.
Definition: rpl_gtid.h:560
mysql_rwlock_t m_rwlock
The rwlock.
Definition: rpl_gtid.h:591
Class to access the value of @global.gtid_mode in an efficient and thread-safe manner.
Definition: rpl_gtid.h:601
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:55
static ulong sysvar_mode
The sys_var framework needs a variable of type ulong to store the value in.
Definition: rpl_gtid.h:614
std::atomic< int > m_atomic_mode
Definition: rpl_gtid.h:603
const char * get_string() const
Return the current gtid_mode as a string.
Definition: rpl_gtid_mode.cc:52
Gtid_mode()
Definition: rpl_gtid.h:606
static const char * names[]
Strings holding the enumeration values for gtid_mode.
Definition: rpl_gtid.h:646
void set(value_type value)
Set a new value for @global.gtid_mode.
Definition: rpl_gtid_mode.cc:43
value_type get() const
Return the current gtid_mode as an enumeration value.
Definition: rpl_gtid_mode.cc:47
static const char * to_string(value_type value)
Return the given gtid_mode as a string.
Definition: rpl_gtid_mode.cc:67
static Checkable_rwlock lock
Protects updates to @global.gtid_mode.
Definition: rpl_gtid.h:657
value_type
Possible values for @global.gtid_mode.
Definition: rpl_gtid.h:617
@ ON_PERMISSIVE
New transactions are GTID-transactions.
Definition: rpl_gtid.h:633
@ OFF
New transactions are anonymous.
Definition: rpl_gtid.h:622
@ OFF_PERMISSIVE
New transactions are anonyomus.
Definition: rpl_gtid.h:628
@ ON
New transactions are GTID-transactions.
Definition: rpl_gtid.h:639
@ DEFAULT
Definition: rpl_gtid.h:623
Stores information to monitor a transaction during the different replication stages.
Definition: rpl_gtid.h:1322
Trx_monitoring_info * last_processed_trx
Holds information about the last processed transaction.
Definition: rpl_gtid.h:1342
const Gtid * get_processing_trx_gtid()
Returns the GTID of the processing_trx.
Definition: rpl_gtid_misc.cc:526
void update(mysql::binlog::event::compression::type t, size_t payload_size, size_t uncompressed_size)
Definition: rpl_gtid_misc.cc:439
void clear()
Clear all monitoring information.
Definition: rpl_gtid_misc.cc:420
void finish()
Sets the final information, copy processing info to last_processed and clears processing info.
Definition: rpl_gtid_misc.cc:487
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:447
~Gtid_monitoring_info()
Destroy this GTID monitoring info object.
Definition: rpl_gtid_misc.cc:379
Trx_monitoring_info * processing_trx
Holds information about transaction being processed.
Definition: rpl_gtid.h:1340
void atomic_lock()
Lock this object when no thread mutex is used to arbitrate the access.
Definition: rpl_gtid_misc.cc:384
void atomic_unlock()
Unlock this object when no thread mutex is used to arbitrate the access.
Definition: rpl_gtid_misc.cc:409
mysql_mutex_t * atomic_mutex
Mutex arbitrating the atomic access to the object.
Definition: rpl_gtid.h:1359
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:504
std::atomic< bool > atomic_locked
The atomic locked flag.
Definition: rpl_gtid.h:1362
bool is_processing_trx_set()
Returns true if the processing_trx is set, false otherwise.
Definition: rpl_gtid_misc.cc:517
bool is_locked
Flag to assert the atomic lock behavior.
Definition: rpl_gtid.h:1365
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:535
Gtid_monitoring_info(mysql_mutex_t *atomic_mutex_arg=nullptr)
Create this GTID monitoring info object.
Definition: rpl_gtid_misc.cc:373
void clear_last_processed_trx()
Clear only the last_processed_trx monitoring info.
Definition: rpl_gtid_misc.cc:433
void clear_processing_trx()
Clear only the processing_trx monitoring info.
Definition: rpl_gtid_misc.cc:427
Iterator over intervals of a const Gtid_set.
Definition: rpl_gtid.h:1985
Const_interval_iterator(const Gtid_set *gtid_set)
Create this Const_interval_iterator.
Definition: rpl_gtid.h:1992
Const_interval_iterator(const Gtid_set *gtid_set, rpl_sidno sidno)
Create this Const_interval_iterator.
Definition: rpl_gtid.h:1988
Class representing a lock on free_intervals_mutex.
Definition: rpl_gtid.h:2213
bool locked
Definition: rpl_gtid.h:2237
void unlock_if_locked()
Lock the lock if it is locked.
Definition: rpl_gtid.h:2226
Free_intervals_lock(Gtid_set *_gtid_set)
Create a new lock, but do not acquire it.
Definition: rpl_gtid.h:2216
~Free_intervals_lock()
Destroy this object and unlock the lock if it is locked.
Definition: rpl_gtid.h:2233
void lock_if_not_locked()
Lock the lock if it is not already locked.
Definition: rpl_gtid.h:2219
Gtid_set * gtid_set
Definition: rpl_gtid.h:2236
Iterator over all gtids in a Gtid_set.
Definition: rpl_gtid.h:2043
Gtid get() const
Return next gtid, or {0,0} if we reached the end.
Definition: rpl_gtid.h:2069
rpl_sidno sidno
The SIDNO of the current element, or 0 if the iterator is past the last element.
Definition: rpl_gtid.h:2096
const Gtid_set * gtid_set
The Gtid_set we iterate over.
Definition: rpl_gtid.h:2091
void next()
Advance to next gtid.
Definition: rpl_gtid.h:2050
rpl_gno gno
The GNO of the current element, or 0 if the iterator is past the last element.
Definition: rpl_gtid.h:2101
Const_interval_iterator ivit
Iterator over the intervals for the current SIDNO.
Definition: rpl_gtid.h:2103
Gtid_iterator(const Gtid_set *gs)
Definition: rpl_gtid.h:2045
void next_sidno()
Find the next sidno that has one or more intervals.
Definition: rpl_gtid.h:2076
Iterator over intervals for a given SIDNO.
Definition: rpl_gtid.h:1944
Interval_p get() const
Return current_elem.
Definition: rpl_gtid.h:1970
void init(Gtid_set_p gtid_set, rpl_sidno sidno)
Reset this iterator.
Definition: rpl_gtid.h:1961
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:1952
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:1978
Interval_iterator_base(Gtid_set_p gtid_set)
Construct a new iterator over the free intervals of a Gtid_set.
Definition: rpl_gtid.h:1957
void next()
Advance current_elem one step.
Definition: rpl_gtid.h:1965
Iterator over intervals of a non-const Gtid_set, with additional methods to modify the Gtid_set.
Definition: rpl_gtid.h:2002
Interval_iterator(Gtid_set *gtid_set)
Destroy this Interval_iterator.
Definition: rpl_gtid.h:2008
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:2016
void insert(Interval *iv)
Insert the given element before current_elem.
Definition: rpl_gtid.h:2018
void remove(Gtid_set *gtid_set)
Remove current_elem.
Definition: rpl_gtid.h:2023
Interval_iterator(Gtid_set *gtid_set, rpl_sidno sidno)
Create this Interval_iterator.
Definition: rpl_gtid.h:2005
Represents a set of GTIDs.
Definition: rpl_gtid.h:1466
void encode(uchar *buf) const
Encodes this Gtid_set as a binary string.
Definition: rpl_gtid_set.cc:1237
void put_free_interval(Interval *iv)
Puts the given interval in the list of free intervals.
Definition: rpl_gtid_set.cc:255
rpl_gno get_last_gno(rpl_sidno sidno) const
Definition: rpl_gtid_set.cc:724
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:1226
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:1147
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:1068
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:1927
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:1758
int get_n_intervals() const
Return the number of intervals in this Gtid_set.
Definition: rpl_gtid.h:2156
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:913
Sid_map * sid_map
Sid_map associated with this Gtid_set.
Definition: rpl_gtid.h:2330
friend std::ostream & operator<<(std::ostream &os, const Gtid_set &in)
For use with C++ std::ostream
Definition: rpl_gtid.h:1851
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:611
Checkable_rwlock * sid_lock
Read-write lock that protects updates to the number of SIDs.
Definition: rpl_gtid.h:2194
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:989
void init()
Worker for the constructor.
Definition: rpl_gtid_set.cc:102
static const int CHUNK_GROW_SIZE
The default number of intervals in an Interval_chunk.
Definition: rpl_gtid.h:2129
Interval_chunk * chunks
Linked list of chunks.
Definition: rpl_gtid.h:2339
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:1895
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:706
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:132
int get_n_intervals(rpl_sidno sidno) const
Return the number of intervals for the given sidno.
Definition: rpl_gtid.h:2146
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:647
Gtid_set(Sid_map *sid_map, Checkable_rwlock *sid_lock=nullptr)
Constructs a new, empty Gtid_set.
Definition: rpl_gtid_set.cc:85
Interval * free_intervals
Linked list of free intervals.
Definition: rpl_gtid.h:2337
bool contains_gtid(const Gtid >id) const
Return true iff the given GTID exists in this set.
Definition: rpl_gtid.h:1655
static const String_format default_string_format
The default String_format: the format understood by add_gtid_text(const char *).
Definition: rpl_gtid.h:1885
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:288
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:180
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:679
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:1842
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:2335
mysql_mutex_t free_intervals_mutex
Lock protecting the list of free intervals.
Definition: rpl_gtid.h:2199
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:1863
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:1030
int n_chunks
The number of chunks.
Definition: rpl_gtid.h:2351
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:624
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:568
void clear()
Removes all gtids from this Gtid_set.
Definition: rpl_gtid_set.cc:263
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:1110
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:1200
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:350
void get_gtid_intervals(std::list< Gtid_interval > *gtid_intervals) const
Gets all gtid intervals from this Gtid_set.
Definition: rpl_gtid_set.cc:827
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:1682
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:869
size_t cached_string_length
The string length.
Definition: rpl_gtid.h:2343
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:424
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:301
void _add_gtid(rpl_sidno sidno, rpl_gno gno)
Adds the given GTID to this Gtid_set.
Definition: rpl_gtid.h:1528
bool is_empty() const
Returns true if this Gtid_set is empty.
Definition: rpl_gtid.h:1715
static PSI_mutex_key key_gtid_executed_free_intervals_mutex
Definition: rpl_gtid.h:1468
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:1890
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:931
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:1285
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:638
size_t get_encoded_length() const
Returns the length of this Gtid_set when encoded using the encode() function.
Definition: rpl_gtid_set.cc:1370
~Gtid_set()
Destroy this Gtid_set.
Definition: rpl_gtid_set.cc:117
bool has_cached_string_length
If the string is cached.
Definition: rpl_gtid.h:2341
const String_format * cached_string_format
The String_format that was used when cached_string_length was computed.
Definition: rpl_gtid.h:2345
void get_free_interval(Interval **out)
Returns a fresh new Interval object.
Definition: rpl_gtid_set.cc:242
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:761
void _remove_gtid(const Gtid >id)
Removes the given GTID from this Gtid_set.
Definition: rpl_gtid.h:1566
Sid_map * get_sid_map() const
Return the Sid_map associated with this Gtid_set.
Definition: rpl_gtid.h:1898
void _remove_gtid(rpl_sidno sidno, rpl_gno gno)
Removes the given GTID from this Gtid_set.
Definition: rpl_gtid.h:1544
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:191
void _add_gtid(const Gtid >id)
Adds the given GTID to this Gtid_set.
Definition: rpl_gtid.h:1560
rpl_sidno get_max_sidno() const
Returns the maximal sidno that this Gtid_set currently has space for.
Definition: rpl_gtid.h:1661
void assert_free_intervals_locked()
Definition: rpl_gtid.h:2239
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:1738
Represents the server's GTID state: the set of committed GTIDs, the set of lost gtids,...
Definition: rpl_gtid.h:2713
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:768
int init()
Add @GLOBAL.SERVER_UUID to this binlog's Sid_map.
Definition: rpl_gtid_state.cc:660
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:777
void end_automatic_gtid_violating_transaction()
Decrease the global counter when ending a GTID-violating transaction having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2902
void broadcast_owned_sidnos(const THD *thd)
Broadcast the condition for all SIDNOs owned by the given THD.
Definition: rpl_gtid_state.cc:143
const Gtid_set * get_executed_gtids() const
Definition: rpl_gtid.h:3207
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:556
void print() const
Debug only: print this Gtid_state to stdout.
Definition: rpl_gtid.h:3263
const Gtid_set * get_lost_gtids() const
Return a pointer to the Gtid_set that contains the lost gtids.
Definition: rpl_gtid.h:3202
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:570
void begin_anonymous_gtid_violating_transaction()
Increase the global counter when starting a GTID-violating transaction having GTID_NEXT=ANONYMOUS.
Definition: rpl_gtid.h:2932
rpl_sidno server_sidno
The SIDNO for this server.
Definition: rpl_gtid.h:3411
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:301
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:947
void update_gtids_impl_lock_sidno(rpl_sidno sidno)
Lock a given sidno of a transaction being updated.
Definition: rpl_gtid_state.cc:828
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:3052
Sid_map * sid_map
The Sid_map used by this Gtid_state.
Definition: rpl_gtid.h:3388
std::atomic< int32 > atomic_anonymous_gtid_count
The number of anonymous transactions owned by any client.
Definition: rpl_gtid.h:3414
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:702
void end_gtid_wait()
Decrease the global counter when ending a call to WAIT_FOR_EXECUTED_GTID_SET.
Definition: rpl_gtid.h:2999
Gtid_state(Checkable_rwlock *_sid_lock, Sid_map *_sid_map)
Constructs a new Gtid_state object.
Definition: rpl_gtid.h:2722
Gtid_set lost_gtids
The set of GTIDs that existed in some previously purged binary log.
Definition: rpl_gtid.h:3395
const Owned_gtids * get_owned_gtids() const
Return a pointer to the Owned_gtids that contains the owned gtids.
Definition: rpl_gtid.h:3223
void unlock_owned_sidnos(const THD *thd)
Unlock all SIDNOs owned by the given THD.
Definition: rpl_gtid_state.cc:131
const rpl_sid & get_server_sid() const
Return the server's SID.
Definition: rpl_gtid.h:3227
Owned_gtids owned_gtids
The set of GTIDs that are owned by some thread.
Definition: rpl_gtid.h:3409
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:473
rpl_sidno get_server_sidno() const
Return the server's SID's SIDNO.
Definition: rpl_gtid.h:3225
const Gtid_set * get_previous_gtids_logged() const
Definition: rpl_gtid.h:3219
void update_gtids_impl_broadcast_and_unlock_sidno(rpl_sidno sidno)
Unlock a given sidno after broadcasting its changes.
Definition: rpl_gtid_state.cc:909
int32 get_gtid_wait_count()
Return the number of clients that have an ongoing call to WAIT_FOR_EXECUTED_GTID_SET.
Definition: rpl_gtid.h:3016
Mutex_cond_array sid_locks
Contains one mutex/cond pair for every SIDNO.
Definition: rpl_gtid.h:3390
char * to_string() const
Debug only: return a newly allocated string, or NULL on out-of-memory.
Definition: rpl_gtid.h:3256
int read_gtid_executed_from_table()
Fetch gtids from gtid_executed table and store them into gtid_executed set.
Definition: rpl_gtid_state.cc:753
Gtid_set previous_gtids_logged
Definition: rpl_gtid.h:3407
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:616
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:266
const Gtid_set * get_gtids_only_in_table() const
Definition: rpl_gtid.h:3212
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:757
int32 get_anonymous_gtid_violating_transaction_count()
Return the number of ongoing GTID-violating transactions having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2974
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:549
void assert_sidno_lock_owner(rpl_sidno sidno) const
Assert that we own the given SIDNO.
Definition: rpl_gtid.h:3097
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:957
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:923
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:289
void acquire_anonymous_ownership()
Acquire anonymous ownership.
Definition: rpl_gtid.h:2846
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:761
void update_on_rollback(THD *thd)
Update the state after the given thread has rollbacked.
Definition: rpl_gtid_state.cc:210
Gtid_set gtids_only_in_table
Definition: rpl_gtid.h:3405
rpl_gno get_automatic_gno(rpl_sidno sidno) const
Computes the next available GNO.
Definition: rpl_gtid_state.cc:412
Gtid_set executed_gtids
Definition: rpl_gtid.h:3400
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:855
int32 get_automatic_gtid_violating_transaction_count()
Return the number of ongoing GTID-violating transactions having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2924
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:3273
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:155
void unlock_sidno(rpl_sidno sidno)
Unlocks a mutex for the given SIDNO.
Definition: rpl_gtid.h:3093
bool is_owned(const Gtid >id) const
Returns true if GTID is owned, otherwise returns 0.
Definition: rpl_gtid.h:2779
int to_string(char *buf) const
Debug only: Generate a string in the given buffer and return the length.
Definition: rpl_gtid.h:3243
bool is_executed(const Gtid >id) const
Returns true if the given GTID is logged.
Definition: rpl_gtid.h:2766
Prealloced_array< bool, 8 > commit_group_sidnos
This array is used by Gtid_state_update_gtids_impl* functions.
Definition: rpl_gtid.h:3661
void update_prev_gtids(Gtid_set *write_gtid_set)
Updates previously logged GTID set before writing to table.
Definition: rpl_gtid_state.cc:597
Checkable_rwlock * sid_lock
Read-write lock that protects updates to the number of SIDs.
Definition: rpl_gtid.h:3386
void end_gtid_violating_transaction(THD *thd)
Definition: rpl_gtid_state.cc:253
void begin_automatic_gtid_violating_transaction()
Increase the global counter when starting a GTID-violating transaction having GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:2882
void update_gtids_impl_broadcast_and_unlock_sidnos()
Unlocks all locked sidnos after broadcasting their changes.
Definition: rpl_gtid_state.cc:915
void lock_sidno(rpl_sidno sidno)
Locks a mutex for the given SIDNO.
Definition: rpl_gtid.h:3091
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:800
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:563
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:3236
std::atomic< int32 > atomic_automatic_gtid_violation_count
The number of GTID-violating transactions that use GTID_NEXT=AUTOMATIC.
Definition: rpl_gtid.h:3416
std::atomic< int32 > atomic_gtid_wait_count
The number of clients that are executing WAIT_FOR_EXECUTED_GTID_SET.
Definition: rpl_gtid.h:3421
void end_anonymous_gtid_violating_transaction()
Decrease the global counter when ending a GTID-violating transaction having GTID_NEXT=ANONYMOUS.
Definition: rpl_gtid.h:2950
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:462
int clear(THD *thd)
Reset the state and persistor after RESET BINARY LOGS AND GTIDS: 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:3418
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:203
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:834
int32 get_anonymous_ownership_count()
Return the number of clients that hold anonymous ownership.
Definition: rpl_gtid.h:2876
void update_gtids_impl_end(THD *thd, bool more_trx)
Handle the final part of update_gtids_impl.
Definition: rpl_gtid_state.cc:953
int save(THD *thd)
Save gtid owned by the thd into executed_gtids variable and gtid_executed table.
Definition: rpl_gtid_state.cc:675
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:790
void broadcast_sidno(rpl_sidno sidno)
Broadcasts updates for the given SIDNO.
Definition: rpl_gtid.h:3095
void release_anonymous_ownership()
Release anonymous ownership.
Definition: rpl_gtid.h:2861
void begin_gtid_wait()
Increase the global counter when starting a call to WAIT_FOR_EXECUTED_GTID_SET.
Definition: rpl_gtid.h:2982
void update_gtids_impl(THD *thd, bool is_commit)
Remove the GTID owned by thread from owned GTIDs.
Definition: rpl_gtid_state.cc:217
Represents a growable array where each element contains a mutex and a condition variable.
Definition: rpl_gtid.h:924
Prealloced_array< Mutex_cond *, 8 > m_array
Definition: rpl_gtid.h:1047
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:1046
bool wait(const THD *thd, int sidno, struct timespec *abstime) const
Wait for signal on the n'th condition variable.
Definition: rpl_gtid.h:986
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:946
void assert_not_owner(int n) const
Assert that this thread does not own the n'th mutex.
Definition: rpl_gtid.h:962
~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:953
void unlock(int n) const
Unlock the n'th mutex.
Definition: rpl_gtid.h:941
void lock(int n) const
Lock the n'th mutex.
Definition: rpl_gtid.h:936
Mutex_cond * get_mutex_cond(int n) const
Return the Nth Mutex_cond object.
Definition: rpl_gtid.h:1038
Iterator over all gtids in a Owned_gtids set.
Definition: rpl_gtid.h:2617
rpl_sidno max_sidno
Max SIDNO of the current iterator.
Definition: rpl_gtid.h:2672
Node * node
Current node on current SIDNO hash.
Definition: rpl_gtid.h:2679
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:2677
const Owned_gtids * owned_gtids
The Owned_gtids set we iterate over.
Definition: rpl_gtid.h:2668
Node * get_node() const
Return the current GTID Node, or NULL if we reached the end.
Definition: rpl_gtid.h:2664
Gtid_iterator(const Owned_gtids *og)
Definition: rpl_gtid.h:2619
Gtid get() const
Return next GTID, or {0,0} if we reached the end.
Definition: rpl_gtid.h:2655
void next()
Advance to next GTID.
Definition: rpl_gtid.h:2629
rpl_sidno sidno
The SIDNO of the current element, or 1 in the initial iteration.
Definition: rpl_gtid.h:2670
malloc_unordered_multimap< rpl_gno, unique_ptr_my_free< Node > > * hash
Current SIDNO hash.
Definition: rpl_gtid.h:2674
Represents the set of GTIDs that are owned by some thread.
Definition: rpl_gtid.h:2428
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:2523
char * to_string() const
Debug only: return a newly allocated string representation of this Owned_gtids.
Definition: rpl_gtid.h:2555
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:2539
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:2480
int to_string(char *out) const
Write a string representation of this Owned_gtids to the given buffer.
Definition: rpl_gtid.h:2496
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:2485
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:2598
Prealloced_array< malloc_unordered_multimap< rpl_gno, unique_ptr_my_free< Node > > *, 8 > sidno_to_hash
Growable array of hashes.
Definition: rpl_gtid.h:2610
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:2573
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:2596
~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:2563
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:734
~Sid_map()
Destroy this Sid_map.
Definition: rpl_gtid_sid_map.cc:52
Checkable_rwlock * sid_lock
Read-write lock that protects updates to the number of SIDNOs.
Definition: rpl_gtid.h:880
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:821
rpl_sidno sid_to_sidno(const rpl_sid &sid) const
Get the SIDNO for a given SID.
Definition: rpl_gtid.h:775
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:860
rpl_sidno get_max_sidno() const
Return the biggest sidno in this Sid_map.
Definition: rpl_gtid.h:831
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:886
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:899
Checkable_rwlock * get_sid_lock() const
Return the sid_lock.
Definition: rpl_gtid.h:837
malloc_unordered_map< rpl_sid, unique_ptr_my_free< Node >, mysql::gtid::Hash_Uuid > _sid_to_sidno
Hash that maps SID to SIDNO.
Definition: rpl_gtid.h:892
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 REPLICA)
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:801
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:35
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
static char buf[MAX_BUF]
Definition: conf_to_src.cc:72
const char * p
Definition: ctype-mb.cc:1234
#define MY_WME
Definition: my_sys.h:127
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
A better implementation of the UNIX ctype(3) library.
#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:1085
static PFS_engine_table_share_proxy table
Definition: pfs.cc:60
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:497
type
Definition: base.h:39
std::int64_t gno_t
Definition: global.h:36
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:113
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:2881
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:1836
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:227
const int MAX_THREAD_ID_TEXT_LENGTH
The maximal possible length of thread_id when printed in decimal.
Definition: rpl_gtid.h:273
const rpl_gno GNO_WARNING_THRESHOLD
If the GNO goes above the number, generate a warning.
Definition: rpl_gtid.h:269
ulong _gtid_consistency_mode
Current value for ENFORCE_GTID_CONSISTENCY.
Definition: rpl_gtid_misc.cc:40
const rpl_gno GNO_END
One-past-the-max value of GNO.
Definition: rpl_gtid.h:267
enum_return_status map_macro_enum(int status)
enum to map the result of Uuid::parse to the above Macros
Definition: rpl_gtid.h:219
enum_gtid_consistency_mode get_gtid_consistency_mode()
Return the current value of ENFORCE_GTID_CONSISTENCY.
Definition: rpl_gtid_misc.cc:64
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:4047
PSI_memory_key key_memory_Gtid_cache_to_string
mysql::gtid::gno_t rpl_gno
GNO, the second (numeric) component of a GTID, is an alias of mysql::gtid::gno_t.
Definition: rpl_gtid.h:103
enum_return_status
Generic return type for many functions that can succeed or fail.
Definition: rpl_gtid.h:122
@ RETURN_STATUS_OK
The function completed successfully.
Definition: rpl_gtid.h:124
@ RETURN_STATUS_UNREPORTED_ERROR
The function completed with error but did not report it.
Definition: rpl_gtid.h:126
@ RETURN_STATUS_REPORTED_ERROR
The function completed with error and has called my_error.
Definition: rpl_gtid.h:128
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:58
int rpl_sidno
Type of SIDNO (source ID number, first component of GTID)
Definition: rpl_gtid.h:96
int format_gno(char *s, rpl_gno gno)
Formats a GNO as a string.
Definition: rpl_gtid_set.cc:420
mysql::gtid::Uuid rpl_sid
Definition: rpl_gtid.h:293
Gtid_mode global_gtid_mode
The one and only instance of Gtid_mode.
Definition: rpl_gtid_mode.cc:30
const int MAX_GNO_TEXT_LENGTH
The length of MAX_GNO when printed in decimal.
Definition: rpl_gtid.h:271
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:3904
@ GTID_STATEMENT_CANCEL
Statement should be cancelled.
Definition: rpl_gtid.h:3908
@ GTID_STATEMENT_EXECUTE
Statement can execute.
Definition: rpl_gtid.h:3906
@ 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:3913
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:104
rpl_gno parse_gno(const char **s)
Parse a GNO from a string.
Definition: rpl_gtid_set.cc:412
PSI_memory_key key_memory_Gtid_set_Interval_chunk
Definition: rpl_gtid_set.cc:66
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:253
Gtid_state * gtid_state
Global state of GTIDs.
Definition: mysqld.cc:1837
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:217
Checkable_rwlock * global_sid_lock
Protects Gtid_state. See comment above gtid_state for details.
Definition: mysqld.cc:1835
PSI_memory_key key_memory_Gtid_set_to_string
Definition: rpl_gtid_set.cc:65
#define RETURN_OK
Returns RETURN_STATUS_OK.
Definition: rpl_gtid.h:210
std::ostream & operator<<(std::ostream &oss, Gtid_mode::value_type const &mode)
Definition: rpl_gtid_mode.cc:71
enum_gtid_consistency_mode
Possible values for ENFORCE_GTID_CONSISTENCY.
Definition: rpl_gtid.h:230
@ GTID_CONSISTENCY_MODE_ON
Definition: rpl_gtid.h:232
@ GTID_CONSISTENCY_MODE_WARN
Definition: rpl_gtid.h:233
@ GTID_CONSISTENCY_MODE_OFF
Definition: rpl_gtid.h:231
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:3689
@ UNDEFINED_GTID
GTID_NEXT is set to this state after a transaction with GTID_NEXT=='UUID:NUMBER' is committed.
Definition: rpl_gtid.h:3755
@ 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:3721
@ ASSIGNED_GTID
Specifies that the transaction has been assigned a GTID (UUID:NUMBER).
Definition: rpl_gtid.h:3711
@ 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:3792
@ NOT_YET_DETERMINED_GTID
Definition: rpl_gtid.h:3782
@ AUTOMATIC_GTID
Specifies that the GTID has not been generated yet; it will be generated on commit.
Definition: rpl_gtid.h:3703
void check_return_status(enum_return_status status, const char *action, const char *status_name, int allow_unreported)
Definition: rpl_gtid_misc.cc:191
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:214
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:1054
rpl_gno gno_start
Definition: rpl_gtid.h:1058
rpl_gno gno_end
Definition: rpl_gtid.h:1060
void set(rpl_sidno sid_no, rpl_gno start, rpl_gno end)
Definition: rpl_gtid.h:1061
rpl_sidno sidno
Definition: rpl_gtid.h:1056
Contains a list of intervals allocated by this Gtid_set.
Definition: rpl_gtid.h:2124
Interval intervals[1]
Definition: rpl_gtid.h:2126
Interval_chunk * next
Definition: rpl_gtid.h:2125
Represents one element in the linked list of intervals associated with a SIDNO.
Definition: rpl_gtid.h:1904
rpl_gno start
The first GNO of this interval.
Definition: rpl_gtid.h:1907
rpl_gno end
The first GNO after this interval.
Definition: rpl_gtid.h:1909
bool equals(const Interval &other) const
Return true iff this interval is equal to the given interval.
Definition: rpl_gtid.h:1911
Interval * next
Pointer to next interval in list.
Definition: rpl_gtid.h:1915
Holds information about a Gtid_set.
Definition: rpl_gtid.h:2381
Gtid_set * gtid_set
Pointer to the Gtid_set.
Definition: rpl_gtid.h:2383
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:2396
Gtid_set * get_gtid_set() const
Return NULL if this is NULL, otherwise return the Gtid_set.
Definition: rpl_gtid.h:2387
void set_null()
Set this Gtid_set to NULL.
Definition: rpl_gtid.h:2407
bool is_non_null
True if this Gtid_set is NULL.
Definition: rpl_gtid.h:2385
This struct represents a specification of a GTID for a statement to be executed: either "AUTOMATIC",...
Definition: rpl_gtid.h:3803
void set_not_yet_determined()
Set the type to NOT_YET_DETERMINED_GTID.
Definition: rpl_gtid.h:3824
enum_gtid_type type
The type of this GTID.
Definition: rpl_gtid.h:3805
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:3811
bool equals(const Gtid_specification &other) const
Return true if this Gtid_specification is equal to 'other'.
Definition: rpl_gtid.h:3831
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:3818
static const int MAX_TEXT_LENGTH
Definition: rpl_gtid.h:3854
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:3890
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:3822
void set_undefined()
Set to undefined. Must only be called if the type is ASSIGNED_GTID.
Definition: rpl_gtid.h:3826
void set_automatic()
Set the type to AUTOMATIC_GTID.
Definition: rpl_gtid.h:3820
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:3813
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:3839
void print() const
Debug only: print this Gtid_specification to stdout.
Definition: rpl_gtid.h:3880
TODO: Move this structure to mysql/binlog/event/control_events.h when we start using C++11.
Definition: rpl_gtid.h:1077
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:1112
void print(const Sid_map *sid_map) const
Debug only: print this Gtid to stdout.
Definition: rpl_gtid.h:1153
bool is_empty() const
Return true if sidno is zero (and assert that gno is zero too in this case).
Definition: rpl_gtid.h:1100
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:1160
void set(rpl_sidno sidno_arg, rpl_gno gno_arg)
Set both components to the given, positive values.
Definition: rpl_gtid.h:1089
void clear()
Set both components to 0.
Definition: rpl_gtid.h:1084
rpl_gno gno
GNO of this Gtid.
Definition: rpl_gtid.h:1081
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:70