Changeset 1247 for DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_NodePowerManagementClusterPlugin.java

Timestamp:

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

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_NodePowerManagementClusterPlugin.java (modified) (8 diffs)

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

@@ -12 +12 @@
 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.profiles.energy.power.StandardPowerStateName;
@@ -54 +54 @@
                                                 addToSchedulingPlan(plan, task, choosenResources);
                                         } else {
-                                                if(harnessIdleNodesToWork(task, resourceManager.getComputingNodes()))
+                                                if(harnessIdleNodesToWork(task, resourceManager.getNodes()))
                                                         i--;
                                         }
                                 }
                         }
-                        turnOffIdleNodes(resourceManager.getComputingNodes());
+                        turnOffIdleNodes(resourceManager.getNodes());
                         break;
                 }
@@ -67 +67 @@
         private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution(ClusterResourceManager resourceManager, TaskInterface<?> task) {
 
-                List<ComputingNode> nodes = resourceManager.getComputingNodes();
+                List<Node> nodes = resourceManager.getNodes();
                 nodes = findSuitableNodes(task, nodes);
-                Collections.sort(nodes, new Comparator<ComputingNode>(){
-                    public int compare(ComputingNode node1, ComputingNode node2){    
+                Collections.sort(nodes, new Comparator<Node>(){
+                    public int compare(Node node1, Node node2){    
                         return node1.getResourceCharacteristic().getParameters().get("category").get(0).getContent().compareTo(node2.getResourceCharacteristic().getParameters().get("category").get(0).getContent());
                     }
@@ -98 +98 @@
         }
         
-        private List<ComputingNode> findSuitableNodes(TaskInterface<?> task, List<ComputingNode> nodes){
+        private List<Node> findSuitableNodes(TaskInterface<?> task, List<Node> nodes){
                 int cpuRequest;
                 try {
@@ -105 +105 @@
                         cpuRequest = 1;
                 }
-                List<ComputingNode> avNodes = new ArrayList<ComputingNode>();
-                for(ComputingNode node: nodes){
+                List<Node> avNodes = new ArrayList<Node>();
+                for(Node node: nodes){
                         if(node.getFreeProcessorsNumber() >= cpuRequest){
                                 avNodes.add(node);
@@ -114 +114 @@
         }
 
-        private void turnOffIdleNodes(List<ComputingNode> nodes){
-                for(ComputingNode node : nodes){
+        private void turnOffIdleNodes(List<Node> nodes){
+                for(Node node : nodes){
                         if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){
                                 node.getPowerInterface().setPowerState(StandardPowerStateName.OFF);
@@ -122 +122 @@
         }
         
-        private boolean harnessIdleNodesToWork(TaskInterface<?> task, List<ComputingNode> nodes){
+        private boolean harnessIdleNodesToWork(TaskInterface<?> task, List<Node> nodes){
                 int cpuRequest;
                 try {
@@ -129 +129 @@
                         cpuRequest = 1;
                 }
-                Collections.sort(nodes, new Comparator<ComputingNode>(){
-                    public int compare(ComputingNode node1, ComputingNode node2){    
+                Collections.sort(nodes, new Comparator<Node>(){
+                    public int compare(Node node1, Node node2){    
                         return node1.getResourceCharacteristic().getParameters().get("category").get(0).getContent().compareTo(node2.getResourceCharacteristic().getParameters().get("category").get(0).getContent());
                     }
                 });
                 for (int i = 0; i < nodes.size() && cpuRequest > 0; i++) {
-                        ComputingNode node = nodes.get(i);
+                        Node node = nodes.get(i);
                         if(node.getPowerInterface().getPowerState() == StandardPowerStateName.OFF){
                                 node.getPowerInterface().setPowerState(StandardPowerStateName.ON);