@@ -106,45 +106,46 @@ func BenchmarkWeightedRoundRobinSelector_Select(b *testing.B) {
106
106
}
107
107
}
108
108
109
- func TestWeightedICMPSelector (t * testing.T ) {
110
- calc := make (map [string ]int )
111
- servers := make (map [string ]string )
112
- servers ["@localhost:3333" ] = ""
113
- servers ["@www.baidu.com:3334" ] = ""
114
- servers ["@xxxx.xxxx:333" ] = ""
115
- s := newWeightedICMPSelector (servers )
116
- ctx := context .Background ()
117
- for i := 0 ; i < 10 ; i ++ {
118
- host := s .Select (ctx , "" , "" , nil )
119
- if _ , ok := calc [host ]; ok {
120
- calc [host ]++
121
- } else {
122
- calc [host ] = 0
123
- }
124
- }
125
- if len (calc ) != 2 {
126
- t .Errorf ("expected %d but got %d" , 2 , len (servers ))
127
- }
128
- }
129
- func TestWeightedICMPSelector_UpdateServer (t * testing.T ) {
130
- calc := make (map [string ]int )
131
- servers := make (map [string ]string )
132
- servers ["@localhost:3333" ] = ""
133
- servers ["@www.baidu.com:3334" ] = ""
134
- servers ["@xxxx.xxxx:333" ] = ""
135
- s := newWeightedICMPSelector (servers )
136
- ctx := context .Background ()
137
- servers ["@www.sina.com:3333" ] = ""
138
- s .UpdateServer (servers )
139
- for i := 0 ; i < 10 ; i ++ {
140
- host := s .Select (ctx , "" , "" , nil )
141
- if _ , ok := calc [host ]; ok {
142
- calc [host ]++
143
- } else {
144
- calc [host ] = 0
145
- }
146
- }
147
- if len (calc ) != 3 {
148
- t .Errorf ("expected %d but got %d" , 3 , len (servers ))
149
- }
150
- }
109
+ //
110
+ //func TestWeightedICMPSelector(t *testing.T) {
111
+ // calc := make(map[string]int)
112
+ // servers := make(map[string]string)
113
+ // servers["@localhost:3333"] = ""
114
+ // servers["@www.baidu.com:3334"] = ""
115
+ // servers["@xxxx.xxxx:333"] = ""
116
+ // s := newWeightedICMPSelector(servers)
117
+ // ctx := context.Background()
118
+ // for i := 0; i < 10; i++ {
119
+ // host := s.Select(ctx, "", "", nil)
120
+ // if _, ok := calc[host]; ok {
121
+ // calc[host]++
122
+ // } else {
123
+ // calc[host] = 0
124
+ // }
125
+ // }
126
+ // if len(calc) != 2 {
127
+ // t.Errorf("expected %d but got %d", 2, len(servers))
128
+ // }
129
+ //}
130
+ //func TestWeightedICMPSelector_UpdateServer(t *testing.T) {
131
+ // calc := make(map[string]int)
132
+ // servers := make(map[string]string)
133
+ // servers["@localhost:3333"] = ""
134
+ // servers["@www.baidu.com:3334"] = ""
135
+ // servers["@xxxx.xxxx:333"] = ""
136
+ // s := newWeightedICMPSelector(servers)
137
+ // ctx := context.Background()
138
+ // servers["@www.sina.com:3333"] = ""
139
+ // s.UpdateServer(servers)
140
+ // for i := 0; i < 10; i++ {
141
+ // host := s.Select(ctx, "", "", nil)
142
+ // if _, ok := calc[host]; ok {
143
+ // calc[host]++
144
+ // } else {
145
+ // calc[host] = 0
146
+ // }
147
+ // }
148
+ // if len(calc) != 3 {
149
+ // t.Errorf("expected %d but got %d", 3, len(servers))
150
+ // }
151
+ //}
0 commit comments