Ignore:
Timestamp:
07/15/14 16:26:31 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/example/energy
Files:
16 edited

Legend:

Unmodified
Added
Removed
  • DCWoRMS/branches/coolemall/src/example/energy/BaseEnergyEstimationPlugin.java

    r1396 r1415  
    33import schedframe.Parameters; 
    44import schedframe.PluginConfiguration; 
    5 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     5import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    66import schedframe.resources.computing.profiles.energy.power.plugin.EnergyEstimationPlugin; 
     7import schedframe.resources.computing.profiles.energy.power.plugin.EnergyPluginConfiguration; 
    78import schedframe.resources.devices.PhysicalResource; 
    89import schedframe.scheduling.manager.tasks.JobRegistry; 
     10import schemas.StringValueWithUnit; 
    911 
    1012public abstract class BaseEnergyEstimationPlugin implements EnergyEstimationPlugin { 
    1113 
     14         EnergyPluginConfiguration plugConf; 
     15          
    1216        @Override 
    1317        public PluginConfiguration getConfiguration() { 
    14                 // TODO Auto-generated method stub 
    15                 return null; 
     18                return plugConf; 
    1619        } 
    1720         
    1821        @Override 
    19         public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     22        public double estimateAirflow(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    2023                throw new RuntimeException("Not implemented."); 
    2124        } 
    2225 
    2326        @Override 
    24         public double estimateTemperature(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource  resource) { 
     27        public double estimateTemperature(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource  resource) { 
    2528                throw new RuntimeException("Not implemented."); 
    2629        } 
    2730         
    2831        public void init(Parameters parameters) { 
    29  
     32                plugConf = new EnergyPluginConfiguration(); 
     33                try{ 
     34                        StringValueWithUnit powerCapLevel = parameters.get("powerCapLevel").get(0); 
     35                        plugConf.setPowerCapLevel(Double.valueOf(powerCapLevel.getContent()).doubleValue()); 
     36                } catch(Exception e){ 
     37                        plugConf.setPowerCapLevel(-1); 
     38                } 
     39                try{ 
     40                        StringValueWithUnit powerFloorLevel = parameters.get("powerFloorLevel").get(0); 
     41                        plugConf.setPowerFloorLevel(Double.valueOf(powerFloorLevel.getContent()).doubleValue()); 
     42                } catch(Exception e){ 
     43                        plugConf.setPowerFloorLevel(-1); 
     44                } 
    3045        } 
    3146 
  • DCWoRMS/branches/coolemall/src/example/energy/DataCenterEnergyEstimationPlugin.java

    r1258 r1415  
    33import schedframe.resources.computing.Node; 
    44import schedframe.resources.computing.DataCenter; 
    5 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     5import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    66import schedframe.resources.computing.profiles.energy.power.PowerUsage; 
    77import schedframe.resources.devices.PhysicalResource; 
     
    1111 
    1212        @Override 
    13         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     13        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1414                        PhysicalResource resource) { 
    1515                double power = 0; 
  • DCWoRMS/branches/coolemall/src/example/energy/DefaultEnergyEstimationPlugin.java

    r1207 r1415  
    22 
    33import schedframe.resources.computing.ComputingResource; 
    4 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     4import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    55import schedframe.resources.devices.PhysicalResource; 
    66import schedframe.scheduling.manager.tasks.JobRegistry; 
     
    1010 
    1111 
    12         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     12        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    1313                double powerConsumption = 0; 
    1414                try { 
  • DCWoRMS/branches/coolemall/src/example/energy/NodeEnergyEstimationPlugin.java

    r1247 r1415  
    33import schedframe.resources.computing.Node; 
    44import schedframe.resources.computing.Processor; 
    5 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     5import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    66import schedframe.resources.devices.Device; 
    77import schedframe.resources.devices.PhysicalResource; 
     
    1010public class NodeEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1111 
    12         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     12        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1313                        PhysicalResource resource) { 
    1414                double powerConsumption = 0; 
  • DCWoRMS/branches/coolemall/src/example/energy/ProcessorEnergyEstimationPlugin.java

    r1207 r1415  
    33import schedframe.resources.ResourceStatus; 
    44import schedframe.resources.computing.Processor; 
    5 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     5import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    66import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    77import schedframe.resources.devices.PhysicalResource; 
     
    1010public class ProcessorEnergyEstimationPlugin extends BaseEnergyEstimationPlugin  { 
    1111 
    12         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     12        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1313                        PhysicalResource resource) { 
    1414                double powerConsumption; 
     
    4242                         
    4343                } 
     44                if(cpu.getLoadInterface().getRecentUtilization().getValue() != 0.0){ 
     45                        powerConsumption = powerConsumption * cpu.getLoadInterface().getRecentUtilization().getValue()/100;                      
     46                } 
    4447                return powerConsumption; 
    4548        } 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/CB1EnergyEstimationPlugin.java

    r1396 r1415  
    1010import schedframe.resources.computing.coolemall.ComputeBox1; 
    1111import schedframe.resources.computing.coolemall.NodeGroup; 
    12 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     12import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    1313import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    1414import schedframe.resources.computing.profiles.energy.power.PState; 
     
    2626        double powerUpgradeLevel = -1; 
    2727         
    28         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     28        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    2929                        PhysicalResource resource) { 
    3030                 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/CB2EnergyEstimationPlugin.java

    r1396 r1415  
    88import schedframe.resources.computing.coolemall.ComputeBox1; 
    99import schedframe.resources.computing.coolemall.NodeGroup; 
    10 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     10import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    1111import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    1212import schedframe.resources.devices.Device; 
     
    1919public class CB2EnergyEstimationPlugin extends BaseEnergyEstimationPlugin{ 
    2020 
    21         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     21        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    2222                        PhysicalResource resource) { 
    2323                 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/CoolingDeviceEnergyEstimationPlugin.java

    r1396 r1415  
    77import schedframe.resources.computing.coolemall.ComputeBox1; 
    88import schedframe.resources.computing.coolemall.NodeGroup; 
    9 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     9import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    1010import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    1111import schedframe.resources.devices.Device; 
     
    1818public class CoolingDeviceEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1919 
    20         public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     20        public double estimateAirflow(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    2121                double airflow = 0; 
    2222                return airflow; 
    2323        } 
    2424 
    25         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     25        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    2626                        PhysicalResource resource) { 
    2727                 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/FanEnergyEstimationPlugin.java

    r1396 r1415  
    11package example.energy.coolemall; 
    22 
    3 import schedframe.events.scheduling.EventReason; 
     3import schedframe.events.EventReason; 
    44import schedframe.resources.computing.ComputingResource; 
    55import schedframe.resources.computing.Node; 
    6 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     6import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    77import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    88import schedframe.resources.devices.Device; 
     
    1414public class FanEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1515 
    16         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     16        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1717                        PhysicalResource resource) { 
    1818                 
     
    3535        } 
    3636         
    37         public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     37        public double estimateAirflow(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    3838                 
    3939                double airflow = 0; 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/FlowPumpInletEnergyEstimationPlugin.java

    r1396 r1415  
    55import schedframe.resources.computing.coolemall.ComputeBox1; 
    66import schedframe.resources.computing.coolemall.NodeGroup; 
    7 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     7import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    88import schedframe.resources.devices.Device; 
    99import schedframe.resources.devices.Fan; 
     
    1515public class FlowPumpInletEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1616 
    17         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     17        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1818                        PhysicalResource resource) { 
    1919                 
     
    8686        } 
    8787         
    88         public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     88        public double estimateAirflow(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    8989                double airflow = 0; 
    9090                double Vair_total; 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/FlowPumpOutletEnergyEstimationPlugin.java

    r1396 r1415  
    55import schedframe.resources.computing.coolemall.ComputeBox1; 
    66import schedframe.resources.computing.coolemall.NodeGroup; 
    7 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     7import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    88import schedframe.resources.devices.Device; 
    99import schedframe.resources.devices.Fan; 
     
    1515public class FlowPumpOutletEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1616 
    17         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     17        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1818                        PhysicalResource resource) { 
    1919                 
     
    2323        } 
    2424         
    25         public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     25        public double estimateAirflow(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    2626                double airflow = 0; 
    2727                double Vair_total; 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/HeatsinkEnergyEstimationPlugin.java

    r1247 r1415  
    33import schedframe.resources.computing.Node; 
    44import schedframe.resources.computing.Processor; 
    5 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     5import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    66import schedframe.resources.devices.Device; 
    77import schedframe.resources.devices.PhysicalResource; 
     
    1111public class HeatsinkEnergyEstimationPlugin extends BaseEnergyEstimationPlugin  { 
    1212 
    13         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     13        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1414                        PhysicalResource resource) { 
    1515                 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/NodeEnergyEstimationPlugin.java

    r1396 r1415  
    55import schedframe.resources.computing.Node; 
    66import schedframe.resources.computing.Processor; 
    7 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     7import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    88import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    99import schedframe.resources.devices.Device; 
     
    1515public class NodeEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1616 
    17         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     17        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1818                        PhysicalResource resource) { 
    1919                double powerConsumption = 0; 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/NodeGroupEnergyEstimationPlugin.java

    r1247 r1415  
    33import schedframe.resources.computing.Node; 
    44import schedframe.resources.computing.coolemall.NodeGroup; 
    5 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     5import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    66import schedframe.resources.devices.PhysicalResource; 
    77import schedframe.scheduling.manager.tasks.JobRegistry; 
     
    1010public class NodeGroupEnergyEstimationPlugin extends BaseEnergyEstimationPlugin{ 
    1111 
    12         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     12        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1313                        PhysicalResource resource) { 
    1414                 
  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/ProcessorEnergyEstimationPlugin.java

    r1322 r1415  
    22 
    33import schedframe.resources.computing.Processor; 
    4 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     4import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    55import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    66import schedframe.resources.devices.PhysicalResource; 
     
    1010public class ProcessorEnergyEstimationPlugin extends BaseEnergyEstimationPlugin  { 
    1111 
    12         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     12        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1313                        PhysicalResource resource) { 
    1414                 
  • DCWoRMS/branches/coolemall/src/example/energy/device/FanEnergyEstimationPlugin.java

    r1396 r1415  
    11package example.energy.device; 
    22 
    3 import schedframe.events.scheduling.EventReason; 
    4 import schedframe.resources.computing.profiles.energy.EnergyEvent; 
     3import schedframe.events.EventReason; 
     4import schedframe.resources.computing.profiles.energy.ResourceEvent; 
    55import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    66import schedframe.resources.devices.PhysicalResource; 
     
    1010public class FanEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1111 
    12         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, 
     12        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, 
    1313                        PhysicalResource resource) { 
    1414                double powerConsumption = 0; 
     
    2424        } 
    2525 
    26         public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     26        public double estimateAirflow(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    2727                double airflow= 0; 
    2828                try { 
Note: See TracChangeset for help on using the changeset viewer.