From 6714dd5779518abb899fe6a84b170471710a1c03 Mon Sep 17 00:00:00 2001 From: Newnius Date: Sat, 11 Apr 2020 11:42:03 +0800 Subject: [PATCH] bugfix --- src/resource_pool.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/resource_pool.go b/src/resource_pool.go index 7e645be..682b27f 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -111,6 +111,8 @@ func (pool *ResourcePool) update(node NodeStatus) { pool.mu.Lock() defer pool.mu.Unlock() + pool.heartBeat[node.ClientID] = time.Now() + pool.counterTotal++ if version, ok := pool.versions[node.ClientID]; ok && version == node.Version { return @@ -128,7 +130,6 @@ func (pool *ResourcePool) update(node NodeStatus) { } } pool.nodes[node.ClientID] = node - pool.heartBeat[node.ClientID] = time.Now() pool.versions[node.ClientID] = node.Version log.Debug(pool.nodes) }