summaryrefslogtreecommitdiff
path: root/src/DHTTaskFactoryImpl.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-03-30 14:46:26 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2010-03-30 14:46:26 +0000
commite7e214fef2c9f1a7f39a3157e2595cc7da7db608 (patch)
treeaad51976c6d503fe93373e09b9de4efa9fd3b5c9 /src/DHTTaskFactoryImpl.cc
parent68156ef258079c50965b86483ea7b119a82c93ad (diff)
2010-03-30 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Added --dht-message-timeout option. * doc/aria2c.1.txt * src/DHTConstants.h * src/DHTMessageDispatcherImpl.cc * src/DHTMessageDispatcherImpl.h * src/DHTMessageTracker.cc * src/DHTMessageTracker.h * src/DHTReplaceNodeTask.h * src/DHTSetup.cc * src/DHTTaskFactoryImpl.cc * src/DHTTaskFactoryImpl.h * src/OptionHandlerFactory.cc * src/prefs.cc * src/prefs.h * src/usage_text.h * test/DHTMessageTrackerTest.cc
Diffstat (limited to 'src/DHTTaskFactoryImpl.cc')
-rw-r--r--src/DHTTaskFactoryImpl.cc6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/DHTTaskFactoryImpl.cc b/src/DHTTaskFactoryImpl.cc
index ee5ade9a..77fb9514 100644
--- a/src/DHTTaskFactoryImpl.cc
+++ b/src/DHTTaskFactoryImpl.cc
@@ -53,7 +53,9 @@
namespace aria2 {
-DHTTaskFactoryImpl::DHTTaskFactoryImpl():_logger(LogFactory::getInstance()) {}
+DHTTaskFactoryImpl::DHTTaskFactoryImpl():
+ _timeout(DHT_MESSAGE_TIMEOUT),
+ _logger(LogFactory::getInstance()) {}
DHTTaskFactoryImpl::~DHTTaskFactoryImpl() {}
@@ -62,6 +64,7 @@ DHTTaskFactoryImpl::createPingTask(const SharedHandle<DHTNode>& remoteNode,
size_t numRetry)
{
SharedHandle<DHTPingTask> task(new DHTPingTask(remoteNode, numRetry));
+ task->setTimeout(_timeout);
setCommonProperty(task);
return task;
}
@@ -108,6 +111,7 @@ DHTTaskFactoryImpl::createReplaceNodeTask(const SharedHandle<DHTBucket>& bucket,
const SharedHandle<DHTNode>& newNode)
{
SharedHandle<DHTReplaceNodeTask> task(new DHTReplaceNodeTask(bucket, newNode));
+ task->setTimeout(_timeout);
setCommonProperty(task);
return task;
}