Merge pull request #33483 from moypray/grpc_timeout
Limit max backoff delay to 2 seconds for GRPC connection Upstream-commit: 8420e7e7f5bea6cc4aafc943efe88e483ec5ac0a Component: engine
This commit is contained in:
@ -96,11 +96,13 @@ func New(stateDir string, options ...RemoteOption) (_ Remote, err error) {
|
||||
|
||||
// don't output the grpc reconnect logging
|
||||
grpclog.SetLogger(log.New(ioutil.Discard, "", log.LstdFlags))
|
||||
dialOpts := append([]grpc.DialOption{grpc.WithInsecure()},
|
||||
dialOpts := []grpc.DialOption{
|
||||
grpc.WithInsecure(),
|
||||
grpc.WithBackoffMaxDelay(2 * time.Second),
|
||||
grpc.WithDialer(func(addr string, timeout time.Duration) (net.Conn, error) {
|
||||
return net.DialTimeout("unix", addr, timeout)
|
||||
}),
|
||||
)
|
||||
}
|
||||
conn, err := grpc.Dial(r.rpcAddr, dialOpts...)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("error connecting to containerd: %v", err)
|
||||
|
||||
Reference in New Issue
Block a user