etcd-tester: add FailFast(false) to grpc calls

tools/functional-tester/etcd-tester/cluster.go

@@ -25,6 +25,7 @@ import (
 
 	pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
 	"github.com/coreos/etcd/tools/functional-tester/etcd-agent/client"
+	"google.golang.org/grpc"
 )
 
 const (
@@ -263,7 +264,7 @@ func (c *cluster) compactKV(rev int64, timeout time.Duration) (err error) {
 		kvc := pb.NewKVClient(conn)
 		ctx, cancel := context.WithTimeout(context.Background(), timeout)
 		plog.Printf("[compact kv #%d] starting (endpoint %s)", i, u)
-		_, cerr := kvc.Compact(ctx, &pb.CompactionRequest{Revision: rev, Physical: true})
+		_, cerr := kvc.Compact(ctx, &pb.CompactionRequest{Revision: rev, Physical: true}, grpc.FailFast(false))
 		cancel()
 		conn.Close()
 		succeed := true

tools/functional-tester/etcd-tester/member.go

@@ -93,7 +93,7 @@ func (m *member) RevHash() (int64, int64, error) {
 	}
 	mt := pb.NewMaintenanceClient(conn)
 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
-	resp, err := mt.Hash(ctx, &pb.HashRequest{})
+	resp, err := mt.Hash(ctx, &pb.HashRequest{}, grpc.FailFast(false))
 	cancel()
 	conn.Close()
 

tools/functional-tester/etcd-tester/stresser.go

@@ -109,7 +109,8 @@ func (s *stresser) run(ctx context.Context, kvc pb.KVClient) {
 		_, err := kvc.Put(putctx, &pb.PutRequest{
 			Key:   []byte(fmt.Sprintf("foo%d", rand.Intn(s.KeySuffixRange))),
 			Value: []byte(randStr(s.KeySize)),
-		})
+		},
+			grpc.FailFast(false))
 		putcancel()
 		if err != nil {
 			shouldContinue := false