ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer Class Reference

Inheritance diagram for ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer:

Public Member Functions
void	acquire (device::Event const &iEvent, device::EventSetup const &iSetup) override
	HGCalSoALayerClustersProducer (edm::ParameterSet const &config)
void	produce (device::Event &iEvent, device::EventSetup const &iSetup) override
	~HGCalSoALayerClustersProducer () override=default
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
HGCalLayerClustersSoAAlgoWrapper	algo_
device::EDPutToken< HGCalSoAClustersDeviceCollection > const	deviceTokenSoAClusters_
device::EDGetToken< HGCalSoARecHitsExtraDeviceCollection > const	getTokenDeviceClusters_
device::EDGetToken< HGCalSoARecHitsDeviceCollection > const	getTokenDeviceRecHits_
unsigned int	num_clusters_
float	positionDeltaRho2_
float	thresholdW0_

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 26 of file HGCalSoALayerClustersProducer.cc.

Constructor & Destructor Documentation

HGCalSoALayerClustersProducer()

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

inline

Definition at line 28 of file HGCalSoALayerClustersProducer.cc.

        : getTokenDeviceRecHits_{consumes(config.getParameter<edm::InputTag>("hgcalRecHitsSoA"))},
          getTokenDeviceClusters_{consumes(config.getParameter<edm::InputTag>("hgcalRecHitsLayerClustersSoA"))},
          deviceTokenSoAClusters_{produces()},
          thresholdW0_(config.getParameter<double>("thresholdW0")),
          positionDeltaRho2_(config.getParameter<double>("positionDeltaRho2")) {}

~HGCalSoALayerClustersProducer()

ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::~HGCalSoALayerClustersProducer ( )

overridedefault

Member Function Documentation

acquire()

void ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::acquire ( device::Event const &  iEvent, device::EventSetup const &  iSetup  )

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 37 of file HGCalSoALayerClustersProducer.cc.

References getTokenDeviceClusters_, iEvent, and num_clusters_.

                                                                                     {
      // Get LayerClusters almost-SoA on device: this has still the same
      // cardinality as the RecHitsSoA, but has all the required information
      // to assemble the clusters, i.e., it has the cluster index assigned to
      // each rechit.
      auto const& deviceInputClusters = iEvent.get(getTokenDeviceClusters_);
      auto const inputClusters_v = deviceInputClusters.view();
      //
      // Allocate output SoA for the clusters, one entry for each cluster
      auto device_numclusters = cms::alpakatools::make_device_view<const unsigned int>(
          alpaka::getDev(iEvent.queue()), inputClusters_v.numberOfClustersScalar());
      auto host_numclusters = cms::alpakatools::make_host_view<unsigned int>(num_clusters_);
      alpaka::memcpy(iEvent.queue(), host_numclusters, device_numclusters);
    }

fillDescriptions()

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

inlinestatic

Definition at line 81 of file HGCalSoALayerClustersProducer.cc.

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

                                                                             {
      edm::ParameterSetDescription desc;
      desc.add<edm::InputTag>("hgcalRecHitsLayerClustersSoA", edm::InputTag("TO BE DEFINED"));
      desc.add<edm::InputTag>("hgcalRecHitsSoA", edm::InputTag("TO BE DEFINED"));
      desc.add<double>("thresholdW0", 2.9);
      desc.add<double>("positionDeltaRho2", 1.69);
      descriptions.addWithDefaultLabel(desc);
    }

produce()

void ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::produce ( device::Event &  iEvent, device::EventSetup const &  iSetup  )

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 52 of file HGCalSoALayerClustersProducer.cc.

References algo_, deviceTokenSoAClusters_, getTokenDeviceClusters_, getTokenDeviceRecHits_, iEvent, eostools::move(), num_clusters_, convertSQLitetoXML_cfg::output, positionDeltaRho2_, ALPAKA_ACCELERATOR_NAMESPACE::HGCalLayerClustersSoAAlgoWrapper::run(), and thresholdW0_.

                                                                               {
      // Get RecHitsSoA on the device
      auto const& deviceInputRecHits = iEvent.get(getTokenDeviceRecHits_);
      auto const inputRechits_v = deviceInputRecHits.view();

      // Get LayerClusters almost-SoA on device: this has still the same
      // cardinality as the RecHitsSoA, but has all the required information
      // to assemble the clusters, i.e., it has the cluster index assigned to
      // each rechit.
      auto const& deviceInputClusters = iEvent.get(getTokenDeviceClusters_);
      auto const inputClusters_v = deviceInputClusters.view();

      HGCalSoAClustersDeviceCollection output(num_clusters_, iEvent.queue());
      auto output_v = output.view();
      // Allocate workspace SoA cluster
      HGCalSoAClustersExtraDeviceCollection outputWorkspace(num_clusters_, iEvent.queue());
      auto output_workspace_v = outputWorkspace.view();

      algo_.run(iEvent.queue(),
                num_clusters_,
                thresholdW0_,
                positionDeltaRho2_,
                inputRechits_v,
                inputClusters_v,
                output_v,
                output_workspace_v);
      iEvent.emplace(deviceTokenSoAClusters_, std::move(output));
    }

Member Data Documentation

algo_

HGCalLayerClustersSoAAlgoWrapper ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::algo_

private

Definition at line 94 of file HGCalSoALayerClustersProducer.cc.

Referenced by produce().

deviceTokenSoAClusters_

device::EDPutToken<HGCalSoAClustersDeviceCollection> const ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::deviceTokenSoAClusters_

private

Definition at line 93 of file HGCalSoALayerClustersProducer.cc.

Referenced by produce().

getTokenDeviceClusters_

device::EDGetToken<HGCalSoARecHitsExtraDeviceCollection> const ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::getTokenDeviceClusters_

private

Definition at line 92 of file HGCalSoALayerClustersProducer.cc.

Referenced by acquire(), and produce().

getTokenDeviceRecHits_

device::EDGetToken<HGCalSoARecHitsDeviceCollection> const ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::getTokenDeviceRecHits_

private

Definition at line 91 of file HGCalSoALayerClustersProducer.cc.

Referenced by produce().

num_clusters_

unsigned int ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::num_clusters_

private

Definition at line 95 of file HGCalSoALayerClustersProducer.cc.

Referenced by acquire(), and produce().

positionDeltaRho2_

float ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::positionDeltaRho2_

private

Definition at line 97 of file HGCalSoALayerClustersProducer.cc.

Referenced by produce().

thresholdW0_

float ALPAKA_ACCELERATOR_NAMESPACE::HGCalSoALayerClustersProducer::thresholdW0_

private

Definition at line 96 of file HGCalSoALayerClustersProducer.cc.

Referenced by produce().