From d391ce1daf193d4551027dc6c24ce8d4a0f093ae Mon Sep 17 00:00:00 2001 From: Artem Glazychev Date: Mon, 25 Mar 2024 18:16:00 +0700 Subject: [PATCH] Pass missing dial timeout option (#812) Signed-off-by: Artem Glazychev --- pkg/networkservice/chains/forwarder/server.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/networkservice/chains/forwarder/server.go b/pkg/networkservice/chains/forwarder/server.go index af909d65..54d37892 100644 --- a/pkg/networkservice/chains/forwarder/server.go +++ b/pkg/networkservice/chains/forwarder/server.go @@ -88,7 +88,7 @@ func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, vppConn authorizeServer: authorize.NewServer(authorize.Any()), authorizeMonitorConnectionServer: authmonitor.NewMonitorConnectionServer(authmonitor.Any()), clientURL: &url.URL{Scheme: "unix", Host: "connect.to.socket"}, - dialTimeout: time.Millisecond * 200, + dialTimeout: time.Millisecond * 300, domain2Device: make(map[string]string), } for _, opt := range options { @@ -100,10 +100,12 @@ func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, vppConn registryrecvfd.NewNetworkServiceEndpointRegistryClient(), registrysendfd.NewNetworkServiceEndpointRegistryClient(), ), + registryclient.WithDialTimeout(opts.dialTimeout), registryclient.WithDialOptions(opts.dialOpts...), ) nsClient := registryclient.NewNetworkServiceRegistryClient(ctx, registryclient.WithClientURL(opts.clientURL), + registryclient.WithDialTimeout(opts.dialTimeout), registryclient.WithDialOptions(opts.dialOpts...)) ikev2Key, err := ipsec.GenerateRSAKey()