Home
last modified time | relevance | path

Searched refs:replayer_thd (Results 1 – 12 of 12) sorted by relevance

/dports/databases/mariadb105-client/mariadb-10.5.15/sql/
H A Dwsrep_client_service.cc264 THD *replayer_thd= new THD(true, true); in replay() local
265 replayer_thd->thread_stack= m_thd->thread_stack; in replay()
266 replayer_thd->real_id= pthread_self(); in replay()
267 replayer_thd->prior_thr_create_utime= in replay()
268 replayer_thd->start_utime= microsecond_interval_timer(); in replay()
269 replayer_thd->set_command(COM_SLEEP); in replay()
270 replayer_thd->reset_for_next_command(true); in replay()
274 Wsrep_replayer_service replayer_service(replayer_thd, m_thd); in replay()
275 wsrep::provider& provider(replayer_thd->wsrep_cs().provider()); in replay()
276 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(), in replay()
[all …]
H A Dwsrep_high_priority_service.cc621 : Wsrep_high_priority_service(replayer_thd) in Wsrep_replayer_service()
664 wsrep_assign_from_threadvars(replayer_thd); in Wsrep_replayer_service()
666 wsrep_store_threadvars(replayer_thd); in Wsrep_replayer_service()
667 wsrep_open(replayer_thd); in Wsrep_replayer_service()
668 wsrep_before_command(replayer_thd); in Wsrep_replayer_service()
674 THD* replayer_thd= m_thd; in ~Wsrep_replayer_service() local
678 wsrep_after_apply(replayer_thd); in ~Wsrep_replayer_service()
679 wsrep_after_command_ignore_result(replayer_thd); in ~Wsrep_replayer_service()
680 wsrep_close(replayer_thd); in ~Wsrep_replayer_service()
681 wsrep_reset_threadvars(replayer_thd); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_high_priority_service.h98 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);
/dports/databases/mariadb104-server/mariadb-10.4.24/sql/
H A Dwsrep_client_service.cc265 THD *replayer_thd= new THD(true, true); in replay() local
266 replayer_thd->thread_stack= m_thd->thread_stack; in replay()
267 replayer_thd->real_id= pthread_self(); in replay()
268 replayer_thd->prior_thr_create_utime= in replay()
269 replayer_thd->start_utime= microsecond_interval_timer(); in replay()
270 replayer_thd->set_command(COM_SLEEP); in replay()
271 replayer_thd->reset_for_next_command(true); in replay()
275 Wsrep_replayer_service replayer_service(replayer_thd, m_thd); in replay()
276 wsrep::provider& provider(replayer_thd->wsrep_cs().provider()); in replay()
277 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(), in replay()
[all …]
H A Dwsrep_high_priority_service.cc599 : Wsrep_high_priority_service(replayer_thd) in Wsrep_replayer_service()
642 wsrep_assign_from_threadvars(replayer_thd); in Wsrep_replayer_service()
644 wsrep_store_threadvars(replayer_thd); in Wsrep_replayer_service()
645 wsrep_open(replayer_thd); in Wsrep_replayer_service()
646 wsrep_before_command(replayer_thd); in Wsrep_replayer_service()
652 THD* replayer_thd= m_thd; in ~Wsrep_replayer_service() local
656 wsrep_after_apply(replayer_thd); in ~Wsrep_replayer_service()
657 wsrep_after_command_ignore_result(replayer_thd); in ~Wsrep_replayer_service()
658 wsrep_close(replayer_thd); in ~Wsrep_replayer_service()
659 wsrep_reset_threadvars(replayer_thd); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_high_priority_service.h99 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/
H A Dwsrep_client_service.cc265 THD *replayer_thd= new THD(true, true);
266 replayer_thd->thread_stack= m_thd->thread_stack;
267 replayer_thd->real_id= pthread_self();
268 replayer_thd->prior_thr_create_utime=
269 replayer_thd->start_utime= microsecond_interval_timer();
270 replayer_thd->set_command(COM_SLEEP);
271 replayer_thd->reset_for_next_command(true);
275 Wsrep_replayer_service replayer_service(replayer_thd, m_thd);
276 wsrep::provider& provider(replayer_thd->wsrep_cs().provider());
277 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(),
[all …]
H A Dwsrep_high_priority_service.cc599 : Wsrep_high_priority_service(replayer_thd) in Wsrep_replayer_service()
642 wsrep_assign_from_threadvars(replayer_thd); in Wsrep_replayer_service()
644 wsrep_store_threadvars(replayer_thd); in Wsrep_replayer_service()
645 wsrep_open(replayer_thd); in Wsrep_replayer_service()
646 wsrep_before_command(replayer_thd); in Wsrep_replayer_service()
652 THD* replayer_thd= m_thd; in ~Wsrep_replayer_service() local
656 wsrep_after_apply(replayer_thd); in ~Wsrep_replayer_service()
657 wsrep_after_command_ignore_result(replayer_thd); in ~Wsrep_replayer_service()
658 wsrep_close(replayer_thd); in ~Wsrep_replayer_service()
659 wsrep_reset_threadvars(replayer_thd); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_high_priority_service.h99 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/
H A Dwsrep_client_service.cc264 THD *replayer_thd= new THD(true, true); in replay() local
265 replayer_thd->thread_stack= m_thd->thread_stack; in replay()
266 replayer_thd->real_id= pthread_self(); in replay()
267 replayer_thd->prior_thr_create_utime= in replay()
268 replayer_thd->start_utime= microsecond_interval_timer(); in replay()
269 replayer_thd->set_command(COM_SLEEP); in replay()
270 replayer_thd->reset_for_next_command(true); in replay()
274 Wsrep_replayer_service replayer_service(replayer_thd, m_thd); in replay()
275 wsrep::provider& provider(replayer_thd->wsrep_cs().provider()); in replay()
276 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(), in replay()
[all …]
H A Dwsrep_high_priority_service.cc621 : Wsrep_high_priority_service(replayer_thd) in Wsrep_replayer_service()
664 wsrep_assign_from_threadvars(replayer_thd); in Wsrep_replayer_service()
666 wsrep_store_threadvars(replayer_thd); in Wsrep_replayer_service()
667 wsrep_open(replayer_thd); in Wsrep_replayer_service()
668 wsrep_before_command(replayer_thd); in Wsrep_replayer_service()
674 THD* replayer_thd= m_thd; in ~Wsrep_replayer_service() local
678 wsrep_after_apply(replayer_thd); in ~Wsrep_replayer_service()
679 wsrep_after_command_ignore_result(replayer_thd); in ~Wsrep_replayer_service()
680 wsrep_close(replayer_thd); in ~Wsrep_replayer_service()
681 wsrep_reset_threadvars(replayer_thd); in ~Wsrep_replayer_service()
[all …]
H A Dwsrep_high_priority_service.h98 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);