Function backup_block_commit

sql/backup.cc:398–440

*/

static bool backup_block_commit(THD *thd)
{
  DBUG_ENTER("backup_block_commit");
  if (thd->mdl_context.upgrade_shared_lock(backup_flush_ticket,
                                           MDL_BACKUP_WAIT_COMMIT,
                                           thd->variables.lock_wait_timeout))
    DBUG_RETURN(1);

  /* We can ignore errors from flush_tables () */
  (void) flush_tables(thd, FLUSH_SYS_TABLES);

  if (mysql_bin_log.is_open())
  {
    mysql_mutex_lock(mysql_bin_log.get_log_lock());
    mysql_file_sync(mysql_bin_log.get_log_file()->file, MYF(MY_WME));
    mysql_mutex_unlock(mysql_bin_log.get_log_lock());
  }
  thd->clear_error();

#ifdef WITH_WSREP
  if (WSREP_NNULL(thd) && !thd->wsrep_desynced_backup_stage)
  {
    Wsrep_server_state &server_state= Wsrep_server_state::instance();
    bool mariabackup= (server_state.state() == Wsrep_server_state::s_donor
                       && !strcmp(wsrep_sst_method, "mariabackup"));

    /* If this node is donor and mariabackup is not used
       we desync and pause provider here if it is not yet done.
    */
    if (!mariabackup)
    {
      if (server_state.desync_and_pause().is_undefined())
        DBUG_RETURN(1);

      WSREP_INFO("Server desynched from group during BACKUP STAGE BLOCK_COMMIT.");
      thd->wsrep_desynced_backup_stage= true;
      DEBUG_SYNC(thd, "wsrep_backup_stage_commit_after_desync_and_pause");
    }
  }
#endif /* WITH_WSREP */

  DBUG_RETURN(0);
}


/**