summaryrefslogtreecommitdiff
path: root/src/SinkStreamFilter.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/SinkStreamFilter.cc
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/SinkStreamFilter.cc')
-rw-r--r--src/SinkStreamFilter.cc41
1 files changed, 21 insertions, 20 deletions
diff --git a/src/SinkStreamFilter.cc b/src/SinkStreamFilter.cc
index a1abdf06..47f529de 100644
--- a/src/SinkStreamFilter.cc
+++ b/src/SinkStreamFilter.cc
@@ -46,38 +46,37 @@ namespace aria2 {
const std::string SinkStreamFilter::NAME("SinkStreamFilter");
-SinkStreamFilter::SinkStreamFilter(WrDiskCache* wrDiskCache, bool hashUpdate):
- wrDiskCache_(wrDiskCache),
- hashUpdate_(hashUpdate),
- bytesProcessed_(0) {}
+SinkStreamFilter::SinkStreamFilter(WrDiskCache* wrDiskCache, bool hashUpdate)
+ : wrDiskCache_(wrDiskCache), hashUpdate_(hashUpdate), bytesProcessed_(0)
+{
+}
-ssize_t SinkStreamFilter::transform
-(const std::shared_ptr<BinaryStream>& out,
- const std::shared_ptr<Segment>& segment,
- const unsigned char* inbuf, size_t inlen)
+ssize_t SinkStreamFilter::transform(const std::shared_ptr<BinaryStream>& out,
+ const std::shared_ptr<Segment>& segment,
+ const unsigned char* inbuf, size_t inlen)
{
size_t wlen;
- if(inlen > 0) {
- if(segment->getLength() > 0) {
+ if (inlen > 0) {
+ if (segment->getLength() > 0) {
// We must not write data larger than available space in
// segment.
assert(segment->getLength() >= segment->getWrittenLength());
- size_t lenAvail = segment->getLength()-segment->getWrittenLength();
+ size_t lenAvail = segment->getLength() - segment->getWrittenLength();
wlen = std::min(inlen, lenAvail);
- } else {
+ }
+ else {
wlen = inlen;
}
const std::shared_ptr<Piece>& piece = segment->getPiece();
- if(piece->getWrDiskCacheEntry()) {
+ if (piece->getWrDiskCacheEntry()) {
assert(wrDiskCache_);
// If we receive small data (e.g., 1 or 2 bytes), cache entry
// becomes a headache. To mitigate this problem, we allocate
// cache buffer at least 4KiB and append the data to the
// contagious cache data.
- size_t alen = piece->appendWrCache(wrDiskCache_,
- segment->getPositionToWrite(),
- inbuf, wlen);
- if(alen < wlen) {
+ size_t alen = piece->appendWrCache(
+ wrDiskCache_, segment->getPositionToWrite(), inbuf, wlen);
+ if (alen < wlen) {
size_t len = wlen - alen;
size_t capacity = std::max(len, static_cast<size_t>(4_k));
auto dataCopy = new unsigned char[capacity];
@@ -85,14 +84,16 @@ ssize_t SinkStreamFilter::transform
piece->updateWrCache(wrDiskCache_, dataCopy, 0, len, capacity,
segment->getPositionToWrite() + alen);
}
- } else {
+ }
+ else {
out->writeData(inbuf, wlen, segment->getPositionToWrite());
}
- if(hashUpdate_) {
+ if (hashUpdate_) {
segment->updateHash(segment->getWrittenLength(), inbuf, wlen);
}
segment->updateWrittenLength(wlen);
- } else {
+ }
+ else {
wlen = 0;
}
bytesProcessed_ = wlen;