diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:39:47 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:40:08 +0900 |
| commit | b1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch) | |
| tree | 9ce465b42bf09372118335c7c619bb2b41869eaf /src/aria2api.cc | |
| parent | 4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff) | |
make clang-format using clang-format-3.6
Diffstat (limited to 'src/aria2api.cc')
| -rw-r--r-- | src/aria2api.cc | 502 |
1 files changed, 221 insertions, 281 deletions
diff --git a/src/aria2api.cc b/src/aria2api.cc index c681b9c4..b7a8b268 100644 --- a/src/aria2api.cc +++ b/src/aria2api.cc @@ -63,24 +63,25 @@ #include "Notifier.h" #include "ApiCallbackDownloadEventListener.h" #ifdef ENABLE_BITTORRENT -# include "bittorrent_helper.h" +#include "bittorrent_helper.h" #endif // ENABLE_BITTORRENT namespace aria2 { Session::Session(const KeyVals& options) - : context(std::make_shared<Context>(false, 0, nullptr, options)) -{} + : context(std::make_shared<Context>(false, 0, nullptr, options)) +{ +} -Session::~Session() -{} +Session::~Session() {} SessionConfig::SessionConfig() - : keepRunning(false), - useSignalHandler(true), - downloadEventCallback(nullptr), - userData(nullptr) -{} + : keepRunning(false), + useSignalHandler(true), + downloadEventCallback(nullptr), + userData(nullptr) +{ +} namespace { Platform* platform = nullptr; @@ -91,7 +92,8 @@ int libraryInit() global::initConsole(true); try { platform = new Platform(); - } catch(RecoverableException& e) { + } + catch (RecoverableException& e) { A2_LOG_ERROR_EX(EX_EXCEPTION_CAUGHT, e); return -1; } @@ -111,30 +113,32 @@ Session* sessionNew(const KeyVals& options, const SessionConfig& config) std::unique_ptr<Session> session; try { session = make_unique<Session>(options); - } catch(RecoverableException& e) { + } + catch (RecoverableException& e) { return nullptr; } - if(session->context->reqinfo) { - if(!config.useSignalHandler) { + if (session->context->reqinfo) { + if (!config.useSignalHandler) { session->context->reqinfo->setUseSignalHandler(false); } rv = session->context->reqinfo->prepare(); - if(rv != 0) { + if (rv != 0) { return nullptr; } auto& e = session->context->reqinfo->getDownloadEngine(); - if(config.keepRunning) { + if (config.keepRunning) { e->getRequestGroupMan()->setKeepRunning(true); // Add command to make aria2 keep event polling e->addCommand(make_unique<KeepRunningCommand>(e->newCUID(), e.get())); } - if(config.downloadEventCallback) { - session->listener = make_unique<ApiCallbackDownloadEventListener> - (session.get(), config.downloadEventCallback, config.userData); - SingletonHolder<Notifier>::instance() - ->addDownloadEventListener(session->listener.get()); + if (config.downloadEventCallback) { + session->listener = make_unique<ApiCallbackDownloadEventListener>( + session.get(), config.downloadEventCallback, config.userData); + SingletonHolder<Notifier>::instance()->addDownloadEventListener( + session->listener.get()); } - } else { + } + else { return nullptr; } return session.release(); @@ -156,9 +160,10 @@ int run(Session* session, RUN_MODE mode) int shutdown(Session* session, bool force) { auto& e = session->context->reqinfo->getDownloadEngine(); - if(force) { + if (force) { e->requestForceHalt(); - } else { + } + else { e->requestHalt(); } // Skip next polling timeout. This avoids 1 second delay when there @@ -167,39 +172,32 @@ int shutdown(Session* session, bool force) return 0; } -std::string gidToHex(A2Gid gid) -{ - return GroupId::toHex(gid); -} +std::string gidToHex(A2Gid gid) { return GroupId::toHex(gid); } A2Gid hexToGid(const std::string& hex) { A2Gid gid; - if(GroupId::toNumericId(gid, hex.c_str()) == 0) { + if (GroupId::toNumericId(gid, hex.c_str()) == 0) { return gid; - } else { + } + else { return 0; } } -bool isNull(A2Gid gid) -{ - return gid == 0; -} +bool isNull(A2Gid gid) { return gid == 0; } namespace { -template<typename InputIterator, typename Pred> -void apiGatherOption -(InputIterator first, InputIterator last, - Pred pred, - Option* option, - const std::shared_ptr<OptionParser>& optionParser) -{ - for(; first != last; ++first) { +template <typename InputIterator, typename Pred> +void apiGatherOption(InputIterator first, InputIterator last, Pred pred, + Option* option, + const std::shared_ptr<OptionParser>& optionParser) +{ + for (; first != last; ++first) { const std::string& optionName = (*first).first; PrefPtr pref = option::k2p(optionName); const OptionHandler* handler = optionParser->find(pref); - if(!handler || !pred(handler)) { + if (!handler || !pred(handler)) { // Just ignore the unacceptable options in this context. continue; } @@ -213,25 +211,26 @@ void apiGatherRequestOption(Option* option, const KeyVals& options, const std::shared_ptr<OptionParser>& optionParser) { apiGatherOption(options.begin(), options.end(), - std::mem_fn(&OptionHandler::getInitialOption), - option, optionParser); + std::mem_fn(&OptionHandler::getInitialOption), option, + optionParser); } } // namespace namespace { -void apiGatherChangeableOption(Option* option, const KeyVals& options, - const std::shared_ptr<OptionParser>& optionParser) +void apiGatherChangeableOption( + Option* option, const KeyVals& options, + const std::shared_ptr<OptionParser>& optionParser) { apiGatherOption(options.begin(), options.end(), - std::mem_fn(&OptionHandler::getChangeOption), - option, optionParser); + std::mem_fn(&OptionHandler::getChangeOption), option, + optionParser); } } // namespace namespace { -void apiGatherChangeableOptionForReserved -(Option* option, const KeyVals& options, - const std::shared_ptr<OptionParser>& optionParser) +void apiGatherChangeableOptionForReserved( + Option* option, const KeyVals& options, + const std::shared_ptr<OptionParser>& optionParser) { apiGatherOption(options.begin(), options.end(), std::mem_fn(&OptionHandler::getChangeOptionForReserved), @@ -240,133 +239,128 @@ void apiGatherChangeableOptionForReserved } // namespace namespace { -void apiGatherChangeableGlobalOption -(Option* option, const KeyVals& options, - const std::shared_ptr<OptionParser>& optionParser) +void apiGatherChangeableGlobalOption( + Option* option, const KeyVals& options, + const std::shared_ptr<OptionParser>& optionParser) { apiGatherOption(options.begin(), options.end(), - std::mem_fn(&OptionHandler::getChangeGlobalOption), - option, optionParser); + std::mem_fn(&OptionHandler::getChangeGlobalOption), option, + optionParser); } } // namespace namespace { void addRequestGroup(const std::shared_ptr<RequestGroup>& group, - DownloadEngine* e, - int position) + DownloadEngine* e, int position) { - if(position >= 0) { + if (position >= 0) { e->getRequestGroupMan()->insertReservedGroup(position, group); - } else { + } + else { e->getRequestGroupMan()->addReservedGroup(group); } } } // namespace -int addUri(Session* session, - A2Gid* gid, - const std::vector<std::string>& uris, - const KeyVals& options, - int position) +int addUri(Session* session, A2Gid* gid, const std::vector<std::string>& uris, + const KeyVals& options, int position) { auto& e = session->context->reqinfo->getDownloadEngine(); auto requestOption = std::make_shared<Option>(*e->getOption()); try { apiGatherRequestOption(requestOption.get(), options, OptionParser::getInstance()); - } catch(RecoverableException& e) { + } + catch (RecoverableException& e) { A2_LOG_INFO_EX(EX_EXCEPTION_CAUGHT, e); return -1; } - std::vector<std::shared_ptr<RequestGroup> > result; + std::vector<std::shared_ptr<RequestGroup>> result; createRequestGroupForUri(result, requestOption, uris, /* ignoreForceSeq = */ true, /* ignoreLocalPath = */ true); - if(!result.empty()) { + if (!result.empty()) { addRequestGroup(result.front(), e.get(), position); - if(gid) { + if (gid) { *gid = result.front()->getGID(); } } return 0; } -int addMetalink(Session* session, - std::vector<A2Gid>* gids, - const std::string& metalinkFile, - const KeyVals& options, +int addMetalink(Session* session, std::vector<A2Gid>* gids, + const std::string& metalinkFile, const KeyVals& options, int position) { #ifdef ENABLE_METALINK auto& e = session->context->reqinfo->getDownloadEngine(); auto requestOption = std::make_shared<Option>(*e->getOption()); - std::vector<std::shared_ptr<RequestGroup> > result; + std::vector<std::shared_ptr<RequestGroup>> result; try { apiGatherRequestOption(requestOption.get(), options, OptionParser::getInstance()); requestOption->put(PREF_METALINK_FILE, metalinkFile); createRequestGroupForMetalink(result, requestOption); - } catch(RecoverableException& e) { + } + catch (RecoverableException& e) { A2_LOG_INFO_EX(EX_EXCEPTION_CAUGHT, e); return -1; } - if(!result.empty()) { - if(position >= 0) { + if (!result.empty()) { + if (position >= 0) { e->getRequestGroupMan()->insertReservedGroup(position, result); - } else { + } + else { e->getRequestGroupMan()->addReservedGroup(result); } - if(gids) { - for(std::vector<std::shared_ptr<RequestGroup> >::const_iterator i = - result.begin(), eoi = result.end(); i != eoi; ++i) { + if (gids) { + for (std::vector<std::shared_ptr<RequestGroup>>::const_iterator + i = result.begin(), + eoi = result.end(); + i != eoi; ++i) { (*gids).push_back((*i)->getGID()); } } } return 0; -#else // !ENABLE_METALINK +#else // !ENABLE_METALINK return -1; #endif // !ENABLE_METALINK } -int addTorrent(Session* session, - A2Gid* gid, - const std::string& torrentFile, +int addTorrent(Session* session, A2Gid* gid, const std::string& torrentFile, const std::vector<std::string>& webSeedUris, - const KeyVals& options, - int position) + const KeyVals& options, int position) { #ifdef ENABLE_BITTORRENT auto& e = session->context->reqinfo->getDownloadEngine(); auto requestOption = std::make_shared<Option>(*e->getOption()); - std::vector<std::shared_ptr<RequestGroup> > result; + std::vector<std::shared_ptr<RequestGroup>> result; try { apiGatherRequestOption(requestOption.get(), options, OptionParser::getInstance()); requestOption->put(PREF_TORRENT_FILE, torrentFile); createRequestGroupForBitTorrent(result, requestOption, webSeedUris, torrentFile); - } catch(RecoverableException& e) { + } + catch (RecoverableException& e) { A2_LOG_INFO_EX(EX_EXCEPTION_CAUGHT, e); return -1; } - if(!result.empty()) { + if (!result.empty()) { addRequestGroup(result.front(), e.get(), position); - if(gid) { + if (gid) { *gid = result.front()->getGID(); } } return 0; -#else // !ENABLE_BITTORRENT +#else // !ENABLE_BITTORRENT return -1; #endif // !ENABLE_BITTORRENT } -int addTorrent(Session* session, - A2Gid* gid, - const std::string& torrentFile, - const KeyVals& options, - int position) +int addTorrent(Session* session, A2Gid* gid, const std::string& torrentFile, + const KeyVals& options, int position) { return addTorrent(session, gid, torrentFile, std::vector<std::string>(), options, position); @@ -376,22 +370,26 @@ int removeDownload(Session* session, A2Gid gid, bool force) { auto& e = session->context->reqinfo->getDownloadEngine(); std::shared_ptr<RequestGroup> group = e->getRequestGroupMan()->findGroup(gid); - if(group) { - if(group->getState() == RequestGroup::STATE_ACTIVE) { - if(force) { + if (group) { + if (group->getState() == RequestGroup::STATE_ACTIVE) { + if (force) { group->setForceHaltRequested(true, RequestGroup::USER_REQUEST); - } else { + } + else { group->setHaltRequested(true, RequestGroup::USER_REQUEST); } e->setRefreshInterval(std::chrono::milliseconds(0)); - } else { - if(group->isDependencyResolved()) { + } + else { + if (group->isDependencyResolved()) { e->getRequestGroupMan()->removeReservedGroup(gid); - } else { + } + else { return -1; } } - } else { + } + else { return -1; } return 0; @@ -401,9 +399,9 @@ int pauseDownload(Session* session, A2Gid gid, bool force) { auto& e = session->context->reqinfo->getDownloadEngine(); std::shared_ptr<RequestGroup> group = e->getRequestGroupMan()->findGroup(gid); - if(group) { + if (group) { bool reserved = group->getState() == RequestGroup::STATE_WAITING; - if(pauseRequestGroup(group, reserved, force)) { + if (pauseRequestGroup(group, reserved, force)) { e->setRefreshInterval(std::chrono::milliseconds(0)); return 0; } @@ -415,11 +413,11 @@ int unpauseDownload(Session* session, A2Gid gid) { auto& e = session->context->reqinfo->getDownloadEngine(); std::shared_ptr<RequestGroup> group = e->getRequestGroupMan()->findGroup(gid); - if(!group || - group->getState() != RequestGroup::STATE_WAITING || - !group->isPauseRequested()) { + if (!group || group->getState() != RequestGroup::STATE_WAITING || + !group->isPauseRequested()) { return -1; - } else { + } + else { group->setPauseRequested(false); e->getRequestGroupMan()->requestQueueCheck(); } @@ -431,7 +429,8 @@ int changePosition(Session* session, A2Gid gid, int pos, OffsetMode how) auto& e = session->context->reqinfo->getDownloadEngine(); try { return e->getRequestGroupMan()->changeReservedGroupPosition(gid, pos, how); - } catch(RecoverableException& e) { + } + catch (RecoverableException& e) { A2_LOG_INFO_EX(EX_EXCEPTION_CAUGHT, e); return -1; } @@ -441,23 +440,26 @@ int changeOption(Session* session, A2Gid gid, const KeyVals& options) { auto& e = session->context->reqinfo->getDownloadEngine(); std::shared_ptr<RequestGroup> group = e->getRequestGroupMan()->findGroup(gid); - if(group) { + if (group) { Option option; try { - if(group->getState() == RequestGroup::STATE_ACTIVE) { + if (group->getState() == RequestGroup::STATE_ACTIVE) { apiGatherChangeableOption(&option, options, OptionParser::getInstance()); - } else { + } + else { apiGatherChangeableOptionForReserved(&option, options, OptionParser::getInstance()); } - } catch(RecoverableException& err) { + } + catch (RecoverableException& err) { A2_LOG_INFO_EX(EX_EXCEPTION_CAUGHT, err); return -1; } changeOption(group, option, e.get()); return 0; - } else { + } + else { return -1; } } @@ -466,9 +468,10 @@ const std::string& getGlobalOption(Session* session, const std::string& name) { auto& e = session->context->reqinfo->getDownloadEngine(); PrefPtr pref = option::k2p(name); - if(OptionParser::getInstance()->find(pref)) { + if (OptionParser::getInstance()->find(pref)) { return e->getOption()->get(pref); - } else { + } + else { return A2STR::NIL; } } @@ -476,12 +479,13 @@ const std::string& getGlobalOption(Session* session, const std::string& name) KeyVals getGlobalOptions(Session* session) { auto& e = session->context->reqinfo->getDownloadEngine(); - const std::shared_ptr<OptionParser>& optionParser = OptionParser::getInstance(); + const std::shared_ptr<OptionParser>& optionParser = + OptionParser::getInstance(); const Option* option = e->getOption(); KeyVals options; - for(size_t i = 1, len = option::countOption(); i < len; ++i) { + for (size_t i = 1, len = option::countOption(); i < len; ++i) { PrefPtr pref = option::i2p(i); - if(option->defined(pref) && optionParser->find(pref)) { + if (option->defined(pref) && optionParser->find(pref)) { options.push_back(KeyVals::value_type(pref->k, option->get(pref))); } } @@ -495,7 +499,8 @@ int changeGlobalOption(Session* session, const KeyVals& options) try { apiGatherChangeableGlobalOption(&option, options, OptionParser::getInstance()); - } catch(RecoverableException& err) { + } + catch (RecoverableException& err) { A2_LOG_INFO_EX(EX_EXCEPTION_CAUGHT, err); return -1; } @@ -522,20 +527,18 @@ std::vector<A2Gid> getActiveDownload(Session* session) auto& e = session->context->reqinfo->getDownloadEngine(); const RequestGroupList& groups = e->getRequestGroupMan()->getRequestGroups(); std::vector<A2Gid> res; - for(const auto& group : groups) { + for (const auto& group : groups) { res.push_back(group->getGID()); } return res; } namespace { -template<typename OutputIterator, typename InputIterator> -void createUriEntry -(OutputIterator out, - InputIterator first, InputIterator last, - UriStatus status) +template <typename OutputIterator, typename InputIterator> +void createUriEntry(OutputIterator out, InputIterator first, InputIterator last, + UriStatus status) { - for(; first != last; ++first) { + for (; first != last; ++first) { UriData uriData; uriData.uri = *first; uriData.status = status; @@ -545,31 +548,26 @@ void createUriEntry } // namespace namespace { -template<typename OutputIterator> -void createUriEntry -(OutputIterator out, const std::shared_ptr<FileEntry>& file) +template <typename OutputIterator> +void createUriEntry(OutputIterator out, const std::shared_ptr<FileEntry>& file) { - createUriEntry(out, - file->getSpentUris().begin(), - file->getSpentUris().end(), + createUriEntry(out, file->getSpentUris().begin(), file->getSpentUris().end(), URI_USED); - createUriEntry(out, - file->getRemainingUris().begin(), - file->getRemainingUris().end(), - URI_WAITING); + createUriEntry(out, file->getRemainingUris().begin(), + file->getRemainingUris().end(), URI_WAITING); } } // namespace namespace { -FileData createFileData -(const std::shared_ptr<FileEntry>& fe, int index, const BitfieldMan* bf) +FileData createFileData(const std::shared_ptr<FileEntry>& fe, int index, + const BitfieldMan* bf) { FileData file; file.index = index; file.path = fe->getPath(); file.length = fe->getLength(); - file.completedLength = bf->getOffsetCompletedLength - (fe->getOffset(), fe->getLength()); + file.completedLength = + bf->getOffsetCompletedLength(fe->getOffset(), fe->getLength()); file.selected = fe->isRequested(); createUriEntry(std::back_inserter(file.uris), fe); return file; @@ -577,27 +575,22 @@ FileData createFileData } // namespace namespace { -template<typename OutputIterator, typename InputIterator> -void createFileEntry -(OutputIterator out, - InputIterator first, InputIterator last, - const BitfieldMan* bf) +template <typename OutputIterator, typename InputIterator> +void createFileEntry(OutputIterator out, InputIterator first, + InputIterator last, const BitfieldMan* bf) { size_t index = 1; - for(; first != last; ++first) { + for (; first != last; ++first) { out++ = createFileData(*first, index++, bf); } } } // namespace namespace { -template<typename OutputIterator, typename InputIterator> -void createFileEntry -(OutputIterator out, - InputIterator first, InputIterator last, - int64_t totalLength, - int32_t pieceLength, - const std::string& bitfield) +template <typename OutputIterator, typename InputIterator> +void createFileEntry(OutputIterator out, InputIterator first, + InputIterator last, int64_t totalLength, + int32_t pieceLength, const std::string& bitfield) { BitfieldMan bf(pieceLength, totalLength); bf.setBitfield(reinterpret_cast<const unsigned char*>(bitfield.data()), @@ -607,16 +600,14 @@ void createFileEntry } // namespace namespace { -template<typename OutputIterator, typename InputIterator> -void createFileEntry -(OutputIterator out, - InputIterator first, InputIterator last, - int64_t totalLength, - int32_t pieceLength, - const std::shared_ptr<PieceStorage>& ps) +template <typename OutputIterator, typename InputIterator> +void createFileEntry(OutputIterator out, InputIterator first, + InputIterator last, int64_t totalLength, + int32_t pieceLength, + const std::shared_ptr<PieceStorage>& ps) { BitfieldMan bf(pieceLength, totalLength); - if(ps) { + if (ps) { bf.setBitfield(ps->getBitfield(), ps->getBitfieldLength()); } createFileEntry(out, first, last, &bf); @@ -624,16 +615,15 @@ void createFileEntry } // namespace namespace { -template<typename OutputIterator> -void pushRequestOption -(OutputIterator out, - const std::shared_ptr<Option>& option, - const std::shared_ptr<OptionParser>& oparser) +template <typename OutputIterator> +void pushRequestOption(OutputIterator out, + const std::shared_ptr<Option>& option, + const std::shared_ptr<OptionParser>& oparser) { - for(size_t i = 1, len = option::countOption(); i < len; ++i) { + for (size_t i = 1, len = option::countOption(); i < len; ++i) { PrefPtr pref = option::i2p(i); const OptionHandler* h = oparser->find(pref); - if(h && h->getInitialOption() && option->defined(pref)) { + if (h && h->getInitialOption() && option->defined(pref)) { out++ = KeyVals::value_type(pref->k, option->get(pref)); } } @@ -645,9 +635,10 @@ const std::string& getRequestOption(const std::shared_ptr<Option>& option, const std::string& name) { PrefPtr pref = option::k2p(name); - if(OptionParser::getInstance()->find(pref)) { + if (OptionParser::getInstance()->find(pref)) { return option->get(pref); - } else { + } + else { return A2STR::NIL; } } @@ -666,18 +657,20 @@ KeyVals getRequestOptions(const std::shared_ptr<Option>& option) namespace { struct RequestGroupDH : public DownloadHandle { RequestGroupDH(const std::shared_ptr<RequestGroup>& group) - : group(group), - ts(group->calculateStat()) - {} + : group(group), ts(group->calculateStat()) + { + } virtual ~RequestGroupDH() {} virtual DownloadStatus getStatus() CXX11_OVERRIDE { - if(group->getState() == RequestGroup::STATE_ACTIVE) { + if (group->getState() == RequestGroup::STATE_ACTIVE) { return DOWNLOAD_ACTIVE; - } else { - if(group->isPauseRequested()) { + } + else { + if (group->isPauseRequested()) { return DOWNLOAD_PAUSED; - } else { + } + else { return DOWNLOAD_WAITING; } } @@ -697,27 +690,21 @@ struct RequestGroupDH : public DownloadHandle { virtual std::string getBitfield() CXX11_OVERRIDE { const std::shared_ptr<PieceStorage>& ps = group->getPieceStorage(); - if(ps) { + if (ps) { return std::string(reinterpret_cast<const char*>(ps->getBitfield()), ps->getBitfieldLength()); - } else { + } + else { return ""; } } - virtual int getDownloadSpeed() CXX11_OVERRIDE - { - return ts.downloadSpeed; - } - virtual int getUploadSpeed() CXX11_OVERRIDE - { - return ts.uploadSpeed; - } + virtual int getDownloadSpeed() CXX11_OVERRIDE { return ts.downloadSpeed; } + virtual int getUploadSpeed() CXX11_OVERRIDE { return ts.uploadSpeed; } virtual const std::string& getInfoHash() CXX11_OVERRIDE { #ifdef ENABLE_BITTORRENT - if(group->getDownloadContext()->hasAttribute(CTX_ATTR_BT)) { - return bittorrent::getTorrentAttrs(group->getDownloadContext()) - ->infoHash; + if (group->getDownloadContext()->hasAttribute(CTX_ATTR_BT)) { + return bittorrent::getTorrentAttrs(group->getDownloadContext())->infoHash; } #endif // ENABLE_BITTORRENT return A2STR::NIL; @@ -735,18 +722,12 @@ struct RequestGroupDH : public DownloadHandle { { return group->getNumConnection(); } - virtual int getErrorCode() CXX11_OVERRIDE - { - return 0; - } + virtual int getErrorCode() CXX11_OVERRIDE { return 0; } virtual const std::vector<A2Gid>& getFollowedBy() CXX11_OVERRIDE { return group->followedBy(); } - virtual A2Gid getBelongsTo() CXX11_OVERRIDE - { - return group->belongsTo(); - } + virtual A2Gid getBelongsTo() CXX11_OVERRIDE { return group->belongsTo(); } virtual const std::string& getDir() CXX11_OVERRIDE { return group->getOption()->get(PREF_DIR); @@ -755,11 +736,9 @@ struct RequestGroupDH : public DownloadHandle { { std::vector<FileData> res; const std::shared_ptr<DownloadContext>& dctx = group->getDownloadContext(); - createFileEntry(std::back_inserter(res), - dctx->getFileEntries().begin(), - dctx->getFileEntries().end(), - dctx->getTotalLength(), dctx->getPieceLength(), - group->getPieceStorage()); + createFileEntry(std::back_inserter(res), dctx->getFileEntries().begin(), + dctx->getFileEntries().end(), dctx->getTotalLength(), + dctx->getPieceLength(), group->getPieceStorage()); return res; } virtual int getNumFiles() CXX11_OVERRIDE @@ -772,31 +751,32 @@ struct RequestGroupDH : public DownloadHandle { const std::shared_ptr<DownloadContext>& dctx = group->getDownloadContext(); BitfieldMan bf(dctx->getPieceLength(), dctx->getTotalLength()); const std::shared_ptr<PieceStorage>& ps = group->getPieceStorage(); - if(ps) { + if (ps) { bf.setBitfield(ps->getBitfield(), ps->getBitfieldLength()); } - return createFileData(dctx->getFileEntries()[index-1], index, &bf); + return createFileData(dctx->getFileEntries()[index - 1], index, &bf); } virtual BtMetaInfoData getBtMetaInfo() CXX11_OVERRIDE { BtMetaInfoData res; #ifdef ENABLE_BITTORRENT - if(group->getDownloadContext()->hasAttribute(CTX_ATTR_BT)) { + if (group->getDownloadContext()->hasAttribute(CTX_ATTR_BT)) { auto torrentAttrs = - bittorrent::getTorrentAttrs(group->getDownloadContext()); + bittorrent::getTorrentAttrs(group->getDownloadContext()); res.announceList = torrentAttrs->announceList; res.comment = torrentAttrs->comment; res.creationDate = torrentAttrs->creationDate; res.mode = torrentAttrs->mode; - if(!torrentAttrs->metadata.empty()) { + if (!torrentAttrs->metadata.empty()) { res.name = torrentAttrs->name; } - } else + } + else #endif // ENABLE_BITTORRENT - { - res.creationDate = 0; - res.mode = BT_FILE_MODE_NONE; - } + { + res.creationDate = 0; + res.mode = BT_FILE_MODE_NONE; + } return res; } virtual const std::string& getOption(const std::string& name) CXX11_OVERRIDE @@ -814,13 +794,11 @@ struct RequestGroupDH : public DownloadHandle { namespace { struct DownloadResultDH : public DownloadHandle { - DownloadResultDH(std::shared_ptr<DownloadResult> dr) - : dr(std::move(dr)) - {} + DownloadResultDH(std::shared_ptr<DownloadResult> dr) : dr(std::move(dr)) {} virtual ~DownloadResultDH() {} virtual DownloadStatus getStatus() CXX11_OVERRIDE { - switch(dr->result) { + switch (dr->result) { case error_code::FINISHED: return DOWNLOAD_COMPLETE; case error_code::REMOVED: @@ -829,80 +807,44 @@ struct DownloadResultDH : public DownloadHandle { return DOWNLOAD_ERROR; } } - virtual int64_t getTotalLength() CXX11_OVERRIDE - { - return dr->totalLength; - } + virtual int64_t getTotalLength() CXX11_OVERRIDE { return dr->totalLength; } virtual int64_t getCompletedLength() CXX11_OVERRIDE { return dr->completedLength; } - virtual int64_t getUploadLength() CXX11_OVERRIDE - { - return dr->uploadLength; - } - virtual std::string getBitfield() CXX11_OVERRIDE - { - return dr->bitfield; - } - virtual int getDownloadSpeed() CXX11_OVERRIDE - { - return 0; - } - virtual int getUploadSpeed() CXX11_OVERRIDE - { - return 0; - } + virtual int64_t getUploadLength() CXX11_OVERRIDE { return dr->uploadLength; } + virtual std::string getBitfield() CXX11_OVERRIDE { return dr->bitfield; } + virtual int getDownloadSpeed() CXX11_OVERRIDE { return 0; } + virtual int getUploadSpeed() CXX11_OVERRIDE { return 0; } virtual const std::string& getInfoHash() CXX11_OVERRIDE { return dr->infoHash; } - virtual size_t getPieceLength() CXX11_OVERRIDE - { - return dr->pieceLength; - } - virtual int getNumPieces() CXX11_OVERRIDE - { - return dr->numPieces; - } - virtual int getConnections() CXX11_OVERRIDE - { - return 0; - } - virtual int getErrorCode() CXX11_OVERRIDE - { - return dr->result; - } + virtual size_t getPieceLength() CXX11_OVERRIDE { return dr->pieceLength; } + virtual int getNumPieces() CXX11_OVERRIDE { return dr->numPieces; } + virtual int getConnections() CXX11_OVERRIDE { return 0; } + virtual int getErrorCode() CXX11_OVERRIDE { return dr->result; } virtual const std::vector<A2Gid>& getFollowedBy() CXX11_OVERRIDE { return dr->followedBy; } - virtual A2Gid getBelongsTo() CXX11_OVERRIDE - { - return dr->belongsTo; - } - virtual const std::string& getDir() CXX11_OVERRIDE - { - return dr->dir; - } + virtual A2Gid getBelongsTo() CXX11_OVERRIDE { return dr->belongsTo; } + virtual const std::string& getDir() CXX11_OVERRIDE { return dr->dir; } virtual std::vector<FileData> getFiles() CXX11_OVERRIDE { std::vector<FileData> res; - createFileEntry(std::back_inserter(res), - dr->fileEntries.begin(), dr->fileEntries.end(), - dr->totalLength, dr->pieceLength, dr->bitfield); + createFileEntry(std::back_inserter(res), dr->fileEntries.begin(), + dr->fileEntries.end(), dr->totalLength, dr->pieceLength, + dr->bitfield); return res; } - virtual int getNumFiles() CXX11_OVERRIDE - { - return dr->fileEntries.size(); - } + virtual int getNumFiles() CXX11_OVERRIDE { return dr->fileEntries.size(); } virtual FileData getFile(int index) CXX11_OVERRIDE { BitfieldMan bf(dr->pieceLength, dr->totalLength); bf.setBitfield(reinterpret_cast<const unsigned char*>(dr->bitfield.data()), dr->bitfield.size()); - return createFileData(dr->fileEntries[index-1], index, &bf); + return createFileData(dr->fileEntries[index - 1], index, &bf); } virtual BtMetaInfoData getBtMetaInfo() CXX11_OVERRIDE { @@ -925,20 +867,18 @@ DownloadHandle* getDownloadHandle(Session* session, A2Gid gid) auto& e = session->context->reqinfo->getDownloadEngine(); auto& rgman = e->getRequestGroupMan(); std::shared_ptr<RequestGroup> group = rgman->findGroup(gid); - if(group) { + if (group) { return new RequestGroupDH(group); - } else { + } + else { std::shared_ptr<DownloadResult> ds = rgman->findDownloadResult(gid); - if(ds) { + if (ds) { return new DownloadResultDH(ds); } } return nullptr; } -void deleteDownloadHandle(DownloadHandle* dh) -{ - delete dh; -} +void deleteDownloadHandle(DownloadHandle* dh) { delete dh; } } // namespace aria2 |
