WorkerPool.h

Go to the documentation of this file.

#ifndef CARMA_CONTROL_WORKERPOOL_H
#define CARMA_CONTROL_WORKERPOOL_H




#include <set>
#include <string>


struct timespec;
struct timeval;


namespace carma {
namespace util {
    class WorkRequest;
}  // namespace carma::util

namespace control {

struct WorkerPoolStats {
    unsigned int frameExceptions;
    unsigned int totalExceptions;

    unsigned int instExecuteCount;
    unsigned int instQueueCount;

    std::string  frameQueueTimeMaxId;
    unsigned int frameQueueCount;
    unsigned int frameQueueTimeMax;
    unsigned int frameQueueTimeMin;
    unsigned int frameQueueTimeAvg;

    std::string  totalQueueTimeMaxId;
    unsigned int totalQueueCount;
    unsigned int totalQueueTimeMax;
    unsigned int totalQueueTimeMin;
    unsigned int totalQueueTimeAvg;

    std::string  frameExecuteTimeMaxId;
    unsigned int frameExecuteCount;
    unsigned int frameExecuteTimeMax;
    unsigned int frameExecuteTimeMin;
    unsigned int frameExecuteTimeAvg;

    std::string  totalExecuteTimeMaxId;
    unsigned int totalExecuteCount;
    unsigned int totalExecuteTimeMax;
    unsigned int totalExecuteTimeMin;
    unsigned int totalExecuteTimeAvg;
};


class WorkerPool {
    public:
        WorkerPool( const ::std::string & id,
                    ::size_t              numWorkers,
                    bool                  logStatsByDefault );
        
        virtual ~WorkerPool( );
        
        void queueRequestGroup(
            const ::std::set< util::WorkRequest > & group );
        
        void queueRequestGroup(
            const ::std::set< util::WorkRequest > & group,
            bool                                    logStats );
        
        void queueRequestGroup(
            const ::std::set< util::WorkRequest > & group,
            struct ::timeval &                      queueTime );

        void queueRequestGroup(
            const ::std::set< util::WorkRequest > & group,
            bool                                    logStats,
            struct ::timeval &                      queueTime );

        void queueRequestGroup(
            const ::std::set< util::WorkRequest > & group,
            struct ::timespec &                     queueTime );

        void queueRequestGroup(
            const ::std::set< util::WorkRequest > & group,
            bool                                    logStats,
            struct ::timespec &                     queueTime );

        void getStatistics(struct WorkerPoolStats &stats);

    private:
        // No copying
        WorkerPool( const WorkerPool & rhs );
        WorkerPool & operator=( const WorkerPool & rhs );
        
        class Impl;
    
        Impl * impl_;
};


}  // namespace carma::control
}  // namespace carma


#endif