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

Using ranked proactive cluster wide capper with clever recapping

Browse source
This commit is contained in:
Pradyumna Kaushik 2016-12-07 01:11:30 -05:00 • committed by Renan DelValle
parent f55169c91c
commit 2d3b484151
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
scheduler.go
View file

@ -56,7 +56,7 @@ func main() {
fmt.Println(task) fmt.Println(task)
} }
scheduler := schedulers.NewProactiveClusterwideCapFCFS(tasks, *ignoreWatts) scheduler := schedulers.NewProactiveClusterwideCapRanked(tasks, *ignoreWatts)
driver, err := sched.NewMesosSchedulerDriver(sched.DriverConfig{ driver, err := sched.NewMesosSchedulerDriver(sched.DriverConfig{
Master: *master, Master: *master,
Framework: &mesos.FrameworkInfo{ Framework: &mesos.FrameworkInfo{

4
schedulers/proactiveclusterwidecappingranked.go
View file

@ -381,8 +381,8 @@ func (s *ProactiveClusterwideCapRanked) StatusUpdate(driver sched.SchedulerDrive
// Need to remove the task from the window // Need to remove the task from the window
s.capper.taskFinished(*status.TaskId.Value) s.capper.taskFinished(*status.TaskId.Value)
// Determining the new cluster wide cap. // Determining the new cluster wide cap.
tempCap, err := s.capper.recap(s.totalPower, s.taskMonitor, *status.TaskId.Value) //tempCap, err := s.capper.recap(s.totalPower, s.taskMonitor, *status.TaskId.Value)
// tempCap, err := s.capper.cleverRecap(s.totalPower, s.taskMonitor, *status.TaskId.Value) tempCap, err := s.capper.cleverRecap(s.totalPower, s.taskMonitor, *status.TaskId.Value)
if err == nil { if err == nil {
// If new determined cap value is different from the current recap value then we need to recap. // If new determined cap value is different from the current recap value then we need to recap.