From f8ef77120ee8c5f0c557195e6b2599acefb538bb Mon Sep 17 00:00:00 2001 From: Gyu-Ho Lee Date: Thu, 18 Aug 2016 15:26:03 -0700 Subject: [PATCH] etcd-tester: request with grpc.FailFast true Fix https://github.com/coreos/etcd/issues/6221. Since we close the grpc connection, FailFast false will block. --- tools/functional-tester/etcd-tester/stresser.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/tools/functional-tester/etcd-tester/stresser.go b/tools/functional-tester/etcd-tester/stresser.go index 6983526892e..589bc980c5a 100644 --- a/tools/functional-tester/etcd-tester/stresser.go +++ b/tools/functional-tester/etcd-tester/stresser.go @@ -76,7 +76,7 @@ func newStressPut(kvc pb.KVClient, keySuffixRange, keySize int) stressFunc { _, err := kvc.Put(ctx, &pb.PutRequest{ Key: []byte(fmt.Sprintf("foo%016x", rand.Intn(keySuffixRange))), Value: randBytes(keySize), - }, grpc.FailFast(false)) + }) return err } } @@ -85,7 +85,7 @@ func newStressRange(kvc pb.KVClient, keySuffixRange int) stressFunc { return func(ctx context.Context) error { _, err := kvc.Range(ctx, &pb.RangeRequest{ Key: []byte(fmt.Sprintf("foo%016x", rand.Intn(keySuffixRange))), - }, grpc.FailFast(false)) + }) return err } } @@ -97,7 +97,7 @@ func newStressRangeInterval(kvc pb.KVClient, keySuffixRange int) stressFunc { _, err := kvc.Range(ctx, &pb.RangeRequest{ Key: []byte(fmt.Sprintf("foo%016x", start)), RangeEnd: []byte(fmt.Sprintf("foo%016x", end)), - }, grpc.FailFast(false)) + }) return err } } @@ -106,7 +106,7 @@ func newStressDelete(kvc pb.KVClient, keySuffixRange int) stressFunc { return func(ctx context.Context) error { _, err := kvc.DeleteRange(ctx, &pb.DeleteRangeRequest{ Key: []byte(fmt.Sprintf("foo%016x", rand.Intn(keySuffixRange))), - }, grpc.FailFast(false)) + }) return err } } @@ -118,7 +118,7 @@ func newStressDeleteInterval(kvc pb.KVClient, keySuffixRange int) stressFunc { _, err := kvc.DeleteRange(ctx, &pb.DeleteRangeRequest{ Key: []byte(fmt.Sprintf("foo%016x", start)), RangeEnd: []byte(fmt.Sprintf("foo%016x", end)), - }, grpc.FailFast(false)) + }) return err } }