Changeset 539 for DCWoRMS/trunk/build/classes/example/localplugin/FCFSCPUFreqScalingClusterLocalPlugin.java

Timestamp:

10/31/12 13:52:06 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/build/classes/example/localplugin/FCFSCPUFreqScalingClusterLocalPlugin.java (modified) (9 diffs)

DCWoRMS/trunk/build/classes/example/localplugin/FCFSCPUFreqScalingClusterLocalPlugin.java

@@ -1 +1 @@
 package example.localplugin;
 
-import gridsim.Gridlet;
+import gridsim.dcworms.DCWormsTags;
 
 import java.util.ArrayList;
@@ -18 +18 @@
 import schedframe.resources.units.ResourceUnitName;
 import schedframe.resources.units.StandardResourceUnitName;
-import schedframe.scheduling.ResourceHistoryItem;
-import schedframe.scheduling.UsedResourceList;
+import schedframe.scheduling.UsedResourcesList;
 import schedframe.scheduling.manager.resources.ClusterResourceManager;
 import schedframe.scheduling.manager.resources.ResourceManager;
@@ -28 +27 @@
 import schedframe.scheduling.queue.TaskQueue;
 import schedframe.scheduling.queue.TaskQueueList;
-import schedframe.scheduling.tasks.SubmittedTask;
 import schedframe.scheduling.tasks.TaskInterface;
 import schedframe.scheduling.tasks.WorkloadUnit;
+import dcworms.schedframe.scheduling.Executable;
 
-public class FCFSCPUFreqScalingClusterLocalPlugin extends BaseLocalPlugin {
+public class FCFSCPUFreqScalingClusterLocalPlugin extends BaseLocalSchedulingPlugin {
 
         List<Processor> allocatedCPUs;
@@ -39 +38 @@
         }
 
-        public SchedulingPlanInterface schedule(SchedulingEvent event, TaskQueueList queues, JobRegistry jobRegistry,
+        public SchedulingPlanInterface<?> schedule(SchedulingEvent event, TaskQueueList queues, JobRegistry jobRegistry,
                         ResourceManager resManager, ModuleList modules) {
 
@@ -55 +54 @@
                         // check all tasks in queue
                         for (int i = 0; i < q.size(); i++) {
-                                WorkloadUnit<?> job = q.get(i);
+                                WorkloadUnit job = q.get(i);
                                 TaskInterface<?> task = (TaskInterface<?>) job;
                                 // if status of the tasks in READY
-                                if (task.getStatus() == Gridlet.READY) {
+                                if (task.getStatus() == DCWormsTags.READY) {
 
                                         Map<ResourceUnitName, ResourceUnit> choosenResources = chooseResourcesForExecution(resourceManager, task);
@@ -76 +75 @@
                 case TASK_FINISHED:
                         TaskFinishedEvent finEvent = (TaskFinishedEvent) event;
-                        SubmittedTask subTask = (SubmittedTask )jobRegistry.getSubmittedTask(finEvent.getJobId(), finEvent.getTaskId());
-                        UsedResourceList<ResourceHistoryItem> usedResourcesList = subTask.getUsedResources();
+                        Executable exec = (Executable) jobRegistry.getExecutable(finEvent.getJobId(), finEvent.getTaskId());
+                        UsedResourcesList usedResourcesList = exec.getUsedResources();
                         ProcessingElements pes = (ProcessingElements)usedResourcesList.getLast().getResourceUnits().get(StandardResourceUnitName.PE);
                         List<Processor> processors =  new ArrayList<Processor>();
@@ -89 +88 @@
                 case TASK_REQUESTED_TIME_EXPIRED:
                         TaskRequestedTimeExpiredEvent timExpEvent = (TaskRequestedTimeExpiredEvent) event;
-                         subTask = (SubmittedTask )jobRegistry.getSubmittedTask(timExpEvent.getJobId(), timExpEvent.getTaskId());
-                        usedResourcesList = subTask.getUsedResources();
+                        exec = (Executable) jobRegistry.getExecutable(timExpEvent.getJobId(), timExpEvent.getTaskId());
+                        usedResourcesList = exec.getUsedResources();
                         pes = (ProcessingElements)usedResourcesList.getLast().getResourceUnits().get(StandardResourceUnitName.PE);
                         processors =  new ArrayList<Processor>();
@@ -98 +97 @@
                         // check all tasks in queue
                         for (int i = 0; i < q.size(); i++) {
-                                WorkloadUnit<?> job = q.get(i);
+                                WorkloadUnit job = q.get(i);
                                 TaskInterface<?> task = (TaskInterface<?>) job;
                                 // if status of the tasks in READY
-                                if (task.getStatus() == Gridlet.READY) {
+                                if (task.getStatus() == DCWormsTags.READY) {
 
                                         Map<ResourceUnitName, ResourceUnit> choosenResources = chooseResourcesForExecution(resourceManager, task);
@@ -188 +187 @@
                 }
         }
-        
-        public String getName() {
-                return getClass().getName();
-        }
 
 }