|
|
|
#include <DQMStreamerReader.h>
Classes | |
| struct | OpenFile |
Public Types | |
| typedef std::vector< std::string > | Strings |
 Public Types inherited from edm::InputSource | |
| enum | ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize } |
| enum | ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents } |
| typedef ProductRegistryHelper::TypeLabelList | TypeLabelList |
Public Member Functions | |
| DQMStreamerReader (edm::ParameterSet const &pset, edm::InputSourceDescription const &desc) | |
| bool | newHeader () |
| virtual | ~DQMStreamerReader () |
| Public Member Functions inherited from edm::StreamerInputSource | |
| void | deserializeAndMergeWithRegistry (InitMsgView const &initView, bool subsequent=false) |
| void | deserializeEvent (EventMsgView const &eventView) |
| std::unique_ptr< SendJobHeader > | deserializeRegistry (InitMsgView const &initView) |
| StreamerInputSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
| virtual | ~StreamerInputSource () |
| Public Member Functions inherited from edm::RawInputSource | |
| RawInputSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
| virtual | ~RawInputSource () |
| 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 | doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *) |
| Called by framework at beginning of lumi block. More... | |
| 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 | doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException, ProcessContext const *) |
| Called by framework at end of lumi block. More... | |
| void | doEndRun (RunPrincipal &rp, bool cleaningUpAfterException, ProcessContext const *) |
| Called by framework at end of run. More... | |
| void | doPostForkReacquireResources (std::shared_ptr< multicore::MessageReceiverForSource >) |
| void | doPreForkReleaseResources () |
| Called by the framework before forking the process. 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) |
| 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... | |
| ItemType | nextItemType () |
| Advances the source to the next item. More... | |
| InputSource & | operator= (InputSource const &)=delete |
| 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... | |
| std::shared_ptr < ProductRegistry > & | productRegistry () |
| 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::unique_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 | 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 |
| 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... | |
| SharedResourcesAcquirer * | 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) |
| bool | skipForForking () |
| 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 () |
| Destructor. More... | |
Static Public Member Functions | |
| static void | fillDescriptions (edm::ConfigurationDescriptions &descriptions) |
| Static Public Member Functions inherited from edm::StreamerInputSource | |
| static void | fillDescription (ParameterSetDescription &description) |
| static void | mergeIntoRegistry (SendJobHeader const &header, ProductRegistry &, BranchIDListHelper &, ThinnedAssociationsHelper &, bool subsequent) |
| static unsigned int | uncompressBuffer (unsigned char *inputBuffer, unsigned int inputSize, std::vector< unsigned char > &outputBuffer, unsigned int expectedFullSize) |
| Static Public Member Functions inherited from edm::RawInputSource | |
| static void | fillDescription (ParameterSetDescription &description) |
| 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 &) |
Protected Member Functions | |
| virtual bool | checkNextEvent () |
| virtual void | skip (int toSkip) |
| Protected Member Functions inherited from edm::StreamerInputSource | |
| void | resetAfterEndRun () |
| Protected Member Functions inherited from edm::RawInputSource | |
| void | makeEvent (EventPrincipal &eventPrincipal, EventAuxiliary const &eventAuxiliary) |
| void | setInputFileTransitionsEachEvent () |
| 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... | |
| ItemType | state () const |
Private Member Functions | |
| bool | acceptEvent (const EventMsgView *) |
| void | closeFile_ (const std::string &reason) |
| EventMsgView const * | getEventMsg () |
| InitMsgView const * | getHeaderMsg () |
| bool | matchTriggerSel (Strings const &tnames) |
| void | openFile_ (const DQMFileIterator::LumiEntry &entry) |
| bool | openNextFile_ () |
| EventMsgView const * | prepareNextEvent () |
| bool | prepareNextFile () |
| void | reset_ () |
| bool | triggerSel () |
Private Attributes | |
| bool | acceptAllEvt_ |
| std::shared_ptr< TriggerSelector > | eventSelector_ |
| std::shared_ptr < edm::EventSkipperByID > | eventSkipperByID_ |
| struct dqmservices::DQMStreamerReader::OpenFile | file_ |
| DQMFileIterator | fiterator_ |
| bool | flagDeleteDatFiles_ |
| bool | flagEndOfRunKills_ |
| bool | flagSkipFirstLumis_ |
| Strings | hltSel_ |
| bool | matchTriggerSel_ |
| unsigned int | minEventsPerLs_ |
| edm::Service < DQMMonitoringService > | mon_ |
| unsigned int | processedEventPerLs_ |
| std::string | runInputDir_ |
| unsigned int | runNumber_ |
| std::string | streamLabel_ |
Additional Inherited Members | |
| Static Protected Member Functions inherited from edm::StreamerInputSource | |
| static void | buildClassCache (SendDescs const &descs) |
| static void | declareStreamers (SendDescs const &descs) |
Definition at line 24 of file DQMStreamerReader.h.
| typedef std::vector<std::string> dqmservices::DQMStreamerReader::Strings |
Definition at line 33 of file DQMStreamerReader.h.
| dqmservices::DQMStreamerReader::DQMStreamerReader | ( | edm::ParameterSet const & | pset, |
| edm::InputSourceDescription const & | desc | ||
| ) |
Definition at line 28 of file DQMStreamerReader.cc.
|
virtual |
Definition at line 46 of file DQMStreamerReader.cc.
|
private |
Check the trigger path to accept event
Definition at line 368 of file DQMStreamerReader.cc.
|
protectedvirtual |
This is the actual code for checking the new event and/or deserializing it.
Implements edm::RawInputSource.
Definition at line 294 of file DQMStreamerReader.cc.
|
private |
Definition at line 136 of file DQMStreamerReader.cc.
|
static |
Definition at line 403 of file DQMStreamerReader.cc.
|
private |
Definition at line 184 of file DQMStreamerReader.cc.
|
private |
Definition at line 171 of file DQMStreamerReader.cc.
|
private |
Check if hlt selection matches any trigger name taken from the header file
Definition at line 344 of file DQMStreamerReader.cc.
| bool dqmservices::DQMStreamerReader::newHeader | ( | ) |
|
private |
Definition at line 98 of file DQMStreamerReader.cc.
|
private |
Definition at line 145 of file DQMStreamerReader.cc.
|
private |
Waits and reads the event header. If end-of-run nullptr is returned.
Definition at line 256 of file DQMStreamerReader.cc.
|
private |
Prepare (open) the next file for reading. It is used by prepareNextEvent and in the constructor.
Does not block/wait.
Return false if this is end of run and/or no more file are available. However, return of "true" does not imply the file has been openned, but we need to wait until some future file becomes available.
Definition at line 205 of file DQMStreamerReader.cc.
|
privatevirtual |
Reimplemented from edm::RawInputSource.
Definition at line 54 of file DQMStreamerReader.cc.
|
protectedvirtual |
Reimplemented from edm::InputSource.
Definition at line 387 of file DQMStreamerReader.cc.
|
private |
If hlt trigger selection is '*', return a boolean variable to accept all events
Definition at line 330 of file DQMStreamerReader.cc.
|
private |
Definition at line 58 of file DQMStreamerReader.h.
|
private |
Definition at line 84 of file DQMStreamerReader.h.
|
private |
Definition at line 83 of file DQMStreamerReader.h.
|
private |
|
private |
Definition at line 73 of file DQMStreamerReader.h.
|
private |
Definition at line 71 of file DQMStreamerReader.h.
|
private |
Definition at line 70 of file DQMStreamerReader.h.
|
private |
Definition at line 69 of file DQMStreamerReader.h.
|
private |
Definition at line 64 of file DQMStreamerReader.h.
|
private |
Definition at line 59 of file DQMStreamerReader.h.
|
private |
Definition at line 67 of file DQMStreamerReader.h.
|
private |
Definition at line 87 of file DQMStreamerReader.h.
|
private |
Definition at line 66 of file DQMStreamerReader.h.
|
private |
Definition at line 62 of file DQMStreamerReader.h.
|
private |
Definition at line 61 of file DQMStreamerReader.h.
|
private |
Definition at line 63 of file DQMStreamerReader.h.
1.8.5
