/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
H A D | rpl_mts_submode.h | 35 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 D | log_event_old.h | 207 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 D | rpl_mts_submode.h | 39 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 D | rpl_rli.cc | 104 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 D | rpl_slave_until_options.h | 35 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 D | rpl_mts_submode.h | 35 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 D | log_event_old.h | 207 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 D | log_event.h | 346 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 D | rpl_mts_submode.h | 35 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 D | log_event_old.h | 207 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 D | log_event.h | 346 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 D | rpl_mts_submode.h | 35 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 D | log_event_old.h | 207 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 D | rpl_mts_submode.h | 35 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 D | log_event_old.h | 207 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 D | log_event.h | 346 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 D | rpl_mts_submode.h | 35 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 D | log_event_old.h | 207 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 D | log_event_old.h | 207 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 D | log_event_old.h | 207 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 D | log_event_old.h | 207 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 D | log_event_old.h | 207 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 D | log_event_old.h | 207 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 D | log_event_old.h | 198 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 D | slave.h | 48 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);
|