ecaldqm::DQWorkerClient Class Reference

#include <DQWorkerClient.h>

Inheritance diagram for ecaldqm::DQWorkerClient:

Public Types
enum	ProcessType { kLumi, kJob, nProcessType }
enum	Quality {   kBad = 0, kGood = 1, kUnknown = 2, kMBad = 3,   kMGood = 4, kMUnknown = 5 }

Public Member Functions
void	bookMEs (DQMStore::IBooker &) override
	DQWorkerClient ()
void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override
virtual void	producePlots (ProcessType)=0
void	releaseMEs () override
void	releaseSource ()
virtual void	resetMEs ()
bool	retrieveSource (DQMStore::IGetter &, ProcessType)
bool	runsOn (ProcessType _type) const
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 &)
	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 ()

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

Protected Member Functions
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=kJob) 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
virtual void	setParams (edm::ParameterSet const &)
void	setVerbosity (int _verbosity)

Protected Attributes
bool	hasLumiPlots_
std::set< std::string >	qualitySummaries_
MESetCollection	sources_
StatusManager const *	statusManager_
Protected Attributes inherited from ecaldqm::DQWorker
bool	booked_
MESetCollection	MEs_
std::string	name_
bool	onlineMode_
Timestamp	timestamp_
int	verbosity_
bool	willConvertToEDM_

Detailed Description

Definition at line 14 of file DQWorkerClient.h.

Member Enumeration Documentation

enum ecaldqm::DQWorkerClient::ProcessType

Enumerator
kLumi
kJob
nProcessType

Definition at line 16 of file DQWorkerClient.h.

                     {
      kLumi,
      kJob,
      nProcessType
    };

enum ecaldqm::DQWorkerClient::Quality

Enumerator
kBad
kGood
kUnknown
kMBad
kMGood
kMUnknown

Definition at line 41 of file DQWorkerClient.h.

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

Constructor & Destructor Documentation

ecaldqm::DQWorkerClient::DQWorkerClient

(

)

Definition at line 18 of file DQWorkerClient.cc.

References hasLumiPlots_, and ecaldqm::DQWorker::MEs_.

                                 :
    DQWorker(),
    sources_(),
    qualitySummaries_(),
    hasLumiPlots_(false),
    statusManager_(0)
  {
    for(MESetCollection::iterator mItr(MEs_.begin()); mItr != MEs_.end(); ++mItr){
      if(mItr->second->getLumiFlag()){
        hasLumiPlots_ = true;
        break;
      }
    }
  }

virtual ecaldqm::DQWorkerClient::~DQWorkerClient ( )

inlinevirtual

Definition at line 23 of file DQWorkerClient.h.

{}

Member Function Documentation

void ecaldqm::DQWorkerClient::bookMEs ( DQMStore::IBooker &  _ibooker )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 85 of file DQWorkerClient.cc.

References ecaldqm::DQWorker::bookMEs(), and resetMEs().

Referenced by EcalDQMonitorClient::dqmEndLuminosityBlock().

  {
    DQWorker::bookMEs(_ibooker);
    resetMEs();
  }

void ecaldqm::DQWorkerClient::endLuminosityBlock ( edm::LuminosityBlock const &  , edm::EventSetup const &    )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Reimplemented in ecaldqm::TowerStatusTask.

Definition at line 72 of file DQWorkerClient.cc.

References sources_.

  {
// MESetChannel class removed until concurrency issue is finalized
#if 0
    for(MESetCollection::iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr){
      if(!sItr->second->getLumiFlag()) continue;
      MESetChannel const* channel(dynamic_cast<MESetChannel const*>(sItr->second));
      if(channel) channel->checkDirectory();
    }
#endif
  }

void ecaldqm::DQWorkerClient::fillDescriptions ( edm::ParameterSetDescription &  _desc )

static

Definition at line 35 of file DQWorkerClient.cc.

References edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::addWildcardUntracked(), ecaldqm::DQWorker::fillDescriptions(), ecaldqm::fillMESetDescriptions(), and edm::RequireZeroOrMore.

Referenced by EcalDQMonitorClient::fillDescriptions().

  {
    DQWorker::fillDescriptions(_desc);
    _desc.addWildcardUntracked<std::vector<std::string> >("*");

    edm::ParameterSetDescription sourceParameters;
    edm::ParameterSetDescription sourceNodeParameters;
    fillMESetDescriptions(sourceNodeParameters);
    sourceParameters.addNode(edm::ParameterWildcard<edm::ParameterSetDescription>("*", edm::RequireZeroOrMore, false, sourceNodeParameters));
    _desc.addUntracked("sources", sourceParameters);
  }

virtual void ecaldqm::DQWorkerClient::producePlots ( ProcessType  )

pure virtual

Implemented in ecaldqm::TowerStatusTask, ecaldqm::SummaryClient, ecaldqm::CalibrationSummaryClient, ecaldqm::CertificationClient, ecaldqm::IntegrityClient, ecaldqm::LaserClient, ecaldqm::LedClient, ecaldqm::OccupancyClient, ecaldqm::PedestalClient, ecaldqm::PNIntegrityClient, ecaldqm::PresampleClient, ecaldqm::RawDataClient, ecaldqm::SelectiveReadoutClient, ecaldqm::TestPulseClient, ecaldqm::TimingClient, and ecaldqm::TrigPrimClient.

Referenced by EcalDQMonitorClient::runWorkers().

void ecaldqm::DQWorkerClient::releaseMEs ( )

overridevirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 92 of file DQWorkerClient.cc.

References ecaldqm::DQWorker::releaseMEs(), and releaseSource().

  {
    DQWorker::releaseMEs();
    releaseSource();    
  }

void ecaldqm::DQWorkerClient::releaseSource

(

)

Definition at line 99 of file DQWorkerClient.cc.

References sources_.

Referenced by releaseMEs(), and EcalDQMonitorClient::runWorkers().

  {
    for(MESetCollection::iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr)
      sItr->second->clear();
  }

void ecaldqm::DQWorkerClient::resetMEs ( )

virtual

Reimplemented in ecaldqm::SummaryClient.

Definition at line 122 of file DQWorkerClient.cc.

References MonitorElement::DQM_KIND_TH2F, ecaldqm::MESet::getKind(), ecaldqm::MESetMulti::getMultiplicity(), kUnknown, ecaldqm::DQWorker::MEs_, trackerHitRTTI::multi, qualitySummaries_, ecaldqm::MESetMulti::reset(), ecaldqm::MESet::reset(), ecaldqm::MESetMulti::resetAll(), ecaldqm::MESet::resetAll(), and ecaldqm::MESetMulti::use().

Referenced by bookMEs(), ecaldqm::SummaryClient::resetMEs(), and EcalDQMonitorClient::runWorkers().

  {
    for(MESetCollection::iterator mItr(MEs_.begin()); mItr != MEs_.end(); ++mItr){
      MESet* meset(mItr->second);

      if(qualitySummaries_.find(mItr->first) != qualitySummaries_.end()){
        MESetMulti* multi(dynamic_cast<MESetMulti*>(meset));
        if(multi){
          for(unsigned iS(0); iS < multi->getMultiplicity(); ++iS){
            multi->use(iS);
            if(multi->getKind() == MonitorElement::DQM_KIND_TH2F){
              multi->resetAll(-1.);
              multi->reset(kUnknown);
            }
            else
              multi->reset(-1.);
          }
        }
        else{
          if(meset->getKind() == MonitorElement::DQM_KIND_TH2F){
            meset->resetAll(-1.);
            meset->reset(kUnknown);
          }
          else
            meset->reset(-1.);
        }
      }
      else
        meset->reset();
    }
  }    

bool ecaldqm::DQWorkerClient::retrieveSource	(	DQMStore::IGetter &	_igetter,
		ProcessType	_type
	)

Definition at line 106 of file DQWorkerClient.cc.

References kLumi, ecaldqm::DQWorker::name_, ecaldqm::DQWorker::onlineMode_, sources_, AlCaHLTBitMon_QueryRunRegistry::string, and ecaldqm::DQWorker::verbosity_.

Referenced by EcalDQMonitorClient::runWorkers().

  {
    std::string failedPath;
    for(MESetCollection::iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr){
      if(!onlineMode_ && _type == kLumi && !sItr->second->getLumiFlag()) continue;
      if(verbosity_ > 1) edm::LogInfo("EcalDQM") << name_ << ": Retrieving source " << sItr->first;
      if(!sItr->second->retrieve(_igetter, &failedPath)){
        if(verbosity_ > 1) edm::LogWarning("EcalDQM") << name_ << ": Could not find source " << sItr->first << "@" << failedPath;
        return false;
      }
    }

    return true;
  }

bool ecaldqm::DQWorkerClient::runsOn ( ProcessType  _type ) const

inline

Definition at line 35 of file DQWorkerClient.h.

References hasLumiPlots_, and kJob.

Referenced by EcalDQMonitorClient::dqmEndLuminosityBlock(), and EcalDQMonitorClient::runWorkers().

{ return _type == kJob || hasLumiPlots_; }

void ecaldqm::DQWorkerClient::setME ( edm::ParameterSet const &  _ps )

inlinefinalprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 51 of file DQWorkerClient.h.

References ecaldqm::DQWorker::setME().

{ DQWorker::setME(_ps); }

void ecaldqm::DQWorkerClient::setSource ( edm::ParameterSet const &  _params )

overrideprotectedvirtual

Reimplemented from ecaldqm::DQWorker.

Definition at line 48 of file DQWorkerClient.cc.

References ecaldqm::createMESet(), edm::ParameterSet::getParameterNames(), edm::ParameterSet::getUntrackedParameterSet(), mergeVDriftHistosByStation::name, ecaldqm::DQWorker::name_, ecaldqm::DQWorker::onlineMode_, sources_, contentValuesCheck::ss, AlCaHLTBitMon_QueryRunRegistry::string, and ecaldqm::DQWorker::verbosity_.

  {
    std::vector<std::string> const& sourceNames(_params.getParameterNames());

    for(unsigned iS(0); iS < sourceNames.size(); iS++){
      std::string name(sourceNames[iS]);
      edm::ParameterSet const& params(_params.getUntrackedParameterSet(name));

      if(onlineMode_ && params.getUntrackedParameter<bool>("online")) continue;
        
      sources_.insert(name, createMESet(params));
    }

    if(verbosity_ > 1){
      std::stringstream ss;
      ss << name_ << ": Using ";
      for(MESetCollection::const_iterator sItr(sources_.begin()); sItr != sources_.end(); ++sItr)
        ss << sItr->first << " ";
      ss << "as sources";
      edm::LogInfo("EcalDQM") << ss.str();
    }
  }

void ecaldqm::DQWorkerClient::setStatusManager ( StatusManager const &  _manager )

inline

Definition at line 39 of file DQWorkerClient.h.

References statusManager_.

Referenced by EcalDQMonitorClient::EcalDQMonitorClient().

{ statusManager_ = &_manager; }

void ecaldqm::DQWorkerClient::towerAverage_ ( MESet &  _target, MESet const &  _source, float  _threshold  )

protected

Definition at line 155 of file DQWorkerClient.cc.

References ecaldqm::MESet::beginChannel(), EcalTrigTowerConstituentsMap::constituentsOf(), ws_sso_content_reader::content, EcalTriggerTower, ecaldqm::MESet::end(), ecaldqm::MESet::getBinContent(), ecaldqm::getTrigTowerMap(), timingPdfMaker::mean, ecaldqm::scConstituents(), ecaldqm::MESet::iterator::toNextChannel(), and ecaldqm::towerId().

Referenced by ecaldqm::LaserClient::producePlots(), ecaldqm::TestPulseClient::producePlots(), ecaldqm::PresampleClient::producePlots(), ecaldqm::PedestalClient::producePlots(), and ecaldqm::LedClient::producePlots().

  {
    bool isQuality(_threshold > 0.);

    MESet::iterator tEnd(_target.end());
    for(MESet::iterator tItr(_target.beginChannel()); tItr != tEnd; tItr.toNextChannel()){
      DetId towerId(tItr->getId());

      std::vector<DetId> cryIds;
      if(towerId.subdetId() == EcalTriggerTower)
        cryIds = getTrigTowerMap()->constituentsOf(EcalTrigTowerDetId(towerId));
      else{
        cryIds = scConstituents(EcalScDetId(towerId));
      }

      if(cryIds.size() == 0) return;

      float mean(0.);
      float nValid(0.);
      bool masked(false);
      for(unsigned iId(0); iId < cryIds.size(); ++iId){
        float content(_source.getBinContent(cryIds[iId]));
        if(isQuality){
          if(content < 0. || content == 2.) continue;
          if(content == 5.) masked = true;
          else{
            nValid += 1;
            if(content > 2.){
              masked = true;
              mean += content - 3.;
            }
            else
              mean += content;
          }
        }
        else{
          mean += content;
          nValid += 1.;
        }
      }
      
      if(isQuality){
        if(nValid < 1.) tItr->setBinContent(masked ? 5. : 2.);
        else{
          mean /= nValid;
          if(mean < _threshold) tItr->setBinContent(masked ? 3. : 0.);
          else tItr->setBinContent(masked ? 4. : 1.);
        }
      }
      else
        tItr->setBinContent(nValid < 1. ? 0. : mean / nValid);
    }
  }

bool ecaldqm::DQWorkerClient::using_ ( std::string const &  _name, ProcessType  _type = kJob  ) const

inlineprotected

Definition at line 54 of file DQWorkerClient.h.

References kJob, and sources_.

Referenced by ecaldqm::CalibrationSummaryClient::producePlots(), ecaldqm::SummaryClient::producePlots(), and ecaldqm::CalibrationSummaryClient::setParams().

    {
      MESetCollection::const_iterator itr(sources_.find(_name));
      if(itr == sources_.end()) return false;
      if(_type == kJob) return true;
      else return itr->second->getLumiFlag();
    }

Member Data Documentation

bool ecaldqm::DQWorkerClient::hasLumiPlots_

protected

Definition at line 67 of file DQWorkerClient.h.

Referenced by DQWorkerClient(), and runsOn().

std::set<std::string> ecaldqm::DQWorkerClient::qualitySummaries_

protected

Definition at line 65 of file DQWorkerClient.h.

Referenced by ecaldqm::CertificationClient::CertificationClient(), ecaldqm::IntegrityClient::IntegrityClient(), ecaldqm::OccupancyClient::OccupancyClient(), ecaldqm::PNIntegrityClient::PNIntegrityClient(), ecaldqm::PresampleClient::PresampleClient(), ecaldqm::RawDataClient::RawDataClient(), resetMEs(), ecaldqm::CalibrationSummaryClient::setParams(), ecaldqm::TestPulseClient::setParams(), ecaldqm::PedestalClient::setParams(), ecaldqm::LaserClient::setParams(), ecaldqm::LedClient::setParams(), ecaldqm::SummaryClient::SummaryClient(), ecaldqm::TimingClient::TimingClient(), and ecaldqm::TrigPrimClient::TrigPrimClient().

MESetCollection ecaldqm::DQWorkerClient::sources_

protected

Definition at line 64 of file DQWorkerClient.h.

Referenced by endLuminosityBlock(), ecaldqm::CertificationClient::producePlots(), ecaldqm::TimingClient::producePlots(), ecaldqm::IntegrityClient::producePlots(), ecaldqm::PedestalClient::producePlots(), ecaldqm::PNIntegrityClient::producePlots(), ecaldqm::PresampleClient::producePlots(), ecaldqm::RawDataClient::producePlots(), ecaldqm::LaserClient::producePlots(), ecaldqm::SelectiveReadoutClient::producePlots(), ecaldqm::CalibrationSummaryClient::producePlots(), ecaldqm::LedClient::producePlots(), ecaldqm::TestPulseClient::producePlots(), ecaldqm::TrigPrimClient::producePlots(), ecaldqm::OccupancyClient::producePlots(), ecaldqm::SummaryClient::producePlots(), releaseSource(), retrieveSource(), ecaldqm::LaserClient::setParams(), ecaldqm::CalibrationSummaryClient::setParams(), ecaldqm::LedClient::setParams(), ecaldqm::TestPulseClient::setParams(), ecaldqm::PedestalClient::setParams(), ecaldqm::SummaryClient::setParams(), setSource(), and using_().

StatusManager const* ecaldqm::DQWorkerClient::statusManager_

protected

Definition at line 69 of file DQWorkerClient.h.

Referenced by ecaldqm::IntegrityClient::producePlots(), ecaldqm::TrigPrimClient::producePlots(), ecaldqm::TimingClient::producePlots(), ecaldqm::TestPulseClient::producePlots(), ecaldqm::RawDataClient::producePlots(), ecaldqm::LedClient::producePlots(), ecaldqm::PNIntegrityClient::producePlots(), ecaldqm::PedestalClient::producePlots(), ecaldqm::OccupancyClient::producePlots(), ecaldqm::PresampleClient::producePlots(), ecaldqm::LaserClient::producePlots(), and setStatusManager().