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/DHTPeerLookupTask.cc | |
| parent | 126a4bde612eb0e6c48cf2f13ebe3eac45cc71a8 (diff) | |
Require -std=c++11 and use std::shared_ptr instead of SharedHandle
Diffstat (limited to 'src/DHTPeerLookupTask.cc')
| -rw-r--r-- | src/DHTPeerLookupTask.cc | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/src/DHTPeerLookupTask.cc b/src/DHTPeerLookupTask.cc index 3c0b9eaa..9a9711d4 100644 --- a/src/DHTPeerLookupTask.cc +++ b/src/DHTPeerLookupTask.cc @@ -53,7 +53,7 @@ namespace aria2 { DHTPeerLookupTask::DHTPeerLookupTask -(const SharedHandle<DownloadContext>& downloadContext, +(const std::shared_ptr<DownloadContext>& downloadContext, uint16_t tcpPort) : DHTAbstractNodeLookupTask<DHTGetPeersReplyMessage> (bittorrent::getInfoHash(downloadContext)), @@ -62,10 +62,10 @@ DHTPeerLookupTask::DHTPeerLookupTask void DHTPeerLookupTask::getNodesFromMessage -(std::vector<SharedHandle<DHTNode> >& nodes, +(std::vector<std::shared_ptr<DHTNode> >& nodes, const DHTGetPeersReplyMessage* message) { - const std::vector<SharedHandle<DHTNode> >& knodes = + const std::vector<std::shared_ptr<DHTNode> >& knodes = message->getClosestKNodes(); nodes.insert(nodes.end(), knodes.begin(), knodes.end()); } @@ -73,7 +73,7 @@ DHTPeerLookupTask::getNodesFromMessage void DHTPeerLookupTask::onReceivedInternal (const DHTGetPeersReplyMessage* message) { - SharedHandle<DHTNode> remoteNode = message->getRemoteNode(); + std::shared_ptr<DHTNode> remoteNode = message->getRemoteNode(); tokenStorage_[util::toHex(remoteNode->getID(), DHT_ID_LENGTH)] = message->getToken(); peerStorage_->addPeer(message->getValues()); @@ -81,15 +81,15 @@ void DHTPeerLookupTask::onReceivedInternal static_cast<unsigned long>(message->getValues().size()))); } -SharedHandle<DHTMessage> DHTPeerLookupTask::createMessage -(const SharedHandle<DHTNode>& remoteNode) +std::shared_ptr<DHTMessage> DHTPeerLookupTask::createMessage +(const std::shared_ptr<DHTNode>& remoteNode) { return getMessageFactory()->createGetPeersMessage(remoteNode, getTargetID()); } -SharedHandle<DHTMessageCallback> DHTPeerLookupTask::createCallback() +std::shared_ptr<DHTMessageCallback> DHTPeerLookupTask::createCallback() { - return SharedHandle<DHTPeerLookupTaskCallback> + return std::shared_ptr<DHTPeerLookupTaskCallback> (new DHTPeerLookupTaskCallback(this)); } @@ -99,20 +99,20 @@ void DHTPeerLookupTask::onFinish() util::toHex(getTargetID(), DHT_ID_LENGTH).c_str())); // send announce_peer message to K closest nodes size_t num = DHTBucket::K; - for(std::deque<SharedHandle<DHTNodeLookupEntry> >::const_iterator i = + for(std::deque<std::shared_ptr<DHTNodeLookupEntry> >::const_iterator i = getEntries().begin(), eoi = getEntries().end(); i != eoi && num > 0; ++i) { if(!(*i)->used) { continue; } - const SharedHandle<DHTNode>& node = (*i)->node; + const std::shared_ptr<DHTNode>& node = (*i)->node; std::string idHex = util::toHex(node->getID(), DHT_ID_LENGTH); std::string token = tokenStorage_[idHex]; if(token.empty()) { A2_LOG_DEBUG(fmt("Token is empty for ID:%s", idHex.c_str())); continue; } - SharedHandle<DHTMessage> m = + std::shared_ptr<DHTMessage> m = getMessageFactory()->createAnnouncePeerMessage (node, getTargetID(), // this is infoHash @@ -123,7 +123,7 @@ void DHTPeerLookupTask::onFinish() } } -void DHTPeerLookupTask::setPeerStorage(const SharedHandle<PeerStorage>& ps) +void DHTPeerLookupTask::setPeerStorage(const std::shared_ptr<PeerStorage>& ps) { peerStorage_ = ps; } |
