In This Package:

DaqFormatContext.h

Go to the documentation of this file.

#ifndef DAQFORMATMODULES_DAQFORMATCONTEXT_H
#define DAQFORMATMODULES_DAQFORMATCONTEXT_H

/*
 *  DaqFormatContext.h
 *  DaqFormatModules
 *
 *  Created by Simon Patton on 8/5/10.
 *  Copyright 2010 DayaBay Collaboration. All rights reserved.
 *
 */
#include <vector>

#include "GaudiKernel/IEvtSelector.h"

class IMessageSvc;

class DaqReadoutSvc;
class IDaqReadoutSvc;

namespace DybDaq {
    class DaqFormatSelector;
    class EventReadout;
    class FileBuffer;
    class DaqFromFStream;
}

namespace DybDaq {
    
    class DaqFormatContext : public IEvtSelector::Context {
        
    public:
        
        friend class DaqFormatSelector;

        const static unsigned int kExitOnInvalid;
        
        const static unsigned int kSkipInvalid;
        
        const static unsigned int kProcessInvalid;
        
        virtual ~DaqFormatContext();
        
        virtual void* identifier() const;
        
        const DybDaq::EventReadout* event() const;
        
    protected:
        
        DaqFormatContext(const std::vector<std::string>& inputFiles,
                         const unsigned int actionOnInvalid,
                         IMessageSvc& msgSvc,
                         IDaqReadoutSvc& daqSvc);
        
        StatusCode jump(int distance);
        
        StatusCode isGoodEvent() const;

    private:
        
        DaqFormatContext();
        
        DaqFormatContext(const DaqFormatContext& rhs);
        
        DaqFormatContext& operator=(const DaqFormatContext& rhs);
        
        StatusCode moveToNextEvent();
        
        DybDaq::DaqFromFStream* openNextFile();
        
        IMessageSvc& m_messageSvc;

        DaqReadoutSvc* m_daqSvc;

        bool m_expiredEndRecord;

        DybDaq::DaqFromFStream* m_reader;
        
        const DybDaq::EventReadout* m_event;
        
        std::vector<std::string>::const_iterator m_nextFile;

        std::vector<std::string>::const_iterator m_endFile;

        bool m_warnedAboutSkip;

        unsigned int m_actionOnInvalid;
    };
    
}

#endif // DAQFORMATMODULES_DAQFORMATCONTEXT_H

---