Changeset 1247 for DCWoRMS/branches/coolemall/src/test/article/recs/plugins/scheduling/RecsExclusivenessRandomNodePowManSP.java

Timestamp:

11/28/13 10:54:54 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/test/article/recs/plugins/scheduling/RecsExclusivenessRandomNodePowManSP.java (modified) (5 diffs)

DCWoRMS/branches/coolemall/src/test/article/recs/plugins/scheduling/RecsExclusivenessRandomNodePowManSP.java

@@ -14 +14 @@
 import schedframe.events.scheduling.SchedulingEvent;
 import schedframe.resources.ResourceStatus;
-import schedframe.resources.computing.ComputingNode;
+import schedframe.resources.computing.Node;
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Core;
@@ -64 +64 @@
                                 }
                         }
-                        turnOffIdleNodes(resourceManager.getComputingNodes());
+                        turnOffIdleNodes(resourceManager.getNodes());
                         break;
                 }
@@ -75 +75 @@
                 Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>();
                 
-                List<ComputingNode> nodes = resourceManager.getComputingNodes();
-                List<ComputingNode> avNodes = filterNodes(nodes, task);
+                List<Node> nodes = resourceManager.getNodes();
+                List<Node> avNodes = filterNodes(nodes, task);
                 if(avNodes.size() == 0)
                         return null;
-                ComputingNode node = randomNode(avNodes);
+                Node node = randomNode(avNodes);
                 if(node.getStatus() == ResourceStatus.UNAVAILABLE) {
                         node.getPowerInterface().setPowerState(StandardPowerStateName.ON);
@@ -113 +113 @@
         }
         
-        private List<ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){
-                List<ComputingNode> filteredNodes = new ArrayList<ComputingNode>();
-                for (ComputingNode node : nodes) {
+        private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){
+                List<Node> filteredNodes = new ArrayList<Node>();
+                for (Node node : nodes) {
                         int cpuRequest;
                         try {
@@ -156 +156 @@
         }
         
-        private ComputingNode randomNode(List<ComputingNode> nodes){
+        private Node randomNode(List<Node> nodes){
                 return nodes.get(rand.nextInt(nodes.size()));
         }
         
-        private void turnOffIdleNodes(List<ComputingNode> nodes){
-                for(ComputingNode node : nodes){
+        private void turnOffIdleNodes(List<Node> nodes){
+                for(Node node : nodes){
                         Processor proc = node.getProcessors().get(0);
                         int freeCores = 0;