METHOD_0 ( ) { java . lang . String collection = ( com . IDENT_0 . client . test . IDENT_1 . IDENT_2 . IDENT_3 ) + STRING_0 ; java . lang . String IDENT_4 = ( STRING_0 0 + collection ) + STRING_0 3 ; "<AssertPlaceHolder>" ; com . IDENT_0 . client . IDENT_1 . IDENT_5 IDENT_6 = com . IDENT_0 . client . test . IDENT_1 . IDENT_2 . IDENT_7 . METHOD_1 ( ) ; IDENT_6 . METHOD_2 ( INT_0 ) ; IDENT_6 . METHOD_3 ( ( batch ) -> { logger . debug ( STRING_1 , batch . METHOD_4 ( ) , batch . METHOD_5 ( ) . length ) ; for ( com . IDENT_0 . client . IDENT_1 . IDENT_8 IDENT_9 : batch . METHOD_5 ( ) ) { } } ) . METHOD_6 ( ( batch , IDENT_10 ) -> { for ( com . IDENT_0 . client . IDENT_1 . IDENT_8 IDENT_9 : batch . METHOD_5 ( ) ) { } } ) ; com . IDENT_0 . client . IDENT_1 . IDENT_11 IDENT_12 = com . IDENT_0 . client . test . IDENT_1 . IDENT_2 . IDENT_7 . METHOD_7 ( IDENT_6 ) ; java . util . concurrent . atomic . IDENT_13 < java . lang . Throwable > IDENT_14 = new java . util . concurrent . atomic . METHOD_8 ( ) ; class IDENT_15 implements java . lang . IDENT_16 { @ com . IDENT_0 . client . test . IDENT_1 . Override public void run ( ) { try { for ( int j = 0 ; j < 100 ; j ++ ) { java . lang . String uri = ( ( STRING_2 + j ) + STRING_3 ) + ( java . lang . Thread . METHOD_9 ( ) . getId ( ) ) ; logger . debug ( ( STRING_4 + uri ) ) ; com . IDENT_0 . client . io . IDENT_17 meta = new com . IDENT_0 . client . io . METHOD_10 ( ) . METHOD_11 ( collection , com . IDENT_0 . client . test . IDENT_1 . IDENT_2 . IDENT_3 ) ; IDENT_6 . add ( uri , meta , new com . IDENT_0 . client . io . METHOD_12 ( "test" ) ) ; if ( j == INT_1 ) { logger . debug ( STRING_0 1 ) ; IDENT_6 . METHOD_13 ( ) ; logger . debug ( STRING_5 ) ; com . IDENT_0 . client . test . IDENT_1 . IDENT_2 . IDENT_7 . METHOD_14 ( IDENT_12 ) ; } } } catch ( java . lang . IllegalStateException e ) { if ( STRING_6 . equals ( e . getMessage ( ) ) ) { logger . debug ( ( STRING_0 4 + e ) ) ; } else { IDENT_14 . set ( e ) ; } } catch ( java . lang . Throwable e ) { IDENT_14 . set ( e ) ; } } } java . lang . Thread IDENT_18 ; java . lang . Thread IDENT_19 ; IDENT_18 = new java . lang . Thread ( new METHOD_15 ( ) ) ; IDENT_19 = new java . lang . Thread ( new METHOD_15 ( ) ) ; IDENT_18 . start ( ) ; IDENT_19 . start ( ) ; IDENT_18 . join ( ) ; IDENT_19 . join ( ) ; if ( ( IDENT_14 . get ( ) ) != null ) { throw IDENT_14 . get ( ) ; } System . out . println ( ( STRING_7 + ( com . IDENT_0 . client . test . IDENT_1 . IDENT_2 . client . METHOD_16 ( ) . METHOD_17 ( IDENT_4 ) . METHOD_18 ( ) . next ( ) . METHOD_19 ( ) . METHOD_20 ( ) ) ) ) ; } METHOD_16 ( ) { return new com . IDENT_0 . client . impl . METHOD_21 ( services , METHOD_22 ( ) ) ; }
org . junit . Assert . assertTrue ( ( ( com . IDENT_0 . client . test . IDENT_1 . IDENT_2 . client . METHOD_16 ( ) . METHOD_17 ( IDENT_4 ) . METHOD_18 ( ) . next ( ) . METHOD_19 ( ) . METHOD_20 ( ) ) == 0 ) )