Lines Matching refs:trn_ctx

1380   Transaction_ctx *trn_ctx= thd->get_transaction();  in trans_register_ha()  local
1387 Ha_trx_info *knownn_trans= trn_ctx->ha_trx_info(trx_scope); in trans_register_ha()
1412 trn_ctx->set_ha_trx_info(trx_scope, ha_info); in trans_register_ha()
1415 trn_ctx->set_no_2pc(trx_scope, true); in trans_register_ha()
1417 trn_ctx->xid_state()->set_query_id(thd->query_id); in trans_register_ha()
1433 const XID *xid= trn_ctx->xid_state()->get_xid(); in trans_register_ha()
1454 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_prepare() local
1457 if (trn_ctx->is_active(Transaction_ctx::SESSION)) in ha_prepare()
1459 const Ha_trx_info *ha_info= trn_ctx->ha_trx_info( in ha_prepare()
1708 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_commit_trans() local
1720 all || !trn_ctx->is_active(Transaction_ctx::SESSION); in ha_commit_trans()
1722 Ha_trx_info *ha_info= trn_ctx->ha_trx_info(trx_scope); in ha_commit_trans()
1723 XID_STATE *xid_state= trn_ctx->xid_state(); in ha_commit_trans()
1735 assert(!trn_ctx->is_active(Transaction_ctx::STMT) || in ha_commit_trans()
1769 trn_ctx->set_rw_ha_count(trx_scope, rw_ha_count); in ha_commit_trans()
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()
1926 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_commit_low() local
1929 Ha_trx_info *ha_info= trn_ctx->ha_trx_info(trx_scope), *ha_info_next; in ha_commit_low()
1975 trn_ctx->reset_scope(trx_scope); in ha_commit_low()
1978 trn_ctx->invalidate_changed_tables_in_cache(); 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()
2012 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_rollback_low() local
2016 Ha_trx_info *ha_info= trn_ctx->ha_trx_info(trx_scope), *ha_info_next; in ha_rollback_low()
2029 assert(trn_ctx->xid_state()->get_state() != XID_STATE::XA_NOTR || in ha_rollback_low()
2061 trn_ctx->reset_scope(trx_scope); in ha_rollback_low()
2083 trn_ctx->xid_state()->set_error(thd); in ha_rollback_low()
2093 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_rollback_trans() local
2094 bool is_xa_rollback= trn_ctx->xid_state()->has_state(XID_STATE::XA_PREPARED); in ha_rollback_trans()
2110 all || !trn_ctx->is_active(Transaction_ctx::SESSION); in ha_rollback_trans()
2118 assert(!trn_ctx->is_active(Transaction_ctx::STMT) || in ha_rollback_trans()
2152 trn_ctx->cleanup(); in ha_rollback_trans()
2178 trn_ctx->cannot_safely_rollback( in ha_rollback_trans()
2181 trn_ctx->push_unsafe_rollback_warnings(thd); in ha_rollback_trans()
2204 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_commit_attachable() local
2205 Ha_trx_info *ha_info= trn_ctx->ha_trx_info(Transaction_ctx::STMT); in ha_commit_attachable()
2214 assert(! trn_ctx->is_active(Transaction_ctx::SESSION)); in ha_commit_attachable()
2241 trn_ctx->reset_scope(Transaction_ctx::STMT); in ha_commit_attachable()
2256 trn_ctx->cleanup(); in ha_commit_attachable()
2284 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_release_temporary_latches() local
2292 for (info= trn_ctx->ha_trx_info(Transaction_ctx::STMT); in ha_release_temporary_latches()
2315 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_rollback_to_savepoint_can_release_mdl() local
2325 for (ha_info= trn_ctx->ha_trx_info(trx_scope); in ha_rollback_to_savepoint_can_release_mdl()
2342 Transaction_ctx *trn_ctx= thd->get_transaction(); in ha_rollback_to_savepoint() local
2350 trn_ctx->set_rw_ha_count(trx_scope, 0); in ha_rollback_to_savepoint()
2351 trn_ctx->set_no_2pc(trx_scope, 0); in ha_rollback_to_savepoint()
2371 trn_ctx->set_no_2pc(trx_scope, true); in ha_rollback_to_savepoint()
2378 for (ha_info= trn_ctx->ha_trx_info(trx_scope); ha_info != sv->ha_list; in ha_rollback_to_savepoint()
2393 trn_ctx->set_ha_trx_info(trx_scope, sv->ha_list); in ha_rollback_to_savepoint()