Streamer.h

Go to the documentation of this file.

/***
 *       Filename:  Streamer.h
 *
 *    Description:  Stream table data to a  stream.
 *
 *        Version:  0.0.1
 *        Created:  2016-04-26

 *       Revision:  none
 *
 *         Author:  Dilawar Singh <dilawars@ncbs.res.in>
 *   Organization:  NCBS Bangalore
 *
 *        License:  GNU GPL2
 */

#ifndef  Streamer_INC
#define  Streamer_INC

#define STRINGSTREAM_DOUBLE_PRECISION       10

#include <iostream>
#include <string>
#include <map>
#include <fstream>
#include <sstream>

#include "StreamerBase.h"
#include "Table.h"

using namespace std;

class Streamer : public StreamerBase
{

public:
    Streamer();
    ~Streamer();

    Streamer& operator=( const Streamer& st );

    /* Cleaup before quitting */
    void cleanUp( void );

    string getOutFilepath( void ) const;
    void setOutFilepath( string path );

    string getFormat( void ) const;
    void setFormat( string format );

    size_t getNumTables( void ) const;

    void addTable( Id table );
    void addTables( vector<Id> tables);

    void removeTable( Id table );
    void removeTables( vector<Id> table );

    void zipWithTime( );

    void process(const Eref& e, ProcPtr p);

    void reinit(const Eref& e, ProcPtr p);

    static const Cinfo * initCinfo();

private:

    string outfilePath_;
    string format_;
    bool isOutfilePathSet_;

    // dt_ and tick number of Table's clock
    vector<double> tableDt_;
    vector<unsigned int> tableTick_;

    // This currTime is not computed using the ProcPtr but rather using Tables
    // dt_ and number of entries written.
    double currTime_;

    // Used for adding or removing tables
    vector<Id> tableIds_;
    vector<Table*> tables_;
    vector<string> columns_;

    /*  Keep data in vector */
    vector<double> data_;

};

#endif   /* ----- #ifndef Streamer_INC  ----- */