diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-07-04 00:56:29 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-07-04 00:56:29 +0900 |
| commit | c36370ef60ae4f8c1ed251a404ccddff671194a1 (patch) | |
| tree | 0a6a9a324778b40215ce7da0b9358f295afbdb37 /src/LpdReceiveMessageCommand.cc | |
| parent | 57f1902ee1fd24e2fa94a5e5c0ee357335366d7d (diff) | |
Use std::unique_ptr for LpdMessage instead of std::shared_ptr
Diffstat (limited to 'src/LpdReceiveMessageCommand.cc')
| -rw-r--r-- | src/LpdReceiveMessageCommand.cc | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/LpdReceiveMessageCommand.cc b/src/LpdReceiveMessageCommand.cc index e0f11715..a685e8a3 100644 --- a/src/LpdReceiveMessageCommand.cc +++ b/src/LpdReceiveMessageCommand.cc @@ -73,12 +73,12 @@ bool LpdReceiveMessageCommand::execute() return true; } for(size_t i = 0; i < 20; ++i) { - std::shared_ptr<LpdMessage> m = receiver_->receiveMessage(); + auto m = receiver_->receiveMessage(); if(!m) { break; } - std::shared_ptr<BtRegistry> reg = e_->getBtRegistry(); - std::shared_ptr<DownloadContext> dctx = reg->getDownloadContext(m->infoHash); + auto& reg = e_->getBtRegistry(); + auto& dctx = reg->getDownloadContext(m->infoHash); if(!dctx) { A2_LOG_DEBUG(fmt("Download Context is null for infohash=%s.", util::toHex(m->infoHash).c_str())); @@ -90,11 +90,11 @@ bool LpdReceiveMessageCommand::execute() } RequestGroup* group = dctx->getOwnerRequestGroup(); assert(group); - const std::shared_ptr<BtObject>& btobj = reg->get(group->getGID()); + auto& btobj = reg->get(group->getGID()); assert(btobj); - const std::shared_ptr<PeerStorage>& peerStorage = btobj->peerStorage; + auto& peerStorage = btobj->peerStorage; assert(peerStorage); - std::shared_ptr<Peer> peer = m->peer; + auto& peer = m->peer; if(peerStorage->addPeer(peer)) { A2_LOG_DEBUG(fmt("LPD peer %s:%u local=%d added.", peer->getIPAddress().c_str(), peer->getPort(), |