| 2920 | |
| 2921 | |
| 2922 | void |
| 2923 | binlog_post_commit(THD *thd, bool all) |
| 2924 | { |
| 2925 | if (!opt_binlog_engine_hton) |
| 2926 | return; |
| 2927 | |
| 2928 | binlog_cache_mngr *cache_mngr= thd->binlog_get_cache_mngr(); |
| 2929 | if (likely(cache_mngr != nullptr) && unlikely(cache_mngr->need_engine_2pc)) |
| 2930 | { |
| 2931 | DBUG_ASSERT(!cache_mngr->trx_cache.engine_binlog_info.internal_xa); |
| 2932 | DBUG_ASSERT(thd->lex->sql_command == SQLCOM_XA_COMMIT && |
| 2933 | thd->lex->xa_opt != XA_ONE_PHASE); |
| 2934 | cache_mngr->need_engine_2pc= false; |
| 2935 | (*opt_binlog_engine_hton->binlog_unlog) |
| 2936 | (thd->transaction->xid_state.get_xid(), |
| 2937 | &cache_mngr->trx_cache.engine_binlog_info.engine_ptr); |
| 2938 | } |
| 2939 | } |
| 2940 | |
| 2941 | |
| 2942 | void |
no test coverage detected