Home
last modified time | relevance | path

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

12345678910

/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dtransaction.cc84 assert(thd->get_transaction()->is_empty(Transaction_ctx::STMT)); in trans_check_state()
366 Transaction_ctx::SESSION); in trans_rollback()
415 Transaction_ctx::SESSION); in trans_rollback_implicit()
463 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_commit_stmt()
479 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_stmt()
513 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_rollback_stmt()
536 Transaction_ctx::STMT)) in trans_rollback_stmt()
548 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_rollback_stmt()
582 cannot_safely_rollback(Transaction_ctx::STMT)); in trans_commit_attachable()
592 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_attachable()
[all …]
H A Dtransaction_info.cc28 Transaction_ctx::Transaction_ctx() in Transaction_ctx() function in Transaction_ctx
41 void Transaction_ctx::push_unsafe_rollback_warnings(THD *thd) in push_unsafe_rollback_warnings()
60 bool Transaction_ctx::add_changed_table(const char *key, long key_length) in add_changed_table()
110 CHANGED_TABLE_LIST* Transaction_ctx::changed_table_dup(const char *key, in changed_table_dup()
H A Dxa.cc901 Transaction_ctx *transaction; in trans_xa_recover()
1138 Transaction_ctx *transaction= (Transaction_ctx*)ptr; in transaction_free_hash()
1187 Transaction_ctx *transaction_cache_search(XID *xid) in transaction_cache_search()
1191 Transaction_ctx *res= in transaction_cache_search()
1192 (Transaction_ctx *)my_hash_search(&transaction_cache, in transaction_cache_search()
1218 Transaction_ctx *transaction= new (std::nothrow) Transaction_ctx(); in create_and_insert_new_transaction()
1233 bool transaction_cache_detach(Transaction_ctx *transaction) in transaction_cache_detach()
1282 void transaction_cache_delete(Transaction_ctx *transaction) in transaction_cache_delete()
1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans()
1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans()
[all …]
H A Dxa.h593 class Transaction_ctx; variable
618 Transaction_ctx *transaction_cache_search(XID *xid);
634 bool transaction_cache_insert(XID *xid, Transaction_ctx *transaction);
649 bool transaction_cache_detach(Transaction_ctx *transaction);
674 void transaction_cache_delete(Transaction_ctx *transaction);
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Dtransaction.cc84 assert(thd->get_transaction()->is_empty(Transaction_ctx::STMT)); in trans_check_state()
366 Transaction_ctx::SESSION); in trans_rollback()
415 Transaction_ctx::SESSION); in trans_rollback_implicit()
463 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_commit_stmt()
479 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_stmt()
513 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_rollback_stmt()
536 Transaction_ctx::STMT)) in trans_rollback_stmt()
548 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_rollback_stmt()
582 cannot_safely_rollback(Transaction_ctx::STMT)); in trans_commit_attachable()
592 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_attachable()
[all …]
H A Dtransaction_info.cc28 Transaction_ctx::Transaction_ctx() in Transaction_ctx() function in Transaction_ctx
41 void Transaction_ctx::push_unsafe_rollback_warnings(THD *thd) in push_unsafe_rollback_warnings()
60 bool Transaction_ctx::add_changed_table(const char *key, long key_length) in add_changed_table()
110 CHANGED_TABLE_LIST* Transaction_ctx::changed_table_dup(const char *key, in changed_table_dup()
H A Dxa.cc901 Transaction_ctx *transaction; in trans_xa_recover()
1138 Transaction_ctx *transaction= (Transaction_ctx*)ptr; in transaction_free_hash()
1187 Transaction_ctx *transaction_cache_search(XID *xid) in transaction_cache_search()
1191 Transaction_ctx *res= in transaction_cache_search()
1192 (Transaction_ctx *)my_hash_search(&transaction_cache, in transaction_cache_search()
1218 Transaction_ctx *transaction= new (std::nothrow) Transaction_ctx(); in create_and_insert_new_transaction()
1233 bool transaction_cache_detach(Transaction_ctx *transaction) in transaction_cache_detach()
1282 void transaction_cache_delete(Transaction_ctx *transaction) in transaction_cache_delete()
1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans()
1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans()
[all …]
H A Dxa.h593 class Transaction_ctx; variable
618 Transaction_ctx *transaction_cache_search(XID *xid);
634 bool transaction_cache_insert(XID *xid, Transaction_ctx *transaction);
649 bool transaction_cache_detach(Transaction_ctx *transaction);
674 void transaction_cache_delete(Transaction_ctx *transaction);
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Dtransaction.cc84 assert(thd->get_transaction()->is_empty(Transaction_ctx::STMT)); in trans_check_state()
366 Transaction_ctx::SESSION); in trans_rollback()
415 Transaction_ctx::SESSION); in trans_rollback_implicit()
463 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_commit_stmt()
479 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_stmt()
513 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_rollback_stmt()
536 Transaction_ctx::STMT)) in trans_rollback_stmt()
548 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_rollback_stmt()
582 cannot_safely_rollback(Transaction_ctx::STMT)); in trans_commit_attachable()
592 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_attachable()
[all …]
H A Dtransaction_info.cc28 Transaction_ctx::Transaction_ctx() in Transaction_ctx() function in Transaction_ctx
41 void Transaction_ctx::push_unsafe_rollback_warnings(THD *thd) in push_unsafe_rollback_warnings()
60 bool Transaction_ctx::add_changed_table(const char *key, long key_length) in add_changed_table()
110 CHANGED_TABLE_LIST* Transaction_ctx::changed_table_dup(const char *key, in changed_table_dup()
H A Dxa.cc901 Transaction_ctx *transaction; in trans_xa_recover()
1138 Transaction_ctx *transaction= (Transaction_ctx*)ptr; in transaction_free_hash()
1187 Transaction_ctx *transaction_cache_search(XID *xid) in transaction_cache_search()
1191 Transaction_ctx *res= in transaction_cache_search()
1192 (Transaction_ctx *)my_hash_search(&transaction_cache, in transaction_cache_search()
1218 Transaction_ctx *transaction= new (std::nothrow) Transaction_ctx(); in create_and_insert_new_transaction()
1233 bool transaction_cache_detach(Transaction_ctx *transaction) in transaction_cache_detach()
1282 void transaction_cache_delete(Transaction_ctx *transaction) in transaction_cache_delete()
1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans()
1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans()
[all …]
H A Dxa.h593 class Transaction_ctx; variable
618 Transaction_ctx *transaction_cache_search(XID *xid);
634 bool transaction_cache_insert(XID *xid, Transaction_ctx *transaction);
649 bool transaction_cache_detach(Transaction_ctx *transaction);
674 void transaction_cache_delete(Transaction_ctx *transaction);
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Dtransaction.cc99 DBUG_ASSERT(thd->get_transaction()->is_empty(Transaction_ctx::STMT)); in trans_check_state()
327 DBUG_ASSERT(thd->get_transaction()->is_empty(Transaction_ctx::STMT) && in trans_commit_implicit()
459 DBUG_ASSERT(thd->get_transaction()->is_empty(Transaction_ctx::STMT) && in trans_rollback_implicit()
531 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) { in trans_commit_stmt()
545 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_stmt()
577 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) { in trans_rollback_stmt()
596 Transaction_ctx::STMT)) in trans_rollback_stmt()
620 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_rollback_stmt()
654 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) { in trans_commit_attachable()
660 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_attachable()
[all …]
H A Dtransaction_info.cc42 Transaction_ctx::Transaction_ctx() in Transaction_ctx() function in Transaction_ctx
57 void Transaction_ctx::push_unsafe_rollback_warnings(THD *thd) { in push_unsafe_rollback_warnings()
76 void Transaction_ctx::register_ha(enum_trx_scope scope, Ha_trx_info *ha_info, in register_ha()
H A Dxa.cc87 void operator()(Transaction_ctx *) const;
465 static std::shared_ptr<Transaction_ctx>
484 std::shared_ptr<Transaction_ctx> transaction = in find_trn_for_recover_and_check_its_state()
588 std::shared_ptr<Transaction_ctx> transaction = in process_external_xa_commit()
880 std::shared_ptr<Transaction_ctx> transaction = in process_external_xa_rollback()
1510 std::shared_ptr<Transaction_ctx> res{nullptr}; in transaction_cache_search()
1545 Transaction_ctx *transaction = new (std::nothrow) Transaction_ctx(); in create_and_insert_new_transaction()
1557 std::shared_ptr<Transaction_ctx>( in create_and_insert_new_transaction()
1562 bool transaction_cache_detach(Transaction_ctx *transaction) { in transaction_cache_detach()
1663 Transaction_ctx *trn_ctx = thd->get_transaction(); in applier_reset_xa_trans()
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Dtransaction.cc366 Transaction_ctx::SESSION); in trans_rollback()
415 Transaction_ctx::SESSION); in trans_rollback_implicit()
463 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_commit_stmt()
479 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_stmt()
513 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_rollback_stmt()
536 Transaction_ctx::STMT)) in trans_rollback_stmt()
548 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_rollback_stmt()
582 cannot_safely_rollback(Transaction_ctx::STMT)); in trans_commit_attachable()
585 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_commit_attachable()
592 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_attachable()
[all …]
H A Dxa.cc900 Transaction_ctx *transaction; in trans_xa_recover()
1137 Transaction_ctx *transaction= (Transaction_ctx*)ptr; in transaction_free_hash()
1186 Transaction_ctx *transaction_cache_search(XID *xid) in transaction_cache_search()
1190 Transaction_ctx *res= in transaction_cache_search()
1191 (Transaction_ctx *)my_hash_search(&transaction_cache, in transaction_cache_search()
1217 Transaction_ctx *transaction= new (std::nothrow) Transaction_ctx(); in create_and_insert_new_transaction()
1232 bool transaction_cache_detach(Transaction_ctx *transaction) in transaction_cache_detach()
1281 void transaction_cache_delete(Transaction_ctx *transaction) in transaction_cache_delete()
1335 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans()
1353 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans()
[all …]
H A Dtransaction_info.cc28 Transaction_ctx::Transaction_ctx() in Transaction_ctx() function in Transaction_ctx
41 void Transaction_ctx::push_unsafe_rollback_warnings(THD *thd) in push_unsafe_rollback_warnings()
60 bool Transaction_ctx::add_changed_table(const char *key, long key_length) in add_changed_table()
110 CHANGED_TABLE_LIST* Transaction_ctx::changed_table_dup(const char *key, in changed_table_dup()
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Dtransaction.cc84 assert(thd->get_transaction()->is_empty(Transaction_ctx::STMT)); in trans_check_state()
366 Transaction_ctx::SESSION); in trans_rollback()
415 Transaction_ctx::SESSION); in trans_rollback_implicit()
463 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_commit_stmt()
479 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_stmt()
513 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_rollback_stmt()
536 Transaction_ctx::STMT)) in trans_rollback_stmt()
548 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_rollback_stmt()
582 cannot_safely_rollback(Transaction_ctx::STMT)); in trans_commit_attachable()
592 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_attachable()
[all …]
H A Dtransaction_info.cc28 Transaction_ctx::Transaction_ctx() in Transaction_ctx() function in Transaction_ctx
41 void Transaction_ctx::push_unsafe_rollback_warnings(THD *thd) in push_unsafe_rollback_warnings()
60 bool Transaction_ctx::add_changed_table(const char *key, long key_length) in add_changed_table()
110 CHANGED_TABLE_LIST* Transaction_ctx::changed_table_dup(const char *key, in changed_table_dup()
H A Dxa.cc901 Transaction_ctx *transaction; in trans_xa_recover()
1138 Transaction_ctx *transaction= (Transaction_ctx*)ptr; in transaction_free_hash()
1187 Transaction_ctx *transaction_cache_search(XID *xid) in transaction_cache_search()
1191 Transaction_ctx *res= in transaction_cache_search()
1192 (Transaction_ctx *)my_hash_search(&transaction_cache, in transaction_cache_search()
1218 Transaction_ctx *transaction= new (std::nothrow) Transaction_ctx(); in create_and_insert_new_transaction()
1233 bool transaction_cache_detach(Transaction_ctx *transaction) in transaction_cache_detach()
1282 void transaction_cache_delete(Transaction_ctx *transaction) in transaction_cache_delete()
1336 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans()
1354 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans()
[all …]
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Dtransaction.cc84 assert(thd->get_transaction()->is_empty(Transaction_ctx::STMT)); in trans_check_state()
399 Transaction_ctx::SESSION); in trans_rollback()
451 Transaction_ctx::SESSION); in trans_rollback_implicit()
499 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_commit_stmt()
525 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_stmt()
559 if (thd->get_transaction()->is_active(Transaction_ctx::STMT)) in trans_rollback_stmt()
585 Transaction_ctx::STMT)) in trans_rollback_stmt()
597 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_rollback_stmt()
631 cannot_safely_rollback(Transaction_ctx::STMT)); in trans_commit_attachable()
641 thd->get_transaction()->reset(Transaction_ctx::STMT); in trans_commit_attachable()
[all …]
H A Dtransaction_info.cc28 Transaction_ctx::Transaction_ctx() in Transaction_ctx() function in Transaction_ctx
41 void Transaction_ctx::push_unsafe_rollback_warnings(THD *thd) in push_unsafe_rollback_warnings()
60 bool Transaction_ctx::add_changed_table(const char *key, long key_length) in add_changed_table()
110 CHANGED_TABLE_LIST* Transaction_ctx::changed_table_dup(const char *key, in changed_table_dup()
H A Dxa.cc980 Transaction_ctx *transaction; in trans_xa_recover()
1217 Transaction_ctx *transaction= (Transaction_ctx*)ptr; in transaction_free_hash()
1266 Transaction_ctx *transaction_cache_search(XID *xid) in transaction_cache_search()
1270 Transaction_ctx *res= in transaction_cache_search()
1271 (Transaction_ctx *)my_hash_search(&transaction_cache, in transaction_cache_search()
1297 Transaction_ctx *transaction= new (std::nothrow) Transaction_ctx(); in create_and_insert_new_transaction()
1312 bool transaction_cache_detach(Transaction_ctx *transaction) in transaction_cache_detach()
1361 void transaction_cache_delete(Transaction_ctx *transaction) in transaction_cache_delete()
1415 Transaction_ctx *trn_ctx= thd->get_transaction(); in applier_reset_xa_trans()
1433 trn_ctx->set_ha_trx_info(Transaction_ctx::SESSION, NULL); in applier_reset_xa_trans()
[all …]
H A Dxa.h593 class Transaction_ctx; variable
618 Transaction_ctx *transaction_cache_search(XID *xid);
634 bool transaction_cache_insert(XID *xid, Transaction_ctx *transaction);
649 bool transaction_cache_detach(Transaction_ctx *transaction);
674 void transaction_cache_delete(Transaction_ctx *transaction);

12345678910