#include <StreamerFileReader.h>
Public Member Functions | |
InitMsgView const * | getHeader () |
EventMsgView const * | getNextEvent () |
bool | newHeader () |
StreamerFileReader (ParameterSet const &pset, InputSourceDescription const &desc) | |
virtual | ~StreamerFileReader () |
Public Member Functions inherited from edm::StreamerInputSource | |
void | deserializeAndMergeWithRegistry (InitMsgView const &initView, bool subsequent=false) |
void | deserializeEvent (EventMsgView const &eventView) |
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 | |
boost::shared_ptr < ActivityRegistry > | actReg () const |
Accessor for Activity Registry. More... | |
boost::shared_ptr < BranchIDListHelper > | branchIDListHelper () const |
Accessor for branchIDListHelper. More... | |
void | closeFile (FileBlock *, bool cleaningUpAfterException) |
close current file More... | |
void | doBeginJob () |
Called by framework at beginning of job. More... | |
void | doBeginLumi (LuminosityBlockPrincipal &lbp) |
Called by framework at beginning of lumi block. More... | |
void | doBeginRun (RunPrincipal &rp) |
Called by framework at beginning of run. More... | |
void | doEndJob () |
Called by framework at end of job. More... | |
void | doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException) |
Called by framework at end of lumi block. More... | |
void | doEndRun (RunPrincipal &rp, bool cleaningUpAfterException) |
Called by framework at end of run. More... | |
void | doPostForkReacquireResources (boost::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... | |
boost::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 () |
InputSource & | operator= (InputSource const &)=delete |
bool | primary () const |
Accessor for primary input source flag. More... | |
ProcessConfiguration const & | processConfiguration () const |
Accessor for Process Configuration. More... | |
std::string const & | processGUID () const |
Accessor for global process identifier. More... | |
ProcessingMode | processingMode () const |
RunsLumisAndEvents (default), RunsAndLumis, or Runs. More... | |
boost::shared_ptr < ProductRegistry const > | productRegistry () const |
Accessor for product registry. More... | |
bool | randomAccess () const |
boost::shared_ptr < LuminosityBlockPrincipal > | readAndCacheLumi (HistoryAppender &historyAppender) |
Read next luminosity block (new lumi) More... | |
boost::shared_ptr< RunPrincipal > | readAndCacheRun (HistoryAppender &historyAppender) |
Read next run (new run) More... | |
void | readAndMergeLumi (boost::shared_ptr< LuminosityBlockPrincipal > lbp) |
Read next luminosity block (same as a prior lumi) More... | |
void | readAndMergeRun (boost::shared_ptr< RunPrincipal > rp) |
Read next run (same as a prior run) More... | |
EventPrincipal * | readEvent (EventPrincipal &ep) |
EventPrincipal * | readEvent (EventPrincipal &ep, EventID const &) |
Read a specific event. More... | |
std::unique_ptr< FileBlock > | readFile () |
Read next file. More... | |
boost::shared_ptr < LuminosityBlockAuxiliary > | readLuminosityBlockAuxiliary () |
Read next luminosity block Auxilary. More... | |
boost::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... | |
ProcessingController::ReverseState | reverseState () const |
void | rewind () |
Begin again at the first event. More... | |
RunNumber_t | run () const |
Accessor for current run number. More... | |
boost::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 () |
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 (ConfigurationDescriptions &descriptions) |
Static Public Member Functions inherited from edm::StreamerInputSource | |
static std::auto_ptr < SendJobHeader > | deserializeRegistry (InitMsgView const &initView) |
static void | fillDescription (ParameterSetDescription &description) |
static void | mergeIntoRegistry (SendJobHeader const &header, ProductRegistry &, BranchIDListHelper &, 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 &) |
Private Member Functions | |
virtual bool | checkNextEvent () |
virtual void | closeFile_ () |
virtual void | reset_ () |
virtual void | skip (int toSkip) |
Private Attributes | |
boost::shared_ptr < EventSkipperByID > | eventSkipperByID_ |
int | initialNumberOfEventsToSkip_ |
std::vector< std::string > | streamerNames_ |
std::unique_ptr < StreamerInputFile > | streamReader_ |
Additional Inherited Members | |
Public Types inherited from edm::InputSource | |
enum | ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat } |
enum | ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents } |
typedef ProductRegistryHelper::TypeLabelList | TypeLabelList |
Protected Member Functions inherited from edm::StreamerInputSource | |
void | resetAfterEndRun () |
Protected Member Functions inherited from edm::RawInputSource | |
EventPrincipal * | makeEvent (EventPrincipal &eventPrincipal, EventAuxiliary const &eventAuxiliary) |
void | setInputFileTransitionsEachEvent () |
Protected Member Functions inherited from edm::InputSource | |
void | decreaseRemainingEventsBy (int iSkipped) |
bool | eventCached () const |
boost::shared_ptr < LuminosityBlockPrincipal > const | luminosityBlockPrincipal () const |
bool | newLumi () const |
bool | newRun () const |
ProductRegistry & | productRegistryUpdate () const |
void | reset () const |
void | resetEventCached () |
void | resetLuminosityBlockAuxiliary (bool isNewLumi=true) const |
void | resetNewLumi () |
void | resetNewRun () |
void | resetRunAuxiliary (bool isNewRun=true) const |
boost::shared_ptr < RunPrincipal > const | runPrincipal () 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 |
Static Protected Member Functions inherited from edm::StreamerInputSource | |
static void | buildClassCache (SendDescs const &descs) |
static void | declareStreamers (SendDescs const &descs) |
Definition at line 22 of file StreamerFileReader.h.
edm::StreamerFileReader::StreamerFileReader | ( | ParameterSet const & | pset, |
InputSourceDescription const & | desc | ||
) |
Definition at line 14 of file StreamerFileReader.cc.
References validate_alignment_devdb10_cfg::catalog, edm::InputFileCatalog::fileNames(), edm::ParameterSet::getUntrackedParameter(), reset_(), streamerNames_, and AlCaHLTBitMon_QueryRunRegistry::string.
|
virtual |
Definition at line 26 of file StreamerFileReader.cc.
|
privatevirtual |
Implements edm::RawInputSource.
Definition at line 47 of file StreamerFileReader.cc.
References edm::StreamerInputSource::deserializeAndMergeWithRegistry(), edm::StreamerInputSource::deserializeEvent(), getHeader(), getNextEvent(), and newHeader().
|
privatevirtual |
Reimplemented from edm::InputSource.
Definition at line 79 of file StreamerFileReader.cc.
References streamReader_.
|
static |
Definition at line 110 of file StreamerFileReader.cc.
References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::EventSkipperByID::fillDescription(), edm::StreamerInputSource::fillDescription(), edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.
InitMsgView const * edm::StreamerFileReader::getHeader | ( | ) |
Definition at line 89 of file StreamerFileReader.cc.
References InitMsgView::code(), edm::hlt::Exception, edm::errors::FileReadError, Header::INIT, and streamReader_.
Referenced by checkNextEvent(), and reset_().
EventMsgView const * edm::StreamerFileReader::getNextEvent | ( | ) |
Definition at line 102 of file StreamerFileReader.cc.
References streamReader_.
Referenced by checkNextEvent(), and skip().
bool edm::StreamerFileReader::newHeader | ( | ) |
Definition at line 84 of file StreamerFileReader.cc.
References streamReader_.
Referenced by checkNextEvent().
|
privatevirtual |
Reimplemented from edm::RawInputSource.
Definition at line 30 of file StreamerFileReader.cc.
References edm::StreamerInputSource::deserializeAndMergeWithRegistry(), eventSkipperByID_, edm::hlt::Exception, edm::errors::FileReadError, getHeader(), initialNumberOfEventsToSkip_, skip(), streamerNames_, and streamReader_.
Referenced by StreamerFileReader().
|
privatevirtual |
Reimplemented from edm::InputSource.
Definition at line 65 of file StreamerFileReader.cc.
References EventMsgView::event(), eventSkipperByID_, getNextEvent(), i, EventMsgView::lumi(), and EventMsgView::run().
Referenced by reset_().
|
private |
Definition at line 40 of file StreamerFileReader.h.
|
private |
Definition at line 41 of file StreamerFileReader.h.
Referenced by reset_().
|
private |
Definition at line 38 of file StreamerFileReader.h.
Referenced by reset_(), and StreamerFileReader().
|
private |
Definition at line 39 of file StreamerFileReader.h.
Referenced by closeFile_(), getHeader(), getNextEvent(), newHeader(), and reset_().