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

Merge pull request #16263 from Rajalakshmi-Girish/flake-grpc-rr

Browse Source 
Fix flaky integration/clientv3/naming TestEtcdGrpcResolverRoundRobin
This commit is contained in:
Benjamin Wang 2023-07-18 09:49:56 +01:00 committed by GitHub
commit e209968dc3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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))
}
}