Method addMultipleModsFilesToStructure

src/directoryrefresher.cpp:390–453

}

void DirectoryRefresher::addMultipleModsFilesToStructure(
    MOShared::DirectoryEntry* directoryStructure, const std::vector<EntryInfo>& entries,
    DirectoryRefreshProgress* progress)
{
  std::vector<DirectoryStats> stats(entries.size());

  if (progress) {
    progress->start(entries.size());
  }

  log::debug("refresher: using {} threads", m_threadCount);
  g_threads.setMax(m_threadCount);

  for (std::size_t i = 0; i < entries.size(); ++i) {
    const auto& e  = entries[i];
    const int prio = e.priority + 1;

    if constexpr (DirectoryStats::EnableInstrumentation) {
      stats[i].mod = entries[i].modName.toStdString();
    }

    try {
      if (e.stealFiles.length() > 0) {
        stealModFilesIntoStructure(directoryStructure, e.modName, prio, e.absolutePath,
                                   e.stealFiles);

        if (progress) {
          progress->addDone();
        }
      } else {
        auto& mt = g_threads.request();

        mt.gameFeatures = &m_Core.gameFeatures();
        mt.progress     = progress;
        mt.ds           = directoryStructure;
        mt.modName      = e.modName.toStdWString();
        mt.path         = QDir::toNativeSeparators(e.absolutePath).toStdWString();
        mt.prio         = prio;

        mt.archives.clear();
        for (auto&& a : e.archives) {
          mt.archives.push_back(a.toStdWString());
        }

        mt.enabledArchives.clear();
        for (auto&& a : m_EnabledArchives) {
          mt.enabledArchives.insert(a.toStdWString());
        }

        mt.stats = &stats[i];

        mt.wakeup();
      }
    } catch (const std::exception& ex) {
      emit error(tr("failed to read mod (%1): %2").arg(e.modName, ex.what()));
    }
  }