spdf/elektron
Archived
1
0
Fork 0
Code Issues 4 Pull requests 1 Projects Releases Packages Wiki Activity

Fix: Mutex lock handling issues with task running

Browse source
This commit is contained in:
Akash Kothawale 2018-02-05 02:18:33 -05:00 • committed by Pradyumna Kaushik
parent 9c09321d81
commit 3d5bb772fb
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
schedulers/base.go
View file

@ -76,7 +76,9 @@ func (s *BaseScheduler) init(opts ...schedPolicyOption) {
log.Fatal(err)
}
}
s.TasksRunningMutex.Lock()
s.Running = make(map[string]map[string]bool)
s.TasksRunningMutex.Unlock()
s.HostNameToSlaveID = make(map[string]string)
s.mutex = sync.Mutex{}
s.schedWindowResStrategy = schedUtils.SchedWindowResizingCritToStrategy["fillNextOfferCycle"]
@ -101,10 +103,9 @@ func (s *BaseScheduler) newTask(offer *mesos.Offer, task def.Task) *mesos.TaskIn
if _, ok := s.Running[offer.GetSlaveId().GoString()]; !ok {
s.Running[offer.GetSlaveId().GoString()] = make(map[string]bool)
}
s.TasksRunningMutex.Unlock()
// Add task to list of tasks running on node
s.Running[offer.GetSlaveId().GoString()][taskName] = true
s.TasksRunningMutex.Unlock()
resources := []*mesos.Resource{
mesosutil.NewScalarResource("cpus", task.CPU),