benjamyn/any-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

yamux: move listCtx to Init

Browse Source
This commit is contained in:
Sergey Cherepanov 2023-06-08 14:37:54 +02:00
parent 24ce490524
commit 15326da736
No known key found for this signature in database
GPG Key ID: 87F8EDE8FBDF637C
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
net/transport/yamux/yamux.go
View File

@ -55,6 +55,7 @@ func (y *yamuxTransport) Init(a *app.App) (err error) {
y.yamuxConf.EnableKeepAlive = false y.yamuxConf.EnableKeepAlive = false
y.yamuxConf.StreamOpenTimeout = time.Duration(y.conf.DialTimeoutSec) * time.Second y.yamuxConf.StreamOpenTimeout = time.Duration(y.conf.DialTimeoutSec) * time.Second
y.yamuxConf.ConnectionWriteTimeout = time.Duration(y.conf.WriteTimeoutSec) * time.Second y.yamuxConf.ConnectionWriteTimeout = time.Duration(y.conf.WriteTimeoutSec) * time.Second
y.listCtx, y.listCtxCancel = context.WithCancel(context.Background())
return return
} }
@ -75,7 +76,6 @@ func (y *yamuxTransport) Run(ctx context.Context) (err error) {
} }
y.listeners = append(y.listeners, list) y.listeners = append(y.listeners, list)
} }
y.listCtx, y.listCtxCancel = context.WithCancel(context.Background())
for _, list := range y.listeners { for _, list := range y.listeners {
go y.acceptLoop(y.listCtx, list) go y.acceptLoop(y.listCtx, list)
} }