RequestGroupMan.cc 34 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094
  1. /* <!-- copyright */
  2. /*
  3. * aria2 - The high speed download utility
  4. *
  5. * Copyright (C) 2006 Tatsuhiro Tsujikawa
  6. *
  7. * This program is free software; you can redistribute it and/or modify
  8. * it under the terms of the GNU General Public License as published by
  9. * the Free Software Foundation; either version 2 of the License, or
  10. * (at your option) any later version.
  11. *
  12. * This program is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU General Public License
  18. * along with this program; if not, write to the Free Software
  19. * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  20. *
  21. * In addition, as a special exception, the copyright holders give
  22. * permission to link the code of portions of this program with the
  23. * OpenSSL library under certain conditions as described in each
  24. * individual source file, and distribute linked combinations
  25. * including the two.
  26. * You must obey the GNU General Public License in all respects
  27. * for all of the code used other than OpenSSL. If you modify
  28. * file(s) with this exception, you may extend this exception to your
  29. * version of the file(s), but you are not obligated to do so. If you
  30. * do not wish to do so, delete this exception statement from your
  31. * version. If you delete this exception statement from all source
  32. * files in the program, then also delete it here.
  33. */
  34. /* copyright --> */
  35. #include "RequestGroupMan.h"
  36. #include <unistd.h>
  37. #include <cstring>
  38. #include <iomanip>
  39. #include <sstream>
  40. #include <numeric>
  41. #include <algorithm>
  42. #include <utility>
  43. #include "BtProgressInfoFile.h"
  44. #include "RecoverableException.h"
  45. #include "RequestGroup.h"
  46. #include "LogFactory.h"
  47. #include "Logger.h"
  48. #include "DownloadEngine.h"
  49. #include "message.h"
  50. #include "a2functional.h"
  51. #include "DownloadResult.h"
  52. #include "DownloadContext.h"
  53. #include "ServerStatMan.h"
  54. #include "ServerStat.h"
  55. #include "PeerStat.h"
  56. #include "SegmentMan.h"
  57. #include "FeedbackURISelector.h"
  58. #include "InorderURISelector.h"
  59. #include "AdaptiveURISelector.h"
  60. #include "Option.h"
  61. #include "prefs.h"
  62. #include "File.h"
  63. #include "util.h"
  64. #include "Command.h"
  65. #include "FileEntry.h"
  66. #include "fmt.h"
  67. #include "FileAllocationEntry.h"
  68. #include "CheckIntegrityEntry.h"
  69. #include "Segment.h"
  70. #include "DlAbortEx.h"
  71. #include "uri.h"
  72. #include "Triplet.h"
  73. #include "Signature.h"
  74. #include "OutputFile.h"
  75. #include "download_helper.h"
  76. #include "UriListParser.h"
  77. #include "SingletonHolder.h"
  78. #include "Notifier.h"
  79. #ifdef ENABLE_BITTORRENT
  80. # include "bittorrent_helper.h"
  81. #endif // ENABLE_BITTORRENT
  82. namespace aria2 {
  83. RequestGroupMan::RequestGroupMan
  84. (const std::vector<SharedHandle<RequestGroup> >& requestGroups,
  85. int maxSimultaneousDownloads,
  86. const Option* option)
  87. : reservedGroups_(requestGroups.begin(), requestGroups.end()),
  88. maxSimultaneousDownloads_(maxSimultaneousDownloads),
  89. option_(option),
  90. serverStatMan_(new ServerStatMan()),
  91. maxOverallDownloadSpeedLimit_
  92. (option->getAsInt(PREF_MAX_OVERALL_DOWNLOAD_LIMIT)),
  93. maxOverallUploadSpeedLimit_(option->getAsInt
  94. (PREF_MAX_OVERALL_UPLOAD_LIMIT)),
  95. rpc_(option->getAsBool(PREF_ENABLE_RPC)),
  96. queueCheck_(true),
  97. removedErrorResult_(0),
  98. removedLastErrorResult_(error_code::FINISHED),
  99. maxDownloadResult_(option->getAsInt(PREF_MAX_DOWNLOAD_RESULT))
  100. {
  101. addRequestGroupIndex(requestGroups);
  102. }
  103. RequestGroupMan::~RequestGroupMan() {}
  104. bool RequestGroupMan::downloadFinished()
  105. {
  106. if(rpc_) {
  107. return false;
  108. }
  109. return requestGroups_.empty() && reservedGroups_.empty();
  110. }
  111. void RequestGroupMan::addRequestGroup
  112. (const SharedHandle<RequestGroup>& group)
  113. {
  114. requestGroups_.push_back(group);
  115. }
  116. void RequestGroupMan::addReservedGroup
  117. (const std::vector<SharedHandle<RequestGroup> >& groups)
  118. {
  119. requestQueueCheck();
  120. addRequestGroupIndex(groups);
  121. reservedGroups_.insert(reservedGroups_.end(), groups.begin(), groups.end());
  122. }
  123. void RequestGroupMan::addReservedGroup
  124. (const SharedHandle<RequestGroup>& group)
  125. {
  126. requestQueueCheck();
  127. addRequestGroupIndex(group);
  128. reservedGroups_.push_back(group);
  129. }
  130. void RequestGroupMan::insertReservedGroup
  131. (size_t pos, const std::vector<SharedHandle<RequestGroup> >& groups)
  132. {
  133. requestQueueCheck();
  134. addRequestGroupIndex(groups);
  135. reservedGroups_.insert
  136. (reservedGroups_.begin()+std::min(reservedGroups_.size(), pos),
  137. groups.begin(), groups.end());
  138. }
  139. void RequestGroupMan::insertReservedGroup
  140. (size_t pos, const SharedHandle<RequestGroup>& group)
  141. {
  142. requestQueueCheck();
  143. addRequestGroupIndex(group);
  144. reservedGroups_.insert
  145. (reservedGroups_.begin()+std::min(reservedGroups_.size(), pos), group);
  146. }
  147. void RequestGroupMan::addRequestGroupIndex
  148. (const SharedHandle<RequestGroup>& group)
  149. {
  150. assert(groupIndex_.count(group->getGID()) == 0);
  151. groupIndex_[group->getGID()] = group;
  152. }
  153. void RequestGroupMan::addRequestGroupIndex
  154. (const std::vector<SharedHandle<RequestGroup> >& groups)
  155. {
  156. for(std::vector<SharedHandle<RequestGroup> >::const_iterator i =
  157. groups.begin(); i != groups.end(); ++i) {
  158. addRequestGroupIndex(*i);
  159. }
  160. }
  161. namespace {
  162. void removeRequestGroupIndex
  163. (std::map<a2_gid_t, SharedHandle<RequestGroup> >& groupIndex,
  164. const SharedHandle<RequestGroup>& group)
  165. {
  166. assert(groupIndex.count(group->getGID()) == 1);
  167. groupIndex.erase(group->getGID());
  168. }
  169. } // namespace
  170. size_t RequestGroupMan::countRequestGroup() const
  171. {
  172. return requestGroups_.size();
  173. }
  174. SharedHandle<RequestGroup> RequestGroupMan::getRequestGroup(size_t index) const
  175. {
  176. if(index < requestGroups_.size()) {
  177. return requestGroups_[index];
  178. } else {
  179. return SharedHandle<RequestGroup>();
  180. }
  181. }
  182. namespace {
  183. template<typename Iterator>
  184. Iterator findByGID(Iterator first, Iterator last, a2_gid_t gid)
  185. {
  186. for(; first != last; ++first) {
  187. if((*first)->getGID() == gid) {
  188. return first;
  189. }
  190. }
  191. return first;
  192. }
  193. } // namespace
  194. SharedHandle<RequestGroup>
  195. RequestGroupMan::findRequestGroup(a2_gid_t gid) const
  196. {
  197. SharedHandle<RequestGroup> res = findGroup(gid);
  198. if(res) {
  199. if(res->getState() == RequestGroup::STATE_ACTIVE) {
  200. return res;
  201. } else {
  202. return SharedHandle<RequestGroup>();
  203. }
  204. } else {
  205. return res;
  206. }
  207. }
  208. SharedHandle<RequestGroup>
  209. RequestGroupMan::findReservedGroup(a2_gid_t gid) const
  210. {
  211. SharedHandle<RequestGroup> res = findGroup(gid);
  212. if(res) {
  213. if(res->getState() == RequestGroup::STATE_WAITING) {
  214. return res;
  215. } else {
  216. return SharedHandle<RequestGroup>();
  217. }
  218. } else {
  219. return res;
  220. }
  221. }
  222. SharedHandle<RequestGroup> RequestGroupMan::findGroup(a2_gid_t gid) const
  223. {
  224. std::map<a2_gid_t, SharedHandle<RequestGroup> >::const_iterator i =
  225. groupIndex_.find(gid);
  226. if(i != groupIndex_.end()) {
  227. return (*i).second;
  228. } else {
  229. return SharedHandle<RequestGroup>();
  230. }
  231. }
  232. size_t RequestGroupMan::changeReservedGroupPosition
  233. (a2_gid_t gid, int pos, HOW how)
  234. {
  235. std::deque<SharedHandle<RequestGroup> >::iterator i =
  236. findByGID(reservedGroups_.begin(), reservedGroups_.end(), gid);
  237. if(i == reservedGroups_.end()) {
  238. throw DL_ABORT_EX(fmt("GID#%" PRId64 " not found in the waiting queue.", gid));
  239. }
  240. SharedHandle<RequestGroup> rg = *i;
  241. const size_t maxPos = reservedGroups_.size()-1;
  242. if(how == POS_SET) {
  243. if(pos < 0) {
  244. pos = 0;
  245. } else if(pos > 0) {
  246. pos = std::min(maxPos, (size_t)pos);
  247. }
  248. } else if(how == POS_CUR) {
  249. size_t abspos = std::distance(reservedGroups_.begin(), i);
  250. if(pos < 0) {
  251. int dist = -std::distance(reservedGroups_.begin(), i);
  252. pos = abspos+std::max(pos, dist);
  253. } else if(pos > 0) {
  254. int dist = std::distance(i, reservedGroups_.end())-1;
  255. pos = abspos+std::min(pos, dist);
  256. } else {
  257. pos = abspos;
  258. }
  259. } else if(how == POS_END) {
  260. if(pos >= 0) {
  261. pos = maxPos;
  262. } else {
  263. pos = maxPos-std::min(maxPos, (size_t)-pos);
  264. }
  265. }
  266. if(std::distance(reservedGroups_.begin(), i) < pos) {
  267. std::rotate(i, i+1, reservedGroups_.begin()+pos+1);
  268. } else {
  269. std::rotate(reservedGroups_.begin()+pos, i, i+1);
  270. }
  271. return pos;
  272. }
  273. bool RequestGroupMan::removeReservedGroup(a2_gid_t gid)
  274. {
  275. std::deque<SharedHandle<RequestGroup> >::iterator i =
  276. findByGID(reservedGroups_.begin(), reservedGroups_.end(), gid);
  277. if(i == reservedGroups_.end()) {
  278. return false;
  279. } else {
  280. removeRequestGroupIndex(groupIndex_, *i);
  281. reservedGroups_.erase(i);
  282. return true;
  283. }
  284. }
  285. namespace {
  286. void notifyDownloadEvent
  287. (const std::string& event, const SharedHandle<RequestGroup>& group)
  288. {
  289. SingletonHolder<Notifier>::instance()->notifyDownloadEvent(event, group);
  290. }
  291. } // namespace
  292. namespace {
  293. void executeStopHook
  294. (const SharedHandle<RequestGroup>& group,
  295. const Option* option,
  296. error_code::Value result)
  297. {
  298. if(result == error_code::FINISHED &&
  299. !option->blank(PREF_ON_DOWNLOAD_COMPLETE)) {
  300. util::executeHookByOptName(group, option, PREF_ON_DOWNLOAD_COMPLETE);
  301. } else if(result != error_code::IN_PROGRESS &&
  302. result != error_code::REMOVED &&
  303. !option->blank(PREF_ON_DOWNLOAD_ERROR)) {
  304. util::executeHookByOptName(group, option, PREF_ON_DOWNLOAD_ERROR);
  305. } else if(!option->blank(PREF_ON_DOWNLOAD_STOP)) {
  306. util::executeHookByOptName(group, option, PREF_ON_DOWNLOAD_STOP);
  307. }
  308. if(result == error_code::FINISHED) {
  309. notifyDownloadEvent(Notifier::ON_DOWNLOAD_COMPLETE, group);
  310. } else if(result != error_code::IN_PROGRESS &&
  311. result != error_code::REMOVED) {
  312. notifyDownloadEvent(Notifier::ON_DOWNLOAD_ERROR, group);
  313. } else {
  314. notifyDownloadEvent(Notifier::ON_DOWNLOAD_STOP, group);
  315. }
  316. }
  317. } // namespace
  318. namespace {
  319. class ProcessStoppedRequestGroup {
  320. private:
  321. DownloadEngine* e_;
  322. std::deque<SharedHandle<DownloadResult> >& downloadResults_;
  323. std::deque<SharedHandle<RequestGroup> >& reservedGroups_;
  324. std::map<a2_gid_t, SharedHandle<RequestGroup> >& groupIndex_;
  325. void saveSignature(const SharedHandle<RequestGroup>& group)
  326. {
  327. SharedHandle<Signature> sig =
  328. group->getDownloadContext()->getSignature();
  329. if(sig && !sig->getBody().empty()) {
  330. // filename of signature file is the path to download file followed by
  331. // ".sig".
  332. std::string signatureFile = group->getFirstFilePath()+".sig";
  333. if(sig->save(signatureFile)) {
  334. A2_LOG_NOTICE(fmt(MSG_SIGNATURE_SAVED, signatureFile.c_str()));
  335. } else {
  336. A2_LOG_NOTICE(fmt(MSG_SIGNATURE_NOT_SAVED, signatureFile.c_str()));
  337. }
  338. }
  339. }
  340. public:
  341. ProcessStoppedRequestGroup
  342. (DownloadEngine* e,
  343. std::deque<SharedHandle<DownloadResult> >& downloadResults,
  344. std::deque<SharedHandle<RequestGroup> >& reservedGroups,
  345. std::map<a2_gid_t, SharedHandle<RequestGroup> >& groupIndex)
  346. : e_(e),
  347. downloadResults_(downloadResults),
  348. reservedGroups_(reservedGroups),
  349. groupIndex_(groupIndex)
  350. {}
  351. void operator()(const SharedHandle<RequestGroup>& group)
  352. {
  353. if(group->getNumCommand() == 0) {
  354. const SharedHandle<DownloadContext>& dctx = group->getDownloadContext();
  355. // DownloadContext::resetDownloadStopTime() is only called when
  356. // download completed. If
  357. // DownloadContext::getDownloadStopTime().isZero() is true, then
  358. // there is a possibility that the download is error or
  359. // in-progress and resetDownloadStopTime() is not called. So
  360. // call it here.
  361. if(dctx->getDownloadStopTime().isZero()) {
  362. dctx->resetDownloadStopTime();
  363. }
  364. try {
  365. group->closeFile();
  366. if(group->isPauseRequested()) {
  367. A2_LOG_NOTICE
  368. (fmt(_("Download GID#%" PRId64 " paused"), group->getGID()));
  369. group->saveControlFile();
  370. } else if(group->downloadFinished() &&
  371. !group->getDownloadContext()->isChecksumVerificationNeeded()) {
  372. group->applyLastModifiedTimeToLocalFiles();
  373. group->reportDownloadFinished();
  374. if(group->allDownloadFinished()) {
  375. group->removeControlFile();
  376. saveSignature(group);
  377. } else {
  378. group->saveControlFile();
  379. }
  380. std::vector<SharedHandle<RequestGroup> > nextGroups;
  381. group->postDownloadProcessing(nextGroups);
  382. if(!nextGroups.empty()) {
  383. A2_LOG_DEBUG
  384. (fmt("Adding %lu RequestGroups as a result of"
  385. " PostDownloadHandler.",
  386. static_cast<unsigned long>(nextGroups.size())));
  387. e_->getRequestGroupMan()->insertReservedGroup(0, nextGroups);
  388. }
  389. #ifdef ENABLE_BITTORRENT
  390. // For in-memory download (e.g., Magnet URI), the
  391. // FileEntry::getPath() does not return actual file path, so
  392. // we don't remove it.
  393. if(group->getOption()->getAsBool(PREF_BT_REMOVE_UNSELECTED_FILE) &&
  394. !group->inMemoryDownload() &&
  395. dctx->hasAttribute(CTX_ATTR_BT)) {
  396. A2_LOG_INFO(fmt(MSG_REMOVING_UNSELECTED_FILE, group->getGID()));
  397. const std::vector<SharedHandle<FileEntry> >& files =
  398. dctx->getFileEntries();
  399. for(std::vector<SharedHandle<FileEntry> >::const_iterator i =
  400. files.begin(), eoi = files.end(); i != eoi; ++i) {
  401. if(!(*i)->isRequested()) {
  402. if(File((*i)->getPath()).remove()) {
  403. A2_LOG_INFO(fmt(MSG_FILE_REMOVED, (*i)->getPath().c_str()));
  404. } else {
  405. A2_LOG_INFO(fmt(MSG_FILE_COULD_NOT_REMOVED,
  406. (*i)->getPath().c_str()));
  407. }
  408. }
  409. }
  410. }
  411. #endif // ENABLE_BITTORRENT
  412. } else {
  413. A2_LOG_NOTICE
  414. (fmt(_("Download GID#%" PRId64 " not complete: %s"),
  415. group->getGID(),
  416. group->getDownloadContext()->getBasePath().c_str()));
  417. group->saveControlFile();
  418. }
  419. } catch(RecoverableException& ex) {
  420. A2_LOG_ERROR_EX(EX_EXCEPTION_CAUGHT, ex);
  421. }
  422. if(group->isPauseRequested()) {
  423. group->setState(RequestGroup::STATE_WAITING);
  424. reservedGroups_.push_front(group);
  425. group->releaseRuntimeResource(e_);
  426. group->setForceHaltRequested(false);
  427. util::executeHookByOptName(group, e_->getOption(),
  428. PREF_ON_DOWNLOAD_PAUSE);
  429. notifyDownloadEvent(Notifier::ON_DOWNLOAD_PAUSE, group);
  430. // TODO Should we have to prepend spend uris to remaining uris
  431. // in case PREF_REUSE_URI is disabed?
  432. } else {
  433. SharedHandle<DownloadResult> dr = group->createDownloadResult();
  434. e_->getRequestGroupMan()->addDownloadResult(dr);
  435. executeStopHook(group, e_->getOption(), dr->result);
  436. group->releaseRuntimeResource(e_);
  437. removeRequestGroupIndex(groupIndex_, group);
  438. }
  439. }
  440. }
  441. };
  442. } // namespace
  443. namespace {
  444. class CollectServerStat {
  445. private:
  446. RequestGroupMan* requestGroupMan_;
  447. public:
  448. CollectServerStat(RequestGroupMan* requestGroupMan):
  449. requestGroupMan_(requestGroupMan) {}
  450. void operator()(const SharedHandle<RequestGroup>& group)
  451. {
  452. if(group->getNumCommand() == 0) {
  453. // Collect statistics during download in PeerStats and update/register
  454. // ServerStatMan
  455. if(group->getSegmentMan()) {
  456. bool singleConnection =
  457. group->getSegmentMan()->getPeerStats().size() == 1;
  458. const std::vector<SharedHandle<PeerStat> >& peerStats =
  459. group->getSegmentMan()->getFastestPeerStats();
  460. for(std::vector<SharedHandle<PeerStat> >::const_iterator i =
  461. peerStats.begin(), eoi = peerStats.end(); i != eoi; ++i) {
  462. if((*i)->getHostname().empty() || (*i)->getProtocol().empty()) {
  463. continue;
  464. }
  465. int speed = (*i)->getAvgDownloadSpeed();
  466. if (speed == 0) continue;
  467. SharedHandle<ServerStat> ss =
  468. requestGroupMan_->getOrCreateServerStat((*i)->getHostname(),
  469. (*i)->getProtocol());
  470. ss->increaseCounter();
  471. ss->updateDownloadSpeed(speed);
  472. if(singleConnection) {
  473. ss->updateSingleConnectionAvgSpeed(speed);
  474. }
  475. else {
  476. ss->updateMultiConnectionAvgSpeed(speed);
  477. }
  478. }
  479. }
  480. }
  481. }
  482. };
  483. } // namespace
  484. namespace {
  485. class FindStoppedRequestGroup {
  486. public:
  487. bool operator()(const SharedHandle<RequestGroup>& group) {
  488. return group->getNumCommand() == 0;
  489. }
  490. };
  491. } // namespace
  492. void RequestGroupMan::updateServerStat()
  493. {
  494. std::for_each(requestGroups_.begin(), requestGroups_.end(),
  495. CollectServerStat(this));
  496. }
  497. void RequestGroupMan::removeStoppedGroup(DownloadEngine* e)
  498. {
  499. size_t numPrev = requestGroups_.size();
  500. updateServerStat();
  501. std::for_each(requestGroups_.begin(), requestGroups_.end(),
  502. ProcessStoppedRequestGroup
  503. (e, downloadResults_, reservedGroups_, groupIndex_));
  504. std::deque<SharedHandle<RequestGroup> >::iterator i =
  505. std::remove_if(requestGroups_.begin(),
  506. requestGroups_.end(),
  507. FindStoppedRequestGroup());
  508. if(i != requestGroups_.end()) {
  509. requestGroups_.erase(i, requestGroups_.end());
  510. }
  511. size_t numRemoved = numPrev-requestGroups_.size();
  512. if(numRemoved > 0) {
  513. A2_LOG_DEBUG(fmt("%lu RequestGroup(s) deleted.",
  514. static_cast<unsigned long>(numRemoved)));
  515. }
  516. }
  517. void RequestGroupMan::configureRequestGroup
  518. (const SharedHandle<RequestGroup>& requestGroup) const
  519. {
  520. const std::string& uriSelectorValue =
  521. requestGroup->getOption()->get(PREF_URI_SELECTOR);
  522. SharedHandle<URISelector> sel;
  523. if(uriSelectorValue == V_FEEDBACK) {
  524. sel.reset(new FeedbackURISelector(serverStatMan_));
  525. } else if(uriSelectorValue == V_INORDER) {
  526. sel.reset(new InorderURISelector());
  527. } else if(uriSelectorValue == V_ADAPTIVE) {
  528. sel.reset(new AdaptiveURISelector(serverStatMan_, requestGroup.get()));
  529. }
  530. if(sel) {
  531. requestGroup->setURISelector(sel);
  532. }
  533. }
  534. namespace {
  535. void createInitialCommand(const SharedHandle<RequestGroup>& requestGroup,
  536. std::vector<Command*>& commands,
  537. DownloadEngine* e)
  538. {
  539. requestGroup->createInitialCommand(commands, e);
  540. }
  541. } // namespace
  542. void RequestGroupMan::fillRequestGroupFromReserver(DownloadEngine* e)
  543. {
  544. removeStoppedGroup(e);
  545. if(static_cast<size_t>(maxSimultaneousDownloads_) <= requestGroups_.size()) {
  546. return;
  547. }
  548. std::vector<SharedHandle<RequestGroup> > temp;
  549. int count = 0;
  550. int num = maxSimultaneousDownloads_-requestGroups_.size();
  551. while(count < num && (uriListParser_ || !reservedGroups_.empty())) {
  552. if(uriListParser_ && reservedGroups_.empty()) {
  553. std::vector<SharedHandle<RequestGroup> > groups;
  554. bool ok = createRequestGroupFromUriListParser(groups, option_,
  555. uriListParser_.get());
  556. if(ok) {
  557. addRequestGroupIndex(groups);
  558. reservedGroups_.insert(reservedGroups_.end(), groups.begin(),
  559. groups.end());
  560. } else {
  561. uriListParser_.reset();
  562. if(reservedGroups_.empty()) {
  563. break;
  564. }
  565. }
  566. }
  567. SharedHandle<RequestGroup> groupToAdd = reservedGroups_.front();
  568. reservedGroups_.pop_front();
  569. std::vector<Command*> commands;
  570. try {
  571. if((rpc_ && groupToAdd->isPauseRequested()) ||
  572. !groupToAdd->isDependencyResolved()) {
  573. temp.push_back(groupToAdd);
  574. continue;
  575. }
  576. // Drop pieceStorage here because paused download holds its
  577. // reference.
  578. groupToAdd->dropPieceStorage();
  579. configureRequestGroup(groupToAdd);
  580. createInitialCommand(groupToAdd, commands, e);
  581. groupToAdd->setRequestGroupMan(this);
  582. if(commands.empty()) {
  583. requestQueueCheck();
  584. }
  585. groupToAdd->setState(RequestGroup::STATE_ACTIVE);
  586. requestGroups_.push_back(groupToAdd);
  587. ++count;
  588. e->addCommand(commands);
  589. commands.clear();
  590. } catch(RecoverableException& ex) {
  591. A2_LOG_ERROR_EX(EX_EXCEPTION_CAUGHT, ex);
  592. A2_LOG_DEBUG("Deleting temporal commands.");
  593. std::for_each(commands.begin(), commands.end(), Deleter());
  594. commands.clear();
  595. A2_LOG_DEBUG("Commands deleted");
  596. groupToAdd->setLastErrorCode(ex.getErrorCode());
  597. // We add groupToAdd to e in order to it is processed in
  598. // removeStoppedGroup().
  599. groupToAdd->setState(RequestGroup::STATE_ACTIVE);
  600. requestGroups_.push_back(groupToAdd);
  601. requestQueueCheck();
  602. }
  603. util::executeHookByOptName(groupToAdd, e->getOption(),
  604. PREF_ON_DOWNLOAD_START);
  605. notifyDownloadEvent(Notifier::ON_DOWNLOAD_START, groupToAdd);
  606. }
  607. if(!temp.empty()) {
  608. reservedGroups_.insert(reservedGroups_.begin(), temp.begin(), temp.end());
  609. }
  610. if(count > 0) {
  611. e->setNoWait(true);
  612. e->setRefreshInterval(0);
  613. A2_LOG_DEBUG(fmt("%d RequestGroup(s) added.", count));
  614. }
  615. }
  616. void RequestGroupMan::save()
  617. {
  618. for(std::deque<SharedHandle<RequestGroup> >::const_iterator itr =
  619. requestGroups_.begin(), eoi = requestGroups_.end(); itr != eoi; ++itr) {
  620. if((*itr)->allDownloadFinished() &&
  621. !(*itr)->getDownloadContext()->isChecksumVerificationNeeded()) {
  622. (*itr)->removeControlFile();
  623. } else {
  624. try {
  625. (*itr)->saveControlFile();
  626. } catch(RecoverableException& e) {
  627. A2_LOG_ERROR_EX(EX_EXCEPTION_CAUGHT, e);
  628. }
  629. }
  630. }
  631. }
  632. void RequestGroupMan::closeFile()
  633. {
  634. for(std::deque<SharedHandle<RequestGroup> >::const_iterator itr =
  635. requestGroups_.begin(), eoi = requestGroups_.end(); itr != eoi; ++itr) {
  636. (*itr)->closeFile();
  637. }
  638. }
  639. RequestGroupMan::DownloadStat RequestGroupMan::getDownloadStat() const
  640. {
  641. int finished = 0;
  642. int error = removedErrorResult_;
  643. int inprogress = 0;
  644. int removed = 0;
  645. error_code::Value lastError = removedLastErrorResult_;
  646. for(std::deque<SharedHandle<DownloadResult> >::const_iterator itr =
  647. downloadResults_.begin(), eoi = downloadResults_.end();
  648. itr != eoi; ++itr) {
  649. if((*itr)->belongsTo != 0) {
  650. continue;
  651. }
  652. if((*itr)->result == error_code::FINISHED) {
  653. ++finished;
  654. } else if((*itr)->result == error_code::IN_PROGRESS) {
  655. ++inprogress;
  656. } else if((*itr)->result == error_code::REMOVED) {
  657. ++removed;
  658. } else {
  659. ++error;
  660. lastError = (*itr)->result;
  661. }
  662. }
  663. return DownloadStat(finished, error, inprogress, removed,
  664. reservedGroups_.size(),
  665. lastError);
  666. }
  667. void RequestGroupMan::showDownloadResults(OutputFile& o, bool full) const
  668. {
  669. #ifdef __MINGW32__
  670. int pathRowSize = 58;
  671. #else // !__MINGW32__
  672. int pathRowSize = 59;
  673. #endif // !__MINGW32__
  674. // Download Results:
  675. // idx|stat|path/length
  676. // ===+====+=======================================================================
  677. o.printf("\n%s"
  678. "\ngid|stat|avg speed |",
  679. _("Download Results:"));
  680. if(full) {
  681. o.write(" %|path/URI"
  682. "\n===+====+===========+===+");
  683. pathRowSize -= 4;
  684. } else {
  685. o.write("path/URI"
  686. "\n===+====+===========+");
  687. }
  688. std::string line(pathRowSize, '=');
  689. o.printf("%s\n", line.c_str());
  690. int ok = 0;
  691. int err = 0;
  692. int inpr = 0;
  693. int rm = 0;
  694. for(std::deque<SharedHandle<DownloadResult> >::const_iterator itr =
  695. downloadResults_.begin(), eoi = downloadResults_.end();
  696. itr != eoi; ++itr) {
  697. if((*itr)->belongsTo != 0) {
  698. continue;
  699. }
  700. const char* status;
  701. if((*itr)->result == error_code::FINISHED) {
  702. status = "OK";
  703. ++ok;
  704. } else if((*itr)->result == error_code::IN_PROGRESS) {
  705. status = "INPR";
  706. ++inpr;
  707. } else if((*itr)->result == error_code::REMOVED) {
  708. status = "RM";
  709. ++rm;
  710. } else {
  711. status = "ERR";
  712. ++err;
  713. }
  714. if(full) {
  715. formatDownloadResultFull(o, status, *itr);
  716. } else {
  717. o.write(formatDownloadResult(status, *itr).c_str());
  718. o.write("\n");
  719. }
  720. }
  721. if(ok > 0 || err > 0 || inpr > 0 || rm > 0) {
  722. o.printf("\n%s\n", _("Status Legend:"));
  723. if(ok > 0) {
  724. o.write(_("(OK):download completed."));
  725. }
  726. if(err > 0) {
  727. o.write(_("(ERR):error occurred."));
  728. }
  729. if(inpr > 0) {
  730. o.write(_("(INPR):download in-progress."));
  731. }
  732. if(rm > 0) {
  733. o.write(_("(RM):download removed."));
  734. }
  735. o.write("\n");
  736. }
  737. }
  738. namespace {
  739. void formatDownloadResultCommon
  740. (std::ostream& o,
  741. const char* status,
  742. const SharedHandle<DownloadResult>& downloadResult)
  743. {
  744. o << std::setw(3) << downloadResult->gid << "|"
  745. << std::setw(4) << status << "|"
  746. << std::setw(11);
  747. if(downloadResult->sessionTime > 0) {
  748. o << util::abbrevSize
  749. (downloadResult->sessionDownloadLength*1000/downloadResult->sessionTime)+
  750. "B/s";
  751. } else {
  752. o << "n/a";
  753. }
  754. o << "|";
  755. }
  756. } // namespace
  757. void RequestGroupMan::formatDownloadResultFull
  758. (OutputFile& out,
  759. const char* status,
  760. const SharedHandle<DownloadResult>& downloadResult) const
  761. {
  762. BitfieldMan bt(downloadResult->pieceLength, downloadResult->totalLength);
  763. bt.setBitfield(reinterpret_cast<const unsigned char*>
  764. (downloadResult->bitfield.data()),
  765. downloadResult->bitfield.size());
  766. bool head = true;
  767. const std::vector<SharedHandle<FileEntry> >& fileEntries =
  768. downloadResult->fileEntries;
  769. for(std::vector<SharedHandle<FileEntry> >::const_iterator i =
  770. fileEntries.begin(), eoi = fileEntries.end(); i != eoi; ++i) {
  771. if(!(*i)->isRequested()) {
  772. continue;
  773. }
  774. std::stringstream o;
  775. if(head) {
  776. formatDownloadResultCommon(o, status, downloadResult);
  777. head = false;
  778. } else {
  779. o << " | | |";
  780. }
  781. if((*i)->getLength() == 0 || downloadResult->bitfield.empty()) {
  782. o << " -|";
  783. } else {
  784. int64_t completedLength =
  785. bt.getOffsetCompletedLength((*i)->getOffset(), (*i)->getLength());
  786. o << std::setw(3) << 100*completedLength/(*i)->getLength() << "|";
  787. }
  788. writeFilePath(o, *i, downloadResult->inMemoryDownload);
  789. o << "\n";
  790. out.write(o.str().c_str());
  791. }
  792. if(head) {
  793. std::stringstream o;
  794. formatDownloadResultCommon(o, status, downloadResult);
  795. o << " -|n/a\n";
  796. out.write(o.str().c_str());
  797. }
  798. }
  799. std::string RequestGroupMan::formatDownloadResult
  800. (const char* status,
  801. const SharedHandle<DownloadResult>& downloadResult) const
  802. {
  803. std::stringstream o;
  804. formatDownloadResultCommon(o, status, downloadResult);
  805. const std::vector<SharedHandle<FileEntry> >& fileEntries =
  806. downloadResult->fileEntries;
  807. writeFilePath(fileEntries.begin(), fileEntries.end(), o,
  808. downloadResult->inMemoryDownload);
  809. return o.str();
  810. }
  811. namespace {
  812. template<typename StringInputIterator, typename FileEntryInputIterator>
  813. bool sameFilePathExists(StringInputIterator sfirst,
  814. StringInputIterator slast,
  815. FileEntryInputIterator ffirst,
  816. FileEntryInputIterator flast)
  817. {
  818. for(; ffirst != flast; ++ffirst) {
  819. if(std::binary_search(sfirst, slast, (*ffirst)->getPath())) {
  820. return true;
  821. }
  822. }
  823. return false;
  824. }
  825. } // namespace
  826. bool RequestGroupMan::isSameFileBeingDownloaded(RequestGroup* requestGroup) const
  827. {
  828. // TODO it may be good to use dedicated method rather than use
  829. // isPreLocalFileCheckEnabled
  830. if(!requestGroup->isPreLocalFileCheckEnabled()) {
  831. return false;
  832. }
  833. std::vector<std::string> files;
  834. for(std::deque<SharedHandle<RequestGroup> >::const_iterator itr =
  835. requestGroups_.begin(), eoi = requestGroups_.end(); itr != eoi; ++itr) {
  836. if((*itr).get() != requestGroup) {
  837. const std::vector<SharedHandle<FileEntry> >& entries =
  838. (*itr)->getDownloadContext()->getFileEntries();
  839. std::transform(entries.begin(), entries.end(),
  840. std::back_inserter(files),
  841. mem_fun_sh(&FileEntry::getPath));
  842. }
  843. }
  844. std::sort(files.begin(), files.end());
  845. const std::vector<SharedHandle<FileEntry> >& entries =
  846. requestGroup->getDownloadContext()->getFileEntries();
  847. return sameFilePathExists(files.begin(), files.end(),
  848. entries.begin(), entries.end());
  849. }
  850. void RequestGroupMan::halt()
  851. {
  852. for(std::deque<SharedHandle<RequestGroup> >::const_iterator i =
  853. requestGroups_.begin(), eoi = requestGroups_.end(); i != eoi; ++i) {
  854. (*i)->setHaltRequested(true);
  855. }
  856. }
  857. void RequestGroupMan::forceHalt()
  858. {
  859. for(std::deque<SharedHandle<RequestGroup> >::const_iterator i =
  860. requestGroups_.begin(), eoi = requestGroups_.end(); i != eoi; ++i) {
  861. (*i)->setForceHaltRequested(true);
  862. }
  863. }
  864. TransferStat RequestGroupMan::calculateStat()
  865. {
  866. TransferStat s;
  867. for(std::deque<SharedHandle<RequestGroup> >::const_iterator i =
  868. requestGroups_.begin(), eoi = requestGroups_.end(); i != eoi; ++i) {
  869. s += (*i)->calculateStat();
  870. }
  871. return s;
  872. }
  873. SharedHandle<DownloadResult>
  874. RequestGroupMan::findDownloadResult(a2_gid_t gid) const
  875. {
  876. for(std::deque<SharedHandle<DownloadResult> >::const_iterator i =
  877. downloadResults_.begin(), eoi = downloadResults_.end(); i != eoi; ++i) {
  878. if((*i)->gid == gid) {
  879. return *i;
  880. }
  881. }
  882. return SharedHandle<DownloadResult>();
  883. }
  884. bool RequestGroupMan::removeDownloadResult(a2_gid_t gid)
  885. {
  886. for(std::deque<SharedHandle<DownloadResult> >::iterator i =
  887. downloadResults_.begin(), eoi = downloadResults_.end(); i != eoi; ++i) {
  888. if((*i)->gid == gid) {
  889. downloadResults_.erase(i);
  890. return true;
  891. }
  892. }
  893. return false;
  894. }
  895. void RequestGroupMan::addDownloadResult(const SharedHandle<DownloadResult>& dr)
  896. {
  897. if(maxDownloadResult_ == 0) {
  898. if(!downloadResults_.empty()) {
  899. for(std::deque<SharedHandle<DownloadResult> >::iterator i =
  900. downloadResults_.begin(), eoi = downloadResults_.end(); i != eoi;
  901. ++i) {
  902. if((*i)->belongsTo == 0 && (*i)->result != error_code::FINISHED) {
  903. removedLastErrorResult_ = (*i)->result;
  904. ++removedErrorResult_;
  905. }
  906. }
  907. downloadResults_.clear();
  908. }
  909. if(dr->belongsTo == 0 && dr->result != error_code::FINISHED) {
  910. removedLastErrorResult_ = dr->result;
  911. ++removedErrorResult_;
  912. }
  913. } else {
  914. int curSize = downloadResults_.size();
  915. if(curSize >= maxDownloadResult_) {
  916. std::deque<SharedHandle<DownloadResult> >::iterator last =
  917. downloadResults_.begin()+curSize-maxDownloadResult_+1;
  918. for(std::deque<SharedHandle<DownloadResult> >::iterator i =
  919. downloadResults_.begin(); i != last; ++i) {
  920. if((*i)->belongsTo == 0 && (*i)->result != error_code::FINISHED) {
  921. removedLastErrorResult_ = (*i)->result;
  922. ++removedErrorResult_;
  923. }
  924. }
  925. downloadResults_.erase(downloadResults_.begin(), last);
  926. }
  927. downloadResults_.push_back(dr);
  928. }
  929. }
  930. void RequestGroupMan::purgeDownloadResult()
  931. {
  932. downloadResults_.clear();
  933. }
  934. SharedHandle<ServerStat>
  935. RequestGroupMan::findServerStat(const std::string& hostname,
  936. const std::string& protocol) const
  937. {
  938. return serverStatMan_->find(hostname, protocol);
  939. }
  940. SharedHandle<ServerStat>
  941. RequestGroupMan::getOrCreateServerStat(const std::string& hostname,
  942. const std::string& protocol)
  943. {
  944. SharedHandle<ServerStat> ss = findServerStat(hostname, protocol);
  945. if(!ss) {
  946. ss.reset(new ServerStat(hostname, protocol));
  947. addServerStat(ss);
  948. }
  949. return ss;
  950. }
  951. bool RequestGroupMan::addServerStat(const SharedHandle<ServerStat>& serverStat)
  952. {
  953. return serverStatMan_->add(serverStat);
  954. }
  955. bool RequestGroupMan::loadServerStat(const std::string& filename)
  956. {
  957. return serverStatMan_->load(filename);
  958. }
  959. bool RequestGroupMan::saveServerStat(const std::string& filename) const
  960. {
  961. return serverStatMan_->save(filename);
  962. }
  963. void RequestGroupMan::removeStaleServerStat(time_t timeout)
  964. {
  965. serverStatMan_->removeStaleServerStat(timeout);
  966. }
  967. bool RequestGroupMan::doesOverallDownloadSpeedExceed()
  968. {
  969. return maxOverallDownloadSpeedLimit_ > 0 &&
  970. maxOverallDownloadSpeedLimit_ < calculateStat().getDownloadSpeed();
  971. }
  972. bool RequestGroupMan::doesOverallUploadSpeedExceed()
  973. {
  974. return maxOverallUploadSpeedLimit_ > 0 &&
  975. maxOverallUploadSpeedLimit_ < calculateStat().getUploadSpeed();
  976. }
  977. void RequestGroupMan::getUsedHosts
  978. (std::vector<std::pair<size_t, std::string> >& usedHosts)
  979. {
  980. // vector of triplet which consists of use count, -download speed,
  981. // hostname. We want to sort by least used and faster download
  982. // speed. We use -download speed so that we can sort them using
  983. // operator<().
  984. std::vector<Triplet<size_t, int, std::string> > tempHosts;
  985. for(std::deque<SharedHandle<RequestGroup> >::const_iterator i =
  986. requestGroups_.begin(), eoi = requestGroups_.end(); i != eoi; ++i) {
  987. const FileEntry::InFlightRequestSet& inFlightReqs =
  988. (*i)->getDownloadContext()->getFirstFileEntry()->getInFlightRequests();
  989. for(FileEntry::InFlightRequestSet::iterator j =
  990. inFlightReqs.begin(), eoj = inFlightReqs.end(); j != eoj; ++j) {
  991. uri_split_result us;
  992. if(uri_split(&us, (*j)->getUri().c_str()) == 0) {
  993. std::vector<Triplet<size_t, int, std::string> >::iterator k;
  994. std::vector<Triplet<size_t, int, std::string> >::iterator eok =
  995. tempHosts.end();
  996. std::string host = uri::getFieldString(us, USR_HOST,
  997. (*j)->getUri().c_str());
  998. for(k = tempHosts.begin(); k != eok; ++k) {
  999. if((*k).third == host) {
  1000. ++(*k).first;
  1001. break;
  1002. }
  1003. }
  1004. if(k == eok) {
  1005. std::string protocol = uri::getFieldString(us, USR_SCHEME,
  1006. (*j)->getUri().c_str());
  1007. SharedHandle<ServerStat> ss = findServerStat(host, protocol);
  1008. int invDlSpeed = (ss && ss->isOK()) ?
  1009. -(static_cast<int>(ss->getDownloadSpeed())) : 0;
  1010. tempHosts.push_back(makeTriplet(1, invDlSpeed, host));
  1011. }
  1012. }
  1013. }
  1014. }
  1015. std::sort(tempHosts.begin(), tempHosts.end());
  1016. std::transform(tempHosts.begin(), tempHosts.end(),
  1017. std::back_inserter(usedHosts), Tuple2Pair<1, 3>());
  1018. }
  1019. void RequestGroupMan::setUriListParser
  1020. (const SharedHandle<UriListParser>& uriListParser)
  1021. {
  1022. uriListParser_ = uriListParser;
  1023. }
  1024. } // namespace aria2