#include <EcalDetIdToBeRecoveredProducer.h>

Inheritance diagram for EcalDetIdToBeRecoveredProducer:

Public Member Functions
virtual void	beginRun (edm::Run const &run, const edm::EventSetup &es) overridefinal

	EcalDetIdToBeRecoveredProducer (const edm::ParameterSet &ps)

virtual void	produce (edm::Event &evt, const edm::EventSetup &es) overridefinal

	~EcalDetIdToBeRecoveredProducer ()

Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default

Public Member Functions inherited from edm::stream::EDProducerBase
	EDProducerBase ()

ModuleDescription const &	moduleDescription () const

virtual	~EDProducerBase ()

Public Member Functions inherited from edm::ProducerBase
	ProducerBase ()

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

virtual	~ProducerBase ()

Public Member Functions inherited from edm::EDConsumerBase
	EDConsumerBase ()

ProductHolderIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductHolderIndexAndSkipBit > &) const

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

Private Attributes
const EcalChannelStatusMap *	chStatus_

std::string	ebDetIdCollection_

edm::EDGetTokenT < EBDetIdCollection >	ebIntegrityChIdErrorsToken_

edm::EDGetTokenT < EBDetIdCollection >	ebIntegrityGainErrorsToken_

edm::EDGetTokenT < EBDetIdCollection >	ebIntegrityGainSwitchErrorsToken_

edm::EDGetTokenT < EBSrFlagCollection >	ebSrFlagToken_

const EcalElectronicsMapping *	ecalMapping_

std::string	eeDetIdCollection_

edm::EDGetTokenT < EEDetIdCollection >	eeIntegrityChIdErrorsToken_

edm::EDGetTokenT < EEDetIdCollection >	eeIntegrityGainErrorsToken_

edm::EDGetTokenT < EEDetIdCollection >	eeIntegrityGainSwitchErrorsToken_

edm::EDGetTokenT < EESrFlagCollection >	eeSrFlagToken_

edm::EDGetTokenT < EcalElectronicsIdCollection >	integrityBlockSizeErrorsToken_

edm::EDGetTokenT < EcalElectronicsIdCollection >	integrityTTIdErrorsToken_

std::string	scDetIdCollection_

std::string	ttDetIdCollection_

edm::ESHandle < EcalTrigTowerConstituentsMap >	ttMap_

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer<>
typedef CacheContexts< T...>	CacheTypes

typedef CacheTypes::GlobalCache	GlobalCache

typedef AbilityChecker< T...>	HasAbility

typedef CacheTypes::LuminosityBlockCache	LuminosityBlockCache

typedef LuminosityBlockContextT < LuminosityBlockCache, RunCache, GlobalCache >	LuminosityBlockContext

typedef CacheTypes::LuminosityBlockSummaryCache	LuminosityBlockSummaryCache

typedef CacheTypes::RunCache	RunCache

typedef RunContextT< RunCache, GlobalCache >	RunContext

typedef CacheTypes::RunSummaryCache	RunSummaryCache

Public Types inherited from edm::stream::EDProducerBase
typedef EDProducerAdaptorBase	ModuleType

Public Types inherited from edm::ProducerBase
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Static Public Member Functions inherited from edm::stream::EDProducerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Protected Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

Detailed Description

produce ECAL rechits from uncalibrated rechits

$Id: $Date: $Revision:

Author: Federico Ferri, CEA-Saclay IRFU/SPP

Definition at line 30 of file EcalDetIdToBeRecoveredProducer.h.

Constructor & Destructor Documentation

EcalDetIdToBeRecoveredProducer::EcalDetIdToBeRecoveredProducer ( const edm::ParameterSet & ps )

explicit

Definition at line 22 of file EcalDetIdToBeRecoveredProducer.cc.

References ebDetIdCollection_, ebIntegrityChIdErrorsToken_, ebIntegrityGainErrorsToken_, ebIntegrityGainSwitchErrorsToken_, ebSrFlagToken_, eeDetIdCollection_, eeIntegrityChIdErrorsToken_, eeIntegrityGainErrorsToken_, eeIntegrityGainSwitchErrorsToken_, eeSrFlagToken_, edm::ParameterSet::getParameter(), integrityBlockSizeErrorsToken_, integrityTTIdErrorsToken_, scDetIdCollection_, AlCaHLTBitMon_QueryRunRegistry::string, and ttDetIdCollection_.

 {
         // SRP collections
         ebSrFlagToken_ = consumes<EBSrFlagCollection>(ps.getParameter<edm::InputTag>("ebSrFlagCollection"));
         eeSrFlagToken_ = consumes<EESrFlagCollection>(ps.getParameter<edm::InputTag>("eeSrFlagCollection"));
 
         // Integrity for xtal data
         ebIntegrityGainErrorsToken_ = consumes<EBDetIdCollection>(ps.getParameter<edm::InputTag>("ebIntegrityGainErrors"));
         ebIntegrityGainSwitchErrorsToken_ = consumes<EBDetIdCollection>(ps.getParameter<edm::InputTag>("ebIntegrityGainSwitchErrors"));
         ebIntegrityChIdErrorsToken_ = consumes<EBDetIdCollection>(ps.getParameter<edm::InputTag>("ebIntegrityChIdErrors"));
 
         // Integrity for xtal data - EE specific (to be rivisited towards EB+EE common collection)
         eeIntegrityGainErrorsToken_ = consumes<EEDetIdCollection>(ps.getParameter<edm::InputTag>("eeIntegrityGainErrors"));
         eeIntegrityGainSwitchErrorsToken_ = consumes<EEDetIdCollection>(ps.getParameter<edm::InputTag>("eeIntegrityGainSwitchErrors"));
         eeIntegrityChIdErrorsToken_ = consumes<EEDetIdCollection>(ps.getParameter<edm::InputTag>("eeIntegrityChIdErrors"));
 
         // Integrity Errors
         integrityTTIdErrorsToken_ = consumes<EcalElectronicsIdCollection>(ps.getParameter<edm::InputTag>("integrityTTIdErrors"));
         integrityBlockSizeErrorsToken_ = consumes<EcalElectronicsIdCollection>(ps.getParameter<edm::InputTag>("integrityBlockSizeErrors"));
 
         // output collections
         ebDetIdCollection_ = ps.getParameter<std::string>("ebDetIdToBeRecovered");
         eeDetIdCollection_ = ps.getParameter<std::string>("eeDetIdToBeRecovered");
         ttDetIdCollection_ = ps.getParameter<std::string>("ebFEToBeRecovered");
         scDetIdCollection_ = ps.getParameter<std::string>("eeFEToBeRecovered");
 
         produces< std::set<EBDetId> >( ebDetIdCollection_ );
         produces< std::set<EEDetId> >( eeDetIdCollection_ );
         produces< std::set<EcalTrigTowerDetId> >( ttDetIdCollection_ );
         produces< std::set<EcalScDetId> >( scDetIdCollection_ );
 }

EcalDetIdToBeRecoveredProducer::~EcalDetIdToBeRecoveredProducer ( )

Definition at line 55 of file EcalDetIdToBeRecoveredProducer.cc.

56 {

57 }

Member Function Documentation

void EcalDetIdToBeRecoveredProducer::beginRun	(	edm::Run const &	run,
		const edm::EventSetup &	es
	)

finaloverridevirtual

Reimplemented from edm::stream::EDProducerBase.

Definition at line 60 of file EcalDetIdToBeRecoveredProducer.cc.

References chStatus_, ecalMapping_, edm::EventSetup::get(), edm::ESHandle< class >::product(), and ttMap_.

 {
         edm::ESHandle< EcalElectronicsMapping > pEcalMapping;
         es.get<EcalMappingRcd>().get(pEcalMapping);
         ecalMapping_ = pEcalMapping.product();
 
         edm::ESHandle< EcalChannelStatusMap > pChStatus;
         es.get<EcalChannelStatusRcd>().get(pChStatus);
         chStatus_ = pChStatus.product();
 
         es.get<IdealGeometryRecord>().get(ttMap_);
 }

void EcalDetIdToBeRecoveredProducer::produce	(	edm::Event &	evt,
		const edm::EventSetup &	es
	)

finaloverridevirtual

Implements edm::stream::EDProducerBase.

Definition at line 81 of file EcalDetIdToBeRecoveredProducer.cc.

References edm::EDCollection< T >::begin(), chStatus_, coll, ebDetIdCollection_, ebIntegrityChIdErrorsToken_, ebIntegrityGainErrorsToken_, ebIntegrityGainSwitchErrorsToken_, ebSrFlagToken_, EcalBarrel, EcalEndcap, ecalMapping_, eeDetIdCollection_, eeIntegrityChIdErrorsToken_, eeIntegrityGainErrorsToken_, eeIntegrityGainSwitchErrorsToken_, eeSrFlagToken_, edm::EDCollection< T >::end(), EcalCondObjectContainer< T >::end(), EcalCondObjectContainer< T >::find(), archive::flag, edm::Event::getByToken(), EcalElectronicsMapping::getDetId(), i, include(), integrityBlockSizeErrorsToken_, integrityTTIdErrorsToken_, EcalScDetId::ix(), EcalScDetId::iy(), j, edm::EDCollection< T >::push_back(), edm::Event::put(), scDetIdCollection_, edm::EDCollection< T >::size(), EcalSrFlag::SRF_FORCED_MASK, EcalSrFlag::SRF_FULL, EcalElectronicsId::subdet(), edmStreamStallGrapher::t, EBDetId::tower(), ttDetIdCollection_, ecaldqm::ttId(), ttMap_, EEDetId::validDetId(), and EcalScDetId::zside().

 {
         std::vector< edm::Handle<EBDetIdCollection> > ebDetIdColls;
         std::vector< edm::Handle<EEDetIdCollection> > eeDetIdColls;
         std::vector< edm::Handle<EcalElectronicsIdCollection> > ttColls;
 
         std::auto_ptr< std::set<EBDetId> > ebDetIdToRecover( new std::set<EBDetId> ); // isolated channels to be recovered
         std::auto_ptr< std::set<EEDetId> > eeDetIdToRecover( new std::set<EEDetId> ); // isolated channels to be recovered
         std::auto_ptr< std::set<EcalTrigTowerDetId> > ebTTDetIdToRecover( new std::set<EcalTrigTowerDetId> ); // tt to be recovered
         std::auto_ptr< std::set<EcalScDetId> > eeSCDetIdToRecover( new std::set<EcalScDetId> ); // sc to be recovered
 
         /*
          * get collections
          */
 
         // Selective Readout Flags
         edm::Handle<EBSrFlagCollection> ebSrFlags;
         ev.getByToken(ebSrFlagToken_, ebSrFlags );
 
         edm::Handle<EESrFlagCollection> eeSrFlags;
         ev.getByToken(eeSrFlagToken_, eeSrFlags );
 
         // Integrity errors
         edm::Handle<EBDetIdCollection> ebIntegrityGainErrors;
         ev.getByToken( ebIntegrityGainErrorsToken_, ebIntegrityGainErrors );
 
     ebDetIdColls.push_back( ebIntegrityGainErrors );
        
         edm::Handle<EBDetIdCollection> ebIntegrityGainSwitchErrors;
         ev.getByToken( ebIntegrityGainSwitchErrorsToken_, ebIntegrityGainSwitchErrors );       
     ebDetIdColls.push_back( ebIntegrityGainSwitchErrors );
 
         edm::Handle<EBDetIdCollection> ebIntegrityChIdErrors;
         ev.getByToken( ebIntegrityChIdErrorsToken_, ebIntegrityChIdErrors );
     ebDetIdColls.push_back( ebIntegrityChIdErrors );
        
         edm::Handle<EEDetIdCollection> eeIntegrityGainErrors;
         ev.getByToken( eeIntegrityGainErrorsToken_, eeIntegrityGainErrors );
     eeDetIdColls.push_back( eeIntegrityGainErrors );
        
         edm::Handle<EEDetIdCollection> eeIntegrityGainSwitchErrors;
         ev.getByToken( eeIntegrityGainSwitchErrorsToken_, eeIntegrityGainSwitchErrors );
     eeDetIdColls.push_back( eeIntegrityGainSwitchErrors );
         
 
 
         edm::Handle<EEDetIdCollection> eeIntegrityChIdErrors;
         ev.getByToken( eeIntegrityChIdErrorsToken_, eeIntegrityChIdErrors );
     eeDetIdColls.push_back( eeIntegrityChIdErrors );
  
  
  
 
         edm::Handle<EcalElectronicsIdCollection> integrityTTIdErrors;
         ev.getByToken( integrityTTIdErrorsToken_, integrityTTIdErrors );
     ttColls.push_back( integrityTTIdErrors );
 
         edm::Handle<EcalElectronicsIdCollection> integrityBlockSizeErrors;
         ev.getByToken( integrityBlockSizeErrorsToken_, integrityBlockSizeErrors );
     ttColls.push_back( integrityBlockSizeErrors );
                
         /*
          *  get regions of interest from SRP
          */
         // -- Barrel
         EBDetIdCollection ebSrpDetId;
         EcalTrigTowerDetIdCollection ebSrpTTDetId;
         for ( EBSrFlagCollection::const_iterator it = ebSrFlags->begin(); it != ebSrFlags->end(); ++it ) {
                 const int flag = it->value();
                 if ( flag == EcalSrFlag::SRF_FULL || ( flag == EcalSrFlag::SRF_FORCED_MASK) ) {
                         const EcalTrigTowerDetId ttId = it->id();
                         ebSrpTTDetId.push_back( ttId );
                 
                         const std::vector<DetId> vid = ttMap_->constituentsOf( ttId );
                 
                         for ( std::vector<DetId>::const_iterator itId = vid.begin(); itId != vid.end(); ++itId ) {
                                 ebSrpDetId.push_back( *itId );
                         }
                 }
         }
         // -- Endcap
         EEDetIdCollection eeSrpDetId;
         //EcalTrigTowerDetIdCollection eeSrpTTDetId;
         for ( EESrFlagCollection::const_iterator it = eeSrFlags->begin(); it != eeSrFlags->end(); ++it ) {
                 const int flag = it->value();
                 if ( flag == EcalSrFlag::SRF_FULL || ( flag == EcalSrFlag::SRF_FORCED_MASK) ) {
                         //EcalTrigTowerDetId ttId = it->id();
                         //eeSrpTTDetId.push_back( ttId );
                         const EcalScDetId scId( it->id() );
                         // not clear how to get the vector of DetId constituents of a SC...
                         //std::vector<DetId> vid = ecalMapping_->dccTowerConstituents( eId.dccId(), eId.towerId() );
                         std::vector<DetId> vid;
                         for(int dx=1; dx<=5; ++dx){
                                 for(int dy=1; dy<=5; ++dy){
                                         const int ix = (scId.ix()-1)*5 + dx;
                                         const int iy = (scId.iy()-1)*5 + dy;
                                         const int iz = scId.zside();
                                         if(EEDetId::validDetId(ix, iy, iz)){
                                                 vid.push_back(EEDetId(ix, iy, iz));
                                         }
                                 }
                         }
                         //std::vector<DetId> vid = ttMap_->constituentsOf( ttId );
                         for ( std::vector<DetId>::const_iterator itId = vid.begin(); itId != vid.end(); ++itId ) {
                                 eeSrpDetId.push_back( *itId );
                         }
                 }
         }
         // SRP switched off: get the list from the DB
         if ( ebSrFlags->size() == 0 ) {
         }
         // SRP switched off: get the list from the DB
         if ( eeSrFlags->size() == 0 ) {
         }
 
         /*
          *  get OR of integrity error collections
          *  in interesting regions flagged by SRP
          *  and insert them in the list of DetId to recover
          */
         // -- Barrel
         for ( std::vector<edm::Handle<EBDetIdCollection> >::const_iterator it = ebDetIdColls.begin(); it != ebDetIdColls.end(); ++it )
         {
                 const EBDetIdCollection * idc = it->product();
                 for ( EBDetIdCollection::const_iterator jt = idc->begin(); jt != idc->end(); ++jt )
                   if (include(ebSrpDetId, *jt))
                     ebDetIdToRecover->insert( *jt );
         }
         // -- Endcap
         for ( std::vector<edm::Handle<EEDetIdCollection> >::const_iterator it = eeDetIdColls.begin(); it != eeDetIdColls.end(); ++it )
         {
                 const EEDetIdCollection * idc = it->product();
                 for ( EEDetIdCollection::const_iterator jt = idc->begin(); jt != idc->end(); ++jt )
                   if (include(eeSrpDetId, *jt))
                     eeDetIdToRecover->insert( *jt );
         }
 
         /* 
          * find isolated dead channels (from DB info)           --> chStatus 10, 11, 12
          * and group of dead channels w/ trigger(from DB info)  --> chStatus 13
          * in interesting regions flagged by SRP
          */
         // -- Barrel
         for ( EBDetIdCollection::const_iterator itId = ebSrpDetId.begin(); itId != ebSrpDetId.end(); ++itId ) {
                 EcalChannelStatusMap::const_iterator chit = chStatus_->find( *itId );
                 if ( chit != chStatus_->end() ) {
                         const int flag = (*chit).getStatusCode();
                         if ( flag >= 10 && flag <= 12) { // FIXME -- avoid hardcoded values...
                                 ebDetIdToRecover->insert( *itId );
                         } else if ( flag == 13 || flag == 14 ) { // FIXME -- avoid hardcoded values...
                                 ebTTDetIdToRecover->insert( (*itId).tower() );
                         }
                 } else {
                         edm::LogError("EcalDetIdToBeRecoveredProducer") << "No channel status found for xtal "
                                 << (*itId).rawId()
                                 << "! something wrong with EcalChannelStatus in your DB? ";
                 }
         }
         // -- Endcap
         for ( EEDetIdCollection::const_iterator itId = eeSrpDetId.begin(); itId != eeSrpDetId.end(); ++itId ) {
                 EcalChannelStatusMap::const_iterator chit = chStatus_->find( *itId );
                 if ( chit != chStatus_->end() ) {
                         int flag = (*chit).getStatusCode() ;
                         if ( flag >= 10 && flag <= 12) { // FIXME -- avoid hardcoded values...
                                 eeDetIdToRecover->insert( *itId );
                         } else if ( flag == 13 || flag == 14 ) { // FIXME -- avoid hardcoded values...
                                 eeSCDetIdToRecover->insert( EcalScDetId(1+((*itId).ix()-1)/5,1+((*itId).iy()-1)/5,(*itId).zside()) );
                         }
                 } else {
                         edm::LogError("EcalDetIdToBeRecoveredProducer") << "No channel status found for xtal "
                                 << (*itId).rawId()
                                 << "! something wrong with EcalChannelStatus in your DB? ";
                 }
         }
         
         
         // loop over electronics id associated with TT and SC
         for (size_t t = 0; t < ttColls.size(); ++t) {
           const EcalElectronicsIdCollection& coll = *(ttColls[t]);
 
           for (size_t i = 0; i < coll.size(); ++i)
           {
             const EcalElectronicsId elId = coll[i];
             const EcalSubdetector subdet = elId.subdet();
             const DetId detId = ecalMapping_->getDetId(elId);
             
             if (subdet == EcalBarrel) { // elId pointing to TT
               // get list of crystals corresponding to TT
               const EcalTrigTowerDetId ttId( ttMap_->towerOf(detId) );
               const std::vector<DetId>& vid = ttMap_->constituentsOf(ttId);
               
               for (size_t j = 0; j < vid.size(); ++j) {
                 const EBDetId ebdi(vid[j]);
                 if (include(ebSrpDetId, ebdi)) {
                   ebDetIdToRecover->insert(ebdi);
                   ebTTDetIdToRecover->insert(ebdi.tower());
                 }
               }
             }
             else if (subdet == EcalEndcap) { // elId pointing to SC
               // extract list of crystals corresponding to SC
               const EcalScDetId scId(detId);
               std::vector<DetId> vid;
               for(int dx=1; dx<=5; ++dx) {
                 for(int dy=1; dy<=5; ++dy) {
                   const int ix = (scId.ix()-1)*5 + dx;
                   const int iy = (scId.iy()-1)*5 + dy;
                   const int iz = scId.zside();
                   if(EEDetId::validDetId(ix, iy, iz))
                     vid.push_back(EEDetId(ix, iy, iz));
                 }
               }
               
               for (size_t j = 0; j < vid.size(); ++j) {
                 const EEDetId eedi(vid[i]);
                 if (include(eeSrpDetId, eedi)) {
                   eeDetIdToRecover->insert(eedi);
                   eeSCDetIdToRecover->insert(EcalScDetId(eedi));
                 }
               }
             }
             else
               edm::LogWarning("EcalDetIdToBeRecoveredProducer")
                 << "Incorrect EcalSubdetector = " << subdet
                 << " in EcalElectronicsIdCollection collection ";
           }
         }
 
         // return the collections
         ev.put( ebDetIdToRecover, ebDetIdCollection_ );
         ev.put( eeDetIdToRecover, eeDetIdCollection_ );
         ev.put( ebTTDetIdToRecover, ttDetIdCollection_ );
         ev.put( eeSCDetIdToRecover, scDetIdCollection_ );
 }