120 const char *assign_gtids_to_anonymous_transactions_value);
303#ifdef HAVE_PSI_INTERFACE
385 ulonglong immediate_ts_arg,
bool skipped =
false) {
445 const char *transient_err_message_arg,
446 ulong trans_retries_arg) {
448 transient_errno_arg, transient_err_message_arg, trans_retries_arg);
516 char const *param_privilege_checks_username,
517 char const *param_privilege_checks_hostname);
542 char const *param_privilege_checks_username,
543 char const *param_privilege_checks_hostname);
554 char const *param_privilege_checks_username,
555 char const *param_privilege_checks_hostname);
564 std::pair<const char *, const char *>
589 char const *channel_name =
nullptr,
590 char const *user_name =
nullptr,
591 char const *host_name =
nullptr)
const;
857 const char *buff_coord)
const;
965 down_cast<Until_position *>(
until_option)->notify_log_name_change();
985 down_cast<Until_position *>(
until_option)->notify_log_name_change();
1000 bool force =
false);
1017 bool update_THD_status =
true);
1031 bool update_THD_status =
true);
1045 bool update_THD_status =
true);
1056 TABLE **conv_table_var)
const {
1057 assert(tabledef_var && conv_table_var);
1060 if (ptr->table == table_arg) {
1061 *tabledef_var = &
static_cast<RPL_Table_ref *
>(ptr)->m_tabledef;
1062 *conv_table_var =
static_cast<RPL_Table_ref *
>(ptr)->m_conv_table;
1063 DBUG_PRINT(
"debug", (
"Fetching table data for table %s.%s:"
1064 " tabledef: %p, conv_table: %p",
1066 *tabledef_var, *conv_table_var));
1255 std::atomic<longlong>
1454 DBUG_PRINT(
"info", (
"is_in_stmt()=%d", ret));
1468 DBUG_PRINT(
"info", (
"is_in_trx_or_stmt()=%d", ret));
1499 DBUG_PRINT(
"info", (
"is_in_group()=%d", ret));
1527 int rli_init_info(
bool skip_received_gtid_set_recovery =
false);
1680 uint param_id,
const char *param_channel,
bool is_rli_fake);
1734 ulong current_version);
2196 if (!rli)
return false;
2206 ->has_ddl_committed) &&
2403 std::vector<std::tuple<ulong, TABLE const *, Rows_log_event *>>
2404 &extra_privileges)
const;
2418 std::initializer_list<std::string_view> extra_privileges)
const;
2432 bool has_access(std::initializer_list<ulong> extra_privileges)
const;
2485 std::vector<std::string> &columns)
const;
Contains the classes representing events occurring in the replication stream.
Utility class to allow RAII pattern with Security_context class.
Definition: rpl_rli.h:2353
Applier_security_context_guard(Applier_security_context_guard &&)=delete
void extract_columns_to_check(TABLE const *table, Rows_log_event *event, std::vector< std::string > &columns) const
Definition: rpl_rli.cc:3499
virtual ~Applier_security_context_guard()
Destructor that restores the backed up security context, if needed.
Definition: rpl_rli.cc:3417
Applier_security_context_guard(Relay_log_info const *rli, THD const *thd)
If needed, backs up the current thd security context and replaces it with a security context for PRIV...
Definition: rpl_rli.cc:3366
bool skip_priv_checks() const
Returns whether or not privilege checks may be skipped within the current context.
Definition: rpl_rli.cc:3425
Security_context m_applier_security_ctx
Applier security context based on PRIVILEGE_CHECK_USER user.
Definition: rpl_rli.h:2474
bool m_privilege_checks_none
Flag that states if privilege check should be skipped.
Definition: rpl_rli.h:2480
Applier_security_context_guard & operator=(const Applier_security_context_guard &)=delete
std::string get_username() const
Returns the username for the user for which the security context was initialized.
Definition: rpl_rli.cc:3487
THD const * m_thd
The THD object for which the security context will be initialized.
Definition: rpl_rli.h:2472
Security_context * m_previous
Backed up security context.
Definition: rpl_rli.h:2478
Security_context * m_current
Currently in use security context.
Definition: rpl_rli.h:2476
bool m_logged_in_acl_user
Flag that states if there is a logged user.
Definition: rpl_rli.h:2482
std::string get_hostname() const
Returns the hostname for the user for which the security context was initialized.
Definition: rpl_rli.cc:3493
Applier_security_context_guard & operator=(Applier_security_context_guard &&)=delete
bool has_access(std::vector< std::tuple< ulong, TABLE const *, Rows_log_event * > > &extra_privileges) const
Checks if the PRIVILEGE_CHECKS_USER user has access to the privilieges passed on by extra_privileges ...
Definition: rpl_rli.cc:3453
Relay_log_info const * m_target
The Relay_log_info object holding the info required to initialize the context.
Definition: rpl_rli.h:2468
Applier_security_context_guard(const Applier_security_context_guard &)=delete
This class is used to store the type and value for Assign_gtids_to_anonymous_transactions parameter o...
Definition: rpl_rli.h:91
bool set_info(enum_type assign_gtids_to_anonymous_transactions_type, const char *assign_gtids_to_anonymous_transactions_value)
Definition: rpl_rli.cc:3297
rpl_sidno m_sidno
Definition: rpl_rli.h:128
enum_type get_type() const
Definition: rpl_rli.cc:3293
enum_type m_type
This stores the type of Assign_gtids_to_anonymous_transactions info.
Definition: rpl_rli.h:124
Assign_gtids_to_anonymous_transactions_info()
The default constructor initializes parameters to their default value.
Definition: rpl_rli.h:108
std::string m_value
Stores the UUID in case the m_type is not OFF.
Definition: rpl_rli.h:126
enum_type
This accepted value of the type of the Assign_gtids_to_anonymous_transactions info OFF : Anonymous gt...
Definition: rpl_rli.h:104
rpl_sidno get_sidno() const
Definition: rpl_rli.h:112
std::string get_value() const
Definition: rpl_rli.cc:3288
This has the functionality of mysql_rwlock_t, with two differences:
Definition: rpl_gtid.h:308
void assert_some_lock() const
Assert that some thread holds either the read or the write lock.
Definition: rpl_gtid.h:545
On a replica and only on a replica, this class is responsible for committing the applied transactions...
Definition: rpl_replica_commit_order_manager.h:196
Definition: rpl_utility.h:523
void rewind()
Definition: rpl_utility.cc:1299
This is a subclass if Gtid_event and Log_event.
Definition: log_event.h:3734
rpl_sidno get_sidno(bool need_lock)
Return the SIDNO relative to the global sid_map for this GTID.
Definition: log_event.cc:13382
enum_gtid_type get_type() const
Return the gtid type for this Gtid_log_event: this can be either ANONYMOUS_GTID, AUTOMATIC_GTID,...
Definition: log_event.h:3839
rpl_gno get_gno() const
Return the GNO for this GTID.
Definition: log_event.h:3875
Stores information to monitor a transaction during the different replication stages.
Definition: rpl_gtid.h:1310
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
bool is_processing_trx_set()
Returns true if the processing_trx is set, false otherwise.
Definition: rpl_gtid_misc.cc:516
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
void clear_processing_trx()
Clear only the processing_trx monitoring info.
Definition: rpl_gtid_misc.cc:426
Represents a set of GTIDs.
Definition: rpl_gtid.h:1454
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
void _add_gtid(rpl_sidno sidno, rpl_gno gno)
Adds the given GTID to this Gtid_set.
Definition: rpl_gtid.h:1516
Sid_map * get_sid_map() const
Return the Sid_map associated with this Gtid_set.
Definition: rpl_gtid.h:1886
This is the abstract base class for binary log events.
Definition: log_event.h:547
Log_event_type get_type_code() const
Definition: log_event.h:804
Utility class to allow RAII pattern with MDL_request and MDL_context classes.
Definition: rpl_rli.h:2249
bool lock(MDL_key::enum_mdl_namespace namespace_arg, enum_mdl_type mdl_type_arg, bool blocking=false)
Uses the target THD object MDL context to acquire the lock identified by namespace_arg with MDL type ...
Definition: rpl_rli.cc:3338
bool is_locked()
Returns whether or not the lock as been acquired within this object life-cycle.
Definition: rpl_rli.cc:3364
THD * m_target
The THD object holding the MDL context used for acquiring/releasing.
Definition: rpl_rli.h:2314
MDL_lock_guard(THD *target)
Constructor that initializes the object and the target THD object but doesn't try to acquire any lock...
Definition: rpl_rli.cc:3328
MDL_request m_request
The MDL request holding the MDL ticket issued upon acquisition.
Definition: rpl_rli.h:2316
virtual ~MDL_lock_guard()
Destructor that unlocks all acquired locks.
Definition: rpl_rli.cc:3357
A pending metadata lock request.
Definition: mdl.h:800
Definition: rpl_mta_submode.h:54
bool empty() const
Definition: prealloced_array.h:225
size_t size() const
Definition: prealloced_array.h:226
A Query event is written to the binary log whenever the database is modified on the master,...
Definition: log_event.h:1273
RAII class to control the slave applier execution context binding with a being handled event.
Definition: rpl_rli.h:2231
Relay_log_info * m_rli
Definition: rpl_rli.h:2232
void set_current_event(Log_event *ev)
Definition: rpl_rli.h:2239
~RLI_current_event_raii()
Definition: rpl_rli.h:2240
RLI_current_event_raii(Relay_log_info *rli_arg, Log_event *ev)
Definition: rpl_rli.h:2235
Definition: rpl_rli.h:201
bool curr_group_seen_begin
Definition: rpl_rli.h:1178
uint checkpoint_group
Definition: rpl_rli.h:1208
static constexpr int RLI_FLUSH_IGNORE_SYNC_OPT
Ignore server sync options and flush.
Definition: rpl_rli.h:1533
static const int LINES_IN_RELAY_LOG_INFO_WITH_WORKERS
Definition: rpl_rli.h:1849
enum_return_check check_if_info_was_cleared(const enum_return_check &previous_result) const
Checks if the underlying Rpl_info handler holds information for the fields to be kept between slave r...
Definition: rpl_rli.cc:1958
enum_require_table_primary_key m_require_table_primary_key_check
Identifies what is the slave policy on primary keys in tables.
Definition: rpl_rli.h:793
Prealloced_array< Slave_job_item, 8 > curr_group_da
Definition: rpl_rli.h:1175
enum_priv_checks_status check_applier_acl_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname)
Checks the existence of user provided as part of the PRIVILEGE_CHECKS_USER option.
Definition: rpl_rli.cc:3051
Format_description_log_event * get_rli_description_event() const
Return the current Format_description_log_event.
Definition: rpl_rli.h:1725
ulonglong mts_events_assigned
Definition: rpl_rli.h:1244
char cached_charset[6]
Definition: rpl_rli.h:924
volatile uint32 slave_skip_counter
Definition: rpl_rli.h:898
std::atomic< int32 > atomic_channel_open_temp_tables
Definition: rpl_rli.h:351
TABLE * save_temporary_tables
Definition: rpl_rli.h:345
int stmt_done(my_off_t event_log_pos)
Helper function to do after statement completion.
Definition: rpl_rli.cc:1229
ulong wq_size_waits_cnt
Definition: rpl_rli.h:1248
mysql_cond_t log_space_cond
Definition: rpl_rli.h:901
ulonglong get_group_master_log_pos_info() const
Definition: rpl_rli.h:1578
bool reset_group_relay_log_pos(const char **errmsg)
Reset group_relay_log_name and group_relay_log_pos to the start of the first relay log file.
Definition: rpl_rli.cc:509
void set_event_start_pos(my_off_t pos)
Definition: rpl_rli.h:1630
bool is_in_group() const
A group is defined as the entire range of events that constitute a transaction or auto-committed stat...
Definition: rpl_rli.h:1497
bool cached_charset_compare(char *charset) const
Definition: rpl_rli.cc:1219
int count_relay_log_space()
Definition: rpl_rli.cc:488
int flush_current_log()
Definition: rpl_rli.cc:1859
ulonglong max_updated_index
Definition: rpl_rli.h:1204
Rows_query_log_event * rows_query_ev
Definition: rpl_rli.h:1053
bool is_long_find_row_note_printed()
Definition: rpl_rli.h:1711
void notify_relay_log_change()
Invalidates cached until_log_name and event_relay_log_name comparison result.
Definition: rpl_rli.h:963
int init_until_option(THD *thd, const LEX_MASTER_INFO *master_param)
Initialize until option object when starting slave.
Definition: rpl_rli.cc:2704
bool set_info_search_keys(Rpl_info_handler *to) override
To search in the slave repositories, each slave info object (mi, rli or worker) should use a primary ...
Definition: rpl_rli.cc:2294
bool is_in_trx_or_stmt() const
Auxiliary function used by is_in_group.
Definition: rpl_rli.h:1466
void set_filter(Rpl_filter *channel_filter)
Set replication filter for the channel.
Definition: rpl_rli.h:1796
volatile ulong pending_jobs
Definition: rpl_rli.h:1154
volatile long mts_wq_excess_cnt
Definition: rpl_rli.h:1194
bool curr_group_seen_gtid
Definition: rpl_rli.h:1177
Gtid_set * gtid_set
Definition: rpl_rli.h:723
ulong mts_wq_no_underrun_cnt
Definition: rpl_rli.h:1254
const char * get_group_master_log_name() const
Definition: rpl_rli.h:1568
MY_BITMAP recovery_groups
Definition: rpl_rli.h:1209
table_mapping m_table_map
Definition: rpl_rli.h:1051
ulong mts_slave_worker_queue_len_max
Definition: rpl_rli.h:1158
static const int LINES_IN_RELAY_LOG_INFO_WITH_CHANNEL
Definition: rpl_rli.h:1860
mysql_cond_t logical_clock_cond
Definition: rpl_rli.h:316
bool is_in_stmt() const
Auxiliary function used by is_in_group.
Definition: rpl_rli.h:1452
ulonglong mts_groups_assigned
Definition: rpl_rli.h:1245
bool reinit_sql_thread_io_cache(const char *log, bool need_data_lock)
@ UNTIL_SQL_VIEW_ID
Definition: rpl_rli.h:920
@ UNTIL_MASTER_POS
Definition: rpl_rli.h:915
@ UNTIL_NONE
Definition: rpl_rli.h:914
@ UNTIL_SQL_BEFORE_GTIDS
Definition: rpl_rli.h:917
@ UNTIL_SQL_AFTER_GTIDS
Definition: rpl_rli.h:918
@ UNTIL_SQL_AFTER_MTS_GAPS
Definition: rpl_rli.h:919
@ UNTIL_DONE
Definition: rpl_rli.h:921
@ UNTIL_RELAY_POS
Definition: rpl_rli.h:916
void close_temporary_tables()
Definition: rpl_rli.cc:1001
ulong retried_trans
Definition: rpl_rli.h:933
struct timespec last_clock
Identifies the last time a checkpoint routine has been executed.
Definition: rpl_rli.h:956
Checkable_rwlock * get_sid_lock()
Definition: rpl_rli.h:809
void detach_engine_ha_data(THD *thd)
Detaches the engine ha_data from THD.
Definition: rpl_rli.cc:2784
mysql_mutex_t pending_jobs_lock
Definition: rpl_rli.h:1155
bool inited_hash_workers
Definition: rpl_rli.h:1125
void set_event_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1633
ulonglong group_relay_log_pos
Definition: rpl_rli.h:698
uchar slave_version_split[3]
Definition: rpl_rli.h:1735
ulong mts_coordinator_basic_nap
Definition: rpl_rli.h:1197
size_t slave_patternload_file_size
Definition: rpl_rli.h:951
char ign_master_log_name_end[FN_REFLEN]
Definition: rpl_rli.h:943
bool recovery_groups_inited
Definition: rpl_rli.h:1210
ulonglong event_relay_log_pos
Definition: rpl_rli.h:702
void end_info()
Definition: rpl_rli.cc:1839
bool rli_fake
Definition: rpl_rli.h:731
ulong opt_replica_parallel_workers
Definition: rpl_rli.h:1199
void set_allow_drop_write_set(bool does_not_require_ws)
Definition: rpl_rli.h:2019
std::atomic< longlong > mts_total_wait_overlap
Definition: rpl_rli.h:1256
time_t get_sql_delay()
Definition: rpl_rli.h:1665
void clear_gtid_monitoring_info()
Clears the Gtid_monitoring_info fields.
Definition: rpl_rli.h:433
char group_master_log_name[FN_REFLEN]
Definition: rpl_rli.h:719
void clear_mts_recovery_groups()
Definition: rpl_rli.h:1334
Prealloced_array< db_worker_hash_entry *, 4 > curr_group_assigned_parts
Definition: rpl_rli.h:1173
const char * get_for_channel_str(bool upper_case=false) const override
Definition: rpl_rli.cc:2669
ulonglong ign_master_log_pos_end
Definition: rpl_rli.h:944
void cleanup_after_query()
Definition: rpl_rli.h:1392
Commit_order_manager * get_commit_order_manager()
Definition: rpl_rli.h:1748
ulong trans_retries
Definition: rpl_rli.h:933
void init_workers(ulong)
The method to invoke at slave threads start.
Definition: rpl_rli.cc:263
~Relay_log_info() override
Definition: rpl_rli.cc:284
uint32 m_flags
Definition: rpl_rli.h:1838
void clear_tables_to_lock()
Definition: rpl_rli.cc:1364
const char * get_until_log_name()
Definition: rpl_rli.cc:2686
void post_rollback()
Execute actions at replicated atomic DLL post rollback time.
Definition: rpl_rli.h:2084
my_off_t event_start_pos
Definition: rpl_rli.h:706
static const int LINES_IN_RELAY_LOG_INFO_WITH_PRIV_CHECKS_HOSTNAME
Definition: rpl_rli.h:1879
bool m_is_engine_ha_data_detached
Definition: rpl_rli.h:1988
static size_t get_number_info_rli_fields()
Definition: rpl_rli.cc:2032
bool reported_unsafe_warning
Definition: rpl_rli.h:1688
static const int LINES_IN_RELAY_LOG_INFO_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_VALUE
Definition: rpl_rli.h:1911
void set_require_table_primary_key_check(enum_require_table_primary_key require_pk)
Sets the field that tells what is the slave policy concerning primary keys on replicated tables.
Definition: rpl_rli.cc:3274
RPL_Table_ref * tables_to_lock
Definition: rpl_rli.h:1049
uint64 original_commit_timestamp
Definition: rpl_rli.h:1094
mysql_cond_t pending_jobs_cond
Definition: rpl_rli.h:1156
@ MTS_KILLED_GROUP
Definition: rpl_rli.h:1238
@ MTS_NOT_IN_GROUP
Definition: rpl_rli.h:1234
@ MTS_IN_GROUP
Definition: rpl_rli.h:1236
@ MTS_END_GROUP
Definition: rpl_rli.h:1237
void set_commit_order_manager(Commit_order_manager *mngr)
Definition: rpl_rli.h:1750
std::vector< Slave_worker * > workers_copy_pfs
Definition: rpl_rli.h:1141
static const int LINES_IN_RELAY_LOG_INFO_WITH_REQUIRE_TABLE_PRIMARY_KEY_CHECK
Definition: rpl_rli.h:1896
void set_thd_tx_priority(int priority)
Definition: rpl_rli.h:2007
void fill_coord_err_buf(loglevel level, int err_code, const char *buff_coord) const
Update the error number, message and timestamp fields.
Definition: rpl_rli.cc:553
volatile ulong mts_wq_overrun_cnt
Definition: rpl_rli.h:1247
enum_return_status add_gtid_set(const Gtid_set *gtid_set)
Adds a GTID set to received GTID set.
Definition: rpl_rli.cc:2676
bool replicate_same_server_id
Definition: rpl_rli.h:324
void add_logged_gtid(rpl_sidno sidno, rpl_gno gno)
Definition: rpl_rli.h:811
bool is_time_for_mta_checkpoint()
Check if it is time to compute MTS checkpoint.
Definition: rpl_rli.cc:2920
void set_flag(enum_state_flag flag)
Set the value of a replication state flag.
Definition: rpl_rli.h:1420
std::string m_privilege_checks_hostname
The host name part of the user passed on to PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.h:765
mysql_mutex_t slave_worker_hash_lock
Definition: rpl_rli.h:1127
ulong exit_counter
Definition: rpl_rli.h:1203
int rli_init_info(bool skip_received_gtid_set_recovery=false)
Initialize the relay log info.
Definition: rpl_rli.cc:1493
void reset_notified_relay_log_change()
While a group is executed by a Worker the relay log can change.
Definition: rpl_rli.cc:344
static void set_nullable_fields(MY_BITMAP *nullable_fields)
Sets bits for columns that are allowed to be NULL.
Definition: rpl_rli.cc:2036
bool m_is_applier_source_position_info_invalid
Are positions invalid.
Definition: rpl_rli.h:802
void set_master_info(Master_info *info)
Definition: rpl_rli.cc:1868
bool gtid_retrieved_initialized
Definition: rpl_rli.h:733
ulonglong stats_exec_time
Definition: rpl_rli.h:1268
bool force_flush_postponed_due_to_split_trans
Definition: rpl_rli.h:1746
volatile ulong mts_wq_underrun_w_id
Definition: rpl_rli.h:1183
void clear_processing_trx()
Clears the processing_trx structure fields.
Definition: rpl_rli.h:428
void deinit_workers()
The method to invoke at slave threads stop.
Definition: rpl_rli.cc:282
void clear_privilege_checks_user()
Clears the info related to the data initialized from PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.cc:2957
my_off_t get_event_start_pos()
Definition: rpl_rli.h:1631
bool get_ignore_write_set_memory_limit()
Definition: rpl_rli.h:2015
virtual void post_commit(bool on_rollback)
Cleanup of any side effect that pre_commit() inflicts, including restore of the last executed group c...
Definition: rpl_rli.cc:2856
void start_sql_delay(time_t delay_end)
Indicate that a delay starts.
Definition: rpl_rli.cc:2044
void cached_charset_invalidate()
Last charset (6 bytes) seen by slave SQL thread is cached here; it helps the thread save 3 get_charse...
Definition: rpl_rli.cc:1212
static const int LINES_IN_RELAY_LOG_INFO_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_TYPE
Definition: rpl_rli.h:1903
uint tables_to_lock_count
Definition: rpl_rli.h:1050
std::atomic< bool > ignore_log_space_limit
Definition: rpl_rli.h:876
int get_thd_tx_priority()
Definition: rpl_rli.h:2009
bool mts_recovery_group_seen_begin
Definition: rpl_rli.h:1213
bool long_find_row_note_printed
Definition: rpl_rli.h:1931
Deferred_log_events * deferred_events
Definition: rpl_rli.h:1102
Rpl_filter * rpl_filter
Definition: rpl_rli.h:253
ulong replica_parallel_workers
Definition: rpl_rli.h:1201
@ COMMIT_TS_FOUND
Definition: rpl_rli.h:363
@ COMMIT_TS_NOT_FOUND
Definition: rpl_rli.h:361
@ COMMIT_TS_UNKNOWN
Definition: rpl_rli.h:359
ulonglong log_space_limit
Definition: rpl_rli.h:875
Until_option * until_option
Definition: rpl_rli.h:1976
ulonglong mts_total_wait_worker_avail
Definition: rpl_rli.h:1261
int flush_info(const int flush_flags)
Stores the file and position where the execute-slave thread are in the relay log:
Definition: rpl_rli.cc:1924
bool is_relay_log_recovery
Definition: rpl_rli.h:336
Relay_log_info(bool is_slave_recovery, PSI_mutex_key *param_key_info_run_lock, PSI_mutex_key *param_key_info_data_lock, PSI_mutex_key *param_key_info_sleep_lock, PSI_mutex_key *param_key_info_thd_lock, PSI_mutex_key *param_key_info_data_cond, PSI_mutex_key *param_key_info_start_cond, PSI_mutex_key *param_key_info_stop_cond, PSI_mutex_key *param_key_info_sleep_cond, uint param_id, const char *param_channel, bool is_rli_fake)
Definition: rpl_rli.cc:107
bool workers_array_initialized
Definition: rpl_rli.h:1152
bool write_info(Rpl_info_handler *to) override
Definition: rpl_rli.cc:2302
time_t sql_delay_end
During a delay, specifies the point in time when the delay ends.
Definition: rpl_rli.h:1836
void set_ignore_write_set_memory_limit(bool ignore_limit)
Definition: rpl_rli.h:2011
bool mts_wq_oversize
Definition: rpl_rli.h:1161
bool m_privilege_checks_user_corrupted
Tells whether or not the internal data regarding PRIVILEGE_CHECKS_USER is corrupted.
Definition: rpl_rli.h:772
enum_state_flag
Flags for the state of the replication.
Definition: rpl_rli.h:257
@ IN_STMT
The replication thread is inside a statement.
Definition: rpl_rli.h:259
@ STATE_FLAGS_COUNT
Flag counter.
Definition: rpl_rli.h:262
uint event_relay_log_number
Definition: rpl_rli.h:701
enum Relay_log_info::@148 commit_timestamps_status
the status of the commit timestamps for the relay log
ulong mts_recovery_group_cnt
Definition: rpl_rli.h:1211
time_t row_stmt_start_timestamp
Definition: rpl_rli.h:1930
static constexpr int RLI_FLUSH_IGNORE_GTID_ONLY
Flush disresgarding the value of GTID_ONLY.
Definition: rpl_rli.h:1535
void set_group_master_log_name(const char *log_file_name)
Definition: rpl_rli.h:1582
void clear_flag(enum_state_flag flag)
Clear the value of a replication state flag.
Definition: rpl_rli.h:1436
ulong mts_wq_overfill_cnt
Definition: rpl_rli.h:1262
bool belongs_to_client()
Definition: rpl_rli.h:298
void set_future_event_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1564
bool curr_group_isolated
Definition: rpl_rli.h:1179
void set_long_find_row_note_printed()
Definition: rpl_rli.h:1705
void set_privilege_checks_user_corrupted(bool is_corrupted)
Sets the flag that tells whether or not the data regarding the PRIVILEGE_CHECKS_USER is corrupted.
Definition: rpl_rli.cc:2964
char group_relay_log_name[FN_REFLEN]
Event group means a group of events of a transaction.
Definition: rpl_rli.h:697
time_t get_row_stmt_start_timestamp()
Definition: rpl_rli.h:1695
ulonglong get_future_event_relay_log_pos()
Definition: rpl_rli.h:1561
time_t get_sql_delay_end()
Definition: rpl_rli.h:1667
void cleanup_context(THD *, bool)
Definition: rpl_rli.cc:1276
char new_group_master_log_name[FN_REFLEN]
Storage for holding newly computed values for the last executed event group coordinates while the cur...
Definition: rpl_rli.h:1281
Slave_worker * get_worker(size_t n)
Definition: rpl_rli.h:1298
mysql_mutex_t log_space_lock
Definition: rpl_rli.h:900
ulong adapt_to_master_version(Format_description_log_event *fdle)
adaptation for the slave applier to specific master versions.
Definition: rpl_rli.cc:2505
bool is_engine_ha_data_detached()
Checks whether engine ha data is detached from THD.
Definition: rpl_rli.h:2074
bool is_mts_recovery() const
returns true if there is any gap-group of events to execute at slave starting phase.
Definition: rpl_rli.h:1332
void notify_group_master_log_name_update()
The same as notify_group_relay_log_name_update but for group_master_log_name.
Definition: rpl_rli.h:983
enum_require_row_status
Definition: rpl_rli.h:243
@ PRIV_CHECKS_USER_NOT_NULL
Value for privilege_checks_user is not empty.
@ SUCCESS
Function ended successfully.
Assign_gtids_to_anonymous_transactions_info m_assign_gtids_to_anonymous_transactions_info
Stores the information related to the ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS parameter of CHANGE MAST...
Definition: rpl_rli.h:289
virtual Relay_log_info * get_c_rli()
Get coordinator's RLI.
Definition: rpl_rli.h:1789
void clear_sql_delay()
Reset the delay.
Definition: rpl_rli.h:891
Log_event * current_event
Reference to being applied event.
Definition: rpl_rli.h:1995
time_t mts_last_online_stat
Definition: rpl_rli.h:1273
my_off_t get_until_log_pos()
Definition: rpl_rli.cc:2695
Mts_submode * current_mts_submode
Definition: rpl_rli.h:1320
time_t set_row_stmt_start_timestamp()
Definition: rpl_rli.h:1697
Slave_committed_queue * gaq
Definition: rpl_rli.h:1168
bool is_relay_log_truncated()
Definition: rpl_rli.h:805
bool m_ignore_write_set_memory_limit
If the SQL thread should or not ignore the set limit for write set collection.
Definition: rpl_rli.h:1967
my_off_t new_group_master_log_pos
Definition: rpl_rli.h:1282
bool clear_info()
Clears from this Relay_log_info object all attribute values that are not to be kept.
Definition: rpl_rli.cc:1986
void clear_until_option()
Definition: rpl_rli.h:1773
ulonglong stats_read_time
Definition: rpl_rli.h:1269
bool is_privilege_checks_user_null() const
Returns whether or not there is no user configured for PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.cc:2946
void set_sql_delay(time_t _sql_delay)
Definition: rpl_rli.h:1666
static const int PRIV_CHECKS_HOSTNAME_LENGTH
Definition: rpl_rli.h:1884
bool is_applier_source_position_info_invalid() const
Returns if the applier positions are marked as being invalid or not.
Definition: rpl_rli.cc:3284
bool is_group_master_log_pos_invalid
Flag that the group_master_log_pos is invalid.
Definition: rpl_rli.h:867
void reset_row_stmt_start_timestamp()
Definition: rpl_rli.h:1703
MYSQL_BIN_LOG relay_log
Definition: rpl_rli.h:330
static const int LINES_IN_RELAY_LOG_INFO_WITH_ID
Definition: rpl_rli.h:1855
bool m_require_row_format
Tells if the slave is only accepting events logged with row based logging.
Definition: rpl_rli.h:781
void reset_notified_checkpoint(ulong count, time_t new_ts, bool update_timestamp=false)
While a group is executed by a Worker the relay log can change.
Definition: rpl_rli.cc:371
bool m_allow_drop_write_set
Even if a component says all transactions require write sets, this variable says the SQL thread trans...
Definition: rpl_rli.h:1973
uint rli_checkpoint_seqno
Definition: rpl_rli.h:1206
uint get_event_relay_log_number()
Definition: rpl_rli.h:1614
bool is_until_satisfied_at_start_slave()
Definition: rpl_rli.h:2027
std::pair< const char *, const char * > print_applier_security_context_user_host() const
Returns a printable representation of the username and hostname currently being used in the applier s...
Definition: rpl_rli.cc:3077
static const int MAXIMUM_LINES_IN_RELAY_LOG_INFO_FILE
Definition: rpl_rli.h:1917
void set_group_master_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1586
volatile my_off_t group_master_log_pos
Definition: rpl_rli.h:720
long mts_worker_underrun_level
Definition: rpl_rli.h:1195
bool is_until_satisfied_before_dispatching_event(const Log_event *ev)
Definition: rpl_rli.h:2031
ulonglong get_group_relay_log_pos()
Definition: rpl_rli.h:1593
void set_group_relay_log_name(const char *log_file_name, size_t len)
Definition: rpl_rli.h:1598
int inc_group_relay_log_pos(ulonglong log_pos, bool need_data_lock, bool force=false)
Last executed event group coordinates are updated and optionally forcibly flushed to a repository.
Definition: rpl_rli.cc:929
ulonglong log_space_total
Definition: rpl_rli.h:875
bool is_group_relay_log_name_invalid(const char **errmsg)
Check if group_relay_log_name is in index file.
Definition: rpl_rli.cc:523
Relay_log_info & operator=(const Relay_log_info &info)
const char * get_rpl_log_name() const
Definition: rpl_rli.h:1636
void set_until_option(Until_option *option)
Definition: rpl_rli.h:1767
void finished_processing()
When the processing of a transaction is completed, that timestamp is recorded, the information is cop...
Definition: rpl_rli.h:415
enum_priv_checks_status set_privilege_checks_user(char const *param_privilege_checks_username, char const *param_privilege_checks_hostname)
Initializes data related to PRIVILEGE_CHECKS_USER, specifically the user name and the user hostname.
Definition: rpl_rli.cc:2970
int purge_relay_logs(THD *thd, const char **errmsg, bool delete_only=false)
Purges relay logs.
Definition: rpl_rli.cc:1033
bool is_privilege_checks_user_corrupted() const
Returns whether or not the internal data regarding PRIVILEGE_CHECKS_USER is corrupted.
Definition: rpl_rli.cc:2953
bool is_until_satisfied_after_dispatching_event()
Definition: rpl_rli.h:2035
enum_priv_checks_status initialize_security_context(THD *thd)
Initializes the security context associated with the PRIVILEGE_CHECKS_USER user that is to be used by...
Definition: rpl_rli.cc:3219
void set_group_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1601
const char * get_group_relay_log_name()
Definition: rpl_rli.h:1592
enum_priv_checks_status check_privilege_checks_user()
Checks the validity and integrity of the data related to PRIVILEGE_CHECKS_USER, specifically the user...
Definition: rpl_rli.cc:3000
const char * get_event_relay_log_name()
Definition: rpl_rli.h:1605
virtual int set_rli_description_event(Format_description_log_event *fdle)
Delete the existing event and set a new one.
Definition: rpl_rli.cc:2385
Gtid_monitoring_info * gtid_monitoring_info
Stores information on the last processed transaction or the transaction that is currently being proce...
Definition: rpl_rli.h:748
const char * add_channel_to_relay_log_name(char *buff, uint buff_size, const char *base_name)
sets the suffix required for relay log names in multisource replication.
Definition: rpl_rli.cc:1180
size_t get_worker_count()
Definition: rpl_rli.h:1287
ulonglong get_group_master_log_pos() const
Definition: rpl_rli.h:1575
const char * get_group_master_log_name_info() const
Definition: rpl_rli.h:1571
void report_privilege_check_error(enum loglevel level, enum_priv_checks_status status_code, bool to_client, char const *channel_name=nullptr, char const *user_name=nullptr, char const *host_name=nullptr) const
Outputs the error message associated with applier thread user privilege checks error error_code.
Definition: rpl_rli.cc:3095
enum_require_table_primary_key
Identifies what is the replica policy on primary keys in tables.
Definition: rpl_rli.h:268
@ PK_CHECK_ON
The replica enforces tables to have primary keys for a given channel.
Definition: rpl_rli.h:277
@ PK_CHECK_STREAM
The replica sets the value of sql_require_primary_key according to the source replicated value.
Definition: rpl_rli.h:275
@ PK_CHECK_OFF
The replica does not enforce any policy around primary keys.
Definition: rpl_rli.h:279
@ PK_CHECK_GENERATE
The replica generates GIPKs for incoming keyless tables.
Definition: rpl_rli.h:281
@ PK_CHECK_NONE
No policy, used on PFS.
Definition: rpl_rli.h:270
void started_processing(Gtid gtid_arg, ulonglong original_ts_arg, ulonglong immediate_ts_arg, bool skipped=false)
Stores the details of the transaction which has just started processing.
Definition: rpl_rli.h:384
bool pre_commit()
The method implements a pre-commit hook to add up a new statement typically to a DDL transaction to u...
Definition: rpl_rli.h:2096
void retried_processing(uint transient_errno_arg, const char *transient_err_message_arg, ulong trans_retries_arg)
When a transaction is retried, the error number and message, and total number of retries are stored.
Definition: rpl_rli.h:444
static constexpr int RLI_FLUSH_NO_OPTION
No flush options given to relay log flush.
Definition: rpl_rli.h:1531
bool sql_thread_kill_accepted
Definition: rpl_rli.h:1693
static const int PRIV_CHECKS_USERNAME_LENGTH
Definition: rpl_rli.h:1872
void slave_close_thread_tables(THD *)
Definition: rpl_rli.cc:1405
enum_priv_checks_status
Set of possible return values for the member methods related to PRIVILEGE_CHECKS_USER management.
Definition: rpl_rli.h:209
@ USERNAME_NULL_HOSTNAME_NOT_NULL
Value for the username part of the user is NULL but the value for the hostname is not NULL.
@ USER_DOES_NOT_HAVE_PRIVILEGES
Provided user doesn't have the necessary privileges to execute the needed operations.
@ USER_ANONYMOUS
Value for user is anonymous (''@'...')
@ USERNAME_TOO_LONG
Value for the username part of the user is larger than 32 characters.
@ HOSTNAME_TOO_LONG
Value for the hostname part of the user is larger than 255 characters.
@ LOAD_DATA_EVENT_NOT_ALLOWED
Provided user doesn't have FILE privileges during the execution of a LOAD DATAevent.
@ USER_DATA_CORRUPTED
Values provided for the internal variables are corrupted.
@ USER_DOES_NOT_EXIST
Provided user doesn't exists.
@ SUCCESS
Function ended successfully.
@ HOSTNAME_SYNTAX_ERROR
Value for the hostname part of the user has illegal characters.
bool ddl_not_atomic
Raised when slave applies and writes to its binary log statement which is not atomic DDL and has no X...
Definition: rpl_rli.h:2005
bool get_flag(enum_state_flag flag)
Get the value of a replication state flag.
Definition: rpl_rli.h:1429
static const int LINES_IN_RELAY_LOG_INFO_WITH_REQUIRE_ROW_FORMAT
Definition: rpl_rli.h:1889
void inc_event_relay_log_pos()
Definition: rpl_rli.h:988
volatile ulong abort_pos_wait
Definition: rpl_rli.h:899
bool read_info(Rpl_info_handler *from) override
Definition: rpl_rli.cc:2050
void started_processing(Gtid_log_event *gtid_log_ev_arg)
Stores the details of the transaction which has just started processing.
Definition: rpl_rli.h:398
struct timespec stats_begin
Definition: rpl_rli.h:1271
mysql_mutex_t exit_count_lock
Definition: rpl_rli.h:1157
void notify_relay_log_truncated()
Receiver thread notifies that it truncated some data from relay log.
Definition: rpl_rli.cc:2909
uint relay_log_name_to_number(const char *name)
Definition: rpl_rli.cc:2661
Sid_map * get_sid_map()
Definition: rpl_rli.h:807
time_t last_event_start_time
Definition: rpl_rli.h:1091
ulonglong get_event_relay_log_pos()
Definition: rpl_rli.h:1606
void relay_log_number_to_name(uint number, char name[FN_REFLEN+1])
Given the extension number of the relay log, gets the full relay log path.
Definition: rpl_rli.cc:2648
ulong adapt_to_master_version_updown(ulong master_version, ulong current_version)
The method compares two supplied versions and carries out down- or up- grade customization of executi...
Definition: rpl_rli.cc:2585
enum_priv_checks_status initialize_applier_security_context()
Initializes the security context associated with the PRIVILEGE_CHECKS_USER user that is to be used by...
Definition: rpl_rli.cc:3255
static const int LINES_IN_RELAY_LOG_INFO_WITH_PRIV_CHECKS_USERNAME
Definition: rpl_rli.h:1867
ulonglong mts_pending_jobs_size
Definition: rpl_rli.h:1159
Format_description_log_event * rli_description_event
Definition: rpl_rli.h:1801
bool mts_finalize_recovery()
Called when gaps execution is ended so it is crash-safe to reset the last session Workers info.
Definition: rpl_rli.cc:428
enum Relay_log_info::@150 mts_group_status
void set_group_relay_log_name(const char *log_file_name)
Definition: rpl_rli.h:1594
int thd_tx_priority
Definition: rpl_rli.h:1961
my_off_t new_group_relay_log_pos
Definition: rpl_rli.h:1284
void clear_relay_log_truncated()
Applier clears the flag after it handled the situation.
Definition: rpl_rli.cc:2915
enum Relay_log_info::@149 until_condition
Replication_transaction_boundary_parser transaction_parser
Definition: rpl_rli.h:648
char slave_patternload_file[FN_REFLEN]
Definition: rpl_rli.h:950
ulong mts_recovery_index
Definition: rpl_rli.h:1212
void unset_long_find_row_note_printed()
Definition: rpl_rli.h:1707
mysql_mutex_t mts_temp_table_LOCK
Definition: rpl_rli.h:310
bool deferred_events_collecting
Definition: rpl_rli.h:1108
bool m_relay_log_truncated
It will be set to true when receiver truncated relay log for some reason.
Definition: rpl_rli.h:755
bool is_mts_in_group()
returns true if Coordinator is scheduling events belonging to the same group and has not reached yet ...
Definition: rpl_rli.h:1357
time_t last_master_timestamp
Definition: rpl_rli.h:885
bool is_parallel_exec() const
returns true if events are to be executed in parallel
Definition: rpl_rli.h:1345
int wait_for_gtid_set(THD *thd, const char *gtid, double timeout, bool update_THD_status=true)
Wait for a GTID set to be executed.
Definition: rpl_rli.cc:769
malloc_unordered_map< std::string, unique_ptr_with_deleter< db_worker_hash_entry > > mapping_db_to_worker
Definition: rpl_rli.h:1124
bool error_on_rli_init_info
Definition: rpl_rli.h:456
std::string get_privilege_checks_username() const
Retrieves the username part of the PRIVILEGE_CHECKS_USER option of CHANGE MASTER TO statement.
Definition: rpl_rli.cc:2938
static const int LINES_IN_RELAY_LOG_INFO_WITH_DELAY
Definition: rpl_rli.h:1844
Master_info * mi
Definition: rpl_rli.h:348
std::atomic< bool > sql_force_rotate_relay
Definition: rpl_rli.h:883
std::string m_privilege_checks_username
The user name part of the user passed on to PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.h:760
bool is_processing_trx()
Definition: rpl_rli.h:420
bool is_row_format_required() const
Returns whether the slave is running in row mode only.
Definition: rpl_rli.cc:3260
const Gtid_set * get_gtid_set() const
Definition: rpl_rli.h:827
void cleanup_after_session()
Definition: rpl_rli.h:1396
PSI_mutex_key m_key_mta_temp_table_LOCK
Definition: rpl_rli.h:304
virtual bool commit_positions()
The method implements updating a slave info table.
Definition: rpl_rli.cc:2805
char event_relay_log_name[FN_REFLEN]
Definition: rpl_rli.h:699
enum_require_table_primary_key get_require_table_primary_key_check() const
Returns what is the slave policy concerning primary keys on replicated tables.
Definition: rpl_rli.cc:3270
Slave_worker_array workers
Definition: rpl_rli.h:1119
bool get_allow_drop_write_set()
Definition: rpl_rli.h:2023
ulonglong future_event_relay_log_pos
Definition: rpl_rli.h:703
Commit_order_manager * commit_order_mngr
Definition: rpl_rli.h:1809
struct timespec ts_exec[2]
Definition: rpl_rli.h:1270
std::string get_privilege_checks_hostname() const
Retrieves the host part of the PRIVILEGE_CHECKS_USER option of CHANGE MASTER TO statement.
Definition: rpl_rli.cc:2942
Gtid_monitoring_info * get_gtid_monitoring_info()
Definition: rpl_rli.h:369
char new_group_relay_log_name[FN_REFLEN]
Definition: rpl_rli.h:1283
void set_event_relay_log_name(const char *log_file_name)
Definition: rpl_rli.h:1607
void set_applier_source_position_info_invalid(bool invalid)
Marks the applier position information as being invalid or not.
Definition: rpl_rli.cc:3280
int wait_for_pos(THD *thd, String *log_name, longlong log_pos, double timeout)
Waits until the SQL thread reaches (has executed up to) the log/position or timed out.
Definition: rpl_rli.cc:589
void set_require_row_format(bool require_row)
Sets the flag that tells whether or not the slave is running in row mode only.
Definition: rpl_rli.cc:3264
void reattach_engine_ha_data(THD *thd)
Reattaches the engine ha_data to THD.
Definition: rpl_rli.cc:2794
bool mts_end_group_sets_max_dbs
Definition: rpl_rli.h:1180
time_t sql_delay
Delay slave SQL thread by this amount of seconds.
Definition: rpl_rli.h:1826
mysql_cond_t slave_worker_hash_cond
Definition: rpl_rli.h:1128
Relay_log_info(const Relay_log_info &info)
Slave_worker * last_assigned_worker
Definition: rpl_rli.h:1163
ulong recovery_parallel_workers
Definition: rpl_rli.h:1205
ulonglong mts_pending_jobs_size_max
Definition: rpl_rli.h:1160
bool get_table_data(TABLE *table_arg, table_def **tabledef_var, TABLE **conv_table_var) const
Definition: rpl_rli.h:1055
enum_mts_parallel_type channel_mts_submode
Definition: rpl_rli.h:1318
void set_event_relay_log_number(uint number)
Definition: rpl_rli.h:1615
mysql_mutex_t mts_gaq_LOCK
Definition: rpl_rli.h:315
This is the class for verifying transaction boundaries in a replication event stream.
Definition: rpl_trx_boundary_parser.h:50
Common base class for all row-containing log events.
Definition: log_event.h:2598
It is used to record the original query for the rows events in RBR.
Definition: log_event.h:3561
Rpl_filter.
Definition: rpl_filter.h:213
Definition: rpl_info_factory.h:43
Definition: rpl_info_handler.h:57
Definition: rpl_info.h:42
mysql_mutex_t data_lock
Definition: rpl_info.h:57
bool is_transactional() const
Definition: rpl_info.h:110
THD * info_thd
Definition: rpl_info.h:77
A set of THD members describing the current authenticated user.
Definition: sql_security_ctx.h:53
Represents a bidirectional map between SID and SIDNO.
Definition: rpl_gtid.h:723
Checkable_rwlock * get_sid_lock() const
Return the sid_lock.
Definition: rpl_gtid.h:826
Group Assigned Queue whose first element identifies first gap in committed sequence.
Definition: rpl_rli_pdb.h:350
Definition: rpl_rli_pdb.h:497
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
Gtid owned_gtid
The GTID of the currently owned transaction.
Definition: sql_class.h:3708
bool slave_thread
Definition: sql_class.h:2676
Relay_log_info * rli_slave
Definition: sql_class.h:1065
enum enum_thread_type system_thread
Definition: sql_class.h:2469
System_variables variables
Definition: sql_lexer_thd.h:61
bool is_commit_in_middle_of_statement
Definition: sql_class.h:3866
bool is_operating_substatement_implicitly
Definition: sql_class.h:2292
Table_ref * next_global
Definition: table.h:3448
This is the abstract base class for slave start until options.
Definition: rpl_replica_until_options.h:55
bool is_satisfied_after_dispatching_event()
check if the until option is satisfied after applied or dispatched a event.
Definition: rpl_replica_until_options.h:96
bool is_satisfied_before_dispatching_event(const Log_event *ev)
check if the until option is satisfied before applying or dispatching a event.
Definition: rpl_replica_until_options.h:82
bool is_satisfied_at_start_slave()
Check if the until option is already satisfied at coordinator starting.
Definition: rpl_replica_until_options.h:66
unsigned long long int original_commit_timestamp
Timestamp when the transaction was committed on the originating master.
Definition: control_events.h:995
unsigned long long int immediate_commit_timestamp
Timestamp when the transaction was committed on the nearest master.
Definition: control_events.h:997
uint16_t error_code
Definition: statement_events.h:559
std::unordered_map, but with my_malloc, so that you can track the memory used using PSI memory keys.
Definition: map_helpers.h:147
A table definition from the master.
Definition: rpl_utility.h:247
Maps table id's (integers) to table pointers.
Definition: rpl_tblmap.h:50
#define mysql_mutex_lock(M)
Definition: mysql_mutex.h:49
#define mysql_mutex_unlock(M)
Definition: mysql_mutex.h:56
#define base_name(A)
Definition: my_sys.h:705
uint sql_replica_skip_counter
a copy of active_mi->rli->slave_skip_counter, for showing in SHOW GLOBAL VARIABLES,...
Definition: rpl_replica.cc:8765
bool is_atomic_ddl(THD *thd, bool using_trans_arg)
The function lists all DDL instances that are supported for crash-recovery (WL9175).
Definition: log_event.cc:3719
unsigned int PSI_mutex_key
Instrumented mutex key.
Definition: psi_mutex_bits.h:51
static int flag
Definition: hp_test1.cc:39
std::string log_file_name(const Log_files_context &ctx, Log_file_id file_id)
Provides name of the log file with the given file id, e.g.
Definition: log0files_io.cc:728
Binary log event definitions.
char * strmake(char *dst, const char *src, size_t length)
Definition: strmake.cc:42
std::unique_ptr< T, void(*)(T *)> unique_ptr_with_deleter
std::unique_ptr, but with a custom delete function.
Definition: map_helpers.h:88
void bitmap_free(MY_BITMAP *map)
Definition: my_bitmap.cc:157
#define DBUG_PRINT(keyword, arglist)
Definition: my_dbug.h:180
Some integer typedefs for easier portability.
unsigned long long int ulonglong
Definition: my_inttypes.h:55
ulonglong my_off_t
Definition: my_inttypes.h:71
unsigned char uchar
Definition: my_inttypes.h:51
long long int longlong
Definition: my_inttypes.h:54
uint64_t uint64
Definition: my_inttypes.h:68
uint32_t uint32
Definition: my_inttypes.h:66
Common #defines and includes for file and socket I/O.
#define FN_REFLEN
Definition: my_io.h:82
Definition of the global "loglevel" enumeration.
loglevel
Definition: my_loglevel.h:40
Defines various enable/disable and HAVE_ macros related to the performance schema instrumentation sys...
#define HAVE_PSI_INTERFACE
Definition: my_psi_config.h:38
Common header for many mysys elements.
static int count
Definition: myisam_ftdump.cc:42
Instrumentation helpers for conditions.
ABI for instrumented mutexes.
@ QUERY_EVENT
Definition: binlog_event.h:288
const std::string charset("charset")
static bool timeout(bool(*wait_condition)())
Timeout function.
Definition: log0meb.cc:495
std::vector< T, ut::allocator< T > > vector
Specialization of vector which uses allocator.
Definition: ut0new.h:2872
Instrumentation helpers for mutexes.
PSI_memory_key key_memory_db_worker_hash_entry
Definition: psi_memory_key.cc:103
Instrumentation helpers for mutexes.
#define OPTION_BEGIN
Definition: query_options.h:74
required uint32 status
Definition: replication_asynchronous_connection_failover.proto:60
required uint32 priority
Definition: replication_group_member_actions.proto:34
required string event
Definition: replication_group_member_actions.proto:31
enum_return_status
Generic return type for many functions that can succeed or fail.
Definition: rpl_gtid.h:121
int rpl_sidno
Type of SIDNO (source ID number, first component of GTID)
Definition: rpl_gtid.h:95
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
@ ASSIGNED_GTID
Specifies that the transaction has been assigned a GTID (UUID:NUMBER).
Definition: rpl_gtid.h:3698
enum_return_check
Definition: rpl_info_handler.h:50
enum_mts_parallel_type
Definition: rpl_mta_submode.h:46
bool operator!(Relay_log_info::enum_priv_checks_status status)
Negation operator for enum_priv_checks_status, to facilitate validation against SUCCESS.
Definition: rpl_rli.cc:2930
Prealloced_array< Slave_worker *, 4 > Slave_worker_array
Definition: rpl_rli.h:78
struct slave_job_item Slave_job_item
bool is_mts_worker(const THD *thd)
Definition: rpl_rli.h:2142
bool is_committed_ddl(Log_event *ev)
Checks whether the supplied event encodes a (2pc-aware) DDL that has been already committed.
Definition: rpl_rli.h:2158
bool is_atomic_ddl_commit_on_slave(THD *thd)
Checks whether the transaction identified by the argument is executed by a slave applier thread is an...
Definition: rpl_rli.h:2190
bool mysql_show_relaylog_events(THD *thd)
Execute a SHOW RELAYLOG EVENTS statement.
Definition: rpl_rli.cc:1448
bool is_mts_db_partitioned(Relay_log_info *rli)
Auxiliary function to check if we have a db partitioned MTS.
Definition: rpl_rli.cc:2665
Replication transaction boundary parser.
enum_mdl_type
Type of metadata lock request.
Definition: sql_lexer_yacc_state.h:105
case opt name
Definition: sslopt-case.h:32
TODO: Move this structure to libbinlogevents/include/control_events.h when we start using C++11.
Definition: rpl_gtid.h:1065
rpl_sidno sidno
SIDNO of this Gtid.
Definition: rpl_gtid.h:1067
Structure to hold parameters for CHANGE MASTER, START SLAVE, and STOP SLAVE.
Definition: sql_lex.h:350
enum_mdl_namespace
Object namespaces.
Definition: mdl.h:399
const char * str
Definition: mysql_lex_string.h:40
Definition: my_bitmap.h:42
Extend the normal Table_ref with a few new fields needed by the slave thread, but nowhere else.
Definition: rpl_utility.h:511
LEX_CSTRING table_name
Definition: table.h:771
LEX_CSTRING db
Definition: table.h:770
TABLE_SHARE * s
Definition: table.h:1396
Legends running throughout the module:
Definition: rpl_rli_pdb.h:73
An instrumented cond structure.
Definition: mysql_cond_bits.h:49
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:49
Log_event * data
Definition: rpl_rli.h:81
my_off_t relay_pos
Definition: rpl_rli.h:83
uint relay_number
Definition: rpl_rli.h:82
static bool update_timestamp(THD *thd, set_var *var)
Definition: sys_vars.cc:5597
@ SYSTEM_THREAD_SLAVE_WORKER
Definition: thread_type.h:41
@ SYSTEM_THREAD_SLAVE_SQL
Definition: thread_type.h:36
Include file for Sun RPC to compile out of the box.
unsigned int uint
Definition: uca-dump.cc:29
int n
Definition: xcom_base.cc:508