DybOutputFileRoller.h

Go to the documentation of this file.

#ifndef DYBOUTPUTFILEROLLER
#define DYBOUTPUTFILEROLLER

#include "RootIOSvc/IRootIOSvc.h"
#include "Context/TimeStamp.h"
#include "GaudiAlg/GaudiAlgorithm.h"

#include <string>


class DybOutputFileRoller : public GaudiAlgorithm
{
public:
    DybOutputFileRoller(const std::string& name, ISvcLocator* svcloc);
    virtual ~DybOutputFileRoller();
    
    StatusCode initialize();
    StatusCode execute();
    StatusCode finalize();
    
private: // Properties

    std::string m_condition;

    typedef std::map<std::string,std::string> ConditionPropertyMap_t;
    ConditionPropertyMap_t m_condpropmap;

private:
    int m_current_execnum;
    IRootIOSvc* m_rio;
    IRootIOSvc::FileMap m_filemap;

    // Parse condition and bookkeeping data
    struct ConditionData {
        ConditionData(int s, char u, int c=0, 
                      int e = 0, const TimeStamp& ts = TimeStamp::GetBOT())
            : size(s), unit(u), count(c), cycles(e), timestamp(ts) {}
        ConditionData()
            : size(0), unit(0), count(0), cycles(0), timestamp(TimeStamp::GetBOT()) {}
        int size;               // parsed condition size
        char unit;              // parsed condition unit
        int count;              // file count
        int cycles;             // cycles left before a roll for E condition
        TimeStamp timestamp;    // target timestamp for roll for S condition
                                // M condition does not need anything here
    };

    typedef std::map<std::string,ConditionData> CDMap_t;
    CDMap_t m_cdmap;

    StatusCode roll(std::string stream, ConditionData& cd);
    StatusCode check_e(std::string stream, ConditionData& cd);
    StatusCode check_m(std::string stream, ConditionData& cd);
    StatusCode check_s(std::string stream, ConditionData& cd);

};

#endif  // DYBOUTPUTFILEROLLER