Changeset 495 for DCWoRMS/trunk/src/simulator/stats/implementation/out

Timestamp:

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

Author:

wojtekp

Message:

 

Location:

DCWoRMS/trunk/src/simulator/stats/implementation/out

Files:

• FormatedStringSerializer.java (deleted)
• StatsSerializer.java (modified) (2 diffs)
• StringSerializer.java (modified) (4 diffs)

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

@@ -4 +4 @@
 import simulator.stats.implementation.GSSAccumulatorsStats;
 import simulator.stats.implementation.JobStats;
+import simulator.stats.implementation.ResourceAirFlowStats;
 import simulator.stats.implementation.ResourceEnergyStats;
 import simulator.stats.implementation.ResourceStats;
@@ -28 +29 @@
         public Object visit(ResourceEnergyStats arg);
 
+        public Object visit(ResourceAirFlowStats arg);
         
         public Object visit(GSSAccumulatorsStats arg);

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

@@ -11 +11 @@
 import simulator.stats.implementation.GSSAccumulatorsStats;
 import simulator.stats.implementation.JobStats;
+import simulator.stats.implementation.ResourceAirFlowStats;
 import simulator.stats.implementation.ResourceEnergyStats;
 import simulator.stats.implementation.ResourceStats;
@@ -258 +259 @@
 
         public Object visit(ResourceUsageStats resourceUsageStats) {
-                Map<Long, Integer> resourceUsage = resourceUsageStats.getUsage();
+                Map<Long, Double> resourceUsage = resourceUsageStats.getUsage();
                 
                 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);
@@ -371 +372 @@
         }
 
+        public Object visit(ResourceAirFlowStats resourceAirFlowStats) {
+                Map<Long, Double> resourceAirFlow = resourceAirFlowStats.getAirFlow();
+                
+                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.getMeanUsage() + " sum: " +resourceAirFlowStats.getSumUsage());
+                        buffer.append(System.getProperty("line.separator"));    
+                }
+
+                return buffer.toString();
+        }
+
         public Object visit(GSSAccumulatorsStats accStats) {