summaryrefslogtreecommitdiff
path: root/src/DefaultPeerStorage.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-10-26 21:26:41 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2013-10-26 21:28:58 +0900
commit6d2dd2ab186f5c8b6406ae4659c07b850317d2ed (patch)
tree92c8d37f482eba5df958e0f5393f51a2841a9926 /src/DefaultPeerStorage.cc
parent234dd76cd43b53d4b32490bd67f534951410fae1 (diff)
DefaultPeerStorage: Code cleanup
Diffstat (limited to 'src/DefaultPeerStorage.cc')
-rw-r--r--src/DefaultPeerStorage.cc25
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",