Changeset 708 for DCWoRMS/trunk/src/test/article/recs/plugins

Timestamp:

12/20/12 17:23:35 (12 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/trunk/src/test/article/recs/plugins/scheduling

Files:

• RecsExclusivenessDFSSP.java (modified) (3 diffs)
• RecsExclusivenessEnOptNodePowManSP.java (added)
• RecsExclusivenessEnOptSP.java (modified) (5 diffs)
• RecsExclusivenessNodePowManSP.java (deleted)
• RecsExclusivenessRandomNodePowManSP.java (added)
• RecsExclusivenessRandomSP.java (modified) (2 diffs)
• RecsExclusivenessSP.java (deleted)
• RecsSP.java (modified) (1 diff)
• old (added)

DCWoRMS/trunk/src/test/article/recs/plugins/scheduling/RecsExclusivenessDFSSP.java

@@ -3 +3 @@
 import gridsim.dcworms.DCWormsTags;
 
+import java.io.FileNotFoundException;
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.MissingResourceException;
 import java.util.Random;
 
@@ -132 +135 @@
                                 if(freeCores != cores.size())
                                         continue;
+                                try {
+                                        if(!getExecutiveness(createExecutivenessQuery(task, node)))
+                                                continue;
+                                } catch (FileNotFoundException e) {
+                                        continue;
+                                } catch (IOException e) {
+                                        continue;
+                                } catch (MissingResourceException e){
+                                        continue;
+                                }
                                 
                                 filteredNodes.add(node);
@@ -158 +171 @@
                                 rppi.setPState(rppi.getHighestPState().getName());
                         else
-                                rppi.setPState(rppi.getLowestPState().getName());
+                                rppi.setPState(rppi.getHighestPState().getName());
 
                 }

DCWoRMS/trunk/src/test/article/recs/plugins/scheduling/RecsExclusivenessEnOptSP.java

@@ -22 +22 @@
 import schedframe.resources.computing.Core;
 import schedframe.resources.computing.Processor;
+import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.ResourceUnit;
@@ -84 +85 @@
                 List<ComputingNode> nodes = resourceManager.getComputingNodes();
                 Collections.sort(nodes, new EnergyComparator(task));
+                //System.out.println("*****");
                 for (ComputingNode node : nodes) {
+                        //System.out.println(node.getCategory());
                         int cpuRequest;
                         try {
@@ -111 +114 @@
                                 if(freeCores != cores.size())
                                         continue;
+                                
+                                try {
+                                        if(!getExecutiveness(createExecutivenessQuery(task, node)))
+                                                continue;
+                                } catch (FileNotFoundException e) {
+                                        continue;
+                                } catch (IOException e) {
+                                        continue;
+                                } catch (MissingResourceException e){
+                                        continue;
+                                }
+                                
                                 List<ComputingResource> choosenResources = new ArrayList<ComputingResource>();                          
                                 for (int i = 0; i < cores.size() && cpuRequest > 0; i++) {
@@ -201 +216 @@
                 double node2EU = Double.MAX_VALUE;
                 try {
-                                node1EU = getMeasuredTime(createQuery(task, node1)) * getMeasuredPower(createQuery(task, node1));
-                                node2EU = getMeasuredTime(createQuery(task, node2)) * getMeasuredPower(createQuery(task, node2));
-                        } catch (FileNotFoundException e) {
+                                node1EU = getMeasuredTime(createQuery(task, node1)) * (getMeasuredPower(createQuery(task, node1)) - node1.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON));
+                                //System.out.println(node1.getCategory() + ": " + node1EU + "; "+ getMeasuredTime(createQuery(task, node1)) +";" + node1.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON) + ":" + getMeasuredPower(createQuery(task, node1)));
+                                node2EU = getMeasuredTime(createQuery(task, node2)) * (getMeasuredPower(createQuery(task, node2)) - node2.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON));
+                                //System.out.println(node2.getCategory() + ": " + node2EU + "; "+ getMeasuredTime(createQuery(task, node2)) +";" + node2.getPowerInterface().getPowerConsumption(StandardPowerStateName.ON) + ":" + getMeasuredPower(createQuery(task, node2)));
+                } catch (FileNotFoundException e) {
 
                         } catch (IOException e) {
@@ -209 +226 @@
                         } catch (MissingResourceException e){
                                 
+                        } catch (NoSuchFieldException e) {
+
                         }
                 if(node1EU > node2EU)

DCWoRMS/trunk/src/test/article/recs/plugins/scheduling/RecsExclusivenessRandomSP.java

@@ -3 +3 @@
 import gridsim.dcworms.DCWormsTags;
 
+import java.io.FileNotFoundException;
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.MissingResourceException;
 import java.util.Random;
 
@@ -131 +134 @@
                                         continue;
                                 
+                                try {
+                                        if(!getExecutiveness(createExecutivenessQuery(task, node)))
+                                                continue;
+                                } catch (FileNotFoundException e) {
+                                        continue;
+                                } catch (IOException e) {
+                                        continue;
+                                } catch (MissingResourceException e){
+                                        continue;
+                                }
                                 filteredNodes.add(node);
                         }

DCWoRMS/trunk/src/test/article/recs/plugins/scheduling/RecsSP.java

@@ -27 +27 @@
         }
         
-        protected String createQuery(TaskInterface<?> task, ComputingNode node) {
+        protected String createExecutivenessQuery(TaskInterface<?> task, ComputingNode node) {
                 Executable exec = (Executable)task;
                 String query = getApplicationType(exec) + "." + getNodeCategory(node);