QReader.hh

Go to the documentation of this file.

 
#ifndef _MQ_READER_HH_
#define _MQ_READER_HH_
 
#include "QBaseModule.hh"
#include "QError.hh"
#include <string>
#include <vector>
#include "QRWCommon.hh"
 
 
Q_BEGIN_NAMESPACE
 
class QEventAssembler;
class QEventList;
class QNeighboursFiller;
class QReaderEventGeneratorFiller;
 
class QReader : public QBaseModule 
{
    public:
        QReader();
                virtual ~QReader();
 
                virtual void Init(QEventAssembler& eva) = 0;
                
                virtual bool Do(QEventAssembler& eva) = 0;
                
                virtual void Done() = 0;
 
        virtual const QError& JumpToEvent(Long64_t eventnumber); 
        
        const int& GetFileNumber() {return fFileNumber;}
 
        static std::list<std::string> GetFilesList()  { return fFullPathFilesList; }
 
        bool DoBase(QEventAssembler& eva);
 
        bool NeighboursOn() { return fNeighboursOn; }
 
    protected:
        void InitFileManager();
        void OpenNewFile(const std::string& fileName);
        int fFileNumber;
        std::vector<std::string> fFileList;
        static std::list<std::string> fFullPathFilesList;
        bool fReadFileList;
        std::string fFileListPath;
        unsigned int fProcessedNumber;
        int fEventNumberPrintStep; 
        QError fErr;
        QRWCommon* fRWCommon;
    private:
 
        void Begin(QEventAssembler& eva);
        bool Process(QEventAssembler& eva, QEventList& neigh,const bool exec, QEventList& oneigh);
        void End();
        const QError& BaseJumpToEvent(Long64_t eventnumber); 
        void ReadFilesList(std::string path);
        void NotifyOpenNewFile(const std::string &fileName);
 
        Long64_t fReadNumber;
 
        QNeighboursFiller* fNeighboursFiller;
        QReaderEventGeneratorFiller* fReaderEventGeneratorFiller;
        std::vector<std::string>::const_iterator fFileListIter;
        bool fNeighboursOn;
        
        std::string fNextFileName;
        std::map<unsigned int,std::string> fReadNumberAtFileOpen;
        bool fNewFileOpen;
 
 
        friend class QSequence;
};
 
 
#undef REGISTER_MODULE
#define REGISTER_MODULE(clazz) REGISTER_MOD(clazz,Diana::QReader)
 
Q_END_NAMESPACE
 
 
#endif