CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Classes | Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes
DQMRootSource Class Reference
Inheritance diagram for DQMRootSource:
edm::InputSource edm::ProductRegistryHelper

Classes

class  RunLumiPHIDKey
 
class  RunPHIDKey
 

Public Member Functions

 DQMRootSource (edm::ParameterSet const &, const edm::InputSourceDescription &)
 
virtual ~DQMRootSource ()
 
- Public Member Functions inherited from edm::InputSource
std::shared_ptr< ActivityRegistryactReg () 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...
 
InputSourceoperator= (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...
 
ProcessHistoryRegistryprocessHistoryRegistry ()
 
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< FileBlockreadFile ()
 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< RunAuxiliaryreadRunAuxiliary ()
 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...
 
SharedResourcesAcquirerresourceSharedWithDelayedReader ()
 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< RunAuxiliaryrunAuxiliary () 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::InputSource
static const std::string & baseType ()
 
static void fillDescription (ParameterSetDescription &desc)
 
static void fillDescriptions (ConfigurationDescriptions &descriptions)
 
static void prevalidate (ConfigurationDescriptions &)
 

Private Member Functions

virtual void closeFile_ () override
 
 DQMRootSource (const DQMRootSource &)
 
virtual edm::InputSource::ItemType getNextItemType () override
 
void logFileAction (char const *msg, char const *fileName) const
 
const DQMRootSourceoperator= (const DQMRootSource &)
 
void readElements ()
 
virtual void readEvent_ (edm::EventPrincipal &) override
 
virtual std::unique_ptr
< edm::FileBlock
readFile_ () override
 
virtual void readLuminosityBlock_ (edm::LuminosityBlockPrincipal &lbCache) override
 
virtual std::shared_ptr
< edm::LuminosityBlockAuxiliary
readLuminosityBlockAuxiliary_ () override
 
void readNextItemType ()
 
virtual void readRun_ (edm::RunPrincipal &rpCache) override
 
virtual std::shared_ptr
< edm::RunAuxiliary
readRunAuxiliary_ () override
 
bool setupFile (unsigned int iIndex)
 
bool skipIt (edm::RunNumber_t, edm::LuminosityBlockNumber_t) const
 

Private Attributes

edm::InputFileCatalog m_catalog
 
std::auto_ptr< TFile > m_file
 
size_t m_fileIndex
 
unsigned int m_filterOnRun
 
std::vector
< edm::ProcessHistoryID
m_historyIDs
 
edm::JobReport::Token m_jrToken
 
bool m_justOpenedFileSoNeedToGenerateRunTransition
 
unsigned int m_lastSeenLumi2
 
edm::ProcessHistoryID m_lastSeenReducedPHID
 
edm::ProcessHistoryID m_lastSeenReducedPHID2
 
unsigned int m_lastSeenRun
 
unsigned int m_lastSeenRun2
 
edm::LuminosityBlockAuxiliary m_lumiAux
 
std::set< MonitorElement * > m_lumiElements
 
std::vector
< edm::LuminosityBlockRange
m_lumisToProcess
 
std::list< unsigned int >::iterator m_nextIndexItr
 
edm::InputSource::ItemType m_nextItemType
 
std::list< unsigned int > m_orderedIndices
 
std::list< unsigned int >::iterator m_presentIndexItr
 
size_t m_presentlyOpenFileIndex
 
std::vector
< edm::ProcessHistoryID
m_reducedHistoryIDs
 
edm::RunAuxiliary m_runAux
 
std::set< MonitorElement * > m_runElements
 
std::vector< RunLumiToRange > m_runlumiToRange
 
std::vector< edm::RunNumber_tm_runsToProcess
 
bool m_shouldReadMEs
 
bool m_skipBadFiles
 
std::vector< boost::shared_ptr
< TreeReaderBase > > 
m_treeReaders
 
std::vector< TTree * > m_trees
 

Additional Inherited Members

- 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
 
- Protected Member Functions inherited from edm::InputSource
void decreaseRemainingEventsBy (int iSkipped)
 
bool eventCached () const
 
bool newLumi () const
 
bool newRun () const
 
ProcessHistoryRegistryprocessHistoryRegistryForUpdate ()
 
ProductRegistryproductRegistryUpdate ()
 
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
 

Detailed Description

Definition at line 302 of file DQMRootSource.cc.

Constructor & Destructor Documentation

DQMRootSource::DQMRootSource ( edm::ParameterSet const &  iPSet,
const edm::InputSourceDescription iDesc 
)

Definition at line 443 of file DQMRootSource.cc.

DQMRootSource::~DQMRootSource ( )
virtual

Definition at line 490 of file DQMRootSource.cc.

DQMRootSource::DQMRootSource ( const DQMRootSource )
private

Member Function Documentation

void DQMRootSource::closeFile_ ( )
overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 680 of file DQMRootSource.cc.

void DQMRootSource::fillDescriptions ( edm::ConfigurationDescriptions descriptions)
static

Definition at line 424 of file DQMRootSource.cc.

edm::InputSource::ItemType DQMRootSource::getNextItemType ( )
overrideprivatevirtual

Implements edm::InputSource.

Definition at line 518 of file DQMRootSource.cc.

void DQMRootSource::logFileAction ( char const *  msg,
char const *  fileName 
) const
private

Definition at line 1045 of file DQMRootSource.cc.

const DQMRootSource& DQMRootSource::operator= ( const DQMRootSource )
private
void DQMRootSource::readElements ( )
private

Definition at line 686 of file DQMRootSource.cc.

void DQMRootSource::readEvent_ ( edm::EventPrincipal )
overrideprivatevirtual

Implements edm::InputSource.

Definition at line 513 of file DQMRootSource.cc.

std::unique_ptr< edm::FileBlock > DQMRootSource::readFile_ ( )
overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 651 of file DQMRootSource.cc.

void DQMRootSource::readLuminosityBlock_ ( edm::LuminosityBlockPrincipal lbCache)
overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 614 of file DQMRootSource.cc.

std::shared_ptr< edm::LuminosityBlockAuxiliary > DQMRootSource::readLuminosityBlockAuxiliary_ ( )
overrideprivatevirtual

Implements edm::InputSource.

Definition at line 540 of file DQMRootSource.cc.

void DQMRootSource::readNextItemType ( )
private

Definition at line 727 of file DQMRootSource.cc.

void DQMRootSource::readRun_ ( edm::RunPrincipal rpCache)
overrideprivatevirtual

If the collate option is not set for the DQMStore, we should indeed be sure to reset all histograms after a run transition, but we should definitely avoid doing it using a local, private copy of the actual content of the DQMStore. Clients are completely free to delete/add MonitorElements from the DQMStore and the local copy stored in the std::set will never notice it until it will try to reset a deleted object. That's why the resetting directly queries the DQMStore for its current content.

Reimplemented from edm::InputSource.

Definition at line 556 of file DQMRootSource.cc.

std::shared_ptr< edm::RunAuxiliary > DQMRootSource::readRunAuxiliary_ ( )
overrideprivatevirtual

Implements edm::InputSource.

Definition at line 524 of file DQMRootSource.cc.

bool DQMRootSource::setupFile ( unsigned int  iIndex)
private

Definition at line 788 of file DQMRootSource.cc.

bool DQMRootSource::skipIt ( edm::RunNumber_t  run,
edm::LuminosityBlockNumber_t  lumi 
) const
private

Definition at line 1029 of file DQMRootSource.cc.

Member Data Documentation

edm::InputFileCatalog DQMRootSource::m_catalog
private

Definition at line 380 of file DQMRootSource.cc.

std::auto_ptr<TFile> DQMRootSource::m_file
private

Definition at line 390 of file DQMRootSource.cc.

size_t DQMRootSource::m_fileIndex
private

Definition at line 385 of file DQMRootSource.cc.

unsigned int DQMRootSource::m_filterOnRun
private

Definition at line 400 of file DQMRootSource.cc.

std::vector<edm::ProcessHistoryID> DQMRootSource::m_historyIDs
private

Definition at line 409 of file DQMRootSource.cc.

edm::JobReport::Token DQMRootSource::m_jrToken
private

Definition at line 412 of file DQMRootSource.cc.

bool DQMRootSource::m_justOpenedFileSoNeedToGenerateRunTransition
private

Definition at line 405 of file DQMRootSource.cc.

unsigned int DQMRootSource::m_lastSeenLumi2
private

Definition at line 399 of file DQMRootSource.cc.

edm::ProcessHistoryID DQMRootSource::m_lastSeenReducedPHID
private

Definition at line 395 of file DQMRootSource.cc.

edm::ProcessHistoryID DQMRootSource::m_lastSeenReducedPHID2
private

Definition at line 397 of file DQMRootSource.cc.

unsigned int DQMRootSource::m_lastSeenRun
private

Definition at line 396 of file DQMRootSource.cc.

unsigned int DQMRootSource::m_lastSeenRun2
private

Definition at line 398 of file DQMRootSource.cc.

edm::LuminosityBlockAuxiliary DQMRootSource::m_lumiAux
private

Definition at line 382 of file DQMRootSource.cc.

std::set<MonitorElement*> DQMRootSource::m_lumiElements
private

Definition at line 407 of file DQMRootSource.cc.

std::vector<edm::LuminosityBlockRange> DQMRootSource::m_lumisToProcess
private

Definition at line 402 of file DQMRootSource.cc.

std::list<unsigned int>::iterator DQMRootSource::m_nextIndexItr
private

Definition at line 387 of file DQMRootSource.cc.

edm::InputSource::ItemType DQMRootSource::m_nextItemType
private

Definition at line 383 of file DQMRootSource.cc.

std::list<unsigned int> DQMRootSource::m_orderedIndices
private

Definition at line 394 of file DQMRootSource.cc.

std::list<unsigned int>::iterator DQMRootSource::m_presentIndexItr
private

Definition at line 388 of file DQMRootSource.cc.

size_t DQMRootSource::m_presentlyOpenFileIndex
private

Definition at line 386 of file DQMRootSource.cc.

std::vector<edm::ProcessHistoryID> DQMRootSource::m_reducedHistoryIDs
private

Definition at line 410 of file DQMRootSource.cc.

edm::RunAuxiliary DQMRootSource::m_runAux
private

Definition at line 381 of file DQMRootSource.cc.

std::set<MonitorElement*> DQMRootSource::m_runElements
private

Definition at line 408 of file DQMRootSource.cc.

std::vector<RunLumiToRange> DQMRootSource::m_runlumiToRange
private

Definition at line 389 of file DQMRootSource.cc.

std::vector<edm::RunNumber_t> DQMRootSource::m_runsToProcess
private

Definition at line 403 of file DQMRootSource.cc.

bool DQMRootSource::m_shouldReadMEs
private

Definition at line 406 of file DQMRootSource.cc.

bool DQMRootSource::m_skipBadFiles
private

Definition at line 401 of file DQMRootSource.cc.

std::vector<boost::shared_ptr<TreeReaderBase> > DQMRootSource::m_treeReaders
private

Definition at line 392 of file DQMRootSource.cc.

std::vector<TTree*> DQMRootSource::m_trees
private

Definition at line 391 of file DQMRootSource.cc.