Method finish_commit

phx_percona/percona/sql/binlog.cc:7158–7233

Helper function executed when leaving @c ordered_commit. This function contain the necessary code for fetching the error code, doing post-commit checks, and wrapping up the commit if necessary. It is typically called when enter_stage indicates that the thread should bail out, and also when the ultimate leader thread finishes executing @c ordered_commit. It is typically used

   success.
 */
int
MYSQL_BIN_LOG::finish_commit(THD *thd)
{
  /*
    In some unlikely situations, it can happen that binary
    log is closed before the thread flushes it's cache.
    In that case, clear the caches before doing commit.
  */
  if (unlikely(!is_open()))
  {
    binlog_cache_mngr *cache_mngr= thd_get_cache_mngr(thd);
    if (cache_mngr)
      cache_mngr->reset();
  }
  if (thd->transaction.flags.commit_low)
  {
    const bool all= thd->transaction.flags.real_commit;
    /*
      storage engine commit
    */
    DBUG_ASSERT(thd->commit_error != THD::CE_COMMIT_ERROR);
    if (thd->commit_error == THD::CE_NONE)
    {
      /*
        Acquire a shared lock to block commits if an X lock has been acquired by
        LOCK TABLES FOR BACKUP or START TRANSACTION WITH CONSISTENT SNAPSHOT. We
        only reach this code if binlog_order_commits=0.
      */
      DBUG_ASSERT(opt_binlog_order_commits == 0);

      slock();

      if (ha_commit_low(thd, all, false))
        thd->commit_error= THD::CE_COMMIT_ERROR;

      sunlock();
    }
    /*
      Decrement the prepared XID counter after storage engine commit
    */
    if (thd->transaction.flags.xid_written)
      dec_prep_xids(thd);
    /*
      If commit succeeded, we call the after_commit hook

      TODO: This hook here should probably move outside/below this
            if and be the only after_commit invocation left in the
            code.
    */
    if ((thd->commit_error != THD::CE_COMMIT_ERROR ) && thd->transaction.flags.run_hooks)
    {
      (void) RUN_HOOK(transaction, after_commit, (thd, all));
      thd->transaction.flags.run_hooks= false;
    }
  }
  else if (thd->transaction.flags.xid_written)
    dec_prep_xids(thd);