diff options
author | mats@romeo.(none) <> | 2006-11-10 15:10:41 +0100 |
---|---|---|
committer | mats@romeo.(none) <> | 2006-11-10 15:10:41 +0100 |
commit | 1fb9105ebd647be9d4b4c582d1e8354f0ea38414 (patch) | |
tree | d2bcf30804ac9fe4cbb41f7d84d8e565ef8ffe5f /sql/slave.h | |
parent | edb70453532f7647b1d280fcc218f466d7512f42 (diff) | |
download | mariadb-git-1fb9105ebd647be9d4b4c582d1e8354f0ea38414.tar.gz |
BUG#23171 (Illegal slave restart group position):
Second patch to fix skipping code. Moving relay and binary log
position changing code from do_apply_event [old exec_event()] into
do_update_pos() and doing other changes necessary to support that.
Fixing a bug that can cause deadlock if rotating binary log when committing
a changes to a transactional table that is not inside a transaction and
cause a rotate log.
Diffstat (limited to 'sql/slave.h')
-rw-r--r-- | sql/slave.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sql/slave.h b/sql/slave.h index 24ba09d78d3..1e5be3ab8bd 100644 --- a/sql/slave.h +++ b/sql/slave.h @@ -164,9 +164,9 @@ bool show_master_info(THD* thd, MASTER_INFO* mi); bool show_binlog_info(THD* thd); const char *print_slave_db_safe(const char *db); -int check_expected_error(THD* thd, RELAY_LOG_INFO* rli, int error_code); +int check_expected_error(THD* thd, RELAY_LOG_INFO const *rli, int error_code); void skip_load_data_infile(NET* net); -void slave_print_msg(enum loglevel level, RELAY_LOG_INFO* rli, +void slave_print_msg(enum loglevel level, RELAY_LOG_INFO const *rli, int err_code, const char* msg, ...) ATTRIBUTE_FORMAT(printf, 4, 5); @@ -184,7 +184,7 @@ int init_relay_log_pos(RELAY_LOG_INFO* rli,const char* log,ulonglong pos, int purge_relay_logs(RELAY_LOG_INFO* rli, THD *thd, bool just_reset, const char** errmsg); void set_slave_thread_options(THD* thd); -void set_slave_thread_default_charset(THD* thd, RELAY_LOG_INFO *rli); +void set_slave_thread_default_charset(THD *thd, RELAY_LOG_INFO const *rli); void rotate_relay_log(MASTER_INFO* mi); pthread_handler_t handle_slave_io(void *arg); |