From 164f30a6632ae90d9000a154dda6d02b13af631a Mon Sep 17 00:00:00 2001 From: fisherxu Date: Fri, 24 Aug 2018 10:18:21 +0800 Subject: [PATCH] use dailcontext Kubernetes-commit: 89f3fa3d62791e756dcbd645818ea03d7c1a86b8 --- pkg/storage/value/encrypt/envelope/grpc_service.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pkg/storage/value/encrypt/envelope/grpc_service.go b/pkg/storage/value/encrypt/envelope/grpc_service.go index c9295ed1f..b29b62178 100644 --- a/pkg/storage/value/encrypt/envelope/grpc_service.go +++ b/pkg/storage/value/encrypt/envelope/grpc_service.go @@ -59,7 +59,10 @@ func NewGRPCService(endpoint string) (Service, error) { return nil, err } - connection, err := grpc.Dial(addr, grpc.WithInsecure(), grpc.WithTimeout(timeout), grpc.WithDialer(unixDial)) + ctx, cancel := context.WithTimeout(context.Background(), timeout) + defer cancel() + + connection, err := grpc.DialContext(ctx, addr, grpc.WithInsecure(), grpc.WithDialer(unixDial)) if err != nil { return nil, fmt.Errorf("connect remote KMS provider %q failed, error: %v", addr, err) }