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-1301 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
24typedef 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
35struct slave_connection_state;
36
37extern my_bool opt_show_slave_auth_info;
38extern char *master_host, *master_info_file;
39
40extern int max_binlog_dump_events;
41extern my_bool opt_sporadic_binlog_dump_fail;
42
43int start_slave(THD* thd, Master_info* mi, bool net_report);
44int stop_slave(THD* thd, Master_info* mi, bool net_report);
45bool change_master(THD* thd, Master_info* mi, bool *master_info_added);
46bool mysql_show_binlog_events(THD* thd);
47int reset_slave(THD *thd, Master_info* mi);
48int reset_master(THD* thd, rpl_gtid *init_state, uint32 init_state_len,
49 ulong next_log_number);
50bool purge_master_logs(THD* thd, const char* to_log);
51bool purge_master_logs_before_date(THD* thd, time_t purge_time);
52bool log_in_use(const char* log_name);
53void adjust_linfo_offsets(my_off_t purge_offset);
54void show_binlogs_get_fields(THD *thd, List<Item> *field_list);
55bool show_binlogs(THD* thd);
56extern int init_master_info(Master_info* mi);
57void kill_zombie_dump_threads(uint32 slave_server_id);
58int check_binlog_magic(IO_CACHE* log, const char** errmsg);
59
60struct LOAD_FILE_IO_CACHE : public IO_CACHE
61{
62 THD* thd;
63 my_off_t last_pos_in_file;
64 bool wrote_create_file, log_delayed;
65 int (*real_read_function)(struct st_io_cache *,uchar *,size_t);
66};
67
68int log_loaded_block(IO_CACHE* file, uchar *Buffer, size_t Count);
69int init_replication_sys_vars();
70void mysql_binlog_send(THD* thd, char* log_ident, my_off_t pos, ushort flags);
71
72#ifdef HAVE_PSI_INTERFACE
73extern PSI_mutex_key key_LOCK_slave_state, key_LOCK_binlog_state;
74#endif
75void rpl_init_gtid_slave_state();
76void rpl_deinit_gtid_slave_state();
77void rpl_init_gtid_waiting();
78void rpl_deinit_gtid_waiting();
79int gtid_state_from_binlog_pos(const char *name, uint32 pos, String *out_str);
80int rpl_append_gtid_state(String *dest, bool use_binlog);
81int rpl_load_gtid_state(slave_connection_state *state, bool use_binlog);
82bool rpl_gtid_pos_check(THD *thd, char *str, size_t len);
83bool rpl_gtid_pos_update(THD *thd, char *str, size_t len);
84#else
85
86struct LOAD_FILE_IO_CACHE : public IO_CACHE { };
87
88#endif /* HAVE_REPLICATION */
89
90#endif /* SQL_REPL_INCLUDED */
91