edm::PrincipalCache Class Reference

#include <PrincipalCache.h>

Public Member Functions
void	adjustEventsToNewProductRegistry (std::shared_ptr< ProductRegistry const > reg)
void	adjustIndexesAfterProductRegistryAddition ()
void	deleteRun (ProcessHistoryID const &phid, RunNumber_t run)
EventPrincipal &	eventPrincipal (unsigned int iStreamIndex) const
std::shared_ptr< LuminosityBlockPrincipal >	getAvailableLumiPrincipalPtr ()
bool	hasRunPrincipal () const
void	insert (std::shared_ptr< RunPrincipal > rp)
void	insert (std::unique_ptr< LuminosityBlockPrincipal > lbp)
void	insert (std::shared_ptr< EventPrincipal > ep)
void	merge (std::shared_ptr< RunAuxiliary > aux, std::shared_ptr< ProductRegistry const > reg)
void	preReadFile ()
	PrincipalCache ()
	PrincipalCache (PrincipalCache &&)=default
RunPrincipal &	runPrincipal (ProcessHistoryID const &phid, RunNumber_t run) const
RunPrincipal &	runPrincipal () const
std::shared_ptr< RunPrincipal > const &	runPrincipalPtr (ProcessHistoryID const &phid, RunNumber_t run) const
std::shared_ptr< RunPrincipal > const &	runPrincipalPtr () const
void	setNumberOfConcurrentPrincipals (PreallocationConfiguration const &)
void	setProcessHistoryRegistry (ProcessHistoryRegistry const &phr)
	~PrincipalCache ()

Private Member Functions
void	throwLumiMissing () const
void	throwRunMissing () const

Private Attributes
std::vector< std::shared_ptr< EventPrincipal > >	eventPrincipals_
ProcessHistoryID	inputProcessHistoryID_
LuminosityBlockNumber_t	lumi_
edm::ReusableObjectHolder< LuminosityBlockPrincipal >	lumiHolder_
ProcessHistoryRegistry const *	processHistoryRegistry_
ProcessHistoryID	reducedInputProcessHistoryID_
RunNumber_t	run_
std::shared_ptr< RunPrincipal >	runPrincipal_

Detailed Description

Definition at line 47 of file PrincipalCache.h.

Constructor & Destructor Documentation

edm::PrincipalCache::PrincipalCache

(

)

Definition at line 12 of file PrincipalCache.cc.

                                 :
    run_(0U),
    lumi_(0U) {
  }

edm::PrincipalCache::~PrincipalCache

(

)

Definition at line 17 of file PrincipalCache.cc.

{ }

edm::PrincipalCache::PrincipalCache ( PrincipalCache &&  )

default

Member Function Documentation

void edm::PrincipalCache::adjustEventsToNewProductRegistry

(

std::shared_ptr< ProductRegistry const >

reg

)

Definition at line 138 of file PrincipalCache.cc.

References edm::Principal::adjustIndexesAfterProductRegistryAddition(), edm::Principal::adjustToNewProductRegistry(), eventPrincipal(), and eventPrincipals_.

Referenced by eventPrincipal(), and edm::EventProcessor::readFile().

                                                                                                {
    for(auto &eventPrincipal : eventPrincipals_) {
      if (eventPrincipal) {
        eventPrincipal->adjustIndexesAfterProductRegistryAddition();
        bool eventOK = eventPrincipal->adjustToNewProductRegistry(*reg);
        assert(eventOK);
      }
    }
  }

void edm::PrincipalCache::adjustIndexesAfterProductRegistryAddition

(

)

Definition at line 148 of file PrincipalCache.cc.

References lumiHolder_, eostools::move(), AlCaHLTBitMon_ParallelJobs::p, runPrincipal_, and groupFilesInBlocks::temp.

Referenced by eventPrincipal(), and edm::EventProcessor::readFile().

                                                                 {
    if (runPrincipal_) {
      runPrincipal_->adjustIndexesAfterProductRegistryAddition();
    }
    //Need to temporarily hold all the lumis to clear out the lumiHolder_
    std::vector<std::shared_ptr<LuminosityBlockPrincipal>> temp;
    while(auto p = lumiHolder_.tryToGet()) {
      p->adjustIndexesAfterProductRegistryAddition();
      temp.emplace_back(std::move(p));
    }
  }

void edm::PrincipalCache::deleteRun	(	ProcessHistoryID const &	phid,
		RunNumber_t	run
	)

Definition at line 119 of file PrincipalCache.cc.

References Exception, edm::errors::LogicError, reducedInputProcessHistoryID_, run_, and runPrincipal_.

Referenced by edm::SubProcess::deleteRunFromCache(), edm::EventProcessor::deleteRunFromCache(), edm::test::TestProcessor::endRun(), and eventPrincipal().

                                                                              {
    if (runPrincipal_.get() == nullptr) {
      throw edm::Exception(edm::errors::LogicError)
        << "PrincipalCache::deleteRun\n"
        << "Illegal attempt to delete run from cache\n"
        << "There is no run in cache to delete\n"
        << "Contact a Framework Developer\n";
    }
    if (reducedInputProcessHistoryID_ != phid ||
        run != run_) {
      throw edm::Exception(edm::errors::LogicError)
        << "PrincipalCache::deleteRun\n"
        << "Illegal attempt to delete run from cache\n"
        << "Run number or reduced ProcessHistoryID inconsistent with those in cache\n"
        << "Contact a Framework Developer\n";
    }
    runPrincipal_.reset();
  }

EventPrincipal& edm::PrincipalCache::eventPrincipal ( unsigned int  iStreamIndex ) const

inline

Definition at line 62 of file PrincipalCache.h.

References adjustEventsToNewProductRegistry(), adjustIndexesAfterProductRegistryAddition(), printConversionInfo::aux, deleteRun(), eventPrincipals_, insert(), merge(), and setNumberOfConcurrentPrincipals().

Referenced by adjustEventsToNewProductRegistry(), edm::EventProcessor::beginLumiAsync(), edm::test::TestProcessor::event(), edm::SubProcess::processAsync(), edm::EventProcessor::processEventAsyncImpl(), edm::EventProcessor::readEvent(), and edm::test::TestProcessor::testImpl().

{ return *(eventPrincipals_[iStreamIndex]); }

std::shared_ptr< LuminosityBlockPrincipal > edm::PrincipalCache::getAvailableLumiPrincipalPtr

(

)

Definition at line 62 of file PrincipalCache.cc.

References lumiHolder_.

Referenced by edm::test::TestProcessor::beginLuminosityBlock(), edm::SubProcess::doBeginLuminosityBlockAsync(), hasRunPrincipal(), and edm::EventProcessor::readLuminosityBlock().

{ return lumiHolder_.tryToGet();}

bool edm::PrincipalCache::hasRunPrincipal ( ) const

inline

Definition at line 58 of file PrincipalCache.h.

References electrons_cff::bool, getAvailableLumiPrincipalPtr(), and runPrincipal_.

Referenced by edm::EventProcessor::readLuminosityBlock(), and edm::EventProcessor::readRun().

{return bool(runPrincipal_);}

void edm::PrincipalCache::insert

(

std::shared_ptr< RunPrincipal >

rp

)

Definition at line 94 of file PrincipalCache.cc.

References Exception, inputProcessHistoryID_, edm::errors::LogicError, processHistoryRegistry_, reducedInputProcessHistoryID_, edm::ProcessHistoryRegistry::reducedProcessHistoryID(), run_, and runPrincipal_.

Referenced by edm::test::TestProcessor::beginRun(), edm::SubProcess::doBeginRunAsync(), eventPrincipal(), edm::EventProcessor::init(), edm::EventProcessor::readRun(), edm::SubProcess::SubProcess(), and edm::test::TestProcessor::TestProcessor().

                                                            {
    if (runPrincipal_.get() != nullptr) {
      throw edm::Exception(edm::errors::LogicError)
        << "PrincipalCache::insert\n"
        << "Illegal attempt to insert run into cache\n"
        << "Contact a Framework Developer\n";
    }
    if (inputProcessHistoryID_ != rp->aux().processHistoryID()) {
      reducedInputProcessHistoryID_ = processHistoryRegistry_->reducedProcessHistoryID(rp->aux().processHistoryID());
      inputProcessHistoryID_ = rp->aux().processHistoryID();
    }
    run_ = rp->run();
    runPrincipal_ = rp; 
  }

void edm::PrincipalCache::insert

(

std::unique_ptr< LuminosityBlockPrincipal >

lbp

)

Definition at line 109 of file PrincipalCache.cc.

References lumiHolder_, and eostools::move().

                                                                         {
    lumiHolder_.add(std::move(lbp));
  }

void edm::PrincipalCache::insert

(

std::shared_ptr< EventPrincipal >

ep

)

Definition at line 113 of file PrincipalCache.cc.

References eventPrincipals_.

                                                              {
    unsigned int iStreamIndex = ep->streamID().value();
    assert(iStreamIndex < eventPrincipals_.size());
    eventPrincipals_[iStreamIndex] = ep;
  }

void edm::PrincipalCache::merge	(	std::shared_ptr< RunAuxiliary >	aux,
		std::shared_ptr< ProductRegistry const >	reg
	)

Definition at line 64 of file PrincipalCache.cc.

References Exception, inputProcessHistoryID_, edm::errors::LogicError, processHistoryRegistry_, reducedInputProcessHistoryID_, edm::ProcessHistoryRegistry::reducedProcessHistoryID(), run_, and runPrincipal_.

Referenced by eventPrincipal(), and edm::EventProcessor::readAndMergeRun().

                                                                                                      {
    if (runPrincipal_.get() == nullptr) {
      throw edm::Exception(edm::errors::LogicError)
        << "PrincipalCache::merge\n"
        << "Illegal attempt to merge run into cache\n"
        << "There is no run in cache to merge with\n"
        << "Contact a Framework Developer\n";
    }
    if (inputProcessHistoryID_ != aux->processHistoryID()) {
      if (reducedInputProcessHistoryID_ != processHistoryRegistry_->reducedProcessHistoryID(aux->processHistoryID())) {
        throw edm::Exception(edm::errors::LogicError)
          << "PrincipalCache::merge\n"
          << "Illegal attempt to merge run into cache\n"
          << "Reduced ProcessHistoryID inconsistent with the one already in cache\n"
          << "Contact a Framework Developer\n";
      }
      inputProcessHistoryID_ = aux->processHistoryID();
    }
    if (aux->run() != run_) {
      throw edm::Exception(edm::errors::LogicError)
        << "PrincipalCache::merge\n"
        << "Illegal attempt to merge run into cache\n"
        << "Run number inconsistent with run number already in cache\n"
        << "Contact a Framework Developer\n";
    }
    bool runOK = runPrincipal_->adjustToNewProductRegistry(*reg);
    assert(runOK);
    runPrincipal_->mergeAuxiliary(*aux);
  }

void edm::PrincipalCache::preReadFile

(

)

Definition at line 161 of file PrincipalCache.cc.

References runPrincipal_.

Referenced by edm::EventProcessor::readFile(), and setProcessHistoryRegistry().

                              {
    if (runPrincipal_) {
      runPrincipal_->preReadFile();
    }
  }

RunPrincipal & edm::PrincipalCache::runPrincipal	(	ProcessHistoryID const &	phid,
		RunNumber_t	run
	)		const

Definition at line 26 of file PrincipalCache.cc.

References reducedInputProcessHistoryID_, run_, runPrincipal_, and throwRunMissing().

Referenced by edm::EventProcessor::beginRun(), edm::test::TestProcessor::beginRun(), edm::EventProcessor::endRun(), edm::test::TestProcessor::endRun(), edm::EventProcessor::endUnfinishedRun(), edm::SubProcess::writeRunAsync(), and edm::EventProcessor::writeRunAsync().

                                                                                  {
    if (phid != reducedInputProcessHistoryID_ ||
        run != run_ ||
        runPrincipal_.get() == nullptr) {
      throwRunMissing();
    }
    return *runPrincipal_.get();
  }

RunPrincipal & edm::PrincipalCache::runPrincipal

(

)

const

Definition at line 46 of file PrincipalCache.cc.

References runPrincipal_, and throwRunMissing().

                                     {
    if (runPrincipal_.get() == nullptr) {
      throwRunMissing();
    }
    return *runPrincipal_.get();
  }

std::shared_ptr< RunPrincipal > const & edm::PrincipalCache::runPrincipalPtr	(	ProcessHistoryID const &	phid,
		RunNumber_t	run
	)		const

Definition at line 36 of file PrincipalCache.cc.

References reducedInputProcessHistoryID_, run_, runPrincipal_, and throwRunMissing().

Referenced by edm::test::TestProcessor::beginLuminosityBlock(), edm::SubProcess::doBeginLuminosityBlockAsync(), edm::SubProcess::doBeginRunAsync(), edm::SubProcess::doEndRunAsync(), edm::SubProcess::doStreamBeginRunAsync(), edm::SubProcess::doStreamEndRunAsync(), edm::EventProcessor::readAndMergeRun(), and edm::EventProcessor::readLuminosityBlock().

                                                                                     {
    if (phid != reducedInputProcessHistoryID_ ||
        run != run_ ||
        runPrincipal_.get() == nullptr) {
      throwRunMissing();
    }
    return runPrincipal_;
  }

std::shared_ptr< RunPrincipal > const & edm::PrincipalCache::runPrincipalPtr

(

)

const

Definition at line 54 of file PrincipalCache.cc.

References runPrincipal_, and throwRunMissing().

                                        {
    if (runPrincipal_.get() == nullptr) {
      throwRunMissing();
    }
    return runPrincipal_;
  }

void edm::PrincipalCache::setNumberOfConcurrentPrincipals

(

PreallocationConfiguration const &

iConfig

)

Definition at line 20 of file PrincipalCache.cc.

References eventPrincipals_, and edm::PreallocationConfiguration::numberOfStreams().

Referenced by eventPrincipal(), edm::EventProcessor::init(), edm::SubProcess::SubProcess(), and edm::test::TestProcessor::TestProcessor().

  {
    eventPrincipals_.resize(iConfig.numberOfStreams());
  }

void edm::PrincipalCache::setProcessHistoryRegistry ( ProcessHistoryRegistry const &  phr )

inline

Definition at line 77 of file PrincipalCache.h.

References preReadFile(), processHistoryRegistry_, throwLumiMissing(), and throwRunMissing().

Referenced by edm::EventProcessor::init(), edm::SubProcess::SubProcess(), and edm::test::TestProcessor::TestProcessor().

{processHistoryRegistry_ = &phr;}

void edm::PrincipalCache::throwLumiMissing ( ) const

private

Definition at line 176 of file PrincipalCache.cc.

References Exception, and edm::errors::LogicError.

Referenced by setProcessHistoryRegistry().

                                         {
    throw edm::Exception(edm::errors::LogicError)
      << "PrincipalCache::lumiPrincipal or PrincipalCache::lumiPrincipalPtr\n"
      << "Requested a luminosity block that is not in the cache (should never happen)\n"
      << "Contact a Framework Developer\n";
  }

void edm::PrincipalCache::throwRunMissing ( ) const

private

Definition at line 168 of file PrincipalCache.cc.

References Exception, and edm::errors::LogicError.

Referenced by runPrincipal(), runPrincipalPtr(), and setProcessHistoryRegistry().

                                        {
    throw edm::Exception(edm::errors::LogicError)
      << "PrincipalCache::runPrincipal\n"
      << "Requested a run that is not in the cache (should never happen)\n"
      << "Contact a Framework Developer\n";
  }

Member Data Documentation

std::vector<std::shared_ptr<EventPrincipal> > edm::PrincipalCache::eventPrincipals_

private

Definition at line 90 of file PrincipalCache.h.

Referenced by adjustEventsToNewProductRegistry(), eventPrincipal(), insert(), and setNumberOfConcurrentPrincipals().

ProcessHistoryID edm::PrincipalCache::inputProcessHistoryID_

private

Definition at line 102 of file PrincipalCache.h.

Referenced by insert(), and merge().

LuminosityBlockNumber_t edm::PrincipalCache::lumi_

private

Definition at line 105 of file PrincipalCache.h.

edm::ReusableObjectHolder<LuminosityBlockPrincipal> edm::PrincipalCache::lumiHolder_

private

Definition at line 89 of file PrincipalCache.h.

Referenced by adjustIndexesAfterProductRegistryAddition(), getAvailableLumiPrincipalPtr(), and insert().

ProcessHistoryRegistry const* edm::PrincipalCache::processHistoryRegistry_

private

Definition at line 93 of file PrincipalCache.h.

Referenced by insert(), merge(), and setProcessHistoryRegistry().

ProcessHistoryID edm::PrincipalCache::reducedInputProcessHistoryID_

private

Definition at line 103 of file PrincipalCache.h.

Referenced by deleteRun(), insert(), merge(), runPrincipal(), and runPrincipalPtr().

RunNumber_t edm::PrincipalCache::run_

private

Definition at line 104 of file PrincipalCache.h.

Referenced by deleteRun(), insert(), merge(), runPrincipal(), and runPrincipalPtr().

std::shared_ptr<RunPrincipal> edm::PrincipalCache::runPrincipal_

private

Definition at line 88 of file PrincipalCache.h.

Referenced by adjustIndexesAfterProductRegistryAddition(), deleteRun(), hasRunPrincipal(), insert(), merge(), preReadFile(), runPrincipal(), and runPrincipalPtr().