diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-03-26 17:12:52 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2016-03-26 17:20:27 +0900 |
| commit | d64089632e82a2548752c7a6baaa68365a795a74 (patch) | |
| tree | 57fc7b85a8c1290975d58fa4761b04a7695bf7e3 /src/UTMetadataRequestFactory.cc | |
| parent | c81b1321122e8509b55c94c0cbca0d8d6d319f0c (diff) | |
| parent | a7cd943a06b1a5ff4515b57060b84037f8d01f9f (diff) | |
Merge branch 'master' into random-webseeding
Diffstat (limited to 'src/UTMetadataRequestFactory.cc')
| -rw-r--r-- | src/UTMetadataRequestFactory.cc | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/src/UTMetadataRequestFactory.cc b/src/UTMetadataRequestFactory.cc index 3824ec4c..3e4b361d 100644 --- a/src/UTMetadataRequestFactory.cc +++ b/src/UTMetadataRequestFactory.cc @@ -50,29 +50,30 @@ namespace aria2 { UTMetadataRequestFactory::UTMetadataRequestFactory() - : dctx_{nullptr}, - dispatcher_{nullptr}, - messageFactory_{nullptr}, - tracker_{nullptr}, - cuid_{0} -{} + : dctx_{nullptr}, + dispatcher_{nullptr}, + messageFactory_{nullptr}, + tracker_{nullptr}, + cuid_{0} +{ +} -std::vector<std::unique_ptr<BtMessage>> UTMetadataRequestFactory::create -(size_t num, PieceStorage* pieceStorage) +std::vector<std::unique_ptr<BtMessage>> +UTMetadataRequestFactory::create(size_t num, PieceStorage* pieceStorage) { auto msgs = std::vector<std::unique_ptr<BtMessage>>{}; - while(num) { + while (num) { auto metadataRequests = tracker_->getAllTrackedIndex(); auto p = pieceStorage->getMissingPiece(peer_, metadataRequests, cuid_); - if(!p) { + if (!p) { A2_LOG_DEBUG("No ut_metadata piece is available to download."); break; } --num; A2_LOG_DEBUG(fmt("Creating ut_metadata request index=%lu", static_cast<unsigned long>(p->getIndex()))); - auto m = make_unique<UTMetadataRequestExtensionMessage> - (peer_->getExtensionMessageID(ExtensionMessageRegistry::UT_METADATA)); + auto m = make_unique<UTMetadataRequestExtensionMessage>( + peer_->getExtensionMessageID(ExtensionMessageRegistry::UT_METADATA)); m->setIndex(p->getIndex()); m->setDownloadContext(dctx_); m->setBtMessageDispatcher(dispatcher_); |
