Home
last modified time | relevance | path

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

12

/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Drpl_trx_tracking.cc149 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 Dhandler.cc1739 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 Dxa.cc1663 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 Drpl_trx_tracking.cc122 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 Dhandler.cc1791 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 Dxa.cc1335 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 Dbinlog.cc1652 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 Drpl_trx_tracking.cc122 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 Dhandler.cc1824 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 Dxa.cc1336 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 Drpl_trx_tracking.cc122 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 Dhandler.cc1819 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 Dxa.cc1415 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 Dbinlog.cc1702 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 Dwsrep_hton.cc103 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 Drpl_trx_tracking.cc122 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 Dhandler.cc1824 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 Dxa.cc1336 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 Drpl_trx_tracking.cc122 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 Dhandler.cc1791 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 Dxa.cc1336 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 Dbinlog.cc1652 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 Drpl_trx_tracking.cc122 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 Dhandler.cc1824 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 Dxa.cc1336 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()

12