/* * This class is an example only. A "final" version of * this class should implement the DataInput interface * and provide implementations for the methods declared in * DataInput. */ import java.io.*; public class CheckedDataInput { private Checksum cksum; private DataInput in; public CheckedDataInput(DataInput in, Checksum cksum) { this.cksum = cksum; this.in = in; } public byte readByte() throws IOException { byte b = in.readByte(); cksum.update(b); return b; } public void readFully(byte[] b) throws IOException { in.readFully(b, 0, b.length); cksum.update(b, 0, b.length); } public void readFully(byte[] b, int off, int len) throws IOException { in.readFully(b, off, len); cksum.update(b, off, len); } public Checksum getChecksum() { return cksum; } }