METHOD_0 ( ) { io . netty . IDENT_0 . IDENT_1 IDENT_2 = new io . netty . IDENT_0 . METHOD_1 ( ) ; io . netty . channel . IDENT_3 . IDENT_4 . IDENT_5 IDENT_6 = new io . netty . channel . IDENT_3 . IDENT_4 . METHOD_2 ( STRING_0 ) ; IDENT_2 . group ( new io . netty . channel . METHOD_3 ( ) , new io . netty . channel . METHOD_3 ( ) ) . channel ( io . netty . channel . IDENT_3 . IDENT_7 . class ) . METHOD_4 ( IDENT_6 ) ; io . netty . IDENT_0 . IDENT_8 IDENT_9 = new io . netty . IDENT_0 . METHOD_5 ( ) ; io . netty . channel . IDENT_3 . IDENT_4 . METHOD_2 IDENT_10 = new io . netty . channel . IDENT_3 . IDENT_4 . METHOD_2 ( STRING_1 ) ; IDENT_9 . group ( new io . netty . channel . METHOD_3 ( ) ) . channel ( io . netty . channel . IDENT_3 . IDENT_11 . class ) . METHOD_6 ( new io . netty . channel . IDENT_3 . METHOD_7 ( io . netty . channel . IDENT_3 . IDENT_4 . IDENT_12 ) ) . handler ( IDENT_10 ) ; IDENT_2 . METHOD_8 ( new io . netty . channel . IDENT_3 . METHOD_7 ( io . netty . channel . IDENT_3 . IDENT_4 . IDENT_12 ) ) . sync ( ) ; int count = 100 ; for ( int i = 1 ; i < ( count + 1 ) ; i ++ ) { io . netty . channel . IDENT_13 ch = IDENT_9 . connect ( ) . sync ( ) . channel ( ) ; int target = i * ( io . netty . channel . IDENT_3 . IDENT_4 . IDENT_14 ) ; while ( ( ( IDENT_6 . count . get ( ) ) != target ) || ( ( IDENT_10 . count . get ( ) ) != target ) ) { java . lang . Thread . sleep ( 50 ) ; } close ( ch , IDENT_10 ) ; } "<AssertPlaceHolder>" ; } get ( ) { return METHOD_9 ( ) ; }
org . junit . Assert . assertEquals ( ( ( count * 2 ) * ( io . netty . channel . IDENT_3 . IDENT_4 . IDENT_14 ) ) , ( ( IDENT_6 . count . get ( ) ) + ( IDENT_10 . count . get ( ) ) ) )