summaryrefslogtreecommitdiff
path: root/src/UTMetadataRequestTracker.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2016-03-26 17:12:52 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2016-03-26 17:20:27 +0900
commitd64089632e82a2548752c7a6baaa68365a795a74 (patch)
tree57fc7b85a8c1290975d58fa4761b04a7695bf7e3 /src/UTMetadataRequestTracker.cc
parentc81b1321122e8509b55c94c0cbca0d8d6d319f0c (diff)
parenta7cd943a06b1a5ff4515b57060b84037f8d01f9f (diff)
Merge branch 'master' into random-webseeding
Diffstat (limited to 'src/UTMetadataRequestTracker.cc')
-rw-r--r--src/UTMetadataRequestTracker.cc28
1 files changed, 15 insertions, 13 deletions
diff --git a/src/UTMetadataRequestTracker.cc b/src/UTMetadataRequestTracker.cc
index cbb20806..213c198f 100644
--- a/src/UTMetadataRequestTracker.cc
+++ b/src/UTMetadataRequestTracker.cc
@@ -59,7 +59,7 @@ void UTMetadataRequestTracker::remove(size_t index)
{
auto i = std::find(trackedRequests_.begin(), trackedRequests_.end(),
RequestEntry(index));
- if(i != trackedRequests_.end()) {
+ if (i != trackedRequests_.end()) {
trackedRequests_.erase(i);
}
}
@@ -74,14 +74,15 @@ std::vector<size_t> UTMetadataRequestTracker::removeTimeoutEntry()
trackedRequests_.erase(
std::remove_if(std::begin(trackedRequests_), std::end(trackedRequests_),
[&indexes](const RequestEntry& ent) {
- if (ent.elapsed(TIMEOUT)) {
- A2_LOG_DEBUG(fmt("ut_metadata request timeout. index=%lu",
- static_cast<unsigned long>(ent.index_)));
- indexes.push_back(ent.index_);
- return true;
- }
- return false;
- }),
+ if (ent.elapsed(TIMEOUT)) {
+ A2_LOG_DEBUG(
+ fmt("ut_metadata request timeout. index=%lu",
+ static_cast<unsigned long>(ent.index_)));
+ indexes.push_back(ent.index_);
+ return true;
+ }
+ return false;
+ }),
std::end(trackedRequests_));
return indexes;
}
@@ -89,9 +90,10 @@ std::vector<size_t> UTMetadataRequestTracker::removeTimeoutEntry()
size_t UTMetadataRequestTracker::avail() const
{
const size_t MAX_OUTSTANDING_REQUEST = 1;
- if(MAX_OUTSTANDING_REQUEST > count()) {
- return MAX_OUTSTANDING_REQUEST-count();
- } else {
+ if (MAX_OUTSTANDING_REQUEST > count()) {
+ return MAX_OUTSTANDING_REQUEST - count();
+ }
+ else {
return 0;
}
}
@@ -99,7 +101,7 @@ size_t UTMetadataRequestTracker::avail() const
std::vector<size_t> UTMetadataRequestTracker::getAllTrackedIndex() const
{
std::vector<size_t> indexes;
- for(auto& e: trackedRequests_) {
+ for (auto& e : trackedRequests_) {
indexes.push_back(e.index_);
}
return indexes;