YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-15 08:16:43 +00:00
Code Issues Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
Newnius
2020-04-11 11:42:03 +08:00
parent 11aded3427
commit 6714dd5779
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/resource_pool.go
View File

@@ -111,6 +111,8 @@ func (pool *ResourcePool) update(node NodeStatus) {
pool.mu.Lock() pool.mu.Lock()
defer pool.mu.Unlock() defer pool.mu.Unlock()
pool.heartBeat[node.ClientID] = time.Now()
pool.counterTotal++ pool.counterTotal++
if version, ok := pool.versions[node.ClientID]; ok && version == node.Version { if version, ok := pool.versions[node.ClientID]; ok && version == node.Version {
return return
@@ -128,7 +130,6 @@ func (pool *ResourcePool) update(node NodeStatus) {
} }
} }
pool.nodes[node.ClientID] = node pool.nodes[node.ClientID] = node
pool.heartBeat[node.ClientID] = time.Now()
pool.versions[node.ClientID] = node.Version pool.versions[node.ClientID] = node.Version
log.Debug(pool.nodes) log.Debug(pool.nodes)
} }