public class CompressedInputStream extends InputStream
<BUG>{
private final CompressionInfo info;</BUG>
private final BlockingQueue<byte[]> dataBuffer;
<BUG>private final byte[] buffer;
protected long bufferOffset = 0;</BUG>
private long current = 0;
protected int validBufferBytes = -1;
private final Checksum checksum;
private final byte[] checksumBytes = new byte[4];

public class CompressedInputStream extends InputStream
{
private static final Logger logger = LoggerFactory.getLogger(CompressedInputStream.class);
private final CompressionInfo info;
private final BlockingQueue<byte[]> dataBuffer;
private byte[] buffer;
protected long bufferOffset = 0;
private long current = 0;
protected int validBufferBytes = -1;
private final Checksum checksum;
private final byte[] checksumBytes = new byte[4];
