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

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/example/energy/BaseEnergyEstimationPlugin.java

    r1207 r1396  
    1717         
    1818        @Override 
    19         public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     19        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    2020                throw new RuntimeException("Not implemented."); 
    2121        } 

  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/CB1EnergyEstimationPlugin.java

    r1329 r1396  
    1111import schedframe.resources.computing.coolemall.NodeGroup; 
    1212import schedframe.resources.computing.profiles.energy.EnergyEvent; 
    13 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     13import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    1414import schedframe.resources.computing.profiles.energy.power.PState; 
    1515import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    … …  
    105105                        for(Device device: nodeGroup.getResourceCharacteristic().getDevices()){ 
    106106                                try { 
    107                                         fpc = fpc + device.getAirThroughputInterface().getPowerConsumption(new UserAirThroughputStateName("2")); 
     107                                        fpc = fpc + device.getAirflowInterface().getPowerConsumption(new CustomAirflowStateName("2")); 
    108108                                } catch (NoSuchFieldException e) { 
    109109                                        // TODO Auto-generated catch block 

  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/CB2EnergyEstimationPlugin.java

    r1299 r1396  
    168168                 
    169169                delta_p = ConfigurationOptions.coolingData.getPressureDrop(); 
    170                 Vair_total = ConfigurationOptions.coolingData.getAirFlowVolume(); 
     170                Vair_total = ConfigurationOptions.coolingData.getAirflowVolume(); 
    171171                 
    172172                if(delta_p != -1 && Vair_total != -1) 
    … …  
    192192                                                        double Vair_recs1 = 0; 
    193193 
    194                                                         Vair_recs1  = fan.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     194                                                        Vair_recs1  = fan.getAirflowInterface().getRecentAirflow().getValue(); 
    195195 
    196196                                                        double Vair_recs2 = 0; 
    … …  
    198198                                                                if(device2.getType().equals(StandardResourceType.Inlet) && device2.getFullName().equals(fan.getFullName().replace("Outlet", "Inlet"))){ 
    199199 
    200                                                                         Vair_recs2  = device2.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     200                                                                        Vair_recs2  = device2.getAirflowInterface().getRecentAirflow().getValue(); 
    201201 
    202202                                                                        break; 
    … …  
    401401                                        if(fan.getPowerInterface().getRecentPowerUsage().getValue() == -1){ 
    402402                                                try { 
    403                                                         Qfans = Qfans + (1 - delta_2) * fan.getAirThroughputInterface().getPowerConsumption(fan.getAirThroughputInterface().getAirThroughputState()); 
     403                                                        Qfans = Qfans + (1 - delta_2) * fan.getAirflowInterface().getPowerConsumption(fan.getAirflowInterface().getAirflowState()); 
    404404                                                } catch (NoSuchFieldException e) { 
    405405                                                        // TODO Auto-generated catch block 
    … …  
    443443                double ro = 1.168;//constant 
    444444                 
    445                 Vair_total = ConfigurationOptions.coolingData.getAirFlowVolume(); 
     445                Vair_total = ConfigurationOptions.coolingData.getAirflowVolume(); 
    446446                 
    447447                if(Vair_total != -1) { 
    … …  
    465465                                                        double Vair_recs1 = 0; 
    466466 
    467                                                         Vair_recs1  = fan.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     467                                                        Vair_recs1  = fan.getAirflowInterface().getRecentAirflow().getValue(); 
    468468 
    469469                                                        double Vair_recs2 = 0; 
    … …  
    471471                                                                if(device2.getType().equals(StandardResourceType.Inlet) && device2.getFullName().equals(fan.getFullName().replace("Outlet", "Inlet"))){ 
    472472 
    473                                                                         Vair_recs2  = device2.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     473                                                                        Vair_recs2  = device2.getAirflowInterface().getRecentAirflow().getValue(); 
    474474 
    475475                                                                        break; 

  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/CoolingDeviceEnergyEstimationPlugin.java

    r1299 r1396  
    1818public class CoolingDeviceEnergyEstimationPlugin extends BaseEnergyEstimationPlugin { 
    1919 
    20         public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    21                 double airThroughput = 0; 
    22                 return airThroughput; 
     20        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     21                double airflow = 0; 
     22                return airflow; 
    2323        } 
    2424 
    … …  
    140140                 
    141141                delta_p = ConfigurationOptions.coolingData.getPressureDrop(); 
    142                 Vair_total = ConfigurationOptions.coolingData.getAirFlowVolume(); 
     142                Vair_total = ConfigurationOptions.coolingData.getAirflowVolume(); 
    143143                 
    144144                if(delta_p != -1 && Vair_total != -1) 
    … …  
    164164                                                        double Vair_recs1 = 0; 
    165165 
    166                                                         Vair_recs1  = fan.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     166                                                        Vair_recs1  = fan.getAirflowInterface().getRecentAirflow().getValue(); 
    167167 
    168168                                                        double Vair_recs2 = 0; 
    … …  
    170170                                                                if(device2.getType().equals(StandardResourceType.Inlet) && device2.getFullName().equals(fan.getFullName().replace("Outlet", "Inlet"))){ 
    171171 
    172                                                                         Vair_recs2  = device2.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     172                                                                        Vair_recs2  = device2.getAirflowInterface().getRecentAirflow().getValue(); 
    173173 
    174174                                                                        break; 
    … …  
    373373                                        if(fan.getPowerInterface().getRecentPowerUsage().getValue() == -1){ 
    374374                                                try { 
    375                                                         Qfans = Qfans + (1 - delta_2) * fan.getAirThroughputInterface().getPowerConsumption(fan.getAirThroughputInterface().getAirThroughputState()); 
     375                                                        Qfans = Qfans + (1 - delta_2) * fan.getAirflowInterface().getPowerConsumption(fan.getAirflowInterface().getAirflowState()); 
    376376                                                } catch (NoSuchFieldException e) { 
    377377                                                        // TODO Auto-generated catch block 
    … …  
    415415                double ro = 1.168;//constant 
    416416                 
    417                 Vair_total = ConfigurationOptions.coolingData.getAirFlowVolume(); 
     417                Vair_total = ConfigurationOptions.coolingData.getAirflowVolume(); 
    418418                 
    419419                if(Vair_total != -1) { 
    … …  
    437437                                                        double Vair_recs1 = 0; 
    438438 
    439                                                         Vair_recs1  = fan.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     439                                                        Vair_recs1  = fan.getAirflowInterface().getRecentAirflow().getValue(); 
    440440 
    441441                                                        double Vair_recs2 = 0; 
    … …  
    443443                                                                if(device2.getType().equals(StandardResourceType.Inlet) && device2.getFullName().equals(fan.getFullName().replace("Outlet", "Inlet"))){ 
    444444 
    445                                                                         Vair_recs2  = device2.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     445                                                                        Vair_recs2  = device2.getAirflowInterface().getRecentAirflow().getValue(); 
    446446 
    447447                                                                        break; 

  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/FanEnergyEstimationPlugin.java

    r1299 r1396  
    2121                Fan fan = (Fan) resource; 
    2222                try { 
    23                         powerConsumption = fan.getAirThroughputInterface().getPowerConsumption(fan.getAirThroughputInterface().getAirThroughputState()); 
     23                        powerConsumption = fan.getAirflowInterface().getPowerConsumption(fan.getAirflowInterface().getAirflowState()); 
    2424                } catch (NoSuchFieldException e) { 
    2525                        // TODO Auto-generated catch block 
    … …  
    3535        } 
    3636         
    37         public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     37        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    3838                 
    39                 double airThroughput = 0; 
     39                double airflow = 0; 
    4040                Fan fan = (Fan) resource; 
    4141                try { 
    4242                        if(event.getReason() == EventReason.SIM_INIT) 
    43                                 airThroughput = fan.getAirThroughputInterface().getAirFlow(fan.getAirThroughputInterface().getAirThroughputState()); 
     43                                airflow = fan.getAirflowInterface().getAirflow(fan.getAirflowInterface().getAirflowState()); 
    4444                        else 
    45                                 airThroughput = fan.getAirThroughputInterface().getAirFlow(fan.getAirThroughputInterface().getAirThroughputState()); 
     45                                airflow = fan.getAirflowInterface().getAirflow(fan.getAirflowInterface().getAirflowState()); 
    4646                } catch (NoSuchFieldException e) { 
    4747                        // TODO Auto-generated catch block 
    … …  
    6565 
    6666                 
    67                 return airThroughput * getNumberOfWorkingNodes(fan)/(double)fan.getChilledResources().size(); 
     67                return airflow * getNumberOfWorkingNodes(fan)/(double)fan.getChilledResources().size(); 
    6868        } 
    6969         

  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/FlowPumpInletEnergyEstimationPlugin.java

    r1299 r1396  
    2626                 
    2727                delta_p = ConfigurationOptions.coolingData.getPressureDrop(); 
    28                 Vair_total = ConfigurationOptions.coolingData.getAirFlowVolume(); 
     28                Vair_total = ConfigurationOptions.coolingData.getAirflowVolume(); 
    2929                 
    3030                if(delta_p != -1 && Vair_total != -1) 
    … …  
    5353                                                        double Vair_recs1 = 0; 
    5454 
    55                                                         Vair_recs1  = fan.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     55                                                        Vair_recs1  = fan.getAirflowInterface().getRecentAirflow().getValue(); 
    5656 
    5757                                                        double Vair_recs2 = 0; 
    … …  
    5959                                                                if(device2.getType().equals(StandardResourceType.Inlet) && device2.getFullName().equals(fan.getFullName().replace("Outlet", "Inlet"))){ 
    6060 
    61                                                                         Vair_recs2  = device2.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     61                                                                        Vair_recs2  = device2.getAirflowInterface().getRecentAirflow().getValue(); 
    6262 
    6363                                                                        break; 
    … …  
    8686        } 
    8787         
    88         public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    89                 double airThroughput = 0; 
     88        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     89                double airflow = 0; 
    9090                double Vair_total; 
    9191                 
    92                 Vair_total = ConfigurationOptions.coolingData.getAirFlowVolume(); 
     92                Vair_total = ConfigurationOptions.coolingData.getAirflowVolume(); 
    9393                if(Vair_total != -1) { 
    94                         airThroughput = Vair_total; 
     94                        airflow = Vair_total; 
    9595                } else { 
    9696                        Device flowPump = (Device) resource; 
    … …  
    114114                                                        double Vair_recs1 = 0; 
    115115 
    116                                                         Vair_recs1  = fan.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     116                                                        Vair_recs1  = fan.getAirflowInterface().getRecentAirflow().getValue(); 
    117117 
    118118                                                        double Vair_recs2 = 0; 
    … …  
    120120                                                                if(device2.getType().equals(StandardResourceType.Inlet) && device2.getFullName().equals(fan.getFullName().replace("Outlet", "Inlet"))){ 
    121121 
    122                                                                         Vair_recs2  = device2.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     122                                                                        Vair_recs2  = device2.getAirflowInterface().getRecentAirflow().getValue(); 
    123123 
    124124                                                                        break; 
    … …  
    136136                        mair_total = mair_rack; 
    137137                        Vair_total = mair_total / ro; 
    138                         airThroughput = Vair_total; 
     138                        airflow = Vair_total; 
    139139                } 
    140                 return airThroughput; 
     140                return airflow; 
    141141        } 
    142142         

  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/FlowPumpOutletEnergyEstimationPlugin.java

    r1299 r1396  
    2323        } 
    2424         
    25         public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    26                 double airThroughput = 0; 
     25        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     26                double airflow = 0; 
    2727                double Vair_total; 
    2828                 
    29                 Vair_total = ConfigurationOptions.coolingData.getAirFlowVolume(); 
     29                Vair_total = ConfigurationOptions.coolingData.getAirflowVolume(); 
    3030                if(Vair_total != -1) { 
    31                         airThroughput = Vair_total; 
     31                        airflow = Vair_total; 
    3232                } else { 
    3333                        Device flowPump = (Device) resource; 
    … …  
    5151                                                        double Vair_recs1 = 0; 
    5252 
    53                                                         Vair_recs1  = fan.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     53                                                        Vair_recs1  = fan.getAirflowInterface().getRecentAirflow().getValue(); 
    5454 
    5555                                                        double Vair_recs2 = 0; 
    … …  
    5757                                                                if(device2.getType().equals(StandardResourceType.Inlet) && device2.getFullName().equals(fan.getFullName().replace("Outlet", "Inlet"))){ 
    5858 
    59                                                                         Vair_recs2  = device2.getAirThroughputInterface().getRecentAirFlow().getValue(); 
     59                                                                        Vair_recs2  = device2.getAirflowInterface().getRecentAirflow().getValue(); 
    6060 
    6161                                                                        break; 
    … …  
    7373                        mair_total = mair_rack; 
    7474                        Vair_total = mair_total / ro; 
    75                         airThroughput = Vair_total; 
     75                        airflow = Vair_total; 
    7676                } 
    77                 return airThroughput; 
     77                return airflow; 
    7878        } 
    7979} 

  • DCWoRMS/branches/coolemall/src/example/energy/coolemall/NodeEnergyEstimationPlugin.java

    r1299 r1396  
    3434                                                if(fan.getPowerInterface().getRecentPowerUsage().getValue() == -1){ 
    3535                                                        try { 
    36                                                                 powerConsumption = powerConsumption + fan.getAirThroughputInterface().getPowerConsumption(fan.getAirThroughputInterface().getAirThroughputState())/getNumberOfWorkingNodes(fan); 
     36                                                                powerConsumption = powerConsumption + fan.getAirflowInterface().getPowerConsumption(fan.getAirflowInterface().getAirflowState())/getNumberOfWorkingNodes(fan); 
    3737                                                        } catch (NoSuchFieldException e) { 
    3838                                                                // TODO Auto-generated catch block 

  • DCWoRMS/branches/coolemall/src/example/energy/device/FanEnergyEstimationPlugin.java

    r1207 r1396  
    33import schedframe.events.scheduling.EventReason; 
    44import schedframe.resources.computing.profiles.energy.EnergyEvent; 
    5 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     5import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    66import schedframe.resources.devices.PhysicalResource; 
    77import schedframe.scheduling.manager.tasks.JobRegistry; 
    … …  
    1515                try { 
    1616                        if(event.getReason() == EventReason.SIM_INIT) 
    17                                 powerConsumption = powerConsumption + resource.getAirThroughputInterface().getPowerConsumption(StandardAirThroughputStateName.OFF); 
     17                                powerConsumption = powerConsumption + resource.getAirflowInterface().getPowerConsumption(StandardAirflowStateName.OFF); 
    1818                        else 
    19                                 powerConsumption = powerConsumption + resource.getAirThroughputInterface().getPowerConsumption(resource.getAirThroughputInterface().getAirThroughputState()); 
     19                                powerConsumption = powerConsumption + resource.getAirflowInterface().getPowerConsumption(resource.getAirflowInterface().getAirflowState()); 
    2020                } catch (NoSuchFieldException e) { 
    2121                } 
    … …  
    2424        } 
    2525 
    26         public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
    27                 double airThroughput = 0; 
     26        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource) { 
     27                double airflow= 0; 
    2828                try { 
    2929                        if(event.getReason() == EventReason.SIM_INIT) 
    30                                 airThroughput = resource.getAirThroughputInterface().getAirFlow(StandardAirThroughputStateName.OFF); 
     30                                airflow = resource.getAirflowInterface().getAirflow(StandardAirflowStateName.OFF); 
    3131                        else 
    32                                 airThroughput = resource.getAirThroughputInterface().getAirFlow(resource.getAirThroughputInterface().getAirThroughputState()); 
     32                                airflow = resource.getAirflowInterface().getAirflow(resource.getAirflowInterface().getAirflowState()); 
    3333                } catch (NoSuchFieldException e) { 
    3434                        // TODO Auto-generated catch block 
    3535                        e.printStackTrace(); 
    3636                } 
    37                 return airThroughput; 
     37                return airflow; 
    3838        } 
    3939} 

  • DCWoRMS/branches/coolemall/src/example/globalplugin/BaseGlobalPlugin.java

    r516 r1396  
    66import schedframe.scheduling.TaskList; 
    77import schedframe.scheduling.manager.resources.ResourceManager; 
     8import schedframe.scheduling.plugin.ModuleList; 
    89import schedframe.scheduling.plugin.SchedulingPluginConfiguration; 
    910import schedframe.scheduling.plugin.grid.GlobalSchedulingPlugin; 
    10 import schedframe.scheduling.plugin.grid.ModuleList; 
    1111import schedframe.scheduling.queue.TaskQueue; 
    1212import schedframe.scheduling.queue.TaskQueueList; 

  • DCWoRMS/branches/coolemall/src/example/globalplugin/GridFCFSLoadBalancingPlugin.java

    r497 r1396  
    33 
    44import java.util.List; 
    5 import java.util.Properties; 
    65 
    76import org.apache.commons.logging.Log; 
    … …  
    1615import schedframe.scheduling.plan.impl.ScheduledTask; 
    1716import schedframe.scheduling.plan.impl.SchedulingPlan; 
    18 import schedframe.scheduling.plugin.grid.Module; 
    19 import schedframe.scheduling.plugin.grid.ModuleList; 
     17import schedframe.scheduling.plugin.Module; 
     18import schedframe.scheduling.plugin.ModuleList; 
    2019import schedframe.scheduling.plugin.grid.ResourceDiscovery; 
    2120import schedframe.scheduling.queue.QueueDescription; 

  • DCWoRMS/branches/coolemall/src/example/globalplugin/GridFCFSRandomPlugin.java

    r497 r1396  
    22 
    33import java.util.List; 
    4 import java.util.Properties; 
    54import java.util.Random; 
    65 
    … …  
    1312import schedframe.scheduling.plan.impl.ScheduledTask; 
    1413import schedframe.scheduling.plan.impl.SchedulingPlan; 
    15 import schedframe.scheduling.plugin.grid.Module; 
    16 import schedframe.scheduling.plugin.grid.ModuleList; 
     14import schedframe.scheduling.plugin.Module; 
     15import schedframe.scheduling.plugin.ModuleList; 
    1716import schedframe.scheduling.plugin.grid.ResourceDiscovery; 
    1817import schedframe.scheduling.queue.TaskQueue; 
    … …  
    2928        } 
    3029         
    31         public SchedulingPlanInterface schedule(SchedulingEvent event, 
     30        public SchedulingPlanInterface<?> schedule(SchedulingEvent event, 
    3231                        TaskQueueList queues,  
    3332                        JobRegistry jobRegistry, 

  • DCWoRMS/branches/coolemall/src/example/globalplugin/GridFCFSRoundRobinPlugin.java

    r497 r1396  
    1212import schedframe.scheduling.plan.impl.ScheduledTask; 
    1313import schedframe.scheduling.plan.impl.SchedulingPlan; 
    14 import schedframe.scheduling.plugin.grid.Module; 
    15 import schedframe.scheduling.plugin.grid.ModuleList; 
     14import schedframe.scheduling.plugin.Module; 
     15import schedframe.scheduling.plugin.ModuleList; 
    1616import schedframe.scheduling.plugin.grid.ResourceDiscovery; 
    1717import schedframe.scheduling.queue.TaskQueue; 
    … …  
    2424        private LinkedList<String> lastUsedResources = new LinkedList<String>(); 
    2525 
    26         public SchedulingPlanInterface schedule(SchedulingEvent event, 
     26        public SchedulingPlanInterface<?> schedule(SchedulingEvent event, 
    2727                        TaskQueueList queues,  
    2828                        JobRegistry jobRegistry, 

  • DCWoRMS/branches/coolemall/src/example/load/DefaultLoadEstimationPlugin.java

    r1290 r1396  
    55import schedframe.resources.devices.PhysicalResource; 
    66import schedframe.scheduling.manager.tasks.JobRegistry; 
    7 import simulator.stats.GSSAccumulator; 
     7import simulator.stats.DCwormsAccumulator; 
    88 
    99 
    … …  
    1313 
    1414                ComputingResource computingResource = (ComputingResource) resource; 
    15                 GSSAccumulator childrenLoad = new GSSAccumulator(); 
     15                DCwormsAccumulator childrenLoad = new DCwormsAccumulator(); 
    1616                for(ComputingResource compRes: computingResource.getChildren()){ 
    1717                        childrenLoad.add(compRes.getLoadInterface().getRecentUtilization().getValue()); 

  • DCWoRMS/branches/coolemall/src/example/load/ProcessorLoadEstimationPlugin.java

    r1299 r1396  
    2626                        double cpuUsage = 1 / nrOfThreadsOnCpu; 
    2727 
    28                         for(PhaseBehaviour pb: task.getCurrentResourceConsumption().getBehaviourList()){ 
     28                        for(PhaseBehaviour pb: task.getExecutionProfile().getCurrentResourceConsumption().getBehaviourList()){ 
    2929                                if(pb.getResouceName().equals("PM_CPU_Usage")){ 
    3030                                        cpuUsage = pb.getUtilization(); 

  • 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                                        } 

  • DCWoRMS/branches/coolemall/src/example/timeestimation/coolemall/CPUFreqScalingPhaseTimeEstimationPlugin.java

    r1364 r1396  
    22 
    33import java.util.Map; 
    4  
    5 import org.joda.time.DateTime; 
    64 
    75import schedframe.events.scheduling.SchedulingEvent; 
    … …  
    1412import schedframe.resources.units.ResourceUnitName; 
    1513import schedframe.resources.units.StandardResourceUnitName; 
    16 import schedframe.scheduling.tasks.phases.ResourceConsumption; 
    1714import dcworms.schedframe.scheduling.ExecTask; 
    18 import dcworms.schedframe.scheduling.Executable; 
    1915import example.timeestimation.BaseTimeEstimationPlugin; 
    2016 
    … …  
    2622                        double completionPercentage) { 
    2723                 
    28                 String taskFreqString = task.getCurrentResourceConsumption().getReferenceHardware().get("cpu_maxfreq"); 
     24                String taskFreqString = task.getExecutionProfile().getCurrentResourceConsumption().getReferenceHardware().get("cpu_maxfreq"); 
    2925                double taskFreq = Double.valueOf(taskFreqString); 
    3026                 
    … …  
    4945                        currentFrequency = taskFreq; 
    5046 
    51                 double execTime = (1 - completionPercentage/100) * task.getCurrentResourceConsumption().getDuration() * (taskFreq / currentFrequency); 
     47                double execTime = (1 - completionPercentage/100) * task.getExecutionProfile().getCurrentResourceConsumption().getDuration() * (taskFreq / currentFrequency); 
    5248 
    5349                // if the result is very close to 0, but less then one millisecond then round this result to 0.001 

  • DCWoRMS/branches/coolemall/src/example/timeestimation/coolemall/PhaseTimeEstimationPlugin.java

    r1253 r1396  
    2525                Executable exec = (Executable) task; 
    2626 
    27                 ResourceConsumption resConsumption = exec.getResourceConsumptionProfile().getCurrentResourceConsumption(); 
     27                ResourceConsumption resConsumption = exec.getExecutionProfile().getCurrentResourceConsumption(); 
    2828 
    2929                double execTime = (1 - completionPercentage/100) * resConsumption.getDuration(); 
Note: See TracChangeset for help on using the changeset viewer.