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

Timestamp:

11/26/13 11:56:07 (11 years ago)

Author:

wojtekp

Message:

 

File:

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

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

@@ -7 +7 @@
 
 import schedframe.events.Event;
-import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.extensions.Extension;
 import schedframe.resources.computing.extensions.ExtensionException;
@@ -20 +19 @@
 import schedframe.resources.computing.profiles.energy.thermal.ThermalProfile;
 import schedframe.resources.computing.profiles.energy.thermal.ui.ThermalInterface;
+import schedframe.resources.devices.PhysicalResource;
 import schedframe.scheduling.manager.tasks.JobRegistryImpl;
+import simulator.DataCenterWorkloadSimulator;
 
 public class EnergyExtension implements Extension{
@@ -35 +36 @@
         protected ThermalProfile thermalProfile;
         
-        protected ComputingResource computingResource;
-
-
-        public EnergyExtension(ComputingResource computingResource, PowerInterface powerInterface, PowerProfile powerProfile) {
+        protected PhysicalResource resource;
+
+
+        /*public EnergyExtension(PhysicalResource resource, PowerInterface powerInterface, PowerProfile powerProfile) {
+                super();
+                this.resource = resource;
                 this.powerProfile = powerProfile;
-                this.powerInterface = PowerInterfaceFactory.createPowerInterface(computingResource, powerProfile);
-        }
-        
-        public EnergyExtension(ComputingResource computingResource, PowerProfile powerProfile,
+                this.powerInterface = PowerInterfaceFactory.createPowerInterface(resource, powerProfile);
+        }
+        
+        public EnergyExtension(PhysicalResource resource, PowerProfile powerProfile,
                         AirThroughputProfile airFlowProfile) {
                 super();
-                this.computingResource = computingResource;
+                this.resource = resource;
                 this.powerProfile = powerProfile;
-                this.powerInterface = PowerInterfaceFactory.createPowerInterface(computingResource, powerProfile);
+                this.powerInterface = PowerInterfaceFactory.createPowerInterface(resource, powerProfile);
                 this.airFlowProfile = airFlowProfile;
-                this.airFlowInterface = AirThroughputInterfaceFactory.createAirThroughputInterface(computingResource, airFlowProfile);
-        }
-        
-        public EnergyExtension(ComputingResource computingResource, PowerProfile powerProfile,
+                this.airFlowInterface = AirThroughputInterfaceFactory.createAirThroughputInterface(resource, airFlowProfile);
+        }
+        
+        public EnergyExtension(PhysicalResource resource, PowerProfile powerProfile,
                         AirThroughputProfile airFlowProfile, ThermalProfile thermalProfile) {
                 super();
-                this.computingResource = computingResource;
+                this.resource = resource;
                 this.powerProfile = powerProfile;
-                this.powerInterface = PowerInterfaceFactory.createPowerInterface(computingResource, powerProfile);
+                this.powerInterface = PowerInterfaceFactory.createPowerInterface(resource, powerProfile);
                 this.airFlowProfile = airFlowProfile;
-                this.airFlowInterface = AirThroughputInterfaceFactory.createAirThroughputInterface(computingResource, airFlowProfile);
+                this.airFlowInterface = AirThroughputInterfaceFactory.createAirThroughputInterface(resource, airFlowProfile);
                 this.thermalProfile = thermalProfile;
-                this.thermalInterface = ThermalInterfaceFactory.createThermalInterface(computingResource, thermalProfile);
-        }
-
+                this.thermalInterface = ThermalInterfaceFactory.createThermalInterface(resource, thermalProfile);
+        }*/
+
+        public static class Builder {
+                  
+                protected PhysicalResource resource;
+                protected PowerInterface powerInterface;
+                protected PowerProfile powerProfile;
+                
+                protected AirThroughputInterface airFlowInterface;
+                protected AirThroughputProfile airFlowProfile;
+                
+                protected ThermalInterface thermalInterface;
+                protected ThermalProfile thermalProfile;
+                
+                public Builder resource(PhysicalResource res) {this.resource = res; return this;}
+                
+                public Builder powerProfile(PowerProfile pp){this.powerProfile = pp; this.powerInterface = PowerInterfaceFactory.createPowerInterface(resource, powerProfile); return this; }
+
+        public Builder airFlowProfile(AirThroughputProfile atp){this.airFlowProfile = atp; this.airFlowInterface = AirThroughputInterfaceFactory.createAirThroughputInterface(resource, airFlowProfile); return this; }
+
+        public Builder thermalProfile(ThermalProfile tp){this.thermalProfile = tp; this.thermalInterface = ThermalInterfaceFactory.createThermalInterface(resource, thermalProfile); return this; }
+
+        public EnergyExtension build() {
+            return new EnergyExtension(this);
+        }
+        }
+        
+        private EnergyExtension(Builder builder) {
+                this.resource = builder.resource;
+                this.powerInterface = builder.powerInterface;
+                this.powerProfile = builder.powerProfile;
+                
+                this.airFlowInterface = builder.airFlowInterface ;
+                this.airFlowProfile = builder.airFlowProfile;
+                
+                this.thermalInterface = builder.thermalInterface;
+                this.thermalProfile = builder.thermalProfile;
+        }
+
+        
         public boolean supportsEvent(Event event) {
 
@@ -82 +123 @@
                 if(event.getType().getName().equals(EnergyEventType.AIRFLOW_STATE_CHANGED.getName()))
                         return true;
+                if(event.getType().getName().equals(EnergyEventType.TEMPERATURE_CHANGED.getName()))
+                        return true;
                 
                 else return false;
@@ -90 +133 @@
                 EnergyEvent enEvent = (EnergyEvent)event;
                 double power = 0;
-                double temperature = 0;
+                boolean status = false;
                 try{
                         switch (enEvent.getType()) {
                         
                         case POWER_STATE_CHANGED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
                                 /*if(computingResource instanceof ComputingNode){
                                         ComputingNode node = (ComputingNode)computingResource;
@@ -109 +152 @@
                                         }
                                 }
-                                else*/ powerProfile.addToPowerUsageHistory(power);
-                                temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                thermalProfile.addToTemperatureHistory(temperature);
+                                else*/ 
+                                
+                                status = powerProfile.addToPowerUsageHistory(power);
                                 break;
                                 
                         case FREQUENCY_CHANGED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                powerProfile.addToPowerUsageHistory(power);
-                                temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                thermalProfile.addToTemperatureHistory(temperature);
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                status = powerProfile.addToPowerUsageHistory(power);
                                 break;
                                 
                         case TASK_STARTED:
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                powerProfile.addToPowerUsageHistory(power);
-                                temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                thermalProfile.addToTemperatureHistory(temperature);
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                status = powerProfile.addToPowerUsageHistory(power);
                                 break;
         
                         case TASK_FINISHED:
-                                //System.out.println(this.resource.getName() + " - ENERGY EXTENSION: TASK FINISHED");
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                //System.out.println(this.resource.getName() + " - ESTIMATED ENERGY:" + power);
-                                powerProfile.addToPowerUsageHistory(power);
-                                temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                thermalProfile.addToTemperatureHistory(temperature);
+                                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(computingResource.getName()), computingResource);
-                                powerProfile.addToPowerUsageHistory(power);
-                                temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                thermalProfile.addToTemperatureHistory(temperature);
+                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                status = powerProfile.addToPowerUsageHistory(power);
                                 break;
                                 
                         case AIRFLOW_STATE_CHANGED:
-                                double airFlow = powerProfile.getEnergyEstimationPlugin().estimateAirThroughput(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                airFlowProfile.addToPowerUsageHistory(airFlow);
-                                power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
-                                powerProfile.addToPowerUsageHistory(power);
-                                temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
+                                double airFlow = powerProfile.getEnergyEstimationPlugin().estimateAirThroughput(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
+                                airFlowProfile.addToAirFlowHistory(airFlow);
+                                break;
+                                
+                        case TEMPERATURE_CHANGED:
+                                double temperature = powerProfile.getEnergyEstimationPlugin().estimateTemperature(enEvent, new JobRegistryImpl(resource.getFullName()), resource);
                                 thermalProfile.addToTemperatureHistory(temperature);
                                 break;
@@ -156 +190 @@
                         
                 }
+                if(status){
+                        DataCenterWorkloadSimulator.getEventManager().sendToResources(resource.getType(), 0, new EnergyEvent(EnergyEventType.TEMPERATURE_CHANGED, resource.getFullName()));
+                }
         }