/* */ #include "BtFileAllocationEntry.h" #include #include "BtSetup.h" #include "RequestGroup.h" #include "Command.h" #include "DownloadEngine.h" #include "DownloadContext.h" #include "FileEntry.h" #include "PieceStorage.h" #include "DiskAdaptor.h" #include "Option.h" #include "prefs.h" #include "LogFactory.h" namespace aria2 { BtFileAllocationEntry::BtFileAllocationEntry(RequestGroup* requestGroup) : FileAllocationEntry(requestGroup, nullptr) { } BtFileAllocationEntry::~BtFileAllocationEntry() = default; void BtFileAllocationEntry::prepareForNextAction( std::vector>& commands, DownloadEngine* e) { auto rg = getRequestGroup(); auto& dctx = rg->getDownloadContext(); auto& ps = rg->getPieceStorage(); auto diskAdaptor = ps->getDiskAdaptor(); auto& option = rg->getOption(); BtSetup().setup(commands, rg, e, option.get()); if (option->getAsBool(PREF_ENABLE_MMAP) && option->get(PREF_FILE_ALLOCATION) != V_NONE && diskAdaptor->size() <= option->getAsLLInt(PREF_MAX_MMAP_LIMIT)) { diskAdaptor->enableMmap(); } if (!rg->downloadFinished()) { // For DownloadContext::resetDownloadStartTime(), see also // RequestGroup::createInitialCommand() dctx->resetDownloadStartTime(); const auto& fileEntries = dctx->getFileEntries(); if (isUriSuppliedForRequsetFileEntry(std::begin(fileEntries), std::end(fileEntries))) { rg->createNextCommandWithAdj(commands, e, 0); } if (option->getAsInt(PREF_AUTO_SAVE_INTERVAL) != 0) { try { rg->saveControlFile(); } catch (RecoverableException& e) { A2_LOG_ERROR_EX(EX_EXCEPTION_CAUGHT, e); } } } else { #ifdef __MINGW32__ if (!diskAdaptor->isReadOnlyEnabled()) { // On Windows, if aria2 opens files with GENERIC_WRITE access // right, some programs cannot open them aria2 is seeding. To // avoid this situation, re-open the files with read-only // enabled. A2_LOG_INFO("Closing files and re-open them with read-only mode" " enabled."); diskAdaptor->closeFile(); diskAdaptor->enableReadOnly(); diskAdaptor->openFile(); } #endif // __MINGW32__ rg->enableSeedOnly(); } } } // namespace aria2