| can_be_retried(THD *thd) override | cs::apply::Csa_worker_context | virtual |
| Channel_id typedef | cs::apply::Parallel_worker_context | |
| Csa_worker_context(Trx_id trx_seq_num, Worker_id worker_id, const std::string &channel_id, THD *trx_ctx, int current_retry, int retries_num) | cs::apply::Csa_worker_context | |
| found_commit_order_deadlock() const override | cs::apply::Csa_worker_context | virtual |
| get_channel_id() const | cs::apply::Csa_worker_context | |
| get_for_channel_id(bool upper_case) const override | cs::apply::Csa_worker_context | virtual |
| get_mdl_context() override | cs::apply::Csa_worker_context | virtual |
| get_transaction_ctx() override | cs::apply::Csa_worker_context | virtual |
| get_trx_id() override | cs::apply::Csa_worker_context | virtual |
| get_worker_id() const override | cs::apply::Csa_worker_context | virtual |
| get_worker_metrics() override | cs::apply::Csa_worker_context | virtual |
| handle_commit_order_deadlock() | cs::apply::Csa_worker_context | |
| has_temporary_error(THD *thd, int error) | cs::apply::Csa_worker_context | |
| is_csa() const override | cs::apply::Csa_worker_context | virtual |
| is_rollback_requested() const | cs::apply::Csa_worker_context | inline |
| is_same_channel(const Parallel_worker_context *arg) const override | cs::apply::Csa_worker_context | virtual |
| m_channel_id | cs::apply::Csa_worker_context | private |
| m_current_retry | cs::apply::Csa_worker_context | private |
| m_disabled_worker_metrics | cs::apply::Csa_worker_context | static |
| m_for_channel_id | cs::apply::Csa_worker_context | mutableprivate |
| m_is_commit_order_deadlock | cs::apply::Csa_worker_context | private |
| m_retries_num | cs::apply::Csa_worker_context | private |
| m_rollback | cs::apply::Csa_worker_context | private |
| m_rollback_promise | cs::apply::Csa_worker_context | private |
| m_rpco_state | cs::apply::Csa_worker_context | private |
| m_trx_ctx | cs::apply::Csa_worker_context | private |
| m_trx_id | cs::apply::Csa_worker_context | private |
| m_worker_id | cs::apply::Csa_worker_context | private |
| Parallel_worker_context()=default | cs::apply::Parallel_worker_context | |
| report_commit_order_deadlock(bool for_self=false) override | cs::apply::Csa_worker_context | virtual |
| reset_commit_order_deadlock() override | cs::apply::Csa_worker_context | virtual |
| Rpco_state enum name | cs::apply::Csa_worker_context | private |
| set_applied() | cs::apply::Csa_worker_context | |
| set_committing() | cs::apply::Csa_worker_context | |
| Trx_id typedef | cs::apply::Csa_worker_context | |
| update(Trx_id trx_seq_num, Worker_id worker_id, THD *trx_ctx, int current_retry) | cs::apply::Csa_worker_context | |
| update(Worker_id worker_id, int current_retry) | cs::apply::Csa_worker_context | |
| update(Trx_id trx_seq_num, Worker_id worker_id, const std::string &channel_id, THD *trx_ctx, int current_retry, int retries_num) | cs::apply::Csa_worker_context | |
| wait_for_rollback() | cs::apply::Csa_worker_context | |
| Worker_id typedef | cs::apply::Csa_worker_context | |
| ~Parallel_worker_context()=default | cs::apply::Parallel_worker_context | virtual |