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/SinkStreamFilter.cc | |
| parent | 4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff) | |
make clang-format using clang-format-3.6
Diffstat (limited to 'src/SinkStreamFilter.cc')
| -rw-r--r-- | src/SinkStreamFilter.cc | 41 |
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; |
