LArRawDataContByteStreamTool.icc

Go to the documentation of this file.

//Dear emacs, this is -*- c++ -*-
 
/*
  Copyright (C) 2002-2021 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef LARBYTESTREAM_LARRAWDATACONTBYTESTREAMTOOL_ICC
#define LARBYTESTREAM_LARRAWDATACONTBYTESTREAMTOOL_ICC
 
//#include "LArRawEvent/LArRawChannelCollection.h"
//#include "LArRecEvent/LArCellCollection.h"
//#include "LArRawEvent/LArDigitContainer.h"
 
 
template <class COLLECTION >
bool LArRawDataContByteStreamTool::checkGainConsistency(const COLLECTION* coll) const
{typedef typename COLLECTION::const_iterator contIter;
 contIter it=coll->begin();
 contIter it_e=coll->end();
 if (it==it_e) //empty container
   return true;
 int fixgain=(*it)->gain();
 for (;it!=it_e;++it)
   if (fixgain!=(*it)->gain())
      return false;
 return true;
}
 
 
// We read all avaliable data => Loop over all LAr-Subdetectors and all RODs
// All the methods derivated from the template should be there
// The Following collection types are included :
// LArAccumulatedCalibDigit, LArAccumulatedDigit, LArCalibDigit, LArDigit,
// LArFebHeader and LArRawChannel
template <class COLLECTION, typename ...ARGS >
StatusCode LArRawDataContByteStreamTool::convert(const RawEvent* re,
                                                 COLLECTION* coll,
                                                 CaloGain::CaloGain gain,
                                                 ARGS&&... args) const
{
        RobIndex_t robIndex;
    if (prepareRobIndex(re, robIndex).isFailure()){
          ATH_MSG_ERROR ( "Error in prepareRobIndex " );
          return StatusCode::FAILURE;
    }
        RobIndex_t::const_iterator it = robIndex.find(eformat::LAR);
        if ( it != robIndex.end() ) {
          const std::vector<const uint32_t*>& robs = (*it).second;
      std::vector<const uint32_t*>::const_iterator rob_add;
          for(rob_add = robs.begin(); rob_add!=robs.end();++rob_add){
            try {
              OFFLINE_FRAGMENTS_NAMESPACE::PointerType p;
          OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment robFrag(*rob_add);
              uint32_t fragSourceID = robFrag.rod_source_id();
            
              if( fragSourceID & 0x1000 ){
                  ATH_MSG_DEBUG(" skip Latome fragment with source ID "<< std::hex << fragSourceID);
                  continue;
              }
 
          if (!m_decoder->check_valid (&robFrag, msg())) {
            ATH_MSG_WARNING ( "Error reading bytestream event: "
                                  << "Invalid ROB fragment for source ID " << robFrag.rod_source_id() );
            continue; //return StatusCode::FAILURE;
          }
          uint32_t n = robFrag.rod_ndata() ; 
          robFrag.rod_data(p); 
          if (n < 3) {
            ATH_MSG_WARNING ( "Error reading bytestream event: "
                                  << "Empty ROD block (less than 3 words) for source ID " << robFrag.rod_source_id() );
            continue;
            //return StatusCode::FAILURE;
          }
              ATH_MSG_DEBUG ( "Format Version Number of ROD-Data Block: " 
                              << MSG::hex << robFrag.rod_version()
                              << MSG::dec);
              ATH_MSG_VERBOSE ( "Calling RodDecoder for source ID " << MSG::hex 
                                << robFrag.rod_source_id() << MSG::dec );
          m_decoder->fillCollection(robFrag,
                                        p,n,*coll,gain,
                                        std::forward<ARGS>(args)...); // ..and decode them.
            }
            catch (eformat::Issue& ex) {
              ATH_MSG_WARNING ( " exception thrown by ROBFragment, badly corrupted event. Abort decoding " );
             coll->clear();
             break;
            }
    }//end if LAr SubDet or ROS event building
  }//end of if empty
  ATH_MSG_VERBOSE ( "End of LArDigitCnvTool. Container size=" << coll->size() );
  return StatusCode::SUCCESS;
}
 
#endif