/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
H A D | rpl_gtid_state.cc | 36 logged_gtids.clear(); in clear() 48 DBUG_ASSERT(!logged_gtids.contains_gtid(gtid)); in acquire_ownership() 154 ret= logged_gtids._add_gtid(g); in update_on_flush() 165 ret= logged_gtids._add_gtid(thd->owned_gtid); in update_on_flush() 251 Gtid_set::Const_interval_iterator ivit(&logged_gtids, sidno); in get_automatic_gno() 336 PROPAGATE_REPORTED_ERROR(logged_gtids.ensure_sidno(sidno)); in ensure_sidno() 341 DBUG_ASSERT(logged_gtids.get_max_sidno() >= sidno); in ensure_sidno() 357 if (!logged_gtids.is_empty()) in add_lost_gtids() 374 PROPAGATE_REPORTED_ERROR(logged_gtids.add_gtid_text(text)); in add_lost_gtids()
|
H A D | rpl_rli.cc | 913 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in wait_for_gtid_set() local 918 gtid->c_ptr_safe(), wait_gtid_set.is_subset(logged_gtids), in wait_for_gtid_set() 920 logged_gtids->dbug_print("gtid_executed:"); in wait_for_gtid_set() 927 if (wait_gtid_set.is_subset(logged_gtids) && in wait_for_gtid_set() 1416 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1417 if (until_sql_gtids.is_intersection_nonempty(logged_gtids)) in is_until_satisfied() 1450 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1451 if (until_sql_gtids.is_subset(logged_gtids)) in is_until_satisfied()
|
H A D | rpl_gtid_execution.cc | 293 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in skip_statement() local 295 DBUG_ASSERT(logged_gtids->contains_gtid(thd->variables.gtid_next.gtid)); in skip_statement()
|
H A D | rpl_gtid.h | 2114 logged_gtids(sid_map, sid_lock), in Gtid_state() 2149 bool ret= logged_gtids.contains_gtid(gtid); in is_logged() 2286 const Gtid_set *get_logged_gtids() const { return &logged_gtids; } in get_logged_gtids() 2307 logged_gtids.get_string_length() + in get_max_string_length() 2316 p+= logged_gtids.to_string(p); in to_string() 2377 Gtid_set logged_gtids; variable
|
H A D | mysqld.cc | 5945 const Gtid_set *logged_gtids= gtid_state->get_logged_gtids(); in win_main() local 5946 if (gtid_mode > 1 || !logged_gtids->is_empty()) in win_main() 5948 Previous_gtids_log_event prev_gtids_ev(logged_gtids); in win_main()
|
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
H A D | rpl_gtid_state.cc | 36 logged_gtids.clear(); in clear() 48 DBUG_ASSERT(!logged_gtids.contains_gtid(gtid)); in acquire_ownership() 154 ret= logged_gtids._add_gtid(g); in update_on_flush() 165 ret= logged_gtids._add_gtid(thd->owned_gtid); in update_on_flush() 251 Gtid_set::Const_interval_iterator ivit(&logged_gtids, sidno); in get_automatic_gno() 336 PROPAGATE_REPORTED_ERROR(logged_gtids.ensure_sidno(sidno)); in ensure_sidno() 341 DBUG_ASSERT(logged_gtids.get_max_sidno() >= sidno); in ensure_sidno() 357 if (!logged_gtids.is_empty()) in add_lost_gtids() 374 PROPAGATE_REPORTED_ERROR(logged_gtids.add_gtid_text(text)); in add_lost_gtids()
|
H A D | rpl_rli.cc | 913 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in wait_for_gtid_set() local 918 gtid->c_ptr_safe(), wait_gtid_set.is_subset(logged_gtids), in wait_for_gtid_set() 920 logged_gtids->dbug_print("gtid_executed:"); in wait_for_gtid_set() 927 if (wait_gtid_set.is_subset(logged_gtids) && in wait_for_gtid_set() 1416 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1417 if (until_sql_gtids.is_intersection_nonempty(logged_gtids)) in is_until_satisfied() 1450 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1451 if (until_sql_gtids.is_subset(logged_gtids)) in is_until_satisfied()
|
H A D | rpl_gtid_execution.cc | 293 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in skip_statement() local 295 DBUG_ASSERT(logged_gtids->contains_gtid(thd->variables.gtid_next.gtid)); in skip_statement()
|
H A D | rpl_gtid.h | 2114 logged_gtids(sid_map, sid_lock), in Gtid_state() 2149 bool ret= logged_gtids.contains_gtid(gtid); in is_logged() 2286 const Gtid_set *get_logged_gtids() const { return &logged_gtids; } in get_logged_gtids() 2307 logged_gtids.get_string_length() + in get_max_string_length() 2316 p+= logged_gtids.to_string(p); in to_string() 2377 Gtid_set logged_gtids; variable
|
H A D | mysqld.cc | 5955 const Gtid_set *logged_gtids= gtid_state->get_logged_gtids(); in win_main() local 5956 if (gtid_mode > 1 || !logged_gtids->is_empty()) in win_main() 5958 Previous_gtids_log_event prev_gtids_ev(logged_gtids); in win_main()
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
H A D | rpl_gtid_state.cc | 36 logged_gtids.clear(); in clear() 48 DBUG_ASSERT(!logged_gtids.contains_gtid(gtid)); in acquire_ownership() 154 ret= logged_gtids._add_gtid(g); in update_on_flush() 165 ret= logged_gtids._add_gtid(thd->owned_gtid); in update_on_flush() 251 Gtid_set::Const_interval_iterator ivit(&logged_gtids, sidno); in get_automatic_gno() 336 PROPAGATE_REPORTED_ERROR(logged_gtids.ensure_sidno(sidno)); in ensure_sidno() 341 DBUG_ASSERT(logged_gtids.get_max_sidno() >= sidno); in ensure_sidno() 357 if (!logged_gtids.is_empty()) in add_lost_gtids() 374 PROPAGATE_REPORTED_ERROR(logged_gtids.add_gtid_text(text)); in add_lost_gtids()
|
H A D | rpl_rli.cc | 913 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in wait_for_gtid_set() local 918 gtid->c_ptr_safe(), wait_gtid_set.is_subset(logged_gtids), in wait_for_gtid_set() 920 logged_gtids->dbug_print("gtid_executed:"); in wait_for_gtid_set() 927 if (wait_gtid_set.is_subset(logged_gtids) && in wait_for_gtid_set() 1416 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1417 if (until_sql_gtids.is_intersection_nonempty(logged_gtids)) in is_until_satisfied() 1450 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1451 if (until_sql_gtids.is_subset(logged_gtids)) in is_until_satisfied()
|
H A D | rpl_gtid_execution.cc | 293 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in skip_statement() local 295 DBUG_ASSERT(logged_gtids->contains_gtid(thd->variables.gtid_next.gtid)); in skip_statement()
|
H A D | rpl_gtid.h | 2114 logged_gtids(sid_map, sid_lock), in Gtid_state() 2149 bool ret= logged_gtids.contains_gtid(gtid); in is_logged() 2286 const Gtid_set *get_logged_gtids() const { return &logged_gtids; } in get_logged_gtids() 2307 logged_gtids.get_string_length() + in get_max_string_length() 2316 p+= logged_gtids.to_string(p); in to_string() 2377 Gtid_set logged_gtids; variable
|
H A D | mysqld.cc | 5955 const Gtid_set *logged_gtids= gtid_state->get_logged_gtids(); in win_main() local 5956 if (gtid_mode > 1 || !logged_gtids->is_empty()) in win_main() 5958 Previous_gtids_log_event prev_gtids_ev(logged_gtids); in win_main()
|
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/ |
H A D | rpl_gtid_state.cc | 36 logged_gtids.clear(); in clear() 48 DBUG_ASSERT(!logged_gtids.contains_gtid(gtid)); in acquire_ownership() 154 ret= logged_gtids._add_gtid(g); in update_on_flush() 165 ret= logged_gtids._add_gtid(thd->owned_gtid); in update_on_flush() 251 Gtid_set::Const_interval_iterator ivit(&logged_gtids, sidno); in get_automatic_gno() 336 PROPAGATE_REPORTED_ERROR(logged_gtids.ensure_sidno(sidno)); in ensure_sidno() 341 DBUG_ASSERT(logged_gtids.get_max_sidno() >= sidno); in ensure_sidno() 357 if (!logged_gtids.is_empty()) in add_lost_gtids() 374 PROPAGATE_REPORTED_ERROR(logged_gtids.add_gtid_text(text)); in add_lost_gtids()
|
H A D | rpl_rli.cc | 910 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in wait_for_gtid_set() local 915 gtid->c_ptr_safe(), wait_gtid_set.is_subset(logged_gtids), in wait_for_gtid_set() 917 logged_gtids->dbug_print("gtid_executed:"); in wait_for_gtid_set() 924 if (wait_gtid_set.is_subset(logged_gtids) && in wait_for_gtid_set() 1349 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1350 if (until_sql_gtids.is_intersection_nonempty(logged_gtids)) in is_until_satisfied() 1383 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1384 if (until_sql_gtids.is_subset(logged_gtids)) in is_until_satisfied()
|
H A D | rpl_gtid_execution.cc | 293 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in skip_statement() local 295 DBUG_ASSERT(logged_gtids->contains_gtid(thd->variables.gtid_next.gtid)); in skip_statement()
|
H A D | rpl_gtid.h | 2114 logged_gtids(sid_map, sid_lock), in Gtid_state() 2149 bool ret= logged_gtids.contains_gtid(gtid); in is_logged() 2286 const Gtid_set *get_logged_gtids() const { return &logged_gtids; } in get_logged_gtids() 2307 logged_gtids.get_string_length() + in get_max_string_length() 2316 p+= logged_gtids.to_string(p); in to_string() 2377 Gtid_set logged_gtids; variable
|
H A D | mysqld.cc | 6239 const Gtid_set *logged_gtids= gtid_state->get_logged_gtids(); in win_main() local 6240 if (gtid_mode > 1 || !logged_gtids->is_empty()) in win_main() 6242 Previous_gtids_log_event prev_gtids_ev(logged_gtids); in win_main()
|
/dports/databases/mysql56-client/mysql-5.6.51/sql/ |
H A D | rpl_gtid_state.cc | 36 logged_gtids.clear(); in clear() 48 DBUG_ASSERT(!logged_gtids.contains_gtid(gtid)); in acquire_ownership() 154 ret= logged_gtids._add_gtid(g); in update_on_flush() 165 ret= logged_gtids._add_gtid(thd->owned_gtid); in update_on_flush() 251 Gtid_set::Const_interval_iterator ivit(&logged_gtids, sidno); in get_automatic_gno() 336 PROPAGATE_REPORTED_ERROR(logged_gtids.ensure_sidno(sidno)); in ensure_sidno() 341 DBUG_ASSERT(logged_gtids.get_max_sidno() >= sidno); in ensure_sidno() 357 if (!logged_gtids.is_empty()) in add_lost_gtids() 374 PROPAGATE_REPORTED_ERROR(logged_gtids.add_gtid_text(text)); in add_lost_gtids()
|
H A D | rpl_rli.cc | 910 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in wait_for_gtid_set() local 915 gtid->c_ptr_safe(), wait_gtid_set.is_subset(logged_gtids), in wait_for_gtid_set() 917 logged_gtids->dbug_print("gtid_executed:"); in wait_for_gtid_set() 924 if (wait_gtid_set.is_subset(logged_gtids) && in wait_for_gtid_set() 1349 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1350 if (until_sql_gtids.is_intersection_nonempty(logged_gtids)) in is_until_satisfied() 1383 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in is_until_satisfied() local 1384 if (until_sql_gtids.is_subset(logged_gtids)) in is_until_satisfied()
|
H A D | rpl_gtid_execution.cc | 293 const Gtid_set* logged_gtids= gtid_state->get_logged_gtids(); in skip_statement() local 295 DBUG_ASSERT(logged_gtids->contains_gtid(thd->variables.gtid_next.gtid)); in skip_statement()
|
H A D | rpl_gtid.h | 2114 logged_gtids(sid_map, sid_lock), in Gtid_state() 2149 bool ret= logged_gtids.contains_gtid(gtid); in is_logged() 2286 const Gtid_set *get_logged_gtids() const { return &logged_gtids; } in get_logged_gtids() 2307 logged_gtids.get_string_length() + in get_max_string_length() 2316 p+= logged_gtids.to_string(p); in to_string() 2377 Gtid_set logged_gtids; variable
|
H A D | mysqld.cc | 5559 const Gtid_set *logged_gtids= gtid_state->get_logged_gtids(); in win_main() local 5560 if (gtid_mode > 1 || !logged_gtids->is_empty()) in win_main() 5562 Previous_gtids_log_event prev_gtids_ev(logged_gtids); in win_main()
|