edm::ProductRegistry Class Reference

#include <ProductRegistry.h>

Inheritance diagram for edm::ProductRegistry:

Classes
struct	Transients

Public Types
typedef std::map< BranchKey, BranchDescription const >	ConstProductList
typedef std::map< BranchKey, BranchDescription >	ProductList

Public Member Functions
void	addLabelAlias (BranchDescription const &productdesc, std::string const &labelAlias, std::string const &instanceAlias)
void	addProduct (BranchDescription const &productdesc, bool iFromListener=false)
std::vector< BranchDescription const * >	allBranchDescriptions () const
std::vector< std::string >	allBranchNames () const
bool	anyProductProduced () const
bool	anyProducts (BranchType const brType) const
template<typename T >
void	callForEachBranch (T const &iFunc)
ConstProductList &	constProductList ()
void	copyProduct (BranchDescription const &productdesc)
bool	frozen () const
ProductHolderIndex const &	getNextIndexValue (BranchType branchType) const
ProductHolderIndex	indexFrom (BranchID const &iID) const
void	initializeTransients ()
std::string	merge (ProductRegistry const &other, std::string const &fileName, BranchDescription::MatchMode branchesMustMatch=BranchDescription::Permissive)
std::vector< std::string > const &	missingDictionaries () const
std::vector< std::string > &	missingDictionariesForUpdate ()
void	print (std::ostream &os) const
ProductList const &	productList () const
ProductList &	productListUpdator ()
std::shared_ptr < ProductHolderIndexHelper > const &	productLookup (BranchType branchType) const
bool	productProduced (BranchType branchType) const
	ProductRegistry ()
	ProductRegistry (ProductList const &productList, bool toBeFrozen=true)
void	setFrozen (bool initializeLookupInfo=true)
ProductList::size_type	size () const
void	updateFromInput (ProductList const &other)
void	updateFromInput (std::vector< BranchDescription > const &other)
virtual	~ProductRegistry ()

Private Member Functions
virtual void	addCalled (BranchDescription const &, bool iFromListener)
void	freezeIt (bool frozen=true)
void	initializeLookupTables ()
ProductHolderIndex &	nextIndexValue (BranchType branchType)
void	setProductProduced (BranchType branchType)
void	throwIfFrozen () const
void	throwIfNotFrozen () const
void	updateConstProductRegistry ()

Private Attributes
ProductList	productList_
Transients	transient_

Detailed Description

author Stefano ARGIRO author Bill Tanenbaum

Date

19 Jul 2005

Definition at line 29 of file ProductRegistry.h.

Member Typedef Documentation

typedef std::map<BranchKey, BranchDescription const> edm::ProductRegistry::ConstProductList

Definition at line 43 of file ProductRegistry.h.

typedef std::map<BranchKey, BranchDescription> edm::ProductRegistry::ProductList

Definition at line 32 of file ProductRegistry.h.

Constructor & Destructor Documentation

edm::ProductRegistry::ProductRegistry

(

)

Definition at line 39 of file ProductRegistry.cc.

                                   :
      productList_(),
      transient_() {
  }

edm::ProductRegistry::ProductRegistry ( ProductList const &  productList, bool  toBeFrozen = true  )

explicit

Definition at line 78 of file ProductRegistry.cc.

References freezeIt().

                                                                                  :
      productList_(productList),
      transient_() {
    freezeIt(toBeFrozen);
  }

virtual edm::ProductRegistry::~ProductRegistry ( )

inlinevirtual

Definition at line 41 of file ProductRegistry.h.

{}

Member Function Documentation

void edm::ProductRegistry::addCalled ( BranchDescription const &  , bool  iFromListener  )

privatevirtual

Reimplemented in edm::SignallingProductRegistry.

Definition at line 173 of file ProductRegistry.cc.

Referenced by addLabelAlias(), and addProduct().

                                                           {
  }

void edm::ProductRegistry::addLabelAlias	(	BranchDescription const &	productdesc,
		std::string const &	labelAlias,
		std::string const &	instanceAlias
	)

Definition at line 101 of file ProductRegistry.cc.

References addCalled(), edm::BranchDescription::branchID(), edm::BranchID::isValid(), edm::BranchDescription::produced(), productList_, run_regression::ret, and throwIfFrozen().

                                                                 {
    assert(productDesc.produced());
    assert(productDesc.branchID().isValid());
    throwIfFrozen();
    BranchDescription bd(productDesc, labelAlias, instanceAlias);
    std::pair<ProductList::iterator, bool> ret =
         productList_.insert(std::make_pair(BranchKey(bd), bd));
    assert(ret.second);
    addCalled(bd, false);
  }

void edm::ProductRegistry::addProduct	(	BranchDescription const &	productdesc,
		bool	iFromListener = false
	)

Definition at line 85 of file ProductRegistry.cc.

References addCalled(), edm::errors::Configuration, edm::hlt::Exception, edm::BranchDescription::processName(), edm::BranchDescription::produced(), productList_, run_regression::ret, and throwIfFrozen().

Referenced by edm::ProductRegistryHelper::addToRegistry().

                                                 {
    assert(productDesc.produced());
    throwIfFrozen();
    checkDicts(productDesc);
    std::pair<ProductList::iterator, bool> ret =
         productList_.insert(std::make_pair(BranchKey(productDesc), productDesc));
    if(!ret.second) {
      throw Exception(errors::Configuration, "Duplicate Process")
        << "The process name " << productDesc.processName() << " was previously used on these products.\n"
        << "Please modify the configuration file to use a distinct process name.\n";
    }
    addCalled(productDesc, fromListener);
  }

std::vector< BranchDescription const * > edm::ProductRegistry::allBranchDescriptions

(

)

const

Definition at line 188 of file ProductRegistry.cc.

References productList(), query::result, and size().

Referenced by edm::ConstProductRegistry::allBranchDescriptions(), edm::RootFile::dropOnInput(), edm::SubProcess::selectProducts(), edm::OutputModule::selectProducts(), and edm::one::OutputModuleBase::selectProducts().

                                               {
    std::vector<BranchDescription const*> result;
    result.reserve(productList().size());

    for(auto const& product : productList()) {
      result.push_back(&product.second);
    }
    return result;
  }

std::vector< std::string > edm::ProductRegistry::allBranchNames

(

)

const

Definition at line 177 of file ProductRegistry.cc.

References productList(), query::result, and size().

Referenced by edm::ConstProductRegistry::allBranchNames().

                                        {
    std::vector<std::string> result;
    result.reserve(productList().size());

    for(auto const& product : productList()) {
      result.push_back(product.second.branchName());
    }
    return result;
  }

bool edm::ProductRegistry::anyProductProduced ( ) const

inline

Definition at line 111 of file ProductRegistry.h.

References edm::ProductRegistry::Transients::anyProductProduced_, and transient_.

Referenced by edm::ConstProductRegistry::anyProductProduced(), and edm::SubProcess::process().

{return transient_.anyProductProduced_;}

bool edm::ProductRegistry::anyProducts

(

BranchType const

brType

)

const

Definition at line 129 of file ProductRegistry.cc.

References productList_, and throwIfNotFrozen().

                                                      {
    throwIfNotFrozen();
    for(ProductList::const_iterator it = productList_.begin(), itEnd = productList_.end();
        it != itEnd; ++it) {
      if(it->second.branchType() == brType) {
        return true;
      }
    }
    return false;
  }

template<typename T >

void edm::ProductRegistry::callForEachBranch ( T const &  iFunc )

inline

Definition at line 85 of file ProductRegistry.h.

References productList_.

Referenced by edm::ProducerBase::registerProducts(), edm::stream::EDAnalyzerBase::registerProductsAndCallbacks(), edm::EDAnalyzer::registerProductsAndCallbacks(), edm::one::EDAnalyzerBase::registerProductsAndCallbacks(), and edm::global::EDAnalyzerBase::registerProductsAndCallbacks().

                                            {
      //NOTE: If implementation changes from a map, need to check that iterators are still valid
      // after an insert with the new container, else need to copy the container and iterate over the copy
      for(ProductRegistry::ProductList::const_iterator itEntry = productList_.begin(),
          itEntryEnd = productList_.end();
          itEntry != itEntryEnd; ++itEntry) {
        iFunc(itEntry->second);
      }
    }

ConstProductList& edm::ProductRegistry::constProductList ( )

inline

Definition at line 100 of file ProductRegistry.h.

References edm::ProductRegistry::Transients::constProductList_, and transient_.

Referenced by initializeLookupTables(), and updateConstProductRegistry().

                                         {
       //throwIfNotFrozen();
       return transient_.constProductList_;
    }

void edm::ProductRegistry::copyProduct

(

BranchDescription const &

productdesc

)

Definition at line 115 of file ProductRegistry.cc.

References edm::combinable(), getDQMSummary::iter, roll_playback::k, edm::BranchDescription::produced(), productList_, and throwIfFrozen().

Referenced by edm::DaqProvenanceHelper::daqInit(), edm::LHEProvenanceHelper::LHEProvenanceHelper(), edm::RootFile::RootFile(), and updateFromInput().

                                                                   {
    assert(!productDesc.produced());
    throwIfFrozen();
    BranchKey k = BranchKey(productDesc);
    ProductList::iterator iter = productList_.find(k);
    if(iter == productList_.end()) {
      productList_.insert(std::make_pair(k, productDesc));
    } else {
      assert(combinable(iter->second, productDesc));
      iter->second.merge(productDesc);
    }
  }

void edm::ProductRegistry::freezeIt ( bool  frozen = true )

inlineprivate

Definition at line 155 of file ProductRegistry.h.

References frozen(), edm::ProductRegistry::Transients::frozen_, and transient_.

Referenced by ProductRegistry(), and setFrozen().

{transient_.frozen_ = frozen;}

bool edm::ProductRegistry::frozen ( ) const

inline

Definition at line 125 of file ProductRegistry.h.

References edm::ProductRegistry::Transients::frozen_, and transient_.

Referenced by freezeIt(), edm::StreamerInputSource::mergeIntoRegistry(), setFrozen(), throwIfFrozen(), and throwIfNotFrozen().

{return transient_.frozen_;}

ProductHolderIndex const & edm::ProductRegistry::getNextIndexValue

(

BranchType

branchType

)

const

Definition at line 345 of file ProductRegistry.cc.

References edm::ProductRegistry::Transients::eventNextIndexValue_, edm::InEvent, edm::InLumi, edm::ProductRegistry::Transients::lumiNextIndexValue_, edm::ProductRegistry::Transients::runNextIndexValue_, and transient_.

Referenced by initializeLookupTables(), and merge().

                                                                {
    if (branchType == InEvent) return transient_.eventNextIndexValue_;
    if (branchType == InLumi) return  transient_.lumiNextIndexValue_;
    return transient_.runNextIndexValue_;
  }

ProductHolderIndex edm::ProductRegistry::indexFrom

(

BranchID const &

iID

)

const

Definition at line 330 of file ProductRegistry.cc.

References edm::ProductRegistry::Transients::branchIDToIndex_, edm::ProductHolderIndexInvalid, and transient_.

                                                                         {
    std::map<BranchID, ProductHolderIndex>::const_iterator itFind = transient_.branchIDToIndex_.find(iID);
    if(itFind == transient_.branchIDToIndex_.end()) {
      return ProductHolderIndexInvalid;
    }
    return itFind->second;
  }

void edm::ProductRegistry::initializeLookupTables ( )

private

Definition at line 268 of file ProductRegistry.cc.

References edm::ProductRegistry::Transients::branchIDToIndex_, constProductList(), edm::copy_all(), edm::ProductRegistry::Transients::eventNextIndexValue_, edm::productholderindexhelper::getContainedTypeFromWrapper(), getNextIndexValue(), cmsHarvester::index, edm::InEvent, edm::InLumi, edm::InRun, edm::eventsetup::heterocontainer::insert(), getDQMSummary::iter, combine::key, edm::ProductRegistry::Transients::lumiNextIndexValue_, missingDictionariesForUpdate(), nextIndexValue(), productList_, productLookup(), edm::ProductRegistry::Transients::runNextIndexValue_, setProductProduced(), and transient_.

Referenced by setFrozen().

                                               {
    std::map<TypeID, TypeID> containedTypeMap;
    StringSet missingDicts;
    transient_.branchIDToIndex_.clear();
    constProductList().clear();

    for(auto const& product : productList_) {
      auto const& key = product.first;
      auto const& desc = product.second;

      constProductList().insert(std::make_pair(key, BranchDescription(desc)));

      if(desc.produced()) {
        setProductProduced(desc.branchType());
      }

      //only do the following if the data is supposed to be available in the event
      if(desc.present()) {
        if(!bool(desc.unwrappedType()) || !bool(desc.wrappedType())) {
          missingDicts.insert(desc.className());
        } else {
          TypeID wrappedTypeID(desc.wrappedType().typeInfo());
          TypeID typeID(desc.unwrappedType().typeInfo());
          TypeID containedTypeID;
          auto const& iter = containedTypeMap.find(typeID);
          if(iter != containedTypeMap.end()) {
             containedTypeID = iter->second;
          } else {
             containedTypeID = productholderindexhelper::getContainedTypeFromWrapper(wrappedTypeID, typeID.className());
             containedTypeMap.emplace(typeID, containedTypeID);
          }
          ProductHolderIndex index =
            productLookup(desc.branchType())->insert(typeID,
                                                     desc.moduleLabel().c_str(),
                                                     desc.productInstanceName().c_str(),
                                                     desc.processName().c_str(),
                                                     containedTypeID);

          transient_.branchIDToIndex_[desc.branchID()] = index;
        }
      }
    }
    productLookup(InEvent)->setFrozen();
    productLookup(InLumi)->setFrozen();
    productLookup(InRun)->setFrozen();

    transient_.eventNextIndexValue_ = productLookup(InEvent)->nextIndexValue();
    transient_.lumiNextIndexValue_ = productLookup(InLumi)->nextIndexValue();
    transient_.runNextIndexValue_ = productLookup(InRun)->nextIndexValue();

    for(auto const& product : productList_) {
      auto const& desc = product.second;
      if (transient_.branchIDToIndex_.find(desc.branchID()) == transient_.branchIDToIndex_.end()) {
        transient_.branchIDToIndex_[desc.branchID()] = getNextIndexValue(desc.branchType());
        ++nextIndexValue(desc.branchType());
      }
    }

    missingDictionariesForUpdate().reserve(missingDicts.size());
    copy_all(missingDicts, std::back_inserter(missingDictionariesForUpdate()));
  }

void edm::ProductRegistry::initializeTransients ( )

inline

Definition at line 123 of file ProductRegistry.h.

References edm::ProductRegistry::Transients::reset(), and transient_.

{transient_.reset();}

std::string edm::ProductRegistry::merge	(	ProductRegistry const &	other,
		std::string const &	fileName,
		BranchDescription::MatchMode	branchesMustMatch = BranchDescription::Permissive
	)

Definition at line 213 of file ProductRegistry.cc.

References edm::ProductRegistry::Transients::branchIDToIndex_, alignCSCRings::e, getNextIndexValue(), i, j, edm::match(), nextIndexValue(), productList(), productList_, alignCSCRings::s, edm::BranchDescription::Strict, AlCaHLTBitMon_QueryRunRegistry::string, transient_, and updateConstProductRegistry().

Referenced by edm::StreamerInputSource::mergeIntoRegistry(), edm::RootInputFileSequence::nextFile(), and edm::RootInputFileSequence::previousFile().

                                                      {
    std::ostringstream differences;

    ProductRegistry::ProductList::iterator j = productList_.begin();
    ProductRegistry::ProductList::iterator s = productList_.end();
    ProductRegistry::ProductList::const_iterator i = other.productList().begin();
    ProductRegistry::ProductList::const_iterator e = other.productList().end();

    // Loop over entries in the main product registry.
    while(j != s || i != e) {
      if(j != s && j->second.produced()) {
        // Ignore branches just produced (i.e. not in input file).
        ++j;
      } else if(j == s || (i != e && i->first < j->first)) {
        if(i->second.present()) {
          differences << "Branch '" << i->second.branchName() << "' is in file '" << fileName << "'\n";
          differences << "    but not in previous files.\n";
        } else {
          productList_.insert(*i);
          transient_.branchIDToIndex_[i->second.branchID()] = getNextIndexValue(i->second.branchType());
          ++nextIndexValue(i->second.branchType());
        }
        ++i;
      } else if(i == e || (j != s && j->first < i->first)) {
        if(j->second.present() && branchesMustMatch == BranchDescription::Strict) {
          differences << "Branch '" << j->second.branchName() << "' is in previous files\n";
          differences << "    but not in file '" << fileName << "'.\n";
        }
        ++j;
      } else {
        std::string difs = match(j->second, i->second, fileName);
        if(difs.empty()) {
          j->second.merge(i->second);
        } else {
          differences << difs;
        }
        ++i;
        ++j;
      }
    }
    updateConstProductRegistry();
    return differences.str();
  }

std::vector<std::string> const& edm::ProductRegistry::missingDictionaries ( ) const

inline

Definition at line 113 of file ProductRegistry.h.

References edm::ProductRegistry::Transients::missingDictionaries_, and transient_.

                                                            {
      return transient_.missingDictionaries_;
    }

std::vector<std::string>& edm::ProductRegistry::missingDictionariesForUpdate ( )

inline

Definition at line 117 of file ProductRegistry.h.

References edm::ProductRegistry::Transients::missingDictionaries_, and transient_.

Referenced by initializeLookupTables().

                                                         {
      return transient_.missingDictionaries_;
    }

ProductHolderIndex & edm::ProductRegistry::nextIndexValue ( BranchType  branchType )

private

Definition at line 352 of file ProductRegistry.cc.

References edm::ProductRegistry::Transients::eventNextIndexValue_, edm::InEvent, edm::InLumi, edm::ProductRegistry::Transients::lumiNextIndexValue_, edm::ProductRegistry::Transients::runNextIndexValue_, and transient_.

Referenced by initializeLookupTables(), and merge().

                                                       {
    if (branchType == InEvent) return transient_.eventNextIndexValue_;
    if (branchType == InLumi) return  transient_.lumiNextIndexValue_;
    return transient_.runNextIndexValue_;
  }

void edm::ProductRegistry::print

(

std::ostream &

os

)

const

Definition at line 338 of file ProductRegistry.cc.

References productList_.

Referenced by edm::operator<<().

                                                  {
    for(auto const& product: productList_) {
      os << product.second << "\n-----\n";
    }
  }

ProductList const& edm::ProductRegistry::productList ( ) const

inline

Definition at line 61 of file ProductRegistry.h.

References productList_.

Referenced by edm::Principal::adjustToNewProductRegistry(), allBranchDescriptions(), allBranchNames(), edm::ProductSelector::fillDroppedToKept(), merge(), edm::operator==(), edm::ConstProductRegistry::productList(), edm::ThinningProducer< Collection, Selector >::registerThinnedAssociations(), edm::RootFile::RootFile(), edm::SubProcess::selectProducts(), edm::OutputModule::selectProducts(), edm::one::OutputModuleBase::selectProducts(), edm::BranchIDListHelper::updateFromRegistry(), and edm::ProvenanceCheckerOutputModule::write().

                                           {
      //throwIfNotFrozen();
      return productList_;
    }

ProductList& edm::ProductRegistry::productListUpdator ( )

inline

Definition at line 66 of file ProductRegistry.h.

References productList_, and throwIfFrozen().

Referenced by edm::RootFile::dropOnInput(), edm::RootFile::RootFile(), edm::WorkerManager::setOnDemandProducts(), fwlite::internal::BranchMapReaderStrategyV8::updateFile(), fwlite::internal::BranchMapReaderStrategyV11::updateFile(), fwlite::internal::BranchMapReaderStrategyV17::updateFile(), fwlite::internal::BranchMapReaderStrategyV1::updateMap(), and ProvenanceDumper::work_().

                                      {
      throwIfFrozen();
      return productList_;
    }

std::shared_ptr< ProductHolderIndexHelper > const & edm::ProductRegistry::productLookup

(

BranchType

branchType

)

const

Definition at line 141 of file ProductRegistry.cc.

References edm::ProductRegistry::Transients::eventProductLookup_, edm::InEvent, edm::InLumi, edm::ProductRegistry::Transients::lumiProductLookup_, edm::ProductRegistry::Transients::runProductLookup_, and transient_.

Referenced by edm::WorkerManager::beginJob(), edm::Schedule::changeModule(), and initializeLookupTables().

                                                            {
    if (branchType == InEvent) return transient_.eventProductLookup_;
    if (branchType == InLumi) return transient_.lumiProductLookup_;
    return transient_.runProductLookup_;
  }

bool edm::ProductRegistry::productProduced ( BranchType  branchType ) const

inline

Definition at line 110 of file ProductRegistry.h.

References revisionDML::branchType(), edm::ProductRegistry::Transients::productProduced_, and transient_.

{return transient_.productProduced_[branchType];}

void edm::ProductRegistry::setFrozen

(

bool

initializeLookupInfo = true

)

Definition at line 148 of file ProductRegistry.cc.

References freezeIt(), frozen(), and initializeLookupTables().

Referenced by fwlite::internal::BranchMapReaderStrategyV8::updateFile(), fwlite::internal::BranchMapReaderStrategyV11::updateFile(), fwlite::internal::BranchMapReaderStrategyV17::updateFile(), and fwlite::internal::BranchMapReaderStrategyV1::updateMap().

                                                      {
    if(frozen()) return;
    freezeIt();
    if(initializeLookupInfo) {
      initializeLookupTables();
    }
  }

void edm::ProductRegistry::setProductProduced ( BranchType  branchType )

inlineprivate

Definition at line 150 of file ProductRegistry.h.

References edm::ProductRegistry::Transients::anyProductProduced_, revisionDML::branchType(), edm::ProductRegistry::Transients::productProduced_, and transient_.

Referenced by initializeLookupTables().

                                                   {
      transient_.productProduced_[branchType] = true;
      transient_.anyProductProduced_ = true;
    }

ProductList::size_type edm::ProductRegistry::size ( void  ) const

inline

Definition at line 94 of file ProductRegistry.h.

References productList_.

Referenced by allBranchDescriptions(), and allBranchNames().

{return productList_.size();}

void edm::ProductRegistry::throwIfFrozen ( ) const

private

Definition at line 157 of file ProductRegistry.cc.

References edm::hlt::Exception, and frozen().

Referenced by addLabelAlias(), addProduct(), copyProduct(), and productListUpdator().

                                       {
    if(frozen()) {
      throw cms::Exception("ProductRegistry", "throwIfFrozen")
        << "cannot modify the ProductRegistry because it is frozen\n";
    }
  }

void edm::ProductRegistry::throwIfNotFrozen ( ) const

private

Definition at line 165 of file ProductRegistry.cc.

References edm::hlt::Exception, and frozen().

Referenced by anyProducts().

                                          {
    if(!frozen()) {
      throw cms::Exception("ProductRegistry", "throwIfNotFrozen")
        << "cannot read the ProductRegistry because it is not yet frozen\n";
    }
  }

void edm::ProductRegistry::updateConstProductRegistry ( )

private

Definition at line 259 of file ProductRegistry.cc.

References constProductList(), combine::key, and productList_.

Referenced by merge().

                                                   {
    constProductList().clear();
    for(auto const& product : productList_) {
      auto const& key = product.first;
      auto const& desc = product.second;
      constProductList().insert(std::make_pair(key, BranchDescription(desc)));
    }
  }

void edm::ProductRegistry::updateFromInput

(

ProductList const &

other

)

Definition at line 199 of file ProductRegistry.cc.

References copyProduct().

Referenced by edm::StreamerInputSource::mergeIntoRegistry(), and edm::RootInputFileSequence::RootInputFileSequence().

                                                           {
    for(auto const& product : other) {
      copyProduct(product.second);
    }
  }

void edm::ProductRegistry::updateFromInput

(

std::vector< BranchDescription > const &

other

)

Definition at line 206 of file ProductRegistry.cc.

References copyProduct().

                                                                            {
    for(BranchDescription const& branchDescription : other) {
      copyProduct(branchDescription);
    }
  }

Member Data Documentation

ProductList edm::ProductRegistry::productList_

private

Definition at line 165 of file ProductRegistry.h.

Referenced by addLabelAlias(), addProduct(), anyProducts(), callForEachBranch(), copyProduct(), initializeLookupTables(), merge(), print(), productList(), productListUpdator(), size(), and updateConstProductRegistry().

Transients edm::ProductRegistry::transient_

private

Definition at line 166 of file ProductRegistry.h.

Referenced by anyProductProduced(), constProductList(), freezeIt(), frozen(), getNextIndexValue(), indexFrom(), initializeLookupTables(), initializeTransients(), merge(), missingDictionaries(), missingDictionariesForUpdate(), nextIndexValue(), productLookup(), productProduced(), and setProductProduced().