/home/sebastian/gpudbms/trunk/hype-library/include/core/workload_generator.hpp

Go to the documentation of this file.

/***********************************************************************************************************
Copyright (c) 2012, Sebastian Breß, Otto-von-Guericke University of Magdeburg, Germany. All rights reserved.

This program and accompanying materials are made available under the terms of the 
GNU LESSER GENERAL PUBLIC LICENSE - Version 3, http://www.gnu.org/licenses/lgpl-3.0.txt
***********************************************************************************************************/

#pragma once

//#include <iostream>
#include <fstream>
#include <string>
#include <vector>
//#include <numeric>

/*#include <boost/circular_buffer.hpp>
#include <boost/tokenizer.hpp>
#include <boost/filesystem.hpp>
#include <boost/lexical_cast.hpp>

#include <core/operation.hpp>
#include <core/time_measurement.hpp>

#include <core/plotscriptgenerator.hpp>
#include <core/scheduler.hpp>*/
#include <core/measurementpair.hpp>
#include <core/offline_algorithm.hpp>
#include <config/exports.hpp>

/* temporarily disable warnings because of missing STL DLL interface */
#ifdef _MSC_VER
#  pragma warning(push)
#  pragma warning(disable: 4251)
#endif

namespace hype{
        namespace core{

unsigned int& getWorkloadID(); 

class StatisticsGatherer;

class HYPE_EXPORT WorkloadGenerator{
        public:
        friend class StatisticsGatherer;
        
        WorkloadGenerator(const std::string& operation_name);
        
        ~WorkloadGenerator();

        bool addOffline_Algorithm(const Offline_Algorithm& meas_pair_prov);
        
        void run();

        void nextIteration();

        void shuffleWorkload();

        void reset();
                
        private:
        std::string operation_name_;
        unsigned int number_of_right_decisions_;
        unsigned int number_of_total_decisions_;
        std::vector <Offline_Algorithm> offline_algorithms;
        std::vector<double> isolated_execution_time_of_algorithms_;
        std::fstream logfile;
        //reference models
        double execution_time_of_ideal_model_;
        double execution_time_of_cpu_only_model_;
        double execution_time_of_gpu_only_model_;
   //for real model
        double execution_time_of_real_model_;
        double total_time_for_overhead_of_addObservation_;
        double total_time_for_overhead_of_getOptimalAlgorithm_;
        std::vector<MeasurementPair> execution_history_; 
        //Feature: inter device parallelism
        double inter_device_parallel_time_cpu_;
        double inter_device_parallel_time_gpu_;                 
};

        }; //end namespace core
}; //end namespace hype

#ifdef _MSC_VER
#  pragma warning(pop)
#endif