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