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."); } }