From cfe0f90d997ababd14ff6aaace4543a6cda36b74 Mon Sep 17 00:00:00 2001
From: GoEdgeLab <goedgecloud@gmail.com>
Date: Sun, 12 Dec 2021 14:38:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=A8=E5=B1=80IP=E5=90=8D=E5=8D=95=E4=B8=8D?=
 =?UTF-8?q?=E5=8D=B3=E6=97=B6=E9=80=9A=E7=9F=A5=E8=8A=82=E7=82=B9=E6=9B=B4?=
 =?UTF-8?q?=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/db/models/ip_item_dao.go            | 5 +++++
 internal/rpc/services/service_node_stream.go | 1 +
 2 files changed, 6 insertions(+)

diff --git a/internal/db/models/ip_item_dao.go b/internal/db/models/ip_item_dao.go
index aa058a74..e790643b 100644
--- a/internal/db/models/ip_item_dao.go
+++ b/internal/db/models/ip_item_dao.go
@@ -185,6 +185,11 @@ func (this *IPItemDAO) CreateIPItem(tx *dbs.Tx,
 	}
 	itemId := types.Int64(op.Id)
 
+	// 全局名单不需要即时更新，防止数量过多而导致性能问题
+	if listId == firewallconfigs.GlobalListId {
+		return itemId, nil
+	}
+
 	err = this.NotifyUpdate(tx, itemId)
 	if err != nil {
 		return 0, err
diff --git a/internal/rpc/services/service_node_stream.go b/internal/rpc/services/service_node_stream.go
index 31c16888..8ebb6666 100644
--- a/internal/rpc/services/service_node_stream.go
+++ b/internal/rpc/services/service_node_stream.go
@@ -84,6 +84,7 @@ func (this *NodeService) NodeStream(server pb.NodeService_NodeStreamServer) erro
 
 	defer func() {
 		// 修改当前API节点的主边缘节点
+		/// TODO 每个集群应该有一个primaryNodeId
 		if primaryNodeId == nodeId {
 			primaryNodeId = 0