void function ( ) { consumeConnectionBacklog ( ) ; try { fs . listFiles ( new Path ( "srini_string" ) , false ) ; fail ( "srini_string" ) ; } catch ( SocketTimeoutException loc0 ) { GenericTestUtils . assertExceptionContains ( fs . getUri ( ) . getAuthority ( ) + "srini_string" , loc0 ) ; } }
expect connect timeout , because the connection backlog is consumed . concode_field_sep int TEST_TIMEOUT concode_elem_sep int SHORT_SOCKET_TIMEOUT concode_elem_sep URLConnectionFactory connectionFactory concode_elem_sep List<SocketChannel> clients concode_elem_sep Log LOG concode_elem_sep int CONNECTION_BACKLOG concode_elem_sep ServerSocket serverSocket concode_elem_sep Thread serverThread concode_elem_sep int CLIENTS_TO_CONSUME_BACKLOG concode_elem_sep WebHdfsFileSystem fs concode_elem_sep InetSocketAddress nnHttpAddress concode_elem_sep TimeoutSource timeoutSource concode_field_sep void testAuthUrlReadTimeout concode_elem_sep void testTwoStepWriteConnectTimeout concode_elem_sep void testRedirectReadTimeout concode_elem_sep Collection<Object[]> data concode_elem_sep void testAuthUrlConnectTimeout concode_elem_sep void testRedirectConnectTimeout concode_elem_sep HttpURLConnection configure concode_elem_sep void tearDown concode_elem_sep void testReadTimeout concode_elem_sep void testTwoStepWriteReadTimeout concode_elem_sep void setUp concode_elem_sep void startSingleTemporaryRedirectResponseThread concode_elem_sep void consumeConnectionBacklog concode_elem_sep String temporaryRedirect