blob: c6ef585b5b4140e0cef8ca3343109e03f50cd43a [file] [log] [blame]
khenaidooac637102019-01-14 15:44:34 -05001// Copyright 2017 The etcd Authors
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7// http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15package clientv3
16
17import "context"
18
19// TODO: remove this when "FailFast=false" is fixed.
20// See https://github.com/grpc/grpc-go/issues/1532.
21func readyWait(rpcCtx, clientCtx context.Context, ready <-chan struct{}) error {
22 select {
23 case <-ready:
24 return nil
25 case <-rpcCtx.Done():
26 return rpcCtx.Err()
27 case <-clientCtx.Done():
28 return clientCtx.Err()
29 }
30}