Ignore:
Timestamp:
06/26/14 14:18:01 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/example/localplugin
Files:
25 edited

Legend:

Unmodified
Added
Removed
  • DCWoRMS/branches/coolemall/src/example/localplugin/BaseLocalSchedulingPlugin.java

    r555 r1396  
    1717import schedframe.scheduling.plan.impl.ScheduledTask; 
    1818import schedframe.scheduling.plan.impl.SchedulingPlan; 
     19import schedframe.scheduling.plugin.ModuleList; 
    1920import schedframe.scheduling.plugin.SchedulingPluginConfiguration; 
    20 import schedframe.scheduling.plugin.grid.ModuleList; 
    2121import schedframe.scheduling.plugin.local.LocalSchedulingPlugin; 
    2222import schedframe.scheduling.queue.TaskQueue; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_ConsolidationHighPerf_NodePowMan_Plugin.java

    r1299 r1396  
    1717import schedframe.resources.computing.Node; 
    1818import schedframe.resources.computing.Processor; 
    19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     19import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    2020import schedframe.resources.computing.profiles.energy.power.PState; 
    2121import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
     
    3030import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3131import schedframe.scheduling.plan.impl.SchedulingPlan; 
    32 import schedframe.scheduling.plugin.grid.ModuleList; 
     32import schedframe.scheduling.plugin.ModuleList; 
    3333import schedframe.scheduling.queue.TaskQueue; 
    3434import schedframe.scheduling.queue.TaskQueueList; 
     
    169169                                        for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 
    170170                                                if(device.getType().equals(StandardResourceType.Fan)){ 
    171                                                         device.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     171                                                        device.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    172172                                                        break; 
    173173                                                } 
     
    192192                                for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 
    193193                                        if(device.getType().equals(StandardResourceType.Fan)){ 
    194                                                 device.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF); 
     194                                                device.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 
    195195                                                break; 
    196196                                        } 
  • DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_ConsolidationLowPower_NodePowMan_Plugin.java

    r1299 r1396  
    1717import schedframe.resources.computing.Node; 
    1818import schedframe.resources.computing.Processor; 
    19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     19import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    2020import schedframe.resources.computing.profiles.energy.power.PState; 
    2121import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
     
    3030import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3131import schedframe.scheduling.plan.impl.SchedulingPlan; 
    32 import schedframe.scheduling.plugin.grid.ModuleList; 
     32import schedframe.scheduling.plugin.ModuleList; 
    3333import schedframe.scheduling.queue.TaskQueue; 
    3434import schedframe.scheduling.queue.TaskQueueList; 
     
    168168                                        for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 
    169169                                                if(device.getType().equals(StandardResourceType.Fan)){ 
    170                                                         device.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     170                                                        device.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    171171                                                        break; 
    172172                                                } 
     
    191191                                for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 
    192192                                        if(device.getType().equals(StandardResourceType.Fan)){ 
    193                                                 device.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF); 
     193                                                device.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 
    194194                                                break; 
    195195                                        } 
  • DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_DFSPlugin.java

    r1299 r1396  
    2121import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2222import schedframe.scheduling.plan.impl.SchedulingPlan; 
    23 import schedframe.scheduling.plugin.grid.ModuleList; 
     23import schedframe.scheduling.plugin.ModuleList; 
    2424import schedframe.scheduling.queue.TaskQueue; 
    2525import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_ExamplePlugin.java

    r1299 r1396  
    2525import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2626import schedframe.scheduling.plan.impl.SchedulingPlan; 
    27 import schedframe.scheduling.plugin.grid.ModuleList; 
     27import schedframe.scheduling.plugin.ModuleList; 
    2828import schedframe.scheduling.queue.TaskQueue; 
    2929import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/Cluster_FCFSBF_RandomPlugin.java

    r1258 r1396  
    1313import schedframe.scheduling.plan.SchedulingPlanInterface; 
    1414import schedframe.scheduling.plan.impl.SchedulingPlan; 
    15 import schedframe.scheduling.plugin.grid.ModuleList; 
     15import schedframe.scheduling.plugin.ModuleList; 
    1616import schedframe.scheduling.queue.TaskQueue; 
    1717import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_LocalPlugin.java

    r888 r1396  
    66import schedframe.scheduling.manager.tasks.JobRegistry; 
    77import schedframe.scheduling.plan.impl.SchedulingPlan; 
    8 import schedframe.scheduling.plugin.grid.ModuleList; 
     8import schedframe.scheduling.plugin.ModuleList; 
    99import schedframe.scheduling.queue.TaskQueue; 
    1010import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationHighPerf_NodePowMan_SP.java

    r1299 r1396  
    1616import schedframe.resources.computing.Core; 
    1717import schedframe.resources.computing.Processor; 
    18 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     18import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    1919import schedframe.resources.computing.profiles.energy.power.PState; 
    2020import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
     
    3131import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3232import schedframe.scheduling.plan.impl.SchedulingPlan; 
    33 import schedframe.scheduling.plugin.grid.ModuleList; 
     33import schedframe.scheduling.plugin.ModuleList; 
    3434import schedframe.scheduling.queue.TaskQueue; 
    3535import schedframe.scheduling.queue.TaskQueueList; 
     
    226226                                                        Fan fan = (Fan) device; 
    227227                                                        if(fan.getChilledResources().contains(node.getFullName())){ 
    228                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     228                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    229229                                                        } 
    230230                                                } 
     
    262262                                                if(fan.getChilledResources().contains(node.getFullName())){ 
    263263                                                        if(nrOfChilldedNodes == 1) 
    264                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     264                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    265265                                                        else { 
    266266                                                                for(String chilledNode: fan.getChilledResources()){ 
     
    274274                                                                } 
    275275                                                                if(nrOfChilldedNodes <= 1) 
    276                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     276                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    277277                                                        } 
    278278 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationHighPerf_SP.java

    r1299 r1396  
    2525import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2626import schedframe.scheduling.plan.impl.SchedulingPlan; 
    27 import schedframe.scheduling.plugin.grid.ModuleList; 
     27import schedframe.scheduling.plugin.ModuleList; 
    2828import schedframe.scheduling.queue.TaskQueue; 
    2929import schedframe.scheduling.queue.TaskQueueList; 
     
    7272        } 
    7373 
    74         @SuppressWarnings("unchecked") 
    7574        private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 
    7675                        ClusterResourceManager resourceManager, TaskInterface<?> task) { 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationLowPower_NodePowMan_SP.java

    r1299 r1396  
    1616import schedframe.resources.computing.Node; 
    1717import schedframe.resources.computing.Processor; 
    18 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     18import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    1919import schedframe.resources.computing.profiles.energy.power.PState; 
    2020import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
     
    3131import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3232import schedframe.scheduling.plan.impl.SchedulingPlan; 
    33 import schedframe.scheduling.plugin.grid.ModuleList; 
     33import schedframe.scheduling.plugin.ModuleList; 
    3434import schedframe.scheduling.queue.TaskQueue; 
    3535import schedframe.scheduling.queue.TaskQueueList; 
     
    226226                                                        Fan fan = (Fan) device; 
    227227                                                        if(fan.getChilledResources().contains(node.getFullName())){ 
    228                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     228                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    229229                                                        } 
    230230                                                } 
     
    262262                                                if(fan.getChilledResources().contains(node.getFullName())){ 
    263263                                                        if(nrOfChilldedNodes == 1) 
    264                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     264                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    265265                                                        else { 
    266266                                                                for(String chilledNode: fan.getChilledResources()){ 
     
    274274                                                                } 
    275275                                                                if(nrOfChilldedNodes <= 1) 
    276                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     276                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    277277                                                        } 
    278278 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationLowPower_SP.java

    r1299 r1396  
    2525import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2626import schedframe.scheduling.plan.impl.SchedulingPlan; 
    27 import schedframe.scheduling.plugin.grid.ModuleList; 
     27import schedframe.scheduling.plugin.ModuleList; 
    2828import schedframe.scheduling.queue.TaskQueue; 
    2929import schedframe.scheduling.queue.TaskQueueList; 
     
    7272        } 
    7373 
    74         @SuppressWarnings("unchecked") 
    7574        private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 
    7675                        ClusterResourceManager resourceManager, TaskInterface<?> task) { 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_LoadBalancing_SP.java

    r1258 r1396  
    1111import schedframe.scheduling.plan.SchedulingPlanInterface; 
    1212import schedframe.scheduling.plan.impl.SchedulingPlan; 
    13 import schedframe.scheduling.plugin.grid.ModuleList; 
     13import schedframe.scheduling.plugin.ModuleList; 
    1414import schedframe.scheduling.queue.TaskQueue; 
    1515import schedframe.scheduling.queue.TaskQueueList; 
     
    5454        } 
    5555 
    56         @SuppressWarnings("unchecked") 
    5756        private String chooseProvider(ClusterResourceManager resourceManager) { 
    5857                List<Node> nodes = resourceManager.getNodes(); 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_Random_SP.java

    r1258 r1396  
    2121import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2222import schedframe.scheduling.plan.impl.SchedulingPlan; 
    23 import schedframe.scheduling.plugin.grid.ModuleList; 
     23import schedframe.scheduling.plugin.ModuleList; 
    2424import schedframe.scheduling.queue.TaskQueue; 
    2525import schedframe.scheduling.queue.TaskQueueList; 
     
    7070        } 
    7171 
    72         @SuppressWarnings("unchecked") 
    7372        private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 
    7473                        ClusterResourceManager resourceManager, TaskInterface<?> task) { 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationHighPerf_NodePowMan_SP.java

    r1299 r1396  
    1717import schedframe.resources.computing.Processor; 
    1818import schedframe.resources.computing.Rack; 
    19 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     19import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    2020import schedframe.resources.computing.profiles.energy.power.PState; 
    2121import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
     
    3232import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3333import schedframe.scheduling.plan.impl.SchedulingPlan; 
    34 import schedframe.scheduling.plugin.grid.ModuleList; 
     34import schedframe.scheduling.plugin.ModuleList; 
    3535import schedframe.scheduling.queue.TaskQueue; 
    3636import schedframe.scheduling.queue.TaskQueueList; 
     
    227227                                                        Fan fan = (Fan) device; 
    228228                                                        if(fan.getChilledResources().contains(node.getFullName())){ 
    229                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     229                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    230230                                                        } 
    231231                                                } 
     
    263263                                                if(fan.getChilledResources().contains(node.getFullName())){ 
    264264                                                        if(nrOfChilldedNodes == 1) 
    265                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     265                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    266266                                                        else { 
    267267                                                                for(String chilledNode: fan.getChilledResources()){ 
     
    275275                                                                } 
    276276                                                                if(nrOfChilldedNodes <= 1) 
    277                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     277                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    278278                                                        } 
    279279 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationHighPerf_PowerCapping_SP.java

    r1319 r1396  
    2020import schedframe.resources.computing.coolemall.ComputeBox1; 
    2121import schedframe.resources.computing.coolemall.NodeGroup; 
    22 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     22import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    2323import schedframe.resources.computing.profiles.energy.power.PState; 
    2424import schedframe.resources.devices.Device; 
     
    3434import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3535import schedframe.scheduling.plan.impl.SchedulingPlan; 
    36 import schedframe.scheduling.plugin.grid.ModuleList; 
     36import schedframe.scheduling.plugin.ModuleList; 
    3737import schedframe.scheduling.queue.TaskQueue; 
    3838import schedframe.scheduling.queue.TaskQueueList; 
     
    364364 
    365365                                                                                if(fan.getChilledResources().contains(n.getFullName())){ 
    366                                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     366                                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    367367                                                                                } 
    368368                                                                        } 
     
    457457 
    458458                                                                                if(fan.getChilledResources().contains(n.getFullName())){ 
    459                                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     459                                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    460460                                                                                } 
    461461                                                                        } 
     
    546546                        for(Device device: nodeGroup.getResourceCharacteristic().getDevices()){ 
    547547                                try { 
    548                                         fpc = fpc + device.getAirThroughputInterface().getPowerConsumption(new UserAirThroughputStateName("2")); 
     548                                        fpc = fpc + device.getAirflowInterface().getPowerConsumption(new CustomAirflowStateName("2")); 
    549549                                } catch (NoSuchFieldException e) { 
    550550                                        // TODO Auto-generated catch block 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationHighPerf_SP.java

    r1299 r1396  
    2626import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2727import schedframe.scheduling.plan.impl.SchedulingPlan; 
    28 import schedframe.scheduling.plugin.grid.ModuleList; 
     28import schedframe.scheduling.plugin.ModuleList; 
    2929import schedframe.scheduling.queue.TaskQueue; 
    3030import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationLowPower_NodePowMan_SP.java

    r1299 r1396  
    1616import schedframe.resources.computing.Node; 
    1717import schedframe.resources.computing.Processor; 
    18 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     18import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    1919import schedframe.resources.computing.profiles.energy.power.PState; 
    2020import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
     
    3131import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3232import schedframe.scheduling.plan.impl.SchedulingPlan; 
    33 import schedframe.scheduling.plugin.grid.ModuleList; 
     33import schedframe.scheduling.plugin.ModuleList; 
    3434import schedframe.scheduling.queue.TaskQueue; 
    3535import schedframe.scheduling.queue.TaskQueueList; 
     
    226226                                                        Fan fan = (Fan) device; 
    227227                                                        if(fan.getChilledResources().contains(node.getFullName())){ 
    228                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     228                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    229229                                                        } 
    230230                                                } 
     
    262262                                                if(fan.getChilledResources().contains(node.getFullName())){ 
    263263                                                        if(nrOfChilldedNodes == 1) 
    264                                                                 fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     264                                                                fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    265265                                                        else { 
    266266                                                                for(String chilledNode: fan.getChilledResources()){ 
     
    274274                                                                } 
    275275                                                                if(nrOfChilldedNodes <= 1) 
    276                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("1")); 
     276                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("1")); 
    277277                                                        } 
    278278 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationLowPower_PowerCapping_SP.java

    r1319 r1396  
    2020import schedframe.resources.computing.coolemall.ComputeBox1; 
    2121import schedframe.resources.computing.coolemall.NodeGroup; 
    22 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     22import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    2323import schedframe.resources.computing.profiles.energy.power.PState; 
    2424import schedframe.resources.devices.Device; 
     
    3434import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3535import schedframe.scheduling.plan.impl.SchedulingPlan; 
    36 import schedframe.scheduling.plugin.grid.ModuleList; 
     36import schedframe.scheduling.plugin.ModuleList; 
    3737import schedframe.scheduling.queue.TaskQueue; 
    3838import schedframe.scheduling.queue.TaskQueueList; 
     
    282282 
    283283                                                                                if(fan.getChilledResources().contains(n.getFullName())){ 
    284                                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     284                                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    285285                                                                                } 
    286286                                                                        } 
     
    375375 
    376376                                                                                if(fan.getChilledResources().contains(n.getFullName())){ 
    377                                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     377                                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    378378                                                                                } 
    379379                                                                        } 
     
    464464                        for(Device device: nodeGroup.getResourceCharacteristic().getDevices()){ 
    465465                                try { 
    466                                         fpc = fpc + device.getAirThroughputInterface().getPowerConsumption(new UserAirThroughputStateName("2")); 
     466                                        fpc = fpc + device.getAirflowInterface().getPowerConsumption(new CustomAirflowStateName("2")); 
    467467                                } catch (NoSuchFieldException e) { 
    468468                                        // TODO Auto-generated catch block 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_ConsolidationLowPower_SP.java

    r1299 r1396  
    2525import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2626import schedframe.scheduling.plan.impl.SchedulingPlan; 
    27 import schedframe.scheduling.plugin.grid.ModuleList; 
     27import schedframe.scheduling.plugin.ModuleList; 
    2828import schedframe.scheduling.queue.TaskQueue; 
    2929import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_LoadBalancing_SP.java

    r1319 r1396  
    1111import schedframe.scheduling.plan.SchedulingPlanInterface; 
    1212import schedframe.scheduling.plan.impl.SchedulingPlan; 
    13 import schedframe.scheduling.plugin.grid.ModuleList; 
     13import schedframe.scheduling.plugin.ModuleList; 
    1414import schedframe.scheduling.queue.TaskQueue; 
    1515import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_Random_PowerCapping_SP.java

    r1319 r1396  
    1919import schedframe.resources.computing.coolemall.ComputeBox1; 
    2020import schedframe.resources.computing.coolemall.NodeGroup; 
    21 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     21import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    2222import schedframe.resources.computing.profiles.energy.power.PState; 
    2323import schedframe.resources.devices.Device; 
     
    3232import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3333import schedframe.scheduling.plan.impl.SchedulingPlan; 
    34 import schedframe.scheduling.plugin.grid.ModuleList; 
     34import schedframe.scheduling.plugin.ModuleList; 
    3535import schedframe.scheduling.queue.TaskQueue; 
    3636import schedframe.scheduling.queue.TaskQueueList; 
     
    245245 
    246246                                                                                if(fan.getChilledResources().contains(n.getFullName())){ 
    247                                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     247                                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    248248                                                                                } 
    249249                                                                        } 
     
    338338 
    339339                                                                                if(fan.getChilledResources().contains(n.getFullName())){ 
    340                                                                                         fan.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("2")); 
     340                                                                                        fan.getAirflowInterface().setAirflowState(new CustomAirflowStateName("2")); 
    341341                                                                                } 
    342342                                                                        } 
     
    427427                        for(Device device: nodeGroup.getResourceCharacteristic().getDevices()){ 
    428428                                try { 
    429                                         fpc = fpc + device.getAirThroughputInterface().getPowerConsumption(new UserAirThroughputStateName("2")); 
     429                                        fpc = fpc + device.getAirflowInterface().getPowerConsumption(new CustomAirflowStateName("2")); 
    430430                                } catch (NoSuchFieldException e) { 
    431431                                        // TODO Auto-generated catch block 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_Random_SP.java

    r1319 r1396  
    2323import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2424import schedframe.scheduling.plan.impl.SchedulingPlan; 
    25 import schedframe.scheduling.plugin.grid.ModuleList; 
     25import schedframe.scheduling.plugin.ModuleList; 
    2626import schedframe.scheduling.queue.TaskQueue; 
    2727import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Consolidation_SP.java

    r1258 r1396  
    2525import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2626import schedframe.scheduling.plan.impl.SchedulingPlan; 
    27 import schedframe.scheduling.plugin.grid.ModuleList; 
     27import schedframe.scheduling.plugin.ModuleList; 
    2828import schedframe.scheduling.queue.TaskQueue; 
    2929import schedframe.scheduling.queue.TaskQueueList; 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_LB_SP.java

    r1258 r1396  
    1111import schedframe.scheduling.plan.SchedulingPlanInterface; 
    1212import schedframe.scheduling.plan.impl.SchedulingPlan; 
    13 import schedframe.scheduling.plugin.grid.ModuleList; 
     13import schedframe.scheduling.plugin.ModuleList; 
    1414import schedframe.scheduling.queue.TaskQueue; 
    1515import schedframe.scheduling.queue.TaskQueueList; 
     
    5555        } 
    5656 
    57         @SuppressWarnings("unchecked") 
    5857        private String chooseProvider(ClusterResourceManager resourceManager) { 
    5958                List<Node> nodes = resourceManager.getNodes(); 
  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Random_SP.java

    r1258 r1396  
    1212import schedframe.resources.computing.Core; 
    1313import schedframe.resources.computing.Node; 
    14 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     14import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    1515import schedframe.resources.devices.Device; 
    1616import schedframe.resources.units.ProcessingElements; 
     
    2323import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2424import schedframe.scheduling.plan.impl.SchedulingPlan; 
    25 import schedframe.scheduling.plugin.grid.ModuleList; 
     25import schedframe.scheduling.plugin.ModuleList; 
    2626import schedframe.scheduling.queue.TaskQueue; 
    2727import schedframe.scheduling.queue.TaskQueueList; 
     
    7979        } 
    8080 
    81         @SuppressWarnings("unchecked") 
    8281        private Node chooseRandomProvider(ClusterResourceManager resourceManager) { 
    8382                List<Node> nodes = resourceManager.getNodes(); 
     
    184183                                for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 
    185184                                        if(device.getFullName().equals(Node_Fan_Mapping.getNode_fan().get(node.getFullName()))){ 
    186                                                 device.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("Off")); 
     185                                                device.getAirflowInterface().setAirflowState(new CustomAirflowStateName("Off")); 
    187186                                                break; 
    188187                                        } 
     
    192191                                for(Device device: node.getParent().getResourceCharacteristic().getDevices()){ 
    193192                                        if(device.getFullName().equals(Node_Fan_Mapping.getNode_fan().get(node.getFullName()))){ 
    194                                                 device.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("On")); 
     193                                                device.getAirflowInterface().setAirflowState(new CustomAirflowStateName("On")); 
    195194                                                break; 
    196195                                        } 
Note: See TracChangeset for help on using the changeset viewer.