From 143490e4d426be56c8797bce363af76d18c50eb0 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 30 Apr 2020 14:23:21 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 218368b..025bf7b 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -188,6 +188,7 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus { var candidates []NodeStatus /* first round, find vacant gpu */ for i := 0; i < pool.poolsCount; i++ { + log.Info("lock,", (i+poolID)%pool.poolsCount) pool.poolsMu[(i+poolID)%pool.poolsCount].Lock() locks[(i+poolID)%pool.poolsCount] = pool.poolsMu[(i+poolID)%pool.poolsCount] for _, node := range pool.pools[(i+poolID)%pool.poolsCount] { @@ -286,6 +287,7 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus { } for _, lock := range locks { + log.Info("unlock ", lock) lock.Unlock() } go func(res NodeStatus) {