Changeset 229 for xssim/trunk/src/simulator/stats/implementation/GSSimStatistics.java

Timestamp:

04/06/12 11:05:53 (13 years ago)

Author:

wojtekp

Message:

 

File:

• xssim/trunk/src/simulator/stats/implementation/GSSimStatistics.java (modified) (4 diffs)

xssim/trunk/src/simulator/stats/implementation/GSSimStatistics.java

@@ -65 +65 @@
 import simulator.GenericUser;
 import simulator.GridSchedulingSimulator;
+import simulator.stats.GSSAccumulator;
 import simulator.stats.SimulationStatistics;
 import simulator.stats.implementation.out.AbstractStringSerializer;
@@ -77 +78 @@
 import test.rewolucja.resources.exception.ResourceException;
 import test.rewolucja.resources.physical.base.ComputingResource;
+import test.rewolucja.resources.physical.implementation.ComputingNode;
+import test.rewolucja.resources.physical.implementation.Processor;
 import test.rewolucja.resources.utils.ResourceController;
 import test.rewolucja.scheduling.JobRegistry;
@@ -313 +316 @@
                         }
                         if(type_stats.containsKey(resType)){
+                                Map<String, GSSAccumulator> energyCategoryStats = new TreeMap<String, GSSAccumulator>();
+                                Map<String, GSSAccumulator> loadCategoryStats = new TreeMap<String, GSSAccumulator>();
                                 for(ComputingResource resource: resources){
                                         ResourceUsageStats resourceUsage = null;
@@ -344 +349 @@
                                                 }
                                         }
-                                }
+                                        
+                                        
+                                        if(resType == ResourceType.COMPUTING_NODE){
+                                                ComputingNode compNode = (ComputingNode) resource;
+                                                if(energyCategoryStats.containsKey(resType+"#"+compNode.getCategory().getName())){
+                                                        GSSAccumulator acc = energyCategoryStats.get(resType+"#"+compNode.getCategory().getName());
+                                                        acc.add(energyUsage.meanUsage);
+                                                        energyCategoryStats.put(resType+"#"+compNode.getCategory().getName(), acc);
+                                                } else{
+                                                        GSSAccumulator acc = new GSSAccumulator();
+                                                        acc.add(energyUsage.meanUsage);
+                                                        energyCategoryStats.put(resType+"#"+compNode.getCategory().getName(), acc);
+                                                }
+                                                
+                                                if(loadCategoryStats.containsKey(resType+"#"+compNode.getCategory().getName())){
+                                                        GSSAccumulator acc = loadCategoryStats.get(resType+"#"+compNode.getCategory().getName());
+                                                        acc.add(resourceUsage.meanUsage);
+                                                        loadCategoryStats.put(resType+"#"+compNode.getCategory().getName(), acc);
+                                                } else{
+                                                        GSSAccumulator acc = new GSSAccumulator();
+                                                        acc.add(resourceUsage.meanUsage);
+                                                        loadCategoryStats.put(resType+"#"+compNode.getCategory().getName(), acc);
+                                                }
+                                        } else if(resType == ResourceType.CPU){
+                                                Processor proc = (Processor)resource;
+                                                if(energyCategoryStats.containsKey(resType+"#"+proc.getComputingNode().getCategory().getName())){
+                                                        GSSAccumulator acc = energyCategoryStats.get(resType+"#"+proc.getComputingNode().getCategory().getName());
+                                                        acc.add(energyUsage.meanUsage);
+                                                        energyCategoryStats.put(resType+"#"+proc.getComputingNode().getCategory().getName(), acc);
+                                                } else{
+                                                        GSSAccumulator acc = new GSSAccumulator();
+                                                        acc.add(energyUsage.meanUsage);
+                                                        energyCategoryStats.put(resType+"#"+proc.getComputingNode().getCategory().getName(), acc);
+                                                }
+                                                
+                                                if(loadCategoryStats.containsKey(resType+"#"+proc.getComputingNode().getCategory().getName())){
+                                                        GSSAccumulator acc = loadCategoryStats.get(resType+"#"+proc.getComputingNode().getCategory().getName());
+                                                        acc.add(resourceUsage.meanUsage);
+                                                        loadCategoryStats.put(resType+"#"+proc.getComputingNode().getCategory().getName(), acc);
+                                                } else{
+                                                        GSSAccumulator acc = new GSSAccumulator();
+                                                        acc.add(resourceUsage.meanUsage);
+                                                        loadCategoryStats.put(resType+"#"+proc.getComputingNode().getCategory().getName(), acc);
+                                                }
+                                        }
+                                }
+                                
+                                if(energyCategoryStats.size()>0)
+                                {
+                                        energyStatsFile.println("\n=========BY CATEGORY===========");
+                                        for(String key: energyCategoryStats.keySet()){
+                                                GSSAccumulator acc = energyCategoryStats.get(key);
+                                                energyStatsFile.println(key + "- mean: "  +acc.getMean()+ " sum: " +acc.getMean()*(endSimulationTime-startSimulationTime)/(3600*1000)*acc.getCount());
+                                        }
+                                        energyStatsFile.println("\n\n");
+                                }
+                                
+                                if(loadCategoryStats.size()>0)
+                                {
+                                        resourceLoadStatsFile.println("\n=========BY CATEGORY===========");
+                                        for(String key: loadCategoryStats.keySet()){
+                                                GSSAccumulator acc = loadCategoryStats.get(key);
+                                                resourceLoadStatsFile.println(key + "- mean: "  +acc.getMean());
+                                        }
+                                        resourceLoadStatsFile.println("\n\n");
+                                }
+
                         }
                 }