/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/ |
H A D | rpl_trx_tracking.cc | 149 Transaction_ctx *trn_ctx = thd->get_transaction(); in get_dependency() local 151 DBUG_ASSERT(trn_ctx->sequence_number > in get_dependency() 165 trn_ctx->sequence_number - m_max_committed_transaction.get_offset(); in get_dependency() 167 if (trn_ctx->last_committed <= m_max_committed_transaction.get_offset()) in get_dependency() 171 std::max(trn_ctx->last_committed, m_last_blocking_transaction) - in get_dependency() 175 m_last_blocking_transaction = trn_ctx->sequence_number; in get_dependency() 378 Transaction_ctx *trn_ctx = thd->get_transaction(); in update_max_committed() local 379 m_commit_order.update_max_committed(trn_ctx->sequence_number); in update_max_committed() 383 trn_ctx->sequence_number = SEQ_UNINIT; in update_max_committed() 385 DBUG_ASSERT(trn_ctx->last_committed == SEQ_UNINIT || in update_max_committed()
|
H A D | handler.cc | 1739 if (!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) in ha_commit_trans() 1786 trn_ctx->cleanup(); in ha_commit_trans() 1947 trn_ctx->reset_scope(trx_scope); in ha_commit_low() 1964 if (all) trn_ctx->cleanup(); in ha_commit_low() 1970 trn_ctx->m_flags.commit_low = false; in ha_commit_low() 1980 trn_ctx->m_flags.run_hooks = false; in ha_commit_low() 2022 trn_ctx->reset_scope(trx_scope); in ha_rollback_low() 2044 trn_ctx->xid_state()->set_error(thd); in ha_rollback_low() 2104 trn_ctx->cleanup(); in ha_rollback_trans() 2206 trn_ctx->cleanup(); in ha_commit_attachable() [all …]
|
H A D | xa.cc | 1663 Transaction_ctx *trn_ctx = thd->get_transaction(); in applier_reset_xa_trans() local 1664 XID_STATE *xid_state = trn_ctx->xid_state(); in applier_reset_xa_trans() 1681 trn_ctx->reset_unsafe_rollback_flags(Transaction_ctx::STMT); in applier_reset_xa_trans() 1684 transaction_cache_detach(trn_ctx); in applier_reset_xa_trans() 1691 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, nullptr); in applier_reset_xa_trans() 1692 trn_ctx->set_no_2pc(Transaction_ctx::SESSION, false); in applier_reset_xa_trans() 1693 trn_ctx->cleanup(); in applier_reset_xa_trans()
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
H A D | rpl_trx_tracking.cc | 122 Transaction_ctx *trn_ctx= thd->get_transaction(); in get_dependency() local 124 DBUG_ASSERT(trn_ctx->sequence_number in get_dependency() 138 trn_ctx->sequence_number - m_max_committed_transaction.get_offset(); in get_dependency() 141 trn_ctx->last_committed <= m_max_committed_transaction.get_offset() in get_dependency() 143 : trn_ctx->last_committed - m_max_committed_transaction.get_offset(); in get_dependency() 371 Transaction_ctx *trn_ctx= thd->get_transaction(); in update_max_committed() local 372 m_commit_order.update_max_committed(trn_ctx->sequence_number); in update_max_committed() 376 trn_ctx->sequence_number= SEQ_UNINIT; in update_max_committed() 378 DBUG_ASSERT(trn_ctx->last_committed == SEQ_UNINIT || in update_max_committed()
|
H A D | handler.cc | 1791 if (!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) in ha_commit_trans() 1842 trn_ctx->cleanup(); in ha_commit_trans() 1923 trn_ctx->reset_scope(trx_scope); in ha_commit_low() 1931 trn_ctx->cleanup(); in ha_commit_low() 1937 trn_ctx->m_flags.commit_low= false; in ha_commit_low() 1949 trn_ctx->m_flags.run_hooks= false; in ha_commit_low() 1996 trn_ctx->reset_scope(trx_scope); in ha_rollback_low() 2087 trn_ctx->cleanup(); in ha_rollback_trans() 2113 trn_ctx->cannot_safely_rollback( in ha_rollback_trans() 2191 trn_ctx->cleanup(); in ha_commit_attachable() [all …]
|
H A D | xa.cc | 1335 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans() local 1336 XID_STATE *xid_state= trn_ctx->xid_state(); in applier_reset_xa_trans() 1343 trn_ctx->reset_unsafe_rollback_flags(Transaction_ctx::STMT); in applier_reset_xa_trans() 1346 transaction_cache_detach(trn_ctx); in applier_reset_xa_trans() 1353 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans() 1354 trn_ctx->set_no_2pc(Transaction_ctx::SESSION, false); in applier_reset_xa_trans() 1355 trn_ctx->cleanup(); in applier_reset_xa_trans()
|
H A D | binlog.cc | 1652 Transaction_ctx *trn_ctx= thd->get_transaction(); in flush() local 1666 if (trn_ctx->last_committed == SEQ_UNINIT) in flush() 1667 trn_ctx->last_committed= trn_ctx->sequence_number - 1; in flush() 2497 Transaction_ctx *trn_ctx= thd->get_transaction(); in rollback() local 8639 Transaction_ctx *trn_ctx= thd->get_transaction(); in commit() local 8640 my_xid xid= trn_ctx->xid_state()->get_xid()->get_my_xid(); in commit() 8665 YESNO(trn_ctx->no_2pc(trx_scope)), in commit() 8666 trn_ctx->rw_ha_count(trx_scope))); in commit() 8691 if (!all && !trn_ctx->is_active(trx_scope) && in commit() 8767 (all || !trn_ctx->is_active(Transaction_ctx::SESSION)); in commit() [all …]
|
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
H A D | rpl_trx_tracking.cc | 122 Transaction_ctx *trn_ctx= thd->get_transaction(); in get_dependency() local 124 assert(trn_ctx->sequence_number in get_dependency() 138 trn_ctx->sequence_number - m_max_committed_transaction.get_offset(); in get_dependency() 141 trn_ctx->last_committed <= m_max_committed_transaction.get_offset() in get_dependency() 143 : trn_ctx->last_committed - m_max_committed_transaction.get_offset(); in get_dependency() 373 Transaction_ctx *trn_ctx= thd->get_transaction(); in update_max_committed() local 374 m_commit_order.update_max_committed(trn_ctx->sequence_number); in update_max_committed() 378 trn_ctx->sequence_number= SEQ_UNINIT; in update_max_committed() 380 assert(trn_ctx->last_committed == SEQ_UNINIT || in update_max_committed()
|
H A D | handler.cc | 1824 if (!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) in ha_commit_trans() 1875 trn_ctx->cleanup(); in ha_commit_trans() 1959 trn_ctx->reset_scope(trx_scope); in ha_commit_low() 1967 trn_ctx->cleanup(); in ha_commit_low() 1973 trn_ctx->m_flags.commit_low= false; in ha_commit_low() 1985 trn_ctx->m_flags.run_hooks= false; in ha_commit_low() 2032 trn_ctx->reset_scope(trx_scope); in ha_rollback_low() 2125 trn_ctx->cleanup(); in ha_rollback_trans() 2151 trn_ctx->cannot_safely_rollback( in ha_rollback_trans() 2229 trn_ctx->cleanup(); in ha_commit_attachable() [all …]
|
H A D | xa.cc | 1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans() local 1337 XID_STATE *xid_state= trn_ctx->xid_state(); in applier_reset_xa_trans() 1344 trn_ctx->reset_unsafe_rollback_flags(Transaction_ctx::STMT); in applier_reset_xa_trans() 1347 transaction_cache_detach(trn_ctx); in applier_reset_xa_trans() 1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans() 1355 trn_ctx->set_no_2pc(Transaction_ctx::SESSION, false); in applier_reset_xa_trans() 1356 trn_ctx->cleanup(); in applier_reset_xa_trans()
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
H A D | rpl_trx_tracking.cc | 122 Transaction_ctx *trn_ctx= thd->get_transaction(); in get_dependency() local 124 assert(trn_ctx->sequence_number in get_dependency() 138 trn_ctx->sequence_number - m_max_committed_transaction.get_offset(); in get_dependency() 141 trn_ctx->last_committed <= m_max_committed_transaction.get_offset() in get_dependency() 143 : trn_ctx->last_committed - m_max_committed_transaction.get_offset(); in get_dependency() 373 Transaction_ctx *trn_ctx= thd->get_transaction(); in update_max_committed() local 374 m_commit_order.update_max_committed(trn_ctx->sequence_number); in update_max_committed() 378 trn_ctx->sequence_number= SEQ_UNINIT; in update_max_committed() 380 assert(trn_ctx->last_committed == SEQ_UNINIT || in update_max_committed()
|
H A D | handler.cc | 1819 if ((!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) || in ha_commit_trans() 1825 if (!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) in ha_commit_trans() 1883 trn_ctx->cleanup(); in ha_commit_trans() 1975 trn_ctx->reset_scope(trx_scope); in ha_commit_low() 1983 trn_ctx->cleanup(); in ha_commit_low() 1992 trn_ctx->m_flags.commit_low= false; in ha_commit_low() 2004 trn_ctx->m_flags.run_hooks= false; in ha_commit_low() 2061 trn_ctx->reset_scope(trx_scope); in ha_rollback_low() 2152 trn_ctx->cleanup(); in ha_rollback_trans() 2256 trn_ctx->cleanup(); in ha_commit_attachable() [all …]
|
H A D | xa.cc | 1415 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans() local 1416 XID_STATE *xid_state= trn_ctx->xid_state(); in applier_reset_xa_trans() 1423 trn_ctx->reset_unsafe_rollback_flags(Transaction_ctx::STMT); in applier_reset_xa_trans() 1426 transaction_cache_detach(trn_ctx); in applier_reset_xa_trans() 1433 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans() 1434 trn_ctx->set_no_2pc(Transaction_ctx::SESSION, false); in applier_reset_xa_trans() 1435 trn_ctx->cleanup(); in applier_reset_xa_trans()
|
H A D | binlog.cc | 1702 Transaction_ctx *trn_ctx= thd->get_transaction(); in flush() local 1716 if (trn_ctx->last_committed == SEQ_UNINIT) in flush() 1717 trn_ctx->last_committed= trn_ctx->sequence_number - 1; in flush() 2562 Transaction_ctx *trn_ctx= thd->get_transaction(); in rollback() local 8736 Transaction_ctx *trn_ctx= thd->get_transaction(); in commit() local 8742 my_xid xid= trn_ctx->xid_state()->get_xid()->get_my_xid(); in commit() 8768 YESNO(trn_ctx->no_2pc(trx_scope)), in commit() 8769 trn_ctx->rw_ha_count(trx_scope))); in commit() 8794 if (!all && !trn_ctx->is_active(trx_scope) && in commit() 8909 ((trn_ctx->rw_ha_count(trx_scope) > 1) || in commit() [all …]
|
H A D | wsrep_hton.cc | 103 Transaction_ctx *trn_ctx= thd->get_transaction(); in wsrep_register_hton() local 106 Ha_trx_info *ha_info= trn_ctx->ha_trx_info(trx_scope), *ha_info_next; in wsrep_register_hton()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
H A D | rpl_trx_tracking.cc | 122 Transaction_ctx *trn_ctx= thd->get_transaction(); in get_dependency() local 124 assert(trn_ctx->sequence_number in get_dependency() 138 trn_ctx->sequence_number - m_max_committed_transaction.get_offset(); in get_dependency() 141 trn_ctx->last_committed <= m_max_committed_transaction.get_offset() in get_dependency() 143 : trn_ctx->last_committed - m_max_committed_transaction.get_offset(); in get_dependency() 373 Transaction_ctx *trn_ctx= thd->get_transaction(); in update_max_committed() local 374 m_commit_order.update_max_committed(trn_ctx->sequence_number); in update_max_committed() 378 trn_ctx->sequence_number= SEQ_UNINIT; in update_max_committed() 380 assert(trn_ctx->last_committed == SEQ_UNINIT || in update_max_committed()
|
H A D | handler.cc | 1824 if (!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) in ha_commit_trans() 1875 trn_ctx->cleanup(); in ha_commit_trans() 1959 trn_ctx->reset_scope(trx_scope); in ha_commit_low() 1967 trn_ctx->cleanup(); in ha_commit_low() 1973 trn_ctx->m_flags.commit_low= false; in ha_commit_low() 1985 trn_ctx->m_flags.run_hooks= false; in ha_commit_low() 2032 trn_ctx->reset_scope(trx_scope); in ha_rollback_low() 2125 trn_ctx->cleanup(); in ha_rollback_trans() 2151 trn_ctx->cannot_safely_rollback( in ha_rollback_trans() 2229 trn_ctx->cleanup(); in ha_commit_attachable() [all …]
|
H A D | xa.cc | 1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans() local 1337 XID_STATE *xid_state= trn_ctx->xid_state(); in applier_reset_xa_trans() 1344 trn_ctx->reset_unsafe_rollback_flags(Transaction_ctx::STMT); in applier_reset_xa_trans() 1347 transaction_cache_detach(trn_ctx); in applier_reset_xa_trans() 1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans() 1355 trn_ctx->set_no_2pc(Transaction_ctx::SESSION, false); in applier_reset_xa_trans() 1356 trn_ctx->cleanup(); in applier_reset_xa_trans()
|
/dports/databases/mysql57-client/mysql-5.7.36/sql/ |
H A D | rpl_trx_tracking.cc | 122 Transaction_ctx *trn_ctx= thd->get_transaction(); in get_dependency() local 124 assert(trn_ctx->sequence_number in get_dependency() 138 trn_ctx->sequence_number - m_max_committed_transaction.get_offset(); in get_dependency() 141 trn_ctx->last_committed <= m_max_committed_transaction.get_offset() in get_dependency() 143 : trn_ctx->last_committed - m_max_committed_transaction.get_offset(); in get_dependency() 373 Transaction_ctx *trn_ctx= thd->get_transaction(); in update_max_committed() local 374 m_commit_order.update_max_committed(trn_ctx->sequence_number); in update_max_committed() 378 trn_ctx->sequence_number= SEQ_UNINIT; in update_max_committed() 380 assert(trn_ctx->last_committed == SEQ_UNINIT || in update_max_committed()
|
H A D | handler.cc | 1791 if (!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) in ha_commit_trans() 1842 trn_ctx->cleanup(); in ha_commit_trans() 1923 trn_ctx->reset_scope(trx_scope); in ha_commit_low() 1931 trn_ctx->cleanup(); in ha_commit_low() 1937 trn_ctx->m_flags.commit_low= false; in ha_commit_low() 1949 trn_ctx->m_flags.run_hooks= false; in ha_commit_low() 1996 trn_ctx->reset_scope(trx_scope); in ha_rollback_low() 2087 trn_ctx->cleanup(); in ha_rollback_trans() 2113 trn_ctx->cannot_safely_rollback( in ha_rollback_trans() 2191 trn_ctx->cleanup(); in ha_commit_attachable() [all …]
|
H A D | xa.cc | 1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans() local 1337 XID_STATE *xid_state= trn_ctx->xid_state(); in applier_reset_xa_trans() 1344 trn_ctx->reset_unsafe_rollback_flags(Transaction_ctx::STMT); in applier_reset_xa_trans() 1347 transaction_cache_detach(trn_ctx); in applier_reset_xa_trans() 1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans() 1355 trn_ctx->set_no_2pc(Transaction_ctx::SESSION, false); in applier_reset_xa_trans() 1356 trn_ctx->cleanup(); in applier_reset_xa_trans()
|
H A D | binlog.cc | 1652 Transaction_ctx *trn_ctx= thd->get_transaction(); in flush() local 1666 if (trn_ctx->last_committed == SEQ_UNINIT) in flush() 1667 trn_ctx->last_committed= trn_ctx->sequence_number - 1; in flush() 2498 Transaction_ctx *trn_ctx= thd->get_transaction(); in rollback() local 8639 Transaction_ctx *trn_ctx= thd->get_transaction(); in commit() local 8640 my_xid xid= trn_ctx->xid_state()->get_xid()->get_my_xid(); in commit() 8665 YESNO(trn_ctx->no_2pc(trx_scope)), in commit() 8666 trn_ctx->rw_ha_count(trx_scope))); in commit() 8691 if (!all && !trn_ctx->is_active(trx_scope) && in commit() 8767 (all || !trn_ctx->is_active(Transaction_ctx::SESSION)); in commit() [all …]
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
H A D | rpl_trx_tracking.cc | 122 Transaction_ctx *trn_ctx= thd->get_transaction(); in get_dependency() local 124 assert(trn_ctx->sequence_number in get_dependency() 138 trn_ctx->sequence_number - m_max_committed_transaction.get_offset(); in get_dependency() 141 trn_ctx->last_committed <= m_max_committed_transaction.get_offset() in get_dependency() 143 : trn_ctx->last_committed - m_max_committed_transaction.get_offset(); in get_dependency() 373 Transaction_ctx *trn_ctx= thd->get_transaction(); in update_max_committed() local 374 m_commit_order.update_max_committed(trn_ctx->sequence_number); in update_max_committed() 378 trn_ctx->sequence_number= SEQ_UNINIT; in update_max_committed() 380 assert(trn_ctx->last_committed == SEQ_UNINIT || in update_max_committed()
|
H A D | handler.cc | 1824 if (!trn_ctx->no_2pc(trx_scope) && (trn_ctx->rw_ha_count(trx_scope) > 1)) in ha_commit_trans() 1875 trn_ctx->cleanup(); in ha_commit_trans() 1959 trn_ctx->reset_scope(trx_scope); in ha_commit_low() 1967 trn_ctx->cleanup(); in ha_commit_low() 1973 trn_ctx->m_flags.commit_low= false; in ha_commit_low() 1985 trn_ctx->m_flags.run_hooks= false; in ha_commit_low() 2032 trn_ctx->reset_scope(trx_scope); in ha_rollback_low() 2125 trn_ctx->cleanup(); in ha_rollback_trans() 2151 trn_ctx->cannot_safely_rollback( in ha_rollback_trans() 2229 trn_ctx->cleanup(); in ha_commit_attachable() [all …]
|
H A D | xa.cc | 1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans() local 1337 XID_STATE *xid_state= trn_ctx->xid_state(); in applier_reset_xa_trans() 1344 trn_ctx->reset_unsafe_rollback_flags(Transaction_ctx::STMT); in applier_reset_xa_trans() 1347 transaction_cache_detach(trn_ctx); in applier_reset_xa_trans() 1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans() 1355 trn_ctx->set_no_2pc(Transaction_ctx::SESSION, false); in applier_reset_xa_trans() 1356 trn_ctx->cleanup(); in applier_reset_xa_trans()
|