METHOD_0 ( ) { try { final java . util . IDENT_0 IDENT_1 = new java . util . METHOD_1 ( ) ; final long IDENT_2 = IDENT_1 . METHOD_2 ( ) ; final int IDENT_3 = INT_0 ; final int IDENT_4 = INT_1 ; IDENT_1 . METHOD_3 ( IDENT_2 ) ; for ( int i = 0 ; i < IDENT_3 ; i ++ ) { org . apache . flink . streaming . runtime . io . IDENT_5 . METHOD_4 ( IDENT_6 , ( ( IDENT_1 . METHOD_5 ( IDENT_7 ) ) + 1 ) , IDENT_1 . METHOD_5 ( IDENT_4 ) ) ; } IDENT_6 . position ( 0L ) ; IDENT_1 . METHOD_3 ( IDENT_2 ) ; org . apache . flink . streaming . runtime . io . IDENT_8 . IDENT_9 IDENT_10 = new org . apache . flink . streaming . runtime . io . IDENT_8 . METHOD_6 ( IDENT_11 , IDENT_6 , buffer , IDENT_7 ) ; IDENT_10 . METHOD_7 ( ) ; for ( int i = 0 ; i < IDENT_3 ; i ++ ) { org . apache . flink . streaming . runtime . io . IDENT_5 . METHOD_8 ( IDENT_10 . METHOD_9 ( ) , ( ( IDENT_1 . METHOD_5 ( IDENT_7 ) ) + 1 ) , IDENT_1 . METHOD_5 ( IDENT_4 ) ) ; } "<AssertPlaceHolder>" ; } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; org . junit . Assert . fail ( e . getMessage ( ) ) ; } } METHOD_9 ( ) { if ( ( buffer . METHOD_10 ( ) ) < ( org . apache . flink . streaming . runtime . io . IDENT_8 . METHOD_6 . IDENT_12 ) ) { buffer . METHOD_11 ( ) ; while ( ( buffer . position ( ) ) < ( org . apache . flink . streaming . runtime . io . IDENT_8 . METHOD_6 . IDENT_12 ) ) { if ( ( IDENT_6 . read ( buffer ) ) == ( - 1 ) ) { if ( ( buffer . position ( ) ) == 0 ) { return null ; } else { throw new java . io . IOException ( STRING_0 ) ; } } } buffer . METHOD_12 ( ) ; } final int channel = buffer . METHOD_13 ( ) ; final int length = buffer . METHOD_13 ( ) ; final boolean IDENT_13 = ( buffer . get ( ) ) == 0 ; if ( IDENT_13 ) { if ( length > ( IDENT_7 ) ) { throw new java . io . IOException ( java . lang . String . format ( STRING_1 , length , IDENT_7 ) ) ; } org . apache . flink . core . IDENT_14 . IDENT_15 IDENT_16 = org . apache . flink . core . IDENT_14 . IDENT_17 . METHOD_14 ( IDENT_7 ) ; int IDENT_18 = 0 ; int IDENT_19 = length ; while ( true ) { int IDENT_20 = java . lang . Math . min ( buffer . METHOD_10 ( ) , IDENT_19 ) ; if ( IDENT_20 > 0 ) { IDENT_16 . put ( IDENT_18 , buffer , IDENT_20 ) ; IDENT_18 += IDENT_20 ; IDENT_19 OP_0 IDENT_20 ; } if ( IDENT_19 == 0 ) { break ; } else { buffer . METHOD_15 ( ) ; if ( ( IDENT_6 . read ( buffer ) ) == ( - 1 ) ) { throw new java . io . IOException ( STRING_2 ) ; } buffer . METHOD_12 ( ) ; } } org . apache . flink . runtime . io . network . buffer . IDENT_21 buf = new org . apache . flink . runtime . io . network . buffer . METHOD_16 ( IDENT_16 , org . apache . flink . runtime . io . network . buffer . IDENT_22 . INSTANCE ) ; buf . METHOD_17 ( length ) ; return new org . apache . flink . runtime . io . network . IDENT_23 . consumer . METHOD_18 ( buf , channel ) ; } else { if ( length > ( ( buffer . METHOD_19 ( ) ) - ( org . apache . flink . streaming . runtime . io . IDENT_8 . METHOD_6 . IDENT_12 ) ) ) { throw new java . io . IOException ( STRING_3 ) ; } if ( ( buffer . METHOD_10 ( ) ) < length ) { buffer . METHOD_11 ( ) ; while ( ( buffer . position ( ) ) < length ) { if ( ( IDENT_6 . read ( buffer ) ) == ( - 1 ) ) { throw new java . io . IOException ( STRING_4 ) ; } } buffer . METHOD_12 ( ) ; } int IDENT_24 = buffer . METHOD_20 ( ) ; buffer . METHOD_20 ( ( ( buffer . position ( ) ) + length ) ) ; org . apache . flink . runtime . event . IDENT_25 IDENT_26 = org . apache . flink . runtime . io . network . api . serialization . IDENT_27 . METHOD_21 ( buffer , getClass ( ) . METHOD_22 ( ) ) ; buffer . METHOD_20 ( IDENT_24 ) ; return new org . apache . flink . runtime . io . network . IDENT_23 . consumer . METHOD_18 ( IDENT_26 , channel ) ; } }
org . junit . Assert . assertNull ( IDENT_10 . METHOD_9 ( ) )