Method commit

sql/log.cc:15169–15263

}

bool Binlog_commit_by_rotate::commit(MYSQL_BIN_LOG::group_commit_entry *entry)
{
  bool check_purge= false;
  THD *thd= entry->thd;
  binlog_cache_mngr *cache_mngr= entry->cache_mngr;
  binlog_cache_data *cache_data= cache_mngr->get_binlog_cache_data(true);
  if (unlikely(!cache_mngr->using_trx_cache || cache_data->empty()))
    cache_data= cache_mngr->get_binlog_cache_data(false);

  /* Call them before enter log_lock to avoid holding the lock long */
  if (cache_data->sync_temp_file())
    return true;

  /*
    If there was a rollback_to_savepoint happened before, the real length of
    tmp file can be greater than the file_end_pos. Truncate the cache tmp
    file to file_end_pos of this cache.
  */
  my_chsize(cache_data->cache_log.file, cache_data->temp_file_length(), 0,
            MYF(0));

  if (thd->wait_for_prior_commit())
    return true;

  // It will be released by trx_group_commit_with_engines
  mysql_mutex_lock(&mysql_bin_log.LOCK_log);

  enum enum_binlog_checksum_alg expected_alg=
      mysql_bin_log.checksum_alg_reset != BINLOG_CHECKSUM_ALG_UNDEF
          ? mysql_bin_log.checksum_alg_reset
          : (enum_binlog_checksum_alg) binlog_checksum_options;

  /*
    In legacy mode, all events should has a valid position this done by
    updating log_pos field when writing events from binlog cache to binlog
    file. Thus rename binlog cache to binlog file is not supported in legacy
    mode.

    if the cache's checksum alg is not same to the binlog's checksum, it needs
    to recalculate the checksum. Thus rename binlog cache to binlog file is
    not supported.
  */
  if (!mysql_bin_log.is_open() || opt_binlog_legacy_event_pos ||
      (expected_alg != cache_data->checksum_opt))
  {
    mysql_mutex_unlock(&mysql_bin_log.LOCK_log);
    // It cannot do rename, so go to group commit
    return mysql_bin_log.write_transaction_with_group_commit(entry);
  }

  m_entry= entry;
  m_replaced= false;
  m_cache_data= cache_data;
  ulong prev_binlog_id= mysql_bin_log.current_binlog_id;

  /*
    Rotate will call replace_binlog_file() to rename the transaction's binlog
    cache to the new binlog file.