diff options
Diffstat (limited to 'src/GZipDecodingStreamFilter.cc')
| -rw-r--r-- | src/GZipDecodingStreamFilter.cc | 53 |
1 files changed, 24 insertions, 29 deletions
diff --git a/src/GZipDecodingStreamFilter.cc b/src/GZipDecodingStreamFilter.cc index ac8f5a4a..2895403e 100644 --- a/src/GZipDecodingStreamFilter.cc +++ b/src/GZipDecodingStreamFilter.cc @@ -43,19 +43,17 @@ namespace aria2 { const std::string GZipDecodingStreamFilter::NAME("GZipDecodingStreamFilter"); -GZipDecodingStreamFilter::GZipDecodingStreamFilter -(std::unique_ptr<StreamFilter> delegate) - : StreamFilter{std::move(delegate)}, - strm_{nullptr}, - finished_{false}, - bytesProcessed_{0} -{} - -GZipDecodingStreamFilter::~GZipDecodingStreamFilter() +GZipDecodingStreamFilter::GZipDecodingStreamFilter( + std::unique_ptr<StreamFilter> delegate) + : StreamFilter{std::move(delegate)}, + strm_{nullptr}, + finished_{false}, + bytesProcessed_{0} { - release(); } +GZipDecodingStreamFilter::~GZipDecodingStreamFilter() { release(); } + void GZipDecodingStreamFilter::init() { finished_ = false; @@ -68,28 +66,28 @@ void GZipDecodingStreamFilter::init() strm_->next_in = Z_NULL; // initalize z_stream with gzip/zlib format auto detection enabled. - if(Z_OK != inflateInit2(strm_, 47)) { + if (Z_OK != inflateInit2(strm_, 47)) { throw DL_ABORT_EX("Initializing z_stream failed."); } } void GZipDecodingStreamFilter::release() { - if(strm_) { + if (strm_) { inflateEnd(strm_); delete strm_; strm_ = nullptr; } } -ssize_t GZipDecodingStreamFilter::transform -(const std::shared_ptr<BinaryStream>& out, - const std::shared_ptr<Segment>& segment, - const unsigned char* inbuf, size_t inlen) +ssize_t +GZipDecodingStreamFilter::transform(const std::shared_ptr<BinaryStream>& out, + const std::shared_ptr<Segment>& segment, + const unsigned char* inbuf, size_t inlen) { bytesProcessed_ = 0; ssize_t outlen = 0; - if(inlen == 0) { + if (inlen == 0) { return outlen; } @@ -97,28 +95,28 @@ ssize_t GZipDecodingStreamFilter::transform strm_->next_in = const_cast<unsigned char*>(inbuf); unsigned char outbuf[OUTBUF_LENGTH]; - while(1) { + while (1) { strm_->avail_out = OUTBUF_LENGTH; strm_->next_out = outbuf; int ret = ::inflate(strm_, Z_NO_FLUSH); - if(ret == Z_STREAM_END) { + if (ret == Z_STREAM_END) { finished_ = true; - } else if(ret != Z_OK && ret != Z_BUF_ERROR) { - throw DL_ABORT_EX(fmt("libz::inflate() failed. cause:%s", - strm_->msg)); + } + else if (ret != Z_OK && ret != Z_BUF_ERROR) { + throw DL_ABORT_EX(fmt("libz::inflate() failed. cause:%s", strm_->msg)); } - size_t produced = OUTBUF_LENGTH-strm_->avail_out; + size_t produced = OUTBUF_LENGTH - strm_->avail_out; outlen += getDelegate()->transform(out, segment, outbuf, produced); - if(strm_->avail_out > 0) { + if (strm_->avail_out > 0) { break; } } assert(inlen >= strm_->avail_in); - bytesProcessed_ = inlen-strm_->avail_in; + bytesProcessed_ = inlen - strm_->avail_in; return outlen; } @@ -127,9 +125,6 @@ bool GZipDecodingStreamFilter::finished() return finished_ && getDelegate()->finished(); } -const std::string& GZipDecodingStreamFilter::getName() const -{ - return NAME; -} +const std::string& GZipDecodingStreamFilter::getName() const { return NAME; } } // namespace aria2 |
