#include <LH5Source.h>
Public Member Functions | |
LH5Source (const edm::ParameterSet ¶ms, const edm::InputSourceDescription &desc) | |
~LH5Source () override | |
Public Member Functions inherited from edm::ProducerSourceFromFiles | |
InputFileCatalog & | catalog () |
std::vector< std::string > | fileNames (unsigned iCatalog) const |
std::vector< std::string > const & | logicalFileNames () const |
ProducerSourceFromFiles (ParameterSet const &pset, InputSourceDescription const &desc, bool realData) | |
~ProducerSourceFromFiles () override | |
Public Member Functions inherited from edm::ProducerSourceBase | |
ProducerSourceBase (ParameterSet const &pset, InputSourceDescription const &desc, bool realData) | |
~ProducerSourceBase () noexcept(false) override | |
Public Member Functions inherited from edm::IDGeneratorSourceBase< PuttableSourceBase > | |
EventNumber_t | event () const |
unsigned int | eventCreationDelay () const |
EventID const & | eventID () const |
IDGeneratorSourceBase (ParameterSet const &pset, InputSourceDescription const &desc, bool realData) | |
LuminosityBlockNumber_t | luminosityBlock () const |
unsigned int | numberEventsInLumi () const |
unsigned int | numberEventsInRun () const |
unsigned int | numberEventsInThisLumi () const |
unsigned int | numberEventsInThisRun () const |
TimeValue_t | presentTime () const |
RunNumber_t | run () const |
unsigned int | timeBetweenEvents () const |
~IDGeneratorSourceBase () noexcept(false) override | |
Public Member Functions inherited from edm::PuttableSourceBase | |
bool | hasAbilityToProduceInBeginLumis () const final |
bool | hasAbilityToProduceInBeginRuns () const final |
PuttableSourceBase & | operator= (const PuttableSourceBase &)=delete |
PuttableSourceBase (ParameterSet const &, InputSourceDescription const &) | |
PuttableSourceBase (const PuttableSourceBase &)=delete | |
void | registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &) |
void | registerProducts () final |
Register any produced products. More... | |
void | resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel) |
Public Member Functions inherited from edm::InputSource | |
std::shared_ptr< ActivityRegistry > | actReg () const |
Accessor for Activity Registry. More... | |
std::shared_ptr< BranchIDListHelper const > | branchIDListHelper () const |
Accessors for branchIDListHelper. More... | |
std::shared_ptr< BranchIDListHelper > & | branchIDListHelper () |
void | closeFile (FileBlock *, bool cleaningUpAfterException) |
close current file More... | |
void | doBeginJob () |
Called by framework at beginning of job. More... | |
void | doEndJob () |
Called by framework at end of job. More... | |
void | fillProcessBlockHelper () |
Fill the ProcessBlockHelper with info for the current file. More... | |
ProcessingController::ForwardState | forwardState () const |
bool | goToEvent (EventID const &eventID) |
InputSource (ParameterSet const &, InputSourceDescription const &) | |
Constructor. More... | |
InputSource (InputSource const &)=delete | |
void | issueReports (EventID const &eventID, StreamID streamID) |
issue an event report More... | |
LuminosityBlockNumber_t | luminosityBlock () const |
Accessor for current luminosity block number. More... | |
std::shared_ptr< LuminosityBlockAuxiliary > | luminosityBlockAuxiliary () const |
Called by the framework to merge or insert lumi in principal cache. More... | |
int | maxEvents () const |
int | maxLuminosityBlocks () const |
ModuleDescription const & | moduleDescription () const |
Accessor for 'module' description. More... | |
ItemTypeInfo | nextItemType () |
Advances the source to the next item. More... | |
bool | nextProcessBlock (ProcessBlockPrincipal &) |
Next process block, return false if there is none, sets the processName in the principal. More... | |
InputSource & | operator= (InputSource const &)=delete |
std::shared_ptr< ProcessBlockHelper const > | processBlockHelper () const |
Accessors for processBlockHelper. More... | |
std::shared_ptr< ProcessBlockHelper > & | processBlockHelper () |
ProcessConfiguration const & | processConfiguration () const |
Accessor for Process Configuration. More... | |
std::string const & | processGUID () const |
Accessor for global process identifier. More... | |
ProcessHistoryRegistry const & | processHistoryRegistry () const |
Accessors for process history registry. More... | |
ProcessHistoryRegistry & | processHistoryRegistry () |
ProcessingMode | processingMode () const |
RunsLumisAndEvents (default), RunsAndLumis, or Runs. More... | |
std::shared_ptr< ProductRegistry const > | productRegistry () const |
Accessors for product registry. More... | |
bool | randomAccess () const |
void | readAndMergeLumi (LuminosityBlockPrincipal &lbp) |
Read next luminosity block (same as a prior lumi) More... | |
void | readAndMergeRun (RunPrincipal &rp) |
Read next run (same as a prior run) More... | |
void | readEvent (EventPrincipal &ep, StreamContext &) |
Read next event. More... | |
bool | readEvent (EventPrincipal &ep, EventID const &, StreamContext &) |
Read a specific event. More... | |
std::shared_ptr< FileBlock > | readFile () |
Read next file. More... | |
void | readLuminosityBlock (LuminosityBlockPrincipal &lumiPrincipal, HistoryAppender &historyAppender) |
Read next luminosity block (new lumi) More... | |
std::shared_ptr< LuminosityBlockAuxiliary > | readLuminosityBlockAuxiliary () |
Read next luminosity block Auxilary. More... | |
void | readProcessBlock (ProcessBlockPrincipal &) |
Read next process block. More... | |
void | readRun (RunPrincipal &runPrincipal, HistoryAppender &historyAppender) |
Read next run (new run) More... | |
std::shared_ptr< RunAuxiliary > | readRunAuxiliary () |
Read next run Auxiliary. More... | |
ProcessHistoryID const & | reducedProcessHistoryID () const |
int | remainingEvents () const |
int | remainingLuminosityBlocks () const |
void | repeat () |
Reset the remaining number of events/lumis to the maximum number. More... | |
std::pair< SharedResourcesAcquirer *, std::recursive_mutex * > | resourceSharedWithDelayedReader () |
Returns nullptr if no resource shared between the Source and a DelayedReader. More... | |
ProcessingController::ReverseState | reverseState () const |
void | rewind () |
Begin again at the first event. More... | |
RunNumber_t | run () const |
Accessor for current run number. More... | |
std::shared_ptr< RunAuxiliary > | runAuxiliary () const |
Called by the framework to merge or insert run in principal cache. More... | |
void | setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb) |
Set the luminosity block ID. More... | |
void | setRunNumber (RunNumber_t r) |
Set the run number. More... | |
void | skipEvents (int offset) |
void | switchTo (std::shared_ptr< ProductRegistry > iOther) |
switch to a different ProductRegistry. More... | |
std::shared_ptr< ThinnedAssociationsHelper const > | thinnedAssociationsHelper () const |
Accessors for thinnedAssociationsHelper. More... | |
std::shared_ptr< ThinnedAssociationsHelper > & | thinnedAssociationsHelper () |
Timestamp const & | timestamp () const |
Accessor for the current time, as seen by the input source. More... | |
virtual | ~InputSource () noexcept(false) |
Destructor. More... | |
Public Member Functions inherited from edm::ProducerBase | |
void | callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func) |
std::vector< edm::ProductResolverIndex > const & | indiciesForPutProducts (BranchType iBranchType) const |
ProducerBase () | |
std::vector< edm::ProductResolverIndex > const & | putTokenIndexToProductResolverIndex () const |
std::vector< bool > const & | recordProvenanceList () const |
void | registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &) |
std::function< void(BranchDescription const &)> | registrationCallback () const |
used by the fwk to register list of products More... | |
void | resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel) |
TypeLabelList const & | typeLabelList () const |
used by the fwk to register the list of products of this module More... | |
~ProducerBase () noexcept(false) override | |
Static Public Member Functions | |
static void | fillDescriptions (edm::ConfigurationDescriptions &descriptions) |
Static Public Member Functions inherited from edm::ProducerSourceFromFiles | |
static void | fillDescription (ParameterSetDescription &desc) |
Static Public Member Functions inherited from edm::IDGeneratorSourceBase< PuttableSourceBase > | |
static void | fillDescription (ParameterSetDescription &desc) |
Static Public Member Functions inherited from edm::InputSource | |
static const std::string & | baseType () |
static void | fillDescription (ParameterSetDescription &desc) |
static void | fillDescriptions (ConfigurationDescriptions &descriptions) |
static void | prevalidate (ConfigurationDescriptions &) |
Private Member Functions | |
void | endJob () override |
void | fillRunInfoProduct (lhef::LHERunInfo const &, LHERunInfoProduct &) |
void | nextEvent () |
void | produce (edm::Event &) override |
void | putRunInfoProduct (edm::RunPrincipal &) |
void | readEvent_ (edm::EventPrincipal &eventPrincipal) override |
void | readLuminosityBlock_ (edm::LuminosityBlockPrincipal &lumiPrincipal) override |
std::shared_ptr< edm::LuminosityBlockAuxiliary > | readLuminosityBlockAuxiliary_ () override |
void | readRun_ (edm::RunPrincipal &runPrincipal) override |
std::shared_ptr< edm::RunAuxiliary > | readRunAuxiliary_ () override |
bool | setRunAndEventInfo (edm::EventID &, edm::TimeValue_t &, edm::EventAuxiliary::ExperimentType &) override |
Private Attributes | |
edm::LHEProvenanceHelper | lheProvenanceHelper_ |
std::shared_ptr< lhef::LHEEvent > | partonLevel_ |
edm::ProcessHistoryID | phid_ |
std::unique_ptr< lhef::LH5Reader > | reader_ |
std::shared_ptr< lhef::LHERunInfo > | runInfoLast_ |
std::unique_ptr< LHERunInfoProduct > | runInfoProductLast_ |
Additional Inherited Members | |
Public Types inherited from edm::InputSource | |
enum | ItemPosition : char { ItemPosition::Invalid, ItemPosition::LastItemToBeMerged, ItemPosition::NotLastItemToBeMerged } |
enum | ItemType : char { ItemType::IsInvalid, ItemType::IsStop, ItemType::IsFile, ItemType::IsRun, ItemType::IsLumi, ItemType::IsEvent, ItemType::IsRepeat, ItemType::IsSynchronize } |
enum | ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents } |
Public Types inherited from edm::ProducerBase | |
template<typename T > | |
using | BranchAliasSetterT = ProductRegistryHelper::BranchAliasSetterT< T > |
using | ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const *, const char *, edm::ProductResolverIndex > > |
typedef ProductRegistryHelper::TypeLabelList | TypeLabelList |
Public Attributes inherited from edm::InputSource | |
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> | postEventReadFromSourceSignal_ |
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> | preEventReadFromSourceSignal_ |
Protected Member Functions inherited from edm::ProducerSourceFromFiles | |
void | incrementFileIndex () |
Protected Member Functions inherited from edm::IDGeneratorSourceBase< PuttableSourceBase > | |
void | doReadEvent (EventPrincipal &eventPrincipal, F &&f) |
void | doReadEventWithDelayedReader (EventPrincipal &eventPrincipal, ProcessHistoryID const &historyID, EventSelectionIDVector eventSelectionIDs, BranchListIndexes branchListIndexes, DelayedReader *reader) |
Protected Member Functions inherited from edm::InputSource | |
void | decreaseRemainingEventsBy (int iSkipped) |
bool | eventCached () const |
bool | newLumi () const |
bool | newRun () const |
ProcessHistoryRegistry & | processHistoryRegistryForUpdate () |
ProductRegistry & | productRegistryUpdate () |
void | reset () const |
void | resetEventCached () |
void | resetLuminosityBlockAuxiliary (bool isNewLumi=true) const |
void | resetNewLumi () |
void | resetNewRun () |
void | resetRunAuxiliary (bool isNewRun=true) const |
void | setEventCached () |
Called by the framework to merge or ached() const {return eventCached_;}. More... | |
void | setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp) |
void | setNewLumi () |
void | setNewRun () |
void | setRunAuxiliary (RunAuxiliary *rp) |
void | setTimestamp (Timestamp const &theTime) |
To set the current time, as seen by the input source. More... | |
ItemTypeInfo | state () const |
Protected Member Functions inherited from edm::ProducerBase | |
template<Transition Tr = Transition::Event> | |
auto | produces (std::string instanceName) noexcept |
declare what type of product will make and with which optional label More... | |
template<Transition B> | |
BranchAliasSetter | produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true) |
template<BranchType B> | |
BranchAliasSetter | produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true) |
BranchAliasSetter | produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true) |
template<typename ProductType , Transition B> | |
BranchAliasSetterT< ProductType > | produces (std::string instanceName) |
template<class ProductType > | |
BranchAliasSetterT< ProductType > | produces () |
template<typename ProductType , BranchType B> | |
BranchAliasSetterT< ProductType > | produces (std::string instanceName) |
template<typename ProductType , BranchType B> | |
BranchAliasSetterT< ProductType > | produces () |
template<class ProductType > | |
BranchAliasSetterT< ProductType > | produces (std::string instanceName) |
template<typename ProductType , Transition B> | |
BranchAliasSetterT< ProductType > | produces () |
template<Transition Tr = Transition::Event> | |
auto | produces () noexcept |
ProducesCollector | producesCollector () |
Definition at line 33 of file LH5Source.h.
|
explicit |
Definition at line 33 of file LH5Source.cc.
References edm::LHEProvenanceHelper::lheAugment(), edm::LHEProvenanceHelper::lheInit(), lheProvenanceHelper_, nextEvent(), phid_, and edm::InputSource::processHistoryRegistryForUpdate().
|
override |
Definition at line 52 of file LH5Source.cc.
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 54 of file LH5Source.cc.
References reader_.
|
static |
Definition at line 191 of file LH5Source.cc.
References edm::ConfigurationDescriptions::add(), submitPVResolutionJobs::desc, edm::ProducerSourceFromFiles::fillDescription(), and mitigatedMETSequence_cff::U.
|
private |
Definition at line 95 of file LH5Source.cc.
References LHERunInfoProduct::addComment(), LHERunInfoProduct::addHeader(), DummyCfis::c, lhef::LHERunInfo::getComments(), lhef::LHERunInfo::getHeaders(), and h.
Referenced by nextEvent().
|
private |
Definition at line 56 of file LH5Source.cc.
References fillRunInfoProduct(), edm::FromFiles::incrementFileIndex(), edm::LHEProvenanceHelper::lheAugment(), edm::LHEProvenanceHelper::lheInit(), lheProvenanceHelper_, eostools::move(), partonLevel_, phid_, edm::InputSource::processHistoryRegistryForUpdate(), reader_, edm::InputSource::resetRunAuxiliary(), runInfoLast_, and runInfoProductLast_.
Referenced by LH5Source(), and setRunAndEventInfo().
|
inlineoverrideprivatevirtual |
|
private |
Definition at line 117 of file LH5Source.cc.
References lheProvenanceHelper_, eostools::move(), edm::RunPrincipal::put(), runInfoProductLast_, and edm::LHEProvenanceHelper::runProductBranchDescription_.
Referenced by readRun_().
|
overrideprivatevirtual |
Reimplemented from edm::ProducerSourceBase.
Definition at line 138 of file LH5Source.cc.
References LHEEventProduct::addComment(), LHEEventProduct::addWeight(), cms::cuda::assert(), printConversionInfo::aux, edm::LHEProvenanceHelper::branchListIndexes_, edm::InputSource::eventCached(), edm::IDGeneratorSourceBase< PuttableSourceBase >::eventID(), edm::LHEProvenanceHelper::eventProductBranchDescription_, edm::LHEProvenanceHelper::eventProductProvenance_, edm::EventPrincipal::fillEventPrincipal(), lheProvenanceHelper_, eostools::move(), partonLevel_, phid_, edm::IDGeneratorSourceBase< PuttableSourceBase >::presentTime(), edm::InputSource::processGUID(), edm::InputSource::processHistoryRegistry(), edm::InputSource::processingMode(), edm::EventPrincipal::put(), edm::InputSource::resetEventCached(), and edm::InputSource::RunsLumisAndEvents.
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 111 of file LH5Source.cc.
References edm::LuminosityBlockPrincipal::aux(), edm::LuminosityBlockPrincipal::fillLuminosityBlockPrincipal(), edm::InputSource::luminosityBlockAuxiliary(), phid_, edm::LuminosityBlockAuxiliary::processHistoryID(), and edm::InputSource::processHistoryRegistry().
|
overrideprivatevirtual |
Implements edm::InputSource.
Definition at line 180 of file LH5Source.cc.
References printConversionInfo::aux, edm::IDGeneratorSourceBase< PuttableSourceBase >::eventID(), edm::Timestamp::invalidTimestamp(), edm::EventID::luminosityBlock(), phid_, edm::IDGeneratorSourceBase< PuttableSourceBase >::presentTime(), edm::InputSource::processingMode(), edm::InputSource::resetNewLumi(), edm::EventID::run(), and edm::InputSource::Runs.
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 104 of file LH5Source.cc.
References edm::RunPrincipal::fillRunPrincipal(), phid_, edm::InputSource::processHistoryRegistryForUpdate(), putRunInfoProduct(), and edm::InputSource::runAuxiliary().
|
overrideprivatevirtual |
Implements edm::InputSource.
Definition at line 172 of file LH5Source.cc.
References printConversionInfo::aux, edm::IDGeneratorSourceBase< PuttableSourceBase >::eventID(), edm::Timestamp::invalidTimestamp(), phid_, edm::IDGeneratorSourceBase< PuttableSourceBase >::presentTime(), edm::InputSource::resetNewRun(), and edm::EventID::run().
|
overrideprivatevirtual |
Implements edm::IDGeneratorSourceBase< PuttableSourceBase >.
Definition at line 125 of file LH5Source.cc.
References nextEvent(), and partonLevel_.
|
private |
Definition at line 61 of file LH5Source.h.
Referenced by LH5Source(), nextEvent(), putRunInfoProduct(), and readEvent_().
|
private |
Definition at line 58 of file LH5Source.h.
Referenced by nextEvent(), readEvent_(), and setRunAndEventInfo().
|
private |
Definition at line 62 of file LH5Source.h.
Referenced by LH5Source(), nextEvent(), readEvent_(), readLuminosityBlock_(), readLuminosityBlockAuxiliary_(), readRun_(), and readRunAuxiliary_().
|
private |
Definition at line 55 of file LH5Source.h.
Referenced by endJob(), and nextEvent().
|
private |
Definition at line 57 of file LH5Source.h.
Referenced by nextEvent().
|
private |
Definition at line 60 of file LH5Source.h.
Referenced by nextEvent(), and putRunInfoProduct().