METHOD_0 ( ) { org . IDENT_0 . api . IDENT_1 IDENT_2 = IDENT_0 . METHOD_1 ( STRING_0 ) . METHOD_2 ( ) ; "<AssertPlaceHolder>" ; final java . util . concurrent . atomic . IDENT_3 IDENT_4 = new java . util . concurrent . atomic . METHOD_3 ( ) ; java . lang . Thread IDENT_5 = new java . lang . Thread ( ( ) -> { org . IDENT_0 . api . IDENT_1 IDENT_6 = org . IDENT_0 . IDENT_0 . METHOD_1 ( STRING_0 ) . METHOD_4 ( ) ; METHOD_4 . METHOD_5 ( ) ; IDENT_4 . METHOD_6 ( ) ; } ) ; java . lang . Thread IDENT_7 = new java . lang . Thread ( ( ) -> { org . IDENT_0 . api . IDENT_1 METHOD_4 = org . IDENT_0 . IDENT_0 . METHOD_1 ( STRING_0 ) . METHOD_4 ( ) ; METHOD_4 . METHOD_5 ( ) ; IDENT_4 . METHOD_6 ( ) ; } ) ; IDENT_5 . start ( ) ; IDENT_7 . start ( ) ; METHOD_7 ( ) . METHOD_8 ( INT_0 , TimeUnit . IDENT_8 ) . METHOD_9 ( ( ) -> ( IDENT_4 . get ( ) ) == 2 ) ; } METHOD_10 ( long , long , java . util . concurrent . TimeUnit ) { long IDENT_9 = - 1 ; if ( IDENT_10 != ( - 1 ) ) { IDENT_9 = ( unit . METHOD_11 ( IDENT_11 ) ) * 2 ; } long time = java . lang . System . currentTimeMillis ( ) ; long IDENT_12 = - 1 ; if ( IDENT_11 != ( - 1 ) ) { IDENT_12 = unit . METHOD_11 ( IDENT_11 ) ; } long IDENT_13 = METHOD_12 ( IDENT_12 ) ; int IDENT_14 = METHOD_13 ( ) ; java . util . List < org . IDENT_0 . api . IDENT_1 > IDENT_15 = new java . util . ArrayList ( IDENT_16 . size ( ) ) ; for ( java . util . IDENT_17 < org . IDENT_0 . api . IDENT_1 > iterator = IDENT_16 . METHOD_14 ( ) ; iterator . hasNext ( ) ; ) { org . IDENT_0 . api . IDENT_1 METHOD_5 = iterator . next ( ) ; boolean IDENT_18 ; try { if ( ( IDENT_11 == ( - 1 ) ) && ( IDENT_10 == ( - 1 ) ) ) { IDENT_18 = METHOD_5 . METHOD_10 ( ) ; } else { long IDENT_19 = java . lang . Math . min ( IDENT_13 , IDENT_12 ) ; IDENT_18 = METHOD_5 . METHOD_10 ( IDENT_19 , IDENT_9 , TimeUnit . IDENT_20 ) ; } } catch ( org . IDENT_0 . client . IDENT_21 e ) { METHOD_15 ( java . util . Arrays . asList ( METHOD_5 ) ) ; IDENT_18 = false ; } catch ( java . lang . Exception e ) { IDENT_18 = false ; } if ( IDENT_18 ) { IDENT_15 . add ( METHOD_5 ) ; } else { if ( ( ( IDENT_16 . size ( ) ) - ( IDENT_15 . size ( ) ) ) == ( METHOD_13 ( ) ) ) { break ; } if ( METHOD_13 == 0 ) { METHOD_15 ( IDENT_15 ) ; if ( ( IDENT_11 == ( - 1 ) ) && ( IDENT_10 == ( - 1 ) ) ) { return false ; } METHOD_13 = METHOD_13 ( ) ; IDENT_15 . METHOD_16 ( ) ; while ( iterator . METHOD_17 ( ) ) { iterator . METHOD_18 ( ) ; } } else { METHOD_13 OP_0 ; } } if ( IDENT_12 != ( - 1 ) ) { IDENT_12 OP_1 ( java . lang . System . currentTimeMillis ( ) ) - time ; time = java . lang . System . currentTimeMillis ( ) ; if ( IDENT_12 <= 0 ) { METHOD_15 ( IDENT_15 ) ; return false ; } } } if ( IDENT_10 != ( - 1 ) ) { java . util . List < org . IDENT_0 . api . IDENT_22 < java . lang . Boolean > > IDENT_23 = new java . util . ArrayList ( IDENT_15 . size ( ) ) ; for ( org . IDENT_0 . api . IDENT_1 IDENT_24 : IDENT_15 ) { org . IDENT_0 . api . IDENT_22 < java . lang . Boolean > future = ( ( org . IDENT_0 . IDENT_25 ) ( IDENT_24 ) ) . METHOD_19 ( unit . METHOD_11 ( IDENT_10 ) , TimeUnit . IDENT_20 ) ; IDENT_23 . add ( future ) ; } for ( org . IDENT_0 . api . IDENT_22 < java . lang . Boolean > IDENT_26 : IDENT_23 ) { IDENT_26 . METHOD_20 ( ) ; } } return true ; }
org . junit . Assert . assertTrue ( METHOD_2 . METHOD_10 ( 1 , 10 , TimeUnit . IDENT_8 ) )