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