/dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
H A D | transaction.cc | 84 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 D | transaction_info.cc | 28 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 D | xa.cc | 901 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 D | xa.h | 593 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 D | transaction.cc | 84 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 D | transaction_info.cc | 28 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 D | xa.cc | 901 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 D | xa.h | 593 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 D | transaction.cc | 84 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 D | transaction_info.cc | 28 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 D | xa.cc | 901 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 D | xa.h | 593 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 D | transaction.cc | 99 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 D | transaction_info.cc | 42 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 D | xa.cc | 87 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 D | transaction.cc | 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() 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 D | xa.cc | 900 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 D | transaction_info.cc | 28 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 D | transaction.cc | 84 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 D | transaction_info.cc | 28 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 D | xa.cc | 901 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 D | transaction.cc | 84 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 D | transaction_info.cc | 28 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 D | xa.cc | 980 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 D | xa.h | 593 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);
|