From fda4a7674ba92cf8ccfc21d1ed50ba4bb5568f22 Mon Sep 17 00:00:00 2001 From: Newnius Date: Tue, 4 Jun 2019 11:12:02 +0800 Subject: [PATCH] add keep alive support --- src/resource_pool.go | 1 + 1 file changed, 1 insertion(+) diff --git a/src/resource_pool.go b/src/resource_pool.go index dc9c554..56babb4 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -16,6 +16,7 @@ type ResourcePool struct { func (pool *ResourcePool) start() { /* check dead nodes */ + pool.heartBeat = map[string]time.Time{} for k, v := range pool.heartBeat { if v.Add(time.Second * 30).Before(time.Now()) { delete(pool.nodes, k)