1 /* Copyright (c) 2000, 2011, Oracle and/or its affiliates. All rights reserved. 2 3 This program is free software; you can redistribute it and/or modify 4 it under the terms of the GNU General Public License as published by 5 the Free Software Foundation; version 2 of the License. 6 7 This program is distributed in the hope that it will be useful, 8 but WITHOUT ANY WARRANTY; without even the implied warranty of 9 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 10 GNU General Public License for more details. 11 12 You should have received a copy of the GNU General Public License 13 along with this program; if not, write to the Free Software 14 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1335 USA */ 15 16 #ifndef SQL_REPL_INCLUDED 17 #define SQL_REPL_INCLUDED 18 19 #include "rpl_filter.h" 20 21 #ifdef HAVE_REPLICATION 22 #include "slave.h" 23 24 typedef struct st_slave_info 25 { 26 uint32 server_id; 27 uint32 rpl_recovery_rank, master_id; 28 char host[HOSTNAME_LENGTH*SYSTEM_CHARSET_MBMAXLEN+1]; 29 char user[USERNAME_LENGTH+1]; 30 char password[MAX_PASSWORD_LENGTH*SYSTEM_CHARSET_MBMAXLEN+1]; 31 uint16 port; 32 THD* thd; 33 } SLAVE_INFO; 34 35 struct slave_connection_state; 36 37 extern my_bool opt_show_slave_auth_info; 38 extern char *master_host, *master_info_file; 39 40 extern int max_binlog_dump_events; 41 extern my_bool opt_sporadic_binlog_dump_fail; 42 43 int start_slave(THD* thd, Master_info* mi, bool net_report); 44 int stop_slave(THD* thd, Master_info* mi, bool net_report); 45 bool change_master(THD* thd, Master_info* mi, bool *master_info_added); 46 bool mysql_show_binlog_events(THD* thd); 47 int reset_slave(THD *thd, Master_info* mi); 48 int reset_master(THD* thd, rpl_gtid *init_state, uint32 init_state_len, 49 ulong next_log_number); 50 bool purge_master_logs(THD* thd, const char* to_log); 51 bool purge_master_logs_before_date(THD* thd, time_t purge_time); 52 bool log_in_use(const char* log_name); 53 void adjust_linfo_offsets(my_off_t purge_offset); 54 void show_binlogs_get_fields(THD *thd, List<Item> *field_list); 55 bool show_binlogs(THD* thd); 56 extern int init_master_info(Master_info* mi); 57 void kill_zombie_dump_threads(uint32 slave_server_id); 58 int check_binlog_magic(IO_CACHE* log, const char** errmsg); 59 int compare_log_name(const char *log_1, const char *log_2); 60 61 struct LOAD_FILE_IO_CACHE : public IO_CACHE 62 { 63 THD* thd; 64 my_off_t last_pos_in_file; 65 bool wrote_create_file, log_delayed; 66 int (*real_read_function)(struct st_io_cache *,uchar *,size_t); 67 }; 68 69 int log_loaded_block(IO_CACHE* file, uchar *Buffer, size_t Count); 70 int init_replication_sys_vars(); 71 void mysql_binlog_send(THD* thd, char* log_ident, my_off_t pos, ushort flags); 72 73 #ifdef HAVE_PSI_INTERFACE 74 extern PSI_mutex_key key_LOCK_slave_state, key_LOCK_binlog_state; 75 #endif 76 void rpl_init_gtid_slave_state(); 77 void rpl_deinit_gtid_slave_state(); 78 void rpl_init_gtid_waiting(); 79 void rpl_deinit_gtid_waiting(); 80 int gtid_state_from_binlog_pos(const char *name, uint32 pos, String *out_str); 81 int rpl_append_gtid_state(String *dest, bool use_binlog); 82 int rpl_load_gtid_state(slave_connection_state *state, bool use_binlog); 83 bool rpl_gtid_pos_check(THD *thd, char *str, size_t len); 84 bool rpl_gtid_pos_update(THD *thd, char *str, size_t len); 85 #else 86 87 struct LOAD_FILE_IO_CACHE : public IO_CACHE { }; 88 89 #endif /* HAVE_REPLICATION */ 90 91 #endif /* SQL_REPL_INCLUDED */ 92