Changeset 1378 for DCWoRMS/branches/coolemall/src/test/pausing_resuming

Timestamp:

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

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/test/pausing_resuming

Files:

• FCFSBF_RandomPluginPausing.java (modified) (5 diffs)
• resources1.xml (modified) (1 diff)
• workload.swf (modified) (1 diff)

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;
+        }
 
 

DCWoRMS/branches/coolemall/src/test/pausing_resuming/resources1.xml

@@ -6 +6 @@
         <resources>
                 <computingResource class="DataCenter" name="compRes">
-                        <!-- Defined data center contains only 6 processors -->
-                        <computingResource class="Processor" count="1"/>
+                        <!-- Defined data center contains only 4 processors -->
+                        <computingResource class="Processor" count="4"/>
                 </computingResource>
                 <scheduler class="Cluster" name="cluster">

DCWoRMS/branches/coolemall/src/test/pausing_resuming/workload.swf

@@ -13 +13 @@
 ;PUSpeed: 1
 ;
-
-
-                1                       0                       -1              7200    1               -1              -1              1               -1              -1              -1              -1              -1              1               1               1               -1              -1
-                2                       3600                    -1              7200    1               -1              -1              1               -1              -1              -1              -1              -1              1               1               1               -1              -1
+                0               0               -1              7200            4               -1              -1              4               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1
+                1               360             -1              7200            2               -1              -1              2               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1
+                2               1200            -1              7200            1               -1              -1              1               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1
+                3               3600            -1              7200            1               -1              -1              1               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1
+                4               5400            -1              7200            1               -1              -1              1               7200            -1              -1              -1              -1              -1              -1              -1              -1              -1