Changeset 539 for DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/EnergyExtension.java

Timestamp:

10/31/12 13:52:06 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/EnergyExtension.java (modified) (6 diffs)

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/EnergyExtension.java

@@ -11 +11 @@
 import schedframe.resources.computing.extensions.ExtensionException;
 import schedframe.resources.computing.extensions.ExtensionType;
+import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile;
+import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface;
 import schedframe.resources.computing.profiles.energy.power.PowerProfile;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 import schedframe.scheduling.manager.tasks.JobRegistryImpl;
 
-public class EnergyExtension implements Extension/*, ResourceVisitor */{
+public class EnergyExtension implements Extension{
 
         private Log log = LogFactory.getLog(EnergyExtension.class);
@@ -21 +23 @@
         protected PowerInterface powerInterface;
         protected PowerProfile powerProfile;
-
+        
+        protected AirThroughputInterface airFlowInterface;
+        protected AirThroughputProfile airFlowProfile;
+        
         protected ComputingResource computingResource;
 
@@ -29 +34 @@
         }
 
-        @Override
+        public EnergyExtension(PowerInterface powerInterface, PowerProfile powerProfile,
+                        AirThroughputInterface airFlowInterface, AirThroughputProfile airFlowProfile) {
+                super();
+                this.powerInterface = powerInterface;
+                this.powerProfile = powerProfile;
+                this.airFlowInterface = airFlowInterface;
+                this.airFlowProfile = airFlowProfile;
+        }
+
         public boolean supportsEvent(Event event) {
 
                 if(powerProfile == null || powerProfile.getEnergyEstimationPlugin() == null)
                         return false;
-                
                 if(event.getType().getName().equals(EnergyEventType.POWER_STATE_CHANGED.getName()))
                         return true;
@@ -43 +55 @@
                 else if(event.getType().getName().equals(EnergyEventType.TASK_FINISHED.getName()))
                         return true;
+                
+                if(airFlowProfile == null)
+                        return false;   
+                if(event.getType().getName().equals(EnergyEventType.AIRFLOW_STATE_CHANGED.getName()))
+                        return true;
+                
                 else return false;
 
         }
-        
 
-        @Override
         public void handleEvent(Event event) {
                 EnergyEvent enEvent = (EnergyEvent)event;
@@ -87 +103 @@
                         //System.out.println(this.resource.getName() + " - ESTIMATED ENERGY:" + power);
                         powerProfile.addToPowerUsageHistory(power);
-
+                        break;
+                case AIRFLOW_STATE_CHANGED:
+                        System.out.println("=====");
+                        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);
                         break;
                 }
         }
-        
-        @Override
+
         public void init(Properties properties) throws ExtensionException {
                 // TODO Auto-generated method stub
         }
 
-        @Override
         public ExtensionType getType() {
                 return ExtensionType.ENERGY_EXTENSION;
@@ -118 +138 @@
         }
 
+        public AirThroughputInterface getAirThroughputInterface() {
+                return airFlowInterface;
+        }
+
+        public AirThroughputProfile getAirFlowProfile() {
+                return airFlowProfile;
+        }
 
 }