METHOD_0 ( ) { final java . util . concurrent . IDENT_0 < java . lang . Integer > IDENT_1 = new java . util . concurrent . METHOD_1 ( ) ; final int IDENT_2 = INT_0 * INT_1 ; final org . glassfish . IDENT_3 . impl . IDENT_4 future = org . glassfish . IDENT_3 . impl . IDENT_5 . create ( ) ; final java . util . concurrent . IDENT_6 IDENT_7 = java . util . concurrent . IDENT_8 . METHOD_2 ( 1 ) ; final java . util . concurrent . atomic . IDENT_9 IDENT_10 = new java . util . concurrent . atomic . METHOD_3 ( ) ; try { METHOD_4 ( new org . glassfish . IDENT_3 . http . server . METHOD_5 ( ) { @ org . glassfish . IDENT_3 . http . server . Override public void service ( final org . glassfish . IDENT_3 . http . server . IDENT_11 req , final org . glassfish . IDENT_3 . http . server . Response res ) throws org . glassfish . IDENT_3 . http . server . Exception { IDENT_10 . METHOD_6 ( ) ; res . METHOD_7 ( ) ; IDENT_7 . METHOD_8 ( new java . lang . METHOD_9 ( ) { @ org . glassfish . IDENT_3 . http . server . Override public void run ( ) { try { java . io . InputStream is = req . METHOD_10 ( ) ; for ( int i = 0 ; i < IDENT_2 ; i ++ ) { int c = is . read ( ) ; if ( c != ( i OP_0 INT_0 ) ) { future . METHOD_11 ( new java . lang . IllegalStateException ( ( ( ( STRING_0 + i ) + STRING_1 ) + c ) ) ) ; return ; } } res . METHOD_12 ( 200 , STRING_2 ) ; java . io . IDENT_12 IDENT_13 = res . METHOD_13 ( ) ; IDENT_13 . write ( STRING_3 . getBytes ( ) ) ; IDENT_13 . METHOD_14 ( ) ; future . result ( STRING_3 ) ; } catch ( java . lang . Exception e ) { future . METHOD_11 ( e ) ; } finally { res . METHOD_15 ( ) ; } } } ) ; } } ) ; byte [ ] content = METHOD_16 ( ( IDENT_2 * 2 ) ) ; java . util . concurrent . IDENT_14 < org . glassfish . IDENT_3 . IDENT_15 > IDENT_16 = connect ( STRING_4 , org . glassfish . IDENT_3 . http . server . IDENT_17 . IDENT_18 , IDENT_1 ) ; org . glassfish . IDENT_3 . IDENT_15 connection = IDENT_16 . get ( 10 , TimeUnit . IDENT_19 ) ; METHOD_17 ( connection , content , IDENT_1 , false ) ; future . get ( 10 , TimeUnit . IDENT_19 ) ; java . lang . Thread . sleep ( INT_2 ) ; "<AssertPlaceHolder>" ; } finally { IDENT_7 . METHOD_18 ( ) ; } } get ( ) { return IDENT_20 ; }
org . junit . Assert . assertEquals ( 1 , IDENT_10 . get ( ) )