From 462d251bfbb4f094326dd3edb77dd7de4002f52a Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 4 May 2020 00:52:27 +0800 Subject: [PATCH] update --- src/resource_pool.go | 2 +- src/scheduler_fair.go | 3 --- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/src/resource_pool.go b/src/resource_pool.go index d50558f..fb6cb58 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -132,7 +132,7 @@ func (pool *ResourcePool) getNodePool(name string) int { /* save pool status periodically */ func (pool *ResourcePool) saveStatusHistory() { /* waiting for data */ - time.Sleep(time.Second * 30) + //time.Sleep(time.Second * 30) for { summary := PoolStatus{} diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 9cbd688..3a81a34 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -353,7 +353,6 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node for cur := start; ; { if _, ok := locks[cur.ID]; !ok { - log.Info("lock ", cur.ID) cur.Lock.Lock() locks[cur.ID] = &cur.Lock } @@ -403,7 +402,6 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node allocationType = 2 for cur := start; ; { if _, ok := locks[cur.ID]; !ok { - log.Info("lock ", cur.ID) cur.Lock.Lock() locks[cur.ID] = &cur.Lock } @@ -445,7 +443,6 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node allocationType = 3 for cur := start; ; { if _, ok := locks[cur.ID]; !ok { - log.Info("lock ", cur.ID) cur.Lock.Lock() locks[cur.ID] = &cur.Lock }