Method decompress

java/org/brotli/wrapper/dec/Decoder.java:143–190

Decodes the given data buffer starting at offset till length.

(byte[] data, int offset, int length)

  /** Decodes the given data buffer starting at offset till length. */
  public static byte[] decompress(byte[] data, int offset, int length) throws IOException {
    ArrayList<byte[]> output = new ArrayList<>();
    int totalOutputSize = 0;
    DecoderJNI.Wrapper decoder = new DecoderJNI.Wrapper(length);
    try {
      decoder.getInputBuffer().put(data, offset, length);
      decoder.push(length);
      while (decoder.getStatus() != DecoderJNI.Status.DONE) {
        switch (decoder.getStatus()) {
          case OK:
            decoder.push(0);
            break;

          case NEEDS_MORE_OUTPUT:
            ByteBuffer buffer = decoder.pull();
            byte[] chunk = new byte[buffer.remaining()];
            buffer.get(chunk);
            output.add(chunk);
            totalOutputSize += chunk.length;
            break;

          case NEEDS_MORE_INPUT:
            // Give decoder a chance to process the remaining of the buffered byte.
            decoder.push(0);
            // If decoder still needs input, this means that stream is truncated.
            if (decoder.getStatus() == DecoderJNI.Status.NEEDS_MORE_INPUT) {
              throw new IOException("corrupted input");
            }
            break;

          default:
            throw new IOException("corrupted input");
        }
      }
    } finally {
      decoder.destroy();
    }
    if (output.size() == 1) {
      return output.get(0);
    }
    byte[] result = new byte[totalOutputSize];
    int resultOffset = 0;
    for (byte[] chunk : output) {
      System.arraycopy(chunk, 0, result, resultOffset, chunk.length);
      resultOffset += chunk.length;
    }
    return result;
  }

  /** Decodes the given data buffer. */
  public static byte[] decompress(byte[] data) throws IOException {