Changeset 1051 for DCWoRMS

Timestamp:

05/27/13 14:27:46 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Random_SP.java (modified) (5 diffs)

DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Random_SP.java

@@ -1 +1 @@
 package example.localplugin.coolemall.recs;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Random;
@@ -7 +8 @@
 import schedframe.exceptions.ResourceException;
 import schedframe.resources.UserResourceType;
-import schedframe.resources.computing.ComputingResource;
+import schedframe.resources.computing.ComputingNode;
+import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
 import schedframe.scheduling.manager.resources.ClusterResourceManager;
 import schedframe.scheduling.manager.resources.ResourceManager;
@@ -43 +45 @@
                         TaskQueue q = queues.get(0);
                         
+                        List<ComputingNode> notSelectedNodes = null;
+                        try {
+                                notSelectedNodes = (List<ComputingNode>) resourceManager.getResourcesOfType(new UserResourceType("Node"));
+                        } catch (ResourceException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                        }
                         // check all tasks in queue
                         for (int i = 0; i < q.size(); i++) {
@@ -48 +57 @@
                                 // if status of the tasks in READY
                                 if (task.getStatus() == DCWormsTags.READY) {
-
-                                        String nodeName = chooseRandomProvider(resourceManager);
-                                        if (nodeName != null) {
-                                                addToSchedulingPlan(plan, task, nodeName);
+                                        ComputingNode node = chooseRandomProvider(resourceManager);
+                                        if (node != null) {
+                                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_ON);
+                                                notSelectedNodes.remove(node);
+                                                addToSchedulingPlan(plan, task, node.getName());
                                         }
                                 }
                         }
+                        adjustOtherFans(notSelectedNodes);
                         break;
                 }
@@ -61 +72 @@
 
         @SuppressWarnings("unchecked")
-        private String chooseRandomProvider(ClusterResourceManager resourceManager) {
-                List<ComputingResource> nodes = null;
+        private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager) {
+                List<ComputingNode> nodes = null;
                 try {
-                        nodes = (List<ComputingResource>) resourceManager.getResourcesOfType(new UserResourceType("Node"));
+                        nodes = (List<ComputingNode>) resourceManager.getResourcesOfType(new UserResourceType("Node"));
                 } catch (ResourceException e) {
                         // TODO Auto-generated catch block
                         e.printStackTrace();
                 }
+                nodes = filterNodes(nodes);
                 int nodeIdx = rand.nextInt(nodes.size());
-                return nodes.get(nodeIdx).getName();
+                return nodes.get(nodeIdx);
         }
 
+        private List<ComputingNode> filterNodes(List<ComputingNode> nodes){
+                List<ComputingNode> filteredNodes = new ArrayList<ComputingNode>();
+                for (ComputingNode node : nodes) {
+                        if(node.getFreeProcessors().size() > 0)
+                                filteredNodes.add(node);
+                }
+                
+                return filteredNodes;
+        }
+        private void adjustOtherFans(List<ComputingNode> nodes) {
+                for (ComputingNode node : nodes) {
+                        if (node.getProcessors().size() == node.getFreeProcessorsNumber()) {
+                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF);
+                        } else {
+                                node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_ON);
+                        }
+                }
+        }
 }