Changeset 1499 for DCWoRMS/branches/coolemall/src/experiments/e2dc2013/recs/plugins/scheduling/exp2

Timestamp:

12/29/14 17:24:25 (10 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/experiments/e2dc2013

Files:

• . (added)
• recs (added)
• recs/plugins (added)
• recs/plugins/scheduling (added)
• recs/plugins/scheduling/exp2 (copied) (copied from DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2)
• recs/plugins/scheduling/exp2/RecsIn2OutSP.java (modified) (2 diffs)
• recs/plugins/scheduling/exp2/RecsLeft2RightSP.java (modified) (5 diffs)
• recs/plugins/scheduling/exp2/RecsOut2InSP.java (modified) (2 diffs)
• recs/plugins/scheduling/exp2/RecsRandomSP.java (modified) (2 diffs)

DCWoRMS/branches/coolemall/src/experiments/e2dc2013/recs/plugins/scheduling/exp2/RecsIn2OutSP.java

@@ -1 @@
-package test.article2.recs.plugins.scheduling.exp2;
-
+package experiments.e2dc2013.recs.plugins.scheduling.exp2;
+
+import experiments.e2dc2013.recs.plugins.scheduling.RecsSP;
 import gridsim.dcworms.DCWormsTags;
 
@@ -32 +33 @@
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
-import test.article2.recs.plugins.scheduling.RecsSP;
 
 public class RecsIn2OutSP extends RecsSP {

DCWoRMS/branches/coolemall/src/experiments/e2dc2013/recs/plugins/scheduling/exp2/RecsLeft2RightSP.java

@@ -1 @@
-package test.article2.recs.plugins.scheduling.exp2;
-
+package experiments.e2dc2013.recs.plugins.scheduling.exp2;
+
+import experiments.e2dc2013.recs.plugins.scheduling.RecsSP;
 import gridsim.dcworms.DCWormsTags;
 
@@ -15 +16 @@
 import schedframe.events.scheduling.SchedulingEvent;
 import schedframe.resources.ResourceStatus;
+import schedframe.resources.StandardResourceType;
 import schedframe.resources.computing.Node;
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Core;
+import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName;
 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName;
+import schedframe.resources.devices.Device;
+import schedframe.resources.devices.Fan;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.ResourceUnit;
@@ -32 +37 @@
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
-import test.article2.recs.plugins.scheduling.RecsSP;
 
 public class RecsLeft2RightSP extends RecsSP {
@@ -62 +66 @@
                                         Node node = chooseProvider(resourceManager, task);
                                         if (node != null) {
-                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
+                                                for(Device device: node.getParent().getResourceCharacteristic().getDevices()){
+                                                        
+                                                        if(device.getType().equals(StandardResourceType.Fan)){
+                                                                Fan fan = (Fan) device;
+
+                                                                if(fan.getChilledResources().contains(node.getFullName())){
+                                                                        fan.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
+                                                                }
+                                                        }
+                                                }
+                                                //node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                                                 notSelectedNodes.remove(node);
                                                 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task));
@@ -170 +184 @@
                                 // node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF);
                         } else {
-                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
+                                for(Device device: node.getParent().getResourceCharacteristic().getDevices()){
+                                        
+                                        if(device.getType().equals(StandardResourceType.Fan)){
+                                                Fan fan = (Fan) device;
+
+                                                if(fan.getChilledResources().contains(node.getFullName())){
+                                                        fan.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
+                                                }
+                                        }
+                                }
+                                //node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON);
                         }
                 }

DCWoRMS/branches/coolemall/src/experiments/e2dc2013/recs/plugins/scheduling/exp2/RecsOut2InSP.java

@@ -1 @@
-package test.article2.recs.plugins.scheduling.exp2;
+package experiments.e2dc2013.recs.plugins.scheduling.exp2;
 
+import experiments.e2dc2013.recs.plugins.scheduling.RecsSP;
 import gridsim.dcworms.DCWormsTags;
 
@@ -32 +33 @@
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
-import test.article2.recs.plugins.scheduling.RecsSP;
 
 public class RecsOut2InSP extends RecsSP {

DCWoRMS/branches/coolemall/src/experiments/e2dc2013/recs/plugins/scheduling/exp2/RecsRandomSP.java

@@ -1 @@
-package test.article2.recs.plugins.scheduling.exp2;
+package experiments.e2dc2013.recs.plugins.scheduling.exp2;
 
+import experiments.e2dc2013.recs.plugins.scheduling.RecsSP;
 import gridsim.dcworms.DCWormsTags;
 
@@ -30 +31 @@
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
-import test.article2.recs.plugins.scheduling.RecsSP;
 
 public class RecsRandomSP extends RecsSP {