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

Minor renaming of receivers in some schedulers

Browse source
This commit is contained in:
Renan DelValle 2016-10-18 17:39:44 -04:00
parent bf9a5a6005
commit fa0cd43a5e
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
schedulers/firstfit.go
View file

@ -13,13 +13,13 @@ import (
)
// Decides if to take an offer or not
func (*FirstFit) takeOffer(offer *mesos.Offer, task def.Task) bool {
func (s *FirstFit) takeOffer(offer *mesos.Offer, task def.Task) bool {
cpus, mem, watts := OfferAgg(offer)
//TODO: Insert watts calculation here instead of taking them as a parameter
if cpus >= task.CPU && mem >= task.RAM && watts >= task.Watts {
if cpus >= task.CPU && mem >= task.RAM && (s.ignoreWatts || watts >= task.Watts) {
return true
}

4
schedulers/firstfitsortedwatts.go
View file

@ -14,13 +14,13 @@ import (
)
// Decides if to take an offer or not
func (*FirstFitSortedWatts) takeOffer(offer *mesos.Offer, task def.Task) bool {
func (s *FirstFitSortedWatts) takeOffer(offer *mesos.Offer, task def.Task) bool {
cpus, mem, watts := OfferAgg(offer)
//TODO: Insert watts calculation here instead of taking them as a parameter
if cpus >= task.CPU && mem >= task.RAM && watts >= task.Watts {
if cpus >= task.CPU && mem >= task.RAM && (s.ignoreWatts || watts >= task.Watts) {
return true
}