Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix flaky integration/clientv3/naming TestEtcdGrpcResolverRoundRobin

Browse Source 
Signed-off-by: Rajalakshmi Girish <rajalakshmi.girish1@ibm.com>
This commit is contained in:
Rajalakshmi Girish 2023-07-17 23:24:46 -07:00
parent 0c643dfb21
commit ea72194935
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration/clientv3/naming/resolver_test.go
View File

@ -93,7 +93,7 @@ func testEtcdGrpcResolver(t *testing.T, lbPolicy string) {
// Send more requests
lastResponse := []byte{'1'}
totalRequests := 1000
totalRequests := 3500
for i := 1; i < totalRequests; i++ {
resp, err := c.UnaryCall(context.TODO(), &testpb.SimpleRequest{}, grpc.WaitForReady(true))
if err != nil {
@ -111,7 +111,7 @@ func testEtcdGrpcResolver(t *testing.T, lbPolicy string) {
// If the load balancing policy is pick first then return payload should equal number of requests
t.Logf("Last response: %v", string(lastResponse))
if lbPolicy == "pick_first" {
if string(lastResponse) != "1000" {
if string(lastResponse) != "3500" {
t.Fatalf("unexpected total responses from foo: %s", string(lastResponse))
}
}