Home
last modified time | relevance | path

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

/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Drpl_gtid_state.cc36 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 Drpl_rli.cc913 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 Drpl_gtid_execution.cc293 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 Drpl_gtid.h2114 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 Dmysqld.cc5945 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 Drpl_gtid_state.cc36 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 Drpl_rli.cc913 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 Drpl_gtid_execution.cc293 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 Drpl_gtid.h2114 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 Dmysqld.cc5955 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 Drpl_gtid_state.cc36 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 Drpl_rli.cc913 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 Drpl_gtid_execution.cc293 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 Drpl_gtid.h2114 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 Dmysqld.cc5955 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 Drpl_gtid_state.cc36 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 Drpl_rli.cc910 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 Drpl_gtid_execution.cc293 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 Drpl_gtid.h2114 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 Dmysqld.cc6239 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 Drpl_gtid_state.cc36 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 Drpl_rli.cc910 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 Drpl_gtid_execution.cc293 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 Drpl_gtid.h2114 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 Dmysqld.cc5559 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()