METHOD_0 ( ) { final java . util . concurrent . IDENT_0 IDENT_1 = new java . util . concurrent . METHOD_1 ( 1 ) ; final java . util . concurrent . METHOD_1 IDENT_2 = new java . util . concurrent . METHOD_1 ( 1 ) ; org . apache . flink . runtime . io . IDENT_3 . IDENT_4 . IDENT_5 IDENT_6 = mock ( org . apache . flink . runtime . io . IDENT_3 . IDENT_4 . IDENT_5 . class ) ; METHOD_2 ( new org . mockito . IDENT_7 . IDENT_8 < java . lang . IDENT_9 > ( ) { @ org . apache . flink . runtime . io . network . IDENT_10 . Override public org . apache . flink . runtime . io . network . IDENT_10 . IDENT_9 METHOD_3 ( org . mockito . IDENT_11 . IDENT_12 IDENT_11 ) throws java . lang . Throwable { IDENT_2 . METHOD_4 ( ) ; IDENT_1 . METHOD_5 ( ) ; return null ; } } ) . when ( IDENT_6 ) . close ( ) ; org . apache . flink . runtime . io . IDENT_3 . IDENT_4 . IDENT_13 IDENT_14 = mock ( org . apache . flink . runtime . io . IDENT_3 . IDENT_4 . IDENT_13 . class ) ; when ( IDENT_14 . METHOD_6 ( METHOD_7 ( IDENT_15 . IDENT_16 . class ) ) ) . thenReturn ( IDENT_6 ) ; final org . apache . flink . runtime . io . network . IDENT_10 . IDENT_17 IDENT_10 = new org . apache . flink . runtime . io . network . IDENT_10 . METHOD_8 ( 0 , mock ( org . apache . flink . runtime . io . network . IDENT_10 . IDENT_18 . class ) , IDENT_14 ) ; "<AssertPlaceHolder>" ; java . util . concurrent . IDENT_19 executor = java . util . concurrent . IDENT_20 . METHOD_9 ( ) ; java . util . concurrent . IDENT_21 < java . lang . IDENT_9 > IDENT_22 = executor . METHOD_10 ( new java . util . concurrent . IDENT_23 < java . lang . IDENT_9 > ( ) { @ org . apache . flink . runtime . io . network . IDENT_10 . Override public org . apache . flink . runtime . io . network . IDENT_10 . IDENT_9 call ( ) throws org . apache . flink . runtime . io . network . IDENT_10 . Exception { IDENT_10 . METHOD_11 ( ) ; return null ; } } ) ; IDENT_2 . METHOD_5 ( ) ; IDENT_10 . METHOD_12 ( ) ; IDENT_1 . METHOD_4 ( ) ; IDENT_22 . get ( ) ; } METHOD_12 ( ) { MOD_0 ( IDENT_24 ) { org . apache . flink . runtime . io . network . IDENT_10 . IDENT_25 view = IDENT_26 ; if ( ( view != null ) && ( ( view . getClass ( ) ) == ( org . apache . flink . runtime . io . network . IDENT_10 . IDENT_27 . class ) ) ) { org . apache . flink . runtime . io . network . IDENT_10 . IDENT_27 IDENT_28 = ( ( org . apache . flink . runtime . io . network . IDENT_10 . IDENT_27 ) ( view ) ) ; return IDENT_28 . METHOD_12 ( ) ; } else if ( ( IDENT_6 ) == null ) { IDENT_6 = IDENT_14 . METHOD_6 ( IDENT_14 . METHOD_13 ( ) ) ; int IDENT_29 = IDENT_24 . size ( ) ; long IDENT_30 = METHOD_14 ( IDENT_31 ) ; int IDENT_32 = IDENT_29 - ( IDENT_24 . size ( ) ) ; org . apache . flink . runtime . io . network . IDENT_10 . METHOD_8 . LOG . debug ( STRING_0 , parent . METHOD_15 ( ) , IDENT_30 , IDENT_32 , index , parent . METHOD_16 ( ) ) ; return IDENT_32 ; } } return 0 ; }
org . junit . Assert . assertEquals ( 0 , IDENT_10 . METHOD_12 ( ) )