summaryrefslogtreecommitdiff
path: root/src/DHTTaskFactoryImpl.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-06-22 01:10:38 +0900
commit07d270c87e6f9184aea4ca17eb26e466712e8db2 (patch)
tree2dfbaa2e0d2ad0f38cb73098608f7d67a64320f8 /src/DHTTaskFactoryImpl.cc
parent126a4bde612eb0e6c48cf2f13ebe3eac45cc71a8 (diff)
Require -std=c++11 and use std::shared_ptr instead of SharedHandle
Diffstat (limited to 'src/DHTTaskFactoryImpl.cc')
-rw-r--r--src/DHTTaskFactoryImpl.cc38
1 files changed, 19 insertions, 19 deletions
diff --git a/src/DHTTaskFactoryImpl.cc b/src/DHTTaskFactoryImpl.cc
index aec36c7c..2bed9da5 100644
--- a/src/DHTTaskFactoryImpl.cc
+++ b/src/DHTTaskFactoryImpl.cc
@@ -60,63 +60,63 @@ DHTTaskFactoryImpl::DHTTaskFactoryImpl()
DHTTaskFactoryImpl::~DHTTaskFactoryImpl() {}
-SharedHandle<DHTTask>
-DHTTaskFactoryImpl::createPingTask(const SharedHandle<DHTNode>& remoteNode,
+std::shared_ptr<DHTTask>
+DHTTaskFactoryImpl::createPingTask(const std::shared_ptr<DHTNode>& remoteNode,
int numRetry)
{
- SharedHandle<DHTPingTask> task(new DHTPingTask(remoteNode, numRetry));
+ std::shared_ptr<DHTPingTask> task(new DHTPingTask(remoteNode, numRetry));
task->setTimeout(timeout_);
setCommonProperty(task);
return task;
}
-SharedHandle<DHTTask>
+std::shared_ptr<DHTTask>
DHTTaskFactoryImpl::createNodeLookupTask(const unsigned char* targetID)
{
- SharedHandle<DHTNodeLookupTask> task(new DHTNodeLookupTask(targetID));
+ std::shared_ptr<DHTNodeLookupTask> task(new DHTNodeLookupTask(targetID));
setCommonProperty(task);
return task;
}
-SharedHandle<DHTTask>
+std::shared_ptr<DHTTask>
DHTTaskFactoryImpl::createBucketRefreshTask()
{
- SharedHandle<DHTBucketRefreshTask> task(new DHTBucketRefreshTask());
+ std::shared_ptr<DHTBucketRefreshTask> task(new DHTBucketRefreshTask());
setCommonProperty(task);
return task;
}
-SharedHandle<DHTTask>
+std::shared_ptr<DHTTask>
DHTTaskFactoryImpl::createPeerLookupTask
-(const SharedHandle<DownloadContext>& ctx,
+(const std::shared_ptr<DownloadContext>& ctx,
uint16_t tcpPort,
- const SharedHandle<PeerStorage>& peerStorage)
+ const std::shared_ptr<PeerStorage>& peerStorage)
{
- SharedHandle<DHTPeerLookupTask> task(new DHTPeerLookupTask(ctx, tcpPort));
+ std::shared_ptr<DHTPeerLookupTask> task(new DHTPeerLookupTask(ctx, tcpPort));
// TODO this may be not freed by RequestGroup::releaseRuntimeResource()
task->setPeerStorage(peerStorage);
setCommonProperty(task);
return task;
}
-SharedHandle<DHTTask>
+std::shared_ptr<DHTTask>
DHTTaskFactoryImpl::createPeerAnnounceTask(const unsigned char* infoHash)
{
// TODO
- return SharedHandle<DHTTask>();
+ return std::shared_ptr<DHTTask>();
}
-SharedHandle<DHTTask>
-DHTTaskFactoryImpl::createReplaceNodeTask(const SharedHandle<DHTBucket>& bucket,
- const SharedHandle<DHTNode>& newNode)
+std::shared_ptr<DHTTask>
+DHTTaskFactoryImpl::createReplaceNodeTask(const std::shared_ptr<DHTBucket>& bucket,
+ const std::shared_ptr<DHTNode>& newNode)
{
- SharedHandle<DHTReplaceNodeTask> task(new DHTReplaceNodeTask(bucket, newNode));
+ std::shared_ptr<DHTReplaceNodeTask> task(new DHTReplaceNodeTask(bucket, newNode));
task->setTimeout(timeout_);
setCommonProperty(task);
return task;
}
-void DHTTaskFactoryImpl::setCommonProperty(const SharedHandle<DHTAbstractTask>& task)
+void DHTTaskFactoryImpl::setCommonProperty(const std::shared_ptr<DHTAbstractTask>& task)
{
task->setRoutingTable(routingTable_);
task->setMessageDispatcher(dispatcher_);
@@ -145,7 +145,7 @@ void DHTTaskFactoryImpl::setTaskQueue(DHTTaskQueue* taskQueue)
taskQueue_ = taskQueue;
}
-void DHTTaskFactoryImpl::setLocalNode(const SharedHandle<DHTNode>& localNode)
+void DHTTaskFactoryImpl::setLocalNode(const std::shared_ptr<DHTNode>& localNode)
{
localNode_ = localNode;
}