diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-10-26 21:26:41 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2013-10-26 21:28:58 +0900 |
| commit | 6d2dd2ab186f5c8b6406ae4659c07b850317d2ed (patch) | |
| tree | 92c8d37f482eba5df958e0f5393f51a2841a9926 /src/DefaultPeerStorage.cc | |
| parent | 234dd76cd43b53d4b32490bd67f534951410fae1 (diff) | |
DefaultPeerStorage: Code cleanup
Diffstat (limited to 'src/DefaultPeerStorage.cc')
| -rw-r--r-- | src/DefaultPeerStorage.cc | 25 |
1 files changed, 12 insertions, 13 deletions
diff --git a/src/DefaultPeerStorage.cc b/src/DefaultPeerStorage.cc index 0a3dcf9e..2a424d96 100644 --- a/src/DefaultPeerStorage.cc +++ b/src/DefaultPeerStorage.cc @@ -60,15 +60,13 @@ const size_t MAX_PEER_LIST_UPDATE = 100; DefaultPeerStorage::DefaultPeerStorage() : maxPeerListSize_(MAX_PEER_LIST_SIZE), - seederStateChoke_(new BtSeederStateChoke()), - leecherStateChoke_(new BtLeecherStateChoke()), + seederStateChoke_(make_unique<BtSeederStateChoke>()), + leecherStateChoke_(make_unique<BtLeecherStateChoke>()), lastTransferStatMapUpdated_(0) {} DefaultPeerStorage::~DefaultPeerStorage() { - delete seederStateChoke_; - delete leecherStateChoke_; assert(uniqPeers_.size() == unusedPeers_.size() + usedPeers_.size()); } @@ -112,13 +110,14 @@ bool DefaultPeerStorage::addPeer(const std::shared_ptr<Peer>& peer) return true; } -void DefaultPeerStorage::addPeer(const std::vector<std::shared_ptr<Peer> >& peers) +void DefaultPeerStorage::addPeer +(const std::vector<std::shared_ptr<Peer>>& peers) { size_t added = 0; size_t addMax = std::min(maxPeerListSize_, MAX_PEER_LIST_UPDATE); - for(auto itr = peers.begin(), - eoi = peers.end(); itr != eoi && added < addMax; ++itr) { - const std::shared_ptr<Peer>& peer = *itr; + for(auto itr = std::begin(peers), eoi = std::end(peers); + itr != eoi && added < addMax; ++itr) { + auto& peer = *itr; if(isPeerAlreadyAdded(peer)) { A2_LOG_DEBUG(fmt("Adding %s:%u is rejected because it has been already" " added.", @@ -148,8 +147,8 @@ void DefaultPeerStorage::addDroppedPeer(const std::shared_ptr<Peer>& peer) { // Make sure that no duplicated peer exists in droppedPeers_. If // exists, erase older one. - for(auto i = droppedPeers_.begin(), - eoi = droppedPeers_.end(); i != eoi; ++i) { + for(auto i = std::begin(droppedPeers_), eoi = std::end(droppedPeers_); + i != eoi; ++i) { if((*i)->getIPAddress() == peer->getIPAddress() && (*i)->getPort() == peer->getPort()) { droppedPeers_.erase(i); @@ -162,7 +161,7 @@ void DefaultPeerStorage::addDroppedPeer(const std::shared_ptr<Peer>& peer) } } -const std::deque<std::shared_ptr<Peer> >& DefaultPeerStorage::getUnusedPeers() +const std::deque<std::shared_ptr<Peer>>& DefaultPeerStorage::getUnusedPeers() { return unusedPeers_; } @@ -172,7 +171,7 @@ const PeerSet& DefaultPeerStorage::getUsedPeers() return usedPeers_; } -const std::deque<std::shared_ptr<Peer> >& DefaultPeerStorage::getDroppedPeers() +const std::deque<std::shared_ptr<Peer>>& DefaultPeerStorage::getDroppedPeers() { return droppedPeers_; } @@ -229,7 +228,7 @@ std::shared_ptr<Peer> DefaultPeerStorage::checkoutPeer(cuid_t cuid) if(!isPeerAvailable()) { return nullptr; } - std::shared_ptr<Peer> peer = unusedPeers_.front(); + auto peer = unusedPeers_.front(); unusedPeers_.pop_front(); if(peer->usedBy() != 0) { A2_LOG_WARN(fmt("CUID#%" PRId64 " is already set for peer %s:%u", |
