Changeset 539 for DCWoRMS/trunk/build/classes/simulator/stats/implementation/out/StringSerializer.java

Timestamp:

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

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/build/classes/simulator/stats/implementation/out/StringSerializer.java (modified) (5 diffs)

DCWoRMS/trunk/build/classes/simulator/stats/implementation/out/StringSerializer.java

@@ -11 +11 @@
 import simulator.stats.implementation.GSSAccumulatorsStats;
 import simulator.stats.implementation.JobStats;
-import simulator.stats.implementation.ResourceEnergyStats;
+import simulator.stats.implementation.ResourceAirFlowStats;
+import simulator.stats.implementation.ResourcePowerStats;
 import simulator.stats.implementation.ResourceStats;
 import simulator.stats.implementation.ResourceUsageStats;
@@ -258 +259 @@
 
         public Object visit(ResourceUsageStats resourceUsageStats) {
-                Map<Long, Integer> resourceUsage = resourceUsageStats.getUsage();
+                Map<Long, Double> resourceUsage = resourceUsageStats.getHistory();
                 
                 int mapSize = resourceUsage.size();
@@ -297 +298 @@
                         buffer.append(resourceUsageStats.getResourceName());
                         buffer.append(fieldSeparator);
-                        Integer value = resourceUsage.get(timestamp);
+                        Double value = resourceUsage.get(timestamp);
                         buffer.append(timestamp);
                         buffer.append(fieldSeparator);
@@ -306 +307 @@
 
                 }
-
-                buffer.append("mean: " + resourceUsageStats.getMeanUsage());
-                buffer.append(System.getProperty("line.separator"));
-                return buffer.toString();
-        }
-
-        public Object visit(ResourceEnergyStats resourceEnergyStats) {
-                Map<Long, Double> resourceEnergy = resourceEnergyStats.getEnergy();
+                if(resourceUsage.size() > 0){
+                        buffer.append("mean: " + resourceUsageStats.getMeanValue());
+                        buffer.append(System.getProperty("line.separator"));    
+                }
+                return buffer.toString();
+        }
+
+        public Object visit(ResourcePowerStats resourceEnergyStats) {
+                Map<Long, Double> resourceEnergy = resourceEnergyStats.getHistory();
                 
                 int mapSize = resourceEnergy.size();
@@ -361 +363 @@
 
                 }
-                buffer.append("mean: "+resourceEnergyStats.getMeanUsage() + " sum: " +resourceEnergyStats.getSumUsage());
-                buffer.append(System.getProperty("line.separator"));
+                
+                if(resourceEnergy.size() > 0) {
+                        buffer.append("mean: "+resourceEnergyStats.getMeanValue() + " sum: " +resourceEnergyStats.getSumValue());
+                        buffer.append(System.getProperty("line.separator"));    
+                }
+
+                return buffer.toString();
+        }
+
+        public Object visit(ResourceAirFlowStats resourceAirFlowStats) {
+                Map<Long, Double> resourceAirFlow = resourceAirFlowStats.getHistory();
+                
+                int mapSize = resourceAirFlow.size();
+                /*
+                 * FIXME:
+                 * Integer.MAX_VALUE = 2147483647. We assume, that each line contains 
+                 * max 30 signs - this gives max 71582788 lines. If resourceUsage map
+                 * contains more elements then we have a problem, because content of
+                 * resourceUsage map will not fit in the buffer.
+                 * This will need further attention in the future.
+                 */
+                int maxSize = (Integer.MAX_VALUE / 30 ) - 1;
+                if(mapSize >= maxSize){
+                        log.error("Resource usage data is to long to fit in the buffer.");
+                        return null;
+                }
+                
+                int size = 30 * resourceAirFlow.size();
+                
+                StringBuffer buffer = null;
+
+                if(printedHeaders.add(resourceAirFlowStats.getUsageType())) {
+                        buffer = new StringBuffer(size + 42);
+                        String[] headers = resourceAirFlowStats.getHeaders();
+                        for(int i = 0; i < headers.length; i++)
+                        {
+                                buffer.append(headers[i]);
+                                buffer.append(fieldSeparator);
+                        }
+                        buffer.append(System.getProperty("line.separator"));
+                } else {
+                        buffer = new StringBuffer(size);
+                }
+                
+                
+                for (Long timestamp : resourceAirFlow.keySet()) {
+                        
+                        buffer.append(resourceAirFlowStats.getResourceName());
+                        buffer.append(fieldSeparator);
+                        Double value = resourceAirFlow.get(timestamp);
+                        buffer.append(timestamp);
+                        buffer.append(fieldSeparator);
+                        buffer.append(DataCenterWorkloadSimulator.DFAULT_NUMBER_FORMAT
+                                        .format(value));
+                        buffer.append(fieldSeparator);
+                        buffer.append(System.getProperty("line.separator"));
+
+                }
+                
+                if(resourceAirFlow.size() > 0) {
+                        buffer.append("mean: "+resourceAirFlowStats.getMeanValue() + " sum: " +resourceAirFlowStats.getSumValue());
+                        buffer.append(System.getProperty("line.separator"));    
+                }
 
                 return buffer.toString();