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

Minor comments and style changes

Browse source
This commit is contained in:
Renan DelValle 2017-01-06 18:53:03 -05:00
parent 776bffb100
commit 841c5e0392
2 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
schedulers/base.go
View file

@ -6,8 +6,7 @@ import (
"log" "log"
) )
type base struct { type base struct{}
}
func (s *base) OfferRescinded(_ sched.SchedulerDriver, offerID *mesos.OfferID) { func (s *base) OfferRescinded(_ sched.SchedulerDriver, offerID *mesos.OfferID) {
log.Printf("Offer %s rescinded", offerID) log.Printf("Offer %s rescinded", offerID)

5
schedulers/bpMaxMin.go
View file

@ -124,6 +124,9 @@ func (s *BPMaxMinWatts) newTask(offer *mesos.Offer, task def.Task) *mesos.TaskIn
} }
} }
// Determine if the remaining space inside of the offer is enough for this
// the task we need to create. If it is, create a TaskInfo and return it.
func (s *BPMaxMinWatts) CheckFit(i int, func (s *BPMaxMinWatts) CheckFit(i int,
task def.Task, task def.Task,
offer *mesos.Offer, offer *mesos.Offer,
@ -187,7 +190,7 @@ func (s *BPMaxMinWatts) ResourceOffers(driver sched.SchedulerDriver, offers []*m
totalCPU := 0.0 totalCPU := 0.0
totalRAM := 0.0 totalRAM := 0.0
// Ordered s.tasks is ordered by median Max Peak // Assumes s.tasks is ordered in non-decreasing median max peak order
// Attempt to schedule a single instance of the heaviest workload available first // Attempt to schedule a single instance of the heaviest workload available first
// Start from the back until one fits // Start from the back until one fits