Changeset 267 for xssim/branches/tpiontek/src/simulator/stats/implementation/GSSimStatistics.java

Timestamp:

04/13/12 09:35:02 (13 years ago)

Author:

wojtekp

Message:

 

File:

• xssim/branches/tpiontek/src/simulator/stats/implementation/GSSimStatistics.java (modified) (6 diffs)

xssim/branches/tpiontek/src/simulator/stats/implementation/GSSimStatistics.java

@@ -99 +99 @@
 
         protected static final String RAW_TASKS_STATISTICS_OUTPUT_FILE_NAME = "Tasks.txt";
+        protected static final String CATEGORY_TASKS_STATISTICS_OUTPUT_FILE_NAME = "TasksCategory.txt";
         protected static final String JOBS_STATISTICS_OUTPUT_FILE_NAME = "Jobs.txt";
 
@@ -982 +983 @@
                 ganttDiagramTaskSeriesCollection = new TaskSeriesCollection();
                 ganttDiagramWaitingTimeSeriesCollection = new TaskSeriesCollection();
+                
+                HashMap<String, List<TaskStats>> cat_taskStats = new HashMap<String, List<TaskStats>>();
+                
 
                 PrintStream taskStatsFile = null;
@@ -992 +996 @@
                 }
 
+                PrintStream taskCategoryStatsFile = null;
+                try {
+                        File file = new File(outputFolderName + STATS_FILE_NAME_PREFIX + simulationIdentifier + "_"
+                                        + CATEGORY_TASKS_STATISTICS_OUTPUT_FILE_NAME);
+                        taskCategoryStatsFile = new PrintStream(new FileOutputStream(file));
+                } catch (IOException e) {
+                        taskCategoryStatsFile = null;
+                }
+                
                 PrintStream jobStatsFile = null;
                 if (configuration.createjobsstatistics) {
@@ -1035 +1048 @@
                                         taskStatsList.add(taskStats);
                                 }
+                                
+                                String taskID = task.getJobId();
+                                Integer taskGroupID = Integer.parseInt(taskID) % 4;
+                                
+                                List<TaskStats> taskCatStatsList= cat_taskStats.get(taskGroupID.toString());
+
+                                if (taskCatStatsList == null) {
+                                        taskCatStatsList = new ArrayList<TaskStats>();
+                                        cat_taskStats.put(taskGroupID.toString(), taskCatStatsList);
+                                }
+                                taskCatStatsList.add(taskStats);
+                                
+
                         }
                         if (configuration.createjobsstatistics && taskStatsList.size() > 0) {
@@ -1047 +1073 @@
                         }
                 }
-
+                
+                for(String catID: cat_taskStats.keySet()){
+                        TaskCategoryStats taskCatStats = createTaskCategoryStats(cat_taskStats.get(catID));
+                        if (taskCategoryStatsFile != null) {
+                                Object txt = taskCatStats.serialize(serializer);
+                                taskCategoryStatsFile.println(txt);
+                        }
+                }
+
+                
                 if (configuration.createsimulationstatistics) {
                         accStats.makespan.add(maxCj);
@@ -1075 +1110 @@
         }
 
+        private TaskCategoryStats createTaskCategoryStats(List<TaskStats> tasksStats) {
+
+                String taskID = ((TaskStats) tasksStats.get(0)).getJobID();
+                String catID = String.valueOf(Integer.parseInt(taskID) % 4);
+                TaskCategoryStats taskCatStats = new TaskCategoryStats(catID);
+                double maxCj = 0;
+
+                for (int i = 0; i < tasksStats.size(); i++) {
+
+                        TaskStats task = (TaskStats) tasksStats.get(i);
+                        taskCatStats.meanTaskStartTime.add(task.getStartTime());
+                        taskCatStats.meanTaskCompletionTime.add(task.getCompletionTime());
+                        maxCj = Math.max(maxCj, task.getCompletionTime());
+                        taskCatStats.meanTaskExecutionTime.add(task.getExecutionTime());
+                        taskCatStats.meanTaskWaitingTime.add(task.getWaitingTime());
+                        taskCatStats.meanTaskFlowTime.add(task.getFlowTime());
+                        taskCatStats.meanTaskGQ_WaitingTime.add(task.getGQ_WaitingTime());
+                        taskCatStats.lateness.add(task.getLateness());
+                        taskCatStats.tardiness.add(task.getTardiness());
+                }
+                taskCatStats.makespan.add(maxCj);
+
+                return taskCatStats;
+        }
+        
         private JobStats createJobStats(List<TaskStats> tasksStats) {