diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-06-22 01:10:38 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-06-22 01:10:38 +0900 |
| commit | 07d270c87e6f9184aea4ca17eb26e466712e8db2 (patch) | |
| tree | 2dfbaa2e0d2ad0f38cb73098608f7d67a64320f8 /src/DHTTaskFactoryImpl.cc | |
| parent | 126a4bde612eb0e6c48cf2f13ebe3eac45cc71a8 (diff) | |
Require -std=c++11 and use std::shared_ptr instead of SharedHandle
Diffstat (limited to 'src/DHTTaskFactoryImpl.cc')
| -rw-r--r-- | src/DHTTaskFactoryImpl.cc | 38 |
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; } |
