Changeset 1396 for DCWoRMS/branches


Ignore:
Timestamp:
06/26/14 14:18:01 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src
Files:
2 added
3 deleted
87 edited
22 moved

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/dcworms/schedframe/scheduling/ExecTask.java

    r1362 r1396  
    44 
    55import schedframe.scheduling.ExecutionHistoryItem; 
    6 import schedframe.scheduling.ResourceHistoryItem; 
     6import schedframe.scheduling.ResourceItem; 
    77import schedframe.scheduling.tasks.TaskInterface; 
    8 import schedframe.scheduling.tasks.phases.ResourceConsumption; 
    98import schedframe.scheduling.tasks.phases.ExecutionProfile; 
    109import schedframe.scheduling.tasks.requirements.ResourceParameterName; 
    … …  
    1514        public Object getExpectedSpecificResource(ResourceParameterName resourceName); 
    1615         
    17         public LinkedList<ExecutionHistoryItem> getExecHistory(); 
    18         public LinkedList<ResourceHistoryItem> getAllocatedResources(); 
     16        public ExecutionProfile getExecutionProfile(); 
    1917         
    20         public ExecutionProfile getResourceConsumptionProfile(); 
    21         public ResourceConsumption getCurrentResourceConsumption(); 
     18        public LinkedList<ResourceItem> getAllocatedResources(); 
     19    public String getSchedulerName(); 
    2220         
    23     public String getSchedulerName(); 
     21        public LinkedList<ExecutionHistoryItem> getExecutionHistory(); 
     22 
    2423} 

  • DCWoRMS/branches/coolemall/src/dcworms/schedframe/scheduling/Executable.java

    r1362 r1396  
    2424import schedframe.resources.units.StandardResourceUnitName; 
    2525import schedframe.scheduling.ExecutionHistoryItem; 
    26 import schedframe.scheduling.ResourceHistoryItem; 
     26import schedframe.scheduling.ResourceItem; 
    2727import schedframe.scheduling.WorkloadUnitHandler; 
    2828import schedframe.scheduling.manager.tasks.JobRegistryImpl; 
    … …  
    6565         
    6666        protected LinkedList<ExecutionHistoryItem> execHistory;; 
    67         protected LinkedList<ResourceHistoryItem> allocatedResources; 
     67        protected LinkedList<ResourceItem> allocatedResources; 
    6868         
    6969        public Executable(Task t){ 
    … …  
    7171                this.status = DCWormsTags.CREATED; 
    7272 
    73                 this.allocatedResources = new LinkedList<ResourceHistoryItem>(); 
     73                this.allocatedResources = new LinkedList<ResourceItem>(); 
    7474                this.execHistory = new LinkedList<ExecutionHistoryItem>(); 
    7575                init(); 
    … …  
    8181                this.processesSetId = procesesSet.getId();  
    8282                 
    83                 this.allocatedResources = new LinkedList<ResourceHistoryItem>(); 
     83                this.allocatedResources = new LinkedList<ResourceItem>(); 
    8484                this.execHistory = new LinkedList<ExecutionHistoryItem>(); 
    8585                init(); 
    … …  
    366366        }*/ 
    367367         
    368         public ExecutionProfile getResourceConsumptionProfile(){ 
     368        public ExecutionProfile getExecutionProfile(){ 
    369369                return execProfile; 
    370370        } 
    … …  
    470470        } 
    471471 
    472         public LinkedList<ExecutionHistoryItem> getExecHistory() { 
     472        public LinkedList<ExecutionHistoryItem> getExecutionHistory() { 
    473473                return execHistory; 
    474474        } 
    … …  
    478478        } 
    479479 
    480         public LinkedList<ResourceHistoryItem> getAllocatedResources() { 
     480        public LinkedList<ResourceItem> getAllocatedResources() { 
    481481                return allocatedResources; 
    482482        } 
    483483 
    484         public void addAllocatedResources(ResourceHistoryItem allocatedResourcesItem) { 
     484        public void addAllocatedResources(ResourceItem allocatedResourcesItem) { 
    485485                this.allocatedResources.add(allocatedResourcesItem); 
    486486        } 

  • 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(); 

  • DCWoRMS/branches/coolemall/src/schedframe/SimulatedEnvironment.java

    r1207 r1396  
    1111 
    1212import schedframe.exceptions.ResourceException; 
    13 import schedframe.resources.ResourceHistoryChanges; 
     13import schedframe.resources.ResourceHistoryItem; 
    1414import schedframe.resources.computing.ComputingResource; 
    1515import schedframe.scheduling.Scheduler; 
    … …  
    2121        protected List<Initializable> toInit; 
    2222        protected Set<String> compResLayers; 
    23         protected static List<ResourceHistoryChanges> compResHistory = new ArrayList<ResourceHistoryChanges>(); 
     23        protected static List<ResourceHistoryItem> compResHistory = new ArrayList<ResourceHistoryItem>(); 
    2424         
    2525        public SimulatedEnvironment(Scheduler logicalStructure, List<ComputingResource> compResources){ 
    … …  
    156156 
    157157        public static void traceResource(long timestamp, String resourceName, String operation, String paramter){ 
    158                 ResourceHistoryChanges rhc = new ResourceHistoryChanges(timestamp, resourceName, operation, paramter); 
     158                ResourceHistoryItem rhc = new ResourceHistoryItem(timestamp, resourceName, operation, paramter); 
    159159                compResHistory.add(rhc); 
    160160        } 
    161161 
    162         public static List<ResourceHistoryChanges> getCompResHistory() { 
     162        public static List<ResourceHistoryItem> getCompResHistory() { 
    163163                return compResHistory; 
    164164        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/CustomResourceType.java

    r477 r1396  
    22 
    33 
    4 public class UserResourceType implements ResourceType { 
     4public class CustomResourceType implements ResourceType { 
    55 
    66        protected String name; 
    77 
    8         public UserResourceType(String name) { 
     8        public CustomResourceType(String name) { 
    99                this.name = name; 
    1010        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/ResourceHistoryItem.java

    r1207 r1396  
    22 
    33 
    4 public class ResourceHistoryChanges { 
     4public class ResourceHistoryItem { 
    55         
    66        private long timestamp;  
    77        private String resourceName; 
    8         private String operation; 
     8        private String action; 
    99        private String paramter; 
    1010         
    11         public ResourceHistoryChanges(long timestamp, String resourceName, String operation, String paramter) { 
     11        public ResourceHistoryItem(long timestamp, String resourceName, String action, String paramter) { 
    1212                super(); 
    1313                this.timestamp = timestamp; 
    1414                this.resourceName = resourceName; 
    15                 this.operation = operation; 
     15                this.action = action; 
    1616                this.paramter = paramter; 
    1717        } 
    … …  
    2525        } 
    2626         
    27         public String getOperation() { 
    28                 return operation; 
     27        public String getAction() { 
     28                return action; 
    2929        } 
    3030         

  • DCWoRMS/branches/coolemall/src/schedframe/resources/ResourceTypeFactory.java

    r1207 r1396  
    6060                        return StandardResourceType.LS; 
    6161                 
    62                 return new UserResourceType(typeName); 
     62                return new CustomResourceType(typeName); 
    6363        } 
    6464} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/ComputingResource.java

    r1392 r1396  
    5757                initCharacteristics(resDesc); 
    5858                accept(new LoadExtension(resDesc.getLoadProfile(), this)); 
    59                 accept(new EnergyExtension.Builder().resource(this).powerProfile(resDesc.getPowerProfile()).airFlowProfile(resDesc.getAirThroughputProfile()).thermalProfile(resDesc.getThermalProfile()).build());      
     59                accept(new EnergyExtension.Builder().resource(this).powerProfile(resDesc.getPowerProfile()).airflowProfile(resDesc.getAirflowProfile()).thermalProfile(resDesc.getThermalProfile()).build());    
    6060        } 
    6161 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/EnergyExtension.java

    r1389 r1396  
    1010import schedframe.resources.computing.extensions.ExtensionException; 
    1111import schedframe.resources.computing.extensions.ExtensionType; 
    12 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputInterfaceFactory; 
    13 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile; 
    14 import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface; 
     12import schedframe.resources.computing.profiles.energy.airthroughput.AirflowInterfaceFactory; 
     13import schedframe.resources.computing.profiles.energy.airthroughput.AirflowProfile; 
     14import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirflowInterface; 
    1515import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory; 
    1616import schedframe.resources.computing.profiles.energy.power.PowerProfile; 
    … …  
    3030        protected PowerProfile powerProfile; 
    3131         
    32         protected AirThroughputInterface airFlowInterface; 
    33         protected AirThroughputProfile airFlowProfile; 
     32        protected AirflowInterface airflowInterface; 
     33        protected AirflowProfile airflowProfile; 
    3434         
    3535        protected ThermalInterface thermalInterface; 
    … …  
    7474                protected PowerProfile powerProfile; 
    7575                 
    76                 protected AirThroughputInterface airFlowInterface; 
    77                 protected AirThroughputProfile airFlowProfile; 
     76                protected AirflowInterface airflowInterface; 
     77                protected AirflowProfile airflowProfile; 
    7878                 
    7979                protected ThermalInterface thermalInterface; 
    … …  
    8484                public Builder powerProfile(PowerProfile pp){this.powerProfile = pp; this.powerInterface = PowerInterfaceFactory.createPowerInterface(resource, powerProfile); return this; } 
    8585 
    86         public Builder airFlowProfile(AirThroughputProfile atp){this.airFlowProfile = atp; this.airFlowInterface = AirThroughputInterfaceFactory.createAirThroughputInterface(resource, airFlowProfile); return this; } 
     86        public Builder airflowProfile(AirflowProfile atp){this.airflowProfile = atp; this.airflowInterface = AirflowInterfaceFactory.createAirflowInterface(resource, airflowProfile); return this; } 
    8787 
    8888        public Builder thermalProfile(ThermalProfile tp){this.thermalProfile = tp; this.thermalInterface = ThermalInterfaceFactory.createThermalInterface(resource, thermalProfile); return this; } 
    … …  
    9898                this.powerProfile = builder.powerProfile; 
    9999                 
    100                 this.airFlowInterface = builder.airFlowInterface ; 
    101                 this.airFlowProfile = builder.airFlowProfile; 
     100                this.airflowInterface = builder.airflowInterface ; 
     101                this.airflowProfile = builder.airflowProfile; 
    102102                 
    103103                this.thermalInterface = builder.thermalInterface; 
    … …  
    163163                                 
    164164                        case AIRFLOW_STATE_CHANGED: 
    165                                 double airFlow = powerProfile.getEnergyEstimationPlugin().estimateAirThroughput(enEvent, new JobRegistryImpl(resource.getFullName()), resource); 
    166                                 airFlowProfile.addToAirFlowHistory(airFlow); 
     165                                double airflow = powerProfile.getEnergyEstimationPlugin().estimateAirflow(enEvent, new JobRegistryImpl(resource.getFullName()), resource); 
     166                                airflowProfile.addToAirFlowHistory(airflow); 
    167167                                break; 
    168168                                 
    … …  
    204204        } 
    205205 
    206         public AirThroughputInterface getAirThroughputInterface() { 
    207                 return airFlowInterface; 
    208         } 
    209  
    210         public AirThroughputProfile getAirFlowProfile() { 
    211                 return airFlowProfile; 
     206        public AirflowInterface getAirflowInterface() { 
     207                return airflowInterface; 
     208        } 
     209 
     210        public AirflowProfile getAirFlowProfile() { 
     211                return airflowProfile; 
    212212        } 
    213213         

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/AirFlowValue.java

    r495 r1396  
    33import schedframe.resources.computing.profiles.energy.MeasurementHistory; 
    44 
    5 public class AirFlowValue extends MeasurementHistory{ 
     5public class AirflowValue extends MeasurementHistory{ 
    66 
    7         public AirFlowValue(long timestamp, double value){ 
     7        public AirflowValue(long timestamp, double value){ 
    88                super(timestamp, value); 
    99        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/AirflowInterfaceFactory.java

    r1318 r1396  
    33import schedframe.resources.StandardResourceType; 
    44import schedframe.resources.computing.ComputingResource; 
    5 import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface; 
    6 import schedframe.resources.computing.profiles.energy.airthroughput.ui.ComputingResourceAirThroughputInterface; 
     5import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirflowInterface; 
     6import schedframe.resources.computing.profiles.energy.airthroughput.ui.ComputingResourceAirflowInterface; 
    77import schedframe.resources.devices.PhysicalResource; 
    8 import schedframe.resources.devices.DeviceAirThroughputInterface; 
    9 import schedframe.resources.devices.coolemall.FanAirThroughputInterface; 
     8import schedframe.resources.devices.DeviceAirflowInterface; 
     9import schedframe.resources.devices.coolemall.FanAirflowInterface; 
    1010 
    11 public class AirThroughputInterfaceFactory { 
     11public class AirflowInterfaceFactory { 
    1212         
    13         public static AirThroughputInterface createAirThroughputInterface(PhysicalResource resource, AirThroughputProfile atp){ 
     13        public static AirflowInterface createAirflowInterface(PhysicalResource resource, AirflowProfile atp){ 
    1414                if(atp == null) 
    1515                        return null; 
    16                 AirThroughputInterface airThroughputInterface = null; 
     16                AirflowInterface airflowInterface = null; 
    1717                if(resource.getType().getName().equals(StandardResourceType.CRAH.getName())) 
    18                         airThroughputInterface = new DeviceAirThroughputInterface(resource, atp); 
     18                        airflowInterface = new DeviceAirflowInterface(resource, atp); 
    1919                else if(resource.getType().getName().equals(StandardResourceType.Fan.getName())) 
    20                         airThroughputInterface = new FanAirThroughputInterface(resource, atp); 
     20                        airflowInterface = new FanAirflowInterface(resource, atp); 
    2121                else if(resource.getType().getName().equals(StandardResourceType.Inlet.getName())) 
    22                         airThroughputInterface = new FanAirThroughputInterface(resource, atp); 
     22                        airflowInterface = new FanAirflowInterface(resource, atp); 
    2323                else if(resource.getType().getName().equals(StandardResourceType.Outlet.getName())) 
    24                         airThroughputInterface = new FanAirThroughputInterface(resource, atp); 
     24                        airflowInterface = new FanAirflowInterface(resource, atp); 
    2525                else if(resource.getType().getName().equals(StandardResourceType.CoolingDevice.getName())) 
    26                         airThroughputInterface = new DeviceAirThroughputInterface(resource, atp); 
     26                        airflowInterface = new DeviceAirflowInterface(resource, atp); 
    2727                else 
    28                         airThroughputInterface = new ComputingResourceAirThroughputInterface((ComputingResource)resource, atp); 
    29                 return airThroughputInterface; 
     28                        airflowInterface = new ComputingResourceAirflowInterface((ComputingResource)resource, atp); 
     29                return airflowInterface; 
    3030        } 
    3131} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/AirflowProfile.java

    r1207 r1396  
    77 
    88import schedframe.Parameters; 
    9 import schedframe.resources.computing.profiles.energy.airthroughput.plugin.AirThroughputEstimationPlugin; 
     9import schedframe.resources.computing.profiles.energy.airthroughput.plugin.AirflowEstimationPlugin; 
    1010 
    11 public class AirThroughputProfile { 
     11public class AirflowProfile { 
    1212         
    13         protected List<AirFlowValue> airFlowHistory; 
     13        protected List<AirflowValue> airflowHistory; 
    1414         
    15         protected AirThroughputEstimationPlugin airThroughputEstimationPlugin; 
    16         protected List <AirThroughputState> airThroughputStates; 
     15        protected AirflowEstimationPlugin airflowEstimationPlugin; 
     16        protected List <AirflowState> airflowStates; 
    1717        protected Parameters parameters; 
    1818 
    19         public AirThroughputProfile(AirThroughputEstimationPlugin airThroughputEstimationPlugin, List<AirThroughputState> airThroughputStates) { 
     19        public AirflowProfile(AirflowEstimationPlugin airflowEstimationPlugin, List<AirflowState> airflowStates) { 
    2020                super(); 
    21                 this.airThroughputEstimationPlugin = airThroughputEstimationPlugin; 
    22                 this.airThroughputStates = airThroughputStates; 
    23                 this.airFlowHistory = new ArrayList<AirFlowValue>(); 
     21                this.airflowEstimationPlugin = airflowEstimationPlugin; 
     22                this.airflowStates = airflowStates; 
     23                this.airflowHistory = new ArrayList<AirflowValue>(); 
    2424        } 
    2525 
    26         public List<AirThroughputState> getAirThroughputStates() { 
    27                 return airThroughputStates; 
     26        public List<AirflowState> getAirflowStates() { 
     27                return airflowStates; 
    2828        } 
    2929         
    30         public void addToAirFlowHistory(double airFlow) { 
     30        public void addToAirFlowHistory(double airflow) { 
    3131 
    32                 if (airFlowHistory.size() == 0) { 
    33                         AirFlowValue usage = new AirFlowValue(DateTimeUtils.currentTimeMillis(), airFlow); 
    34                         airFlowHistory.add(usage); 
     32                if (airflowHistory.size() == 0) { 
     33                        AirflowValue usage = new AirflowValue(DateTimeUtils.currentTimeMillis(), airflow); 
     34                        airflowHistory.add(usage); 
    3535                        return; 
    3636                } 
    3737 
    38                 int lastIdx = airFlowHistory.size() - 1; 
    39                 double lastAirFlow = airFlowHistory.get(lastIdx).getValue(); 
    40                 if (lastAirFlow != airFlow) { 
    41                         AirFlowValue usage = airFlowHistory.get(lastIdx); 
     38                int lastIdx = airflowHistory.size() - 1; 
     39                double lastAirflow = airflowHistory.get(lastIdx).getValue(); 
     40                if (lastAirflow != airflow) { 
     41                        AirflowValue usage = airflowHistory.get(lastIdx); 
    4242                        long currentTime = DateTimeUtils.currentTimeMillis(); 
    4343                        if (usage.getTimestamp() == currentTime) { 
    44                                 usage.setValue(airFlow); 
    45                                 if(lastIdx > 0 && airFlowHistory.get(lastIdx - 1).getValue() == airFlow) 
    46                                         airFlowHistory.remove(usage); 
     44                                usage.setValue(airflow); 
     45                                if(lastIdx > 0 && airflowHistory.get(lastIdx - 1).getValue() == airflow) 
     46                                        airflowHistory.remove(usage); 
    4747                        } else { 
    48                                 usage = new AirFlowValue(DateTimeUtils.currentTimeMillis(), airFlow); 
    49                                 airFlowHistory.add(usage); 
     48                                usage = new AirflowValue(DateTimeUtils.currentTimeMillis(), airflow); 
     49                                airflowHistory.add(usage); 
    5050                        } 
    5151                } 
    5252        } 
    5353 
    54         public List<AirFlowValue> getAirThroughputHistory() { 
    55                 return airFlowHistory; 
     54        public List<AirflowValue> getAirflowHistory() { 
     55                return airflowHistory; 
    5656        } 
    5757         

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/AirflowState.java

    r477 r1396  
    33import schedframe.Parameters; 
    44 
    5 public class AirThroughputState { 
     5public class AirflowState { 
    66 
    7         protected String name; 
     7        protected AirflowStateName name; 
    88        protected double value; 
    99        protected double powerUsage; 
    1010         
    11         public AirThroughputState(String name, double value, double powerUsage) { 
     11        public AirflowState(AirflowStateName name, double value, double powerUsage) { 
    1212                super(); 
    1313                this.name = name; 
    … …  
    1616        } 
    1717         
    18         public String getName() { 
     18        public AirflowStateName getName() { 
    1919                return name; 
    2020        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/AirflowStateName.java

    r753 r1396  
    11package schedframe.resources.computing.profiles.energy.airthroughput; 
    22 
    3 public interface AirThroughputStateName { 
     3public interface AirflowStateName { 
    44 
    5         public String getName(); 
     5        public String getLabel(); 
    66 
    77} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/CustomAirflowStateName.java

    r753 r1396  
    22 
    33 
    4 public class UserAirThroughputStateName implements AirThroughputStateName{ 
     4public class CustomAirflowStateName implements AirflowStateName{ 
    55 
    66        protected String name; 
    77 
    8         public UserAirThroughputStateName(String name) { 
     8        public CustomAirflowStateName(String name) { 
    99                this.name = name; 
    1010        } 
    1111 
    12         public String getName() { 
     12        public String getLabel() { 
    1313                return name; 
    1414        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/StandardAirflowStateName.java

    r1207 r1396  
    11package schedframe.resources.computing.profiles.energy.airthroughput; 
    22 
    3 public enum  StandardAirThroughputStateName implements AirThroughputStateName{ 
     3public enum  StandardAirflowStateName implements AirflowStateName{ 
    44 
    55        ON, 
    66        OFF; 
    77 
    8         public String getName() { 
     8        public String getLabel() { 
    99                return toString(); 
    1010        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/plugin/AirflowEstimationPlugin.java

    r748 r1396  
    66import schedframe.scheduling.manager.tasks.JobRegistry; 
    77 
    8 public interface AirThroughputEstimationPlugin extends Plugin { 
     8public interface AirflowEstimationPlugin extends Plugin { 
    99         
    10         public double estimateAirThroughput(Event event, JobRegistry jobRegistry, ComputingResource resource); 
     10        public double estimateAirflow(Event event, JobRegistry jobRegistry, ComputingResource resource); 
    1111} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/plugin/DefaultAirflowEstimationPlugin.java

    r770 r1396  
    77import schedframe.scheduling.manager.tasks.JobRegistry; 
    88 
    9 public class DefaultAirThroughputEstimationPlugin implements AirThroughputEstimationPlugin { 
     9public class DefaultAirflowEstimationPlugin implements AirflowEstimationPlugin { 
    1010 
    1111        @Override 
    … …  
    2828 
    2929        @Override 
    30         public double estimateAirThroughput(Event event, JobRegistry jobRegistry, ComputingResource resource) { 
     30        public double estimateAirflow(Event event, JobRegistry jobRegistry, ComputingResource resource) { 
    3131                throw new RuntimeException("This interface is depracated. For air throughput estimation please use the estimateAirThroughput method form EnergyEstimationPlugin interface."); 
    3232        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/ui/AirflowInterface.java

    r1380 r1396  
    44 
    55import schedframe.Parameters; 
    6 import schedframe.resources.computing.profiles.energy.airthroughput.AirFlowValue; 
    7 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputState; 
    8 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputStateName; 
     6import schedframe.resources.computing.profiles.energy.airthroughput.AirflowValue; 
     7import schedframe.resources.computing.profiles.energy.airthroughput.AirflowState; 
     8import schedframe.resources.computing.profiles.energy.airthroughput.AirflowStateName; 
    99 
    10 public interface AirThroughputInterface { 
     10public interface AirflowInterface { 
    1111         
    12         public AirThroughputStateName getAirThroughputState(); 
     12        public AirflowStateName getAirflowState(); 
    1313         
    14         public boolean setAirThroughputState(AirThroughputStateName airThroughputState); 
     14        public boolean setAirflowState(AirflowStateName airflowState); 
    1515         
    16         public boolean supportAirThroughputState(AirThroughputStateName powerState); 
     16        public boolean supportAirflowState(AirflowStateName powerState); 
    1717         
    18         public List<AirThroughputState> getSupportedAirThroughputStates(); 
     18        public List<AirflowState> getSupportedAirflowStates(); 
    1919         
    20         public double getAirFlow(AirThroughputStateName state) throws NoSuchFieldException; 
     20        public double getAirflow(AirflowStateName state) throws NoSuchFieldException; 
    2121         
    22         public double getPowerConsumption(AirThroughputStateName state) throws NoSuchFieldException; 
     22        public double getPowerConsumption(AirflowStateName state) throws NoSuchFieldException; 
    2323         
    24         public AirFlowValue getRecentAirFlow(); 
     24        public AirflowValue getRecentAirflow(); 
    2525         
    26         List<AirFlowValue> getAirFlowHistory(); 
     26        List<AirflowValue> getAirflowHistory(); 
    2727         
    2828        public Parameters getParameters(); 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput/ui/ComputingResourceAirflowInterface.java

    r1380 r1396  
    1010import schedframe.resources.computing.profiles.energy.EnergyEvent; 
    1111import schedframe.resources.computing.profiles.energy.EnergyEventType; 
    12 import schedframe.resources.computing.profiles.energy.airthroughput.AirFlowValue; 
    13 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile; 
    14 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputState; 
    15 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputStateName; 
    16 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
     12import schedframe.resources.computing.profiles.energy.airthroughput.AirflowValue; 
     13import schedframe.resources.computing.profiles.energy.airthroughput.AirflowProfile; 
     14import schedframe.resources.computing.profiles.energy.airthroughput.AirflowState; 
     15import schedframe.resources.computing.profiles.energy.airthroughput.AirflowStateName; 
     16import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
    1717 
    18 public class ComputingResourceAirThroughputInterface implements AirThroughputInterface{ 
     18public class ComputingResourceAirflowInterface implements AirflowInterface{ 
    1919 
    20         protected AirThroughputStateName currentAirThroughputState; 
    21         protected AirThroughputProfile airThroughputProfile; 
     20        protected AirflowStateName currentAirflowState; 
     21        protected AirflowProfile airflowProfile; 
    2222        protected ComputingResource resource; 
    2323         
    24         public ComputingResourceAirThroughputInterface(ComputingResource resource, AirThroughputProfile airThroughputProfile){ 
     24        public ComputingResourceAirflowInterface(ComputingResource resource, AirflowProfile airflowProfile){ 
    2525                this.resource = resource; 
    26                 this.airThroughputProfile = airThroughputProfile; 
    27                 this.currentAirThroughputState = StandardAirThroughputStateName.ON; 
     26                this.airflowProfile = airflowProfile; 
     27                this.currentAirflowState = StandardAirflowStateName.ON; 
    2828        } 
    2929         
    30         public AirThroughputStateName getAirThroughputState() { 
    31                 return currentAirThroughputState; 
     30        public AirflowStateName getAirflowState() { 
     31                return currentAirflowState; 
    3232        } 
    3333 
    34         public boolean setAirThroughputState(AirThroughputStateName state) { 
    35                 if(supportAirThroughputState(state)){ 
    36                         currentAirThroughputState = state; 
     34        public boolean setAirflowState(AirflowStateName state) { 
     35                if(supportAirflowState(state)){ 
     36                        currentAirflowState = state; 
    3737                         
    3838                        //TO DO - notifications should be called for all resources starting form the lowest layer 
    … …  
    4444        } 
    4545 
    46         public boolean supportAirThroughputState(AirThroughputStateName state) { 
    47                 for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    48                         if(airFlowState.getName().equals(state.getName())){ 
     46        public boolean supportAirflowState(AirflowStateName state) { 
     47                for(AirflowState airflowState: airflowProfile.getAirflowStates()){ 
     48                        if(airflowState.getName().equals(state.getLabel())){ 
    4949                                return true; 
    5050                        } 
    … …  
    5353        } 
    5454 
    55         public List<AirThroughputState> getSupportedAirThroughputStates() { 
    56                 List<AirThroughputState> airThroughputStates = new ArrayList<AirThroughputState>(); 
    57                 for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    58                         airThroughputStates.add(airFlowState); 
     55        public List<AirflowState> getSupportedAirflowStates() { 
     56                List<AirflowState> airflowStates = new ArrayList<AirflowState>(); 
     57                for(AirflowState airflowState: airflowProfile.getAirflowStates()){ 
     58                        airflowStates.add(airflowState); 
    5959                } 
    60                 return airThroughputStates; 
     60                return airflowStates; 
    6161        } 
    6262 
    63         public double getAirFlow(AirThroughputStateName state) throws NoSuchFieldException { 
    64                 double airThroughput = 0; 
    65                 if(supportAirThroughputState(state)){ 
    66                         for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    67                                 if(airFlowState.getName().equals(state.getName())){ 
    68                                         airThroughput = airFlowState.getValue(); 
     63        public double getAirflow(AirflowStateName state) throws NoSuchFieldException { 
     64                double airflow = 0; 
     65                if(supportAirflowState(state)){ 
     66                        for(AirflowState airflowState: airflowProfile.getAirflowStates()){ 
     67                                if(airflowState.getName().equals(state.getLabel())){ 
     68                                        airflow = airflowState.getValue(); 
    6969                                        break; 
    7070                                } 
    7171                        } 
    7272                } 
    73                 return airThroughput; 
     73                return airflow; 
    7474        } 
    7575 
    76         public double getPowerConsumption(AirThroughputStateName state) throws NoSuchFieldException { 
     76        public double getPowerConsumption(AirflowStateName state) throws NoSuchFieldException { 
    7777                double powerConsumption = 0; 
    78                 if(supportAirThroughputState(state)){ 
    79                         for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    80                                 if(airFlowState.getName().equals(state.getName())){ 
    81                                         powerConsumption = airFlowState.getPowerUsage(); 
     78                if(supportAirflowState(state)){ 
     79                        for(AirflowState airflowState: airflowProfile.getAirflowStates()){ 
     80                                if(airflowState.getName().equals(state.getLabel())){ 
     81                                        powerConsumption = airflowState.getPowerUsage(); 
    8282                                        break; 
    8383                                } 
    … …  
    8787        } 
    8888         
    89         public AirFlowValue getRecentAirFlow() { 
    90                 AirFlowValue airFlow = null; 
    91                 int lastIdx = getAirFlowHistory().size() - 1; 
     89        public AirflowValue getRecentAirflow() { 
     90                AirflowValue airflow = null; 
     91                int lastIdx = getAirflowHistory().size() - 1; 
    9292                if(lastIdx >= 0) 
    93                         airFlow = getAirFlowHistory().get(lastIdx); 
     93                        airflow = getAirflowHistory().get(lastIdx); 
    9494                else {   
    9595                        try { 
    96                                 airFlow = new AirFlowValue(DateTimeUtils.currentTimeMillis(), getAirFlow(currentAirThroughputState)); 
     96                                airflow = new AirflowValue(DateTimeUtils.currentTimeMillis(), getAirflow(currentAirflowState)); 
    9797                        } catch (NoSuchFieldException e) { 
    9898                        } 
    9999                } 
    100                 return airFlow; 
     100                return airflow; 
    101101        } 
    102102         
    103         public List<AirFlowValue> getAirFlowHistory(){ 
    104                 return airThroughputProfile.getAirThroughputHistory(); 
     103        public List<AirflowValue> getAirflowHistory(){ 
     104                return airflowProfile.getAirflowHistory(); 
    105105        } 
    106106         
    107107         
    108108        public Parameters getParameters() { 
    109                 return airThroughputProfile.getParameters(); 
     109                return airflowProfile.getParameters(); 
    110110        } 
    111111 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/CustomPowerStateName.java

    r477 r1396  
    11package schedframe.resources.computing.profiles.energy.power; 
    22 
    3 public class UserPowerStateName implements PowerStateName { 
     3public class CustomPowerStateName implements PowerStateName { 
    44 
    55        protected String name; 
    66 
    7         public UserPowerStateName(String name) { 
     7        public CustomPowerStateName(String name) { 
    88                this.name = name; 
    99        } 
    1010 
    11         public String getName() { 
     11        public String getLabel() { 
    1212                return name; 
    1313        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/PowerStateName.java

    r477 r1396  
    33public interface PowerStateName { 
    44         
    5         public String getName(); 
     5        public String getLabel(); 
    66 
    77} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/PowerStateNameFactory.java

    r477 r1396  
    66        public static PowerStateName createPowerStateName (String powerStateName){ 
    77                 
    8                 if(powerStateName.equals(StandardPowerStateName.ON.getName())) 
     8                if(powerStateName.equals(StandardPowerStateName.ON.getLabel())) 
    99                        return StandardPowerStateName.ON; 
    1010                 
    11                 else if(powerStateName.equals(StandardPowerStateName.OFF.getName())) 
     11                else if(powerStateName.equals(StandardPowerStateName.OFF.getLabel())) 
    1212                        return StandardPowerStateName.OFF; 
    1313                 
    14                 else if(powerStateName.equals(StandardPowerStateName.HIBERNATE.getName())) 
     14                else if(powerStateName.equals(StandardPowerStateName.HIBERNATE.getLabel())) 
    1515                        return StandardPowerStateName.HIBERNATE; 
    1616                 
    17                 else if(powerStateName.equals(StandardPowerStateName.SLEEP.getName())) 
     17                else if(powerStateName.equals(StandardPowerStateName.SLEEP.getLabel())) 
    1818                        return StandardPowerStateName.SLEEP; 
    1919                 
    20                 else if(powerStateName.equals(StandardPowerStateName.SUSPEND.getName())) 
     20                else if(powerStateName.equals(StandardPowerStateName.SUSPEND.getLabel())) 
    2121                        return StandardPowerStateName.SUSPEND; 
    2222                 
    23                 else return new UserPowerStateName(powerStateName); 
     23                else return new CustomPowerStateName(powerStateName); 
    2424        } 
    2525} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/StandardPowerStateName.java

    r477 r1396  
    1010        HIBERNATE; 
    1111 
    12         public String getName() { 
     12        public String getLabel() { 
    1313                return toString(); 
    1414        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/plugin/EnergyEstimationPlugin.java

    r1207 r1396  
    1010        public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource); 
    1111 
    12         public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource); 
     12        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource); 
    1313 
    1414        public double estimateTemperature(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource); 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/ui/ComputingResourcePowerInterface.java

    r1374 r1396  
    7474        public boolean supportPowerState(PowerStateName state) { 
    7575                for(PowerState powerState: powerProfile.getSupportedPowerStates()){ 
    76                         if(powerState.getName().getName().equals(state.getName())){ 
     76                        if(powerState.getName().getLabel().equals(state.getLabel())){ 
    7777                                return true; 
    7878                        } 
    … …  
    8686                if(supportPowerState(state)){ 
    8787                        for(PowerState powerState: powerProfile.getSupportedPowerStates()){ 
    88                                 if(powerState.getName().getName().equals(state.getName())){ 
     88                                if(powerState.getName().getLabel().equals(state.getLabel())){ 
    8989                                        powerConsumption = powerState.getPowerUsage(); 
    9090                                        break; 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/devices/Device.java

    r1207 r1396  
    2525                this.extensionList = new ExtensionListImpl(1); 
    2626                initCharacteristics(devDesc); 
    27                 accept(new EnergyExtension.Builder().resource(this).powerProfile(devDesc.getPowerProfile()).airFlowProfile(devDesc.getAirThroughputProfile()).thermalProfile(devDesc.getThermalProfile()).build());      
     27                accept(new EnergyExtension.Builder().resource(this).powerProfile(devDesc.getPowerProfile()).airflowProfile(devDesc.getAirflowProfile()).thermalProfile(devDesc.getThermalProfile()).build());    
    2828        } 
    2929 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/devices/DeviceAirflowInterface.java

    r1380 r1396  
    99import schedframe.resources.computing.profiles.energy.EnergyEvent; 
    1010import schedframe.resources.computing.profiles.energy.EnergyEventType; 
    11 import schedframe.resources.computing.profiles.energy.airthroughput.AirFlowValue; 
    12 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile; 
    13 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputState; 
    14 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputStateName; 
    15 import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
    16 import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface; 
     11import schedframe.resources.computing.profiles.energy.airthroughput.AirflowValue; 
     12import schedframe.resources.computing.profiles.energy.airthroughput.AirflowProfile; 
     13import schedframe.resources.computing.profiles.energy.airthroughput.AirflowState; 
     14import schedframe.resources.computing.profiles.energy.airthroughput.AirflowStateName; 
     15import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirflowStateName; 
     16import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirflowInterface; 
    1717 
    18 public class DeviceAirThroughputInterface implements AirThroughputInterface{ 
     18public class DeviceAirflowInterface implements AirflowInterface{ 
    1919 
    20         protected AirThroughputStateName currentAirThroughputState; 
    21         protected AirThroughputProfile airThroughputProfile; 
     20        protected AirflowStateName currentAirflowState; 
     21        protected AirflowProfile airflowProfile; 
    2222        protected PhysicalResource resource; 
    2323         
    24         public DeviceAirThroughputInterface(PhysicalResource resource, AirThroughputProfile airThroughputProfile){ 
     24        public DeviceAirflowInterface(PhysicalResource resource, AirflowProfile airflowProfile){ 
    2525                this.resource = resource; 
    26                 this.airThroughputProfile = airThroughputProfile; 
    27                 this.currentAirThroughputState = StandardAirThroughputStateName.ON; 
     26                this.airflowProfile = airflowProfile; 
     27                this.currentAirflowState = StandardAirflowStateName.ON; 
    2828        } 
    2929         
    30         public AirThroughputStateName getAirThroughputState() { 
    31                 return currentAirThroughputState; 
     30        public AirflowStateName getAirflowState() { 
     31                return currentAirflowState; 
    3232        } 
    3333 
    34         public boolean setAirThroughputState(AirThroughputStateName state) { 
    35                 if(supportAirThroughputState(state)){ 
    36                         currentAirThroughputState = state; 
     34        public boolean setAirflowState(AirflowStateName state) { 
     35                if(supportAirflowState(state)){ 
     36                        currentAirflowState = state; 
    3737                         
    3838                        //TO DO - notifications should be called for all resources starting form the lowest layer 
    … …  
    4444        } 
    4545 
    46         public boolean supportAirThroughputState(AirThroughputStateName state) { 
    47                 for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    48                         if(airFlowState.getName().equals(state.getName())){ 
     46        public boolean supportAirflowState(AirflowStateName state) { 
     47                for(AirflowState airflowState: airflowProfile.getAirflowStates()){ 
     48                        if(airflowState.getName().getLabel().equals(state.getLabel())){ 
    4949                                return true; 
    5050                        } 
    … …  
    5353        } 
    5454 
    55         public List<AirThroughputState> getSupportedAirThroughputStates(){ 
    56                 List<AirThroughputState> airThroughputStates = new ArrayList<AirThroughputState>(); 
    57                 for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    58                         airThroughputStates.add(airFlowState); 
     55        public List<AirflowState> getSupportedAirflowStates(){ 
     56                List<AirflowState> airflowStates = new ArrayList<AirflowState>(); 
     57                for(AirflowState airFlowState: airflowProfile.getAirflowStates()){ 
     58                        airflowStates.add(airFlowState); 
    5959                } 
    60                 return airThroughputStates; 
     60                return airflowStates; 
    6161        } 
    6262 
    63         public double getAirFlow(AirThroughputStateName state) throws NoSuchFieldException { 
    64                 double airThroughput = 0; 
    65                 if(supportAirThroughputState(state)){ 
    66                         for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    67                                 if(airFlowState.getName().equals(state.getName())){ 
    68                                         airThroughput = airFlowState.getValue(); 
     63        public double getAirflow(AirflowStateName state) throws NoSuchFieldException { 
     64                double airflow = 0; 
     65                if(supportAirflowState(state)){ 
     66                        for(AirflowState airflowState: airflowProfile.getAirflowStates()){ 
     67                                if(airflowState.getName().getLabel().equals(state.getLabel())){ 
     68                                        airflow = airflowState.getValue(); 
    6969                                        break; 
    7070                                } 
    7171                        } 
    7272                } 
    73                 return airThroughput; 
     73                return airflow; 
    7474        } 
    7575 
    76         public double getPowerConsumption(AirThroughputStateName state) throws NoSuchFieldException { 
     76        public double getPowerConsumption(AirflowStateName state) throws NoSuchFieldException { 
    7777                double powerConsumption = 0; 
    78                 if(supportAirThroughputState(state)){ 
    79                         for(AirThroughputState airFlowState: airThroughputProfile.getAirThroughputStates()){ 
    80                                 if(airFlowState.getName().equals(state.getName())){ 
    81                                         powerConsumption = airFlowState.getPowerUsage(); 
     78                if(supportAirflowState(state)){ 
     79                        for(AirflowState airflowState: airflowProfile.getAirflowStates()){ 
     80                                if(airflowState.getName().getLabel().equals(state.getLabel())){ 
     81                                        powerConsumption = airflowState.getPowerUsage(); 
    8282                                        break; 
    8383                                } 
    … …  
    8787        } 
    8888         
    89         public AirFlowValue getRecentAirFlow() { 
    90                 AirFlowValue airFlow = null; 
    91                 int lastIdx = getAirFlowHistory().size() - 1; 
     89        public AirflowValue getRecentAirflow() { 
     90                AirflowValue airflow = null; 
     91                int lastIdx = getAirflowHistory().size() - 1; 
    9292                if(lastIdx >= 0) 
    93                         airFlow = getAirFlowHistory().get(lastIdx); 
     93                        airflow = getAirflowHistory().get(lastIdx); 
    9494                else {   
    9595                        try { 
    96                                 airFlow = new AirFlowValue(DateTimeUtils.currentTimeMillis(), getAirFlow(currentAirThroughputState)); 
     96                                airflow = new AirflowValue(DateTimeUtils.currentTimeMillis(), getAirflow(currentAirflowState)); 
    9797                        } catch (NoSuchFieldException e) { 
    9898                        } 
    9999                } 
    100                 return airFlow; 
     100                return airflow; 
    101101        } 
    102102         
    103         public List<AirFlowValue> getAirFlowHistory(){ 
    104                 return airThroughputProfile.getAirThroughputHistory(); 
     103        public List<AirflowValue> getAirflowHistory(){ 
     104                return airflowProfile.getAirflowHistory(); 
    105105        } 
    106106         
    107107        public Parameters getParameters() { 
    108                 return airThroughputProfile.getParameters(); 
     108                return airflowProfile.getParameters(); 
    109109        } 
    110110 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/devices/PhysicalResource.java

    r1287 r1396  
    1212import schedframe.resources.computing.extensions.ExtensionType; 
    1313import schedframe.resources.computing.profiles.energy.EnergyExtension; 
    14 import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface; 
     14import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirflowInterface; 
    1515import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface; 
    1616import schedframe.resources.computing.profiles.energy.thermal.ui.ThermalInterface; 
    … …  
    7070        } 
    7171         
    72         public AirThroughputInterface getAirThroughputInterface(){ 
     72        public AirflowInterface getAirflowInterface(){ 
    7373                Extension extension = getExtension(ExtensionType.ENERGY_EXTENSION); 
    7474                if(extension != null){ 
    7575                        EnergyExtension ee = (EnergyExtension)extension; 
    76                         return ee.getAirThroughputInterface(); 
     76                        return ee.getAirflowInterface(); 
    7777                } 
    7878                return null; 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/devices/coolemall/FanAirflowInterface.java

    r1317 r1396  
    11package schedframe.resources.devices.coolemall; 
    22 
    3 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile; 
    4 import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
     3import schedframe.resources.computing.profiles.energy.airthroughput.AirflowProfile; 
     4import schedframe.resources.computing.profiles.energy.airthroughput.CustomAirflowStateName; 
    55import schedframe.resources.devices.PhysicalResource; 
    6 import schedframe.resources.devices.DeviceAirThroughputInterface; 
     6import schedframe.resources.devices.DeviceAirflowInterface; 
    77 
    8 public class FanAirThroughputInterface extends DeviceAirThroughputInterface { 
     8public class FanAirflowInterface extends DeviceAirflowInterface { 
    99 
    10         public FanAirThroughputInterface(PhysicalResource resource, AirThroughputProfile airThroughputProfile) { 
    11                 super(resource, airThroughputProfile); 
    12                 this.currentAirThroughputState = new UserAirThroughputStateName("2"); 
     10        public FanAirflowInterface(PhysicalResource resource, AirflowProfile airflowProfile) { 
     11                super(resource, airflowProfile); 
     12                this.currentAirflowState = new CustomAirflowStateName("2"); 
    1313        } 
    1414         
    1515        public boolean turnOn(){ 
    16                 return setAirThroughputState(new UserAirThroughputStateName("2")); 
     16                return setAirflowState(new CustomAirflowStateName("2")); 
    1717        } 
    1818 
    1919        public boolean turnOff(){ 
    20                 return setAirThroughputState(new UserAirThroughputStateName("1")); 
     20                return setAirflowState(new CustomAirflowStateName("1")); 
    2121        } 
    2222} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/devices/description/PhysicalResourceDescription.java

    r1317 r1396  
    1010import schedframe.resources.computing.description.ResourceDescription; 
    1111import schedframe.resources.computing.location.Location; 
    12 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile; 
    13 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputState; 
    14 import schedframe.resources.computing.profiles.energy.airthroughput.plugin.AirThroughputEstimationPlugin; 
    15 import schedframe.resources.computing.profiles.energy.airthroughput.plugin.DefaultAirThroughputEstimationPlugin; 
     12import schedframe.resources.computing.profiles.energy.airthroughput.AirflowStateNameFactory; 
     13import schedframe.resources.computing.profiles.energy.airthroughput.AirflowProfile; 
     14import schedframe.resources.computing.profiles.energy.airthroughput.AirflowState; 
     15import schedframe.resources.computing.profiles.energy.airthroughput.plugin.AirflowEstimationPlugin; 
     16import schedframe.resources.computing.profiles.energy.airthroughput.plugin.DefaultAirflowEstimationPlugin; 
    1617import schedframe.resources.computing.profiles.energy.power.PState; 
    1718import schedframe.resources.computing.profiles.energy.power.PowerProfile; 
    … …  
    3637 
    3738        protected PowerProfile powerProfile; 
    38         protected AirThroughputProfile airThroughputProfile; 
     39        protected AirflowProfile airflowProfile; 
    3940        protected ThermalProfile thermalProfile; 
    4041        protected LoadProfile loadProfile; 
    … …  
    5859                if (profile != null) { 
    5960                        initPowerProfile(profile.getPowerProfile()); 
    60                         initAirThroughputProfile(profile.getAirThroughputProfile()); 
     61                        initAirflowProfile(profile.getAirThroughputProfile()); 
    6162                        initThermalProfile(profile.getThermalProfile()); 
    6263                        initLoadProfile(profile.getLoadProfile()); 
    … …  
    151152        } 
    152153 
    153         protected void initAirThroughputProfile(schemas.AirThroughputProfile airThroughputProfile) { 
    154                 if (airThroughputProfile != null) { 
    155                          
    156                         AirThroughputEstimationPlugin airThroughputEstimationPlugin = null; 
    157                         List<AirThroughputState> airThroughputStates = null; 
    158                         if(airThroughputProfile.getAirThroughputEstimationPlugin() != null){ 
    159                                 String airThroughputEstimationPluginName = airThroughputProfile.getAirThroughputEstimationPlugin().getName(); 
    160                                 if(airThroughputEstimationPluginName != null) { 
    161                                         airThroughputEstimationPlugin = (AirThroughputEstimationPlugin) InstanceFactory.createInstance( 
    162                                                         airThroughputEstimationPluginName, AirThroughputEstimationPlugin.class);                         
     154        protected void initAirflowProfile(schemas.AirThroughputProfile airflowProfile) { 
     155                if (airflowProfile != null) { 
     156                         
     157                        AirflowEstimationPlugin airflowEstimationPlugin = null; 
     158                        List<AirflowState> airflowStates = null; 
     159                        if(airflowProfile.getAirThroughputEstimationPlugin() != null){ 
     160                                String airflowEstimationPluginName = airflowProfile.getAirThroughputEstimationPlugin().getName(); 
     161                                if(airflowEstimationPluginName != null) { 
     162                                        airflowEstimationPlugin = (AirflowEstimationPlugin) InstanceFactory.createInstance( 
     163                                                        airflowEstimationPluginName, AirflowEstimationPlugin.class);                     
    163164                                } else { 
    164                                         airThroughputEstimationPlugin = new DefaultAirThroughputEstimationPlugin(); 
    165                                 } 
    166                                 Parameters params = extractParameters(airThroughputProfile.getAirThroughputEstimationPlugin().getParameter()); 
    167                                 airThroughputEstimationPlugin.init(params); 
    168                         } 
    169                         if(airThroughputProfile.getAirThroughputStates() != null){ 
    170                                 airThroughputStates = new ArrayList<AirThroughputState>(); 
    171                                 int airThrouhputStateCount = airThroughputProfile.getAirThroughputStates().getAirThroughputStateCount(); 
    172                                 for (int i = 0; i < airThrouhputStateCount; i++) { 
    173                                         schemas.AirThroughputState ats = airThroughputProfile.getAirThroughputStates().getAirThroughputState(i); 
    174                                         AirThroughputState airThroughputState = new AirThroughputState(ats.getName(), ats.getValue() 
     165                                        airflowEstimationPlugin = new DefaultAirflowEstimationPlugin(); 
     166                                } 
     167                                Parameters params = extractParameters(airflowProfile.getAirThroughputEstimationPlugin().getParameter()); 
     168                                airflowEstimationPlugin.init(params); 
     169                        } 
     170                        if(airflowProfile.getAirThroughputStates() != null){ 
     171                                airflowStates = new ArrayList<AirflowState>(); 
     172                                int airflowStateCount = airflowProfile.getAirThroughputStates().getAirThroughputStateCount(); 
     173                                for (int i = 0; i < airflowStateCount; i++) { 
     174                                        schemas.AirThroughputState ats = airflowProfile.getAirThroughputStates().getAirThroughputState(i); 
     175                                        AirflowState airflowState = new AirflowState(AirflowStateNameFactory.createAirflowStateName(ats.getName()), ats.getValue() 
    175176                                                        .getContent(), ats.getPowerUsage().getContent()); 
    176177                                        Parameters params = extractParameters(ats.getParameter()); 
    177                                         airThroughputState.init(params); 
    178                                         airThroughputStates.add(airThroughputState); 
    179                                 } 
    180                         } 
    181                         this.airThroughputProfile = new AirThroughputProfile(airThroughputEstimationPlugin, airThroughputStates); 
    182                         Parameters params = extractParameters(airThroughputProfile.getParameter()); 
    183                         this.airThroughputProfile.init(params); 
     178                                        airflowState.init(params); 
     179                                        airflowStates.add(airflowState); 
     180                                } 
     181                        } 
     182                        this.airflowProfile = new AirflowProfile(airflowEstimationPlugin, airflowStates); 
     183                        Parameters params = extractParameters(airflowProfile.getParameter()); 
     184                        this.airflowProfile.init(params); 
    184185                } 
    185186        } 
    … …  
    281282        } 
    282283 
    283         public AirThroughputProfile getAirThroughputProfile() { 
    284                 return airThroughputProfile; 
     284        public AirflowProfile getAirflowProfile() { 
     285                return airflowProfile; 
    285286        } 
    286287 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/units/CustomResourceUnitName.java

    r477 r1396  
    11package schedframe.resources.units; 
    22 
    3 public class UserResourceUnitName implements ResourceUnitName { 
     3public class CustomResourceUnitName implements ResourceUnitName { 
    44 
    55        protected String name; 
    66 
    7         public UserResourceUnitName(String name) { 
     7        public CustomResourceUnitName(String name) { 
    88                this.name = name; 
    99        } 
    1010 
    11         public String getName() { 
     11        public String getLabel() { 
    1212                return name; 
    1313        } 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/units/ResourceUnitFactory.java

    r1384 r1396  
    1818         
    1919        public static ResourceUnit createUnit(String unitName, String resId, int totalAmount, int usedAmount){ 
    20                 if(unitName.equalsIgnoreCase(StandardResourceUnitName.CPU.getName())) 
     20                if(unitName.equalsIgnoreCase(StandardResourceUnitName.CPU.getLabel())) 
    2121                        return new PEUnit(resId, totalAmount, usedAmount); 
    22                 if(unitName.equalsIgnoreCase(StandardResourceUnitName.PE.getName())) 
     22                if(unitName.equalsIgnoreCase(StandardResourceUnitName.PE.getLabel())) 
    2323                        return new PEUnit(resId, totalAmount, usedAmount); 
    24                 else if(unitName.equalsIgnoreCase(StandardResourceUnitName.MEMORY.getName())) 
     24                else if(unitName.equalsIgnoreCase(StandardResourceUnitName.MEMORY.getLabel())) 
    2525                         return new Memory(resId, totalAmount, usedAmount); 
    26                 else if(unitName.equalsIgnoreCase(StandardResourceUnitName.STORAGE.getName())) 
     26                else if(unitName.equalsIgnoreCase(StandardResourceUnitName.STORAGE.getLabel())) 
    2727                         return new Storage(resId, totalAmount, usedAmount); 
    28                 else if(unitName.equalsIgnoreCase(StandardResourceUnitName.GPU.getName())) 
     28                else if(unitName.equalsIgnoreCase(StandardResourceUnitName.GPU.getLabel())) 
    2929                         return new GPU(resId, totalAmount, usedAmount); 
    30                 else if (unitName.equalsIgnoreCase(StandardResourceUnitName.CPUSPEED.getName())) 
     30                else if (unitName.equalsIgnoreCase(StandardResourceUnitName.CPUSPEED.getLabel())) 
    3131                        return new CpuSpeed(resId, totalAmount, usedAmount);  
    32                 else if (unitName.equalsIgnoreCase(StandardResourceUnitName.COST.getName())) 
     32                else if (unitName.equalsIgnoreCase(StandardResourceUnitName.COST.getLabel())) 
    3333                        return new Cost(resId, totalAmount); 
    34                 else if (unitName.equalsIgnoreCase(StandardResourceUnitName.APPLICATION.getName())) 
     34                else if (unitName.equalsIgnoreCase(StandardResourceUnitName.APPLICATION.getLabel())) 
    3535                        return new Applications(resId);  
    3636                else 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/units/ResourceUnitName.java

    r477 r1396  
    33public interface ResourceUnitName { 
    44         
    5         public String getName(); 
     5        public String getLabel(); 
    66 
    77} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/units/ResourceUnitNameFactory.java

    r477 r1396  
    66        public static ResourceUnitName createResourceUnitName(String unitName){ 
    77 
    8                 if(unitName.equals(StandardResourceUnitName.MEMORY.getName())) 
     8                if(unitName.equals(StandardResourceUnitName.MEMORY.getLabel())) 
    99                        return StandardResourceUnitName.MEMORY; 
    1010                 
    11                 else if (unitName.equals(StandardResourceUnitName.STORAGE.getName())) 
     11                else if (unitName.equals(StandardResourceUnitName.STORAGE.getLabel())) 
    1212                        return StandardResourceUnitName.STORAGE; 
    1313                 
    14                 else if (unitName.equals(StandardResourceUnitName.PE.getName())) 
     14                else if (unitName.equals(StandardResourceUnitName.PE.getLabel())) 
    1515                        return StandardResourceUnitName.PE; 
    1616                 
    17                 else if (unitName.equals(StandardResourceUnitName.CPUSPEED.getName())) 
     17                else if (unitName.equals(StandardResourceUnitName.CPUSPEED.getLabel())) 
    1818                        return StandardResourceUnitName.CPUSPEED; 
    1919                 
    20                 else if (unitName.equals(StandardResourceUnitName.GPU.getName())) 
     20                else if (unitName.equals(StandardResourceUnitName.GPU.getLabel())) 
    2121                        return StandardResourceUnitName.GPU; 
    2222                 
    23                 else if (unitName.equals(StandardResourceUnitName.APPLICATION.getName())) 
     23                else if (unitName.equals(StandardResourceUnitName.APPLICATION.getLabel())) 
    2424                        return StandardResourceUnitName.APPLICATION; 
    2525                 
    26                 else if (unitName.equals(StandardResourceUnitName.COST.getName())) 
     26                else if (unitName.equals(StandardResourceUnitName.COST.getLabel())) 
    2727                        return StandardResourceUnitName.COST; 
    2828 
    29                 else return new UserResourceUnitName(unitName); 
     29                else return new CustomResourceUnitName(unitName); 
    3030        } 
    3131} 

  • DCWoRMS/branches/coolemall/src/schedframe/resources/units/StandardResourceUnitName.java

    r477 r1396  
    4646    } 
    4747 
    48     public String getName(){ 
     48    public String getLabel(){ 
    4949        return this.name; 
    5050    } 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/GridResourceDiscovery.java

    r493 r1396  
    2020import schedframe.resources.units.ResourceUnitName; 
    2121import schedframe.scheduling.manager.resources.ResourceManager; 
    22 import schedframe.scheduling.plugin.grid.ModuleType; 
     22import schedframe.scheduling.plugin.ModuleType; 
    2323import schedframe.scheduling.plugin.grid.ResourceDiscovery; 
    2424import schedframe.scheduling.tasks.requirements.AbstractResourceRequirements; 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/ResourceItem.java

    r1362 r1396  
    22 
    33import java.util.HashSet; 
     4import java.util.LinkedList; 
     5import java.util.List; 
    46import java.util.Map; 
    57import java.util.Set; 
    68 
     9import schedframe.resources.computing.ComputingResource; 
     10import schedframe.resources.units.ProcessingElements; 
    711import schedframe.resources.units.ResourceUnit; 
    812import schedframe.resources.units.ResourceUnitName; 
     13import schedframe.resources.units.StandardResourceUnitName; 
    914 
    10 public class ResourceHistoryItem { 
     15public class ResourceItem { 
    1116 
    1217        protected Map<ResourceUnitName, ResourceUnit> usedResources; 
    1318        protected Set<String> visitedResources; 
    1419 
    15         public ResourceHistoryItem(Map<ResourceUnitName, ResourceUnit> usedResources){ 
     20        public ResourceItem(Map<ResourceUnitName, ResourceUnit> usedResources){ 
    1621                this.usedResources = usedResources; 
    1722                this.visitedResources = new HashSet<String>(); 
     23                saveResourceNames(); 
    1824        } 
    1925         
    … …  
    2228        } 
    2329         
    24         public void trackResource(String resName){ 
    25                 visitedResources.add(resName); 
    26         } 
    27          
    28         public Set<String> getVisitedResources(){ 
     30        public Set<String> getResourceNames(){ 
    2931                return visitedResources; 
    3032        } 
    3133         
     34        private void saveResourceNames(){ 
     35                ProcessingElements pes = (ProcessingElements) usedResources.get(StandardResourceUnitName.PE); 
     36                for (ComputingResource resource : pes) { 
     37 
     38                        LinkedList<ComputingResource> toExamine = new LinkedList<ComputingResource>(); 
     39                        toExamine.push(resource); 
     40 
     41                        while (!toExamine.isEmpty()) { 
     42                                ComputingResource compResource = toExamine.pop(); 
     43                                List<ComputingResource> resources = compResource.getChildren(); 
     44                                if(resources.isEmpty()){ 
     45                                        if(!visitedResources.contains(compResource.getFullName())){ 
     46                                                visitedResources.add(compResource.getFullName()); 
     47                                        } 
     48                                } else { 
     49                                        for (int i = 0; i < resources.size(); i++) { 
     50                                                ComputingResource resourceChild = resources.get(i); 
     51                                                toExamine.addLast(resourceChild); 
     52                                        } 
     53                                } 
     54                        } 
     55                } 
     56        } 
    3257} 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/resources/LocalResourceManager.java

    r1392 r1396  
    306306                        for(ResourceUnitName resUnitName: resources.keySet()){ 
    307307                                ResourceUnit resUnit = resources.get(resUnitName); 
    308                                 if(resUnit.getName().getName().equals(StandardResourceUnitName.PE.getName())){ 
     308                                if(resUnit.getName().getLabel().equals(StandardResourceUnitName.PE.getLabel())){ 
    309309                                        ProcessingElements pe = (ProcessingElements)resUnit; 
    310310                                        for(ComputingResource cr: pe){ 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/tasks/JobRegistryImpl.java

    r1362 r1396  
    5353                        for (ExecTask task: executables) { 
    5454                                if (task.getStatus() == status) { 
    55                                         Set<String> visitedResource = task.getAllocatedResources().getLast().getVisitedResources(); 
     55                                        Set<String> visitedResource = task.getAllocatedResources().getLast().getResourceNames(); 
    5656                                        for(String res: visitedResource){ 
    5757                                                if(res.contains(context)){ 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/plugin/Module.java

    r477 r1396  
    1 package schedframe.scheduling.plugin.grid; 
     1package schedframe.scheduling.plugin; 
    22 
    33import java.util.Properties; 
    4  
    5 import eduni.simjava.Sim_event; 
    64 
    75import schedframe.exceptions.ModuleException; 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/plugin/ModuleList.java

    r477 r1396  
    1 package schedframe.scheduling.plugin.grid; 
     1package schedframe.scheduling.plugin; 
    22 
    33import java.util.List; 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/plugin/ModuleListImpl.java

    r477 r1396  
    1 package schedframe.scheduling.plugin.grid; 
     1package schedframe.scheduling.plugin; 
    22 
    33import java.util.ArrayList; 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/plugin/ModuleType.java

    r777 r1396  
    1 package schedframe.scheduling.plugin.grid; 
     1package schedframe.scheduling.plugin; 
    22 
    3 import schedframe.StaticResourceLoadCalendar; 
     3 
     4import schedframe.scheduling.plugin.grid.ResourceDiscovery; 
    45import test.EventManager; 
    56 
    … …  
    1314 
    1415        RESOURCE_DISCOVERY("Resource_discovery", ResourceDiscovery.class), 
    15         RESOURCE_CALENDAR("Resource calendar", StaticResourceLoadCalendar.class), 
    1616        EVENT_MANAGER("Event manager", EventManager.class); 
    1717        //DATA_MANAGER("Data Manager", DataManager.class), 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/plugin/SchedulingPlugin.java

    r516 r1396  
    77import schedframe.scheduling.manager.tasks.JobRegistry; 
    88import schedframe.scheduling.plan.SchedulingPlanInterface; 
    9 import schedframe.scheduling.plugin.grid.ModuleList; 
    109import schedframe.scheduling.queue.TaskQueueList; 
    1110 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/plugin/grid/ResourceDiscovery.java

    r477 r1396  
    66import schedframe.scheduling.SchedulerDescription; 
    77import schedframe.scheduling.SecurityContext; 
     8import schedframe.scheduling.plugin.Module; 
    89import schedframe.scheduling.tasks.requirements.AbstractResourceRequirements; 
    910 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/plugin/local/LocalSchedulingPlugin.java

    r515 r1396  
    55import schedframe.scheduling.manager.resources.ResourceManager; 
    66import schedframe.scheduling.manager.tasks.JobRegistry; 
     7import schedframe.scheduling.plugin.ModuleList; 
    78import schedframe.scheduling.plugin.SchedulingPlugin; 
    8 import schedframe.scheduling.plugin.grid.ModuleList; 
    99import schedframe.scheduling.queue.TaskQueueList; 
    1010 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/AbstractManagementSystem.java

    r1377 r1396  
    2323import schedframe.scheduling.plan.AllocationInterface; 
    2424import schedframe.scheduling.plan.SchedulingPlanInterface; 
     25import schedframe.scheduling.plugin.ModuleList; 
    2526import schedframe.scheduling.plugin.SchedulingPlugin; 
    2627import schedframe.scheduling.plugin.estimation.ExecutionTimeEstimationPlugin; 
    27 import schedframe.scheduling.plugin.grid.ModuleList; 
    2828import schedframe.scheduling.manager.resources.ResourceAllocation; 
    2929import schedframe.scheduling.queue.TaskQueue; 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/global/GridBroker.java

    r1385 r1396  
    1212import schedframe.scheduling.Scheduler; 
    1313import schedframe.scheduling.manager.resources.ManagedResources; 
     14import schedframe.scheduling.plugin.ModuleListImpl; 
    1415import schedframe.scheduling.plugin.SchedulingPlugin; 
    1516import schedframe.scheduling.plugin.estimation.ExecutionTimeEstimationPlugin; 
    16 import schedframe.scheduling.plugin.grid.ModuleListImpl; 
    1717import schedframe.scheduling.queue.TaskQueueList; 
    1818 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

    r1392 r1396  
    44import java.util.HashMap; 
    55import java.util.Iterator; 
    6 import java.util.LinkedList; 
    76import java.util.List; 
    87import java.util.Map; 
    9 import java.util.Set; 
    108 
    119import org.apache.commons.logging.Log; 
    … …  
    3331import schedframe.resources.units.StandardResourceUnitName; 
    3432import schedframe.scheduling.ExecutionHistoryItem; 
    35 import schedframe.scheduling.ResourceHistoryItem; 
     33import schedframe.scheduling.ResourceItem; 
    3634import schedframe.scheduling.Scheduler; 
    3735import schedframe.scheduling.TaskList; 
    … …  
    4442import schedframe.scheduling.plan.ScheduledTaskInterface; 
    4543import schedframe.scheduling.plan.SchedulingPlanInterface; 
     44import schedframe.scheduling.plugin.ModuleListImpl; 
    4645import schedframe.scheduling.plugin.SchedulingPlugin; 
    4746import schedframe.scheduling.plugin.estimation.ExecutionTimeEstimationPlugin; 
    48 import schedframe.scheduling.plugin.grid.ModuleListImpl; 
    4947import schedframe.scheduling.policy.AbstractManagementSystem; 
    5048import schedframe.scheduling.queue.TaskQueueList; 
    … …  
    5654import schedframe.scheduling.tasks.WorkloadUnit; 
    5755import simulator.DCWormsConstants; 
    58 import simulator.stats.GSSAccumulator; 
     56import simulator.stats.DCwormsAccumulator; 
    5957import simulator.utils.DoubleMath; 
    6058import dcworms.schedframe.scheduling.ExecTask; 
    … …  
    382380 
    383381                saveExecutionHistory(exec, exec.getCompletionPercentage(), phaseDuration); 
    384                 if(exec.getResourceConsumptionProfile().isLast()){ 
     382                if(exec.getExecutionProfile().isLast()){ 
    385383                        scheduler.sendInternal(phaseDuration, DCWormsTags.TASK_EXECUTION_FINISHED, execTask);; 
    386384                } else { 
    … …  
    451449                        ExecTask task = iter.next(); 
    452450                        Executable exec = (Executable)task; 
    453                         ExecutionHistoryItem execHistItem = exec.getExecHistory().getLast(); 
     451                        ExecutionHistoryItem execHistItem = exec.getExecutionHistory().getLast(); 
    454452                        //System.out.println("--- upadteProgressX: " + Sim_system.sim_clock() ); 
    455453                        //System.out.println("taskId: " + exec.getId() + "; completion percentage: " + exec.getCompletionPercentage() + "; timespan: " + timeSpan + "; estimatedDuration: " +  execHistItem.getCompletionPercentage()); 
    … …  
    496494                                        execTask, choosenResources, exec.getCompletionPercentage())).intValue(); 
    497495 
    498                         ExecutionHistoryItem execHistItem = exec.getExecHistory().getLast(); 
     496                        ExecutionHistoryItem execHistItem = exec.getExecutionHistory().getLast(); 
    499497                        double lastTimeStamp = execHistItem.getTimeStamp().getMillis()/1000; 
    500498                        if(DoubleMath.subtract((lastTimeStamp + execHistItem.getEstimatedDuration()), (new DateTime().getMillis()/1000 + phaseDuration)) == 0.0){ 
    … …  
    508506                        saveExecutionHistory(exec, exec.getCompletionPercentage(), phaseDuration); 
    509507                         
    510                         if(exec.getResourceConsumptionProfile().isLast()){ 
     508                        if(exec.getExecutionProfile().isLast()){ 
    511509                                ExecTaskFilter filter = new ExecTaskFilter(exec.getUniqueId(), DCWormsTags.TASK_EXECUTION_FINISHED); 
    512510                                scheduler.sim_cancel(filter, null); 
    … …  
    542540                        saveExecutionHistory(exec, exec.getCompletionPercentage(), phaseDuration); 
    543541                         
    544                         if(exec.getResourceConsumptionProfile().isLast()){ 
     542                        if(exec.getExecutionProfile().isLast()){ 
    545543                                scheduler.sendInternal(phaseDuration, DCWormsTags.TASK_EXECUTION_FINISHED, execTask); 
    546544                        } else { 
    … …  
    555553        public double calculateTotalLoad() { 
    556554 
    557                 GSSAccumulator loadAcc = new GSSAccumulator(); 
     555                DCwormsAccumulator loadAcc = new DCwormsAccumulator(); 
    558556                try { 
    559557                        for(ComputingResource compRes: getResourceManager().getResourcesOfType(StandardResourceType.Node)){ 
    … …  
    718716                boolean allocationStatus = getAllocationManager().allocateResources(choosenResources, exclusive); 
    719717                if(allocationStatus){ 
    720                         ResourceHistoryItem resourceHistoryItem = new ResourceHistoryItem(choosenResources); 
     718                        ResourceItem resourceHistoryItem = new ResourceItem(choosenResources); 
    721719                        exec.addAllocatedResources(resourceHistoryItem); 
    722                         saveResourceHistory(exec); 
    723720                        return true; 
    724721                } 
    … …  
    726723        } 
    727724         
    728         private void saveResourceHistory(Executable exec){ 
    729                 ProcessingElements pes = (ProcessingElements) exec.getAllocatedResources().getLast().getResourceUnits().get(StandardResourceUnitName.PE); 
    730                 for (ComputingResource resource : pes) { 
    731  
    732                         LinkedList<ComputingResource> toExamine = new LinkedList<ComputingResource>(); 
    733                         toExamine.push(resource); 
    734  
    735                         while (!toExamine.isEmpty()) { 
    736                                 ComputingResource compResource = toExamine.pop(); 
    737                                 List<ComputingResource> resources = compResource.getChildren(); 
    738                                 if(resources.isEmpty()){ 
    739                                         Set<String> visitedResources = exec.getAllocatedResources().getLast().getVisitedResources(); 
    740                                         if(!visitedResources.contains(compResource.getFullName())){ 
    741                                                 exec.getAllocatedResources().getLast().trackResource(compResource.getFullName()); 
    742                                         } 
    743                                 } else { 
    744                                         for (int i = 0; i < resources.size(); i++) { 
    745                                                 ComputingResource resourceChild = resources.get(i); 
    746                                                 toExamine.addLast(resourceChild); 
    747                                         } 
    748                                 } 
    749                         } 
    750                 } 
    751         } 
     725 
    752726         
    753727} 

  • DCWoRMS/branches/coolemall/src/schedframe/scheduling/tasks/Job.java

    r1374 r1396  
    11package schedframe.scheduling.tasks; 
    2  
    3  
    4 import org.qcg.broker.schemas.resreqs.ParentType; 
    5 import org.qcg.broker.schemas.resreqs.ResourceRequirements; 
    6 import org.qcg.broker.schemas.resreqs.Workflow; 
    7 import org.qcg.broker.schemas.resreqs.types.TaskStatesName; 
    82 
    93 
    … …  
    159 
    1610import org.joda.time.DateTime; 
     11import org.qcg.broker.schemas.resreqs.ResourceRequirements; 
    1712 
    1813import qcg.shared.constants.BrokerConstants; 
    19  
    2014import schedframe.scheduling.WorkloadUnitHandler; 
    2115import schedframe.scheduling.manager.tasks.JobRegistryImpl; 
    … …  
    210204        } 
    211205         
    212         private List<Task> getReadyTasks() throws NoSuchFieldException{ 
    213                  
    214                 List<Task> availableTasks = new ArrayList<Task>(); 
    215                 int size = tasks.size(); 
    216                  
    217                 for(int i = 0; i < size; i++){ 
    218                         int parCnt; 
    219                         int previousTaskSucceedCnt = 0; 
    220                         Task task = tasks.get(i); 
    221                         if(task.getStatus() != (int)BrokerConstants.TASK_STATUS_UNSUBMITTED) 
    222                                 continue; 
    223                         //the following procedure supports only one nested structure 
    224                         Workflow w = task.getDescription().getWorkflow(); 
    225                         if (w == null){ 
    226                                 availableTasks.add(task); 
    227                                 continue; 
    228                         } 
    229                         if(w.getAnd() != null) { 
    230                                 parCnt = w.getAnd().getParentOpTypeItemCount(); 
    231                                 if(parCnt == 0){ 
    232                                         availableTasks.add(task); 
    233                                 }else 
    234                                 { 
    235                                         for(int j = 0; j < parCnt; j++){ 
    236                                                 ParentType par = w.getAnd().getParentOpTypeItem(j).getParent(); 
    237                                                 if(par.getTriggerState().compareTo(TaskStatesName.FINISHED) == 0){ 
    238                                                         if(!getTask(par.getContent()).isFinished()){ 
    239                                                                 break; 
    240                                                         } 
    241                                                 } 
    242                                                 previousTaskSucceedCnt++; 
    243                                         } 
    244  
    245                                         if(previousTaskSucceedCnt == parCnt) 
    246                                                 availableTasks.add(task); 
    247                                 } 
    248                         }  
    249                         else if(w.getOr() != null) { 
    250                                 parCnt = w.getOr().getParentOpTypeItemCount(); 
    251                                 if(parCnt == 0){ 
    252                                         availableTasks.add(task); 
    253                                 } 
    254                                 else{ 
    255                                         for(int j = 0; j < parCnt; j++){ 
    256                                                 ParentType par = w.getOr().getParentOpTypeItem(j).getParent(); 
    257                                                 if(par.getTriggerState().compareTo(TaskStatesName.FINISHED) == 0){ 
    258                                                         if(!getTask(par.getContent()).isFinished()){ 
    259                                                                 continue; 
    260                                                         } 
    261                                                 } 
    262                                                 previousTaskSucceedCnt++; 
    263                                         } 
    264  
    265                                         if(previousTaskSucceedCnt > 0) 
    266                                                 availableTasks.add(task); 
    267                                 } 
    268                         } 
    269                         else { 
    270                                 parCnt = w.getParentCount(); 
    271                                 if(parCnt == 0){ 
    272                                         availableTasks.add(task); 
    273                                 }else{ 
    274                                         for(int j = 0; j < parCnt; j++){ 
    275                                                 ParentType par = w.getParent(j); 
    276                                                 if(par.getTriggerState().compareTo(TaskStatesName.FINISHED) == 0){ 
    277                                                         if(!getTask(par.getContent()).isFinished()){ 
    278                                                                 continue; 
    279                                                         } 
    280                                                 } 
    281                                                 previousTaskSucceedCnt++; 
    282                                         } 
    283  
    284                                         if(previousTaskSucceedCnt == parCnt) 
    285                                                 availableTasks.add(task); 
    286                                 } 
    287                         } 
    288                 }                
    289                 return availableTasks; 
    290         } 
    291          
    292206} 

  • DCWoRMS/branches/coolemall/src/simulator/ConfigurationOptions.java

    r1299 r1396  
    187187         
    188188        public String [] resForEnergyChart; 
    189         public String [] resForAirFlowChart; 
     189        public String [] resForAirflowChart; 
    190190        public String [] resForTemperatureChart; 
    191191        public String [] resForUtilizationChart; 
    … …  
    195195        public double inletRoomAirTempeature; 
    196196        public double ambientAirTempeature; 
    197         public double airFlowVolume; 
     197        public double airflowVolume; 
    198198        public double alpha; 
    199199         
    … …  
    334334                 
    335335                try { 
    336                         co.resForAirFlowChart = bundle.getString(CREATEDIAGRAMS_AIRFLOW).split(";"); 
    337                         if(co.resForAirFlowChart.length > 0){ 
     336                        co.resForAirflowChart = bundle.getString(CREATEDIAGRAMS_AIRFLOW).split(";"); 
     337                        if(co.resForAirflowChart.length > 0){ 
    338338                                co.creatediagrams_resairflow = true; 
    339339                        } 
    … …  
    416416                 
    417417                try { 
    418                         co.airFlowVolume = Double.valueOf(bundle.getString(AIR_FLOW_VOLUME)).doubleValue(); 
    419                 } catch(MissingResourceException e){ 
    420                         co.airFlowVolume = -1; 
     418                        co.airflowVolume = Double.valueOf(bundle.getString(AIR_FLOW_VOLUME)).doubleValue(); 
     419                } catch(MissingResourceException e){ 
     420                        co.airflowVolume = -1; 
    421421                } 
    422422                 
    … …  
    427427                } 
    428428                 
    429                 ConfigurationOptions.coolingData = new CoolingModelData(co.pressureDrop, co.outletRoomAirTempeature, co.inletRoomAirTempeature, co.ambientAirTempeature, co.airFlowVolume, co.alpha); 
     429                ConfigurationOptions.coolingData = new CoolingModelData(co.pressureDrop, co.outletRoomAirTempeature, co.inletRoomAirTempeature, co.ambientAirTempeature, co.airflowVolume, co.alpha); 
    430430                return co; 
    431431        } 

  • DCWoRMS/branches/coolemall/src/simulator/reader/ResourceReader.java

    r1374 r1396  
    2626import schedframe.Parameters; 
    2727import schedframe.SimulatedEnvironment; 
    28 import schedframe.exceptions.ResourceException; 
    2928import schedframe.resources.CoolEmAllResourceFactory; 
    3029import schedframe.resources.Resource; 

  • DCWoRMS/branches/coolemall/src/simulator/stats/AbstractMetricsCalculator.java

    r1299 r1396  
    1313        protected static final double SEC_IN_HOUR = 3600; 
    1414         
    15         protected Map<String, List<GSSAccumulator>> metricsData = new HashMap<String, List<GSSAccumulator>>(); 
     15        protected Map<String, List<DCwormsAccumulator>> metricsData = new HashMap<String, List<DCwormsAccumulator>>(); 
    1616 
    1717        protected long startTime; 
    … …  
    2828        abstract public List<MetricsStats> calulateMetrics(); 
    2929         
    30         public void addMetricsData(String resourceTypeName, GSSAccumulator resourceEnergyAccumulator){ 
    31                 List<GSSAccumulator> resourceEnergyAccumulatorList = metricsData.get(resourceTypeName); 
     30        public void addMetricsData(String resourceTypeName, DCwormsAccumulator resourceEnergyAccumulator){ 
     31                List<DCwormsAccumulator> resourceEnergyAccumulatorList = metricsData.get(resourceTypeName); 
    3232                if(resourceEnergyAccumulatorList == null){ 
    33                         resourceEnergyAccumulatorList = new ArrayList<GSSAccumulator>(); 
     33                        resourceEnergyAccumulatorList = new ArrayList<DCwormsAccumulator>(); 
    3434                } 
    3535                resourceEnergyAccumulatorList.add(resourceEnergyAccumulator); 
    … …  
    3737        } 
    3838         
    39         public Map<String, List<GSSAccumulator>> getMetricsData(){ 
     39        public Map<String, List<DCwormsAccumulator>> getMetricsData(){ 
    4040                return metricsData; 
    4141        } 

  • DCWoRMS/branches/coolemall/src/simulator/stats/AccumulatedStatistics.java

    r481 r1396  
    1010import java.util.List; 
    1111 
    12 import simulator.stats.implementation.DCWormsStatistics; 
    1312import gridsim.Accumulator; 
    1413 
    … …  
    5049                } 
    5150                 
    52                 GSSAccumulator resourceLoad = getAccumulatedResourceLoad(); 
    53                 GSSAccumulator reservationLoad = getAccumulatedReservationLoad(); 
    54                 GSSAccumulator makespan = getAccumulatedMakespan(); 
    55                 GSSAccumulator taskExecutionTime = getAccumulatedJobExecutionTime(); 
    56                 GSSAccumulator taskQueueLength = getAccumulatedQueueJobCount(); 
    57                 GSSAccumulator taskCompletionTime = getAccumulatedCompletionTime(); 
    58                 GSSAccumulator taskWaitingTime = getAccumulatedWaitingTime(); 
    59                 GSSAccumulator taskFlowTime = getAccumulatedJobFlowTime(); 
    60                 GSSAccumulator taskLateness = getAccumulatedLateness(); 
    61                 GSSAccumulator delayedTasks = getAccumulatedDelayedTasks(); 
    62                 GSSAccumulator taskTardiness = getAccumulatedTardiness(); 
    63                 GSSAccumulator failedRequests = getAccumulatedFailedRequests(); 
     51                DCwormsAccumulator resourceLoad = getAccumulatedResourceLoad(); 
     52                DCwormsAccumulator reservationLoad = getAccumulatedReservationLoad(); 
     53                DCwormsAccumulator makespan = getAccumulatedMakespan(); 
     54                DCwormsAccumulator taskExecutionTime = getAccumulatedJobExecutionTime(); 
     55                DCwormsAccumulator taskQueueLength = getAccumulatedQueueJobCount(); 
     56                DCwormsAccumulator taskCompletionTime = getAccumulatedCompletionTime(); 
     57                DCwormsAccumulator taskWaitingTime = getAccumulatedWaitingTime(); 
     58                DCwormsAccumulator taskFlowTime = getAccumulatedJobFlowTime(); 
     59                DCwormsAccumulator taskLateness = getAccumulatedLateness(); 
     60                DCwormsAccumulator delayedTasks = getAccumulatedDelayedTasks(); 
     61                DCwormsAccumulator taskTardiness = getAccumulatedTardiness(); 
     62                DCwormsAccumulator failedRequests = getAccumulatedFailedRequests(); 
    6463                 
    6564                out.print("Delayed tasks (accumulated)"); 
    … …  
    9190        } 
    9291 
    93         public GSSAccumulator getAccumulatedResourceLoad() { 
    94                 GSSAccumulator resourceMeanLoad = new GSSAccumulator();  
    95                 for (SimulationStatistics simStat : simulations) { 
    96                         GSSAccumulator simulationResTotalLoad = simStat.getStats(SimulationStatistics.RESOURCES_TOTAL_LOAD);  
     92        public DCwormsAccumulator getAccumulatedResourceLoad() { 
     93                DCwormsAccumulator resourceMeanLoad = new DCwormsAccumulator();  
     94                for (SimulationStatistics simStat : simulations) { 
     95                        DCwormsAccumulator simulationResTotalLoad = simStat.getStats(SimulationStatistics.RESOURCES_TOTAL_LOAD);  
    9796                        resourceMeanLoad.add(simulationResTotalLoad.getMean()); 
    9897                } 
    … …  
    10099        } 
    101100 
    102         public GSSAccumulator getAccumulatedReservationLoad(){ 
    103                 GSSAccumulator reservationMean = new GSSAccumulator(); 
     101        public DCwormsAccumulator getAccumulatedReservationLoad(){ 
     102                DCwormsAccumulator reservationMean = new DCwormsAccumulator(); 
    104103                for (SimulationStatistics simStat : simulations) { 
    105104                        Accumulator simulationResvTotalLoad = simStat.getStats(SimulationStatistics.RESOURCES_RESERVATION_LOAD); 
    … …  
    119118        }*/ 
    120119 
    121         public GSSAccumulator getAccumulatedJobFlowTime() { 
    122                 GSSAccumulator meanJobFlowTime = new GSSAccumulator(); 
     120        public DCwormsAccumulator getAccumulatedJobFlowTime() { 
     121                DCwormsAccumulator meanJobFlowTime = new DCwormsAccumulator(); 
    123122                for (SimulationStatistics simStat : simulations) { 
    124123                        Accumulator simulationJobFlowTime = simStat.getStats(SimulationStatistics.TASK_FLOW_TIME); 
    … …  
    128127        } 
    129128 
    130         public GSSAccumulator getAccumulatedLateness() { 
    131                 GSSAccumulator meanLateness = new GSSAccumulator(); 
     129        public DCwormsAccumulator getAccumulatedLateness() { 
     130                DCwormsAccumulator meanLateness = new DCwormsAccumulator(); 
    132131                for (SimulationStatistics simStat : simulations) { 
    133132                        Accumulator simulationLateness = simStat.getStats(SimulationStatistics.TASK_LATENESS); 
    … …  
    137136        } 
    138137 
    139         public GSSAccumulator getAccumulatedFailedRequests() { 
    140                 GSSAccumulator meanFailedRequests = new GSSAccumulator(); 
     138        public DCwormsAccumulator getAccumulatedFailedRequests() { 
     139                DCwormsAccumulator meanFailedRequests = new DCwormsAccumulator(); 
    141140                for (SimulationStatistics simStat : simulations) { 
    142141                        Accumulator simulationFailedRequestes = simStat.getStats(SimulationStatistics.FAILED_REQUESTS); 
    … …  
    146145        } 
    147146 
    148         public GSSAccumulator getAccumulatedTardiness() { 
    149                 GSSAccumulator meanTardiness = new GSSAccumulator(); 
     147        public DCwormsAccumulator getAccumulatedTardiness() { 
     148                DCwormsAccumulator meanTardiness = new DCwormsAccumulator(); 
    150149                for (SimulationStatistics simStat : simulations) { 
    151150                        Accumulator simulationJobTardiness = simStat.getStats(SimulationStatistics.TASK_TARDINESS); 
    … …  
    155154        } 
    156155 
    157         public GSSAccumulator getAccumulatedDelayedTasks() { 
    158                 GSSAccumulator delayedTasks = new GSSAccumulator(); 
     156        public DCwormsAccumulator getAccumulatedDelayedTasks() { 
     157                DCwormsAccumulator delayedTasks = new DCwormsAccumulator(); 
    159158                for (SimulationStatistics simStat : simulations) { 
    160159                        Accumulator simulationDelayedTasks = simStat.getStats(SimulationStatistics.DELAYED_TASKS); 
    … …  
    164163        } 
    165164 
    166         public GSSAccumulator getAccumulatedCompletionTime() { 
    167                 GSSAccumulator meanJobCompletionTime = new GSSAccumulator(); 
     165        public DCwormsAccumulator getAccumulatedCompletionTime() { 
     166                DCwormsAccumulator meanJobCompletionTime = new DCwormsAccumulator(); 
    168167                 
    169168                for (SimulationStatistics simStat : simulations) { 
    … …  
    174173        } 
    175174 
    176         public GSSAccumulator getAccumulatedMakespan() { 
    177                 GSSAccumulator meanMakespan = new GSSAccumulator(); 
     175        public DCwormsAccumulator getAccumulatedMakespan() { 
     176                DCwormsAccumulator meanMakespan = new DCwormsAccumulator(); 
    178177                for (SimulationStatistics simStat : simulations) { 
    179178                        meanMakespan.add(simStat.getStats(SimulationStatistics.MAKESPAN).getMean()); 
    … …  
    182181        } 
    183182 
    184         public GSSAccumulator getAccumulatedWaitingTime() { 
    185                 GSSAccumulator meanWaitingTime = new GSSAccumulator(); 
     183        public DCwormsAccumulator getAccumulatedWaitingTime() { 
     184                DCwormsAccumulator meanWaitingTime = new DCwormsAccumulator(); 
    186185                for (SimulationStatistics simStat : simulations) 
    187186                        meanWaitingTime.add(simStat.getStats(SimulationStatistics.TASK_WAITING_TIME).getMean()); 
    … …  
    189188        } 
    190189 
    191         public GSSAccumulator getAccumulatedJobExecutionTime() { 
    192                 GSSAccumulator meanJobExecutionTime = new GSSAccumulator(); 
     190        public DCwormsAccumulator getAccumulatedJobExecutionTime() { 
     191                DCwormsAccumulator meanJobExecutionTime = new DCwormsAccumulator(); 
    193192                for (SimulationStatistics simStat : simulations) 
    194193                        meanJobExecutionTime.add(simStat.getStats(SimulationStatistics.TASK_EXECUTION_TIME).getMean()); 
    … …  
    196195        } 
    197196 
    198         public GSSAccumulator getAccumulatedQueueJobCount() { 
    199                 GSSAccumulator meanQueuJobCount = new GSSAccumulator(); 
     197        public DCwormsAccumulator getAccumulatedQueueJobCount() { 
     198                DCwormsAccumulator meanQueuJobCount = new DCwormsAccumulator(); 
    200199                for (SimulationStatistics simStat : simulations) 
    201200                        meanQueuJobCount.add(simStat.getStats(SimulationStatistics.RESOURCES_QUEUE_LENGTH).getMean()); 

  • DCWoRMS/branches/coolemall/src/simulator/stats/CoolEmAllMetricsCalculator.java

    r1331 r1396  
    5151                         
    5252                        double roomPower = 0; 
    53                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     53                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    5454                                roomPower = roomPower + acc.getSum(); 
    5555                        } 
    … …  
    6666                try{ 
    6767                        double itComputingPower = 0; 
    68                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     68                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    6969                                itComputingPower = itComputingPower + acc.getSum(); 
    7070                        } 
    … …  
    8181                try{ 
    8282                        double totalSitePower = 0;  
    83                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     83                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    8484                                totalSitePower = totalSitePower + acc.getSum(); 
    8585                        } 
    8686                        double nodeComputingPower = 0; 
    87                         for(GSSAccumulator acc: metricsData.get("Node")){ 
     87                        for(DCwormsAccumulator acc: metricsData.get("Node")){ 
    8888                                nodeComputingPower = nodeComputingPower+ acc.getSum(); 
    8989                        } 
    9090                        double itComputingPower = 0; 
    91                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     91                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    9292                                itComputingPower = itComputingPower + acc.getSum(); 
    9393                        } 
    … …  
    105105                try{ 
    106106                        double nodeComputingPower = 0; 
    107                         for(GSSAccumulator acc: metricsData.get("Node")){ 
     107                        for(DCwormsAccumulator acc: metricsData.get("Node")){ 
    108108                                nodeComputingPower = nodeComputingPower+ acc.getSum(); 
    109109                        } 
    110110                        double itComputingPower = 0; 
    111                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     111                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    112112                                itComputingPower = itComputingPower + acc.getSum(); 
    113113                        } 
    … …  
    126126                         
    127127                        double roomPower = 0; 
    128                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     128                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    129129                                roomPower = roomPower + acc.getSum(); 
    130130                        } 
    131131                         
    132132                        double totalSitePower = 0; 
    133                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     133                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    134134                                totalSitePower = totalSitePower + acc.getSum(); 
    135135                        } 
    … …  
    137137                 
    138138                        double nodeComputingPower = 0; 
    139                         for(GSSAccumulator acc: metricsData.get("Node")){ 
     139                        for(DCwormsAccumulator acc: metricsData.get("Node")){ 
    140140                                nodeComputingPower = nodeComputingPower+ acc.getSum(); 
    141141                        } 
    142142                        double itComputingPower = 0; 
    143                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     143                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    144144                                itComputingPower = itComputingPower + acc.getSum(); 
    145145                        } 
    … …  
    159159                         
    160160                        double roomPower = 0; 
    161                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     161                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    162162                                roomPower = roomPower + acc.getSum(); 
    163163                        } 
    164164                         
    165165                        double totalSitePower = 0; 
    166                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     166                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    167167                                totalSitePower = totalSitePower + acc.getSum(); 
    168168                        } 
    … …  
    183183                        for(String key: metricsData.keySet()){ 
    184184                                if(key.contains("UW_")){ 
    185                                         for(GSSAccumulator acc: metricsData.get(key)){ 
     185                                        for(DCwormsAccumulator acc: metricsData.get(key)){ 
    186186                                                usefulWork= usefulWork + acc.getSum(); 
    187187                                        } 
    … …  
    203203                        for(String key: metricsData.keySet()){ 
    204204                                if(key.contains("/")){ 
    205                                         for(GSSAccumulator acc: metricsData.get(key)){ 
     205                                        for(DCwormsAccumulator acc: metricsData.get(key)){ 
    206206                                                usefulWork= usefulWork + acc.getSum(); 
    207207                                        } 
    … …  
    209209                        } 
    210210                        double totalSitePower = 0;  
    211                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     211                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    212212                                totalSitePower = totalSitePower + acc.getSum(); 
    213213                        } 
    … …  
    228228                        double maxPower = 0; 
    229229                         
    230                         for(GSSAccumulator acc: metricsData.get("Rack_MAX")){ 
     230                        for(DCwormsAccumulator acc: metricsData.get("Rack_MAX")){ 
    231231                                maxPower = maxPower + acc.getSum(); 
    232232                        } 
    … …  
    246246                        double maxPower = 0; 
    247247                         
    248                         for(GSSAccumulator acc: metricsData.get("Room_MAX")){ 
     248                        for(DCwormsAccumulator acc: metricsData.get("Room_MAX")){ 
    249249                                maxPower = maxPower + acc.getSum(); 
    250250                        } 
    … …  
    263263                try{ 
    264264                        double inletsPower = 0; 
    265                         for(GSSAccumulator acc: metricsData.get("Inlet")){ 
     265                        for(DCwormsAccumulator acc: metricsData.get("Inlet")){ 
    266266                                inletsPower = inletsPower + acc.getSum(); 
    267267                        } 
    268268                         
    269269                        double outletsPower = 0; 
    270                         for(GSSAccumulator acc: metricsData.get("Outlet")){ 
     270                        for(DCwormsAccumulator acc: metricsData.get("Outlet")){ 
    271271                                outletsPower = outletsPower + acc.getSum(); 
    272272                        } 
    273273                         
    274274                        double nodeComputingPower = 0; 
    275                         for(GSSAccumulator acc: metricsData.get("Node")){ 
     275                        for(DCwormsAccumulator acc: metricsData.get("Node")){ 
    276276                                nodeComputingPower = nodeComputingPower+ acc.getSum(); 
    277277                        } 
    278278                        double itComputingPower = 0; 
    279                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     279                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    280280                                itComputingPower = itComputingPower + acc.getSum(); 
    281281                        } 
    … …  
    294294                try{ 
    295295                        double roomPower = 0; 
    296                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     296                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    297297                                roomPower = roomPower + acc.getSum(); 
    298298                        } 
    … …  
    309309                try{ 
    310310                        double coolingDevicePower = 0; 
    311                         for(GSSAccumulator acc: metricsData.get("CoolingDevice")){ 
     311                        for(DCwormsAccumulator acc: metricsData.get("CoolingDevice")){ 
    312312                                coolingDevicePower = coolingDevicePower + acc.getSum(); 
    313313                        } 
    … …  
    327327                        for(String key: metricsData.keySet()){ 
    328328                                if(key.contains("FlowPump")){ 
    329                                         for(GSSAccumulator acc: metricsData.get(key)){ 
     329                                        for(DCwormsAccumulator acc: metricsData.get(key)){ 
    330330                                                flowPump = flowPump + acc.getSum(); 
    331331                                        } 
    … …  
    346346                try{ 
    347347                        double roomPower = 0; 
    348                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     348                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    349349                                roomPower = roomPower + acc.getSum(); 
    350350                        } 
    351351                         
    352352                        double totalSitePower = 0; 
    353                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     353                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    354354                                totalSitePower = totalSitePower + acc.getSum(); 
    355355                        } 
    356356                         
    357357                        double coolingDevicePower = 0; 
    358                         for(GSSAccumulator acc: metricsData.get("CoolingDevice")){ 
     358                        for(DCwormsAccumulator acc: metricsData.get("CoolingDevice")){ 
    359359                                coolingDevicePower = coolingDevicePower + acc.getSum(); 
    360360                        } 
    361361                         
    362362                        double inletsPower = 0; 
    363                         for(GSSAccumulator acc: metricsData.get("Inlet")){ 
     363                        for(DCwormsAccumulator acc: metricsData.get("Inlet")){ 
    364364                                inletsPower = inletsPower + acc.getSum(); 
    365365                        } 
    366366                         
    367367                        double outletsPower = 0; 
    368                         for(GSSAccumulator acc: metricsData.get("Outlet")){ 
     368                        for(DCwormsAccumulator acc: metricsData.get("Outlet")){ 
    369369                                outletsPower = outletsPower + acc.getSum(); 
    370370                        } 
    371371                         
    372372                        double nodeComputingPower = 0; 
    373                         for(GSSAccumulator acc: metricsData.get("Node")){ 
     373                        for(DCwormsAccumulator acc: metricsData.get("Node")){ 
    374374                                nodeComputingPower = nodeComputingPower+ acc.getSum(); 
    375375                        } 
    376376                        double itComputingPower = 0; 
    377                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     377                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    378378                                itComputingPower = itComputingPower + acc.getSum(); 
    379379                        } 
    … …  
    394394                         
    395395                        double roomPower = 0; 
    396                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     396                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    397397                                roomPower = roomPower + acc.getSum(); 
    398398                        } 
    … …  
    411411                         
    412412                        double roomPower = 0; 
    413                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     413                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    414414                                roomPower = roomPower + acc.getSum(); 
    415415                        } 
    … …  
    427427                        double itComputingEnergy = 0; 
    428428                         
    429                         for(GSSAccumulator acc: metricsData.get("Processor_CALC")){ 
     429                        for(DCwormsAccumulator acc: metricsData.get("Processor_CALC")){ 
    430430                                itComputingEnergy = itComputingEnergy + acc.getSum(); 
    431431                        } 

  • DCWoRMS/branches/coolemall/src/simulator/stats/DCwormsAccumulator.java

    r477 r1396  
    44package simulator.stats; 
    55 
    6 import java.io.PrintStream; 
    76 
    87import simulator.DataCenterWorkloadSimulator; 
    … …  
    1514 *  
    1615 */ 
    17 public class GSSAccumulator extends Accumulator { 
     16public class DCwormsAccumulator extends Accumulator { 
    1817 
    19         public GSSAccumulator() { 
     18        public DCwormsAccumulator() { 
    2019                super(); 
    2120        } 
    2221 
    23         public GSSAccumulator(Accumulator acc) { 
     22        public DCwormsAccumulator(Accumulator acc) { 
    2423                n_ = acc.getCount(); 
    2524                mean_ = acc.getMean(); 
    … …  
    4948 
    5049        public boolean equals(Object obj) { 
    51                 if (!(obj instanceof GSSAccumulator)) 
     50                if (!(obj instanceof DCwormsAccumulator)) 
    5251                        return false; 
    5352 
    54                 GSSAccumulator otherAcc = (GSSAccumulator) obj; 
     53                DCwormsAccumulator otherAcc = (DCwormsAccumulator) obj; 
    5554                if (Double.compare(this.last_, otherAcc.last_) != 0) 
    5655                        return false; 

  • DCWoRMS/branches/coolemall/src/simulator/stats/DCwormsMetricsCalculator.java

    r1377 r1396  
    55 
    66import simulator.stats.implementation.MetricsStats; 
    7 import example.energy.coolemall.CoolEmAllTestbedMeasurements; 
    87 
    98public class DCwormsMetricsCalculator extends AbstractMetricsCalculator{ 
    … …  
    4544                         
    4645                        double roomPower = 0; 
    47                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     46                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    4847                                roomPower = roomPower + acc.getSum(); 
    4948                        } 
    … …  
    6160                try{ 
    6261                        double itComputingPower = 0; 
    63                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     62                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    6463                                itComputingPower = itComputingPower + acc.getSum(); 
    6564                        } 
    … …  
    7675                try{ 
    7776                        double totalSitePower = 0;  
    78                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     77                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    7978                                totalSitePower = totalSitePower + acc.getSum(); 
    8079                        } 
    8180                        double nodeComputingPower = 0; 
    82                         for(GSSAccumulator acc: metricsData.get("Node")){ 
     81                        for(DCwormsAccumulator acc: metricsData.get("Node")){ 
    8382                                nodeComputingPower = nodeComputingPower+ acc.getSum(); 
    8483                        } 
    8584                        double itComputingPower = 0; 
    86                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     85                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    8786                                itComputingPower = itComputingPower + acc.getSum(); 
    8887                        } 
    … …  
    101100                         
    102101                        double roomPower = 0; 
    103                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     102                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    104103                                roomPower = roomPower + acc.getSum(); 
    105104                        } 
    106105                         
    107106                        double totalSitePower = 0; 
    108                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     107                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    109108                                totalSitePower = totalSitePower + acc.getSum(); 
    110109                        } 
    … …  
    112111                 
    113112                        double nodeComputingPower = 0; 
    114                         for(GSSAccumulator acc: metricsData.get("Node")){ 
     113                        for(DCwormsAccumulator acc: metricsData.get("Node")){ 
    115114                                nodeComputingPower = nodeComputingPower+ acc.getSum(); 
    116115                        } 
    117116                        double itComputingPower = 0; 
    118                         for(GSSAccumulator acc: metricsData.get("Processor")){ 
     117                        for(DCwormsAccumulator acc: metricsData.get("Processor")){ 
    119118                                itComputingPower = itComputingPower + acc.getSum(); 
    120119                        } 
    … …  
    134133                         
    135134                        double roomPower = 0; 
    136                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     135                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    137136                                roomPower = roomPower + acc.getSum(); 
    138137                        } 
    139138                         
    140139                        double totalSitePower = 0; 
    141                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     140                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    142141                                totalSitePower = totalSitePower + acc.getSum(); 
    143142                        } 
    … …  
    158157                        for(String key: metricsData.keySet()){ 
    159158                                if(key.contains("/")){ 
    160                                         for(GSSAccumulator acc: metricsData.get(key)){ 
     159                                        for(DCwormsAccumulator acc: metricsData.get(key)){ 
    161160                                                usefulWork= usefulWork + acc.getSum(); 
    162161                                        } 
    … …  
    178177                        for(String key: metricsData.keySet()){ 
    179178                                if(key.contains("/")){ 
    180                                         for(GSSAccumulator acc: metricsData.get(key)){ 
     179                                        for(DCwormsAccumulator acc: metricsData.get(key)){ 
    181180                                                usefulWork= usefulWork + acc.getSum(); 
    182181                                        } 
    … …  
    184183                        } 
    185184                        double totalSitePower = 0;  
    186                         for(GSSAccumulator acc: metricsData.get("Rack")){ 
     185                        for(DCwormsAccumulator acc: metricsData.get("Rack")){ 
    187186                                totalSitePower = totalSitePower + acc.getSum(); 
    188187                        } 
    … …  
    204203                        double maxPower = 0; 
    205204                         
    206                         for(GSSAccumulator acc: metricsData.get("Room_MAX")){ 
     205                        for(DCwormsAccumulator acc: metricsData.get("Room_MAX")){ 
    207206                                maxPower = maxPower + acc.getSum(); 
    208207                        } 
    … …  
    221220                try{ 
    222221                        double coolingDevicePower = 0; 
    223                         for(GSSAccumulator acc: metricsData.get("CoolingDevice")){ 
     222                        for(DCwormsAccumulator acc: metricsData.get("CoolingDevice")){ 
    224223                                coolingDevicePower = coolingDevicePower + acc.getSum(); 
    225224                        } 
    … …  
    237236                         
    238237                        double roomPower = 0; 
    239                         for(GSSAccumulator acc: metricsData.get("Room")){ 
     238                        for(DCwormsAccumulator acc: metricsData.get("Room")){ 
    240239                                roomPower = roomPower + acc.getSum(); 
    241240                        } 
    … …  
    252251                try{ 
    253252                        double itComputingEnergy = 0; 
    254                         for(GSSAccumulator acc: metricsData.get("Processor_CALC")){ 
     253                        for(DCwormsAccumulator acc: metricsData.get("Processor_CALC")){ 
    255254                                itComputingEnergy = itComputingEnergy + acc.getSum(); 
    256255                        } 

  • DCWoRMS/branches/coolemall/src/simulator/stats/MetricsCalculator.java

    r1299 r1396  
    1010        public List<MetricsStats> calulateMetrics(); 
    1111         
    12         public void addMetricsData(String resourceTypeName, GSSAccumulator resourceEnergyAccumulator); 
     12        public void addMetricsData(String resourceTypeName, DCwormsAccumulator resourceEnergyAccumulator); 
    1313         
    14         public Map<String, List<GSSAccumulator>> getMetricsData(); 
     14        public Map<String, List<DCwormsAccumulator>> getMetricsData(); 
    1515         
    1616} 

  • DCWoRMS/branches/coolemall/src/simulator/stats/SimulationStatistics.java

    r477 r1396  
    4444        public String getOutputFolderName(); 
    4545 
    46         public GSSAccumulator getStats(String resourcesTotalLoad); 
     46        public DCwormsAccumulator getStats(String resourcesTotalLoad); 
    4747 
    4848        public boolean accumulatedStats(); 

  • DCWoRMS/branches/coolemall/src/simulator/stats/StatisticsInfo.java

    r477 r1396  
    99 
    1010        /** The mean value */ 
    11         protected GSSAccumulator mean; 
     11        protected DCwormsAccumulator mean; 
    1212        /** The standard deviation value */ 
    13         protected GSSAccumulator stdev; 
     13        protected DCwormsAccumulator stdev; 
    1414        /** The minimal value */ 
    15         protected GSSAccumulator max; 
     15        protected DCwormsAccumulator max; 
    1616        /** The maximal value */ 
    17         protected GSSAccumulator min; 
     17        protected DCwormsAccumulator min; 
    1818        /** 
    1919         * @param mean 
    … …  
    2222         * @param min 
    2323         */ 
    24         public StatisticsInfo(GSSAccumulator mean, GSSAccumulator stdev, GSSAccumulator max, GSSAccumulator min) { 
     24        public StatisticsInfo(DCwormsAccumulator mean, DCwormsAccumulator stdev, DCwormsAccumulator max, DCwormsAccumulator min) { 
    2525                this.mean = mean; 
    2626                this.stdev = stdev; 
    … …  
    3131         * @return the maximal value 
    3232         */ 
    33         public GSSAccumulator getMax() { 
     33        public DCwormsAccumulator getMax() { 
    3434                return max; 
    3535        } 
    … …  
    3737         * @return the mean value 
    3838         */ 
    39         public GSSAccumulator getMean() { 
     39        public DCwormsAccumulator getMean() { 
    4040                return mean; 
    4141        } 
    … …  
    4343         * @return the minimal value 
    4444         */ 
    45         public GSSAccumulator getMin() { 
     45        public DCwormsAccumulator getMin() { 
    4646                return min; 
    4747        } 
    … …  
    4949         * @return the standard deviation value 
    5050         */ 
    51         public GSSAccumulator getStdev() { 
     51        public DCwormsAccumulator getStdev() { 
    5252                return stdev; 
    5353        } 

  • DCWoRMS/branches/coolemall/src/simulator/stats/implementation/AccumulatedResourceStats.java

    r477 r1396  
    11package simulator.stats.implementation; 
    22 
    3 import simulator.stats.GSSAccumulator; 
     3import simulator.stats.DCwormsAccumulator; 
    44import simulator.stats.implementation.out.StatsSerializer; 
    55 
    … …  
    1212 
    1313        // accumulated resource statistic 
    14         protected GSSAccumulator resourceLoad; 
    15         protected GSSAccumulator resourceReservationLoad; 
     14        protected DCwormsAccumulator resourceLoad; 
     15        protected DCwormsAccumulator resourceReservationLoad; 
    1616        protected String resourceName; 
    1717 
    … …  
    2121        public AccumulatedResourceStats(String resourceName) { 
    2222                this.resourceName = resourceName; 
    23                 this.resourceLoad = new GSSAccumulator(); 
    24                 this.resourceReservationLoad = new GSSAccumulator(); 
     23                this.resourceLoad = new DCwormsAccumulator(); 
     24                this.resourceReservationLoad = new DCwormsAccumulator(); 
    2525        } 
    2626 
    … …  
    3737        } 
    3838 
    39         public GSSAccumulator getResourceLoad() { 
     39        public DCwormsAccumulator getResourceLoad() { 
    4040                return this.resourceLoad; 
    4141        } 
    4242 
    43         public GSSAccumulator getResourceReservationLoad() { 
     43        public DCwormsAccumulator getResourceReservationLoad() { 
    4444                return this.resourceReservationLoad; 
    4545        } 

  • DCWoRMS/branches/coolemall/src/simulator/stats/implementation/DCWormsStatistics.java

    r1374 r1396  
    5959import schedframe.ExecutablesList; 
    6060import schedframe.SimulatedEnvironment; 
    61 import schedframe.exceptions.ResourceException; 
     61import schedframe.resources.CustomResourceType; 
    6262import schedframe.resources.ResourceType; 
    63 import schedframe.resources.UserResourceType; 
    6463import schedframe.resources.computing.ComputingResource; 
    65 import schedframe.resources.computing.Processor; 
    6664import schedframe.resources.computing.extensions.Extension; 
    6765import schedframe.resources.computing.extensions.ExtensionList; 
    … …  
    6967import schedframe.resources.computing.profiles.energy.EnergyExtension; 
    7068import schedframe.resources.computing.profiles.energy.MeasurementHistory; 
    71 import schedframe.resources.computing.profiles.energy.airthroughput.AirFlowValue; 
     69import schedframe.resources.computing.profiles.energy.airthroughput.AirflowValue; 
    7270import schedframe.resources.computing.profiles.energy.power.PowerUsage; 
    7371import schedframe.resources.computing.profiles.energy.thermal.TemperatureValue; 
    … …  
    8078import schedframe.resources.units.StandardResourceUnitName; 
    8179import schedframe.scheduling.ExecutionHistoryItem; 
    82 import schedframe.scheduling.ResourceHistoryItem; 
     80import schedframe.scheduling.ResourceItem; 
    8381import schedframe.scheduling.Scheduler; 
    8482import schedframe.scheduling.manager.tasks.JobRegistry; 
    … …  
    9189import simulator.GenericUser; 
    9290import simulator.stats.CoolEmAllMetricsCalculator; 
     91import simulator.stats.DCwormsAccumulator; 
    9392import simulator.stats.DCwormsMetricsCalculator; 
    94 import simulator.stats.GSSAccumulator; 
    9593import simulator.stats.MetricsCalculator; 
    9694import simulator.stats.SimulationStatistics; 
    … …  
    124122        protected static final String RESOURCEUTILIZATION_STATISTICS_OUTPUT_FILE_NAME = "ResourceUtilization.txt"; 
    125123        protected static final String ENERGYUSAGE_STATISTICS_OUTPUT_FILE_NAME = "EnergyUsage.txt"; 
    126         protected static final String AIRFLOW_STATISTICS_OUTPUT_FILE_NAME = "AirThroughput.txt"; 
     124        protected static final String AIRFLOW_STATISTICS_OUTPUT_FILE_NAME = "Airflow.txt"; 
    127125        protected static final String TEMPERATURE_STATISTICS_OUTPUT_FILE_NAME = "Temperature.txt"; 
    128126        protected static final String USEFUL_WORK_STATISTICS_OUTPUT_FILE_NAME = "UsefulWork.txt"; 
    … …  
    144142 
    145143        protected GSSAccumulatorsStats accStats; 
    146         protected Map<String, GSSAccumulator> statsData; 
     144        protected Map<String, DCwormsAccumulator> statsData; 
    147145         
    148146        protected GenericUser users; 
    … …  
    232230                task_processorsMap = new HashMap<String, Set<ComputingResource>>(); 
    233231                accStats = new GSSAccumulatorsStats(); 
    234                 statsData = new HashMap<String, GSSAccumulator>(); 
     232                statsData = new HashMap<String, DCwormsAccumulator>(); 
    235233                 
    236234                this.serializer = new StringSerializer();                
    … …  
    298296                                cStats.add(Stats.chartEnergy); 
    299297                        cStats.add(Stats.textAirFlow); 
    300                         if(ArrayUtils.contains(configuration.resForAirFlowChart, resourceTypeName)) 
     298                        if(ArrayUtils.contains(configuration.resForAirflowChart, resourceTypeName)) 
    301299                                cStats.add(Stats.chartAirFlow); 
    302300                        cStats.add(Stats.textTemperature); 
    … …  
    420418                List<ComputingResource> compResources = null; 
    421419                for(String resourceTypeName: resourceController.getComputingResourceLayers()){ 
    422                         GSSAccumulator resourceEnergyAccumulator = new GSSAccumulator(); 
    423                         GSSAccumulator maxResourceEnergyAccumulator = new GSSAccumulator(); 
    424                         GSSAccumulator calculationsEnergyAccumulator = new GSSAccumulator(); 
     420                        DCwormsAccumulator resourceEnergyAccumulator = new DCwormsAccumulator(); 
     421                        DCwormsAccumulator maxResourceEnergyAccumulator = new DCwormsAccumulator(); 
     422                        DCwormsAccumulator calculationsEnergyAccumulator = new DCwormsAccumulator(); 
    425423                        compResources = new ArrayList<ComputingResource>(); 
    426424                        for(ComputingResource compRes: resourceController.getComputingResources() ){ 
    427                                 compResources.addAll(compRes.getDescendantsByType(new UserResourceType(resourceTypeName))); 
     425                                compResources.addAll(compRes.getDescendantsByType(new CustomResourceType(resourceTypeName))); 
    428426                        } 
    429427                        if(resourceController.getComputingResources().get(0).getType().getName().equals(resourceTypeName)) 
    … …  
    526524                                                 
    527525                                                for(Device device: compResource.getResourceCharacteristic().getDevices()){ 
    528                                                         GSSAccumulator devAccumulator = new GSSAccumulator(); 
     526                                                        DCwormsAccumulator devAccumulator = new DCwormsAccumulator(); 
    529527                                                        ResourcePowerStats deviceEnergyUsage = gatherResourcePowerConsumptionStats(device); 
    530528                                                        deviceEnergyUsage.setMeanValue(calculateMeanValue(deviceEnergyUsage)); 
    … …  
    592590                                                        } 
    593591                                                         
    594                                                         if(ArrayUtils.contains(configuration.resForAirFlowChart, device.getType().getName())){ 
     592                                                        if(ArrayUtils.contains(configuration.resForAirflowChart, device.getType().getName())){ 
    595593                                                                if (configuration.creatediagrams_resairflow) { 
    596594                                                                        createResourceAirFlowDiagramData(deviceAirFlow); 
    … …  
    767765 
    768766 
    769                         LinkedList<ResourceHistoryItem> resourceHistory = exec.getAllocatedResources(); 
     767                        LinkedList<ResourceItem> resourceHistory = exec.getAllocatedResources(); 
    770768                        if(resourceHistory.size() == 0) 
    771769                                continue; 
    … …  
    805803 
    806804                                        try{ 
    807                                                 double usefulWork = execTask.getResourceConsumptionProfile().getUsefulWork()/pes.size(); 
     805                                                double usefulWork = execTask.getExecutionProfile().getUsefulWork()/pes.size(); 
    808806                                                //double usefulWork = gatherUsefulWorkStats(pe).getValue(); 
    809                                                 GSSAccumulator uwAcc; 
     807                                                DCwormsAccumulator uwAcc; 
    810808                                                if(metCalc.getMetricsData().containsKey("UW_" + pe.getFullName())){ 
    811809                                                        uwAcc = metCalc.getMetricsData().get("UW_" + pe.getFullName()).get(0); 
    812810                                                        uwAcc.add(usefulWork); 
    813811                                                } else { 
    814                                                         uwAcc = new GSSAccumulator(); 
     812                                                        uwAcc = new DCwormsAccumulator(); 
    815813                                                        uwAcc.add(usefulWork); 
    816814                                                        metCalc.addMetricsData("UW_" + pe.getFullName(), uwAcc); 
    … …  
    832830                        Executable exec = (Executable) execTask; 
    833831 
    834                         LinkedList<ResourceHistoryItem> resourceHistory = exec.getAllocatedResources(); 
     832                        LinkedList<ResourceItem> resourceHistory = exec.getAllocatedResources(); 
    835833                        if(resourceHistory.size() == 0) 
    836834                                continue; 
    837835 
    838836                        for(int i = 0; i < resourceHistory .size(); i++){ 
    839                                 ResourceHistoryItem resHistItem = resourceHistory.get(i); 
     837                                ResourceItem resHistItem = resourceHistory.get(i); 
    840838                                Map<ResourceUnitName, ResourceUnit> res = resHistItem.getResourceUnits(); 
    841839                                ResourceUnit resUnit = res.get(StandardResourceUnitName.PE); 
    842840                                //ProcessingElements pes = (ProcessingElements) resUnit ; 
    843                                 LinkedList<ExecutionHistoryItem> execHistory = exec.getExecHistory(); 
     841                                LinkedList<ExecutionHistoryItem> execHistory = exec.getExecutionHistory(); 
    844842                                long st = -1, et; 
    845843                                for(int j = 0; j < execHistory .size(); j++){ 
    … …  
    893891 
    894892                                                                try{ 
    895                                                                         double usefulWork = execTask.getResourceConsumptionProfile().getUsefulWork()/pes.size(); 
     893                                                                        double usefulWork = execTask.getExecutionProfile().getUsefulWork()/pes.size(); 
    896894                                                                        usefulWork = ((et - st) / (1000 * getExecutionTime(execTask))) * usefulWork; 
    897                                                                         GSSAccumulator uwAcc; 
     895                                                                        DCwormsAccumulator uwAcc; 
    898896                                                                        if(metCalc.getMetricsData().containsKey("UW_" + pe.getFullName())){ 
    899897                                                                                uwAcc = metCalc.getMetricsData().get("UW_" + pe.getFullName()).get(0); 
    900898                                                                                uwAcc.add(usefulWork); 
    901899                                                                        } else { 
    902                                                                                 uwAcc = new GSSAccumulator(); 
     900                                                                                uwAcc = new DCwormsAccumulator(); 
    903901                                                                                uwAcc.add(usefulWork); 
    904902                                                                                metCalc.addMetricsData("UW_" + pe.getFullName(), uwAcc); 
    … …  
    922920                long previousTimestamp = 0; 
    923921                int previousStatus = DCWormsTags.CREATED; 
    924                 for(ExecutionHistoryItem execHistItem: execTask.getExecHistory()){ 
     922                for(ExecutionHistoryItem execHistItem: execTask.getExecutionHistory()){ 
    925923                        if(previousStatus == DCWormsTags.INEXEC){ 
    926924                                executionTime = executionTime  + (execHistItem.getTimeStamp().getMillis()/1000 - previousTimestamp); 
    … …  
    10331031                JobRegistry jr = new JobRegistryImpl(compResource.getFullName()); 
    10341032                for(ExecTask task: jr.getFinishedTasks()){ 
    1035                         usefulWork = usefulWork + task.getResourceConsumptionProfile().getUsefulWork(); 
     1033                        usefulWork = usefulWork + task.getExecutionProfile().getUsefulWork(); 
    10361034                } 
    10371035                ResourceUsefulWorkStats usefulWorkStats = new ResourceUsefulWorkStats(compResource.getFullName(), compResource.getType(), usageType, usefulWork, endSimulationTime); 
    … …  
    11751173                                        if(ee.getAirFlowProfile() == null) 
    11761174                                                break; 
    1177                                         List<AirFlowValue> airFlowHistory = ee.getAirFlowProfile().getAirThroughputHistory(); 
     1175                                        List<AirflowValue> airFlowHistory = ee.getAirFlowProfile().getAirflowHistory(); 
    11781176                                        if(airFlowHistory.size() == 0) 
    11791177                                                break; 
    11801178                                        long endSimulationTime = DateTimeUtilsExt.currentTimeMillis(); 
    1181                                         airFlowHistory.add(new AirFlowValue(endSimulationTime, ee.getAirFlowProfile().getAirThroughputHistory().get(ee.getAirFlowProfile().getAirThroughputHistory().size()-1).getValue())); 
    1182                                         for(AirFlowValue af:airFlowHistory){ 
     1179                                        airFlowHistory.add(new AirflowValue(endSimulationTime, ee.getAirFlowProfile().getAirflowHistory().get(ee.getAirFlowProfile().getAirflowHistory().size()-1).getValue())); 
     1180                                        for(AirflowValue af:airFlowHistory){ 
    11831181                                                airFlow.put(af.getTimestamp(), af.getValue()); 
    11841182                                        } 
    … …  
    14021400                                resourceAirFlowDiagram = getResourceDynamicDiagram(resourceAirFlowDiagrams.get(resType), simulationTime, chartName, 
    14031401                                                subtitle, axisName); 
    1404                                 if (!saveXYPlotChart(resourceAirFlowDiagram, fileName + "AirThroughput_" + resType)) 
     1402                                if (!saveXYPlotChart(resourceAirFlowDiagram, fileName + "Airflow_" + resType)) 
    14051403                                        return false; 
    14061404                        } 
    … …  
    20402038        } 
    20412039 
    2042         public GSSAccumulator getStats(String name) { 
     2040        public DCwormsAccumulator getStats(String name) { 
    20432041                return statsData.get(name); 
    20442042        } 

  • DCWoRMS/branches/coolemall/src/simulator/stats/implementation/GSSAccumulatorsStats.java

    r1277 r1396  
    11package simulator.stats.implementation; 
    22 
    3 import simulator.stats.GSSAccumulator; 
     3import simulator.stats.DCwormsAccumulator; 
    44import simulator.stats.implementation.out.StatsSerializer; 
    55 
    66public class GSSAccumulatorsStats implements StatsInterface { 
    77 
    8         public GSSAccumulator meanTotalOccupancy; 
    9         public GSSAccumulator meanTotalLoad; 
    10         public GSSAccumulator meanQueueLength; 
    11         public GSSAccumulator meanEnergyUsage; 
    12         public GSSAccumulator meanAirFlow; 
    13         public GSSAccumulator meanTemperature; 
     8        public DCwormsAccumulator meanTotalOccupancy; 
     9        public DCwormsAccumulator meanTotalLoad; 
     10        public DCwormsAccumulator meanQueueLength; 
     11        public DCwormsAccumulator meanEnergyUsage; 
     12        public DCwormsAccumulator meanAirFlow; 
     13        public DCwormsAccumulator meanTemperature; 
    1414 
    15         public GSSAccumulator meanTaskStartTime; 
    16         public GSSAccumulator meanTaskCompletionTime; 
    17         public GSSAccumulator meanTaskExecutionTime; 
    18         public GSSAccumulator meanTaskWaitingTime; 
    19         public GSSAccumulator meanTaskFlowTime; 
    20         public GSSAccumulator lateness; 
    21         public GSSAccumulator tardiness; 
    22         public GSSAccumulator delayedTasks; 
    23         public GSSAccumulator failedRequests; 
    24         public GSSAccumulator makespan; 
     15        public DCwormsAccumulator meanTaskStartTime; 
     16        public DCwormsAccumulator meanTaskCompletionTime; 
     17        public DCwormsAccumulator meanTaskExecutionTime; 
     18        public DCwormsAccumulator meanTaskWaitingTime; 
     19        public DCwormsAccumulator meanTaskFlowTime; 
     20        public DCwormsAccumulator lateness; 
     21        public DCwormsAccumulator tardiness; 
     22        public DCwormsAccumulator delayedTasks; 
     23        public DCwormsAccumulator failedRequests; 
     24        public DCwormsAccumulator makespan; 
    2525 
    2626        private String[] headers = { "Resource name", "mean", "stdev", "variance", 
    … …  
    2828 
    2929        public GSSAccumulatorsStats() { 
    30                 meanTotalOccupancy = new GSSAccumulator(); 
    31                 meanTotalLoad = new GSSAccumulator(); 
    32                 meanQueueLength = new GSSAccumulator(); 
    33                 meanEnergyUsage = new GSSAccumulator();  
    34                 meanAirFlow = new GSSAccumulator();  
    35                 meanTemperature = new GSSAccumulator();  
     30                meanTotalOccupancy = new DCwormsAccumulator(); 
     31                meanTotalLoad = new DCwormsAccumulator(); 
     32                meanQueueLength = new DCwormsAccumulator(); 
     33                meanEnergyUsage = new DCwormsAccumulator();  
     34                meanAirFlow = new DCwormsAccumulator();  
     35                meanTemperature = new DCwormsAccumulator();  
    3636                 
    37                 meanTaskStartTime = new GSSAccumulator(); 
    38                 meanTaskCompletionTime = new GSSAccumulator(); 
    39                 meanTaskExecutionTime = new GSSAccumulator(); 
    40                 meanTaskWaitingTime = new GSSAccumulator(); 
    41                 meanTaskFlowTime = new GSSAccumulator(); 
    42                 lateness = new GSSAccumulator(); 
    43                 tardiness = new GSSAccumulator(); 
    44                 delayedTasks = new GSSAccumulator(); 
    45                 failedRequests = new GSSAccumulator(); 
    46                 makespan = new GSSAccumulator(); 
     37                meanTaskStartTime = new DCwormsAccumulator(); 
     38                meanTaskCompletionTime = new DCwormsAccumulator(); 
     39                meanTaskExecutionTime = new DCwormsAccumulator(); 
     40                meanTaskWaitingTime = new DCwormsAccumulator(); 
     41                meanTaskFlowTime = new DCwormsAccumulator(); 
     42                lateness = new DCwormsAccumulator(); 
     43                tardiness = new DCwormsAccumulator(); 
     44                delayedTasks = new DCwormsAccumulator(); 
     45                failedRequests = new DCwormsAccumulator(); 
     46                makespan = new DCwormsAccumulator(); 
    4747        } 
    4848 

  • DCWoRMS/branches/coolemall/src/simulator/stats/implementation/JobStats.java

    r477 r1396  
    11package simulator.stats.implementation; 
    22 
    3 import java.io.PrintStream; 
    4  
    5 import simulator.stats.GSSAccumulator; 
     3import simulator.stats.DCwormsAccumulator; 
    64import simulator.stats.implementation.out.StatsSerializer; 
    75 
    … …  
    1412 
    1513        protected String jobID; 
    16         protected GSSAccumulator meanTaskCompletionTime; 
    17         protected GSSAccumulator meanTaskExecutionTime; 
    18         protected GSSAccumulator meanTaskStartTime; 
    19         protected GSSAccumulator meanTaskFlowTime; 
    20         protected GSSAccumulator meanTaskWaitingTime; 
    21         protected GSSAccumulator meanTaskGQ_WaitingTime; 
    22         protected GSSAccumulator lateness; 
    23         protected GSSAccumulator tardiness; 
    24         protected GSSAccumulator makespan; 
     14        protected DCwormsAccumulator meanTaskCompletionTime; 
     15        protected DCwormsAccumulator meanTaskExecutionTime; 
     16        protected DCwormsAccumulator meanTaskStartTime; 
     17        protected DCwormsAccumulator meanTaskFlowTime; 
     18        protected DCwormsAccumulator meanTaskWaitingTime; 
     19        protected DCwormsAccumulator meanTaskGQ_WaitingTime; 
     20        protected DCwormsAccumulator lateness; 
     21        protected DCwormsAccumulator tardiness; 
     22        protected DCwormsAccumulator makespan; 
    2523 
    2624        JobStats(String jobID) { 
    … …  
    3533 
    3634        private void init() { 
    37                 this.meanTaskCompletionTime = new GSSAccumulator(); 
    38                 this.meanTaskExecutionTime = new GSSAccumulator(); 
    39                 this.meanTaskStartTime = new GSSAccumulator(); 
    40                 this.meanTaskFlowTime = new GSSAccumulator(); 
    41                 this.meanTaskWaitingTime = new GSSAccumulator(); 
    42                 this.meanTaskGQ_WaitingTime = new GSSAccumulator(); 
    43                 this.lateness = new GSSAccumulator(); 
    44                 this.tardiness = new GSSAccumulator(); 
    45                 this.makespan = new GSSAccumulator(); 
     35                this.meanTaskCompletionTime = new DCwormsAccumulator(); 
     36                this.meanTaskExecutionTime = new DCwormsAccumulator(); 
     37                this.meanTaskStartTime = new DCwormsAccumulator(); 
     38                this.meanTaskFlowTime = new DCwormsAccumulator(); 
     39                this.meanTaskWaitingTime = new DCwormsAccumulator(); 
     40                this.meanTaskGQ_WaitingTime = new DCwormsAccumulator(); 
     41                this.lateness = new DCwormsAccumulator(); 
     42                this.tardiness = new DCwormsAccumulator(); 
     43                this.makespan = new DCwormsAccumulator(); 
    4644        } 
    4745 
    … …  
    5048        } 
    5149 
    52         public GSSAccumulator getMeanTaskCompletionTime() { 
     50        public DCwormsAccumulator getMeanTaskCompletionTime() { 
    5351                return meanTaskCompletionTime; 
    5452        } 
    5553 
    56         public GSSAccumulator getMeanTaskExecutionTime() { 
     54        public DCwormsAccumulator getMeanTaskExecutionTime() { 
    5755                return meanTaskExecutionTime; 
    5856        } 
    5957 
    60         public GSSAccumulator getMeanTaskStartTime() { 
     58        public DCwormsAccumulator getMeanTaskStartTime() { 
    6159                return meanTaskStartTime; 
    6260        } 
    6361 
    64         public GSSAccumulator getMeanTaskFlowTime() { 
     62        public DCwormsAccumulator getMeanTaskFlowTime() { 
    6563                return meanTaskFlowTime; 
    6664        } 
    6765 
    68         public GSSAccumulator getMeanTaskWaitingTime() { 
     66        public DCwormsAccumulator getMeanTaskWaitingTime() { 
    6967                return meanTaskWaitingTime; 
    7068        } 
    7169 
    72         public GSSAccumulator getMeanTaskGQ_WaitingTime() { 
     70        public DCwormsAccumulator getMeanTaskGQ_WaitingTime() { 
    7371                return meanTaskGQ_WaitingTime; 
    7472        } 
    7573 
    76         public GSSAccumulator getLateness() { 
     74        public DCwormsAccumulator getLateness() { 
    7775                return lateness; 
    7876        } 
    7977 
    80         public GSSAccumulator getTardiness() { 
     78        public DCwormsAccumulator getTardiness() { 
    8179                return tardiness; 
    8280        } 
    8381 
    84         public GSSAccumulator getMakespan() { 
     82        public DCwormsAccumulator getMakespan() { 
    8583                return makespan; 
    8684        } 

  • DCWoRMS/branches/coolemall/src/simulator/stats/implementation/ResourceHistoryStats.java

    r1207 r1396  
    33import java.util.List; 
    44 
    5 import schedframe.resources.ResourceHistoryChanges; 
     5import schedframe.resources.ResourceHistoryItem; 
    66import simulator.stats.implementation.out.StatsSerializer; 
    77 
    … …  
    1010        private String[] headers = {"timestamp", "resourceName", "operation", "parameter" }; 
    1111 
    12         protected List<ResourceHistoryChanges> resHistChanges; 
     12        protected List<ResourceHistoryItem> resHist; 
    1313         
    14         public ResourceHistoryStats(List<ResourceHistoryChanges> resHistChanges) { 
    15                 super(); 
    16                 this.resHistChanges = resHistChanges; 
     14        public ResourceHistoryStats(List<ResourceHistoryItem> resHist) { 
     15                this.resHist = resHist; 
    1716        } 
    18  
    1917 
    2018        public Object serialize(StatsSerializer serializer) { 
    … …  
    2624        } 
    2725 
    28  
    29         public List<ResourceHistoryChanges> getResHistChanges() { 
    30                 return resHistChanges; 
     26        public List<ResourceHistoryItem> getResourceHistory() { 
     27                return resHist; 
    3128        } 
    3229} 

  • DCWoRMS/branches/coolemall/src/simulator/stats/implementation/TaskStats.java

    r1362 r1396  
    108108                long previousTimestamp = 0;              
    109109                int previousStatus = DCWormsTags.CREATED; 
    110                 for(ExecutionHistoryItem execHistItem: task.getExecHistory()){ 
     110                for(ExecutionHistoryItem execHistItem: task.getExecutionHistory()){ 
    111111                        if(previousStatus == DCWormsTags.INEXEC){ 
    112112                                executionTime = executionTime  + (execHistItem.getTimeStamp().getMillis()/1000 - previousTimestamp); 

  • DCWoRMS/branches/coolemall/src/simulator/stats/implementation/out/CoolEmAllStringSerializer.java

    r1207 r1396  
    88 
    99import schedframe.resources.CoolEmAllResourceType; 
    10 import schedframe.resources.ResourceHistoryChanges; 
     10import schedframe.resources.ResourceHistoryItem; 
    1111import schedframe.resources.StandardResourceType; 
    1212import simulator.stats.implementation.MetricsStats; 
    … …  
    311311                df.setGroupingUsed(false); 
    312312                 
    313                 for(ResourceHistoryChanges rhc: arg.getResHistChanges()){ 
     313                for(ResourceHistoryItem rhc: arg.getResourceHistory()){ 
    314314                        buffer.append(rhc.getTimestamp()); 
    315315                        buffer.append(fieldSeparator); 
    316316                        buffer.append(rhc.getResourceName()); 
    317317                        buffer.append(fieldSeparator); 
    318                         buffer.append(rhc.getOperation()); 
     318                        buffer.append(rhc.getAction()); 
    319319                        buffer.append(fieldSeparator); 
    320320                        buffer.append(rhc.getParamter()); 
Note: See TracChangeset for help on using the changeset viewer.