FWLiteESRecordWriterAnalyzer Class Reference

#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::EDAnalyzer
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
	EDAnalyzer ()
SerialTaskQueue *	globalLuminosityBlocksQueue ()
SerialTaskQueue *	globalRunsQueue ()
ModuleDescription const &	moduleDescription () const
std::string	workerType () const
	~EDAnalyzer () 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 &&)=default
	EDConsumerBase (EDConsumerBase const &)=delete
ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const
std::vector< ESProxyIndex > 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::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const
EDConsumerBase &	operator= (EDConsumerBase &&)=default
EDConsumerBase const &	operator= (EDConsumerBase const &)=delete
bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const
bool	registeredToConsumeMany (TypeID const &, BranchType) const
ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const
void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
void	updateLookup (eventsetup::ESRecordsToProxyIndices 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	update (const edm::EventSetup &)

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::EDAnalyzer
typedef EDAnalyzer	ModuleType
Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels
Static Public Member Functions inherited from edm::EDAnalyzer
static const std::string &	baseType ()
static void	fillDescriptions (ConfigurationDescriptions &descriptions)
static void	prevalidate (ConfigurationDescriptions &)
static bool	wantsGlobalLuminosityBlocks ()
static bool	wantsGlobalRuns ()
static bool	wantsInputProcessBlocks ()
static bool	wantsProcessBlocks ()
static bool	wantsStreamLuminosityBlocks ()
static bool	wantsStreamRuns ()
Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)
template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept
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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()
template<Transition Tr = Transition::Event>
constexpr auto	esConsumes () noexcept
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)
template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag) noexcept
template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)
template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

Detailed Description

Description: [one line class summary]

Implementation: [Notes on implementation]

Definition at line 143 of file FWLiteESRecordWriterAnalyzer.cc.

Constructor & Destructor Documentation

FWLiteESRecordWriterAnalyzer()

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

explicit

Definition at line 175 of file FWLiteESRecordWriterAnalyzer.cc.

                                                                                         {
  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");
}

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

~FWLiteESRecordWriterAnalyzer()

FWLiteESRecordWriterAnalyzer::~FWLiteESRecordWriterAnalyzer ( )

override

Definition at line 194 of file FWLiteESRecordWriterAnalyzer.cc.

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

References m_file.

Member Function Documentation

analyze()

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

overrideprivatevirtual

Implements edm::EDAnalyzer.

Definition at line 274 of file FWLiteESRecordWriterAnalyzer.cc.

                                                                                         {
  update(iSetup);
}

References update().

beginJob()

void FWLiteESRecordWriterAnalyzer::beginJob ( void  )

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 279 of file FWLiteESRecordWriterAnalyzer.cc.

{}

beginLuminosityBlock()

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

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 285 of file FWLiteESRecordWriterAnalyzer.cc.

                                                                                                              {
  update(iSetup);
}

References update().

beginRun()

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

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 284 of file FWLiteESRecordWriterAnalyzer.cc.

{ update(iSetup); }

References update().

endJob()

void FWLiteESRecordWriterAnalyzer::endJob ( void  )

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 282 of file FWLiteESRecordWriterAnalyzer.cc.

{ m_file->Write(); }

References m_file.

update()

void FWLiteESRecordWriterAnalyzer::update ( const edm::EventSetup &  iSetup )

private

Definition at line 204 of file FWLiteESRecordWriterAnalyzer.cc.

                                                                     {
  using edm::eventsetup::heterocontainer::HCTypeTag;
  if (m_handlers.empty()) {
    //now we have access to the EventSetup so we can setup our data structure
    for (std::map<std::string, std::vector<std::pair<std::string, std::string> > >::iterator
             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 rec = iSetup.find(tt);
      if (not rec) {
        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
        std::vector<edm::eventsetup::DataKey> keys;
        rec->fillRegisteredDataKeys(keys);
        for (std::vector<edm::eventsetup::DataKey>::iterator itKey = keys.begin(), itKeyEnd = keys.end();
             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));
      }
      m_handlers.push_back(std::make_shared<RecordHandler>(rKey, m_file, dataInfos));
    }
  }
 
  for (std::vector<std::shared_ptr<RecordHandler> >::iterator it = m_handlers.begin(), itEnd = m_handlers.end();
       it != itEnd;
       ++it) {
    (*it)->update(iSetup);
  }
}

References data, Exception, edm::EventSetup::find(), edm::typelookup::findType(), relativeConstraints::keys, m_file, m_handlers, m_recordToDataNames, genParticles_cff::map, AlCaHLTBitMon_QueryRunRegistry::string, groupFilesInBlocks::tt, and trackerHitRTTI::vector.

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

Member Data Documentation

m_file

TFile* FWLiteESRecordWriterAnalyzer::m_file

private

Definition at line 161 of file FWLiteESRecordWriterAnalyzer.cc.

Referenced by endJob(), FWLiteESRecordWriterAnalyzer(), update(), and ~FWLiteESRecordWriterAnalyzer().

m_handlers

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

private

Definition at line 158 of file FWLiteESRecordWriterAnalyzer.cc.

Referenced by update().

m_recordToDataNames

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

private

Definition at line 160 of file FWLiteESRecordWriterAnalyzer.cc.

Referenced by FWLiteESRecordWriterAnalyzer(), and update().