diff --git a/src/resource_pool.go b/src/resource_pool.go index 787e557..d50558f 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -84,18 +84,6 @@ func (pool *ResourcePool) start() { pool.saveStatusHistory() }() - segID := rand.Intn(pool.poolsCount) - start := &pool.pools[segID] - if start.Nodes == nil { - start = start.Next - } - for cur := start; ; { - log.Info(cur.ID) - cur = cur.Next - if cur.ID == start.ID { - break - } - } } /* check dead nodes periodically */ diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index bc2d16a..d3ef829 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -740,6 +740,7 @@ func (scheduler *SchedulerFair) UpdateNextQueue() { Memory := 0.0001 start := pool.pools[0].Next for cur := start; ; { + log.Info(cur.ID) cur.Lock.Lock() for _, node := range cur.Nodes { CPU += float64(node.NumCPU) @@ -786,7 +787,7 @@ func (scheduler *SchedulerFair) UpdateNextQueue() { } scheduler.nextQueue = next scheduler.queueMu.Unlock() - log.Debug("updateNextQueue ->", next) + log.Info("updateNextQueue ->", next) } func (scheduler *SchedulerFair) Attach(GPU string, job string) {