Home
last modified time | relevance | path

Searched refs:Relay_log_info (Results 1 – 25 of 611) sorted by relevance

12345678910>>...25

/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Drpl_mts_submode.h35 class Relay_log_info; variable
66 virtual int schedule_next_event(Relay_log_info* rli,
82 virtual int wait_for_workers_to_finish(Relay_log_info *rli,
100 int schedule_next_event(Relay_log_info* rli, Log_event *ev) in schedule_next_event()
103 void attach_temp_tables(THD *thd, const Relay_log_info* rli, in attach_temp_tables()
107 void detach_temp_tables(THD *thd, const Relay_log_info* rli, in detach_temp_tables()
118 int wait_for_workers_to_finish(Relay_log_info *rli,
143 int wait_for_workers_to_finish(Relay_log_info *rli,
186 Slave_worker* get_free_worker(Relay_log_info *rli);
210 int wait_for_workers_to_finish(Relay_log_info *rli,
[all …]
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
410 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
468 virtual int do_exec_row(const Relay_log_info *const);
485 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
541 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Drpl_mts_submode.h39 class Relay_log_info; variable
83 virtual int wait_for_workers_to_finish(Relay_log_info *rli,
105 void attach_temp_tables(THD *thd, const Relay_log_info *rli,
107 void detach_temp_tables(THD *thd, const Relay_log_info *rli,
109 Slave_worker *get_least_occupied_worker(Relay_log_info *,
113 int wait_for_workers_to_finish(Relay_log_info *rli,
162 Slave_worker *get_free_worker(Relay_log_info *rli);
167 void attach_temp_tables(THD *thd, const Relay_log_info *rli,
169 void detach_temp_tables(THD *thd, const Relay_log_info *rli,
183 int wait_for_workers_to_finish(Relay_log_info *rli,
[all …]
H A Drpl_rli.cc104 Relay_log_info::Relay_log_info(bool is_slave_recovery, in Relay_log_info() function in Relay_log_info
280 Relay_log_info::~Relay_log_info() { in ~Relay_log_info()
1821 void Relay_log_info::end_info() { in end_info()
1841 int Relay_log_info::flush_current_log() { in flush_current_log()
1960 bool Relay_log_info::clear_info() { in clear_info()
2873 Relay_log_info::enum_priv_checks_status
2903 Relay_log_info::enum_priv_checks_status
2919 Relay_log_info::enum_priv_checks_status
2955 Relay_log_info::enum_priv_checks_status Relay_log_info::check_applier_acl_user( in check_applier_acl_user()
3121 Relay_log_info::enum_priv_checks_status
[all …]
H A Drpl_slave_until_options.h35 class Relay_log_info; variable
103 Relay_log_info *m_rli;
105 Until_option(Relay_log_info *rli) : m_rli(rli) {} in Until_option()
171 Until_position(Relay_log_info *rli) : Until_option(rli) {} in Until_position()
206 Until_master_position(Relay_log_info *rli) : Until_position(rli) {} in Until_master_position()
229 Until_relay_position(Relay_log_info *rli) : Until_position(rli) {} in Until_relay_position()
267 Until_gtids(Relay_log_info *rli) in Until_gtids()
278 Until_before_gtids(Relay_log_info *rli) : Until_gtids(rli) {} in Until_before_gtids()
293 Until_after_gtids(Relay_log_info *rli) : Until_gtids(rli) {} in Until_after_gtids()
308 Until_view_id(Relay_log_info *rli) in Until_view_id()
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Drpl_mts_submode.h35 class Relay_log_info; variable
63 virtual int schedule_next_event(Relay_log_info* rli,
79 virtual int wait_for_workers_to_finish(Relay_log_info *rli,
96 int schedule_next_event(Relay_log_info* rli, Log_event *ev);
97 void attach_temp_tables(THD *thd, const Relay_log_info* rli,
99 void detach_temp_tables(THD *thd, const Relay_log_info* rli,
101 Slave_worker* get_least_occupied_worker(Relay_log_info* rli,
105 int wait_for_workers_to_finish(Relay_log_info *rli,
148 Slave_worker* get_free_worker(Relay_log_info *rli);
172 int wait_for_workers_to_finish(Relay_log_info *rli,
[all …]
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
410 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
468 virtual int do_exec_row(const Relay_log_info *const);
485 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
541 virtual int do_exec_row(const Relay_log_info *const);
[all …]
H A Dlog_event.h346 class Relay_log_info; variable
653 Relay_log_info *worker;
1198 int apply_event(Relay_log_info *rli);
1218 int update_pos(Relay_log_info *rli) in update_pos()
1482 int do_apply_event(Relay_log_info const *rli,
3379 int do_apply_row(Relay_log_info const *rli);
3453 int do_hash_row(Relay_log_info const *rli);
4149 int do_update_pos(Relay_log_info *rli);
4338 int do_update_pos(Relay_log_info *rli);
4419 int do_update_pos(Relay_log_info *rli);
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Drpl_mts_submode.h35 class Relay_log_info; variable
63 virtual int schedule_next_event(Relay_log_info* rli,
79 virtual int wait_for_workers_to_finish(Relay_log_info *rli,
96 int schedule_next_event(Relay_log_info* rli, Log_event *ev);
97 void attach_temp_tables(THD *thd, const Relay_log_info* rli,
99 void detach_temp_tables(THD *thd, const Relay_log_info* rli,
101 Slave_worker* get_least_occupied_worker(Relay_log_info* rli,
105 int wait_for_workers_to_finish(Relay_log_info *rli,
148 Slave_worker* get_free_worker(Relay_log_info *rli);
172 int wait_for_workers_to_finish(Relay_log_info *rli,
[all …]
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
410 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
468 virtual int do_exec_row(const Relay_log_info *const);
485 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
541 virtual int do_exec_row(const Relay_log_info *const);
[all …]
H A Dlog_event.h346 class Relay_log_info; variable
653 Relay_log_info *worker;
1198 int apply_event(Relay_log_info *rli);
1218 int update_pos(Relay_log_info *rli) in update_pos()
1482 int do_apply_event(Relay_log_info const *rli,
3379 int do_apply_row(Relay_log_info const *rli);
3453 int do_hash_row(Relay_log_info const *rli);
4149 int do_update_pos(Relay_log_info *rli);
4338 int do_update_pos(Relay_log_info *rli);
4419 int do_update_pos(Relay_log_info *rli);
[all …]
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Drpl_mts_submode.h35 class Relay_log_info; variable
63 virtual int schedule_next_event(Relay_log_info* rli,
79 virtual int wait_for_workers_to_finish(Relay_log_info *rli,
96 int schedule_next_event(Relay_log_info* rli, Log_event *ev);
97 void attach_temp_tables(THD *thd, const Relay_log_info* rli,
99 void detach_temp_tables(THD *thd, const Relay_log_info* rli,
101 Slave_worker* get_least_occupied_worker(Relay_log_info* rli,
105 int wait_for_workers_to_finish(Relay_log_info *rli,
148 Slave_worker* get_free_worker(Relay_log_info *rli);
172 int wait_for_workers_to_finish(Relay_log_info *rli,
[all …]
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
410 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
468 virtual int do_exec_row(const Relay_log_info *const);
485 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
541 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Drpl_mts_submode.h35 class Relay_log_info; variable
63 virtual int schedule_next_event(Relay_log_info* rli,
79 virtual int wait_for_workers_to_finish(Relay_log_info *rli,
96 int schedule_next_event(Relay_log_info* rli, Log_event *ev);
97 void attach_temp_tables(THD *thd, const Relay_log_info* rli,
99 void detach_temp_tables(THD *thd, const Relay_log_info* rli,
101 Slave_worker* get_least_occupied_worker(Relay_log_info* rli,
105 int wait_for_workers_to_finish(Relay_log_info *rli,
148 Slave_worker* get_free_worker(Relay_log_info *rli);
172 int wait_for_workers_to_finish(Relay_log_info *rli,
[all …]
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
410 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
468 virtual int do_exec_row(const Relay_log_info *const);
485 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
541 virtual int do_exec_row(const Relay_log_info *const);
[all …]
H A Dlog_event.h346 class Relay_log_info; variable
653 Relay_log_info *worker;
1198 int apply_event(Relay_log_info *rli);
1218 int update_pos(Relay_log_info *rli) in update_pos()
1482 int do_apply_event(Relay_log_info const *rli,
3379 int do_apply_row(Relay_log_info const *rli);
3453 int do_hash_row(Relay_log_info const *rli);
4149 int do_update_pos(Relay_log_info *rli);
4338 int do_update_pos(Relay_log_info *rli);
4419 int do_update_pos(Relay_log_info *rli);
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Drpl_mts_submode.h35 class Relay_log_info; variable
63 virtual int schedule_next_event(Relay_log_info* rli,
79 virtual int wait_for_workers_to_finish(Relay_log_info *rli,
96 int schedule_next_event(Relay_log_info* rli, Log_event *ev);
97 void attach_temp_tables(THD *thd, const Relay_log_info* rli,
99 void detach_temp_tables(THD *thd, const Relay_log_info* rli,
101 Slave_worker* get_least_occupied_worker(Relay_log_info* rli,
105 int wait_for_workers_to_finish(Relay_log_info *rli,
148 Slave_worker* get_free_worker(Relay_log_info *rli);
172 int wait_for_workers_to_finish(Relay_log_info *rli,
[all …]
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
410 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
468 virtual int do_exec_row(const Relay_log_info *const);
485 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
541 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
411 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
469 virtual int do_exec_row(const Relay_log_info *const);
487 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
543 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
411 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
469 virtual int do_exec_row(const Relay_log_info *const);
487 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
543 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
411 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
469 virtual int do_exec_row(const Relay_log_info *const);
487 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
543 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
411 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
469 virtual int do_exec_row(const Relay_log_info *const);
487 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
543 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/mysql56-client/mysql-5.6.51/sql/
H A Dlog_event_old.h207 int find_row(const Relay_log_info *const);
208 int write_row(const Relay_log_info *const, const bool);
211 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
223 virtual int do_apply_event(Relay_log_info const *rli);
224 virtual int do_update_pos(Relay_log_info *rli);
395 virtual int do_exec_row(const Relay_log_info *const);
411 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
469 virtual int do_exec_row(const Relay_log_info *const);
487 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
543 virtual int do_exec_row(const Relay_log_info *const);
[all …]
/dports/databases/mysql55-client/mysql-5.5.62/sql/
H A Dlog_event_old.h198 int find_row(const Relay_log_info *const);
199 int write_row(const Relay_log_info *const, const bool);
202 int unpack_current_row(const Relay_log_info *const rli) in unpack_current_row()
214 virtual int do_apply_event(Relay_log_info const *rli);
215 virtual int do_update_pos(Relay_log_info *rli);
387 virtual int do_exec_row(const Relay_log_info *const);
403 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
463 virtual int do_exec_row(const Relay_log_info *const);
481 virtual int do_apply_event(const Relay_log_info *rli) in do_apply_event()
538 virtual int do_exec_row(const Relay_log_info *const);
[all …]
H A Dslave.h48 class Relay_log_info; variable
150 bool flush_relay_log_info(Relay_log_info* rli);
185 bool rpl_master_has_bug(const Relay_log_info *rli, uint bug_id, bool report,
194 void clear_until_condition(Relay_log_info* rli);
195 void clear_slave_error(Relay_log_info* rli);
196 void end_relay_log_info(Relay_log_info* rli);
200 int init_relay_log_pos(Relay_log_info* rli,const char* log,ulonglong pos,
204 int purge_relay_logs(Relay_log_info* rli, THD *thd, bool just_reset,
207 void set_slave_thread_default_charset(THD *thd, Relay_log_info const *rli);
209 int apply_event_and_update_pos(Log_event* ev, THD* thd, Relay_log_info* rli);

12345678910>>...25