Method compressInternal

c++/src/Compression.cc:226–251

  }

  void CompressionStream::compressInternal() {
    if (rawInputBuffer.size() != 0) {
      ensureHeader();

      uint64_t preSize = getSize();
      uint64_t totalCompressedSize = doStreamingCompression();
      if (totalCompressedSize >= static_cast<unsigned long>(rawInputBuffer.size())) {
        writeHeader(static_cast<size_t>(rawInputBuffer.size()), true);
        // reset output buffer
        outputBuffer = nullptr;
        outputPosition = outputSize = 0;
        uint64_t backup = getSize() - preSize;
        BufferedOutputStream::BackUp(static_cast<int>(backup));

        // copy raw input buffer into block buffer
        uint64_t blockNumber = rawInputBuffer.getBlockNumber();
        for (uint64_t i = 0; i < blockNumber; ++i) {
          auto block = rawInputBuffer.getBlock(i);
          writeData(reinterpret_cast<const unsigned char*>(block.data), block.size);
        }
      } else {
        writeHeader(totalCompressedSize, false);
      }
      rawInputBuffer.resize(0);
    }
  }

  bool CompressionStream::Next(void** data, int* size) {
    if (rawInputBuffer.size() > compressionBlockSize) {