in src/main/java/com/hadoop/compression/lzo/LzoCompressor.java [338:342]
public boolean needsInput() { return !(compressedDirectBuf.remaining() > 0 || uncompressedDirectBuf.remaining() == 0 || userBufLen > 0); }