public synchronized boolean needsInput()

in src/main/java/com/hadoop/compression/lzo/LzoDecompressor.java [253:270]

• 13 lines of code
• 4 McCabe index (conditional complexity)

  public synchronized boolean needsInput() {
    // Consume remaining compressed data?
    if (uncompressedDirectBuf.remaining() > 0) {
      return false;
    }

    // Check if lzo has consumed all input
    if (compressedDirectBufLen <= 0) {
      // Check if we have consumed all user-input
      if (userBufLen <= 0) {
        return true;
      } else {
        setInputFromSavedData();
      }
    }

    return false;
  }