ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL > Class Template Reference

Inheritance diagram for ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >:

Public Member Functions
	PFRecHitSoAProducer (edm::ParameterSet const &config)
void	produce (edm::StreamID, device::Event &event, const device::EventSetup &setup) const override
Public Member Functions inherited from ALPAKA_ACCELERATOR_NAMESPACE::global::EDProducer<>
void	produce (edm::StreamID sid, edm::Event &iEvent, edm::EventSetup const &iSetup) const final
Public Member Functions inherited from edm::ProducerBase< edm::global::EDProducer, Args... >
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const
	ProducerBase ()
std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const
std::vector< bool > const &	recordProvenanceList () const
void	registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &)
std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...
void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)
TypeLabelList const &	typeLabelList () const
	used by the fwk to register the list of products of this module More...
	~ProducerBase () noexcept(false) override

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

Private Attributes
const device::EDPutToken< reco::PFRecHitDeviceCollection >	pfRecHitsToken_
std::vector< std::pair< device::EDGetToken< typename CAL::CaloRecHitSoATypeDevice >, device::ESGetToken< typename CAL::ParameterType, typename CAL::ParameterRecordType > > >	recHitsToken_
const bool	synchronise_
const device::ESGetToken< typename CAL::TopologyTypeDevice, typename CAL::TopologyRecordType >	topologyToken_

Additional Inherited Members
Public Types inherited from edm::ProducerBase< edm::global::EDProducer, Args... >
using	BranchAliasSetterT = ProductRegistryHelper::BranchAliasSetterT< T >
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const *, const char *, edm::ProductResolverIndex > >
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList
Protected Member Functions inherited from edm::ProducerBase< edm::global::EDProducer, Args... >
auto	produces (std::string instanceName) noexcept
	declare what type of product will make and with which optional label More...
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
auto	produces () noexcept
ProducesCollector	producesCollector ()

Detailed Description

template<typename CAL>
class ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >

Definition at line 21 of file PFRecHitSoAProducer.cc.

Constructor & Destructor Documentation

PFRecHitSoAProducer()

template<typename CAL >

ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >::PFRecHitSoAProducer ( edm::ParameterSet const &  config )

inline

Definition at line 23 of file PFRecHitSoAProducer.cc.

References deDxTools::esConsumes(), and HLT_2024v12_cff::producers.

        : topologyToken_(esConsumes(config.getParameter<edm::ESInputTag>("topology"))),
          pfRecHitsToken_(produces()),
          synchronise_(config.getUntrackedParameter<bool>("synchronise")) {
      // Workaround until the ProductID problem in issue https://github.com/cms-sw/cmssw/issues/44643 is fixed
#ifdef ALPAKA_ACC_CPU_B_SEQ_T_SEQ_ENABLED
      producesTemporarily("edm::DeviceProduct<alpaka_cuda_async::reco::PFRecHitDeviceCollection>");
#endif

      const std::vector<edm::ParameterSet> producers = config.getParameter<std::vector<edm::ParameterSet>>("producers");
      recHitsToken_.reserve(producers.size());
      for (const edm::ParameterSet& producer : producers) {
        recHitsToken_.emplace_back(consumes(producer.getParameter<edm::InputTag>("src")),
                                   esConsumes(producer.getParameter<edm::ESInputTag>("params")));
      }
    }

Member Function Documentation

fillDescriptions()

template<typename CAL >

static void ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

inlinestatic

Definition at line 63 of file PFRecHitSoAProducer.cc.

References edm::ConfigurationDescriptions::addWithDefaultLabel(), submitPVResolutionJobs::desc, ProducerED_cfi::InputTag, and HLT_2024v12_cff::producers.

                                                                             {
      edm::ParameterSetDescription desc;
      edm::ParameterSetDescription producers;
      producers.add<edm::InputTag>("src", edm::InputTag(""))->setComment("Input CaloRecHitSoA");
      producers.add<edm::ESInputTag>("params", edm::ESInputTag(""))->setComment("Quality cut parameters");
      std::vector<edm::ParameterSet> producersDefault(1);
      producersDefault[0].addParameter<edm::InputTag>("src", edm::InputTag(""));
      producersDefault[0].addParameter<edm::ESInputTag>("params", edm::ESInputTag(""));
      desc.addVPSet("producers", producers, producersDefault)->setComment("List of inputs and quality cuts");
      desc.add<edm::ESInputTag>("topology", edm::ESInputTag(""))->setComment("Topology information");
      desc.addUntracked<bool>("synchronise", false)
          ->setComment("Add synchronisation point after execution (for benchmarking asynchronous execution)");
      descriptions.addWithDefaultLabel(desc);
    }

produce()

template<typename CAL >

void ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >::produce ( edm::StreamID  , device::Event &  event, const device::EventSetup &  setup  ) const

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::global::EDProducer<>.

Definition at line 40 of file PFRecHitSoAProducer.cc.

References createfilelist::int, eostools::move(), HLT_2024v12_cff::pfRecHits, ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitProducerKernel< CAL >::processRecHits(), singleTopDQM_cfi::setup, unpackBuffers-CaloStage2::token, HLT_2024v12_cff::topology, and SequenceTypes::wait().

                                                                                                {
      const typename CAL::TopologyTypeDevice& topology = setup.getData(topologyToken_);

      uint32_t num_recHits = 0;
      for (const auto& token : recHitsToken_)
        num_recHits += event.get(token.first)->metadata().size();

      reco::PFRecHitDeviceCollection pfRecHits{(int)num_recHits, event.queue()};

      if (num_recHits != 0) {
        PFRecHitProducerKernel<CAL> kernel{event.queue(), num_recHits};
        for (const auto& token : recHitsToken_)
          kernel.processRecHits(
              event.queue(), event.get(token.first), setup.getData(token.second), topology, pfRecHits);
        kernel.associateTopologyInfo(event.queue(), topology, pfRecHits);
      }

      if (synchronise_)
        alpaka::wait(event.queue());

      event.emplace(pfRecHitsToken_, std::move(pfRecHits));
    }

Member Data Documentation

pfRecHitsToken_

template<typename CAL >

const device::EDPutToken<reco::PFRecHitDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >::pfRecHitsToken_

private

Definition at line 83 of file PFRecHitSoAProducer.cc.

recHitsToken_

template<typename CAL >

std::vector<std::pair<device::EDGetToken<typename CAL::CaloRecHitSoATypeDevice>, device::ESGetToken<typename CAL::ParameterType, typename CAL::ParameterRecordType> > > ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >::recHitsToken_

private

Definition at line 82 of file PFRecHitSoAProducer.cc.

synchronise_

template<typename CAL >

const bool ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >::synchronise_

private

Definition at line 84 of file PFRecHitSoAProducer.cc.

topologyToken_

template<typename CAL >

const device::ESGetToken<typename CAL::TopologyTypeDevice, typename CAL::TopologyRecordType> ALPAKA_ACCELERATOR_NAMESPACE::PFRecHitSoAProducer< CAL >::topologyToken_

private

Definition at line 79 of file PFRecHitSoAProducer.cc.