Changeset 1207 for DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_FanManagementClusterPlugin.java

Timestamp:

11/26/13 11:56:07 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_FanManagementClusterPlugin.java (modified) (3 diffs)

DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_FanManagementClusterPlugin.java

@@ -8 +8 @@
 
 import schedframe.events.scheduling.SchedulingEvent;
+import schedframe.resources.StandardResourceType;
 import schedframe.resources.computing.ComputingNode;
 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName;
+import schedframe.resources.devices.Device;
 import schedframe.scheduling.manager.resources.ClusterResourceManager;
 import schedframe.scheduling.manager.resources.ResourceManager;
@@ -54 +56 @@
                                         if (node != null) {
                                                 //if there are two or more tasks ( running on the given node then
-                                                if(new JobRegistryImpl(node.getName()).getRunningTasks().size() > 0)
-                                                        node.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("FAN_ON_TURBO"));
-                                                else 
-                                                        node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_ON);
+                                                if(new JobRegistryImpl(node.getFullName()).getRunningTasks().size() > 0){
+                                                        List<Device> devices = node.getResourceCharacteristic().getDevices();
+                                                        for(Device dev : devices){
+                                                                if(dev.getType().equals(StandardResourceType.Fan)){
+                                                                        dev.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("FAN_ON_TURBO"));
+                                                                }
+                                                        }
+                                                }
+                                                else {
+                                                        List<Device> devices = node.getResourceCharacteristic().getDevices();
+                                                        for(Device dev : devices){
+                                                                if(dev.getType().equals(StandardResourceType.Fan)){
+                                                                        dev.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);       
+                                                                }
+                                                        }
+                                                }
                                                 notSelectedNodes.remove(node);
-                                                addToSchedulingPlan(plan, task, node.getName());
+                                                addToSchedulingPlan(plan, task, node.getFullName());
                                         }
                                 }
@@ -98 +112 @@
         private void adjustOtherFans(List<ComputingNode> nodes){
                 for(ComputingNode node : nodes){
+                        List<Device> devices = node.getResourceCharacteristic().getDevices();
                         if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){
-                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF);
-                        } else if(new JobRegistryImpl(node.getName()).getRunningTasks().size() > 1)
-                                node.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("FAN_ON_TURBO"));
-                        else 
-                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_ON);
+                                for(Device dev : devices){
+                                        if(dev.getType().equals(StandardResourceType.Fan)){
+                                                dev.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);
+                                        }
+                                }
+                        } else if(new JobRegistryImpl(node.getFullName()).getRunningTasks().size() > 1){
+                                for(Device dev : devices){
+                                        if(dev.getType().equals(StandardResourceType.Fan)){
+                                                dev.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("FAN_ON_TURBO"));
+                                        }
+                                }
+                        }
+                        else {
+                                for(Device dev : devices){
+                                        if(dev.getType().equals(StandardResourceType.Fan)){
+                                                dev.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);
+                                        }
+                                }
+                        }
                 }
         }