From cbaef3bd59c7e43cbeaf605520b89ece092a27ba Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 30 Apr 2020 21:26:04 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 16cb5fb..d2030fe 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -34,7 +34,7 @@ type SchedulerFair struct { enablePreSchedule bool enablePreScheduleRatio float64 - UsingGPU int + UsingGPU int UsingGPUMu sync.Mutex } @@ -309,6 +309,7 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node if valid2 { t := s now := (int)(time.Now().Unix()) + log.Info(t, now, estimate, est) if now-t > est.Total-est.Post-estimate.Pre && status.MemoryFree > task.MemoryGPU { available = append(available, status) } @@ -362,9 +363,6 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node } } - - - for i := range locks { pool.poolsMu[i].Unlock() }