summaryrefslogtreecommitdiff
path: root/src/GZipDecodingStreamFilter.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/GZipDecodingStreamFilter.cc')
-rw-r--r--src/GZipDecodingStreamFilter.cc53
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