Function binlog_commit

sql/log.cc:2802–2919

This function is called once after each statement. It has the responsibility to flush the caches to the binary log on commits. @param thd The client thread that executes the transaction. @param all This is @c true if this is a real transaction commit, and @false otherwise. @param ro_1pc read-only one-phase commit transaction */

  @param ro_1pc  read-only one-phase commit transaction
*/
int binlog_commit(THD *thd, bool all, bool ro_1pc)
{
  int error= 0;
  PSI_stage_info org_stage;
  DBUG_ENTER("binlog_commit");

  bool is_ending_transaction= ending_trans(thd, all);

  binlog_cache_mngr *const cache_mngr= thd->binlog_get_cache_mngr();
  /*
    cache_mngr can be NULL in case if binlog logging is disabled.
  */
  if (!cache_mngr)
  {
    DBUG_ASSERT(WSREP(thd) ||
                (thd->lex->sql_command != SQLCOM_XA_PREPARE &&
                !(thd->lex->sql_command == SQLCOM_XA_COMMIT &&
                  thd->lex->xa_opt == XA_ONE_PHASE)));

    DBUG_RETURN(0);
  }
  /*
    This is true if we are doing an alter table that is replicated as
    CREATE TABLE ... SELECT
  */
  if (thd->variables.option_bits & OPTION_BIN_COMMIT_OFF)
    DBUG_RETURN(0);

  DBUG_PRINT("debug",
             ("all: %d, in_transaction: %s, all.modified_non_trans_table: %s, stmt.modified_non_trans_table: %s",
              all,
              YESNO(thd->in_multi_stmt_transaction_mode()),
              YESNO(thd->transaction->all.modified_non_trans_table),
              YESNO(thd->transaction->stmt.modified_non_trans_table)));

  thd->backup_stage(&org_stage);
  THD_STAGE_INFO(thd, stage_binlog_write);
  if (!cache_mngr->stmt_cache.empty())
  {
#ifdef WITH_WSREP
    if (wsrep_on(thd) && !ending_trans(thd, all))
    {
      /*
        We should not clear stmt cache in case we are in transaction.
        However we should write all pending row events to disk to
        ensure we did not run out of disk quota.
      */
      error= thd->binlog_flush_pending_rows_event(TRUE, FALSE);
    }
    else
#endif /* WITH_WSREP */
      error= binlog_commit_flush_stmt_cache(thd, all, cache_mngr);
  }
  if (cache_mngr->trx_cache.empty() &&
      (thd->transaction->xid_state.get_state_code() != XA_PREPARED ||
       !(thd->ha_data[binlog_tp.slot].ha_info[1].is_started() &&
         thd->ha_data[binlog_tp.slot].ha_info[1].is_trx_read_write())))
  {