Function buildFileInfosForBackupEntries

src/Backups/BackupFileInfo.cpp:221–267

}

BackupFileInfos buildFileInfosForBackupEntries(const BackupEntries & backup_entries, const BackupPtr & base_backup, const ReadSettings & read_settings, ThreadPool & thread_pool, QueryStatusPtr process_list_element)
{
    LoggerPtr log = getLogger("FileInfosFromBackupEntries");
    LOG_TRACE(log, "Building file infos for backup entries");
    auto timer = CurrentThread::getProfileEvents().timer(ProfileEvents::BackupPreparingFileInfosMicroseconds);

    BackupFileInfos infos;
    infos.resize(backup_entries.size());

    std::atomic_bool failed = false;

    ThreadPoolCallbackRunnerLocal<void> runner(thread_pool, ThreadName::BACKUP_WORKER);
    for (size_t i = 0; i != backup_entries.size(); ++i)
    {
        if (failed)
            break;

        /// Passing references here is fine. All the objects are created **before** runner so they will be destroyed after it in case
        /// of an exception
        runner.enqueueAndKeepTrack([&infos, &backup_entries, &read_settings, &base_backup, &process_list_element, i, log, &failed, current_component = Coordination::getCurrentComponent()]()
        {
            if (failed)
                return;

            auto component_guard = Coordination::setCurrentComponent(current_component);
            try
            {
                const auto & name = backup_entries[i].first;
                const auto & entry = backup_entries[i].second;

                if (process_list_element)
                    process_list_element->checkTimeLimit();

                infos[i] = buildFileInfoForBackupEntry(name, entry, base_backup, read_settings, log);
            }
            catch (...)
            {
                failed = true;
                throw;
            }
        });
    }

    runner.waitForAllToFinishAndRethrowFirstError();

    return infos;
}

}