import org.apache.hadoop.fi.FiHFlushTestUtil; //导入依赖的package包/类
/** Methods initializes a test and sets required actions to be used later by
 * an injected advice
 * @param conf mini cluster configuration
 * @param methodName String representation of a test method invoking this 
 * method
 * @param block_size needed size of file's block
 * @param a is an action to be set for the set
 * @throws IOException in case of any errors
 */
private static void runDiskErrorTest (final Configuration conf, 
    final String methodName, final int block_size, DerrAction a, int index,
    boolean trueVerification)
    throws IOException {
  FiTestUtil.LOG.info("Running " + methodName + " ...");
  final HFlushTest hft = (HFlushTest) FiHFlushTestUtil.initTest();
  hft.fiCallHFlush.set(a);
  hft.fiErrorOnCallHFlush.set(new DataTransferTestUtil.VerificationAction(methodName, index));
  TestHFlush.doTheJob(conf, methodName, block_size, (short)3);
  if (trueVerification)
    assertTrue("Some of expected conditions weren't detected", hft.isSuccess());
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil; //导入依赖的package包/类
/**
 * Methods initializes a test and sets required actions to be used later by
 * an injected advice
 *
 * @param conf
 *     mini cluster configuration
 * @param methodName
 *     String representation of a test method invoking this
 *     method
 * @param block_size
 *     needed size of file's block
 * @param a
 *     is an action to be set for the set
 * @throws IOException
 *     in case of any errors
 */
private static void runDiskErrorTest(final Configuration conf,
    final String methodName, final int block_size, DerrAction a, int index,
    boolean trueVerification) throws IOException {
  FiTestUtil.LOG.info("Running " + methodName + " ...");
  final HFlushTest hft = (HFlushTest) FiHFlushTestUtil.initTest();
  hft.fiCallHFlush.set(a);
  hft.fiErrorOnCallHFlush
      .set(new DataTransferTestUtil.VerificationAction(methodName, index));
  TestHFlush.doTheJob(conf, methodName, block_size, (short) 3);
  if (trueVerification) {
    assertTrue("Some of expected conditions weren't detected",
        hft.isSuccess());
  }
}