summaryrefslogtreecommitdiff
path: root/src/OpenedFileCounter.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:39:47 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:40:08 +0900
commitb1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch)
tree9ce465b42bf09372118335c7c619bb2b41869eaf /src/OpenedFileCounter.cc
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/OpenedFileCounter.cc')
-rw-r--r--src/OpenedFileCounter.cc51
1 files changed, 22 insertions, 29 deletions
diff --git a/src/OpenedFileCounter.cc b/src/OpenedFileCounter.cc
index aa350079..d97b2bbf 100644
--- a/src/OpenedFileCounter.cc
+++ b/src/OpenedFileCounter.cc
@@ -46,18 +46,17 @@ namespace aria2 {
OpenedFileCounter::OpenedFileCounter(RequestGroupMan* rgman,
size_t maxOpenFiles)
- : rgman_(rgman),
- maxOpenFiles_(maxOpenFiles),
- numOpenFiles_(0)
-{}
+ : rgman_(rgman), maxOpenFiles_(maxOpenFiles), numOpenFiles_(0)
+{
+}
void OpenedFileCounter::ensureMaxOpenFileLimit(size_t numNewFiles)
{
- if(!rgman_) {
+ if (!rgman_) {
return;
}
- if(numOpenFiles_ + numNewFiles <= maxOpenFiles_) {
+ if (numOpenFiles_ + numNewFiles <= maxOpenFiles_) {
numOpenFiles_ += numNewFiles;
return;
}
@@ -68,32 +67,30 @@ void OpenedFileCounter::ensureMaxOpenFileLimit(size_t numNewFiles)
auto& requestGroups = rgman_->getRequestGroups();
auto mark = std::begin(requestGroups);
- std::advance(mark,
- SimpleRandomizer::getInstance()->
- getRandomNumber(requestGroups.size()));
+ std::advance(mark, SimpleRandomizer::getInstance()->getRandomNumber(
+ requestGroups.size()));
- auto closeFun = [&left](const std::shared_ptr<RequestGroup>& group)
- {
- auto& ps = group->getPieceStorage();
+ auto closeFun = [&left](const std::shared_ptr<RequestGroup>& group) {
+ auto& ps = group->getPieceStorage();
- if(!ps) {
- return;
- }
+ if (!ps) {
+ return;
+ }
- auto diskAdaptor = ps->getDiskAdaptor();
+ auto diskAdaptor = ps->getDiskAdaptor();
- if(!diskAdaptor) {
- return;
- }
+ if (!diskAdaptor) {
+ return;
+ }
- left -= diskAdaptor->tryCloseFile(left);
- };
+ left -= diskAdaptor->tryCloseFile(left);
+ };
- for(auto i = mark; i != std::end(requestGroups) && left > 0; ++i) {
+ for (auto i = mark; i != std::end(requestGroups) && left > 0; ++i) {
closeFun(*i);
}
- for(auto i = std::begin(requestGroups); i != mark && left > 0; ++i) {
+ for (auto i = std::begin(requestGroups); i != mark && left > 0; ++i) {
closeFun(*i);
}
@@ -103,7 +100,7 @@ void OpenedFileCounter::ensureMaxOpenFileLimit(size_t numNewFiles)
void OpenedFileCounter::reduceNumOfOpenedFile(size_t numCloseFiles)
{
- if(!rgman_) {
+ if (!rgman_) {
return;
}
@@ -111,10 +108,6 @@ void OpenedFileCounter::reduceNumOfOpenedFile(size_t numCloseFiles)
numOpenFiles_ -= numCloseFiles;
}
-void OpenedFileCounter::deactivate()
-{
- rgman_ = nullptr;
-}
+void OpenedFileCounter::deactivate() { rgman_ = nullptr; }
} // namespace aria2
-