METHOD_0 ( ) { org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_2 IDENT_3 = org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_2 . METHOD_1 ( ) . build ( ) ; int IDENT_4 = 8 ; java . util . Set < org . apache . IDENT_0 . net . IDENT_5 > IDENT_6 = org . apache . IDENT_0 . stream . storage . impl . IDENT_7 . IDENT_8 . METHOD_2 ( IDENT_4 ) ; org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_2 IDENT_9 = controller . METHOD_3 ( IDENT_10 , IDENT_3 , IDENT_6 ) ; org . apache . IDENT_0 . stream . storage . impl . IDENT_7 . IDENT_8 . METHOD_4 ( IDENT_9 , IDENT_6 , true ) ; org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_2 IDENT_11 = controller . METHOD_3 ( IDENT_10 , IDENT_9 , IDENT_6 ) ; "<AssertPlaceHolder>" ; } METHOD_3 ( org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_12 , org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_2 , java . util . Set ) { if ( IDENT_6 . isEmpty ( ) ) { log . info ( STRING_0 ) ; return IDENT_13 ; } java . util . Map < org . apache . IDENT_0 . net . IDENT_5 , java . util . Set < java . lang . Long > > IDENT_14 ; try { IDENT_14 = IDENT_13 . METHOD_5 ( ) . entrySet ( ) . stream ( ) . collect ( java . util . stream . IDENT_15 . METHOD_6 ( ( IDENT_16 ) -> { try { return new org . apache . IDENT_0 . net . METHOD_7 ( IDENT_16 . getKey ( ) ) ; } catch ( IDENT_17 ) { org . apache . IDENT_0 . stream . storage . impl . IDENT_7 . log . error ( STRING_1 ) ; throw new < org . apache . IDENT_0 . stream . storage . impl . IDENT_7 . IDENT_17 > com . google . common . util . concurrent . METHOD_8 ( ( STRING_2 + ( IDENT_16 . getKey ( ) ) ) ) ; } } , ( IDENT_18 ) -> IDENT_18 . getValue ( ) . METHOD_9 ( ) . stream ( ) . collect ( java . util . stream . IDENT_15 . METHOD_10 ( ) ) ) ) ; } catch ( com . google . common . util . concurrent . METHOD_8 IDENT_19 ) { log . warn ( STRING_3 , IDENT_13 , IDENT_19 . METHOD_11 ( ) . getMessage ( ) ) ; IDENT_14 = com . google . common . collect . IDENT_20 . METHOD_12 ( ) ; } java . util . Set < org . apache . IDENT_0 . net . METHOD_7 > IDENT_21 = IDENT_14 . METHOD_13 ( ) ; if ( IDENT_21 . isEmpty ( ) ) { return org . apache . IDENT_0 . stream . storage . impl . IDENT_7 . IDENT_22 . METHOD_14 ( IDENT_10 , IDENT_6 ) ; } java . util . Set < org . apache . IDENT_0 . net . METHOD_7 > IDENT_23 = com . google . common . collect . IDENT_24 . METHOD_15 ( IDENT_6 , IDENT_21 ) . METHOD_16 ( ) ; java . util . Set < org . apache . IDENT_0 . net . METHOD_7 > IDENT_25 = com . google . common . collect . IDENT_24 . METHOD_15 ( IDENT_21 , IDENT_6 ) . METHOD_16 ( ) ; if ( ( IDENT_23 . isEmpty ( ) ) && ( IDENT_25 . isEmpty ( ) ) ) { return IDENT_13 ; } log . info ( ( STRING_4 + STRING_5 ) , IDENT_23 . size ( ) , IDENT_23 , IDENT_25 . size ( ) , IDENT_25 ) ; java . util . Set < java . lang . Long > IDENT_26 = IDENT_14 . entrySet ( ) . stream ( ) . filter ( ( IDENT_27 ) -> ! ( IDENT_6 . contains ( IDENT_27 . getKey ( ) ) ) ) . METHOD_17 ( ( IDENT_27 ) -> IDENT_27 . getValue ( ) . stream ( ) ) . collect ( java . util . stream . IDENT_15 . METHOD_10 ( ) ) ; java . util . IDENT_28 < org . apache . commons . lang3 . tuple . IDENT_29 < org . apache . IDENT_0 . net . METHOD_7 , java . util . IDENT_30 < java . lang . Long > > > IDENT_31 = new java . util . METHOD_18 ( new org . apache . IDENT_0 . stream . storage . impl . IDENT_7 . IDENT_22 . METHOD_19 ( ) ) ; for ( Map . Entry < org . apache . IDENT_0 . net . METHOD_7 , java . util . Set < java . lang . Long > > entry : IDENT_14 . entrySet ( ) ) { org . apache . IDENT_0 . net . METHOD_7 host = entry . getKey ( ) ; if ( ! ( IDENT_6 . contains ( host ) ) ) { if ( log . METHOD_20 ( ) ) { log . trace ( STRING_6 , host ) ; } continue ; } else { if ( log . METHOD_20 ( ) ) { log . trace ( STRING_7 , host ) ; } IDENT_31 . add ( org . apache . commons . lang3 . tuple . IDENT_29 . of ( host , com . google . common . collect . Lists . METHOD_21 ( entry . getValue ( ) ) ) ) ; } } for ( org . apache . IDENT_0 . net . METHOD_7 server : IDENT_23 ) { IDENT_31 . add ( org . apache . commons . lang3 . tuple . IDENT_29 . of ( server , com . google . common . collect . Lists . METHOD_21 ( ) ) ) ; } for ( java . lang . Long IDENT_32 : IDENT_26 ) { org . apache . commons . lang3 . tuple . IDENT_29 < org . apache . IDENT_0 . net . METHOD_7 , java . util . IDENT_30 < java . lang . Long > > IDENT_33 = IDENT_31 . METHOD_22 ( ) ; IDENT_33 . getValue ( ) . add ( IDENT_32 ) ; IDENT_31 . add ( IDENT_33 ) ; } int IDENT_34 ; if ( ( IDENT_31 . size ( ) ) > ( IDENT_10 . METHOD_23 ( ) ) ) { IDENT_34 = 1 ; } else { IDENT_34 = ( ( ( IDENT_10 . METHOD_23 ( ) ) OP_0 ( IDENT_31 . size ( ) ) ) == 0 ) ? 0 : 1 ; } org . apache . commons . lang3 . tuple . IDENT_29 < org . apache . IDENT_0 . net . METHOD_7 , java . util . IDENT_30 < java . lang . Long > > IDENT_35 = IDENT_31 . first ( ) ; org . apache . commons . lang3 . tuple . IDENT_29 < org . apache . IDENT_0 . net . METHOD_7 , java . util . IDENT_30 < java . lang . Long > > IDENT_36 = IDENT_31 . METHOD_24 ( ) ; while ( ( ( IDENT_36 . getValue ( ) . size ( ) ) - ( IDENT_35 . getValue ( ) . size ( ) ) ) > IDENT_34 ) { IDENT_35 = IDENT_31 . METHOD_22 ( ) ; IDENT_36 = IDENT_31 . METHOD_25 ( ) ; java . lang . Long IDENT_32 = IDENT_36 . getValue ( ) . METHOD_26 ( ) ; IDENT_35 . getValue ( ) . METHOD_27 ( IDENT_32 ) ; IDENT_31 . add ( IDENT_35 ) ; IDENT_31 . add ( IDENT_36 ) ; IDENT_35 = IDENT_31 . first ( ) ; IDENT_36 = IDENT_31 . METHOD_24 ( ) ; } java . util . Map < java . lang . String , org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_37 > IDENT_38 = com . google . common . collect . IDENT_20 . METHOD_12 ( ) ; IDENT_31 . METHOD_28 ( ( IDENT_39 ) -> IDENT_38 . put ( IDENT_39 . getKey ( ) . toString ( ) , org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_37 . METHOD_1 ( ) . METHOD_29 ( IDENT_39 . getValue ( ) ) . build ( ) ) ) ; return org . apache . IDENT_0 . stream . IDENT_1 . cluster . IDENT_2 . METHOD_1 ( ) . METHOD_30 ( IDENT_38 ) . build ( ) ; }
org . junit . Assert . assertSame ( IDENT_9 , IDENT_11 )