Changeset 1396 for DCWoRMS/branches/coolemall/src/example/localplugin
- Timestamp:
- 06/26/14 14:18:01 (11 years ago)
- Location:
- DCWoRMS/branches/coolemall/src/example/localplugin
- Files:
-
- 25 edited
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/branches/coolemall/src/example/localplugin/BaseLocalSchedulingPlugin.java
r555 r1396 17 17 import schedframe.scheduling.plan.impl.ScheduledTask; 18 18 import schedframe.scheduling.plan.impl.SchedulingPlan; 19 import schedframe.scheduling.plugin.ModuleList; 19 20 import schedframe.scheduling.plugin.SchedulingPluginConfiguration; 20 import schedframe.scheduling.plugin.grid.ModuleList;21 21 import schedframe.scheduling.plugin.local.LocalSchedulingPlugin; 22 22 import schedframe.scheduling.queue.TaskQueue; -
DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_ConsolidationHighPerf_NodePowMan_Plugin.java
r1299 r1396 17 17 import schedframe.resources.computing.Node; 18 18 import schedframe.resources.computing.Processor; 19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 20 20 import schedframe.resources.computing.profiles.energy.power.PState; 21 21 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; … … 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; … … 169 169 for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 170 170 if(device.getType().equals(StandardResourceType.Fan)){ 171 device.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);171 device.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 172 172 break; 173 173 } … … 192 192 for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 193 193 if(device.getType().equals(StandardResourceType.Fan)){ 194 device.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);194 device.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 195 195 break; 196 196 } -
DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_ConsolidationLowPower_NodePowMan_Plugin.java
r1299 r1396 17 17 import schedframe.resources.computing.Node; 18 18 import schedframe.resources.computing.Processor; 19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAir ThroughputStateName;19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 20 20 import schedframe.resources.computing.profiles.energy.power.PState; 21 21 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; … … 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; … … 168 168 for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 169 169 if(device.getType().equals(StandardResourceType.Fan)){ 170 device.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON);170 device.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 171 171 break; 172 172 } … … 191 191 for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 192 192 if(device.getType().equals(StandardResourceType.Fan)){ 193 device.getAir ThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);193 device.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 194 194 break; 195 195 } -
DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_DFSPlugin.java
r1299 r1396 21 21 import schedframe.scheduling.plan.SchedulingPlanInterface; 22 22 import schedframe.scheduling.plan.impl.SchedulingPlan; 23 import schedframe.scheduling.plugin. grid.ModuleList;23 import schedframe.scheduling.plugin.ModuleList; 24 24 import schedframe.scheduling.queue.TaskQueue; 25 25 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_ExamplePlugin.java
r1299 r1396 25 25 import schedframe.scheduling.plan.SchedulingPlanInterface; 26 26 import schedframe.scheduling.plan.impl.SchedulingPlan; 27 import schedframe.scheduling.plugin. grid.ModuleList;27 import schedframe.scheduling.plugin.ModuleList; 28 28 import schedframe.scheduling.queue.TaskQueue; 29 29 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_RandomPlugin.java
r1258 r1396 13 13 import schedframe.scheduling.plan.SchedulingPlanInterface; 14 14 import schedframe.scheduling.plan.impl.SchedulingPlan; 15 import schedframe.scheduling.plugin. grid.ModuleList;15 import schedframe.scheduling.plugin.ModuleList; 16 16 import schedframe.scheduling.queue.TaskQueue; 17 17 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_LocalPlugin.java
r888 r1396 6 6 import schedframe.scheduling.manager.tasks.JobRegistry; 7 7 import schedframe.scheduling.plan.impl.SchedulingPlan; 8 import schedframe.scheduling.plugin. grid.ModuleList;8 import schedframe.scheduling.plugin.ModuleList; 9 9 import schedframe.scheduling.queue.TaskQueue; 10 10 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationHighPerf_NodePowMan_SP.java
r1299 r1396 16 16 import schedframe.resources.computing.Core; 17 17 import schedframe.resources.computing.Processor; 18 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;18 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 19 19 import schedframe.resources.computing.profiles.energy.power.PState; 20 20 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; … … 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; … … 226 226 Fan fan = (Fan) device; 227 227 if(fan.getChilledResources().contains(node.getFullName())){ 228 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));228 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 229 229 } 230 230 } … … 262 262 if(fan.getChilledResources().contains(node.getFullName())){ 263 263 if(nrOfChilldedNodes == 1) 264 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));264 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 265 265 else { 266 266 for(String chilledNode: fan.getChilledResources()){ … … 274 274 } 275 275 if(nrOfChilldedNodes <= 1) 276 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));276 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 277 277 } 278 278 -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationHighPerf_SP.java
r1299 r1396 25 25 import schedframe.scheduling.plan.SchedulingPlanInterface; 26 26 import schedframe.scheduling.plan.impl.SchedulingPlan; 27 import schedframe.scheduling.plugin. grid.ModuleList;27 import schedframe.scheduling.plugin.ModuleList; 28 28 import schedframe.scheduling.queue.TaskQueue; 29 29 import schedframe.scheduling.queue.TaskQueueList; … … 72 72 } 73 73 74 @SuppressWarnings("unchecked")75 74 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 76 75 ClusterResourceManager resourceManager, TaskInterface<?> task) { -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationLowPower_NodePowMan_SP.java
r1299 r1396 16 16 import schedframe.resources.computing.Node; 17 17 import schedframe.resources.computing.Processor; 18 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;18 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 19 19 import schedframe.resources.computing.profiles.energy.power.PState; 20 20 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; … … 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; … … 226 226 Fan fan = (Fan) device; 227 227 if(fan.getChilledResources().contains(node.getFullName())){ 228 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));228 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 229 229 } 230 230 } … … 262 262 if(fan.getChilledResources().contains(node.getFullName())){ 263 263 if(nrOfChilldedNodes == 1) 264 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));264 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 265 265 else { 266 266 for(String chilledNode: fan.getChilledResources()){ … … 274 274 } 275 275 if(nrOfChilldedNodes <= 1) 276 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));276 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 277 277 } 278 278 -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationLowPower_SP.java
r1299 r1396 25 25 import schedframe.scheduling.plan.SchedulingPlanInterface; 26 26 import schedframe.scheduling.plan.impl.SchedulingPlan; 27 import schedframe.scheduling.plugin. grid.ModuleList;27 import schedframe.scheduling.plugin.ModuleList; 28 28 import schedframe.scheduling.queue.TaskQueue; 29 29 import schedframe.scheduling.queue.TaskQueueList; … … 72 72 } 73 73 74 @SuppressWarnings("unchecked")75 74 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 76 75 ClusterResourceManager resourceManager, TaskInterface<?> task) { -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_LoadBalancing_SP.java
r1258 r1396 11 11 import schedframe.scheduling.plan.SchedulingPlanInterface; 12 12 import schedframe.scheduling.plan.impl.SchedulingPlan; 13 import schedframe.scheduling.plugin. grid.ModuleList;13 import schedframe.scheduling.plugin.ModuleList; 14 14 import schedframe.scheduling.queue.TaskQueue; 15 15 import schedframe.scheduling.queue.TaskQueueList; … … 54 54 } 55 55 56 @SuppressWarnings("unchecked")57 56 private String chooseProvider(ClusterResourceManager resourceManager) { 58 57 List<Node> nodes = resourceManager.getNodes(); -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_Random_SP.java
r1258 r1396 21 21 import schedframe.scheduling.plan.SchedulingPlanInterface; 22 22 import schedframe.scheduling.plan.impl.SchedulingPlan; 23 import schedframe.scheduling.plugin. grid.ModuleList;23 import schedframe.scheduling.plugin.ModuleList; 24 24 import schedframe.scheduling.queue.TaskQueue; 25 25 import schedframe.scheduling.queue.TaskQueueList; … … 70 70 } 71 71 72 @SuppressWarnings("unchecked")73 72 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 74 73 ClusterResourceManager resourceManager, TaskInterface<?> task) { -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationHighPerf_NodePowMan_SP.java
r1299 r1396 17 17 import schedframe.resources.computing.Processor; 18 18 import schedframe.resources.computing.Rack; 19 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;19 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 20 20 import schedframe.resources.computing.profiles.energy.power.PState; 21 21 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; … … 32 32 import schedframe.scheduling.plan.SchedulingPlanInterface; 33 33 import schedframe.scheduling.plan.impl.SchedulingPlan; 34 import schedframe.scheduling.plugin. grid.ModuleList;34 import schedframe.scheduling.plugin.ModuleList; 35 35 import schedframe.scheduling.queue.TaskQueue; 36 36 import schedframe.scheduling.queue.TaskQueueList; … … 227 227 Fan fan = (Fan) device; 228 228 if(fan.getChilledResources().contains(node.getFullName())){ 229 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));229 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 230 230 } 231 231 } … … 263 263 if(fan.getChilledResources().contains(node.getFullName())){ 264 264 if(nrOfChilldedNodes == 1) 265 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));265 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 266 266 else { 267 267 for(String chilledNode: fan.getChilledResources()){ … … 275 275 } 276 276 if(nrOfChilldedNodes <= 1) 277 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));277 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 278 278 } 279 279 -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationHighPerf_PowerCapping_SP.java
r1319 r1396 20 20 import schedframe.resources.computing.coolemall.ComputeBox1; 21 21 import schedframe.resources.computing.coolemall.NodeGroup; 22 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;22 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 23 23 import schedframe.resources.computing.profiles.energy.power.PState; 24 24 import schedframe.resources.devices.Device; … … 34 34 import schedframe.scheduling.plan.SchedulingPlanInterface; 35 35 import schedframe.scheduling.plan.impl.SchedulingPlan; 36 import schedframe.scheduling.plugin. grid.ModuleList;36 import schedframe.scheduling.plugin.ModuleList; 37 37 import schedframe.scheduling.queue.TaskQueue; 38 38 import schedframe.scheduling.queue.TaskQueueList; … … 364 364 365 365 if(fan.getChilledResources().contains(n.getFullName())){ 366 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));366 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 367 367 } 368 368 } … … 457 457 458 458 if(fan.getChilledResources().contains(n.getFullName())){ 459 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));459 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 460 460 } 461 461 } … … 546 546 for(Device device: nodeGroup.getResourceCharacteristic().getDevices()){ 547 547 try { 548 fpc = fpc + device.getAir ThroughputInterface().getPowerConsumption(new UserAirThroughputStateName("2"));548 fpc = fpc + device.getAirflowInterface().getPowerConsumption(new CustomAirflowStateName("2")); 549 549 } catch (NoSuchFieldException e) { 550 550 // TODO Auto-generated catch block -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationHighPerf_SP.java
r1299 r1396 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; -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationLowPower_NodePowMan_SP.java
r1299 r1396 16 16 import schedframe.resources.computing.Node; 17 17 import schedframe.resources.computing.Processor; 18 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;18 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 19 19 import schedframe.resources.computing.profiles.energy.power.PState; 20 20 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; … … 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; … … 226 226 Fan fan = (Fan) device; 227 227 if(fan.getChilledResources().contains(node.getFullName())){ 228 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));228 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 229 229 } 230 230 } … … 262 262 if(fan.getChilledResources().contains(node.getFullName())){ 263 263 if(nrOfChilldedNodes == 1) 264 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));264 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 265 265 else { 266 266 for(String chilledNode: fan.getChilledResources()){ … … 274 274 } 275 275 if(nrOfChilldedNodes <= 1) 276 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1"));276 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 277 277 } 278 278 -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationLowPower_PowerCapping_SP.java
r1319 r1396 20 20 import schedframe.resources.computing.coolemall.ComputeBox1; 21 21 import schedframe.resources.computing.coolemall.NodeGroup; 22 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;22 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 23 23 import schedframe.resources.computing.profiles.energy.power.PState; 24 24 import schedframe.resources.devices.Device; … … 34 34 import schedframe.scheduling.plan.SchedulingPlanInterface; 35 35 import schedframe.scheduling.plan.impl.SchedulingPlan; 36 import schedframe.scheduling.plugin. grid.ModuleList;36 import schedframe.scheduling.plugin.ModuleList; 37 37 import schedframe.scheduling.queue.TaskQueue; 38 38 import schedframe.scheduling.queue.TaskQueueList; … … 282 282 283 283 if(fan.getChilledResources().contains(n.getFullName())){ 284 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));284 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 285 285 } 286 286 } … … 375 375 376 376 if(fan.getChilledResources().contains(n.getFullName())){ 377 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));377 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 378 378 } 379 379 } … … 464 464 for(Device device: nodeGroup.getResourceCharacteristic().getDevices()){ 465 465 try { 466 fpc = fpc + device.getAir ThroughputInterface().getPowerConsumption(new UserAirThroughputStateName("2"));466 fpc = fpc + device.getAirflowInterface().getPowerConsumption(new CustomAirflowStateName("2")); 467 467 } catch (NoSuchFieldException e) { 468 468 // TODO Auto-generated catch block -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationLowPower_SP.java
r1299 r1396 25 25 import schedframe.scheduling.plan.SchedulingPlanInterface; 26 26 import schedframe.scheduling.plan.impl.SchedulingPlan; 27 import schedframe.scheduling.plugin. grid.ModuleList;27 import schedframe.scheduling.plugin.ModuleList; 28 28 import schedframe.scheduling.queue.TaskQueue; 29 29 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_LoadBalancing_SP.java
r1319 r1396 11 11 import schedframe.scheduling.plan.SchedulingPlanInterface; 12 12 import schedframe.scheduling.plan.impl.SchedulingPlan; 13 import schedframe.scheduling.plugin. grid.ModuleList;13 import schedframe.scheduling.plugin.ModuleList; 14 14 import schedframe.scheduling.queue.TaskQueue; 15 15 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_Random_PowerCapping_SP.java
r1319 r1396 19 19 import schedframe.resources.computing.coolemall.ComputeBox1; 20 20 import schedframe.resources.computing.coolemall.NodeGroup; 21 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;21 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 22 22 import schedframe.resources.computing.profiles.energy.power.PState; 23 23 import schedframe.resources.devices.Device; … … 32 32 import schedframe.scheduling.plan.SchedulingPlanInterface; 33 33 import schedframe.scheduling.plan.impl.SchedulingPlan; 34 import schedframe.scheduling.plugin. grid.ModuleList;34 import schedframe.scheduling.plugin.ModuleList; 35 35 import schedframe.scheduling.queue.TaskQueue; 36 36 import schedframe.scheduling.queue.TaskQueueList; … … 245 245 246 246 if(fan.getChilledResources().contains(n.getFullName())){ 247 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));247 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 248 248 } 249 249 } … … 338 338 339 339 if(fan.getChilledResources().contains(n.getFullName())){ 340 fan.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2"));340 fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 341 341 } 342 342 } … … 427 427 for(Device device: nodeGroup.getResourceCharacteristic().getDevices()){ 428 428 try { 429 fpc = fpc + device.getAir ThroughputInterface().getPowerConsumption(new UserAirThroughputStateName("2"));429 fpc = fpc + device.getAirflowInterface().getPowerConsumption(new CustomAirflowStateName("2")); 430 430 } catch (NoSuchFieldException e) { 431 431 // TODO Auto-generated catch block -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_Random_SP.java
r1319 r1396 23 23 import schedframe.scheduling.plan.SchedulingPlanInterface; 24 24 import schedframe.scheduling.plan.impl.SchedulingPlan; 25 import schedframe.scheduling.plugin. grid.ModuleList;25 import schedframe.scheduling.plugin.ModuleList; 26 26 import schedframe.scheduling.queue.TaskQueue; 27 27 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Consolidation_SP.java
r1258 r1396 25 25 import schedframe.scheduling.plan.SchedulingPlanInterface; 26 26 import schedframe.scheduling.plan.impl.SchedulingPlan; 27 import schedframe.scheduling.plugin. grid.ModuleList;27 import schedframe.scheduling.plugin.ModuleList; 28 28 import schedframe.scheduling.queue.TaskQueue; 29 29 import schedframe.scheduling.queue.TaskQueueList; -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_LB_SP.java
r1258 r1396 11 11 import schedframe.scheduling.plan.SchedulingPlanInterface; 12 12 import schedframe.scheduling.plan.impl.SchedulingPlan; 13 import schedframe.scheduling.plugin. grid.ModuleList;13 import schedframe.scheduling.plugin.ModuleList; 14 14 import schedframe.scheduling.queue.TaskQueue; 15 15 import schedframe.scheduling.queue.TaskQueueList; … … 55 55 } 56 56 57 @SuppressWarnings("unchecked")58 57 private String chooseProvider(ClusterResourceManager resourceManager) { 59 58 List<Node> nodes = resourceManager.getNodes(); -
DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Random_SP.java
r1258 r1396 12 12 import schedframe.resources.computing.Core; 13 13 import schedframe.resources.computing.Node; 14 import schedframe.resources.computing.profiles.energy.airthroughput. UserAirThroughputStateName;14 import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 15 15 import schedframe.resources.devices.Device; 16 16 import schedframe.resources.units.ProcessingElements; … … 23 23 import schedframe.scheduling.plan.SchedulingPlanInterface; 24 24 import schedframe.scheduling.plan.impl.SchedulingPlan; 25 import schedframe.scheduling.plugin. grid.ModuleList;25 import schedframe.scheduling.plugin.ModuleList; 26 26 import schedframe.scheduling.queue.TaskQueue; 27 27 import schedframe.scheduling.queue.TaskQueueList; … … 79 79 } 80 80 81 @SuppressWarnings("unchecked")82 81 private Node chooseRandomProvider(ClusterResourceManager resourceManager) { 83 82 List<Node> nodes = resourceManager.getNodes(); … … 184 183 for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 185 184 if(device.getFullName().equals(Node_Fan_Mapping.getNode_fan().get(node.getFullName()))){ 186 device.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("Off"));185 device.getAirflowInterface().setAirflowState(new CustomAirflowStateName("Off")); 187 186 break; 188 187 } … … 192 191 for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 193 192 if(device.getFullName().equals(Node_Fan_Mapping.getNode_fan().get(node.getFullName()))){ 194 device.getAir ThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("On"));193 device.getAirflowInterface().setAirflowState(new CustomAirflowStateName("On")); 195 194 break; 196 195 }
Note: See TracChangeset
for help on using the changeset viewer.