Changeset 1399 for DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2

Timestamp:

06/26/14 14:24:08 (11 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2

Files:

• RecsIn2OutSP.java (modified) (4 diffs)
• RecsLeft2RightSP.java (modified) (4 diffs)
• RecsOut2InSP.java (modified) (4 diffs)
• RecsRandomSP.java (modified) (4 diffs)

DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsIn2OutSP.java

@@ -18 +18 @@
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Core;
-import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
+import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.ResourceUnit;
@@ -28 +28 @@
 import schedframe.scheduling.plan.SchedulingPlanInterface;
 import schedframe.scheduling.plan.impl.SchedulingPlan;
-import schedframe.scheduling.plugin.grid.ModuleList;
+import schedframe.scheduling.plugin.ModuleList;
 import schedframe.scheduling.queue.TaskQueue;
 import schedframe.scheduling.queue.TaskQueueList;
@@ -61 +61 @@
                                         Node node = chooseProvider(resourceManager, task);
                                         if (node != null) {
-                                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                                                 notSelectedNodes.remove(node);
                                                 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task));
@@ -170 +170 @@
                                 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF);
                         } else { 
-                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                         }
                 }

DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsLeft2RightSP.java

@@ -18 +18 @@
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Core;
-import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
+import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.ResourceUnit;
@@ -28 +28 @@
 import schedframe.scheduling.plan.SchedulingPlanInterface;
 import schedframe.scheduling.plan.impl.SchedulingPlan;
-import schedframe.scheduling.plugin.grid.ModuleList;
+import schedframe.scheduling.plugin.ModuleList;
 import schedframe.scheduling.queue.TaskQueue;
 import schedframe.scheduling.queue.TaskQueueList;
@@ -62 +62 @@
                                         Node node = chooseProvider(resourceManager, task);
                                         if (node != null) {
-                                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                                                 notSelectedNodes.remove(node);
                                                 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task));
@@ -170 +170 @@
                                 // node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF);
                         } else {
-                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                         }
                 }

DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsOut2InSP.java

@@ -18 +18 @@
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Core;
-import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
+import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.ResourceUnit;
@@ -28 +28 @@
 import schedframe.scheduling.plan.SchedulingPlanInterface;
 import schedframe.scheduling.plan.impl.SchedulingPlan;
-import schedframe.scheduling.plugin.grid.ModuleList;
+import schedframe.scheduling.plugin.ModuleList;
 import schedframe.scheduling.queue.TaskQueue;
 import schedframe.scheduling.queue.TaskQueueList;
@@ -61 +61 @@
                                         Node node = chooseProvider(resourceManager, task);
                                         if (node != null) {
-                                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                                                 notSelectedNodes.remove(node);
                                                 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task));
@@ -169 +169 @@
                                 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF);
                         } else { 
-                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                         }
                 }

DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsRandomSP.java

@@ -14 +14 @@
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Core;
-import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
-import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName;
+import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName;
+import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.ResourceUnit;
@@ -26 +26 @@
 import schedframe.scheduling.plan.SchedulingPlanInterface;
 import schedframe.scheduling.plan.impl.SchedulingPlan;
-import schedframe.scheduling.plugin.grid.ModuleList;
+import schedframe.scheduling.plugin.ModuleList;
 import schedframe.scheduling.queue.TaskQueue;
 import schedframe.scheduling.queue.TaskQueueList;
@@ -58 +58 @@
                                         Node node = chooseRandomProvider(resourceManager, task);
                                         if (node != null) {
-                                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                                                 notSelectedNodes.remove(node);
                                                 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task));
@@ -152 +152 @@
                 for(Node node : nodes){
                         if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){
-                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);
+                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF);
                         } else if(new JobRegistryImpl(node.getFullName()).getRunningTasks().size() > 1)
-                                node.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("FAN_ON_TURBO"));
+                                node.getAirflowInterface().setAirflowState(new CustomAirflowStateName("FAN_ON_TURBO"));
                         else 
-                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                 }
         }