203204205206207208209
* Client finishes setup successfully. */ @Test public void pipeline_Fi_07() throws IOException { final String methodName = FiTestUtil.getMethodName(); runSlowDatanodeTest(methodName, new SleepAction(methodName, 1, 3000)); }
213214215216217218219
* Client finishes setup successfully. */ @Test public void pipeline_Fi_08() throws IOException { final String methodName = FiTestUtil.getMethodName(); runSlowDatanodeTest(methodName, new SleepAction(methodName, 2, 3000)); }
314315316317318319320
t.fiPipelineClose.set(a); write1byte(methodName); } private static void run41_43(String name, int i) throws IOException { runPipelineCloseTest(name, new SleepAction(name, i, 3000)); }
328329330331332333334
t.fiPipelineAck.set(new ConstraintSatisfactionAction<DatanodeID, IOException>(a, marker)); write1byte(name); } private static void run39_40(String name, int i) throws IOException { runPipelineCloseAck(name, i, new SleepAction(name, i, 0)); }