streaming : client writes several packets with dn1 very slow . client finishes write successfully . concode_field_sep byte[] toRead concode_elem_sep short REPLICATION concode_elem_sep long BLOCKSIZE concode_elem_sep int PACKET_SIZE concode_elem_sep Configuration conf concode_elem_sep int MIN_N_PACKET concode_elem_sep int MAX_N_PACKET concode_elem_sep byte[] bytes concode_elem_sep int MAX_SLEEP concode_field_sep void pipeline_Fi_17 concode_elem_sep void runTest17_19 concode_elem_sep void runTest34_35 concode_elem_sep void pipeline_Fi_18 concode_elem_sep void pipeline_Fi_29 concode_elem_sep void pipeline_Fi_19 concode_elem_sep void pipeline_Fi_34 concode_elem_sep void pipeline_Fi_35 concode_elem_sep void runTest29_30 concode_elem_sep FSDataOutputStream createFile concode_elem_sep void pipeline_Fi_30 concode_elem_sep void pipeline_Fi_20 concode_elem_sep void writeSeveralPackets concode_elem_sep void pipeline_Fi_22 concode_elem_sep void initSlowDatanodeTest
void function ( ) { final String loc0 = FiTestUtil . getMethodName ( ) ; FiTestUtil . LOG . info ( "srini_string" + loc0 + "srini_string" ) ; final DataTransferTest loc1 = ( DataTransferTest ) DataTransferTestUtil . initTest ( ) ; initSlowDatanodeTest ( loc1 , new SleepAction ( loc0 , 1 , MAX_SLEEP ) ) ; writeSeveralPackets ( loc0 ) ; }