Changeset 778 for DCWoRMS/trunk/src/example/localplugin/FCFSBF_FanManagementClusterPlugin.java

Timestamp:

01/10/13 12:35:31 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/src/example/localplugin/FCFSBF_FanManagementClusterPlugin.java (modified) (5 diffs)

DCWoRMS/trunk/src/example/localplugin/FCFSBF_FanManagementClusterPlugin.java

@@ -3 +3 @@
 import gridsim.dcworms.DCWormsTags;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Random;
@@ -9 +10 @@
 import schedframe.resources.computing.ComputingNode;
 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
+import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName;
 import schedframe.scheduling.manager.resources.ClusterResourceManager;
 import schedframe.scheduling.manager.resources.ResourceManager;
 import schedframe.scheduling.manager.tasks.JobRegistry;
+import schedframe.scheduling.manager.tasks.JobRegistryImpl;
 import schedframe.scheduling.plan.SchedulingPlanInterface;
 import schedframe.scheduling.plan.impl.SchedulingPlan;
@@ -48 +51 @@
                                 if (task.getStatus() == DCWormsTags.READY) {
 
-                                        ComputingNode node = chooseRandomProvider(resourceManager);
+                                        ComputingNode node = chooseRandomProvider(resourceManager, task);
                                         if (node != null) {
-                                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_ON);
+                                                //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);
                                                 notSelectedNodes.remove(node);
                                                 addToSchedulingPlan(plan, task, node.getName());
@@ -56 +63 @@
                                 }
                         }
-                        turnOffIdleNodes(notSelectedNodes);
+                        adjustOtherFans(notSelectedNodes);
                         break;
                 }
@@ -62 +69 @@
         }
 
-        private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager) {
-                List<ComputingNode> nodes = resourceManager.getComputingNodes();
-                int nodeIdx = rand.nextInt(nodes.size());
-                return nodes.get(nodeIdx);
+        private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {
+                List<ComputingNode> nodes = filterNodes(resourceManager.getComputingNodes(), task);
+                return randomNode(nodes);
         }
         
-        private void turnOffIdleNodes(List<ComputingNode> nodes){
+        private List<ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){
+                List<ComputingNode> filteredNodes = new ArrayList<ComputingNode>();
+                for (ComputingNode node : nodes) {
+                        int cpuRequest;
+                        try {
+                                cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
+                        } catch (NoSuchFieldException e) {
+                                cpuRequest = 0;
+                        }
+                        if (cpuRequest != 0) {
+                                if(node.getFreeProcessorsNumber() > cpuRequest)
+                                        filteredNodes.add(node);
+                        }
+                }
+                
+                return filteredNodes;
+        }
+        
+        private ComputingNode randomNode(List<ComputingNode> nodes){
+                return nodes.get(rand.nextInt(nodes.size()));
+        }
+        
+        private void adjustOtherFans(List<ComputingNode> nodes){
                 for(ComputingNode node : nodes){
                         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);
                 }
         }
 
-
+        
 }