YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-06-07 22:31:55 +00:00
Code Issues Releases Wiki Activity

add keep alive support

Browse Source
This commit is contained in:
Newnius 2019-06-04 11:15:12 +08:00
parent fda4a7674b
commit 6045e91cca
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/resource_pool.go
View File

@ -16,12 +16,18 @@ 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)
go func() {
pool.heartBeat = map[string]time.Time{}
for {
for k, v := range pool.heartBeat {
if v.Add(time.Second * 30).Before(time.Now()) {
delete(pool.nodes, k)
}
}
time.Sleep(time.Second * 10)
}
}
}()
/* save pool status periodically */
go func() {