1#ifndef BINLOG_H_INCLUDED
24#define BINLOG_H_INCLUDED
66class Transaction_boundary_parser;
80#define MAX_LOG_UNIQUE_FN_EXT 0x7FFFFFFF
86#define MAX_ALLOWED_FN_EXT_RESET_MASTER 2000000000
98#define LOG_INFO_EOF -1
100#define LOG_INFO_INVALID -3
101#define LOG_INFO_SEEK -4
102#define LOG_INFO_MEM -6
103#define LOG_INFO_FATAL -7
104#define LOG_INFO_IN_USE -8
105#define LOG_INFO_EMFILE -9
106#define LOG_INFO_BACKUP_LOCK -10
107#define LOG_INFO_NOT_IN_USE -11
110#define LOG_CLOSE_INDEX 1
111#define LOG_CLOSE_TO_BE_OPENED 2
112#define LOG_CLOSE_STOP_EVENT 4
295 const char *new_name,
uint32 new_index_number);
299 uint32 new_index_number = 0);
317 const char *
generate_name(
const char *log_name,
const char *suffix,
417 bool find_first_log(std::string &binlog_file_name, std::string &errmsg);
433 Gtid *first_gtid, std::string &errmsg);
595 const bool check_and_skip_flush_logs =
false);
613 THD **out_queue_var);
690 const char *message);
697 void close()
override;
702#if defined(MYSQL_SERVER)
706 bool is_transactional);
766 bool open_binlog(
const char *log_name,
const char *new_name,
767 ulong max_size_arg,
bool null_created_arg,
768 bool need_lock_index,
bool need_tsid_lock,
770 uint32 new_index_number = 0);
771 bool open_index_file(
const char *index_file_name_arg,
const char *log_name,
772 bool need_lock_index);
811 bool do_flush_and_sync =
true);
813 const char *err_msg,
bool do_flush_and_sync =
true);
860 int rotate(
bool force_rotate,
bool *check_purge);
895 int purge_logs(
const char *to_log,
bool included,
bool need_lock_index,
896 bool need_update_threads,
ulonglong *decrease_log_space,
903 bool need_lock_index);
913 bool need_lock_index);
915 void close(uint exiting,
bool need_lock_log,
bool need_lock_index);
936 bool need_lock_index =
true);
970 std::string &errmsg);
993 const Gtid_set *slave_executed_gtid_set,
994 std::string &errmsg);
int destroy(azio_stream *s)
Definition: azio.cc:371
int64 query_id_t
Definition: binlog.h:71
MYSQL_PLUGIN_IMPORT MYSQL_BIN_LOG mysql_bin_log
Contains the classes representing events occurring in the replication stream.
It owns an allocator, a byte stream, an event_data stream and an event object stream.
Definition: binlog_reader.h:294
Byte container that provides a storage for serializing session binlog events.
Definition: binlog_ostream.h:173
Auxiliary class to copy serialized events to the binary log and correct some of the fields that are n...
Definition: binlog.cc:1380
StageID
Constants for queues for different stages.
Definition: rpl_commit_stage_manager.h:165
Stores information to monitor a transaction during the different replication stages.
Definition: rpl_gtid.h:1411
Represents a set of GTIDs.
Definition: rpl_gtid.h:1555
Container to hold and allow iteration over a set of Ha_trx_info objects.
Definition: transaction_info.h:502
Either statement transaction or normal transaction - related thread-specific storage engine data.
Definition: transaction_info.h:402
Class representing an incident, an occurrence out of the ordinary, that happened on the master.
Definition: log_event.h:3593
This is the abstract base class for binary log events.
Definition: log_event.h:537
Logical binlog file which wraps and hides the detail of lower layer storage implementation.
Definition: binlog.cc:380
mysql_mutex_t * get_binlog_end_pos_lock()
Definition: binlog.h:1004
const char * get_name() const
Definition: binlog.h:939
mysql_cond_t m_prep_xids_cond
Definition: binlog.h:251
mysql_mutex_t * get_commit_lock()
Definition: binlog.h:942
mysql_mutex_t LOCK_binlog_end_pos
Definition: binlog.h:207
std::atomic< my_off_t > atomic_binlog_end_pos
Definition: binlog.h:211
void unlock_binlog_end_pos()
Definition: binlog.h:1006
PSI_mutex_key m_key_LOCK_xids
The instrumentation key to use for @ LOCK_xids.
Definition: binlog.h:184
mysql_mutex_t LOCK_commit
Definition: binlog.h:204
char db[NAME_LEN+1]
Definition: binlog.h:149
void set_previous_gtid_set_relaylog(Gtid_set *previous_gtid_set_param)
Definition: binlog.h:466
IO_CACHE crash_safe_index_file
Definition: binlog.h:219
void reset_bytes_written()
Definition: binlog.h:710
void lock_binlog_end_pos()
Definition: binlog.h:1005
enum_log_state
Definition: binlog.h:143
@ LOG_OPENED
Definition: binlog.h:143
@ LOG_CLOSED
Definition: binlog.h:143
@ LOG_TO_BE_OPENED
Definition: binlog.h:143
mysql_mutex_t LOCK_index
Definition: binlog.h:203
PSI_mutex_key m_key_COND_done
The PFS instrumentation key for @ COND_done.
Definition: binlog.h:174
mysql_mutex_t LOCK_sync
Definition: binlog.h:206
PSI_mutex_key m_key_LOCK_after_commit
The instrumentation key to use for @ LOCK_after_commit.
Definition: binlog.h:180
PSI_mutex_key m_key_LOCK_commit_queue
The PFS instrumentation key for @ LOCK_commit_queue.
Definition: binlog.h:162
bool write_event_to_binlog_and_flush(Log_event *ev)
mysql_mutex_t LOCK_after_commit
Definition: binlog.h:205
Binlog_ofile * get_binlog_file()
Definition: binlog.h:945
mysql_mutex_t LOCK_log_info
Definition: binlog.h:1069
int open(const char *opt_name) override
Initialize and open the coordinator log.
Definition: binlog.h:524
mysql_mutex_t * get_log_lock()
Definition: binlog.h:940
bool is_open() const
Definition: binlog.h:319
IO_CACHE purge_index_file
Definition: binlog.h:227
PSI_cond_key m_key_prep_xids_cond
The instrumentation key to use for @ prep_xids_cond.
Definition: binlog.h:190
my_off_t get_binlog_end_pos() const
Definition: binlog.h:1000
void lock_index()
Definition: binlog.h:947
PSI_mutex_key m_key_LOCK_flush_queue
The PFS instrumentation key for @ LOCK_flush_queue.
Definition: binlog.h:168
PSI_mutex_key m_key_LOCK_after_commit_queue
The PFS instrumentation key for @ LOCK_after_commit_queue.
Definition: binlog.h:164
int32 get_prep_xids()
Definition: binlog.h:266
std::atomic< enum_log_state > atomic_log_state
Definition: binlog.h:519
Gtid_set * previous_gtid_set_relaylog
Definition: binlog.h:522
PSI_cond_key m_key_update_cond
The instrumentation key to use for @ update_cond.
Definition: binlog.h:188
void set_psi_keys(PSI_mutex_key key_LOCK_index, PSI_mutex_key key_LOCK_commit, PSI_mutex_key key_LOCK_commit_queue, PSI_mutex_key key_LOCK_after_commit, PSI_mutex_key key_LOCK_after_commit_queue, PSI_mutex_key key_LOCK_done, PSI_mutex_key key_LOCK_flush_queue, PSI_mutex_key key_LOCK_log, PSI_mutex_key key_LOCK_binlog_end_pos, PSI_mutex_key key_LOCK_sync, PSI_mutex_key key_LOCK_sync_queue, PSI_mutex_key key_LOCK_xids, PSI_mutex_key key_LOCK_log_info, PSI_mutex_key key_LOCK_wait_for_group_turn, PSI_cond_key key_COND_done, PSI_cond_key key_COND_flush_queue, PSI_cond_key key_update_cond, PSI_cond_key key_prep_xids_cond, PSI_cond_key key_COND_wait_for_group_turn, PSI_file_key key_file_log, PSI_file_key key_file_log_index, PSI_file_key key_file_log_cache, PSI_file_key key_file_log_index_cache)
Definition: binlog.h:363
char * get_index_fname()
Definition: binlog.h:937
bool write_error
Definition: binlog.h:150
uint * sync_period_ptr
Definition: binlog.h:248
mysql_mutex_t * get_after_commit_lock()
Definition: binlog.h:943
PSI_mutex_key m_key_LOCK_done
The PFS instrumentation key for @ LOCK_done.
Definition: binlog.h:166
std::set< LOG_INFO * > log_info_set
Definition: binlog.h:1072
std::atomic< int32 > m_atomic_prep_xids
Definition: binlog.h:252
Binlog_ofile * m_binlog_file
Definition: binlog.h:151
PSI_mutex_key m_key_LOCK_sync
The instrumentation key to use for @ LOCK_sync.
Definition: binlog.h:182
void add_bytes_written(ulonglong inc)
Definition: binlog.h:709
bool inited
Definition: binlog.h:150
PSI_file_key m_key_file_log_index_cache
The instrumentation key to use for opening a log index cache file.
Definition: binlog.h:200
mysql_mutex_t * get_index_lock()
Definition: binlog.h:941
PSI_mutex_key m_key_LOCK_binlog_end_pos
The instrumentation key to use for @ LOCK_binlog_end_pos.
Definition: binlog.h:160
char index_file_name[FN_REFLEN]
Definition: binlog.h:214
IO_CACHE * get_index_file()
Definition: binlog.h:949
mysql_cond_t * get_log_cond()
Definition: binlog.h:944
mysql_mutex_t LOCK_log
Definition: binlog.h:146
ulong max_size
Definition: binlog.h:239
bool is_relay_log
Definition: binlog.h:322
PSI_mutex_key m_key_LOCK_index
The instrumentation key to use for @ LOCK_index.
Definition: binlog.h:158
uint get_sync_period()
Definition: binlog.h:268
PSI_cond_key m_key_COND_wait_for_group_turn
The PFS instrumentation key for @ COND_wait_for_group_turn.
Definition: binlog.h:192
PSI_mutex_key m_key_LOCK_log
The instrumentation key to use for @ LOCK_log.
Definition: binlog.h:156
PSI_mutex_key m_key_COND_flush_queue
The PFS instrumentation key for @ COND_flush_queue.
Definition: binlog.h:176
uint file_id
Definition: binlog.h:242
ulonglong bytes_written
Definition: binlog.h:212
mysql_cond_t update_cond
Definition: binlog.h:209
PSI_mutex_key m_key_LOCK_commit
The instrumentation key to use for @ LOCK_commit.
Definition: binlog.h:178
PSI_mutex_key m_key_LOCK_wait_for_group_turn
The PFS instrumentation key for @ LOCK_wait_for_group_turn.
Definition: binlog.h:172
void unlock_index()
Definition: binlog.h:948
PSI_file_key m_key_file_log
The instrumentation key to use for opening the log file.
Definition: binlog.h:194
PSI_mutex_key m_key_LOCK_sync_queue
The PFS instrumentation key for @ LOCK_sync_queue.
Definition: binlog.h:170
char * get_log_fname()
Definition: binlog.h:938
char purge_index_file_name[FN_REFLEN]
Definition: binlog.h:228
mysql::binlog::event::enum_binlog_checksum_alg relay_log_checksum_alg
Definition: binlog.h:358
Transaction_dependency_tracker m_dependency_tracker
Manage the MTS dependency tracking.
Definition: binlog.h:407
IO_CACHE index_file
Definition: binlog.h:213
mysql_mutex_t LOCK_xids
Definition: binlog.h:208
PSI_file_key m_key_file_log_cache
The instrumentation key to use for opening a log cache file.
Definition: binlog.h:198
uint sync_counter
Definition: binlog.h:249
PSI_file_key m_log_file_key
Instrumentation key to use for file io in log_file.
Definition: binlog.h:154
bool is_rotating_caused_by_incident
Definition: binlog.h:1027
char * name
Definition: binlog.h:147
char log_file_name[FN_REFLEN]
Definition: binlog.h:148
uint8 checksum_alg_reset
Definition: binlog.h:324
PSI_mutex_key m_key_LOCK_log_info
The instrumentation key to use for @ m_key_LOCK_log_info.
Definition: binlog.h:186
char crash_safe_index_file_name[FN_REFLEN]
Definition: binlog.h:220
static const int MAX_RETRIES_FOR_DELETE_RENAME_FAILURE
Definition: binlog.h:995
PSI_file_key m_key_file_log_index
The instrumentation key to use for opening the log index file.
Definition: binlog.h:196
Definition: rpl_rli.h:202
Common base class for all row-containing log events.
Definition: log_event.h:2763
Transaction Coordinator Log.
Definition: tc_log.h:143
enum_result
Definition: tc_log.h:159
For each client connection we create a separate thread with THD serving as a thread/connection descri...
Definition: sql_lexer_thd.h:35
enum_trx_scope
Definition: transaction_info.h:55
Dependency tracker is a container singleton that dispatches between the three methods associated with...
Definition: rpl_trx_tracking.h:216
Represents a bidirectional map between TSID and SIDNO.
Definition: rpl_gtid.h:748
Caches for non-transactional and transactional data before writing it to the binary log.
Definition: binlog.cc:701
This is the base class for verifying transaction boundaries.
Definition: trx_boundary_parser.h:49
Definition: item_func.h:3012
#define mysql_mutex_lock(M)
Definition: mysql_mutex.h:49
#define mysql_mutex_unlock(M)
Definition: mysql_mutex.h:56
void harvest_bytes_written(Relay_log_info *rli, bool need_log_space_lock)
Definition: binlog.cc:7880
bool mysql_show_binlog_events(THD *thd)
Execute a SHOW BINLOG EVENTS statement.
Definition: binlog.cc:3504
bool stmt_cannot_safely_rollback(const THD *thd)
This function checks if current statement cannot be rollded back safely.
Definition: binlog.cc:3192
bool normalize_binlog_name(char *to, const char *from, bool is_relay_log)
Turns a relative log binary log path into a full path, based on the opt_bin_logname or opt_relay_logn...
Definition: binlog.cc:245
int write_xa_to_cache(THD *thd)
Logging XA commit/rollback of a prepared transaction.
Definition: binlog.cc:2495
std::pair< int, std::list< std::string > > get_log_index(bool need_lock_index=true)
Retrieves the contents of the index file associated with this log object into an std::list<std::strin...
Definition: binlog.cc:5591
int close_purge_index_file()
Definition: binlog.cc:6109
void set_max_size(ulong max_size_arg)
Definition: binlog.cc:7899
ulong rpl_read_size
Definition: binlog.cc:188
int flush_cache_to_file(my_off_t *flush_end_pos)
Flush the I/O cache to file.
Definition: binlog.cc:8731
void report_cache_write_error(THD *thd, bool is_transactional)
Definition: binlog.cc:5387
bool is_transaction_empty(THD *thd)
Check if the the transaction is empty.
Definition: binlog.cc:3083
int log_loaded_block(IO_CACHE *file)
Load data's io cache specific hook to be executed before a chunk of data is being read into the cache...
Definition: binlog.cc:3341
bool trans_cannot_safely_rollback(const THD *thd)
This function checks if a transaction cannot be rolled back safely.
Definition: binlog.cc:3179
THD * fetch_and_process_flush_stage_queue(const bool check_and_skip_flush_logs=false)
Fetch and empty BINLOG_FLUSH_STAGE and COMMIT_ORDER_FLUSH_STAGE flush queues and flush transactions t...
Definition: binlog.cc:8500
int rotate(bool force_rotate, bool *check_purge)
The method executes rotation when LOCK_log is already acquired by the caller.
Definition: binlog.cc:7201
void update_thd_next_event_pos(THD *thd)
Definition: binlog.cc:6974
int find_log_pos(LOG_INFO *linfo, const char *log_name, bool need_lock_index)
Find the position in the log-index-file for the given log name.
Definition: binlog.cc:5436
bool trans_has_updated_trans_table(const THD *thd)
This function checks if a transactional table was updated by the current transaction.
Definition: binlog.cc:3121
void close() override
This is called on shutdown, after ha_panic.
Definition: binlog.cc:8106
int new_file_without_locking(Format_description_log_event *extra_description_event)
Definition: binlog.cc:6501
void report_missing_purged_gtids(const Gtid_set *slave_executed_gtid_set, std::string &errmsg)
Function to report the missing GTIDs.
Definition: binlog.cc:9249
uint next_file_id()
Definition: binlog.cc:7323
void cleanup()
Definition: binlog.cc:3553
int process_flush_stage_queue(my_off_t *total_bytes_var, bool *rotate_var, THD **out_queue_var)
Execute the flush stage.
Definition: binlog.cc:8542
bool do_write_cache(Binlog_cache_storage *cache, class Binlog_event_writer *writer)
Write the contents of the given IO_CACHE to the binary log.
Definition: binlog.cc:7429
int rollback(THD *thd, bool all) override
Write a rollback record of the transaction to the binary log.
Definition: binlog.cc:2644
void init_pthread_objects()
Definition: binlog.cc:3578
bool reencrypt_logs()
Re-encrypt previous existent binary/relay logs as below.
Definition: binlog.cc:1905
void unregister_log_info(LOG_INFO *log_info)
Unregister LOG_INFO when it is no longer needed.
Definition: binlog.cc:7360
int log_in_use(const char *log_name)
Check if any threads use log name.
Definition: binlog.cc:7366
const char * log_bin_index
Definition: binlog.cc:184
int open_binlog(const char *opt_name)
Definition: binlog.cc:7945
~MYSQL_BIN_LOG() override
Definition: binlog.cc:3549
bool binlog_enabled()
Check whether binlog_hton has valid slot and enabled.
Definition: binlog.cc:1332
bool is_empty_transaction_in_binlog_cache(const THD *thd)
Check if at least one of transacaction and statement binlog caches contains an empty transaction,...
Definition: binlog.cc:3102
int register_purge_index_entry(const char *entry)
Definition: binlog.cc:6140
int sync_purge_index_file()
Definition: binlog.cc:6129
int get_gtid_executed(Tsid_map *tsid_map, Gtid_set *gtid_set)
Deep copy global_tsid_map and gtid_executed.
Definition: binlog.cc:7331
int gtid_end_transaction(THD *thd)
If the thread owns a GTID, this function generates an empty transaction and releases ownership of the...
Definition: binlog.cc:1784
void register_log_info(LOG_INFO *log_info)
Register LOG_INFO so that log_in_use and adjust_linfo_offsets can operate on all logs.
Definition: binlog.cc:7354
int set_purge_index_file_name(const char *base_file_name)
Definition: binlog.cc:6074
void process_commit_stage_queue(THD *thd, THD *queue)
Commit a sequence of sessions.
Definition: binlog.cc:8599
void register_binlog_handler(THD *thd, bool trx)
Definition: binlog.cc:9465
bool open(PSI_file_key log_file_key, const char *log_name, const char *new_name, uint32 new_index_number)
Open the logfile and init IO_CACHE.
Definition: binlog.cc:3808
bool write_buffer(const char *buf, uint len, Master_info *mi)
Definition: binlog.cc:6915
int open_purge_index_file(bool destroy)
Definition: binlog.cc:6086
int set_crash_safe_index_file_name(const char *base_file_name)
Set the name of crash safe index file.
Definition: binlog.cc:5800
const char * log_bin_basename
Definition: binlog.cc:185
int purge_logs(const char *to_log, bool included, bool need_lock_index, bool need_update_threads, ulonglong *decrease_log_space, bool auto_purge)
Remove all logs before the given log from disk and from the index file.
Definition: binlog.cc:5953
bool write_transaction(THD *thd, binlog_cache_data *cache_data, Binlog_event_writer *writer)
Write the Gtid_log_event to the binary log (prior to writing the statement or transaction cache).
Definition: binlog.cc:1629
bool truncate_update_log_file(const char *log_name, my_off_t valid_pos, my_off_t binlog_size, bool update)
Truncte log file and clear LOG_EVENT_BINLOG_IN_USE_F when update is set.
Definition: binlog.cc:6856
bool truncate_relaylog_file(Master_info *mi, my_off_t valid_pos)
Truncate the active relay log file in the specified position.
Definition: binlog.cc:8067
void check_binlog_cache_size(THD *thd)
Checks if the BINLOG_CACHE_SIZE's value is greater than MAX_BINLOG_CACHE_SIZE.
Definition: binlog.cc:1293
bool is_current_stmt_binlog_enabled_and_caches_empty(const THD *thd) const
Checks whether binlog caches are disabled (binlog does not cache data) or empty in case binloggging i...
Definition: binlog.cc:2943
bool write_event_to_binlog_and_sync(Log_event *ev)
Definition: binlog.cc:7665
bool read_binlog_in_use_flag(Binlog_file_reader &binlog_file_reader)
Read binary log stream header and Format_desc event from binlog_file_reader.
Definition: binlog.cc:7915
bool is_active(const char *log_file_name) const
Check if we are writing/reading to the given log file.
Definition: binlog.cc:6453
void check_binlog_stmt_cache_size(THD *thd)
Checks if the BINLOG_STMT_CACHE_SIZE's value is greater than MAX_BINLOG_STMT_CACHE_SIZE.
Definition: binlog.cc:1313
std::pair< bool, bool > sync_binlog_file(bool force)
Call fsync() to sync the file to disk.
Definition: binlog.cc:8744
int find_next_relay_log(char log_name[FN_REFLEN+1])
Find the relay log name following the given name from relay log index file.
Definition: binlog.cc:5570
int generate_new_name(char *new_name, const char *log_name, uint32 new_index_number=0)
Definition: binlog.cc:3742
int flush_and_set_pending_rows_event(THD *thd, Rows_log_event *event, bool is_transactional)
Definition: binlog.cc:6990
int finish_commit(THD *thd)
Helper function executed when leaving ordered_commit.
Definition: binlog.cc:8787
bool write_stmt_directly(THD *thd, const char *stmt, size_t stmt_len, enum enum_sql_command sql_command)
Write a dml into statement cache and then flush it into binlog.
Definition: binlog.cc:7591
bool ending_single_stmt_trans(THD *thd, const bool all)
This function checks if a single statement transaction is about to commit or not.
Definition: binlog.cc:3168
int raw_get_current_log(LOG_INFO *linfo)
Definition: binlog.cc:5360
int remove_logs_from_index(LOG_INFO *linfo, bool need_update_threads)
Remove logs from index file.
Definition: binlog.cc:5891
enum_result commit(THD *thd, bool all) override
Commit the transaction in the transaction coordinator.
Definition: binlog.cc:8171
bool check_write_error(const THD *thd)
Definition: binlog.cc:5368
bool purge_source_logs_to_file(THD *thd, const char *to_log)
Purges the binary log files up to the file name passed as a paramenter.
Definition: binlog.cc:3207
int find_next_log(LOG_INFO *linfo, bool need_lock_index)
Find the position in the log-index-file for the given log name.
Definition: binlog.cc:5524
int wait_for_update()
Wait until we get a signal that the binary log has been updated.
Definition: binlog.cc:7763
void make_log_name(char *buf, const char *log_ident)
Create a new log file name.
Definition: binlog.cc:6442
bool change_stage(THD *thd, Commit_stage_manager::StageID stage, THD *queue, mysql_mutex_t *leave_mutex, mysql_mutex_t *enter_mutex)
Enter a stage of the ordered commit procedure.
Definition: binlog.cc:8700
bool find_first_log(std::string &binlog_file_name, std::string &errmsg)
Find the oldest binary log referenced by the index file.
Definition: binlog.cc:4453
bool write_cache(THD *thd, class binlog_cache_data *cache_data, class Binlog_event_writer *writer)
Write the contents of the statement or transaction cache to the binary log.
Definition: binlog.cc:7703
bool write_event(Log_event *event_info)
Write an event to the binary log cache.
Definition: binlog.cc:7033
void update_binlog_end_pos(bool need_lock=true)
Definition: binlog.cc:9380
int rotate_and_purge(THD *thd, bool force_rotate)
Execute a FLUSH LOGS statement.
Definition: binlog.cc:7291
int get_current_log(LOG_INFO *linfo, bool need_lock_log=true)
Definition: binlog.cc:5352
bool is_query_in_union(THD *thd, query_id_t query_id_param)
Definition: binlog.cc:6965
int new_file_impl(bool need_lock, Format_description_log_event *extra_description_event)
Start writing to a new log file or reopen the old file.
Definition: binlog.cc:6521
bool write_event_to_binlog(Log_event *ev)
Definition: binlog.cc:7644
bool reset_logs(THD *thd, bool delete_only=false)
Removes files, as part of a RESET BINARY LOGS AND GTIDS or RESET REPLICA statement,...
Definition: binlog.cc:5634
bool purge_source_logs_before_date(THD *thd, time_t purge_time)
Execute a PURGE BINARY LOGS BEFORE <date> command.
Definition: binlog.cc:3246
bool stmt_has_updated_trans_table(Ha_trx_info_list const &ha_list)
This function checks if a transactional table was updated by the current statement.
Definition: binlog.cc:3135
bool ending_trans(THD *thd, const bool all)
This function checks if a transaction, either a multi-statement or a single statement transaction is ...
Definition: binlog.cc:3153
int query_error_code(const THD *thd, bool not_killed)
Definition: binlog.cc:3273
void process_after_commit_stage_queue(THD *thd, THD *first)
Process after commit for a sequence of sessions.
Definition: binlog.cc:8672
std::pair< int, my_off_t > flush_thread_caches(THD *thd)
Flush caches for session.
Definition: binlog.cc:8448
int move_crash_safe_index_file_to_index_file(bool need_lock_index)
Move crash safe index file to index file.
Definition: binlog.cc:5151
void report_missing_gtids(const Gtid_set *previous_gtid_set, const Gtid_set *slave_executed_gtid_set, std::string &errmsg)
Function to report the missing GTIDs.
Definition: binlog.cc:9313
int purge_index_entry(THD *thd, ulonglong *decrease_log_space, bool need_lock_index)
Definition: binlog.cc:6157
bool init_and_set_log_file_name(const char *log_name, const char *new_name, uint32 new_index_number)
Definition: binlog.cc:3782
const char * generate_name(const char *log_name, const char *suffix, char *buff)
Definition: binlog.cc:3763
int purge_logs_before_date(time_t purge_time, bool auto_purge)
Remove all logs before the given file date from disk and from the index file.
Definition: binlog.cc:6326
bool opt_binlog_order_commits
Definition: binlog.cc:182
void init_thd_variables(THD *thd, bool all, bool skip_commit)
Set thread variables used while flushing a transaction.
Definition: binlog.cc:8465
int open_crash_safe_index_file()
Open a (new) crash safe index file.
Definition: binlog.cc:5824
void start_union_events(THD *thd, query_id_t query_id_param)
Definition: binlog.cc:6952
bool is_inited_purge_index_file()
Definition: binlog.cc:6124
bool init_gtid_sets(Gtid_set *all_gtids, Gtid_set *lost_gtids, bool verify_checksum, bool need_lock, mysql::binlog::event::Transaction_boundary_parser *trx_parser, Gtid_monitoring_info *partial_trx, bool is_server_starting=false)
Reads the set of all GTIDs in the binary/relay log, and the set of all lost GTIDs in the binary log,...
Definition: binlog.cc:4566
bool open_index_file(const char *index_file_name_arg, const char *log_name, bool need_lock_index)
Definition: binlog.cc:3861
bool write_incident(THD *thd, bool need_lock_log, const char *err_msg, bool do_flush_and_sync=true)
Creates an incident event and writes it to the binary log.
Definition: binlog.cc:7623
bool assign_automatic_gtids_to_flush_group(THD *first_seen)
Assign automatic generated GTIDs for all commit group threads in the flush stage having gtid_next....
Definition: binlog.cc:1567
int register_create_index_entry(const char *entry)
Definition: binlog.cc:6152
int close_crash_safe_index_file()
Close the crash safe index file.
Definition: binlog.cc:5856
void auto_purge()
This function runs automatic purge if the conditions to meet automatic purge are met.
Definition: binlog.cc:7231
int prepare(THD *thd, bool all) override
Log a prepare record of the transaction to the storage engines.
Definition: binlog.cc:8118
void handle_binlog_flush_or_sync_error(THD *thd, bool need_lock_log, const char *message)
Helper function to handle flush or sync stage errors.
Definition: binlog.cc:8891
int ordered_commit(THD *thd, bool all, bool skip_commit=false)
Flush and commit the transaction.
Definition: binlog.cc:8941
int add_log_to_index(uchar *log_file_name, size_t name_len, bool need_lock_index)
Append log file name to index file.
Definition: binlog.cc:5309
void adjust_linfo_offsets(my_off_t purge_offset)
Adjust the position pointer in the binary log file for all running replicas.
Definition: binlog.cc:7392
MYSQL_BIN_LOG(uint *sync_period, bool relay_log=false)
Definition: binlog.cc:3525
bool flush_and_sync(const bool force=false)
Flush binlog cache and synchronize to disk.
Definition: binlog.cc:6942
int new_file(Format_description_log_event *extra_description_event)
Definition: binlog.cc:6492
bool show_binlog_events(THD *thd, MYSQL_BIN_LOG *binary_log)
Definition: binlog.cc:3376
void inc_prep_xids(THD *thd)
Increment the prepared XID counter.
Definition: binlog.cc:6457
void dec_prep_xids(THD *thd)
Decrement the prepared XID counter.
Definition: binlog.cc:6468
void stop_union_events(THD *thd)
Definition: binlog.cc:6960
bool flush()
Definition: binlog.cc:6938
void signal_update()
Notifies waiting threads that binary log has been updated.
Definition: binlog.cc:9372
int check_trx_rw_engines(THD *thd, Transaction_ctx::enum_trx_scope trx_scope)
Check if the transaction has no rw flag set for any of the storage engines.
Definition: binlog.cc:3090
bool find_first_log_not_in_gtid_set(char *binlog_file_name, const Gtid_set *gtid_set, Gtid *first_gtid, std::string &errmsg)
Find the oldest binary log that contains any GTID that is not in the given gtid set.
Definition: binlog.cc:4468
void report_binlog_write_error()
Definition: binlog.cc:7755
bool after_write_to_relay_log(Master_info *mi)
Called after an event has been written to the relay log by the IO thread.
Definition: binlog.cc:6760
void auto_purge_at_server_startup()
This member function is to be called at server startup.
Definition: binlog.cc:7219
#define log_info(...)
Definition: log_client.h:152
unsigned int PSI_cond_key
Instrumented cond key.
Definition: psi_cond_bits.h:43
unsigned int PSI_file_key
Instrumented file key.
Definition: psi_file_bits.h:47
unsigned int PSI_mutex_key
Instrumented mutex key.
Definition: psi_mutex_bits.h:51
#define mysql_mutex_assert_not_owner(M)
Wrapper, to use safe_mutex_assert_not_owner with instrumented mutexes.
Definition: mysql_mutex.h:125
Some integer typedefs for easier portability.
unsigned long long int ulonglong
Definition: my_inttypes.h:55
uint8_t uint8
Definition: my_inttypes.h:62
ulonglong my_off_t
Definition: my_inttypes.h:71
unsigned char uchar
Definition: my_inttypes.h:51
int64_t int64
Definition: my_inttypes.h:67
int32_t int32
Definition: my_inttypes.h:65
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
Functions related to handling of plugins and other dynamically loaded libraries.
#define MYSQL_PLUGIN_IMPORT
Definition: my_sharedlib.h:70
enum_sql_command
Definition: my_sqlcommand.h:45
Common header for many mysys elements.
uint32 my_thread_id
Definition: my_thread_local.h:33
static int not_killed
Definition: myisamchk.cc:1618
static uint update
Definition: myisamlog.cc:93
static QUEUE queue
Definition: myisampack.cc:209
Common definition between mysql server & client.
#define NAME_LEN
Definition: mysql_com.h:66
Instrumentation helpers for conditions.
ABI for instrumented mutexes.
Type inc(Shards< COUNT > &shards, size_t id)
Increment the counter of a shard by 1.
Definition: ut0counter.h:292
Definition: buf0block_hint.cc:29
static bool timeout(bool(*wait_condition)())
Timeout function.
Definition: log0meb.cc:497
enum_binlog_checksum_alg
Enumeration spcifying checksum algorithm used to encode a binary log event.
Definition: binlog_event.h:460
Instrumentation helpers for conditions.
Instrumentation helpers for mutexes.
Performance schema instrumentation interface.
Performance schema instrumentation interface.
Instrumentation helpers for mutexes.
required string event
Definition: replication_group_member_actions.proto:31
Item_result type
Definition: binlog.h:92
ulong length
Definition: binlog.h:91
char * value
Definition: binlog.h:90
bool unsigned_flag
Definition: binlog.h:94
user_var_entry * user_var_event
Definition: binlog.h:89
uint charset_number
Definition: binlog.h:93
TODO: Move this structure to mysql/binlog/event/control_events.h when we start using C++11.
Definition: rpl_gtid.h:1099
Definition: binlog.h:1075
bool log_delayed
Definition: binlog.h:1078
my_off_t last_pos_in_file
Definition: binlog.h:1077
bool logged_data_file
Definition: binlog.h:1078
THD * thd
Definition: binlog.h:1076
my_thread_id thread_id
Definition: binlog.h:121
my_off_t pos
Definition: binlog.h:117
my_off_t index_file_start_offset
Definition: binlog.h:116
LOG_INFO()
Definition: binlog.h:122
bool fatal
Definition: binlog.h:118
char log_file_name[FN_REFLEN]
Definition: binlog.h:115
my_off_t index_file_offset
Definition: binlog.h:116
int entry_index
Definition: binlog.h:119
int encrypted_header_size
Definition: binlog.h:120
Definition: completion_hash.h:34
An instrumented cond structure.
Definition: mysql_cond_bits.h:49
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:49
MySQL mutex implementation.
Include file for Sun RPC to compile out of the box.
Transaction boundary parser definitions.
Item_result
Type of the user defined function return slot and arguments.
Definition: udf_registration_types.h:38
static int all(site_def const *s, node_no node)
Definition: xcom_transport.cc:881