ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducerToDevice Class Reference

Inheritance diagram for ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducerToDevice:

Public Member Functions
void	acquire (device::Event const &iEvent, device::EventSetup const &iSetup) override
void	produce (device::Event &iEvent, device::EventSetup const &iSetup) override
	TestAlpakaStreamSynchronizingProducerToDevice (edm::ParameterSet const &iConfig)
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
TestAlgo	algo_
std::unique_ptr< portabletest::TestDeviceCollection >	deviceProduct_
const device::EDPutToken< portabletest::TestDeviceCollection >	putToken_
const int32_t	size_

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

This class demonstrates a stream EDProducer that

• produces a device EDProduct (that can get transferred to host automatically)
• synchronizes in a non-blocking way with the ExternalWork module ability (via the SynchronizingEDProcucer base class)

Definition at line 19 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

Constructor & Destructor Documentation

TestAlpakaStreamSynchronizingProducerToDevice()

ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducerToDevice::TestAlpakaStreamSynchronizingProducerToDevice ( edm::ParameterSet const &  iConfig )

inline

Definition at line 21 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

References edm::ProducerBase< edm::stream::EDProducer, edm::ExternalWork, Args... >::produces().

        : putToken_{produces()},
          size_{iConfig.getParameter<edm::ParameterSet>("size").getParameter<int32_t>(
              EDM_STRINGIZE(ALPAKA_ACCELERATOR_NAMESPACE))} {}

Member Function Documentation

acquire()

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

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 26 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

References algo_, deviceProduct_, ALPAKA_ACCELERATOR_NAMESPACE::TestAlgo::fill(), iEvent, and size_.

                                                                                     {
      deviceProduct_ = std::make_unique<portabletest::TestDeviceCollection>(size_, iEvent.queue());

      // run the algorithm, potentially asynchronously
      algo_.fill(iEvent.queue(), *deviceProduct_);
    }

fillDescriptions()

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

inlinestatic

Definition at line 37 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

References edm::ParameterSetDescription::add(), edm::ConfigurationDescriptions::addWithDefaultLabel(), and submitPVResolutionJobs::desc.

                                                                             {
      edm::ParameterSetDescription desc;

      edm::ParameterSetDescription psetSize;
      psetSize.add<int32_t>("alpaka_serial_sync");
      psetSize.add<int32_t>("alpaka_cuda_async");
      psetSize.add<int32_t>("alpaka_rocm_async");
      desc.add("size", psetSize);

      descriptions.addWithDefaultLabel(desc);
    }

produce()

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

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 33 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

References deviceProduct_, iEvent, eostools::move(), and putToken_.

                                                                               {
      iEvent.put(putToken_, std::move(deviceProduct_));
    }

Member Data Documentation

algo_

TestAlgo ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducerToDevice::algo_

private

Definition at line 54 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

Referenced by acquire().

deviceProduct_

std::unique_ptr<portabletest::TestDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducerToDevice::deviceProduct_

private

Definition at line 56 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

Referenced by acquire(), and produce().

putToken_

const device::EDPutToken<portabletest::TestDeviceCollection> ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducerToDevice::putToken_

private

Definition at line 50 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

Referenced by produce().

size_

const int32_t ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducerToDevice::size_

private

Definition at line 51 of file TestAlpakaStreamSynchronizingProducerToDevice.cc.

Referenced by acquire().