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

Performed a git fmt

Browse source
This commit is contained in:
Abhishek Jain 2017-03-24 16:34:17 -04:00
parent 10358b418b
commit abc718b554
3 changed files with 12 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

8
schedulers/bottomHeavy.go
View file

@ -293,16 +293,16 @@ func (s *BottomHeavy) ResourceOffers(driver sched.SchedulerDriver, offers []*mes
default:
}
if _, ok := constants.PowerClasses["A"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["A"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersHeavyPowerClasses, offer)
}
if _, ok := constants.PowerClasses["B"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["B"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersHeavyPowerClasses, offer)
}
if _, ok := constants.PowerClasses["C"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["C"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersLightPowerClasses, offer)
}
if _, ok := constants.PowerClasses["D"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["D"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersLightPowerClasses, offer)
}

8
schedulers/topHeavy.go
View file

@ -292,16 +292,16 @@ func (s *TopHeavy) ResourceOffers(driver sched.SchedulerDriver, offers []*mesos.
default:
}
if _, ok := constants.PowerClasses["A"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["A"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersHeavyPowerClasses, offer)
}
if _, ok := constants.PowerClasses["B"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["B"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersHeavyPowerClasses, offer)
}
if _, ok := constants.PowerClasses["C"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["C"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersLightPowerClasses, offer)
}
if _, ok := constants.PowerClasses["D"][*offer.Hostname]; ok{
if _, ok := constants.PowerClasses["D"][*offer.Hostname]; ok {
offersHeavyPowerClasses = append(offersLightPowerClasses, offer)
}
}

8
utilities/offerUtils/offerUtils.go
View file

@ -1,11 +1,11 @@
package offerUtils
import (
"bitbucket.org/sunybingcloud/electron-archive/utilities/offerUtils"
"bitbucket.org/sunybingcloud/electron/constants"
mesos "github.com/mesos/mesos-go/mesosproto"
"strings"
"log"
"bitbucket.org/sunybingcloud/electron-archive/utilities/offerUtils"
"strings"
)
func OfferAgg(offer *mesos.Offer) (float64, float64, float64) {
@ -81,8 +81,8 @@ func AddHostIfNew(offer *mesos.Offer) {
constants.PowerClasses[class] = make(map[string]struct{})
}
// If the host of this class is not yet present in PowerClasses[class], add it.
if _, ok:= constants.PowerClasses[class][host]; !ok {
if _, ok := constants.PowerClasses[class][host]; !ok {
constants.PowerClasses[class][host] = struct{}{}
}
}
}
}