[1500] | 1 | package experiments.simpat2014.models.article; |
---|
[1469] | 2 | |
---|
| 3 | import java.util.List; |
---|
| 4 | |
---|
| 5 | import schedframe.resources.CoolEmAllResourceType; |
---|
| 6 | import schedframe.resources.computing.ComputingResource; |
---|
| 7 | import schedframe.resources.computing.Node; |
---|
| 8 | import schedframe.resources.computing.Processor; |
---|
| 9 | import schedframe.resources.computing.Rack; |
---|
| 10 | import schedframe.resources.computing.coolemall.ComputeBox1; |
---|
| 11 | import schedframe.resources.computing.coolemall.NodeGroup; |
---|
| 12 | import schedframe.resources.computing.profiles.energy.ResourceEvent; |
---|
| 13 | import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; |
---|
| 14 | import schedframe.resources.computing.profiles.energy.power.PState; |
---|
| 15 | import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; |
---|
| 16 | import schedframe.resources.devices.Device; |
---|
| 17 | import schedframe.resources.devices.PhysicalResource; |
---|
| 18 | import schedframe.scheduling.manager.tasks.JobRegistry; |
---|
| 19 | import simulator.DataCenterWorkloadSimulator; |
---|
| 20 | import example.energy.BaseEnergyEstimationPlugin; |
---|
| 21 | import example.energy.coolemall.CoolEmAllTestbedMeasurements; |
---|
| 22 | import gridsim.dcworms.DCWormsTags; |
---|
| 23 | |
---|
| 24 | public class RackEnergyEstimationPlugin extends BaseEnergyEstimationPlugin{ |
---|
| 25 | |
---|
| 26 | public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, |
---|
| 27 | PhysicalResource resource) { |
---|
| 28 | |
---|
| 29 | |
---|
| 30 | double powerConsumption = 0; |
---|
| 31 | Rack rack = (Rack)resource; |
---|
| 32 | for(ComputingResource nodeGroup: rack.getChildren()){ |
---|
| 33 | try{ |
---|
| 34 | powerConsumption = powerConsumption + nodeGroup.getPowerInterface().getRecentPowerUsage().getValue(); |
---|
| 35 | } catch (Exception e){ |
---|
| 36 | |
---|
| 37 | } |
---|
| 38 | } |
---|
| 39 | |
---|
| 40 | for(Node node: rack.getNodes()){ |
---|
| 41 | if(node.getProcessors().get(0).getThermalInterface().getRecentTemperature().getValue() > 90){ |
---|
| 42 | //powerConsumption = powerConsumption + 15; |
---|
| 43 | } |
---|
| 44 | } |
---|
| 45 | |
---|
| 46 | int nrOfPoweredOffNodes = 0; |
---|
| 47 | for(Node node: rack.getNodes()){ |
---|
| 48 | if(node.getPowerInterface().getPowerState().equals(StandardPowerStateName.OFF)){ |
---|
| 49 | nrOfPoweredOffNodes++; |
---|
| 50 | } |
---|
| 51 | } |
---|
| 52 | if(nrOfPoweredOffNodes != rack.getNodes().size()){ |
---|
| 53 | powerConsumption = (powerConsumption + CoolEmAllTestbedMeasurements.OTHER_DEVICES_POWER_CONSUMPTION)/CoolEmAllTestbedMeasurements.POWER_SUPPLY_EFFICIENCY; |
---|
| 54 | } |
---|
| 55 | |
---|
| 56 | return powerConsumption; |
---|
| 57 | } |
---|
| 58 | |
---|
| 59 | |
---|
| 60 | } |
---|