diff --git a/src/libutil/compression.cc b/src/libutil/compression.cc index c5dae42fa..7e725cae1 100644 --- a/src/libutil/compression.cc +++ b/src/libutil/compression.cc @@ -186,19 +186,11 @@ struct BrotliDecompressionSink : ChunkedCompressionSink ref decompress(const std::string & method, const std::string & in) { - if (method == "none" || method == "") - return make_ref(in); - else if (method == "br") { - StringSink ssink; - auto sink = makeDecompressionSink(method, ssink); - (*sink)(in); - sink->finish(); - return ssink.s; - } else { - StringSource ssrc(in); - auto src = makeDecompressionSource(ssrc); - return make_ref(src->drain()); - } + StringSink ssink; + auto sink = makeDecompressionSink(method, ssink); + (*sink)(in); + sink->finish(); + return ssink.s; } std::unique_ptr makeDecompressionSink(const std::string & method, Sink & nextSink) @@ -209,7 +201,7 @@ std::unique_ptr makeDecompressionSink(const std::string & method, Si return std::make_unique(nextSink); else return sourceToSink([&](Source & source) { - auto decompressionSource = makeDecompressionSource(source); + auto decompressionSource = std::make_unique(source); decompressionSource->drainInto(nextSink); }); } @@ -267,11 +259,6 @@ struct BrotliCompressionSink : ChunkedCompressionSink } }; -std::unique_ptr makeDecompressionSource(Source & prev) -{ - return std::unique_ptr(new ArchiveDecompressionSource(prev)); -} - ref makeCompressionSink(const std::string & method, Sink & nextSink, const bool parallel) { std::vector la_supports = { diff --git a/src/libutil/compression.hh b/src/libutil/compression.hh index a140f8be2..338a0d9f2 100644 --- a/src/libutil/compression.hh +++ b/src/libutil/compression.hh @@ -15,8 +15,6 @@ struct CompressionSink : BufferedSink, FinishSink using FinishSink::finish; }; -std::unique_ptr makeDecompressionSource(Source & prev); - ref decompress(const std::string & method, const std::string & in); std::unique_ptr makeDecompressionSink(const std::string & method, Sink & nextSink);