METHOD_0 ( ) { obj = new org . pentaho . di . repository . IDENT_0 . METHOD_1 ( ) ; obj . METHOD_2 ( ) ; final java . util . concurrent . IDENT_1 factory = new java . util . concurrent . METHOD_3 ( ) { MOD_0 final java . util . concurrent . atomic . IDENT_2 IDENT_3 = new java . util . concurrent . atomic . METHOD_4 ( 0 ) ; public org . pentaho . di . repository . IDENT_0 . Thread METHOD_5 ( java . lang . IDENT_4 r ) { final java . lang . Thread t = java . util . concurrent . IDENT_5 . METHOD_6 ( ) . METHOD_5 ( r ) ; t . METHOD_7 ( true ) ; t . setName ( ( ( STRING_0 + STRING_1 ) + ( IDENT_3 . METHOD_8 ( ) ) ) ) ; return t ; } } ; final java . util . concurrent . IDENT_6 exec = java . util . concurrent . IDENT_5 . METHOD_9 ( IDENT_7 , factory ) ; java . util . Map < java . util . concurrent . IDENT_8 , org . pentaho . di . repository . IDENT_0 . METHOD_1 . IDENT_9 > IDENT_10 = new java . util . concurrent . IDENT_11 < java . util . concurrent . IDENT_8 , org . pentaho . di . repository . IDENT_0 . METHOD_1 . IDENT_9 > ( ) ; for ( int i = 0 ; i < ( IDENT_12 ) ; i ++ ) { org . pentaho . di . repository . IDENT_0 . METHOD_1 . IDENT_9 IDENT_13 = new org . pentaho . di . repository . IDENT_0 . METHOD_1 . METHOD_10 ( i ) ; IDENT_10 . put ( exec . METHOD_11 ( IDENT_13 ) , IDENT_13 ) ; } try { exec . METHOD_12 ( ) ; exec . METHOD_13 ( IDENT_14 , TimeUnit . IDENT_15 ) ; java . util . concurrent . atomic . IDENT_16 IDENT_17 = new java . util . concurrent . atomic . METHOD_14 ( true ) ; IDENT_10 . entrySet ( ) . METHOD_15 ( ( entry ) -> { try { entry . getKey ( ) . get ( ) ; } catch ( e ) { IDENT_17 . set ( false ) ; fail ( STRING_2 ) ; org . pentaho . di . repository . IDENT_0 . e . printStackTrace ( ) ; } catch ( e ) { IDENT_17 . set ( false ) ; fail ( STRING_3 ) ; org . pentaho . di . repository . IDENT_0 . e . printStackTrace ( ) ; } if ( ! ( entry . getValue ( ) . IDENT_17 ) ) { IDENT_17 . set ( false ) ; entry . getValue ( ) . t . printStackTrace ( ) ; } } ) ; "<AssertPlaceHolder>" ; } catch ( java . lang . IDENT_18 e ) { org . junit . Assert . fail ( STRING_4 ) ; } } get ( ) { if ( org . pentaho . di . core . util . Utils . isEmpty ( IDENT_19 . METHOD_16 ( STRING_5 ) ) ) { log . METHOD_17 ( STRING_6 ) ; return IDENT_20 . get ( ) ; } org . pentaho . di . core . IDENT_21 . IDENT_22 IDENT_21 = new org . pentaho . di . core . IDENT_21 . METHOD_18 ( ) ; IDENT_21 . METHOD_19 ( null ) ; java . lang . String protocol = IDENT_19 . METHOD_16 ( STRING_7 ) ; java . lang . String host = IDENT_19 . METHOD_16 ( STRING_8 ) ; java . lang . String port = IDENT_19 . METHOD_16 ( STRING_9 ) ; boolean IDENT_23 = ( STRING_10 . equalsIgnoreCase ( protocol ) ) || ( STRING_11 . equalsIgnoreCase ( protocol ) ) ; return new org . pentaho . di . IDENT_24 . IDENT_25 . IDENT_26 . METHOD_20 ( IDENT_19 , host , port , IDENT_23 ) ; }
org . junit . Assert . assertTrue ( IDENT_17 . get ( ) )