AverageAccumulator.h

Go to the documentation of this file.

/*
 * AverageAccumulator.h - Class definition for accumulating monitor point
 * values of various types.
 */

#ifndef        CARMA_MONITOR_AVERAGE_ACCUMULATOR_H
#define        CARMA_MONITOR_AVERAGE_ACCUMULATOR_H

#include <map>

#include "carma/monitor/MonitorSystem.h"
#include "carma/monitor/TypedAverageAccumulatorT.h"
#include "carma/dbms/dbFFIO.h"


namespace carma {
namespace monitor {


typedef TypedAverageAccumulatorT< MonitorPointChar, double > CharAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointByte, double > ByteAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointShort, double > ShortAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointInt, double > IntAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointBool, long > BoolAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointEnum, int > EnumAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointFloat, double > FloatAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointDouble, double > DoubleAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointComplex, ::std::complex< float > > ComplexAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointAbstime, double > AbstimeAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointString, ::std::string > StringAccumulator;
typedef TypedAverageAccumulatorT< MonitorPointSerialNo, long > SerialNoAccumulator;


typedef enum {
    MONITOR_DB_TYPE_NUMERIC,
    MONITOR_DB_TYPE_SHORT,
    MONITOR_DB_TYPE_STRING,
    MONITOR_DB_TYPE_COMPLEX,
    // Always last
    MONITOR_DB_TYPE_NUM_TYPES
} DBwriteType;


class AverageAccumulator {
  private:
    // frameCount when last accumulate() was performed.
    long              frameCount_;
    MonitorSystem&    monitorSystem_;

    CharAccumulator&  aveCharAccumulator_;
    ByteAccumulator&  aveByteAccumulator_;
    ShortAccumulator& aveShortAccumulator_;
    IntAccumulator&   aveIntAccumulator_;
    BoolAccumulator&  aveBoolAccumulator_;
    EnumAccumulator&  aveEnumAccumulator_;
    FloatAccumulator& aveFloatAccumulator_;
    DoubleAccumulator& aveDoubleAccumulator_;
    ComplexAccumulator& aveComplexAccumulator_;
    AbstimeAccumulator& aveAbstimeAccumulator_;
    StringAccumulator& aveStringAccumulator_;
    SerialNoAccumulator& aveSerialNoAccumulator_;

  public:

    AverageAccumulator (MonitorSystem& monitorSystem, 
                        const MonitorPoint::ARCHIVE_PRIORITY priority) ;

    ~AverageAccumulator () ;

    void accumulate () ;

    void resetAccumulator () ;

    void writeLongAveragesToStrings( long          timestamp,
                                     std::string & shortString, 
                                     std::string & numericString,
                                     std::string & stringString, 
                                     std::string & complexString,
                                     char *        scratchString ) const;

    void writeInstAveragesToFile( long   frameCount, 
                                  FILE * shortFile, 
                                  FILE * numericFile, 
                                  FILE * stringFile, 
                                  FILE * complexFile ) const;

    void writeInstAveragesToFile( long                  frameCount, 
                                  carma::dbms::dbFFIO & shortFile, 
                                  carma::dbms::dbFFIO & numericFile, 
                                  carma::dbms::dbFFIO & stringFile, 
                                  carma::dbms::dbFFIO & complexFile ) const;

    void dumpInstAveragesToDBFile( DBwriteType dbWriteType, 
                                   long        frameCount,
                                   FILE *      file ) const;
                                   
    void dumpInstAveragesToDBFile( DBwriteType           dbWriteType,
                                   long                  frameCount,
                                   carma::dbms::dbFFIO & file ) const;
    
    void writeLongAveragesToFile( long   frameCount,
                                  FILE * shortFile,
                                  FILE * numericFile, 
                                  FILE * stringFile,
                                  FILE * complexFile ) const;

private:
    void dumpLongAveragesToDBFile( DBwriteType  dbWriteType,
                                   const char * frameCountText,
                                   FILE *       file ) const;



}; // class AverageAccumulator


} // end namespace carma::monitor
} // end namespace carma


#endif