121 const char *assign_gtids_to_anonymous_transactions_value);
304#ifdef HAVE_PSI_INTERFACE
386 ulonglong immediate_ts_arg,
bool skipped =
false) {
446 const char *transient_err_message_arg,
447 ulong trans_retries_arg) {
449 transient_errno_arg, transient_err_message_arg, trans_retries_arg);
517 char const *param_privilege_checks_username,
518 char const *param_privilege_checks_hostname);
543 char const *param_privilege_checks_username,
544 char const *param_privilege_checks_hostname);
555 char const *param_privilege_checks_username,
556 char const *param_privilege_checks_hostname);
565 std::pair<const char *, const char *>
590 char const *channel_name =
nullptr,
591 char const *user_name =
nullptr,
592 char const *host_name =
nullptr)
const;
888 const char *buff_coord)
const;
996 down_cast<Until_position *>(
until_option)->notify_log_name_change();
1016 down_cast<Until_position *>(
until_option)->notify_log_name_change();
1031 bool force =
false);
1048 bool update_THD_status =
true);
1062 bool update_THD_status =
true);
1076 bool update_THD_status =
true);
1087 TABLE **conv_table_var)
const {
1088 assert(tabledef_var && conv_table_var);
1091 if (ptr->table == table_arg) {
1092 *tabledef_var = &
static_cast<RPL_Table_ref *
>(ptr)->m_tabledef;
1093 *conv_table_var =
static_cast<RPL_Table_ref *
>(ptr)->m_conv_table;
1094 DBUG_PRINT(
"debug", (
"Fetching table data for table %s.%s:"
1095 " tabledef: %p, conv_table: %p",
1097 *tabledef_var, *conv_table_var));
1286 std::atomic<longlong>
1487 DBUG_PRINT(
"info", (
"is_in_stmt()=%d", ret));
1501 DBUG_PRINT(
"info", (
"is_in_trx_or_stmt()=%d", ret));
1532 DBUG_PRINT(
"info", (
"is_in_group()=%d", ret));
1560 int rli_init_info(
bool skip_received_gtid_set_recovery =
false);
1713 uint param_id,
const char *param_channel,
bool is_rli_fake);
1767 ulong current_version);
2229 if (!rli)
return false;
2239 ->has_ddl_committed) &&
2436 std::vector<std::tuple<ulong, TABLE const *, Rows_log_event *>>
2437 &extra_privileges)
const;
2451 std::initializer_list<std::string_view> extra_privileges)
const;
2465 bool has_access(std::initializer_list<ulong> extra_privileges)
const;
2518 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:2386
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:3536
virtual ~Applier_security_context_guard()
Destructor that restores the backed up security context, if needed.
Definition: rpl_rli.cc:3454
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:3403
bool skip_priv_checks() const
Returns whether or not privilege checks may be skipped within the current context.
Definition: rpl_rli.cc:3462
Security_context m_applier_security_ctx
Applier security context based on PRIVILEGE_CHECK_USER user.
Definition: rpl_rli.h:2507
bool m_privilege_checks_none
Flag that states if privilege check should be skipped.
Definition: rpl_rli.h:2513
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:3524
THD const * m_thd
The THD object for which the security context will be initialized.
Definition: rpl_rli.h:2505
Security_context * m_previous
Backed up security context.
Definition: rpl_rli.h:2511
Security_context * m_current
Currently in use security context.
Definition: rpl_rli.h:2509
bool m_logged_in_acl_user
Flag that states if there is a logged user.
Definition: rpl_rli.h:2515
std::string get_hostname() const
Returns the hostname for the user for which the security context was initialized.
Definition: rpl_rli.cc:3530
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:3490
Relay_log_info const * m_target
The Relay_log_info object holding the info required to initialize the context.
Definition: rpl_rli.h:2501
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:92
bool set_info(enum_type assign_gtids_to_anonymous_transactions_type, const char *assign_gtids_to_anonymous_transactions_value)
Definition: rpl_rli.cc:3334
rpl_sidno m_sidno
Definition: rpl_rli.h:129
enum_type get_type() const
Definition: rpl_rli.cc:3330
enum_type m_type
This stores the type of Assign_gtids_to_anonymous_transactions info.
Definition: rpl_rli.h:125
Assign_gtids_to_anonymous_transactions_info()
The default constructor initializes parameters to their default value.
Definition: rpl_rli.h:109
std::string m_value
Stores the UUID in case the m_type is not OFF.
Definition: rpl_rli.h:127
enum_type
This accepted value of the type of the Assign_gtids_to_anonymous_transactions info OFF : Anonymous gt...
Definition: rpl_rli.h:105
rpl_sidno get_sidno() const
Definition: rpl_rli.h:113
std::string get_value() const
Definition: rpl_rli.cc:3325
This has the functionality of mysql_rwlock_t, with two differences:
Definition: rpl_gtid.h:309
void assert_some_lock() const
Assert that some thread holds either the read or the write lock.
Definition: rpl_gtid.h:556
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:1300
This is a subclass if Gtid_event and Log_event.
Definition: log_event.h:3741
rpl_gno get_gno() const override
Return the GNO for this GTID.
Definition: log_event.h:3882
rpl_sidno get_sidno(bool need_lock)
Return the SIDNO relative to the global sid_map for this GTID.
Definition: log_event.cc:13339
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:3846
Stores information to monitor a transaction during the different replication stages.
Definition: rpl_gtid.h:1321
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
bool is_processing_trx_set()
Returns true if the processing_trx is set, false otherwise.
Definition: rpl_gtid_misc.cc:517
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
void clear_processing_trx()
Clear only the processing_trx monitoring info.
Definition: rpl_gtid_misc.cc:427
Represents a set of GTIDs.
Definition: rpl_gtid.h:1465
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
void _add_gtid(rpl_sidno sidno, rpl_gno gno)
Adds the given GTID to this Gtid_set.
Definition: rpl_gtid.h:1527
Sid_map * get_sid_map() const
Return the Sid_map associated with this Gtid_set.
Definition: rpl_gtid.h:1897
This is the abstract base class for binary log events.
Definition: log_event.h:542
virtual Log_event_type get_type_code() const
Definition: log_event.h:799
Utility class to allow RAII pattern with MDL_request and MDL_context classes.
Definition: rpl_rli.h:2282
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:3375
bool is_locked()
Returns whether or not the lock as been acquired within this object life-cycle.
Definition: rpl_rli.cc:3401
THD * m_target
The THD object holding the MDL context used for acquiring/releasing.
Definition: rpl_rli.h:2347
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:3365
MDL_request m_request
The MDL request holding the MDL ticket issued upon acquisition.
Definition: rpl_rli.h:2349
virtual ~MDL_lock_guard()
Destructor that unlocks all acquired locks.
Definition: rpl_rli.cc:3394
A pending metadata lock request.
Definition: mdl.h:801
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:1275
RAII class to control the slave applier execution context binding with a being handled event.
Definition: rpl_rli.h:2264
Relay_log_info * m_rli
Definition: rpl_rli.h:2265
void set_current_event(Log_event *ev)
Definition: rpl_rli.h:2272
~RLI_current_event_raii()
Definition: rpl_rli.h:2273
RLI_current_event_raii(Relay_log_info *rli_arg, Log_event *ev)
Definition: rpl_rli.h:2268
Definition: rpl_rli.h:202
bool curr_group_seen_begin
Definition: rpl_rli.h:1209
uint checkpoint_group
Definition: rpl_rli.h:1239
static constexpr int RLI_FLUSH_IGNORE_SYNC_OPT
Ignore server sync options and flush.
Definition: rpl_rli.h:1566
static const int LINES_IN_RELAY_LOG_INFO_WITH_WORKERS
Definition: rpl_rli.h:1882
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:1969
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:824
Prealloced_array< Slave_job_item, 8 > curr_group_da
Definition: rpl_rli.h:1206
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:3088
Format_description_log_event * get_rli_description_event() const
Return the current Format_description_log_event.
Definition: rpl_rli.h:1758
ulonglong group_source_log_start_pos
Definition: rpl_rli.h:729
ulonglong mts_events_assigned
Definition: rpl_rli.h:1275
char cached_charset[6]
Definition: rpl_rli.h:955
volatile uint32 slave_skip_counter
Definition: rpl_rli.h:929
std::atomic< int32 > atomic_channel_open_temp_tables
Definition: rpl_rli.h:352
TABLE * save_temporary_tables
Definition: rpl_rli.h:346
std::tuple< ulonglong, ulonglong > get_group_source_log_start_end_pos() const
Get event group positions in source binary log on a replica which is processed by a worker in MTA or ...
Definition: rpl_rli.cc:2942
int stmt_done(my_off_t event_log_pos)
Helper function to do after statement completion.
Definition: rpl_rli.cc:1238
ulong wq_size_waits_cnt
Definition: rpl_rli.h:1279
mysql_cond_t log_space_cond
Definition: rpl_rli.h:932
ulonglong get_group_master_log_pos_info() const
Definition: rpl_rli.h:1611
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:518
void set_event_start_pos(my_off_t pos)
Definition: rpl_rli.h:1663
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:1530
bool cached_charset_compare(char *charset) const
Definition: rpl_rli.cc:1228
int count_relay_log_space()
Definition: rpl_rli.cc:497
int flush_current_log()
Definition: rpl_rli.cc:1868
ulonglong max_updated_index
Definition: rpl_rli.h:1235
Rows_query_log_event * rows_query_ev
Definition: rpl_rli.h:1084
bool is_long_find_row_note_printed()
Definition: rpl_rli.h:1744
void notify_relay_log_change()
Invalidates cached until_log_name and event_relay_log_name comparison result.
Definition: rpl_rli.h:994
int init_until_option(THD *thd, const LEX_MASTER_INFO *master_param)
Initialize until option object when starting slave.
Definition: rpl_rli.cc:2715
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:2305
bool is_in_trx_or_stmt() const
Auxiliary function used by is_in_group.
Definition: rpl_rli.h:1499
void set_filter(Rpl_filter *channel_filter)
Set replication filter for the channel.
Definition: rpl_rli.h:1829
@ MTS_KILLED_GROUP
Definition: rpl_rli.h:1269
@ MTS_NOT_IN_GROUP
Definition: rpl_rli.h:1265
@ MTS_IN_GROUP
Definition: rpl_rli.h:1267
@ MTS_END_GROUP
Definition: rpl_rli.h:1268
volatile ulong pending_jobs
Definition: rpl_rli.h:1185
time_t mta_coordinator_has_waited_stat
Last moment in time the MTA printed a coordinator waited stats.
Definition: rpl_rli.h:1306
volatile long mts_wq_excess_cnt
Definition: rpl_rli.h:1225
bool curr_group_seen_gtid
Definition: rpl_rli.h:1208
Gtid_set * gtid_set
Definition: rpl_rli.h:754
ulong mts_wq_no_underrun_cnt
Definition: rpl_rli.h:1285
const char * get_group_master_log_name() const
Definition: rpl_rli.h:1601
MY_BITMAP recovery_groups
Definition: rpl_rli.h:1240
table_mapping m_table_map
Definition: rpl_rli.h:1082
ulong mts_slave_worker_queue_len_max
Definition: rpl_rli.h:1189
static const int LINES_IN_RELAY_LOG_INFO_WITH_CHANNEL
Definition: rpl_rli.h:1893
mysql_cond_t logical_clock_cond
Definition: rpl_rli.h:317
bool is_in_stmt() const
Auxiliary function used by is_in_group.
Definition: rpl_rli.h:1485
ulonglong mts_groups_assigned
Definition: rpl_rli.h:1276
bool reinit_sql_thread_io_cache(const char *log, bool need_data_lock)
@ COMMIT_TS_FOUND
Definition: rpl_rli.h:364
@ COMMIT_TS_NOT_FOUND
Definition: rpl_rli.h:362
@ COMMIT_TS_UNKNOWN
Definition: rpl_rli.h:360
void close_temporary_tables()
Definition: rpl_rli.cc:1010
ulong retried_trans
Definition: rpl_rli.h:964
struct timespec last_clock
Identifies the last time a checkpoint routine has been executed.
Definition: rpl_rli.h:987
Checkable_rwlock * get_sid_lock()
Definition: rpl_rli.h:840
void detach_engine_ha_data(THD *thd)
Detaches the engine ha_data from THD.
Definition: rpl_rli.cc:2795
mysql_mutex_t pending_jobs_lock
Definition: rpl_rli.h:1186
bool inited_hash_workers
Definition: rpl_rli.h:1156
void set_event_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1666
ulonglong group_relay_log_pos
Definition: rpl_rli.h:699
uchar slave_version_split[3]
Definition: rpl_rli.h:1768
ulong mts_coordinator_basic_nap
Definition: rpl_rli.h:1228
bool group_source_log_seen_start_pos
Event group beginning event has been seen.
Definition: rpl_rli.h:725
size_t slave_patternload_file_size
Definition: rpl_rli.h:982
char ign_master_log_name_end[FN_REFLEN]
Definition: rpl_rli.h:974
bool recovery_groups_inited
Definition: rpl_rli.h:1241
ulonglong event_relay_log_pos
Definition: rpl_rli.h:703
void end_info()
Definition: rpl_rli.cc:1848
bool rli_fake
Definition: rpl_rli.h:762
ulong opt_replica_parallel_workers
Definition: rpl_rli.h:1230
void set_allow_drop_write_set(bool does_not_require_ws)
Definition: rpl_rli.h:2052
std::atomic< longlong > mts_total_wait_overlap
Definition: rpl_rli.h:1287
time_t get_sql_delay()
Definition: rpl_rli.h:1698
void clear_gtid_monitoring_info()
Clears the Gtid_monitoring_info fields.
Definition: rpl_rli.h:434
char group_master_log_name[FN_REFLEN]
Definition: rpl_rli.h:750
void clear_mts_recovery_groups()
Definition: rpl_rli.h:1367
Prealloced_array< db_worker_hash_entry *, 4 > curr_group_assigned_parts
Definition: rpl_rli.h:1204
const char * get_for_channel_str(bool upper_case=false) const override
Definition: rpl_rli.cc:2680
ulonglong ign_master_log_pos_end
Definition: rpl_rli.h:975
void cleanup_after_query()
Definition: rpl_rli.h:1425
Commit_order_manager * get_commit_order_manager()
Definition: rpl_rli.h:1781
enum Relay_log_info::@151 commit_timestamps_status
the status of the commit timestamps for the relay log
ulong trans_retries
Definition: rpl_rli.h:964
void init_workers(ulong)
The method to invoke at slave threads start.
Definition: rpl_rli.cc:271
~Relay_log_info() override
Definition: rpl_rli.cc:293
uint32 m_flags
Definition: rpl_rli.h:1871
void clear_tables_to_lock()
Definition: rpl_rli.cc:1373
const char * get_until_log_name()
Definition: rpl_rli.cc:2697
void post_rollback()
Execute actions at replicated atomic DLL post rollback time.
Definition: rpl_rli.h:2117
my_off_t event_start_pos
Definition: rpl_rli.h:737
static const int LINES_IN_RELAY_LOG_INFO_WITH_PRIV_CHECKS_HOSTNAME
Definition: rpl_rli.h:1912
bool m_is_engine_ha_data_detached
Definition: rpl_rli.h:2021
static size_t get_number_info_rli_fields()
Definition: rpl_rli.cc:2043
bool reported_unsafe_warning
Definition: rpl_rli.h:1721
static const int LINES_IN_RELAY_LOG_INFO_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_VALUE
Definition: rpl_rli.h:1944
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:3311
RPL_Table_ref * tables_to_lock
Definition: rpl_rli.h:1080
uint64 original_commit_timestamp
Definition: rpl_rli.h:1125
mysql_cond_t pending_jobs_cond
Definition: rpl_rli.h:1187
void set_commit_order_manager(Commit_order_manager *mngr)
Definition: rpl_rli.h:1783
std::vector< Slave_worker * > workers_copy_pfs
Definition: rpl_rli.h:1172
static const int LINES_IN_RELAY_LOG_INFO_WITH_REQUIRE_TABLE_PRIMARY_KEY_CHECK
Definition: rpl_rli.h:1929
void set_thd_tx_priority(int priority)
Definition: rpl_rli.h:2040
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:562
volatile ulong mts_wq_overrun_cnt
Definition: rpl_rli.h:1278
enum_return_status add_gtid_set(const Gtid_set *gtid_set)
Adds a GTID set to received GTID set.
Definition: rpl_rli.cc:2687
bool replicate_same_server_id
Definition: rpl_rli.h:325
void add_logged_gtid(rpl_sidno sidno, rpl_gno gno)
Definition: rpl_rli.h:842
bool is_time_for_mta_checkpoint()
Check if it is time to compute MTS checkpoint.
Definition: rpl_rli.cc:2957
void set_flag(enum_state_flag flag)
Set the value of a replication state flag.
Definition: rpl_rli.h:1453
std::string m_privilege_checks_hostname
The host name part of the user passed on to PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.h:796
mysql_mutex_t slave_worker_hash_lock
Definition: rpl_rli.h:1158
ulong exit_counter
Definition: rpl_rli.h:1234
int rli_init_info(bool skip_received_gtid_set_recovery=false)
Initialize the relay log info.
Definition: rpl_rli.cc:1502
void reset_notified_relay_log_change()
While a group is executed by a Worker the relay log can change.
Definition: rpl_rli.cc:353
static void set_nullable_fields(MY_BITMAP *nullable_fields)
Sets bits for columns that are allowed to be NULL.
Definition: rpl_rli.cc:2047
bool m_is_applier_source_position_info_invalid
Are positions invalid.
Definition: rpl_rli.h:833
void set_master_info(Master_info *info)
Definition: rpl_rli.cc:1877
bool gtid_retrieved_initialized
Definition: rpl_rli.h:764
ulonglong stats_exec_time
Definition: rpl_rli.h:1299
bool force_flush_postponed_due_to_split_trans
Definition: rpl_rli.h:1779
volatile ulong mts_wq_underrun_w_id
Definition: rpl_rli.h:1214
void clear_processing_trx()
Clears the processing_trx structure fields.
Definition: rpl_rli.h:429
void deinit_workers()
The method to invoke at slave threads stop.
Definition: rpl_rli.cc:291
void clear_privilege_checks_user()
Clears the info related to the data initialized from PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.cc:2994
my_off_t get_event_start_pos()
Definition: rpl_rli.h:1664
bool get_ignore_write_set_memory_limit()
Definition: rpl_rli.h:2048
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:2867
void start_sql_delay(time_t delay_end)
Indicate that a delay starts.
Definition: rpl_rli.cc:2055
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:1221
static const int LINES_IN_RELAY_LOG_INFO_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_TYPE
Definition: rpl_rli.h:1936
uint tables_to_lock_count
Definition: rpl_rli.h:1081
std::atomic< bool > ignore_log_space_limit
Definition: rpl_rli.h:907
int get_thd_tx_priority()
Definition: rpl_rli.h:2042
bool mts_recovery_group_seen_begin
Definition: rpl_rli.h:1244
bool long_find_row_note_printed
Definition: rpl_rli.h:1964
Deferred_log_events * deferred_events
Definition: rpl_rli.h:1133
Rpl_filter * rpl_filter
Definition: rpl_rli.h:254
ulong replica_parallel_workers
Definition: rpl_rli.h:1232
ulonglong log_space_limit
Definition: rpl_rli.h:906
Until_option * until_option
Definition: rpl_rli.h:2009
ulonglong mts_total_wait_worker_avail
Definition: rpl_rli.h:1292
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:1933
bool is_relay_log_recovery
Definition: rpl_rli.h:337
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:111
bool workers_array_initialized
Definition: rpl_rli.h:1183
bool write_info(Rpl_info_handler *to) override
Definition: rpl_rli.cc:2313
time_t sql_delay_end
During a delay, specifies the point in time when the delay ends.
Definition: rpl_rli.h:1869
void set_ignore_write_set_memory_limit(bool ignore_limit)
Definition: rpl_rli.h:2044
bool mts_wq_oversize
Definition: rpl_rli.h:1192
bool m_privilege_checks_user_corrupted
Tells whether or not the internal data regarding PRIVILEGE_CHECKS_USER is corrupted.
Definition: rpl_rli.h:803
enum_state_flag
Flags for the state of the replication.
Definition: rpl_rli.h:258
@ IN_STMT
The replication thread is inside a statement.
Definition: rpl_rli.h:260
@ STATE_FLAGS_COUNT
Flag counter.
Definition: rpl_rli.h:263
uint event_relay_log_number
Definition: rpl_rli.h:702
ulong mts_recovery_group_cnt
Definition: rpl_rli.h:1242
time_t row_stmt_start_timestamp
Definition: rpl_rli.h:1963
static constexpr int RLI_FLUSH_IGNORE_GTID_ONLY
Flush disresgarding the value of GTID_ONLY.
Definition: rpl_rli.h:1568
void set_group_master_log_name(const char *log_file_name)
Definition: rpl_rli.h:1615
void clear_flag(enum_state_flag flag)
Clear the value of a replication state flag.
Definition: rpl_rli.h:1469
ulong mts_wq_overfill_cnt
Definition: rpl_rli.h:1293
bool belongs_to_client()
Definition: rpl_rli.h:299
void set_future_event_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1597
bool curr_group_isolated
Definition: rpl_rli.h:1210
void set_long_find_row_note_printed()
Definition: rpl_rli.h:1738
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:3001
char group_relay_log_name[FN_REFLEN]
Event group means a group of events of a transaction.
Definition: rpl_rli.h:698
time_t get_row_stmt_start_timestamp()
Definition: rpl_rli.h:1728
ulonglong get_future_event_relay_log_pos()
Definition: rpl_rli.h:1594
time_t get_sql_delay_end()
Definition: rpl_rli.h:1700
void cleanup_context(THD *, bool)
Definition: rpl_rli.cc:1285
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:1314
Slave_worker * get_worker(size_t n)
Definition: rpl_rli.h:1331
mysql_mutex_t log_space_lock
Definition: rpl_rli.h:931
ulong adapt_to_master_version(Format_description_log_event *fdle)
adaptation for the slave applier to specific master versions.
Definition: rpl_rli.cc:2516
bool is_engine_ha_data_detached()
Checks whether engine ha data is detached from THD.
Definition: rpl_rli.h:2107
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:1365
enum Relay_log_info::@152 until_condition
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:1014
enum_require_row_status
Definition: rpl_rli.h:244
@ 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:290
virtual Relay_log_info * get_c_rli()
Get coordinator's RLI.
Definition: rpl_rli.h:1822
void clear_sql_delay()
Reset the delay.
Definition: rpl_rli.h:922
Log_event * current_event
Reference to being applied event.
Definition: rpl_rli.h:2028
time_t mts_last_online_stat
Definition: rpl_rli.h:1304
my_off_t get_until_log_pos()
Definition: rpl_rli.cc:2706
Mts_submode * current_mts_submode
Definition: rpl_rli.h:1353
time_t set_row_stmt_start_timestamp()
Definition: rpl_rli.h:1730
Slave_committed_queue * gaq
Definition: rpl_rli.h:1199
bool is_relay_log_truncated()
Definition: rpl_rli.h:836
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:2000
my_off_t new_group_master_log_pos
Definition: rpl_rli.h:1315
bool clear_info()
Clears from this Relay_log_info object all attribute values that are not to be kept.
Definition: rpl_rli.cc:1997
void clear_until_option()
Definition: rpl_rli.h:1806
ulonglong stats_read_time
Definition: rpl_rli.h:1300
bool is_privilege_checks_user_null() const
Returns whether or not there is no user configured for PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.cc:2983
void set_sql_delay(time_t _sql_delay)
Definition: rpl_rli.h:1699
static const int PRIV_CHECKS_HOSTNAME_LENGTH
Definition: rpl_rli.h:1917
bool is_applier_source_position_info_invalid() const
Returns if the applier positions are marked as being invalid or not.
Definition: rpl_rli.cc:3321
bool is_group_master_log_pos_invalid
Flag that the group_master_log_pos is invalid.
Definition: rpl_rli.h:898
void reset_row_stmt_start_timestamp()
Definition: rpl_rli.h:1736
MYSQL_BIN_LOG relay_log
Definition: rpl_rli.h:331
static const int LINES_IN_RELAY_LOG_INFO_WITH_ID
Definition: rpl_rli.h:1888
bool m_require_row_format
Tells if the slave is only accepting events logged with row based logging.
Definition: rpl_rli.h:812
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:380
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:2006
uint rli_checkpoint_seqno
Definition: rpl_rli.h:1237
uint get_event_relay_log_number()
Definition: rpl_rli.h:1647
bool is_until_satisfied_at_start_slave()
Definition: rpl_rli.h:2060
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:3114
static const int MAXIMUM_LINES_IN_RELAY_LOG_INFO_FILE
Definition: rpl_rli.h:1950
void set_group_master_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1619
volatile my_off_t group_master_log_pos
Definition: rpl_rli.h:751
long mts_worker_underrun_level
Definition: rpl_rli.h:1226
bool is_until_satisfied_before_dispatching_event(const Log_event *ev)
Definition: rpl_rli.h:2064
ulonglong get_group_relay_log_pos()
Definition: rpl_rli.h:1626
void set_group_relay_log_name(const char *log_file_name, size_t len)
Definition: rpl_rli.h:1631
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:938
ulonglong log_space_total
Definition: rpl_rli.h:906
bool is_group_relay_log_name_invalid(const char **errmsg)
Check if group_relay_log_name is in index file.
Definition: rpl_rli.cc:532
Relay_log_info & operator=(const Relay_log_info &info)
const char * get_rpl_log_name() const
Definition: rpl_rli.h:1669
void set_until_option(Until_option *option)
Definition: rpl_rli.h:1800
void finished_processing()
When the processing of a transaction is completed, that timestamp is recorded, the information is cop...
Definition: rpl_rli.h:416
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:3007
int purge_relay_logs(THD *thd, const char **errmsg, bool delete_only=false)
Purges relay logs.
Definition: rpl_rli.cc:1042
bool is_privilege_checks_user_corrupted() const
Returns whether or not the internal data regarding PRIVILEGE_CHECKS_USER is corrupted.
Definition: rpl_rli.cc:2990
bool is_until_satisfied_after_dispatching_event()
Definition: rpl_rli.h:2068
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:3256
void set_group_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1634
const char * get_group_relay_log_name()
Definition: rpl_rli.h:1625
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:3037
const char * get_event_relay_log_name()
Definition: rpl_rli.h:1638
virtual int set_rli_description_event(Format_description_log_event *fdle)
Delete the existing event and set a new one.
Definition: rpl_rli.cc:2396
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:779
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:1189
size_t get_worker_count()
Definition: rpl_rli.h:1320
ulonglong get_group_master_log_pos() const
Definition: rpl_rli.h:1608
const char * get_group_master_log_name_info() const
Definition: rpl_rli.h:1604
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:3132
enum_require_table_primary_key
Identifies what is the replica policy on primary keys in tables.
Definition: rpl_rli.h:269
@ PK_CHECK_ON
The replica enforces tables to have primary keys for a given channel.
Definition: rpl_rli.h:278
@ PK_CHECK_STREAM
The replica sets the value of sql_require_primary_key according to the source replicated value.
Definition: rpl_rli.h:276
@ PK_CHECK_OFF
The replica does not enforce any policy around primary keys.
Definition: rpl_rli.h:280
@ PK_CHECK_GENERATE
The replica generates GIPKs for incoming keyless tables.
Definition: rpl_rli.h:282
@ PK_CHECK_NONE
No policy, used on PFS.
Definition: rpl_rli.h:271
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:385
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:2129
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:445
static constexpr int RLI_FLUSH_NO_OPTION
No flush options given to relay log flush.
Definition: rpl_rli.h:1564
bool sql_thread_kill_accepted
Definition: rpl_rli.h:1726
static const int PRIV_CHECKS_USERNAME_LENGTH
Definition: rpl_rli.h:1905
void slave_close_thread_tables(THD *)
Definition: rpl_rli.cc:1414
enum_priv_checks_status
Set of possible return values for the member methods related to PRIVILEGE_CHECKS_USER management.
Definition: rpl_rli.h:210
@ 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:2038
bool get_flag(enum_state_flag flag)
Get the value of a replication state flag.
Definition: rpl_rli.h:1462
static const int LINES_IN_RELAY_LOG_INFO_WITH_REQUIRE_ROW_FORMAT
Definition: rpl_rli.h:1922
void inc_event_relay_log_pos()
Definition: rpl_rli.h:1019
volatile ulong abort_pos_wait
Definition: rpl_rli.h:930
bool read_info(Rpl_info_handler *from) override
Definition: rpl_rli.cc:2061
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:399
struct timespec stats_begin
Definition: rpl_rli.h:1302
mysql_mutex_t exit_count_lock
Definition: rpl_rli.h:1188
void notify_relay_log_truncated()
Receiver thread notifies that it truncated some data from relay log.
Definition: rpl_rli.cc:2946
uint relay_log_name_to_number(const char *name)
Definition: rpl_rli.cc:2672
Sid_map * get_sid_map()
Definition: rpl_rli.h:838
time_t last_event_start_time
Definition: rpl_rli.h:1122
ulonglong get_event_relay_log_pos()
Definition: rpl_rli.h:1639
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:2659
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:2596
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:3292
static const int LINES_IN_RELAY_LOG_INFO_WITH_PRIV_CHECKS_USERNAME
Definition: rpl_rli.h:1900
ulonglong mts_pending_jobs_size
Definition: rpl_rli.h:1190
Format_description_log_event * rli_description_event
Definition: rpl_rli.h:1834
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:437
void set_group_relay_log_name(const char *log_file_name)
Definition: rpl_rli.h:1627
int thd_tx_priority
Definition: rpl_rli.h:1994
ulonglong group_source_log_end_pos
Definition: rpl_rli.h:733
my_off_t new_group_relay_log_pos
Definition: rpl_rli.h:1317
void clear_relay_log_truncated()
Applier clears the flag after it handled the situation.
Definition: rpl_rli.cc:2952
enum Relay_log_info::@153 mts_group_status
Replication_transaction_boundary_parser transaction_parser
Definition: rpl_rli.h:649
char slave_patternload_file[FN_REFLEN]
Definition: rpl_rli.h:981
ulong mts_recovery_index
Definition: rpl_rli.h:1243
void unset_long_find_row_note_printed()
Definition: rpl_rli.h:1740
mysql_mutex_t mts_temp_table_LOCK
Definition: rpl_rli.h:311
bool deferred_events_collecting
Definition: rpl_rli.h:1139
bool m_relay_log_truncated
It will be set to true when receiver truncated relay log for some reason.
Definition: rpl_rli.h:786
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:1390
time_t last_master_timestamp
Definition: rpl_rli.h:916
bool is_parallel_exec() const
returns true if events are to be executed in parallel
Definition: rpl_rli.h:1378
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:778
malloc_unordered_map< std::string, unique_ptr_with_deleter< db_worker_hash_entry > > mapping_db_to_worker
Definition: rpl_rli.h:1155
bool error_on_rli_init_info
Definition: rpl_rli.h:457
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:2975
static const int LINES_IN_RELAY_LOG_INFO_WITH_DELAY
Definition: rpl_rli.h:1877
Master_info * mi
Definition: rpl_rli.h:349
std::atomic< bool > sql_force_rotate_relay
Definition: rpl_rli.h:914
std::string m_privilege_checks_username
The user name part of the user passed on to PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.h:791
bool is_processing_trx()
Definition: rpl_rli.h:421
bool is_row_format_required() const
Returns whether the slave is running in row mode only.
Definition: rpl_rli.cc:3297
const Gtid_set * get_gtid_set() const
Definition: rpl_rli.h:858
void cleanup_after_session()
Definition: rpl_rli.h:1429
PSI_mutex_key m_key_mta_temp_table_LOCK
Definition: rpl_rli.h:305
virtual bool commit_positions()
The method implements updating a slave info table.
Definition: rpl_rli.cc:2816
char event_relay_log_name[FN_REFLEN]
Definition: rpl_rli.h:700
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:3307
Slave_worker_array workers
Definition: rpl_rli.h:1150
bool get_allow_drop_write_set()
Definition: rpl_rli.h:2056
ulonglong future_event_relay_log_pos
Definition: rpl_rli.h:704
Commit_order_manager * commit_order_mngr
Definition: rpl_rli.h:1842
struct timespec ts_exec[2]
Definition: rpl_rli.h:1301
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:2979
void set_group_source_log_start_end_pos(const Log_event *ev)
Process an event and based on its type () set group beginning and end.
Definition: rpl_rli.cc:2920
Gtid_monitoring_info * get_gtid_monitoring_info()
Definition: rpl_rli.h:370
char new_group_relay_log_name[FN_REFLEN]
Definition: rpl_rli.h:1316
void set_event_relay_log_name(const char *log_file_name)
Definition: rpl_rli.h:1640
void set_applier_source_position_info_invalid(bool invalid)
Marks the applier position information as being invalid or not.
Definition: rpl_rli.cc:3317
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:598
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:3301
void reattach_engine_ha_data(THD *thd)
Reattaches the engine ha_data to THD.
Definition: rpl_rli.cc:2805
bool mts_end_group_sets_max_dbs
Definition: rpl_rli.h:1211
time_t sql_delay
Delay slave SQL thread by this amount of seconds.
Definition: rpl_rli.h:1859
mysql_cond_t slave_worker_hash_cond
Definition: rpl_rli.h:1159
Relay_log_info(const Relay_log_info &info)
Slave_worker * last_assigned_worker
Definition: rpl_rli.h:1194
ulong recovery_parallel_workers
Definition: rpl_rli.h:1236
@ UNTIL_SQL_VIEW_ID
Definition: rpl_rli.h:951
@ UNTIL_MASTER_POS
Definition: rpl_rli.h:946
@ UNTIL_NONE
Definition: rpl_rli.h:945
@ UNTIL_SQL_BEFORE_GTIDS
Definition: rpl_rli.h:948
@ UNTIL_SQL_AFTER_GTIDS
Definition: rpl_rli.h:949
@ UNTIL_SQL_AFTER_MTS_GAPS
Definition: rpl_rli.h:950
@ UNTIL_DONE
Definition: rpl_rli.h:952
@ UNTIL_RELAY_POS
Definition: rpl_rli.h:947
ulonglong mts_pending_jobs_size_max
Definition: rpl_rli.h:1191
bool get_table_data(TABLE *table_arg, table_def **tabledef_var, TABLE **conv_table_var) const
Definition: rpl_rli.h:1086
enum_mts_parallel_type channel_mts_submode
Definition: rpl_rli.h:1351
void set_event_relay_log_number(uint number)
Definition: rpl_rli.h:1648
mysql_mutex_t mts_gaq_LOCK
Definition: rpl_rli.h:316
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:2606
It is used to record the original query for the rows events in RBR.
Definition: log_event.h:3568
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:52
Represents a bidirectional map between SID and SIDNO.
Definition: rpl_gtid.h:734
Checkable_rwlock * get_sid_lock() const
Return the sid_lock.
Definition: rpl_gtid.h:837
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:3724
bool slave_thread
Definition: sql_class.h:2698
Relay_log_info * rli_slave
Definition: sql_class.h:1060
enum enum_thread_type system_thread
Definition: sql_class.h:2491
System_variables variables
Definition: sql_lexer_thd.h:61
bool is_commit_in_middle_of_statement
Definition: sql_class.h:3882
bool is_operating_substatement_implicitly
Definition: sql_class.h:2314
Table_ref * next_global
Definition: table.h:3494
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:1020
unsigned long long int immediate_commit_timestamp
Timestamp when the transaction was committed on the nearest master.
Definition: control_events.h:1022
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:709
uint sql_replica_skip_counter
a copy of active_mi->rli->slave_skip_counter, for showing in SHOW GLOBAL VARIABLES,...
Definition: rpl_replica.cc:8774
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:3673
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:724
Binary log event definitions.
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:44
Instrumentation helpers for conditions.
ABI for instrumented mutexes.
@ QUERY_EVENT
Definition: binlog_event.h:288
static PFS_engine_table_share_proxy table
Definition: pfs.cc:60
const std::string charset("charset")
static bool timeout(bool(*wait_condition)())
Timeout function.
Definition: log0meb.cc:497
std::vector< T, ut::allocator< T > > vector
Specialization of vector which uses allocator.
Definition: ut0new.h:2873
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:122
int rpl_sidno
Type of SIDNO (source ID number, first component of GTID)
Definition: rpl_gtid.h:96
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:103
@ ASSIGNED_GTID
Specifies that the transaction has been assigned a GTID (UUID:NUMBER).
Definition: rpl_gtid.h:3709
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:2967
Prealloced_array< Slave_worker *, 4 > Slave_worker_array
Definition: rpl_rli.h:79
struct slave_job_item Slave_job_item
bool is_mts_worker(const THD *thd)
Definition: rpl_rli.h:2175
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:2191
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:2223
bool mysql_show_relaylog_events(THD *thd)
Execute a SHOW RELAYLOG EVENTS statement.
Definition: rpl_rli.cc:1457
bool is_mts_db_partitioned(Relay_log_info *rli)
Auxiliary function to check if we have a db partitioned MTS.
Definition: rpl_rli.cc:2676
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
char * strmake(char *dst, const char *src, size_t length)
Definition: strmake.cc:41
TODO: Move this structure to libbinlogevents/include/control_events.h when we start using C++11.
Definition: rpl_gtid.h:1076
rpl_sidno sidno
SIDNO of this Gtid.
Definition: rpl_gtid.h:1078
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:770
LEX_CSTRING db
Definition: table.h:769
TABLE_SHARE * s
Definition: table.h:1395
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:82
my_off_t relay_pos
Definition: rpl_rli.h:84
uint relay_number
Definition: rpl_rli.h:83
static bool update_timestamp(THD *thd, set_var *var)
Definition: sys_vars.cc:5593
@ 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.
int n
Definition: xcom_base.cc:508