source: DCWoRMS/branches/coolemall/src/simulator/stats/AccumulatedStatistics.java @ 1396

package simulator.stats;



import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.PrintStream;
import java.util.ArrayList;
import java.util.List;

import gridsim.Accumulator;


public class AccumulatedStatistics {

        protected static final String ACCUMULATED_SIMULATIONS_STATISTICS_OUTPUT_FILE_NAME = "Stats_Accumulated_Simulations.txt";  
        
        protected List<SimulationStatistics> simulations;

        public AccumulatedStatistics(int noOfSimulations) {
                simulations = new ArrayList<SimulationStatistics>(noOfSimulations);
        }

        public AccumulatedStatistics() {
                simulations = new ArrayList<SimulationStatistics>();
        }

        public void add(SimulationStatistics simulationStatistics) {
                simulations.add(simulationStatistics);
        }

        public void saveStatistics() {          

                SimulationStatistics simulationStatisticsNew = simulations.get(0);

                if(!simulationStatisticsNew.accumulatedStats())
                        return;
                String dirName = simulationStatisticsNew.getOutputFolderName();
                if(dirName == null)
                        return;

                PrintStream out = null;
                try {
                        File file = new File(dirName + ACCUMULATED_SIMULATIONS_STATISTICS_OUTPUT_FILE_NAME);
                        out = new PrintStream(new FileOutputStream(file));
                }  catch (IOException e) {
                        e.printStackTrace();
                }
                
                DCwormsAccumulator resourceLoad = getAccumulatedResourceLoad();
                DCwormsAccumulator reservationLoad = getAccumulatedReservationLoad();
                DCwormsAccumulator makespan = getAccumulatedMakespan();
                DCwormsAccumulator taskExecutionTime = getAccumulatedJobExecutionTime();
                DCwormsAccumulator taskQueueLength = getAccumulatedQueueJobCount();
                DCwormsAccumulator taskCompletionTime = getAccumulatedCompletionTime();
                DCwormsAccumulator taskWaitingTime = getAccumulatedWaitingTime();
                DCwormsAccumulator taskFlowTime = getAccumulatedJobFlowTime();
                DCwormsAccumulator taskLateness = getAccumulatedLateness();
                DCwormsAccumulator delayedTasks = getAccumulatedDelayedTasks();
                DCwormsAccumulator taskTardiness = getAccumulatedTardiness();
                DCwormsAccumulator failedRequests = getAccumulatedFailedRequests();
                
                out.print("Delayed tasks (accumulated)");
                out.println(delayedTasks);
                out.print("Failed requests (accumulated)");
                out.println(failedRequests);
                out.print("Makespan (accumulated)");
                out.println(makespan);          
                out.print("Resources queue length (accumulated)");
                out.println(taskQueueLength);
                out.print("Mean (accumulated) resource load");
                out.println(resourceLoad);              
                out.print("Mean (accumulated) reservation load");
                out.println(reservationLoad);           
                out.print("Task completion time (accumulated)");
                out.println(taskCompletionTime);                
                out.print("Task execution time (accumulated)");
                out.println(taskExecutionTime);         
                out.print("Task flow time (accumulated)");
                out.println(taskFlowTime);
                out.print("Task waiting time (accumulated)");
                out.println(taskWaitingTime);
                out.print("Task lateness (accumulated)");
                out.println(taskLateness);              
                out.print("Task tardiness (accumulated)");
                out.println(taskTardiness);             
                out.println(); 
                out.close();
        }

        public DCwormsAccumulator getAccumulatedResourceLoad() {
                DCwormsAccumulator resourceMeanLoad = new DCwormsAccumulator(); 
                for (SimulationStatistics simStat : simulations) {
                        DCwormsAccumulator simulationResTotalLoad = simStat.getStats(SimulationStatistics.RESOURCES_TOTAL_LOAD); 
                        resourceMeanLoad.add(simulationResTotalLoad.getMean());
                }
                return resourceMeanLoad; 
        }

        public DCwormsAccumulator getAccumulatedReservationLoad(){
                DCwormsAccumulator reservationMean = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations) {
                        Accumulator simulationResvTotalLoad = simStat.getStats(SimulationStatistics.RESOURCES_RESERVATION_LOAD);
                        reservationMean.add(simulationResvTotalLoad.getMean());
                }
                return reservationMean;
        }

        /*public GSSAccumulator getAccumulatedBokrerThroughput() {
                GSSAccumulator meanThroughput = new GSSAccumulator();
                
                for (SimulationStatisticsNew simStat : simulations) {
                        double simulationMeanThroughput = simStat.getBrokerStats().average(Sim_stat.THROUGHPUT);
                        meanThroughput.add(simulationMeanThroughput);
                }
                return meanThroughput;
        }*/

        public DCwormsAccumulator getAccumulatedJobFlowTime() {
                DCwormsAccumulator meanJobFlowTime = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations) {
                        Accumulator simulationJobFlowTime = simStat.getStats(SimulationStatistics.TASK_FLOW_TIME);
                        meanJobFlowTime.add(simulationJobFlowTime.getMean());
                }
                return meanJobFlowTime;
        }

        public DCwormsAccumulator getAccumulatedLateness() {
                DCwormsAccumulator meanLateness = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations) {
                        Accumulator simulationLateness = simStat.getStats(SimulationStatistics.TASK_LATENESS);
                        meanLateness.add(simulationLateness.getMean());
                }
                return meanLateness;
        }

        public DCwormsAccumulator getAccumulatedFailedRequests() {
                DCwormsAccumulator meanFailedRequests = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations) {
                        Accumulator simulationFailedRequestes = simStat.getStats(SimulationStatistics.FAILED_REQUESTS);
                        meanFailedRequests.add(simulationFailedRequestes.getMean());
                }
                return meanFailedRequests;
        }

        public DCwormsAccumulator getAccumulatedTardiness() {
                DCwormsAccumulator meanTardiness = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations) {
                        Accumulator simulationJobTardiness = simStat.getStats(SimulationStatistics.TASK_TARDINESS);
                        meanTardiness.add(simulationJobTardiness.getMean());
                }
                return meanTardiness;
        }

        public DCwormsAccumulator getAccumulatedDelayedTasks() {
                DCwormsAccumulator delayedTasks = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations) {
                        Accumulator simulationDelayedTasks = simStat.getStats(SimulationStatistics.DELAYED_TASKS);
                        delayedTasks.add(simulationDelayedTasks.getMean());
                }
                return delayedTasks;
        }

        public DCwormsAccumulator getAccumulatedCompletionTime() {
                DCwormsAccumulator meanJobCompletionTime = new DCwormsAccumulator();
                
                for (SimulationStatistics simStat : simulations) {
                        Accumulator simulationJobTurnaroundTime = simStat.getStats(SimulationStatistics.TASK_COMPLETION_TIME);
                        meanJobCompletionTime.add(simulationJobTurnaroundTime.getMean());
                }
                return meanJobCompletionTime;
        }

        public DCwormsAccumulator getAccumulatedMakespan() {
                DCwormsAccumulator meanMakespan = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations) {
                        meanMakespan.add(simStat.getStats(SimulationStatistics.MAKESPAN).getMean());
                }
                return meanMakespan;
        }

        public DCwormsAccumulator getAccumulatedWaitingTime() {
                DCwormsAccumulator meanWaitingTime = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations)
                        meanWaitingTime.add(simStat.getStats(SimulationStatistics.TASK_WAITING_TIME).getMean());
                return meanWaitingTime;
        }

        public DCwormsAccumulator getAccumulatedJobExecutionTime() {
                DCwormsAccumulator meanJobExecutionTime = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations)
                        meanJobExecutionTime.add(simStat.getStats(SimulationStatistics.TASK_EXECUTION_TIME).getMean());
                return meanJobExecutionTime;
        }

        public DCwormsAccumulator getAccumulatedQueueJobCount() {
                DCwormsAccumulator meanQueuJobCount = new DCwormsAccumulator();
                for (SimulationStatistics simStat : simulations)
                        meanQueuJobCount.add(simStat.getStats(SimulationStatistics.RESOURCES_QUEUE_LENGTH).getMean());
                return meanQueuJobCount;
        }

}