Changeset 1207 for DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput

Timestamp:

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

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/airthroughput

Files:

• AirThroughputInterfaceFactory.java (modified) (1 diff)
• AirThroughputProfile.java (modified) (1 diff)
• StandardAirThroughputStateName.java (modified) (1 diff)
• ui/AirThroughputInterface.java (modified) (3 diffs)
• ui/ComputingResourceAirThroughputInterface.java (modified) (4 diffs)

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

@@ -1 +1 @@
 package schedframe.resources.computing.profiles.energy.airthroughput;
 
+import schedframe.resources.StandardResourceType;
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface;
 import schedframe.resources.computing.profiles.energy.airthroughput.ui.ComputingResourceAirThroughputInterface;
+import schedframe.resources.devices.PhysicalResource;
+import schedframe.resources.devices.PhysicalResourceAirThroughputInterface;
+import schedframe.resources.devices.coolemall.FanAirThroughputInterface;
 
 public class AirThroughputInterfaceFactory {
         
-        public static AirThroughputInterface createAirThroughputInterface(ComputingResource resource, AirThroughputProfile atp){
+        public static AirThroughputInterface createAirThroughputInterface(PhysicalResource resource, AirThroughputProfile atp){
                 if(atp == null)
                         return null;
-                AirThroughputInterface airThroughputInterface = new ComputingResourceAirThroughputInterface(resource, atp);
-
+                AirThroughputInterface airThroughputInterface = null;
+                if(resource.getType().getName().equals(StandardResourceType.CRAH.getName()))
+                        airThroughputInterface = new PhysicalResourceAirThroughputInterface(resource, atp);
+                else if(resource.getType().getName().equals(StandardResourceType.Fan.getName()))
+                        airThroughputInterface = new FanAirThroughputInterface(resource, atp);
+                else if(resource.getType().getName().equals(StandardResourceType.Inlet.getName()))
+                        airThroughputInterface = new FanAirThroughputInterface(resource, atp);
+                else if(resource.getType().getName().equals(StandardResourceType.Outlet.getName()))
+                        airThroughputInterface = new FanAirThroughputInterface(resource, atp);
+                else if(resource.getType().getName().equals(StandardResourceType.CoolingDevice.getName()))
+                        airThroughputInterface = new PhysicalResourceAirThroughputInterface(resource, atp);
+                else
+                        airThroughputInterface = new ComputingResourceAirThroughputInterface((ComputingResource)resource, atp);
                 return airThroughputInterface;
         }

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

@@ -28 +28 @@
         }
         
-        public void addToPowerUsageHistory(double airFlow) {
+        public void addToAirFlowHistory(double airFlow) {
 
                 if (airFlowHistory.size() == 0) {

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

@@ -3 +3 @@
 public enum  StandardAirThroughputStateName implements AirThroughputStateName{
 
-        FAN_ON,
-        FAN_OFF;
+        ON,
+        OFF;
 
         public String getName() {

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

@@ -4 +4 @@
 
 import schedframe.Parameters;
+import schedframe.resources.computing.profiles.energy.airthroughput.AirFlowValue;
 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputState;
 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputStateName;
@@ -9 +10 @@
 public interface AirThroughputInterface {
         
-        public AirThroughputStateName  getAirThroughputState();
+        public AirThroughputStateName getAirThroughputState();
         
         public boolean setAirThroughputState(AirThroughputStateName airThroughputState);
@@ -21 +22 @@
         public double getPowerConsumption(AirThroughputStateName state) throws NoSuchFieldException;
         
+        public AirFlowValue getRecentAirFlow();
+        
+        List<AirFlowValue> getAirFlowHistory();
+        
         public Parameters getParameters();
+        
+        
 }

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

@@ -4 +4 @@
 import java.util.List;
 
+import org.joda.time.DateTimeUtils;
+
 import schedframe.Parameters;
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.profiles.energy.EnergyEvent;
 import schedframe.resources.computing.profiles.energy.EnergyEventType;
+import schedframe.resources.computing.profiles.energy.airthroughput.AirFlowValue;
 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile;
 import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputState;
@@ -22 +25 @@
                 this.resource = resource;
                 this.airThroughputProfile = airThroughputProfile;
-                this.currentAirThroughputState = StandardAirThroughputStateName.FAN_ON;
+                this.currentAirThroughputState = StandardAirThroughputStateName.ON;
         }
         
@@ -34 +37 @@
                         
                         //TO DO - notifications should be called for all resources starting form the lowest layer
-                        resource.handleEvent(new EnergyEvent(EnergyEventType.AIRFLOW_STATE_CHANGED, resource.getName()));
+                        resource.handleEvent(new EnergyEvent(EnergyEventType.AIRFLOW_STATE_CHANGED, resource.getFullName()));
+                        resource.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, resource.getFullName()));
                         return true;
                 }
@@ -83 +87 @@
         }
         
+        public AirFlowValue getRecentAirFlow() {
+                AirFlowValue airFlow = null;
+                int lastIdx = getAirFlowHistory().size() - 1;
+                if(lastIdx >= 0)
+                        airFlow = getAirFlowHistory().get(lastIdx);
+                else {  
+                        try {
+                                airFlow = new AirFlowValue(DateTimeUtils.currentTimeMillis(), getAirFlow(currentAirThroughputState));
+                        } catch (NoSuchFieldException e) {
+                        }
+                }
+                return airFlow;
+        }
+        
+        public List<AirFlowValue> getAirFlowHistory(){
+                return airThroughputProfile.getAirThroughputHistory();
+        }
+        
+        
         public Parameters getParameters() {
                 return airThroughputProfile.getParameters();