#include <TriggerJSONMonitoring.h>

Inheritance diagram for TriggerJSONMonitoring:

Public Member Functions
virtual void	analyze (const edm::Event &, const edm::EventSetup &)

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

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

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

void	reset (bool changed=false)

	TriggerJSONMonitoring (const edm::ParameterSet &)

	~TriggerJSONMonitoring ()

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

	EDAnalyzer ()

ModuleDescription const &	moduleDescription () const

std::string	workerType () const

virtual	~EDAnalyzer ()

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 ()

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Private Attributes
std::string	baseRunDir

HLTConfigProvider	hltConfig_

std::vector< std::string >	hltNames_

std::vector< IntJ >	hltPaths_

std::string	jsonDefinitionFile

boost::shared_ptr < jsoncollector::FastMonitor >	jsonMonitor_

DataPointDefinition	outJson_

IntJ	processed_

edm::InputTag	triggerResults_

edm::EDGetTokenT < edm::TriggerResults >	triggerResultsToken_

Additional Inherited Members
Public Types inherited from edm::EDAnalyzer
typedef EDAnalyzer	ModuleType

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

Description: This class prints JSON files with trigger info.

Created: Wed, 09 Jul 2014

Author: Aram Avetisyan; Daniel Salerno

See header file for documentation

Author: Aram Avetisyan; Daniel Salerno

Definition at line 36 of file TriggerJSONMonitoring.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 22 of file TriggerJSONMonitoring.cc.

References edm::ParameterSet::exists(), edm::ParameterSet::getParameter(), triggerResults_, and triggerResultsToken_.

 {
   if (ps.exists("triggerResults")) triggerResults_ = ps.getParameter<edm::InputTag> ("triggerResults");
   else                             triggerResults_ = edm::InputTag("TriggerResults","","HLT");
   
   triggerResultsToken_ = consumes<edm::TriggerResults>(triggerResults_);
 }

TriggerJSONMonitoring::~TriggerJSONMonitoring ( )

Definition at line 30 of file TriggerJSONMonitoring.cc.

31 {

32 }

Member Function Documentation

void TriggerJSONMonitoring::analyze	(	const edm::Event &	iEvent,
		const edm::EventSetup &	iSetup
	)

virtual

Implements edm::EDAnalyzer.

Definition at line 42 of file TriggerJSONMonitoring.cc.

References edm::InputTag::encode(), edm::Event::getByToken(), hltNames_, hltPaths_, i, LogDebug, n, processed_, triggerResults_, triggerResultsToken_, and jsoncollector::IntJ::value().

 {
 
   using namespace std;
   using namespace edm;
 
   processed_.value()++;
 
   //Get hold of TriggerResults
   Handle<TriggerResults> HLTR;
   iEvent.getByToken(triggerResultsToken_, HLTR);
   if (!HLTR.isValid()) {
     LogDebug("TriggerJSONMonitoring") << "HLT TriggerResults with label ["+triggerResults_.encode()+"] not found!" << std::endl;
     return;
   }
   
   // decision for each HLT path
   const unsigned int n(hltNames_.size());
   for (unsigned int i=0; i<n; i++) {
     if (HLTR->accept(i)){
       hltPaths_[i].value()++;
     }
   }
 
 }

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

virtual

Reimplemented from edm::EDAnalyzer.

Definition at line 155 of file TriggerJSONMonitoring.cc.

References hltPaths_, i, jsonDefinitionFile, jsonMonitor_, outJson_, processed_, reset(), and AlCaHLTBitMon_QueryRunRegistry::string.

 {
 
   std::string outJsonDefName = jsonDefinitionFile;
 
   jsonMonitor_.reset(new jsoncollector::FastMonitor(&outJson_, false));
   jsonMonitor_->setDefPath(outJsonDefName);
   jsonMonitor_->registerGlobalMonitorable(&processed_,false);
 
   for(unsigned int i = 0; i < hltPaths_.size(); i++){
     jsonMonitor_->registerGlobalMonitorable(&hltPaths_[i], false);
   }
 
   jsonMonitor_->commit(nullptr);
 
   reset();
 }

void TriggerJSONMonitoring::beginRun	(	edm::Run const &	iRun,
		edm::EventSetup const &	iSetup
	)

virtual

Reimplemented from edm::EDAnalyzer.

Definition at line 92 of file TriggerJSONMonitoring.cc.

References jsoncollector::DataPointDefinition::addLegendItem(), baseRunDir, hltConfig_, hltNames_, hltPaths_, i, HLTConfigProvider::init(), j, jsonDefinitionFile, n, getDQMSummary::outfile, outJson_, edm::InputTag::process(), processed_, reset(), edm::RunBase::run(), jsoncollector::DataPointDefinition::setDefaultGroup(), jsoncollector::JsonMonitorable::setName(), SUM, and triggerResults_.

 {
 
    //Get the run directory from the EvFDaqDirector
    baseRunDir = edm::Service<evf::EvFDaqDirector>()->baseRunDir();
   
    // initialize hltConfig_
    bool changed = true;
    if (hltConfig_.init(iRun, iSetup, triggerResults_.process(), changed)) {
      reset(true);
    }
 
    // set up JSON
    processed_.setName("Processed");
 
    DataPointDefinition outJsonTemp_;
 
    outJsonTemp_.setDefaultGroup("data");
    outJsonTemp_.addLegendItem("Processed","integer",DataPointDefinition::SUM);
 
    const unsigned int n = hltNames_.size();
 
    for(unsigned int i =0; i<n; i++){
      hltPaths_[i].setName( hltNames_[i] );
      outJsonTemp_.addLegendItem(hltNames_[i],"integer",DataPointDefinition::SUM);
    }
 
    outJson_ = outJsonTemp_;
 
    // create JSON definition file
    unsigned int nRun = iRun.run();
 
    std::stringstream sjsd;
    sjsd << baseRunDir << "/mon/HLTRates_run"<< nRun; 
    sjsd << "_pid" << std::setfill('0') << std::setw(5) << getpid() << ".jsd";
    jsonDefinitionFile = sjsd.str();
    
    std::ofstream outfile( jsonDefinitionFile );
    outfile << "{" << std::endl;
    outfile << "   \"data\" : [" << std::endl;
    outfile << "      {" << std::endl;
    outfile << "         \"name\" : \"Processed\"," << std::endl;
    outfile << "         \"operation\" : \"sum\"," << std::endl;
    outfile << "         \"type\" : \"integer\"" << std::endl;
    
    for(unsigned int j =0; j<n; j++){
      outfile << "      }," << std::endl;
      outfile << "      {" << std::endl;
      outfile << "         \"name\" : \"" << hltNames_[j] << "\"," << std::endl;
      outfile << "         \"operation\" : \"sum\"," << std::endl;
      outfile << "         \"type\" : \"integer\"" << std::endl;
    } 
    
    outfile << "      }" << std::endl;
    outfile << "   ]" << std::endl;
    outfile << "}" << std::endl;
    
    outfile.close();
 
    //std::cout << "CurrentRunDir is " << RunDir << std::endl;  //***
 }

void TriggerJSONMonitoring::endLuminosityBlock	(	edm::LuminosityBlock const &	ls,
		edm::EventSetup const &
	)

virtual

Reimplemented from edm::EDAnalyzer.

Definition at line 174 of file TriggerJSONMonitoring.cc.

References baseRunDir, hltNames_, hltPaths_, i, jsonMonitor_, LogDebug, edm::LuminosityBlockBase::luminosityBlock(), edm::LuminosityBlockBase::run(), findQualityFiles::size, contentValuesCheck::ss, and AlCaHLTBitMon_QueryRunRegistry::string.

 {
 
   unsigned int uiLS  = ls.luminosityBlock();
   unsigned int uiRun = ls.run();
 
   jsonMonitor_->snap(uiLS);
 
   std::stringstream ss;
   ss << baseRunDir << "/mon/" << "HLTRates";
   ss << "_run" << uiRun << "_ls" << std::setfill('0') << std::setw(4) << uiLS;
   ss << "_pid" << std::setfill('0') << std::setw(5) << getpid() << ".jsn";
   std::string outputJsonNameStream = ss.str();
   
   jsonMonitor_->outputFullJSON(outputJsonNameStream, uiLS);
 
   // Debug output
   LogDebug("TriggerJSONMonitoring") << "i hltNames #Accepted" << std::endl;
   const unsigned int size = hltNames_.size();
   for (unsigned int i = 0; i < size; i++) {
     LogDebug("TriggerJSONMonitoring") << i                    << " "
                       << hltNames_[i]         << " "
                       << hltPaths_[i].value() << std::endl;
   }
 
 }

void TriggerJSONMonitoring::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 35 of file TriggerJSONMonitoring.cc.

References edm::ConfigurationDescriptions::add(), and edm::ParameterSetDescription::add().

                                                                                   {
   edm::ParameterSetDescription desc;
   desc.add<edm::InputTag>("triggerResults",edm::InputTag("TriggerResults","","HLT"));
   descriptions.add("triggerJSONMonitoring", desc);
 }

void TriggerJSONMonitoring::reset ( bool changed = false )

Definition at line 69 of file TriggerJSONMonitoring.cc.

References hltConfig_, hltNames_, hltPaths_, i, n, processed_, HLTConfigProvider::triggerNames(), and jsoncollector::IntJ::value().

Referenced by beginLuminosityBlock(), and beginRun().

                                          {
 
   processed_.value() = 0;
 
   // update trigger names
   if (changed) hltNames_ = hltConfig_.triggerNames();
 
   const unsigned int n = hltNames_.size();
 
   if (changed) {
     // resize per-path counter
     hltPaths_.resize(n);
   }
 
   // reset per-path counter
   for (unsigned int i = 0; i < n; i++) {
     hltPaths_[i].value() = 0;
   }
 
 }