/* */ #include "FileAllocationCommand.h" #include "FileAllocationMan.h" #include "FileAllocationEntry.h" #include "DownloadEngine.h" #include "RequestGroup.h" #include "Logger.h" #include "message.h" #include "prefs.h" #include "util.h" #include "DownloadEngine.h" #include "DownloadContext.h" #include "a2functional.h" #include "RecoverableException.h" namespace aria2 { FileAllocationCommand::FileAllocationCommand(int cuid, RequestGroup* requestGroup, DownloadEngine* e, const FileAllocationEntryHandle& fileAllocationEntry): RealtimeCommand(cuid, requestGroup, e), _fileAllocationEntry(fileAllocationEntry) {} FileAllocationCommand::~FileAllocationCommand() {} bool FileAllocationCommand::executeInternal() { if(_e->isHaltRequested()) { return true; } _fileAllocationEntry->allocateChunk(); if(_fileAllocationEntry->finished()) { logger->debug(MSG_ALLOCATION_COMPLETED, _timer.difference(), util::itos(_requestGroup->getTotalLength(), true).c_str()); _e->_fileAllocationMan->dropPickedEntry(); std::deque commands; try { _fileAllocationEntry->prepareForNextAction(commands, _e); } catch(RecoverableException& e) { std::for_each(commands.begin(), commands.end(), Deleter()); throw; } _e->addCommand(commands); _e->setNoWait(true); return true; } else { _e->commands.push_back(this); return false; } } bool FileAllocationCommand::handleException(Exception& e) { _e->_fileAllocationMan->dropPickedEntry(); logger->error(MSG_FILE_ALLOCATION_FAILURE, e, cuid); logger->error(MSG_DOWNLOAD_NOT_COMPLETE, cuid, _requestGroup->getDownloadContext()->getBasePath().c_str()); return true; } } // namespace aria2