Public Member Functions | |
OneLumiPoolSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
Public Member Functions inherited from edm::PoolSource | |
bool | bypassVersionCheck () const |
bool | dropDescendants () const |
bool | labelRawDataLikeMC () const |
unsigned int | nStreams () const |
PoolSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
ProcessHistoryRegistry & | processHistoryRegistryForUpdate () |
ProductRegistry & | productRegistryUpdate () |
ProductSelectorRules const & | productSelectorRules () const |
RunHelperBase * | runHelper () |
bool | skipBadFiles () const |
int | treeMaxVirtualSize () const |
~PoolSource () override | |
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... | |
virtual void | doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *) |
Called by framework at beginning of lumi block. More... | |
virtual void | doBeginRun (RunPrincipal &rp, ProcessContext const *) |
Called by framework at beginning of run. 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 |
virtual void | registerProducts () |
Register any produced products. More... | |
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... | |
Private Member Functions | |
ItemTypeInfo | getNextItemType () override |
void | readEvent_ (EventPrincipal &eventPrincipal) override |
std::shared_ptr< LuminosityBlockAuxiliary > | readLuminosityBlockAuxiliary_ () override |
Private Attributes | |
bool | seenFirstLumi_ = false |
Definition at line 13 of file OneLumiPoolSource.cc.
|
explicit |
Definition at line 29 of file OneLumiPoolSource.cc.
|
overrideprivatevirtual |
Implements edm::InputSource.
Definition at line 40 of file OneLumiPoolSource.cc.
References edm::PoolSource::getNextItemType(), edm::InputSource::IsLumi, edm::PoolSource::readLuminosityBlock_(), seenFirstLumi_, and groupFilesInBlocks::temp.
|
inlineoverrideprivatevirtual |
Implements edm::InputSource.
Definition at line 21 of file OneLumiPoolSource.cc.
References edm::PoolSource::readEvent_(), edm::EventPrincipal::run(), and edm::EventPrincipal::setRunAndLumiNumber().
|
overrideprivatevirtual |
Implements edm::InputSource.
Definition at line 32 of file OneLumiPoolSource.cc.
References compareTotals::hist, edm::PoolSource::readLuminosityBlockAuxiliary_(), and runTheMatrix::ret.
|
private |
Definition at line 26 of file OneLumiPoolSource.cc.
Referenced by getNextItemType().