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

Timestamp:

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

Author:

wojtekp

Message:

 

File:

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

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

@@ -9 +9 @@
 import schedframe.events.scheduling.SchedulingEvent;
 import schedframe.resources.StandardResourceType;
-import schedframe.resources.computing.ComputingNode;
+import schedframe.resources.computing.Node;
 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName;
@@ -46 +46 @@
                         // BaseLocalSchedulingPlugin.placeJobsInQueues() method)
                         TaskQueue q = queues.get(0);
-                        List<ComputingNode> notSelectedNodes = resourceManager.getComputingNodes();
+                        List<Node> notSelectedNodes = resourceManager.getNodes();
                         // check all tasks in queue
                         for (int i = 0; i < q.size(); i++) {
@@ -53 +53 @@
                                 if (task.getStatus() == DCWormsTags.READY) {
 
-                                        ComputingNode node = chooseRandomProvider(resourceManager, task);
+                                        Node node = chooseRandomProvider(resourceManager, task);
                                         if (node != null) {
                                                 //if there are two or more tasks ( running on the given node then
@@ -83 +83 @@
         }
 
-        private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {
-                List<ComputingNode> nodes = filterNodes(resourceManager.getComputingNodes(), task);
+        private Node chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {
+                List<Node> nodes = filterNodes(resourceManager.getNodes(), task);
                 return randomNode(nodes);
         }
         
-        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 {
@@ -106 +106 @@
         }
         
-        private ComputingNode randomNode(List<ComputingNode> nodes){
+        private Node randomNode(List<Node> nodes){
                 return nodes.get(rand.nextInt(nodes.size()));
         }
         
-        private void adjustOtherFans(List<ComputingNode> nodes){
-                for(ComputingNode node : nodes){
+        private void adjustOtherFans(List<Node> nodes){
+                for(Node node : nodes){
                         List<Device> devices = node.getResourceCharacteristic().getDevices();
                         if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){