Changeset 1415 for DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/EnergyExtension.java

Timestamp:

07/15/14 16:26:31 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/EnergyExtension.java (modified) (4 diffs)

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

@@ -15 +15 @@
 import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory;
 import schedframe.resources.computing.profiles.energy.power.PowerProfile;
+import schedframe.resources.computing.profiles.energy.power.PowerStateName;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 import schedframe.resources.computing.profiles.energy.thermal.ThermalInterfaceFactory;
@@ -110 +111 @@
                 if(powerProfile == null || powerProfile.getEnergyEstimationPlugin() == null)
                         return false;
-                if(event.getType().getName().equals(EnergyEventType.POWER_STATE_CHANGED.getName()))
-                        return true;
-                else if(event.getType().getName().equals(EnergyEventType.FREQUENCY_CHANGED.getName()))
-                        return true;
-                else if(event.getType().getName().equals(EnergyEventType.TASK_STARTED.getName()))
-                        return true;
-                else if(event.getType().getName().equals(EnergyEventType.TASK_FINISHED.getName()))
-                        return true;
-                else if(event.getType().getName().equals(EnergyEventType.RESOURCE_UTILIZATION_CHANGED.getName()))
-                        return true;
-        
-                if(event.getType().getName().equals(EnergyEventType.AIRFLOW_STATE_CHANGED.getName()))
-                        return true;
-                if(event.getType().getName().equals(EnergyEventType.TEMPERATURE_CHANGED.getName()))
+                if(event.getType().getName().equals(ResourceEventType.POWER_STATE_CHANGED.getName()))
+                        return true;
+                else if(event.getType().getName().equals(ResourceEventType.CPU_FREQUENCY_CHANGED.getName()))
+                        return true;
+                else if(event.getType().getName().equals(ResourceEventType.TASK_STARTED.getName()))
+                        return true;
+                else if(event.getType().getName().equals(ResourceEventType.TASK_FINISHED.getName()))
+                        return true;
+                else if(event.getType().getName().equals(ResourceEventType.UTILIZATION_CHANGED.getName()))
+                        return true;
+        
+                if(event.getType().getName().equals(ResourceEventType.AIRFLOW_STATE_CHANGED.getName()))
+                        return true;
+                if(event.getType().getName().equals(ResourceEventType.TEMPERATURE_CHANGED.getName()))
                         return true;
                 
@@ -131 +132 @@
         public void handleEvent(Event event) {
                 
-                EnergyEvent enEvent = (EnergyEvent)event;
+                ResourceEvent resEvent = (ResourceEvent)event;
                 double power = 0;
                 boolean status = false;
                 try{
-                        switch (enEvent.getType()) {
+                        switch (resEvent.getType()) {
                         
+                        case UPDATE_POWER_STATE:
+                                PowerStateName newPowerState = (PowerStateName) resEvent.getData();
+                                powerInterface.setPowerState(newPowerState);
+                                break;
+                                
                         case POWER_STATE_CHANGED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);                      
-                                status = powerProfile.addToPowerUsageHistory(power);
-                                break;
-                                
-                        case FREQUENCY_CHANGED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(resEvent, new JobRegistryImpl(resource.getFullName()), resource);                     
+                                status = powerProfile.addToPowerUsageHistory(power);
+                                break;
+                                
+                        case CPU_FREQUENCY_CHANGED:
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(resEvent, new JobRegistryImpl(resource.getFullName()), resource);
                                 status = powerProfile.addToPowerUsageHistory(power);
                                 break;
                                 
                         case TASK_STARTED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(resEvent, new JobRegistryImpl(resource.getFullName()), resource);
                                 status = powerProfile.addToPowerUsageHistory(power);
                                 break;
         
                         case TASK_FINISHED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
-                                status = powerProfile.addToPowerUsageHistory(power);
-                                break;
-                                
-                        case RESOURCE_UTILIZATION_CHANGED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(resEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                status = powerProfile.addToPowerUsageHistory(power);
+                                break;
+                                
+                        case UTILIZATION_CHANGED:
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(resEvent, new JobRegistryImpl(resource.getFullName()), resource);
                                 status = powerProfile.addToPowerUsageHistory(power);
                                 break;
                                 
                         case AIRFLOW_STATE_CHANGED:
-                                double airflow = powerProfile.getEnergyEstimationPlugin().estimateAirflow(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                double airflow = powerProfile.getEnergyEstimationPlugin().estimateAirflow(resEvent, new JobRegistryImpl(resource.getFullName()), resource);
                                 airflowProfile.addToAirFlowHistory(airflow);
                                 break;
                                 
                         case TEMPERATURE_CHANGED:
-                                double temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                double temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(resEvent, new JobRegistryImpl(resource.getFullName()), resource);
                                 thermalProfile.addToTemperatureHistory(temperature);
                                 break;
@@ -176 +182 @@
                 }
                 if(status){
-                        DataCenterWorkloadSimulator.getEventManager().sendToResources(resource.getType(), 0, new EnergyEvent(EnergyEventType.TEMPERATURE_CHANGED, resource.getFullName()));
+                        DataCenterWorkloadSimulator.getEventManager().sendToResources(resource.getType(), 0, new ResourceEvent(ResourceEventType.TEMPERATURE_CHANGED, resource.getFullName()));
                 }
         }