From 8a6ad00e2172592d07c5bc931b505f48bb81cf4d Mon Sep 17 00:00:00 2001 From: Pradyumna Kaushik Date: Thu, 10 Nov 2016 21:16:57 -0500 Subject: [PATCH] fixed an error --- schedulers/proactiveclusterwidecappers.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/schedulers/proactiveclusterwidecappers.go b/schedulers/proactiveclusterwidecappers.go index 7b94982..65bdf2e 100644 --- a/schedulers/proactiveclusterwidecappers.go +++ b/schedulers/proactiveclusterwidecappers.go @@ -24,7 +24,7 @@ import ( // Structure containing utility data structures used to compute cluster-wide dynamic cap. type clusterwideCapper struct { // 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. current_sum float64 // 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 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 task.TaskID == taskID { + if tsk.TaskID == taskID { task_element_to_remove = task_element } } @@ -183,7 +183,7 @@ func (capper clusterwideCapper) taskFinished(taskID string) { // Ranked based scheduling. 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 if available_power == nil || len(tasks_to_schedule) == 0 { return nil, nil, errors.New("Invalid argument: available_power, tasks_to_schedule")