Changeset 805 for DCWoRMS/trunk/src/simulator/stats/implementation/out/StringSerializer.java

Timestamp:

01/28/13 10:18:30 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/src/simulator/stats/implementation/out/StringSerializer.java (modified) (2 diffs)

DCWoRMS/trunk/src/simulator/stats/implementation/out/StringSerializer.java

@@ -14 +14 @@
 import simulator.stats.implementation.ResourcePowerStats;
 import simulator.stats.implementation.ResourceStats;
+import simulator.stats.implementation.ResourceTemperatureStats;
 import simulator.stats.implementation.ResourceUsageStats;
 import simulator.stats.implementation.TaskStats;
@@ -429 +430 @@
                 return buffer.toString();
         }
+        
+        public Object visit(ResourceTemperatureStats resourceTemperatureStats) {
+                Map<Long, Double> resourceTemperature = resourceTemperatureStats.getHistory();
+                
+                int mapSize = resourceTemperature.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 temperature data is to long to fit in the buffer.");
+                        return null;
+                }
+                
+                int size = 30 * resourceTemperature.size();
+                
+                StringBuffer buffer = null;
+
+                if(printedHeaders.add(resourceTemperatureStats.getUsageType())) {
+                        buffer = new StringBuffer(size + 42);
+                        String[] headers = resourceTemperatureStats.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 : resourceTemperature.keySet()) {
+                        
+                        buffer.append(resourceTemperatureStats.getResourceName());
+                        buffer.append(fieldSeparator);
+                        Double value = resourceTemperature.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(resourceTemperature.size() > 0) {
+                        buffer.append("mean: "+resourceTemperatureStats.getMeanValue() + " sum: " +resourceTemperatureStats.getSumValue());
+                        buffer.append(System.getProperty("line.separator"));    
+                }
+
+                return buffer.toString();
+        }
+
 
         public Object visit(GSSAccumulatorsStats accStats) {