From d4c9bd524aff2013fe088e7582d3bfe480f02122 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Fri, 26 Nov 2021 13:53:34 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=96=B0=E5=90=AF=E5=8A=A8?= =?UTF-8?q?=E8=8A=82=E7=82=B9=E6=97=B6=E8=8E=B7=E5=8F=96=E4=B8=8D=E5=88=B0?= =?UTF-8?q?=E6=9C=80=E6=96=B0=E9=85=8D=E7=BD=AE=E7=9A=84Bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/rpc/services/service_node.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/rpc/services/service_node.go b/internal/rpc/services/service_node.go index db829471..68ba9e3f 100644 --- a/internal/rpc/services/service_node.go +++ b/internal/rpc/services/service_node.go @@ -33,7 +33,7 @@ type NodeVersionCache struct { CacheMap map[int64]*utils.CacheMap // version => map } -var nodeVersionCacheMap = map[int64]*NodeVersionCache{} // [cluster_id]_[version] => cache +var nodeVersionCacheMap = map[int64]*NodeVersionCache{} // [cluster_id] => { [version] => cache } var nodeVersionCacheLocker = &sync.Mutex{} // NodeService 边缘节点相关服务 @@ -1582,6 +1582,10 @@ func (this *NodeService) findClusterCacheMap(clusterId int64, version int64) *ut nodeVersionCacheLocker.Lock() defer nodeVersionCacheLocker.Unlock() + if version == 0 { + return utils.NewCacheMap() + } + cache, ok := nodeVersionCacheMap[clusterId] if ok { cacheMap, ok := cache.CacheMap[version]