METHOD_0 ( ) { METHOD_1 ( false ) ; final org . apache . kafka . streams . processor . IDENT_0 IDENT_1 = new org . apache . kafka . streams . processor . METHOD_2 ( 0 , 0 ) ; "<AssertPlaceHolder>" ; } METHOD_3 ( org . apache . kafka . streams . processor . METHOD_2 ) { if ( ! ( IDENT_2 ) ) { return true ; } final java . io . File IDENT_3 ; final org . apache . kafka . streams . processor . IDENT_4 . IDENT_5 . IDENT_6 IDENT_7 = IDENT_8 . get ( IDENT_1 ) ; if ( ( IDENT_7 != null ) && ( IDENT_7 . IDENT_9 . equals ( java . lang . Thread . METHOD_4 ( ) . getName ( ) ) ) ) { org . apache . kafka . streams . processor . IDENT_4 . IDENT_5 . log . trace ( STRING_0 , METHOD_5 ( ) , IDENT_1 ) ; return true ; } else if ( IDENT_7 != null ) { return false ; } try { IDENT_3 = new java . io . File ( METHOD_6 ( IDENT_1 ) , org . apache . kafka . streams . processor . IDENT_4 . IDENT_5 . IDENT_10 ) ; } catch ( final org . apache . kafka . streams . errors . IDENT_11 e ) { return false ; } final java . nio . IDENT_12 . IDENT_13 channel ; try { channel = METHOD_7 ( IDENT_1 , IDENT_3 . METHOD_8 ( ) ) ; } catch ( final java . nio . file . IDENT_14 e ) { return false ; } final java . nio . IDENT_12 . IDENT_15 METHOD_3 = METHOD_9 ( channel ) ; if ( METHOD_3 != null ) { IDENT_8 . put ( IDENT_1 , new org . apache . kafka . streams . processor . IDENT_4 . IDENT_5 . METHOD_10 ( java . lang . Thread . METHOD_4 ( ) . getName ( ) , METHOD_3 ) ) ; org . apache . kafka . streams . processor . IDENT_4 . IDENT_5 . log . debug ( STRING_1 , METHOD_5 ( ) , IDENT_1 ) ; } return METHOD_3 != null ; }
org . junit . Assert . assertTrue ( directory . METHOD_3 ( IDENT_1 ) )