From 15326da736ee9b37550cfa7081409ca2a7ac47e4 Mon Sep 17 00:00:00 2001 From: Sergey Cherepanov Date: Thu, 8 Jun 2023 14:37:54 +0200 Subject: [PATCH] yamux: move listCtx to Init --- net/transport/yamux/yamux.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/net/transport/yamux/yamux.go b/net/transport/yamux/yamux.go index d47d16cc..9a0245a9 100644 --- a/net/transport/yamux/yamux.go +++ b/net/transport/yamux/yamux.go @@ -55,6 +55,7 @@ func (y *yamuxTransport) Init(a *app.App) (err error) { y.yamuxConf.EnableKeepAlive = false y.yamuxConf.StreamOpenTimeout = time.Duration(y.conf.DialTimeoutSec) * time.Second y.yamuxConf.ConnectionWriteTimeout = time.Duration(y.conf.WriteTimeoutSec) * time.Second + y.listCtx, y.listCtxCancel = context.WithCancel(context.Background()) return } @@ -75,7 +76,6 @@ func (y *yamuxTransport) Run(ctx context.Context) (err error) { } y.listeners = append(y.listeners, list) } - y.listCtx, y.listCtxCancel = context.WithCancel(context.Background()) for _, list := range y.listeners { go y.acceptLoop(y.listCtx, list) }