summaryrefslogtreecommitdiff
path: root/src/DHTTaskFactoryImpl.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2008-02-08 15:53:45 +0000
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2008-02-08 15:53:45 +0000
commit1b7c1982896dba1d38e1fe84ba9660996607f5f9 (patch)
treed12047cb37ded1e18d4d5b97844412538beb19ff /src/DHTTaskFactoryImpl.cc
parentd82e183d346375ac8a58a298a58728be615f947e (diff)
2008-02-08 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Removed "using namespace std;" from all sources. Appended std:: prefix to c++ standard classes. Included string.h where mem* function are used.
Diffstat (limited to 'src/DHTTaskFactoryImpl.cc')
-rw-r--r--src/DHTTaskFactoryImpl.cc29
1 files changed, 17 insertions, 12 deletions
diff --git a/src/DHTTaskFactoryImpl.cc b/src/DHTTaskFactoryImpl.cc
index 9fd31342..c4f2101e 100644
--- a/src/DHTTaskFactoryImpl.cc
+++ b/src/DHTTaskFactoryImpl.cc
@@ -39,6 +39,7 @@
#include "DHTMessageFactory.h"
#include "DHTTaskQueue.h"
#include "LogFactory.h"
+#include "Logger.h"
#include "DHTPingTask.h"
#include "DHTNodeLookupTask.h"
#include "DHTBucketRefreshTask.h"
@@ -50,6 +51,8 @@
#include "PeerStorage.h"
#include "BtRuntime.h"
+namespace aria2 {
+
DHTTaskFactoryImpl::DHTTaskFactoryImpl():_localNode(0),
_routingTable(0),
_dispatcher(0),
@@ -59,8 +62,8 @@ DHTTaskFactoryImpl::DHTTaskFactoryImpl():_localNode(0),
DHTTaskFactoryImpl::~DHTTaskFactoryImpl() {}
-DHTTaskHandle
-DHTTaskFactoryImpl::createPingTask(const DHTNodeHandle& remoteNode,
+SharedHandle<DHTTask>
+DHTTaskFactoryImpl::createPingTask(const SharedHandle<DHTNode>& remoteNode,
size_t numRetry)
{
SharedHandle<DHTPingTask> task = new DHTPingTask(remoteNode, numRetry);
@@ -68,7 +71,7 @@ DHTTaskFactoryImpl::createPingTask(const DHTNodeHandle& remoteNode,
return task;
}
-DHTTaskHandle
+SharedHandle<DHTTask>
DHTTaskFactoryImpl::createNodeLookupTask(const unsigned char* targetID)
{
SharedHandle<DHTNodeLookupTask> task = new DHTNodeLookupTask(targetID);
@@ -76,7 +79,7 @@ DHTTaskFactoryImpl::createNodeLookupTask(const unsigned char* targetID)
return task;
}
-DHTTaskHandle
+SharedHandle<DHTTask>
DHTTaskFactoryImpl::createBucketRefreshTask()
{
SharedHandle<DHTBucketRefreshTask> task = new DHTBucketRefreshTask();
@@ -84,31 +87,31 @@ DHTTaskFactoryImpl::createBucketRefreshTask()
return task;
}
-DHTTaskHandle
-DHTTaskFactoryImpl::createPeerLookupTask(const BtContextHandle& ctx)
+SharedHandle<DHTTask>
+DHTTaskFactoryImpl::createPeerLookupTask(const SharedHandle<BtContext>& ctx)
{
SharedHandle<DHTPeerLookupTask> task = new DHTPeerLookupTask(ctx);
setCommonProperty(task);
return task;
}
-DHTTaskHandle
+SharedHandle<DHTTask>
DHTTaskFactoryImpl::createPeerAnnounceTask(const unsigned char* infoHash)
{
// TODO
return 0;
}
-DHTTaskHandle
-DHTTaskFactoryImpl::createReplaceNodeTask(const DHTBucketHandle& bucket,
- const DHTNodeHandle& newNode)
+SharedHandle<DHTTask>
+DHTTaskFactoryImpl::createReplaceNodeTask(const SharedHandle<DHTBucket>& bucket,
+ const SharedHandle<DHTNode>& newNode)
{
SharedHandle<DHTReplaceNodeTask> task = new DHTReplaceNodeTask(bucket, newNode);
setCommonProperty(task);
return task;
}
-void DHTTaskFactoryImpl::setCommonProperty(const DHTAbstractTaskHandle& task)
+void DHTTaskFactoryImpl::setCommonProperty(const SharedHandle<DHTAbstractTask>& task)
{
task->setRoutingTable(_routingTable);
task->setMessageDispatcher(_dispatcher);
@@ -137,7 +140,9 @@ void DHTTaskFactoryImpl::setTaskQueue(const WeakHandle<DHTTaskQueue> taskQueue)
_taskQueue = taskQueue;
}
-void DHTTaskFactoryImpl::setLocalNode(const DHTNodeHandle& localNode)
+void DHTTaskFactoryImpl::setLocalNode(const SharedHandle<DHTNode>& localNode)
{
_localNode = localNode;
}
+
+} // namespace aria2