Changeset 1420 for DCWoRMS/branches/coolemall/src/test/migrate/NodeEnergyEstimationPlugin.java

Timestamp:

07/15/14 16:37:15 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/test/migrate/NodeEnergyEstimationPlugin.java (modified) (5 diffs)

DCWoRMS/branches/coolemall/src/test/migrate/NodeEnergyEstimationPlugin.java

@@ -2 +2 @@
 
 import schedframe.resources.computing.Node;
-import schedframe.resources.computing.profiles.energy.EnergyEvent;
+import schedframe.resources.computing.profiles.energy.ResourceEvent;
 import schedframe.resources.computing.profiles.energy.power.PowerState;
 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName;
 import schedframe.resources.computing.profiles.energy.power.CustomPowerStateName;
+import schedframe.resources.computing.profiles.energy.power.plugin.EnergyPluginConfiguration;
 import schedframe.resources.devices.PhysicalResource;
 import schedframe.scheduling.manager.tasks.JobRegistry;
@@ -14 +15 @@
 public class NodeEnergyEstimationPlugin extends BaseEnergyEstimationPlugin {
 
-        private static int POWER_CAP_LEVEL = 150;
-
-        
-        public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry,
+        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry,
                         PhysicalResource resource) {
                 double powerConsumption = 0;
+                EnergyPluginConfiguration epConf = (EnergyPluginConfiguration) getConfiguration();
+                
                 Node node = (Node) resource;
 
@@ -25 +25 @@
                         powerConsumption = getPowerConsumption(node);
                 } 
-                if(powerConsumption > POWER_CAP_LEVEL ){
+                if(powerConsumption > epConf.getPowerCapLevel()){
                         DataCenterWorkloadSimulator.getEventManager().sendToAllSchedulers(0, DCWormsTags.POWER_LIMIT_EXCEEDED, node.getFullName());
                 }
@@ -62 +62 @@
 
                                         for(PowerState powerState: node.getPowerInterface().getSupportedPowerStates()){
-                                                Double load = Double.valueOf(powerState.getName().getLabel().substring(3));
+                                                Double load;
+                                                try{
+                                                        load = Double.valueOf(powerState.getName().getLabel().substring(3));
+                                                }catch (Exception e){
+                                                        continue;
+                                                }
                                                 if(loadLevel > load){
                                                         lowerLoadLevel = load;
@@ -68 +73 @@
                                                 else if(loadLevel < load){
                                                         higherLoadLevel = load;
-                                                        break;
                                                 }
                                         }