Inheritance diagram for SiStripClusterizerFromRawGPU:

Public Member Functions
	SiStripClusterizerFromRawGPU (const edm::ParameterSet &conf)

Public Member Functions inherited from edm::stream::EDProducer< edm::ExternalWork >
	EDProducer ()=default

	EDProducer (const EDProducer &)=delete

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginProcessBlocks () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndProcessBlocks () const final

bool	hasAbilityToProduceInEndRuns () const final

const EDProducer &	operator= (const EDProducer &)=delete

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

Private Member Functions
void	acquire (edm::Event const &ev, edm::EventSetup const &es, edm::WaitingTaskWithArenaHolder waitingTaskHolder) override

void	fill (uint32_t idet, const FEDRawDataCollection &rawColl, const SiStripClusterizerConditions &conditions)

void	produce (edm::Event &ev, const edm::EventSetup &es) override

void	run (const FEDRawDataCollection &rawColl, const SiStripClusterizerConditions &conditions)

Private Attributes
std::vector< std::unique_ptr< sistrip::FEDBuffer > >	buffers_

edm::ESGetToken< stripgpu::SiStripClusterizerConditionsGPU, SiStripClusterizerConditionsRcd >	conditionsToken_

edm::ESGetToken< SiStripClusterizerConditions, SiStripClusterizerConditionsRcd >	cpuConditionsToken_

cms::cuda::ContextState	ctxState_

stripgpu::SiStripRawToClusterGPUKernel	gpuAlgo_

edm::EDGetTokenT< FEDRawDataCollection >	inputToken_

edm::EDPutTokenT< cms::cuda::Product< SiStripClustersCUDADevice > >	outputToken_

std::vector< const FEDRawData * >	raw_

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer< edm::ExternalWork >
using	CacheTypes = CacheContexts< T... >

using	GlobalCache = typename CacheTypes::GlobalCache

using	HasAbility = AbilityChecker< T... >

using	InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache

using	LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache

using	LuminosityBlockContext = LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >

using	LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache

using	RunCache = typename CacheTypes::RunCache

using	RunContext = RunContextT< RunCache, GlobalCache >

using	RunSummaryCache = typename CacheTypes::RunSummaryCache

Detailed Description

Definition at line 64 of file ClustersFromRawProducerGPU.cc.

Constructor & Destructor Documentation

◆ SiStripClusterizerFromRawGPU()

SiStripClusterizerFromRawGPU::SiStripClusterizerFromRawGPU ( const edm::ParameterSet & conf )

inlineexplicit

Definition at line 66 of file ClustersFromRawProducerGPU.cc.

References edm::ParameterSet::getParameter(), and AlCaHLTBitMon_QueryRunRegistry::string.

       : buffers_(sistrip::FED_ID_MAX),
         raw_(sistrip::FED_ID_MAX),
         gpuAlgo_(conf.getParameter<edm::ParameterSet>("Clusterizer")),
         inputToken_(consumes(conf.getParameter<edm::InputTag>("ProductLabel"))),
         outputToken_(produces<cms::cuda::Product<SiStripClustersCUDADevice>>()),
         conditionsToken_(esConsumes(edm::ESInputTag{"", conf.getParameter<std::string>("ConditionsLabel")})),
         cpuConditionsToken_(esConsumes(edm::ESInputTag{"", conf.getParameter<std::string>("ConditionsLabel")})) {}

Member Function Documentation

◆ acquire()

void SiStripClusterizerFromRawGPU::acquire	(	edm::Event const &	ev,
		edm::EventSetup const &	es,
		edm::WaitingTaskWithArenaHolder	waitingTaskHolder
	)

inlineoverrideprivate

Definition at line 78 of file ClustersFromRawProducerGPU.cc.

References buffers_, submitPVValidationJobs::conditions, conditionsToken_, cpuConditionsToken_, ctxState_, makeMEIFBenchmarkPlots::ev, edm::EventSetup::getData(), gpuAlgo_, inputToken_, stripgpu::SiStripRawToClusterGPUKernel::makeAsync(), eostools::move(), raw_, l1tstage2_dqm_sourceclient-live_cfg::rawData, and run().

                                                                          {
     const auto& conditions = es.getData(conditionsToken_);        //these need to be GPU conditions
     const auto& cpuConditions = es.getData(cpuConditionsToken_);  //CPU conditions
 
     // Sets the current device and creates a CUDA stream
     cms::cuda::ScopedContextAcquire ctx{ev.streamID(), std::move(waitingTaskHolder), ctxState_};
 
     // get raw data
     auto const& rawData = ev.get(inputToken_);
     run(rawData, cpuConditions);
 
     // Queues asynchronous data transfers and kernels to the CUDA stream
     // returned by cms::cuda::ScopedContextAcquire::stream()
     gpuAlgo_.makeAsync(raw_, buffers_, conditions, ctx.stream());
 
     // Destructor of ctx queues a callback to the CUDA stream notifying
     // waitingTaskHolder when the queued asynchronous work has finished
   }

◆ fill()

void SiStripClusterizerFromRawGPU::fill	(	uint32_t	idet,
		const FEDRawDataCollection &	rawColl,
		const SiStripClusterizerConditions &	conditions
	)

private

Definition at line 151 of file ClustersFromRawProducerGPU.cc.

References edmScanValgrind::buffer, buffers_, submitPVValidationJobs::conditions, getInfo::conn, FEDRawDataCollection::FEDData(), l1tstage2_dqm_sourceclient-live_cfg::fedId, raw_, l1tstage2_dqm_sourceclient-live_cfg::rawData, and UNLIKELY.

Referenced by run().

                                                                                         {
   auto const& det = conditions.findDetId(idet);
   if (!det.valid())
     return;
 
   // Loop over apv-pairs of det
   for (auto const conn : conditions.currentConnection(det)) {
     if UNLIKELY (!conn)
       continue;
 
     const uint16_t fedId = conn->fedId();
 
     // If fed id is null or connection is invalid continue
     if UNLIKELY (!fedId || !conn->isConnected()) {
       continue;
     }
 
     // If Fed hasnt already been initialised, extract data and initialise
     sistrip::FEDBuffer* buffer = buffers_[fedId].get();
     if (!buffer) {
       const FEDRawData& rawData = rawColl.FEDData(fedId);
       raw_[fedId] = &rawData;
       buffers_[fedId] = fillBuffer(fedId, rawData);
     }
   }  // end loop over conn
 }

◆ fillDescriptions()

void SiStripClusterizerFromRawGPU::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 130 of file ClustersFromRawProducerGPU.cc.

References edm::ConfigurationDescriptions::addWithDefaultLabel(), HLT_2022v15_cff::clusterizer, submitPVResolutionJobs::desc, StripClusterizerAlgorithmFactory::fillDescriptions(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                               {
   edm::ParameterSetDescription desc;
 
   desc.add("ProductLabel", edm::InputTag("rawDataCollector"));
   desc.add<std::string>("ConditionsLabel", "");
 
   edm::ParameterSetDescription clusterizer;
   StripClusterizerAlgorithmFactory::fillDescriptions(clusterizer);
   desc.add("Clusterizer", clusterizer);
 
   descriptions.addWithDefaultLabel(desc);
 }

◆ produce()

void SiStripClusterizerFromRawGPU::produce	(	edm::Event &	ev,
		const edm::EventSetup &	es
	)

inlineoverrideprivate

Definition at line 99 of file ClustersFromRawProducerGPU.cc.

References visDQMUpload::buf, buffers_, ctxState_, makeMEIFBenchmarkPlots::ev, stripgpu::SiStripRawToClusterGPUKernel::getResults(), gpuAlgo_, and outputToken_.

                                                                {
     cms::cuda::ScopedContextProduce ctx{ctxState_};
 
     // Now getResult() returns data in GPU memory that is passed to the
     // constructor of OutputData. cms::cuda::ScopedContextProduce::emplace() wraps the
     // OutputData to cms::cuda::Product<OutputData>. cms::cuda::Product<T> stores also
     // the current device and the CUDA stream since those will be needed
     // in the consumer side.
     ctx.emplace(ev, outputToken_, gpuAlgo_.getResults(ctx.stream()));
 
     for (auto& buf : buffers_)
       buf.reset(nullptr);
   }

◆ run()

void SiStripClusterizerFromRawGPU::run	(	const FEDRawDataCollection &	rawColl,
		const SiStripClusterizerConditions &	conditions
	)

private

Definition at line 143 of file ClustersFromRawProducerGPU.cc.

References submitPVValidationJobs::conditions, and fill().

Referenced by acquire().

                                                                                        {
   // loop over good det in cabling
   for (auto idet : conditions.allDetIds()) {
     fill(idet, rawColl, conditions);
   }  // end loop over dets
 }