1 | package test.article2.recs.plugins.energy; |
---|
2 | |
---|
3 | import java.io.FileNotFoundException; |
---|
4 | import java.io.IOException; |
---|
5 | |
---|
6 | import schedframe.resources.computing.ComputingNode; |
---|
7 | import schedframe.resources.computing.ComputingResource; |
---|
8 | import schedframe.resources.computing.Processor; |
---|
9 | import schedframe.resources.computing.profiles.energy.EnergyEvent; |
---|
10 | import schedframe.scheduling.manager.tasks.JobRegistry; |
---|
11 | |
---|
12 | public class IntelNodeEEP extends RecsNodeBaseEEP { |
---|
13 | |
---|
14 | public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, |
---|
15 | ComputingResource resource) { |
---|
16 | double powerConsumption = 0; |
---|
17 | ComputingNode node = (ComputingNode) resource; |
---|
18 | |
---|
19 | try { |
---|
20 | if(jobRegistry.getRunningTasks().size() > 0) { |
---|
21 | powerConsumption = powerConsumption + getMeasuredPower(createQuery(jobRegistry.getRunningTasks().get(0))); |
---|
22 | } |
---|
23 | else { |
---|
24 | for(Processor cpu: node.getProcessors()){ |
---|
25 | try{ |
---|
26 | //powerConsumption = powerConsumption + cpu.getPowerInterface().getRecentPowerUsage().getValue(); |
---|
27 | } catch (Exception e){ |
---|
28 | |
---|
29 | } |
---|
30 | } |
---|
31 | try { |
---|
32 | powerConsumption = powerConsumption + node.getPowerInterface().getPowerConsumption(node.getPowerInterface().getPowerState()); |
---|
33 | } catch (NoSuchFieldException e) { |
---|
34 | } |
---|
35 | } |
---|
36 | } catch (FileNotFoundException e) { |
---|
37 | // TODO Auto-generated catch block |
---|
38 | e.printStackTrace(); |
---|
39 | } catch (IOException e) { |
---|
40 | // TODO Auto-generated catch block |
---|
41 | e.printStackTrace(); |
---|
42 | } |
---|
43 | |
---|
44 | return powerConsumption; |
---|
45 | } |
---|
46 | |
---|
47 | } |
---|