diff options
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(), |