1 | package example.energy; |
---|
2 | |
---|
3 | import gssim.schedframe.scheduling.ExecTaskInterface; |
---|
4 | |
---|
5 | import java.util.List; |
---|
6 | import java.util.Properties; |
---|
7 | |
---|
8 | import schedframe.resources.PowerState; |
---|
9 | import test.rewolucja.energy.EnergyEvent; |
---|
10 | import test.rewolucja.resources.ResourceStatus; |
---|
11 | import test.rewolucja.resources.physical.base.ComputingResource; |
---|
12 | import test.rewolucja.resources.physical.implementation.Processor; |
---|
13 | import test.rewolucja.scheduling.JobRegistryInterface; |
---|
14 | |
---|
15 | public class CPUEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { |
---|
16 | |
---|
17 | @Override |
---|
18 | public double estimatePowerConsumption(EnergyEvent event, JobRegistryInterface jobRegistry, |
---|
19 | ComputingResource resource) { |
---|
20 | Processor cpu = (Processor)resource; |
---|
21 | |
---|
22 | if(resource.getPowerInterface().getPowerState() == PowerState.OFF) |
---|
23 | return 0; |
---|
24 | |
---|
25 | double factor = 1.3; |
---|
26 | |
---|
27 | if(resource.getStatus() == ResourceStatus.BUSY) |
---|
28 | { |
---|
29 | List<ExecTaskInterface> tasks = jobRegistry.getRunningTasks(); |
---|
30 | int type = Integer.parseInt( tasks.get(0).getJobId()); |
---|
31 | |
---|
32 | switch( type % 4) |
---|
33 | { |
---|
34 | case 0: factor = 1.1; break; |
---|
35 | case 1: factor = 1.2; break; |
---|
36 | case 2: factor = 1.3; break; |
---|
37 | case 3: factor = 1.4; break; |
---|
38 | } |
---|
39 | |
---|
40 | return cpu.getPowerInterface().getPState().getPower() * factor; |
---|
41 | } |
---|
42 | else |
---|
43 | return cpu.getPowerInterface().getPState().getPower(); |
---|
44 | } |
---|
45 | |
---|
46 | public String getName() { |
---|
47 | return getClass().getName(); |
---|
48 | } |
---|
49 | |
---|
50 | public void init(Properties properties) { |
---|
51 | // TODO Auto-generated method stub |
---|
52 | |
---|
53 | } |
---|
54 | |
---|
55 | } |
---|