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

fixed an error

Browse source
This commit is contained in:
Pradyumna Kaushik 2016-11-10 21:16:57 -05:00 • committed by Renan DelValle
parent 0f8a2d3f0c
commit 7b19cfb4fc
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
schedulers/proactiveclusterwidecappers.go
View file

@ -24,7 +24,7 @@ import (
// Structure containing utility data structures used to compute cluster-wide dynamic cap. // Structure containing utility data structures used to compute cluster-wide dynamic cap.
type clusterwideCapper struct { type clusterwideCapper struct {
// window of tasks. // window of tasks.
window_of_tasks list.list window_of_tasks list.List
// The current sum of requested powers of the tasks in the window. // The current sum of requested powers of the tasks in the window.
current_sum float64 current_sum float64
// The current number of tasks in the window. // The current number of tasks in the window.
@ -167,7 +167,7 @@ func (capper clusterwideCapper) taskFinished(taskID string) {
var task_element_to_remove *list.Element var task_element_to_remove *list.Element
for task_element := capper.window_of_tasks.Front(); task_element != nil; task_element = task_element.Next() { for task_element := capper.window_of_tasks.Front(); task_element != nil; task_element = task_element.Next() {
if tsk, ok := task_element.Value.(*def.Task); ok { if tsk, ok := task_element.Value.(*def.Task); ok {
if task.TaskID == taskID { if tsk.TaskID == taskID {
task_element_to_remove = task_element task_element_to_remove = task_element
} }
} }
@ -183,7 +183,7 @@ func (capper clusterwideCapper) taskFinished(taskID string) {
// Ranked based scheduling. // Ranked based scheduling.
func (capper clusterwideCapper) rankedDetermineCap(available_power map[string]float64, func (capper clusterwideCapper) rankedDetermineCap(available_power map[string]float64,
tasks_to_schedule []*def.Task) ([]*def.Task, map[string]float64, error) { tasks_to_schedule []*def.Task) ([]*def.Task, map[int]float64, error) {
// Validation // Validation
if available_power == nil || len(tasks_to_schedule) == 0 { if available_power == nil || len(tasks_to_schedule) == 0 {
return nil, nil, errors.New("Invalid argument: available_power, tasks_to_schedule") return nil, nil, errors.New("Invalid argument: available_power, tasks_to_schedule")