Home
last modified time | relevance | path

Searched refs:orig_thd (Results 1 – 25 of 52) sorted by relevance

123

/dports/databases/mariadb104-server/mariadb-10.4.24/sql/
H A Dwsrep_high_priority_service.cc600 , m_orig_thd(orig_thd) in Wsrep_replayer_service()
608 DBUG_ASSERT(!orig_thd->m_reprepare_observer); in Wsrep_replayer_service()
626 if (orig_thd->locked_tables_mode && orig_thd->lock) in Wsrep_replayer_service()
629 orig_thd->thread_id); in Wsrep_replayer_service()
630 orig_thd->locked_tables_list.unlock_locked_tables(orig_thd); in Wsrep_replayer_service()
634 thd_proc_info(orig_thd, "wsrep replaying trx"); in Wsrep_replayer_service()
643 wsrep_reset_threadvars(orig_thd); in Wsrep_replayer_service()
653 THD* orig_thd= m_orig_thd; in ~Wsrep_replayer_service() local
660 wsrep_store_threadvars(orig_thd); in ~Wsrep_replayer_service()
668 orig_thd->reset_kill_query(); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_server_service.h89 wsrep_create_streaming_applier(THD *orig_thd, const char *ctx);
99 wsrep_create_storage_service(THD *orig_thd, const char *ctx);
H A Dwsrep_schema.cc165 thd_context_switch(THD *orig_thd, THD *cur_thd) in thd_context_switch() argument
166 : m_orig_thd(orig_thd) in thd_context_switch()
1205 int Wsrep_schema::replay_transaction(THD* orig_thd, in replay_transaction() argument
1214 thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in replay_transaction()
1221 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, &thd); in replay_transaction()
1267 Wsrep_schema_impl::thd_context_switch thd_context_switch(&thd, orig_thd); in replay_transaction()
1269 ret= wsrep_apply_events(orig_thd, rli, buf.c_ptr_quick(), buf.length()); in replay_transaction()
1323 int Wsrep_schema::recover_sr_transactions(THD *orig_thd) in recover_sr_transactions() argument
1327 storage_thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in recover_sr_transactions()
1336 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, in recover_sr_transactions()
H A Dwsrep_schema.h134 int recover_sr_transactions(THD* orig_thd);
H A Dwsrep_server_service.cc88 wsrep_create_streaming_applier(THD *orig_thd, const char *ctx) in wsrep_create_streaming_applier() argument
102 init_service_thd(thd, orig_thd->thread_stack); in wsrep_create_streaming_applier()
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/
H A Dwsrep_high_priority_service.cc600 , m_orig_thd(orig_thd) in Wsrep_replayer_service()
608 DBUG_ASSERT(!orig_thd->m_reprepare_observer); in Wsrep_replayer_service()
626 if (orig_thd->locked_tables_mode && orig_thd->lock) in Wsrep_replayer_service()
629 orig_thd->thread_id); in Wsrep_replayer_service()
630 orig_thd->locked_tables_list.unlock_locked_tables(orig_thd); in Wsrep_replayer_service()
634 thd_proc_info(orig_thd, "wsrep replaying trx"); in Wsrep_replayer_service()
643 wsrep_reset_threadvars(orig_thd); in Wsrep_replayer_service()
653 THD* orig_thd= m_orig_thd; in ~Wsrep_replayer_service() local
660 wsrep_store_threadvars(orig_thd); in ~Wsrep_replayer_service()
668 orig_thd->reset_kill_query(); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_server_service.h89 wsrep_create_streaming_applier(THD *orig_thd, const char *ctx);
99 wsrep_create_storage_service(THD *orig_thd, const char *ctx);
H A Dwsrep_schema.cc165 thd_context_switch(THD *orig_thd, THD *cur_thd) in thd_context_switch() argument
166 : m_orig_thd(orig_thd) in thd_context_switch()
1205 int Wsrep_schema::replay_transaction(THD* orig_thd, in replay_transaction() argument
1214 thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in replay_transaction()
1221 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, &thd); in replay_transaction()
1267 Wsrep_schema_impl::thd_context_switch thd_context_switch(&thd, orig_thd); in replay_transaction()
1269 ret= wsrep_apply_events(orig_thd, rli, buf.c_ptr_quick(), buf.length()); in replay_transaction()
1323 int Wsrep_schema::recover_sr_transactions(THD *orig_thd) in recover_sr_transactions() argument
1327 storage_thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in recover_sr_transactions()
1336 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, in recover_sr_transactions()
H A Dwsrep_schema.h134 int recover_sr_transactions(THD* orig_thd);
H A Dwsrep_server_service.cc88 wsrep_create_streaming_applier(THD *orig_thd, const char *ctx) in wsrep_create_streaming_applier() argument
102 init_service_thd(thd, orig_thd->thread_stack); in wsrep_create_streaming_applier()
/dports/databases/mariadb105-client/mariadb-10.5.15/sql/
H A Dwsrep_high_priority_service.cc622 , m_orig_thd(orig_thd) in Wsrep_replayer_service()
630 DBUG_ASSERT(!orig_thd->m_reprepare_observer); in Wsrep_replayer_service()
648 if (orig_thd->locked_tables_mode && orig_thd->lock) in Wsrep_replayer_service()
651 orig_thd->thread_id); in Wsrep_replayer_service()
652 orig_thd->locked_tables_list.unlock_locked_tables(orig_thd); in Wsrep_replayer_service()
656 thd_proc_info(orig_thd, "wsrep replaying trx"); in Wsrep_replayer_service()
665 wsrep_reset_threadvars(orig_thd); in Wsrep_replayer_service()
675 THD* orig_thd= m_orig_thd; in ~Wsrep_replayer_service() local
682 wsrep_store_threadvars(orig_thd); in ~Wsrep_replayer_service()
690 orig_thd->reset_kill_query(); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_server_service.h89 wsrep_create_streaming_applier(THD *orig_thd, const char *ctx);
99 wsrep_create_storage_service(THD *orig_thd, const char *ctx);
H A Dwsrep_schema.cc184 thd_context_switch(THD *orig_thd, THD *cur_thd) in thd_context_switch() argument
185 : m_orig_thd(orig_thd) in thd_context_switch()
1233 int Wsrep_schema::replay_transaction(THD* orig_thd, in replay_transaction() argument
1242 thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in replay_transaction()
1249 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, &thd); in replay_transaction()
1295 Wsrep_schema_impl::thd_context_switch thd_context_switch(&thd, orig_thd); in replay_transaction()
1297 ret= wsrep_apply_events(orig_thd, rli, buf.c_ptr_quick(), buf.length()); in replay_transaction()
1351 int Wsrep_schema::recover_sr_transactions(THD *orig_thd) in recover_sr_transactions() argument
1355 storage_thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in recover_sr_transactions()
1364 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, in recover_sr_transactions()
H A Dwsrep_schema.h134 int recover_sr_transactions(THD* orig_thd);
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/
H A Dwsrep_high_priority_service.cc622 , m_orig_thd(orig_thd) in Wsrep_replayer_service()
630 DBUG_ASSERT(!orig_thd->m_reprepare_observer); in Wsrep_replayer_service()
648 if (orig_thd->locked_tables_mode && orig_thd->lock) in Wsrep_replayer_service()
651 orig_thd->thread_id); in Wsrep_replayer_service()
652 orig_thd->locked_tables_list.unlock_locked_tables(orig_thd); in Wsrep_replayer_service()
656 thd_proc_info(orig_thd, "wsrep replaying trx"); in Wsrep_replayer_service()
665 wsrep_reset_threadvars(orig_thd); in Wsrep_replayer_service()
675 THD* orig_thd= m_orig_thd; in ~Wsrep_replayer_service() local
682 wsrep_store_threadvars(orig_thd); in ~Wsrep_replayer_service()
690 orig_thd->reset_kill_query(); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_server_service.h89 wsrep_create_streaming_applier(THD *orig_thd, const char *ctx);
99 wsrep_create_storage_service(THD *orig_thd, const char *ctx);
H A Dwsrep_schema.cc184 thd_context_switch(THD *orig_thd, THD *cur_thd) in thd_context_switch() argument
185 : m_orig_thd(orig_thd) in thd_context_switch()
1233 int Wsrep_schema::replay_transaction(THD* orig_thd, in replay_transaction() argument
1242 thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in replay_transaction()
1249 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, &thd); in replay_transaction()
1295 Wsrep_schema_impl::thd_context_switch thd_context_switch(&thd, orig_thd); in replay_transaction()
1297 ret= wsrep_apply_events(orig_thd, rli, buf.c_ptr_quick(), buf.length()); in replay_transaction()
1351 int Wsrep_schema::recover_sr_transactions(THD *orig_thd) in recover_sr_transactions() argument
1355 storage_thd.thread_stack= (orig_thd ? orig_thd->thread_stack : in recover_sr_transactions()
1364 Wsrep_schema_impl::thd_context_switch thd_context_switch(orig_thd, in recover_sr_transactions()
H A Dwsrep_schema.h134 int recover_sr_transactions(THD* orig_thd);
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/
H A Dopt_costconstantcache.cc384 THD *orig_thd = current_thd; in read_cost_constants() local
418 if (orig_thd) orig_thd->store_globals(); in read_cost_constants()
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Dopt_costconstantcache.cc438 THD *orig_thd= current_thd; in read_cost_constants() local
480 if(orig_thd) in read_cost_constants()
481 orig_thd->store_globals(); in read_cost_constants()
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dopt_costconstantcache.cc438 THD *orig_thd= current_thd; in read_cost_constants() local
480 if(orig_thd) in read_cost_constants()
481 orig_thd->store_globals(); in read_cost_constants()
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/
H A Dopt_costconstantcache.cc438 THD *orig_thd= current_thd; in read_cost_constants() local
480 if(orig_thd) in read_cost_constants()
481 orig_thd->store_globals(); in read_cost_constants()
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Dopt_costconstantcache.cc438 THD *orig_thd= current_thd; in read_cost_constants() local
480 if(orig_thd) in read_cost_constants()
481 orig_thd->store_globals(); in read_cost_constants()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/
H A Dopt_costconstantcache.cc438 THD *orig_thd= current_thd; in read_cost_constants() local
480 if(orig_thd) in read_cost_constants()
481 orig_thd->store_globals(); in read_cost_constants()
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Dopt_costconstantcache.cc438 THD *orig_thd= current_thd; in read_cost_constants() local
480 if(orig_thd) in read_cost_constants()
481 orig_thd->store_globals(); in read_cost_constants()

123