ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer Class Reference

Inheritance diagram for ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer:

Public Member Functions
void	acquire (device::Event const &event, device::EventSetup const &setup) override
	PFClusterSoAProducer (edm::ParameterSet const &config)
void	produce (device::Event &event, device::EventSetup const &setup) override
Public Member Functions inherited from ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>
void	acquire (edm::Event const &iEvent, edm::EventSetup const &iSetup, edm::WaitingTaskWithArenaHolder holder) final
void	produce (edm::Event &iEvent, edm::EventSetup const &iSetup) final
Public Member Functions inherited from edm::ProducerBase< edm::stream::EDProducer, edm::ExternalWork, 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 edm::EDGetTokenT< reco::PFRecHitHostCollection >	inputPFRecHitSoA_Token_
cms::alpakatools::host_buffer< uint32_t >	numRHF_
const device::EDPutToken< reco::PFClusterDeviceCollection >	outputPFClusterSoA_Token_
const device::EDPutToken< reco::PFRecHitFractionDeviceCollection >	outputPFRHFractionSoA_Token_
const device::ESGetToken< reco::PFClusterParamsDeviceCollection, JobConfigurationGPURecord >	pfClusParamsToken
std::optional< reco::PFClusteringEdgeVarsDeviceCollection >	pfClusteringEdgeVars_
std::optional< reco::PFClusteringVarsDeviceCollection >	pfClusteringVars_
std::optional< reco::PFClusterDeviceCollection >	pfClusters_
const bool	synchronise_
const device::ESGetToken< reco::PFRecHitHCALTopologyDeviceCollection, PFRecHitHCALTopologyRecord >	topologyToken_

Additional Inherited Members
Public Types inherited from edm::ProducerBase< edm::stream::EDProducer, edm::ExternalWork, 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::stream::EDProducer, edm::ExternalWork, 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

Definition at line 19 of file PFClusterSoAProducer.cc.

Constructor & Destructor Documentation

PFClusterSoAProducer()

ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::PFClusterSoAProducer ( edm::ParameterSet const &  config )

inline

Definition at line 21 of file PFClusterSoAProducer.cc.

        : pfClusParamsToken(esConsumes(config.getParameter<edm::ESInputTag>("pfClusterParams"))),
          topologyToken_(esConsumes(config.getParameter<edm::ESInputTag>("topology"))),
          inputPFRecHitSoA_Token_{consumes(config.getParameter<edm::InputTag>("pfRecHits"))},
          outputPFClusterSoA_Token_{produces()},
          outputPFRHFractionSoA_Token_{produces()},
          numRHF_{cms::alpakatools::make_host_buffer<uint32_t, Platform>()},
          synchronise_(config.getParameter<bool>("synchronise")) {}

Member Function Documentation

acquire()

void ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::acquire ( device::Event const &  event, device::EventSetup const &  setup  )

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 30 of file PFClusterSoAProducer.cc.

References inputPFRecHitSoA_Token_, numRHF_, submitPVValidationJobs::params, pfClusParamsToken, pfClusteringEdgeVars_, pfClusteringVars_, pfClusters_, HLT_2024v14_cff::pfRecHits, ALPAKA_ACCELERATOR_NAMESPACE::PFClusterProducerKernel::seedTopoAndContract(), singleTopDQM_cfi::setup, HLT_2024v14_cff::topology, and topologyToken_.

                                                                                   {
      const reco::PFClusterParamsDeviceCollection& params = setup.getData(pfClusParamsToken);
      const reco::PFRecHitHCALTopologyDeviceCollection& topology = setup.getData(topologyToken_);
      const reco::PFRecHitHostCollection& pfRecHits = event.get(inputPFRecHitSoA_Token_);
      int nRH = 0;
      if (pfRecHits->metadata().size() != 0)
        nRH = pfRecHits->size();

      pfClusteringVars_.emplace(nRH, event.queue());
      pfClusteringEdgeVars_.emplace(nRH * 8, event.queue());
      pfClusters_.emplace(nRH, event.queue());

      *numRHF_ = 0;

      if (nRH != 0) {
        PFClusterProducerKernel kernel(event.queue(), pfRecHits);
        kernel.seedTopoAndContract(event.queue(),
                                   params,
                                   topology,
                                   *pfClusteringVars_,
                                   *pfClusteringEdgeVars_,
                                   pfRecHits,
                                   *pfClusters_,
                                   numRHF_.data());
      }
    }

fillDescriptions()

static void ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

inlinestatic

Definition at line 90 of file PFClusterSoAProducer.cc.

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

                                                                             {
      edm::ParameterSetDescription desc;
      desc.add<edm::InputTag>("pfRecHits", edm::InputTag(""));
      desc.add<edm::ESInputTag>("pfClusterParams", edm::ESInputTag(""));
      desc.add<edm::ESInputTag>("topology", edm::ESInputTag(""));
      desc.add<bool>("synchronise", false);
      descriptions.addWithDefaultLabel(desc);
    }

produce()

void ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::produce ( device::Event &  event, device::EventSetup const &  setup  )

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 57 of file PFClusterSoAProducer.cc.

References ALPAKA_ACCELERATOR_NAMESPACE::PFClusterProducerKernel::cluster(), inputPFRecHitSoA_Token_, eostools::move(), numRHF_, outputPFClusterSoA_Token_, outputPFRHFractionSoA_Token_, submitPVValidationJobs::params, pfClusParamsToken, pfClusteringEdgeVars_, pfClusteringVars_, pfClusters_, HLT_2024v14_cff::pfRecHits, singleTopDQM_cfi::setup, synchronise_, HLT_2024v14_cff::topology, topologyToken_, and SequenceTypes::wait().

                                                                             {
      const reco::PFClusterParamsDeviceCollection& params = setup.getData(pfClusParamsToken);
      const reco::PFRecHitHCALTopologyDeviceCollection& topology = setup.getData(topologyToken_);
      const reco::PFRecHitHostCollection& pfRecHits = event.get(inputPFRecHitSoA_Token_);
      int nRH = 0;

      std::optional<reco::PFRecHitFractionDeviceCollection> pfrhFractions;

      if (pfRecHits->metadata().size() != 0)
        nRH = pfRecHits->size();

      if (nRH != 0) {
        pfrhFractions.emplace(*numRHF_.data(), event.queue());
        PFClusterProducerKernel kernel(event.queue(), pfRecHits);
        kernel.cluster(event.queue(),
                       params,
                       topology,
                       *pfClusteringVars_,
                       *pfClusteringEdgeVars_,
                       pfRecHits,
                       *pfClusters_,
                       *pfrhFractions);
      } else {
        pfrhFractions.emplace(0, event.queue());
      }

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

      event.emplace(outputPFClusterSoA_Token_, std::move(*pfClusters_));
      event.emplace(outputPFRHFractionSoA_Token_, std::move(*pfrhFractions));
    }

Member Data Documentation

inputPFRecHitSoA_Token_

const edm::EDGetTokenT<reco::PFRecHitHostCollection> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::inputPFRecHitSoA_Token_

private

Definition at line 102 of file PFClusterSoAProducer.cc.

Referenced by acquire(), and produce().

numRHF_

cms::alpakatools::host_buffer<uint32_t> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::numRHF_

private

Definition at line 105 of file PFClusterSoAProducer.cc.

Referenced by acquire(), and produce().

outputPFClusterSoA_Token_

const device::EDPutToken<reco::PFClusterDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::outputPFClusterSoA_Token_

private

Definition at line 103 of file PFClusterSoAProducer.cc.

Referenced by produce().

outputPFRHFractionSoA_Token_

const device::EDPutToken<reco::PFRecHitFractionDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::outputPFRHFractionSoA_Token_

private

Definition at line 104 of file PFClusterSoAProducer.cc.

Referenced by produce().

pfClusParamsToken

const device::ESGetToken<reco::PFClusterParamsDeviceCollection, JobConfigurationGPURecord> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::pfClusParamsToken

private

Definition at line 100 of file PFClusterSoAProducer.cc.

Referenced by acquire(), and produce().

pfClusteringEdgeVars_

std::optional<reco::PFClusteringEdgeVarsDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::pfClusteringEdgeVars_

private

Definition at line 107 of file PFClusterSoAProducer.cc.

Referenced by acquire(), and produce().

pfClusteringVars_

std::optional<reco::PFClusteringVarsDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::pfClusteringVars_

private

Definition at line 106 of file PFClusterSoAProducer.cc.

Referenced by acquire(), and produce().

pfClusters_

std::optional<reco::PFClusterDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::pfClusters_

private

Definition at line 108 of file PFClusterSoAProducer.cc.

Referenced by acquire(), and produce().

synchronise_

const bool ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::synchronise_

private

Definition at line 109 of file PFClusterSoAProducer.cc.

Referenced by produce().

topologyToken_

const device::ESGetToken<reco::PFRecHitHCALTopologyDeviceCollection, PFRecHitHCALTopologyRecord> ALPAKA_ACCELERATOR_NAMESPACE::PFClusterSoAProducer::topologyToken_

private

Definition at line 101 of file PFClusterSoAProducer.cc.

Referenced by acquire(), and produce().