#include <ThinningProducer.h>

Inheritance diagram for edm::ThinningProducer< Collection, Selector >:

Public Member Functions
void	produce (Event &event, EventSetup const &eventSetup) override

void	registerThinnedAssociations (ProductRegistry const &productRegistry, ThinnedAssociationsHelper &thinnedAssociationsHelper) override

	ThinningProducer (ParameterSet const &pset)

	~ThinningProducer () override

Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default

	EDProducer (const EDProducer &)=delete

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginProcessBlocks () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndProcessBlocks () const final

bool	hasAbilityToProduceInEndRuns () const final

const EDProducer &	operator= (const EDProducer &)=delete

Static Public Member Functions
static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Private Types
using	SelectorChooseReturnType = decltype(selector_->choose(0U, std::declval< typename detail::ElementType< Collection >::type const >()))

Private Attributes
edm::InputTag	inputTag_

edm::EDGetTokenT< Collection >	inputToken_

edm::EDPutTokenT< Collection >	outputToken_

edm::propagate_const< std::unique_ptr< Selector > >	selector_

edm::EDPutTokenT< ThinnedAssociation >	thinnedOutToken_

Static Private Attributes
static constexpr bool	isSlimming = detail::IsStdOptional<SelectorChooseReturnType>::value

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer<>
using	CacheTypes = CacheContexts< T... >

using	GlobalCache = typename CacheTypes::GlobalCache

using	HasAbility = AbilityChecker< T... >

using	InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache

using	LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache

using	LuminosityBlockContext = LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >

using	LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache

using	RunCache = typename CacheTypes::RunCache

using	RunContext = RunContextT< RunCache, GlobalCache >

using	RunSummaryCache = typename CacheTypes::RunSummaryCache

Detailed Description

template<typename Collection, typename Selector>
class edm::ThinningProducer< Collection, Selector >

Author: W. David Dagenhart, created 11 June 2014

Definition at line 68 of file ThinningProducer.h.

Member Typedef Documentation

◆ SelectorChooseReturnType

template<typename Collection , typename Selector >

using edm::ThinningProducer< Collection, Selector >::SelectorChooseReturnType = decltype(selector_->choose(0U, std::declval<typename detail::ElementType<Collection>::type const>()))

private

Definition at line 88 of file ThinningProducer.h.

Constructor & Destructor Documentation

◆ ThinningProducer()

template<typename Collection , typename Selector >

edm::ThinningProducer< Collection, Selector >::ThinningProducer ( ParameterSet const & pset )

explicit

Definition at line 96 of file ThinningProducer.h.

References edm::ThinningProducer< Collection, Selector >::inputTag_, edm::ThinningProducer< Collection, Selector >::inputToken_, edm::ThinningProducer< Collection, Selector >::outputToken_, muonDTDigis_cfi::pset, and edm::ThinningProducer< Collection, Selector >::thinnedOutToken_.

       : selector_(new Selector(pset, consumesCollector())) {
     inputTag_ = pset.getParameter<InputTag>("inputTag");
     inputToken_ = consumes<Collection>(inputTag_);
 
     outputToken_ = produces<Collection>();
     thinnedOutToken_ = produces<ThinnedAssociation>();
   }

◆ ~ThinningProducer()

template<typename Collection , typename Selector >

edm::ThinningProducer< Collection, Selector >::~ThinningProducer ( )

override

Definition at line 106 of file ThinningProducer.h.

106 {}

Member Function Documentation

◆ fillDescriptions()

template<typename Collection , typename Selector >

void edm::ThinningProducer< Collection, Selector >::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 109 of file ThinningProducer.h.

References edm::ConfigurationDescriptions::addWithDefaultLabel(), submitPVResolutionJobs::desc, and reco::modules::fillPSetDescription().

                                                                                                        {
     ParameterSetDescription desc;
     desc.setComment("Produces thinned collections and associations to them");
     desc.add<edm::InputTag>("inputTag");
     Selector::fillPSetDescription(desc);
     descriptions.addWithDefaultLabel(desc);
   }

◆ produce()

template<typename Collection , typename Selector >

void edm::ThinningProducer< Collection, Selector >::produce	(	Event &	event,
		EventSetup const &	eventSetup
	)

override

Definition at line 118 of file ThinningProducer.h.

References edmPickEvents::event, options_cfi::eventSetup, edm::detail::fillCollectionForThinning(), edm::OrphanHandleBase::id(), HLT_2022v14_cff::inputCollection, eostools::move(), edm::ThinnedAssociation::setParentCollectionID(), and edm::ThinnedAssociation::setThinnedCollectionID().

                                                                                                  {
     auto inputCollection = event.getHandle(inputToken_);
 
     edm::Event const& constEvent = event;
     selector_->preChoose(inputCollection, constEvent, eventSetup);
 
     Collection thinnedCollection;
     ThinnedAssociation thinnedAssociation;
 
     unsigned int iIndex = 0;
     for (auto iter = inputCollection->begin(), iterEnd = inputCollection->end(); iter != iterEnd; ++iter, ++iIndex) {
       using namespace detail;
       fillCollectionForThinning(*iter, *selector_, iIndex, thinnedCollection, thinnedAssociation);
     }
     selector_->reset();
 
     OrphanHandle<Collection> orphanHandle = event.emplace(outputToken_, std::move(thinnedCollection));
 
     thinnedAssociation.setParentCollectionID(inputCollection.id());
     thinnedAssociation.setThinnedCollectionID(orphanHandle.id());
     event.emplace(thinnedOutToken_, std::move(thinnedAssociation));
   }

◆ registerThinnedAssociations()

template<typename Collection , typename Selector >

void edm::ThinningProducer< Collection, Selector >::registerThinnedAssociations	(	ProductRegistry const &	productRegistry,
		ThinnedAssociationsHelper &	thinnedAssociationsHelper
	)

override

Definition at line 142 of file ThinningProducer.h.

References edm::ThinnedAssociationsHelper::addAssociation(), submitPVResolutionJobs::desc, edm::InputTag::instance(), edm::InputTag::label(), edm::InputTag::process(), edm::ProductRegistry::productList(), and edm::InputTag::willSkipCurrentProcess().

                                                                                                     {
     BranchID associationID;
     BranchID thinnedCollectionID;
 
     // If the InputTag does not specify the process name, it is
     // possible that there will be more than one match found below.
     // For a particular event only one match is correct and the
     // others will be false. It even possible for some events one
     // match is correct and for others another is correct. This is
     // a side effect of the lookup mechanisms when the process name
     // is not specified.
     // When using the registry this generates one would have to
     // check the ProductIDs in ThinnedAssociation product to get
     // the correct association. This ambiguity will probably be
     // rare and possibly never occur in practice.
     std::vector<BranchID> parentCollectionIDs;
 
     ProductRegistry::ProductList const& productList = productRegistry.productList();
     for (auto const& product : productList) {
       BranchDescription const& desc = product.second;
       if (desc.dropped()) {
         // Dropped branch does not have type information, but they can
         // be ignored here because all of the parent/thinned/association
         // branches are expected to be present
         continue;
       }
       if (desc.unwrappedType().typeInfo() == typeid(Collection)) {
         if (desc.produced() && desc.moduleLabel() == moduleDescription().moduleLabel() &&
             desc.productInstanceName().empty()) {
           thinnedCollectionID = desc.branchID();
         }
         if (desc.moduleLabel() == inputTag_.label() && desc.productInstanceName() == inputTag_.instance()) {
           if (inputTag_.willSkipCurrentProcess()) {
             if (!desc.produced()) {
               parentCollectionIDs.push_back(desc.branchID());
             }
           } else if (inputTag_.process().empty() || inputTag_.process() == desc.processName()) {
             if (desc.produced()) {
               parentCollectionIDs.push_back(desc.originalBranchID());
             } else {
               parentCollectionIDs.push_back(desc.branchID());
             }
           }
         }
       }
       if (desc.produced() && desc.unwrappedType().typeInfo() == typeid(ThinnedAssociation) &&
           desc.moduleLabel() == moduleDescription().moduleLabel() && desc.productInstanceName().empty()) {
         associationID = desc.branchID();
       }
     }
     if (parentCollectionIDs.empty()) {
       // This could happen if the input collection was dropped. Go ahead and add
       // an entry and let the exception be thrown only if the module is run (when
       // it cannot find the product).
       thinnedAssociationsHelper.addAssociation(BranchID(), associationID, thinnedCollectionID, isSlimming);
     } else {
       for (auto const& parentCollectionID : parentCollectionIDs) {
         thinnedAssociationsHelper.addAssociation(parentCollectionID, associationID, thinnedCollectionID, isSlimming);
       }
     }
   }