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

Timestamp:

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

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/build/classes/example/localplugin/FCFS_BFLocalPlugin.java (modified) (3 diffs)

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

@@ -1 +1 @@
 package example.localplugin;
 
-import gridsim.Gridlet;
+import gridsim.dcworms.DCWormsTags;
 import schedframe.events.scheduling.SchedulingEvent;
 import schedframe.scheduling.manager.resources.ResourceManager;
 import schedframe.scheduling.manager.tasks.JobRegistry;
-import schedframe.scheduling.plan.SchedulingPlanInterface;
 import schedframe.scheduling.plan.impl.SchedulingPlan;
 import schedframe.scheduling.plugin.grid.ModuleList;
@@ -13 +12 @@
 import schedframe.scheduling.tasks.WorkloadUnit;
 
-public class FCFS_BFLocalPlugin extends BaseLocalPlugin {
+public class FCFS_BFLocalPlugin extends BaseLocalSchedulingPlugin {
 
-        public SchedulingPlanInterface<?> schedule(SchedulingEvent event, TaskQueueList queues, JobRegistry jobRegistry,
+        public SchedulingPlan schedule(SchedulingEvent event, TaskQueueList queues, JobRegistry jobRegistry,
                          ResourceManager resManager, ModuleList modules) {
 
                 SchedulingPlan plan = new SchedulingPlan();
-                // chose the events types to serve.
-                // Different actions for different events are possible.
+                // Chose the events types to serve. Different actions for different events are possible.
                 switch (event.getType()) {
                 case START_TASK_EXECUTION:
                 case TASK_FINISHED:
-                //case TIMER:
+                        
                         // our tasks are placed only in first queue (see BaseLocalPlugin.placeJobsInQueues() method)
+                        TaskQueue q = queues.get(0);
                         
-                        TaskQueue q = queues.get(0);
                         // 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) {
                                         addToSchedulingPlan(plan, task);
                                 }
@@ -43 +41 @@
         }
 
-        public String getName() {
-                return getClass().getName();
-        }
-
-
 }