import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
/**
 *  Create a OomAction with a CountdownConstraint
 *  so that it throws OutOfMemoryError if the count is zero.
 */
public static ConstraintSatisfactionAction<DatanodeID, IOException>
    createCountdownOomAction(
      String currentTest, int i, int count) {
  return new ConstraintSatisfactionAction<DatanodeID, IOException>(
      new OomAction(currentTest, i), new CountdownConstraint(count));
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
/**
 *  Create a DoosAction with a CountdownConstraint
 *  so that it throws DiskOutOfSpaceException if the count is zero.
 */
public static ConstraintSatisfactionAction<DatanodeID, IOException>
  createCountdownDoosAction(
    String currentTest, int i, int count) {
  return new ConstraintSatisfactionAction<DatanodeID, IOException>(
      new DoosAction(currentTest, i), new CountdownConstraint(count));
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
private static void runPipelineCloseAck(String name, int i, DataNodeAction a
    ) throws IOException {
  FiTestUtil.LOG.info("Running " + name + " ...");
  final DataTransferTest t = (DataTransferTest)DataTransferTestUtil.initTest();
  final MarkerConstraint marker = new MarkerConstraint(name);
  t.fiPipelineClose.set(new DatanodeMarkingAction(name, i, marker));
  t.fiPipelineAck.set(new ConstraintSatisfactionAction<DatanodeID, IOException>(a, marker));
  TestFiDataTransferProtocol.write1byte(name);
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
/**
 * Create a SleepAction with a CountdownConstraint
 * for datanode i in the pipeline.
 * When the count is zero,
 * sleep some period of time so that it slows down the datanode
 * or sleep forever so the that datanode becomes not responding.
 */
public static ConstraintSatisfactionAction<DatanodeID, IOException> createCountdownSleepAction(
    String currentTest, int i, long minDuration, long maxDuration,
    int count) {
  return new ConstraintSatisfactionAction<DatanodeID, IOException>(
      new SleepAction(currentTest, i, minDuration, maxDuration),
      new CountdownConstraint(count));
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
private static void runPipelineCloseAck(String name, int i, DataNodeAction a)
    throws IOException {
  FiTestUtil.LOG.info("Running " + name + " ...");
  final DataTransferTest t =
      (DataTransferTest) DataTransferTestUtil.initTest();
  final MarkerConstraint marker = new MarkerConstraint(name);
  t.fiPipelineClose.set(new DatanodeMarkingAction(name, i, marker));
  t.fiPipelineAck.set(
      new ConstraintSatisfactionAction<DatanodeID, IOException>(a, marker));
  TestFiDataTransferProtocol.write1byte(name);
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
private static void runPipelineCloseAck(String name, int i, DataNodeAction a
    ) throws IOException {
  FiTestUtil.LOG.info("Running " + name + " ...");
  final DataTransferTest t = (DataTransferTest)DataTransferTestUtil.initTest();
  final MarkerConstraint marker = new MarkerConstraint(name);
  t.fiPipelineClose.set(new DatanodeMarkingAction(name, i, marker));
  t.fiPipelineAck.set(new ConstraintSatisfactionAction<DatanodeID, IOException>(a, marker));
  write1byte(name);
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
/**
 * Same as
 * createCountdownSleepAction(currentTest, i, duration, duration+1, count).
 */
public static ConstraintSatisfactionAction<DatanodeID, IOException> createCountdownSleepAction(
    String currentTest, int i, long duration, int count) {
  return createCountdownSleepAction(currentTest, i, duration, duration+1,
      count);
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
/**
 * Create a OomAction with a CountdownConstraint
 * so that it throws OutOfMemoryError if the count is zero.
 */
public static ConstraintSatisfactionAction<DatanodeID, IOException> createCountdownOomAction(
    String currentTest, int i, int count) {
  return new ConstraintSatisfactionAction<DatanodeID, IOException>(
      new OomAction(currentTest, i), new CountdownConstraint(count));
}
 

import org.apache.hadoop.fi.FiTestUtil.ConstraintSatisfactionAction; //导入依赖的package包/类
/**
 * Create a DoosAction with a CountdownConstraint
 * so that it throws DiskOutOfSpaceException if the count is zero.
 */
public static ConstraintSatisfactionAction<DatanodeID, IOException> createCountdownDoosAction(
    String currentTest, int i, int count) {
  return new ConstraintSatisfactionAction<DatanodeID, IOException>(
      new DoosAction(currentTest, i), new CountdownConstraint(count));
}