Changeset 1378 for DCWoRMS/branches/coolemall/src/test/pausing_resuming/FCFSBF_RandomPluginPausing.java

Timestamp:

06/06/14 10:48:49 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/test/pausing_resuming/FCFSBF_RandomPluginPausing.java (modified) (5 diffs)

DCWoRMS/branches/coolemall/src/test/pausing_resuming/FCFSBF_RandomPluginPausing.java

@@ -1 +1 @@
 package test.pausing_resuming;
-
-import dcworms.schedframe.scheduling.ExecTask;
-import dcworms.schedframe.scheduling.Executable;
-import example.localplugin.BaseLocalSchedulingPlugin;
-import gridsim.Gridlet;
-import gridsim.dcworms.DCWormsTags;
 
 import java.util.ArrayList;
@@ -11 +5 @@
 import java.util.List;
 import java.util.Map;
-import java.util.Properties;
-
-import org.joda.time.DateTime;
 
 import schedframe.events.scheduling.SchedulingEvent;
-import schedframe.exceptions.ResourceException;
 import schedframe.resources.ResourceStatus;
-import schedframe.resources.StandardResourceType;
-import schedframe.resources.computing.Node;
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Processor;
-import schedframe.resources.computing.profiles.energy.EnergyEventType;
-import schedframe.resources.units.Memory;
-import schedframe.resources.units.PEUnit;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.ResourceUnit;
@@ -35 +20 @@
 import schedframe.scheduling.plan.impl.SchedulingPlan;
 import schedframe.scheduling.plugin.grid.ModuleList;
-import schedframe.scheduling.plugin.local.ResourceAllocation;
 import schedframe.scheduling.queue.TaskQueue;
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
-import simulator.DataCenterWorkloadSimulator;
+import dcworms.schedframe.scheduling.ExecTask;
+import example.localplugin.BaseLocalSchedulingPlugin;
+import gridsim.dcworms.DCWormsTags;
 
 public class FCFSBF_RandomPluginPausing extends BaseLocalSchedulingPlugin {
@@ -67 +53 @@
                                                 addToSchedulingPlan(plan, task, choosenResources);
                                         } else {
-                                                if(jobRegistry.getRunningTasks().size() > 0) {
-                                                        for(ExecTask exec: jobRegistry.getRunningTasks()){
-                                                                jobRegistry.pauseTask(exec.getJobId(), exec.getId());
-                                                        }
-                                                } 
+                                                ExecTask taskToPause = getTaskWithLowestPriority(jobRegistry.getRunningTasks());
+                                                if(getTaskPriority(task) > getTaskPriority(taskToPause)){
+                                                        jobRegistry.pauseTask(taskToPause.getJobId(), taskToPause.getId());
+                                                }
                                         }
                                 }
@@ -154 +139 @@
                 return null;
         }
-
+        
+        
+        private int getTaskPriority(TaskInterface<?> task){
+                int priority;
+                
+                try {
+                        double cpuRequest = task.getCpuCntRequest();
+                        priority = (-1) * Double.valueOf(cpuRequest).intValue();
+                } catch (NoSuchFieldException e) {
+                        priority = Integer.MIN_VALUE;
+                }
+                
+                return priority;
+        }
+        
+        private ExecTask getTaskWithLowestPriority(List<ExecTask> tasks){
+                ExecTask lowestPriorityTask = null;
+                int lowestPriority = Integer.MAX_VALUE;
+                for(ExecTask execTask: tasks){
+                        int taskPriority = getTaskPriority(execTask);
+                        if(taskPriority < lowestPriority){
+                                lowestPriority = getTaskPriority(execTask);
+                                lowestPriorityTask = execTask;
+                        }
+                }
+                
+                return lowestPriorityTask;
+        }