From a4c75a70655c4977f870b43c02088b70c8646ab0 Mon Sep 17 00:00:00 2001 From: Newnius Date: Sun, 3 May 2020 11:19:51 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index e2a75c5..56ae0c3 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -129,6 +129,7 @@ func (scheduler *SchedulerFair) Start() { } else { cnt *= 13 } + log.Info(cnt, reserved, pool.TotalGPU, scheduler.UsingGPU) if cnt+(scheduler.allocatingGPU)*13 > (pool.TotalGPU-scheduler.UsingGPU-reserved)*10 { scheduler.schedulingMu.Lock() scheduler.schedulingJobsCnt-- @@ -178,6 +179,7 @@ func (scheduler *SchedulerFair) Start() { if len(t) == 0 || !InstanceOfGroupManager().groups[t[0].Group].Reserved { continue } + log.Info(scheduler.queueUsingGPU) scheduler.queuesUsingGPUMu.Lock() if cnt, ok := scheduler.queuesSchedulingCnt[t[0].Group]; ok && cnt > 0 { scheduler.queuesUsingGPUMu.Unlock() @@ -748,7 +750,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) {