#include <FedRawDataInputSource.h>
Public Member Functions | |
FedRawDataInputSource (edm::ParameterSet const &, edm::InputSourceDescription const &) | |
std::pair< bool, unsigned int > | getEventReport (unsigned int lumi, bool erase) |
~FedRawDataInputSource () override | |
Public Member Functions inherited from edm::RawInputSource | |
RawInputSource (ParameterSet const &pset, InputSourceDescription const &desc) | |
~RawInputSource () 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... | |
virtual void | doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException, ProcessContext const *) |
Called by framework at end of lumi block. More... | |
virtual void | doEndRun (RunPrincipal &rp, bool cleaningUpAfterException, ProcessContext const *) |
Called by framework at end of run. 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 |
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) |
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... | |
Static Public Member Functions | |
static void | fillDescriptions (edm::ConfigurationDescriptions &descriptions) |
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 | |
bool | checkNextEvent () override |
void | read (edm::EventPrincipal &eventPrincipal) override |
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... | |
virtual void | skip (int offset) |
ItemType | state () const |
Private Types | |
typedef std::pair< InputFile *, InputChunk * > | ReaderInfo |
Private Member Functions | |
void | createBoLSFile (const uint32_t lumiSection, bool checkIfExists) |
void | deleteFile (std::string const &) |
bool | exceptionState () |
edm::Timestamp | fillFEDRawDataCollection (FEDRawDataCollection &) |
evf::EvFDaqDirector::FileStatus | getFile (unsigned int &ls, std::string &nextFile, uint32_t &fsize, uint64_t &lockWaitTime) |
evf::EvFDaqDirector::FileStatus | getNextEvent () |
int | grabNextJsonFile (boost::filesystem::path const &) |
long | initFileList () |
void | maybeOpenNewLumiSection (const uint32_t lumiSection) |
evf::EvFDaqDirector::FileStatus | nextEvent () |
void | readNextChunkIntoBuffer (InputFile *file) |
void | readSupervisor () |
void | readWorker (unsigned int tid) |
void | reportEventsThisLumiInSource (unsigned int lumi, unsigned int events) |
void | rewind_ () override |
void | threadError () |
Friends | |
struct | InputChunk |
struct | InputFile |
Additional Inherited Members | |
Public Types inherited from edm::InputSource | |
enum | ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize } |
enum | ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents } |
Public Attributes inherited from edm::InputSource | |
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> | postEventReadFromSourceSignal_ |
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)> | preEventReadFromSourceSignal_ |
Definition at line 41 of file FedRawDataInputSource.h.
|
private |
Definition at line 134 of file FedRawDataInputSource.h.
|
explicit |
Definition at line 56 of file FedRawDataInputSource.cc.
References edm::Timestamp::beginOfTime(), crc32c_hw_test(), cvReader_, daqDirector_, edm::DaqProvenanceHelper::daqInit(), daqProvenanceHelper_, defPath_, dpd_, MillePedeFileConverter_cfg::e, eventChunkBlock_, eventChunkSize_, Exception, fileDeleteLock_, fileListLoopMode_, fileListMode_, filesToDelete_, fms_, freeChunks_, mps_fire::i, evf::FastMonitoringThread::inInit, initFileList(), InputChunk, edm::Timestamp::invalidTimestamp(), numBuffers_, numConcurrentReads_, Utilities::operator, processHistoryID_, edm::InputSource::processHistoryRegistryForUpdate(), edm::InputSource::productRegistryUpdate(), quit_threads_, readBlocks_, readingFilesCount_, readWorker(), edm::InputSource::runAuxiliary(), runNumber_, evf::EvFDaqDirector::setDeleteTracking(), evf::EvFDaqDirector::setFMS(), evf::FastMonitoringService::setInputSource(), evf::FastMonitoringService::setInState(), evf::FastMonitoringService::setInStateSup(), edm::InputSource::setNewRun(), edm::InputSource::setRunAuxiliary(), singleBufferMode_, startupCv_, startupLock_, trackingPlots::stat, AlCaHLTBitMon_QueryRunRegistry::string, thread_quit_signal, threadInit_, tid_active_, workerJob_, and workerThreads_.
|
override |
Definition at line 186 of file FedRawDataInputSource.cc.
References cvReader_, deleteFile(), filesToDelete_, mps_fire::i, mReader_, numConcurrentReads_, quit_threads_, readSupervisorThread_, startedSupervisorThread_, thread_quit_signal, and workerThreads_.
|
overrideprotectedvirtual |
Implements edm::RawInputSource.
Definition at line 236 of file FedRawDataInputSource.cc.
References evf::EvFDaqDirector::createProcessingNotificationMaybe(), currentLumiSection_, daqDirector_, evf::EvFDaqDirector::emptyLumisectionMode(), event_, eventRunNumber_, eventsThisLumi_, fileListLoopMode_, fileListMode_, fms_, runEdmFileComparison::found, fuOutputDir_, evf::EvFDaqDirector::getEoLSFilePathOnBU(), evf::EvFDaqDirector::getEoLSFilePathOnFU(), evf::EvFDaqDirector::getEoRFilePathOnFU(), getLSFromFilename_, evf::FastMonitoringThread::inWaitInput, L1EventID_, evf::EvFDaqDirector::lockFULocal2(), maybeOpenNewLumiSection(), evf::EvFDaqDirector::newLumi, nextEvent(), evf::EvFDaqDirector::noFile, readSupervisor(), readSupervisorThread_, reportEventsThisLumiInSource(), edm::InputSource::resetLuminosityBlockAuxiliary(), evf::EvFDaqDirector::runEnded, runNumber_, edm::InputSource::setEventCached(), evf::FastMonitoringService::setInState(), startedSupervisorThread_, startupCv_, startupLock_, trackingPlots::stat, AlCaHLTBitMon_QueryRunRegistry::string, and evf::EvFDaqDirector::unlockFULocal2().
|
private |
Definition at line 313 of file FedRawDataInputSource.cc.
References daqDirector_, evf::EvFDaqDirector::getBoLSFilePathOnFU(), trackingPlots::stat, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by maybeOpenNewLumiSection().
|
private |
Definition at line 638 of file FedRawDataInputSource.cc.
References cppFunctionSkipper::exception, fileListMode_, MillePedeFileConverter_cfg::fileName, LogDebug, callgraph::path, and MatrixUtil::remove().
Referenced by getNextEvent(), read(), and ~FedRawDataInputSource().
|
inlineprivate |
Definition at line 70 of file FedRawDataInputSource.h.
References PatBasicFWLiteAnalyzer::events, FrontierConditions_GlobalTag_cff::file, ws_sso_content_reader::getFile(), eostools::ls(), and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by getNextEvent().
|
static |
Definition at line 219 of file FedRawDataInputSource.cc.
References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::setAllowAnything(), edm::ParameterSetDescription::setComment(), and edm::ParameterDescriptionNode::setComment().
|
private |
Definition at line 745 of file FedRawDataInputSource.cc.
References FEDRawData::data(), event_, fedt_struct::eventsize, evf::evtn::evm_board_sense(), Exception, FED_EVSZ_EXTRACT, FED_SOID_EXTRACT, FEDRawDataCollection::FEDData(), l1t::stage2::layer2::fedId, evf::evtn::get(), evf::evtn::getgpshigh(), evf::evtn::getgpslow(), evf::evtn::gtpe_board_sense(), evf::evtn::gtpe_get(), GTPEventID_, FEDNumbering::MAXFEDID, FEDNumbering::MINTCDSuTCAFEDID, FEDNumbering::MINTriggerEGTPFEDID, FEDNumbering::MINTriggerGTPFEDID, FEDRawData::resize(), fedh_struct::sourceid, tcds_pointer_, and ntuplemaker::time.
Referenced by read().
std::pair< bool, unsigned int > FedRawDataInputSource::getEventReport | ( | unsigned int | lumi, |
bool | erase | ||
) |
Definition at line 1384 of file FedRawDataInputSource.cc.
References CommonMethods::lock(), monlock_, and sourceEventsReport_.
Referenced by evf::FastMonitoringService::preGlobalEndLumi().
|
private |
Definition at line 1427 of file FedRawDataInputSource.cc.
References fileListIndex_, fileListLoopMode_, MillePedeFileConverter_cfg::fileName, fileNames_, loopModeIterationInc_, evf::EvFDaqDirector::newFile, callgraph::path, evf::EvFDaqDirector::runEnded, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by readSupervisor().
|
inlineprivate |
Definition at line 375 of file FedRawDataInputSource.cc.
References InputFile::advance(), bufferInputRead_, InputFile::bufferPosition_, chunkIsFree_, InputFile::chunkPosition_, InputFile::chunks_, crc32c(), InputFile::currentChunk_, currentFile_, currentFileIndex_, currentLumiSection_, cvWakeup_, daqDirector_, deleteFile(), detectedFRDversion_, event_, eventChunkSize_, eventsThisLumi_, Exception, exceptionState(), fileDeleteLock_, fileListMode_, InputFile::fileName_, fileQueue_, InputFile::fileSize_, filesToDelete_, fms_, FRDHeaderVersionSize, freeChunks_, getLSFromFilename_, evf::FastMonitoringThread::inCachedEvent, evf::FastMonitoringThread::inChecksumEvent, evf::FastMonitoringThread::inChunkReceived, evf::FastMonitoringThread::inNewLumi, evf::FastMonitoringThread::inProcessingFile, evf::FastMonitoringThread::inRunEnd, evf::FastMonitoringThread::inWaitChunk, evf::FastMonitoringThread::inWaitInput, evf::EvFDaqDirector::isSingleStreamThread(), dttmaxenums::L, InputFile::lumi_, maybeOpenNewLumiSection(), InputFile::moveToPreviousChunk(), mWakeup_, InputFile::nChunks_, InputFile::nEvents_, evf::EvFDaqDirector::newFile, evf::EvFDaqDirector::newLumi, evf::EvFDaqDirector::noFile, InputFile::nProcessed_, InputFile::parent_, readingFilesCount_, readNextChunkIntoBuffer(), reportEventsThisLumiInSource(), InputFile::rewindChunk(), evf::EvFDaqDirector::runAbort, evf::EvFDaqDirector::runEnded, evf::EvFDaqDirector::sameFile, evf::FastMonitoringService::setExceptionDetected(), setExceptionState_, evf::FastMonitoringService::setInState(), singleBufferMode_, mps_update::status, InputFile::status_, threadError(), mps_check::timeout, verifyAdler32_, verifyChecksum_, and InputFile::waitForChunk().
Referenced by nextEvent().
|
private |
Definition at line 799 of file FedRawDataInputSource.cc.
References popcon2dropbox::copy(), daqDirector_, data, jsoncollector::DataPoint::deserialize(), reco::dp, dpd_, MillePedeFileConverter_cfg::e, cppFunctionSkipper::exception, Exception, fuOutputDir_, jsoncollector::DataPoint::getData(), Json::Reader::getFormatedErrorMessages(), jsoncollector::DataPointDefinition::getNames(), mps_fire::i, LogDebug, Json::Reader::parse(), callgraph::path, matplotRender::reader, MatrixUtil::remove(), AlCaHLTBitMon_QueryRunRegistry::string, summarizeEdmComparisonLogfiles::success, and evf::EvFDaqDirector::unlockFULocal().
Referenced by readSupervisor().
|
private |
Definition at line 1398 of file FedRawDataInputSource.cc.
References a, b, end, MillePedeFileConverter_cfg::fileName, fileNames_, callgraph::path, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by FedRawDataInputSource().
|
private |
Definition at line 324 of file FedRawDataInputSource.cc.
References createBoLSFile(), currentLumiSection_, daqDirector_, runEdmFileComparison::found, evf::EvFDaqDirector::getEoLSFilePathOnFU(), edm::Timestamp::invalidTimestamp(), evf::EvFDaqDirector::lockFULocal2(), edm::InputSource::luminosityBlock(), edm::InputSource::luminosityBlockAuxiliary(), processHistoryID_, edm::InputSource::resetLuminosityBlockAuxiliary(), edm::InputSource::run(), edm::InputSource::runAuxiliary(), edm::InputSource::setLuminosityBlockAuxiliary(), trackingPlots::stat, AlCaHLTBitMon_QueryRunRegistry::string, and evf::EvFDaqDirector::unlockFULocal2().
Referenced by checkNextEvent(), and getNextEvent().
|
inlineprivate |
Definition at line 365 of file FedRawDataInputSource.cc.
References getNextEvent(), svgfig::load(), evf::EvFDaqDirector::noFile, edm::shutdown_flag, and mps_update::status.
Referenced by checkNextEvent().
|
overrideprotectedvirtual |
Implements edm::RawInputSource.
Definition at line 671 of file FedRawDataInputSource.cc.
References printConversionInfo::aux, edm::DaqProvenanceHelper::branchDescription(), checkEvery_, chunkIsFree_, InputFile::chunks_, InputFile::currentChunk_, currentFile_, currentFileIndex_, currentLumiSection_, daqProvenanceHelper_, deleteFile(), edm::DaqProvenanceHelper::dummyProvenance(), eventID_, eventRunNumber_, eventsThisLumi_, fileDeleteLock_, fileListLoopMode_, filesToDelete_, fillFEDRawDataCollection(), fms_, freeChunks_, GTPEventID_, mps_fire::i, evf::FastMonitoringThread::inNoRequest, evf::FastMonitoringThread::inReadCleanup, evf::FastMonitoringThread::inReadEvent, L1EventID_, edm::RawInputSource::makeEvent(), evf::evtn::makeEventAuxiliary(), eostools::move(), InputFile::nProcessed_, nStreams_, edm::EventAuxiliary::PhysicsTrigger, edm::InputSource::processGUID(), processHistoryID_, edm::EventPrincipal::put(), evf::FastMonitoringService::setInState(), edm::EventAuxiliary::setProcessHistoryID(), streamFileTracker_, edm::EventPrincipal::streamID(), tcds_pointer_, and useL1EventID_.
Referenced by edmIntegrityCheck.PublishToFileSystem::get(), Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::goto(), readNextChunkIntoBuffer(), readWorker(), and Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::setFilterBranches().
|
private |
Definition at line 1319 of file FedRawDataInputSource.cc.
References bufferInputRead_, InputFile::chunkPosition_, InputFile::chunks_, eventChunkBlock_, eventChunkSize_, Exception, fileDescriptor_, InputFile::fileName_, InputFile::fileSize_, mps_fire::i, plotBeamSpotDB::last, LogDebug, read(), and readBlocks_.
Referenced by getNextEvent().
|
private |
Definition at line 909 of file FedRawDataInputSource.cc.
References InputFile::chunks_, cvReader_, cvWakeup_, daqDirector_, eventChunkSize_, fileListMode_, fileQueue_, fms_, freeChunks_, getFile(), getLSFromFilename_, grabNextJsonFile(), mps_fire::i, InputFile, evf::FastMonitoringThread::inRunEnd, evf::FastMonitoringThread::inSupBusy, evf::FastMonitoringThread::inSupFileLimit, evf::FastMonitoringThread::inSupLockPolling, evf::FastMonitoringThread::inSupNewFile, evf::FastMonitoringThread::inSupNewFileWaitChunk, evf::FastMonitoringThread::inSupNewFileWaitChunkCopying, evf::FastMonitoringThread::inSupNewFileWaitThread, evf::FastMonitoringThread::inSupNewFileWaitThreadCopying, evf::FastMonitoringThread::inSupNoFile, evf::FastMonitoringThread::inSupWaitFreeChunk, evf::FastMonitoringThread::inSupWaitFreeChunkCopying, evf::FastMonitoringThread::inSupWaitFreeThread, evf::FastMonitoringThread::inSupWaitFreeThreadCopying, LogDebug, eostools::ls(), maxBufferedFiles_, mReader_, mWakeup_, evf::EvFDaqDirector::newFile, evf::EvFDaqDirector::newLumi, evf::EvFDaqDirector::noFile, callgraph::path, quit_threads_, InputChunk::readComplete_, readingFilesCount_, evf::FastMonitoringService::reportLockWait(), InputChunk::reset(), evf::EvFDaqDirector::runAbort, evf::EvFDaqDirector::runEnded, setExceptionState_, evf::FastMonitoringService::setInStateSup(), edm::shutdown_flag, singleBufferMode_, evf::FastMonitoringService::startedLookingForFile(), startupCv_, startupLock_, trackingPlots::stat, mps_update::status, evf::FastMonitoringService::stoppedLookingForFile(), AlCaHLTBitMon_QueryRunRegistry::string, thread_quit_signal, tid_active_, mps_check::timeout, evf::EvFDaqDirector::updateFuLock(), workerJob_, workerPool_, and workerThreads_.
Referenced by checkNextEvent().
|
private |
Definition at line 1184 of file FedRawDataInputSource.cc.
References InputChunk::buf_, InputFile::chunks_, cvReader_, detectedFRDversion_, mps_update::diff, end, eventChunkBlock_, FrontierConditions_GlobalTag_cff::file, InputChunk::fileIndex_, InputFile::fileName_, plotBeamSpotDB::first, mps_fire::i, init, plotBeamSpotDB::last, LogDebug, mReader_, cmsPerfSuiteHarvest::now, InputChunk::offset_, read(), readBlocks_, InputChunk::readComplete_, edm::second(), setExceptionState_, command_line::start, startupCv_, startupLock_, thread_quit_signal, threadInit_, tid_active_, InputChunk::usedSize_, workerJob_, and workerPool_.
Referenced by FedRawDataInputSource().
|
private |
Definition at line 1373 of file FedRawDataInputSource.cc.
References CommonMethods::lock(), monlock_, and sourceEventsReport_.
Referenced by checkNextEvent(), and getNextEvent().
|
overrideprivatevirtual |
Reimplemented from edm::InputSource.
Definition at line 905 of file FedRawDataInputSource.cc.
|
private |
Definition at line 1259 of file FedRawDataInputSource.cc.
References Exception, and quit_threads_.
Referenced by getNextEvent().
|
friend |
Definition at line 44 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource().
|
friend |
Definition at line 43 of file FedRawDataInputSource.h.
Referenced by readSupervisor().
|
private |
Definition at line 175 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and readNextChunkIntoBuffer().
|
private |
Definition at line 166 of file FedRawDataInputSource.h.
Referenced by read().
|
private |
Definition at line 138 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and read().
|
private |
Definition at line 137 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and read().
|
private |
Definition at line 160 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and read().
|
private |
Definition at line 118 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), getNextEvent(), maybeOpenNewLumiSection(), and read().
|
private |
Definition at line 151 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readSupervisor(), readWorker(), and ~FedRawDataInputSource().
|
private |
Definition at line 170 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and readSupervisor().
|
private |
Definition at line 83 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), createBoLSFile(), FedRawDataInputSource(), getNextEvent(), grabNextJsonFile(), maybeOpenNewLumiSection(), and readSupervisor().
|
private |
Definition at line 111 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), and read().
|
private |
Definition at line 85 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource().
|
private |
Definition at line 136 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and readWorker().
|
private |
Definition at line 126 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), and grabNextJsonFile().
|
private |
Definition at line 113 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), fillFEDRawDataCollection(), and getNextEvent().
|
private |
Definition at line 88 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readNextChunkIntoBuffer(), and readWorker().
|
private |
Definition at line 87 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), getNextEvent(), readNextChunkIntoBuffer(), and readSupervisor().
|
private |
Definition at line 115 of file FedRawDataInputSource.h.
Referenced by read().
|
private |
Definition at line 119 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), and read().
|
private |
Definition at line 123 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), getNextEvent(), and read().
|
private |
Definition at line 124 of file FedRawDataInputSource.h.
|
private |
Definition at line 163 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), getNextEvent(), and read().
|
private |
Definition at line 174 of file FedRawDataInputSource.h.
Referenced by readNextChunkIntoBuffer().
|
private |
Definition at line 104 of file FedRawDataInputSource.h.
Referenced by getFile().
|
private |
Definition at line 105 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), FedRawDataInputSource(), getFile(), and read().
|
private |
Definition at line 103 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), deleteFile(), FedRawDataInputSource(), getNextEvent(), and readSupervisor().
|
private |
Definition at line 100 of file FedRawDataInputSource.h.
Referenced by getFile(), and initFileList().
|
private |
Definition at line 162 of file FedRawDataInputSource.h.
|
private |
Definition at line 148 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and readSupervisor().
Definition at line 161 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), getNextEvent(), read(), and ~FedRawDataInputSource().
|
private |
Definition at line 82 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), FedRawDataInputSource(), getNextEvent(), read(), and readSupervisor().
|
private |
Definition at line 147 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), getNextEvent(), read(), and readSupervisor().
|
private |
Definition at line 109 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), and grabNextJsonFile().
|
private |
Definition at line 96 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), getNextEvent(), and readSupervisor().
|
private |
Definition at line 120 of file FedRawDataInputSource.h.
Referenced by fillFEDRawDataCollection(), and read().
|
private |
Definition at line 121 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), and read().
|
private |
Definition at line 106 of file FedRawDataInputSource.h.
Referenced by getFile().
|
private |
Definition at line 91 of file FedRawDataInputSource.h.
Referenced by readSupervisor().
|
private |
Definition at line 180 of file FedRawDataInputSource.h.
Referenced by getEventReport(), and reportEventsThisLumiInSource().
|
private |
Definition at line 150 of file FedRawDataInputSource.h.
Referenced by readSupervisor(), readWorker(), and ~FedRawDataInputSource().
|
private |
Definition at line 169 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), and readSupervisor().
|
private |
Definition at line 165 of file FedRawDataInputSource.h.
Referenced by read().
|
private |
Definition at line 90 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource().
|
private |
Definition at line 92 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), and ~FedRawDataInputSource().
|
private |
Definition at line 116 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), maybeOpenNewLumiSection(), and read().
|
private |
Definition at line 154 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readSupervisor(), threadError(), and ~FedRawDataInputSource().
|
private |
Definition at line 89 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readNextChunkIntoBuffer(), and readWorker().
|
private |
Definition at line 93 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), getNextEvent(), and readSupervisor().
|
private |
Definition at line 141 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), and ~FedRawDataInputSource().
|
private |
Definition at line 108 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), and FedRawDataInputSource().
|
private |
Definition at line 156 of file FedRawDataInputSource.h.
Referenced by getNextEvent(), readSupervisor(), and readWorker().
|
private |
Definition at line 173 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), getNextEvent(), and readSupervisor().
|
private |
Definition at line 179 of file FedRawDataInputSource.h.
Referenced by getEventReport(), and reportEventsThisLumiInSource().
|
private |
Definition at line 140 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), and ~FedRawDataInputSource().
|
private |
Definition at line 158 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), FedRawDataInputSource(), readSupervisor(), and readWorker().
|
private |
Definition at line 157 of file FedRawDataInputSource.h.
Referenced by checkNextEvent(), FedRawDataInputSource(), readSupervisor(), and readWorker().
|
private |
Definition at line 164 of file FedRawDataInputSource.h.
Referenced by read().
|
private |
Definition at line 122 of file FedRawDataInputSource.h.
Referenced by fillFEDRawDataCollection(), and read().
|
private |
Definition at line 155 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readSupervisor(), readWorker(), and ~FedRawDataInputSource().
|
private |
Definition at line 177 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), and readWorker().
|
private |
Definition at line 152 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readSupervisor(), and readWorker().
|
private |
Definition at line 99 of file FedRawDataInputSource.h.
Referenced by read().
|
private |
Definition at line 97 of file FedRawDataInputSource.h.
Referenced by getNextEvent().
|
private |
Definition at line 98 of file FedRawDataInputSource.h.
Referenced by getNextEvent().
|
private |
Definition at line 145 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readSupervisor(), and readWorker().
|
private |
Definition at line 144 of file FedRawDataInputSource.h.
Referenced by readSupervisor(), and readWorker().
|
private |
Definition at line 142 of file FedRawDataInputSource.h.
Referenced by FedRawDataInputSource(), readSupervisor(), and ~FedRawDataInputSource().