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