From 46e0daeb192df638524a28684df120db885d9197 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Thu, 8 Jul 2021 18:37:11 +0800 Subject: [PATCH] =?UTF-8?q?=E5=81=A5=E5=BA=B7=E6=A3=80=E6=9F=A5=E5=A4=B1?= =?UTF-8?q?=E8=B4=A5=E6=97=B6=EF=BC=8C=E4=BC=9A=E8=87=AA=E5=8A=A8=E5=B0=9D?= =?UTF-8?q?=E8=AF=95=E5=86=8D=E6=AC=A1=E8=BF=9E=E6=8E=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/tasks/health_check_executor.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/tasks/health_check_executor.go b/internal/tasks/health_check_executor.go index 5b121af8..fad9c034 100644 --- a/internal/tasks/health_check_executor.go +++ b/internal/tasks/health_check_executor.go @@ -185,7 +185,11 @@ func (this *HealthCheckExecutor) checkNode(healthCheckConfig *serverconfigs.Heal if err != nil { return nil, err } - return net.Dial(network, result.NodeAddr+":"+port) + conn, err := net.Dial(network, result.NodeAddr+":"+port) + if err == nil { + return conn, nil + } + return net.DialTimeout(network, result.NodeAddr+":"+port, timeout) }, MaxIdleConns: 1, MaxIdleConnsPerHost: 1,