METHOD_0 ( ) { org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_2 IDENT_3 = mock ( org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_2 . class ) ; int IDENT_4 = INT_0 ; org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_5 pool = METHOD_1 ( new org . IDENT_0 . IDENT_1 . elasticsearch . METHOD_2 ( org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_6 . IDENT_7 , org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_6 . IDENT_8 , IDENT_3 , 100 , false , org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_6 . IDENT_9 , 0 , org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_6 . IDENT_10 ) ) ; final java . util . concurrent . atomic . IDENT_11 IDENT_12 = new java . util . concurrent . atomic . METHOD_3 ( ) ; when ( IDENT_3 . METHOD_4 ( eq ( pool ) ) ) . METHOD_5 ( new org . mockito . IDENT_13 . IDENT_14 < java . lang . Boolean > ( ) { MOD_0 java . util . concurrent . atomic . METHOD_3 IDENT_15 = new java . util . concurrent . atomic . METHOD_3 ( IDENT_4 ) ; MOD_0 java . util . IDENT_16 random = new java . util . METHOD_6 ( ) ; @ org . IDENT_0 . IDENT_1 . elasticsearch . Override public org . IDENT_0 . IDENT_1 . elasticsearch . Boolean METHOD_7 ( org . mockito . IDENT_17 . IDENT_18 IDENT_17 ) throws org . IDENT_0 . IDENT_1 . elasticsearch . IDENT_19 { java . lang . Thread . sleep ( ( ( random . METHOD_8 ( 10 ) ) + 10 ) ) ; if ( ( IDENT_15 . METHOD_9 ( ) ) <= 0 ) { pool . METHOD_10 ( 2 ) ; return true ; } IDENT_12 . METHOD_11 ( ) ; return true ; } } ) ; java . util . concurrent . IDENT_20 start = new java . util . concurrent . METHOD_12 ( 1 ) ; java . util . concurrent . METHOD_12 end = new java . util . concurrent . METHOD_12 ( 10 ) ; for ( int IDENT_21 = 0 ; IDENT_21 < 10 ; IDENT_21 ++ ) { new java . lang . Thread ( ( ) -> { try { start . METHOD_13 ( ) ; pool . METHOD_14 ( ) ; } catch ( e ) { System . out . println ( org . IDENT_0 . IDENT_1 . elasticsearch . e . getMessage ( ) ) ; org . junit . Assert . fail ( ) ; } catch ( e ) { org . junit . Assert . fail ( ) ; } finally { end . METHOD_15 ( ) ; } } ) . start ( ) ; } java . lang . Thread . sleep ( 100 ) ; start . METHOD_15 ( ) ; end . METHOD_13 ( ) ; "<AssertPlaceHolder>" ; } start ( ) { METHOD_16 ( ) ; super . start ( ) ; }
org . junit . Assert . assertEquals ( IDENT_4 , IDENT_12 . get ( ) )