Inheritance diagram for ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducer:

Public Member Functions
void	acquire (device::Event const &iEvent, device::EventSetup const &iSetup) override

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

	TestAlpakaStreamSynchronizingProducer (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
const device::ESGetToken< AlpakaESTestDataDDevice, AlpakaESTestRecordD >	esTokenDevice_

int const	expectedInt_

TestHelperClass	helper_

cms::alpakatest::TestHostOnlyHelperClass const	hostHelper_

const edm::EDPutTokenT< portabletest::TestHostCollection >	putToken_

const edm::EDPutTokenT< portabletest::TestHostMultiCollection2 >	putTokenMulti2_

const edm::EDPutTokenT< portabletest::TestHostMultiCollection3 >	putTokenMulti3_

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

uses a helper class (need to use edm::ConsumesCollector), that
- consumes a device EDProduct
- consumes a host ESProduct
- consumes a device ESProduct
uses a non-Alpaka-aware helper class (need to use edm::ConsumesCollector), that
- consumes a host EDProduct
- consumes a host ESProduct
consumes a device ESProduct
produces a host EDProduct
synchronizes in a non-blocking way with the ExternalWork module ability (via the SynchronizingEDProcucer base class)

Definition at line 25 of file TestAlpakaStreamSynchronizingProducer.cc.

Constructor & Destructor Documentation

◆ TestAlpakaStreamSynchronizingProducer()

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

inline

Definition at line 27 of file TestAlpakaStreamSynchronizingProducer.cc.

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

         : esTokenDevice_(esConsumes()),
           putToken_{produces()},
           putTokenMulti2_{produces()},
           putTokenMulti3_{produces()},
           helper_{iConfig, consumesCollector()},
           hostHelper_{iConfig, consumesCollector()},
           expectedInt_{iConfig.getParameter<int>("expectedInt")} {}

Member Function Documentation

◆ acquire()

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

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 36 of file TestAlpakaStreamSynchronizingProducer.cc.

References esTokenDevice_, Exception, expectedInt_, ALPAKA_ACCELERATOR_NAMESPACE::device::EventSetup::getData(), helper_, hostHelper_, iEvent, ALPAKA_ACCELERATOR_NAMESPACE::TestHelperClass::makeAsync(), cms::alpakatest::TestHostOnlyHelperClass::run(), and relativeConstraints::value.

                                                                                      {
       [[maybe_unused]] auto const& esData = iSetup.getData(esTokenDevice_);
 
       int const value = hostHelper_.run(iEvent, iSetup);
       if (value != expectedInt_) {
         throw cms::Exception("Assert") << "Expected value " << expectedInt_ << ", but got " << value;
       }
 
       helper_.makeAsync(iEvent, iSetup);
     }

◆ fillDescriptions()

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

inlinestatic

Definition at line 53 of file TestAlpakaStreamSynchronizingProducer.cc.

References edm::ConfigurationDescriptions::addWithDefaultLabel(), submitPVResolutionJobs::desc, cms::alpakatest::TestHostOnlyHelperClass::fillPSetDescription(), and ALPAKA_ACCELERATOR_NAMESPACE::TestHelperClass::fillPSetDescription().

                                                                              {
       edm::ParameterSetDescription desc;
       TestHelperClass::fillPSetDescription(desc);
       cms::alpakatest::TestHostOnlyHelperClass::fillPSetDescription(desc);
       desc.add<int>("expectedInt");
       descriptions.addWithDefaultLabel(desc);
     }

◆ produce()

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

inlineoverridevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 47 of file TestAlpakaStreamSynchronizingProducer.cc.

References helper_, iEvent, ALPAKA_ACCELERATOR_NAMESPACE::TestHelperClass::moveFrom(), ALPAKA_ACCELERATOR_NAMESPACE::TestHelperClass::moveFromMulti2(), ALPAKA_ACCELERATOR_NAMESPACE::TestHelperClass::moveFromMulti3(), putToken_, putTokenMulti2_, and putTokenMulti3_.

                                                                                {
       iEvent.emplace(putToken_, helper_.moveFrom());
       iEvent.emplace(putTokenMulti2_, helper_.moveFromMulti2());
       iEvent.emplace(putTokenMulti3_, helper_.moveFromMulti3());
     }

Member Data Documentation

◆ esTokenDevice_

const device::ESGetToken<AlpakaESTestDataDDevice, AlpakaESTestRecordD> ALPAKA_ACCELERATOR_NAMESPACE::TestAlpakaStreamSynchronizingProducer::esTokenDevice_

private

Definition at line 62 of file TestAlpakaStreamSynchronizingProducer.cc.

Referenced by acquire().