MuonCalibStreamFileInputSvc Class Reference

#include <MuonCalibStreamFileInputSvc.h>

Inheritance diagram for MuonCalibStreamFileInputSvc:

Collaboration diagram for MuonCalibStreamFileInputSvc:

Public Member Functions
	MuonCalibStreamFileInputSvc (const std::string &name, ISvcLocator *svcloc)
virtual	~MuonCalibStreamFileInputSvc ()
virtual StatusCode	initialize () override
virtual const LVL2_MUON_CALIBRATION::CalibEvent *	nextEvent () override
virtual const LVL2_MUON_CALIBRATION::CalibEvent *	currentEvent () const override
	Get a pointer to the current event.

Private Attributes
Long64_t	m_fileEventCounter {0}
Long64_t	m_totalEventCounter {0}
Gaudi::Property< int >	m_DumpStream {this, "DumpStream", 0}
std::unique_ptr< DataReader >	m_reader {}
bool	m_EoF {false}
std::unique_ptr< LVL2_MUON_CALIBRATION::CalibEvent >	m_re {}
std::unique_ptr< LVL2_MUON_CALIBRATION::CalibDataLoader >	m_dataLoader {}
DataBuffer	m_dataBuffer
Gaudi::Property< std::vector< std::string > >	m_inputFiles {this, "InputFiles", {} }
std::vector< std::string >::iterator	m_inputFilesIt {m_inputFiles.value().begin()}

Detailed Description

Definition at line 26 of file MuonCalibStreamFileInputSvc.h.

Constructor & Destructor Documentation

MuonCalibStreamFileInputSvc()

MuonCalibStreamFileInputSvc::MuonCalibStreamFileInputSvc	(	const std::string &	name,
		ISvcLocator *	svcloc )

Definition at line 23 of file MuonCalibStreamFileInputSvc.cxx.

                                                                                                   :
    base_class(name, svcloc) {}

~MuonCalibStreamFileInputSvc()

MuonCalibStreamFileInputSvc::~MuonCalibStreamFileInputSvc ( )

virtual

Definition at line 27 of file MuonCalibStreamFileInputSvc.cxx.

{}

Member Function Documentation

currentEvent()

const LVL2_MUON_CALIBRATION::CalibEvent * MuonCalibStreamFileInputSvc::currentEvent ( ) const

overridevirtual

Get a pointer to the current event.

Definition at line 110 of file MuonCalibStreamFileInputSvc.cxx.

                                                                                       {
    // Return a pointer to the  raw event.
    return m_re.get();
}

initialize()

StatusCode MuonCalibStreamFileInputSvc::initialize ( )

overridevirtual

Definition at line 30 of file MuonCalibStreamFileInputSvc.cxx.

                                                   {
 
    // Check that the vector of input file names is not empty.
    if (m_inputFiles.empty()) {
        ATH_MSG_ERROR(" initialize: No input event files ");
        return StatusCode::FAILURE;
    }
 
    // Set the iterator to the first input file.
    m_inputFilesIt = m_inputFiles.begin();
 
    // instantiate the data loader
    m_dataLoader = std::make_unique<LVL2_MUON_CALIBRATION::CalibDataLoader>(m_inputFilesIt->c_str(), false, 0xffffffff, 0, DEFAULT_BUFFER_SIZE);
 
    m_EoF = false;
 
    return StatusCode::SUCCESS;
}  // MuonCalibStreamFileInputSvc::initialize()

nextEvent()

const LVL2_MUON_CALIBRATION::CalibEvent * MuonCalibStreamFileInputSvc::nextEvent ( )

overridevirtual

Definition at line 50 of file MuonCalibStreamFileInputSvc.cxx.

                                                                              {
 
    if (m_EoF) {  // EOF reached, need to change input file
        ATH_MSG_INFO("nextEvent: end of file reached ");
        m_totalEventCounter += m_fileEventCounter;
 
        ATH_MSG_INFO("nextEvent: finished with file  " << *m_inputFilesIt);
        ATH_MSG_INFO(" Number of Events in this file " << m_fileEventCounter);
        ATH_MSG_INFO(" Total number of Events        " << m_totalEventCounter);
 
        // Reinitialize the file event counter.
        m_fileEventCounter = 0;
 
        ++m_inputFilesIt;
 
        if (m_inputFilesIt == m_inputFiles.end()) {
            ATH_MSG_INFO("no more file to read  ");
            return 0;
        }
 
        // do the next File
        m_dataLoader = std::make_unique<LVL2_MUON_CALIBRATION::CalibDataLoader>(m_inputFilesIt->c_str(), false, 0xffffffff, 0, DEFAULT_BUFFER_SIZE);
 
        m_EoF = false;
 
        return nextEvent();
    }
 
    ++m_fileEventCounter;
 
    // try to read next event
    // add TGC fragment and move the print out of the fragment to DEBUG outputLevel
    if (m_dataLoader->next(m_dataBuffer)) {
        m_re = std::make_unique<LVL2_MUON_CALIBRATION::CalibEvent>(m_dataBuffer);
 
        if (m_re) {
            if (m_re->mdt() != 0) {
                if (m_DumpStream != 0)
                    ATH_MSG_DEBUG(" MuonCalibStreamFileInputSvc::next event -- eta=" << m_re->eta() << " mdt " << *(m_re->mdt()));
            }
            if (m_re->rpc() != 0) {
                if (m_DumpStream != 0)
                    ATH_MSG_DEBUG(" MuonCalibStreamFileInputSvc::next event -- eta=" << m_re->eta() << " rpc " << *(m_re->rpc()));
            }
            if (m_re->tgc() != 0) {
                if (m_DumpStream != 0)
                    ATH_MSG_DEBUG(" MuonCalibStreamFileInputSvc::next event -- eta=" << m_re->eta() << " tgc " << *(m_re->tgc()));
            }
        }
    } else {
        // file must be over
        m_EoF = true;
        return nextEvent();
    }
 
    // Return
    return m_re.get();
}  // MuonCalibStreamFileInputSvc::nextEvent()

Member Data Documentation

m_dataBuffer

DataBuffer MuonCalibStreamFileInputSvc::m_dataBuffer

private

Definition at line 45 of file MuonCalibStreamFileInputSvc.h.

m_dataLoader

std::unique_ptr<LVL2_MUON_CALIBRATION::CalibDataLoader> MuonCalibStreamFileInputSvc::m_dataLoader {}

private

Definition at line 44 of file MuonCalibStreamFileInputSvc.h.

{};

m_DumpStream

Gaudi::Property<int> MuonCalibStreamFileInputSvc::m_DumpStream {this, "DumpStream", 0}

private

Definition at line 40 of file MuonCalibStreamFileInputSvc.h.

{this, "DumpStream", 0};

m_EoF

bool MuonCalibStreamFileInputSvc::m_EoF {false}

private

Definition at line 42 of file MuonCalibStreamFileInputSvc.h.

{false};

m_fileEventCounter

Long64_t MuonCalibStreamFileInputSvc::m_fileEventCounter {0}

private

Definition at line 38 of file MuonCalibStreamFileInputSvc.h.

{0};

m_inputFiles

Gaudi::Property<std::vector<std::string> > MuonCalibStreamFileInputSvc::m_inputFiles {this, "InputFiles", {} }

private

Definition at line 46 of file MuonCalibStreamFileInputSvc.h.

{this, "InputFiles", {} };

m_inputFilesIt

std::vector<std::string>::iterator MuonCalibStreamFileInputSvc::m_inputFilesIt {m_inputFiles.value().begin()}

private

Definition at line 47 of file MuonCalibStreamFileInputSvc.h.

{m_inputFiles.value().begin()};

m_re

std::unique_ptr<LVL2_MUON_CALIBRATION::CalibEvent> MuonCalibStreamFileInputSvc::m_re {}

private

Definition at line 43 of file MuonCalibStreamFileInputSvc.h.

{};

m_reader

std::unique_ptr<DataReader> MuonCalibStreamFileInputSvc::m_reader {}

private

Definition at line 41 of file MuonCalibStreamFileInputSvc.h.

{};

m_totalEventCounter

Long64_t MuonCalibStreamFileInputSvc::m_totalEventCounter {0}

private

Definition at line 39 of file MuonCalibStreamFileInputSvc.h.

{0};

---

The documentation for this class was generated from the following files:

• MuonCalibStreamFileInputSvc.h
• MuonCalibStreamFileInputSvc.cxx