diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:39:47 +0900 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2015-12-27 18:40:08 +0900 |
| commit | b1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch) | |
| tree | 9ce465b42bf09372118335c7c619bb2b41869eaf /src/AbstractSingleDiskAdaptor.cc | |
| parent | 4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff) | |
make clang-format using clang-format-3.6
Diffstat (limited to 'src/AbstractSingleDiskAdaptor.cc')
| -rw-r--r-- | src/AbstractSingleDiskAdaptor.cc | 94 |
1 files changed, 44 insertions, 50 deletions
diff --git a/src/AbstractSingleDiskAdaptor.cc b/src/AbstractSingleDiskAdaptor.cc index 899168f1..470beb37 100644 --- a/src/AbstractSingleDiskAdaptor.cc +++ b/src/AbstractSingleDiskAdaptor.cc @@ -41,13 +41,15 @@ #include "WrDiskCacheEntry.h" #include "LogFactory.h" #ifdef HAVE_SOME_FALLOCATE -# include "FallocFileAllocationIterator.h" +#include "FallocFileAllocationIterator.h" #endif // HAVE_SOME_FALLOCATE namespace aria2 { -AbstractSingleDiskAdaptor::AbstractSingleDiskAdaptor(): - totalLength_(0), readOnly_(false) {} +AbstractSingleDiskAdaptor::AbstractSingleDiskAdaptor() + : totalLength_(0), readOnly_(false) +{ +} AbstractSingleDiskAdaptor::~AbstractSingleDiskAdaptor() {} @@ -61,34 +63,31 @@ void AbstractSingleDiskAdaptor::openFile() diskWriter_->openFile(totalLength_); } -void AbstractSingleDiskAdaptor::closeFile() -{ - diskWriter_->closeFile(); -} +void AbstractSingleDiskAdaptor::closeFile() { diskWriter_->closeFile(); } void AbstractSingleDiskAdaptor::openExistingFile() { diskWriter_->openExistingFile(totalLength_); } -void AbstractSingleDiskAdaptor::writeData -(const unsigned char* data, size_t len, int64_t offset) +void AbstractSingleDiskAdaptor::writeData(const unsigned char* data, size_t len, + int64_t offset) { diskWriter_->writeData(data, len, offset); } -ssize_t AbstractSingleDiskAdaptor::readData -(unsigned char* data, size_t len, int64_t offset) +ssize_t AbstractSingleDiskAdaptor::readData(unsigned char* data, size_t len, + int64_t offset) { return diskWriter_->readData(data, len, offset); } -ssize_t AbstractSingleDiskAdaptor::readDataDropCache -(unsigned char* data, size_t len, int64_t offset) +ssize_t AbstractSingleDiskAdaptor::readDataDropCache(unsigned char* data, + size_t len, int64_t offset) { auto rv = readData(data, len, offset); - if(rv > 0) { + if (rv > 0) { diskWriter_->dropCache(len, offset); } @@ -106,31 +105,32 @@ void AbstractSingleDiskAdaptor::writeCache(const WrDiskCacheEntry* entry) size_t buflen = 0; size_t buffoffset = 0; const WrDiskCacheEntry::DataCellSet& dataSet = entry->getDataSet(); - for(auto & d : dataSet) { - if(start+static_cast<ssize_t>(buflen) < d->goff) { - A2_LOG_DEBUG(fmt("Cache flush goff=%" PRId64 ", len=%lu", - start, static_cast<unsigned long>(buflen))); - writeData(buf+buffoffset, buflen-buffoffset, start); + for (auto& d : dataSet) { + if (start + static_cast<ssize_t>(buflen) < d->goff) { + A2_LOG_DEBUG(fmt("Cache flush goff=%" PRId64 ", len=%lu", start, + static_cast<unsigned long>(buflen))); + writeData(buf + buffoffset, buflen - buffoffset, start); start = d->goff; buflen = buffoffset = 0; } - if(buflen == 0 && (d->goff & 0xfff) == 0 && (d->len & 0xfff) == 0) { + if (buflen == 0 && (d->goff & 0xfff) == 0 && (d->len & 0xfff) == 0) { // Already aligned. Write it without copy. - A2_LOG_DEBUG(fmt("Cache flush goff=%" PRId64 ", len=%lu", - start, static_cast<unsigned long>(d->len))); + A2_LOG_DEBUG(fmt("Cache flush goff=%" PRId64 ", len=%lu", start, + static_cast<unsigned long>(d->len))); writeData(d->data + d->offset, d->len, start); start += d->len; - } else { - if(buflen == 0) { + } + else { + if (buflen == 0) { buflen = buffoffset = d->goff & 0xfff; } size_t wlen = std::min(sizeof(buf) - buflen, d->len); - memcpy(buf+buflen, d->data + d->offset, wlen); + memcpy(buf + buflen, d->data + d->offset, wlen); buflen += wlen; - if(buflen == sizeof(buf)) { - A2_LOG_DEBUG(fmt("Cache flush goff=%" PRId64 ", len=%lu", - start, static_cast<unsigned long>(buflen))); - writeData(buf+buffoffset, buflen-buffoffset, start); + if (buflen == sizeof(buf)) { + A2_LOG_DEBUG(fmt("Cache flush goff=%" PRId64 ", len=%lu", start, + static_cast<unsigned long>(buflen))); + writeData(buf + buffoffset, buflen - buffoffset, start); memcpy(buf, d->data + d->offset + wlen, d->len - wlen); start += sizeof(buf) - buffoffset; buflen = d->len - wlen; @@ -138,7 +138,7 @@ void AbstractSingleDiskAdaptor::writeCache(const WrDiskCacheEntry* entry) } } } - writeData(buf+buffoffset, buflen-buffoffset, start); + writeData(buf + buffoffset, buflen - buffoffset, start); } bool AbstractSingleDiskAdaptor::fileExists() @@ -146,10 +146,7 @@ bool AbstractSingleDiskAdaptor::fileExists() return File(getFilePath()).exists(); } -int64_t AbstractSingleDiskAdaptor::size() -{ - return File(getFilePath()).size(); -} +int64_t AbstractSingleDiskAdaptor::size() { return File(getFilePath()).size(); } void AbstractSingleDiskAdaptor::truncate(int64_t length) { @@ -159,18 +156,18 @@ void AbstractSingleDiskAdaptor::truncate(int64_t length) std::unique_ptr<FileAllocationIterator> AbstractSingleDiskAdaptor::fileAllocationIterator() { - switch(getFileAllocationMethod()) { + switch (getFileAllocationMethod()) { #ifdef HAVE_SOME_FALLOCATE - case(DiskAdaptor::FILE_ALLOC_FALLOC): - return make_unique<FallocFileAllocationIterator> - (diskWriter_.get(), size() ,totalLength_); + case (DiskAdaptor::FILE_ALLOC_FALLOC): + return make_unique<FallocFileAllocationIterator>(diskWriter_.get(), size(), + totalLength_); #endif // HAVE_SOME_FALLOCATE - case(DiskAdaptor::FILE_ALLOC_TRUNC): - return make_unique<TruncFileAllocationIterator> - (diskWriter_.get(), size(), totalLength_); + case (DiskAdaptor::FILE_ALLOC_TRUNC): + return make_unique<TruncFileAllocationIterator>(diskWriter_.get(), size(), + totalLength_); default: - return make_unique<AdaptiveFileAllocationIterator> - (diskWriter_.get(), size(), totalLength_); + return make_unique<AdaptiveFileAllocationIterator>(diskWriter_.get(), + size(), totalLength_); } } @@ -186,20 +183,17 @@ void AbstractSingleDiskAdaptor::disableReadOnly() readOnly_ = false; } -void AbstractSingleDiskAdaptor::enableMmap() -{ - diskWriter_->enableMmap(); -} +void AbstractSingleDiskAdaptor::enableMmap() { diskWriter_->enableMmap(); } void AbstractSingleDiskAdaptor::cutTrailingGarbage() { - if(File(getFilePath()).size() > totalLength_) { + if (File(getFilePath()).size() > totalLength_) { diskWriter_->truncate(totalLength_); } } -void AbstractSingleDiskAdaptor::setDiskWriter -(std::unique_ptr<DiskWriter> diskWriter) +void AbstractSingleDiskAdaptor::setDiskWriter( + std::unique_ptr<DiskWriter> diskWriter) { diskWriter_ = std::move(diskWriter); } |
