import org.apache.hadoop.fs.slive.DataVerifier.VerifyOutput; //导入依赖的package包/类
@Test
public void testDataWriting() throws Exception {
  long byteAm = 100;
  File fn = getTestFile();
  DataWriter writer = new DataWriter(rnd);
  FileOutputStream fs = new FileOutputStream(fn);
  GenerateOutput ostat = writer.writeSegment(byteAm, fs);
  LOG.info(ostat);
  fs.close();
  assertTrue(ostat.getBytesWritten() == byteAm);
  DataVerifier vf = new DataVerifier();
  FileInputStream fin = new FileInputStream(fn);
  VerifyOutput vfout = vf.verifyFile(byteAm, new DataInputStream(fin));
  LOG.info(vfout);
  fin.close();
  assertEquals(vfout.getBytesRead(), byteAm);
  assertTrue(vfout.getChunksDifferent() == 0);
}
 

import org.apache.hadoop.fs.slive.DataVerifier.VerifyOutput; //导入依赖的package包/类
@Test
public void testBadChunks() throws Exception {
  File fn = getTestFile();
  int byteAm = 10000;
  FileOutputStream fout = new FileOutputStream(fn);
  byte[] bytes = new byte[byteAm];
  rnd.nextBytes(bytes);
  fout.write(bytes);
  fout.close();
  // attempt to read it
  DataVerifier vf = new DataVerifier();
  VerifyOutput vout = new VerifyOutput(0, 0, 0, 0);
  DataInputStream in = null;
  try {
    in = new DataInputStream(new FileInputStream(fn));
    vout = vf.verifyFile(byteAm, in);
  } catch (Exception e) {

  } finally {
    if(in != null) in.close();
  }
  assertTrue(vout.getChunksSame() == 0);
}