167
167
bool high_priority);
169
169
/* If fd is -1, dump to NET */
170
int32_t mysql_table_dump(THD* thd, const char* db,
170
int32_t mysql_table_dump(Session* thd, const char* db,
171
171
const char* tbl_name, int32_t fd = -1);
173
173
/* retrieve table from master and copy to slave*/
174
int32_t fetch_master_table(THD* thd, const char* db_name, const char* table_name,
174
int32_t fetch_master_table(Session* thd, const char* db_name, const char* table_name,
175
175
Master_info* mi, DRIZZLE *drizzle, bool overwrite);
177
bool show_master_info(THD* thd, Master_info* mi);
178
bool show_binlog_info(THD* thd);
177
bool show_master_info(Session* thd, Master_info* mi);
178
bool show_binlog_info(Session* thd);
179
179
bool rpl_master_has_bug(Relay_log_info *rli, uint32_t bug_id, bool report= true);
180
bool rpl_master_erroneous_autoinc(THD* thd);
180
bool rpl_master_erroneous_autoinc(Session* thd);
182
182
const char *print_slave_db_safe(const char *db);
183
int32_t check_expected_error(THD* thd, Relay_log_info const *rli, int32_t error_code);
183
int32_t check_expected_error(Session* thd, Relay_log_info const *rli, int32_t error_code);
184
184
void skip_load_data_infile(NET* net);
186
186
void end_slave(); /* clean up */
194
194
bool need_data_lock, const char** errmsg,
195
195
bool look_for_description_event);
197
int32_t purge_relay_logs(Relay_log_info* rli, THD *thd, bool just_reset,
197
int32_t purge_relay_logs(Relay_log_info* rli, Session *thd, bool just_reset,
198
198
const char** errmsg);
199
void set_slave_thread_options(THD* thd);
199
void set_slave_thread_options(Session* thd);
200
200
void rotate_relay_log(Master_info* mi);
201
int32_t apply_event_and_update_pos(Log_event* ev, THD* thd, Relay_log_info* rli,
201
int32_t apply_event_and_update_pos(Log_event* ev, Session* thd, Relay_log_info* rli,
204
204
pthread_handler_t handle_slave_io(void *arg);
220
220
extern char *master_ssl_ca, *master_ssl_capath, *master_ssl_cert;
221
221
extern char *master_ssl_cipher, *master_ssl_key;
223
extern I_List<THD> threads;
223
extern I_List<Session> threads;
225
225
/* masks for start/stop operations on io and sql slave threads */
226
226
#define SLAVE_IO 1