source: DCWoRMS/trunk/src/example/energy/ComputingNodeWithFanEnergyEstimationPlugin.java @ 774

package example.energy;

import schedframe.events.scheduling.EventReason;
import schedframe.resources.computing.ComputingNode;
import schedframe.resources.computing.ComputingResource;
import schedframe.resources.computing.Processor;
import schedframe.resources.computing.profiles.energy.EnergyEvent;
import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName;
import schedframe.scheduling.manager.tasks.JobRegistry;

public class ComputingNodeWithFanEnergyEstimationPlugin extends BaseEnergyEstimationPlugin {

        public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry,
                        ComputingResource resource) {
                double powerConsumption = 0;
                ComputingNode node = (ComputingNode) resource;
                for(Processor cpu: node.getProcessors()){
                        try{
                                powerConsumption = powerConsumption + cpu.getPowerInterface().getRecentPowerUsage().getValue();
                        } catch (Exception e){
                                
                        }
                }
                try {
                        powerConsumption = powerConsumption + node.getPowerInterface().getPowerConsumption(node.getPowerInterface().getPowerState());
                        if(event.getReason() == EventReason.SIM_INIT)
                                powerConsumption = powerConsumption + node.getAirThroughputInterface().getPowerConsumption(StandardAirThroughputStateName.FAN_OFF);
                        else
                                powerConsumption = powerConsumption + node.getAirThroughputInterface().getPowerConsumption(node.getAirThroughputInterface().getAirThroughputState());
                } catch (NoSuchFieldException e) {
                }

                return powerConsumption;
        }

        public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, ComputingResource resource) {
                double airThroughput = 0;
                try {
                        if(event.getReason() == EventReason.SIM_INIT)
                                airThroughput = resource.getAirThroughputInterface().getAirFlow(StandardAirThroughputStateName.FAN_OFF);
                        else
                                airThroughput = resource.getAirThroughputInterface().getAirFlow(resource.getAirThroughputInterface().getAirThroughputState());
                } catch (NoSuchFieldException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                return airThroughput;
                //throw new RuntimeException("Not implemented.");
        }
}