import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的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.DerrAction; //导入依赖的package包/类
/** The tests calls 
 * {@link #runDiskErrorTest(Configuration, String, int, DerrAction, int, boolean)}
 * to make a number of writes across a block boundaries.
 * hflush() is called after each write() during a pipeline life time.
 * Thus, injected fault ought to be triggered for 0th datanode
 */
@Test
public void hFlushFi01_b() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  Configuration conf = new HdfsConfiguration();
  int customPerChecksumSize = 512;
  int customBlockSize = customPerChecksumSize * 3;
  conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize);
  runDiskErrorTest(conf, methodName, 
      customBlockSize, new DerrAction(methodName, 0), 0, true);
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的package包/类
/** Similar to {@link #hFlushFi01_b()} but writing happens
 * across block and checksum's boundaries
 */
@Test
public void hFlushFi01_c() throws Exception { 
  final String methodName = FiTestUtil.getMethodName();
  Configuration conf = new HdfsConfiguration();
  int customPerChecksumSize = 400;
  int customBlockSize = customPerChecksumSize * 3;
  conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize);
  runDiskErrorTest(conf, methodName, 
      customBlockSize, new DerrAction(methodName, 0), 0, true);
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的package包/类
/** Similar to {@link #hFlushFi01_a()} but for a pipeline's 1st datanode
 */
@Test
public void hFlushFi02_a() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  runDiskErrorTest(new HdfsConfiguration(), methodName,
      AppendTestUtil.BLOCK_SIZE, new DerrAction(methodName, 1), 1, false);
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的package包/类
/** Similar to {@link #hFlushFi01_b()} but for a pipeline's 1st datanode
 */
@Test
public void hFlushFi02_b() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  Configuration conf = new HdfsConfiguration();
  int customPerChecksumSize = 512;
  int customBlockSize = customPerChecksumSize * 3;
  conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize);
  runDiskErrorTest(conf, methodName,
      customBlockSize, new DerrAction(methodName, 1), 1, true);
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的package包/类
/** Similar to {@link #hFlushFi01_c()} but for a pipeline's 1st datanode
 */
@Test
public void hFlushFi02_c() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  Configuration conf = new HdfsConfiguration();
  int customPerChecksumSize = 400;
  int customBlockSize = customPerChecksumSize * 3;
  conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize);
  runDiskErrorTest(conf, methodName,
      customBlockSize, new DerrAction(methodName, 1), 1, true);
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的package包/类
/** Similar to {@link #hFlushFi01_a()} but for a pipeline's 2nd datanode
 */
@Test
public void hFlushFi03_a() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  runDiskErrorTest(new HdfsConfiguration(), methodName,
      AppendTestUtil.BLOCK_SIZE, new DerrAction(methodName, 2), 2, false);
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的package包/类
/** Similar to {@link #hFlushFi01_b()} but for a pipeline's 2nd datanode
 */
@Test
public void hFlushFi03_b() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  Configuration conf = new HdfsConfiguration();
  int customPerChecksumSize = 512;
  int customBlockSize = customPerChecksumSize * 3;
  conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize);
  runDiskErrorTest(conf, methodName,
      customBlockSize, new DerrAction(methodName, 2), 2, true);
}
 

import org.apache.hadoop.fi.FiHFlushTestUtil.DerrAction; //导入依赖的package包/类
/** Similar to {@link #hFlushFi01_c()} but for a pipeline's 2nd datanode
 */
@Test
public void hFlushFi03_c() throws IOException {
  final String methodName = FiTestUtil.getMethodName();
  Configuration conf = new HdfsConfiguration();
  int customPerChecksumSize = 400;
  int customBlockSize = customPerChecksumSize * 3;
  conf.setInt(DFSConfigKeys.DFS_BYTES_PER_CHECKSUM_KEY, customPerChecksumSize);
  conf.setLong(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, customBlockSize);
  runDiskErrorTest(conf, methodName,
      customBlockSize, new DerrAction(methodName, 2), 2, true);
}