Home
last modified time | relevance | path

Searched refs:wait_for_commit_ptr (Results 1 – 25 of 28) sorted by relevance

12

/dports/databases/mariadb105-client/mariadb-10.5.15/sql/
H A Dwsrep_binlog.cc363 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 Drpl_parallel.cc180 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 Dsql_class.h4805 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 Dlog.cc7703 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 Dwsrep_binlog.cc363 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 Drpl_parallel.cc180 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 Dsql_class.h4646 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 Dlog.cc7500 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 Dsql_class.cc633 wait_for_commit_ptr(0), in THD()
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/
H A Dwsrep_binlog.cc363 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 Drpl_parallel.cc180 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 Dsql_class.h4646 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 Dlog.cc7500 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 Dsql_class.cc633 wait_for_commit_ptr(0), in THD()
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/
H A Dwsrep_binlog.cc363 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 Drpl_parallel.cc180 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 Dsql_class.h4805 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 Dlog.cc7703 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 Drpl_parallel.cc162 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 Dsql_class.h4543 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 Dlog.cc7434 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 Drpl_parallel.cc162 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 Dsql_class.h4543 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 Dlog.cc7434 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 Dsql_class.cc643 wait_for_commit_ptr(0),

12