Ignore:
Timestamp:
06/26/14 14:24:08 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins
Files:
12 edited

Legend:

Unmodified
Added
Removed
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/energy/FanEnergyEstimationPlugin.java

    r1210 r1399  
    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/test/article2/recs/plugins/energy/RecsCpuBaseEEP.java

    r1210 r1399  
    55import schedframe.resources.computing.Processor; 
    66import schedframe.resources.computing.profiles.energy.EnergyEvent; 
    7 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     7import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    88import schedframe.resources.devices.PhysicalResource; 
    99import schedframe.scheduling.manager.tasks.JobRegistry; 
     
    3939                try { 
    4040                        if(event.getReason() == EventReason.SIM_INIT) 
    41                                 airThroughput = resource.getAirThroughputInterface().getAirFlow(StandardAirThroughputStateName.OFF); 
     41                                airThroughput = resource.getAirflowInterface().getAirflow(StandardAirflowStateName.OFF); 
    4242                        else 
    43                                 airThroughput = resource.getAirThroughputInterface().getAirFlow(resource.getAirThroughputInterface().getAirThroughputState()); 
     43                                airThroughput = resource.getAirflowInterface().getAirflow(resource.getAirflowInterface().getAirflowState()); 
    4444                } catch (NoSuchFieldException e) { 
    4545                        // TODO Auto-generated catch block 
     
    5353                                if(id - resId == 9 || id - resId == -9){ 
    5454                                        try { 
    55                                                 airThroughput = airThroughput + compResource.getAirThroughputInterface().getAirFlow(compResource.getAirThroughputInterface().getAirThroughputState())/2; 
     55                                                airThroughput = airThroughput + compResource.getAirflowInterface().getAirflow(compResource.getAirflowInterface().getAirflowState())/2; 
    5656                                        } catch (NoSuchFieldException e) { 
    5757                 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/energy/RecsNodeBaseEEP.java

    r1368 r1399  
    1515import schedframe.resources.computing.Processor; 
    1616import schedframe.resources.computing.profiles.energy.EnergyEvent; 
    17 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     17import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    1818import schedframe.resources.units.PEUnit; 
    1919import schedframe.resources.units.ProcessingElements; 
     
    5757                try { 
    5858                        if(event.getReason() == EventReason.SIM_INIT) 
    59                                 airThroughput = resource.getAirThroughputInterface().getAirFlow(StandardAirThroughputStateName.OFF); 
     59                                airThroughput = resource.getAirflowInterface().getAirflow(StandardAirflowStateName.OFF); 
    6060                        else 
    61                                 airThroughput = resource.getAirThroughputInterface().getAirFlow(resource.getAirThroughputInterface().getAirThroughputState()); 
     61                                airThroughput = resource.getAirflowInterface().getAirflow(resource.getAirflowInterface().getAirflowState()); 
    6262                } catch (NoSuchFieldException e) { 
    6363                        // TODO Auto-generated catch block 
     
    7171                                if(id - resId == 9 || id - resId == -9){ 
    7272                                        try { 
    73                                                 airThroughput = airThroughput + compResource.getAirThroughputInterface().getAirFlow(compResource.getAirThroughputInterface().getAirThroughputState())/2; 
     73                                                airThroughput = airThroughput + compResource.getAirflowInterface().getAirflow(compResource.getAirflowInterface().getAirflowState())/2; 
    7474                                        } catch (NoSuchFieldException e) { 
    7575                 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsInIdleSP.java

    r1247 r1399  
    1616import schedframe.resources.computing.ComputingResource; 
    1717import schedframe.resources.computing.Core; 
    18 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     18import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    1919import schedframe.resources.units.ProcessingElements; 
    2020import schedframe.resources.units.ResourceUnit; 
     
    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; 
     
    5959                                        Node node = chooseProvider(resourceManager, task); 
    6060                                        if (node != null) { 
    61                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     61                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6262                                                notSelectedNodes.remove(node); 
    6363                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    166166                                //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 
    167167                        } else {  
    168                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     168                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    169169                        } 
    170170                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsInOffSP.java

    r1247 r1399  
    1717import schedframe.resources.computing.Core; 
    1818import schedframe.resources.computing.Processor; 
    19 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
    20 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     19import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
     20import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    2121import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    2222import schedframe.resources.units.ProcessingElements; 
     
    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; 
     
    6363                                        Node node = chooseProvider(resourceManager, task); 
    6464                                        if (node != null) { 
    65                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     65                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6666                                                notSelectedNodes.remove(node); 
    6767                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    186186                for(Node node : nodes){ 
    187187                        if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 
    188                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF); 
     188                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 
    189189                        } else { 
    190                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     190                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    191191                        } 
    192192                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsInOutSP.java

    r1247 r1399  
    1919import schedframe.resources.computing.ComputingResource; 
    2020import schedframe.resources.computing.Core; 
    21 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     21import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    2222import schedframe.resources.units.ProcessingElements; 
    2323import schedframe.resources.units.ResourceUnit; 
     
    2929import schedframe.scheduling.plan.SchedulingPlanInterface; 
    3030import schedframe.scheduling.plan.impl.SchedulingPlan; 
    31 import schedframe.scheduling.plugin.grid.ModuleList; 
     31import schedframe.scheduling.plugin.ModuleList; 
    3232import schedframe.scheduling.queue.TaskQueue; 
    3333import schedframe.scheduling.queue.TaskQueueList; 
     
    6262                                        Node node = chooseProvider(resourceManager, task); 
    6363                                        if (node != null) { 
    64                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     64                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6565                                                notSelectedNodes.remove(node); 
    6666                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    170170                                //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 
    171171                        } else {  
    172                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     172                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    173173                        } 
    174174                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsOutIdleSP.java

    r1247 r1399  
    1616import schedframe.resources.computing.ComputingResource; 
    1717import schedframe.resources.computing.Core; 
    18 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     18import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    1919import schedframe.resources.units.ProcessingElements; 
    2020import schedframe.resources.units.ResourceUnit; 
     
    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; 
     
    5959                                        Node node = chooseProvider(resourceManager, task); 
    6060                                        if (node != null) { 
    61                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     61                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6262                                                notSelectedNodes.remove(node); 
    6363                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    166166                                //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 
    167167                        } else {  
    168                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     168                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    169169                        } 
    170170                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp1/RecsOutOffSP.java

    r1247 r1399  
    1818import schedframe.resources.computing.Core; 
    1919import schedframe.resources.computing.Processor; 
    20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
    21 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     20import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
     21import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    2222import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    2323import schedframe.resources.units.ProcessingElements; 
     
    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; 
     
    6464                                        Node node = chooseProvider(resourceManager, task); 
    6565                                        if (node != null) { 
    66                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     66                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6767                                                notSelectedNodes.remove(node); 
    6868                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    187187                for(Node node : nodes){ 
    188188                        if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 
    189                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF); 
     189                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 
    190190                        } else {  
    191                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     191                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    192192                        } 
    193193                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsIn2OutSP.java

    r1247 r1399  
    1818import schedframe.resources.computing.ComputingResource; 
    1919import schedframe.resources.computing.Core; 
    20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     20import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    2121import schedframe.resources.units.ProcessingElements; 
    2222import schedframe.resources.units.ResourceUnit; 
     
    2828import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2929import schedframe.scheduling.plan.impl.SchedulingPlan; 
    30 import schedframe.scheduling.plugin.grid.ModuleList; 
     30import schedframe.scheduling.plugin.ModuleList; 
    3131import schedframe.scheduling.queue.TaskQueue; 
    3232import schedframe.scheduling.queue.TaskQueueList; 
     
    6161                                        Node node = chooseProvider(resourceManager, task); 
    6262                                        if (node != null) { 
    63                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     63                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6464                                                notSelectedNodes.remove(node); 
    6565                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    170170                                //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 
    171171                        } else {  
    172                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     172                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    173173                        } 
    174174                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsLeft2RightSP.java

    r1247 r1399  
    1818import schedframe.resources.computing.ComputingResource; 
    1919import schedframe.resources.computing.Core; 
    20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     20import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    2121import schedframe.resources.units.ProcessingElements; 
    2222import schedframe.resources.units.ResourceUnit; 
     
    2828import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2929import schedframe.scheduling.plan.impl.SchedulingPlan; 
    30 import schedframe.scheduling.plugin.grid.ModuleList; 
     30import schedframe.scheduling.plugin.ModuleList; 
    3131import schedframe.scheduling.queue.TaskQueue; 
    3232import schedframe.scheduling.queue.TaskQueueList; 
     
    6262                                        Node node = chooseProvider(resourceManager, task); 
    6363                                        if (node != null) { 
    64                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     64                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6565                                                notSelectedNodes.remove(node); 
    6666                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    170170                                // node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 
    171171                        } else { 
    172                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     172                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    173173                        } 
    174174                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsOut2InSP.java

    r1247 r1399  
    1818import schedframe.resources.computing.ComputingResource; 
    1919import schedframe.resources.computing.Core; 
    20 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     20import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    2121import schedframe.resources.units.ProcessingElements; 
    2222import schedframe.resources.units.ResourceUnit; 
     
    2828import schedframe.scheduling.plan.SchedulingPlanInterface; 
    2929import schedframe.scheduling.plan.impl.SchedulingPlan; 
    30 import schedframe.scheduling.plugin.grid.ModuleList; 
     30import schedframe.scheduling.plugin.ModuleList; 
    3131import schedframe.scheduling.queue.TaskQueue; 
    3232import schedframe.scheduling.queue.TaskQueueList; 
     
    6161                                        Node node = chooseProvider(resourceManager, task); 
    6262                                        if (node != null) { 
    63                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     63                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6464                                                notSelectedNodes.remove(node); 
    6565                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    169169                                //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); 
    170170                        } else {  
    171                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     171                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    172172                        } 
    173173                } 
  • DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsRandomSP.java

    r1247 r1399  
    1414import schedframe.resources.computing.ComputingResource; 
    1515import schedframe.resources.computing.Core; 
    16 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
    17 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     16import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
     17import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    1818import schedframe.resources.units.ProcessingElements; 
    1919import schedframe.resources.units.ResourceUnit; 
     
    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; 
     
    5858                                        Node node = chooseRandomProvider(resourceManager, task); 
    5959                                        if (node != null) { 
    60                                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     60                                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    6161                                                notSelectedNodes.remove(node); 
    6262                                                addToSchedulingPlan(plan, task, chooseResourcesForExecution(node, task)); 
     
    152152                for(Node node : nodes){ 
    153153                        if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 
    154                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF); 
     154                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.OFF); 
    155155                        } else if(new JobRegistryImpl(node.getFullName()).getRunningTasks().size() > 1) 
    156                                 node.getAirThroughputInterface().setAirThroughputState(new UserAirThroughputStateName("FAN_ON_TURBO")); 
     156                                node.getAirflowInterface().setAirflowState(new CustomAirflowStateName("FAN_ON_TURBO")); 
    157157                        else  
    158                                 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); 
     158                                node.getAirflowInterface().setAirflowState(StandardAirflowStateName.ON); 
    159159                } 
    160160        } 
Note: See TracChangeset for help on using the changeset viewer.