From 4c4fe67ee0655868134bf3ac5ff3ea3d23ea3a25 Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 4 May 2020 00:12:11 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 31e5ec6..65d1006 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -353,6 +353,7 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node for cur := start; ; { if _, ok := locks[cur.ID]; !ok { + log.Info("lock", cur.ID) cur.Lock.Lock() locks[cur.ID] = cur.Lock } @@ -402,6 +403,7 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node allocationType = 2 for cur := start; ; { if _, ok := locks[cur.ID]; !ok { + log.Info("lock", cur.ID) cur.Lock.Lock() locks[cur.ID] = cur.Lock } @@ -443,6 +445,7 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node allocationType = 3 for cur := start; ; { if _, ok := locks[cur.ID]; !ok { + log.Info("lock", cur.ID) cur.Lock.Lock() locks[cur.ID] = cur.Lock }