|
| bool | start_slave_cmd (THD *thd) |
| | Entry point to the START REPLICA command. More...
|
| |
| bool | stop_slave_cmd (THD *thd) |
| | Entry point for the STOP REPLICA command. More...
|
| |
| bool | change_master_cmd (THD *thd) |
| | Entry point for the CHANGE REPLICATION SOURCE command. More...
|
| |
| int | change_master (THD *thd, Master_info *mi, LEX_SOURCE_INFO *lex_mi, bool preserve_logs) |
| | Execute a CHANGE REPLICATION SOURCE statement. More...
|
| |
| bool | reset_slave_cmd (THD *thd) |
| | Entry function for RESET REPLICA command. More...
|
| |
| bool | show_slave_status_cmd (THD *thd) |
| | Entry point for SHOW REPLICA STATUS command. More...
|
| |
| bool | flush_relay_logs_cmd (THD *thd) |
| | Entry point for FLUSH RELAYLOGS command or to flush relaylogs for the FLUSH LOGS command. More...
|
| |
| bool | reencrypt_relay_logs () |
| | Re-encrypt previous relay logs with current master key for all slave channels. More...
|
| |
| int | flush_relay_logs (Master_info *mi, THD *thd) |
| | flushes the relay logs of a replication channel. More...
|
| |
| int | reset_slave (THD *thd, Master_info *mi, bool reset_all) |
| | Execute a RESET REPLICA statement. More...
|
| |
| int | reset_slave (THD *thd) |
| | Execute a RESET REPLICA (for all channels), used in Multisource replication. More...
|
| |
| int | init_recovery (Master_info *mi) |
| |
| int | load_mi_and_rli_from_repositories (Master_info *mi, bool ignore_if_no_info, int thread_mask, bool skip_received_gtid_set_and_relaylog_recovery=false, bool force_load=false) |
| | Call mi->init_info() and/or mi->rli->init_info(), which will read the replication configuration from repositories. More...
|
| |
| void | end_info (Master_info *mi) |
| |
| void | clear_info (Master_info *mi) |
| | Clear the information regarding the Master_info and Relay_log_info objects represented by the parameter, meaning, setting to NULL all attributes that are not meant to be kept between slave resets. More...
|
| |
| int | remove_info (Master_info *mi) |
| |
| bool | reset_info (Master_info *mi) |
| | Resets the information regarding the Master_info and Relay_log_info objects represented by the parameter, meaning, setting to NULL all attributes that are not meant to be kept between slave resets and persisting all other attribute values in the repository. More...
|
| |
| int | flush_master_info (Master_info *mi, bool force, bool need_lock=true, bool flush_relay_log=true, bool skip_repo_persistence=false) |
| | This method flushes the current configuration for the channel into the connection metadata repository. More...
|
| |
| void | add_replica_skip_errors (const char *arg) |
| |
| void | set_replica_skip_errors (char **replica_skip_errors_ptr) |
| | Change arg to the string with the nice, human-readable skip error values. More...
|
| |
| int | add_new_channel (Master_info **mi, const char *channel) |
| | This function is first called when the Master_info object corresponding to a channel in a multisourced slave does not exist. More...
|
| |
| int | terminate_slave_threads (Master_info *mi, int thread_mask, ulong stop_wait_timeout, bool need_lock_term=true) |
| | Terminates the slave threads according to the given mask. More...
|
| |
| bool | start_slave_threads (bool need_lock_slave, bool wait_for_start, Master_info *mi, int thread_mask) |
| |
| bool | start_slave (THD *thd) |
| | Function to start a slave for all channels. More...
|
| |
| int | stop_slave (THD *thd) |
| | Function to stop a slave for all channels. More...
|
| |
| bool | start_slave (THD *thd, LEX_REPLICA_CONNECTION *connection_param, LEX_SOURCE_INFO *master_param, int thread_mask_input, Master_info *mi, bool set_mts_settings) |
| | Executes a START REPLICA statement. More...
|
| |
| int | stop_slave (THD *thd, Master_info *mi, bool net_report, bool for_one_channel, bool *push_temp_tables_warning) |
| | Execute a STOP REPLICA statement. More...
|
| |
| bool | start_slave_thread (PSI_thread_key thread_key, my_start_routine h_func, mysql_mutex_t *start_lock, mysql_mutex_t *cond_lock, mysql_cond_t *start_cond, std::atomic< uint > *slave_running, std::atomic< ulong > *slave_run_id, Master_info *mi) |
| |
| bool | show_slave_status (THD *thd, Master_info *mi) |
| | Execute a SHOW REPLICA STATUS statement. More...
|
| |
| bool | show_slave_status (THD *thd) |
| | Method to the show the replication status in all channels. More...
|
| |
| const char * | print_slave_db_safe (const char *db) |
| |
| void | end_slave () |
| |
| void | delete_slave_info_objects () |
| | Free all resources used by slave threads at time of executing shutdown. More...
|
| |
| void | set_slave_thread_options (THD *thd) |
| | Set slave thread default options. More...
|
| |
| void | set_slave_thread_default_charset (THD *thd, Relay_log_info const *rli) |
| |
| int | rotate_relay_log (Master_info *mi, bool log_master_fd=true, bool need_lock=true, bool need_log_space_lock=true) |
| | Rotates the relay log. More...
|
| |
| QUEUE_EVENT_RESULT | queue_event (Master_info *mi, const char *buf, ulong event_len, bool do_flush_mi) |
| | Store an event received from the master connection into the relay log. More...
|
| |
| int | heartbeat_queue_event (bool is_valid, Master_info *&mi, std::string binlog_name, uint64_t position, unsigned long &inc_pos, bool &do_flush_mi) |
| |
| void * | handle_slave_io (void *arg) |
| | Slave IO thread entry point. More...
|
| |
| void * | handle_slave_sql (void *arg) |
| | Slave SQL thread entry point. More...
|
| |
| int | connect_to_master (THD *thd, MYSQL *mysql, Master_info *mi, bool reconnect, bool suppress_warnings, const std::string &host, const uint port, bool is_io_thread) |
| |
| bool | net_request_file (NET *net, const char *fname) |
| |
| bool | mts_recovery_groups (Relay_log_info *rli) |
| |
| bool | mta_checkpoint_routine (Relay_log_info *rli, bool force) |
| | Processing rli->gaq to find out the low-water-mark (lwm) coordinates which is stored into the central recovery table. More...
|
| |
| bool | sql_slave_killed (THD *thd, Relay_log_info *rli) |
| | The function analyzes a possible killed status and makes a decision whether to accept it or not. More...
|
| |
| bool | is_network_error (uint errorno) |
| |
| int | init_replica_thread (THD *thd, SLAVE_THD_TYPE thd_type) |
| |
| void | enable_applier_metric_collection () |
| | Enables metric collection for replication structures It affects new and already created and running channels. More...
|
| |
| void | disable_applier_metric_collection () |
| | Disables metric collection for replication structures It affects new and already created and running channels. More...
|
| |
1.9.2