From bc73df92b8ce53508aa9177e07804799d4d86374 Mon Sep 17 00:00:00 2001
From: GoEdgeLab <goedgecloud@gmail.com>
Date: Sun, 5 Jun 2022 17:18:26 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E9=80=81=E8=BF=9C=E7=A8=8B=E6=8C=87?=
 =?UTF-8?q?=E4=BB=A4=E6=97=B6=E5=8C=85=E6=8B=AC=E4=BB=8E=E8=8A=82=E7=82=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/web/actions/default/nodes/nodeutils/utils.go | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/internal/web/actions/default/nodes/nodeutils/utils.go b/internal/web/actions/default/nodes/nodeutils/utils.go
index 531b6026..03fa9ec1 100644
--- a/internal/web/actions/default/nodes/nodeutils/utils.go
+++ b/internal/web/actions/default/nodes/nodeutils/utils.go
@@ -35,7 +35,8 @@ func SendMessageToCluster(ctx context.Context, clusterId int64, code string, msg
 
 	// 获取所有节点
 	nodesResp, err := defaultRPCClient.NodeRPC().FindAllEnabledNodesWithNodeClusterId(ctx, &pb.FindAllEnabledNodesWithNodeClusterIdRequest{
-		NodeClusterId: clusterId,
+		NodeClusterId:    clusterId,
+		IncludeSecondary: true,
 	})
 	if err != nil {
 		return results, err
@@ -45,10 +46,10 @@ func SendMessageToCluster(ctx context.Context, clusterId int64, code string, msg
 		return results, nil
 	}
 
-	rpcMap := map[int64]*rpc.RPCClient{} // apiNodeId => RPCClient
-	locker := &sync.Mutex{}
+	var rpcMap = map[int64]*rpc.RPCClient{} // apiNodeId => RPCClient
+	var locker = &sync.Mutex{}
 
-	wg := &sync.WaitGroup{}
+	var wg = &sync.WaitGroup{}
 	wg.Add(len(nodes))
 
 	for _, node := range nodes {