#include <OccupancyClient.h>

Inheritance diagram for ecaldqm::OccupancyClient:

Public Member Functions
	OccupancyClient ()

void	producePlots (ProcessType) override

	~OccupancyClient ()

Public Member Functions inherited from ecaldqm::DQWorkerClient
void	bookMEs (DQMStore &) override

	DQWorkerClient ()

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

void	releaseMEs () override

void	releaseSource ()

void	resetMEs ()

bool	retrieveSource (DQMStore const &, ProcessType)

void	setStatusManager (StatusManager const &_manager)

virtual	~DQWorkerClient ()

Public Member Functions inherited from ecaldqm::DQWorker
virtual void	beginLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &)

virtual void	beginRun (edm::Run const &, edm::EventSetup const &)

virtual void	bookMEs (DQMStore::IBooker &)

	DQWorker ()

virtual void	endRun (edm::Run const &, edm::EventSetup const &)

std::string const &	getName () const

bool	onlineMode () const

void	setEventNumber (edm::EventNumber_t _e)

void	setLumiNumber (edm::LuminosityBlockNumber_t _l)

void	setRunNumber (edm::RunNumber_t _r)

void	setTime (time_t _t)

virtual	~DQWorker ()

Private Member Functions
void	setParams (edm::ParameterSet const &) override

Private Attributes
float	deviationThreshold_

int	minHits_

Additional Inherited Members
Public Types inherited from ecaldqm::DQWorkerClient
enum	ProcessType { kLumi, kRun, nProcessType }

enum	Quality { kBad = 0, kGood = 1, kUnknown = 2, kMBad = 3, kMGood = 4, kMUnknown = 5 }

Static Public Member Functions inherited from ecaldqm::DQWorkerClient
static void	fillDescriptions (edm::ParameterSetDescription &)

Static Public Member Functions inherited from ecaldqm::DQWorker
static void	fillDescriptions (edm::ParameterSetDescription &_desc)

Protected Member Functions inherited from ecaldqm::DQWorkerClient
void	setME (edm::ParameterSet const &_ps) final

void	setSource (edm::ParameterSet const &) override

void	towerAverage_ (MESet &, MESet const &, float)

bool	using_ (std::string const &_name, ProcessType _type=kRun) const

Protected Member Functions inherited from ecaldqm::DQWorker
void	initialize (std::string const &_name, edm::ParameterSet const &)

void	print_ (std::string const &, int=0) const

void	setVerbosity (int _verbosity)

Protected Attributes inherited from ecaldqm::DQWorkerClient
std::set< std::string >	qualitySummaries_

MESetCollection	sources_

StatusManager const *	statusManager_

Protected Attributes inherited from ecaldqm::DQWorker
MESetCollection	MEs_

std::string	name_

bool	onlineMode_

Timestamp	timestamp_

int	verbosity_

bool	willConvertToEDM_

Detailed Description

Definition at line 8 of file OccupancyClient.h.

Constructor & Destructor Documentation

ecaldqm::OccupancyClient::OccupancyClient ( )

Definition at line 13 of file OccupancyClient.cc.

References ecaldqm::DQWorkerClient::qualitySummaries_.

                                    :
     DQWorkerClient(),
     minHits_(0),
     deviationThreshold_(0.)
   {
     qualitySummaries_.insert("QualitySummary");
   }

ecaldqm::OccupancyClient::~OccupancyClient ( )

inline

Definition at line 11 of file OccupancyClient.h.

11 {}

Member Function Documentation

void ecaldqm::OccupancyClient::producePlots ( ProcessType )

overridevirtual

Implements ecaldqm::DQWorkerClient.

Definition at line 29 of file OccupancyClient.cc.

References EcalTrigTowerDetId::detIdFromDenseIndex(), deviationThreshold_, EcalTriggerTower, python.tagInventory::entries, ecaldqm::getTrigTowerMap(), EcalTrigTowerDetId::ieta(), cmsHarvester::index, ecaldqm::DQWorkerClient::kBad, ecaldqm::DQWorkerClient::kGood, ecaldqm::DQWorkerClient::kMBad, ecaldqm::DQWorkerClient::kMGood, EcalTrigTowerDetId::kSizeForDenseIndexing, ecaldqm::DQWorker::MEs_, minHits_, EcalDQMStatusHelper::PEDESTAL_ONLINE_HIGH_GAIN_RMS_ERROR, EcalDQMStatusHelper::PHYSICS_BAD_CHANNEL_ERROR, EcalDQMStatusHelper::PHYSICS_BAD_CHANNEL_WARNING, ecaldqm::scConstituents(), ecaldqm::DQWorkerClient::sources_, ecaldqm::DQWorkerClient::statusManager_, ecaldqm::MESet::const_iterator::toNextChannel(), and EcalTrigTowerConstituentsMap::towerOf().

   {
     using namespace std;
 
     // number of allowed ieta indices
     // EE-: -28 to -1 with -27, -25 empty
     // EE+: 1 to 28 with 26, 28 empty
     unsigned const nPhiRings(56);
 
     MESet& meQualitySummary(MEs_.at("QualitySummary"));
 //     MESet& meHotDigi(MEs_.at("HotDigi"));
 //     MESet& meHotRecHitThr(MEs_.at("HotRecHitThr"));
 //     MESet& meHotTPDigiThr(MEs_.at("HotTPDigiThr"));
 
     MESet const& sDigi(sources_.at("DigiAll"));
     MESet const& sRecHitThr(sources_.at("RecHitThrAll"));
     MESet const& sTPDigiThr(sources_.at("TPDigiThrAll"));
 
     uint32_t mask(1 << EcalDQMStatusHelper::PEDESTAL_ONLINE_HIGH_GAIN_RMS_ERROR |
                   1 << EcalDQMStatusHelper::PHYSICS_BAD_CHANNEL_WARNING |
                   1 << EcalDQMStatusHelper::PHYSICS_BAD_CHANNEL_ERROR);
 
     double digiPhiRingMean[nPhiRings];
     std::fill_n(digiPhiRingMean, nPhiRings, 0.);
     double rechitPhiRingMean[nPhiRings];
     std::fill_n(rechitPhiRingMean, nPhiRings, 0.);
     int numCrystals[nPhiRings]; // this is static, but is easier to count now
     std::fill_n(numCrystals, nPhiRings, 0);
 
     MESet::const_iterator dEnd(sDigi.end());
     MESet::const_iterator rItr(sRecHitThr);
     for(MESet::const_iterator dItr(sDigi.beginChannel()); dItr != dEnd; dItr.toNextChannel()){
       rItr = dItr;
 
       float entries(dItr->getBinContent());
       float rhentries(rItr->getBinContent());
 
       DetId id(dItr->getId());
       int ieta(0);
       if(id.subdetId() == EcalTriggerTower) // barrel
         ieta = EcalTrigTowerDetId(id).ieta();
       else{
         std::vector<DetId> ids(scConstituents(EcalScDetId(id)));
         if(ids.size() == 0) continue;
         ieta = getTrigTowerMap()->towerOf(ids[0]).ieta();
       }
 
       unsigned index(ieta < 0 ? ieta + 28 : ieta + 27);
 
       digiPhiRingMean[index] += entries;
       rechitPhiRingMean[index] += rhentries;
       numCrystals[index] += 1;
     }
 
     for(unsigned ie(0); ie < nPhiRings; ie++){
       digiPhiRingMean[ie] /= numCrystals[ie];
       rechitPhiRingMean[ie] /= numCrystals[ie];
     }
 
     // second round to find hot towers
     for(MESet::const_iterator dItr(sDigi.beginChannel()); dItr != dEnd; dItr.toNextChannel()){
       DetId id(dItr->getId());
 
       bool doMask(meQualitySummary.maskMatches(id, mask, statusManager_));
 
       rItr = dItr;
 
       float entries(dItr->getBinContent());
       float rhentries(rItr->getBinContent());
 
       int ieta(0);
       if(id.subdetId() == EcalTriggerTower) // barrel
         ieta = EcalTrigTowerDetId(id).ieta();
       else{
         std::vector<DetId> ids(scConstituents(EcalScDetId(id)));
         if(ids.size() == 0) continue;
         ieta = getTrigTowerMap()->towerOf(ids[0]).ieta();
       }
 
       unsigned index(ieta < 0 ? ieta + 28 : ieta + 27);
 
       int quality(doMask ? kMGood : kGood);
 
       if(entries > minHits_ && entries > digiPhiRingMean[index] * deviationThreshold_){
         //        meHotDigi->fill(id);
         quality = doMask ? kMBad : kBad;
       }
       if(rhentries > minHits_ && rhentries > rechitPhiRingMean[index] * deviationThreshold_){
         //        meHotRecHitThr->fill(id);
         quality = doMask ? kMBad : kBad;
       }
 
       meQualitySummary.setBinContent(id, double(quality));
     }
 
     double tpdigiPhiRingMean[nPhiRings];
     std::fill_n(tpdigiPhiRingMean, nPhiRings, 0.);
 
     for(unsigned iTT(0); iTT < EcalTrigTowerDetId::kSizeForDenseIndexing; ++iTT){
       EcalTrigTowerDetId ttid(EcalTrigTowerDetId::detIdFromDenseIndex(iTT));
       float entries(sTPDigiThr.getBinContent(ttid));
 
       unsigned index(ttid.ieta() < 0 ? ttid.ieta() + 28 : ttid.ieta() + 27);
 
       tpdigiPhiRingMean[index] += entries;
     }
 
     for(int ie(0); ie < 28; ie++){
       float denom(-1.);
       if(ie < 27) denom = 72.;
       else denom = 36.;
       tpdigiPhiRingMean[ie] /= denom;
       tpdigiPhiRingMean[55 - ie] /= denom;
     }
 
     for(unsigned iTT(0); iTT < EcalTrigTowerDetId::kSizeForDenseIndexing; ++iTT){
       EcalTrigTowerDetId ttid(EcalTrigTowerDetId::detIdFromDenseIndex(iTT));
 
       float entries(sTPDigiThr.getBinContent(ttid));
 
       unsigned index(ttid.ieta() < 0 ? ttid.ieta() + 28 : ttid.ieta() + 27);
 
       int quality(kGood);
 
       if(entries > minHits_ && entries > tpdigiPhiRingMean[index] * deviationThreshold_){
         //        meHotTPDigiThr.fill(ttid);
         quality = kBad;
       }
 
       if(quality != kBad) continue;
 
       std::vector<DetId> ids(getTrigTowerMap()->constituentsOf(ttid));
       for(unsigned iD(0); iD < ids.size(); ++iD){
         DetId& id(ids[iD]);
 
         int quality(meQualitySummary.getBinContent(id));
         if(quality == kMBad || quality == kBad) continue;
 
         meQualitySummary.setBinContent(id, meQualitySummary.maskMatches(id, mask, statusManager_) ? kMBad : kBad);
       }
     }
   }

void ecaldqm::OccupancyClient::setParams ( edm::ParameterSet const & _params )

overrideprivatevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 22 of file OccupancyClient.cc.

References deviationThreshold_, edm::ParameterSet::getUntrackedParameter(), and minHits_.

   {
     minHits_ = _params.getUntrackedParameter<int>("minHits");
     deviationThreshold_ = _params.getUntrackedParameter<double>("deviationThreshold");
   }

Member Data Documentation

float ecaldqm::OccupancyClient::deviationThreshold_

private

Definition at line 19 of file OccupancyClient.h.

Referenced by producePlots(), and setParams().

int ecaldqm::OccupancyClient::minHits_

private

Definition at line 18 of file OccupancyClient.h.

Referenced by producePlots(), and setParams().

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation