From 485c9dd768b755d29d4373fb167ac6cea69598a1 Mon Sep 17 00:00:00 2001 From: Sergey Cherepanov Date: Wed, 7 Jun 2023 14:49:44 +0200 Subject: [PATCH] yamux default timeouts --- net/transport/yamux/yamux.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/net/transport/yamux/yamux.go b/net/transport/yamux/yamux.go index 18558604..47cb8c52 100644 --- a/net/transport/yamux/yamux.go +++ b/net/transport/yamux/yamux.go @@ -42,6 +42,12 @@ type yamuxTransport struct { func (y *yamuxTransport) Init(a *app.App) (err error) { y.secure = a.MustComponent(secureservice.CName).(secureservice.SecureService) y.conf = a.MustComponent("config").(configGetter).GetYamux() + if y.conf.DialTimeoutSec <= 0 { + y.conf.DialTimeoutSec = 10 + } + if y.conf.WriteTimeoutSec <= 0 { + y.conf.WriteTimeoutSec = 10 + } y.yamuxConf = yamux.DefaultConfig() y.yamuxConf.EnableKeepAlive = false y.yamuxConf.StreamOpenTimeout = time.Duration(y.conf.DialTimeoutSec) * time.Second