#include <PhysicsTools/FWLiteESRecordWriterAnalyzer/src/FWLiteESRecordWriterAnalyzer.cc>

Inheritance diagram for FWLiteESRecordWriterAnalyzer:

Public Member Functions
	FWLiteESRecordWriterAnalyzer (const edm::ParameterSet &)

	~FWLiteESRecordWriterAnalyzer () override

Public Member Functions inherited from edm::one::EDAnalyzer< edm::one::WatchRuns, edm::one::WatchLuminosityBlocks >
	EDAnalyzer ()=default

	EDAnalyzer (const EDAnalyzer &)=delete

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

const EDAnalyzer &	operator= (const EDAnalyzer &)=delete

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () const final

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

	EDAnalyzerBase ()

ModuleDescription const &	moduleDescription () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

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

ESResolverIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESResolverIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const

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::array< std::vector< ModuleDescription const > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, 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

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProductResolverIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Private Member Functions
void	analyze (const edm::Event &, const edm::EventSetup &) override

void	beginJob () override

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

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

void	endJob () override

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

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

void	registerLateConsumes (edm::eventsetup::ESRecordsToProductResolverIndices const &) final

void	update (const edm::EventSetup &, bool isRun)

Private Attributes
TFile *	m_file

std::vector< std::shared_ptr< RecordHandler > >	m_handlers

std::map< std::string, std::vector< std::pair< std::string, std::string > > >	m_recordToDataNames

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

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

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

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes ()

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag)

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

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)

void	resetItemsToGetFrom (BranchType iType)

Detailed Description

Description: [one line class summary]

Implementation: [Notes on implementation]

Definition at line 235 of file FWLiteESRecordWriterAnalyzer.cc.

Constructor & Destructor Documentation

◆ FWLiteESRecordWriterAnalyzer()

FWLiteESRecordWriterAnalyzer::FWLiteESRecordWriterAnalyzer ( const edm::ParameterSet & iConfig )

explicit

Definition at line 271 of file FWLiteESRecordWriterAnalyzer.cc.

References edm::errors::Configuration, data, Exception, edm::ParameterSet::getParameterNamesForType(), edm::ParameterSet::getUntrackedParameter(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, label, m_file, m_recordToDataNames, names, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                          {
   std::vector<std::string> names = iConfig.getParameterNamesForType<std::vector<edm::ParameterSet> >(false);
   if (names.empty()) {
     throw edm::Exception(edm::errors::Configuration) << "No VPSets were given in configuration";
   }
   for (std::vector<std::string>::const_iterator it = names.begin(), itEnd = names.end(); it != itEnd; ++it) {
     const std::vector<edm::ParameterSet>& ps = iConfig.getUntrackedParameter<std::vector<edm::ParameterSet> >(*it);
     std::vector<std::pair<std::string, std::string> >& data = m_recordToDataNames[*it];
     for (std::vector<edm::ParameterSet>::const_iterator itPS = ps.begin(), itPSEnd = ps.end(); itPS != itPSEnd;
          ++itPS) {
       std::string type = itPS->getUntrackedParameter<std::string>("type");
       std::string label = itPS->getUntrackedParameter<std::string>("label", std::string());
       data.push_back(std::make_pair(type, label));
     }
   }
 
   m_file = TFile::Open(iConfig.getUntrackedParameter<std::string>("fileName").c_str(), "NEW");
 }

◆ ~FWLiteESRecordWriterAnalyzer()

FWLiteESRecordWriterAnalyzer::~FWLiteESRecordWriterAnalyzer ( )

override

Definition at line 349 of file FWLiteESRecordWriterAnalyzer.cc.

References m_file.

                                                             {
   // do anything here that needs to be done at desctruction time
   // (e.g. close files, deallocate resources etc.)
   m_file->Close();
   delete m_file;
 }

Member Function Documentation

◆ analyze()

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

overrideprivatevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 368 of file FWLiteESRecordWriterAnalyzer.cc.

368 {}

◆ beginJob()

void FWLiteESRecordWriterAnalyzer::beginJob ( void )

overrideprivatevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 371 of file FWLiteESRecordWriterAnalyzer.cc.

371 {}

◆ beginLuminosityBlock()

void FWLiteESRecordWriterAnalyzer::beginLuminosityBlock	(	edm::LuminosityBlock const &	,
		edm::EventSetup const &	iSetup
	)

overrideprivate

Definition at line 377 of file FWLiteESRecordWriterAnalyzer.cc.

References update().

                                                                                                               {
   update(iSetup, false);
 }

◆ beginRun()

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

overrideprivate

Definition at line 376 of file FWLiteESRecordWriterAnalyzer.cc.

References update().

376 { update(iSetup, true); }

FWLiteESRecordWriterAnalyzer::update

void update(const edm::EventSetup &, bool isRun)

Definition: FWLiteESRecordWriterAnalyzer.cc:359

◆ endJob()

void FWLiteESRecordWriterAnalyzer::endJob ( void )

overrideprivatevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 374 of file FWLiteESRecordWriterAnalyzer.cc.

References m_file.

374 { m_file->Write(); }

FWLiteESRecordWriterAnalyzer::m_file

TFile * m_file

Definition: FWLiteESRecordWriterAnalyzer.cc:257

◆ endLuminosityBlock()

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

inlineoverrideprivate

Definition at line 246 of file FWLiteESRecordWriterAnalyzer.cc.

246 {}

◆ endRun()

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

inlineoverrideprivate

Definition at line 247 of file FWLiteESRecordWriterAnalyzer.cc.

247 {}

◆ registerLateConsumes()

void FWLiteESRecordWriterAnalyzer::registerLateConsumes ( edm::eventsetup::ESRecordsToProductResolverIndices const & iInfo )

finalprivatevirtual

Reimplemented from edm::EDConsumerBase.

Definition at line 290 of file FWLiteESRecordWriterAnalyzer.cc.

References data, Exception, edm::typelookup::findType(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, relativeConstraints::keys, edm::eventsetup::ESRecordsToProductResolverIndices::keysForRecord(), m_file, m_handlers, m_recordToDataNames, edm::eventsetup::ESRecordsToProductResolverIndices::missingRecordIndex(), edm::eventsetup::ESRecordsToProductResolverIndices::recordIndexFor(), AlCaHLTBitMon_QueryRunRegistry::string, and trackerHitRTTI::vector.

                                                                  {
   using edm::eventsetup::heterocontainer::HCTypeTag;
 
   for (auto it = m_recordToDataNames.begin(), itEnd = m_recordToDataNames.end(); it != itEnd; ++it) {
     HCTypeTag tt = HCTypeTag::findType(it->first);
     if (tt == HCTypeTag()) {
       throw cms::Exception("UnknownESRecordType")
           << "The name '" << it->first
           << "' is not associated with a known EventSetupRecord.\n"
              "Please check spelling or load a module known to link with the package which declares that Record.";
     }
     edm::eventsetup::EventSetupRecordKey rKey(tt);
 
     auto recIndex = iInfo.recordIndexFor(rKey);
     if (recIndex == iInfo.missingRecordIndex()) {
       throw cms::Exception("UnknownESRecordType")
           << "The name '" << it->first
           << "' is not associated with a type which is not an EventSetupRecord.\n"
              "Please check your spelling.";
     }
 
     //now figure out what data
     std::vector<std::pair<std::string, std::string> >& data = it->second;
     if (data.empty()) {
       //get everything from the record
       auto keys = iInfo.keysForRecord(rKey);
       for (auto itKey = keys.first, itKeyEnd = keys.second; itKey != itKeyEnd; ++itKey) {
         data.push_back(std::make_pair(std::string(itKey->type().name()), std::string(itKey->name().value())));
       }
     }
 
     std::vector<DataInfo> dataInfos;
     for (std::vector<std::pair<std::string, std::string> >::iterator itData = data.begin(), itDataEnd = data.end();
          itData != itDataEnd;
          ++itData) {
       HCTypeTag tt = HCTypeTag::findType(itData->first);
       if (tt == HCTypeTag()) {
         throw cms::Exception("UnknownESDataType")
             << "The name '" << itData->first << "' is not associated with a known type held in the " << it->first
             << " Record.\n"
                "Please check spelling or load a module known to link with the package which declares that type.";
       }
       if (!bool(edm::TypeWithDict(tt.value()))) {
         throw cms::Exception("NoDictionary")
             << "The type '" << itData->first << "' can not be retrieved from the Record " << it->first
             << " and stored \n"
                "because no dictionary exists for the type.";
       }
       dataInfos.push_back(DataInfo(tt, itData->second));
       dataInfos.back().m_runToken =
           esConsumes<edm::Transition::BeginRun>(rKey, edm::eventsetup::DataKey(tt, itData->second.c_str()));
       dataInfos.back().m_lumiToken =
           esConsumes<edm::Transition::BeginLuminosityBlock>(rKey, edm::eventsetup::DataKey(tt, itData->second.c_str()));
     }
     m_handlers.push_back(std::make_shared<RecordHandler>(rKey, m_file, dataInfos));
   }
 }

◆ update()

void FWLiteESRecordWriterAnalyzer::update	(	const edm::EventSetup &	iSetup,
		bool	isRun
	)

private

Definition at line 359 of file FWLiteESRecordWriterAnalyzer.cc.

References ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, m_handlers, and trackerHitRTTI::vector.

Referenced by progressbar.ProgressBar::__next__(), MatrixUtil.Matrix::__setitem__(), MatrixUtil.Steps::__setitem__(), beginLuminosityBlock(), beginRun(), progressbar.ProgressBar::finish(), and MatrixUtil.Steps::overwrite().

                                                                                  {
   for (std::vector<std::shared_ptr<RecordHandler> >::iterator it = m_handlers.begin(), itEnd = m_handlers.end();
        it != itEnd;
        ++it) {
     (*it)->update(iSetup, isRun);
   }
 }