#include <RawTask.h>

Inheritance diagram for RawTask:

Public Member Functions
void	beginLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override

void	bookHistograms (DQMStore::IBooker &, edm::Run const &, edm::EventSetup const &) override

void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override

	RawTask (edm::ParameterSet const &)

	~RawTask () override

Public Member Functions inherited from hcaldqm::DQTask
void	analyze (edm::Event const &, edm::EventSetup const &) override

void	beginLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override

void	dqmBeginRun (edm::Run const &, edm::EventSetup const &) override

	DQTask (edm::ParameterSet const &)

void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override

	~DQTask () override

Public Member Functions inherited from DQMEDAnalyzer
void	accumulate (edm::Event const &ev, edm::EventSetup const &es) final

void	beginLuminosityBlock (edm::LuminosityBlock const &lumi, edm::EventSetup const &setup) override

void	beginRun (edm::Run const &run, edm::EventSetup const &setup) final

	DQMEDAnalyzer ()

	DQMEDAnalyzer (DQMEDAnalyzer const &)=delete

	DQMEDAnalyzer (DQMEDAnalyzer &&)=delete

void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override

void	endLuminosityBlockProduce (edm::LuminosityBlock &lumi, edm::EventSetup const &setup) final

void	endRun (edm::Run const &run, edm::EventSetup const &setup) override

void	endRunProduce (edm::Run &run, edm::EventSetup const &setup) override

	~DQMEDAnalyzer () override=default

Public Member Functions inherited from edm::one::EDProducer< edm::Accumulator, edm::EndLuminosityBlockProducer, edm::EndRunProducer, edm::one::WatchLuminosityBlocks, edm::one::WatchRuns >
	EDProducer ()=default

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

bool	hasAbilityToProduceInLumis () const final

bool	hasAbilityToProduceInRuns () const final

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

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

ModuleDescription const &	moduleDescription () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

	~EDProducerBase () override

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

std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

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

void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)

	~ProducerBase () override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

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

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

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

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

virtual	~EDConsumerBase () noexcept(false)

Public Member Functions inherited from hcaldqm::DQModule
	DQModule (edm::ParameterSet const &)

virtual	~DQModule ()(false)

Protected Types
enum	RawFlag { fEvnMsm = 0, fBcnMsm = 1, fOrnMsm = 2, fBadQ = 3, nRawFlag = 4 }

Protected Member Functions
void	_process (edm::Event const &, edm::EventSetup const &) override

void	_resetMonitors (hcaldqm::UpdateFreq) override

Protected Member Functions inherited from hcaldqm::DQTask
virtual int	_getCalibType (edm::Event const &)

virtual bool	_isApplicable (edm::Event const &)

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)

Protected Attributes
bool	_calibProcessing

hcaldqm::Container2D	_cBadQuality_depth

hcaldqm::Container2D	_cBadQuality_FEDuTCA

hcaldqm::Container2D	_cBadQuality_FEDVME

hcaldqm::Container2D	_cBadQualityLS_depth

hcaldqm::ContainerSingleProf1D	_cBadQualityvsBX

hcaldqm::ContainerSingleProf1D	_cBadQualityvsLS

hcaldqm::Container2D	_cBcnMsm_ElectronicsuTCA

hcaldqm::Container2D	_cBcnMsm_ElectronicsVME

hcaldqm::ContainerProf1D	_cDataSizevsLS_FED

hcaldqm::Container2D	_cEvnMsm_ElectronicsuTCA

hcaldqm::Container2D	_cEvnMsm_ElectronicsVME

hcaldqm::Container2D	_cOrnMsm_ElectronicsuTCA

hcaldqm::Container2D	_cOrnMsm_ElectronicsVME

hcaldqm::ContainerSingle2D	_cSummaryvsLS

hcaldqm::Container2D	_cSummaryvsLS_FED

hcaldqm::electronicsmap::ElectronicsMap	_ehashmap

hcaldqm::filter::HashFilter	_filter_FEDsuTCA

hcaldqm::filter::HashFilter	_filter_FEDsVME

hcaldqm::filter::HashFilter	_filter_uTCA

hcaldqm::filter::HashFilter	_filter_VME

edm::InputTag	_tagFEDs

edm::InputTag	_tagReport

int	_thresh_calib_nbadq

edm::EDGetTokenT< FEDRawDataCollection >	_tokFEDs

edm::EDGetTokenT< HcalUnpackerReport >	_tokReport

std::vector< hcaldqm::flag::Flag >	_vflags

std::vector< uint32_t >	_vhashFEDs

hcaldqm::ContainerXXX< uint32_t >	_xBadQLS

hcaldqm::ContainerXXX< uint32_t >	_xBcnMsmLS

hcaldqm::ContainerXXX< uint32_t >	_xEvnMsmLS

hcaldqm::ContainerXXX< uint32_t >	_xOrnMsmLS

Protected Attributes inherited from hcaldqm::DQTask
ContainerI	_cEvsPerLS

ContainerI	_cEvsTotal

ContainerS	_cProcessingTypeName

ContainerS	_cRunKeyName

ContainerI	_cRunKeyVal

edm::ESHandle< HcalDbService >	_dbService

HcalElectronicsMap const *	_emap

int	_procLSs

edm::InputTag	_tagRaw

edm::EDGetTokenT< FEDRawDataCollection >	_tokRaw

std::vector< uint32_t >	_vcdaqEids

ContainerXXX< uint32_t >	_xQuality

Protected Attributes inherited from DQMEDAnalyzer
edm::EDPutTokenT< DQMToken >	lumiToken_

edm::EDPutTokenT< DQMToken >	runToken_

Protected Attributes inherited from hcaldqm::DQModule
int	_currentLS

int	_debug

int	_evsPerLS

int	_evsTotal

Logger	_logger

int	_maxLS

ModuleType	_mtype

std::string	_name

ProcessingType	_ptype

std::string	_runkeyName

int	_runkeyVal

std::string	_subsystem

Additional Inherited Members
Public Types inherited from edm::one::EDProducerBase
typedef EDProducerBase	ModuleType

Public Types inherited from edm::ProducerBase
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const , const char , edm::ProductResolverIndex >>

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Detailed Description

file: Author: Description:

Definition at line 24 of file RawTask.h.

Member Enumeration Documentation

enum RawTask::RawFlag

protected

Enumerator
fEvnMsm
fBcnMsm
fOrnMsm
fBadQ
nRawFlag

Definition at line 48 of file RawTask.h.

         {
             fEvnMsm = 0,
             fBcnMsm = 1,
             fOrnMsm = 2,
             fBadQ = 3,
             nRawFlag = 4
         };

Constructor & Destructor Documentation

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

Definition at line 7 of file RawTask.cc.

References _calibProcessing, _tagFEDs, _tagReport, _thresh_calib_nbadq, _tokFEDs, _tokReport, _vflags, fBadQ, fBcnMsm, fEvnMsm, nanoDQM_cfi::Flag, fOrnMsm, edm::ParameterSet::getUntrackedParameter(), and nRawFlag.

                                          :
     DQTask(ps)
 {
     _tagFEDs = ps.getUntrackedParameter<edm::InputTag>("tagFEDs",
         edm::InputTag("rawDataCollector"));
     _tagReport = ps.getUntrackedParameter<edm::InputTag>("tagReport",
         edm::InputTag("hcalDigis"));
     _calibProcessing = ps.getUntrackedParameter<bool>("calibProcessing",
         false);
     _thresh_calib_nbadq = ps.getUntrackedParameter<int>("thresh_calib_nbadq",
         5000);
 
     _tokFEDs = consumes<FEDRawDataCollection>(_tagFEDs);
     _tokReport = consumes<HcalUnpackerReport>(_tagReport);
 
     _vflags.resize(nRawFlag);
     _vflags[fEvnMsm]=flag::Flag("EvnMsm");
     _vflags[fBcnMsm]=flag::Flag("BcnMsm");
     _vflags[fBadQ]=flag::Flag("BadQ");
     _vflags[fOrnMsm]=flag::Flag("OrnMsm");
 }

RawTask::~RawTask ( )

inlineoverride

Definition at line 28 of file RawTask.h.

References _process(), _resetMonitors(), beginLuminosityBlock(), bookHistograms(), and endLuminosityBlock().

28 {}

Member Function Documentation

void RawTask::_process	(	edm::Event const &	e,
		edm::EventSetup const &
	)

overrideprotectedvirtual

Implements hcaldqm::DQTask.

Definition at line 217 of file RawTask.cc.

References _calibProcessing, _cBadQuality_depth, _cBadQuality_FEDuTCA, _cBadQuality_FEDVME, _cBadQualityvsBX, _cBadQualityvsLS, _cBcnMsm_ElectronicsuTCA, _cBcnMsm_ElectronicsVME, _cDataSizevsLS_FED, _cEvnMsm_ElectronicsuTCA, _cEvnMsm_ElectronicsVME, _cOrnMsm_ElectronicsuTCA, _cOrnMsm_ElectronicsVME, hcaldqm::DQModule::_currentLS, _ehashmap, _filter_FEDsuTCA, _filter_FEDsVME, hcaldqm::DQModule::_logger, hcaldqm::DQModule::_ptype, _tagFEDs, _tagReport, _thresh_calib_nbadq, _tokFEDs, _tokReport, _xBadQLS, _xBcnMsmLS, _xEvnMsmLS, _xOrnMsmLS, hcaldqm::DQTask::_xQuality, hcal::AMC13Header::AMCId(), hcal::AMC13Header::AMCPayload(), hcal::AMC13Header::AMCSize(), hcal::AMC13Header::AMCSlot(), HcalUnpackerReport::bad_quality_begin(), HcalUnpackerReport::bad_quality_end(), HcalUnpackerReport::badQualityDigis(), edm::EventBase::bunchCrossing(), hcal::AMC13Header::bunchId(), HcalHTRData::check(), fwrapper::cs, FEDRawData::data(), ecaldqm::dccId(), Logger::dqmthrow(), runTauDisplay::eid, hcaldqm::ContainerXXX< STDTYPE >::exists(), hcaldqm::utilities::fed2crate(), hcaldqm::constants::FED_VME_MIN, FEDRawDataCollection::FEDData(), hcaldqm::constants::FIBER_uTCA_MIN1, hcaldqm::constants::FIBER_VME_MIN, hcaldqm::constants::FIBERCH_MIN, hcaldqm::Container2D::fill(), hcaldqm::ContainerSingle1D::fill(), hcaldqm::Container1D::fill(), hcaldqm::filter::HashFilter::filter(), hcaldqm::fOffline, hcaldqm::fOnline, hcaldqm::ContainerXXX< STDTYPE >::get(), HcalDCCHeader::getBunchId(), HcalHTRData::getBunchNumber(), edm::Event::getByToken(), HcalDCCHeader::getDCCEventNumber(), HcalHTRData::getL1ANumber(), HcalDCCHeader::getOrbitNumber(), HcalHTRData::getOrbitNumber(), HcalDCCHeader::getSourceId(), HcalDCCHeader::getSpigotData(), HcalChannelStatus::HcalCellDead, HcalChannelStatus::HcalCellMask, edm::InputTag::instance(), HcalGenericDetId::isHcalDetId(), HcalElectronicsId::isVMEid(), hcal::AMC13Header::l1aNumber(), HcalUHTRData::l1ANumber(), edm::InputTag::label(), hcaldqm::electronicsmap::ElectronicsMap::lookup(), FEDNumbering::MAXHCALFEDID, FEDNumbering::MAXHCALuTCAFEDID, FEDNumbering::MINHCALFEDID, FEDNumbering::MINHCALuTCAFEDID, hcal::AMC13Header::NAMC(), groupFilesInBlocks::nn, hcal::AMC13Header::orbitNumber(), alignCSCRings::r, hcaldqm::constants::RAW_EMPTY, FEDRawData::size(), HcalDCCHeader::SPIGOT_COUNT, hcaldqm::constants::SPIGOT_MAX, and hcaldqm::constants::SPIGOT_MIN.

Referenced by ~RawTask().

 {
     edm::Handle<FEDRawDataCollection> craw;
     edm::Handle<HcalUnpackerReport> creport;
     if (!e.getByToken(_tokFEDs, craw))
         _logger.dqmthrow("Collection FEDRawDataCollection isn't available"+
             _tagFEDs.label()+" " +_tagFEDs.instance());
     if (!e.getByToken(_tokReport, creport))
         _logger.dqmthrow("Collection HcalUnpackerReport isn't available"+
             _tagReport.label()+" " +_tagReport.instance());
 
     //  extract some info
     int bx = e.bunchCrossing();
 
     /*
      *  For Calibration/Abort Gap Processing
      *  check if the #channels taht are bad from the unpacker 
      *  is > 5000. If it is skip...
      */
     if (_calibProcessing)
     {
         int nbadq = creport->badQualityDigis();
         if (nbadq>=_thresh_calib_nbadq)
             return;
     }
     
     int nn = 0;
     //  loop thru and fill the detIds with bad quality
     //  NOTE: Calibration Channels are skipped!
     //  TODO: Include for Online Calibration Channels marked as bad
     //  a comment below is left on purpose!
     //_cBadQualityvsBX.fill(bx, creport->badQualityDigis());
     for (std::vector<DetId>::const_iterator it=creport->bad_quality_begin();
         it!=creport->bad_quality_end(); ++it)
     {
         //  skip non HCAL det ids
         if (!HcalGenericDetId(*it).isHcalDetId())
             continue;
 
         //  skip those that are of bad quality from conditions
         //  Masked or Dead
         if (_xQuality.exists(HcalDetId(*it)))
         {
             HcalChannelStatus cs(it->rawId(), _xQuality.get(HcalDetId(*it)));
             if (cs.isBitSet(HcalChannelStatus::HcalCellMask) ||
                 cs.isBitSet(HcalChannelStatus::HcalCellDead))
             continue;
         }
 
         nn++;
         HcalElectronicsId eid = HcalElectronicsId(_ehashmap.lookup(*it));
         _cBadQuality_depth.fill(HcalDetId(*it));
         //  ONLINE ONLY!
         if (_ptype==fOnline)
             _xBadQLS.get(eid)++;
         if (_ptype != fOffline) { // hidefed2crate
             if (eid.isVMEid())
             {
                 if (_filter_FEDsVME.filter(eid))
                     continue;
                 _cBadQuality_FEDVME.fill(eid);
             }
             else
             {
                 if (_filter_FEDsuTCA.filter(eid))
                     continue;
                 _cBadQuality_FEDuTCA.fill(eid);
             }
         }
     }
     _cBadQualityvsLS.fill(_currentLS,nn);
     _cBadQualityvsBX.fill(bx, nn);
 
     if (_ptype != fOffline) { // hidefed2crate
         for (int fed=FEDNumbering::MINHCALFEDID; fed<=FEDNumbering::MAXHCALuTCAFEDID; fed++) {
             //  skip nonHCAL FEDs
             if ((fed>FEDNumbering::MAXHCALFEDID &&
                 fed<FEDNumbering::MINHCALuTCAFEDID) || 
                 fed>FEDNumbering::MAXHCALuTCAFEDID)
                 continue;
             FEDRawData const& raw = craw->FEDData(fed);
             if (raw.size()<constants::RAW_EMPTY)
                 continue;
 
             if (fed<=FEDNumbering::MAXHCALFEDID)    // VME
             {
                 HcalDCCHeader const* hdcc = (HcalDCCHeader const*)(raw.data());
                 if (!hdcc)
                     continue;
 
                 uint32_t bcn = hdcc->getBunchId();
                 uint32_t orn = hdcc->getOrbitNumber() & 0x1F; // LS 5 bits only
                 uint32_t evn = hdcc->getDCCEventNumber();
                 int dccId = hdcc->getSourceId()-constants::FED_VME_MIN;
 
                 /* online only */
                 if (_ptype==fOnline)
                 {
                     HcalElectronicsId eid = HcalElectronicsId(constants::FIBERCH_MIN,
                         constants::FIBER_VME_MIN, constants::SPIGOT_MIN, dccId);
                     if (_filter_FEDsVME.filter(eid))
                         continue;
                     _cDataSizevsLS_FED.fill(eid, _currentLS, double(raw.size())/1024.);
                 }
 
                 //  iterate over spigots
                 HcalHTRData htr;
                 for (int is=0; is<HcalDCCHeader::SPIGOT_COUNT; is++)
                 {
                     int r = hdcc->getSpigotData(is, htr, raw.size());
                     if (r!=0 || !htr.check())
                         continue;
                     HcalElectronicsId eid = HcalElectronicsId(
                         constants::FIBERCH_MIN, constants::FIBER_VME_MIN,
                         is, dccId);
                     if (_filter_FEDsVME.filter(eid))
                         continue;
 
                     uint32_t htr_evn = htr.getL1ANumber();
                     uint32_t htr_orn = htr.getOrbitNumber();
                     uint32_t htr_bcn = htr.getBunchNumber();
                     bool qevn = (htr_evn!=evn);
                     bool qbcn = (htr_bcn!=bcn);
                     bool qorn = (htr_orn!=orn);
                     if (qevn)
                     {
                         _cEvnMsm_ElectronicsVME.fill(eid);
 
                         if (_ptype==fOnline && is<=constants::SPIGOT_MAX)
                             _xEvnMsmLS.get(eid)++;
                     }
                     if (qorn)
                     {
                         _cOrnMsm_ElectronicsVME.fill(eid);
 
                         if (_ptype==fOnline && is<=constants::SPIGOT_MAX)
                             _xOrnMsmLS.get(eid)++;
                     }
                     if (qbcn)
                     {
                         _cBcnMsm_ElectronicsVME.fill(eid);
 
                         if (_ptype==fOnline && is<=constants::SPIGOT_MAX)
                             _xBcnMsmLS.get(eid)++;
                     }
                 }
             }
             else    // uTCA
             {
                 hcal::AMC13Header const* hamc13 = (hcal::AMC13Header const*)
                     raw.data();
                 if (!hamc13)
                     continue;
 
                 /* online only */
                 if (_ptype==fOnline)
                 {
                     std::pair<uint16_t, uint16_t> cspair = utilities::fed2crate(fed);
                     HcalElectronicsId eid = HcalElectronicsId(cspair.first,
                         cspair.second, FIBER_uTCA_MIN1, FIBERCH_MIN, false);
                     if (_filter_FEDsuTCA.filter(eid))
                         continue;
                     _cDataSizevsLS_FED.fill(eid, _currentLS, double(raw.size())/1024.);
                 }
 
                 uint32_t bcn = hamc13->bunchId();
                 uint32_t orn = hamc13->orbitNumber() & 0xFFFF; // LS 16bits only
                 uint32_t evn = hamc13->l1aNumber();
                 int namc = hamc13->NAMC();
 
                 for (int iamc=0; iamc<namc; iamc++)
                 {
                     int slot = hamc13->AMCSlot(iamc);
                     int crate = hamc13->AMCId(iamc)&0xFF;
                     HcalElectronicsId eid(crate, slot, FIBER_uTCA_MIN1,
                         FIBERCH_MIN, false);
                     if (_filter_FEDsuTCA.filter(eid))
                         continue;
                     HcalUHTRData uhtr(hamc13->AMCPayload(iamc),
                         hamc13->AMCSize(iamc));
 
                     uint32_t uhtr_evn = uhtr.l1ANumber();
                     uint32_t uhtr_bcn = uhtr.bunchNumber();
                     uint32_t uhtr_orn = uhtr.orbitNumber();
                     bool qevn = (uhtr_evn!=evn);
                     bool qbcn = (uhtr_bcn!=bcn);
                     bool qorn = (uhtr_orn!=orn);
                     if (qevn)
                     {
                         _cEvnMsm_ElectronicsuTCA.fill(eid);
 
                         if (_ptype==fOnline)
                             _xEvnMsmLS.get(eid)++;
                     }
                     if (qorn)
                     {
                         _cOrnMsm_ElectronicsuTCA.fill(eid);
 
                         if (_ptype==fOnline)
                             _xOrnMsmLS.get(eid)++;
                     }
                     if (qbcn)
                     {
                         _cBcnMsm_ElectronicsuTCA.fill(eid);
 
                         if (_ptype==fOnline)
                             _xBcnMsmLS.get(eid)++;
                     }
                 }
             }
         }
     }
 }

void RawTask::_resetMonitors ( hcaldqm::UpdateFreq uf )

overrideprotectedvirtual

Reimplemented from hcaldqm::DQTask.

Definition at line 211 of file RawTask.cc.

Referenced by ~RawTask().

 {
     //  base reset
     DQTask::_resetMonitors(uf);
 }

void RawTask::beginLuminosityBlock	(	edm::LuminosityBlock const &	lb,
		edm::EventSetup const &	es
	)

override

Definition at line 432 of file RawTask.cc.

References hcaldqm::DQModule::_ptype, and hcaldqm::fOnline.

Referenced by ~RawTask().

 {
     DQTask::beginLuminosityBlock(lb, es);
 
 //  _cBadQualityvsLS.extendAxisRange(_currentLS);
 
     //  ONLINE ONLY!
     if (_ptype!=fOnline)
         return;
 //  _cSummaryvsLS_FED.extendAxisRange(_currentLS);
 //  _cSummaryvsLS.extendAxisRange(_currentLS);
     
 }

void RawTask::bookHistograms	(	DQMStore::IBooker &	ib,
		edm::Run const &	r,
		edm::EventSetup const &	es
	)

overridevirtual

Reimplemented from hcaldqm::DQTask.

Definition at line 29 of file RawTask.cc.

Referenced by ~RawTask().

 {
     DQTask::bookHistograms(ib,r,es);
 
     //  GET WHAT YOU NEED
     edm::ESHandle<HcalDbService> dbs;
     es.get<HcalDbRecord>().get(dbs);
     _emap = dbs->getHcalMapping();
     std::vector<uint32_t> vVME;
     std::vector<uint32_t> vuTCA;
     vVME.push_back(HcalElectronicsId(constants::FIBERCH_MIN, 
         constants::FIBER_VME_MIN, SPIGOT_MIN, CRATE_VME_MIN).rawId());
     vuTCA.push_back(HcalElectronicsId(CRATE_uTCA_MIN, SLOT_uTCA_MIN,
         FIBER_uTCA_MIN1, FIBERCH_MIN, false).rawId());
     _filter_VME.initialize(filter::fFilter, hcaldqm::hashfunctions::fElectronics,
         vVME);
     _filter_uTCA.initialize(filter::fFilter, hcaldqm::hashfunctions::fElectronics,
         vuTCA);
 
     _cBadQualityvsLS.initialize(_name, "BadQualityvsLS",
         new hcaldqm::quantity::LumiSection(_maxLS),
         new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN_m0to10000),0);
     _cBadQualityvsBX.initialize(_name, "BadQualityvsBX",
         new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fBX),
         new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN_m0to10000),0);
     _cBadQuality_depth.initialize(_name, "BadQuality",
         hcaldqm::hashfunctions::fdepth,
         new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fieta),
         new hcaldqm::quantity::DetectorQuantity(hcaldqm::quantity::fiphi),
         new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
 
     // FED-based plots
     if (_ptype != fOffline) { // hidefed2crate
         std::vector<int> vFEDs = hcaldqm::utilities::getFEDList(_emap);
         std::vector<int> vFEDsVME = hcaldqm::utilities::getFEDVMEList(_emap);
         std::vector<int> vFEDsuTCA = hcaldqm::utilities::getFEDuTCAList(_emap);
     
         std::vector<uint32_t> vhashFEDsVME;
         std::vector<uint32_t> vhashFEDsuTCA;
     
         for (std::vector<int>::const_iterator it=vFEDsVME.begin();
             it!=vFEDsVME.end(); ++it)
         {
             vhashFEDsVME.push_back(HcalElectronicsId(constants::FIBERCH_MIN,
                 constants::FIBER_VME_MIN, SPIGOT_MIN,
                 (*it)-constants::FED_VME_MIN).rawId());
             _vhashFEDs.push_back(HcalElectronicsId(constants::FIBERCH_MIN,
                 constants::FIBER_VME_MIN, SPIGOT_MIN,
                 (*it)-constants::FED_VME_MIN).rawId());
         }
         for (std::vector<int>::const_iterator it=vFEDsuTCA.begin();
             it!=vFEDsuTCA.end(); ++it)
         {
             std::pair<uint16_t, uint16_t> cspair = utilities::fed2crate(*it);
             vhashFEDsuTCA.push_back(HcalElectronicsId(
                 cspair.first, cspair.second, FIBER_uTCA_MIN1,
                 FIBERCH_MIN, false).rawId());
             _vhashFEDs.push_back(HcalElectronicsId(
                 cspair.first, cspair.second, FIBER_uTCA_MIN1,
                 FIBERCH_MIN, false).rawId());
         }
         _filter_FEDsVME.initialize(filter::fPreserver, 
             hcaldqm::hashfunctions::fFED, vhashFEDsVME);
         _filter_FEDsuTCA.initialize(filter::fPreserver,
             hcaldqm::hashfunctions::fFED, vhashFEDsuTCA);
 
         //  INITIALIZE FIRST
         _cEvnMsm_ElectronicsVME.initialize(_name, "EvnMsm",
             hcaldqm::hashfunctions::fElectronics,
             new hcaldqm::quantity::FEDQuantity(vFEDsVME),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
         _cBcnMsm_ElectronicsVME.initialize(_name, "BcnMsm",
             hcaldqm::hashfunctions::fElectronics,
             new hcaldqm::quantity::FEDQuantity(vFEDsVME),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
         _cOrnMsm_ElectronicsVME.initialize(_name, "OrnMsm",
             hcaldqm::hashfunctions::fElectronics,
             new hcaldqm::quantity::FEDQuantity(vFEDsVME),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
         _cEvnMsm_ElectronicsuTCA.initialize(_name, "EvnMsm",
             hcaldqm::hashfunctions::fElectronics,
             new hcaldqm::quantity::FEDQuantity(vFEDsuTCA),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
         _cBcnMsm_ElectronicsuTCA.initialize(_name, "BcnMsm",
             hcaldqm::hashfunctions::fElectronics,
             new hcaldqm::quantity::FEDQuantity(vFEDsuTCA),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
         _cOrnMsm_ElectronicsuTCA.initialize(_name, "OrnMsm",
             hcaldqm::hashfunctions::fElectronics,
             new hcaldqm::quantity::FEDQuantity(vFEDsuTCA),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
 
         //  Bad Quality
         _cBadQuality_FEDVME.initialize(_name, "BadQuality",
             hcaldqm::hashfunctions::fFED,
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSpigot),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberVMEFiberCh),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
         _cBadQuality_FEDuTCA.initialize(_name, "BadQuality",
             hcaldqm::hashfunctions::fFED,
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fSlotuTCA),
             new hcaldqm::quantity::ElectronicsQuantity(hcaldqm::quantity::fFiberuTCAFiberCh),
             new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fN),0);
 
         //  Online only
         if (_ptype==fOnline)
         {
             _xEvnMsmLS.initialize(hcaldqm::hashfunctions::fFED);
             _xBcnMsmLS.initialize(hcaldqm::hashfunctions::fFED);
             _xOrnMsmLS.initialize(hcaldqm::hashfunctions::fFED);
             _xBadQLS.initialize(hcaldqm::hashfunctions::fFED);
             _cSummaryvsLS_FED.initialize(_name, "SummaryvsLS",
                 hcaldqm::hashfunctions::fFED,
                 new hcaldqm::quantity::LumiSection(_maxLS),
                 new hcaldqm::quantity::FlagQuantity(_vflags),
                 new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fState),0);
             _cSummaryvsLS.initialize(_name, "SummaryvsLS",
                 new hcaldqm::quantity::LumiSection(_maxLS),
                 new hcaldqm::quantity::FEDQuantity(vFEDs),
                 new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fState),0);
             //  FED Size vs LS
             _cDataSizevsLS_FED.initialize(_name, "DataSizevsLS",
                 hcaldqm::hashfunctions::fFED,
                 new hcaldqm::quantity::LumiSection(_maxLS),
                 new hcaldqm::quantity::ValueQuantity(hcaldqm::quantity::fDataSize),0);
         }
 
     }
 
 
     //  BOOK HISTOGRAMS
     if (_ptype != fOffline) {
         _cEvnMsm_ElectronicsVME.book(ib, _emap, _filter_uTCA, _subsystem);
         _cBcnMsm_ElectronicsVME.book(ib, _emap, _filter_uTCA, _subsystem);
         _cOrnMsm_ElectronicsVME.book(ib, _emap, _filter_uTCA, _subsystem);
         _cEvnMsm_ElectronicsuTCA.book(ib, _emap, _filter_VME, _subsystem);
         _cBcnMsm_ElectronicsuTCA.book(ib, _emap, _filter_VME, _subsystem);
         _cOrnMsm_ElectronicsuTCA.book(ib, _emap, _filter_VME, _subsystem);
 
         _cBadQuality_FEDVME.book(ib, _emap, _filter_uTCA, _subsystem);
         _cBadQuality_FEDuTCA.book(ib, _emap, _filter_VME, _subsystem);
     }
     _cBadQuality_depth.book(ib, _emap, _subsystem);
     _cBadQualityvsLS.book(ib, _subsystem);
     _cBadQualityvsBX.book(ib, _subsystem);
 
     // BOOK HISTOGRAMS to be used in ONLINE ONLY!
     if (_ptype==fOnline)
     {
         _xEvnMsmLS.book(_emap);
         _xBcnMsmLS.book(_emap);
         _xOrnMsmLS.book(_emap);
         _xBadQLS.book(_emap);
         _cSummaryvsLS_FED.book(ib, _emap, _subsystem);
         _cSummaryvsLS.book(ib, _subsystem);
         _cDataSizevsLS_FED.book(ib, _emap, _subsystem);
     }
 
     //  FOR OFFLINE PROCESSING MARK THESE HISTOGRAMS AS LUMI BASED
     if (_ptype==fOffline)
     {
         if (_ptype != fOffline) { // hidefed2crate
             // Note that this is deliberately contradictory for the fed2crate fix, so it can be reversed if fed2crate is ever fixed properly,
             _cEvnMsm_ElectronicsVME.setLumiFlag();
             _cBcnMsm_ElectronicsVME.setLumiFlag();
             _cEvnMsm_ElectronicsuTCA.setLumiFlag();
             _cBcnMsm_ElectronicsuTCA.setLumiFlag();
         }
         _cBadQuality_depth.setLumiFlag();
     }
 
     //  initialize hash map
     _ehashmap.initialize(_emap, hcaldqm::electronicsmap::fD2EHashMap);
 }

void RawTask::endLuminosityBlock	(	edm::LuminosityBlock const &	lb,
		edm::EventSetup const &	es
	)

override

Definition at line 447 of file RawTask.cc.

References _cSummaryvsLS, _cSummaryvsLS_FED, hcaldqm::DQModule::_currentLS, hcaldqm::DQModule::_evsPerLS, hcaldqm::DQModule::_ptype, hcaldqm::flag::Flag::_state, hcaldqm::DQTask::_vcdaqEids, _vflags, _vhashFEDs, _xBadQLS, _xBcnMsmLS, _xEvnMsmLS, _xOrnMsmLS, DEFINE_FWK_MODULE, runTauDisplay::eid, hcaldqm::flag::fBAD, fBadQ, fBcnMsm, fEvnMsm, hcaldqm::flag::fGOOD, spr::find(), hcaldqm::flag::fNCDAQ, hcaldqm::fOnline, fOrnMsm, hcaldqm::flag::fPROBLEMATIC, hcaldqm::ContainerXXX< STDTYPE >::get(), hcaldqm::utilities::isFEDHBHE(), hcaldqm::utilities::isFEDHF(), hcaldqm::utilities::isFEDHO(), hcaldqm::ContainerXXX< STDTYPE >::reset(), hcaldqm::flag::Flag::reset(), hcaldqm::Container2D::setBinContent(), and hcaldqm::ContainerSingle2D::setBinContent().

Referenced by ~RawTask().

 {
     if (_ptype!=fOnline)
         return;
 
     //  
     //  GENERATE STATUS ONLY FOR ONLINE!
     //
     for (std::vector<uint32_t>::const_iterator it=_vhashFEDs.begin();
         it!=_vhashFEDs.end(); ++it)
     {
         flag::Flag fSum("RAW");
         HcalElectronicsId eid = HcalElectronicsId(*it);
 
         std::vector<uint32_t>::const_iterator cit=std::find(
             _vcdaqEids.begin(), _vcdaqEids.end(), *it);
         if (cit==_vcdaqEids.end())
         {
             // not @cDAQ
             for (uint32_t iflag=0; iflag<_vflags.size(); iflag++)
                 _cSummaryvsLS_FED.setBinContent(eid, _currentLS, int(iflag),
                     int(flag::fNCDAQ));
             _cSummaryvsLS.setBinContent(eid, _currentLS, int(flag::fNCDAQ));
             continue;
         }
 
         //  FED is @cDAQ
         if (hcaldqm::utilities::isFEDHBHE(eid) || hcaldqm::utilities::isFEDHF(eid) ||
             hcaldqm::utilities::isFEDHO(eid))
         {
             if (_xEvnMsmLS.get(eid)>0)
                 _vflags[fEvnMsm]._state = flag::fBAD;
             else
                 _vflags[fEvnMsm]._state = flag::fGOOD;
             if (_xBcnMsmLS.get(eid)>0)
                 _vflags[fBcnMsm]._state = flag::fBAD;
             else
                 _vflags[fBcnMsm]._state = flag::fGOOD;
             if (_xOrnMsmLS.get(eid)>0)
                 _vflags[fOrnMsm]._state = flag::fBAD;
             else
                 _vflags[fOrnMsm]._state = flag::fGOOD;
             if (double(_xBadQLS.get(eid))>double(12*_evsPerLS))
                 _vflags[fBadQ]._state = flag::fBAD;
             else if (_xBadQLS.get(eid)>0)
                 _vflags[fBadQ]._state = flag::fPROBLEMATIC;
             else
                 _vflags[fBadQ]._state = flag::fGOOD;
         }
 
         int iflag=0;
         //  iterate over all flags:
         //  - sum them all up in summary flag for this FED
         //  - reset each flag right after using it
         for (std::vector<flag::Flag>::iterator ft=_vflags.begin();
             ft!=_vflags.end(); ++ft)
         {
             _cSummaryvsLS_FED.setBinContent(eid, _currentLS, int(iflag),
                 ft->_state);
             fSum+=(*ft);
             iflag++;
 
             //  this is the MUST! We don't keep flags per FED, reset
             //  each one of them after using
             ft->reset();
         }
         _cSummaryvsLS.setBinContent(eid, _currentLS, fSum._state);
     }
 
     //  reset...
     _xOrnMsmLS.reset(); _xEvnMsmLS.reset(); _xBcnMsmLS.reset(); _xBadQLS.reset();
 
     //  in the end always do the DQTask::endLumi
     DQTask::endLuminosityBlock(lb, es);
 }