in src/main/java/com/hadoop/compression/lzo/LzopDecompressor.java [129:136]
public synchronized int decompress(byte[] b, int off, int len)
throws IOException {
int ret = super.decompress(b, off, len);
if (ret > 0) {
for (Checksum chk : chkDMap.values()) chk.update(b, off, ret);
}
return ret;
}