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 14 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 120 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 130 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 103 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 61 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 49 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 57 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 81 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 95 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 97 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 53 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 142 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 20 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 35 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 27 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 42 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 16 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 76 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 154 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 148 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 88 of file PrincipalCache.h.

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

ProcessHistoryID edm::PrincipalCache::inputProcessHistoryID_

private

Definition at line 100 of file PrincipalCache.h.

Referenced by insert(), and merge().

LuminosityBlockNumber_t edm::PrincipalCache::lumi_

private

Definition at line 103 of file PrincipalCache.h.

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

private

Definition at line 87 of file PrincipalCache.h.

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

ProcessHistoryRegistry const* edm::PrincipalCache::processHistoryRegistry_

private

Definition at line 91 of file PrincipalCache.h.

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

ProcessHistoryID edm::PrincipalCache::reducedInputProcessHistoryID_

private

Definition at line 101 of file PrincipalCache.h.

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

RunNumber_t edm::PrincipalCache::run_

private

Definition at line 102 of file PrincipalCache.h.

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

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

private

Definition at line 86 of file PrincipalCache.h.

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