public synchronized void setInput()

in src/main/java/com/hadoop/compression/lzo/LzoDecompressor.java [203:230]

• 23 lines of code
• 5 McCabe index (conditional complexity)

  public synchronized void setInput(byte[] b, int off, int len) {
    if (!isCurrentBlockUncompressed()) {
      if (len > directBufferSize) {
        LOG.warn("Decompression will fail because compressed buffer size :" +
          len + " is greater than this decompressor's directBufferSize: " + 
          directBufferSize + ". To fix this, increase the value of your " + 
          "configuration's io.compression.codec.lzo.buffersize to be larger " +
          "than: " + len + ".");
      }
    }

    if (b == null) {
      throw new NullPointerException();
    }
    if (off < 0 || len < 0 || off > b.length - len) {
      throw new ArrayIndexOutOfBoundsException();
    }

    this.userBuf = b;
    this.userBufOff = off;
    this.userBufLen = len;

    setInputFromSavedData();

    // Reinitialize lzo's output direct-buffer 
    uncompressedDirectBuf.limit(directBufferSize);
    uncompressedDirectBuf.position(directBufferSize);
  }