summaryrefslogtreecommitdiff
path: root/src/AbstractSingleDiskAdaptor.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/AbstractSingleDiskAdaptor.cc
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/AbstractSingleDiskAdaptor.cc')
-rw-r--r--src/AbstractSingleDiskAdaptor.cc94
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);
}