Changeset 539 for DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/airthroughput

Timestamp:

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

Author:

wojtekp

Message:

 

Location:

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/airthroughput

Files:

• AirFlowValue.class (added)
• AirFlowValue.java (added)
• AirThroughputInterfaceFactory.class (added)
• AirThroughputInterfaceFactory.java (added)
• AirThroughputProfile.class (modified) (previous)
• AirThroughputProfile.java (modified) (4 diffs)
• ui (added)
• ui/AirThroughputInterface.class (added)
• ui/AirThroughputInterface.java (added)
• ui/DefaultAirThroughputInterface.class (added)
• ui/DefaultAirThroughputInterface.java (added)

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

@@ -1 +1 @@
 package schedframe.resources.computing.profiles.energy.airthroughput;
 
+import java.util.ArrayList;
 import java.util.List;
+
+import org.joda.time.DateTimeUtils;
 
 import schedframe.Parameters;
@@ -8 +11 @@
 public class AirThroughputProfile {
         
-        AirThroughputEstimationPlugin airThroughputEstimationPlugin;
+        protected List<AirFlowValue> airFlowHistory;
+        
+        protected AirThroughputEstimationPlugin airThroughputEstimationPlugin;
         protected List <AirThroughputState> airThroughputStates;
+        protected Parameters parameters;
 
         public AirThroughputProfile(AirThroughputEstimationPlugin airThroughputEstimationPlugin, List<AirThroughputState> airThroughputStates) {
@@ -15 +21 @@
                 this.airThroughputEstimationPlugin = airThroughputEstimationPlugin;
                 this.airThroughputStates = airThroughputStates;
+                this.airFlowHistory = new ArrayList<AirFlowValue>();
         }
 
@@ -21 +28 @@
         }
         
-        public void init(Parameters parameters){
-                
+        public void addToPowerUsageHistory(double airFlow) {
+
+                if (airFlowHistory.size() == 0) {
+                        AirFlowValue usage = new AirFlowValue(DateTimeUtils.currentTimeMillis(), airFlow);
+                        airFlowHistory.add(usage);
+                        return;
+                }
+
+                int lastIdx = airFlowHistory.size() - 1;
+                double lastAirFlow = airFlowHistory.get(lastIdx).getValue();
+                if (lastAirFlow != airFlow) {
+                        AirFlowValue usage = airFlowHistory.get(lastIdx);
+                        long currentTime = DateTimeUtils.currentTimeMillis();
+                        if (usage.getTimestamp() == currentTime) {
+                                usage.setValue(airFlow);
+                                if(lastIdx > 0 && airFlowHistory.get(lastIdx - 1).getValue() == airFlow)
+                                        airFlowHistory.remove(usage);
+                        } else {
+                                usage = new AirFlowValue(DateTimeUtils.currentTimeMillis(), airFlow);
+                                airFlowHistory.add(usage);
+                        }
+                }
+        }
+
+        public List<AirFlowValue> getAirThroughputHistory() {
+                return airFlowHistory;
+        }
+        
+        public void init(Parameters params){
+                this.parameters = params;
+        }
+
+        public Parameters getParameters() {
+                return parameters;
         }
 }