TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-08 03:00:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复新启动节点时获取不到最新配置的Bug

Browse Source
This commit is contained in:
GoEdgeLab
2021-11-26 13:53:34 +08:00
parent 7a94f5fdf2
commit d4c9bd524a
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
internal/rpc/services/service_node.go
View File

@@ -33,7 +33,7 @@ type NodeVersionCache struct {
CacheMap map[int64]*utils.CacheMap // version => map 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{} var nodeVersionCacheLocker = &sync.Mutex{}
// NodeService 边缘节点相关服务 // NodeService 边缘节点相关服务
@@ -1582,6 +1582,10 @@ func (this *NodeService) findClusterCacheMap(clusterId int64, version int64) *ut
nodeVersionCacheLocker.Lock() nodeVersionCacheLocker.Lock()
defer nodeVersionCacheLocker.Unlock() defer nodeVersionCacheLocker.Unlock()
if version == 0 {
return utils.NewCacheMap()
}
cache, ok := nodeVersionCacheMap[clusterId] cache, ok := nodeVersionCacheMap[clusterId]
if ok { if ok {
cacheMap, ok := cache.CacheMap[version] cacheMap, ok := cache.CacheMap[version]