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 const &)=delete
	EDConsumerBase (EDConsumerBase &&)=default
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
EDConsumerBase const &	operator= (EDConsumerBase const &)=delete
EDConsumerBase &	operator= (EDConsumerBase &&)=default
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
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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)
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: [one line class summary]

Implementation: [Notes on implementation]

Definition at line 143 of file FWLiteESRecordWriterAnalyzer.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 175 of file FWLiteESRecordWriterAnalyzer.cc.

References edm::errors::Configuration, data, Exception, edm::ParameterSet::getParameterNamesForType(), edm::ParameterSet::getUntrackedParameter(), label, 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 ( )

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;
}

Member Function Documentation

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

overrideprivate

Definition at line 274 of file FWLiteESRecordWriterAnalyzer.cc.

References update.

                                                                                         {
  update(iSetup);
}

void FWLiteESRecordWriterAnalyzer::beginJob ( void  )

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 279 of file FWLiteESRecordWriterAnalyzer.cc.

{}

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

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 285 of file FWLiteESRecordWriterAnalyzer.cc.

References DEFINE_FWK_MODULE, and update.

                                                                                                              {
  update(iSetup);
}

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

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 284 of file FWLiteESRecordWriterAnalyzer.cc.

References update.

{ update(iSetup); }

void FWLiteESRecordWriterAnalyzer::endJob ( void  )

overrideprivatevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 282 of file FWLiteESRecordWriterAnalyzer.cc.

{ m_file->Write(); }

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

private

Definition at line 204 of file FWLiteESRecordWriterAnalyzer.cc.

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

Referenced by progressbar.ProgressBar::__next__(), MatrixUtil.Matrix::__setitem__(), MatrixUtil.Steps::__setitem__(), Vispa.Gui.VispaWidget.VispaWidget::autosize(), Vispa.Views.LineDecayView.LineDecayContainer::createObject(), Vispa.Views.LineDecayView.LineDecayContainer::deselectAllObjects(), Vispa.Gui.VispaWidgetOwner.VispaWidgetOwner::deselectAllWidgets(), Vispa.Gui.VispaWidget.VispaWidget::enableAutosizing(), progressbar.ProgressBar::finish(), Vispa.Gui.MenuWidget.MenuWidget::leaveEvent(), Vispa.Gui.VispaWidgetOwner.VispaWidgetOwner::mouseMoveEvent(), Vispa.Gui.MenuWidget.MenuWidget::mouseMoveEvent(), Vispa.Views.LineDecayView.LineDecayContainer::mouseMoveEvent(), Vispa.Gui.VispaWidgetOwner.VispaWidgetOwner::mouseReleaseEvent(), Vispa.Views.LineDecayView.LineDecayContainer::objectMoved(), MatrixUtil.Steps::overwrite(), Vispa.Views.LineDecayView.LineDecayContainer::removeObject(), Vispa.Gui.ConnectableWidget.ConnectableWidget::removePorts(), Vispa.Gui.FindDialog.FindDialog::reset(), Vispa.Gui.PortConnection.PointToPointConnection::select(), Vispa.Gui.VispaWidget.VispaWidget::select(), Vispa.Views.LineDecayView.LineDecayContainer::select(), Vispa.Gui.VispaWidget.VispaWidget::setText(), Vispa.Gui.VispaWidget.VispaWidget::setTitle(), Vispa.Gui.ZoomableWidget.ZoomableWidget::setZoom(), Vispa.Views.LineDecayView.LineDecayContainer::setZoom(), and Vispa.Gui.PortConnection.PointToPointConnection::updateConnection().

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

Member Data Documentation

TFile* FWLiteESRecordWriterAnalyzer::m_file

private

Definition at line 161 of file FWLiteESRecordWriterAnalyzer.cc.

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

private

Definition at line 158 of file FWLiteESRecordWriterAnalyzer.cc.

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

private

Definition at line 160 of file FWLiteESRecordWriterAnalyzer.cc.