CMS 3D CMS Logo

List of all members | Public Member Functions | Private Member Functions | Private Attributes
FWLiteESRecordWriterAnalyzer Class Reference

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

Inheritance diagram for FWLiteESRecordWriterAnalyzer:
edm::EDAnalyzer edm::EDConsumerBase

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 ()
 
SerialTaskQueueglobalLuminosityBlocksQueue ()
 
SerialTaskQueueglobalRunsQueue ()
 
ModuleDescription const & moduleDescription () const
 
std::string workerType () const
 
 ~EDAnalyzer () override
 
- Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfoconsumesInfo () 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
 
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
 
EDConsumerBaseoperator= (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 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>
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<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto esConsumes (ESInputTag const &tag)
 
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.

175  {
176  std::vector<std::string> names = iConfig.getParameterNamesForType<std::vector<edm::ParameterSet> >(false);
177  if (names.empty()) {
178  throw edm::Exception(edm::errors::Configuration) << "No VPSets were given in configuration";
179  }
180  for (std::vector<std::string>::const_iterator it = names.begin(), itEnd = names.end(); it != itEnd; ++it) {
181  const std::vector<edm::ParameterSet>& ps = iConfig.getUntrackedParameter<std::vector<edm::ParameterSet> >(*it);
182  std::vector<std::pair<std::string, std::string> >& data = m_recordToDataNames[*it];
183  for (std::vector<edm::ParameterSet>::const_iterator itPS = ps.begin(), itPSEnd = ps.end(); itPS != itPSEnd;
184  ++itPS) {
185  std::string type = itPS->getUntrackedParameter<std::string>("type");
186  std::string label = itPS->getUntrackedParameter<std::string>("label", std::string());
187  data.push_back(std::make_pair(type, label));
188  }
189  }
190 
191  m_file = TFile::Open(iConfig.getUntrackedParameter<std::string>("fileName").c_str(), "NEW");
192 }

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.

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

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.

274  {
275  update(iSetup);
276 }

References update().

◆ beginJob()

void FWLiteESRecordWriterAnalyzer::beginJob ( void  )
overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 279 of file FWLiteESRecordWriterAnalyzer.cc.

279 {}

◆ beginLuminosityBlock()

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

Reimplemented from edm::EDAnalyzer.

Definition at line 285 of file FWLiteESRecordWriterAnalyzer.cc.

285  {
286  update(iSetup);
287 }

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.

284 { update(iSetup); }

References update().

◆ endJob()

void FWLiteESRecordWriterAnalyzer::endJob ( void  )
overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 282 of file FWLiteESRecordWriterAnalyzer.cc.

282 { m_file->Write(); }

References m_file.

◆ update()

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

Definition at line 204 of file FWLiteESRecordWriterAnalyzer.cc.

204  {
206  if (m_handlers.empty()) {
207  //now we have access to the EventSetup so we can setup our data structure
208  for (std::map<std::string, std::vector<std::pair<std::string, std::string> > >::iterator
209  it = m_recordToDataNames.begin(),
210  itEnd = m_recordToDataNames.end();
211  it != itEnd;
212  ++it) {
213  HCTypeTag tt = HCTypeTag::findType(it->first);
214  if (tt == HCTypeTag()) {
215  throw cms::Exception("UnknownESRecordType")
216  << "The name '" << it->first
217  << "' is not associated with a known EventSetupRecord.\n"
218  "Please check spelling or load a module known to link with the package which declares that Record.";
219  }
221 
222  auto rec = iSetup.find(tt);
223  if (not rec) {
224  throw cms::Exception("UnknownESRecordType")
225  << "The name '" << it->first
226  << "' is not associated with a type which is not an EventSetupRecord.\n"
227  "Please check your spelling.";
228  }
229 
230  //now figure out what data
231  std::vector<std::pair<std::string, std::string> >& data = it->second;
232  if (data.empty()) {
233  //get everything from the record
234  std::vector<edm::eventsetup::DataKey> keys;
235  rec->fillRegisteredDataKeys(keys);
236  for (std::vector<edm::eventsetup::DataKey>::iterator itKey = keys.begin(), itKeyEnd = keys.end();
237  itKey != itKeyEnd;
238  ++itKey) {
239  data.push_back(std::make_pair(std::string(itKey->type().name()), std::string(itKey->name().value())));
240  }
241  }
242 
243  std::vector<DataInfo> dataInfos;
244  for (std::vector<std::pair<std::string, std::string> >::iterator itData = data.begin(), itDataEnd = data.end();
245  itData != itDataEnd;
246  ++itData) {
247  HCTypeTag tt = HCTypeTag::findType(itData->first);
248  if (tt == HCTypeTag()) {
249  throw cms::Exception("UnknownESDataType")
250  << "The name '" << itData->first << "' is not associated with a known type held in the " << it->first
251  << " Record.\n"
252  "Please check spelling or load a module known to link with the package which declares that type.";
253  }
254  if (!bool(edm::TypeWithDict(tt.value()))) {
255  throw cms::Exception("NoDictionary")
256  << "The type '" << itData->first << "' can not be retrieved from the Record " << it->first
257  << " and stored \n"
258  "because no dictionary exists for the type.";
259  }
260  dataInfos.push_back(DataInfo(tt, itData->second));
261  }
262  m_handlers.push_back(std::make_shared<RecordHandler>(rKey, m_file, dataInfos));
263  }
264  }
265 
266  for (std::vector<std::shared_ptr<RecordHandler> >::iterator it = m_handlers.begin(), itEnd = m_handlers.end();
267  it != itEnd;
268  ++it) {
269  (*it)->update(iSetup);
270  }
271 }

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

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

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

edm::typelookup::findType
std::pair< const char *, const std::type_info * > findType(const char *iClassName)
Definition: typelookup.cc:69
groupFilesInBlocks.tt
int tt
Definition: groupFilesInBlocks.py:144
FWLiteESRecordWriterAnalyzer::m_file
TFile * m_file
Definition: FWLiteESRecordWriterAnalyzer.cc:161
FWLiteESRecordWriterAnalyzer::update
void update(const edm::EventSetup &)
Definition: FWLiteESRecordWriterAnalyzer.cc:204
edm::ParameterSet::getUntrackedParameter
T getUntrackedParameter(std::string const &, T const &) const
relativeConstraints.keys
keys
Definition: relativeConstraints.py:89
edm::eventsetup::EventSetupRecordKey
Definition: EventSetupRecordKey.h:30
names
const std::string names[nVars_]
Definition: PhotonIDValueMapProducer.cc:122
AlCaHLTBitMon_QueryRunRegistry.string
string
Definition: AlCaHLTBitMon_QueryRunRegistry.py:256
edm::TypeWithDict
Definition: TypeWithDict.h:38
edm::eventsetup::heterocontainer::HCTypeTag
Definition: HCTypeTag.h:38
FWLiteESRecordWriterAnalyzer::m_handlers
std::vector< std::shared_ptr< RecordHandler > > m_handlers
Definition: FWLiteESRecordWriterAnalyzer.cc:158
edm::ParameterSet::getParameterNamesForType
std::vector< std::string > getParameterNamesForType(bool trackiness=true) const
Definition: ParameterSet.h:168
FWLiteESRecordWriterAnalyzer::m_recordToDataNames
std::map< std::string, std::vector< std::pair< std::string, std::string > > > m_recordToDataNames
Definition: FWLiteESRecordWriterAnalyzer.cc:160
edm::EventSetup::find
std::optional< eventsetup::EventSetupRecordGeneric > find(const eventsetup::EventSetupRecordKey &iKey) const
Definition: EventSetup.h:162
type
type
Definition: HCALResponse.h:21
Exception
Definition: hltDiff.cc:246
data
char data[epos_bytes_allocation]
Definition: EPOS_Wrapper.h:79
genParticles_cff.map
map
Definition: genParticles_cff.py:11
edm::errors::Configuration
Definition: EDMException.h:36
label
const char * label
Definition: PFTauDecayModeTools.cc:11