Merge af4d3d8 into 74966a9

Author: dorooleg

ydb/library/yql/providers/s3/compressors/brotli.cpp

@@ -42,6 +42,7 @@ bool TReadBuffer::nextImpl() {
     do {
         if (InputAvailable_ == 0 && !InputExhausted_) {
             InputAvailable_ = Source_.read(reinterpret_cast<char*>(InBuffer.data()), InBuffer.size());
+            InputSize_ = InputAvailable_;
             if (InputAvailable_ == 0) {
                 InputExhausted_ = true;
             }
@@ -52,8 +53,8 @@ bool TReadBuffer::nextImpl() {
             InitDecoder();
         }
 
-        auto inBuffer = const_cast<const unsigned char*>(reinterpret_cast<unsigned char*>(InBuffer.data()));
-        auto outBuffer = reinterpret_cast<unsigned char*>(OutBuffer.data());
+        auto inBuffer = const_cast<const unsigned char*>(reinterpret_cast<unsigned char*>(InBuffer.data()) + (InputSize_ - InputAvailable_));
+        auto outBuffer = reinterpret_cast<unsigned char*>(OutBuffer.data()) + (OutBuffer.size() - availableOut);
 
         SubstreamFinished_ = false;
         result = BrotliDecoderDecompressStream(

ydb/library/yql/providers/s3/compressors/brotli.h

@@ -23,6 +23,7 @@ class TReadBuffer : public NDB::ReadBuffer {
     bool SubstreamFinished_ = false;
     bool InputExhausted_ = false;
     size_t InputAvailable_ = 0;
+    size_t InputSize_ = 0;
 
     void InitDecoder();
     void FreeDecoder();