#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 ()

virtual const LVL2_MUON_CALIBRATION::CalibEvent *	nextEvent ()

virtual const LVL2_MUON_CALIBRATION::CalibEvent *	currentEvent () const
	Get a pointer to the current event. More...

MsgStream &	msg () const

MsgStream &	msg (const MSG::Level lvl) const

bool	msgLvl (const MSG::Level lvl) const

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 24 of file MuonCalibStreamFileInputSvc.h.

Constructor & Destructor Documentation

◆ MuonCalibStreamFileInputSvc()

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

Definition at line 23 of file MuonCalibStreamFileInputSvc.cxx.

23 :

24 MuonCalibStreamInputSvc(name, svcloc) {}

◆ ~MuonCalibStreamFileInputSvc()

MuonCalibStreamFileInputSvc::~MuonCalibStreamFileInputSvc ( )

virtual

Definition at line 27 of file MuonCalibStreamFileInputSvc.cxx.

27 {}

Member Function Documentation

◆ currentEvent()

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

virtual

Get a pointer to the current event.

Implements MuonCalibStreamInputSvc.

Definition at line 110 of file MuonCalibStreamFileInputSvc.cxx.

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

◆ initialize()

StatusCode MuonCalibStreamFileInputSvc::initialize ( )

virtual

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()

◆ msg() [1/2]

MsgStream& AthCommonMsg< Service >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                 {
     return this->msgStream();
   }

◆ msg() [2/2]

MsgStream& AthCommonMsg< Service >::msg ( const MSG::Level lvl ) const

inlineinherited

Definition at line 27 of file AthCommonMsg.h.

                                                   {
     return this->msgStream(lvl);
   }

◆ msgLvl()

bool AthCommonMsg< Service >::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                                {
     return this->msgLevel(lvl);
   }

◆ nextEvent()

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

virtual

Implements MuonCalibStreamInputSvc.

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()