From 87bb4a9b39ed87aa3d9737eb2fb8b893ca4eb22e Mon Sep 17 00:00:00 2001 From: Newnius Date: Sun, 3 May 2020 11:38:59 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 5f856ce..e1622dc 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -127,13 +127,8 @@ func (scheduler *SchedulerFair) Start() { } scheduler.queuesUsingGPUMu.Unlock() - if cnt == 1 { - cnt *= 10 - } else { - cnt *= 13 - } - log.Info(cnt, reserved, pool.TotalGPU, scheduler.UsingGPU) - if cnt+(scheduler.allocatingGPU)*13 > (pool.TotalGPU-scheduler.UsingGPU-reserved)*10 { + log.Info(cnt, reserved, pool.TotalGPU, scheduler.UsingGPU, scheduler.allocatingGPU) + if cnt*10+(scheduler.allocatingGPU)*13 > (pool.TotalGPU-scheduler.UsingGPU-reserved)*10 { scheduler.schedulingMu.Lock() scheduler.schedulingJobsCnt-- scheduler.schedulingMu.Unlock() @@ -751,7 +746,7 @@ func (scheduler *SchedulerFair) UpdateNextQueue() { } scheduler.nextQueue = next scheduler.queueMu.Unlock() - log.Info("updateNextQueue ->", next) + log.Debug("updateNextQueue ->", next) } func (scheduler *SchedulerFair) Attach(GPU string, job string) {