/dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
H A D | wsrep_client_service.cc | 264 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 D | wsrep_high_priority_service.cc | 621 : 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 D | wsrep_high_priority_service.h | 98 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);
|
/dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
H A D | wsrep_client_service.cc | 265 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 D | wsrep_high_priority_service.cc | 599 : 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 D | wsrep_high_priority_service.h | 99 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);
|
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
H A D | wsrep_client_service.cc | 265 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 D | wsrep_high_priority_service.cc | 599 : 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 D | wsrep_high_priority_service.h | 99 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);
|
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
H A D | wsrep_client_service.cc | 264 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 D | wsrep_high_priority_service.cc | 621 : 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 D | wsrep_high_priority_service.h | 98 Wsrep_replayer_service(THD* replayer_thd, THD* orig_thd);
|