From 2c868f459ee06f713b2b5b46597c600255830380 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 13 Aug 2020 21:35:38 +0800 Subject: [PATCH] [bugfix] preempt, avoid deadlock --- src/scheduler_priority.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/scheduler_priority.go b/src/scheduler_priority.go index bea7a21..f68f945 100644 --- a/src/scheduler_priority.go +++ b/src/scheduler_priority.go @@ -108,10 +108,6 @@ func (scheduler *SchedulerPriority) Start() { } } - before := InstanceOfResourcePool().UsingGPU - log.Info("Start preempt ", preempted.Name) - scheduler.Stop(preempted.Name) - /* Remove from history */ idx := -1 for i, job := range scheduler.history { @@ -125,6 +121,10 @@ func (scheduler *SchedulerPriority) Start() { } scheduler.historyMu.Unlock() + before := InstanceOfResourcePool().UsingGPU + log.Info("Start preempt ", preempted.Name) + scheduler.Stop(preempted.Name) + /* add back */ idx = len(scheduler.queue) for i, job := range scheduler.queue {