AFTER_COMMIT_STAGE enum value | Commit_stage_manager | |
append_to(StageID stage, THD *thd) | Commit_stage_manager | |
BINLOG_FLUSH_STAGE enum value | Commit_stage_manager | |
clear_preempt_status(THD *head) | Commit_stage_manager | |
COMMIT_ORDER_FLUSH_STAGE enum value | Commit_stage_manager | |
COMMIT_STAGE enum value | Commit_stage_manager | |
Commit_stage_manager() | Commit_stage_manager | inlineprivate |
Commit_stage_manager(const Commit_stage_manager &)=delete | Commit_stage_manager | private |
deinit() | Commit_stage_manager | |
disable_manual_session_tickets() | Commit_stage_manager | static |
enable_manual_session_tickets() | Commit_stage_manager | static |
enroll_for(StageID stage, THD *first, mysql_mutex_t *stage_mutex, mysql_mutex_t *enter_mutex) | Commit_stage_manager | |
fetch_queue_acquire_lock(StageID stage) | Commit_stage_manager | |
fetch_queue_skip_acquire_lock(StageID stage) | Commit_stage_manager | |
finish_session_ticket(THD *thd) | Commit_stage_manager | |
get_instance() | Commit_stage_manager | static |
init(PSI_mutex_key key_LOCK_flush_queue, PSI_mutex_key key_LOCK_sync_queue, PSI_mutex_key key_LOCK_commit_queue, PSI_mutex_key key_LOCK_after_commit_queue, PSI_mutex_key key_LOCK_done, PSI_mutex_key key_LOCK_wait_for_group_turn, PSI_cond_key key_COND_done, PSI_cond_key key_COND_flush_queue, PSI_cond_key key_COND_wait_for_group_turn) | Commit_stage_manager | |
leader_await_preempt_status | Commit_stage_manager | private |
leader_thd | Commit_stage_manager | private |
lock_queue(StageID stage) | Commit_stage_manager | inline |
m_cond_preempt | Commit_stage_manager | private |
m_cond_wait_for_ticket_turn | Commit_stage_manager | private |
m_is_initialized | Commit_stage_manager | private |
m_lock_done | Commit_stage_manager | private |
m_lock_wait_for_ticket_turn | Commit_stage_manager | private |
m_queue | Commit_stage_manager | private |
m_queue_lock | Commit_stage_manager | private |
m_stage_cond_binlog | Commit_stage_manager | private |
m_stage_cond_commit_order | Commit_stage_manager | private |
m_stage_cond_leader | Commit_stage_manager | private |
operator=(const Commit_stage_manager &)=delete | Commit_stage_manager | private |
pop_front(StageID stage) | Commit_stage_manager | inline |
process_final_stage_for_ordered_commit_group(THD *first) | Commit_stage_manager | |
signal_done(THD *queue, StageID stage=BINLOG_FLUSH_STAGE) | Commit_stage_manager | |
signal_end_of_ticket(bool force=false) | Commit_stage_manager | |
STAGE_COUNTER enum value | Commit_stage_manager | |
StageID enum name | Commit_stage_manager | |
SYNC_STAGE enum value | Commit_stage_manager | |
unlock_queue(StageID stage) | Commit_stage_manager | inline |
update_session_ticket_state(THD *thd) | Commit_stage_manager | |
update_ticket_manager(std::uint64_t sessions_count, const binlog::BgcTicket &session_ticket) | Commit_stage_manager | |
wait_count_or_timeout(ulong count, long usec, StageID stage) | Commit_stage_manager | |
wait_for_ticket_turn(THD *thd, bool update_ticket_manager=true) | Commit_stage_manager | |