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 }