From d16df29b50aaa90c6b7d0936fa50f89bb65db77e Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 11:15:29 +0800 Subject: [PATCH] update fair --- src/job_manager.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/job_manager.go b/src/job_manager.go index 5e65d75..a26d0ea 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -129,14 +129,12 @@ func (jm *JobManager) start() { func (jm *JobManager) returnResource(status []TaskStatus) { jm.resourcesMu.Lock() defer jm.resourcesMu.Unlock() - if len(jm.resources) == 0 { - return - } /* return resource */ for i := range jm.resources { if jm.resources[i].ClientID == "_released_" { continue } + jm.resources[i].ClientID = "_released_" jm.scheduler.ReleaseResource(jm.job, jm.resources[i]) log.Info("return resource again ", jm.resources[i].ClientID) @@ -156,8 +154,10 @@ func (jm *JobManager) returnResource(status []TaskStatus) { // continue //} } - InstanceOfResourcePool().releaseNetwork(jm.network) - jm.resources = []NodeStatus{} + if jm.network != "" { + InstanceOfResourcePool().releaseNetwork(jm.network) + jm.network = "" + } } /* monitor all tasks */