1 #ifndef FWCore_Framework_Principal_h
2 #define FWCore_Framework_Principal_h
33 #include "boost/iterator/filter_iterator.hpp"
43 class HistoryAppender;
44 class ModuleCallingContext;
45 class ProcessHistoryRegistry;
46 class ProductResolverIndexHelper;
49 class InputProductResolver;
59 typedef boost::filter_iterator<FilledProductPtr, ProductResolverCollection::const_iterator>
const_iterator;
60 typedef boost::filter_iterator<FilledProductPtr, ProductResolverCollection::iterator>
iterator;
69 Principal(std::shared_ptr<ProductRegistry const> reg,
70 std::shared_ptr<ProductResolverIndexHelper const>
productLookup,
74 bool isForPrimaryProcess =
true);
119 bool skipCurrentProcess,
126 bool skipCurrentProcess,
201 void addProduct_(std::unique_ptr<ProductResolverBase> phb);
210 template <
typename F>
213 iFunc(resolver.get());
230 std::vector<WrapperBase const*>&,
231 std::vector<unsigned int>&)
const override;
233 void findProducts(std::vector<ProductResolverBase const*>
const& holders,
270 std::shared_ptr<ProductRegistry const>
preg_;
291 template <
typename PROD>
293 std::shared_ptr<Wrapper<PROD>
const>
297 if(result ==
nullptr) {
298 return std::shared_ptr<Wrapper<PROD>
const>();
collection_type::const_iterator const_iterator
ProductRegistry const & productRegistry() const
ProductResolverBase * getModifiableProductResolver(BranchID const &oid)
virtual void getThinnedProducts(ProductID const &, std::vector< WrapperBase const * > &, std::vector< unsigned int > &) const override
unsigned int ProductResolverIndex
ProductResolverCollection productResolvers_
std::type_info const & dynamicTypeInfo() const
std::shared_ptr< ProcessHistory const > processHistoryPtr_
const_iterator end() const
static PFTauRenderPlugin instance
virtual WrapperBase const * getThinnedProduct(ProductID const &, unsigned int &) const override
std::shared_ptr< ProductResolverBase > SharedProductPtr
void addProduct_(std::unique_ptr< ProductResolverBase > phb)
ProcessHistoryID processHistoryID_
ProductResolverBase * getExistingProduct(BranchID const &branchID)
virtual bool isComplete_() const
void getAllProvenance(std::vector< Provenance const * > &provenances) const
void applyToResolvers(F iFunc)
void getAllStableProvenance(std::vector< StableProvenance const * > &provenances) const
Provenance getProvenance(BranchID const &bid, ModuleCallingContext const *mcc) const
WrapperBase const * wrapper() const
CacheIdentifier_t cacheIdentifier() const
Principal(std::shared_ptr< ProductRegistry const > reg, std::shared_ptr< ProductResolverIndexHelper const > productLookup, ProcessConfiguration const &pc, BranchType bt, HistoryAppender *historyAppender, bool isForPrimaryProcess=true)
void addInputProduct(std::shared_ptr< BranchDescription const > bd)
bool operator()(propagate_const< std::shared_ptr< ProductResolverBase >> const &iObj)
edm::propagate_const< HistoryAppender * > historyAppender_
ProcessHistory const & processHistory() const
boost::filter_iterator< FilledProductPtr, ProductResolverCollection::iterator > iterator
void readAllFromSourceAndMergeImmediately()
std::vector< unsigned int > lookupProcessOrder_
std::vector< propagate_const< std::shared_ptr< ProductResolverBase > > > ProductResolverCollection
void throwConvertTypeError(std::type_info const &expected, std::type_info const &actual)
BasicHandle getByLabel(KindOfType kindOfType, TypeID const &typeID, InputTag const &inputTag, EDConsumerBase const *consumes, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
void addScheduledProduct(std::shared_ptr< BranchDescription const > bd)
ProductData const * findProductByTag(TypeID const &typeID, InputTag const &tag, ModuleCallingContext const *mcc) const
std::shared_ptr< ProductResolverIndexHelper const > productLookup_
std::shared_ptr< Wrapper< PROD > const > getProductByTag(Principal const &ep, InputTag const &tag, ModuleCallingContext const *mcc)
void addProductOrThrow(std::unique_ptr< ProductResolverBase > phb)
std::shared_ptr< ProductRegistry const > preg_
ProcessHistoryID const & processHistoryID() const
CacheIdentifier_t cacheIdentifier_
BranchType const & branchType() const
std::vector< unsigned int > const & lookupProcessOrder() const
void putOrMerge(BranchDescription const &bd, std::unique_ptr< WrapperBase > edp) const
void prefetchAsync(WaitingTask *waitTask, ProductResolverIndex index, bool skipCurrentProcess, ModuleCallingContext const *mcc) const
void addSourceProduct(std::shared_ptr< BranchDescription const > bd)
ProcessHistoryID orderProcessHistoryID_
void addParentProcessProduct(std::shared_ptr< BranchDescription const > bd)
ProcessConfiguration const & processConfiguration() const
DelayedReader * reader() const
ProcessHistory::const_iterator ProcessNameConstIterator
void addUnscheduledProduct(std::shared_ptr< BranchDescription const > bd)
const_iterator begin() const
ProductResolverIndexHelper const & productLookup() const
void resetFailedFromThisProcess()
ProductResolverBase const * ConstProductResolverPtr
void findProducts(std::vector< ProductResolverBase const * > const &holders, TypeID const &typeID, BasicHandleVec &results, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
unsigned long CacheIdentifier_t
virtual WrapperBase const * getIt(ProductID const &) const override
boost::filter_iterator< FilledProductPtr, ProductResolverCollection::const_iterator > const_iterator
bool adjustToNewProductRegistry(ProductRegistry const ®)
ProductData const * findProductByLabel(KindOfType kindOfType, TypeID const &typeID, InputTag const &inputTag, EDConsumerBase const *consumer, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
ConstProductResolverPtr getProductResolverByIndex(ProductResolverIndex const &oid) const
ConstProductResolverPtr getProductResolver(BranchID const &oid) const
void adjustIndexesAfterProductRegistryAddition()
BasicHandle getByToken(KindOfType kindOfType, TypeID const &typeID, ProductResolverIndex index, bool skipCurrentProcess, bool &ambiguous, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
static uInt32 F(BLOWFISH_CTX *ctx, uInt32 x)
void addAliasedProduct(std::shared_ptr< BranchDescription const > bd)
void fillPrincipal(ProcessHistoryID const &hist, ProcessHistoryRegistry const &phr, DelayedReader *reader)
ProductResolverCollection::size_type size_type
EDProductGetter const * prodGetter() const
void recombine(Principal &other, std::vector< BranchID > const &bids)
ProcessConfiguration const * processConfiguration_
std::shared_ptr< WrapperBase const > sharedConstWrapper() const
std::vector< BasicHandle > BasicHandleVec
void getManyByType(TypeID const &typeID, BasicHandleVec &results, EDConsumerBase const *consumes, SharedResourcesAcquirer *sra, ModuleCallingContext const *mcc) const
void deleteProduct(BranchID const &id) const