backport of commit 09962d0521

pull/6603/head
Louis Ruch 3 weeks ago
parent 15c9c127b3
commit 6d2dec2ed7

@ -163,9 +163,10 @@ func (c *Controller) configureForCluster(ln *base.ServerListener) (func(), error
// need to handle individual listener shutdown.
interceptingListener, err := protocol.NewInterceptingListener(
&protocol.InterceptingListenerConfiguration{
Context: c.baseContext,
Storage: workerAuthStorage,
BaseListener: ln.ClusterListener,
Context: c.baseContext,
Storage: workerAuthStorage,
BaseListener: ln.ClusterListener,
TlsHandshakeTimeout: 15 * time.Second,
Options: []nodee.Option{
nodee.WithLogger(eventLogger),
nodee.WithRegistrationWrapper(wrapperToUse),

@ -199,9 +199,10 @@ func (w *Worker) configureForWorker(ln *base.ServerListener, logger *log.Logger,
interceptingListener, err := protocol.NewInterceptingListener(
&protocol.InterceptingListenerConfiguration{
Context: w.baseContext,
Storage: w.WorkerAuthStorage,
BaseListener: ln.ProxyListener,
Context: w.baseContext,
Storage: w.WorkerAuthStorage,
BaseListener: ln.ProxyListener,
TlsHandshakeTimeout: 15 * time.Second,
BaseTlsConfiguration: &tls.Config{
GetConfigForClient: w.getSessionTls(sessionManager),
},

Loading…
Cancel
Save