Method write_transaction_with_group_commit

sql/log.cc:10553–10708

}

bool
MYSQL_BIN_LOG::write_transaction_with_group_commit(group_commit_entry *entry)
{
  DEBUG_SYNC(entry->thd, "before_group_commit_queue");
  int is_leader= queue_for_group_commit(entry);
  binlog_cache_mngr *cache_mngr= entry->cache_mngr;

#ifdef WITH_WSREP
  /* commit order was released in queue_for_group_commit() call,
     here we check if wsrep_commit_ordered() failed or if we are leader */
  switch (is_leader)
  {
  case -2: /* wsrep_ordered_commit() has failed */
    DBUG_ASSERT(wsrep_is_active(entry->thd));
    DBUG_ASSERT(wsrep_run_commit_hook(entry->thd, entry->all));
    entry->thd->wakeup_subsequent_commits(1);
    return true;
  case -3: /* this is leader, wait for prior commit to
              complete. This establishes total order for group leaders
           */
    DBUG_ASSERT(wsrep_is_active(entry->thd));
    DBUG_ASSERT(wsrep_run_commit_hook(entry->thd, entry->all));
    if (entry->thd->wait_for_prior_commit())
      return true;

    /* retain the correct is_leader value */
    is_leader= 1;
    break;

  default: /* native MariaDB cases */
    break;
  }
#endif /* WITH_WSREP */

  /*
    The first in the queue handles group commit for all; the others just wait
    to be signalled when group commit is done.
  */
  if (is_leader < 0)
    return true;                                /* Error */
  else if (is_leader)
    trx_group_commit_leader(entry);
  else if (!entry->queued_by_other)
  {
    DEBUG_SYNC(entry->thd, "after_semisync_queue");

    entry->thd->wait_for_wakeup_ready();
  }
  else
  {
    /*
      If we were queued by another prior commit, then we are woken up
      only when the leader has already completed the commit for us.
      So nothing to do here then.
    */
  }

  if (!opt_optimize_thread_scheduling)