/dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
H A D | wsrep_binlog.cc | 363 wait_for_commit *wfc= thd->wait_for_commit_ptr= &thd->wsrep_wfc; in wsrep_register_for_group_commit() 370 commit_order_tail= thd->wait_for_commit_ptr; in wsrep_register_for_group_commit() 385 wait_for_commit *wfc= thd->wait_for_commit_ptr; in wsrep_unregister_from_group_commit() 398 thd->wait_for_commit_ptr= NULL; in wsrep_unregister_from_group_commit()
|
H A D | rpl_parallel.cc | 180 thd->wait_for_commit_ptr= NULL; in finish_event_group() 770 if(thd->wait_for_commit_ptr) in retry_event_group() 771 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 853 if(thd->wait_for_commit_ptr) in retry_event_group() 854 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 1209 if(unlikely(thd->wait_for_commit_ptr) && group_rgi != NULL) in handle_rpl_parallel_thread() 1259 thd->wait_for_commit_ptr= &rgi->commit_orderer; in handle_rpl_parallel_thread()
|
H A D | sql_class.h | 4805 wait_for_commit *wait_for_commit_ptr; variable 4808 if (wait_for_commit_ptr) in wait_for_prior_commit() 4809 return wait_for_commit_ptr->wait_for_prior_commit(this); in wait_for_prior_commit() 4814 if (wait_for_commit_ptr) in wakeup_subsequent_commits() 4815 wait_for_commit_ptr->wakeup_subsequent_commits(wakeup_error); in wakeup_subsequent_commits() 4818 wait_for_commit *suspended= wait_for_commit_ptr; in suspend_subsequent_commits() 4819 wait_for_commit_ptr= NULL; in suspend_subsequent_commits() 4823 DBUG_ASSERT(!wait_for_commit_ptr); in resume_subsequent_commits() 4824 wait_for_commit_ptr= suspended; in resume_subsequent_commits()
|
H A D | log.cc | 7703 wfc= orig_entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7972 cur= entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 8096 next->thd->wait_for_commit_ptr->wakeup(entry->error); in write_transaction_to_binlog_events() 8475 current->thd->wait_for_commit_ptr->wakeup(current->error); in trx_group_commit_leader()
|
/dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
H A D | wsrep_binlog.cc | 363 wait_for_commit *wfc= thd->wait_for_commit_ptr= &thd->wsrep_wfc; in wsrep_register_for_group_commit() 370 commit_order_tail= thd->wait_for_commit_ptr; in wsrep_register_for_group_commit() 385 wait_for_commit *wfc= thd->wait_for_commit_ptr; in wsrep_unregister_from_group_commit() 398 thd->wait_for_commit_ptr= NULL; in wsrep_unregister_from_group_commit()
|
H A D | rpl_parallel.cc | 180 thd->wait_for_commit_ptr= NULL; in finish_event_group() 768 if(thd->wait_for_commit_ptr) in retry_event_group() 769 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 851 if(thd->wait_for_commit_ptr) in retry_event_group() 852 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 1207 if(unlikely(thd->wait_for_commit_ptr) && group_rgi != NULL) in handle_rpl_parallel_thread() 1257 thd->wait_for_commit_ptr= &rgi->commit_orderer; in handle_rpl_parallel_thread()
|
H A D | sql_class.h | 4646 wait_for_commit *wait_for_commit_ptr; variable 4649 if (wait_for_commit_ptr) in wait_for_prior_commit() 4650 return wait_for_commit_ptr->wait_for_prior_commit(this); in wait_for_prior_commit() 4655 if (wait_for_commit_ptr) in wakeup_subsequent_commits() 4656 wait_for_commit_ptr->wakeup_subsequent_commits(wakeup_error); in wakeup_subsequent_commits() 4659 wait_for_commit *suspended= wait_for_commit_ptr; in suspend_subsequent_commits() 4660 wait_for_commit_ptr= NULL; in suspend_subsequent_commits() 4664 DBUG_ASSERT(!wait_for_commit_ptr); in resume_subsequent_commits() 4665 wait_for_commit_ptr= suspended; in resume_subsequent_commits()
|
H A D | log.cc | 7500 wfc= orig_entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7769 cur= entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7893 next->thd->wait_for_commit_ptr->wakeup(entry->error); in write_transaction_to_binlog_events() 8270 current->thd->wait_for_commit_ptr->wakeup(current->error); in trx_group_commit_leader()
|
H A D | sql_class.cc | 633 wait_for_commit_ptr(0), in THD()
|
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
H A D | wsrep_binlog.cc | 363 wait_for_commit *wfc= thd->wait_for_commit_ptr= &thd->wsrep_wfc; in wsrep_register_for_group_commit() 370 commit_order_tail= thd->wait_for_commit_ptr; in wsrep_register_for_group_commit() 385 wait_for_commit *wfc= thd->wait_for_commit_ptr; in wsrep_unregister_from_group_commit() 398 thd->wait_for_commit_ptr= NULL; in wsrep_unregister_from_group_commit()
|
H A D | rpl_parallel.cc | 180 thd->wait_for_commit_ptr= NULL; in finish_event_group() 768 if(thd->wait_for_commit_ptr) in retry_event_group() 769 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 851 if(thd->wait_for_commit_ptr) in retry_event_group() 852 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 1207 if(unlikely(thd->wait_for_commit_ptr) && group_rgi != NULL) in handle_rpl_parallel_thread() 1257 thd->wait_for_commit_ptr= &rgi->commit_orderer; in handle_rpl_parallel_thread()
|
H A D | sql_class.h | 4646 wait_for_commit *wait_for_commit_ptr; variable 4649 if (wait_for_commit_ptr) in wait_for_prior_commit() 4650 return wait_for_commit_ptr->wait_for_prior_commit(this); in wait_for_prior_commit() 4655 if (wait_for_commit_ptr) in wakeup_subsequent_commits() 4656 wait_for_commit_ptr->wakeup_subsequent_commits(wakeup_error); in wakeup_subsequent_commits() 4659 wait_for_commit *suspended= wait_for_commit_ptr; in suspend_subsequent_commits() 4660 wait_for_commit_ptr= NULL; in suspend_subsequent_commits() 4664 DBUG_ASSERT(!wait_for_commit_ptr); in resume_subsequent_commits() 4665 wait_for_commit_ptr= suspended; in resume_subsequent_commits()
|
H A D | log.cc | 7500 wfc= orig_entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7769 cur= entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7893 next->thd->wait_for_commit_ptr->wakeup(entry->error); in write_transaction_to_binlog_events() 8270 current->thd->wait_for_commit_ptr->wakeup(current->error); in trx_group_commit_leader()
|
H A D | sql_class.cc | 633 wait_for_commit_ptr(0), in THD()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
H A D | wsrep_binlog.cc | 363 wait_for_commit *wfc= thd->wait_for_commit_ptr= &thd->wsrep_wfc; in wsrep_register_for_group_commit() 370 commit_order_tail= thd->wait_for_commit_ptr; in wsrep_register_for_group_commit() 385 wait_for_commit *wfc= thd->wait_for_commit_ptr; in wsrep_unregister_from_group_commit() 398 thd->wait_for_commit_ptr= NULL; in wsrep_unregister_from_group_commit()
|
H A D | rpl_parallel.cc | 180 thd->wait_for_commit_ptr= NULL; in finish_event_group() 770 if(thd->wait_for_commit_ptr) in retry_event_group() 771 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 853 if(thd->wait_for_commit_ptr) in retry_event_group() 854 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 1209 if(unlikely(thd->wait_for_commit_ptr) && group_rgi != NULL) in handle_rpl_parallel_thread() 1259 thd->wait_for_commit_ptr= &rgi->commit_orderer; in handle_rpl_parallel_thread()
|
H A D | sql_class.h | 4805 wait_for_commit *wait_for_commit_ptr; variable 4808 if (wait_for_commit_ptr) in wait_for_prior_commit() 4809 return wait_for_commit_ptr->wait_for_prior_commit(this); in wait_for_prior_commit() 4814 if (wait_for_commit_ptr) in wakeup_subsequent_commits() 4815 wait_for_commit_ptr->wakeup_subsequent_commits(wakeup_error); in wakeup_subsequent_commits() 4818 wait_for_commit *suspended= wait_for_commit_ptr; in suspend_subsequent_commits() 4819 wait_for_commit_ptr= NULL; in suspend_subsequent_commits() 4823 DBUG_ASSERT(!wait_for_commit_ptr); in resume_subsequent_commits() 4824 wait_for_commit_ptr= suspended; in resume_subsequent_commits()
|
H A D | log.cc | 7703 wfc= orig_entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7972 cur= entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 8096 next->thd->wait_for_commit_ptr->wakeup(entry->error); in write_transaction_to_binlog_events() 8475 current->thd->wait_for_commit_ptr->wakeup(current->error); in trx_group_commit_leader()
|
/dports/databases/mariadb103-client/mariadb-10.3.34/sql/ |
H A D | rpl_parallel.cc | 162 thd->wait_for_commit_ptr= NULL; 750 if(thd->wait_for_commit_ptr) 751 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); 833 if(thd->wait_for_commit_ptr) 834 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); 1181 if(unlikely(thd->wait_for_commit_ptr) && group_rgi != NULL) 1231 thd->wait_for_commit_ptr= &rgi->commit_orderer;
|
H A D | sql_class.h | 4543 wait_for_commit *wait_for_commit_ptr; variable 4546 if (wait_for_commit_ptr) in wait_for_prior_commit() 4547 return wait_for_commit_ptr->wait_for_prior_commit(this); in wait_for_prior_commit() 4552 if (wait_for_commit_ptr) in wakeup_subsequent_commits() 4553 wait_for_commit_ptr->wakeup_subsequent_commits(wakeup_error); in wakeup_subsequent_commits() 4556 wait_for_commit *suspended= wait_for_commit_ptr; in suspend_subsequent_commits() 4557 wait_for_commit_ptr= NULL; in suspend_subsequent_commits() 4561 DBUG_ASSERT(!wait_for_commit_ptr); in resume_subsequent_commits() 4562 wait_for_commit_ptr= suspended; in resume_subsequent_commits()
|
H A D | log.cc | 7434 wfc= orig_entry->thd->wait_for_commit_ptr; 7679 cur= entry->thd->wait_for_commit_ptr; 7754 next->thd->wait_for_commit_ptr->wakeup(entry->error); 8148 current->thd->wait_for_commit_ptr->wakeup(current->error);
|
/dports/databases/mariadb103-server/mariadb-10.3.34/sql/ |
H A D | rpl_parallel.cc | 162 thd->wait_for_commit_ptr= NULL; in finish_event_group() 750 if(thd->wait_for_commit_ptr) in retry_event_group() 751 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 833 if(thd->wait_for_commit_ptr) in retry_event_group() 834 thd->wait_for_commit_ptr->unregister_wait_for_prior_commit(); in retry_event_group() 1181 if(unlikely(thd->wait_for_commit_ptr) && group_rgi != NULL) in handle_rpl_parallel_thread() 1231 thd->wait_for_commit_ptr= &rgi->commit_orderer; in handle_rpl_parallel_thread()
|
H A D | sql_class.h | 4543 wait_for_commit *wait_for_commit_ptr; 4546 if (wait_for_commit_ptr) 4547 return wait_for_commit_ptr->wait_for_prior_commit(this); 4552 if (wait_for_commit_ptr) 4553 wait_for_commit_ptr->wakeup_subsequent_commits(wakeup_error); 4556 wait_for_commit *suspended= wait_for_commit_ptr; 4557 wait_for_commit_ptr= NULL; 4561 DBUG_ASSERT(!wait_for_commit_ptr); 4562 wait_for_commit_ptr= suspended;
|
H A D | log.cc | 7434 wfc= orig_entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7679 cur= entry->thd->wait_for_commit_ptr; in queue_for_group_commit() 7754 next->thd->wait_for_commit_ptr->wakeup(entry->error); in write_transaction_to_binlog_events() 8148 current->thd->wait_for_commit_ptr->wakeup(current->error); in trx_group_commit_leader()
|
H A D | sql_class.cc | 643 wait_for_commit_ptr(0),
|