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

Legend:

Unmodified
Added
Removed

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