summaryrefslogtreecommitdiff
path: root/src/BtDependency.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2007-10-11 16:58:24 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2007-10-11 16:58:24 +0000
commit048a2cf59737f761876e81a77e8d064c45c752d7 (patch)
tree65c9d5498aafe6a8c8e640ddfcc43c7013504d0d /src/BtDependency.cc
parente26bbbb9eee140ba24402fe872a752b42f0077de (diff)
2007-10-12 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Implemented BitTorrent/http/ftp integrated download. I've rewritten lots of files and now some headers have forward class declarations to reduce compile time. The implementation is extremely alpha stage, I recommend to use this for testing purpose only.
Diffstat (limited to 'src/BtDependency.cc')
-rw-r--r--src/BtDependency.cc83
1 files changed, 83 insertions, 0 deletions
diff --git a/src/BtDependency.cc b/src/BtDependency.cc
new file mode 100644
index 00000000..8be2266e
--- /dev/null
+++ b/src/BtDependency.cc
@@ -0,0 +1,83 @@
+/* <!-- copyright */
+/*
+ * aria2 - The high speed download utility
+ *
+ * Copyright (C) 2006 Tatsuhiro Tsujikawa
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ *
+ * In addition, as a special exception, the copyright holders give
+ * permission to link the code of portions of this program with the
+ * OpenSSL library under certain conditions as described in each
+ * individual source file, and distribute linked combinations
+ * including the two.
+ * You must obey the GNU General Public License in all respects
+ * for all of the code used other than OpenSSL. If you modify
+ * file(s) with this exception, you may extend this exception to your
+ * version of the file(s), but you are not obligated to do so. If you
+ * do not wish to do so, delete this exception statement from your
+ * version. If you delete this exception statement from all source
+ * files in the program, then also delete it here.
+ */
+/* copyright --> */
+#include "BtDependency.h"
+#include "RequestGroup.h"
+#include "Option.h"
+#include "LogFactory.h"
+#include "DefaultBtContext.h"
+#include "RecoverableException.h"
+#include "message.h"
+#include "prefs.h"
+
+BtDependency::BtDependency(const RequestGroupWeakHandle& dependant,
+ const RequestGroupWeakHandle& dependee,
+ const Option* option):
+ _dependant(dependant),
+ _dependee(dependee),
+ _option(option),
+ _logger(LogFactory::getInstance()) {}
+
+BtDependency::~BtDependency() {}
+
+bool BtDependency::resolve()
+{
+ if(_dependee->getNumCommand() == 0 && _dependee->downloadFinished()) {
+ DefaultBtContextHandle btContext = new DefaultBtContext();
+ try {
+ btContext->load(_dependee->getFilePath());
+ if(_option->defined(PREF_PEER_ID_PREFIX)) {
+ btContext->setPeerIdPrefix(_option->get(PREF_PEER_ID_PREFIX));
+ }
+ btContext->setDir(_dependant->getDownloadContext()->getDir());
+ } catch(RecoverableException* e) {
+ _logger->error(EX_EXCEPTION_CAUGHT, e);
+ delete e;
+ _logger->debug("BtDependency for GID#%d failed. Go without Bt.",
+ _dependant->getGID());
+ return true;
+ }
+ _logger->debug("Dependency resolved for GID#%d", _dependant->getGID());
+ _dependant->setDownloadContext(btContext);
+ btContext->setOwnerRequestGroup(_dependant.get());
+ return true;
+ } else if(_dependee->getNumCommand() == 0) {
+ // _dependee's download failed.
+ _logger->debug("BtDependency for GID#%d failed. Go without Bt.",
+ _dependant->getGID());
+ return true;
+ } else {
+ return false;
+ }
+}