122 const char *assign_gtids_to_anonymous_transactions_value);
305#ifdef HAVE_PSI_INTERFACE
387 ulonglong immediate_ts_arg,
bool skipped =
false) {
447 const char *transient_err_message_arg,
448 ulong trans_retries_arg) {
450 transient_errno_arg, transient_err_message_arg, trans_retries_arg);
518 char const *param_privilege_checks_username,
519 char const *param_privilege_checks_hostname);
544 char const *param_privilege_checks_username,
545 char const *param_privilege_checks_hostname);
556 char const *param_privilege_checks_username,
557 char const *param_privilege_checks_hostname);
566 std::pair<const char *, const char *>
591 char const *channel_name =
nullptr,
592 char const *user_name =
nullptr,
593 char const *host_name =
nullptr)
const;
889 const char *buff_coord)
const;
997 down_cast<Until_position *>(
until_option)->notify_log_name_change();
1017 down_cast<Until_position *>(
until_option)->notify_log_name_change();
1032 bool force =
false);
1049 bool update_THD_status =
true);
1063 bool update_THD_status =
true);
1077 bool update_THD_status =
true);
1088 TABLE **conv_table_var)
const {
1089 assert(tabledef_var && conv_table_var);
1092 if (ptr->table == table_arg) {
1093 *tabledef_var = &
static_cast<RPL_Table_ref *
>(ptr)->m_tabledef;
1094 *conv_table_var =
static_cast<RPL_Table_ref *
>(ptr)->m_conv_table;
1095 DBUG_PRINT(
"debug", (
"Fetching table data for table %s.%s:"
1096 " tabledef: %p, conv_table: %p",
1098 *tabledef_var, *conv_table_var));
1287 std::atomic<longlong>
1486 DBUG_PRINT(
"info", (
"is_in_stmt()=%d", ret));
1500 DBUG_PRINT(
"info", (
"is_in_trx_or_stmt()=%d", ret));
1531 DBUG_PRINT(
"info", (
"is_in_group()=%d", ret));
1559 int rli_init_info(
bool skip_received_gtid_set_recovery =
false);
1712 uint param_id,
const char *param_channel,
bool is_rli_fake);
1766 ulong current_version);
2228 if (!rli)
return false;
2238 ->has_ddl_committed) &&
2435 std::vector<std::tuple<ulong, TABLE const *, Rows_log_event *>>
2436 &extra_privileges)
const;
2450 std::initializer_list<std::string_view> extra_privileges)
const;
2464 bool has_access(std::initializer_list<ulong> extra_privileges)
const;
2517 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:2385
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:3532
virtual ~Applier_security_context_guard()
Destructor that restores the backed up security context, if needed.
Definition: rpl_rli.cc:3450
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:3399
bool skip_priv_checks() const
Returns whether or not privilege checks may be skipped within the current context.
Definition: rpl_rli.cc:3458
Security_context m_applier_security_ctx
Applier security context based on PRIVILEGE_CHECK_USER user.
Definition: rpl_rli.h:2506
bool m_privilege_checks_none
Flag that states if privilege check should be skipped.
Definition: rpl_rli.h:2512
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:3520
THD const * m_thd
The THD object for which the security context will be initialized.
Definition: rpl_rli.h:2504
Security_context * m_previous
Backed up security context.
Definition: rpl_rli.h:2510
Security_context * m_current
Currently in use security context.
Definition: rpl_rli.h:2508
bool m_logged_in_acl_user
Flag that states if there is a logged user.
Definition: rpl_rli.h:2514
std::string get_hostname() const
Returns the hostname for the user for which the security context was initialized.
Definition: rpl_rli.cc:3526
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:3486
Relay_log_info const * m_target
The Relay_log_info object holding the info required to initialize the context.
Definition: rpl_rli.h:2500
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:93
bool set_info(enum_type assign_gtids_to_anonymous_transactions_type, const char *assign_gtids_to_anonymous_transactions_value)
Definition: rpl_rli.cc:3330
rpl_sidno m_sidno
Definition: rpl_rli.h:130
enum_type get_type() const
Definition: rpl_rli.cc:3326
enum_type m_type
This stores the type of Assign_gtids_to_anonymous_transactions info.
Definition: rpl_rli.h:126
Assign_gtids_to_anonymous_transactions_info()
The default constructor initializes parameters to their default value.
Definition: rpl_rli.h:110
std::string m_value
Stores the UUID in case the m_type is not OFF.
Definition: rpl_rli.h:128
enum_type
This accepted value of the type of the Assign_gtids_to_anonymous_transactions info OFF : Anonymous gt...
Definition: rpl_rli.h:106
rpl_sidno get_sidno() const
Definition: rpl_rli.h:114
std::string get_value() const
Definition: rpl_rli.cc:3321
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:546
On a replica and only on a replica, this class is responsible for committing the applied transactions...
Definition: rpl_replica_commit_order_manager.h:197
Definition: rpl_utility.h:524
void rewind()
Definition: rpl_utility.cc:1301
This is a subclass if Gtid_event and Log_event.
Definition: log_event.h:3802
rpl_gno get_gno() const override
Return the GNO for this GTID.
Definition: log_event.h:3945
rpl_sidno get_sidno(bool need_lock)
Return the SIDNO relative to the global sid_map for this GTID.
Definition: log_event.cc:13503
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:3909
Stores information to monitor a transaction during the different replication stages.
Definition: rpl_gtid.h:1311
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:1455
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:1517
Sid_map * get_sid_map() const
Return the Sid_map associated with this Gtid_set.
Definition: rpl_gtid.h:1887
This is the abstract base class for binary log events.
Definition: log_event.h:541
virtual Log_event_type get_type_code() const
Definition: log_event.h:798
Utility class to allow RAII pattern with MDL_request and MDL_context classes.
Definition: rpl_rli.h:2281
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:3371
bool is_locked()
Returns whether or not the lock as been acquired within this object life-cycle.
Definition: rpl_rli.cc:3397
THD * m_target
The THD object holding the MDL context used for acquiring/releasing.
Definition: rpl_rli.h:2346
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:3361
MDL_request m_request
The MDL request holding the MDL ticket issued upon acquisition.
Definition: rpl_rli.h:2348
virtual ~MDL_lock_guard()
Destructor that unlocks all acquired locks.
Definition: rpl_rli.cc:3390
A pending metadata lock request.
Definition: mdl.h:801
Definition: rpl_mta_submode.h:55
bool empty() const
Definition: prealloced_array.h:226
size_t size() const
Definition: prealloced_array.h:227
A Query event is written to the binary log whenever the database is modified on the master,...
Definition: log_event.h:1284
RAII class to control the slave applier execution context binding with a being handled event.
Definition: rpl_rli.h:2263
Relay_log_info * m_rli
Definition: rpl_rli.h:2264
void set_current_event(Log_event *ev)
Definition: rpl_rli.h:2271
~RLI_current_event_raii()
Definition: rpl_rli.h:2272
RLI_current_event_raii(Relay_log_info *rli_arg, Log_event *ev)
Definition: rpl_rli.h:2267
Definition: rpl_rli.h:203
bool curr_group_seen_begin
Definition: rpl_rli.h:1210
uint checkpoint_group
Definition: rpl_rli.h:1240
static constexpr int RLI_FLUSH_IGNORE_SYNC_OPT
Ignore server sync options and flush.
Definition: rpl_rli.h:1565
static const int LINES_IN_RELAY_LOG_INFO_WITH_WORKERS
Definition: rpl_rli.h:1881
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:1965
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:825
Prealloced_array< Slave_job_item, 8 > curr_group_da
Definition: rpl_rli.h:1207
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:3084
Format_description_log_event * get_rli_description_event() const
Return the current Format_description_log_event.
Definition: rpl_rli.h:1757
ulonglong group_source_log_start_pos
Definition: rpl_rli.h:730
ulonglong mts_events_assigned
Definition: rpl_rli.h:1276
char cached_charset[6]
Definition: rpl_rli.h:956
volatile uint32 slave_skip_counter
Definition: rpl_rli.h:930
std::atomic< int32 > atomic_channel_open_temp_tables
Definition: rpl_rli.h:353
TABLE * save_temporary_tables
Definition: rpl_rli.h:347
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:2938
int stmt_done(my_off_t event_log_pos)
Helper function to do after statement completion.
Definition: rpl_rli.cc:1234
ulong wq_size_waits_cnt
Definition: rpl_rli.h:1280
mysql_cond_t log_space_cond
Definition: rpl_rli.h:933
ulonglong get_group_master_log_pos_info() const
Definition: rpl_rli.h:1610
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:514
void set_event_start_pos(my_off_t pos)
Definition: rpl_rli.h:1662
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:1529
bool cached_charset_compare(char *charset) const
Definition: rpl_rli.cc:1224
int count_relay_log_space()
Definition: rpl_rli.cc:493
int flush_current_log()
Definition: rpl_rli.cc:1864
ulonglong max_updated_index
Definition: rpl_rli.h:1236
Rows_query_log_event * rows_query_ev
Definition: rpl_rli.h:1085
bool is_long_find_row_note_printed()
Definition: rpl_rli.h:1743
void notify_relay_log_change()
Invalidates cached until_log_name and event_relay_log_name comparison result.
Definition: rpl_rli.h:995
int init_until_option(THD *thd, const LEX_MASTER_INFO *master_param)
Initialize until option object when starting slave.
Definition: rpl_rli.cc:2711
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:2301
bool is_in_trx_or_stmt() const
Auxiliary function used by is_in_group.
Definition: rpl_rli.h:1498
void set_filter(Rpl_filter *channel_filter)
Set replication filter for the channel.
Definition: rpl_rli.h:1828
volatile ulong pending_jobs
Definition: rpl_rli.h:1186
volatile long mts_wq_excess_cnt
Definition: rpl_rli.h:1226
bool curr_group_seen_gtid
Definition: rpl_rli.h:1209
Gtid_set * gtid_set
Definition: rpl_rli.h:755
ulong mts_wq_no_underrun_cnt
Definition: rpl_rli.h:1286
const char * get_group_master_log_name() const
Definition: rpl_rli.h:1600
MY_BITMAP recovery_groups
Definition: rpl_rli.h:1241
table_mapping m_table_map
Definition: rpl_rli.h:1083
ulong mts_slave_worker_queue_len_max
Definition: rpl_rli.h:1190
static const int LINES_IN_RELAY_LOG_INFO_WITH_CHANNEL
Definition: rpl_rli.h:1892
mysql_cond_t logical_clock_cond
Definition: rpl_rli.h:318
bool is_in_stmt() const
Auxiliary function used by is_in_group.
Definition: rpl_rli.h:1484
ulonglong mts_groups_assigned
Definition: rpl_rli.h:1277
bool reinit_sql_thread_io_cache(const char *log, bool need_data_lock)
@ COMMIT_TS_FOUND
Definition: rpl_rli.h:365
@ COMMIT_TS_NOT_FOUND
Definition: rpl_rli.h:363
@ COMMIT_TS_UNKNOWN
Definition: rpl_rli.h:361
@ MTS_KILLED_GROUP
Definition: rpl_rli.h:1270
@ MTS_NOT_IN_GROUP
Definition: rpl_rli.h:1266
@ MTS_IN_GROUP
Definition: rpl_rli.h:1268
@ MTS_END_GROUP
Definition: rpl_rli.h:1269
void close_temporary_tables()
Definition: rpl_rli.cc:1006
ulong retried_trans
Definition: rpl_rli.h:965
struct timespec last_clock
Identifies the last time a checkpoint routine has been executed.
Definition: rpl_rli.h:988
Checkable_rwlock * get_sid_lock()
Definition: rpl_rli.h:841
void detach_engine_ha_data(THD *thd)
Detaches the engine ha_data from THD.
Definition: rpl_rli.cc:2791
mysql_mutex_t pending_jobs_lock
Definition: rpl_rli.h:1187
bool inited_hash_workers
Definition: rpl_rli.h:1157
void set_event_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1665
ulonglong group_relay_log_pos
Definition: rpl_rli.h:700
uchar slave_version_split[3]
Definition: rpl_rli.h:1767
ulong mts_coordinator_basic_nap
Definition: rpl_rli.h:1229
bool group_source_log_seen_start_pos
Event group beginning event has been seen.
Definition: rpl_rli.h:726
size_t slave_patternload_file_size
Definition: rpl_rli.h:983
char ign_master_log_name_end[FN_REFLEN]
Definition: rpl_rli.h:975
bool recovery_groups_inited
Definition: rpl_rli.h:1242
ulonglong event_relay_log_pos
Definition: rpl_rli.h:704
void end_info()
Definition: rpl_rli.cc:1844
bool rli_fake
Definition: rpl_rli.h:763
ulong opt_replica_parallel_workers
Definition: rpl_rli.h:1231
void set_allow_drop_write_set(bool does_not_require_ws)
Definition: rpl_rli.h:2051
std::atomic< longlong > mts_total_wait_overlap
Definition: rpl_rli.h:1288
time_t get_sql_delay()
Definition: rpl_rli.h:1697
void clear_gtid_monitoring_info()
Clears the Gtid_monitoring_info fields.
Definition: rpl_rli.h:435
char group_master_log_name[FN_REFLEN]
Definition: rpl_rli.h:751
void clear_mts_recovery_groups()
Definition: rpl_rli.h:1366
Prealloced_array< db_worker_hash_entry *, 4 > curr_group_assigned_parts
Definition: rpl_rli.h:1205
const char * get_for_channel_str(bool upper_case=false) const override
Definition: rpl_rli.cc:2676
ulonglong ign_master_log_pos_end
Definition: rpl_rli.h:976
void cleanup_after_query()
Definition: rpl_rli.h:1424
Commit_order_manager * get_commit_order_manager()
Definition: rpl_rli.h:1780
ulong trans_retries
Definition: rpl_rli.h:965
void init_workers(ulong)
The method to invoke at slave threads start.
Definition: rpl_rli.cc:268
~Relay_log_info() override
Definition: rpl_rli.cc:289
uint32 m_flags
Definition: rpl_rli.h:1870
void clear_tables_to_lock()
Definition: rpl_rli.cc:1369
const char * get_until_log_name()
Definition: rpl_rli.cc:2693
void post_rollback()
Execute actions at replicated atomic DLL post rollback time.
Definition: rpl_rli.h:2116
my_off_t event_start_pos
Definition: rpl_rli.h:738
static const int LINES_IN_RELAY_LOG_INFO_WITH_PRIV_CHECKS_HOSTNAME
Definition: rpl_rli.h:1911
bool m_is_engine_ha_data_detached
Definition: rpl_rli.h:2020
static size_t get_number_info_rli_fields()
Definition: rpl_rli.cc:2039
bool reported_unsafe_warning
Definition: rpl_rli.h:1720
static const int LINES_IN_RELAY_LOG_INFO_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_VALUE
Definition: rpl_rli.h:1943
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:3307
RPL_Table_ref * tables_to_lock
Definition: rpl_rli.h:1081
uint64 original_commit_timestamp
Definition: rpl_rli.h:1126
mysql_cond_t pending_jobs_cond
Definition: rpl_rli.h:1188
@ UNTIL_SQL_VIEW_ID
Definition: rpl_rli.h:952
@ UNTIL_MASTER_POS
Definition: rpl_rli.h:947
@ UNTIL_NONE
Definition: rpl_rli.h:946
@ UNTIL_SQL_BEFORE_GTIDS
Definition: rpl_rli.h:949
@ UNTIL_SQL_AFTER_GTIDS
Definition: rpl_rli.h:950
@ UNTIL_SQL_AFTER_MTS_GAPS
Definition: rpl_rli.h:951
@ UNTIL_DONE
Definition: rpl_rli.h:953
@ UNTIL_RELAY_POS
Definition: rpl_rli.h:948
void set_commit_order_manager(Commit_order_manager *mngr)
Definition: rpl_rli.h:1782
std::vector< Slave_worker * > workers_copy_pfs
Definition: rpl_rli.h:1173
static const int LINES_IN_RELAY_LOG_INFO_WITH_REQUIRE_TABLE_PRIMARY_KEY_CHECK
Definition: rpl_rli.h:1928
void set_thd_tx_priority(int priority)
Definition: rpl_rli.h:2039
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:558
volatile ulong mts_wq_overrun_cnt
Definition: rpl_rli.h:1279
enum_return_status add_gtid_set(const Gtid_set *gtid_set)
Adds a GTID set to received GTID set.
Definition: rpl_rli.cc:2683
bool replicate_same_server_id
Definition: rpl_rli.h:326
void add_logged_gtid(rpl_sidno sidno, rpl_gno gno)
Definition: rpl_rli.h:843
bool is_time_for_mta_checkpoint()
Check if it is time to compute MTS checkpoint.
Definition: rpl_rli.cc:2953
void set_flag(enum_state_flag flag)
Set the value of a replication state flag.
Definition: rpl_rli.h:1452
std::string m_privilege_checks_hostname
The host name part of the user passed on to PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.h:797
mysql_mutex_t slave_worker_hash_lock
Definition: rpl_rli.h:1159
ulong exit_counter
Definition: rpl_rli.h:1235
int rli_init_info(bool skip_received_gtid_set_recovery=false)
Initialize the relay log info.
Definition: rpl_rli.cc:1498
void reset_notified_relay_log_change()
While a group is executed by a Worker the relay log can change.
Definition: rpl_rli.cc:349
static void set_nullable_fields(MY_BITMAP *nullable_fields)
Sets bits for columns that are allowed to be NULL.
Definition: rpl_rli.cc:2043
bool m_is_applier_source_position_info_invalid
Are positions invalid.
Definition: rpl_rli.h:834
void set_master_info(Master_info *info)
Definition: rpl_rli.cc:1873
bool gtid_retrieved_initialized
Definition: rpl_rli.h:765
ulonglong stats_exec_time
Definition: rpl_rli.h:1300
bool force_flush_postponed_due_to_split_trans
Definition: rpl_rli.h:1778
volatile ulong mts_wq_underrun_w_id
Definition: rpl_rli.h:1215
void clear_processing_trx()
Clears the processing_trx structure fields.
Definition: rpl_rli.h:430
void deinit_workers()
The method to invoke at slave threads stop.
Definition: rpl_rli.cc:287
void clear_privilege_checks_user()
Clears the info related to the data initialized from PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.cc:2990
my_off_t get_event_start_pos()
Definition: rpl_rli.h:1663
bool get_ignore_write_set_memory_limit()
Definition: rpl_rli.h:2047
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:2863
void start_sql_delay(time_t delay_end)
Indicate that a delay starts.
Definition: rpl_rli.cc:2051
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:1217
static const int LINES_IN_RELAY_LOG_INFO_WITH_ASSIGN_GTIDS_TO_ANONYMOUS_TRANSACTIONS_TYPE
Definition: rpl_rli.h:1935
uint tables_to_lock_count
Definition: rpl_rli.h:1082
std::atomic< bool > ignore_log_space_limit
Definition: rpl_rli.h:908
int get_thd_tx_priority()
Definition: rpl_rli.h:2041
bool mts_recovery_group_seen_begin
Definition: rpl_rli.h:1245
bool long_find_row_note_printed
Definition: rpl_rli.h:1963
Deferred_log_events * deferred_events
Definition: rpl_rli.h:1134
Rpl_filter * rpl_filter
Definition: rpl_rli.h:255
ulong replica_parallel_workers
Definition: rpl_rli.h:1233
ulonglong log_space_limit
Definition: rpl_rli.h:907
Until_option * until_option
Definition: rpl_rli.h:2008
ulonglong mts_total_wait_worker_avail
Definition: rpl_rli.h:1293
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:1929
bool is_relay_log_recovery
Definition: rpl_rli.h:338
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:108
bool workers_array_initialized
Definition: rpl_rli.h:1184
bool write_info(Rpl_info_handler *to) override
Definition: rpl_rli.cc:2309
time_t sql_delay_end
During a delay, specifies the point in time when the delay ends.
Definition: rpl_rli.h:1868
void set_ignore_write_set_memory_limit(bool ignore_limit)
Definition: rpl_rli.h:2043
bool mts_wq_oversize
Definition: rpl_rli.h:1193
bool m_privilege_checks_user_corrupted
Tells whether or not the internal data regarding PRIVILEGE_CHECKS_USER is corrupted.
Definition: rpl_rli.h:804
enum_state_flag
Flags for the state of the replication.
Definition: rpl_rli.h:259
@ IN_STMT
The replication thread is inside a statement.
Definition: rpl_rli.h:261
@ STATE_FLAGS_COUNT
Flag counter.
Definition: rpl_rli.h:264
uint event_relay_log_number
Definition: rpl_rli.h:703
ulong mts_recovery_group_cnt
Definition: rpl_rli.h:1243
time_t row_stmt_start_timestamp
Definition: rpl_rli.h:1962
static constexpr int RLI_FLUSH_IGNORE_GTID_ONLY
Flush disresgarding the value of GTID_ONLY.
Definition: rpl_rli.h:1567
void set_group_master_log_name(const char *log_file_name)
Definition: rpl_rli.h:1614
void clear_flag(enum_state_flag flag)
Clear the value of a replication state flag.
Definition: rpl_rli.h:1468
ulong mts_wq_overfill_cnt
Definition: rpl_rli.h:1294
bool belongs_to_client()
Definition: rpl_rli.h:300
void set_future_event_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1596
bool curr_group_isolated
Definition: rpl_rli.h:1211
void set_long_find_row_note_printed()
Definition: rpl_rli.h:1737
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:2997
char group_relay_log_name[FN_REFLEN]
Event group means a group of events of a transaction.
Definition: rpl_rli.h:699
time_t get_row_stmt_start_timestamp()
Definition: rpl_rli.h:1727
ulonglong get_future_event_relay_log_pos()
Definition: rpl_rli.h:1593
time_t get_sql_delay_end()
Definition: rpl_rli.h:1699
void cleanup_context(THD *, bool)
Definition: rpl_rli.cc:1281
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:1313
Slave_worker * get_worker(size_t n)
Definition: rpl_rli.h:1330
mysql_mutex_t log_space_lock
Definition: rpl_rli.h:932
ulong adapt_to_master_version(Format_description_log_event *fdle)
adaptation for the slave applier to specific master versions.
Definition: rpl_rli.cc:2512
bool is_engine_ha_data_detached()
Checks whether engine ha data is detached from THD.
Definition: rpl_rli.h:2106
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:1364
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:1015
enum_require_row_status
Definition: rpl_rli.h:245
@ 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:291
virtual Relay_log_info * get_c_rli()
Get coordinator's RLI.
Definition: rpl_rli.h:1821
void clear_sql_delay()
Reset the delay.
Definition: rpl_rli.h:923
Log_event * current_event
Reference to being applied event.
Definition: rpl_rli.h:2027
time_t mts_last_online_stat
Definition: rpl_rli.h:1305
my_off_t get_until_log_pos()
Definition: rpl_rli.cc:2702
Mts_submode * current_mts_submode
Definition: rpl_rli.h:1352
time_t set_row_stmt_start_timestamp()
Definition: rpl_rli.h:1729
Slave_committed_queue * gaq
Definition: rpl_rli.h:1200
bool is_relay_log_truncated()
Definition: rpl_rli.h:837
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:1999
my_off_t new_group_master_log_pos
Definition: rpl_rli.h:1314
bool clear_info()
Clears from this Relay_log_info object all attribute values that are not to be kept.
Definition: rpl_rli.cc:1993
void clear_until_option()
Definition: rpl_rli.h:1805
ulonglong stats_read_time
Definition: rpl_rli.h:1301
bool is_privilege_checks_user_null() const
Returns whether or not there is no user configured for PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.cc:2979
void set_sql_delay(time_t _sql_delay)
Definition: rpl_rli.h:1698
static const int PRIV_CHECKS_HOSTNAME_LENGTH
Definition: rpl_rli.h:1916
bool is_applier_source_position_info_invalid() const
Returns if the applier positions are marked as being invalid or not.
Definition: rpl_rli.cc:3317
bool is_group_master_log_pos_invalid
Flag that the group_master_log_pos is invalid.
Definition: rpl_rli.h:899
void reset_row_stmt_start_timestamp()
Definition: rpl_rli.h:1735
MYSQL_BIN_LOG relay_log
Definition: rpl_rli.h:332
static const int LINES_IN_RELAY_LOG_INFO_WITH_ID
Definition: rpl_rli.h:1887
bool m_require_row_format
Tells if the slave is only accepting events logged with row based logging.
Definition: rpl_rli.h:813
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:376
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:2005
uint rli_checkpoint_seqno
Definition: rpl_rli.h:1238
uint get_event_relay_log_number()
Definition: rpl_rli.h:1646
bool is_until_satisfied_at_start_slave()
Definition: rpl_rli.h:2059
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:3110
static const int MAXIMUM_LINES_IN_RELAY_LOG_INFO_FILE
Definition: rpl_rli.h:1949
void set_group_master_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1618
volatile my_off_t group_master_log_pos
Definition: rpl_rli.h:752
long mts_worker_underrun_level
Definition: rpl_rli.h:1227
bool is_until_satisfied_before_dispatching_event(const Log_event *ev)
Definition: rpl_rli.h:2063
ulonglong get_group_relay_log_pos()
Definition: rpl_rli.h:1625
void set_group_relay_log_name(const char *log_file_name, size_t len)
Definition: rpl_rli.h:1630
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:934
ulonglong log_space_total
Definition: rpl_rli.h:907
enum Relay_log_info::@150 until_condition
bool is_group_relay_log_name_invalid(const char **errmsg)
Check if group_relay_log_name is in index file.
Definition: rpl_rli.cc:528
Relay_log_info & operator=(const Relay_log_info &info)
const char * get_rpl_log_name() const
Definition: rpl_rli.h:1668
void set_until_option(Until_option *option)
Definition: rpl_rli.h:1799
void finished_processing()
When the processing of a transaction is completed, that timestamp is recorded, the information is cop...
Definition: rpl_rli.h:417
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:3003
int purge_relay_logs(THD *thd, const char **errmsg, bool delete_only=false)
Purges relay logs.
Definition: rpl_rli.cc:1038
bool is_privilege_checks_user_corrupted() const
Returns whether or not the internal data regarding PRIVILEGE_CHECKS_USER is corrupted.
Definition: rpl_rli.cc:2986
bool is_until_satisfied_after_dispatching_event()
Definition: rpl_rli.h:2067
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:3252
void set_group_relay_log_pos(ulonglong log_pos)
Definition: rpl_rli.h:1633
const char * get_group_relay_log_name()
Definition: rpl_rli.h:1624
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:3033
const char * get_event_relay_log_name()
Definition: rpl_rli.h:1637
virtual int set_rli_description_event(Format_description_log_event *fdle)
Delete the existing event and set a new one.
Definition: rpl_rli.cc:2392
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:780
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:1185
size_t get_worker_count()
Definition: rpl_rli.h:1319
ulonglong get_group_master_log_pos() const
Definition: rpl_rli.h:1607
const char * get_group_master_log_name_info() const
Definition: rpl_rli.h:1603
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:3128
enum_require_table_primary_key
Identifies what is the replica policy on primary keys in tables.
Definition: rpl_rli.h:270
@ PK_CHECK_ON
The replica enforces tables to have primary keys for a given channel.
Definition: rpl_rli.h:279
@ PK_CHECK_STREAM
The replica sets the value of sql_require_primary_key according to the source replicated value.
Definition: rpl_rli.h:277
@ PK_CHECK_OFF
The replica does not enforce any policy around primary keys.
Definition: rpl_rli.h:281
@ PK_CHECK_GENERATE
The replica generates GIPKs for incoming keyless tables.
Definition: rpl_rli.h:283
@ PK_CHECK_NONE
No policy, used on PFS.
Definition: rpl_rli.h:272
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:386
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:2128
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:446
static constexpr int RLI_FLUSH_NO_OPTION
No flush options given to relay log flush.
Definition: rpl_rli.h:1563
bool sql_thread_kill_accepted
Definition: rpl_rli.h:1725
static const int PRIV_CHECKS_USERNAME_LENGTH
Definition: rpl_rli.h:1904
void slave_close_thread_tables(THD *)
Definition: rpl_rli.cc:1410
enum_priv_checks_status
Set of possible return values for the member methods related to PRIVILEGE_CHECKS_USER management.
Definition: rpl_rli.h:211
@ 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.
enum Relay_log_info::@149 commit_timestamps_status
the status of the commit timestamps for the relay log
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:2037
bool get_flag(enum_state_flag flag)
Get the value of a replication state flag.
Definition: rpl_rli.h:1461
static const int LINES_IN_RELAY_LOG_INFO_WITH_REQUIRE_ROW_FORMAT
Definition: rpl_rli.h:1921
void inc_event_relay_log_pos()
Definition: rpl_rli.h:1020
volatile ulong abort_pos_wait
Definition: rpl_rli.h:931
bool read_info(Rpl_info_handler *from) override
Definition: rpl_rli.cc:2057
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:400
struct timespec stats_begin
Definition: rpl_rli.h:1303
mysql_mutex_t exit_count_lock
Definition: rpl_rli.h:1189
void notify_relay_log_truncated()
Receiver thread notifies that it truncated some data from relay log.
Definition: rpl_rli.cc:2942
uint relay_log_name_to_number(const char *name)
Definition: rpl_rli.cc:2668
Sid_map * get_sid_map()
Definition: rpl_rli.h:839
time_t last_event_start_time
Definition: rpl_rli.h:1123
ulonglong get_event_relay_log_pos()
Definition: rpl_rli.h:1638
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:2655
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:2592
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:3288
static const int LINES_IN_RELAY_LOG_INFO_WITH_PRIV_CHECKS_USERNAME
Definition: rpl_rli.h:1899
ulonglong mts_pending_jobs_size
Definition: rpl_rli.h:1191
Format_description_log_event * rli_description_event
Definition: rpl_rli.h:1833
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:433
void set_group_relay_log_name(const char *log_file_name)
Definition: rpl_rli.h:1626
int thd_tx_priority
Definition: rpl_rli.h:1993
ulonglong group_source_log_end_pos
Definition: rpl_rli.h:734
my_off_t new_group_relay_log_pos
Definition: rpl_rli.h:1316
void clear_relay_log_truncated()
Applier clears the flag after it handled the situation.
Definition: rpl_rli.cc:2948
Replication_transaction_boundary_parser transaction_parser
Definition: rpl_rli.h:650
char slave_patternload_file[FN_REFLEN]
Definition: rpl_rli.h:982
ulong mts_recovery_index
Definition: rpl_rli.h:1244
void unset_long_find_row_note_printed()
Definition: rpl_rli.h:1739
mysql_mutex_t mts_temp_table_LOCK
Definition: rpl_rli.h:312
bool deferred_events_collecting
Definition: rpl_rli.h:1140
bool m_relay_log_truncated
It will be set to true when receiver truncated relay log for some reason.
Definition: rpl_rli.h:787
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:1389
time_t last_master_timestamp
Definition: rpl_rli.h:917
bool is_parallel_exec() const
returns true if events are to be executed in parallel
Definition: rpl_rli.h:1377
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:774
malloc_unordered_map< std::string, unique_ptr_with_deleter< db_worker_hash_entry > > mapping_db_to_worker
Definition: rpl_rli.h:1156
bool error_on_rli_init_info
Definition: rpl_rli.h:458
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:2971
static const int LINES_IN_RELAY_LOG_INFO_WITH_DELAY
Definition: rpl_rli.h:1876
Master_info * mi
Definition: rpl_rli.h:350
std::atomic< bool > sql_force_rotate_relay
Definition: rpl_rli.h:915
std::string m_privilege_checks_username
The user name part of the user passed on to PRIVILEGE_CHECKS_USER.
Definition: rpl_rli.h:792
bool is_processing_trx()
Definition: rpl_rli.h:422
bool is_row_format_required() const
Returns whether the slave is running in row mode only.
Definition: rpl_rli.cc:3293
const Gtid_set * get_gtid_set() const
Definition: rpl_rli.h:859
void cleanup_after_session()
Definition: rpl_rli.h:1428
PSI_mutex_key m_key_mta_temp_table_LOCK
Definition: rpl_rli.h:306
virtual bool commit_positions()
The method implements updating a slave info table.
Definition: rpl_rli.cc:2812
char event_relay_log_name[FN_REFLEN]
Definition: rpl_rli.h:701
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:3303
Slave_worker_array workers
Definition: rpl_rli.h:1151
bool get_allow_drop_write_set()
Definition: rpl_rli.h:2055
ulonglong future_event_relay_log_pos
Definition: rpl_rli.h:705
Commit_order_manager * commit_order_mngr
Definition: rpl_rli.h:1841
enum Relay_log_info::@151 mts_group_status
struct timespec ts_exec[2]
Definition: rpl_rli.h:1302
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:2975
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:2916
Gtid_monitoring_info * get_gtid_monitoring_info()
Definition: rpl_rli.h:371
char new_group_relay_log_name[FN_REFLEN]
Definition: rpl_rli.h:1315
void set_event_relay_log_name(const char *log_file_name)
Definition: rpl_rli.h:1639
void set_applier_source_position_info_invalid(bool invalid)
Marks the applier position information as being invalid or not.
Definition: rpl_rli.cc:3313
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:594
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:3297
void reattach_engine_ha_data(THD *thd)
Reattaches the engine ha_data to THD.
Definition: rpl_rli.cc:2801
bool mts_end_group_sets_max_dbs
Definition: rpl_rli.h:1212
time_t sql_delay
Delay slave SQL thread by this amount of seconds.
Definition: rpl_rli.h:1858
mysql_cond_t slave_worker_hash_cond
Definition: rpl_rli.h:1160
Relay_log_info(const Relay_log_info &info)
Slave_worker * last_assigned_worker
Definition: rpl_rli.h:1195
ulong recovery_parallel_workers
Definition: rpl_rli.h:1237
ulonglong mts_pending_jobs_size_max
Definition: rpl_rli.h:1192
bool get_table_data(TABLE *table_arg, table_def **tabledef_var, TABLE **conv_table_var) const
Definition: rpl_rli.h:1087
enum_mts_parallel_type channel_mts_submode
Definition: rpl_rli.h:1350
void set_event_relay_log_number(uint number)
Definition: rpl_rli.h:1647
mysql_mutex_t mts_gaq_LOCK
Definition: rpl_rli.h:317
This is the class for verifying transaction boundaries in a replication event stream.
Definition: rpl_trx_boundary_parser.h:51
Common base class for all row-containing log events.
Definition: log_event.h:2653
It is used to record the original query for the rows events in RBR.
Definition: log_event.h:3625
Rpl_filter.
Definition: rpl_filter.h:214
Definition: rpl_info_factory.h:44
Definition: rpl_info_handler.h:58
Definition: rpl_info.h:43
mysql_mutex_t data_lock
Definition: rpl_info.h:58
bool is_transactional() const
Definition: rpl_info.h:111
THD * info_thd
Definition: rpl_info.h:78
A set of THD members describing the current authenticated user.
Definition: sql_security_ctx.h:54
Represents a bidirectional map between SID and SIDNO.
Definition: rpl_gtid.h:724
Checkable_rwlock * get_sid_lock() const
Return the sid_lock.
Definition: rpl_gtid.h:827
Group Assigned Queue whose first element identifies first gap in committed sequence.
Definition: rpl_rli_pdb.h:351
Definition: rpl_rli_pdb.h:498
Using this class is fraught with peril, and you need to be very careful when doing so.
Definition: sql_string.h:168
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:34
Gtid owned_gtid
The GTID of the currently owned transaction.
Definition: sql_class.h:3698
bool slave_thread
Definition: sql_class.h:2672
Relay_log_info * rli_slave
Definition: sql_class.h:1051
enum enum_thread_type system_thread
Definition: sql_class.h:2465
System_variables variables
Definition: sql_lexer_thd.h:62
bool is_commit_in_middle_of_statement
Definition: sql_class.h:3856
bool is_operating_substatement_implicitly
Definition: sql_class.h:2288
Table_ref * next_global
Definition: table.h:3484
This is the abstract base class for slave start until options.
Definition: rpl_replica_until_options.h:56
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:97
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:83
bool is_satisfied_at_start_slave()
Check if the until option is already satisfied at coordinator starting.
Definition: rpl_replica_until_options.h:67
unsigned long long int original_commit_timestamp
Timestamp when the transaction was committed on the originating master.
Definition: control_events.h:1021
unsigned long long int immediate_commit_timestamp
Timestamp when the transaction was committed on the nearest master.
Definition: control_events.h:1023
uint16_t error_code
Definition: statement_events.h:560
std::unordered_map, but with my_malloc, so that you can track the memory used using PSI memory keys.
Definition: map_helpers.h:148
A table definition from the master.
Definition: rpl_utility.h:248
Maps table id's (integers) to table pointers.
Definition: rpl_tblmap.h:51
#define mysql_mutex_lock(M)
Definition: mysql_mutex.h:50
#define mysql_mutex_unlock(M)
Definition: mysql_mutex.h:57
#define base_name(A)
Definition: my_sys.h:706
uint sql_replica_skip_counter
a copy of active_mi->rli->slave_skip_counter, for showing in SHOW GLOBAL VARIABLES,...
Definition: rpl_replica.cc:8793
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:3727
unsigned int PSI_mutex_key
Instrumented mutex key.
Definition: psi_mutex_bits.h:52
static int flag
Definition: hp_test1.cc:40
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:746
Binary log event definitions.
char * strmake(char *dst, const char *src, size_t length)
Definition: strmake.cc:43
std::unique_ptr< T, void(*)(T *)> unique_ptr_with_deleter
std::unique_ptr, but with a custom delete function.
Definition: map_helpers.h:89
void bitmap_free(MY_BITMAP *map)
Definition: my_bitmap.cc:158
#define DBUG_PRINT(keyword, arglist)
Definition: my_dbug.h:181
Some integer typedefs for easier portability.
unsigned long long int ulonglong
Definition: my_inttypes.h:56
ulonglong my_off_t
Definition: my_inttypes.h:72
unsigned char uchar
Definition: my_inttypes.h:52
long long int longlong
Definition: my_inttypes.h:55
uint64_t uint64
Definition: my_inttypes.h:69
uint32_t uint32
Definition: my_inttypes.h:67
Common #defines and includes for file and socket I/O.
#define FN_REFLEN
Definition: my_io.h:83
Definition of the global "loglevel" enumeration.
loglevel
Definition: my_loglevel.h:41
Defines various enable/disable and HAVE_ macros related to the performance schema instrumentation sys...
#define HAVE_PSI_INTERFACE
Definition: my_psi_config.h:39
Common header for many mysys elements.
static int count
Definition: myisam_ftdump.cc:43
Instrumentation helpers for conditions.
ABI for instrumented mutexes.
@ QUERY_EVENT
Definition: binlog_event.h:289
const std::string charset("charset")
static bool timeout(bool(*wait_condition)())
Timeout function.
Definition: log0meb.cc:496
std::vector< T, ut::allocator< T > > vector
Specialization of vector which uses allocator.
Definition: ut0new.h:2874
Instrumentation helpers for mutexes.
PSI_memory_key key_memory_db_worker_hash_entry
Definition: psi_memory_key.cc:104
Instrumentation helpers for mutexes.
#define OPTION_BEGIN
Definition: query_options.h:75
required uint32 status
Definition: replication_asynchronous_connection_failover.proto:61
required uint32 priority
Definition: replication_group_member_actions.proto:35
required string event
Definition: replication_group_member_actions.proto:32
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:3699
enum_return_check
Definition: rpl_info_handler.h:51
enum_mts_parallel_type
Definition: rpl_mta_submode.h:47
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:2963
Prealloced_array< Slave_worker *, 4 > Slave_worker_array
Definition: rpl_rli.h:80
struct slave_job_item Slave_job_item
bool is_mts_worker(const THD *thd)
Definition: rpl_rli.h:2174
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:2190
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:2222
bool mysql_show_relaylog_events(THD *thd)
Execute a SHOW RELAYLOG EVENTS statement.
Definition: rpl_rli.cc:1453
bool is_mts_db_partitioned(Relay_log_info *rli)
Auxiliary function to check if we have a db partitioned MTS.
Definition: rpl_rli.cc:2672
Replication transaction boundary parser.
enum_mdl_type
Type of metadata lock request.
Definition: sql_lexer_yacc_state.h:106
case opt name
Definition: sslopt-case.h:33
TODO: Move this structure to libbinlogevents/include/control_events.h when we start using C++11.
Definition: rpl_gtid.h:1066
rpl_sidno sidno
SIDNO of this Gtid.
Definition: rpl_gtid.h:1068
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:400
const char * str
Definition: mysql_lex_string.h:41
Definition: my_bitmap.h:43
Extend the normal Table_ref with a few new fields needed by the slave thread, but nowhere else.
Definition: rpl_utility.h:512
LEX_CSTRING table_name
Definition: table.h:774
LEX_CSTRING db
Definition: table.h:773
TABLE_SHARE * s
Definition: table.h:1399
Legends running throughout the module:
Definition: rpl_rli_pdb.h:74
An instrumented cond structure.
Definition: mysql_cond_bits.h:50
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:50
Log_event * data
Definition: rpl_rli.h:83
my_off_t relay_pos
Definition: rpl_rli.h:85
uint relay_number
Definition: rpl_rli.h:84
static bool update_timestamp(THD *thd, set_var *var)
Definition: sys_vars.cc:5620
@ SYSTEM_THREAD_SLAVE_WORKER
Definition: thread_type.h:42
@ SYSTEM_THREAD_SLAVE_SQL
Definition: thread_type.h:37
Include file for Sun RPC to compile out of the box.
unsigned int uint
Definition: uca9-dump.cc:75
int n
Definition: xcom_base.cc:509