From 3c4696ee427049af99db4dc088ea9e2d2ad41f3b Mon Sep 17 00:00:00 2001
From: Sydonian <794346190@qq.com>
Date: Wed, 20 Mar 2024 10:35:02 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96ping=E8=BF=87=E7=A8=8B?=
 =?UTF-8?q?=E7=9A=84=E5=BB=B6=E8=BF=9F=E8=AE=A1=E7=AE=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 common/pkgs/connectivity/collector.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/common/pkgs/connectivity/collector.go b/common/pkgs/connectivity/collector.go
index 20894d7..a6c4de5 100644
--- a/common/pkgs/connectivity/collector.go
+++ b/common/pkgs/connectivity/collector.go
@@ -177,6 +177,18 @@ func (r *Collector) ping(node cdssdk.Node) Connectivity {
 	}
 	defer stgglb.AgentRPCPool.Release(agtCli)
 
+	// 第一次ping保证网络连接建立成功
+	err = agtCli.Ping(*stgglb.Local.NodeID)
+	if err != nil {
+		log.Warnf("pre ping: %v", err)
+		return Connectivity{
+			ToNodeID: node.NodeID,
+			Delay:    nil,
+			TestTime: time.Now(),
+		}
+	}
+
+	// 第二次ping计算延迟
 	start := time.Now()
 	err = agtCli.Ping(*stgglb.Local.NodeID)
 	if err != nil {