From 6cae5aac0ddae70cf5b4de6118258d89b0478d37 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 23:06:13 +0800 Subject: [PATCH] update fair --- src/scheduler_fair.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 93d2609..f494f0b 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -134,8 +134,8 @@ func (scheduler *SchedulerFair) Start() { } } /* if totalGPU can satisfy that job, start borrowing */ - log.Info(totalGPU, minRequestGPU) if bestQueue != "" && totalGPU >= minRequestGPU { + log.Info(totalGPU, minRequestGPU) for { /* if all satisfied, break */ if minRequestGPU == 0 { @@ -190,6 +190,7 @@ func (scheduler *SchedulerFair) Start() { IOU = scheduler.IOUs[bestQueue][queue] } IOU.NumberGPU += minRequestGPU + minRequestGPU = 0 scheduler.queuesQuota[bestQueue].NumberGPU += minRequestGPU log.Info(bestQueue, " borrow ", minRequestGPU, " from ", queue, " now ", scheduler.queuesQuota[bestQueue].NumberGPU) break