- Timestamp:
- 06/26/14 14:24:08 (11 years ago)
- Location:
- DCWoRMS/branches/coolemall/src/test/article2/recs/plugins
- Files:
-
- 12 edited
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/energy/FanEnergyEstimationPlugin.java
r1210 r1399 3 3 import schedframe.events.scheduling.EventReason; 4 4 import schedframe.resources.computing.profiles.energy.EnergyEvent; 5 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;5 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 6 6 import schedframe.resources.devices.PhysicalResource; 7 7 import schedframe.scheduling.manager.tasks.JobRegistry; … … 15 15 try { 16 16 if(event.getReason() == EventReason.SIM_INIT) 17 powerConsumption = powerConsumption + resource.getAir ThroughputInterface().getPowerConsumption(StandardAirThroughputStateName.OFF);17 powerConsumption = powerConsumption + resource.getAirflowInterface().getPowerConsumption(StandardAirflowStateName.OFF); 18 18 else 19 powerConsumption = powerConsumption + resource.getAir ThroughputInterface().getPowerConsumption(resource.getAirThroughputInterface().getAirThroughputState());19 powerConsumption = powerConsumption + resource.getAirflowInterface().getPowerConsumption(resource.getAirflowInterface().getAirflowState()); 20 20 } catch (NoSuchFieldException e) { 21 21 } … … 24 24 } 25 25 26 public double estimateAir Throughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) {27 double air Throughput= 0;26 public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 27 double airflow = 0; 28 28 try { 29 29 if(event.getReason() == EventReason.SIM_INIT) 30 air Throughput = resource.getAirThroughputInterface().getAirFlow(StandardAirThroughputStateName.OFF);30 airflow = resource.getAirflowInterface().getAirflow(StandardAirflowStateName.OFF); 31 31 else 32 air Throughput = resource.getAirThroughputInterface().getAirFlow(resource.getAirThroughputInterface().getAirThroughputState());32 airflow = resource.getAirflowInterface().getAirflow(resource.getAirflowInterface().getAirflowState()); 33 33 } catch (NoSuchFieldException e) { 34 34 // TODO Auto-generated catch block 35 35 e.printStackTrace(); 36 36 } 37 return air Throughput;37 return airflow; 38 38 } 39 39 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/energy/RecsCpuBaseEEP.java
r1210 r1399 5 5 import schedframe.resources.computing.Processor; 6 6 import schedframe.resources.computing.profiles.energy.EnergyEvent; 7 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;7 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 8 8 import schedframe.resources.devices.PhysicalResource; 9 9 import schedframe.scheduling.manager.tasks.JobRegistry; … … 39 39 try { 40 40 if(event.getReason() == EventReason.SIM_INIT) 41 airThroughput = resource.getAir ThroughputInterface().getAirFlow(StandardAirThroughputStateName.OFF);41 airThroughput = resource.getAirflowInterface().getAirflow(StandardAirflowStateName.OFF); 42 42 else 43 airThroughput = resource.getAir ThroughputInterface().getAirFlow(resource.getAirThroughputInterface().getAirThroughputState());43 airThroughput = resource.getAirflowInterface().getAirflow(resource.getAirflowInterface().getAirflowState()); 44 44 } catch (NoSuchFieldException e) { 45 45 // TODO Auto-generated catch block … … 53 53 if(id - resId == 9 || id - resId == -9){ 54 54 try { 55 airThroughput = airThroughput + compResource.getAir ThroughputInterface().getAirFlow(compResource.getAirThroughputInterface().getAirThroughputState())/2;55 airThroughput = airThroughput + compResource.getAirflowInterface().getAirflow(compResource.getAirflowInterface().getAirflowState())/2; 56 56 } catch (NoSuchFieldException e) { 57 57 -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/energy/RecsNodeBaseEEP.java
r1368 r1399 15 15 import schedframe.resources.computing.Processor; 16 16 import schedframe.resources.computing.profiles.energy.EnergyEvent; 17 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;17 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 18 18 import schedframe.resources.units.PEUnit; 19 19 import schedframe.resources.units.ProcessingElements; … … 57 57 try { 58 58 if(event.getReason() == EventReason.SIM_INIT) 59 airThroughput = resource.getAir ThroughputInterface().getAirFlow(StandardAirThroughputStateName.OFF);59 airThroughput = resource.getAirflowInterface().getAirflow(StandardAirflowStateName.OFF); 60 60 else 61 airThroughput = resource.getAir ThroughputInterface().getAirFlow(resource.getAirThroughputInterface().getAirThroughputState());61 airThroughput = resource.getAirflowInterface().getAirflow(resource.getAirflowInterface().getAirflowState()); 62 62 } catch (NoSuchFieldException e) { 63 63 // TODO Auto-generated catch block … … 71 71 if(id - resId == 9 || id - resId == -9){ 72 72 try { 73 airThroughput = airThroughput + compResource.getAir ThroughputInterface().getAirFlow(compResource.getAirThroughputInterface().getAirThroughputState())/2;73 airThroughput = airThroughput + compResource.getAirflowInterface().getAirflow(compResource.getAirflowInterface().getAirflowState())/2; 74 74 } catch (NoSuchFieldException e) { 75 75 -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsInIdleSP.java
r1247 r1399 16 16 import schedframe.resources.computing.ComputingResource; 17 17 import schedframe.resources.computing.Core; 18 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;18 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 19 19 import schedframe.resources.units.ProcessingElements; 20 20 import schedframe.resources.units.ResourceUnit; … … 26 26 import schedframe.scheduling.plan.SchedulingPlanInterface; 27 27 import schedframe.scheduling.plan.impl.SchedulingPlan; 28 import schedframe.scheduling.plugin. grid.ModuleList;28 import schedframe.scheduling.plugin.ModuleList; 29 29 import schedframe.scheduling.queue.TaskQueue; 30 30 import schedframe.scheduling.queue.TaskQueueList; … … 59 59 Node node = chooseProvider(resourceManager, task); 60 60 if (node != null) { 61 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);61 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 62 62 notSelectedNodes.remove(node); 63 63 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 166 166 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 167 167 } else { 168 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);168 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 169 169 } 170 170 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsInOffSP.java
r1247 r1399 17 17 import schedframe.resources.computing.Core; 18 18 import schedframe.resources.computing.Processor; 19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;20 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 20 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 21 21 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 22 22 import schedframe.resources.units.ProcessingElements; … … 30 30 import schedframe.scheduling.plan.SchedulingPlanInterface; 31 31 import schedframe.scheduling.plan.impl.SchedulingPlan; 32 import schedframe.scheduling.plugin. grid.ModuleList;32 import schedframe.scheduling.plugin.ModuleList; 33 33 import schedframe.scheduling.queue.TaskQueue; 34 34 import schedframe.scheduling.queue.TaskQueueList; … … 63 63 Node node = chooseProvider(resourceManager, task); 64 64 if (node != null) { 65 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);65 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 66 66 notSelectedNodes.remove(node); 67 67 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 186 186 for(Node node : nodes){ 187 187 if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 188 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);188 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 189 189 } else { 190 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);190 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 191 191 } 192 192 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsInOutSP.java
r1247 r1399 19 19 import schedframe.resources.computing.ComputingResource; 20 20 import schedframe.resources.computing.Core; 21 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;21 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 22 22 import schedframe.resources.units.ProcessingElements; 23 23 import schedframe.resources.units.ResourceUnit; … … 29 29 import schedframe.scheduling.plan.SchedulingPlanInterface; 30 30 import schedframe.scheduling.plan.impl.SchedulingPlan; 31 import schedframe.scheduling.plugin. grid.ModuleList;31 import schedframe.scheduling.plugin.ModuleList; 32 32 import schedframe.scheduling.queue.TaskQueue; 33 33 import schedframe.scheduling.queue.TaskQueueList; … … 62 62 Node node = chooseProvider(resourceManager, task); 63 63 if (node != null) { 64 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);64 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 65 65 notSelectedNodes.remove(node); 66 66 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 170 170 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 171 171 } else { 172 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);172 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 173 173 } 174 174 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsOutIdleSP.java
r1247 r1399 16 16 import schedframe.resources.computing.ComputingResource; 17 17 import schedframe.resources.computing.Core; 18 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;18 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 19 19 import schedframe.resources.units.ProcessingElements; 20 20 import schedframe.resources.units.ResourceUnit; … … 26 26 import schedframe.scheduling.plan.SchedulingPlanInterface; 27 27 import schedframe.scheduling.plan.impl.SchedulingPlan; 28 import schedframe.scheduling.plugin. grid.ModuleList;28 import schedframe.scheduling.plugin.ModuleList; 29 29 import schedframe.scheduling.queue.TaskQueue; 30 30 import schedframe.scheduling.queue.TaskQueueList; … … 59 59 Node node = chooseProvider(resourceManager, task); 60 60 if (node != null) { 61 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);61 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 62 62 notSelectedNodes.remove(node); 63 63 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 166 166 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 167 167 } else { 168 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);168 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 169 169 } 170 170 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsOutOffSP.java
r1247 r1399 18 18 import schedframe.resources.computing.Core; 19 19 import schedframe.resources.computing.Processor; 20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;21 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 21 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 22 22 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 23 23 import schedframe.resources.units.ProcessingElements; … … 31 31 import schedframe.scheduling.plan.SchedulingPlanInterface; 32 32 import schedframe.scheduling.plan.impl.SchedulingPlan; 33 import schedframe.scheduling.plugin. grid.ModuleList;33 import schedframe.scheduling.plugin.ModuleList; 34 34 import schedframe.scheduling.queue.TaskQueue; 35 35 import schedframe.scheduling.queue.TaskQueueList; … … 64 64 Node node = chooseProvider(resourceManager, task); 65 65 if (node != null) { 66 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);66 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 67 67 notSelectedNodes.remove(node); 68 68 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 187 187 for(Node node : nodes){ 188 188 if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 189 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);189 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 190 190 } else { 191 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);191 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 192 192 } 193 193 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsIn2OutSP.java
r1247 r1399 18 18 import schedframe.resources.computing.ComputingResource; 19 19 import schedframe.resources.computing.Core; 20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 21 21 import schedframe.resources.units.ProcessingElements; 22 22 import schedframe.resources.units.ResourceUnit; … … 28 28 import schedframe.scheduling.plan.SchedulingPlanInterface; 29 29 import schedframe.scheduling.plan.impl.SchedulingPlan; 30 import schedframe.scheduling.plugin. grid.ModuleList;30 import schedframe.scheduling.plugin.ModuleList; 31 31 import schedframe.scheduling.queue.TaskQueue; 32 32 import schedframe.scheduling.queue.TaskQueueList; … … 61 61 Node node = chooseProvider(resourceManager, task); 62 62 if (node != null) { 63 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);63 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 64 64 notSelectedNodes.remove(node); 65 65 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 170 170 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 171 171 } else { 172 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);172 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 173 173 } 174 174 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsLeft2RightSP.java
r1247 r1399 18 18 import schedframe.resources.computing.ComputingResource; 19 19 import schedframe.resources.computing.Core; 20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 21 21 import schedframe.resources.units.ProcessingElements; 22 22 import schedframe.resources.units.ResourceUnit; … … 28 28 import schedframe.scheduling.plan.SchedulingPlanInterface; 29 29 import schedframe.scheduling.plan.impl.SchedulingPlan; 30 import schedframe.scheduling.plugin. grid.ModuleList;30 import schedframe.scheduling.plugin.ModuleList; 31 31 import schedframe.scheduling.queue.TaskQueue; 32 32 import schedframe.scheduling.queue.TaskQueueList; … … 62 62 Node node = chooseProvider(resourceManager, task); 63 63 if (node != null) { 64 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);64 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 65 65 notSelectedNodes.remove(node); 66 66 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 170 170 // node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 171 171 } else { 172 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);172 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 173 173 } 174 174 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsOut2InSP.java
r1247 r1399 18 18 import schedframe.resources.computing.ComputingResource; 19 19 import schedframe.resources.computing.Core; 20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 21 21 import schedframe.resources.units.ProcessingElements; 22 22 import schedframe.resources.units.ResourceUnit; … … 28 28 import schedframe.scheduling.plan.SchedulingPlanInterface; 29 29 import schedframe.scheduling.plan.impl.SchedulingPlan; 30 import schedframe.scheduling.plugin. grid.ModuleList;30 import schedframe.scheduling.plugin.ModuleList; 31 31 import schedframe.scheduling.queue.TaskQueue; 32 32 import schedframe.scheduling.queue.TaskQueueList; … … 61 61 Node node = chooseProvider(resourceManager, task); 62 62 if (node != null) { 63 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);63 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 64 64 notSelectedNodes.remove(node); 65 65 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 169 169 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 170 170 } else { 171 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);171 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 172 172 } 173 173 } -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsRandomSP.java
r1247 r1399 14 14 import schedframe.resources.computing.ComputingResource; 15 15 import schedframe.resources.computing.Core; 16 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;17 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;16 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 17 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 18 18 import schedframe.resources.units.ProcessingElements; 19 19 import schedframe.resources.units.ResourceUnit; … … 26 26 import schedframe.scheduling.plan.SchedulingPlanInterface; 27 27 import schedframe.scheduling.plan.impl.SchedulingPlan; 28 import schedframe.scheduling.plugin. grid.ModuleList;28 import schedframe.scheduling.plugin.ModuleList; 29 29 import schedframe.scheduling.queue.TaskQueue; 30 30 import schedframe.scheduling.queue.TaskQueueList; … … 58 58 Node node = chooseRandomProvider(resourceManager, task); 59 59 if (node != null) { 60 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);60 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 61 61 notSelectedNodes.remove(node); 62 62 addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); … … 152 152 for(Node node : nodes){ 153 153 if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 154 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);154 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 155 155 } else if(new JobRegistryImpl(node.getFullName()).getRunningTasks().size() > 1) 156 node.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("FAN_ON_TURBO"));156 node.getAirflowInterface().setAirflowState(new CustomAirflowStateName("FAN_ON_TURBO")); 157 157 else 158 node.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);158 node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 159 159 } 160 160 }
Note: See TracChangeset
for help on using the changeset viewer.