Fixed a bug.

This commit is contained in:
Abhishek Jain 2017-03-24 16:36:42 -04:00
parent abc718b554
commit 6665ff4776
2 changed files with 4 additions and 4 deletions

View file

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

View file

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